19066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 29066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Copyright (C) 2006 The Android Open Source Project 39066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 49066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Licensed under the Apache License, Version 2.0 (the "License"); 59066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * you may not use this file except in compliance with the License. 69066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * You may obtain a copy of the License at 79066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 89066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * http://www.apache.org/licenses/LICENSE-2.0 99066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Unless required by applicable law or agreed to in writing, software 119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * distributed under the License is distributed on an "AS IS" BASIS, 129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * See the License for the specific language governing permissions and 149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * limitations under the License. 159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/** 189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * High level HTTP Interface 199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Queues requests as necessary 209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectpackage android.net.http; 239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.content.BroadcastReceiver; 259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.content.Context; 269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.content.Intent; 279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.content.IntentFilter; 289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.net.ConnectivityManager; 299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.net.NetworkInfo; 309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.net.Proxy; 319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.net.WebAddress; 329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.os.Handler; 339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.os.Message; 349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.os.SystemProperties; 359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.text.TextUtils; 369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.util.Log; 379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.io.InputStream; 399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.Iterator; 409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.LinkedHashMap; 419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.LinkedList; 429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.ListIterator; 439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.Map; 449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpHost; 469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/** 489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * {@hide} 499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectpublic class RequestQueue implements RequestFeeder { 519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Requests, indexed by HttpHost (scheme, host, port) 559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 56aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott private final LinkedHashMap<HttpHost, LinkedList<Request>> mPending; 57aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott private final Context mContext; 58aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott private final ActivePool mActivePool; 59aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott private final ConnectivityManager mConnectivityManager; 609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private HttpHost mProxyHost = null; 629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private BroadcastReceiver mProxyChangeReceiver; 639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* default simultaneous connection count */ 659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final int CONNECTION_COUNT = 4; 669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This class maintains active connection threads 699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project class ActivePool implements ConnectionManager { 719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** Threads used to process requests */ 729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread[] mThreads; 739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project IdleCache mIdleCache; 759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mTotalRequest; 779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mTotalConnection; 789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mConnectionCount; 799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ActivePool(int connectionCount) { 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mIdleCache = new IdleCache(); 829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectionCount = connectionCount; 839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThreads = new ConnectionThread[mConnectionCount]; 849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThreads[i] = new ConnectionThread( 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext, i, this, RequestQueue.this); 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void startup() { 929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThreads[i].start(); 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void shutdown() { 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThreads[i].requestStop(); 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void startConnectionThread() { 1049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized (RequestQueue.this) { 1059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project RequestQueue.this.notify(); 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void startTiming() { 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 111340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba ConnectionThread rt = mThreads[i]; 112340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba rt.mCurrentThreadTime = -1; 113340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba rt.mTotalThreadTime = 0; 1149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mTotalRequest = 0; 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mTotalConnection = 0; 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void stopTiming() { 1209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int totalTime = 0; 1219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 1229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread rt = mThreads[i]; 123340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba if (rt.mCurrentThreadTime != -1) { 124340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba totalTime += rt.mTotalThreadTime; 125340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba } 126340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba rt.mCurrentThreadTime = 0; 1279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Log.d("Http", "Http thread used " + totalTime + " ms " + " for " 1299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project + mTotalRequest + " requests and " + mTotalConnection 130340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba + " new connections"); 1319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void logState() { 1349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project StringBuilder dump = new StringBuilder(); 1359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 1369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project dump.append(mThreads[i] + "\n"); 1379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v(dump.toString()); 1399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public HttpHost getProxyHost() { 1439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mProxyHost; 1449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Turns off persistence on all live connections 1489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void disablePersistence() { 1509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 1519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection connection = mThreads[i].mConnection; 1529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (connection != null) connection.setCanPersist(false); 1539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mIdleCache.clear(); 1559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Linear lookup -- okay for small thread counts. Might use 1589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private HashMap<HttpHost, LinkedList<ConnectionThread>> mActiveMap; 1599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if this turns out to be a hotspot */ 1609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread getThread(HttpHost host) { 1619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized(RequestQueue.this) { 1629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mThreads.length; i++) { 1639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread ct = mThreads[i]; 1649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection connection = ct.mConnection; 1659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (connection != null && connection.mHost.equals(host)) { 1669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ct; 1679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return null; 1719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public Connection getConnection(Context context, HttpHost host) { 17486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott host = RequestQueue.this.determineHost(host); 1759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection con = mIdleCache.getConnection(host); 1769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (con == null) { 1779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mTotalConnection++; 17886806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott con = Connection.getConnection(mContext, host, mProxyHost, 17986806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott RequestQueue.this); 1809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return con; 1829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 18386806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott public boolean recycleConnection(Connection connection) { 18486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott return mIdleCache.cacheConnection(connection.getHost(), connection); 1859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * A RequestQueue class instance maintains a set of queued 1919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * requests. It orders them, makes the requests against HTTP 1929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * servers, and makes callbacks to supplied eventHandlers as data 1939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * is read. It supports request prioritization, connection reuse 1949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * and pipelining. 1959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 1969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param context application context 1979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public RequestQueue(Context context) { 1999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project this(context, CONNECTION_COUNT); 2009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * A RequestQueue class instance maintains a set of queued 2049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * requests. It orders them, makes the requests against HTTP 2059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * servers, and makes callbacks to supplied eventHandlers as data 2069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * is read. It supports request prioritization, connection reuse 2079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * and pipelining. 2089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 2099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param context application context 2109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param connectionCount The number of simultaneous connections 2119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public RequestQueue(Context context, int connectionCount) { 2139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext = context; 2149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 215fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott mPending = new LinkedHashMap<HttpHost, LinkedList<Request>>(32); 2169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool = new ActivePool(connectionCount); 2189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.startup(); 219aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott 220aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott mConnectivityManager = (ConnectivityManager) 221aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott context.getSystemService(Context.CONNECTIVITY_SERVICE); 2229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Enables data state and proxy tracking 2269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized void enablePlatformNotifications() { 2289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.enablePlatformNotifications() network"); 2299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mProxyChangeReceiver == null) { 2319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyChangeReceiver = 2329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project new BroadcastReceiver() { 2339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 2349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void onReceive(Context ctx, Intent intent) { 2359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project setProxyConfig(); 2369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project }; 2389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext.registerReceiver(mProxyChangeReceiver, 2399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project new IntentFilter(Proxy.PROXY_CHANGE_ACTION)); 2409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 241f1cac90c7baafa48b47c5d178dd12a75ba89af0bRobert Greenwalt // we need to resample the current proxy setup 242f1cac90c7baafa48b47c5d178dd12a75ba89af0bRobert Greenwalt setProxyConfig(); 2439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * If platform notifications have been enabled, call this method 2479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * to disable before destroying RequestQueue 2489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized void disablePlatformNotifications() { 2509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.disablePlatformNotifications() network"); 2519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mProxyChangeReceiver != null) { 2539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext.unregisterReceiver(mProxyChangeReceiver); 2549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyChangeReceiver = null; 2559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Because our IntentReceiver can run within a different thread, 2609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * synchronize setting the proxy 2619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private synchronized void setProxyConfig() { 263aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott NetworkInfo info = mConnectivityManager.getActiveNetworkInfo(); 264aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott if (info != null && info.getType() == ConnectivityManager.TYPE_WIFI) { 2659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyHost = null; 2669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 2679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String host = Proxy.getHost(mContext); 2689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.setProxyConfig " + host); 2699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (host == null) { 2709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyHost = null; 2719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 2729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.disablePersistence(); 2739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyHost = new HttpHost(host, Proxy.getPort(mContext), "http"); 2749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * used by webkit 2809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return proxy host if set, null otherwise 2819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public HttpHost getProxyHost() { 2839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mProxyHost; 2849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Queues an HTTP request 2889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param url The url to load. 2899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param method "GET" or "POST." 2909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param headers A hashmap of http headers. 2919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param eventHandler The event handler for handling returned 2929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * data. Callbacks will be made on the supplied instance. 2939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyProvider InputStream providing HTTP body, null if none 2949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyLength length of body, must be 0 if bodyProvider is null 2959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public RequestHandle queueRequest( 2979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String url, String method, 2989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Map<String, String> headers, EventHandler eventHandler, 299fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott InputStream bodyProvider, int bodyLength) { 3009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WebAddress uri = new WebAddress(url); 3019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return queueRequest(url, uri, method, headers, eventHandler, 302fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott bodyProvider, bodyLength); 3039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Queues an HTTP request 3079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param url The url to load. 3089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param uri The uri of the url to load. 3099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param method "GET" or "POST." 3109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param headers A hashmap of http headers. 3119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param eventHandler The event handler for handling returned 3129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * data. Callbacks will be made on the supplied instance. 3139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyProvider InputStream providing HTTP body, null if none 3149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyLength length of body, must be 0 if bodyProvider is null 3159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public RequestHandle queueRequest( 3179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String url, WebAddress uri, String method, Map<String, String> headers, 3189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project EventHandler eventHandler, 319fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott InputStream bodyProvider, int bodyLength) { 3209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.queueRequest " + uri); 3229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Ensure there is an eventHandler set 3249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (eventHandler == null) { 3259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project eventHandler = new LoggingEventHandler(); 3269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Create and queue request */ 3299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request req; 330eb8be973c7982fe3ece0aeaeca379c3b3cdced0cBjorn Bringert HttpHost httpHost = new HttpHost(uri.getHost(), uri.getPort(), uri.getScheme()); 3319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // set up request 333eb8be973c7982fe3ece0aeaeca379c3b3cdced0cBjorn Bringert req = new Request(method, httpHost, mProxyHost, uri.getPath(), bodyProvider, 334fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott bodyLength, eventHandler, headers); 3359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 336b5b33c734ab2a178f07c667a8c1daf8beab837aaPatrick Scott queueRequest(req, false); 3379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.mTotalRequest++; 3399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // dump(); 3419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.startConnectionThread(); 3429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return new RequestHandle( 3449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project this, url, uri, method, headers, bodyProvider, bodyLength, 3459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req); 3469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 34886806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott private static class SyncFeeder implements RequestFeeder { 34986806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // This is used in the case where the request fails and needs to be 35086806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // requeued into the RequestFeeder. 35186806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott private Request mRequest; 35286806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott SyncFeeder() { 35386806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 35486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott public Request getRequest() { 35586806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott Request r = mRequest; 35686806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott mRequest = null; 35786806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott return r; 35886806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 35986806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott public Request getRequest(HttpHost host) { 36086806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott return getRequest(); 36186806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 36286806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott public boolean haveRequest(HttpHost host) { 36386806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott return mRequest != null; 36486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 36586806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott public void requeueRequest(Request r) { 36686806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott mRequest = r; 36786806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 36886806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 36986806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott 37086806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott public RequestHandle queueSynchronousRequest(String url, WebAddress uri, 37186806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott String method, Map<String, String> headers, 37286806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott EventHandler eventHandler, InputStream bodyProvider, 37386806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott int bodyLength) { 37486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott if (HttpLog.LOGV) { 37586806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott HttpLog.v("RequestQueue.dispatchSynchronousRequest " + uri); 37686806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 37786806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott 378eb8be973c7982fe3ece0aeaeca379c3b3cdced0cBjorn Bringert HttpHost host = new HttpHost(uri.getHost(), uri.getPort(), uri.getScheme()); 37986806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott 380eb8be973c7982fe3ece0aeaeca379c3b3cdced0cBjorn Bringert Request req = new Request(method, host, mProxyHost, uri.getPath(), 38186806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott bodyProvider, bodyLength, eventHandler, headers); 38286806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott 38386806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // Open a new connection that uses our special RequestFeeder 38486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // implementation. 38586806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott host = determineHost(host); 38686806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott Connection conn = Connection.getConnection(mContext, host, mProxyHost, 38786806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott new SyncFeeder()); 38886806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott 38986806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // TODO: I would like to process the request here but LoadListener 39086806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // needs a RequestHandle to process some messages. 39186806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott return new RequestHandle(this, url, uri, method, headers, bodyProvider, 39286806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott bodyLength, req, conn); 39386806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott 39486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 39586806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott 39686806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // Chooses between the proxy and the request's host. 39786806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott private HttpHost determineHost(HttpHost host) { 39886806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // There used to be a comment in ConnectionThread about t-mob's proxy 39986806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // being really bad about https. But, HttpsConnection actually looks 40086806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // for a proxy and connects through it anyway. I think that this check 40186806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // is still valid because if a site is https, we will use 40286806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // HttpsConnection rather than HttpConnection if the proxy address is 40386806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott // not secure. 40486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott return (mProxyHost == null || "https".equals(host.getSchemeName())) 40586806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott ? host : mProxyHost; 40686806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott } 40786806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott 4089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return true iff there are any non-active requests pending 4109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized boolean requestsPending() { 4129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return !mPending.isEmpty(); 4139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * debug tool: prints request queue to log 4189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized void dump() { 4209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v("dump()"); 4219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project StringBuilder dump = new StringBuilder(); 4229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int count = 0; 423fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Iterator<Map.Entry<HttpHost, LinkedList<Request>>> iter; 4249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // mActivePool.log(dump); 4269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!mPending.isEmpty()) { 4289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project iter = mPending.entrySet().iterator(); 4299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (iter.hasNext()) { 430fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Map.Entry<HttpHost, LinkedList<Request>> entry = iter.next(); 4319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String hostName = entry.getKey().getHostName(); 4329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project StringBuilder line = new StringBuilder("p" + count++ + " " + hostName + " "); 4339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 434fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott LinkedList<Request> reqList = entry.getValue(); 435fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott ListIterator reqIter = reqList.listIterator(0); 4369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (iter.hasNext()) { 4379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request request = (Request)iter.next(); 4389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project line.append(request + " "); 4399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project dump.append(line); 4419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project dump.append("\n"); 4429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v(dump.toString()); 4459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* 4489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * RequestFeeder implementation 4499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized Request getRequest() { 4519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request ret = null; 4529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 453aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott if (!mPending.isEmpty()) { 4549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ret = removeFirst(mPending); 4559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.getRequest() => " + ret); 4579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ret; 4589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return a request for given host if possible 4629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized Request getRequest(HttpHost host) { 4649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request ret = null; 4659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 466aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott if (mPending.containsKey(host)) { 467fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott LinkedList<Request> reqList = mPending.get(host); 468a16de7b03a1b2fe9e5eca55ce677c121e97079f8Grace Kloba ret = reqList.removeFirst(); 469a16de7b03a1b2fe9e5eca55ce677c121e97079f8Grace Kloba if (reqList.isEmpty()) { 4709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mPending.remove(host); 4719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.getRequest(" + host + ") => " + ret); 4749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ret; 4759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return true if a request for this host is available 4799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized boolean haveRequest(HttpHost host) { 4819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mPending.containsKey(host); 4829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Put request back on head of queue 4869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void requeueRequest(Request request) { 4889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project queueRequest(request, true); 4899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This must be called to cleanly shutdown RequestQueue 4939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void shutdown() { 4959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.shutdown(); 4969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected synchronized void queueRequest(Request request, boolean head) { 4999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost host = request.mProxyHost == null ? request.mHost : request.mProxyHost; 500fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott LinkedList<Request> reqList; 5019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mPending.containsKey(host)) { 5029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project reqList = mPending.get(host); 5039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 504fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott reqList = new LinkedList<Request>(); 5059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mPending.put(host, reqList); 5069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 507fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott if (head) { 508fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott reqList.addFirst(request); 509fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott } else { 510fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott reqList.add(request); 511fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott } 5129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void startTiming() { 5169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.startTiming(); 5179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void stopTiming() { 5209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.stopTiming(); 5219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* helper */ 524fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott private Request removeFirst(LinkedHashMap<HttpHost, LinkedList<Request>> requestQueue) { 5259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request ret = null; 526fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Iterator<Map.Entry<HttpHost, LinkedList<Request>>> iter = requestQueue.entrySet().iterator(); 5279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (iter.hasNext()) { 528fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Map.Entry<HttpHost, LinkedList<Request>> entry = iter.next(); 529fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott LinkedList<Request> reqList = entry.getValue(); 530a16de7b03a1b2fe9e5eca55ce677c121e97079f8Grace Kloba ret = reqList.removeFirst(); 531a16de7b03a1b2fe9e5eca55ce677c121e97079f8Grace Kloba if (reqList.isEmpty()) { 5329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestQueue.remove(entry.getKey()); 5339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ret; 5369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This interface is exposed to each connection 5409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project interface ConnectionManager { 5429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost getProxyHost(); 5439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection getConnection(Context context, HttpHost host); 54486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott boolean recycleConnection(Connection connection); 5459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 547