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/socks_client_socket_pool.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind.h" 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind_helpers.h" 9eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#include "base/time/time.h" 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/values.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_errors.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_factory.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_handle.h" 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_pool_base.h" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/socks5_client_socket.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/socks_client_socket.h" 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/transport_client_socket_pool.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace net { 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SOCKSSocketParams::SOCKSSocketParams( 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<TransportSocketParams>& proxy_server, 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool socks_v5, 243551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) const HostPortPair& host_port_pair) 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : transport_params_(proxy_server), 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) destination_(host_port_pair), 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) socks_v5_(socks_v5) { 28868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) if (transport_params_.get()) 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ignore_limits_ = transport_params_->ignore_limits(); 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ignore_limits_ = false; 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SOCKSSocketParams::~SOCKSSocketParams() {} 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// SOCKSConnectJobs will time out after this many seconds. Note this is on 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// top of the timeout for the transport socket. 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static const int kSOCKSConnectJobTimeoutInSeconds = 30; 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SOCKSConnectJob::SOCKSConnectJob( 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 423551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) RequestPriority priority, 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<SOCKSSocketParams>& socks_params, 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const base::TimeDelta& timeout_duration, 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) TransportClientSocketPool* transport_pool, 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HostResolver* host_resolver, 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Delegate* delegate, 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetLog* net_log) 493551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) : ConnectJob(group_name, timeout_duration, priority, delegate, 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) BoundNetLog::Make(net_log, NetLog::SOURCE_CONNECT_JOB)), 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) socks_params_(socks_params), 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_pool_(transport_pool), 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) resolver_(host_resolver), 54c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) callback_(base::Bind(&SOCKSConnectJob::OnIOComplete, 55c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) base::Unretained(this))) { 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SOCKSConnectJob::~SOCKSConnectJob() { 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We don't worry about cancelling the tcp socket since the destructor in 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // scoped_ptr<ClientSocketHandle> transport_socket_handle_ will take care of 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // it. 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)LoadState SOCKSConnectJob::GetLoadState() const { 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (next_state_) { 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_TRANSPORT_CONNECT: 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_TRANSPORT_CONNECT_COMPLETE: 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_socket_handle_->GetLoadState(); 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_SOCKS_CONNECT: 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_SOCKS_CONNECT_COMPLETE: 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return LOAD_STATE_CONNECTING; 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return LOAD_STATE_IDLE; 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SOCKSConnectJob::OnIOComplete(int result) { 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = DoLoop(result); 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (rv != ERR_IO_PENDING) 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NotifyDelegateOfCompletion(rv); // Deletes |this| 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSConnectJob::DoLoop(int result) { 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_NE(next_state_, STATE_NONE); 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = result; 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) do { 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) State state = next_state_; 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_NONE; 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (state) { 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_TRANSPORT_CONNECT: 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoTransportConnect(); 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_TRANSPORT_CONNECT_COMPLETE: 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoTransportConnectComplete(rv); 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_SOCKS_CONNECT: 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoSOCKSConnect(); 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_SOCKS_CONNECT_COMPLETE: 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoSOCKSConnectComplete(rv); 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED() << "bad state"; 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = ERR_FAILED; 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } while (rv != ERR_IO_PENDING && next_state_ != STATE_NONE); 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv; 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSConnectJob::DoTransportConnect() { 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_TRANSPORT_CONNECT_COMPLETE; 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_socket_handle_.reset(new ClientSocketHandle()); 1193551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) return transport_socket_handle_->Init(group_name(), 1203551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) socks_params_->transport_params(), 1213551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) priority(), 1223551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) callback_, 1233551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) transport_pool_, 1243551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) net_log()); 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSConnectJob::DoTransportConnectComplete(int result) { 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result != OK) 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_PROXY_CONNECTION_FAILED; 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Reset the timer to just the length of time allowed for SOCKS handshake 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // so that a fast TCP connection plus a slow SOCKS failure doesn't take 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // longer to timeout than it should. 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ResetTimer(base::TimeDelta::FromSeconds(kSOCKSConnectJobTimeoutInSeconds)); 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_SOCKS_CONNECT; 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSConnectJob::DoSOCKSConnect() { 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_SOCKS_CONNECT_COMPLETE; 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Add a SOCKS connection on top of the tcp socket. 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (socks_params_->is_socks_v5()) { 1443551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) socket_.reset(new SOCKS5ClientSocket(transport_socket_handle_.Pass(), 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) socks_params_->destination())); 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 1473551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) socket_.reset(new SOCKSClientSocket(transport_socket_handle_.Pass(), 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) socks_params_->destination(), 1493551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) priority(), 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) resolver_)); 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return socket_->Connect( 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&SOCKSConnectJob::OnIOComplete, base::Unretained(this))); 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSConnectJob::DoSOCKSConnectComplete(int result) { 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result != OK) { 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) socket_->Disconnect(); 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1623551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) SetSocket(socket_.Pass()); 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSConnectJob::ConnectInternal() { 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_TRANSPORT_CONNECT; 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return DoLoop(OK); 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1713551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)scoped_ptr<ConnectJob> 1723551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)SOCKSClientSocketPool::SOCKSConnectJobFactory::NewConnectJob( 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const PoolBase::Request& request, 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ConnectJob::Delegate* delegate) const { 1763551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) return scoped_ptr<ConnectJob>(new SOCKSConnectJob(group_name, 1773551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) request.priority(), 1783551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) request.params(), 1793551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) ConnectionTimeout(), 1803551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) transport_pool_, 1813551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) host_resolver_, 1823551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) delegate, 1833551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) net_log_)); 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)base::TimeDelta 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SOCKSClientSocketPool::SOCKSConnectJobFactory::ConnectionTimeout() const { 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_pool_->ConnectionTimeout() + 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromSeconds(kSOCKSConnectJobTimeoutInSeconds); 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SOCKSClientSocketPool::SOCKSClientSocketPool( 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int max_sockets, 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int max_sockets_per_group, 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketPoolHistograms* histograms, 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HostResolver* host_resolver, 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) TransportClientSocketPool* transport_pool, 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetLog* net_log) 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : transport_pool_(transport_pool), 2003551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) base_(this, max_sockets, max_sockets_per_group, histograms, 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketPool::unused_idle_socket_timeout(), 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketPool::used_idle_socket_timeout(), 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) new SOCKSConnectJobFactory(transport_pool, 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) host_resolver, 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log)) { 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We should always have a |transport_pool_| except in unit tests. 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_pool_) 2083551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) base_.AddLowerLayeredPool(transport_pool_); 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SOCKSClientSocketPool::~SOCKSClientSocketPool() { 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSClientSocketPool::RequestSocket( 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, const void* socket_params, 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RequestPriority priority, ClientSocketHandle* handle, 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const CompletionCallback& callback, const BoundNetLog& net_log) { 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<SOCKSSocketParams>* casted_socket_params = 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<const scoped_refptr<SOCKSSocketParams>*>(socket_params); 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.RequestSocket(group_name, *casted_socket_params, priority, 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) handle, callback, net_log); 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SOCKSClientSocketPool::RequestSockets( 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const void* params, 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int num_sockets, 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const BoundNetLog& net_log) { 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<SOCKSSocketParams>* casted_params = 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<const scoped_refptr<SOCKSSocketParams>*>(params); 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.RequestSockets(group_name, *casted_params, num_sockets, net_log); 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SOCKSClientSocketPool::CancelRequest(const std::string& group_name, 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketHandle* handle) { 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.CancelRequest(group_name, handle); 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SOCKSClientSocketPool::ReleaseSocket(const std::string& group_name, 2423551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) scoped_ptr<StreamSocket> socket, 2433551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) int id) { 2443551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) base_.ReleaseSocket(group_name, socket.Pass(), id); 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SOCKSClientSocketPool::FlushWithError(int error) { 2482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base_.FlushWithError(error); 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SOCKSClientSocketPool::CloseIdleSockets() { 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base_.CloseIdleSockets(); 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSClientSocketPool::IdleSocketCount() const { 2565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.idle_socket_count(); 2575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int SOCKSClientSocketPool::IdleSocketCountInGroup( 2605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name) const { 2615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.IdleSocketCountInGroup(group_name); 2625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)LoadState SOCKSClientSocketPool::GetLoadState( 2655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& group_name, const ClientSocketHandle* handle) const { 2665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.GetLoadState(group_name, handle); 2675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2697d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)base::DictionaryValue* SOCKSClientSocketPool::GetInfoAsValue( 2705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& name, 2715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& type, 2725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool include_nested_pools) const { 2737d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) base::DictionaryValue* dict = base_.GetInfoAsValue(name, type); 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (include_nested_pools) { 2757d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) base::ListValue* list = new base::ListValue(); 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) list->Append(transport_pool_->GetInfoAsValue("transport_socket_pool", 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) "transport_socket_pool", 2785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) false)); 2795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) dict->Set("nested_pools", list); 2805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return dict; 2825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)base::TimeDelta SOCKSClientSocketPool::ConnectionTimeout() const { 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.ConnectionTimeout(); 2865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)ClientSocketPoolHistograms* SOCKSClientSocketPool::histograms() const { 2895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return base_.histograms(); 2905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2923551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)bool SOCKSClientSocketPool::IsStalled() const { 2933551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) return base_.IsStalled(); 2943551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)} 2953551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) 2963551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)void SOCKSClientSocketPool::AddHigherLayeredPool( 2973551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) HigherLayeredPool* higher_pool) { 2983551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) base_.AddHigherLayeredPool(higher_pool); 2993551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)} 3003551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) 3013551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)void SOCKSClientSocketPool::RemoveHigherLayeredPool( 3023551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) HigherLayeredPool* higher_pool) { 3033551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) base_.RemoveHigherLayeredPool(higher_pool); 3043551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)} 3053551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) 3065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool SOCKSClientSocketPool::CloseOneIdleConnection() { 3075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (base_.CloseOneIdleSocket()) 3085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 3093551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) return base_.CloseOneIdleConnectionInHigherLayeredPool(); 3105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace net 313