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( 724a06b68c82fc011d8cd780ed7f0393d1d0617a07Patrick Scott android.os.Process.THREAD_PRIORITY_DEFAULT + 739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project android.os.Process.THREAD_PRIORITY_LESS_FAVORABLE); 749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 75340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba // these are used to get performance data. When it is not in the timing, 76340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba // mCurrentThreadTime is 0. When it starts timing, mCurrentThreadTime is 77340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba // first set to -1, it will be set to the current thread time when the 78340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba // next request starts. 79340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mCurrentThreadTime = 0; 80340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mTotalThreadTime = 0; 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (mRunning) { 83340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba if (mCurrentThreadTime == -1) { 84340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mCurrentThreadTime = SystemClock.currentThreadTimeMillis(); 85340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba } 86340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request request; 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Get a request to process */ 909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project request = mRequestFeeder.getRequest(); 919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* wait for work */ 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (request == null) { 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized(mRequestFeeder) { 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("ConnectionThread: Waiting for work"); 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mWaiting = true; 979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRequestFeeder.wait(); 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (InterruptedException e) { 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mWaiting = false; 102340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba if (mCurrentThreadTime != 0) { 103340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mCurrentThreadTime = SystemClock 104340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba .currentThreadTimeMillis(); 105340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba } 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("ConnectionThread: new request " + 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project request.mHost + " " + request ); 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 11186806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott mConnection = mConnectionManager.getConnection(mContext, 11286806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott request.mHost); 1139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.processRequests(request); 1149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mConnection.getCanPersist()) { 11586806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott if (!mConnectionManager.recycleConnection(mConnection)) { 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.closeConnection(); 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.closeConnection(); 1209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection = null; 122340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba 123340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba if (mCurrentThreadTime > 0) { 124340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba long start = mCurrentThreadTime; 125340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mCurrentThreadTime = SystemClock.currentThreadTimeMillis(); 126340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba mTotalThreadTime += mCurrentThreadTime - start; 127340a1b21de7d5f650b15fab2bcda355ae9776f90Grace Kloba } 1289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized String toString() { 1349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String con = mConnection == null ? "" : mConnection.toString(); 1359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String active = mWaiting ? "w" : "a"; 1369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return "cid " + mId + " " + active + " " + con; 1379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 140