summaryrefslogtreecommitdiffstats
path: root/net/socket/ssl_client_socket_pool.cc
diff options
context:
space:
mode:
authormbelshe@chromium.org <mbelshe@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2011-04-07 15:22:28 +0000
committermbelshe@chromium.org <mbelshe@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2011-04-07 15:22:28 +0000
commitab73904ffa1b236905a4f1253dd03e02dd9e8695 (patch)
tree280c13fdd850ed27e964df6f25cc7b6f16072a3b /net/socket/ssl_client_socket_pool.cc
parent53900d0715c882d9b8ae8281a17272143fd77143 (diff)
downloadchromium_src-ab73904ffa1b236905a4f1253dd03e02dd9e8695.zip
chromium_src-ab73904ffa1b236905a4f1253dd03e02dd9e8695.tar.gz
chromium_src-ab73904ffa1b236905a4f1253dd03e02dd9e8695.tar.bz2
Rename a number of classes previously labeled "TCP" to "Transport" in
preparation for non-TCP transports. This helps because the alternative is to either use non-TCP protocols (like SCTP) in classes which are called "TCPClientSocketPool", or to clone the code as "SCTPClientSocketPool", both of which are less than ideal. For now, we're just testing transports, so the TransportSocketPool classes will determine a single type of transport and just use them. In the future we'll likely need to figure out how to deal with runtime selection of transports, and probably support use of multiple transports either within the same pools or within subpools. But that is for the future. Note that the histograms have some "tcp" references to them. I didn't change these to "transport" yet, because it will effect existing histograms. Renames include: classes: TCPClientSocketPool -> TransportClientSocketPool MockTCPClientSocketPool -> MockTransportClientSocketPool TCPSocketParams -> TransportSocketParams methods (not the exhaustive list): CreateTCPClientSocket() -> CreateTransportClientSocket() DoTCPConnect() -> DoTransportConnect() BUG=none TEST=none Review URL: http://codereview.chromium.org/6804028 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@80781 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net/socket/ssl_client_socket_pool.cc')
-rw-r--r--net/socket/ssl_client_socket_pool.cc86
1 files changed, 47 insertions, 39 deletions
diff --git a/net/socket/ssl_client_socket_pool.cc b/net/socket/ssl_client_socket_pool.cc
index 2004286..41eb885 100644
--- a/net/socket/ssl_client_socket_pool.cc
+++ b/net/socket/ssl_client_socket_pool.cc
@@ -17,12 +17,12 @@
#include "net/socket/socks_client_socket_pool.h"
#include "net/socket/ssl_client_socket.h"
#include "net/socket/ssl_host_info.h"
-#include "net/socket/tcp_client_socket_pool.h"
+#include "net/socket/transport_client_socket_pool.h"
namespace net {
SSLSocketParams::SSLSocketParams(
- const scoped_refptr<TCPSocketParams>& tcp_params,
+ const scoped_refptr<TransportSocketParams>& transport_params,
const scoped_refptr<SOCKSSocketParams>& socks_params,
const scoped_refptr<HttpProxySocketParams>& http_proxy_params,
ProxyServer::Scheme proxy,
@@ -31,7 +31,7 @@ SSLSocketParams::SSLSocketParams(
int load_flags,
bool force_spdy_over_ssl,
bool want_spdy_over_npn)
- : tcp_params_(tcp_params),
+ : transport_params_(transport_params),
http_proxy_params_(http_proxy_params),
socks_params_(socks_params),
proxy_(proxy),
@@ -42,21 +42,21 @@ SSLSocketParams::SSLSocketParams(
want_spdy_over_npn_(want_spdy_over_npn) {
switch (proxy_) {
case ProxyServer::SCHEME_DIRECT:
- DCHECK(tcp_params_.get() != NULL);
+ DCHECK(transport_params_.get() != NULL);
DCHECK(http_proxy_params_.get() == NULL);
DCHECK(socks_params_.get() == NULL);
- ignore_limits_ = tcp_params_->ignore_limits();
+ ignore_limits_ = transport_params_->ignore_limits();
break;
case ProxyServer::SCHEME_HTTP:
case ProxyServer::SCHEME_HTTPS:
- DCHECK(tcp_params_.get() == NULL);
+ DCHECK(transport_params_.get() == NULL);
DCHECK(http_proxy_params_.get() != NULL);
DCHECK(socks_params_.get() == NULL);
ignore_limits_ = http_proxy_params_->ignore_limits();
break;
case ProxyServer::SCHEME_SOCKS4:
case ProxyServer::SCHEME_SOCKS5:
- DCHECK(tcp_params_.get() == NULL);
+ DCHECK(transport_params_.get() == NULL);
DCHECK(http_proxy_params_.get() == NULL);
DCHECK(socks_params_.get() != NULL);
ignore_limits_ = socks_params_->ignore_limits();
@@ -76,7 +76,7 @@ SSLConnectJob::SSLConnectJob(
const std::string& group_name,
const scoped_refptr<SSLSocketParams>& params,
const base::TimeDelta& timeout_duration,
- TCPClientSocketPool* tcp_pool,
+ TransportClientSocketPool* transport_pool,
SOCKSClientSocketPool* socks_pool,
HttpProxyClientSocketPool* http_proxy_pool,
ClientSocketFactory* client_socket_factory,
@@ -90,7 +90,7 @@ SSLConnectJob::SSLConnectJob(
: ConnectJob(group_name, timeout_duration, delegate,
BoundNetLog::Make(net_log, NetLog::SOURCE_CONNECT_JOB)),
params_(params),
- tcp_pool_(tcp_pool),
+ transport_pool_(transport_pool),
socks_pool_(socks_pool),
http_proxy_pool_(http_proxy_pool),
client_socket_factory_(client_socket_factory),
@@ -110,8 +110,8 @@ LoadState SSLConnectJob::GetLoadState() const {
if (transport_socket_handle_->socket())
return LOAD_STATE_ESTABLISHING_PROXY_TUNNEL;
// else, fall through.
- case STATE_TCP_CONNECT:
- case STATE_TCP_CONNECT_COMPLETE:
+ case STATE_TRANSPORT_CONNECT:
+ case STATE_TRANSPORT_CONNECT_COMPLETE:
case STATE_SOCKS_CONNECT:
case STATE_SOCKS_CONNECT_COMPLETE:
case STATE_TUNNEL_CONNECT:
@@ -151,12 +151,12 @@ int SSLConnectJob::DoLoop(int result) {
State state = next_state_;
next_state_ = STATE_NONE;
switch (state) {
- case STATE_TCP_CONNECT:
+ case STATE_TRANSPORT_CONNECT:
DCHECK_EQ(OK, rv);
- rv = DoTCPConnect();
+ rv = DoTransportConnect();
break;
- case STATE_TCP_CONNECT_COMPLETE:
- rv = DoTCPConnectComplete(rv);
+ case STATE_TRANSPORT_CONNECT_COMPLETE:
+ rv = DoTransportConnectComplete(rv);
break;
case STATE_SOCKS_CONNECT:
DCHECK_EQ(OK, rv);
@@ -189,8 +189,8 @@ int SSLConnectJob::DoLoop(int result) {
return rv;
}
-int SSLConnectJob::DoTCPConnect() {
- DCHECK(tcp_pool_);
+int SSLConnectJob::DoTransportConnect() {
+ DCHECK(transport_pool_);
if (ssl_host_info_factory_) {
ssl_host_info_.reset(
@@ -207,15 +207,18 @@ int SSLConnectJob::DoTCPConnect() {
ssl_host_info_->Start();
}
- next_state_ = STATE_TCP_CONNECT_COMPLETE;
+ next_state_ = STATE_TRANSPORT_CONNECT_COMPLETE;
transport_socket_handle_.reset(new ClientSocketHandle());
- scoped_refptr<TCPSocketParams> tcp_params = params_->tcp_params();
- return transport_socket_handle_->Init(group_name(), tcp_params,
- tcp_params->destination().priority(),
- &callback_, tcp_pool_, net_log());
+ scoped_refptr<TransportSocketParams> transport_params =
+ params_->transport_params();
+ return transport_socket_handle_->Init(
+ group_name(),
+ transport_params,
+ transport_params->destination().priority(),
+ &callback_, transport_pool_, net_log());
}
-int SSLConnectJob::DoTCPConnectComplete(int result) {
+int SSLConnectJob::DoTransportConnectComplete(int result) {
if (result == OK)
next_state_ = STATE_SSL_CONNECT;
@@ -372,7 +375,7 @@ int SSLConnectJob::DoSSLConnectComplete(int result) {
int SSLConnectJob::ConnectInternal() {
switch (params_->proxy()) {
case ProxyServer::SCHEME_DIRECT:
- next_state_ = STATE_TCP_CONNECT;
+ next_state_ = STATE_TRANSPORT_CONNECT;
break;
case ProxyServer::SCHEME_HTTP:
case ProxyServer::SCHEME_HTTPS:
@@ -390,7 +393,7 @@ int SSLConnectJob::ConnectInternal() {
}
SSLClientSocketPool::SSLConnectJobFactory::SSLConnectJobFactory(
- TCPClientSocketPool* tcp_pool,
+ TransportClientSocketPool* transport_pool,
SOCKSClientSocketPool* socks_pool,
HttpProxyClientSocketPool* http_proxy_pool,
ClientSocketFactory* client_socket_factory,
@@ -400,7 +403,7 @@ SSLClientSocketPool::SSLConnectJobFactory::SSLConnectJobFactory(
DnsCertProvenanceChecker* dns_cert_checker,
SSLHostInfoFactory* ssl_host_info_factory,
NetLog* net_log)
- : tcp_pool_(tcp_pool),
+ : transport_pool_(transport_pool),
socks_pool_(socks_pool),
http_proxy_pool_(http_proxy_pool),
client_socket_factory_(client_socket_factory),
@@ -412,8 +415,8 @@ SSLClientSocketPool::SSLConnectJobFactory::SSLConnectJobFactory(
net_log_(net_log) {
base::TimeDelta max_transport_timeout = base::TimeDelta();
base::TimeDelta pool_timeout;
- if (tcp_pool_)
- max_transport_timeout = tcp_pool_->ConnectionTimeout();
+ if (transport_pool_)
+ max_transport_timeout = transport_pool_->ConnectionTimeout();
if (socks_pool_) {
pool_timeout = socks_pool_->ConnectionTimeout();
if (pool_timeout > max_transport_timeout)
@@ -438,22 +441,27 @@ SSLClientSocketPool::SSLClientSocketPool(
DnsCertProvenanceChecker* dns_cert_checker,
SSLHostInfoFactory* ssl_host_info_factory,
ClientSocketFactory* client_socket_factory,
- TCPClientSocketPool* tcp_pool,
+ TransportClientSocketPool* transport_pool,
SOCKSClientSocketPool* socks_pool,
HttpProxyClientSocketPool* http_proxy_pool,
SSLConfigService* ssl_config_service,
NetLog* net_log)
- : tcp_pool_(tcp_pool),
+ : transport_pool_(transport_pool),
socks_pool_(socks_pool),
http_proxy_pool_(http_proxy_pool),
base_(max_sockets, max_sockets_per_group, histograms,
base::TimeDelta::FromSeconds(
ClientSocketPool::unused_idle_socket_timeout()),
base::TimeDelta::FromSeconds(kUsedIdleSocketTimeout),
- new SSLConnectJobFactory(tcp_pool, socks_pool, http_proxy_pool,
- client_socket_factory, host_resolver,
- cert_verifier, dnsrr_resolver,
- dns_cert_checker, ssl_host_info_factory,
+ new SSLConnectJobFactory(transport_pool,
+ socks_pool,
+ http_proxy_pool,
+ client_socket_factory,
+ host_resolver,
+ cert_verifier,
+ dnsrr_resolver,
+ dns_cert_checker,
+ ssl_host_info_factory,
net_log)),
ssl_config_service_(ssl_config_service) {
if (ssl_config_service_)
@@ -470,7 +478,7 @@ ConnectJob* SSLClientSocketPool::SSLConnectJobFactory::NewConnectJob(
const PoolBase::Request& request,
ConnectJob::Delegate* delegate) const {
return new SSLConnectJob(group_name, request.params(), ConnectionTimeout(),
- tcp_pool_, socks_pool_, http_proxy_pool_,
+ transport_pool_, socks_pool_, http_proxy_pool_,
client_socket_factory_, host_resolver_,
cert_verifier_, dnsrr_resolver_, dns_cert_checker_,
ssl_host_info_factory_, delegate, net_log_);
@@ -539,10 +547,10 @@ DictionaryValue* SSLClientSocketPool::GetInfoAsValue(
DictionaryValue* dict = base_.GetInfoAsValue(name, type);
if (include_nested_pools) {
ListValue* list = new ListValue();
- if (tcp_pool_) {
- list->Append(tcp_pool_->GetInfoAsValue("tcp_socket_pool",
- "tcp_socket_pool",
- false));
+ if (transport_pool_) {
+ list->Append(transport_pool_->GetInfoAsValue("transport_socket_pool",
+ "transport_socket_pool",
+ false));
}
if (socks_pool_) {
list->Append(socks_pool_->GetInfoAsValue("socks_pool",