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..8726e2aa237b39ec10109021cb70b5ad917c95a4 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,9 @@ 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 UrlRequest mRequest; |
private final List<Pair<String, String>> mRequestHeaders; |
private CronetInputStream mInputStream; |
@@ -48,13 +48,10 @@ 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); |
mInputStream = new CronetInputStream(this); |
mRequestHeaders = new ArrayList<Pair<String, String>>(); |
} |
@@ -255,9 +252,12 @@ class CronetHttpURLConnection extends HttpURLConnection { |
if (connected) { |
return; |
} |
+ final UrlRequest.Builder requestBuilder = new UrlRequest.Builder( |
+ getURL().toString(), new CronetUrlRequestListener(), mMessageLoop, mCronetEngine); |
if (doOutput) { |
if (mOutputStream != null) { |
- mRequest.setUploadDataProvider(mOutputStream.getUploadDataProvider(), mMessageLoop); |
+ requestBuilder.setUploadDataProvider( |
+ mOutputStream.getUploadDataProvider(), mMessageLoop); |
if (getRequestProperty(CONTENT_LENGTH) == null && !isChunkedUpload()) { |
addRequestProperty(CONTENT_LENGTH, |
Long.toString(mOutputStream.getUploadDataProvider().getLength())); |
@@ -277,12 +277,13 @@ class CronetHttpURLConnection extends HttpURLConnection { |
} |
} |
for (Pair<String, String> requestHeader : mRequestHeaders) { |
- mRequest.addHeader(requestHeader.first, requestHeader.second); |
+ requestBuilder.addHeader(requestHeader.first, requestHeader.second); |
} |
if (!getUseCaches()) { |
- mRequest.disableCache(); |
+ requestBuilder.disableCache(); |
} |
connected = true; |
+ mRequest = requestBuilder.build(); |
// Start the request. |
mRequest.start(); |
} |