| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 package org.chromium.net; | 5 package org.chromium.net; |
| 6 | 6 |
| 7 import android.test.suitebuilder.annotation.LargeTest; | 7 import android.test.suitebuilder.annotation.LargeTest; |
| 8 import android.test.suitebuilder.annotation.SmallTest; | 8 import android.test.suitebuilder.annotation.SmallTest; |
| 9 | 9 |
| 10 import org.chromium.base.Log; | 10 import org.chromium.base.Log; |
| (...skipping 13 matching lines...) Expand all Loading... |
| 24 private static final String TAG = "cr.QuicTest"; | 24 private static final String TAG = "cr.QuicTest"; |
| 25 private CronetTestActivity mActivity; | 25 private CronetTestActivity mActivity; |
| 26 | 26 |
| 27 @Override | 27 @Override |
| 28 protected void setUp() throws Exception { | 28 protected void setUp() throws Exception { |
| 29 super.setUp(); | 29 super.setUp(); |
| 30 // Load library first, since we need the Quic test server's URL. | 30 // Load library first, since we need the Quic test server's URL. |
| 31 System.loadLibrary("cronet_tests"); | 31 System.loadLibrary("cronet_tests"); |
| 32 QuicTestServer.startQuicTestServer(getInstrumentation().getTargetContext
()); | 32 QuicTestServer.startQuicTestServer(getInstrumentation().getTargetContext
()); |
| 33 CronetEngine.Builder builder = new CronetEngine.Builder(mActivity); | 33 CronetEngine.Builder builder = new CronetEngine.Builder(mActivity); |
| 34 builder.setMockCertsForTesting("quic_test.example.com.crt"); |
| 34 builder.enableQUIC(true); | 35 builder.enableQUIC(true); |
| 35 builder.addQuicHint(QuicTestServer.getServerHost(), QuicTestServer.getSe
rverPort(), | 36 builder.addQuicHint(QuicTestServer.getServerHost(), QuicTestServer.getSe
rverPort(), |
| 36 QuicTestServer.getServerPort()); | 37 QuicTestServer.getServerPort()); |
| 37 builder.setExperimentalQuicConnectionOptions("PACE,IW10,FOO,DEADBEEF"); | 38 builder.setExperimentalQuicConnectionOptions("PACE,IW10,FOO,DEADBEEF"); |
| 38 | 39 |
| 39 String[] commandLineArgs = {CronetTestActivity.CONFIG_KEY, builder.toStr
ing(), | 40 String[] commandLineArgs = {CronetTestActivity.CONFIG_KEY, builder.toStr
ing(), |
| 40 CronetTestActivity.CACHE_KEY, CronetTestActivity.CACHE_DISK_NO_H
TTP}; | 41 CronetTestActivity.CACHE_KEY, CronetTestActivity.CACHE_DISK_NO_H
TTP}; |
| 41 mActivity = launchCronetTestAppWithUrlAndCommandLineArgs(null, commandLi
neArgs); | 42 mActivity = launchCronetTestAppWithUrlAndCommandLineArgs(null, commandLi
neArgs); |
| 42 } | 43 } |
| 43 | 44 |
| 44 @Override | 45 @Override |
| 45 protected void tearDown() throws Exception { | 46 protected void tearDown() throws Exception { |
| 46 QuicTestServer.shutdownQuicTestServer(); | 47 QuicTestServer.shutdownQuicTestServer(); |
| 47 super.tearDown(); | 48 super.tearDown(); |
| 48 } | 49 } |
| 49 | 50 |
| 50 @SmallTest | 51 @SmallTest |
| 51 @Feature({"Cronet"}) | 52 @Feature({"Cronet"}) |
| 52 public void testQuicLoadUrl_LegacyAPI() throws Exception { | 53 public void testQuicLoadUrl_LegacyAPI() throws Exception { |
| 54 long urlRequestContextAdapter = ((ChromiumUrlRequestFactory) mActivity.m
RequestFactory) |
| 55 .getRequestContext() |
| 56 .getUrlRequestContextAdapter(); |
| 57 NativeTestServer.registerHostResolverProc(urlRequestContextAdapter, true
); |
| 53 String quicURL = QuicTestServer.getServerURL() + "/simple.txt"; | 58 String quicURL = QuicTestServer.getServerURL() + "/simple.txt"; |
| 54 | 59 |
| 55 HashMap<String, String> headers = new HashMap<String, String>(); | 60 HashMap<String, String> headers = new HashMap<String, String>(); |
| 56 TestHttpUrlRequestListener listener = new TestHttpUrlRequestListener(); | 61 TestHttpUrlRequestListener listener = new TestHttpUrlRequestListener(); |
| 57 | 62 |
| 58 // Although the native stack races QUIC and SPDY for the first request, | 63 // Although the native stack races QUIC and SPDY for the first request, |
| 59 // since there is no http server running on the corresponding TCP port, | 64 // since there is no http server running on the corresponding TCP port, |
| 60 // QUIC will always succeed with a 200 (see | 65 // QUIC will always succeed with a 200 (see |
| 61 // net::HttpStreamFactoryImpl::Request::OnStreamFailed). | 66 // net::HttpStreamFactoryImpl::Request::OnStreamFailed). |
| 62 HttpUrlRequest request = mActivity.mRequestFactory.createRequest( | 67 HttpUrlRequest request = mActivity.mRequestFactory.createRequest( |
| 63 quicURL, HttpUrlRequest.REQUEST_PRIORITY_MEDIUM, headers, listen
er); | 68 quicURL, HttpUrlRequest.REQUEST_PRIORITY_MEDIUM, headers, listen
er); |
| 64 request.start(); | 69 request.start(); |
| 65 listener.blockForComplete(); | 70 listener.blockForComplete(); |
| 66 assertEquals(200, listener.mHttpStatusCode); | 71 assertEquals(200, listener.mHttpStatusCode); |
| 67 assertEquals( | 72 assertEquals( |
| 68 "This is a simple text file served by QUIC.\n", | 73 "This is a simple text file served by QUIC.\n", |
| 69 listener.mResponseAsString); | 74 listener.mResponseAsString); |
| 70 assertEquals("quic/1+spdy/3", listener.mNegotiatedProtocol); | 75 assertEquals("quic/1+spdy/3", listener.mNegotiatedProtocol); |
| 71 } | 76 } |
| 72 | 77 |
| 73 @LargeTest | 78 @LargeTest |
| 74 @Feature({"Cronet"}) | 79 @Feature({"Cronet"}) |
| 75 public void testQuicLoadUrl() throws Exception { | 80 public void testQuicLoadUrl() throws Exception { |
| 81 long urlRequestContextAdapter = |
| 82 ((CronetUrlRequestContext) mActivity.mCronetEngine).getUrlReques
tContextAdapter(); |
| 83 NativeTestServer.registerHostResolverProc(urlRequestContextAdapter, fals
e); |
| 84 |
| 76 String quicURL = QuicTestServer.getServerURL() + "/simple.txt"; | 85 String quicURL = QuicTestServer.getServerURL() + "/simple.txt"; |
| 77 TestUrlRequestListener listener = new TestUrlRequestListener(); | 86 TestUrlRequestListener listener = new TestUrlRequestListener(); |
| 78 | 87 |
| 79 // Although the native stack races QUIC and SPDY for the first request, | 88 // Although the native stack races QUIC and SPDY for the first request, |
| 80 // since there is no http server running on the corresponding TCP port, | 89 // since there is no http server running on the corresponding TCP port, |
| 81 // QUIC will always succeed with a 200 (see | 90 // QUIC will always succeed with a 200 (see |
| 82 // net::HttpStreamFactoryImpl::Request::OnStreamFailed). | 91 // net::HttpStreamFactoryImpl::Request::OnStreamFailed). |
| 83 UrlRequest.Builder requestBuilder = new UrlRequest.Builder( | 92 UrlRequest.Builder requestBuilder = new UrlRequest.Builder( |
| 84 quicURL, listener, listener.getExecutor(), mActivity.mCronetEngi
ne); | 93 quicURL, listener, listener.getExecutor(), mActivity.mCronetEngi
ne); |
| 85 requestBuilder.build().start(); | 94 requestBuilder.build().start(); |
| (...skipping 23 matching lines...) Expand all Loading... |
| 109 } | 118 } |
| 110 assertTrue(fileContainsString("local_prefs.json", | 119 assertTrue(fileContainsString("local_prefs.json", |
| 111 QuicTestServer.getServerHost() + ":" + QuicTestServer.getServerP
ort())); | 120 QuicTestServer.getServerHost() + ":" + QuicTestServer.getServerP
ort())); |
| 112 mActivity.mCronetEngine.shutdown(); | 121 mActivity.mCronetEngine.shutdown(); |
| 113 | 122 |
| 114 // Make another request using a new context but with no QUIC hints. | 123 // Make another request using a new context but with no QUIC hints. |
| 115 CronetEngine.Builder builder = | 124 CronetEngine.Builder builder = |
| 116 new CronetEngine.Builder(getInstrumentation().getTargetContext()
); | 125 new CronetEngine.Builder(getInstrumentation().getTargetContext()
); |
| 117 builder.setStoragePath(mActivity.getTestStorage()); | 126 builder.setStoragePath(mActivity.getTestStorage()); |
| 118 builder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK, 1000 * 102
4); | 127 builder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK, 1000 * 102
4); |
| 128 builder.setMockCertsForTesting("quic_test.example.com.crt"); |
| 119 builder.enableQUIC(true); | 129 builder.enableQUIC(true); |
| 120 CronetEngine newEngine = new CronetUrlRequestContext(builder); | 130 CronetEngine newEngine = new CronetUrlRequestContext(builder); |
| 131 long newUrlRequestContextAdapter = |
| 132 ((CronetUrlRequestContext) newEngine).getUrlRequestContextAdapte
r(); |
| 133 NativeTestServer.registerHostResolverProc(newUrlRequestContextAdapter, f
alse); |
| 121 TestUrlRequestListener listener2 = new TestUrlRequestListener(); | 134 TestUrlRequestListener listener2 = new TestUrlRequestListener(); |
| 122 requestBuilder = | 135 requestBuilder = |
| 123 new UrlRequest.Builder(quicURL, listener2, listener2.getExecutor
(), newEngine); | 136 new UrlRequest.Builder(quicURL, listener2, listener2.getExecutor
(), newEngine); |
| 124 requestBuilder.build().start(); | 137 requestBuilder.build().start(); |
| 125 listener2.blockForDone(); | 138 listener2.blockForDone(); |
| 126 assertEquals(200, listener2.mResponseInfo.getHttpStatusCode()); | 139 assertEquals(200, listener2.mResponseInfo.getHttpStatusCode()); |
| 127 assertEquals(expectedContent, listener2.mResponseAsString); | 140 assertEquals(expectedContent, listener2.mResponseAsString); |
| 128 assertEquals("quic/1+spdy/3", listener2.mResponseInfo.getNegotiatedProto
col()); | 141 assertEquals("quic/1+spdy/3", listener2.mResponseInfo.getNegotiatedProto
col()); |
| 129 // The total received bytes should be larger than the content length, to
account for | 142 // The total received bytes should be larger than the content length, to
account for |
| 130 // headers. | 143 // headers. |
| 131 assertTrue( | 144 assertTrue( |
| 132 listener2.mExtendedResponseInfo.getTotalReceivedBytes() > expect
edContent.length()); | 145 listener2.mExtendedResponseInfo.getTotalReceivedBytes() > expect
edContent.length()); |
| 133 } | 146 } |
| 134 | 147 |
| 135 // Returns whether a file contains a particular string. | 148 // Returns whether a file contains a particular string. |
| 136 @SuppressFBWarnings("OBL_UNSATISFIED_OBLIGATION_EXCEPTION_EDGE") | 149 @SuppressFBWarnings("OBL_UNSATISFIED_OBLIGATION_EXCEPTION_EDGE") |
| 137 private boolean fileContainsString(String filename, String content) throws I
OException { | 150 private boolean fileContainsString(String filename, String content) throws I
OException { |
| 138 File file = new File(mActivity.getTestStorage() + "/" + filename); | 151 File file = new File(mActivity.getTestStorage() + "/" + filename); |
| 139 FileInputStream fileInputStream = new FileInputStream(file); | 152 FileInputStream fileInputStream = new FileInputStream(file); |
| 140 byte[] data = new byte[(int) file.length()]; | 153 byte[] data = new byte[(int) file.length()]; |
| 141 fileInputStream.read(data); | 154 fileInputStream.read(data); |
| 142 fileInputStream.close(); | 155 fileInputStream.close(); |
| 143 return new String(data, "UTF-8").contains(content); | 156 return new String(data, "UTF-8").contains(content); |
| 144 } | 157 } |
| 145 } | 158 } |
| OLD | NEW |