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