19066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 29066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Copyright (C) 2007 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 java.io.IOException; 239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.net.UnknownHostException; 249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.ListIterator; 259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.LinkedList; 269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport javax.net.ssl.SSLHandshakeException; 289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.ConnectionReuseStrategy; 309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpEntity; 319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpException; 329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpHost; 339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpVersion; 349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.ParseException; 359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.ProtocolVersion; 369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.protocol.ExecutionContext; 379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.protocol.HttpContext; 389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.protocol.BasicHttpContext; 399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/** 419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * {@hide} 429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectabstract class Connection { 449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Allow a TCP connection 60 idle seconds before erroring out 479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project static final int SOCKET_TIMEOUT = 60000; 499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final int SEND = 0; 519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final int READ = 1; 529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final int DRAIN = 2; 539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final int DONE = 3; 549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final String[] states = {"SEND", "READ", "DRAIN", "DONE"}; 559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Context mContext; 579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** The low level connection */ 599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected AndroidHttpClientConnection mHttpClientConnection = null; 609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * The server SSL certificate associated with this connection 639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * (null if the connection is not secure) 649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * It would be nice to store the whole certificate chain, but 659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * we want to keep things as light-weight as possible 669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected SslCertificate mCertificate = null; 689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * The host this connection is connected to. If using proxy, 719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * this is set to the proxy address 729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost mHost; 749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** true if the connection can be reused for sending more requests */ 769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean mCanPersist; 779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** context required by ConnectionReuseStrategy. */ 799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private HttpContext mHttpContext; 809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** set when cancelled */ 829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static int STATE_NORMAL = 0; 839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static int STATE_CANCEL_REQUESTED = 1; 849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mActive = STATE_NORMAL; 859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** The number of times to try to re-connect (if connect fails). */ 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private final static int RETRY_REQUEST_LIMIT = 2; 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final int MIN_PIPE = 2; 909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final int MAX_PIPE = 3; 919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Doesn't seem to exist anymore in the new HTTP client, so copied here. 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final String HTTP_CONNECTION = "http.connection"; 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project RequestFeeder mRequestFeeder; 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Buffer for feeding response blocks to webkit. One block per 1019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * connection reduces memory churn. 1029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private byte[] mBuf; 1049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected Connection(Context context, HttpHost host, 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project RequestFeeder requestFeeder) { 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mContext = context; 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHost = host; 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRequestFeeder = requestFeeder; 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mCanPersist = false; 1129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpContext = new BasicHttpContext(null); 1139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost getHost() { 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mHost; 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * connection factory: returns an HTTP or HTTPS connection as 1219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * necessary 1229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project static Connection getConnection( 12486806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott Context context, HttpHost host, HttpHost proxy, 1259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project RequestFeeder requestFeeder) { 1269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (host.getSchemeName().equals("http")) { 12886806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott return new HttpConnection(context, host, requestFeeder); 1299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Otherwise, default to https 13286806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott return new HttpsConnection(context, host, proxy, requestFeeder); 1339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return The server SSL certificate associated with this 1379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * connection (null if the connection is not secure) 1389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* package */ SslCertificate getCertificate() { 1409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mCertificate; 1419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Close current network connection 1459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Note: this runs in non-network thread 1469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void cancel() { 1489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActive = STATE_CANCEL_REQUESTED; 1499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project closeConnection(); 1509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 1519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "Connection.cancel(): connection closed " + mHost); 1529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Process requests in queue 1569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * pipelines requests 1579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void processRequests(Request firstRequest) { 1599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request req = null; 1609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean empty; 1619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int error = EventHandler.OK; 1629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Exception exception = null; 1639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project LinkedList<Request> pipe = new LinkedList<Request>(); 1659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int minPipe = MIN_PIPE, maxPipe = MAX_PIPE; 1679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int state = SEND; 1689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (state != DONE) { 1709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 1719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project states[state] + " pipe " + pipe.size()); 1729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* If a request was cancelled, give other cancel requests 1749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project some time to go through so we don't uselessly restart 1759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project connections */ 1769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mActive == STATE_CANCEL_REQUESTED) { 1779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 1789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Thread.sleep(100); 1799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (InterruptedException x) { /* ignore */ } 1809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mActive = STATE_NORMAL; 1819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project switch (state) { 1849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case SEND: { 1859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (pipe.size() == maxPipe) { 1869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project state = READ; 1879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 1889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* get a request */ 1909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (firstRequest == null) { 1919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req = mRequestFeeder.getRequest(mHost); 1929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req = firstRequest; 1949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project firstRequest = null; 1959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (req == null) { 1979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project state = DRAIN; 1989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 1999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.setConnection(this); 2019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Don't work on cancelled requests. */ 2039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (req.mCancelled) { 2049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 2059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "processRequests(): skipping cancelled request " 2069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project + req); 2079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.complete(); 2089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 2099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mHttpClientConnection == null || 2129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project !mHttpClientConnection.isOpen()) { 2139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* If this call fails, the address is bad or 2149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project the net is down. Punt for now. 2159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project FIXME: blow out entire queue here on 2179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project connection failure if net up? */ 2189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!openHttpConnection(req)) { 2209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project state = DONE; 2219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 2229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 225dba8cb76371960457e91b31fa396478f809a5a34Brian Carlstrom /* we have a connection, let the event handler 226dba8cb76371960457e91b31fa396478f809a5a34Brian Carlstrom * know of any associated certificate, 227dba8cb76371960457e91b31fa396478f809a5a34Brian Carlstrom * potentially none. 228dba8cb76371960457e91b31fa396478f809a5a34Brian Carlstrom */ 229dba8cb76371960457e91b31fa396478f809a5a34Brian Carlstrom req.mEventHandler.certificate(mCertificate); 230dba8cb76371960457e91b31fa396478f809a5a34Brian Carlstrom 2319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 2329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* FIXME: don't increment failure count if old 2339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project connection? There should not be a penalty for 2349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project attempting to reuse an old connection */ 2359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.sendRequest(mHttpClientConnection); 2369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (HttpException e) { 2379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 2389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR; 2399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException e) { 2409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 2419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_IO; 2429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IllegalStateException e) { 2439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 2449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_IO; 2459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (exception != null) { 2479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (httpFailure(req, error, exception) && 2489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project !req.mCancelled) { 2499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* retry request if not permanent failure 2509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project or cancelled */ 2519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pipe.addLast(req); 2529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = null; 254aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott state = clearPipe(pipe) ? DONE : SEND; 2559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project minPipe = maxPipe = 1; 2569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 2579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pipe.addLast(req); 2609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!mCanPersist) state = READ; 2619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 2629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case DRAIN: 2659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case READ: { 2669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project empty = !mRequestFeeder.haveRequest(mHost); 2679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int pipeSize = pipe.size(); 2689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (state != DRAIN && pipeSize < minPipe && 2699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project !empty && mCanPersist) { 2709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project state = SEND; 2719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 2729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else if (pipeSize == 0) { 2739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Done if no other work to do */ 2749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project state = empty ? DONE : SEND; 2759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 2769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req = (Request)pipe.removeFirst(); 2799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 2809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "processRequests() reading " + req); 2819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 2839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.readResponse(mHttpClientConnection); 2849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (ParseException e) { 2859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 2869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_IO; 2879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException e) { 2889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 2899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_IO; 2909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IllegalStateException e) { 2919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 2929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_IO; 2939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (exception != null) { 2959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (httpFailure(req, error, exception) && 2969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project !req.mCancelled) { 2979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* retry request if not permanent failure 2989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project or cancelled */ 2999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.reset(); 3009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pipe.addFirst(req); 3019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = null; 3039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mCanPersist = false; 3049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!mCanPersist) { 3069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 3079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "processRequests(): no persist, closing " + 3089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHost); 3099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project closeConnection(); 3119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpContext.removeAttribute(HTTP_CONNECTION); 3139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project clearPipe(pipe); 3149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project minPipe = maxPipe = 1; 315aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott state = SEND; 3169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 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 /** 3249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * After a send/receive failure, any pipelined requests must be 3259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * cleared back to the mRequest queue 3269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return true if mRequests is empty after pipe cleared 3279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean clearPipe(LinkedList<Request> pipe) { 3299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean empty = true; 3309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 3319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "Connection.clearPipe(): clearing pipe " + pipe.size()); 3329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized (mRequestFeeder) { 3339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request tReq; 3349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (!pipe.isEmpty()) { 3359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project tReq = (Request)pipe.removeLast(); 3369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 3379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "clearPipe() adding back " + mHost + " " + tReq); 3389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRequestFeeder.requeueRequest(tReq); 3399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project empty = false; 3409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 34186806ce11a89260147d7c2efa2c192b711d923dbPatrick Scott if (empty) empty = !mRequestFeeder.haveRequest(mHost); 3429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return empty; 3449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return true on success 3489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean openHttpConnection(Request req) { 3509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project long now = SystemClock.uptimeMillis(); 3529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int error = EventHandler.OK; 3539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Exception exception = null; 3549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 3569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // reset the certificate to null before opening a connection 3579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mCertificate = null; 3589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpClientConnection = openConnection(req); 3599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mHttpClientConnection != null) { 3609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpClientConnection.setSocketTimeout(SOCKET_TIMEOUT); 3619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpContext.setAttribute(HTTP_CONNECTION, 3629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpClientConnection); 3639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 3649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // we tried to do SSL tunneling, failed, 3659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // and need to drop the request; 3669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // we have already informed the handler 3679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.mFailCount = RETRY_REQUEST_LIMIT; 3689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 3699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (UnknownHostException e) { 3719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("Failed to open connection"); 3729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_LOOKUP; 3739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 3749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IllegalArgumentException e) { 3759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("Illegal argument exception"); 3769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_CONNECT; 3779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.mFailCount = RETRY_REQUEST_LIMIT; 3789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 3799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (SSLConnectionClosedByUserException e) { 3809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // hack: if we have an SSL connection failure, 3819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // we don't want to reconnect 3829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.mFailCount = RETRY_REQUEST_LIMIT; 3839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // no error message 3849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 3859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (SSLHandshakeException e) { 3869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // hack: if we have an SSL connection failure, 3879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // we don't want to reconnect 3889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.mFailCount = RETRY_REQUEST_LIMIT; 3899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 3909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "SSL exception performing handshake"); 3919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_FAILED_SSL_HANDSHAKE; 3929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 3939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException e) { 3949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = EventHandler.ERROR_CONNECT; 3959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project exception = e; 3969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) { 3999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project long now2 = SystemClock.uptimeMillis(); 4009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v("Connection.openHttpConnection() " + 4019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (now2 - now) + " " + mHost); 4029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (error == EventHandler.OK) { 4059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return true; 4069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 407aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott if (req.mFailCount < RETRY_REQUEST_LIMIT) { 4089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // requeue 4099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mRequestFeeder.requeueRequest(req); 4109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.mFailCount++; 4119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 4129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project httpFailure(req, error, exception); 4139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return error == EventHandler.OK; 4159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Helper. Calls the mEventHandler's error() method only if 4209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * request failed permanently. Increments mFailcount on failure. 4219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 4229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Increments failcount only if the network is believed to be 4239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * connected 4249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 4259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return true if request can be retried (less than 4269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * RETRY_REQUEST_LIMIT failures have occurred). 4279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean httpFailure(Request req, int errorId, Exception e) { 4299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean ret = true; 4309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // e.printStackTrace(); 4329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 4339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "httpFailure() ******* " + e + " count " + req.mFailCount + 434aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott " " + mHost + " " + req.getUri()); 4359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 436aaebc86386c8bb44c25dd06fe573e52ef6b60fbePatrick Scott if (++req.mFailCount >= RETRY_REQUEST_LIMIT) { 4379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ret = false; 4389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String error; 4399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (errorId < 0) { 44083d4a23c280bdcaf6c301651b76ddc6fbf08949cIain Merrick error = ErrorStrings.getString(errorId, mContext); 4419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 4429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Throwable cause = e.getCause(); 4439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project error = cause != null ? cause.toString() : e.getMessage(); 4449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.mEventHandler.error(errorId, error); 4469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project req.complete(); 4479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project closeConnection(); 4509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpContext.removeAttribute(HTTP_CONNECTION); 4519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return ret; 4539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpContext getHttpContext() { 4569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mHttpContext; 4579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Use same logic as ConnectionReuseStrategy 4619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @see ConnectionReuseStrategy 4629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean keepAlive(HttpEntity entity, 4649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ProtocolVersion ver, int connType, final HttpContext context) { 4659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project org.apache.http.HttpConnection conn = (org.apache.http.HttpConnection) 4669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project context.getAttribute(ExecutionContext.HTTP_CONNECTION); 4679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (conn != null && !conn.isOpen()) 4699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 4709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // do NOT check for stale connection, that is an expensive operation 4719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (entity != null) { 4739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (entity.getContentLength() < 0) { 4749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!entity.isChunked() || ver.lessEquals(HttpVersion.HTTP_1_0)) { 4759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // if the content length is not known and is not chunk 4769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // encoded, the connection cannot be reused 4779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 4789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Check for 'Connection' directive 4829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (connType == Headers.CONN_CLOSE) { 4839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 4849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else if (connType == Headers.CONN_KEEP_ALIVE) { 4859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return true; 4869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Resorting to protocol version default close connection policy 4889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return !ver.lessEquals(HttpVersion.HTTP_1_0); 4899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void setCanPersist(HttpEntity entity, ProtocolVersion ver, int connType) { 4929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mCanPersist = keepAlive(entity, ver, connType, mHttpContext); 4939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void setCanPersist(boolean canPersist) { 4969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mCanPersist = canPersist; 4979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean getCanPersist() { 5009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mCanPersist; 5019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** typically http or https... set by subclass */ 5049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project abstract String getScheme(); 5059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project abstract void closeConnection(); 5069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project abstract AndroidHttpClientConnection openConnection(Request req) throws IOException; 5079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Prints request queue to log, for debugging. 5109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * returns request count 5119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized String toString() { 5139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mHost.toString(); 5149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project byte[] getBuf() { 5179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mBuf == null) mBuf = new byte[8192]; 5189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mBuf; 5199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 522