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/http/http_network_session.h" | 5 #include "net/http/http_network_session.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
10 #include "base/debug/stack_trace.h" | 10 #include "base/debug/stack_trace.h" |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
84 spdy_initial_max_concurrent_streams(0), | 84 spdy_initial_max_concurrent_streams(0), |
85 spdy_max_concurrent_streams_limit(0), | 85 spdy_max_concurrent_streams_limit(0), |
86 time_func(&base::TimeTicks::Now), | 86 time_func(&base::TimeTicks::Now), |
87 force_spdy_over_ssl(true), | 87 force_spdy_over_ssl(true), |
88 force_spdy_always(false), | 88 force_spdy_always(false), |
89 use_alternate_protocols(false), | 89 use_alternate_protocols(false), |
90 alternate_protocol_probability_threshold(1), | 90 alternate_protocol_probability_threshold(1), |
91 enable_websocket_over_spdy(false), | 91 enable_websocket_over_spdy(false), |
92 enable_quic(false), | 92 enable_quic(false), |
93 enable_quic_port_selection(true), | 93 enable_quic_port_selection(true), |
94 enable_quic_time_based_loss_detection(false), | |
95 quic_always_require_handshake_confirmation(false), | 94 quic_always_require_handshake_confirmation(false), |
96 quic_disable_connection_pooling(false), | 95 quic_disable_connection_pooling(false), |
97 quic_clock(NULL), | 96 quic_clock(NULL), |
98 quic_random(NULL), | 97 quic_random(NULL), |
99 quic_max_packet_length(kDefaultMaxPacketSize), | 98 quic_max_packet_length(kDefaultMaxPacketSize), |
100 enable_user_alternate_protocol_ports(false), | 99 enable_user_alternate_protocol_ports(false), |
101 quic_crypto_client_stream_factory(NULL), | 100 quic_crypto_client_stream_factory(NULL), |
102 proxy_delegate(NULL) { | 101 proxy_delegate(NULL) { |
103 quic_supported_versions.push_back(QUIC_VERSION_23); | 102 quic_supported_versions.push_back(QUIC_VERSION_23); |
104 } | 103 } |
(...skipping 22 matching lines...) Expand all Loading... |
127 params.cert_verifier, | 126 params.cert_verifier, |
128 params.channel_id_service, | 127 params.channel_id_service, |
129 params.transport_security_state, | 128 params.transport_security_state, |
130 params.quic_crypto_client_stream_factory, | 129 params.quic_crypto_client_stream_factory, |
131 params.quic_random ? params.quic_random : QuicRandom::GetInstance(), | 130 params.quic_random ? params.quic_random : QuicRandom::GetInstance(), |
132 params.quic_clock ? params.quic_clock : new QuicClock(), | 131 params.quic_clock ? params.quic_clock : new QuicClock(), |
133 params.quic_max_packet_length, | 132 params.quic_max_packet_length, |
134 params.quic_user_agent_id, | 133 params.quic_user_agent_id, |
135 params.quic_supported_versions, | 134 params.quic_supported_versions, |
136 params.enable_quic_port_selection, | 135 params.enable_quic_port_selection, |
137 params.enable_quic_time_based_loss_detection, | |
138 params.quic_always_require_handshake_confirmation, | 136 params.quic_always_require_handshake_confirmation, |
139 params.quic_disable_connection_pooling, | 137 params.quic_disable_connection_pooling, |
140 params.quic_connection_options), | 138 params.quic_connection_options), |
141 spdy_session_pool_(params.host_resolver, | 139 spdy_session_pool_(params.host_resolver, |
142 params.ssl_config_service, | 140 params.ssl_config_service, |
143 params.http_server_properties, | 141 params.http_server_properties, |
144 params.transport_security_state, | 142 params.transport_security_state, |
145 params.force_spdy_single_domain, | 143 params.force_spdy_single_domain, |
146 params.enable_spdy_compression, | 144 params.enable_spdy_compression, |
147 params.enable_spdy_ping_based_connection_checking, | 145 params.enable_spdy_ping_based_connection_checking, |
(...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
257 dict->SetBoolean("quic_enabled", params_.enable_quic); | 255 dict->SetBoolean("quic_enabled", params_.enable_quic); |
258 dict->SetBoolean("enable_quic_port_selection", | 256 dict->SetBoolean("enable_quic_port_selection", |
259 params_.enable_quic_port_selection); | 257 params_.enable_quic_port_selection); |
260 base::ListValue* connection_options = new base::ListValue; | 258 base::ListValue* connection_options = new base::ListValue; |
261 for (QuicTagVector::const_iterator it = | 259 for (QuicTagVector::const_iterator it = |
262 params_.quic_connection_options.begin(); | 260 params_.quic_connection_options.begin(); |
263 it != params_.quic_connection_options.end(); ++it) { | 261 it != params_.quic_connection_options.end(); ++it) { |
264 connection_options->AppendString("'" + QuicUtils::TagToString(*it) + "'"); | 262 connection_options->AppendString("'" + QuicUtils::TagToString(*it) + "'"); |
265 } | 263 } |
266 dict->Set("connection_options", connection_options); | 264 dict->Set("connection_options", connection_options); |
267 dict->SetBoolean("enable_quic_time_based_loss_detection", | |
268 params_.enable_quic_time_based_loss_detection); | |
269 dict->SetString("origin_to_force_quic_on", | 265 dict->SetString("origin_to_force_quic_on", |
270 params_.origin_to_force_quic_on.ToString()); | 266 params_.origin_to_force_quic_on.ToString()); |
271 dict->SetDouble("alternate_protocol_probability_threshold", | 267 dict->SetDouble("alternate_protocol_probability_threshold", |
272 params_.alternate_protocol_probability_threshold); | 268 params_.alternate_protocol_probability_threshold); |
273 return dict; | 269 return dict; |
274 } | 270 } |
275 | 271 |
276 void HttpNetworkSession::CloseAllConnections() { | 272 void HttpNetworkSession::CloseAllConnections() { |
277 normal_socket_pool_manager_->FlushSocketPoolsWithError(ERR_ABORTED); | 273 normal_socket_pool_manager_->FlushSocketPoolsWithError(ERR_ABORTED); |
278 websocket_socket_pool_manager_->FlushSocketPoolsWithError(ERR_ABORTED); | 274 websocket_socket_pool_manager_->FlushSocketPoolsWithError(ERR_ABORTED); |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
315 case WEBSOCKET_SOCKET_POOL: | 311 case WEBSOCKET_SOCKET_POOL: |
316 return websocket_socket_pool_manager_.get(); | 312 return websocket_socket_pool_manager_.get(); |
317 default: | 313 default: |
318 NOTREACHED(); | 314 NOTREACHED(); |
319 break; | 315 break; |
320 } | 316 } |
321 return NULL; | 317 return NULL; |
322 } | 318 } |
323 | 319 |
324 } // namespace net | 320 } // namespace net |
OLD | NEW |