1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/DefaultResponseParser.java Wed Dec 31 06:09:35 2014 +0100
1.3 @@ -0,0 +1,122 @@
1.4 +/*
1.5 + * ====================================================================
1.6 + * Licensed to the Apache Software Foundation (ASF) under one
1.7 + * or more contributor license agreements. See the NOTICE file
1.8 + * distributed with this work for additional information
1.9 + * regarding copyright ownership. The ASF licenses this file
1.10 + * to you under the Apache License, Version 2.0 (the
1.11 + * "License"); you may not use this file except in compliance
1.12 + * with the License. You may obtain a copy of the License at
1.13 + *
1.14 + * http://www.apache.org/licenses/LICENSE-2.0
1.15 + *
1.16 + * Unless required by applicable law or agreed to in writing,
1.17 + * software distributed under the License is distributed on an
1.18 + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
1.19 + * KIND, either express or implied. See the License for the
1.20 + * specific language governing permissions and limitations
1.21 + * under the License.
1.22 + * ====================================================================
1.23 + *
1.24 + * This software consists of voluntary contributions made by many
1.25 + * individuals on behalf of the Apache Software Foundation. For more
1.26 + * information on the Apache Software Foundation, please see
1.27 + * <http://www.apache.org/>.
1.28 + *
1.29 + */
1.30 +
1.31 +package ch.boye.httpclientandroidlib.impl.conn;
1.32 +
1.33 +import java.io.IOException;
1.34 +
1.35 +import ch.boye.httpclientandroidlib.annotation.ThreadSafe;
1.36 +
1.37 +import ch.boye.httpclientandroidlib.androidextra.HttpClientAndroidLog;
1.38 +/* LogFactory removed by HttpClient for Android script. */
1.39 +import ch.boye.httpclientandroidlib.HttpException;
1.40 +import ch.boye.httpclientandroidlib.HttpMessage;
1.41 +import ch.boye.httpclientandroidlib.HttpResponseFactory;
1.42 +import ch.boye.httpclientandroidlib.NoHttpResponseException;
1.43 +import ch.boye.httpclientandroidlib.ProtocolException;
1.44 +import ch.boye.httpclientandroidlib.StatusLine;
1.45 +import ch.boye.httpclientandroidlib.conn.params.ConnConnectionPNames;
1.46 +import ch.boye.httpclientandroidlib.impl.io.AbstractMessageParser;
1.47 +import ch.boye.httpclientandroidlib.io.SessionInputBuffer;
1.48 +import ch.boye.httpclientandroidlib.message.LineParser;
1.49 +import ch.boye.httpclientandroidlib.message.ParserCursor;
1.50 +import ch.boye.httpclientandroidlib.params.HttpParams;
1.51 +import ch.boye.httpclientandroidlib.util.CharArrayBuffer;
1.52 +
1.53 +/**
1.54 + * Default HTTP response parser implementation.
1.55 + * <p>
1.56 + * The following parameters can be used to customize the behavior of this
1.57 + * class:
1.58 + * <ul>
1.59 + * <li>{@link ch.boye.httpclientandroidlib.params.CoreConnectionPNames#MAX_HEADER_COUNT}</li>
1.60 + * <li>{@link ch.boye.httpclientandroidlib.params.CoreConnectionPNames#MAX_LINE_LENGTH}</li>
1.61 + * <li>{@link ch.boye.httpclientandroidlib.conn.params.ConnConnectionPNames#MAX_STATUS_LINE_GARBAGE}</li>
1.62 + * </ul>
1.63 + *
1.64 + * @since 4.0
1.65 + */
1.66 +@ThreadSafe // no public methods
1.67 +public class DefaultResponseParser extends AbstractMessageParser {
1.68 +
1.69 + public HttpClientAndroidLog log = new HttpClientAndroidLog(getClass());
1.70 +
1.71 + private final HttpResponseFactory responseFactory;
1.72 + private final CharArrayBuffer lineBuf;
1.73 + private final int maxGarbageLines;
1.74 +
1.75 + public DefaultResponseParser(
1.76 + final SessionInputBuffer buffer,
1.77 + final LineParser parser,
1.78 + final HttpResponseFactory responseFactory,
1.79 + final HttpParams params) {
1.80 + super(buffer, parser, params);
1.81 + if (responseFactory == null) {
1.82 + throw new IllegalArgumentException
1.83 + ("Response factory may not be null");
1.84 + }
1.85 + this.responseFactory = responseFactory;
1.86 + this.lineBuf = new CharArrayBuffer(128);
1.87 + this.maxGarbageLines = params.getIntParameter(
1.88 + ConnConnectionPNames.MAX_STATUS_LINE_GARBAGE, Integer.MAX_VALUE);
1.89 + }
1.90 +
1.91 +
1.92 + @Override
1.93 + protected HttpMessage parseHead(
1.94 + final SessionInputBuffer sessionBuffer) throws IOException, HttpException {
1.95 + //read out the HTTP status string
1.96 + int count = 0;
1.97 + ParserCursor cursor = null;
1.98 + do {
1.99 + // clear the buffer
1.100 + this.lineBuf.clear();
1.101 + int i = sessionBuffer.readLine(this.lineBuf);
1.102 + if (i == -1 && count == 0) {
1.103 + // The server just dropped connection on us
1.104 + throw new NoHttpResponseException("The target server failed to respond");
1.105 + }
1.106 + cursor = new ParserCursor(0, this.lineBuf.length());
1.107 + if (lineParser.hasProtocolVersion(this.lineBuf, cursor)) {
1.108 + // Got one
1.109 + break;
1.110 + } else if (i == -1 || count >= this.maxGarbageLines) {
1.111 + // Giving up
1.112 + throw new ProtocolException("The server failed to respond with a " +
1.113 + "valid HTTP response");
1.114 + }
1.115 + if (this.log.isDebugEnabled()) {
1.116 + this.log.debug("Garbage in response: " + this.lineBuf.toString());
1.117 + }
1.118 + count++;
1.119 + } while(true);
1.120 + //create the status line from the status string
1.121 + StatusLine statusline = lineParser.parseStatusLine(this.lineBuf, cursor);
1.122 + return this.responseFactory.newHttpResponse(statusline, null);
1.123 + }
1.124 +
1.125 +}
