Index: components/cronet/android/java/src/org/chromium/net/impl/UrlRequestBuilderImpl.java |
diff --git a/components/cronet/android/java/src/org/chromium/net/impl/UrlRequestBuilderImpl.java b/components/cronet/android/java/src/org/chromium/net/impl/UrlRequestBuilderImpl.java |
new file mode 100644 |
index 0000000000000000000000000000000000000000..c23bd2a0b4cef205dc82015090cc79b07702fde7 |
--- /dev/null |
+++ b/components/cronet/android/java/src/org/chromium/net/impl/UrlRequestBuilderImpl.java |
@@ -0,0 +1,187 @@ |
+// Copyright 2016 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+package org.chromium.net.impl; |
+ |
+import android.util.Pair; |
+ |
+import org.chromium.base.Log; |
+import org.chromium.net.CronetEngine; |
+import org.chromium.net.ExperimentalUrlRequest; |
+import org.chromium.net.UploadDataProvider; |
+import org.chromium.net.UrlRequest; |
+ |
+import java.util.ArrayList; |
+import java.util.Collection; |
+import java.util.Collections; |
+import java.util.concurrent.Executor; |
+ |
+/** |
+ * Implements {@link org.chromium.net.UrlRequest.Builder} and all experimental features. |
pauljensen
2016/10/03 15:22:38
why not just say ExperimentalUrlRequest.Builder, r
kapishnikov
2016/10/03 23:49:28
Done.
|
+ */ |
+public class UrlRequestBuilderImpl extends ExperimentalUrlRequest.Builder { |
+ private static final String ACCEPT_ENCODING = "Accept-Encoding"; |
+ private static final String TAG = "UrlRequestBuilder"; |
+ |
+ // All fields are temporary storage of UrlRequest configuration to be |
pauljensen
2016/10/03 15:22:38
UrlRequest->ExperimentalUrlRequest
kapishnikov
2016/10/03 23:49:28
Done.
|
+ // copied to built UrlRequests. |
pauljensen
2016/10/03 15:22:38
ditto
kapishnikov
2016/10/03 23:49:28
Done.
|
+ |
+ // CronetEngine to execute request. |
pauljensen
2016/10/03 15:22:38
CronetEngine->CronetEngineBase
kapishnikov
2016/10/03 23:49:28
Done.
|
+ private final CronetEngineBase mCronetEngine; |
+ // URL to request. |
+ private final String mUrl; |
+ // Callback to receive progress callbacks. |
+ private final UrlRequest.Callback mCallback; |
+ // Executor to invoke callback on. |
+ private final Executor mExecutor; |
+ // HTTP method (e.g. GET, POST etc). |
+ private String mMethod; |
+ |
+ // List of request headers, stored as header field name and value pairs. |
+ private final ArrayList<Pair<String, String>> mRequestHeaders = new ArrayList<>(); |
+ // Disable the cache for just this request. |
+ private boolean mDisableCache; |
+ // Disable connection migration for just this request. |
+ private boolean mDisableConnectionMigration; |
+ // Priority of request. Default is medium. |
+ @CronetEngineBase.RequestPriority |
+ private int mPriority = REQUEST_PRIORITY_MEDIUM; |
+ // Request reporting annotations. Avoid extra object creation if no annotations added. |
+ private Collection<Object> mRequestAnnotations = Collections.emptyList(); |
+ // If request is an upload, this provides the request body data. |
+ private UploadDataProvider mUploadDataProvider; |
+ // Executor to call upload data provider back on. |
+ private Executor mUploadDataProviderExecutor; |
+ private boolean mAllowDirectExecutor = false; |
+ |
+ /** |
+ * Creates a builder for {@link UrlRequest} objects. All callbacks for |
+ * generated {@link UrlRequest} objects will be invoked on |
+ * {@code executor}'s thread. {@code executor} must not run tasks on the |
+ * current thread to prevent blocking networking operations and causing |
+ * exceptions during shutdown. |
+ * |
+ * @param url {@link java.net.URL} for the generated requests. |
pauljensen
2016/10/03 15:22:38
remove incorrect @link tag
kapishnikov
2016/10/03 23:49:28
Done.
|
+ * @param callback callback object that gets invoked on different events. |
+ * @param executor {@link Executor} on which all callbacks will be invoked. |
+ * @param cronetEngine {@link CronetEngine} used to execute this request. |
+ */ |
+ UrlRequestBuilderImpl(String url, UrlRequest.Callback callback, Executor executor, |
+ CronetEngineBase cronetEngine) { |
+ super(); |
+ if (url == null) { |
+ throw new NullPointerException("URL is required."); |
+ } |
+ if (callback == null) { |
+ throw new NullPointerException("Callback is required."); |
+ } |
+ if (executor == null) { |
+ throw new NullPointerException("Executor is required."); |
+ } |
+ if (cronetEngine == null) { |
+ throw new NullPointerException("CronetEngine is required."); |
+ } |
+ mUrl = url; |
+ mCallback = callback; |
+ mExecutor = executor; |
+ mCronetEngine = cronetEngine; |
+ } |
+ |
+ @Override |
+ public ExperimentalUrlRequest.Builder setHttpMethod(String method) { |
+ if (method == null) { |
+ throw new NullPointerException("Method is required."); |
+ } |
+ mMethod = method; |
+ return this; |
+ } |
+ |
+ @Override |
+ public UrlRequestBuilderImpl addHeader(String header, String value) { |
+ if (header == null) { |
+ throw new NullPointerException("Invalid header name."); |
+ } |
+ if (value == null) { |
+ throw new NullPointerException("Invalid header value."); |
+ } |
+ if (ACCEPT_ENCODING.equalsIgnoreCase(header)) { |
+ Log.w(TAG, "It's not necessary to set Accept-Encoding on requests - cronet will do" |
+ + " this automatically for you, and setting it yourself has no " |
+ + "effect. See https://crbug.com/581399 for details.", |
+ new Exception()); |
+ return this; |
+ } |
+ mRequestHeaders.add(Pair.create(header, value)); |
+ return this; |
+ } |
+ |
+ @Override |
+ public UrlRequestBuilderImpl disableCache() { |
+ mDisableCache = true; |
+ return this; |
+ } |
+ |
+ @Override |
+ public UrlRequestBuilderImpl disableConnectionMigration() { |
+ mDisableConnectionMigration = true; |
+ return this; |
+ } |
+ |
+ @Override |
+ public UrlRequestBuilderImpl setPriority(@CronetEngineBase.RequestPriority int priority) { |
+ mPriority = priority; |
+ return this; |
+ } |
+ |
+ @Override |
+ public UrlRequestBuilderImpl setUploadDataProvider( |
+ UploadDataProvider uploadDataProvider, Executor executor) { |
+ if (uploadDataProvider == null) { |
+ throw new NullPointerException("Invalid UploadDataProvider."); |
+ } |
+ if (executor == null) { |
+ throw new NullPointerException("Invalid UploadDataProvider Executor."); |
+ } |
+ if (mMethod == null) { |
+ mMethod = "POST"; |
+ } |
+ mUploadDataProvider = uploadDataProvider; |
+ mUploadDataProviderExecutor = executor; |
+ return this; |
+ } |
+ |
+ @Override |
+ public UrlRequestBuilderImpl allowDirectExecutor() { |
+ mAllowDirectExecutor = true; |
+ return this; |
+ } |
+ |
+ @Override |
+ public UrlRequestBuilderImpl addRequestAnnotation(Object annotation) { |
+ if (annotation == null) { |
+ throw new NullPointerException("Invalid metrics annotation."); |
+ } |
+ if (mRequestAnnotations.isEmpty()) { |
+ mRequestAnnotations = new ArrayList<>(); |
+ } |
+ mRequestAnnotations.add(annotation); |
+ return this; |
+ } |
+ |
+ @Override |
+ public UrlRequestBase build() { |
+ final UrlRequestBase request = mCronetEngine.createRequest(mUrl, mCallback, mExecutor, |
+ mPriority, mRequestAnnotations, mDisableCache, mDisableConnectionMigration, |
+ mAllowDirectExecutor); |
+ if (mMethod != null) { |
+ request.setHttpMethod(mMethod); |
+ } |
+ for (Pair<String, String> header : mRequestHeaders) { |
+ request.addHeader(header.first, header.second); |
+ } |
+ if (mUploadDataProvider != null) { |
+ request.setUploadDataProvider(mUploadDataProvider, mUploadDataProviderExecutor); |
+ } |
+ return request; |
+ } |
+} |