http_stream_factory_impl_job.cc revision 5d1f7b1de12d16ceb2c938c56701a3e8bfa558f7
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/http/http_stream_factory_impl_job.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch#include <algorithm> 8eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#include <string> 9eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind_helpers.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/stl_util.h" 147d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)#include "base/strings/string_util.h" 157d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)#include "base/strings/stringprintf.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/values.h" 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "build/build_config.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/connection_type_histograms.h" 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_log.h" 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_util.h" 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_basic_stream.h" 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_network_session.h" 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_pipelined_connection.h" 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_pipelined_host.h" 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_pipelined_host_pool.h" 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_pipelined_stream.h" 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_proxy_client_socket.h" 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_proxy_client_socket_pool.h" 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_request_info.h" 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_server_properties.h" 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_stream_factory.h" 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/http/http_stream_factory_impl_request.h" 332a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "net/quic/quic_http_stream.h" 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_handle.h" 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_pool.h" 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_pool_manager.h" 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/socks_client_socket_pool.h" 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/ssl_client_socket.h" 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/ssl_client_socket_pool.h" 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/spdy/spdy_http_stream.h" 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/spdy/spdy_session.h" 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/spdy/spdy_session_pool.h" 432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "net/ssl/ssl_cert_request_info.h" 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace net { 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Returns parameters associated with the start of a HTTP stream job. 487d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)base::Value* NetLogHttpStreamJobCallback(const GURL* original_url, 497d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) const GURL* url, 507d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) RequestPriority priority, 517d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) NetLog::LogLevel /* log_level */) { 527d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) base::DictionaryValue* dict = new base::DictionaryValue(); 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) dict->SetString("original_url", original_url->GetOrigin().spec()); 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) dict->SetString("url", url->GetOrigin().spec()); 554e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) dict->SetString("priority", RequestPriorityToString(priority)); 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return dict; 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Returns parameters associated with the Proto (with NPN negotiation) of a HTTP 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// stream. 617d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)base::Value* NetLogHttpStreamProtoCallback( 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const SSLClientSocket::NextProtoStatus status, 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string* proto, 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string* server_protos, 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetLog::LogLevel /* log_level */) { 667d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) base::DictionaryValue* dict = new base::DictionaryValue(); 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) dict->SetString("next_proto_status", 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SSLClientSocket::NextProtoStatusToString(status)); 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) dict->SetString("proto", *proto); 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) dict->SetString("server_protos", 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SSLClientSocket::ServerProtosToString(*server_protos)); 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return dict; 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)HttpStreamFactoryImpl::Job::Job(HttpStreamFactoryImpl* stream_factory, 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HttpNetworkSession* session, 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HttpRequestInfo& request_info, 792a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) RequestPriority priority, 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const SSLConfig& server_ssl_config, 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const SSLConfig& proxy_ssl_config, 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetLog* net_log) 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : request_(NULL), 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_info_(request_info), 852a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) priority_(priority), 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) server_ssl_config_(server_ssl_config), 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_ssl_config_(proxy_ssl_config), 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_HTTP_STREAM_JOB)), 89c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) io_callback_(base::Bind(&Job::OnIOComplete, base::Unretained(this))), 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_(new ClientSocketHandle), 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_(session), 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_(stream_factory), 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_(STATE_NONE), 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pac_request_(NULL), 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) blocking_job_(NULL), 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_(NULL), 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) using_ssl_(false), 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) using_spdy_(false), 992a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) using_quic_(false), 1002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) quic_request_(session_->quic_stream_factory()), 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) force_spdy_always_(HttpStreamFactory::force_spdy_always()), 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) force_spdy_over_ssl_(HttpStreamFactory::force_spdy_over_ssl()), 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) spdy_certificate_error_(OK), 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) establishing_tunnel_(false), 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) was_npn_negotiated_(false), 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protocol_negotiated_(kProtoUnknown), 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) num_streams_(0), 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) spdy_session_direct_(false), 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) existing_available_pipeline_(false), 110c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) ptr_factory_(this) { 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(stream_factory); 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(session); 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)HttpStreamFactoryImpl::Job::~Job() { 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log_.EndEvent(NetLog::TYPE_HTTP_STREAM_JOB); 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // When we're in a partially constructed state, waiting for the user to 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // provide certificate handling information or authentication, we can't reuse 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // this stream at all. 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (next_state_ == STATE_WAITING_USER_ACTION) { 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->socket()->Disconnect(); 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_.reset(); 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (pac_request_) 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_->proxy_service()->CancelPacRequest(pac_request_); 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The stream could be in a partial state. It is not reusable. 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (stream_.get() && next_state_ != STATE_DONE) 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_->Close(true /* not reusable */); 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::Start(Request* request) { 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(request); 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_ = request; 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) StartInternal(); 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::Preconnect(int num_streams) { 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_GT(num_streams, 0); 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HostPortPair origin_server = 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HostPortPair(request_info_.url.HostNoBrackets(), 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_info_.url.EffectiveIntPort()); 145ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch base::WeakPtr<HttpServerProperties> http_server_properties = 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_->http_server_properties(); 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (http_server_properties && 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) http_server_properties->SupportsSpdy(origin_server)) { 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) num_streams_ = 1; 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) num_streams_ = num_streams; 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return StartInternal(); 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::RestartTunnelWithProxyAuth( 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const AuthCredentials& credentials) { 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(establishing_tunnel_); 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_RESTART_TUNNEL_AUTH; 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_.reset(); 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return RunLoop(OK); 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)LoadState HttpStreamFactoryImpl::Job::GetLoadState() const { 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (next_state_) { 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESOLVE_PROXY_COMPLETE: 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return session_->proxy_service()->GetLoadState(pac_request_); 16890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) case STATE_INIT_CONNECTION_COMPLETE: 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_CREATE_STREAM_COMPLETE: 1702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return using_quic_ ? LOAD_STATE_CONNECTING : connection_->GetLoadState(); 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return LOAD_STATE_IDLE; 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1762a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void HttpStreamFactoryImpl::Job::MarkAsAlternate( 1772a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const GURL& original_url, 1782a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) PortAlternateProtocolPair alternate) { 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!original_url_.get()); 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) original_url_.reset(new GURL(original_url)); 181c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) if (alternate.protocol == QUIC) { 1822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(session_->params().enable_quic); 1832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) using_quic_ = true; 1842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::WaitFor(Job* job) { 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(STATE_NONE, next_state_); 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(STATE_NONE, job->next_state_); 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!blocking_job_); 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!job->waiting_job_); 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) blocking_job_ = job; 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) job->waiting_job_ = this; 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::Resume(Job* job) { 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(blocking_job_, job); 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) blocking_job_ = NULL; 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We know we're blocked if the next_state_ is STATE_WAIT_FOR_JOB_COMPLETE. 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Unblock |this|. 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (next_state_ == STATE_WAIT_FOR_JOB_COMPLETE) { 20390dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&HttpStreamFactoryImpl::Job::OnIOComplete, 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ptr_factory_.GetWeakPtr(), OK)); 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::Orphan(const Request* request) { 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(request_, request); 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_ = NULL; 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (blocking_job_) { 214eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // We've been orphaned, but there's a job we're blocked on. Don't bother 215eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // racing, just cancel ourself. 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(blocking_job_->waiting_job_); 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) blocking_job_->waiting_job_ = NULL; 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) blocking_job_ = NULL; 219eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch if (stream_factory_->for_websockets_ && 220eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch connection_ && connection_->socket()) 221eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch connection_->socket()->Disconnect(); 222eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch stream_factory_->OnOrphanedJobComplete(this); 223eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } else if (stream_factory_->for_websockets_) { 2241e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) // We cancel this job because a WebSocketHandshakeStream can't be created 225f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // without a WebSocketHandshakeStreamBase::CreateHelper which is stored in 226f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // the Request class and isn't accessible from this job. 227eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch if (connection_ && connection_->socket()) 228eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch connection_->socket()->Disconnect(); 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnOrphanedJobComplete(this); 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2333551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)void HttpStreamFactoryImpl::Job::SetPriority(RequestPriority priority) { 2343551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) priority_ = priority; 2353551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) // TODO(akalin): Propagate this to |connection_| and maybe the 2363551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) // preconnect state. 2373551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)} 2383551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::was_npn_negotiated() const { 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return was_npn_negotiated_; 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2433551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)NextProto HttpStreamFactoryImpl::Job::protocol_negotiated() const { 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return protocol_negotiated_; 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::using_spdy() const { 2485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return using_spdy_; 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const SSLConfig& HttpStreamFactoryImpl::Job::server_ssl_config() const { 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return server_ssl_config_; 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const SSLConfig& HttpStreamFactoryImpl::Job::proxy_ssl_config() const { 2565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return proxy_ssl_config_; 2575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const ProxyInfo& HttpStreamFactoryImpl::Job::proxy_info() const { 2605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return proxy_info_; 2615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::GetSSLInfo() { 2645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(using_ssl_); 2655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!establishing_tunnel_); 2665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(connection_.get() && connection_->socket()); 2675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SSLClientSocket* ssl_socket = 2685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<SSLClientSocket*>(connection_->socket()); 2695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ssl_socket->GetSSLInfo(&ssl_info_); 2705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 27290dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles)SpdySessionKey HttpStreamFactoryImpl::Job::GetSpdySessionKey() const { 2735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // In the case that we're using an HTTPS proxy for an HTTP url, 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // we look for a SPDY session *to* the proxy, instead of to the 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // origin server. 27690dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) PrivacyMode privacy_mode = request_info_.privacy_mode; 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsHttpsProxyAndHttpUrl()) { 27890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) return SpdySessionKey(proxy_info_.proxy_server().host_port_pair(), 27990dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) ProxyServer::Direct(), 28090dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) privacy_mode); 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 28290dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) return SpdySessionKey(origin_, 28390dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) proxy_info_.proxy_server(), 28490dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) privacy_mode); 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::CanUseExistingSpdySession() const { 2895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We need to make sure that if a spdy session was created for 2905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // https://somehost/ that we don't use that session for http://somehost:443/. 2915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The only time we can use an existing session is if the request URL is 2925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // https (the normal case) or if we're connection to a SPDY proxy, or 2935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // if we're running with force_spdy_always_. crbug.com/133176 2945d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // TODO(ricea): Add "wss" back to this list when SPDY WebSocket support is 2955d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // working. 2965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return request_info_.url.SchemeIs("https") || 2975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_info_.proxy_server().is_https() || 2985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) force_spdy_always_; 2995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnStreamReadyCallback() { 3025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(stream_.get()); 3035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!IsPreconnecting()); 304eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(!stream_factory_->for_websockets_); 3055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsOrphaned()) { 3065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnOrphanedJobComplete(this); 3075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 3085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->Complete(was_npn_negotiated(), 3095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protocol_negotiated(), 3105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) using_spdy(), 3115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log_); 3125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->OnStreamReady(this, server_ssl_config_, proxy_info_, 3135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_.release()); 3145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |this| may be deleted after this call. 3165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3181e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnWebSocketHandshakeStreamReadyCallback() { 319eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(websocket_stream_); 320eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(!IsPreconnecting()); 321eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(stream_factory_->for_websockets_); 322eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // An orphaned WebSocket job will be closed immediately and 323eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // never be ready. 324eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(!IsOrphaned()); 325eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch request_->Complete(was_npn_negotiated(), 326eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch protocol_negotiated(), 327eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch using_spdy(), 328eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch net_log_); 3291e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) request_->OnWebSocketHandshakeStreamReady(this, 3301e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) server_ssl_config_, 3311e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) proxy_info_, 3321e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) websocket_stream_.release()); 333eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // |this| may be deleted after this call. 334eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch} 335eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 336eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdochvoid HttpStreamFactoryImpl::Job::OnNewSpdySessionReadyCallback() { 3375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!stream_.get()); 3385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!IsPreconnecting()); 3395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(using_spdy()); 340ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch if (!new_spdy_session_) 341ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch return; 342ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch base::WeakPtr<SpdySession> spdy_session = new_spdy_session_; 343ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch new_spdy_session_.reset(); 3445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsOrphaned()) { 345eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch stream_factory_->OnNewSpdySessionReady( 3465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) spdy_session, spdy_session_direct_, server_ssl_config_, proxy_info_, 3475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) was_npn_negotiated(), protocol_negotiated(), using_spdy(), net_log_); 3485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnOrphanedJobComplete(this); 3495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 350eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch request_->OnNewSpdySessionReady(this, spdy_session, spdy_session_direct_); 3515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |this| may be deleted after this call. 3535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnStreamFailedCallback(int result) { 3565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!IsPreconnecting()); 3575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsOrphaned()) 3585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnOrphanedJobComplete(this); 3595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 3605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->OnStreamFailed(this, result, server_ssl_config_); 3615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |this| may be deleted after this call. 3625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnCertificateErrorCallback( 3655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int result, const SSLInfo& ssl_info) { 3665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!IsPreconnecting()); 3675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsOrphaned()) 3685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnOrphanedJobComplete(this); 3695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 3705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->OnCertificateError(this, result, server_ssl_config_, ssl_info); 3715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |this| may be deleted after this call. 3725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnNeedsProxyAuthCallback( 3755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HttpResponseInfo& response, 3765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HttpAuthController* auth_controller) { 3775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!IsPreconnecting()); 3785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsOrphaned()) 3795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnOrphanedJobComplete(this); 3805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 3815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->OnNeedsProxyAuth( 3825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) this, response, server_ssl_config_, proxy_info_, auth_controller); 3835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |this| may be deleted after this call. 3845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnNeedsClientAuthCallback( 3875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SSLCertRequestInfo* cert_info) { 3885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!IsPreconnecting()); 3895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsOrphaned()) 3905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnOrphanedJobComplete(this); 3915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 3925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->OnNeedsClientAuth(this, server_ssl_config_, cert_info); 3935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |this| may be deleted after this call. 3945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnHttpsProxyTunnelResponseCallback( 3975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HttpResponseInfo& response_info, 3985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HttpStream* stream) { 3995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!IsPreconnecting()); 4005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsOrphaned()) 4015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnOrphanedJobComplete(this); 4025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 4035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->OnHttpsProxyTunnelResponse( 4045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) this, response_info, server_ssl_config_, proxy_info_, stream); 4055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |this| may be deleted after this call. 4065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnPreconnectsComplete() { 4095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!request_); 410868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) if (new_spdy_session_.get()) { 411eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch stream_factory_->OnNewSpdySessionReady(new_spdy_session_, 412eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch spdy_session_direct_, 413eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch server_ssl_config_, 414eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch proxy_info_, 415eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch was_npn_negotiated(), 416eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch protocol_negotiated(), 417eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch using_spdy(), 418eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch net_log_); 4195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->OnPreconnectsComplete(this); 4215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |this| may be deleted after this call. 4225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 4255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::OnHostResolution( 4265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SpdySessionPool* spdy_session_pool, 42790dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) const SpdySessionKey& spdy_session_key, 4285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const AddressList& addresses, 4295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const BoundNetLog& net_log) { 4305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // It is OK to dereference spdy_session_pool, because the 4315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // ClientSocketPoolManager will be destroyed in the same callback that 4325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // destroys the SpdySessionPool. 4337dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch return 4347dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch spdy_session_pool->FindAvailableSession(spdy_session_key, net_log) ? 4357dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch ERR_SPDY_SESSION_ALREADY_EXISTS : OK; 4365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::OnIOComplete(int result) { 4395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RunLoop(result); 4405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::RunLoop(int result) { 4435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result = DoLoop(result); 4445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == ERR_IO_PENDING) 4465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 4475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If there was an error, we should have already resumed the |waiting_job_|, 4495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // if there was one. 4505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(result == OK || waiting_job_ == NULL); 4515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsPreconnecting()) { 45390dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 4545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 4555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind( 4565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &HttpStreamFactoryImpl::Job::OnPreconnectsComplete, 4575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ptr_factory_.GetWeakPtr())); 4585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 4595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsCertificateError(result)) { 4625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Retrieve SSL information from the socket. 4635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) GetSSLInfo(); 4645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_WAITING_USER_ACTION; 46690dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 4675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 4685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind( 4695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &HttpStreamFactoryImpl::Job::OnCertificateErrorCallback, 4705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ptr_factory_.GetWeakPtr(), 4715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result, ssl_info_)); 4725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 4735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (result) { 4765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_PROXY_AUTH_REQUESTED: 4775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { 4785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(connection_.get()); 4795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(connection_->socket()); 4805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(establishing_tunnel_); 4815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ProxyClientSocket* proxy_socket = 4835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<ProxyClientSocket*>(connection_->socket()); 4845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HttpResponseInfo* tunnel_auth_response = 4855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_socket->GetConnectResponseInfo(); 4865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_WAITING_USER_ACTION; 48890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 4895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 4905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind( 491eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch &Job::OnNeedsProxyAuthCallback, 4925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ptr_factory_.GetWeakPtr(), 4935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *tunnel_auth_response, 4945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_socket->GetAuthController())); 4955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 4975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_SSL_CLIENT_AUTH_CERT_NEEDED: 49990dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 5005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 5015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind( 502eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch &Job::OnNeedsClientAuthCallback, 5035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ptr_factory_.GetWeakPtr(), 5045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->ssl_error_response_info().cert_request_info)); 5055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 5065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_HTTPS_PROXY_TUNNEL_RESPONSE: 5085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { 5095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(connection_.get()); 5105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(connection_->socket()); 5115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(establishing_tunnel_); 5125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ProxyClientSocket* proxy_socket = 5145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<ProxyClientSocket*>(connection_->socket()); 51590dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 5165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 5175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind( 518eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch &Job::OnHttpsProxyTunnelResponseCallback, 5195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ptr_factory_.GetWeakPtr(), 5205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *proxy_socket->GetConnectResponseInfo(), 5215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_socket->CreateConnectResponseStream())); 5225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 5235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case OK: 5265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_DONE; 527868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) if (new_spdy_session_.get()) { 52890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 5295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 530eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::Bind(&Job::OnNewSpdySessionReadyCallback, 531868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ptr_factory_.GetWeakPtr())); 532eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } else if (stream_factory_->for_websockets_) { 533eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(websocket_stream_); 534eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::MessageLoop::current()->PostTask( 535eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch FROM_HERE, 5361e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) base::Bind(&Job::OnWebSocketHandshakeStreamReadyCallback, 5371e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) ptr_factory_.GetWeakPtr())); 5385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 539eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(stream_.get()); 54090dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 5415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 5425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind( 543eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch &Job::OnStreamReadyCallback, 5445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ptr_factory_.GetWeakPtr())); 5455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 5475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 54990dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) base::MessageLoop::current()->PostTask( 5505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, 5515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind( 552eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch &Job::OnStreamFailedCallback, 5535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ptr_factory_.GetWeakPtr(), 5545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result)); 5555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 5565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 5585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 5595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoLoop(int result) { 5615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_NE(next_state_, STATE_NONE); 5625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = result; 5635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) do { 5645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) State state = next_state_; 5655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_NONE; 5665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (state) { 5675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_START: 5685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 5695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoStart(); 5705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESOLVE_PROXY: 5725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 5735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoResolveProxy(); 5745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESOLVE_PROXY_COMPLETE: 5765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoResolveProxyComplete(rv); 5775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_WAIT_FOR_JOB: 5795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 5805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoWaitForJob(); 5815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_WAIT_FOR_JOB_COMPLETE: 5835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoWaitForJobComplete(rv); 5845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_INIT_CONNECTION: 5865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 5875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoInitConnection(); 5885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_INIT_CONNECTION_COMPLETE: 5905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoInitConnectionComplete(rv); 5915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_WAITING_USER_ACTION: 5935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoWaitingUserAction(rv); 5945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESTART_TUNNEL_AUTH: 5965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 5975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoRestartTunnelAuth(); 5985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 5995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESTART_TUNNEL_AUTH_COMPLETE: 6005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoRestartTunnelAuthComplete(rv); 6015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 6025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_CREATE_STREAM: 6035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, rv); 6045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoCreateStream(); 6055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 6065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_CREATE_STREAM_COMPLETE: 6075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = DoCreateStreamComplete(rv); 6085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 6095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 6105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED() << "bad state"; 6115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = ERR_FAILED; 6125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 6135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } while (rv != ERR_IO_PENDING && next_state_ != STATE_NONE); 6155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv; 6165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::StartInternal() { 6195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CHECK_EQ(STATE_NONE, next_state_); 6205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_START; 6215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = RunLoop(OK); 6225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(ERR_IO_PENDING, rv); 6235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv; 6245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoStart() { 6275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int port = request_info_.url.EffectiveIntPort(); 6285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) origin_ = HostPortPair(request_info_.url.HostNoBrackets(), port); 6295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) origin_url_ = stream_factory_->ApplyHostMappingRules( 6305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_info_.url, &origin_); 6315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) http_pipelining_key_.reset(new HttpPipelinedHost::Key(origin_)); 6325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log_.BeginEvent(NetLog::TYPE_HTTP_STREAM_JOB, 6345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&NetLogHttpStreamJobCallback, 6352a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) &request_info_.url, &origin_url_, 6362a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) priority_)); 6375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Don't connect to restricted ports. 6392a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool is_port_allowed = IsPortAllowedByDefault(port); 6402a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (request_info_.url.SchemeIs("ftp")) { 6412a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Never share connection with other jobs for FTP requests. 6422a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(!waiting_job_); 6432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 6442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) is_port_allowed = IsPortAllowedByFtp(port); 6452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 6462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (!is_port_allowed && !IsPortAllowedByOverride(port)) { 6475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (waiting_job_) { 6485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_->Resume(this); 6495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_ = NULL; 6505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_UNSAFE_PORT; 6525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_RESOLVE_PROXY; 6555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 6565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoResolveProxy() { 6595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!pac_request_); 6605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_RESOLVE_PROXY_COMPLETE; 6625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (request_info_.load_flags & LOAD_BYPASS_PROXY) { 6645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_info_.UseDirect(); 6655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 6665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return session_->proxy_service()->ResolveProxy( 6695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_info_.url, &proxy_info_, io_callback_, &pac_request_, net_log_); 6705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoResolveProxyComplete(int result) { 6735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pac_request_ = NULL; 6745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == OK) { 6765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Remove unsupported proxies from the list. 6775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_info_.RemoveProxiesWithoutScheme( 6785d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) ProxyServer::SCHEME_DIRECT | ProxyServer::SCHEME_QUIC | 6795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ProxyServer::SCHEME_HTTP | ProxyServer::SCHEME_HTTPS | 6805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ProxyServer::SCHEME_SOCKS4 | ProxyServer::SCHEME_SOCKS5); 6815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_info_.is_empty()) { 6835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // No proxies/direct to choose from. This happens when we don't support 6845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // any of the proxies in the returned list. 6855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result = ERR_NO_SUPPORTED_PROXIES; 6865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result != OK) { 6905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (waiting_job_) { 6915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_->Resume(this); 6925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_ = NULL; 6935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 6955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (blocking_job_) 6985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_WAIT_FOR_JOB; 6995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else 7005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_INIT_CONNECTION; 7015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 7025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::ShouldForceSpdySSL() const { 7055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool rv = force_spdy_always_ && force_spdy_over_ssl_; 7065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv && !HttpStreamFactory::HasSpdyExclusion(origin_); 7075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::ShouldForceSpdyWithoutSSL() const { 7105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool rv = force_spdy_always_ && !force_spdy_over_ssl_; 7115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv && !HttpStreamFactory::HasSpdyExclusion(origin_); 7125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7142a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)bool HttpStreamFactoryImpl::Job::ShouldForceQuic() const { 7157dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch return session_->params().enable_quic && 7167dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch session_->params().origin_to_force_quic_on.Equals(origin_) && 7177dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch proxy_info_.is_direct(); 7182a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 7192a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 7205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoWaitForJob() { 7215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(blocking_job_); 7225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_WAIT_FOR_JOB_COMPLETE; 7235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 7245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoWaitForJobComplete(int result) { 7275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!blocking_job_); 7285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, result); 7295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_INIT_CONNECTION; 7305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 7315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoInitConnection() { 7345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!blocking_job_); 7355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!connection_->is_initialized()); 7365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(proxy_info_.proxy_server().is_valid()); 7375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_INIT_CONNECTION_COMPLETE; 7385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 739eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch using_ssl_ = request_info_.url.SchemeIs("https") || 740eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch request_info_.url.SchemeIs("wss") || ShouldForceSpdySSL(); 7415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) using_spdy_ = false; 7425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (ShouldForceQuic()) 7442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) using_quic_ = true; 7452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 7465d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) if (proxy_info_.is_quic()) 7475d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) using_quic_ = true; 7485d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 7492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (using_quic_) { 7502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(session_->params().enable_quic); 7515d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) if (proxy_info_.is_quic() && !request_info_.url.SchemeIs("http")) { 7522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) NOTREACHED(); 7535d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // TODO(rch): support QUIC proxies for HTTPS urls. 7542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return ERR_NOT_IMPLEMENTED; 7552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 7565d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) HostPortProxyPair destination; 7575d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) destination.first = proxy_info_.is_quic() ? 7585d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) proxy_info_.proxy_server().host_port_pair() : origin_; 7595d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) destination.second = ProxyServer::Direct(); 760c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) next_state_ = STATE_INIT_CONNECTION_COMPLETE; 7615d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) bool secure_quic = using_ssl_ || proxy_info_.is_quic(); 7625d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) int rv = quic_request_.Request( 7635d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) destination, secure_quic, request_info_.method, 7645d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) session_->cert_verifier(), net_log_, io_callback_); 765eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch if (rv != OK) { 766eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // OK, there's no available QUIC session. Let |waiting_job_| resume 767eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // if it's paused. 768eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch if (waiting_job_) { 769eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch waiting_job_->Resume(this); 770eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch waiting_job_ = NULL; 771eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 772eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 773eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch return rv; 7742a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 7752a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 7765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Check first if we have a spdy session for this group. If so, then go 7775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // straight to using that. 77890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) SpdySessionKey spdy_session_key = GetSpdySessionKey(); 779ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch base::WeakPtr<SpdySession> spdy_session = 7807dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch session_->spdy_session_pool()->FindAvailableSession( 7817dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch spdy_session_key, net_log_); 7827dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (spdy_session && CanUseExistingSpdySession()) { 7835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If we're preconnecting, but we already have a SpdySession, we don't 7845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // actually need to preconnect any sockets, so we're done. 7855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsPreconnecting()) 7865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 7875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) using_spdy_ = true; 7885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_CREATE_STREAM; 7895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) existing_spdy_session_ = spdy_session; 7905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 7915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (request_ && (using_ssl_ || ShouldForceSpdyWithoutSSL())) { 7925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Update the spdy session key for the request that launched this job. 7935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->SetSpdySessionKey(spdy_session_key); 7945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (IsRequestEligibleForPipelining()) { 7955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(simonjam): With pipelining, we might be better off using fewer 7965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // connections and thus should make fewer preconnections. Explore 7975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // preconnecting fewer than the requested num_connections. 7985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 7995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Separate note: A forced pipeline is always available if one exists for 8005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // this key. This is different than normal pipelines, which may be 8015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // unavailable or unusable. So, there is no need to worry about a race 8025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // between when a pipeline becomes available and when this job blocks. 8035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) existing_available_pipeline_ = stream_factory_->http_pipelined_host_pool_. 8045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) IsExistingPipelineAvailableForKey(*http_pipelining_key_.get()); 8055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (existing_available_pipeline_) { 8065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 8075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 8085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool was_new_key = request_->SetHttpPipeliningKey( 8095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *http_pipelining_key_.get()); 8105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!was_new_key && session_->force_http_pipelining()) { 8115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 8125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // OK, there's no available SPDY session. Let |waiting_job_| resume if it's 8175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // paused. 8185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (waiting_job_) { 8205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_->Resume(this); 8215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_ = NULL; 8225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_info_.is_http() || proxy_info_.is_https()) 8255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) establishing_tunnel_ = using_ssl_; 8265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool want_spdy_over_npn = original_url_ != NULL; 8285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_info_.is_https()) { 8305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) InitSSLConfig(proxy_info_.proxy_server().host_port_pair(), 8312a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) &proxy_ssl_config_, 8322a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) true /* is a proxy server */); 8335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Disable revocation checking for HTTPS proxies since the revocation 8345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // requests are probably going to need to go through the proxy too. 8355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_ssl_config_.rev_checking_enabled = false; 8365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (using_ssl_) { 8382a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) InitSSLConfig(origin_, &server_ssl_config_, 8392a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) false /* not a proxy server */); 8405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsPreconnecting()) { 843eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(!stream_factory_->for_websockets_); 8445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return PreconnectSocketsForHttpRequest( 8455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) origin_url_, 8465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_info_.extra_headers, 8475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_info_.load_flags, 8482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) priority_, 8495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_, 8505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_info_, 8515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ShouldForceSpdySSL(), 8525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) want_spdy_over_npn, 8535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) server_ssl_config_, 8545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_ssl_config_, 85590dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) request_info_.privacy_mode, 8565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log_, 8575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) num_streams_); 8585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 8595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If we can't use a SPDY session, don't both checking for one after 8605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the hostname is resolved. 8615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) OnHostResolutionCallback resolution_callback = CanUseExistingSpdySession() ? 8625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Bind(&Job::OnHostResolution, session_->spdy_session_pool(), 8635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) GetSpdySessionKey()) : 8645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) OnHostResolutionCallback(); 865eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch if (stream_factory_->for_websockets_) { 8665d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // TODO(ricea): Re-enable NPN when WebSockets over SPDY is supported. 8675d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) SSLConfig websocket_server_ssl_config = server_ssl_config_; 8685d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) websocket_server_ssl_config.next_protos.clear(); 869eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch return InitSocketHandleForWebSocketRequest( 870eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch origin_url_, request_info_.extra_headers, request_info_.load_flags, 871eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch priority_, session_, proxy_info_, ShouldForceSpdySSL(), 8725d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) want_spdy_over_npn, websocket_server_ssl_config, proxy_ssl_config_, 873eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch request_info_.privacy_mode, net_log_, 874eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch connection_.get(), resolution_callback, io_callback_); 875eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 8765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return InitSocketHandleForHttpRequest( 8775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) origin_url_, request_info_.extra_headers, request_info_.load_flags, 8782a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) priority_, session_, proxy_info_, ShouldForceSpdySSL(), 87990dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) want_spdy_over_npn, server_ssl_config_, proxy_ssl_config_, 88090dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) request_info_.privacy_mode, net_log_, 8815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_.get(), resolution_callback, io_callback_); 8825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 8845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoInitConnectionComplete(int result) { 8865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsPreconnecting()) { 88790dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) if (using_quic_) 88890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) return result; 8895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_EQ(OK, result); 8905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 8915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == ERR_SPDY_SESSION_ALREADY_EXISTS) { 8945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We found a SPDY connection after resolving the host. This is 8955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // probably an IP pooled connection. 89690dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) SpdySessionKey spdy_session_key = GetSpdySessionKey(); 8975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) existing_spdy_session_ = 8987dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch session_->spdy_session_pool()->FindAvailableSession( 8997dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch spdy_session_key, net_log_); 9007dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (existing_spdy_session_) { 9015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) using_spdy_ = true; 9025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_CREATE_STREAM; 9035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 9045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // It is possible that the spdy session no longer exists. 9055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ReturnToStateInitConnection(true /* close connection */); 9065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 9085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 9105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(willchan): Make this a bit more exact. Maybe there are recoverable 9115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // errors, such as ignoring certificate errors for Alternate-Protocol. 9125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result < 0 && waiting_job_) { 9135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_->Resume(this); 9145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) waiting_job_ = NULL; 9155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 9175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result < 0 && session_->force_http_pipelining()) { 9185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->AbortPipelinedRequestsWithKey( 9195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) this, *http_pipelining_key_.get(), result, server_ssl_config_); 9205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 9225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |result| may be the result of any of the stacked pools. The following 9235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // logic is used when determining how to interpret an error. 9245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If |result| < 0: 9255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // and connection_->socket() != NULL, then the SSL handshake ran and it 9265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // is a potentially recoverable error. 9275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // and connection_->socket == NULL and connection_->is_ssl_error() is true, 9285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // then the SSL handshake ran with an unrecoverable error. 9295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // otherwise, the error came from one of the other pools. 9305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool ssl_started = using_ssl_ && (result == OK || connection_->socket() || 9315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->is_ssl_error()); 9325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 9335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (ssl_started && (result == OK || IsCertificateError(result))) { 9347dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (using_quic_ && result == OK) { 9355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) was_npn_negotiated_ = true; 9365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NextProto protocol_negotiated = 9377dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SSLClientSocket::NextProtoFromString("quic/1+spdy/3"); 9385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protocol_negotiated_ = protocol_negotiated; 9397dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } else { 9407dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SSLClientSocket* ssl_socket = 9417dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch static_cast<SSLClientSocket*>(connection_->socket()); 9427dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (ssl_socket->WasNpnNegotiated()) { 9437dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch was_npn_negotiated_ = true; 9447dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch std::string proto; 9457dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch std::string server_protos; 9467dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SSLClientSocket::NextProtoStatus status = 9477dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch ssl_socket->GetNextProto(&proto, &server_protos); 9487dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch NextProto protocol_negotiated = 9497dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SSLClientSocket::NextProtoFromString(proto); 9507dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch protocol_negotiated_ = protocol_negotiated; 9517dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch net_log_.AddEvent( 9527dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch NetLog::TYPE_HTTP_STREAM_REQUEST_PROTO, 9537dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::Bind(&NetLogHttpStreamProtoCallback, 9547dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch status, &proto, &server_protos)); 9557dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (ssl_socket->was_spdy_negotiated()) 9567dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SwitchToSpdyMode(); 9577dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 9587dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (ShouldForceSpdySSL()) 9595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SwitchToSpdyMode(); 9605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (proxy_info_.is_https() && connection_->socket() && 9625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result == OK) { 9635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ProxyClientSocket* proxy_socket = 9645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<ProxyClientSocket*>(connection_->socket()); 9655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_socket->IsUsingSpdy()) { 9665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) was_npn_negotiated_ = true; 9675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protocol_negotiated_ = proxy_socket->GetProtocolNegotiated(); 9685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SwitchToSpdyMode(); 9695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 9725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We may be using spdy without SSL 9735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (ShouldForceSpdyWithoutSSL()) 9745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SwitchToSpdyMode(); 9755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 9765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == ERR_PROXY_AUTH_REQUESTED || 9775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result == ERR_HTTPS_PROXY_TUNNEL_RESPONSE) { 9785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!ssl_started); 9795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Other state (i.e. |using_ssl_|) suggests that |connection_| will have an 9805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // SSL socket, but there was an error before that could happen. This 9815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // puts the in progress HttpProxy socket into |connection_| in order to 9825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // complete the auth (or read the response body). The tunnel restart code 9835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // is careful to remove it before returning control to the rest of this 9845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // class. 9855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_.reset(connection_->release_pending_http_proxy_connection()); 9865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 9875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 9895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!ssl_started && result < 0 && original_url_.get()) { 9905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Mark the alternate protocol as broken and fallback. 9915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_->http_server_properties()->SetBrokenAlternateProtocol( 9925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HostPortPair::FromURL(*original_url_)); 9935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 9945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 9955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 996c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) if (using_quic_) { 99790dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) if (result < 0) 99890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) return result; 999c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) stream_ = quic_request_.ReleaseStream(); 1000c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) next_state_ = STATE_NONE; 1001c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return OK; 1002c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) } 1003c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 10045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result < 0 && !ssl_started) 10055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ReconsiderProxyAfterError(result); 10065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) establishing_tunnel_ = false; 10075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (connection_->socket()) { 10095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) LogHttpConnectedMetrics(*connection_); 10105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We officially have a new connection. Record the type. 10125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!connection_->is_reused()) { 10135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ConnectionType type = using_spdy_ ? CONNECTION_SPDY : CONNECTION_HTTP; 10145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UpdateConnectionTypeHistograms(type); 10155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 10165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 10175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Handle SSL errors below. 10195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (using_ssl_) { 10205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(ssl_started); 10215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsCertificateError(result)) { 10225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (using_spdy_ && original_url_.get() && 10235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) original_url_->SchemeIs("http")) { 10245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We ignore certificate errors for http over spdy. 10255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) spdy_certificate_error_ = result; 10265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result = OK; 10275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 10285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result = HandleCertificateError(result); 10295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == OK && !connection_->socket()->IsConnectedAndIdle()) { 10305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ReturnToStateInitConnection(true /* close connection */); 10315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 10325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 10335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 10345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 10355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result < 0) 10365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 10375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 10385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_CREATE_STREAM; 10405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 10415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 10425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoWaitingUserAction(int result) { 10445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // This state indicates that the stream request is in a partially 10455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // completed state, and we've called back to the delegate for more 10465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // information. 10475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We're always waiting here for the delegate to call us back. 10495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_IO_PENDING; 10505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 10515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoCreateStream() { 1053868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) DCHECK(connection_->socket() || existing_spdy_session_.get() || 10542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) existing_available_pipeline_ || using_quic_); 10555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_CREATE_STREAM_COMPLETE; 10575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We only set the socket motivation if we're the first to use 10595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // this socket. Is there a race for two SPDY requests? We really 10605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // need to plumb this through to the connect level. 10615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (connection_->socket() && !connection_->is_reused()) 10625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetSocketMotivation(); 10635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 10645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!using_spdy_) { 10652a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // We may get ftp scheme when fetching ftp resources through proxy. 10665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool using_proxy = (proxy_info_.is_http() || proxy_info_.is_https()) && 10672a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) (request_info_.url.SchemeIs("http") || 10682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) request_info_.url.SchemeIs("ftp")); 10695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (stream_factory_->http_pipelined_host_pool_. 10705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) IsExistingPipelineAvailableForKey(*http_pipelining_key_.get())) { 1071eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(!stream_factory_->for_websockets_); 10725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_.reset(stream_factory_->http_pipelined_host_pool_. 10735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CreateStreamOnExistingPipeline( 10745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *http_pipelining_key_.get())); 10755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CHECK(stream_.get()); 1076eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } else if (stream_factory_->for_websockets_) { 1077eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(request_); 1078f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) DCHECK(request_->websocket_handshake_stream_create_helper()); 1079eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch websocket_stream_.reset( 1080f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) request_->websocket_handshake_stream_create_helper() 1081f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) ->CreateBasicStream(connection_.Pass(), using_proxy)); 10825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (!using_proxy && IsRequestEligibleForPipelining()) { 10835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(simonjam): Support proxies. 10845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_.reset( 10855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stream_factory_->http_pipelined_host_pool_.CreateStreamOnNewPipeline( 10865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *http_pipelining_key_.get(), 10875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_.release(), 10885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) server_ssl_config_, 10895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) proxy_info_, 10905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net_log_, 10915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) was_npn_negotiated_, 10925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protocol_negotiated_)); 10935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CHECK(stream_.get()); 10945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 10951e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) stream_.reset(new HttpBasicStream(connection_.release(), using_proxy)); 10965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 10975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 10985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 10995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CHECK(!stream_.get()); 11015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool direct = true; 1103c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) const ProxyServer& proxy_server = proxy_info_.proxy_server(); 110490dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) PrivacyMode privacy_mode = request_info_.privacy_mode; 110590dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) SpdySessionKey spdy_session_key(origin_, proxy_server, privacy_mode); 11065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsHttpsProxyAndHttpUrl()) { 11075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If we don't have a direct SPDY session, and we're using an HTTPS 11085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // proxy, then we might have a SPDY session to the proxy. 110990dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) // We never use privacy mode for connection to proxy server. 111090dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) spdy_session_key = SpdySessionKey(proxy_server.host_port_pair(), 111190dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) ProxyServer::Direct(), 111290dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) kPrivacyModeDisabled); 11135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) direct = false; 11145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 11155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1116ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch base::WeakPtr<SpdySession> spdy_session; 1117868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) if (existing_spdy_session_.get()) { 11185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We picked up an existing session, so we don't need our socket. 11195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (connection_->socket()) 11205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->socket()->Disconnect(); 11215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->Reset(); 1122ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch std::swap(spdy_session, existing_spdy_session_); 11235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 11245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SpdySessionPool* spdy_pool = session_->spdy_session_pool(); 11257dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch spdy_session = spdy_pool->FindAvailableSession(spdy_session_key, net_log_); 11267dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (!spdy_session) { 11277dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch int error = 11287dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch spdy_pool->CreateAvailableSessionFromSocket(spdy_session_key, 11297dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch connection_.Pass(), 1130868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) net_log_, 1131868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) spdy_certificate_error_, 1132868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) &new_spdy_session_, 1133868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) using_ssl_); 11345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (error != OK) 11355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error; 113690dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) const HostPortPair& host_port_pair = spdy_session_key.host_port_pair(); 1137ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch base::WeakPtr<HttpServerProperties> http_server_properties = 11385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_->http_server_properties(); 11395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (http_server_properties) 11405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) http_server_properties->SetSupportsSpdy(host_port_pair, true); 11415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) spdy_session_direct_ = direct; 11425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 11435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 11445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 11455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1146ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch if (!spdy_session) 11475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_CONNECTION_CLOSED; 11485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(willchan): Delete this code, because eventually, the 11505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // HttpStreamFactoryImpl will be creating all the SpdyHttpStreams, since it 11515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // will know when SpdySessions become available. 11525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1153eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch if (stream_factory_->for_websockets_) { 11545d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // TODO(ricea): Restore this code when WebSockets over SPDY is implemented. 11555d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) NOTREACHED(); 1156eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } else { 1157eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch bool use_relative_url = direct || request_info_.url.SchemeIs("https"); 1158ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch stream_.reset(new SpdyHttpStream(spdy_session, use_relative_url)); 1159eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 11605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 11615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 11625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoCreateStreamComplete(int result) { 11645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result < 0) 11655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 11665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_->proxy_service()->ReportSuccess(proxy_info_); 11685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_NONE; 11695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 11705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 11715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoRestartTunnelAuth() { 11735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_RESTART_TUNNEL_AUTH_COMPLETE; 11745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ProxyClientSocket* proxy_socket = 11755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<ProxyClientSocket*>(connection_->socket()); 11765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return proxy_socket->RestartWithAuth(io_callback_); 11775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 11785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::DoRestartTunnelAuthComplete(int result) { 11805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == ERR_PROXY_AUTH_REQUESTED) 11815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result; 11825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == OK) { 11845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Now that we've got the HttpProxyClientSocket connected. We have 11855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // to release it as an idle socket into the pool and start the connection 11865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // process from the beginning. Trying to pass it in with the 11875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // SSLSocketParams might cause a deadlock since params are dispatched 11885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // interchangeably. This request won't necessarily get this http proxy 11895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // socket, but there will be forward progress. 11905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) establishing_tunnel_ = false; 11915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ReturnToStateInitConnection(false /* do not close connection */); 11925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 11935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 11945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ReconsiderProxyAfterError(result); 11965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 11975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 11985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::ReturnToStateInitConnection( 11995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool close_connection) { 12005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (close_connection && connection_->socket()) 12015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->socket()->Disconnect(); 12025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->Reset(); 12035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (request_) { 12055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->RemoveRequestFromSpdySessionRequestMap(); 12065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->RemoveRequestFromHttpPipeliningRequestMap(); 12075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 12085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_INIT_CONNECTION; 12105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 12115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::SetSocketMotivation() { 12135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (request_info_.motivation == HttpRequestInfo::PRECONNECT_MOTIVATED) 12145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->socket()->SetSubresourceSpeculation(); 12155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) else if (request_info_.motivation == HttpRequestInfo::OMNIBOX_MOTIVATED) 12165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->socket()->SetOmniboxSpeculation(); 12175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(mbelshe): Add other motivations (like EARLY_LOAD_MOTIVATED). 12185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 12195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::IsHttpsProxyAndHttpUrl() const { 12215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!proxy_info_.is_https()) 12225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 12235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (original_url_.get()) { 12245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We currently only support Alternate-Protocol where the original scheme 12255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // is http. 12265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(original_url_->SchemeIs("http")); 12275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return original_url_->SchemeIs("http"); 12285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 12295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return request_info_.url.SchemeIs("http"); 12305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 12315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Sets several fields of ssl_config for the given origin_server based on the 12335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// proxy info and other factors. 12345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::InitSSLConfig( 12355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HostPortPair& origin_server, 12362a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SSLConfig* ssl_config, 12372a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool is_proxy) const { 12385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_info_.is_https() && ssl_config->send_client_cert) { 12395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // When connecting through an HTTPS proxy, disable TLS False Start so 12405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // that client authentication errors can be distinguished between those 12415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // originating from the proxy server (ERR_PROXY_CONNECTION_FAILED) and 12425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // those originating from the endpoint (ERR_SSL_PROTOCOL_ERROR / 12435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // ERR_BAD_SSL_CLIENT_AUTH_CERT). 12445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(rch): This assumes that the HTTPS proxy will only request a 12455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // client certificate during the initial handshake. 12465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // http://crbug.com/59292 12475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ssl_config->false_start_enabled = false; 12485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 12495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) enum { 12515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FALLBACK_NONE = 0, // SSL version fallback did not occur. 12525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FALLBACK_SSL3 = 1, // Fell back to SSL 3.0. 12535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FALLBACK_TLS1 = 2, // Fell back to TLS 1.0. 12545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FALLBACK_TLS1_1 = 3, // Fell back to TLS 1.1. 12555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FALLBACK_MAX 12565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }; 12575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int fallback = FALLBACK_NONE; 12595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (ssl_config->version_fallback) { 12605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (ssl_config->version_max) { 12615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case SSL_PROTOCOL_VERSION_SSL3: 12625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback = FALLBACK_SSL3; 12635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 12645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case SSL_PROTOCOL_VERSION_TLS1: 12655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback = FALLBACK_TLS1; 12665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 12675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case SSL_PROTOCOL_VERSION_TLS1_1: 12685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback = FALLBACK_TLS1_1; 12695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 12705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 12715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 12725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_ENUMERATION("Net.ConnectionUsedSSLVersionFallback", 12735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fallback, FALLBACK_MAX); 12745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12752a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // We also wish to measure the amount of fallback connections for a host that 12762a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // we know implements TLS up to 1.2. Ideally there would be no fallback here 12772a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // but high numbers of SSLv3 would suggest that SSLv3 fallback is being 12782a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // caused by network middleware rather than buggy HTTPS servers. 12792a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const std::string& host = origin_server.host(); 12802a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (!is_proxy && 12812a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) host.size() >= 10 && 12822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) host.compare(host.size() - 10, 10, "google.com") == 0 && 12832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) (host.size() == 10 || host[host.size()-11] == '.')) { 12842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) UMA_HISTOGRAM_ENUMERATION("Net.GoogleConnectionUsedSSLVersionFallback", 12852a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) fallback, FALLBACK_MAX); 12862a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 12872a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 12885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (request_info_.load_flags & LOAD_VERIFY_EV_CERT) 12895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ssl_config->verify_ev_cert = true; 129090dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) 129190dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) // Disable Channel ID if privacy mode is enabled. 129290dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) if (request_info_.privacy_mode == kPrivacyModeEnabled) 129390dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) ssl_config->channel_id_enabled = false; 12945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 12955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 12975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::ReconsiderProxyAfterError(int error) { 12985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!pac_request_); 12995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // A failure to resolve the hostname or any error related to establishing a 13015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TCP connection could be grounds for trying a new proxy configuration. 13025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 13035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Why do this when a hostname cannot be resolved? Some URLs only make sense 13045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // to proxy servers. The hostname in those URLs might fail to resolve if we 13055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // are still using a non-proxy config. We need to check if a proxy config 13065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // now exists that corresponds to a proxy server that could load the URL. 13075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 13085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (error) { 13095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_PROXY_CONNECTION_FAILED: 13105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_NAME_NOT_RESOLVED: 13115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_INTERNET_DISCONNECTED: 13125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_ADDRESS_UNREACHABLE: 13135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_CONNECTION_CLOSED: 13142a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case ERR_CONNECTION_TIMED_OUT: 13155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_CONNECTION_RESET: 13165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_CONNECTION_REFUSED: 13175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_CONNECTION_ABORTED: 13185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_TIMED_OUT: 13195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_TUNNEL_CONNECTION_FAILED: 13205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_SOCKS_CONNECTION_FAILED: 13212a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // This can happen in the case of trying to talk to a proxy using SSL, and 13222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // ending up talking to a captive portal that supports SSL instead. 13232a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case ERR_PROXY_CERTIFICATE_INVALID: 13242a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // This can happen when trying to talk SSL to a non-SSL server (Like a 13252a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // captive portal). 13262a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case ERR_SSL_PROTOCOL_ERROR: 13275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 13285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ERR_SOCKS_CONNECTION_HOST_UNREACHABLE: 13295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Remap the SOCKS-specific "host unreachable" error to a more 13305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // generic error code (this way consumers like the link doctor 13315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // know to substitute their error page). 13325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 13332a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Note that if the host resolving was done by the SOCKS5 proxy, we can't 13345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // differentiate between a proxy-side "host not found" versus a proxy-side 13355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // "address unreachable" error, and will report both of these failures as 13365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // ERR_ADDRESS_UNREACHABLE. 13375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return ERR_ADDRESS_UNREACHABLE; 13385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 13395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error; 13405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 13415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (request_info_.load_flags & LOAD_BYPASS_PROXY) { 13435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error; 13445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 13455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_info_.is_https() && proxy_ssl_config_.send_client_cert) { 13475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) session_->ssl_client_auth_cache()->Remove( 13485d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) proxy_info_.proxy_server().host_port_pair()); 13495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 13505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rv = session_->proxy_service()->ReconsiderProxyAfterError( 13525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_info_.url, &proxy_info_, io_callback_, &pac_request_, net_log_); 13535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (rv == OK || rv == ERR_IO_PENDING) { 13545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the error was during connection setup, there is no socket to 13555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // disconnect. 13565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (connection_->socket()) 13575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->socket()->Disconnect(); 13585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) connection_->Reset(); 13595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (request_) { 13605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->RemoveRequestFromSpdySessionRequestMap(); 13615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request_->RemoveRequestFromHttpPipeliningRequestMap(); 13625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 13635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) next_state_ = STATE_RESOLVE_PROXY_COMPLETE; 13645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 13655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If ReconsiderProxyAfterError() failed synchronously, it means 13665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // there was nothing left to fall-back to, so fail the transaction 13675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // with the last connection error we got. 13685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(eroman): This is a confusing contract, make it more obvious. 13695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rv = error; 13705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 13715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rv; 13735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 13745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int HttpStreamFactoryImpl::Job::HandleCertificateError(int error) { 13765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(using_ssl_); 13775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(IsCertificateError(error)); 13785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SSLClientSocket* ssl_socket = 13805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static_cast<SSLClientSocket*>(connection_->socket()); 13815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ssl_socket->GetSSLInfo(&ssl_info_); 13825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Add the bad certificate to the set of allowed certificates in the 13845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // SSL config object. This data structure will be consulted after calling 13855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // RestartIgnoringLastError(). And the user will be asked interactively 13865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // before RestartIgnoringLastError() is ever called. 13875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SSLConfig::CertAndStatus bad_cert; 13885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 13895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |ssl_info_.cert| may be NULL if we failed to create 13905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // X509Certificate for whatever reason, but normally it shouldn't 13915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // happen, unless this code is used inside sandbox. 1392868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) if (ssl_info_.cert.get() == NULL || 13935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) !X509Certificate::GetDEREncoded(ssl_info_.cert->os_cert_handle(), 13945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) &bad_cert.der_cert)) { 13955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error; 13965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 13975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bad_cert.cert_status = ssl_info_.cert_status; 13985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) server_ssl_config_.allowed_bad_certs.push_back(bad_cert); 13995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int load_flags = request_info_.load_flags; 14015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (session_->params().ignore_certificate_errors) 14025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) load_flags |= LOAD_IGNORE_ALL_CERT_ERRORS; 14035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (ssl_socket->IgnoreCertError(error, load_flags)) 14045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 14055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error; 14065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 14075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::SwitchToSpdyMode() { 14095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (HttpStreamFactory::spdy_enabled()) 14105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) using_spdy_ = true; 14115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 14125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 14145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void HttpStreamFactoryImpl::Job::LogHttpConnectedMetrics( 14155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const ClientSocketHandle& handle) { 14165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_ENUMERATION("Net.HttpSocketType", handle.reuse_type(), 14175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketHandle::NUM_TYPES); 14185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (handle.reuse_type()) { 14205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ClientSocketHandle::UNUSED: 14215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.HttpConnectionLatency", 14225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) handle.setup_time(), 14235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 14245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(10), 14255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 14265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 14275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ClientSocketHandle::UNUSED_IDLE: 14285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.SocketIdleTimeBeforeNextUse_UnusedSocket", 14295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) handle.idle_time(), 14305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 14315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(6), 14325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 14335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 14345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case ClientSocketHandle::REUSED_IDLE: 14355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UMA_HISTOGRAM_CUSTOM_TIMES("Net.SocketIdleTimeBeforeNextUse_ReusedSocket", 14365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) handle.idle_time(), 14375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMilliseconds(1), 14385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta::FromMinutes(6), 14395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 100); 14405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 14415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 14425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 14435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 14445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 14455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 14465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::IsPreconnecting() const { 14485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK_GE(num_streams_, 0); 14495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return num_streams_ > 0; 14505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 14515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::IsOrphaned() const { 14535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return !IsPreconnecting() && !request_; 14545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 14555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool HttpStreamFactoryImpl::Job::IsRequestEligibleForPipelining() { 14575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (IsPreconnecting() || !request_) { 14585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 14595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1460eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch if (stream_factory_->for_websockets_) { 1461eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch return false; 1462eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 14635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (session_->force_http_pipelining()) { 14645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 14655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 14665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!session_->params().http_pipelining_enabled) { 14675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 14685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 14695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (using_ssl_) { 14705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 14715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 14725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (request_info_.method != "GET" && request_info_.method != "HEAD") { 14735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 14745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 14755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (request_info_.load_flags & 14765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) (net::LOAD_MAIN_FRAME | net::LOAD_SUB_FRAME | net::LOAD_PREFETCH | 14775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::LOAD_IS_DOWNLOAD)) { 14785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Avoid pipelining resources that may be streamed for a long time. 14795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 14805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 14815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return stream_factory_->http_pipelined_host_pool_.IsKeyEligibleForPipelining( 14825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *http_pipelining_key_.get()); 14835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 14845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace net 1486