| 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/chromium/quic_stream_factory.h" | 5 #include "net/quic/chromium/quic_stream_factory.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <ostream> | 8 #include <ostream> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 25 matching lines...) Expand all Loading... |
| 36 #include "net/quic/core/quic_client_promised_info.h" | 36 #include "net/quic/core/quic_client_promised_info.h" |
| 37 #include "net/quic/core/quic_http_utils.h" | 37 #include "net/quic/core/quic_http_utils.h" |
| 38 #include "net/quic/test_tools/mock_clock.h" | 38 #include "net/quic/test_tools/mock_clock.h" |
| 39 #include "net/quic/test_tools/mock_crypto_client_stream_factory.h" | 39 #include "net/quic/test_tools/mock_crypto_client_stream_factory.h" |
| 40 #include "net/quic/test_tools/mock_random.h" | 40 #include "net/quic/test_tools/mock_random.h" |
| 41 #include "net/quic/test_tools/quic_config_peer.h" | 41 #include "net/quic/test_tools/quic_config_peer.h" |
| 42 #include "net/quic/test_tools/quic_stream_factory_peer.h" | 42 #include "net/quic/test_tools/quic_stream_factory_peer.h" |
| 43 #include "net/quic/test_tools/quic_test_packet_maker.h" | 43 #include "net/quic/test_tools/quic_test_packet_maker.h" |
| 44 #include "net/quic/test_tools/quic_test_utils.h" | 44 #include "net/quic/test_tools/quic_test_utils.h" |
| 45 #include "net/quic/test_tools/test_task_runner.h" | 45 #include "net/quic/test_tools/test_task_runner.h" |
| 46 #include "net/socket/next_proto.h" | |
| 47 #include "net/socket/socket_test_util.h" | 46 #include "net/socket/socket_test_util.h" |
| 48 #include "net/spdy/spdy_session_test_util.h" | 47 #include "net/spdy/spdy_session_test_util.h" |
| 49 #include "net/spdy/spdy_test_utils.h" | 48 #include "net/spdy/spdy_test_utils.h" |
| 50 #include "net/ssl/channel_id_service.h" | 49 #include "net/ssl/channel_id_service.h" |
| 51 #include "net/ssl/default_channel_id_store.h" | 50 #include "net/ssl/default_channel_id_store.h" |
| 52 #include "net/test/cert_test_util.h" | 51 #include "net/test/cert_test_util.h" |
| 53 #include "net/test/gtest_util.h" | 52 #include "net/test/gtest_util.h" |
| 54 #include "net/test/test_data_directory.h" | 53 #include "net/test/test_data_directory.h" |
| 55 #include "testing/gmock/include/gmock/gmock.h" | 54 #include "testing/gmock/include/gmock/gmock.h" |
| 56 #include "testing/gtest/include/gtest/gtest.h" | 55 #include "testing/gtest/include/gtest/gtest.h" |
| (...skipping 452 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 509 void VerifyInitialization(bool proxy_delegate_provides_quic_supported_proxy) { | 508 void VerifyInitialization(bool proxy_delegate_provides_quic_supported_proxy) { |
| 510 idle_connection_timeout_seconds_ = 500; | 509 idle_connection_timeout_seconds_ = 500; |
| 511 Initialize(); | 510 Initialize(); |
| 512 ProofVerifyDetailsChromium verify_details = DefaultProofVerifyDetails(); | 511 ProofVerifyDetailsChromium verify_details = DefaultProofVerifyDetails(); |
| 513 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); | 512 crypto_client_stream_factory_.AddProofVerifyDetails(&verify_details); |
| 514 const QuicConfig* config = QuicStreamFactoryPeer::GetConfig(factory_.get()); | 513 const QuicConfig* config = QuicStreamFactoryPeer::GetConfig(factory_.get()); |
| 515 EXPECT_EQ(500, config->IdleNetworkTimeout().ToSeconds()); | 514 EXPECT_EQ(500, config->IdleNetworkTimeout().ToSeconds()); |
| 516 | 515 |
| 517 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); | 516 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); |
| 518 | 517 |
| 519 const AlternativeService alternative_service1( | 518 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), |
| 520 kProtoQUIC, host_port_pair_.host(), host_port_pair_.port()); | 519 host_port_pair_.port()); |
| 521 AlternativeServiceInfoVector alternative_service_info_vector; | 520 AlternativeServiceInfoVector alternative_service_info_vector; |
| 522 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); | 521 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
| 523 alternative_service_info_vector.push_back( | 522 alternative_service_info_vector.push_back( |
| 524 AlternativeServiceInfo(alternative_service1, expiration)); | 523 AlternativeServiceInfo(alternative_service1, expiration)); |
| 525 http_server_properties_.SetAlternativeServices( | 524 http_server_properties_.SetAlternativeServices( |
| 526 url::SchemeHostPort(url_), alternative_service_info_vector); | 525 url::SchemeHostPort(url_), alternative_service_info_vector); |
| 527 | 526 |
| 528 HostPortPair host_port_pair2(kServer2HostName, kDefaultServerPort); | 527 HostPortPair host_port_pair2(kServer2HostName, kDefaultServerPort); |
| 529 url::SchemeHostPort server2("https", kServer2HostName, kDefaultServerPort); | 528 url::SchemeHostPort server2("https", kServer2HostName, kDefaultServerPort); |
| 530 const AlternativeService alternative_service2( | 529 const AlternativeService alternative_service2(QUIC, host_port_pair2.host(), |
| 531 kProtoQUIC, host_port_pair2.host(), host_port_pair2.port()); | 530 host_port_pair2.port()); |
| 532 AlternativeServiceInfoVector alternative_service_info_vector2; | 531 AlternativeServiceInfoVector alternative_service_info_vector2; |
| 533 alternative_service_info_vector2.push_back( | 532 alternative_service_info_vector2.push_back( |
| 534 AlternativeServiceInfo(alternative_service2, expiration)); | 533 AlternativeServiceInfo(alternative_service2, expiration)); |
| 535 if (!proxy_delegate_provides_quic_supported_proxy) { | 534 if (!proxy_delegate_provides_quic_supported_proxy) { |
| 536 http_server_properties_.SetAlternativeServices( | 535 http_server_properties_.SetAlternativeServices( |
| 537 server2, alternative_service_info_vector2); | 536 server2, alternative_service_info_vector2); |
| 538 // Verify that the properties of both QUIC servers are stored in the | 537 // Verify that the properties of both QUIC servers are stored in the |
| 539 // HTTP properties map. | 538 // HTTP properties map. |
| 540 EXPECT_EQ(2U, http_server_properties_.alternative_service_map().size()); | 539 EXPECT_EQ(2U, http_server_properties_.alternative_service_map().size()); |
| 541 } else { | 540 } else { |
| (...skipping 3576 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4118 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); | 4117 QuicStreamFactoryPeer::SetTaskRunner(factory_.get(), runner_.get()); |
| 4119 | 4118 |
| 4120 MockQuicData socket_data; | 4119 MockQuicData socket_data; |
| 4121 socket_data.AddRead(SYNCHRONOUS, ERR_IO_PENDING); | 4120 socket_data.AddRead(SYNCHRONOUS, ERR_IO_PENDING); |
| 4122 socket_data.AddSocketDataToFactory(&socket_factory_); | 4121 socket_data.AddSocketDataToFactory(&socket_factory_); |
| 4123 | 4122 |
| 4124 MockQuicData socket_data2; | 4123 MockQuicData socket_data2; |
| 4125 socket_data2.AddRead(SYNCHRONOUS, ERR_IO_PENDING); | 4124 socket_data2.AddRead(SYNCHRONOUS, ERR_IO_PENDING); |
| 4126 socket_data2.AddSocketDataToFactory(&socket_factory_); | 4125 socket_data2.AddSocketDataToFactory(&socket_factory_); |
| 4127 | 4126 |
| 4128 const AlternativeService alternative_service1( | 4127 const AlternativeService alternative_service1(QUIC, host_port_pair_.host(), |
| 4129 kProtoQUIC, host_port_pair_.host(), host_port_pair_.port()); | 4128 host_port_pair_.port()); |
| 4130 AlternativeServiceInfoVector alternative_service_info_vector; | 4129 AlternativeServiceInfoVector alternative_service_info_vector; |
| 4131 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); | 4130 base::Time expiration = base::Time::Now() + base::TimeDelta::FromDays(1); |
| 4132 alternative_service_info_vector.push_back( | 4131 alternative_service_info_vector.push_back( |
| 4133 AlternativeServiceInfo(alternative_service1, expiration)); | 4132 AlternativeServiceInfo(alternative_service1, expiration)); |
| 4134 | 4133 |
| 4135 http_server_properties_.SetAlternativeServices( | 4134 http_server_properties_.SetAlternativeServices( |
| 4136 url::SchemeHostPort(url_), alternative_service_info_vector); | 4135 url::SchemeHostPort(url_), alternative_service_info_vector); |
| 4137 | 4136 |
| 4138 crypto_client_stream_factory_.set_handshake_mode( | 4137 crypto_client_stream_factory_.set_handshake_mode( |
| 4139 MockCryptoClientStream::ZERO_RTT); | 4138 MockCryptoClientStream::ZERO_RTT); |
| (...skipping 1115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5255 // Clear all cached states. | 5254 // Clear all cached states. |
| 5256 factory_->ClearCachedStatesInCryptoConfig( | 5255 factory_->ClearCachedStatesInCryptoConfig( |
| 5257 base::Callback<bool(const GURL&)>()); | 5256 base::Callback<bool(const GURL&)>()); |
| 5258 EXPECT_TRUE(test_cases[0].state->certs().empty()); | 5257 EXPECT_TRUE(test_cases[0].state->certs().empty()); |
| 5259 EXPECT_TRUE(test_cases[1].state->certs().empty()); | 5258 EXPECT_TRUE(test_cases[1].state->certs().empty()); |
| 5260 EXPECT_TRUE(test_cases[2].state->certs().empty()); | 5259 EXPECT_TRUE(test_cases[2].state->certs().empty()); |
| 5261 } | 5260 } |
| 5262 | 5261 |
| 5263 } // namespace test | 5262 } // namespace test |
| 5264 } // namespace net | 5263 } // namespace net |
| OLD | NEW |