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 20 matching lines...) Expand all Loading... |
31 // Load library first, since we need the Quic test server's URL. | 31 // Load library first, since we need the Quic test server's URL. |
32 System.loadLibrary("cronet_tests"); | 32 System.loadLibrary("cronet_tests"); |
33 QuicTestServer.startQuicTestServer(getContext()); | 33 QuicTestServer.startQuicTestServer(getContext()); |
34 | 34 |
35 CronetEngine.Builder builder = new CronetEngine.Builder(getContext()); | 35 CronetEngine.Builder builder = new CronetEngine.Builder(getContext()); |
36 builder.enableQUIC(true); | 36 builder.enableQUIC(true); |
37 builder.addQuicHint(QuicTestServer.getServerHost(), QuicTestServer.getSe
rverPort(), | 37 builder.addQuicHint(QuicTestServer.getServerHost(), QuicTestServer.getSe
rverPort(), |
38 QuicTestServer.getServerPort()); | 38 QuicTestServer.getServerPort()); |
39 builder.setExperimentalQuicConnectionOptions("PACE,IW10,FOO,DEADBEEF"); | 39 builder.setExperimentalQuicConnectionOptions("PACE,IW10,FOO,DEADBEEF"); |
40 builder.setMockCertVerifierForTesting(MockCertVerifier.createMockCertVer
ifier(CERTS_USED)); | 40 builder.setMockCertVerifierForTesting(MockCertVerifier.createMockCertVer
ifier(CERTS_USED)); |
| 41 builder.setStoragePath(CronetTestFramework.getTestStorage(getContext()))
; |
| 42 builder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK_NO_HTTP, 10
00 * 1024); |
41 | 43 |
42 String[] commandLineArgs = {CronetTestFramework.CONFIG_KEY, builder.toSt
ring(), | 44 mTestFramework = startCronetTestFrameworkWithUrlAndCronetEngineBuilder(n
ull, builder); |
43 CronetTestFramework.CACHE_KEY, CronetTestFramework.CACHE_DISK_NO
_HTTP}; | |
44 mTestFramework = startCronetTestFrameworkWithUrlAndCommandLineArgs(null,
commandLineArgs); | |
45 } | 45 } |
46 | 46 |
47 @Override | 47 @Override |
48 protected void tearDown() throws Exception { | 48 protected void tearDown() throws Exception { |
49 QuicTestServer.shutdownQuicTestServer(); | 49 QuicTestServer.shutdownQuicTestServer(); |
50 super.tearDown(); | 50 super.tearDown(); |
51 } | 51 } |
52 | 52 |
53 @SmallTest | 53 @SmallTest |
54 @Feature({"Cronet"}) | 54 @Feature({"Cronet"}) |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
116 // Ignored this exception since the file will only be created wh
en updates are | 116 // Ignored this exception since the file will only be created wh
en updates are |
117 // flushed to the disk. | 117 // flushed to the disk. |
118 } | 118 } |
119 } | 119 } |
120 assertTrue(fileContainsString("local_prefs.json", | 120 assertTrue(fileContainsString("local_prefs.json", |
121 QuicTestServer.getServerHost() + ":" + QuicTestServer.getServerP
ort())); | 121 QuicTestServer.getServerHost() + ":" + QuicTestServer.getServerP
ort())); |
122 mTestFramework.mCronetEngine.shutdown(); | 122 mTestFramework.mCronetEngine.shutdown(); |
123 | 123 |
124 // Make another request using a new context but with no QUIC hints. | 124 // Make another request using a new context but with no QUIC hints. |
125 CronetEngine.Builder builder = new CronetEngine.Builder(getContext()); | 125 CronetEngine.Builder builder = new CronetEngine.Builder(getContext()); |
126 builder.setStoragePath(mTestFramework.getTestStorage()); | 126 builder.setStoragePath(CronetTestFramework.getTestStorage(getContext()))
; |
127 builder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK, 1000 * 102
4); | 127 builder.enableHttpCache(CronetEngine.Builder.HTTP_CACHE_DISK, 1000 * 102
4); |
128 builder.enableQUIC(true); | 128 builder.enableQUIC(true); |
129 builder.setMockCertVerifierForTesting(MockCertVerifier.createMockCertVer
ifier(CERTS_USED)); | 129 builder.setMockCertVerifierForTesting(MockCertVerifier.createMockCertVer
ifier(CERTS_USED)); |
130 CronetEngine newEngine = new CronetUrlRequestContext(builder); | 130 CronetEngine newEngine = new CronetUrlRequestContext(builder); |
131 long newUrlRequestContextAdapter = | 131 long newUrlRequestContextAdapter = |
132 ((CronetUrlRequestContext) newEngine).getUrlRequestContextAdapte
r(); | 132 ((CronetUrlRequestContext) newEngine).getUrlRequestContextAdapte
r(); |
133 NativeTestServer.registerHostResolverProc(newUrlRequestContextAdapter, f
alse); | 133 NativeTestServer.registerHostResolverProc(newUrlRequestContextAdapter, f
alse); |
134 TestUrlRequestCallback callback2 = new TestUrlRequestCallback(); | 134 TestUrlRequestCallback callback2 = new TestUrlRequestCallback(); |
135 requestBuilder = | 135 requestBuilder = |
136 new UrlRequest.Builder(quicURL, callback2, callback2.getExecutor
(), newEngine); | 136 new UrlRequest.Builder(quicURL, callback2, callback2.getExecutor
(), newEngine); |
137 requestBuilder.build().start(); | 137 requestBuilder.build().start(); |
138 callback2.blockForDone(); | 138 callback2.blockForDone(); |
139 assertEquals(200, callback2.mResponseInfo.getHttpStatusCode()); | 139 assertEquals(200, callback2.mResponseInfo.getHttpStatusCode()); |
140 assertEquals(expectedContent, callback2.mResponseAsString); | 140 assertEquals(expectedContent, callback2.mResponseAsString); |
141 assertEquals("quic/1+spdy/3", callback2.mResponseInfo.getNegotiatedProto
col()); | 141 assertEquals("quic/1+spdy/3", callback2.mResponseInfo.getNegotiatedProto
col()); |
142 // 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 |
143 // headers. | 143 // headers. |
144 assertTrue(callback2.mResponseInfo.getReceivedBytesCount() > expectedCon
tent.length()); | 144 assertTrue(callback2.mResponseInfo.getReceivedBytesCount() > expectedCon
tent.length()); |
145 } | 145 } |
146 | 146 |
147 // Returns whether a file contains a particular string. | 147 // Returns whether a file contains a particular string. |
148 @SuppressFBWarnings("OBL_UNSATISFIED_OBLIGATION_EXCEPTION_EDGE") | 148 @SuppressFBWarnings("OBL_UNSATISFIED_OBLIGATION_EXCEPTION_EDGE") |
149 private boolean fileContainsString(String filename, String content) throws I
OException { | 149 private boolean fileContainsString(String filename, String content) throws I
OException { |
150 File file = new File(mTestFramework.getTestStorage() + "/" + filename); | 150 File file = new File(CronetTestFramework.getTestStorage(getContext()) +
"/" + filename); |
151 FileInputStream fileInputStream = new FileInputStream(file); | 151 FileInputStream fileInputStream = new FileInputStream(file); |
152 byte[] data = new byte[(int) file.length()]; | 152 byte[] data = new byte[(int) file.length()]; |
153 fileInputStream.read(data); | 153 fileInputStream.read(data); |
154 fileInputStream.close(); | 154 fileInputStream.close(); |
155 return new String(data, "UTF-8").contains(content); | 155 return new String(data, "UTF-8").contains(content); |
156 } | 156 } |
157 } | 157 } |
OLD | NEW |