transport_client_socket_pool.cc revision 5e3f23d412006dc4db4e659864679f29341e113f
15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/transport_client_socket_pool.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <algorithm> 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/compiler_specific.h" 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/message_loop.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/metrics/histogram.h" 135e3f23d412006dc4db4e659864679f29341e113fTorne (Richard Coles)#include "base/strings/string_util.h" 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/time.h" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/values.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/ip_endpoint.h" 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_log.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_errors.h" 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_factory.h" 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_handle.h" 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_pool_base.h" 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/socket_net_log_params.h" 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/tcp_client_socket.h" 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)using base::TimeDelta; 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace net { 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// TODO(willchan): Base this off RTT instead of statically setting it. Note we 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// choose a timeout that is different from the backup connect job timer so they 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// don't synchronize. 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const int TransportConnectJob::kIPv6FallbackTimerInMs = 300; 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace { 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Returns true iff all addresses in |list| are in the IPv6 family. 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool AddressListOnlyContainsIPv6(const AddressList& list) { 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!list.empty()); 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (AddressList::const_iterator iter = list.begin(); iter != list.end(); 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ++iter) { 412a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (iter->GetFamily() != ADDRESS_FAMILY_IPV6) 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)TransportSocketParams::TransportSocketParams( 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HostPortPair& host_port_pair, 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RequestPriority priority, 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool disable_resolver_cache, 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool ignore_limits, 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const OnHostResolutionCallback& host_resolution_callback) 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : destination_(host_port_pair), 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ignore_limits_(ignore_limits), 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) host_resolution_callback_(host_resolution_callback) { 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Initialize(priority, disable_resolver_cache); 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)TransportSocketParams::~TransportSocketParams() {} 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportSocketParams::Initialize(RequestPriority priority, 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool disable_resolver_cache) { 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) destination_.set_priority(priority); 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (disable_resolver_cache) 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) destination_.set_allow_cached_response(false); 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// TransportConnectJobs will time out after this many seconds. Note this is 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// the total time, including both host resolution and TCP connect() times. 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// TODO(eroman): The use of this constant needs to be re-evaluated. The time 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// needed for TCPClientSocketXXX::Connect() can be arbitrarily long, since 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// the address list may contain many alternatives, and most of those may 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// timeout. Even worse, the per-connect timeout threshold varies greatly 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// between systems (anywhere from 20 seconds to 190 seconds). 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// See comment #12 at http://crbug.com/23364 for specifics. 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static const int kTransportConnectJobTimeoutInSeconds = 240; // 4 minutes. 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)TransportConnectJob::TransportConnectJob( 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<TransportSocketParams>& params, 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta timeout_duration, 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketFactory* client_socket_factory, 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HostResolver* host_resolver, 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Delegate* delegate, 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetLog* net_log) 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : ConnectJob(group_name, timeout_duration, delegate, 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) BoundNetLog::Make(net_log, NetLog::SOURCE_CONNECT_JOB)), 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) params_(params), 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) client_socket_factory_(client_socket_factory), 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) resolver_(host_resolver), 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_(STATE_NONE) { 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)TransportConnectJob::~TransportConnectJob() { 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We don't worry about cancelling the host resolution and TCP connect, since 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // ~SingleRequestHostResolver and ~StreamSocket will take care of it. 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)LoadState TransportConnectJob::GetLoadState() const { 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (next_state_) { 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESOLVE_HOST: 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESOLVE_HOST_COMPLETE: 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return LOAD_STATE_RESOLVING_HOST; 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_TRANSPORT_CONNECT: 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_TRANSPORT_CONNECT_COMPLETE: 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return LOAD_STATE_CONNECTING; 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return LOAD_STATE_IDLE; 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportConnectJob::MakeAddressListStartWithIPv4(AddressList* list) { 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (AddressList::iterator i = list->begin(); i != list->end(); ++i) { 1192a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (i->GetFamily() == ADDRESS_FAMILY_IPV4) { 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) std::rotate(list->begin(), i, list->end()); 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportConnectJob::OnIOComplete(int result) { 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = DoLoop(result); 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (rv != ERR_IO_PENDING) 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NotifyDelegateOfCompletion(rv); // Deletes |this| 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportConnectJob::DoLoop(int result) { 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_NE(next_state_, STATE_NONE); 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = result; 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) do { 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) State state = next_state_; 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_NONE; 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (state) { 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESOLVE_HOST: 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoResolveHost(); 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESOLVE_HOST_COMPLETE: 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoResolveHostComplete(rv); 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_TRANSPORT_CONNECT: 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoTransportConnect(); 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_TRANSPORT_CONNECT_COMPLETE: 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoTransportConnectComplete(rv); 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = ERR_FAILED; 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } while (rv != ERR_IO_PENDING && next_state_ != STATE_NONE); 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv; 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportConnectJob::DoResolveHost() { 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_RESOLVE_HOST_COMPLETE; 1662a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) connect_timing_.dns_start = base::TimeTicks::Now(); 1672a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return resolver_.Resolve( 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) params_->destination(), &addresses_, 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&TransportConnectJob::OnIOComplete, base::Unretained(this)), 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log()); 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportConnectJob::DoResolveHostComplete(int result) { 1752a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) connect_timing_.dns_end = base::TimeTicks::Now(); 1762a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Overwrite connection start time, since for connections that do not go 1772a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // through proxies, |connect_start| should not include dns lookup time. 1782a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) connect_timing_.connect_start = connect_timing_.dns_end; 1792a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == OK) { 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Invoke callback, and abort if it fails. 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!params_->host_resolution_callback().is_null()) 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result = params_->host_resolution_callback().Run(addresses_, net_log()); 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == OK) 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_TRANSPORT_CONNECT; 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportConnectJob::DoTransportConnect() { 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_TRANSPORT_CONNECT_COMPLETE; 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_socket_.reset(client_socket_factory_->CreateTransportClientSocket( 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) addresses_, net_log().net_log(), net_log().source())); 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = transport_socket_->Connect( 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&TransportConnectJob::OnIOComplete, base::Unretained(this))); 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (rv == ERR_IO_PENDING && 1982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) addresses_.front().GetFamily() == ADDRESS_FAMILY_IPV6 && 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) !AddressListOnlyContainsIPv6(addresses_)) { 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_timer_.Start(FROM_HERE, 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(kIPv6FallbackTimerInMs), 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) this, &TransportConnectJob::DoIPv6FallbackTransportConnect); 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv; 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportConnectJob::DoTransportConnectComplete(int result) { 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == OK) { 2092a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool is_ipv4 = addresses_.front().GetFamily() == ADDRESS_FAMILY_IPV4; 2102a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(!connect_timing_.connect_start.is_null()); 2112a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(!connect_timing_.dns_start.is_null()); 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeTicks now = base::TimeTicks::Now(); 2132a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::TimeDelta total_duration = now - connect_timing_.dns_start; 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES( 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) "Net.DNS_Resolution_And_TCP_Connection_Latency2", 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) total_duration, 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2212a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::TimeDelta connect_duration = now - connect_timing_.connect_start; 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.TCP_Connection_Latency", 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connect_duration, 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (is_ipv4) { 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.TCP_Connection_Latency_IPv4_No_Race", 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connect_duration, 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (AddressListOnlyContainsIPv6(addresses_)) { 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.TCP_Connection_Latency_IPv6_Solo", 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connect_duration, 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.TCP_Connection_Latency_IPv6_Raceable", 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connect_duration, 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 2475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) set_socket(transport_socket_.release()); 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_timer_.Stop(); 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Be a bit paranoid and kill off the fallback members to prevent reuse. 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_transport_socket_.reset(); 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_addresses_.reset(); 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 2585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportConnectJob::DoIPv6FallbackTransportConnect() { 2615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The timer should only fire while we're waiting for the main connect to 2625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // succeed. 2635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (next_state_ != STATE_TRANSPORT_CONNECT_COMPLETE) { 2645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 2655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 2665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!fallback_transport_socket_.get()); 2695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!fallback_addresses_.get()); 2705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_addresses_.reset(new AddressList(addresses_)); 2725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) MakeAddressListStartWithIPv4(fallback_addresses_.get()); 2735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_transport_socket_.reset( 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) client_socket_factory_->CreateTransportClientSocket( 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *fallback_addresses_, net_log().net_log(), net_log().source())); 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_connect_start_time_ = base::TimeTicks::Now(); 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = fallback_transport_socket_->Connect( 2785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind( 2795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &TransportConnectJob::DoIPv6FallbackTransportConnectComplete, 2805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Unretained(this))); 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (rv != ERR_IO_PENDING) 2825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DoIPv6FallbackTransportConnectComplete(rv); 2835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportConnectJob::DoIPv6FallbackTransportConnectComplete(int result) { 2865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // This should only happen when we're waiting for the main connect to succeed. 2875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (next_state_ != STATE_TRANSPORT_CONNECT_COMPLETE) { 2885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 2895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 2905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_NE(ERR_IO_PENDING, result); 2935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(fallback_transport_socket_.get()); 2945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(fallback_addresses_.get()); 2955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == OK) { 2972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(!fallback_connect_start_time_.is_null()); 2982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(!connect_timing_.dns_start.is_null()); 2995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeTicks now = base::TimeTicks::Now(); 3002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::TimeDelta total_duration = now - connect_timing_.dns_start; 3015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES( 3025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) "Net.DNS_Resolution_And_TCP_Connection_Latency2", 3035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) total_duration, 3045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 3055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 3065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 3075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta connect_duration = now - fallback_connect_start_time_; 3095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.TCP_Connection_Latency", 3105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connect_duration, 3115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 3125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 3135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 3145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.TCP_Connection_Latency_IPv4_Wins_Race", 3165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connect_duration, 3175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 3185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 3195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 3205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) set_socket(fallback_transport_socket_.release()); 3215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_NONE; 3225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_socket_.reset(); 3235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 3245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Be a bit paranoid and kill off the fallback members to prevent reuse. 3255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_transport_socket_.reset(); 3265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback_addresses_.reset(); 3275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NotifyDelegateOfCompletion(result); // Deletes |this| 3295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportConnectJob::ConnectInternal() { 3325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_RESOLVE_HOST; 3335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return DoLoop(OK); 3345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)ConnectJob* 3375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) TransportClientSocketPool::TransportConnectJobFactory::NewConnectJob( 3385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 3395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const PoolBase::Request& request, 3405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ConnectJob::Delegate* delegate) const { 3415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return new TransportConnectJob(group_name, 3425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request.params(), 3435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ConnectionTimeout(), 3445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) client_socket_factory_, 3455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) host_resolver_, 3465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) delegate, 3475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log_); 3485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)base::TimeDelta 3515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) TransportClientSocketPool::TransportConnectJobFactory::ConnectionTimeout() 3525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const { 3535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base::TimeDelta::FromSeconds(kTransportConnectJobTimeoutInSeconds); 3545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)TransportClientSocketPool::TransportClientSocketPool( 3575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int max_sockets, 3585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int max_sockets_per_group, 3595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketPoolHistograms* histograms, 3605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HostResolver* host_resolver, 3615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketFactory* client_socket_factory, 3625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetLog* net_log) 3635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : base_(max_sockets, max_sockets_per_group, histograms, 3645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketPool::unused_idle_socket_timeout(), 3655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketPool::used_idle_socket_timeout(), 3665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) new TransportConnectJobFactory(client_socket_factory, 3675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) host_resolver, net_log)) { 3685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.EnableConnectBackupJobs(); 3695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)TransportClientSocketPool::~TransportClientSocketPool() {} 3725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportClientSocketPool::RequestSocket( 3745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 3755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const void* params, 3765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RequestPriority priority, 3775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketHandle* handle, 3785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const CompletionCallback& callback, 3795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const BoundNetLog& net_log) { 3805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<TransportSocketParams>* casted_params = 3815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<const scoped_refptr<TransportSocketParams>*>(params); 3825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (net_log.IsLoggingAllEvents()) { 3845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(eroman): Split out the host and port parameters. 3855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log.AddEvent( 3865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetLog::TYPE_TCP_CLIENT_SOCKET_POOL_REQUESTED_SOCKET, 3875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CreateNetLogHostPortPairCallback( 3885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &casted_params->get()->destination().host_port_pair())); 3895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.RequestSocket(group_name, *casted_params, priority, handle, 3925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) callback, net_log); 3935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportClientSocketPool::RequestSockets( 3965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 3975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const void* params, 3985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int num_sockets, 3995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const BoundNetLog& net_log) { 4005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<TransportSocketParams>* casted_params = 4015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<const scoped_refptr<TransportSocketParams>*>(params); 4025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (net_log.IsLoggingAllEvents()) { 4045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(eroman): Split out the host and port parameters. 4055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log.AddEvent( 4065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetLog::TYPE_TCP_CLIENT_SOCKET_POOL_REQUESTED_SOCKETS, 4075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CreateNetLogHostPortPairCallback( 4085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &casted_params->get()->destination().host_port_pair())); 4095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.RequestSockets(group_name, *casted_params, num_sockets, net_log); 4125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportClientSocketPool::CancelRequest( 4155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 4165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketHandle* handle) { 4175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.CancelRequest(group_name, handle); 4185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportClientSocketPool::ReleaseSocket( 4215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 4225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) StreamSocket* socket, 4235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int id) { 4245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.ReleaseSocket(group_name, socket, id); 4255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4272a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void TransportClientSocketPool::FlushWithError(int error) { 4282a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base_.FlushWithError(error); 4295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool TransportClientSocketPool::IsStalled() const { 4325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.IsStalled(); 4335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportClientSocketPool::CloseIdleSockets() { 4365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.CloseIdleSockets(); 4375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportClientSocketPool::IdleSocketCount() const { 4405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.idle_socket_count(); 4415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int TransportClientSocketPool::IdleSocketCountInGroup( 4445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name) const { 4455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.IdleSocketCountInGroup(group_name); 4465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)LoadState TransportClientSocketPool::GetLoadState( 4495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, const ClientSocketHandle* handle) const { 4505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.GetLoadState(group_name, handle); 4515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportClientSocketPool::AddLayeredPool(LayeredPool* layered_pool) { 4545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.AddLayeredPool(layered_pool); 4555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TransportClientSocketPool::RemoveLayeredPool(LayeredPool* layered_pool) { 4585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.RemoveLayeredPool(layered_pool); 4595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)DictionaryValue* TransportClientSocketPool::GetInfoAsValue( 4625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& name, 4635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& type, 4645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool include_nested_pools) const { 4655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.GetInfoAsValue(name, type); 4665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)base::TimeDelta TransportClientSocketPool::ConnectionTimeout() const { 4695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.ConnectionTimeout(); 4705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)ClientSocketPoolHistograms* TransportClientSocketPool::histograms() const { 4735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.histograms(); 4745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace net 477