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

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: fix compile after sync code, introduced by commit 388755 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
« no previous file with comments | « net/quic/quic_stream_factory.cc ('k') | net/spdy/spdy_network_transaction_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 2643 matching lines...) Expand 10 before | Expand all | Expand 10 after
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
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
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
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
OLDNEW
« no previous file with comments | « net/quic/quic_stream_factory.cc ('k') | net/spdy/spdy_network_transaction_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698