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(); |