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

--1:000000000000
+:f18615bc85e8
+/*
+* ====================================================================
+*
+*  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.io.InterruptedIOException;
+import java.net.InetAddress;
+import java.net.Socket;
+import java.util.concurrent.TimeUnit;
+import javax.net.ssl.SSLSocket;
+import javax.net.ssl.SSLSession;
+import ch.boye.httpclientandroidlib.HttpException;
+import ch.boye.httpclientandroidlib.HttpRequest;
+import ch.boye.httpclientandroidlib.HttpEntityEnclosingRequest;
+import ch.boye.httpclientandroidlib.HttpResponse;
+import ch.boye.httpclientandroidlib.HttpConnectionMetrics;
+import ch.boye.httpclientandroidlib.conn.OperatedClientConnection;
+import ch.boye.httpclientandroidlib.conn.ManagedClientConnection;
+import ch.boye.httpclientandroidlib.conn.ClientConnectionManager;
+import ch.boye.httpclientandroidlib.protocol.HttpContext;
+/**
+* Abstract adapter from {@link OperatedClientConnection operated} to
+* {@link ManagedClientConnection managed} client connections.
+* Read and write methods are delegated to the wrapped connection.
+* Operations affecting the connection state have to be implemented
+* by derived classes. Operations for querying the connection state
+* are delegated to the wrapped connection if there is one, or
+* return a default value if there is none.
+* <p>
+* This adapter tracks the checkpoints for reusable communication states,
+* as indicated by {@link #markReusable markReusable} and queried by
+* {@link #isMarkedReusable isMarkedReusable}.
+* All send and receive operations will automatically clear the mark.
+* <p>
+* Connection release calls are delegated to the connection manager,
+* if there is one. {@link #abortConnection abortConnection} will
+* clear the reusability mark first. The connection manager is
+* expected to tolerate multiple calls to the release method.
+*
+* @since 4.0
+*/
+public abstract class AbstractClientConnAdapter
+implements ManagedClientConnection, HttpContext {
+/**
+* The connection manager, if any.
+* This attribute MUST NOT be final, so the adapter can be detached
+* from the connection manager without keeping a hard reference there.
+*/
+private volatile ClientConnectionManager connManager;
+/** The wrapped connection. */
+private volatile OperatedClientConnection wrappedConnection;
+/** The reusability marker. */
+private volatile boolean markedReusable;
+/** True if the connection has been shut down or released. */
+private volatile boolean released;
+/** The duration this is valid for while idle (in ms). */
+private volatile long duration;
+/**
+* Creates a new connection adapter.
+* The adapter is initially <i>not</i>
+* {@link #isMarkedReusable marked} as reusable.
+*
+* @param mgr       the connection manager, or <code>null</code>
+* @param conn      the connection to wrap, or <code>null</code>
+*/
+protected AbstractClientConnAdapter(ClientConnectionManager mgr,
+OperatedClientConnection conn) {
+super();
+connManager = mgr;
+wrappedConnection = conn;
+markedReusable = false;
+released = false;
+duration = Long.MAX_VALUE;
+}
+/**
+* Detaches this adapter from the wrapped connection.
+* This adapter becomes useless.
+*/
+protected synchronized void detach() {
+wrappedConnection = null;
+connManager = null; // base class attribute
+duration = Long.MAX_VALUE;
+}
+protected OperatedClientConnection getWrappedConnection() {
+return wrappedConnection;
+}
+protected ClientConnectionManager getManager() {
+return connManager;
+}
+/**
+* @deprecated use {@link #assertValid(OperatedClientConnection)}
+*/
+@Deprecated
+protected final void assertNotAborted() throws InterruptedIOException {
+if (isReleased()) {
+throw new InterruptedIOException("Connection has been shut down");
+}
+}
+/**
+* @since 4.1
+* @return value of released flag
+*/
+protected boolean isReleased() {
+return released;
+}
+/**
+* Asserts that there is a valid wrapped connection to delegate to.
+*
+* @throws ConnectionShutdownException if there is no wrapped connection
+*                                  or connection has been aborted
+*/
+protected final void assertValid(
+final OperatedClientConnection wrappedConn) throws ConnectionShutdownException {
+if (isReleased() || wrappedConn == null) {
+throw new ConnectionShutdownException();
+}
+}
+public boolean isOpen() {
+OperatedClientConnection conn = getWrappedConnection();
+if (conn == null)
+return false;
+return conn.isOpen();
+}
+public boolean isStale() {
+if (isReleased())
+return true;
+OperatedClientConnection conn = getWrappedConnection();
+if (conn == null)
+return true;
+return conn.isStale();
+}
+public void setSocketTimeout(int timeout) {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+conn.setSocketTimeout(timeout);
+}
+public int getSocketTimeout() {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+return conn.getSocketTimeout();
+}
+public HttpConnectionMetrics getMetrics() {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+return conn.getMetrics();
+}
+public void flush() throws IOException {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+conn.flush();
+}
+public boolean isResponseAvailable(int timeout) throws IOException {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+return conn.isResponseAvailable(timeout);
+}
+public void receiveResponseEntity(HttpResponse response)
+throws HttpException, IOException {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+unmarkReusable();
+conn.receiveResponseEntity(response);
+}
+public HttpResponse receiveResponseHeader()
+throws HttpException, IOException {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+unmarkReusable();
+return conn.receiveResponseHeader();
+}
+public void sendRequestEntity(HttpEntityEnclosingRequest request)
+throws HttpException, IOException {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+unmarkReusable();
+conn.sendRequestEntity(request);
+}
+public void sendRequestHeader(HttpRequest request)
+throws HttpException, IOException {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+unmarkReusable();
+conn.sendRequestHeader(request);
+}
+public InetAddress getLocalAddress() {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+return conn.getLocalAddress();
+}
+public int getLocalPort() {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+return conn.getLocalPort();
+}
+public InetAddress getRemoteAddress() {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+return conn.getRemoteAddress();
+}
+public int getRemotePort() {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+return conn.getRemotePort();
+}
+public boolean isSecure() {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+return conn.isSecure();
+}
+public SSLSession getSSLSession() {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+if (!isOpen())
+return null;
+SSLSession result = null;
+Socket    sock    = conn.getSocket();
+if (sock instanceof SSLSocket) {
+result = ((SSLSocket)sock).getSession();
+}
+return result;
+}
+public void markReusable() {
+markedReusable = true;
+}
+public void unmarkReusable() {
+markedReusable = false;
+}
+public boolean isMarkedReusable() {
+return markedReusable;
+}
+public void setIdleDuration(long duration, TimeUnit unit) {
+if(duration > 0) {
+this.duration = unit.toMillis(duration);
+} else {
+this.duration = -1;
+}
+}
+public synchronized void releaseConnection() {
+if (released) {
+return;
+}
+released = true;
+if (connManager != null) {
+connManager.releaseConnection(this, duration, TimeUnit.MILLISECONDS);
+}
+}
+public synchronized void abortConnection() {
+if (released) {
+return;
+}
+released = true;
+unmarkReusable();
+try {
+shutdown();
+} catch (IOException ignore) {
+}
+if (connManager != null) {
+connManager.releaseConnection(this, duration, TimeUnit.MILLISECONDS);
+}
+}
+public synchronized Object getAttribute(final String id) {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+if (conn instanceof HttpContext) {
+return ((HttpContext) conn).getAttribute(id);
+} else {
+return null;
+}
+}
+public synchronized Object removeAttribute(final String id) {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+if (conn instanceof HttpContext) {
+return ((HttpContext) conn).removeAttribute(id);
+} else {
+return null;
+}
+}
+public synchronized void setAttribute(final String id, final Object obj) {
+OperatedClientConnection conn = getWrappedConnection();
+assertValid(conn);
+if (conn instanceof HttpContext) {
+((HttpContext) conn).setAttribute(id, obj);
+}
+}
+}

The Tor Browser / file comparison

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

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