Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1255)

Unified Diff: components/cronet/android/test/javatests/src/org/chromium/net/QuicTest.java

Issue 2339223002: Cronet API Refactoring (Closed)
Patch Set: Rebase & Conflict Resolution Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: components/cronet/android/test/javatests/src/org/chromium/net/QuicTest.java
diff --git a/components/cronet/android/test/javatests/src/org/chromium/net/QuicTest.java b/components/cronet/android/test/javatests/src/org/chromium/net/QuicTest.java
index bd94619fb5d80644c56869e492716f323a583519..4581326438167d2ca07835677655d454b7321c5b 100644
--- a/components/cronet/android/test/javatests/src/org/chromium/net/QuicTest.java
+++ b/components/cronet/android/test/javatests/src/org/chromium/net/QuicTest.java
@@ -29,7 +29,7 @@ import java.util.concurrent.Executors;
public class QuicTest extends CronetTestBase {
private static final String TAG = "cr.QuicTest";
private CronetTestFramework mTestFramework;
- private CronetEngine.Builder mBuilder;
+ private ExperimentalCronetEngine.Builder mBuilder;
@Override
protected void setUp() throws Exception {
@@ -38,8 +38,8 @@ public class QuicTest extends CronetTestBase {
System.loadLibrary("cronet_tests");
QuicTestServer.startQuicTestServer(getContext());
- mBuilder = new CronetEngine.Builder(getContext());
- mBuilder.enableQuic(true).enableNetworkQualityEstimator(true);
+ mBuilder = new ExperimentalCronetEngine.Builder(getContext());
+ mBuilder.enableNetworkQualityEstimator(true).enableQuic(true);
mBuilder.addQuicHint(QuicTestServer.getServerHost(), QuicTestServer.getServerPort(),
QuicTestServer.getServerPort());
@@ -59,9 +59,10 @@ public class QuicTest extends CronetTestBase {
.put("QUIC", quicParams)
.put("HostResolverRules", hostResolverParams);
mBuilder.setExperimentalOptions(experimentalOptions.toString());
- mBuilder.setMockCertVerifierForTesting(QuicTestServer.createMockCertVerifier());
mBuilder.setStoragePath(CronetTestFramework.getTestStorage(getContext()));
mBuilder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK_NO_HTTP, 1000 * 1024);
+ CronetTestUtil.setMockCertVerifierForTesting(
+ mBuilder, QuicTestServer.createMockCertVerifier());
}
@Override
@@ -82,8 +83,8 @@ public class QuicTest extends CronetTestBase {
// since there is no http server running on the corresponding TCP port,
// QUIC will always succeed with a 200 (see
// net::HttpStreamFactoryImpl::Request::OnStreamFailed).
- UrlRequest.Builder requestBuilder = new UrlRequest.Builder(
- quicURL, callback, callback.getExecutor(), mTestFramework.mCronetEngine);
+ UrlRequest.Builder requestBuilder = mTestFramework.mCronetEngine.newUrlRequestBuilder(
+ quicURL, callback, callback.getExecutor());
requestBuilder.build().start();
callback.blockForDone();
@@ -112,7 +113,8 @@ public class QuicTest extends CronetTestBase {
mTestFramework.mCronetEngine.shutdown();
// Make another request using a new context but with no QUIC hints.
- CronetEngine.Builder builder = new CronetEngine.Builder(getContext());
+ ExperimentalCronetEngine.Builder builder =
+ new ExperimentalCronetEngine.Builder(getContext());
builder.setStoragePath(CronetTestFramework.getTestStorage(getContext()));
builder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK, 1000 * 1024);
builder.enableQuic(true);
@@ -122,11 +124,12 @@ public class QuicTest extends CronetTestBase {
.put("QUIC", quicParams)
.put("HostResolverRules", hostResolverParams);
builder.setExperimentalOptions(experimentalOptions.toString());
- builder.setMockCertVerifierForTesting(QuicTestServer.createMockCertVerifier());
+ CronetTestUtil.setMockCertVerifierForTesting(
+ builder, QuicTestServer.createMockCertVerifier());
mTestFramework = startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, builder);
TestUrlRequestCallback callback2 = new TestUrlRequestCallback();
- requestBuilder = new UrlRequest.Builder(
- quicURL, callback2, callback2.getExecutor(), mTestFramework.mCronetEngine);
+ requestBuilder = mTestFramework.mCronetEngine.newUrlRequestBuilder(
+ quicURL, callback2, callback2.getExecutor());
requestBuilder.build().start();
callback2.blockForDone();
assertEquals(200, callback2.mResponseInfo.getHttpStatusCode());
@@ -174,8 +177,8 @@ public class QuicTest extends CronetTestBase {
// since there is no http server running on the corresponding TCP port,
// QUIC will always succeed with a 200 (see
// net::HttpStreamFactoryImpl::Request::OnStreamFailed).
- UrlRequest.Builder requestBuilder = new UrlRequest.Builder(
- quicURL, callback, callback.getExecutor(), mTestFramework.mCronetEngine);
+ UrlRequest.Builder requestBuilder = mTestFramework.mCronetEngine.newUrlRequestBuilder(
+ quicURL, callback, callback.getExecutor());
requestBuilder.build().start();
callback.blockForDone();
@@ -217,8 +220,8 @@ public class QuicTest extends CronetTestBase {
String quicURL = QuicTestServer.getServerURL() + "/simple.txt";
TestUrlRequestCallback callback = new TestUrlRequestCallback();
- UrlRequest.Builder requestBuilder = new UrlRequest.Builder(
- quicURL, callback, callback.getExecutor(), mTestFramework.mCronetEngine);
+ UrlRequest.Builder requestBuilder = mTestFramework.mCronetEngine.newUrlRequestBuilder(
+ quicURL, callback, callback.getExecutor());
Date startTime = new Date();
requestBuilder.build().start();
callback.blockForDone();
@@ -236,8 +239,8 @@ public class QuicTest extends CronetTestBase {
// Second request should use the same connection and not have ConnectTiming numbers
callback = new TestUrlRequestCallback();
requestFinishedListener.reset();
- requestBuilder = new UrlRequest.Builder(
- quicURL, callback, callback.getExecutor(), mTestFramework.mCronetEngine);
+ requestBuilder = mTestFramework.mCronetEngine.newUrlRequestBuilder(
+ quicURL, callback, callback.getExecutor());
startTime = new Date();
requestBuilder.build().start();
callback.blockForDone();

Powered by Google App Engine
This is Rietveld 408576698