1069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project/* 2069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * $HeadURL: http://svn.apache.org/repos/asf/httpcomponents/httpclient/trunk/module-client/src/main/java/org/apache/http/impl/conn/tsccm/ThreadSafeClientConnManager.java $ 3069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * $Revision: 673450 $ 4069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * $Date: 2008-07-02 10:35:05 -0700 (Wed, 02 Jul 2008) $ 5069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 6069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * ==================================================================== 7069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 8069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Licensed to the Apache Software Foundation (ASF) under one or more 9069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * contributor license agreements. See the NOTICE file distributed with 10069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * this work for additional information regarding copyright ownership. 11069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * The ASF licenses this file to You under the Apache License, Version 2.0 12069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * (the "License"); you may not use this file except in compliance with 13069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * the License. You may obtain a copy of the License at 14069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 15069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * http://www.apache.org/licenses/LICENSE-2.0 16069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 17069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Unless required by applicable law or agreed to in writing, software 18069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * distributed under the License is distributed on an "AS IS" BASIS, 19069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 20069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * See the License for the specific language governing permissions and 21069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * limitations under the License. 22069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * ==================================================================== 23069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 24069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * This software consists of voluntary contributions made by many 25069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * individuals on behalf of the Apache Software Foundation. For more 26069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * information on the Apache Software Foundation, please see 27069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * <http://www.apache.org/>. 28069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 29069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project */ 30069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 31069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectpackage org.apache.http.impl.conn.tsccm; 32069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 339921905a96d7a4528cc30edc3a919f786821eb08Jesse Wilsonimport dalvik.system.SocketTagger; 34069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport java.io.IOException; 35d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkeyimport java.net.Socket; 36069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport java.util.concurrent.TimeUnit; 37069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 38069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.commons.logging.Log; 39069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.commons.logging.LogFactory; 40069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.conn.routing.HttpRoute; 41069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.conn.scheme.SchemeRegistry; 42069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.conn.ClientConnectionManager; 43069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.conn.ClientConnectionOperator; 44069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.conn.ClientConnectionRequest; 45069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.conn.ConnectionPoolTimeoutException; 46069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.conn.ManagedClientConnection; 47069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.conn.OperatedClientConnection; 48069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.params.HttpParams; 49069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectimport org.apache.http.impl.conn.DefaultClientConnectionOperator; 50069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 51069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 52069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 53069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project/** 54069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Manages a pool of {@link OperatedClientConnection client connections}. 55069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * <p> 56069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * This class is derived from <code>MultiThreadedHttpConnectionManager</code> 57069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * in HttpClient 3. See there for original authors. 58069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * </p> 59069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 60069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @author <a href="mailto:rolandw at apache.org">Roland Weber</a> 61069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @author <a href="mailto:becke@u.washington.edu">Michael Becke</a> 62069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 63069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 64069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * <!-- empty lines to avoid svn diff problems --> 65069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @version $Revision: 673450 $ $Date: 2008-07-02 10:35:05 -0700 (Wed, 02 Jul 2008) $ 66069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 67069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @since 4.0 68069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project */ 69069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Projectpublic class ThreadSafeClientConnManager implements ClientConnectionManager { 70069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 71069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project private final Log log = LogFactory.getLog(getClass()); 72069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 73069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project /** The schemes supported by this connection manager. */ 74069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project protected SchemeRegistry schemeRegistry; 75069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 76069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project /** The pool of connections being managed. */ 77069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project protected final AbstractConnPool connectionPool; 78069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 79069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project /** The operator for opening and updating connections. */ 80069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project protected ClientConnectionOperator connOperator; 81069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 82069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 83069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 84069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project /** 85069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Creates a new thread safe connection manager. 86069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 87069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @param params the parameters for this manager 88719e14938db79a6d98ab2bdfdaf1b7b15e1ecbddJesse Wilson * @param schreg the scheme registry 89069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project */ 90069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public ThreadSafeClientConnManager(HttpParams params, 91069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project SchemeRegistry schreg) { 92069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 93069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (params == null) { 94069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project throw new IllegalArgumentException("HTTP parameters may not be null"); 95069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 96069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project this.schemeRegistry = schreg; 97069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project this.connOperator = createConnectionOperator(schreg); 98069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project this.connectionPool = createConnectionPool(params); 99069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 100069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } // <constructor> 101069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 102069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 103069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project @Override 104069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project protected void finalize() throws Throwable { 105069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project shutdown(); 106069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project super.finalize(); 107069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 108069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 109069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 110069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project /** 111069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Hook for creating the connection pool. 112069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 113069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @return the connection pool to use 114069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project */ 115069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project protected AbstractConnPool createConnectionPool(final HttpParams params) { 116069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 117069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project AbstractConnPool acp = new ConnPoolByRoute(connOperator, params); 118069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project boolean conngc = true; //@@@ check parameters to decide 119069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (conngc) { 120069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project acp.enableConnectionGC(); 121069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 122069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project return acp; 123069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 124069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 125069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 126069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project /** 127069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Hook for creating the connection operator. 128069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * It is called by the constructor. 129069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Derived classes can override this method to change the 130069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * instantiation of the operator. 131069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * The default implementation here instantiates 132069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * {@link DefaultClientConnectionOperator DefaultClientConnectionOperator}. 133069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 134069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @param schreg the scheme registry to use, or <code>null</code> 135069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 136069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @return the connection operator to use 137069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project */ 138069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project protected ClientConnectionOperator 139069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project createConnectionOperator(SchemeRegistry schreg) { 140069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 141069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project return new DefaultClientConnectionOperator(schreg); 142069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 143069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 144069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 145069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // non-javadoc, see interface ClientConnectionManager 146069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public SchemeRegistry getSchemeRegistry() { 147069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project return this.schemeRegistry; 148069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 149069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 150069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 151069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public ClientConnectionRequest requestConnection( 152069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project final HttpRoute route, 153069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project final Object state) { 154069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 155069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project final PoolEntryRequest poolRequest = connectionPool.requestPoolEntry( 156069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project route, state); 157069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 158069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project return new ClientConnectionRequest() { 159069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 160069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public void abortRequest() { 161069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project poolRequest.abortRequest(); 162069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 163069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 164069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public ManagedClientConnection getConnection( 165069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project long timeout, TimeUnit tunit) throws InterruptedException, 166069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project ConnectionPoolTimeoutException { 167069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (route == null) { 168069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project throw new IllegalArgumentException("Route may not be null."); 169069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 170069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 171069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (log.isDebugEnabled()) { 172069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project log.debug("ThreadSafeClientConnManager.getConnection: " 173069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project + route + ", timeout = " + timeout); 174069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 175069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 176069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project BasicPoolEntry entry = poolRequest.getPoolEntry(timeout, tunit); 177d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey // BEGIN android-changed 178d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey // When using a recycled Socket, we need to re-tag it with any 179d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey // updated statistics options. 180d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey try { 181d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey final Socket socket = entry.getConnection().getSocket(); 182d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey if (socket != null) { 1839921905a96d7a4528cc30edc3a919f786821eb08Jesse Wilson SocketTagger.get().tag(socket); 184d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey } 185d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey } catch (IOException iox) { 186d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey log.debug("Problem tagging socket.", iox); 187d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey } 188d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey // END android-changed 189069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project return new BasicPooledConnAdapter(ThreadSafeClientConnManager.this, entry); 190069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 191069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 192069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project }; 193069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 194069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 195069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 196069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 197069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // non-javadoc, see interface ClientConnectionManager 198069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public void releaseConnection(ManagedClientConnection conn, long validDuration, TimeUnit timeUnit) { 199069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 200069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (!(conn instanceof BasicPooledConnAdapter)) { 201069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project throw new IllegalArgumentException 202069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project ("Connection class mismatch, " + 203069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project "connection not obtained from this manager."); 204069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 205069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project BasicPooledConnAdapter hca = (BasicPooledConnAdapter) conn; 206069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if ((hca.getPoolEntry() != null) && (hca.getManager() != this)) { 207069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project throw new IllegalArgumentException 208069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project ("Connection not obtained from this manager."); 209069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 210069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 211069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project try { 212d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey // BEGIN android-changed 213d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey // When recycling a Socket, we un-tag it to avoid collecting 214d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey // statistics from future users. 215d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey final BasicPoolEntry entry = (BasicPoolEntry) hca.getPoolEntry(); 216d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey final Socket socket = entry.getConnection().getSocket(); 217d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey if (socket != null) { 2189921905a96d7a4528cc30edc3a919f786821eb08Jesse Wilson SocketTagger.get().untag(socket); 219d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey } 220d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey // END android-changed 221d83e6b1cf9330504abce1d2c8700c9b6b43cc5e8Jeff Sharkey 222069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // make sure that the response has been read completely 223069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (hca.isOpen() && !hca.isMarkedReusable()) { 224069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (log.isDebugEnabled()) { 225069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project log.debug 226069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project ("Released connection open but not marked reusable."); 227069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 228069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // In MTHCM, there would be a call to 229069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // SimpleHttpConnectionManager.finishLastResponse(conn); 230069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // Consuming the response is handled outside in 4.0. 231069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 232069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // make sure this connection will not be re-used 233069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // Shut down rather than close, we might have gotten here 234069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // because of a shutdown trigger. 235069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // Shutdown of the adapter also clears the tracked route. 236069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project hca.shutdown(); 237069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 238069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } catch (IOException iox) { 239069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project //@@@ log as warning? let pass? 240069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (log.isDebugEnabled()) 241069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project log.debug("Exception shutting down released connection.", 242069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project iox); 243069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } finally { 244069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project BasicPoolEntry entry = (BasicPoolEntry) hca.getPoolEntry(); 245069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project boolean reusable = hca.isMarkedReusable(); 246069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project hca.detach(); 247069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project if (entry != null) { 248069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project connectionPool.freeEntry(entry, reusable, validDuration, timeUnit); 249069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 250069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 251069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 252069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 253069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 254069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // non-javadoc, see interface ClientConnectionManager 255069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public void shutdown() { 256069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project connectionPool.shutdown(); 257069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 258069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 259069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 260069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project /** 261069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Gets the total number of pooled connections for the given route. 262069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * This is the total number of connections that have been created and 263069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * are still in use by this connection manager for the route. 264069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * This value will not exceed the maximum number of connections per host. 265069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 266069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @param route the route in question 267069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 268069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @return the total number of pooled connections for that route 269069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project */ 270069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public int getConnectionsInPool(HttpRoute route) { 271069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project return ((ConnPoolByRoute)connectionPool).getConnectionsInPool( 272069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project route); 273069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 274069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 275069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 276069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project /** 277069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * Gets the total number of pooled connections. This is the total number of 278069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * connections that have been created and are still in use by this connection 279069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * manager. This value will not exceed the maximum number of connections 280069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * in total. 281069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * 282069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project * @return the total number of pooled connections 283069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project */ 284069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public int getConnectionsInPool() { 285069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project synchronized (connectionPool) { 286069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project return connectionPool.numConnections; //@@@ 287069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 288069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 289069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 290069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 291069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // non-javadoc, see interface ClientConnectionManager 292069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public void closeIdleConnections(long idleTimeout, TimeUnit tunit) { 293069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project // combine these two in a single call? 294069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project connectionPool.closeIdleConnections(idleTimeout, tunit); 295069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project connectionPool.deleteClosedConnections(); 296069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 297069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 298069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project public void closeExpiredConnections() { 299069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project connectionPool.closeExpiredConnections(); 300069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project connectionPool.deleteClosedConnections(); 301069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project } 302069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 303069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 304069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project} // class ThreadSafeClientConnManager 305069490a5ca2fd1988d29daf45d892f47ad665115The Android Open Source Project 306