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 bc805c458cb90111ec68a3922c4715e1d05f8250..5beff65c36644bc9d83482d473ee9aa84cadfe0b 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 |
@@ -28,7 +28,6 @@ import java.util.concurrent.Executors; |
public class QuicTest extends CronetTestBase { |
private static final String TAG = QuicTest.class.getSimpleName(); |
private static final String QUIC_PROTOCOL_STRING_PREFIX = "http/2+quic/"; |
- private CronetTestFramework mTestFramework; |
private ExperimentalCronetEngine.Builder mBuilder; |
@Override |
@@ -73,7 +72,7 @@ public class QuicTest extends CronetTestBase { |
@Feature({"Cronet"}) |
@OnlyRunNativeCronet |
public void testQuicLoadUrl() throws Exception { |
- mTestFramework = startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, mBuilder); |
+ ExperimentalCronetEngine cronetEngine = mBuilder.build(); |
String quicURL = QuicTestServer.getServerURL() + "/simple.txt"; |
TestUrlRequestCallback callback = new TestUrlRequestCallback(); |
@@ -81,8 +80,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 = mTestFramework.mCronetEngine.newUrlRequestBuilder( |
- quicURL, callback, callback.getExecutor()); |
+ UrlRequest.Builder requestBuilder = |
+ cronetEngine.newUrlRequestBuilder(quicURL, callback, callback.getExecutor()); |
requestBuilder.build().start(); |
callback.blockForDone(); |
@@ -108,7 +107,7 @@ public class QuicTest extends CronetTestBase { |
} |
assertTrue(fileContainsString("local_prefs.json", |
QuicTestServer.getServerHost() + ":" + QuicTestServer.getServerPort())); |
- mTestFramework.mCronetEngine.shutdown(); |
+ cronetEngine.shutdown(); |
// Make another request using a new context but with no QUIC hints. |
ExperimentalCronetEngine.Builder builder = |
@@ -122,10 +121,10 @@ public class QuicTest extends CronetTestBase { |
builder.setExperimentalOptions(experimentalOptions.toString()); |
CronetTestUtil.setMockCertVerifierForTesting( |
builder, QuicTestServer.createMockCertVerifier()); |
- mTestFramework = startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, builder); |
+ cronetEngine = builder.build(); |
TestUrlRequestCallback callback2 = new TestUrlRequestCallback(); |
- requestBuilder = mTestFramework.mCronetEngine.newUrlRequestBuilder( |
- quicURL, callback2, callback2.getExecutor()); |
+ requestBuilder = |
+ cronetEngine.newUrlRequestBuilder(quicURL, callback2, callback2.getExecutor()); |
requestBuilder.build().start(); |
callback2.blockForDone(); |
assertEquals(200, callback2.mResponseInfo.getHttpStatusCode()); |
@@ -156,7 +155,7 @@ public class QuicTest extends CronetTestBase { |
@OnlyRunNativeCronet |
@SuppressWarnings("deprecation") |
public void testNQEWithQuic() throws Exception { |
- mTestFramework = startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, mBuilder); |
+ ExperimentalCronetEngine cronetEngine = mBuilder.build(); |
String quicURL = QuicTestServer.getServerURL() + "/simple.txt"; |
TestNetworkQualityRttListener rttListener = |
@@ -164,18 +163,18 @@ public class QuicTest extends CronetTestBase { |
TestNetworkQualityThroughputListener throughputListener = |
new TestNetworkQualityThroughputListener(Executors.newSingleThreadExecutor()); |
- mTestFramework.mCronetEngine.addRttListener(rttListener); |
- mTestFramework.mCronetEngine.addThroughputListener(throughputListener); |
+ cronetEngine.addRttListener(rttListener); |
+ cronetEngine.addThroughputListener(throughputListener); |
- mTestFramework.mCronetEngine.configureNetworkQualityEstimatorForTesting(true, true, true); |
+ cronetEngine.configureNetworkQualityEstimatorForTesting(true, true, true); |
TestUrlRequestCallback callback = new TestUrlRequestCallback(); |
// Although the native stack races QUIC and SPDY for the first request, |
// 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 = mTestFramework.mCronetEngine.newUrlRequestBuilder( |
- quicURL, callback, callback.getExecutor()); |
+ UrlRequest.Builder requestBuilder = |
+ cronetEngine.newUrlRequestBuilder(quicURL, callback, callback.getExecutor()); |
requestBuilder.build().start(); |
callback.blockForDone(); |
@@ -204,14 +203,14 @@ public class QuicTest extends CronetTestBase { |
// Verify that effective connection type callback is received and |
// effective connection type is correctly set. |
- assertTrue(mTestFramework.mCronetEngine.getEffectiveConnectionType() |
- != EffectiveConnectionType.TYPE_UNKNOWN); |
+ assertTrue( |
+ cronetEngine.getEffectiveConnectionType() != EffectiveConnectionType.TYPE_UNKNOWN); |
// Verify that the HTTP RTT, transport RTT and downstream throughput |
// estimates are available. |
- assertTrue(mTestFramework.mCronetEngine.getHttpRttMs() >= 0); |
- assertTrue(mTestFramework.mCronetEngine.getTransportRttMs() >= 0); |
- assertTrue(mTestFramework.mCronetEngine.getDownstreamThroughputKbps() >= 0); |
+ assertTrue(cronetEngine.getHttpRttMs() >= 0); |
+ assertTrue(cronetEngine.getTransportRttMs() >= 0); |
+ assertTrue(cronetEngine.getDownstreamThroughputKbps() >= 0); |
// Verify that the cached estimates were written to the prefs. |
while (true) { |
@@ -227,22 +226,22 @@ public class QuicTest extends CronetTestBase { |
} |
} |
assertTrue(fileContainsString("local_prefs.json", "network_qualities")); |
- mTestFramework.mCronetEngine.shutdown(); |
+ cronetEngine.shutdown(); |
} |
@SmallTest |
@OnlyRunNativeCronet |
@Feature({"Cronet"}) |
public void testMetricsWithQuic() throws Exception { |
- mTestFramework = startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, mBuilder); |
+ ExperimentalCronetEngine cronetEngine = mBuilder.build(); |
TestRequestFinishedListener requestFinishedListener = new TestRequestFinishedListener(); |
- mTestFramework.mCronetEngine.addRequestFinishedListener(requestFinishedListener); |
+ cronetEngine.addRequestFinishedListener(requestFinishedListener); |
String quicURL = QuicTestServer.getServerURL() + "/simple.txt"; |
TestUrlRequestCallback callback = new TestUrlRequestCallback(); |
- UrlRequest.Builder requestBuilder = mTestFramework.mCronetEngine.newUrlRequestBuilder( |
- quicURL, callback, callback.getExecutor()); |
+ UrlRequest.Builder requestBuilder = |
+ cronetEngine.newUrlRequestBuilder(quicURL, callback, callback.getExecutor()); |
Date startTime = new Date(); |
requestBuilder.build().start(); |
callback.blockForDone(); |
@@ -260,8 +259,8 @@ public class QuicTest extends CronetTestBase { |
// Second request should use the same connection and not have ConnectTiming numbers |
callback = new TestUrlRequestCallback(); |
requestFinishedListener.reset(); |
- requestBuilder = mTestFramework.mCronetEngine.newUrlRequestBuilder( |
- quicURL, callback, callback.getExecutor()); |
+ requestBuilder = |
+ cronetEngine.newUrlRequestBuilder(quicURL, callback, callback.getExecutor()); |
startTime = new Date(); |
requestBuilder.build().start(); |
callback.blockForDone(); |
@@ -276,7 +275,7 @@ public class QuicTest extends CronetTestBase { |
assertEquals(RequestFinishedInfo.SUCCEEDED, requestInfo.getFinishedReason()); |
MetricsTestUtil.checkNoConnectTiming(requestInfo.getMetrics()); |
- mTestFramework.mCronetEngine.shutdown(); |
+ cronetEngine.shutdown(); |
} |
// Helper method to assert that the request is negotiated over QUIC. |