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 Projectpackage android.net.http; 189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.io.EOFException; 209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.io.InputStream; 219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.io.IOException; 229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.Iterator; 239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.Map; 249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.Map.Entry; 259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.zip.GZIPInputStream; 269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.entity.InputStreamEntity; 289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.Header; 299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpClientConnection; 309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpEntity; 319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpEntityEnclosingRequest; 329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpException; 339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpHost; 349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpRequest; 359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpResponse; 369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.HttpStatus; 3752e41583f58132ae109c632b51f8419c4c2225d6Grace Klobaimport org.apache.http.HttpVersion; 389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.ParseException; 399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.ProtocolVersion; 409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.StatusLine; 429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.message.BasicHttpRequest; 439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.message.BasicHttpEntityEnclosingRequest; 449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport org.apache.http.protocol.RequestContent; 459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/** 479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Represents an HTTP request for a given host. 489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * {@hide} 509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectclass Request { 539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** The eventhandler to call as the request progresses */ 559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project EventHandler mEventHandler; 569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private Connection mConnection; 589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** The Apache http request */ 609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project BasicHttpRequest mHttpRequest; 619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** The path component of this request */ 639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String mPath; 649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** Host serving this request */ 669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost mHost; 679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** Set if I'm using a proxy server */ 699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpHost mProxyHost; 709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** True if request has been cancelled */ 729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project volatile boolean mCancelled = false; 739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int mFailCount = 0; 759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7652e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba // This will be used to set the Range field if we retry a connection. This 7752e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba // is http/1.1 feature. 7852e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba private int mReceivedBytes = 0; 7952e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba 809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private InputStream mBodyProvider; 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mBodyLength; 829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private final static String HOST_HEADER = "Host"; 849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private final static String ACCEPT_ENCODING_HEADER = "Accept-Encoding"; 859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private final static String CONTENT_LENGTH_HEADER = "content-length"; 869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Used to synchronize waitUntilComplete() requests */ 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private final Object mClientResource = new Object(); 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 905b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch /** True if loading should be paused **/ 915b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch private boolean mLoadingPaused = false; 925b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Processor used to set content-length and transfer-encoding 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * headers. 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static RequestContent requestContentProcessor = 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project new RequestContent(); 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Instantiates a new Request. 1029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param method GET/POST/PUT 1039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param host The server that will handle this request 1049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param path path part of URI 1059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyProvider InputStream providing HTTP body, null if none 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param bodyLength length of body, must be 0 if bodyProvider is null 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param eventHandler request will make progress callbacks on 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * this interface 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param headers reqeust headers 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Request(String method, HttpHost host, HttpHost proxyHost, String path, 1129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project InputStream bodyProvider, int bodyLength, 1139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project EventHandler eventHandler, 114fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott Map<String, String> headers) { 1159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mEventHandler = eventHandler; 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHost = host; 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mProxyHost = proxyHost; 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mPath = path; 1199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mBodyProvider = bodyProvider; 1209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mBodyLength = bodyLength; 1219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 12245efe69f8019f9743aef4d2b4eb6acf56ea0551fGrace Kloba if (bodyProvider == null && !"POST".equalsIgnoreCase(method)) { 1239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpRequest = new BasicHttpRequest(method, getUri()); 1249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpRequest = new BasicHttpEntityEnclosingRequest( 1269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project method, getUri()); 12745efe69f8019f9743aef4d2b4eb6acf56ea0551fGrace Kloba // it is ok to have null entity for BasicHttpEntityEnclosingRequest. 12845efe69f8019f9743aef4d2b4eb6acf56ea0551fGrace Kloba // By using BasicHttpEntityEnclosingRequest, it will set up the 12945efe69f8019f9743aef4d2b4eb6acf56ea0551fGrace Kloba // correct content-length, content-type and content-encoding. 13045efe69f8019f9743aef4d2b4eb6acf56ea0551fGrace Kloba if (bodyProvider != null) { 13145efe69f8019f9743aef4d2b4eb6acf56ea0551fGrace Kloba setBodyProvider(bodyProvider, bodyLength); 13245efe69f8019f9743aef4d2b4eb6acf56ea0551fGrace Kloba } 1339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project addHeader(HOST_HEADER, getHostPort()); 1359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* FIXME: if webcore will make the root document a 1379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project high-priority request, we can ask for gzip encoding only on 1389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project high priority reqs (saving the trouble for images, etc) */ 1399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project addHeader(ACCEPT_ENCODING_HEADER, "gzip"); 1409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project addHeaders(headers); 1419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1445b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch * @param pause True if the load should be paused. 1455b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch */ 1465b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch synchronized void setLoadingPaused(boolean pause) { 1475b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch mLoadingPaused = pause; 1485b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch 1495b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch // Wake up the paused thread if we're unpausing the load. 1505b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch if (!mLoadingPaused) { 1515b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch notify(); 1525b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch } 1535b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch } 1545b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch 1555b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch /** 1569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param connection Request served by this connection 1579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void setConnection(Connection connection) { 1599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection = connection; 1609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* package */ EventHandler getEventHandler() { 1639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mEventHandler; 1649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Add header represented by given pair to request. Header will 1689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * be formatted in request as "name: value\r\n". 1699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param name of header 1709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param value of header 1719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void addHeader(String name, String value) { 1739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (name == null) { 1749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String damage = "Null http header name"; 1759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.e(damage); 1769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project throw new NullPointerException(damage); 1779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (value == null || value.length() == 0) { 1799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String damage = "Null or empty value for header \"" + name + "\""; 1809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.e(damage); 1819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project throw new RuntimeException(damage); 1829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpRequest.addHeader(name, value); 1849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Add all headers in given map to this request. This is a helper 1889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * method: it calls addHeader for each pair in the map. 1899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void addHeaders(Map<String, String> headers) { 1919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (headers == null) { 1929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return; 1939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Entry<String, String> entry; 1969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Iterator<Entry<String, String>> i = headers.entrySet().iterator(); 1979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (i.hasNext()) { 1989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project entry = i.next(); 1999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project addHeader(entry.getKey(), entry.getValue()); 2009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Send the request line and headers 2059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void sendRequest(AndroidHttpClientConnection httpClientConnection) 2079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project throws HttpException, IOException { 2089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mCancelled) return; // don't send cancelled requests 2109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) { 2129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v("Request.sendRequest() " + mHost.getSchemeName() + "://" + getHostPort()); 2139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // HttpLog.v(mHttpRequest.getRequestLine().toString()); 2149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (false) { 2159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Iterator i = mHttpRequest.headerIterator(); 2169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (i.hasNext()) { 2179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Header header = (Header)i.next(); 2189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v(header.getName() + ": " + header.getValue()); 2199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestContentProcessor.process(mHttpRequest, 2249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.getHttpContext()); 2259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project httpClientConnection.sendRequestHeader(mHttpRequest); 2269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mHttpRequest instanceof HttpEntityEnclosingRequest) { 2279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project httpClientConnection.sendRequestEntity( 2289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (HttpEntityEnclosingRequest) mHttpRequest); 2299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) { 2329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v("Request.requestSent() " + mHost.getSchemeName() + "://" + getHostPort() + mPath); 2339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Receive a single http response. 2399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 2409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param httpClientConnection the request to receive the response for. 2419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void readResponse(AndroidHttpClientConnection httpClientConnection) 2439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project throws IOException, ParseException { 2449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mCancelled) return; // don't send cancelled requests 2469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project StatusLine statusLine = null; 2489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean hasBody = false; 2499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project httpClientConnection.flush(); 2509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int statusCode = 0; 2519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Headers header = new Headers(); 2539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project do { 2549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project statusLine = httpClientConnection.parseResponseHeader(header); 2559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project statusCode = statusLine.getStatusCode(); 2569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } while (statusCode < HttpStatus.SC_OK); 2579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 2589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "Request.readResponseStatus() " + 2599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project statusLine.toString().length() + " " + statusLine); 2609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ProtocolVersion v = statusLine.getProtocolVersion(); 2629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mEventHandler.status(v.getMajor(), v.getMinor(), 2639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project statusCode, statusLine.getReasonPhrase()); 2649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mEventHandler.headers(header); 2659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpEntity entity = null; 2669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project hasBody = canResponseHaveBody(mHttpRequest, statusCode); 2679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (hasBody) 2699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project entity = httpClientConnection.receiveResponseEntity(header); 2709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2716ead8f6771fdc80d3ac67e174066b674f688b2d6Grace Kloba // restrict the range request to the servers claiming that they are 2726ead8f6771fdc80d3ac67e174066b674f688b2d6Grace Kloba // accepting ranges in bytes 2736ead8f6771fdc80d3ac67e174066b674f688b2d6Grace Kloba boolean supportPartialContent = "bytes".equalsIgnoreCase(header 2746ead8f6771fdc80d3ac67e174066b674f688b2d6Grace Kloba .getAcceptRanges()); 27552e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba 2769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (entity != null) { 2779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project InputStream is = entity.getContent(); 2789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // process gzip content encoding 2809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Header contentEncoding = entity.getContentEncoding(); 2819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project InputStream nis = null; 2827cd64bd7e7425408f0dc7e1212e81950a7dab217Grace Kloba byte[] buf = null; 2837cd64bd7e7425408f0dc7e1212e81950a7dab217Grace Kloba int count = 0; 2849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 2859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (contentEncoding != null && 2869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project contentEncoding.getValue().equals("gzip")) { 2879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nis = new GZIPInputStream(is); 2889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 2899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nis = is; 2909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* accumulate enough data to make it worth pushing it 2939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * up the stack */ 2947cd64bd7e7425408f0dc7e1212e81950a7dab217Grace Kloba buf = mConnection.getBuf(); 2959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int len = 0; 2969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int lowWater = buf.length / 2; 2979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (len != -1) { 2985b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch synchronized(this) { 2995b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch while (mLoadingPaused) { 3005b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch // Put this (network loading) thread to sleep if WebCore 3015b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch // has asked us to. This can happen with plugins for 3025b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch // example, if we are streaming data but the plugin has 3035b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch // filled its internal buffers. 3045b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch try { 3055b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch wait(); 3065b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch } catch (InterruptedException e) { 3075b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch HttpLog.e("Interrupted exception whilst " 3085b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch + "network thread paused at WebCore's request." 3095b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch + " " + e.getMessage()); 3105b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch } 3115b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch } 3125b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch } 3135b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch 3149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project len = nis.read(buf, count, buf.length - count); 3155b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch 3169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (len != -1) { 3179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project count += len; 31852e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba if (supportPartialContent) mReceivedBytes += len; 3199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (len == -1 || count >= lowWater) { 3219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("Request.readResponse() " + count); 3229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mEventHandler.data(buf, count); 3239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project count = 0; 3249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (EOFException e) { 3279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* InflaterInputStream throws an EOFException when the 3289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project server truncates gzipped content. Handle this case 3299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project as we do truncated non-gzipped content: no error */ 3307cd64bd7e7425408f0dc7e1212e81950a7dab217Grace Kloba if (count > 0) { 3317cd64bd7e7425408f0dc7e1212e81950a7dab217Grace Kloba // if there is uncommited content, we should commit them 3327cd64bd7e7425408f0dc7e1212e81950a7dab217Grace Kloba mEventHandler.data(buf, count); 3337cd64bd7e7425408f0dc7e1212e81950a7dab217Grace Kloba } 3349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( "readResponse() handling " + e); 3359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch(IOException e) { 3369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // don't throw if we have a non-OK status code 33752e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba if (statusCode == HttpStatus.SC_OK 33852e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba || statusCode == HttpStatus.SC_PARTIAL_CONTENT) { 33952e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba if (supportPartialContent && count > 0) { 34052e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba // if there is uncommited content, we should commit them 34152e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba // as we will continue the request 34252e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba mEventHandler.data(buf, count); 34352e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba } 3449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project throw e; 3459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } finally { 3479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (nis != null) { 3489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nis.close(); 3499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.setCanPersist(entity, statusLine.getProtocolVersion(), 3539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project header.getConnectionType()); 3549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mEventHandler.endData(); 3559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project complete(); 3569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("Request.readResponse(): done " + 3589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHost.getSchemeName() + "://" + getHostPort() + mPath); 3599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Data will not be sent to or received from server after cancel() 3639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * call. Does not close connection--use close() below for that. 3649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 3659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Called by RequestHandle from non-network thread 3669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3675b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch synchronized void cancel() { 3689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) { 3699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpLog.v("Request.cancel(): " + getUri()); 3709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3715b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch 3725b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch // Ensure that the network thread is not blocked by a hanging request from WebCore to 3735b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch // pause the load. 3745b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch mLoadingPaused = false; 3755b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch notify(); 3765b494c1ca4c3cf0e0992c59fe34ae66c81e6dcceBen Murdoch 3779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mCancelled = true; 3789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mConnection != null) { 3799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.cancel(); 3809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String getHostPort() { 3849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String myScheme = mHost.getSchemeName(); 3859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int myPort = mHost.getPort(); 3869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Only send port when we must... many servers can't deal with it 3889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (myPort != 80 && myScheme.equals("http") || 3899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project myPort != 443 && myScheme.equals("https")) { 3909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mHost.toHostString(); 3919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 3929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mHost.getHostName(); 3939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String getUri() { 3979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mProxyHost == null || 3989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHost.getSchemeName().equals("https")) { 3999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mPath; 4009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mHost.getSchemeName() + "://" + getHostPort() + mPath; 4029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * for debugging 4069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public String toString() { 408fe4fec7c66b0d956f008ead0fd899b588cfacb5dPatrick Scott return mPath; 4099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * If this request has been sent once and failed, it must be reset 4149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * before it can be sent again. 4159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void reset() { 4179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* clear content-length header */ 4189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mHttpRequest.removeHeaders(CONTENT_LENGTH_HEADER); 4199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mBodyProvider != null) { 4219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 4229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mBodyProvider.reset(); 4239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException ex) { 4249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v( 4259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "failed to reset body provider " + 4269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project getUri()); 4279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project setBodyProvider(mBodyProvider, mBodyLength); 4299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 43052e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba 43152e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba if (mReceivedBytes > 0) { 43252e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba // reset the fail count as we continue the request 43352e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba mFailCount = 0; 43452e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba // set the "Range" header to indicate that the retry will continue 43552e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba // instead of restarting the request 43652e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba HttpLog.v("*** Request.reset() to range:" + mReceivedBytes); 43752e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba mHttpRequest.setHeader("Range", "bytes=" + mReceivedBytes + "-"); 43852e41583f58132ae109c632b51f8419c4c2225d6Grace Kloba } 4399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Pause thread request completes. Used for synchronous requests, 4439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * and testing 4449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void waitUntilComplete() { 4469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized (mClientResource) { 4479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 4489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("Request.waitUntilComplete()"); 4499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mClientResource.wait(); 4509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (HttpLog.LOGV) HttpLog.v("Request.waitUntilComplete() done waiting"); 4519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (InterruptedException e) { 4529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void complete() { 4579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized (mClientResource) { 4589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mClientResource.notifyAll(); 4599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Decide whether a response comes with an entity. 4649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * The implementation in this class is based on RFC 2616. 4659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Unknown methods and response codes are supposed to 4669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * indicate responses with an entity. 4679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * <br/> 4689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Derived executors can override this method to handle 4699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * methods and response codes not specified in RFC 2616. 4709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 4719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param request the request, to obtain the executed method 4729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param response the response, to obtain the status code 4739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static boolean canResponseHaveBody(final HttpRequest request, 4769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project final int status) { 4779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if ("HEAD".equalsIgnoreCase(request.getRequestLine().getMethod())) { 4799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 4809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return status >= HttpStatus.SC_OK 4829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project && status != HttpStatus.SC_NO_CONTENT 483c319c69b1228f5eee2f9d71a71ad021f3d8ba82bPatrick Scott && status != HttpStatus.SC_NOT_MODIFIED; 4849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Supply an InputStream that provides the body of a request. It's 4889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * not great that the caller must also provide the length of the data 4899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * returned by that InputStream, but the client needs to know up 4909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * front, and I'm not sure how to get this out of the InputStream 4919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * itself without a costly readthrough. I'm not sure skip() would 4929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * do what we want. If you know a better way, please let me know. 4939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private void setBodyProvider(InputStream bodyProvider, int bodyLength) { 4959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!bodyProvider.markSupported()) { 4969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project throw new IllegalArgumentException( 4979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "bodyProvider must support mark()"); 4989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Mark beginning of stream 5009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project bodyProvider.mark(Integer.MAX_VALUE); 5019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ((BasicHttpEntityEnclosingRequest)mHttpRequest).setEntity( 5039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project new InputStreamEntity(bodyProvider, bodyLength)); 5049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Handles SSL error(s) on the way down from the user (the user 5099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * has already provided their feedback). 5109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void handleSslErrorResponse(boolean proceed) { 5129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HttpsConnection connection = (HttpsConnection)(mConnection); 5139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (connection != null) { 5149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project connection.restartConnection(proceed); 5159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Helper: calls error() on eventhandler with appropriate message 5209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This should not be called before the mConnection is set. 5219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void error(int errorId, int resourceId) { 5239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mEventHandler.error( 5249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project errorId, 5259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mConnection.mContext.getText( 5269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project resourceId).toString()); 5279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 530