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 1014 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1025 globals.quic_disable_connection_pooling.CopyToIfSet( | 1025 globals.quic_disable_connection_pooling.CopyToIfSet( |
1026 ¶ms->quic_disable_connection_pooling); | 1026 ¶ms->quic_disable_connection_pooling); |
1027 globals.quic_load_server_info_timeout_ms.CopyToIfSet( | 1027 globals.quic_load_server_info_timeout_ms.CopyToIfSet( |
1028 ¶ms->quic_load_server_info_timeout_ms); | 1028 ¶ms->quic_load_server_info_timeout_ms); |
1029 globals.quic_load_server_info_timeout_srtt_multiplier.CopyToIfSet( | 1029 globals.quic_load_server_info_timeout_srtt_multiplier.CopyToIfSet( |
1030 ¶ms->quic_load_server_info_timeout_srtt_multiplier); | 1030 ¶ms->quic_load_server_info_timeout_srtt_multiplier); |
1031 globals.quic_enable_truncated_connection_ids.CopyToIfSet( | 1031 globals.quic_enable_truncated_connection_ids.CopyToIfSet( |
1032 ¶ms->quic_enable_truncated_connection_ids); | 1032 ¶ms->quic_enable_truncated_connection_ids); |
1033 globals.quic_enable_connection_racing.CopyToIfSet( | 1033 globals.quic_enable_connection_racing.CopyToIfSet( |
1034 ¶ms->quic_enable_connection_racing); | 1034 ¶ms->quic_enable_connection_racing); |
1035 globals.quic_enable_non_blocking_io.CopyToIfSet( | |
1036 ¶ms->quic_enable_non_blocking_io); | |
1037 globals.quic_disable_disk_cache.CopyToIfSet( | 1035 globals.quic_disable_disk_cache.CopyToIfSet( |
1038 ¶ms->quic_disable_disk_cache); | 1036 ¶ms->quic_disable_disk_cache); |
1039 globals.quic_socket_receive_buffer_size.CopyToIfSet( | 1037 globals.quic_socket_receive_buffer_size.CopyToIfSet( |
1040 ¶ms->quic_socket_receive_buffer_size); | 1038 ¶ms->quic_socket_receive_buffer_size); |
1041 globals.enable_quic_port_selection.CopyToIfSet( | 1039 globals.enable_quic_port_selection.CopyToIfSet( |
1042 ¶ms->enable_quic_port_selection); | 1040 ¶ms->enable_quic_port_selection); |
1043 globals.quic_max_packet_length.CopyToIfSet(¶ms->quic_max_packet_length); | 1041 globals.quic_max_packet_length.CopyToIfSet(¶ms->quic_max_packet_length); |
1044 globals.quic_user_agent_id.CopyToIfSet(¶ms->quic_user_agent_id); | 1042 globals.quic_user_agent_id.CopyToIfSet(¶ms->quic_user_agent_id); |
1045 globals.quic_supported_versions.CopyToIfSet( | 1043 globals.quic_supported_versions.CopyToIfSet( |
1046 ¶ms->quic_supported_versions); | 1044 ¶ms->quic_supported_versions); |
(...skipping 126 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1173 float load_server_info_timeout_srtt_multiplier = | 1171 float load_server_info_timeout_srtt_multiplier = |
1174 GetQuicLoadServerInfoTimeoutSrttMultiplier(quic_trial_params); | 1172 GetQuicLoadServerInfoTimeoutSrttMultiplier(quic_trial_params); |
1175 if (load_server_info_timeout_srtt_multiplier != 0) { | 1173 if (load_server_info_timeout_srtt_multiplier != 0) { |
1176 globals->quic_load_server_info_timeout_srtt_multiplier.set( | 1174 globals->quic_load_server_info_timeout_srtt_multiplier.set( |
1177 load_server_info_timeout_srtt_multiplier); | 1175 load_server_info_timeout_srtt_multiplier); |
1178 } | 1176 } |
1179 globals->quic_enable_truncated_connection_ids.set( | 1177 globals->quic_enable_truncated_connection_ids.set( |
1180 ShouldQuicEnableTruncatedConnectionIds(quic_trial_params)); | 1178 ShouldQuicEnableTruncatedConnectionIds(quic_trial_params)); |
1181 globals->quic_enable_connection_racing.set( | 1179 globals->quic_enable_connection_racing.set( |
1182 ShouldQuicEnableConnectionRacing(quic_trial_params)); | 1180 ShouldQuicEnableConnectionRacing(quic_trial_params)); |
1183 globals->quic_enable_non_blocking_io.set( | |
1184 ShouldQuicEnableNonBlockingIO(quic_trial_params)); | |
1185 globals->quic_disable_disk_cache.set( | 1181 globals->quic_disable_disk_cache.set( |
1186 ShouldQuicDisableDiskCache(quic_trial_params)); | 1182 ShouldQuicDisableDiskCache(quic_trial_params)); |
1187 globals->enable_quic_port_selection.set( | 1183 globals->enable_quic_port_selection.set( |
1188 ShouldEnableQuicPortSelection(command_line)); | 1184 ShouldEnableQuicPortSelection(command_line)); |
1189 globals->quic_connection_options = | 1185 globals->quic_connection_options = |
1190 GetQuicConnectionOptions(command_line, quic_trial_params); | 1186 GetQuicConnectionOptions(command_line, quic_trial_params); |
1191 if (ShouldEnableQuicPacing(command_line, quic_trial_params)) { | 1187 if (ShouldEnableQuicPacing(command_line, quic_trial_params)) { |
1192 globals->quic_connection_options.push_back(net::kPACE); | 1188 globals->quic_connection_options.push_back(net::kPACE); |
1193 } | 1189 } |
1194 } | 1190 } |
(...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1382 | 1378 |
1383 // static | 1379 // static |
1384 bool IOThread::ShouldQuicEnableConnectionRacing( | 1380 bool IOThread::ShouldQuicEnableConnectionRacing( |
1385 const VariationParameters& quic_trial_params) { | 1381 const VariationParameters& quic_trial_params) { |
1386 return LowerCaseEqualsASCII( | 1382 return LowerCaseEqualsASCII( |
1387 GetVariationParam(quic_trial_params, "enable_connection_racing"), | 1383 GetVariationParam(quic_trial_params, "enable_connection_racing"), |
1388 "true"); | 1384 "true"); |
1389 } | 1385 } |
1390 | 1386 |
1391 // static | 1387 // static |
1392 bool IOThread::ShouldQuicEnableNonBlockingIO( | |
1393 const VariationParameters& quic_trial_params) { | |
1394 return LowerCaseEqualsASCII( | |
1395 GetVariationParam(quic_trial_params, "enable_non_blocking_io"), | |
1396 "true"); | |
1397 } | |
1398 | |
1399 // static | |
1400 bool IOThread::ShouldQuicDisableDiskCache( | 1388 bool IOThread::ShouldQuicDisableDiskCache( |
1401 const VariationParameters& quic_trial_params) { | 1389 const VariationParameters& quic_trial_params) { |
1402 return LowerCaseEqualsASCII( | 1390 return LowerCaseEqualsASCII( |
1403 GetVariationParam(quic_trial_params, "disable_disk_cache"), "true"); | 1391 GetVariationParam(quic_trial_params, "disable_disk_cache"), "true"); |
1404 } | 1392 } |
1405 | 1393 |
1406 // static | 1394 // static |
1407 int IOThread::GetQuicSocketReceiveBufferSize( | 1395 int IOThread::GetQuicSocketReceiveBufferSize( |
1408 const VariationParameters& quic_trial_params) { | 1396 const VariationParameters& quic_trial_params) { |
1409 int value; | 1397 int value; |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1455 net::QuicVersionVector supported_versions = net::QuicSupportedVersions(); | 1443 net::QuicVersionVector supported_versions = net::QuicSupportedVersions(); |
1456 for (size_t i = 0; i < supported_versions.size(); ++i) { | 1444 for (size_t i = 0; i < supported_versions.size(); ++i) { |
1457 net::QuicVersion version = supported_versions[i]; | 1445 net::QuicVersion version = supported_versions[i]; |
1458 if (net::QuicVersionToString(version) == quic_version) { | 1446 if (net::QuicVersionToString(version) == quic_version) { |
1459 return version; | 1447 return version; |
1460 } | 1448 } |
1461 } | 1449 } |
1462 | 1450 |
1463 return net::QUIC_VERSION_UNSUPPORTED; | 1451 return net::QUIC_VERSION_UNSUPPORTED; |
1464 } | 1452 } |
OLD | NEW |