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 "jingle/glue/proxy_resolving_client_socket.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/basictypes.h" 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind.h" 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind_helpers.h" 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/compiler_specific.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/io_buffer.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_errors.h" 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_network_session.h" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_handle.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_pool_manager.h" 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_context.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_context_getter.h" 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace jingle_glue { 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)ProxyResolvingClientSocket::ProxyResolvingClientSocket( 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::ClientSocketFactory* socket_factory, 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<net::URLRequestContextGetter>& request_context_getter, 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const net::SSLConfig& ssl_config, 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const net::HostPortPair& dest_host_port_pair) 27c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) : proxy_resolve_callback_( 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&ProxyResolvingClientSocket::ProcessProxyResolveDone, 29c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) base::Unretained(this))), 30c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) connect_callback_( 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&ProxyResolvingClientSocket::ProcessConnectDone, 32c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) base::Unretained(this))), 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ssl_config_(ssl_config), 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pac_request_(NULL), 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) dest_host_port_pair_(dest_host_port_pair), 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Assume that we intend to do TLS on this socket; all 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // current use cases do. 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_url_("https://" + dest_host_port_pair_.ToString()), 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) tried_direct_connect_fallback_(false), 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bound_net_log_( 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::BoundNetLog::Make( 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_context_getter->GetURLRequestContext()->net_log(), 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::NetLog::SOURCE_SOCKET)), 44c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) weak_factory_(this) { 45868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) DCHECK(request_context_getter.get()); 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::URLRequestContext* request_context = 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_context_getter->GetURLRequestContext(); 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(request_context); 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!dest_host_port_pair_.host().empty()); 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_GT(dest_host_port_pair_.port(), 0); 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(proxy_url_.is_valid()); 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::HttpNetworkSession::Params session_params; 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.client_socket_factory = socket_factory; 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.host_resolver = request_context->host_resolver(); 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.cert_verifier = request_context->cert_verifier(); 577d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) session_params.transport_security_state = 587d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) request_context->transport_security_state(); 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(rkn): This is NULL because ServerBoundCertService is not thread safe. 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.server_bound_cert_service = NULL; 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.proxy_service = request_context->proxy_service(); 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.ssl_config_service = request_context->ssl_config_service(); 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.http_auth_handler_factory = 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_context->http_auth_handler_factory(); 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.network_delegate = request_context->network_delegate(); 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.http_server_properties = 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_context->http_server_properties(); 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.net_log = request_context->net_log(); 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const net::HttpNetworkSession::Params* reference_params = 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_context->GetNetworkSessionParams(); 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (reference_params) { 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.host_mapping_rules = reference_params->host_mapping_rules; 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.ignore_certificate_errors = 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) reference_params->ignore_certificate_errors; 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.http_pipelining_enabled = 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) reference_params->http_pipelining_enabled; 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.testing_fixed_http_port = 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) reference_params->testing_fixed_http_port; 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.testing_fixed_https_port = 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) reference_params->testing_fixed_https_port; 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_params.trusted_spdy_proxy = reference_params->trusted_spdy_proxy; 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) network_session_ = new net::HttpNetworkSession(session_params); 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)ProxyResolvingClientSocket::~ProxyResolvingClientSocket() { 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Disconnect(); 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int ProxyResolvingClientSocket::Read(net::IOBuffer* buf, int buf_len, 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const net::CompletionCallback& callback) { 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->Read(buf, buf_len, callback); 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return net::ERR_SOCKET_NOT_CONNECTED; 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int ProxyResolvingClientSocket::Write( 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::IOBuffer* buf, 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int buf_len, 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const net::CompletionCallback& callback) { 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->Write(buf, buf_len, callback); 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return net::ERR_SOCKET_NOT_CONNECTED; 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool ProxyResolvingClientSocket::SetReceiveBufferSize(int32 size) { 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->SetReceiveBufferSize(size); 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool ProxyResolvingClientSocket::SetSendBufferSize(int32 size) { 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->SetSendBufferSize(size); 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int ProxyResolvingClientSocket::Connect( 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const net::CompletionCallback& callback) { 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(user_connect_callback_.is_null()); 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) tried_direct_connect_fallback_ = false; 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // First we try and resolve the proxy. 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int status = network_session_->proxy_service()->ResolveProxy( 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_url_, 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &proxy_info_, 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_resolve_callback_, 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &pac_request_, 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bound_net_log_); 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (status != net::ERR_IO_PENDING) { 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We defer execution of ProcessProxyResolveDone instead of calling it 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // directly here for simplicity. From the caller's point of view, 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the connect always happens asynchronously. 141c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) base::MessageLoop* message_loop = base::MessageLoop::current(); 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CHECK(message_loop); 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) message_loop->PostTask( 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&ProxyResolvingClientSocket::ProcessProxyResolveDone, 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) weak_factory_.GetWeakPtr(), status)); 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) user_connect_callback_ = callback; 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return net::ERR_IO_PENDING; 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void ProxyResolvingClientSocket::RunUserConnectCallback(int status) { 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_LE(status, net::OK); 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::CompletionCallback user_connect_callback = user_connect_callback_; 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) user_connect_callback_.Reset(); 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) user_connect_callback.Run(status); 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Always runs asynchronously. 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void ProxyResolvingClientSocket::ProcessProxyResolveDone(int status) { 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pac_request_ = NULL; 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_NE(status, net::ERR_IO_PENDING); 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (status == net::OK) { 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Remove unsupported proxies from the list. 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_info_.RemoveProxiesWithoutScheme( 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::ProxyServer::SCHEME_DIRECT | 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::ProxyServer::SCHEME_HTTP | net::ProxyServer::SCHEME_HTTPS | 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::ProxyServer::SCHEME_SOCKS4 | net::ProxyServer::SCHEME_SOCKS5); 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_info_.is_empty()) { 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // No proxies/direct to choose from. This happens when we don't support 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // any of the proxies in the returned list. 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) status = net::ERR_NO_SUPPORTED_PROXIES; 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Since we are faking the URL, it is possible that no proxies match our URL. 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Try falling back to a direct connection if we have not tried that before. 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (status != net::OK) { 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!tried_direct_connect_fallback_) { 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) tried_direct_connect_fallback_ = true; 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_info_.UseDirect(); 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CloseTransportSocket(); 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RunUserConnectCallback(status); 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_.reset(new net::ClientSocketHandle); 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Now that we have resolved the proxy, we need to connect. 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) status = net::InitSocketHandleForRawConnect( 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) dest_host_port_pair_, network_session_.get(), proxy_info_, ssl_config_, 19590dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) ssl_config_, net::kPrivacyModeDisabled, bound_net_log_, transport_.get(), 19690dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) connect_callback_); 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (status != net::ERR_IO_PENDING) { 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Since this method is always called asynchronously. it is OK to call 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // ProcessConnectDone synchronously. 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ProcessConnectDone(status); 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void ProxyResolvingClientSocket::ProcessConnectDone(int status) { 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (status != net::OK) { 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the connection fails, try another proxy. 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) status = ReconsiderProxyAfterError(status); 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // ReconsiderProxyAfterError either returns an error (in which case it is 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // not reconsidering a proxy) or returns ERR_IO_PENDING if it is considering 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // another proxy. 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_NE(status, net::OK); 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (status == net::ERR_IO_PENDING) 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Proxy reconsideration pending. Return. 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CloseTransportSocket(); 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ReportSuccessfulProxyConnection(); 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RunUserConnectCallback(status); 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// TODO(sanjeevr): This has largely been copied from 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// HttpStreamFactoryImpl::Job::ReconsiderProxyAfterError. This should be 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// refactored into some common place. 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// This method reconsiders the proxy on certain errors. If it does reconsider 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// a proxy it always returns ERR_IO_PENDING and posts a call to 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// ProcessProxyResolveDone with the result of the reconsideration. 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int ProxyResolvingClientSocket::ReconsiderProxyAfterError(int error) { 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!pac_request_); 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_NE(error, net::OK); 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_NE(error, net::ERR_IO_PENDING); 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // A failure to resolve the hostname or any error related to establishing a 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TCP connection could be grounds for trying a new proxy configuration. 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Why do this when a hostname cannot be resolved? Some URLs only make sense 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // to proxy servers. The hostname in those URLs might fail to resolve if we 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // are still using a non-proxy config. We need to check if a proxy config 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // now exists that corresponds to a proxy server that could load the URL. 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (error) { 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_PROXY_CONNECTION_FAILED: 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_NAME_NOT_RESOLVED: 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_INTERNET_DISCONNECTED: 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_ADDRESS_UNREACHABLE: 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_CONNECTION_CLOSED: 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_CONNECTION_RESET: 2475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_CONNECTION_REFUSED: 2485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_CONNECTION_ABORTED: 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_TIMED_OUT: 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_TUNNEL_CONNECTION_FAILED: 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_SOCKS_CONNECTION_FAILED: 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case net::ERR_SOCKS_CONNECTION_HOST_UNREACHABLE: 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Remap the SOCKS-specific "host unreachable" error to a more 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // generic error code (this way consumers like the link doctor 2565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // know to substitute their error page). 2575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 2585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Note that if the host resolving was done by the SOCSK5 proxy, we can't 2595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // differentiate between a proxy-side "host not found" versus a proxy-side 2605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // "address unreachable" error, and will report both of these failures as 2615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // ERR_ADDRESS_UNREACHABLE. 2625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return net::ERR_ADDRESS_UNREACHABLE; 2635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 2645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error; 2655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_info_.is_https() && ssl_config_.send_client_cert) { 2685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) network_session_->ssl_client_auth_cache()->Remove( 2695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_info_.proxy_server().host_port_pair().ToString()); 2705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = network_session_->proxy_service()->ReconsiderProxyAfterError( 2735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_url_, &proxy_info_, proxy_resolve_callback_, &pac_request_, 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bound_net_log_); 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (rv == net::OK || rv == net::ERR_IO_PENDING) { 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CloseTransportSocket(); 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 2785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If ReconsiderProxyAfterError() failed synchronously, it means 2795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // there was nothing left to fall-back to, so fail the transaction 2805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // with the last connection error we got. 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = error; 2825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We either have new proxy info or there was an error in falling back. 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // In both cases we want to post ProcessProxyResolveDone (in the error case 2865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // we might still want to fall back a direct connection). 2875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (rv != net::ERR_IO_PENDING) { 288c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) base::MessageLoop* message_loop = base::MessageLoop::current(); 2895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CHECK(message_loop); 2905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) message_loop->PostTask( 2915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 2925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&ProxyResolvingClientSocket::ProcessProxyResolveDone, 2935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) weak_factory_.GetWeakPtr(), rv)); 2945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Since we potentially have another try to go (trying the direct connect) 2955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // set the return code code to ERR_IO_PENDING. 2965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = net::ERR_IO_PENDING; 2975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv; 2995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void ProxyResolvingClientSocket::ReportSuccessfulProxyConnection() { 3025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) network_session_->proxy_service()->ReportSuccess(proxy_info_); 3035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void ProxyResolvingClientSocket::Disconnect() { 3065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CloseTransportSocket(); 3075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (pac_request_) { 3085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) network_session_->proxy_service()->CancelPacRequest(pac_request_); 3095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pac_request_ = NULL; 3105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) user_connect_callback_.Reset(); 3125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool ProxyResolvingClientSocket::IsConnected() const { 3155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!transport_.get() || !transport_->socket()) 3165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 3175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->IsConnected(); 3185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool ProxyResolvingClientSocket::IsConnectedAndIdle() const { 3215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!transport_.get() || !transport_->socket()) 3225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 3235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->IsConnectedAndIdle(); 3245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int ProxyResolvingClientSocket::GetPeerAddress( 3275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::IPEndPoint* address) const { 3285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->GetPeerAddress(address); 3305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 3315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return net::ERR_SOCKET_NOT_CONNECTED; 3325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int ProxyResolvingClientSocket::GetLocalAddress( 3355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::IPEndPoint* address) const { 3365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->GetLocalAddress(address); 3385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 3395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return net::ERR_SOCKET_NOT_CONNECTED; 3405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const net::BoundNetLog& ProxyResolvingClientSocket::NetLog() const { 3435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->NetLog(); 3455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 3465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return bound_net_log_; 3475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void ProxyResolvingClientSocket::SetSubresourceSpeculation() { 3505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_->socket()->SetSubresourceSpeculation(); 3525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 3535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 3545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void ProxyResolvingClientSocket::SetOmniboxSpeculation() { 3575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_->socket()->SetOmniboxSpeculation(); 3595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 3605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 3615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool ProxyResolvingClientSocket::WasEverUsed() const { 3645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->WasEverUsed(); 3665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 3675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 3685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool ProxyResolvingClientSocket::UsingTCPFastOpen() const { 3715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->UsingTCPFastOpen(); 3735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 3745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 3755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool ProxyResolvingClientSocket::WasNpnNegotiated() const { 3785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 3795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)net::NextProto ProxyResolvingClientSocket::GetNegotiatedProtocol() const { 3825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return transport_->socket()->GetNegotiatedProtocol(); 3845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 3855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return net::kProtoUnknown; 3865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool ProxyResolvingClientSocket::GetSSLInfo(net::SSLInfo* ssl_info) { 3895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 3905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void ProxyResolvingClientSocket::CloseTransportSocket() { 3935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (transport_.get() && transport_->socket()) 3945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_->socket()->Disconnect(); 3955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) transport_.reset(); 3965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace jingle_glue 399