ConnectionThread.java revision 340a1b21de7d5f650b15fab2bcda355ae9776f90
19066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 29066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Copyright (C) 2008 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 Projectpackage android.net.http; 189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.content.Context; 209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.os.SystemClock; 219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpHost; 239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.lang.Thread; 259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/** 279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * {@hide} 289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectclass ConnectionThread extends Thread { 309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project static final int WAIT_TIMEOUT = 5000; 329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project static final int WAIT_TICK = 1000; 339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Performance probe 359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project long mCurrentThreadTime; 36340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba long mTotalThreadTime; 379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean mWaiting; 399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private volatile boolean mRunning = true; 409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private Context mContext; 419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private RequestQueue.ConnectionManager mConnectionManager; 429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private RequestFeeder mRequestFeeder; 439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mId; 459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Connection mConnection; 469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ConnectionThread(Context context, 489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int id, 499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project RequestQueue.ConnectionManager connectionManager, 509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project RequestFeeder requestFeeder) { 519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project super(); 529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext = context; 539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project setName("http" + id); 549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mId = id; 559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnectionManager = connectionManager; 569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRequestFeeder = requestFeeder; 579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void requestStop() { 609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized (mRequestFeeder) { 619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRunning = false; 629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRequestFeeder.notify(); 639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Loop until app shutdown. Runs connections in priority 689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * order. 699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void run() { 719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project android.os.Process.setThreadPriority( 729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project android.os.Process.THREAD_PRIORITY_LESS_FAVORABLE); 739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 74340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba // these are used to get performance data. When it is not in the timing, 75340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba // mCurrentThreadTime is 0. When it starts timing, mCurrentThreadTime is 76340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba // first set to -1, it will be set to the current thread time when the 77340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba // next request starts. 78340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mCurrentThreadTime = 0; 79340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mTotalThreadTime = 0; 809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (mRunning) { 82340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba if (mCurrentThreadTime == -1) { 83340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mCurrentThreadTime = SystemClock.currentThreadTimeMillis(); 84340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba } 85340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba 869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request request; 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Get a request to process */ 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project request = mRequestFeeder.getRequest(); 909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* wait for work */ 929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (request == null) { 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized(mRequestFeeder) { 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("ConnectionThread: Waiting for work"); 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mWaiting = true; 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRequestFeeder.wait(); 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (InterruptedException e) { 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mWaiting = false; 101340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba if (mCurrentThreadTime != 0) { 102340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mCurrentThreadTime = SystemClock 103340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba .currentThreadTimeMillis(); 104340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba } 1059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("ConnectionThread: new request " + 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project request.mHost + " " + request ); 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost proxy = mConnectionManager.getProxyHost(); 1119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost host; 1139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (false) { 1149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Allow https proxy 1159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project host = proxy == null ? request.mHost : proxy; 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Disallow https proxy -- tmob proxy server 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // serves a request loop for https reqs 1199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project host = (proxy == null || 1209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project request.mHost.getSchemeName().equals("https")) ? 1219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project request.mHost : proxy; 1229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection = mConnectionManager.getConnection(mContext, host); 1249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.processRequests(request); 1259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mConnection.getCanPersist()) { 1269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!mConnectionManager.recycleConnection(host, 1279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection)) { 1289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.closeConnection(); 1299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.closeConnection(); 1329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection = null; 134340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba 135340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba if (mCurrentThreadTime > 0) { 136340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba long start = mCurrentThreadTime; 137340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mCurrentThreadTime = SystemClock.currentThreadTimeMillis(); 138340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mTotalThreadTime += mCurrentThreadTime - start; 139340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba } 1409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized String toString() { 1469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String con = mConnection == null ? "" : mConnection.toString(); 1479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String active = mWaiting ? "w" : "a"; 1489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return "cid " + mId + " " + active + " " + con; 1499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 152