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

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

Issue 1363723002: [Cronet] Create Builders, rename UrlRequestContext to CronetEngine (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 3 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/CronetUrlRequestContextTest.java
diff --git a/components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java b/components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java
index d9cc5578e7169c741dd1b7ec1095a251996df6bc..531f43aa41513a3e3e2d92096d035a587481ef64 100644
--- a/components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java
+++ b/components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java
@@ -50,11 +50,11 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
@Override
public void run() {
mRunBlocker.block();
- UrlRequestContext requestContext = mActivity.initRequestContext();
+ CronetEngine cronetEngine = mActivity.initCronetEngine();
mListener = new TestUrlRequestListener();
- UrlRequest urlRequest =
- requestContext.createRequest(mUrl, mListener, mListener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(mUrl, mListener, mListener.getExecutor());
+ cronetEngine.executeRequest(builder);
mListener.blockForDone();
}
}
@@ -67,7 +67,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
@Override
public void onSucceeded(UrlRequest request, ExtendedResponseInfo info) {
super.onSucceeded(request, info);
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
}
@Override
@@ -75,7 +75,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
ResponseInfo info,
UrlRequestException error) {
super.onFailed(request, info, error);
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
}
}
@@ -84,21 +84,18 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
public void testConfigUserAgent() throws Exception {
String userAgentName = "User-Agent";
String userAgentValue = "User-Agent-Value";
- UrlRequestContextConfig config = new UrlRequestContextConfig();
- config.setUserAgent(userAgentValue);
- config.setLibraryName("cronet_tests");
- String[] commandLineArgs = {
- CronetTestActivity.CONFIG_KEY, config.toString()
- };
+ CronetEngine.Builder cronetEngineBuilder = new CronetEngine.Builder();
+ cronetEngineBuilder.setUserAgent(userAgentValue);
+ cronetEngineBuilder.setLibraryName("cronet_tests");
+ String[] commandLineArgs = {CronetTestActivity.CONFIG_KEY, cronetEngineBuilder.toString()};
mActivity = launchCronetTestAppWithUrlAndCommandLineArgs(TEST_URL,
commandLineArgs);
assertTrue(NativeTestServer.startNativeTestServer(
getInstrumentation().getTargetContext()));
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- NativeTestServer.getEchoHeaderURL(userAgentName), listener,
- listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder = new UrlRequest.Builder(
+ NativeTestServer.getEchoHeaderURL(userAgentName), listener, listener.getExecutor());
+ mActivity.mCronetEngine.executeRequest(builder);
mef 2015/09/25 21:32:19 I wonder if anybody is using a pattern where they
pauljensen 2015/09/28 14:18:12 Potentially but they can now create the UrlRequest
listener.blockForDone();
assertEquals(userAgentValue, listener.mResponseAsString);
}
@@ -109,9 +106,9 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
mActivity = launchCronetTestAppAndSkipFactoryInit();
// Ensure native code is loaded before trying to start test server.
- UrlRequestContext.createContext(
- getInstrumentation().getTargetContext(),
- new UrlRequestContextConfig().setLibraryName("cronet_tests"))
+ new CronetEngine.Builder()
+ .setLibraryName("cronet_tests")
+ .build(getInstrumentation().getTargetContext())
.shutdown();
assertTrue(NativeTestServer.startNativeTestServer(
@@ -124,23 +121,22 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
// Enable the Data Reduction Proxy and configure it to use the test
// server as its primary proxy, and to check successfully that this
// proxy is OK to use.
- UrlRequestContextConfig config = new UrlRequestContextConfig();
- config.enableDataReductionProxy("test-key");
- config.setDataReductionProxyOptions(
- serverHostPort, "unused.net:9999",
+ CronetEngine.Builder cronetEngineBuilder = new CronetEngine.Builder();
+ cronetEngineBuilder.enableDataReductionProxy("test-key");
+ cronetEngineBuilder.setDataReductionProxyOptions(serverHostPort, "unused.net:9999",
NativeTestServer.getFileURL("/secureproxychecksuccess.txt"));
- config.setLibraryName("cronet_tests");
- mActivity.mUrlRequestContext = UrlRequestContext.createContext(
- getInstrumentation().getTargetContext(), config);
+ cronetEngineBuilder.setLibraryName("cronet_tests");
+ mActivity.mCronetEngine =
+ cronetEngineBuilder.build(getInstrumentation().getTargetContext());
TestUrlRequestListener listener = new TestUrlRequestListener();
// Construct and start a request that can only be returned by the test
// server. This request will fail if the configuration logic for the
// Data Reduction Proxy is not used.
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- "http://DomainThatDoesnt.Resolve/datareductionproxysuccess.txt",
- listener, listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder = new UrlRequest.Builder(
+ "http://DomainThatDoesnt.Resolve/datareductionproxysuccess.txt", listener,
+ listener.getExecutor());
+ mActivity.mCronetEngine.executeRequest(builder);
listener.blockForDone();
// Verify that the request is successful and that the Data Reduction
@@ -160,11 +156,11 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
// Block listener when response starts to verify that shutdown fails
// if there are active requests.
listener.setAutoAdvance(false);
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- TEST_URL, listener, listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(TEST_URL, listener, listener.getExecutor());
+ UrlRequest urlRequest = mActivity.mCronetEngine.executeRequest(builder);
try {
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
fail("Should throw an exception");
} catch (Exception e) {
assertEquals("Cannot shutdown with active requests.",
@@ -174,7 +170,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
listener.waitForNextStep();
assertEquals(ResponseStep.ON_RESPONSE_STARTED, listener.mResponseStep);
try {
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
fail("Should throw an exception");
} catch (Exception e) {
assertEquals("Cannot shutdown with active requests.",
@@ -185,7 +181,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
listener.waitForNextStep();
assertEquals(ResponseStep.ON_READ_COMPLETED, listener.mResponseStep);
try {
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
fail("Should throw an exception");
} catch (Exception e) {
assertEquals("Cannot shutdown with active requests.",
@@ -223,15 +219,15 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
// Create new request context, but its initialization on the main thread
// will be stuck behind blockingTask.
- final UrlRequestContext requestContext = activity.initRequestContext();
+ final CronetEngine cronetEngine = activity.initCronetEngine();
// Unblock the main thread, so context gets initialized and shutdown on
// it.
block.open();
// Shutdown will wait for init to complete on main thread.
- requestContext.shutdown();
+ cronetEngine.shutdown();
// Verify that context is shutdown.
try {
- requestContext.stopNetLog();
+ cronetEngine.stopNetLog();
fail("Should throw an exception.");
} catch (Exception e) {
assertEquals("Context is shut down.", e.getMessage());
@@ -248,12 +244,12 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
Runnable blockingTask = new Runnable() {
public void run() {
// Create new request context, loading the library.
- final UrlRequestContext requestContext = activity.initRequestContext();
+ final CronetEngine cronetEngine = activity.initCronetEngine();
// Shutdown right after init.
- requestContext.shutdown();
+ cronetEngine.shutdown();
// Verify that context is shutdown.
try {
- requestContext.stopNetLog();
+ cronetEngine.stopNetLog();
fail("Should throw an exception.");
} catch (Exception e) {
assertEquals("Context is shut down.", e.getMessage());
@@ -271,8 +267,8 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
public void testMultipleShutdown() throws Exception {
mActivity = launchCronetTestApp();
try {
- mActivity.mUrlRequestContext.shutdown();
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
+ mActivity.mCronetEngine.shutdown();
fail("Should throw an exception");
} catch (Exception e) {
assertEquals("Context is shut down.",
@@ -285,9 +281,9 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
public void testShutdownAfterError() throws Exception {
mActivity = launchCronetTestApp();
TestUrlRequestListener listener = new ShutdownTestUrlRequestListener();
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
+ UrlRequest.Builder builder = new UrlRequest.Builder(
MOCK_CRONET_TEST_FAILED_URL, listener, listener.getExecutor());
- urlRequest.start();
+ mActivity.mCronetEngine.executeRequest(builder);
listener.blockForDone();
assertTrue(listener.mOnErrorCalled);
}
@@ -300,11 +296,11 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
// Block listener when response starts to verify that shutdown fails
// if there are active requests.
listener.setAutoAdvance(false);
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- TEST_URL, listener, listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(TEST_URL, listener, listener.getExecutor());
+ UrlRequest urlRequest = mActivity.mCronetEngine.executeRequest(builder);
try {
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
fail("Should throw an exception");
} catch (Exception e) {
assertEquals("Cannot shutdown with active requests.",
@@ -313,7 +309,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
listener.waitForNextStep();
assertEquals(ResponseStep.ON_RESPONSE_STARTED, listener.mResponseStep);
urlRequest.cancel();
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
}
@SmallTest
@@ -323,8 +319,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
File directory = new File(PathUtils.getDataDirectory(context));
File file = File.createTempFile("cronet", "json", directory);
CronetUrlRequestContext requestContext = new CronetUrlRequestContext(
- context,
- new UrlRequestContextConfig().setLibraryName("cronet_tests"));
+ context, new CronetEngine.Builder().setLibraryName("cronet_tests"));
// Start NetLog immediately after the request context is created to make
// sure that the call won't crash the app even when the native request
// context is not fully initialized. See crbug.com/470196.
@@ -332,9 +327,9 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
// Start a request.
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest request = requestContext.createRequest(
- TEST_URL, listener, listener.getExecutor());
- request.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(TEST_URL, listener, listener.getExecutor());
+ requestContext.executeRequest(builder);
listener.blockForDone();
requestContext.stopNetLog();
assertTrue(file.exists());
@@ -349,18 +344,17 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
public void testNetLogAfterShutdown() throws Exception {
mActivity = launchCronetTestApp();
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- TEST_URL, listener, listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(TEST_URL, listener, listener.getExecutor());
+ mActivity.mCronetEngine.executeRequest(builder);
listener.blockForDone();
- mActivity.mUrlRequestContext.shutdown();
+ mActivity.mCronetEngine.shutdown();
File directory = new File(PathUtils.getDataDirectory(
getInstrumentation().getTargetContext()));
File file = File.createTempFile("cronet", "json", directory);
try {
- mActivity.mUrlRequestContext.startNetLogToFile(file.getPath(),
- false);
+ mActivity.mCronetEngine.startNetLogToFile(file.getPath(), false);
fail("Should throw an exception.");
} catch (Exception e) {
assertEquals("Context is shut down.", e.getMessage());
@@ -378,17 +372,17 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
getInstrumentation().getTargetContext()));
File file = File.createTempFile("cronet", "json", directory);
// Start NetLog multiple times.
- mActivity.mUrlRequestContext.startNetLogToFile(file.getPath(), false);
- mActivity.mUrlRequestContext.startNetLogToFile(file.getPath(), false);
- mActivity.mUrlRequestContext.startNetLogToFile(file.getPath(), false);
- mActivity.mUrlRequestContext.startNetLogToFile(file.getPath(), false);
+ mActivity.mCronetEngine.startNetLogToFile(file.getPath(), false);
+ mActivity.mCronetEngine.startNetLogToFile(file.getPath(), false);
+ mActivity.mCronetEngine.startNetLogToFile(file.getPath(), false);
+ mActivity.mCronetEngine.startNetLogToFile(file.getPath(), false);
// Start a request.
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- TEST_URL, listener, listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(TEST_URL, listener, listener.getExecutor());
+ mActivity.mCronetEngine.executeRequest(builder);
listener.blockForDone();
- mActivity.mUrlRequestContext.stopNetLog();
+ mActivity.mCronetEngine.stopNetLog();
assertTrue(file.exists());
assertTrue(file.length() != 0);
assertFalse(hasBytesInNetLog(file));
@@ -403,19 +397,19 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
File directory = new File(PathUtils.getDataDirectory(
getInstrumentation().getTargetContext()));
File file = File.createTempFile("cronet", "json", directory);
- mActivity.mUrlRequestContext.startNetLogToFile(file.getPath(), false);
+ mActivity.mCronetEngine.startNetLogToFile(file.getPath(), false);
// Start a request.
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- TEST_URL, listener, listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(TEST_URL, listener, listener.getExecutor());
+ mActivity.mCronetEngine.executeRequest(builder);
listener.blockForDone();
// Stop NetLog multiple times.
- mActivity.mUrlRequestContext.stopNetLog();
- mActivity.mUrlRequestContext.stopNetLog();
- mActivity.mUrlRequestContext.stopNetLog();
- mActivity.mUrlRequestContext.stopNetLog();
- mActivity.mUrlRequestContext.stopNetLog();
+ mActivity.mCronetEngine.stopNetLog();
+ mActivity.mCronetEngine.stopNetLog();
+ mActivity.mCronetEngine.stopNetLog();
+ mActivity.mCronetEngine.stopNetLog();
+ mActivity.mCronetEngine.stopNetLog();
assertTrue(file.exists());
assertTrue(file.length() != 0);
assertFalse(hasBytesInNetLog(file));
@@ -430,15 +424,14 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
File directory = new File(PathUtils.getDataDirectory(context));
File file = File.createTempFile("cronet", "json", directory);
CronetUrlRequestContext requestContext = new CronetUrlRequestContext(
- context,
- new UrlRequestContextConfig().setLibraryName("cronet_tests"));
+ context, new CronetEngine.Builder().setLibraryName("cronet_tests"));
// Start NetLog with logAll as true.
requestContext.startNetLogToFile(file.getPath(), true);
// Start a request.
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest request = requestContext.createRequest(
- TEST_URL, listener, listener.getExecutor());
- request.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(TEST_URL, listener, listener.getExecutor());
+ requestContext.executeRequest(builder);
listener.blockForDone();
requestContext.stopNetLog();
assertTrue(file.exists());
@@ -465,11 +458,11 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
private void enableCache(int cacheType) throws Exception {
String cacheTypeString = "";
- if (cacheType == UrlRequestContextConfig.HTTP_CACHE_DISK) {
+ if (cacheType == CronetEngine.Builder.HTTP_CACHE_DISK) {
cacheTypeString = CronetTestActivity.CACHE_DISK;
- } else if (cacheType == UrlRequestContextConfig.HTTP_CACHE_DISK_NO_HTTP) {
+ } else if (cacheType == CronetEngine.Builder.HTTP_CACHE_DISK_NO_HTTP) {
cacheTypeString = CronetTestActivity.CACHE_DISK_NO_HTTP;
- } else if (cacheType == UrlRequestContextConfig.HTTP_CACHE_IN_MEMORY) {
+ } else if (cacheType == CronetEngine.Builder.HTTP_CACHE_IN_MEMORY) {
cacheTypeString = CronetTestActivity.CACHE_IN_MEMORY;
}
String[] commandLineArgs = {CronetTestActivity.CACHE_KEY, cacheTypeString};
@@ -486,12 +479,11 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
private void checkRequestCaching(String url, boolean expectCached,
boolean disableCache) {
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- url, listener, listener.getExecutor());
+ UrlRequest.Builder builder = new UrlRequest.Builder(url, listener, listener.getExecutor());
if (disableCache) {
- urlRequest.disableCache();
+ builder.disableCache();
}
- urlRequest.start();
+ mActivity.mCronetEngine.executeRequest(builder);
listener.blockForDone();
assertEquals(expectCached, listener.mResponseInfo.wasCached());
}
@@ -499,7 +491,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
@SmallTest
@Feature({"Cronet"})
public void testEnableHttpCacheDisabled() throws Exception {
- enableCache(UrlRequestContextConfig.HTTP_CACHE_DISABLED);
+ enableCache(CronetEngine.Builder.HTTP_CACHE_DISABLED);
String url = NativeTestServer.getFileURL("/cacheable.txt");
checkRequestCaching(url, false);
checkRequestCaching(url, false);
@@ -509,7 +501,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
@SmallTest
@Feature({"Cronet"})
public void testEnableHttpCacheInMemory() throws Exception {
- enableCache(UrlRequestContextConfig.HTTP_CACHE_IN_MEMORY);
+ enableCache(CronetEngine.Builder.HTTP_CACHE_IN_MEMORY);
String url = NativeTestServer.getFileURL("/cacheable.txt");
checkRequestCaching(url, false);
checkRequestCaching(url, true);
@@ -520,7 +512,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
@SmallTest
@Feature({"Cronet"})
public void testEnableHttpCacheDisk() throws Exception {
- enableCache(UrlRequestContextConfig.HTTP_CACHE_DISK);
+ enableCache(CronetEngine.Builder.HTTP_CACHE_DISK);
String url = NativeTestServer.getFileURL("/cacheable.txt");
checkRequestCaching(url, false);
checkRequestCaching(url, true);
@@ -531,7 +523,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
@SmallTest
@Feature({"Cronet"})
public void testEnableHttpCacheDiskNoHttp() throws Exception {
- enableCache(UrlRequestContextConfig.HTTP_CACHE_DISABLED);
+ enableCache(CronetEngine.Builder.HTTP_CACHE_DISABLED);
String url = NativeTestServer.getFileURL("/cacheable.txt");
checkRequestCaching(url, false);
checkRequestCaching(url, false);
@@ -541,7 +533,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
@SmallTest
@Feature({"Cronet"})
public void testDisableCache() throws Exception {
- enableCache(UrlRequestContextConfig.HTTP_CACHE_DISK);
+ enableCache(CronetEngine.Builder.HTTP_CACHE_DISK);
String url = NativeTestServer.getFileURL("/cacheable.txt");
// When cache is disabled, making a request does not write to the cache.
@@ -558,10 +550,9 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
// Cache is disabled after server is shut down, request should fail.
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest(
- url, listener, listener.getExecutor());
- urlRequest.disableCache();
- urlRequest.start();
+ UrlRequest.Builder builder = new UrlRequest.Builder(url, listener, listener.getExecutor());
+ builder.disableCache();
+ mActivity.mCronetEngine.executeRequest(builder);
listener.blockForDone();
assertNotNull(listener.mError);
assertEquals("Exception in CronetUrlRequest: net::ERR_CONNECTION_REFUSED",
@@ -571,7 +562,7 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
@SmallTest
@Feature({"Cronet"})
public void testEnableHttpCacheDiskNewContext() throws Exception {
- enableCache(UrlRequestContextConfig.HTTP_CACHE_DISK);
+ enableCache(CronetEngine.Builder.HTTP_CACHE_DISK);
String url = NativeTestServer.getFileURL("/cacheable.txt");
checkRequestCaching(url, false);
checkRequestCaching(url, true);
@@ -579,9 +570,9 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
checkRequestCaching(url, true);
// Shutdown original context and create another that uses the same cache.
- mActivity.mUrlRequestContext.shutdown();
- mActivity.mUrlRequestContext = UrlRequestContext.createContext(
- getInstrumentation().getTargetContext(), mActivity.getContextConfig());
+ mActivity.mCronetEngine.shutdown();
+ mActivity.mCronetEngine =
+ mActivity.getCronetEngineBuilder().build(getInstrumentation().getTargetContext());
checkRequestCaching(url, true);
}
@@ -591,11 +582,11 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
CronetTestActivity activity = launchCronetTestAppAndSkipFactoryInit();
// Immediately make a request after initializing the context.
- UrlRequestContext requestContext = activity.initRequestContext();
+ CronetEngine cronetEngine = activity.initCronetEngine();
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest urlRequest =
- requestContext.createRequest(TEST_URL, listener, listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(TEST_URL, listener, listener.getExecutor());
+ cronetEngine.executeRequest(builder);
listener.blockForDone();
assertEquals(200, listener.mResponseInfo.getHttpStatusCode());
}
@@ -606,14 +597,14 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
CronetTestActivity activity = launchCronetTestAppAndSkipFactoryInit();
// Make two requests after initializing the context.
- UrlRequestContext requestContext = activity.initRequestContext();
+ CronetEngine cronetEngine = activity.initCronetEngine();
int[] statusCodes = {0, 0};
String[] urls = {TEST_URL, URL_404};
for (int i = 0; i < 2; i++) {
TestUrlRequestListener listener = new TestUrlRequestListener();
- UrlRequest urlRequest =
- requestContext.createRequest(urls[i], listener, listener.getExecutor());
- urlRequest.start();
+ UrlRequest.Builder builder =
+ new UrlRequest.Builder(urls[i], listener, listener.getExecutor());
+ UrlRequest urlRequest = cronetEngine.executeRequest(builder);
listener.blockForDone();
statusCodes[i] = listener.mResponseInfo.getHttpStatusCode();
}
@@ -665,11 +656,11 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
// like crbug.com/453845
mActivity = launchCronetTestApp();
CronetUrlRequestContext firstContext =
- new CronetUrlRequestContext(mActivity, mActivity.getContextConfig());
+ new CronetUrlRequestContext(mActivity, mActivity.getCronetEngineBuilder());
CronetUrlRequestContext secondContext = new CronetUrlRequestContext(
- mActivity.getApplicationContext(), mActivity.getContextConfig());
+ mActivity.getApplicationContext(), mActivity.getCronetEngineBuilder());
CronetUrlRequestContext thirdContext = new CronetUrlRequestContext(
- new ContextWrapper(mActivity), mActivity.getContextConfig());
+ new ContextWrapper(mActivity), mActivity.getCronetEngineBuilder());
firstContext.shutdown();
secondContext.shutdown();
thirdContext.shutdown();

Powered by Google App Engine
This is Rietveld 408576698