RequestQueue.java revision fe4fec7c66b0d956f008ead0fd899b588cfacb5d
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.NetworkConnectivityListener; 309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.net.NetworkInfo; 319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.net.Proxy; 329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.net.WebAddress; 339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.os.Handler; 349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.os.Message; 359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.os.SystemProperties; 369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.text.TextUtils; 379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.util.Log; 389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.io.InputStream; 409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.Iterator; 419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.LinkedHashMap; 429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.LinkedList; 439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.ListIterator; 449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.Map; 459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpHost; 479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/** 499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * {@hide} 509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectpublic class RequestQueue implements RequestFeeder { 529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private Context mContext; 549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Requests, indexed by HttpHost (scheme, host, port) 579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 58fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott private LinkedHashMap<HttpHost, LinkedList<Request>> mPending; 599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** true if connected */ 619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean mNetworkConnected = true; 629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private HttpHost mProxyHost = null; 649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private BroadcastReceiver mProxyChangeReceiver; 659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private ActivePool mActivePool; 679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* default simultaneous connection count */ 699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final int CONNECTION_COUNT = 4; 709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This intent broadcast when http is paused or unpaused due to 739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * net availability toggling 749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public final static String HTTP_NETWORK_STATE_CHANGED_INTENT = 769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "android.net.http.NETWORK_STATE"; 779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public final static String HTTP_NETWORK_STATE_UP = "up"; 789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Listen to platform network state. On a change, 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * (1) kick stack on or off as appropriate 829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * (2) send an intent to my host app telling 839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * it what I've done 849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private NetworkStateTracker mNetworkStateTracker; 869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project class NetworkStateTracker { 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project final static int EVENT_DATA_STATE_CHANGED = 100; 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Context mContext; 919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project NetworkConnectivityListener mConnectivityListener; 929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project NetworkInfo.State mLastNetworkState = NetworkInfo.State.CONNECTED; 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int mCurrentNetworkType; 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project NetworkStateTracker(Context context) { 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext = context; 979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * register for updates 1019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected void enable() { 1039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mConnectivityListener == null) { 1049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* 1059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Initializing the network type is really unnecessary, 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * since as soon as we register with the NCL, we'll 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * get a CONNECTED event for the active network, and 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * we'll configure the HTTP proxy accordingly. However, 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * as a fallback in case that doesn't happen for some 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * reason, initializing to type WIFI would mean that 1119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * we'd start out without a proxy. This seems better 1129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * than thinking we have a proxy (which is probably 1139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * private to the carrier network and therefore 1149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * unreachable outside of that network) when we really 1159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * shouldn't. 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mCurrentNetworkType = ConnectivityManager.TYPE_WIFI; 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectivityListener = new NetworkConnectivityListener(); 1199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectivityListener.registerHandler(mHandler, EVENT_DATA_STATE_CHANGED); 1209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectivityListener.startListening(mContext); 1219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected void disable() { 1259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mConnectivityListener != null) { 1269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectivityListener.unregisterHandler(mHandler); 1279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectivityListener.stopListening(); 1289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectivityListener = null; 1299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private Handler mHandler = new Handler() { 1339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void handleMessage(Message msg) { 1349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project switch (msg.what) { 1359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case EVENT_DATA_STATE_CHANGED: 1369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project networkStateChanged(); 1379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 1389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project }; 1419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int getCurrentNetworkType() { 1439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mCurrentNetworkType; 1449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void networkStateChanged() { 1479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mConnectivityListener == null) 1489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return; 1499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project NetworkConnectivityListener.State connectivityState = mConnectivityListener.getState(); 1529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project NetworkInfo info = mConnectivityListener.getNetworkInfo(); 1539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (info == null) { 1549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * We've been seeing occasional NPEs here. I believe recent changes 1569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * have made this impossible, but in the interest of being totally 1579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * paranoid, check and log this here. 1589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v("NetworkStateTracker: connectivity broadcast" 1609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project + " has null network info - ignoring"); 1619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return; 1629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project NetworkInfo.State state = info.getState(); 1649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) { 1669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v("NetworkStateTracker " + info.getTypeName() + 1679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project " state= " + state + " last= " + mLastNetworkState + 1689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project " connectivityState= " + connectivityState.toString()); 1699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean newConnection = 1729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project state != mLastNetworkState && state == NetworkInfo.State.CONNECTED; 1739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (state == NetworkInfo.State.CONNECTED) { 1759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mCurrentNetworkType = info.getType(); 1769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project setProxyConfig(); 1779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mLastNetworkState = state; 1809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (connectivityState == NetworkConnectivityListener.State.NOT_CONNECTED) { 1819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project setNetworkState(false); 1829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project broadcastState(false); 1839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else if (newConnection) { 1849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project setNetworkState(true); 1859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project broadcastState(true); 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 void broadcastState(boolean connected) { 1919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Intent intent = new Intent(HTTP_NETWORK_STATE_CHANGED_INTENT); 1929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project intent.putExtra(HTTP_NETWORK_STATE_UP, connected); 1939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext.sendBroadcast(intent); 1949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This class maintains active connection threads 1999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project class ActivePool implements ConnectionManager { 2019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** Threads used to process requests */ 2029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread[] mThreads; 2039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project IdleCache mIdleCache; 2059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mTotalRequest; 2079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mTotalConnection; 2089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mConnectionCount; 2099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ActivePool(int connectionCount) { 2119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mIdleCache = new IdleCache(); 2129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectionCount = connectionCount; 2139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThreads = new ConnectionThread[mConnectionCount]; 2149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 2169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThreads[i] = new ConnectionThread( 2179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext, i, this, RequestQueue.this); 2189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void startup() { 2229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 2239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThreads[i].start(); 2249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void shutdown() { 2289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 2299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mThreads[i].requestStop(); 2309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public boolean isNetworkConnected() { 2349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mNetworkConnected; 2359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void startConnectionThread() { 2389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized (RequestQueue.this) { 2399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project RequestQueue.this.notify(); 2409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void startTiming() { 2449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 245340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba ConnectionThread rt = mThreads[i]; 246340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba rt.mCurrentThreadTime = -1; 247340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba rt.mTotalThreadTime = 0; 2489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mTotalRequest = 0; 2509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mTotalConnection = 0; 2519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void stopTiming() { 2549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int totalTime = 0; 2559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 2569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread rt = mThreads[i]; 257340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba if (rt.mCurrentThreadTime != -1) { 258340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba totalTime += rt.mTotalThreadTime; 259340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba } 260340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba rt.mCurrentThreadTime = 0; 2619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Log.d("Http", "Http thread used " + totalTime + " ms " + " for " 2639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project + mTotalRequest + " requests and " + mTotalConnection 264340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba + " new connections"); 2659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void logState() { 2689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project StringBuilder dump = new StringBuilder(); 2699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 2709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project dump.append(mThreads[i] + "\n"); 2719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v(dump.toString()); 2739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public HttpHost getProxyHost() { 2779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mProxyHost; 2789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Turns off persistence on all live connections 2829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void disablePersistence() { 2849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mConnectionCount; i++) { 2859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection connection = mThreads[i].mConnection; 2869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (connection != null) connection.setCanPersist(false); 2879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mIdleCache.clear(); 2899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Linear lookup -- okay for small thread counts. Might use 2929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private HashMap<HttpHost, LinkedList<ConnectionThread>> mActiveMap; 2939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if this turns out to be a hotspot */ 2949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread getThread(HttpHost host) { 2959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized(RequestQueue.this) { 2969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < mThreads.length; i++) { 2979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread ct = mThreads[i]; 2989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection connection = ct.mConnection; 2999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (connection != null && connection.mHost.equals(host)) { 3009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ct; 3019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return null; 3059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public Connection getConnection(Context context, HttpHost host) { 3089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection con = mIdleCache.getConnection(host); 3099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (con == null) { 3109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mTotalConnection++; 3119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project con = Connection.getConnection( 3129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext, host, this, RequestQueue.this); 3139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return con; 3159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public boolean recycleConnection(HttpHost host, Connection connection) { 3179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mIdleCache.cacheConnection(host, connection); 3189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * A RequestQueue class instance maintains a set of queued 3249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * requests. It orders them, makes the requests against HTTP 3259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * servers, and makes callbacks to supplied eventHandlers as data 3269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * is read. It supports request prioritization, connection reuse 3279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * and pipelining. 3289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 3299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param context application context 3309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public RequestQueue(Context context) { 3329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project this(context, CONNECTION_COUNT); 3339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * A RequestQueue class instance maintains a set of queued 3379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * requests. It orders them, makes the requests against HTTP 3389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * servers, and makes callbacks to supplied eventHandlers as data 3399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * is read. It supports request prioritization, connection reuse 3409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * and pipelining. 3419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 3429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param context application context 3439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param connectionCount The number of simultaneous connections 3449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public RequestQueue(Context context, int connectionCount) { 3469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext = context; 3479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 348fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott mPending = new LinkedHashMap<HttpHost, LinkedList<Request>>(32); 3499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool = new ActivePool(connectionCount); 3519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.startup(); 3529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Enables data state and proxy tracking 3569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized void enablePlatformNotifications() { 3589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.enablePlatformNotifications() network"); 3599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mProxyChangeReceiver == null) { 3619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyChangeReceiver = 3629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project new BroadcastReceiver() { 3639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 3649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void onReceive(Context ctx, Intent intent) { 3659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project setProxyConfig(); 3669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project }; 3689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext.registerReceiver(mProxyChangeReceiver, 3699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project new IntentFilter(Proxy.PROXY_CHANGE_ACTION)); 3709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Network state notification is broken on the simulator 3739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project don't register for notifications on SIM */ 3749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String device = SystemProperties.get("ro.product.device"); 3759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean simulation = TextUtils.isEmpty(device); 3769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!simulation) { 3789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mNetworkStateTracker == null) { 3799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mNetworkStateTracker = new NetworkStateTracker(mContext); 3809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mNetworkStateTracker.enable(); 3829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * If platform notifications have been enabled, call this method 3879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * to disable before destroying RequestQueue 3889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized void disablePlatformNotifications() { 3909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.disablePlatformNotifications() network"); 3919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mNetworkStateTracker != null) { 3939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mNetworkStateTracker.disable(); 3949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mProxyChangeReceiver != null) { 3979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext.unregisterReceiver(mProxyChangeReceiver); 3989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyChangeReceiver = null; 3999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Because our IntentReceiver can run within a different thread, 4049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * synchronize setting the proxy 4059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private synchronized void setProxyConfig() { 4079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mNetworkStateTracker.getCurrentNetworkType() == ConnectivityManager.TYPE_WIFI) { 4089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyHost = null; 4099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 4109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String host = Proxy.getHost(mContext); 4119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.setProxyConfig " + host); 4129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (host == null) { 4139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyHost = null; 4149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 4159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.disablePersistence(); 4169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyHost = new HttpHost(host, Proxy.getPort(mContext), "http"); 4179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * used by webkit 4239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return proxy host if set, null otherwise 4249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public HttpHost getProxyHost() { 4269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mProxyHost; 4279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Queues an HTTP request 4319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param url The url to load. 4329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param method "GET" or "POST." 4339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param headers A hashmap of http headers. 4349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param eventHandler The event handler for handling returned 4359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * data. Callbacks will be made on the supplied instance. 4369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyProvider InputStream providing HTTP body, null if none 4379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyLength length of body, must be 0 if bodyProvider is null 4389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public RequestHandle queueRequest( 4409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String url, String method, 4419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Map<String, String> headers, EventHandler eventHandler, 442fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott InputStream bodyProvider, int bodyLength) { 4439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project WebAddress uri = new WebAddress(url); 4449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return queueRequest(url, uri, method, headers, eventHandler, 445fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott bodyProvider, bodyLength); 4469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Queues an HTTP request 4509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param url The url to load. 4519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param uri The uri of the url to load. 4529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param method "GET" or "POST." 4539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param headers A hashmap of http headers. 4549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param eventHandler The event handler for handling returned 4559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * data. Callbacks will be made on the supplied instance. 4569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyProvider InputStream providing HTTP body, null if none 4579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyLength length of body, must be 0 if bodyProvider is null 4589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public RequestHandle queueRequest( 4609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String url, WebAddress uri, String method, Map<String, String> headers, 4619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project EventHandler eventHandler, 462fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott InputStream bodyProvider, int bodyLength) { 4639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.queueRequest " + uri); 4659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Ensure there is an eventHandler set 4679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (eventHandler == null) { 4689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project eventHandler = new LoggingEventHandler(); 4699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Create and queue request */ 4729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request req; 4739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost httpHost = new HttpHost(uri.mHost, uri.mPort, uri.mScheme); 4749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // set up request 4769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req = new Request(method, httpHost, mProxyHost, uri.mPath, bodyProvider, 477fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott bodyLength, eventHandler, headers); 4789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 479b5b33c734ab2a178f07c667a8c1daf8beab837aaPatrick Scott queueRequest(req, false); 4809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.mTotalRequest++; 4829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // dump(); 4849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.startConnectionThread(); 4859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return new RequestHandle( 4879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project this, url, uri, method, headers, bodyProvider, bodyLength, 4889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req); 4899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Called by the NetworkStateTracker -- updates when network connectivity 4939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * is lost/restored. 4949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 4959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * If isNetworkConnected is true, start processing requests 4969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void setNetworkState(boolean isNetworkConnected) { 4989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.setNetworkState() " + isNetworkConnected); 4999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mNetworkConnected = isNetworkConnected; 5009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (isNetworkConnected) 5019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.startConnectionThread(); 5029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return true iff there are any non-active requests pending 5069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized boolean requestsPending() { 5089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return !mPending.isEmpty(); 5099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * debug tool: prints request queue to log 5149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized void dump() { 5169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v("dump()"); 5179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project StringBuilder dump = new StringBuilder(); 5189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int count = 0; 519fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Iterator<Map.Entry<HttpHost, LinkedList<Request>>> iter; 5209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // mActivePool.log(dump); 5229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!mPending.isEmpty()) { 5249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project iter = mPending.entrySet().iterator(); 5259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (iter.hasNext()) { 526fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Map.Entry<HttpHost, LinkedList<Request>> entry = iter.next(); 5279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String hostName = entry.getKey().getHostName(); 5289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project StringBuilder line = new StringBuilder("p" + count++ + " " + hostName + " "); 5299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 530fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott LinkedList<Request> reqList = entry.getValue(); 531fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott ListIterator reqIter = reqList.listIterator(0); 5329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (iter.hasNext()) { 5339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request request = (Request)iter.next(); 5349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project line.append(request + " "); 5359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project dump.append(line); 5379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project dump.append("\n"); 5389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v(dump.toString()); 5419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* 5449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * RequestFeeder implementation 5459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized Request getRequest() { 5479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request ret = null; 5489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mNetworkConnected && !mPending.isEmpty()) { 5509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ret = removeFirst(mPending); 5519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.getRequest() => " + ret); 5539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ret; 5549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return a request for given host if possible 5589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized Request getRequest(HttpHost host) { 5609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request ret = null; 5619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mNetworkConnected && mPending.containsKey(host)) { 563fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott LinkedList<Request> reqList = mPending.get(host); 564fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott if (!reqList.isEmpty()) { 565fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott ret = reqList.removeFirst(); 566fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott } else { 5679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mPending.remove(host); 5689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("RequestQueue.getRequest(" + host + ") => " + ret); 5719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ret; 5729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return true if a request for this host is available 5769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized boolean haveRequest(HttpHost host) { 5789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mPending.containsKey(host); 5799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Put request back on head of queue 5839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void requeueRequest(Request request) { 5859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project queueRequest(request, true); 5869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This must be called to cleanly shutdown RequestQueue 5909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void shutdown() { 5929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.shutdown(); 5939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected synchronized void queueRequest(Request request, boolean head) { 5969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost host = request.mProxyHost == null ? request.mHost : request.mProxyHost; 597fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott LinkedList<Request> reqList; 5989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mPending.containsKey(host)) { 5999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project reqList = mPending.get(host); 6009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 601fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott reqList = new LinkedList<Request>(); 6029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mPending.put(host, reqList); 6039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 604fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott if (head) { 605fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott reqList.addFirst(request); 606fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott } else { 607fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott reqList.add(request); 608fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott } 6099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void startTiming() { 6139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.startTiming(); 6149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void stopTiming() { 6179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActivePool.stopTiming(); 6189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* helper */ 621fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott private Request removeFirst(LinkedHashMap<HttpHost, LinkedList<Request>> requestQueue) { 6229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request ret = null; 623fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Iterator<Map.Entry<HttpHost, LinkedList<Request>>> iter = requestQueue.entrySet().iterator(); 6249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (iter.hasNext()) { 625fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Map.Entry<HttpHost, LinkedList<Request>> entry = iter.next(); 626fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott LinkedList<Request> reqList = entry.getValue(); 627fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott if (!reqList.isEmpty()) { 628fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott ret = reqList.removeFirst(); 629fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott } else { 6309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestQueue.remove(entry.getKey()); 6319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ret; 6349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 6379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This interface is exposed to each connection 6389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 6399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project interface ConnectionManager { 6409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean isNetworkConnected(); 6419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost getProxyHost(); 6429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection getConnection(Context context, HttpHost host); 6439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean recycleConnection(HttpHost host, Connection connection); 6449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 646