Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(354)

Side by Side Diff: net/quic/quic_stream_factory_test.cc

Issue 1904483004: Change SupportsSpdy dict, SpdySettingsMap, ServerNetworkStatsMap, AlternativeServiceMap and disk da… (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: git cl format net Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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 1022 matching lines...) Expand 10 before | Expand all | Expand 10 after
3737 ProofVerifyDetailsChromium verify_details = DefaultProofVerifyDetails(); 3740 ProofVerifyDetailsChromium verify_details = DefaultProofVerifyDetails();
3738 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); 3741 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details);
3739 bool delay_tcp_race = QuicStreamFactoryPeer::GetDelayTcpRace(factory_.get()); 3742 bool delay_tcp_race = QuicStreamFactoryPeer::GetDelayTcpRace(factory_.get());
3740 QuicStreamFactoryPeer::SetDelayTcpRace(factory_.get(), false); 3743 QuicStreamFactoryPeer::SetDelayTcpRace(factory_.get(), false);
3741 MockRead reads[] = {MockRead(SYNCHRONOUS, ERR_IO_PENDING, 0)}; 3744 MockRead reads[] = {MockRead(SYNCHRONOUS, ERR_IO_PENDING, 0)};
3742 SequencedSocketData socket_data(reads, arraysize(reads), nullptr, 0); 3745 SequencedSocketData socket_data(reads, arraysize(reads), nullptr, 0);
3743 socket_factory_.AddSocketDataProvider(&socket_data); 3746 socket_factory_.AddSocketDataProvider(&socket_data);
3744 3747
3745 ServerNetworkStats stats1; 3748 ServerNetworkStats stats1;
3746 stats1.srtt = base::TimeDelta::FromMicroseconds(10); 3749 stats1.srtt = base::TimeDelta::FromMicroseconds(10);
3747 http_server_properties_.SetServerNetworkStats(host_port_pair_, stats1); 3750 url::SchemeHostPort server("https", kDefaultServerHostName,
3751 kDefaultServerPort);
3752 http_server_properties_.SetServerNetworkStats(server, stats1);
3748 3753
3749 crypto_client_stream_factory_.set_handshake_mode( 3754 crypto_client_stream_factory_.set_handshake_mode(
3750 MockCryptoClientStream::ZERO_RTT); 3755 MockCryptoClientStream::ZERO_RTT);
3751 host_resolver_.set_synchronous_mode(true); 3756 host_resolver_.set_synchronous_mode(true);
3752 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), 3757 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(),
3753 "192.168.0.1", ""); 3758 "192.168.0.1", "");
3754 3759
3755 QuicStreamRequest request(factory_.get()); 3760 QuicStreamRequest request(factory_.get());
3756 EXPECT_EQ(ERR_IO_PENDING, 3761 EXPECT_EQ(ERR_IO_PENDING,
3757 request.Request(host_port_pair_, privacy_mode_, 3762 request.Request(host_port_pair_, privacy_mode_,
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after
3791 EXPECT_EQ(500, config->IdleConnectionStateLifetime().ToSeconds()); 3796 EXPECT_EQ(500, config->IdleConnectionStateLifetime().ToSeconds());
3792 3797
3793 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); 3798 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get());
3794 3799
3795 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), 3800 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(),
3796 host_port_pair_.port()); 3801 host_port_pair_.port());
3797 AlternativeServiceInfoVector alternative_service_info_vector; 3802 AlternativeServiceInfoVector alternative_service_info_vector;
3798 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); 3803 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1);
3799 alternative_service_info_vector.push_back( 3804 alternative_service_info_vector.push_back(
3800 AlternativeServiceInfo(alternative_service1, expiration)); 3805 AlternativeServiceInfo(alternative_service1, expiration));
3801 3806 url::SchemeHostPort server("https", kDefaultServerHostName,
3807 kDefaultServerPort);
3802 http_server_properties_.SetAlternativeServices( 3808 http_server_properties_.SetAlternativeServices(
3803 host_port_pair_, alternative_service_info_vector); 3809 server, alternative_service_info_vector);
3804 3810
3805 HostPortPair host_port_pair2(kServer2HostName, kDefaultServerPort); 3811 HostPortPair host_port_pair2(kServer2HostName, kDefaultServerPort);
3812 url::SchemeHostPort server2("https", kServer2HostName, kDefaultServerPort);
3806 const AlternativeService alternative_service2(QUIC, host_port_pair2.host(), 3813 const AlternativeService alternative_service2(QUIC, host_port_pair2.host(),
3807 host_port_pair2.port()); 3814 host_port_pair2.port());
3808 AlternativeServiceInfoVector alternative_service_info_vector2; 3815 AlternativeServiceInfoVector alternative_service_info_vector2;
3809 alternative_service_info_vector2.push_back( 3816 alternative_service_info_vector2.push_back(
3810 AlternativeServiceInfo(alternative_service2, expiration)); 3817 AlternativeServiceInfo(alternative_service2, expiration));
3811 http_server_properties_.SetAlternativeServices( 3818 http_server_properties_.SetAlternativeServices(
3812 host_port_pair2, alternative_service_info_vector2); 3819 server2, alternative_service_info_vector2);
3813 3820
3814 http_server_properties_.SetMaxServerConfigsStoredInProperties( 3821 http_server_properties_.SetMaxServerConfigsStoredInProperties(
3815 kMaxQuicServersToPersist); 3822 kMaxQuicServersToPersist);
3816 3823
3817 QuicServerId quic_server_id(kDefaultServerHostName, 80, 3824 QuicServerId quic_server_id(kDefaultServerHostName, 80,
3818 PRIVACY_MODE_DISABLED); 3825 PRIVACY_MODE_DISABLED);
3819 QuicServerInfoFactory* quic_server_info_factory = 3826 QuicServerInfoFactory* quic_server_info_factory =
3820 new PropertiesBasedQuicServerInfoFactory( 3827 new PropertiesBasedQuicServerInfoFactory(
3821 http_server_properties_.GetWeakPtr()); 3828 http_server_properties_.GetWeakPtr());
3822 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
4156 EXPECT_TRUE(stream2.get()); 4163 EXPECT_TRUE(stream2.get());
4157 4164
4158 EXPECT_TRUE(socket_data1.AllReadDataConsumed()); 4165 EXPECT_TRUE(socket_data1.AllReadDataConsumed());
4159 EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); 4166 EXPECT_TRUE(socket_data1.AllWriteDataConsumed());
4160 EXPECT_TRUE(socket_data2.AllReadDataConsumed()); 4167 EXPECT_TRUE(socket_data2.AllReadDataConsumed());
4161 EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); 4168 EXPECT_TRUE(socket_data2.AllWriteDataConsumed());
4162 } 4169 }
4163 4170
4164 } // namespace test 4171 } // namespace test
4165 } // namespace net 4172 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698