| OLD | NEW | 
|     1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |     1 // Copyright (c) 2012 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/quic/quic_stream_factory.h" |     5 #include "net/quic/quic_stream_factory.h" | 
|     6  |     6  | 
|     7 #include "base/run_loop.h" |     7 #include "base/run_loop.h" | 
|     8 #include "base/strings/string_util.h" |     8 #include "base/strings/string_util.h" | 
|     9 #include "base/thread_task_runner_handle.h" |     9 #include "base/thread_task_runner_handle.h" | 
|    10 #include "net/base/test_data_directory.h" |    10 #include "net/base/test_data_directory.h" | 
| (...skipping 3643 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  3654                        // EXPY |  3654                        // EXPY | 
|  3655                        0x45, 0x58, 0x50, 0x59, |  3655                        0x45, 0x58, 0x50, 0x59, | 
|  3656                        // EXPY end offset |  3656                        // EXPY end offset | 
|  3657                        0x08, 0x00, 0x00, 0x00, |  3657                        0x08, 0x00, 0x00, 0x00, | 
|  3658                        // Value |  3658                        // Value | 
|  3659                        '1', '2', '3', '4', '5', '6', '7', '8'}; |  3659                        '1', '2', '3', '4', '5', '6', '7', '8'}; | 
|  3660  |  3660  | 
|  3661   // Create temporary strings becasue Persist() clears string data in |state|. |  3661   // Create temporary strings becasue Persist() clears string data in |state|. | 
|  3662   string server_config(reinterpret_cast<const char*>(&scfg), sizeof(scfg)); |  3662   string server_config(reinterpret_cast<const char*>(&scfg), sizeof(scfg)); | 
|  3663   string source_address_token("test_source_address_token"); |  3663   string source_address_token("test_source_address_token"); | 
 |  3664   string cert_sct("test_cert_sct"); | 
 |  3665   string chlo_hash("test_chlo_hash"); | 
|  3664   string signature("test_signature"); |  3666   string signature("test_signature"); | 
|  3665   string test_cert("test_cert"); |  3667   string test_cert("test_cert"); | 
|  3666   vector<string> certs; |  3668   vector<string> certs; | 
|  3667   certs.push_back(test_cert); |  3669   certs.push_back(test_cert); | 
|  3668   state->server_config = server_config; |  3670   state->server_config = server_config; | 
|  3669   state->source_address_token = source_address_token; |  3671   state->source_address_token = source_address_token; | 
 |  3672   state->cert_sct = cert_sct; | 
 |  3673   state->chlo_hash = chlo_hash; | 
|  3670   state->server_config_sig = signature; |  3674   state->server_config_sig = signature; | 
|  3671   state->certs = certs; |  3675   state->certs = certs; | 
|  3672  |  3676  | 
|  3673   quic_server_info->Persist(); |  3677   quic_server_info->Persist(); | 
|  3674  |  3678  | 
|  3675   QuicStreamFactoryPeer::MaybeInitialize(factory_.get()); |  3679   QuicStreamFactoryPeer::MaybeInitialize(factory_.get()); | 
|  3676   EXPECT_TRUE(QuicStreamFactoryPeer::HasInitializedData(factory_.get())); |  3680   EXPECT_TRUE(QuicStreamFactoryPeer::HasInitializedData(factory_.get())); | 
|  3677   EXPECT_TRUE(QuicStreamFactoryPeer::SupportsQuicAtStartUp(factory_.get(), |  3681   EXPECT_TRUE(QuicStreamFactoryPeer::SupportsQuicAtStartUp(factory_.get(), | 
|  3678                                                            host_port_pair_)); |  3682                                                            host_port_pair_)); | 
|  3679   EXPECT_FALSE(QuicStreamFactoryPeer::CryptoConfigCacheIsEmpty(factory_.get(), |  3683   EXPECT_FALSE(QuicStreamFactoryPeer::CryptoConfigCacheIsEmpty(factory_.get(), | 
|  3680                                                                quic_server_id)); |  3684                                                                quic_server_id)); | 
|  3681   QuicCryptoClientConfig* crypto_config = |  3685   QuicCryptoClientConfig* crypto_config = | 
|  3682       QuicStreamFactoryPeer::GetCryptoConfig(factory_.get()); |  3686       QuicStreamFactoryPeer::GetCryptoConfig(factory_.get()); | 
|  3683   QuicCryptoClientConfig::CachedState* cached = |  3687   QuicCryptoClientConfig::CachedState* cached = | 
|  3684       crypto_config->LookupOrCreate(quic_server_id); |  3688       crypto_config->LookupOrCreate(quic_server_id); | 
|  3685   EXPECT_FALSE(cached->server_config().empty()); |  3689   EXPECT_FALSE(cached->server_config().empty()); | 
|  3686   EXPECT_TRUE(cached->GetServerConfig()); |  3690   EXPECT_TRUE(cached->GetServerConfig()); | 
|  3687   EXPECT_EQ(server_config, cached->server_config()); |  3691   EXPECT_EQ(server_config, cached->server_config()); | 
|  3688   EXPECT_EQ(source_address_token, cached->source_address_token()); |  3692   EXPECT_EQ(source_address_token, cached->source_address_token()); | 
 |  3693   EXPECT_EQ(cert_sct, cached->cert_sct()); | 
 |  3694   EXPECT_EQ(chlo_hash, cached->chlo_hash()); | 
|  3689   EXPECT_EQ(signature, cached->signature()); |  3695   EXPECT_EQ(signature, cached->signature()); | 
|  3690   ASSERT_EQ(1U, cached->certs().size()); |  3696   ASSERT_EQ(1U, cached->certs().size()); | 
|  3691   EXPECT_EQ(test_cert, cached->certs()[0]); |  3697   EXPECT_EQ(test_cert, cached->certs()[0]); | 
|  3692 } |  3698 } | 
|  3693  |  3699  | 
|  3694 TEST_P(QuicStreamFactoryTest, QuicDoingZeroRTT) { |  3700 TEST_P(QuicStreamFactoryTest, QuicDoingZeroRTT) { | 
|  3695   Initialize(); |  3701   Initialize(); | 
|  3696  |  3702  | 
|  3697   factory_->set_require_confirmation(true); |  3703   factory_->set_require_confirmation(true); | 
|  3698   QuicServerId quic_server_id(host_port_pair_, PRIVACY_MODE_DISABLED); |  3704   QuicServerId quic_server_id(host_port_pair_, PRIVACY_MODE_DISABLED); | 
| (...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  3902   EXPECT_TRUE(stream2.get()); |  3908   EXPECT_TRUE(stream2.get()); | 
|  3903  |  3909  | 
|  3904   EXPECT_TRUE(socket_data1.AllReadDataConsumed()); |  3910   EXPECT_TRUE(socket_data1.AllReadDataConsumed()); | 
|  3905   EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); |  3911   EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); | 
|  3906   EXPECT_TRUE(socket_data2.AllReadDataConsumed()); |  3912   EXPECT_TRUE(socket_data2.AllReadDataConsumed()); | 
|  3907   EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); |  3913   EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); | 
|  3908 } |  3914 } | 
|  3909  |  3915  | 
|  3910 }  // namespace test |  3916 }  // namespace test | 
|  3911 }  // namespace net |  3917 }  // namespace net | 
| OLD | NEW |