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

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

Issue 2802015: Massively simplify the NetworkChangeNotifier infrastructure:... (Closed) Base URL: svn://chrome-svn/chrome/trunk/src/
Patch Set: '' Created 10 years, 6 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 | Annotate | Revision Log
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_util.h" 9 #include "base/string_util.h"
10 #include "net/http/http_network_session.h" 10 #include "net/http/http_network_session.h"
11 #include "net/http/http_network_transaction.h" 11 #include "net/http/http_network_transaction.h"
12 #include "net/socket/client_socket_factory.h" 12 #include "net/socket/client_socket_factory.h"
13 #include "net/spdy/spdy_framer.h" 13 #include "net/spdy/spdy_framer.h"
14 #include "net/spdy/spdy_network_transaction.h" 14 #include "net/spdy/spdy_network_transaction.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 NetworkChangeNotifier* network_change_notifier,
25 HostResolver* host_resolver, 24 HostResolver* host_resolver,
26 ProxyService* proxy_service, 25 ProxyService* proxy_service,
27 SSLConfigService* ssl_config_service, 26 SSLConfigService* ssl_config_service,
28 HttpAuthHandlerFactory* http_auth_handler_factory, 27 HttpAuthHandlerFactory* http_auth_handler_factory,
29 HttpNetworkDelegate* network_delegate, 28 HttpNetworkDelegate* network_delegate,
30 NetLog* net_log) { 29 NetLog* net_log) {
31 DCHECK(proxy_service); 30 DCHECK(proxy_service);
32 31
33 return new HttpNetworkLayer(ClientSocketFactory::GetDefaultFactory(), 32 return new HttpNetworkLayer(ClientSocketFactory::GetDefaultFactory(),
34 network_change_notifier,
35 host_resolver, proxy_service, ssl_config_service, 33 host_resolver, proxy_service, ssl_config_service,
36 http_auth_handler_factory, 34 http_auth_handler_factory,
37 network_delegate, 35 network_delegate,
38 net_log); 36 net_log);
39 } 37 }
40 38
41 // static 39 // static
42 HttpTransactionFactory* HttpNetworkLayer::CreateFactory( 40 HttpTransactionFactory* HttpNetworkLayer::CreateFactory(
43 HttpNetworkSession* session) { 41 HttpNetworkSession* session) {
44 DCHECK(session); 42 DCHECK(session);
45 43
46 return new HttpNetworkLayer(session); 44 return new HttpNetworkLayer(session);
47 } 45 }
48 46
49 //----------------------------------------------------------------------------- 47 //-----------------------------------------------------------------------------
50 bool HttpNetworkLayer::force_spdy_ = false; 48 bool HttpNetworkLayer::force_spdy_ = false;
51 49
52 HttpNetworkLayer::HttpNetworkLayer( 50 HttpNetworkLayer::HttpNetworkLayer(
53 ClientSocketFactory* socket_factory, 51 ClientSocketFactory* socket_factory,
54 NetworkChangeNotifier* network_change_notifier,
55 HostResolver* host_resolver, 52 HostResolver* host_resolver,
56 ProxyService* proxy_service, 53 ProxyService* proxy_service,
57 SSLConfigService* ssl_config_service, 54 SSLConfigService* ssl_config_service,
58 HttpAuthHandlerFactory* http_auth_handler_factory, 55 HttpAuthHandlerFactory* http_auth_handler_factory,
59 HttpNetworkDelegate* network_delegate, 56 HttpNetworkDelegate* network_delegate,
60 NetLog* net_log) 57 NetLog* net_log)
61 : socket_factory_(socket_factory), 58 : socket_factory_(socket_factory),
62 network_change_notifier_(network_change_notifier),
63 host_resolver_(host_resolver), 59 host_resolver_(host_resolver),
64 proxy_service_(proxy_service), 60 proxy_service_(proxy_service),
65 ssl_config_service_(ssl_config_service), 61 ssl_config_service_(ssl_config_service),
66 session_(NULL), 62 session_(NULL),
67 spdy_session_pool_(NULL), 63 spdy_session_pool_(NULL),
68 http_auth_handler_factory_(http_auth_handler_factory), 64 http_auth_handler_factory_(http_auth_handler_factory),
69 network_delegate_(network_delegate), 65 network_delegate_(network_delegate),
70 net_log_(net_log), 66 net_log_(net_log),
71 suspended_(false) { 67 suspended_(false) {
72 DCHECK(proxy_service_); 68 DCHECK(proxy_service_);
73 DCHECK(ssl_config_service_.get()); 69 DCHECK(ssl_config_service_.get());
74 } 70 }
75 71
76 HttpNetworkLayer::HttpNetworkLayer(HttpNetworkSession* session) 72 HttpNetworkLayer::HttpNetworkLayer(HttpNetworkSession* session)
77 : socket_factory_(ClientSocketFactory::GetDefaultFactory()), 73 : socket_factory_(ClientSocketFactory::GetDefaultFactory()),
78 network_change_notifier_(NULL),
79 ssl_config_service_(NULL), 74 ssl_config_service_(NULL),
80 session_(session), 75 session_(session),
81 spdy_session_pool_(session->spdy_session_pool()), 76 spdy_session_pool_(session->spdy_session_pool()),
82 http_auth_handler_factory_(NULL), 77 http_auth_handler_factory_(NULL),
83 network_delegate_(NULL), 78 network_delegate_(NULL),
84 net_log_(NULL), 79 net_log_(NULL),
85 suspended_(false) { 80 suspended_(false) {
86 DCHECK(session_.get()); 81 DCHECK(session_.get());
87 } 82 }
88 83
(...skipping 18 matching lines...) Expand all
107 void HttpNetworkLayer::Suspend(bool suspend) { 102 void HttpNetworkLayer::Suspend(bool suspend) {
108 suspended_ = suspend; 103 suspended_ = suspend;
109 104
110 if (suspend && session_) 105 if (suspend && session_)
111 session_->tcp_socket_pool()->CloseIdleSockets(); 106 session_->tcp_socket_pool()->CloseIdleSockets();
112 } 107 }
113 108
114 HttpNetworkSession* HttpNetworkLayer::GetSession() { 109 HttpNetworkSession* HttpNetworkLayer::GetSession() {
115 if (!session_) { 110 if (!session_) {
116 DCHECK(proxy_service_); 111 DCHECK(proxy_service_);
117 SpdySessionPool* spdy_pool = new SpdySessionPool(network_change_notifier_); 112 SpdySessionPool* spdy_pool = new SpdySessionPool();
118 session_ = new HttpNetworkSession( 113 session_ = new HttpNetworkSession(host_resolver_, proxy_service_,
119 network_change_notifier_, host_resolver_, proxy_service_,
120 socket_factory_, ssl_config_service_, spdy_pool, 114 socket_factory_, ssl_config_service_, spdy_pool,
121 http_auth_handler_factory_, 115 http_auth_handler_factory_, network_delegate_, net_log_);
122 network_delegate_,
123 net_log_);
124 // These were just temps for lazy-initializing HttpNetworkSession. 116 // These were just temps for lazy-initializing HttpNetworkSession.
125 network_change_notifier_ = NULL;
126 host_resolver_ = NULL; 117 host_resolver_ = NULL;
127 proxy_service_ = NULL; 118 proxy_service_ = NULL;
128 socket_factory_ = NULL; 119 socket_factory_ = NULL;
129 http_auth_handler_factory_ = NULL; 120 http_auth_handler_factory_ = NULL;
130 net_log_ = NULL; 121 net_log_ = NULL;
131 network_delegate_ = NULL; 122 network_delegate_ = NULL;
132 } 123 }
133 return session_; 124 return session_;
134 } 125 }
135 126
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after
182 force_spdy_ = false; 173 force_spdy_ = false;
183 } else if (option.empty() && it == spdy_options.begin()) { 174 } else if (option.empty() && it == spdy_options.begin()) {
184 continue; 175 continue;
185 } else { 176 } else {
186 LOG(DFATAL) << "Unrecognized spdy option: " << option; 177 LOG(DFATAL) << "Unrecognized spdy option: " << option;
187 } 178 }
188 } 179 }
189 } 180 }
190 181
191 } // namespace net 182 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698