Index: components/cronet/android/java/src/org/chromium/net/urlconnection/CronetHttpURLConnection.java |
diff --git a/components/cronet/android/java/src/org/chromium/net/urlconnection/CronetHttpURLConnection.java b/components/cronet/android/java/src/org/chromium/net/urlconnection/CronetHttpURLConnection.java |
index 89bf7b69035c66835b24b6b39b535c90b16931e5..f5e4bcde06df4adc2e39194d4bb60feef526412e 100644 |
--- a/components/cronet/android/java/src/org/chromium/net/urlconnection/CronetHttpURLConnection.java |
+++ b/components/cronet/android/java/src/org/chromium/net/urlconnection/CronetHttpURLConnection.java |
@@ -7,10 +7,10 @@ package org.chromium.net.urlconnection; |
import android.util.Pair; |
import org.chromium.base.Log; |
+import org.chromium.net.CronetEngine; |
import org.chromium.net.ExtendedResponseInfo; |
import org.chromium.net.ResponseInfo; |
import org.chromium.net.UrlRequest; |
-import org.chromium.net.UrlRequestContext; |
import org.chromium.net.UrlRequestException; |
import org.chromium.net.UrlRequestListener; |
@@ -36,9 +36,10 @@ import java.util.TreeMap; |
class CronetHttpURLConnection extends HttpURLConnection { |
private static final String TAG = "cr.CronetHttpURLConn"; |
private static final String CONTENT_LENGTH = "Content-Length"; |
- private final UrlRequestContext mUrlRequestContext; |
+ private final CronetEngine mCronetEngine; |
private final MessageLoop mMessageLoop; |
- private final UrlRequest mRequest; |
+ private final UrlRequest.Builder mRequestBuilder; |
+ private UrlRequest mRequest; |
private final List<Pair<String, String>> mRequestHeaders; |
private CronetInputStream mInputStream; |
@@ -48,13 +49,12 @@ class CronetHttpURLConnection extends HttpURLConnection { |
private boolean mOnRedirectCalled = false; |
private boolean mHasResponse = false; |
- public CronetHttpURLConnection(URL url, |
- UrlRequestContext urlRequestContext) { |
+ public CronetHttpURLConnection(URL url, CronetEngine cronetEngine) { |
super(url); |
- mUrlRequestContext = urlRequestContext; |
+ mCronetEngine = cronetEngine; |
mMessageLoop = new MessageLoop(); |
- mRequest = mUrlRequestContext.createRequest(url.toString(), |
- new CronetUrlRequestListener(), mMessageLoop); |
+ mRequestBuilder = new UrlRequest.Builder( |
+ url.toString(), new CronetUrlRequestListener(), mMessageLoop); |
mInputStream = new CronetInputStream(this); |
mRequestHeaders = new ArrayList<Pair<String, String>>(); |
} |
@@ -257,7 +257,8 @@ class CronetHttpURLConnection extends HttpURLConnection { |
} |
if (doOutput) { |
if (mOutputStream != null) { |
- mRequest.setUploadDataProvider(mOutputStream.getUploadDataProvider(), mMessageLoop); |
+ mRequestBuilder.setUploadDataProvider( |
+ mOutputStream.getUploadDataProvider(), mMessageLoop); |
if (getRequestProperty(CONTENT_LENGTH) == null && !isChunkedUpload()) { |
addRequestProperty(CONTENT_LENGTH, |
Long.toString(mOutputStream.getUploadDataProvider().getLength())); |
@@ -277,14 +278,14 @@ class CronetHttpURLConnection extends HttpURLConnection { |
} |
} |
for (Pair<String, String> requestHeader : mRequestHeaders) { |
- mRequest.addHeader(requestHeader.first, requestHeader.second); |
+ mRequestBuilder.addHeader(requestHeader.first, requestHeader.second); |
} |
if (!getUseCaches()) { |
- mRequest.disableCache(); |
+ mRequestBuilder.disableCache(); |
} |
connected = true; |
// Start the request. |
- mRequest.start(); |
+ mRequest = mCronetEngine.executeRequest(mRequestBuilder); |
} |
/** |