Chromium Code Reviews| 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(); |