| 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 3726 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3737 ProofVerifyDetailsChromium verify_details = DefaultProofVerifyDetails(); | 3737 ProofVerifyDetailsChromium verify_details = DefaultProofVerifyDetails(); |
| 3738 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); | 3738 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); |
| 3739 bool delay_tcp_race = QuicStreamFactoryPeer::GetDelayTcpRace(factory_.get()); | 3739 bool delay_tcp_race = QuicStreamFactoryPeer::GetDelayTcpRace(factory_.get()); |
| 3740 QuicStreamFactoryPeer::SetDelayTcpRace(factory_.get(), false); | 3740 QuicStreamFactoryPeer::SetDelayTcpRace(factory_.get(), false); |
| 3741 MockRead reads[] = {MockRead(SYNCHRONOUS, ERR_IO_PENDING, 0)}; | 3741 MockRead reads[] = {MockRead(SYNCHRONOUS, ERR_IO_PENDING, 0)}; |
| 3742 SequencedSocketData socket_data(reads, arraysize(reads), nullptr, 0); | 3742 SequencedSocketData socket_data(reads, arraysize(reads), nullptr, 0); |
| 3743 socket_factory_.AddSocketDataProvider(&socket_data); | 3743 socket_factory_.AddSocketDataProvider(&socket_data); |
| 3744 | 3744 |
| 3745 ServerNetworkStats stats1; | 3745 ServerNetworkStats stats1; |
| 3746 stats1.srtt = base::TimeDelta::FromMicroseconds(10); | 3746 stats1.srtt = base::TimeDelta::FromMicroseconds(10); |
| 3747 http_server_properties_.SetServerNetworkStats(host_port_pair_, stats1); | 3747 url::SchemeHostPort server("https", kDefaultServerHostName, |
| 3748 kDefaultServerPort); |
| 3749 http_server_properties_.SetServerNetworkStats(server, stats1); |
| 3748 | 3750 |
| 3749 crypto_client_stream_factory_.set_handshake_mode( | 3751 crypto_client_stream_factory_.set_handshake_mode( |
| 3750 MockCryptoClientStream::ZERO_RTT); | 3752 MockCryptoClientStream::ZERO_RTT); |
| 3751 host_resolver_.set_synchronous_mode(true); | 3753 host_resolver_.set_synchronous_mode(true); |
| 3752 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), | 3754 host_resolver_.rules()->AddIPLiteralRule(host_port_pair_.host(), |
| 3753 "192.168.0.1", ""); | 3755 "192.168.0.1", ""); |
| 3754 | 3756 |
| 3755 QuicStreamRequest request(factory_.get()); | 3757 QuicStreamRequest request(factory_.get()); |
| 3756 EXPECT_EQ(ERR_IO_PENDING, | 3758 EXPECT_EQ(ERR_IO_PENDING, |
| 3757 request.Request(host_port_pair_, privacy_mode_, | 3759 request.Request(host_port_pair_, privacy_mode_, |
| (...skipping 398 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4156 EXPECT_TRUE(stream2.get()); | 4158 EXPECT_TRUE(stream2.get()); |
| 4157 | 4159 |
| 4158 EXPECT_TRUE(socket_data1.AllReadDataConsumed()); | 4160 EXPECT_TRUE(socket_data1.AllReadDataConsumed()); |
| 4159 EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); | 4161 EXPECT_TRUE(socket_data1.AllWriteDataConsumed()); |
| 4160 EXPECT_TRUE(socket_data2.AllReadDataConsumed()); | 4162 EXPECT_TRUE(socket_data2.AllReadDataConsumed()); |
| 4161 EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); | 4163 EXPECT_TRUE(socket_data2.AllWriteDataConsumed()); |
| 4162 } | 4164 } |
| 4163 | 4165 |
| 4164 } // namespace test | 4166 } // namespace test |
| 4165 } // namespace net | 4167 } // namespace net |
| OLD | NEW |