OLD | NEW |
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 |
OLD | NEW |