| 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.
|
|
|