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

Side by Side Diff: net/http/disk_cache_based_quic_server_info_unittest.cc

Issue 211373004: Revert of Add PrivacyMode support to the QuicStreamFactory. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 9 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 unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « no previous file | net/http/http_stream_factory_impl_job.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 #include "net/http/disk_cache_based_quic_server_info.h" 5 #include "net/http/disk_cache_based_quic_server_info.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/bind_helpers.h" 8 #include "base/bind_helpers.h"
9 #include "base/compiler_specific.h" 9 #include "base/compiler_specific.h"
10 #include "base/message_loop/message_loop.h" 10 #include "base/message_loop/message_loop.h"
11 #include "net/base/net_errors.h" 11 #include "net/base/net_errors.h"
12 #include "net/http/mock_http_cache.h" 12 #include "net/http/mock_http_cache.h"
13 #include "net/quic/crypto/quic_server_info.h" 13 #include "net/quic/crypto/quic_server_info.h"
14 #include "net/quic/quic_session_key.h" 14 #include "net/quic/quic_session_key.h"
15 #include "testing/gtest/include/gtest/gtest.h" 15 #include "testing/gtest/include/gtest/gtest.h"
16 16
17 namespace net {
18 namespace { 17 namespace {
19 18
20 // This is an empty transaction, needed to register the URL and the test mode. 19 // This is an empty transaction, needed to register the URL and the test mode.
21 const MockTransaction kHostInfoTransaction1 = { 20 const MockTransaction kHostInfoTransaction1 = {
22 "quicserverinfo:https://www.google.com:443", 21 "quicserverinfo:https://www.google.com:443",
23 "", 22 "",
24 base::Time(), 23 base::Time(),
25 "", 24 "",
26 LOAD_NORMAL, 25 net::LOAD_NORMAL,
27 "", 26 "",
28 "", 27 "",
29 base::Time(), 28 base::Time(),
30 "", 29 "",
31 TEST_MODE_NORMAL, 30 TEST_MODE_NORMAL,
32 NULL, 31 NULL,
33 0 32 0
34 }; 33 };
35 34
36 const MockTransaction kHostInfoTransaction2 = { 35 const MockTransaction kHostInfoTransaction2 = {
37 "quicserverinfo:http://www.google.com:80", 36 "quicserverinfo:http://www.google.com:80",
38 "", 37 "",
39 base::Time(), 38 base::Time(),
40 "", 39 "",
41 LOAD_NORMAL, 40 net::LOAD_NORMAL,
42 "", 41 "",
43 "", 42 "",
44 base::Time(), 43 base::Time(),
45 "", 44 "",
46 TEST_MODE_NORMAL, 45 TEST_MODE_NORMAL,
47 NULL, 46 NULL,
48 0 47 0
49 }; 48 };
50 49
51 } // namespace
52
53 // Tests that we can delete a DiskCacheBasedQuicServerInfo object in a 50 // Tests that we can delete a DiskCacheBasedQuicServerInfo object in a
54 // completion callback for DiskCacheBasedQuicServerInfo::WaitForDataReady. 51 // completion callback for DiskCacheBasedQuicServerInfo::WaitForDataReady.
55 TEST(DiskCacheBasedQuicServerInfo, DeleteInCallback) { 52 TEST(DiskCacheBasedQuicServerInfo, DeleteInCallback) {
56 // Use the blocking mock backend factory to force asynchronous completion 53 // Use the blocking mock backend factory to force asynchronous completion
57 // of quic_server_info->WaitForDataReady(), so that the callback will run. 54 // of quic_server_info->WaitForDataReady(), so that the callback will run.
58 MockBlockingBackendFactory* factory = new MockBlockingBackendFactory(); 55 MockBlockingBackendFactory* factory = new MockBlockingBackendFactory();
59 MockHttpCache cache(factory); 56 MockHttpCache cache(factory);
60 QuicSessionKey server_key("www.verisign.com", 443, true, 57 net::QuicSessionKey server_key("www.verisign.com", 443, true);
61 kPrivacyModeDisabled); 58 scoped_ptr<net::QuicServerInfo> quic_server_info(
62 scoped_ptr<QuicServerInfo> quic_server_info( 59 new net::DiskCacheBasedQuicServerInfo(server_key, cache.http_cache()));
63 new DiskCacheBasedQuicServerInfo(server_key, cache.http_cache()));
64 quic_server_info->Start(); 60 quic_server_info->Start();
65 TestCompletionCallback callback; 61 net::TestCompletionCallback callback;
66 int rv = quic_server_info->WaitForDataReady(callback.callback()); 62 int rv = quic_server_info->WaitForDataReady(callback.callback());
67 EXPECT_EQ(ERR_IO_PENDING, rv); 63 EXPECT_EQ(net::ERR_IO_PENDING, rv);
68 // Now complete the backend creation and let the callback run. 64 // Now complete the backend creation and let the callback run.
69 factory->FinishCreation(); 65 factory->FinishCreation();
70 EXPECT_EQ(OK, callback.GetResult(rv)); 66 EXPECT_EQ(net::OK, callback.GetResult(rv));
71 } 67 }
72 68
73 // Tests the basic logic of storing, retrieving and updating data. 69 // Tests the basic logic of storing, retrieving and updating data.
74 TEST(DiskCacheBasedQuicServerInfo, Update) { 70 TEST(DiskCacheBasedQuicServerInfo, Update) {
75 MockHttpCache cache; 71 MockHttpCache cache;
76 AddMockTransaction(&kHostInfoTransaction1); 72 AddMockTransaction(&kHostInfoTransaction1);
77 TestCompletionCallback callback; 73 net::TestCompletionCallback callback;
78 74
79 QuicSessionKey server_key("www.google.com", 443, true, kPrivacyModeDisabled); 75 net::QuicSessionKey server_key("www.google.com", 443, true);
80 scoped_ptr<QuicServerInfo> quic_server_info( 76 scoped_ptr<net::QuicServerInfo> quic_server_info(
81 new DiskCacheBasedQuicServerInfo(server_key, cache.http_cache())); 77 new net::DiskCacheBasedQuicServerInfo(server_key, cache.http_cache()));
82 quic_server_info->Start(); 78 quic_server_info->Start();
83 int rv = quic_server_info->WaitForDataReady(callback.callback()); 79 int rv = quic_server_info->WaitForDataReady(callback.callback());
84 EXPECT_EQ(OK, callback.GetResult(rv)); 80 EXPECT_EQ(net::OK, callback.GetResult(rv));
85 81
86 QuicServerInfo::State* state = quic_server_info->mutable_state(); 82 net::QuicServerInfo::State* state = quic_server_info->mutable_state();
87 EXPECT_TRUE(state->certs.empty()); 83 EXPECT_TRUE(state->certs.empty());
88 const string server_config_a = "server_config_a"; 84 const string server_config_a = "server_config_a";
89 const string source_address_token_a = "source_address_token_a"; 85 const string source_address_token_a = "source_address_token_a";
90 const string server_config_sig_a = "server_config_sig_a"; 86 const string server_config_sig_a = "server_config_sig_a";
91 const string cert_a = "cert_a"; 87 const string cert_a = "cert_a";
92 const string cert_b = "cert_b"; 88 const string cert_b = "cert_b";
93 89
94 state->server_config = server_config_a; 90 state->server_config = server_config_a;
95 state->source_address_token = source_address_token_a; 91 state->source_address_token = source_address_token_a;
96 state->server_config_sig = server_config_sig_a; 92 state->server_config_sig = server_config_sig_a;
97 state->certs.push_back(cert_a); 93 state->certs.push_back(cert_a);
98 quic_server_info->Persist(); 94 quic_server_info->Persist();
99 95
100 // Wait until Persist() does the work. 96 // Wait until Persist() does the work.
101 base::MessageLoop::current()->RunUntilIdle(); 97 base::MessageLoop::current()->RunUntilIdle();
102 98
103 // Open the stored QuicServerInfo. 99 // Open the stored QuicServerInfo.
104 quic_server_info.reset( 100 quic_server_info.reset(
105 new DiskCacheBasedQuicServerInfo(server_key, cache.http_cache())); 101 new net::DiskCacheBasedQuicServerInfo(server_key, cache.http_cache()));
106 quic_server_info->Start(); 102 quic_server_info->Start();
107 rv = quic_server_info->WaitForDataReady(callback.callback()); 103 rv = quic_server_info->WaitForDataReady(callback.callback());
108 EXPECT_EQ(OK, callback.GetResult(rv)); 104 EXPECT_EQ(net::OK, callback.GetResult(rv));
109 105
110 // And now update the data. 106 // And now update the data.
111 state = quic_server_info->mutable_state(); 107 state = quic_server_info->mutable_state();
112 state->certs.push_back(cert_b); 108 state->certs.push_back(cert_b);
113 109
114 // Fail instead of DCHECKing double creates. 110 // Fail instead of DCHECKing double creates.
115 cache.disk_cache()->set_double_create_check(false); 111 cache.disk_cache()->set_double_create_check(false);
116 quic_server_info->Persist(); 112 quic_server_info->Persist();
117 base::MessageLoop::current()->RunUntilIdle(); 113 base::MessageLoop::current()->RunUntilIdle();
118 114
119 // Verify that the state was updated. 115 // Verify that the state was updated.
120 quic_server_info.reset( 116 quic_server_info.reset(
121 new DiskCacheBasedQuicServerInfo(server_key, cache.http_cache())); 117 new net::DiskCacheBasedQuicServerInfo(server_key, cache.http_cache()));
122 quic_server_info->Start(); 118 quic_server_info->Start();
123 rv = quic_server_info->WaitForDataReady(callback.callback()); 119 rv = quic_server_info->WaitForDataReady(callback.callback());
124 EXPECT_EQ(OK, callback.GetResult(rv)); 120 EXPECT_EQ(net::OK, callback.GetResult(rv));
125 EXPECT_TRUE(quic_server_info->IsDataReady()); 121 EXPECT_TRUE(quic_server_info->IsDataReady());
126 122
127 const QuicServerInfo::State& state1 = quic_server_info->state(); 123 const net::QuicServerInfo::State& state1 = quic_server_info->state();
128 EXPECT_EQ(server_config_a, state1.server_config); 124 EXPECT_EQ(server_config_a, state1.server_config);
129 EXPECT_EQ(source_address_token_a, state1.source_address_token); 125 EXPECT_EQ(source_address_token_a, state1.source_address_token);
130 EXPECT_EQ(server_config_sig_a, state1.server_config_sig); 126 EXPECT_EQ(server_config_sig_a, state1.server_config_sig);
131 EXPECT_EQ(2U, state1.certs.size()); 127 EXPECT_EQ(2U, state1.certs.size());
132 EXPECT_EQ(cert_a, state1.certs[0]); 128 EXPECT_EQ(cert_a, state1.certs[0]);
133 EXPECT_EQ(cert_b, state1.certs[1]); 129 EXPECT_EQ(cert_b, state1.certs[1]);
134 130
135 RemoveMockTransaction(&kHostInfoTransaction1); 131 RemoveMockTransaction(&kHostInfoTransaction1);
136 } 132 }
137 133
138 // Test that demonstrates different info is returned when the ports differ. 134 // Test that demonstrates different info is returned when the ports differ.
139 TEST(DiskCacheBasedQuicServerInfo, UpdateDifferentPorts) { 135 TEST(DiskCacheBasedQuicServerInfo, UpdateDifferentPorts) {
140 MockHttpCache cache; 136 MockHttpCache cache;
141 AddMockTransaction(&kHostInfoTransaction1); 137 AddMockTransaction(&kHostInfoTransaction1);
142 AddMockTransaction(&kHostInfoTransaction2); 138 AddMockTransaction(&kHostInfoTransaction2);
143 TestCompletionCallback callback; 139 net::TestCompletionCallback callback;
144 140
145 // Persist data for port 443. 141 // Persist data for port 443.
146 QuicSessionKey server_key1("www.google.com", 443, true, kPrivacyModeDisabled); 142 net::QuicSessionKey server_key1("www.google.com", 443, true);
147 scoped_ptr<QuicServerInfo> quic_server_info1( 143 scoped_ptr<net::QuicServerInfo> quic_server_info1(
148 new DiskCacheBasedQuicServerInfo(server_key1, cache.http_cache())); 144 new net::DiskCacheBasedQuicServerInfo(server_key1, cache.http_cache()));
149 quic_server_info1->Start(); 145 quic_server_info1->Start();
150 int rv = quic_server_info1->WaitForDataReady(callback.callback()); 146 int rv = quic_server_info1->WaitForDataReady(callback.callback());
151 EXPECT_EQ(OK, callback.GetResult(rv)); 147 EXPECT_EQ(net::OK, callback.GetResult(rv));
152 148
153 QuicServerInfo::State* state1 = quic_server_info1->mutable_state(); 149 net::QuicServerInfo::State* state1 = quic_server_info1->mutable_state();
154 EXPECT_TRUE(state1->certs.empty()); 150 EXPECT_TRUE(state1->certs.empty());
155 const string server_config_a = "server_config_a"; 151 const string server_config_a = "server_config_a";
156 const string source_address_token_a = "source_address_token_a"; 152 const string source_address_token_a = "source_address_token_a";
157 const string server_config_sig_a = "server_config_sig_a"; 153 const string server_config_sig_a = "server_config_sig_a";
158 const string cert_a = "cert_a"; 154 const string cert_a = "cert_a";
159 155
160 state1->server_config = server_config_a; 156 state1->server_config = server_config_a;
161 state1->source_address_token = source_address_token_a; 157 state1->source_address_token = source_address_token_a;
162 state1->server_config_sig = server_config_sig_a; 158 state1->server_config_sig = server_config_sig_a;
163 state1->certs.push_back(cert_a); 159 state1->certs.push_back(cert_a);
164 quic_server_info1->Persist(); 160 quic_server_info1->Persist();
165 161
166 // Wait until Persist() does the work. 162 // Wait until Persist() does the work.
167 base::MessageLoop::current()->RunUntilIdle(); 163 base::MessageLoop::current()->RunUntilIdle();
168 164
169 // Persist data for port 80. 165 // Persist data for port 80.
170 QuicSessionKey server_key2("www.google.com", 80, false, kPrivacyModeDisabled); 166 net::QuicSessionKey server_key2("www.google.com", 80, false);
171 scoped_ptr<QuicServerInfo> quic_server_info2( 167 scoped_ptr<net::QuicServerInfo> quic_server_info2(
172 new DiskCacheBasedQuicServerInfo(server_key2, cache.http_cache())); 168 new net::DiskCacheBasedQuicServerInfo(server_key2, cache.http_cache()));
173 quic_server_info2->Start(); 169 quic_server_info2->Start();
174 rv = quic_server_info2->WaitForDataReady(callback.callback()); 170 rv = quic_server_info2->WaitForDataReady(callback.callback());
175 EXPECT_EQ(OK, callback.GetResult(rv)); 171 EXPECT_EQ(net::OK, callback.GetResult(rv));
176 172
177 QuicServerInfo::State* state2 = quic_server_info2->mutable_state(); 173 net::QuicServerInfo::State* state2 = quic_server_info2->mutable_state();
178 EXPECT_TRUE(state2->certs.empty()); 174 EXPECT_TRUE(state2->certs.empty());
179 const string server_config_b = "server_config_b"; 175 const string server_config_b = "server_config_b";
180 const string source_address_token_b = "source_address_token_b"; 176 const string source_address_token_b = "source_address_token_b";
181 const string server_config_sig_b = "server_config_sig_b"; 177 const string server_config_sig_b = "server_config_sig_b";
182 const string cert_b = "cert_b"; 178 const string cert_b = "cert_b";
183 179
184 state2->server_config = server_config_b; 180 state2->server_config = server_config_b;
185 state2->source_address_token = source_address_token_b; 181 state2->source_address_token = source_address_token_b;
186 state2->server_config_sig = server_config_sig_b; 182 state2->server_config_sig = server_config_sig_b;
187 state2->certs.push_back(cert_b); 183 state2->certs.push_back(cert_b);
188 quic_server_info2->Persist(); 184 quic_server_info2->Persist();
189 185
190 // Wait until Persist() does the work. 186 // Wait until Persist() does the work.
191 base::MessageLoop::current()->RunUntilIdle(); 187 base::MessageLoop::current()->RunUntilIdle();
192 188
193 // Verify the stored QuicServerInfo for port 443. 189 // Verify the stored QuicServerInfo for port 443.
194 scoped_ptr<QuicServerInfo> quic_server_info( 190 scoped_ptr<net::QuicServerInfo> quic_server_info(
195 new DiskCacheBasedQuicServerInfo(server_key1, cache.http_cache())); 191 new net::DiskCacheBasedQuicServerInfo(server_key1, cache.http_cache()));
196 quic_server_info->Start(); 192 quic_server_info->Start();
197 rv = quic_server_info->WaitForDataReady(callback.callback()); 193 rv = quic_server_info->WaitForDataReady(callback.callback());
198 EXPECT_EQ(OK, callback.GetResult(rv)); 194 EXPECT_EQ(net::OK, callback.GetResult(rv));
199 EXPECT_TRUE(quic_server_info->IsDataReady()); 195 EXPECT_TRUE(quic_server_info->IsDataReady());
200 196
201 const QuicServerInfo::State& state_a = quic_server_info->state(); 197 const net::QuicServerInfo::State& state_a = quic_server_info->state();
202 EXPECT_EQ(server_config_a, state_a.server_config); 198 EXPECT_EQ(server_config_a, state_a.server_config);
203 EXPECT_EQ(source_address_token_a, state_a.source_address_token); 199 EXPECT_EQ(source_address_token_a, state_a.source_address_token);
204 EXPECT_EQ(server_config_sig_a, state_a.server_config_sig); 200 EXPECT_EQ(server_config_sig_a, state_a.server_config_sig);
205 EXPECT_EQ(1U, state_a.certs.size()); 201 EXPECT_EQ(1U, state_a.certs.size());
206 EXPECT_EQ(cert_a, state_a.certs[0]); 202 EXPECT_EQ(cert_a, state_a.certs[0]);
207 203
208 // Verify the stored QuicServerInfo for port 80. 204 // Verify the stored QuicServerInfo for port 80.
209 quic_server_info.reset( 205 quic_server_info.reset(
210 new DiskCacheBasedQuicServerInfo(server_key2, cache.http_cache())); 206 new net::DiskCacheBasedQuicServerInfo(server_key2, cache.http_cache()));
211 quic_server_info->Start(); 207 quic_server_info->Start();
212 rv = quic_server_info->WaitForDataReady(callback.callback()); 208 rv = quic_server_info->WaitForDataReady(callback.callback());
213 EXPECT_EQ(OK, callback.GetResult(rv)); 209 EXPECT_EQ(net::OK, callback.GetResult(rv));
214 EXPECT_TRUE(quic_server_info->IsDataReady()); 210 EXPECT_TRUE(quic_server_info->IsDataReady());
215 211
216 const QuicServerInfo::State& state_b = quic_server_info->state(); 212 const net::QuicServerInfo::State& state_b = quic_server_info->state();
217 EXPECT_EQ(server_config_b, state_b.server_config); 213 EXPECT_EQ(server_config_b, state_b.server_config);
218 EXPECT_EQ(source_address_token_b, state_b.source_address_token); 214 EXPECT_EQ(source_address_token_b, state_b.source_address_token);
219 EXPECT_EQ(server_config_sig_b, state_b.server_config_sig); 215 EXPECT_EQ(server_config_sig_b, state_b.server_config_sig);
220 EXPECT_EQ(1U, state_b.certs.size()); 216 EXPECT_EQ(1U, state_b.certs.size());
221 EXPECT_EQ(cert_b, state_b.certs[0]); 217 EXPECT_EQ(cert_b, state_b.certs[0]);
222 218
223 RemoveMockTransaction(&kHostInfoTransaction2); 219 RemoveMockTransaction(&kHostInfoTransaction2);
224 RemoveMockTransaction(&kHostInfoTransaction1); 220 RemoveMockTransaction(&kHostInfoTransaction1);
225 } 221 }
226 222
227 // Test IsReadyToPersist when there is a pending write. 223 // Test IsReadyToPersist when there is a pending write.
228 TEST(DiskCacheBasedQuicServerInfo, IsReadyToPersist) { 224 TEST(DiskCacheBasedQuicServerInfo, IsReadyToPersist) {
229 MockHttpCache cache; 225 MockHttpCache cache;
230 AddMockTransaction(&kHostInfoTransaction1); 226 AddMockTransaction(&kHostInfoTransaction1);
231 TestCompletionCallback callback; 227 net::TestCompletionCallback callback;
232 228
233 QuicSessionKey server_key("www.google.com", 443, true, kPrivacyModeDisabled); 229 net::QuicSessionKey server_key("www.google.com", 443, true);
234 scoped_ptr<QuicServerInfo> quic_server_info( 230 scoped_ptr<net::QuicServerInfo> quic_server_info(
235 new DiskCacheBasedQuicServerInfo(server_key, cache.http_cache())); 231 new net::DiskCacheBasedQuicServerInfo(server_key, cache.http_cache()));
236 EXPECT_FALSE(quic_server_info->IsDataReady()); 232 EXPECT_FALSE(quic_server_info->IsDataReady());
237 quic_server_info->Start(); 233 quic_server_info->Start();
238 int rv = quic_server_info->WaitForDataReady(callback.callback()); 234 int rv = quic_server_info->WaitForDataReady(callback.callback());
239 EXPECT_EQ(OK, callback.GetResult(rv)); 235 EXPECT_EQ(net::OK, callback.GetResult(rv));
240 EXPECT_TRUE(quic_server_info->IsDataReady()); 236 EXPECT_TRUE(quic_server_info->IsDataReady());
241 237
242 QuicServerInfo::State* state = quic_server_info->mutable_state(); 238 net::QuicServerInfo::State* state = quic_server_info->mutable_state();
243 EXPECT_TRUE(state->certs.empty()); 239 EXPECT_TRUE(state->certs.empty());
244 const string server_config_a = "server_config_a"; 240 const string server_config_a = "server_config_a";
245 const string source_address_token_a = "source_address_token_a"; 241 const string source_address_token_a = "source_address_token_a";
246 const string server_config_sig_a = "server_config_sig_a"; 242 const string server_config_sig_a = "server_config_sig_a";
247 const string cert_a = "cert_a"; 243 const string cert_a = "cert_a";
248 244
249 state->server_config = server_config_a; 245 state->server_config = server_config_a;
250 state->source_address_token = source_address_token_a; 246 state->source_address_token = source_address_token_a;
251 state->server_config_sig = server_config_sig_a; 247 state->server_config_sig = server_config_sig_a;
252 state->certs.push_back(cert_a); 248 state->certs.push_back(cert_a);
253 EXPECT_TRUE(quic_server_info->IsReadyToPersist()); 249 EXPECT_TRUE(quic_server_info->IsReadyToPersist());
254 quic_server_info->Persist(); 250 quic_server_info->Persist();
255 251
256 // Once we call Persist, IsReadyToPersist should return false until Persist 252 // Once we call Persist, IsReadyToPersist should return false until Persist
257 // has completed. 253 // has completed.
258 EXPECT_FALSE(quic_server_info->IsReadyToPersist()); 254 EXPECT_FALSE(quic_server_info->IsReadyToPersist());
259 255
260 // Wait until Persist() does the work. 256 // Wait until Persist() does the work.
261 base::MessageLoop::current()->RunUntilIdle(); 257 base::MessageLoop::current()->RunUntilIdle();
262 258
263 EXPECT_TRUE(quic_server_info->IsReadyToPersist()); 259 EXPECT_TRUE(quic_server_info->IsReadyToPersist());
264 260
265 // Verify that the state was updated. 261 // Verify that the state was updated.
266 quic_server_info.reset( 262 quic_server_info.reset(
267 new DiskCacheBasedQuicServerInfo(server_key, cache.http_cache())); 263 new net::DiskCacheBasedQuicServerInfo(server_key, cache.http_cache()));
268 quic_server_info->Start(); 264 quic_server_info->Start();
269 rv = quic_server_info->WaitForDataReady(callback.callback()); 265 rv = quic_server_info->WaitForDataReady(callback.callback());
270 EXPECT_EQ(OK, callback.GetResult(rv)); 266 EXPECT_EQ(net::OK, callback.GetResult(rv));
271 EXPECT_TRUE(quic_server_info->IsDataReady()); 267 EXPECT_TRUE(quic_server_info->IsDataReady());
272 268
273 const QuicServerInfo::State& state1 = quic_server_info->state(); 269 const net::QuicServerInfo::State& state1 = quic_server_info->state();
274 EXPECT_EQ(server_config_a, state1.server_config); 270 EXPECT_EQ(server_config_a, state1.server_config);
275 EXPECT_EQ(source_address_token_a, state1.source_address_token); 271 EXPECT_EQ(source_address_token_a, state1.source_address_token);
276 EXPECT_EQ(server_config_sig_a, state1.server_config_sig); 272 EXPECT_EQ(server_config_sig_a, state1.server_config_sig);
277 EXPECT_EQ(1U, state1.certs.size()); 273 EXPECT_EQ(1U, state1.certs.size());
278 EXPECT_EQ(cert_a, state1.certs[0]); 274 EXPECT_EQ(cert_a, state1.certs[0]);
279 275
280 RemoveMockTransaction(&kHostInfoTransaction1); 276 RemoveMockTransaction(&kHostInfoTransaction1);
281 } 277 }
282 278
283 } // namespace net 279 } // namespace
OLDNEW
« no previous file with comments | « no previous file | net/http/http_stream_factory_impl_job.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698