| 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);
|
| }
|
|
|
| /**
|
|
|