Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(285)

Side by Side Diff: net/http/http_network_layer.cc

Issue 3533013: net: plumb DnsRRResolver from IOThread to HttpNetworkSession. (Closed)
Patch Set: Created 10 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "net/http/http_network_layer.h" 5 #include "net/http/http_network_layer.h"
6 6
7 #include "base/field_trial.h" 7 #include "base/field_trial.h"
8 #include "base/logging.h" 8 #include "base/logging.h"
9 #include "base/string_split.h" 9 #include "base/string_split.h"
10 #include "base/string_util.h" 10 #include "base/string_util.h"
11 #include "net/http/http_network_session.h" 11 #include "net/http/http_network_session.h"
12 #include "net/http/http_network_transaction.h" 12 #include "net/http/http_network_transaction.h"
13 #include "net/socket/client_socket_factory.h" 13 #include "net/socket/client_socket_factory.h"
14 #include "net/spdy/spdy_framer.h" 14 #include "net/spdy/spdy_framer.h"
15 #include "net/spdy/spdy_session.h" 15 #include "net/spdy/spdy_session.h"
16 #include "net/spdy/spdy_session_pool.h" 16 #include "net/spdy/spdy_session_pool.h"
17 17
18 namespace net { 18 namespace net {
19 19
20 //----------------------------------------------------------------------------- 20 //-----------------------------------------------------------------------------
21 21
22 // static 22 // static
23 HttpTransactionFactory* HttpNetworkLayer::CreateFactory( 23 HttpTransactionFactory* HttpNetworkLayer::CreateFactory(
24 HostResolver* host_resolver, 24 HostResolver* host_resolver,
25 DnsRRResolver* dnsrr_resolver,
25 ProxyService* proxy_service, 26 ProxyService* proxy_service,
26 SSLConfigService* ssl_config_service, 27 SSLConfigService* ssl_config_service,
27 HttpAuthHandlerFactory* http_auth_handler_factory, 28 HttpAuthHandlerFactory* http_auth_handler_factory,
28 HttpNetworkDelegate* network_delegate, 29 HttpNetworkDelegate* network_delegate,
29 NetLog* net_log) { 30 NetLog* net_log) {
30 DCHECK(proxy_service); 31 DCHECK(proxy_service);
31 32
32 return new HttpNetworkLayer(ClientSocketFactory::GetDefaultFactory(), 33 return new HttpNetworkLayer(ClientSocketFactory::GetDefaultFactory(),
33 host_resolver, proxy_service, ssl_config_service, 34 host_resolver, dnsrr_resolver, proxy_service,
34 http_auth_handler_factory, 35 ssl_config_service, http_auth_handler_factory,
35 network_delegate, 36 network_delegate,
36 net_log); 37 net_log);
37 } 38 }
38 39
39 // static 40 // static
40 HttpTransactionFactory* HttpNetworkLayer::CreateFactory( 41 HttpTransactionFactory* HttpNetworkLayer::CreateFactory(
41 HttpNetworkSession* session) { 42 HttpNetworkSession* session) {
42 DCHECK(session); 43 DCHECK(session);
43 44
44 return new HttpNetworkLayer(session); 45 return new HttpNetworkLayer(session);
45 } 46 }
46 47
47 //----------------------------------------------------------------------------- 48 //-----------------------------------------------------------------------------
48 HttpNetworkLayer::HttpNetworkLayer( 49 HttpNetworkLayer::HttpNetworkLayer(
49 ClientSocketFactory* socket_factory, 50 ClientSocketFactory* socket_factory,
50 HostResolver* host_resolver, 51 HostResolver* host_resolver,
52 DnsRRResolver* dnsrr_resolver,
51 ProxyService* proxy_service, 53 ProxyService* proxy_service,
52 SSLConfigService* ssl_config_service, 54 SSLConfigService* ssl_config_service,
53 HttpAuthHandlerFactory* http_auth_handler_factory, 55 HttpAuthHandlerFactory* http_auth_handler_factory,
54 HttpNetworkDelegate* network_delegate, 56 HttpNetworkDelegate* network_delegate,
55 NetLog* net_log) 57 NetLog* net_log)
56 : socket_factory_(socket_factory), 58 : socket_factory_(socket_factory),
57 host_resolver_(host_resolver), 59 host_resolver_(host_resolver),
60 dnsrr_resolver_(dnsrr_resolver),
58 proxy_service_(proxy_service), 61 proxy_service_(proxy_service),
59 ssl_config_service_(ssl_config_service), 62 ssl_config_service_(ssl_config_service),
60 session_(NULL), 63 session_(NULL),
61 spdy_session_pool_(NULL), 64 spdy_session_pool_(NULL),
62 http_auth_handler_factory_(http_auth_handler_factory), 65 http_auth_handler_factory_(http_auth_handler_factory),
63 network_delegate_(network_delegate), 66 network_delegate_(network_delegate),
64 net_log_(net_log), 67 net_log_(net_log),
65 suspended_(false) { 68 suspended_(false) {
66 DCHECK(proxy_service_); 69 DCHECK(proxy_service_);
67 DCHECK(ssl_config_service_.get()); 70 DCHECK(ssl_config_service_.get());
68 } 71 }
69 72
70 HttpNetworkLayer::HttpNetworkLayer( 73 HttpNetworkLayer::HttpNetworkLayer(
71 ClientSocketFactory* socket_factory, 74 ClientSocketFactory* socket_factory,
72 HostResolver* host_resolver, 75 HostResolver* host_resolver,
76 DnsRRResolver* dnsrr_resolver,
73 ProxyService* proxy_service, 77 ProxyService* proxy_service,
74 SSLConfigService* ssl_config_service, 78 SSLConfigService* ssl_config_service,
75 SpdySessionPool* spdy_session_pool, 79 SpdySessionPool* spdy_session_pool,
76 HttpAuthHandlerFactory* http_auth_handler_factory, 80 HttpAuthHandlerFactory* http_auth_handler_factory,
77 HttpNetworkDelegate* network_delegate, 81 HttpNetworkDelegate* network_delegate,
78 NetLog* net_log) 82 NetLog* net_log)
79 : socket_factory_(socket_factory), 83 : socket_factory_(socket_factory),
80 host_resolver_(host_resolver), 84 host_resolver_(host_resolver),
85 dnsrr_resolver_(dnsrr_resolver),
81 proxy_service_(proxy_service), 86 proxy_service_(proxy_service),
82 ssl_config_service_(ssl_config_service), 87 ssl_config_service_(ssl_config_service),
83 session_(NULL), 88 session_(NULL),
84 spdy_session_pool_(spdy_session_pool), 89 spdy_session_pool_(spdy_session_pool),
85 http_auth_handler_factory_(http_auth_handler_factory), 90 http_auth_handler_factory_(http_auth_handler_factory),
86 network_delegate_(network_delegate), 91 network_delegate_(network_delegate),
87 net_log_(net_log), 92 net_log_(net_log),
88 suspended_(false) { 93 suspended_(false) {
89 DCHECK(proxy_service_); 94 DCHECK(proxy_service_);
90 DCHECK(ssl_config_service_.get()); 95 DCHECK(ssl_config_service_.get());
91 } 96 }
92 97
93 HttpNetworkLayer::HttpNetworkLayer(HttpNetworkSession* session) 98 HttpNetworkLayer::HttpNetworkLayer(HttpNetworkSession* session)
94 : socket_factory_(ClientSocketFactory::GetDefaultFactory()), 99 : socket_factory_(ClientSocketFactory::GetDefaultFactory()),
100 dnsrr_resolver_(NULL),
95 ssl_config_service_(NULL), 101 ssl_config_service_(NULL),
96 session_(session), 102 session_(session),
97 spdy_session_pool_(NULL), 103 spdy_session_pool_(NULL),
98 http_auth_handler_factory_(NULL), 104 http_auth_handler_factory_(NULL),
99 network_delegate_(NULL), 105 network_delegate_(NULL),
100 net_log_(NULL), 106 net_log_(NULL),
101 suspended_(false) { 107 suspended_(false) {
102 DCHECK(session_.get()); 108 DCHECK(session_.get());
103 } 109 }
104 110
(...skipping 19 matching lines...) Expand all
124 session_->tcp_socket_pool()->CloseIdleSockets(); 130 session_->tcp_socket_pool()->CloseIdleSockets();
125 } 131 }
126 132
127 HttpNetworkSession* HttpNetworkLayer::GetSession() { 133 HttpNetworkSession* HttpNetworkLayer::GetSession() {
128 if (!session_) { 134 if (!session_) {
129 DCHECK(proxy_service_); 135 DCHECK(proxy_service_);
130 if (!spdy_session_pool_.get()) 136 if (!spdy_session_pool_.get())
131 spdy_session_pool_.reset(new SpdySessionPool(ssl_config_service_)); 137 spdy_session_pool_.reset(new SpdySessionPool(ssl_config_service_));
132 session_ = new HttpNetworkSession( 138 session_ = new HttpNetworkSession(
133 host_resolver_, 139 host_resolver_,
140 dnsrr_resolver_,
134 proxy_service_, 141 proxy_service_,
135 socket_factory_, 142 socket_factory_,
136 ssl_config_service_, 143 ssl_config_service_,
137 spdy_session_pool_.release(), 144 spdy_session_pool_.release(),
138 http_auth_handler_factory_, 145 http_auth_handler_factory_,
139 network_delegate_, 146 network_delegate_,
140 net_log_); 147 net_log_);
141 // These were just temps for lazy-initializing HttpNetworkSession. 148 // These were just temps for lazy-initializing HttpNetworkSession.
142 host_resolver_ = NULL; 149 host_resolver_ = NULL;
150 dnsrr_resolver_ = NULL;
143 proxy_service_ = NULL; 151 proxy_service_ = NULL;
144 socket_factory_ = NULL; 152 socket_factory_ = NULL;
145 http_auth_handler_factory_ = NULL; 153 http_auth_handler_factory_ = NULL;
146 net_log_ = NULL; 154 net_log_ = NULL;
147 network_delegate_ = NULL; 155 network_delegate_ = NULL;
148 } 156 }
149 return session_; 157 return session_;
150 } 158 }
151 159
152 // static 160 // static
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after
225 pair.protocol = HttpAlternateProtocols::NPN_SPDY_2; 233 pair.protocol = HttpAlternateProtocols::NPN_SPDY_2;
226 HttpAlternateProtocols::ForceAlternateProtocol(pair); 234 HttpAlternateProtocols::ForceAlternateProtocol(pair);
227 } else if (option.empty() && it == spdy_options.begin()) { 235 } else if (option.empty() && it == spdy_options.begin()) {
228 continue; 236 continue;
229 } else { 237 } else {
230 LOG(DFATAL) << "Unrecognized spdy option: " << option; 238 LOG(DFATAL) << "Unrecognized spdy option: " << option;
231 } 239 }
232 } 240 }
233 } 241 }
234 } // namespace net 242 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698