| 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 2682 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2693 SequencedSocketData socket_data2(reads2, arraysize(reads2), nullptr, 0); | 2693 SequencedSocketData socket_data2(reads2, arraysize(reads2), nullptr, 0); |
| 2694 socket_factory_.AddSocketDataProvider(&socket_data2); | 2694 socket_factory_.AddSocketDataProvider(&socket_data2); |
| 2695 | 2695 |
| 2696 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), | 2696 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), |
| 2697 host_port_pair_.port()); | 2697 host_port_pair_.port()); |
| 2698 AlternativeServiceInfoVector alternative_service_info_vector; | 2698 AlternativeServiceInfoVector alternative_service_info_vector; |
| 2699 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); | 2699 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
| 2700 alternative_service_info_vector.push_back( | 2700 alternative_service_info_vector.push_back( |
| 2701 AlternativeServiceInfo(alternative_service1, expiration)); | 2701 AlternativeServiceInfo(alternative_service1, expiration)); |
| 2702 | 2702 |
| 2703 url::SchemeHostPort server("https", kDefaultServerHostName, |
| 2704 kDefaultServerPort); |
| 2705 |
| 2703 http_server_properties_.SetAlternativeServices( | 2706 http_server_properties_.SetAlternativeServices( |
| 2704 host_port_pair_, alternative_service_info_vector); | 2707 server, alternative_service_info_vector); |
| 2705 | 2708 |
| 2706 crypto_client_stream_factory_.set_handshake_mode( | 2709 crypto_client_stream_factory_.set_handshake_mode( |
| 2707 MockCryptoClientStream::ZERO_RTT); | 2710 MockCryptoClientStream::ZERO_RTT); |
| 2708 host_resolver_.set_synchronous_mode(true); | 2711 host_resolver_.set_synchronous_mode(true); |
| 2709 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), | 2712 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), |
| 2710 "192.168.0.1", ""); | 2713 "192.168.0.1", ""); |
| 2711 | 2714 |
| 2712 QuicStreamRequest request(factory_.get()); | 2715 QuicStreamRequest request(factory_.get()); |
| 2713 QuicServerId server_id(host_port_pair_, privacy_mode_); | 2716 QuicServerId server_id(host_port_pair_, privacy_mode_); |
| 2714 EXPECT_EQ(ERR_IO_PENDING, | 2717 EXPECT_EQ(ERR_IO_PENDING, |
| (...skipping 1078 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3793 EXPECT_EQ(500, config->IdleConnectionStateLifetime().ToSeconds()); | 3796 EXPECT_EQ(500, config->IdleConnectionStateLifetime().ToSeconds()); |
| 3794 | 3797 |
| 3795 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); | 3798 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); |
| 3796 | 3799 |
| 3797 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), | 3800 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), |
| 3798 host_port_pair_.port()); | 3801 host_port_pair_.port()); |
| 3799 AlternativeServiceInfoVector alternative_service_info_vector; | 3802 AlternativeServiceInfoVector alternative_service_info_vector; |
| 3800 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); | 3803 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
| 3801 alternative_service_info_vector.push_back( | 3804 alternative_service_info_vector.push_back( |
| 3802 AlternativeServiceInfo(alternative_service1, expiration)); | 3805 AlternativeServiceInfo(alternative_service1, expiration)); |
| 3803 | 3806 url::SchemeHostPort server("https", kDefaultServerHostName, |
| 3807 kDefaultServerPort); |
| 3804 http_server_properties_.SetAlternativeServices( | 3808 http_server_properties_.SetAlternativeServices( |
| 3805 host_port_pair_, alternative_service_info_vector); | 3809 server, alternative_service_info_vector); |
| 3806 | 3810 |
| 3807 HostPortPair host_port_pair2(kServer2HostName, kDefaultServerPort); | 3811 HostPortPair host_port_pair2(kServer2HostName, kDefaultServerPort); |
| 3812 url::SchemeHostPort server2("https", kServer2HostName, kDefaultServerPort); |
| 3808 const AlternativeService alternative_service2(QUIC, host_port_pair2.host(), | 3813 const AlternativeService alternative_service2(QUIC, host_port_pair2.host(), |
| 3809 host_port_pair2.port()); | 3814 host_port_pair2.port()); |
| 3810 AlternativeServiceInfoVector alternative_service_info_vector2; | 3815 AlternativeServiceInfoVector alternative_service_info_vector2; |
| 3811 alternative_service_info_vector2.push_back( | 3816 alternative_service_info_vector2.push_back( |
| 3812 AlternativeServiceInfo(alternative_service2, expiration)); | 3817 AlternativeServiceInfo(alternative_service2, expiration)); |
| 3813 http_server_properties_.SetAlternativeServices( | 3818 http_server_properties_.SetAlternativeServices( |
| 3814 host_port_pair2, alternative_service_info_vector2); | 3819 server2, alternative_service_info_vector2); |
| 3815 | 3820 |
| 3816 http_server_properties_.SetMaxServerConfigsStoredInProperties( | 3821 http_server_properties_.SetMaxServerConfigsStoredInProperties( |
| 3817 kMaxQuicServersToPersist); | 3822 kMaxQuicServersToPersist); |
| 3818 | 3823 |
| 3819 QuicServerId quic_server_id(kDefaultServerHostName, 80, | 3824 QuicServerId quic_server_id(kDefaultServerHostName, 80, |
| 3820 PRIVACY_MODE_DISABLED); | 3825 PRIVACY_MODE_DISABLED); |
| 3821 QuicServerInfoFactory* quic_server_info_factory = | 3826 QuicServerInfoFactory* quic_server_info_factory = |
| 3822 new PropertiesBasedQuicServerInfoFactory( | 3827 new PropertiesBasedQuicServerInfoFactory( |
| 3823 http_server_properties_.GetWeakPtr()); | 3828 http_server_properties_.GetWeakPtr()); |
| 3824 factory_->set_quic_server_info_factory(quic_server_info_factory); | 3829 factory_->set_quic_server_info_factory(quic_server_info_factory); |
| (...skipping 333 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4158 EXPECT_TRUE(stream2.get()); | 4163 EXPECT_TRUE(stream2.get()); |
| 4159 | 4164 |
| 4160 EXPECT_TRUE(socket_data1.AllReadDataConsumed()); | 4165 EXPECT_TRUE(socket_data1.AllReadDataConsumed()); |
| 4161 EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); | 4166 EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); |
| 4162 EXPECT_TRUE(socket_data2.AllReadDataConsumed()); | 4167 EXPECT_TRUE(socket_data2.AllReadDataConsumed()); |
| 4163 EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); | 4168 EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); |
| 4164 } | 4169 } |
| 4165 | 4170 |
| 4166 } // namespace test | 4171 } // namespace test |
| 4167 } // namespace net | 4172 } // namespace net |
| OLD | NEW |