| 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 <utility> | 7 #include <utility> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/base64.h" | 10 #include "base/base64.h" |
| (...skipping 1234 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1245 | 1245 |
| 1246 if (params->enable_quic) { | 1246 if (params->enable_quic) { |
| 1247 params->quic_always_require_handshake_confirmation = | 1247 params->quic_always_require_handshake_confirmation = |
| 1248 ShouldQuicAlwaysRequireHandshakeConfirmation(quic_trial_params); | 1248 ShouldQuicAlwaysRequireHandshakeConfirmation(quic_trial_params); |
| 1249 params->quic_disable_connection_pooling = | 1249 params->quic_disable_connection_pooling = |
| 1250 ShouldQuicDisableConnectionPooling(quic_trial_params); | 1250 ShouldQuicDisableConnectionPooling(quic_trial_params); |
| 1251 int receive_buffer_size = GetQuicSocketReceiveBufferSize(quic_trial_params); | 1251 int receive_buffer_size = GetQuicSocketReceiveBufferSize(quic_trial_params); |
| 1252 if (receive_buffer_size != 0) { | 1252 if (receive_buffer_size != 0) { |
| 1253 params->quic_socket_receive_buffer_size = receive_buffer_size; | 1253 params->quic_socket_receive_buffer_size = receive_buffer_size; |
| 1254 } | 1254 } |
| 1255 params->quic_delay_tcp_race = ShouldQuicDelayTcpRace(quic_trial_params); | |
| 1256 float load_server_info_timeout_srtt_multiplier = | 1255 float load_server_info_timeout_srtt_multiplier = |
| 1257 GetQuicLoadServerInfoTimeoutSrttMultiplier(quic_trial_params); | 1256 GetQuicLoadServerInfoTimeoutSrttMultiplier(quic_trial_params); |
| 1258 if (load_server_info_timeout_srtt_multiplier != 0) { | 1257 if (load_server_info_timeout_srtt_multiplier != 0) { |
| 1259 params->quic_load_server_info_timeout_srtt_multiplier = | 1258 params->quic_load_server_info_timeout_srtt_multiplier = |
| 1260 load_server_info_timeout_srtt_multiplier; | 1259 load_server_info_timeout_srtt_multiplier; |
| 1261 } | 1260 } |
| 1262 params->quic_enable_connection_racing = | 1261 params->quic_enable_connection_racing = |
| 1263 ShouldQuicEnableConnectionRacing(quic_trial_params); | 1262 ShouldQuicEnableConnectionRacing(quic_trial_params); |
| 1264 params->quic_enable_non_blocking_io = | 1263 params->quic_enable_non_blocking_io = |
| 1265 ShouldQuicEnableNonBlockingIO(quic_trial_params); | 1264 ShouldQuicEnableNonBlockingIO(quic_trial_params); |
| (...skipping 249 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1515 int value; | 1514 int value; |
| 1516 if (base::StringToInt(GetVariationParam(quic_trial_params, | 1515 if (base::StringToInt(GetVariationParam(quic_trial_params, |
| 1517 "receive_buffer_size"), | 1516 "receive_buffer_size"), |
| 1518 &value)) { | 1517 &value)) { |
| 1519 return value; | 1518 return value; |
| 1520 } | 1519 } |
| 1521 return 0; | 1520 return 0; |
| 1522 } | 1521 } |
| 1523 | 1522 |
| 1524 // static | 1523 // static |
| 1525 bool IOThread::NetworkSessionConfigurator::ShouldQuicDelayTcpRace( | |
| 1526 const VariationParameters& quic_trial_params) { | |
| 1527 return base::LowerCaseEqualsASCII( | |
| 1528 GetVariationParam(quic_trial_params, "delay_tcp_race"), "true"); | |
| 1529 } | |
| 1530 | |
| 1531 // static | |
| 1532 bool IOThread::NetworkSessionConfigurator::ShouldQuicCloseSessionsOnIpChange( | 1524 bool IOThread::NetworkSessionConfigurator::ShouldQuicCloseSessionsOnIpChange( |
| 1533 const VariationParameters& quic_trial_params) { | 1525 const VariationParameters& quic_trial_params) { |
| 1534 return base::LowerCaseEqualsASCII( | 1526 return base::LowerCaseEqualsASCII( |
| 1535 GetVariationParam(quic_trial_params, "close_sessions_on_ip_change"), | 1527 GetVariationParam(quic_trial_params, "close_sessions_on_ip_change"), |
| 1536 "true"); | 1528 "true"); |
| 1537 } | 1529 } |
| 1538 | 1530 |
| 1539 // static | 1531 // static |
| 1540 int IOThread::NetworkSessionConfigurator::GetQuicIdleConnectionTimeoutSeconds( | 1532 int IOThread::NetworkSessionConfigurator::GetQuicIdleConnectionTimeoutSeconds( |
| 1541 const VariationParameters& quic_trial_params) { | 1533 const VariationParameters& quic_trial_params) { |
| (...skipping 234 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1776 // TODO(rtenneti): We should probably use HttpServerPropertiesManager for the | 1768 // TODO(rtenneti): We should probably use HttpServerPropertiesManager for the |
| 1777 // system URLRequestContext too. There's no reason this should be tied to a | 1769 // system URLRequestContext too. There's no reason this should be tied to a |
| 1778 // profile. | 1770 // profile. |
| 1779 return context; | 1771 return context; |
| 1780 } | 1772 } |
| 1781 | 1773 |
| 1782 const metrics::UpdateUsagePrefCallbackType& | 1774 const metrics::UpdateUsagePrefCallbackType& |
| 1783 IOThread::GetMetricsDataUseForwarder() { | 1775 IOThread::GetMetricsDataUseForwarder() { |
| 1784 return metrics_data_use_forwarder_; | 1776 return metrics_data_use_forwarder_; |
| 1785 } | 1777 } |
| OLD | NEW |