| 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 2643 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2654 SequencedSocketData socket_data2(reads2, arraysize(reads2), nullptr, 0); | 2654 SequencedSocketData socket_data2(reads2, arraysize(reads2), nullptr, 0); |
| 2655 socket_factory_.AddSocketDataProvider(&socket_data2); | 2655 socket_factory_.AddSocketDataProvider(&socket_data2); |
| 2656 | 2656 |
| 2657 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), | 2657 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), |
| 2658 host_port_pair_.port()); | 2658 host_port_pair_.port()); |
| 2659 AlternativeServiceInfoVector alternative_service_info_vector; | 2659 AlternativeServiceInfoVector alternative_service_info_vector; |
| 2660 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); | 2660 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
| 2661 alternative_service_info_vector.push_back( | 2661 alternative_service_info_vector.push_back( |
| 2662 AlternativeServiceInfo(alternative_service1, expiration)); | 2662 AlternativeServiceInfo(alternative_service1, expiration)); |
| 2663 | 2663 |
| 2664 url::SchemeHostPort server("https", kDefaultServerHostName, |
| 2665 kDefaultServerPort); |
| 2666 |
| 2664 http_server_properties_.SetAlternativeServices( | 2667 http_server_properties_.SetAlternativeServices( |
| 2665 host_port_pair_, alternative_service_info_vector); | 2668 server, alternative_service_info_vector); |
| 2666 | 2669 |
| 2667 crypto_client_stream_factory_.set_handshake_mode( | 2670 crypto_client_stream_factory_.set_handshake_mode( |
| 2668 MockCryptoClientStream::ZERO_RTT); | 2671 MockCryptoClientStream::ZERO_RTT); |
| 2669 host_resolver_.set_synchronous_mode(true); | 2672 host_resolver_.set_synchronous_mode(true); |
| 2670 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), | 2673 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), |
| 2671 "192.168.0.1", ""); | 2674 "192.168.0.1", ""); |
| 2672 | 2675 |
| 2673 QuicStreamRequest request(factory_.get()); | 2676 QuicStreamRequest request(factory_.get()); |
| 2674 QuicServerId server_id(host_port_pair_, privacy_mode_); | 2677 QuicServerId server_id(host_port_pair_, privacy_mode_); |
| 2675 EXPECT_EQ(ERR_IO_PENDING, | 2678 EXPECT_EQ(ERR_IO_PENDING, |
| (...skipping 995 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3671 ProofVerifyDetailsChromium verify_details = DefaultProofVerifyDetails(); | 3674 ProofVerifyDetailsChromium verify_details = DefaultProofVerifyDetails(); |
| 3672 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); | 3675 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); |
| 3673 bool delay_tcp_race = QuicStreamFactoryPeer::GetDelayTcpRace(factory_.get()); | 3676 bool delay_tcp_race = QuicStreamFactoryPeer::GetDelayTcpRace(factory_.get()); |
| 3674 QuicStreamFactoryPeer::SetDelayTcpRace(factory_.get(), false); | 3677 QuicStreamFactoryPeer::SetDelayTcpRace(factory_.get(), false); |
| 3675 MockRead reads[] = {MockRead(SYNCHRONOUS, ERR_IO_PENDING, 0)}; | 3678 MockRead reads[] = {MockRead(SYNCHRONOUS, ERR_IO_PENDING, 0)}; |
| 3676 SequencedSocketData socket_data(reads, arraysize(reads), nullptr, 0); | 3679 SequencedSocketData socket_data(reads, arraysize(reads), nullptr, 0); |
| 3677 socket_factory_.AddSocketDataProvider(&socket_data); | 3680 socket_factory_.AddSocketDataProvider(&socket_data); |
| 3678 | 3681 |
| 3679 ServerNetworkStats stats1; | 3682 ServerNetworkStats stats1; |
| 3680 stats1.srtt = base::TimeDelta::FromMicroseconds(10); | 3683 stats1.srtt = base::TimeDelta::FromMicroseconds(10); |
| 3681 http_server_properties_.SetServerNetworkStats(host_port_pair_, stats1); | 3684 url::SchemeHostPort server("https", kDefaultServerHostName, |
| 3685 kDefaultServerPort); |
| 3686 http_server_properties_.SetServerNetworkStats(server, stats1); |
| 3682 | 3687 |
| 3683 crypto_client_stream_factory_.set_handshake_mode( | 3688 crypto_client_stream_factory_.set_handshake_mode( |
| 3684 MockCryptoClientStream::ZERO_RTT); | 3689 MockCryptoClientStream::ZERO_RTT); |
| 3685 host_resolver_.set_synchronous_mode(true); | 3690 host_resolver_.set_synchronous_mode(true); |
| 3686 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), | 3691 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), |
| 3687 "192.168.0.1", ""); | 3692 "192.168.0.1", ""); |
| 3688 | 3693 |
| 3689 QuicStreamRequest request(factory_.get()); | 3694 QuicStreamRequest request(factory_.get()); |
| 3690 EXPECT_EQ(ERR_IO_PENDING, | 3695 EXPECT_EQ(ERR_IO_PENDING, |
| 3691 request.Request(host_port_pair_, privacy_mode_, | 3696 request.Request(host_port_pair_, privacy_mode_, |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3725 EXPECT_EQ(500, config->IdleConnectionStateLifetime().ToSeconds()); | 3730 EXPECT_EQ(500, config->IdleConnectionStateLifetime().ToSeconds()); |
| 3726 | 3731 |
| 3727 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); | 3732 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); |
| 3728 | 3733 |
| 3729 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), | 3734 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), |
| 3730 host_port_pair_.port()); | 3735 host_port_pair_.port()); |
| 3731 AlternativeServiceInfoVector alternative_service_info_vector; | 3736 AlternativeServiceInfoVector alternative_service_info_vector; |
| 3732 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); | 3737 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
| 3733 alternative_service_info_vector.push_back( | 3738 alternative_service_info_vector.push_back( |
| 3734 AlternativeServiceInfo(alternative_service1, expiration)); | 3739 AlternativeServiceInfo(alternative_service1, expiration)); |
| 3735 | 3740 url::SchemeHostPort server("https", kDefaultServerHostName, |
| 3741 kDefaultServerPort); |
| 3736 http_server_properties_.SetAlternativeServices( | 3742 http_server_properties_.SetAlternativeServices( |
| 3737 host_port_pair_, alternative_service_info_vector); | 3743 server, alternative_service_info_vector); |
| 3738 | 3744 |
| 3739 HostPortPair host_port_pair2(kServer2HostName, kDefaultServerPort); | 3745 HostPortPair host_port_pair2(kServer2HostName, kDefaultServerPort); |
| 3746 url::SchemeHostPort server2("https", kServer2HostName, kDefaultServerPort); |
| 3740 const AlternativeService alternative_service2(QUIC, host_port_pair2.host(), | 3747 const AlternativeService alternative_service2(QUIC, host_port_pair2.host(), |
| 3741 host_port_pair2.port()); | 3748 host_port_pair2.port()); |
| 3742 AlternativeServiceInfoVector alternative_service_info_vector2; | 3749 AlternativeServiceInfoVector alternative_service_info_vector2; |
| 3743 alternative_service_info_vector2.push_back( | 3750 alternative_service_info_vector2.push_back( |
| 3744 AlternativeServiceInfo(alternative_service2, expiration)); | 3751 AlternativeServiceInfo(alternative_service2, expiration)); |
| 3745 http_server_properties_.SetAlternativeServices( | 3752 http_server_properties_.SetAlternativeServices( |
| 3746 host_port_pair2, alternative_service_info_vector2); | 3753 server2, alternative_service_info_vector2); |
| 3747 | 3754 |
| 3748 http_server_properties_.SetMaxServerConfigsStoredInProperties( | 3755 http_server_properties_.SetMaxServerConfigsStoredInProperties( |
| 3749 kMaxQuicServersToPersist); | 3756 kMaxQuicServersToPersist); |
| 3750 | 3757 |
| 3751 QuicServerId quic_server_id(kDefaultServerHostName, 80, | 3758 QuicServerId quic_server_id(kDefaultServerHostName, 80, |
| 3752 PRIVACY_MODE_DISABLED); | 3759 PRIVACY_MODE_DISABLED); |
| 3753 QuicServerInfoFactory* quic_server_info_factory = | 3760 QuicServerInfoFactory* quic_server_info_factory = |
| 3754 new PropertiesBasedQuicServerInfoFactory( | 3761 new PropertiesBasedQuicServerInfoFactory( |
| 3755 http_server_properties_.GetWeakPtr()); | 3762 http_server_properties_.GetWeakPtr()); |
| 3756 factory_->set_quic_server_info_factory(quic_server_info_factory); | 3763 factory_->set_quic_server_info_factory(quic_server_info_factory); |
| (...skipping 331 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4088 EXPECT_TRUE(stream2.get()); | 4095 EXPECT_TRUE(stream2.get()); |
| 4089 | 4096 |
| 4090 EXPECT_TRUE(socket_data1.AllReadDataConsumed()); | 4097 EXPECT_TRUE(socket_data1.AllReadDataConsumed()); |
| 4091 EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); | 4098 EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); |
| 4092 EXPECT_TRUE(socket_data2.AllReadDataConsumed()); | 4099 EXPECT_TRUE(socket_data2.AllReadDataConsumed()); |
| 4093 EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); | 4100 EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); |
| 4094 } | 4101 } |
| 4095 | 4102 |
| 4096 } // namespace test | 4103 } // namespace test |
| 4097 } // namespace net | 4104 } // namespace net |
| OLD | NEW |