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

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

Issue 2892013002: [Cronet] Clean up tests (Closed)
Patch Set: address comments Created 3 years, 7 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 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.

Powered by Google App Engine
This is Rietveld 408576698