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 "chrome/browser/io_thread.h" | 5 #include "chrome/browser/io_thread.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/base64.h" | 9 #include "base/base64.h" |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 1164 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1175 ¶ms->spdy_default_protocol); | 1175 ¶ms->spdy_default_protocol); |
1176 params->next_protos = globals.next_protos; | 1176 params->next_protos = globals.next_protos; |
1177 globals.trusted_spdy_proxy.CopyToIfSet(¶ms->trusted_spdy_proxy); | 1177 globals.trusted_spdy_proxy.CopyToIfSet(¶ms->trusted_spdy_proxy); |
1178 params->forced_spdy_exclusions = globals.forced_spdy_exclusions; | 1178 params->forced_spdy_exclusions = globals.forced_spdy_exclusions; |
1179 globals.use_alternate_protocols.CopyToIfSet( | 1179 globals.use_alternate_protocols.CopyToIfSet( |
1180 ¶ms->use_alternate_protocols); | 1180 ¶ms->use_alternate_protocols); |
1181 globals.alternative_service_probability_threshold.CopyToIfSet( | 1181 globals.alternative_service_probability_threshold.CopyToIfSet( |
1182 ¶ms->alternative_service_probability_threshold); | 1182 ¶ms->alternative_service_probability_threshold); |
1183 | 1183 |
1184 globals.enable_quic.CopyToIfSet(¶ms->enable_quic); | 1184 globals.enable_quic.CopyToIfSet(¶ms->enable_quic); |
| 1185 globals.disable_insecure_quic.CopyToIfSet(¶ms->disable_insecure_quic); |
1185 globals.enable_quic_for_proxies.CopyToIfSet(¶ms->enable_quic_for_proxies); | 1186 globals.enable_quic_for_proxies.CopyToIfSet(¶ms->enable_quic_for_proxies); |
1186 globals.quic_always_require_handshake_confirmation.CopyToIfSet( | 1187 globals.quic_always_require_handshake_confirmation.CopyToIfSet( |
1187 ¶ms->quic_always_require_handshake_confirmation); | 1188 ¶ms->quic_always_require_handshake_confirmation); |
1188 globals.quic_disable_connection_pooling.CopyToIfSet( | 1189 globals.quic_disable_connection_pooling.CopyToIfSet( |
1189 ¶ms->quic_disable_connection_pooling); | 1190 ¶ms->quic_disable_connection_pooling); |
1190 globals.quic_load_server_info_timeout_srtt_multiplier.CopyToIfSet( | 1191 globals.quic_load_server_info_timeout_srtt_multiplier.CopyToIfSet( |
1191 ¶ms->quic_load_server_info_timeout_srtt_multiplier); | 1192 ¶ms->quic_load_server_info_timeout_srtt_multiplier); |
1192 globals.quic_enable_connection_racing.CopyToIfSet( | 1193 globals.quic_enable_connection_racing.CopyToIfSet( |
1193 ¶ms->quic_enable_connection_racing); | 1194 ¶ms->quic_enable_connection_racing); |
1194 globals.quic_enable_non_blocking_io.CopyToIfSet( | 1195 globals.quic_enable_non_blocking_io.CopyToIfSet( |
(...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1311 const VariationParameters& quic_trial_params, | 1312 const VariationParameters& quic_trial_params, |
1312 bool quic_allowed_by_policy, | 1313 bool quic_allowed_by_policy, |
1313 IOThread::Globals* globals) { | 1314 IOThread::Globals* globals) { |
1314 bool enable_quic = ShouldEnableQuic(command_line, quic_trial_group, | 1315 bool enable_quic = ShouldEnableQuic(command_line, quic_trial_group, |
1315 quic_allowed_by_policy); | 1316 quic_allowed_by_policy); |
1316 globals->enable_quic.set(enable_quic); | 1317 globals->enable_quic.set(enable_quic); |
1317 bool enable_quic_for_proxies = ShouldEnableQuicForProxies( | 1318 bool enable_quic_for_proxies = ShouldEnableQuicForProxies( |
1318 command_line, quic_trial_group, quic_allowed_by_policy); | 1319 command_line, quic_trial_group, quic_allowed_by_policy); |
1319 globals->enable_quic_for_proxies.set(enable_quic_for_proxies); | 1320 globals->enable_quic_for_proxies.set(enable_quic_for_proxies); |
1320 if (enable_quic) { | 1321 if (enable_quic) { |
| 1322 globals->disable_insecure_quic.set( |
| 1323 ShouldDisableInsecureQuic(quic_trial_params)); |
1321 globals->quic_always_require_handshake_confirmation.set( | 1324 globals->quic_always_require_handshake_confirmation.set( |
1322 ShouldQuicAlwaysRequireHandshakeConfirmation(quic_trial_params)); | 1325 ShouldQuicAlwaysRequireHandshakeConfirmation(quic_trial_params)); |
1323 globals->quic_disable_connection_pooling.set( | 1326 globals->quic_disable_connection_pooling.set( |
1324 ShouldQuicDisableConnectionPooling(quic_trial_params)); | 1327 ShouldQuicDisableConnectionPooling(quic_trial_params)); |
1325 int receive_buffer_size = GetQuicSocketReceiveBufferSize(quic_trial_params); | 1328 int receive_buffer_size = GetQuicSocketReceiveBufferSize(quic_trial_params); |
1326 if (receive_buffer_size != 0) { | 1329 if (receive_buffer_size != 0) { |
1327 globals->quic_socket_receive_buffer_size.set(receive_buffer_size); | 1330 globals->quic_socket_receive_buffer_size.set(receive_buffer_size); |
1328 } | 1331 } |
1329 float load_server_info_timeout_srtt_multiplier = | 1332 float load_server_info_timeout_srtt_multiplier = |
1330 GetQuicLoadServerInfoTimeoutSrttMultiplier(quic_trial_params); | 1333 GetQuicLoadServerInfoTimeoutSrttMultiplier(quic_trial_params); |
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1422 const base::CommandLine& command_line = | 1425 const base::CommandLine& command_line = |
1423 *base::CommandLine::ForCurrentProcess(); | 1426 *base::CommandLine::ForCurrentProcess(); |
1424 | 1427 |
1425 if (command_line.HasSwitch(switches::kDisableQuic)) | 1428 if (command_line.HasSwitch(switches::kDisableQuic)) |
1426 return false; | 1429 return false; |
1427 | 1430 |
1428 return data_reduction_proxy::DataReductionProxyParams:: | 1431 return data_reduction_proxy::DataReductionProxyParams:: |
1429 IsIncludedInQuicFieldTrial(); | 1432 IsIncludedInQuicFieldTrial(); |
1430 } | 1433 } |
1431 | 1434 |
| 1435 // static |
| 1436 bool IOThread::ShouldDisableInsecureQuic( |
| 1437 const VariationParameters& quic_trial_params) { |
| 1438 return LowerCaseEqualsASCII( |
| 1439 GetVariationParam(quic_trial_params, "disable_insecure_quic"), |
| 1440 "true"); |
| 1441 } |
| 1442 |
1432 bool IOThread::ShouldEnableQuicPortSelection( | 1443 bool IOThread::ShouldEnableQuicPortSelection( |
1433 const base::CommandLine& command_line) { | 1444 const base::CommandLine& command_line) { |
1434 if (command_line.HasSwitch(switches::kDisableQuicPortSelection)) | 1445 if (command_line.HasSwitch(switches::kDisableQuicPortSelection)) |
1435 return false; | 1446 return false; |
1436 | 1447 |
1437 if (command_line.HasSwitch(switches::kEnableQuicPortSelection)) | 1448 if (command_line.HasSwitch(switches::kEnableQuicPortSelection)) |
1438 return true; | 1449 return true; |
1439 | 1450 |
1440 return false; // Default to disabling port selection on all channels. | 1451 return false; // Default to disabling port selection on all channels. |
1441 } | 1452 } |
(...skipping 191 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1633 net::QuicVersionVector supported_versions = net::QuicSupportedVersions(); | 1644 net::QuicVersionVector supported_versions = net::QuicSupportedVersions(); |
1634 for (size_t i = 0; i < supported_versions.size(); ++i) { | 1645 for (size_t i = 0; i < supported_versions.size(); ++i) { |
1635 net::QuicVersion version = supported_versions[i]; | 1646 net::QuicVersion version = supported_versions[i]; |
1636 if (net::QuicVersionToString(version) == quic_version) { | 1647 if (net::QuicVersionToString(version) == quic_version) { |
1637 return version; | 1648 return version; |
1638 } | 1649 } |
1639 } | 1650 } |
1640 | 1651 |
1641 return net::QUIC_VERSION_UNSUPPORTED; | 1652 return net::QUIC_VERSION_UNSUPPORTED; |
1642 } | 1653 } |
OLD | NEW |