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..48bd9d17711097ae9efacc053579efdef7c5010c 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 |
@@ -57,7 +56,7 @@ public class QuicTest extends CronetTestBase { |
.put("QUIC", quicParams) |
.put("HostResolverRules", hostResolverParams); |
mBuilder.setExperimentalOptions(experimentalOptions.toString()); |
- mBuilder.setStoragePath(CronetTestFramework.getTestStorage(getContext())); |
+ mBuilder.setStoragePath(getTestStorage(getContext())); |
mBuilder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK_NO_HTTP, 1000 * 1024); |
CronetTestUtil.setMockCertVerifierForTesting( |
mBuilder, QuicTestServer.createMockCertVerifier()); |
@@ -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,12 +107,12 @@ 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 = |
new ExperimentalCronetEngine.Builder(getContext()); |
- builder.setStoragePath(CronetTestFramework.getTestStorage(getContext())); |
+ builder.setStoragePath(getTestStorage(getContext())); |
builder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK, 1000 * 1024); |
builder.enableQuic(true); |
JSONObject hostResolverParams = CronetTestUtil.generateHostResolverRules(); |
@@ -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()); |
@@ -139,8 +138,7 @@ public class QuicTest extends CronetTestBase { |
// Returns whether a file contains a particular string. |
@SuppressFBWarnings("OBL_UNSATISFIED_OBLIGATION_EXCEPTION_EDGE") |
private boolean fileContainsString(String filename, String content) throws IOException { |
- File file = |
- new File(CronetTestFramework.getTestStorage(getContext()) + "/prefs/" + filename); |
+ File file = new File(getTestStorage(getContext()) + "/prefs/" + filename); |
FileInputStream fileInputStream = new FileInputStream(file); |
byte[] data = new byte[(int) file.length()]; |
fileInputStream.read(data); |
@@ -156,7 +154,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 +162,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 +202,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 +225,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 +258,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 +274,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. |