| 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 173 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 184 new ChannelIDService(new DefaultChannelIDStore(nullptr))), | 184 new ChannelIDService(new DefaultChannelIDStore(nullptr))), |
| 185 cert_transparency_verifier_(new MultiLogCTVerifier()), | 185 cert_transparency_verifier_(new MultiLogCTVerifier()), |
| 186 scoped_mock_network_change_notifier_(nullptr), | 186 scoped_mock_network_change_notifier_(nullptr), |
| 187 factory_(nullptr), | 187 factory_(nullptr), |
| 188 host_port_pair_(kDefaultServerHostName, kDefaultServerPort), | 188 host_port_pair_(kDefaultServerHostName, kDefaultServerPort), |
| 189 url_(kDefaultUrl), | 189 url_(kDefaultUrl), |
| 190 url2_(kServer2Url), | 190 url2_(kServer2Url), |
| 191 url3_(kServer3Url), | 191 url3_(kServer3Url), |
| 192 url4_(kServer4Url), | 192 url4_(kServer4Url), |
| 193 privacy_mode_(PRIVACY_MODE_DISABLED), | 193 privacy_mode_(PRIVACY_MODE_DISABLED), |
| 194 enable_non_blocking_io_(true), | |
| 195 store_server_configs_in_properties_(false), | 194 store_server_configs_in_properties_(false), |
| 196 close_sessions_on_ip_change_(false), | 195 close_sessions_on_ip_change_(false), |
| 197 idle_connection_timeout_seconds_(kIdleConnectionTimeoutSeconds), | 196 idle_connection_timeout_seconds_(kIdleConnectionTimeoutSeconds), |
| 198 reduced_ping_timeout_seconds_(kPingTimeoutSecs), | 197 reduced_ping_timeout_seconds_(kPingTimeoutSecs), |
| 199 packet_reader_yield_after_duration_milliseconds_( | 198 packet_reader_yield_after_duration_milliseconds_( |
| 200 kQuicYieldAfterDurationMilliseconds), | 199 kQuicYieldAfterDurationMilliseconds), |
| 201 migrate_sessions_on_network_change_(false), | 200 migrate_sessions_on_network_change_(false), |
| 202 migrate_sessions_early_(false), | 201 migrate_sessions_early_(false), |
| 203 allow_server_migration_(false), | 202 allow_server_migration_(false), |
| 204 force_hol_blocking_(false), | 203 force_hol_blocking_(false), |
| 205 race_cert_verification_(false), | 204 race_cert_verification_(false), |
| 206 estimate_initial_rtt_(false) { | 205 estimate_initial_rtt_(false) { |
| 207 clock_.AdvanceTime(QuicTime::Delta::FromSeconds(1)); | 206 clock_.AdvanceTime(QuicTime::Delta::FromSeconds(1)); |
| 208 } | 207 } |
| 209 | 208 |
| 210 void Initialize() { | 209 void Initialize() { |
| 211 DCHECK(!factory_); | 210 DCHECK(!factory_); |
| 212 factory_.reset(new QuicStreamFactory( | 211 factory_.reset(new QuicStreamFactory( |
| 213 net_log_.net_log(), &host_resolver_, ssl_config_service_.get(), | 212 net_log_.net_log(), &host_resolver_, ssl_config_service_.get(), |
| 214 &socket_factory_, &http_server_properties_, &test_proxy_delegate_, | 213 &socket_factory_, &http_server_properties_, &test_proxy_delegate_, |
| 215 cert_verifier_.get(), &ct_policy_enforcer_, channel_id_service_.get(), | 214 cert_verifier_.get(), &ct_policy_enforcer_, channel_id_service_.get(), |
| 216 &transport_security_state_, cert_transparency_verifier_.get(), | 215 &transport_security_state_, cert_transparency_verifier_.get(), |
| 217 /*SocketPerformanceWatcherFactory*/ nullptr, | 216 /*SocketPerformanceWatcherFactory*/ nullptr, |
| 218 &crypto_client_stream_factory_, &random_generator_, &clock_, | 217 &crypto_client_stream_factory_, &random_generator_, &clock_, |
| 219 kDefaultMaxPacketSize, string(), SupportedVersions(version_), | 218 kDefaultMaxPacketSize, string(), SupportedVersions(version_), |
| 220 enable_non_blocking_io_, store_server_configs_in_properties_, | 219 store_server_configs_in_properties_, close_sessions_on_ip_change_, |
| 221 close_sessions_on_ip_change_, | |
| 222 /*mark_quic_broken_when_network_blackholes*/ false, | 220 /*mark_quic_broken_when_network_blackholes*/ false, |
| 223 idle_connection_timeout_seconds_, reduced_ping_timeout_seconds_, | 221 idle_connection_timeout_seconds_, reduced_ping_timeout_seconds_, |
| 224 packet_reader_yield_after_duration_milliseconds_, | 222 packet_reader_yield_after_duration_milliseconds_, |
| 225 migrate_sessions_on_network_change_, migrate_sessions_early_, | 223 migrate_sessions_on_network_change_, migrate_sessions_early_, |
| 226 allow_server_migration_, force_hol_blocking_, race_cert_verification_, | 224 allow_server_migration_, force_hol_blocking_, race_cert_verification_, |
| 227 /*do_not_fragment*/ true, estimate_initial_rtt_, QuicTagVector(), | 225 /*do_not_fragment*/ true, estimate_initial_rtt_, QuicTagVector(), |
| 228 /*enable_token_binding*/ false)); | 226 /*enable_token_binding*/ false)); |
| 229 factory_->set_require_confirmation(false); | 227 factory_->set_require_confirmation(false); |
| 230 } | 228 } |
| 231 | 229 |
| (...skipping 498 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 730 GURL url_; | 728 GURL url_; |
| 731 GURL url2_; | 729 GURL url2_; |
| 732 GURL url3_; | 730 GURL url3_; |
| 733 GURL url4_; | 731 GURL url4_; |
| 734 | 732 |
| 735 PrivacyMode privacy_mode_; | 733 PrivacyMode privacy_mode_; |
| 736 NetLogWithSource net_log_; | 734 NetLogWithSource net_log_; |
| 737 TestCompletionCallback callback_; | 735 TestCompletionCallback callback_; |
| 738 | 736 |
| 739 // Variables to configure QuicStreamFactory. | 737 // Variables to configure QuicStreamFactory. |
| 740 bool enable_non_blocking_io_; | |
| 741 bool store_server_configs_in_properties_; | 738 bool store_server_configs_in_properties_; |
| 742 bool close_sessions_on_ip_change_; | 739 bool close_sessions_on_ip_change_; |
| 743 int idle_connection_timeout_seconds_; | 740 int idle_connection_timeout_seconds_; |
| 744 int reduced_ping_timeout_seconds_; | 741 int reduced_ping_timeout_seconds_; |
| 745 int packet_reader_yield_after_duration_milliseconds_; | 742 int packet_reader_yield_after_duration_milliseconds_; |
| 746 bool migrate_sessions_on_network_change_; | 743 bool migrate_sessions_on_network_change_; |
| 747 bool migrate_sessions_early_; | 744 bool migrate_sessions_early_; |
| 748 bool allow_server_migration_; | 745 bool allow_server_migration_; |
| 749 bool force_hol_blocking_; | 746 bool force_hol_blocking_; |
| 750 bool race_cert_verification_; | 747 bool race_cert_verification_; |
| (...skipping 4462 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5213 // Clear all cached states. | 5210 // Clear all cached states. |
| 5214 factory_->ClearCachedStatesInCryptoConfig( | 5211 factory_->ClearCachedStatesInCryptoConfig( |
| 5215 base::Callback<bool(const GURL&)>()); | 5212 base::Callback<bool(const GURL&)>()); |
| 5216 EXPECT_TRUE(test_cases[0].state->certs().empty()); | 5213 EXPECT_TRUE(test_cases[0].state->certs().empty()); |
| 5217 EXPECT_TRUE(test_cases[1].state->certs().empty()); | 5214 EXPECT_TRUE(test_cases[1].state->certs().empty()); |
| 5218 EXPECT_TRUE(test_cases[2].state->certs().empty()); | 5215 EXPECT_TRUE(test_cases[2].state->certs().empty()); |
| 5219 } | 5216 } |
| 5220 | 5217 |
| 5221 } // namespace test | 5218 } // namespace test |
| 5222 } // namespace net | 5219 } // namespace net |
| OLD | NEW |