| Index: components/cronet/android/test/javatests/src/org/chromium/net/NQETest.java
|
| diff --git a/components/cronet/android/test/javatests/src/org/chromium/net/NQETest.java b/components/cronet/android/test/javatests/src/org/chromium/net/NQETest.java
|
| index 905a83a524e0fa1c4d9751f83c8997db778963af..65cd6c1e9b961e0bc98146a14419a79ff4dcde47 100644
|
| --- a/components/cronet/android/test/javatests/src/org/chromium/net/NQETest.java
|
| +++ b/components/cronet/android/test/javatests/src/org/chromium/net/NQETest.java
|
| @@ -69,61 +69,59 @@ public class NQETest extends CronetTestBase {
|
| @SmallTest
|
| @Feature({"Cronet"})
|
| public void testNotEnabled() throws Exception {
|
| - ExperimentalCronetEngine.Builder mCronetEngineBuilder =
|
| + ExperimentalCronetEngine.Builder cronetEngineBuilder =
|
| new ExperimentalCronetEngine.Builder(getContext());
|
| - final CronetTestFramework testFramework =
|
| - startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, mCronetEngineBuilder);
|
| + final ExperimentalCronetEngine cronetEngine = cronetEngineBuilder.build();
|
| Executor networkQualityExecutor = Executors.newSingleThreadExecutor();
|
| TestNetworkQualityRttListener rttListener =
|
| new TestNetworkQualityRttListener(networkQualityExecutor);
|
| TestNetworkQualityThroughputListener throughputListener =
|
| new TestNetworkQualityThroughputListener(networkQualityExecutor);
|
| try {
|
| - testFramework.mCronetEngine.addRttListener(rttListener);
|
| + cronetEngine.addRttListener(rttListener);
|
| fail("Should throw an exception.");
|
| } catch (IllegalStateException e) {
|
| }
|
| try {
|
| - testFramework.mCronetEngine.addThroughputListener(throughputListener);
|
| + cronetEngine.addThroughputListener(throughputListener);
|
| fail("Should throw an exception.");
|
| } catch (IllegalStateException e) {
|
| }
|
| TestUrlRequestCallback callback = new TestUrlRequestCallback();
|
| - UrlRequest.Builder builder = testFramework.mCronetEngine.newUrlRequestBuilder(
|
| - mUrl, callback, callback.getExecutor());
|
| + UrlRequest.Builder builder =
|
| + cronetEngine.newUrlRequestBuilder(mUrl, callback, callback.getExecutor());
|
| UrlRequest urlRequest = builder.build();
|
|
|
| urlRequest.start();
|
| callback.blockForDone();
|
| assertEquals(0, rttListener.rttObservationCount());
|
| assertEquals(0, throughputListener.throughputObservationCount());
|
| - testFramework.mCronetEngine.shutdown();
|
| + cronetEngine.shutdown();
|
| }
|
|
|
| @SmallTest
|
| @Feature({"Cronet"})
|
| public void testListenerRemoved() throws Exception {
|
| - ExperimentalCronetEngine.Builder mCronetEngineBuilder =
|
| + ExperimentalCronetEngine.Builder cronetEngineBuilder =
|
| new ExperimentalCronetEngine.Builder(getContext());
|
| TestExecutor networkQualityExecutor = new TestExecutor();
|
| TestNetworkQualityRttListener rttListener =
|
| new TestNetworkQualityRttListener(networkQualityExecutor);
|
| - mCronetEngineBuilder.enableNetworkQualityEstimator(true);
|
| - final CronetTestFramework testFramework =
|
| - startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, mCronetEngineBuilder);
|
| - testFramework.mCronetEngine.configureNetworkQualityEstimatorForTesting(true, true, false);
|
| + cronetEngineBuilder.enableNetworkQualityEstimator(true);
|
| + final ExperimentalCronetEngine cronetEngine = cronetEngineBuilder.build();
|
| + cronetEngine.configureNetworkQualityEstimatorForTesting(true, true, false);
|
|
|
| - testFramework.mCronetEngine.addRttListener(rttListener);
|
| - testFramework.mCronetEngine.removeRttListener(rttListener);
|
| + cronetEngine.addRttListener(rttListener);
|
| + cronetEngine.removeRttListener(rttListener);
|
| TestUrlRequestCallback callback = new TestUrlRequestCallback();
|
| - UrlRequest.Builder builder = testFramework.mCronetEngine.newUrlRequestBuilder(
|
| - mUrl, callback, callback.getExecutor());
|
| + UrlRequest.Builder builder =
|
| + cronetEngine.newUrlRequestBuilder(mUrl, callback, callback.getExecutor());
|
| UrlRequest urlRequest = builder.build();
|
| urlRequest.start();
|
| callback.blockForDone();
|
| networkQualityExecutor.runAllTasks();
|
| assertEquals(0, rttListener.rttObservationCount());
|
| - testFramework.mCronetEngine.shutdown();
|
| + cronetEngine.shutdown();
|
| }
|
|
|
| // Returns whether a file contains a particular string.
|
| @@ -142,7 +140,7 @@ public class NQETest extends CronetTestBase {
|
| @Feature({"Cronet"})
|
| @DisabledTest(message = "Disabled due to flaky assert. See crbug.com/710626")
|
| public void testQuicDisabled() throws Exception {
|
| - ExperimentalCronetEngine.Builder mCronetEngineBuilder =
|
| + ExperimentalCronetEngine.Builder cronetEngineBuilder =
|
| new ExperimentalCronetEngine.Builder(getContext());
|
| assert RttThroughputValues.INVALID_RTT_THROUGHPUT < 0;
|
| Executor listenersExecutor = Executors.newSingleThreadExecutor(new ExecutorThreadFactory());
|
| @@ -150,15 +148,13 @@ public class NQETest extends CronetTestBase {
|
| new TestNetworkQualityRttListener(listenersExecutor);
|
| TestNetworkQualityThroughputListener throughputListener =
|
| new TestNetworkQualityThroughputListener(listenersExecutor);
|
| - mCronetEngineBuilder.enableNetworkQualityEstimator(true).enableHttp2(true).enableQuic(
|
| - false);
|
| - mCronetEngineBuilder.setStoragePath(CronetTestFramework.getTestStorage(getContext()));
|
| - final CronetTestFramework testFramework =
|
| - startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, mCronetEngineBuilder);
|
| - testFramework.mCronetEngine.configureNetworkQualityEstimatorForTesting(true, true, true);
|
| + cronetEngineBuilder.enableNetworkQualityEstimator(true).enableHttp2(true).enableQuic(false);
|
| + cronetEngineBuilder.setStoragePath(CronetTestFramework.getTestStorage(getContext()));
|
| + final ExperimentalCronetEngine cronetEngine = cronetEngineBuilder.build();
|
| + cronetEngine.configureNetworkQualityEstimatorForTesting(true, true, true);
|
|
|
| - testFramework.mCronetEngine.addRttListener(rttListener);
|
| - testFramework.mCronetEngine.addThroughputListener(throughputListener);
|
| + cronetEngine.addRttListener(rttListener);
|
| + cronetEngine.addThroughputListener(throughputListener);
|
|
|
| HistogramDelta writeCountHistogram = new HistogramDelta("NQE.Prefs.WriteCount", 1);
|
| assertEquals(0, writeCountHistogram.getDelta()); // Sanity check.
|
| @@ -167,8 +163,8 @@ public class NQETest extends CronetTestBase {
|
| assertEquals(0, readCountHistogram.getDelta()); // Sanity check.
|
|
|
| TestUrlRequestCallback callback = new TestUrlRequestCallback();
|
| - UrlRequest.Builder builder = testFramework.mCronetEngine.newUrlRequestBuilder(
|
| - mUrl, callback, callback.getExecutor());
|
| + UrlRequest.Builder builder =
|
| + cronetEngine.newUrlRequestBuilder(mUrl, callback, callback.getExecutor());
|
| UrlRequest urlRequest = builder.build();
|
| urlRequest.start();
|
| callback.blockForDone();
|
| @@ -205,14 +201,14 @@ public class NQETest extends CronetTestBase {
|
|
|
| // Verify that effective connection type callback is received and
|
| // effective connection type is correctly set.
|
| - assertTrue(testFramework.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(testFramework.mCronetEngine.getHttpRttMs() >= 0);
|
| - assertTrue(testFramework.mCronetEngine.getTransportRttMs() >= 0);
|
| - assertTrue(testFramework.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) {
|
| @@ -229,7 +225,7 @@ public class NQETest extends CronetTestBase {
|
| }
|
| assertTrue(fileContainsString("local_prefs.json", "network_qualities"));
|
|
|
| - testFramework.mCronetEngine.shutdown();
|
| + cronetEngine.shutdown();
|
| assertTrue(writeCountHistogram.getDelta() > 0);
|
| }
|
| }
|
|
|