The Tor Browser: comparison mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/DefaultClientConnection.java

--1:000000000000
+:0941eb747205
+/*
+* ====================================================================
+* Licensed to the Apache Software Foundation (ASF) under one
+* or more contributor license agreements.  See the NOTICE file
+* distributed with this work for additional information
+* regarding copyright ownership.  The ASF licenses this file
+* to you under the Apache License, Version 2.0 (the
+* "License"); you may not use this file except in compliance
+* with the License.  You may obtain a copy of the License at
+*
+*   http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing,
+* software distributed under the License is distributed on an
+* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+* KIND, either express or implied.  See the License for the
+* specific language governing permissions and limitations
+* under the License.
+* ====================================================================
+*
+* This software consists of voluntary contributions made by many
+* individuals on behalf of the Apache Software Foundation.  For more
+* information on the Apache Software Foundation, please see
+* <http://www.apache.org/>.
+*
+*/
+package ch.boye.httpclientandroidlib.impl.conn;
+import java.io.IOException;
+import java.net.Socket;
+import java.util.HashMap;
+import java.util.Map;
+import ch.boye.httpclientandroidlib.annotation.NotThreadSafe;
+import ch.boye.httpclientandroidlib.androidextra.HttpClientAndroidLog;
+/* LogFactory removed by HttpClient for Android script. */
+import ch.boye.httpclientandroidlib.Header;
+import ch.boye.httpclientandroidlib.HttpException;
+import ch.boye.httpclientandroidlib.HttpHost;
+import ch.boye.httpclientandroidlib.HttpRequest;
+import ch.boye.httpclientandroidlib.HttpResponse;
+import ch.boye.httpclientandroidlib.HttpResponseFactory;
+import ch.boye.httpclientandroidlib.params.HttpParams;
+import ch.boye.httpclientandroidlib.params.HttpProtocolParams;
+import ch.boye.httpclientandroidlib.protocol.HttpContext;
+import ch.boye.httpclientandroidlib.impl.SocketHttpClientConnection;
+import ch.boye.httpclientandroidlib.io.HttpMessageParser;
+import ch.boye.httpclientandroidlib.io.SessionInputBuffer;
+import ch.boye.httpclientandroidlib.io.SessionOutputBuffer;
+import ch.boye.httpclientandroidlib.conn.OperatedClientConnection;
+/**
+* Default implementation of an operated client connection.
+* <p>
+* The following parameters can be used to customize the behavior of this
+* class:
+* <ul>
+*  <li>{@link ch.boye.httpclientandroidlib.params.CoreProtocolPNames#STRICT_TRANSFER_ENCODING}</li>
+*  <li>{@link ch.boye.httpclientandroidlib.params.CoreProtocolPNames#HTTP_ELEMENT_CHARSET}</li>
+*  <li>{@link ch.boye.httpclientandroidlib.params.CoreConnectionPNames#SOCKET_BUFFER_SIZE}</li>
+*  <li>{@link ch.boye.httpclientandroidlib.params.CoreConnectionPNames#MAX_LINE_LENGTH}</li>
+*  <li>{@link ch.boye.httpclientandroidlib.params.CoreConnectionPNames#MAX_HEADER_COUNT}</li>
+* </ul>
+*
+* @since 4.0
+*/
+@NotThreadSafe // connSecure, targetHost
+public class DefaultClientConnection extends SocketHttpClientConnection
+implements OperatedClientConnection, HttpContext {
+public HttpClientAndroidLog log = new HttpClientAndroidLog(getClass());
+public HttpClientAndroidLog headerLog = new HttpClientAndroidLog("ch.boye.httpclientandroidlib.headers");
+public HttpClientAndroidLog wireLog = new HttpClientAndroidLog("ch.boye.httpclientandroidlib.wire");
+/** The unconnected socket */
+private volatile Socket socket;
+/** The target host of this connection. */
+private HttpHost targetHost;
+/** Whether this connection is secure. */
+private boolean connSecure;
+/** True if this connection was shutdown. */
+private volatile boolean shutdown;
+/** connection specific attributes */
+private final Map<String, Object> attributes;
+public DefaultClientConnection() {
+super();
+this.attributes = new HashMap<String, Object>();
+}
+public final HttpHost getTargetHost() {
+return this.targetHost;
+}
+public final boolean isSecure() {
+return this.connSecure;
+}
+@Override
+public final Socket getSocket() {
+return this.socket;
+}
+public void opening(Socket sock, HttpHost target) throws IOException {
+assertNotOpen();
+this.socket = sock;
+this.targetHost = target;
+// Check for shutdown after assigning socket, so that
+if (this.shutdown) {
+sock.close(); // allow this to throw...
+// ...but if it doesn't, explicitly throw one ourselves.
+throw new IOException("Connection already shutdown");
+}
+}
+public void openCompleted(boolean secure, HttpParams params) throws IOException {
+assertNotOpen();
+if (params == null) {
+throw new IllegalArgumentException
+("Parameters must not be null.");
+}
+this.connSecure = secure;
+bind(this.socket, params);
+}
+/**
+* Force-closes this connection.
+* If the connection is still in the process of being open (the method
+* {@link #opening opening} was already called but
+* {@link #openCompleted openCompleted} was not), the associated
+* socket that is being connected to a remote address will be closed.
+* That will interrupt a thread that is blocked on connecting
+* the socket.
+* If the connection is not yet open, this will prevent the connection
+* from being opened.
+*
+* @throws IOException      in case of a problem
+*/
+@Override
+public void shutdown() throws IOException {
+shutdown = true;
+try {
+super.shutdown();
+log.debug("Connection shut down");
+Socket sock = this.socket; // copy volatile attribute
+if (sock != null)
+sock.close();
+} catch (IOException ex) {
+log.debug("I/O error shutting down connection", ex);
+}
+}
+@Override
+public void close() throws IOException {
+try {
+super.close();
+log.debug("Connection closed");
+} catch (IOException ex) {
+log.debug("I/O error closing connection", ex);
+}
+}
+@Override
+protected SessionInputBuffer createSessionInputBuffer(
+final Socket socket,
+int buffersize,
+final HttpParams params) throws IOException {
+if (buffersize == -1) {
+buffersize = 8192;
+}
+SessionInputBuffer inbuffer = super.createSessionInputBuffer(
+socket,
+buffersize,
+params);
+if (wireLog.isDebugEnabled()) {
+inbuffer = new LoggingSessionInputBuffer(
+inbuffer,
+new Wire(wireLog),
+HttpProtocolParams.getHttpElementCharset(params));
+}
+return inbuffer;
+}
+@Override
+protected SessionOutputBuffer createSessionOutputBuffer(
+final Socket socket,
+int buffersize,
+final HttpParams params) throws IOException {
+if (buffersize == -1) {
+buffersize = 8192;
+}
+SessionOutputBuffer outbuffer = super.createSessionOutputBuffer(
+socket,
+buffersize,
+params);
+if (wireLog.isDebugEnabled()) {
+outbuffer = new LoggingSessionOutputBuffer(
+outbuffer,
+new Wire(wireLog),
+HttpProtocolParams.getHttpElementCharset(params));
+}
+return outbuffer;
+}
+@Override
+protected HttpMessageParser createResponseParser(
+final SessionInputBuffer buffer,
+final HttpResponseFactory responseFactory,
+final HttpParams params) {
+// override in derived class to specify a line parser
+return new DefaultResponseParser
+(buffer, null, responseFactory, params);
+}
+public void update(Socket sock, HttpHost target,
+boolean secure, HttpParams params)
+throws IOException {
+assertOpen();
+if (target == null) {
+throw new IllegalArgumentException
+("Target host must not be null.");
+}
+if (params == null) {
+throw new IllegalArgumentException
+("Parameters must not be null.");
+}
+if (sock != null) {
+this.socket = sock;
+bind(sock, params);
+}
+targetHost = target;
+connSecure = secure;
+}
+@Override
+public HttpResponse receiveResponseHeader() throws HttpException, IOException {
+HttpResponse response = super.receiveResponseHeader();
+if (log.isDebugEnabled()) {
+log.debug("Receiving response: " + response.getStatusLine());
+}
+if (headerLog.isDebugEnabled()) {
+headerLog.debug("<< " + response.getStatusLine().toString());
+Header[] headers = response.getAllHeaders();
+for (Header header : headers) {
+headerLog.debug("<< " + header.toString());
+}
+}
+return response;
+}
+@Override
+public void sendRequestHeader(HttpRequest request) throws HttpException, IOException {
+if (log.isDebugEnabled()) {
+log.debug("Sending request: " + request.getRequestLine());
+}
+super.sendRequestHeader(request);
+if (headerLog.isDebugEnabled()) {
+headerLog.debug(">> " + request.getRequestLine().toString());
+Header[] headers = request.getAllHeaders();
+for (Header header : headers) {
+headerLog.debug(">> " + header.toString());
+}
+}
+}
+public Object getAttribute(final String id) {
+return this.attributes.get(id);
+}
+public Object removeAttribute(final String id) {
+return this.attributes.remove(id);
+}
+public void setAttribute(final String id, final Object obj) {
+this.attributes.put(id, obj);
+}
+}

The Tor Browser / file comparison

comparison: mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/DefaultClientConnection.java

mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/DefaultClientConnection.java