1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/browser/net/preconnect.h"
#include "base/histogram.h"
#include "base/logging.h"
#include "chrome/browser/profile.h"
#include "chrome/browser/chrome_thread.h"
#include "chrome/common/net/url_request_context_getter.h"
#include "net/base/host_port_pair.h"
#include "net/http/http_network_session.h"
#include "net/http/http_transaction_factory.h"
#include "net/proxy/proxy_service.h"
#include "net/url_request/url_request_context.h"
namespace chrome_browser_net {
// static
bool Preconnect::preconnect_despite_proxy_ = false;
// We will deliberately leak this singular instance, which is used only for
// callbacks.
// static
Preconnect* Preconnect::callback_instance_;
// static
bool Preconnect::PreconnectOnUIThread(const GURL& url) {
// Try to do connection warming for this search provider.
URLRequestContextGetter* getter = Profile::GetDefaultRequestContext();
if (!getter)
return false;
// Prewarm connection to Search URL.
ChromeThread::PostTask(
ChromeThread::IO,
FROM_HERE,
NewRunnableFunction(Preconnect::PreconnectOnIOThread, url));
return true;
}
enum ProxyStatus {
PROXY_STATUS_IGNORED,
PROXY_UNINITIALIZED,
PROXY_NOT_USED,
PROXY_PAC_RESOLVER,
PROXY_HAS_RULES,
PROXY_MAX,
};
static void HistogramPreconnectStatus(ProxyStatus status) {
UMA_HISTOGRAM_ENUMERATION("Net.PreconnectProxyStatus", status, PROXY_MAX);
}
// static
void Preconnect::PreconnectOnIOThread(const GURL& url) {
URLRequestContextGetter* getter = Profile::GetDefaultRequestContext();
if (!getter)
return;
if (!ChromeThread::CurrentlyOn(ChromeThread::IO)) {
LOG(DFATAL) << "This must be run only on the IO thread.";
return;
}
URLRequestContext* context = getter->GetURLRequestContext();
if (preconnect_despite_proxy_) {
HistogramPreconnectStatus(PROXY_STATUS_IGNORED);
} else {
// Currently we avoid all preconnects if there is a proxy configuration.
net::ProxyService* proxy_service = context->proxy_service();
if (!proxy_service->config_has_been_initialized()) {
HistogramPreconnectStatus(PROXY_UNINITIALIZED);
} else {
if (proxy_service->config().MayRequirePACResolver()) {
HistogramPreconnectStatus(PROXY_PAC_RESOLVER);
return;
}
if (!proxy_service->config().proxy_rules().empty()) {
HistogramPreconnectStatus(PROXY_HAS_RULES);
return;
}
HistogramPreconnectStatus(PROXY_NOT_USED);
}
}
net::HttpTransactionFactory* factory = context->http_transaction_factory();
net::HttpNetworkSession* session = factory->GetSession();
scoped_refptr<net::TCPClientSocketPool> pool = session->tcp_socket_pool();
net::TCPSocketParams params(url.host(), url.EffectiveIntPort(), net::LOW,
GURL(), false);
net::ClientSocketHandle handle;
if (!callback_instance_)
callback_instance_ = new Preconnect;
net::HostPortPair endpoint(url.host(), url.EffectiveIntPort());
std::string group_name = endpoint.ToString();
if (url.SchemeIs("https"))
group_name = StringPrintf("ssl/%s", group_name.c_str());
// TODO(jar): This does not handle proxies currently.
handle.Init(group_name, params, net::LOWEST,
callback_instance_, pool, net::BoundNetLog());
handle.Reset();
}
void Preconnect::RunWithParams(const Tuple1<int>& params) {
// This will rarely be called, as we reset the connection just after creating.
NOTREACHED();
}
} // chrome_browser_net
|
