OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "content/shell/browser/shell_url_request_context_getter.h" | 5 #include "extensions/browser/extension_url_request_context_getter.h" |
6 | 6 |
7 #include "base/command_line.h" | 7 #include "base/command_line.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
9 #include "base/strings/string_number_conversions.h" | 9 #include "base/strings/string_number_conversions.h" |
10 #include "base/strings/string_split.h" | 10 #include "base/strings/string_split.h" |
11 #include "base/strings/string_util.h" | 11 #include "base/strings/string_util.h" |
12 #include "base/threading/sequenced_worker_pool.h" | 12 #include "base/threading/sequenced_worker_pool.h" |
13 #include "base/threading/worker_pool.h" | 13 #include "base/threading/worker_pool.h" |
14 #include "content/public/browser/browser_thread.h" | 14 #include "content/public/browser/browser_thread.h" |
15 #include "content/public/browser/cookie_store_factory.h" | 15 #include "content/public/browser/cookie_store_factory.h" |
| 16 #include "content/public/browser/resource_request_info.h" |
16 #include "content/public/common/content_switches.h" | 17 #include "content/public/common/content_switches.h" |
17 #include "content/shell/browser/shell_network_delegate.h" | 18 #include "extensions/browser/extension_network_delegate.h" |
18 #include "content/shell/common/shell_content_client.h" | 19 #include "extensions/browser/info_map.h" |
19 #include "content/shell/common/shell_switches.h" | 20 #include "extensions/common/constants.h" |
| 21 #include "extensions/common/switches.h" |
20 #include "net/base/cache_type.h" | 22 #include "net/base/cache_type.h" |
21 #include "net/cert/cert_verifier.h" | 23 #include "net/cert/cert_verifier.h" |
22 #include "net/cookies/cookie_monster.h" | 24 #include "net/cookies/cookie_monster.h" |
23 #include "net/dns/host_resolver.h" | 25 #include "net/dns/host_resolver.h" |
24 #include "net/dns/mapped_host_resolver.h" | 26 #include "net/dns/mapped_host_resolver.h" |
25 #include "net/http/http_auth_handler_factory.h" | 27 #include "net/http/http_auth_handler_factory.h" |
26 #include "net/http/http_cache.h" | 28 #include "net/http/http_cache.h" |
27 #include "net/http/http_network_session.h" | 29 #include "net/http/http_network_session.h" |
28 #include "net/http/http_server_properties_impl.h" | 30 #include "net/http/http_server_properties_impl.h" |
29 #include "net/http/transport_security_state.h" | 31 #include "net/http/transport_security_state.h" |
30 #include "net/proxy/proxy_service.h" | 32 #include "net/proxy/proxy_service.h" |
31 #include "net/ssl/channel_id_service.h" | 33 #include "net/ssl/channel_id_service.h" |
32 #include "net/ssl/default_channel_id_store.h" | 34 #include "net/ssl/default_channel_id_store.h" |
33 #include "net/ssl/ssl_config_service_defaults.h" | 35 #include "net/ssl/ssl_config_service_defaults.h" |
34 #include "net/url_request/data_protocol_handler.h" | 36 #include "net/url_request/data_protocol_handler.h" |
35 #include "net/url_request/file_protocol_handler.h" | 37 #include "net/url_request/file_protocol_handler.h" |
36 #include "net/url_request/static_http_user_agent_settings.h" | 38 #include "net/url_request/static_http_user_agent_settings.h" |
37 #include "net/url_request/url_request_context.h" | 39 #include "net/url_request/url_request_context.h" |
38 #include "net/url_request/url_request_context_storage.h" | 40 #include "net/url_request/url_request_context_storage.h" |
39 #include "net/url_request/url_request_intercepting_job_factory.h" | 41 #include "net/url_request/url_request_intercepting_job_factory.h" |
40 #include "net/url_request/url_request_job_factory_impl.h" | 42 #include "net/url_request/url_request_job_factory_impl.h" |
41 #include "url/url_constants.h" | 43 #include "url/url_constants.h" |
42 | 44 |
43 namespace content { | 45 namespace extensions { |
44 | 46 |
45 namespace { | 47 namespace { |
46 | |
47 void InstallProtocolHandlers(net::URLRequestJobFactoryImpl* job_factory, | 48 void InstallProtocolHandlers(net::URLRequestJobFactoryImpl* job_factory, |
48 ProtocolHandlerMap* protocol_handlers) { | 49 content::ProtocolHandlerMap* protocol_handlers) { |
49 for (ProtocolHandlerMap::iterator it = | 50 for (content::ProtocolHandlerMap::iterator it = |
50 protocol_handlers->begin(); | 51 protocol_handlers->begin(); |
51 it != protocol_handlers->end(); | 52 it != protocol_handlers->end(); |
52 ++it) { | 53 ++it) { |
53 bool set_protocol = job_factory->SetProtocolHandler( | 54 bool set_protocol = job_factory->SetProtocolHandler( |
54 it->first, it->second.release()); | 55 it->first, it->second.release()); |
55 DCHECK(set_protocol); | 56 DCHECK(set_protocol); |
56 } | 57 } |
57 protocol_handlers->clear(); | 58 protocol_handlers->clear(); |
58 } | 59 } |
59 | 60 |
60 } // namespace | 61 } // namespace |
61 | 62 |
62 ShellURLRequestContextGetter::ShellURLRequestContextGetter( | 63 ExtensionURLRequestContextGetter::ExtensionURLRequestContextGetter( |
| 64 void* browser_context, |
63 bool ignore_certificate_errors, | 65 bool ignore_certificate_errors, |
64 const base::FilePath& base_path, | 66 const base::FilePath& base_path, |
65 base::MessageLoop* io_loop, | 67 base::MessageLoop* io_loop, |
66 base::MessageLoop* file_loop, | 68 base::MessageLoop* file_loop, |
67 ProtocolHandlerMap* protocol_handlers, | 69 content::ProtocolHandlerMap* protocol_handlers, |
68 URLRequestInterceptorScopedVector request_interceptors, | 70 content::URLRequestInterceptorScopedVector request_interceptors, |
69 net::NetLog* net_log) | 71 net::NetLog* net_log, |
70 : ignore_certificate_errors_(ignore_certificate_errors), | 72 InfoMap* extension_info_map) |
| 73 : browser_context_(browser_context), |
| 74 ignore_certificate_errors_(ignore_certificate_errors), |
71 base_path_(base_path), | 75 base_path_(base_path), |
72 io_loop_(io_loop), | 76 io_loop_(io_loop), |
73 file_loop_(file_loop), | 77 file_loop_(file_loop), |
74 net_log_(net_log), | 78 net_log_(net_log), |
| 79 extension_info_map_(extension_info_map), |
75 request_interceptors_(request_interceptors.Pass()) { | 80 request_interceptors_(request_interceptors.Pass()) { |
76 // Must first be created on the UI thread. | 81 // Must first be created on the UI thread. |
77 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 82 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
78 | |
79 std::swap(protocol_handlers_, *protocol_handlers); | 83 std::swap(protocol_handlers_, *protocol_handlers); |
80 | 84 |
81 // We must create the proxy config service on the UI loop on Linux because it | 85 // We must create the proxy config service on the UI loop on Linux because it |
82 // must synchronously run on the glib message loop. This will be passed to | 86 // must synchronously run on the glib message loop. This will be passed to |
83 // the URLRequestContextStorage on the IO thread in GetURLRequestContext(). | 87 // the URLRequestContextStorage on the IO thread in GetURLRequestContext(). |
84 if (!CommandLine::ForCurrentProcess()->HasSwitch(switches::kDumpRenderTree)) { | 88 if (!CommandLine::ForCurrentProcess()->HasSwitch(switches::kDumpRenderTree)) { |
85 proxy_config_service_.reset( | 89 proxy_config_service_.reset( |
86 net::ProxyService::CreateSystemProxyConfigService( | 90 net::ProxyService::CreateSystemProxyConfigService( |
87 io_loop_->message_loop_proxy(), file_loop_->message_loop_proxy())); | 91 io_loop_->message_loop_proxy(), file_loop_->message_loop_proxy())); |
88 } | 92 } |
89 } | 93 } |
90 | 94 |
91 ShellURLRequestContextGetter::~ShellURLRequestContextGetter() { | 95 ExtensionURLRequestContextGetter::~ExtensionURLRequestContextGetter() { |
92 } | 96 } |
93 | 97 |
94 net::URLRequestContext* ShellURLRequestContextGetter::GetURLRequestContext() { | 98 net::URLRequestContext* |
95 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 99 ExtensionURLRequestContextGetter::GetURLRequestContext() { |
| 100 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO)); |
96 | 101 |
97 if (!url_request_context_) { | 102 if (!url_request_context_) { |
98 const CommandLine& command_line = *CommandLine::ForCurrentProcess(); | 103 const CommandLine& command_line = *CommandLine::ForCurrentProcess(); |
99 | 104 |
100 url_request_context_.reset(new net::URLRequestContext()); | 105 url_request_context_.reset(new net::URLRequestContext()); |
101 url_request_context_->set_net_log(net_log_); | 106 url_request_context_->set_net_log(net_log_); |
102 network_delegate_.reset(new ShellNetworkDelegate); | 107 network_delegate_.reset( |
| 108 new ExtensionNetworkDelegate(browser_context_, extension_info_map_)); |
103 if (command_line.HasSwitch(switches::kDumpRenderTree)) | 109 if (command_line.HasSwitch(switches::kDumpRenderTree)) |
104 ShellNetworkDelegate::SetAcceptAllCookies(false); | 110 ExtensionNetworkDelegate::SetAcceptAllCookies(false); |
105 url_request_context_->set_network_delegate(network_delegate_.get()); | 111 url_request_context_->set_network_delegate(network_delegate_.get()); |
106 storage_.reset( | 112 storage_.reset( |
107 new net::URLRequestContextStorage(url_request_context_.get())); | 113 new net::URLRequestContextStorage(url_request_context_.get())); |
108 storage_->set_cookie_store(CreateCookieStore(CookieStoreConfig())); | 114 storage_->set_cookie_store(CreateCookieStore(content::CookieStoreConfig())); |
109 storage_->set_channel_id_service(new net::ChannelIDService( | 115 storage_->set_channel_id_service(new net::ChannelIDService( |
110 new net::DefaultChannelIDStore(NULL), | 116 new net::DefaultChannelIDStore(NULL), |
111 base::WorkerPool::GetTaskRunner(true))); | 117 base::WorkerPool::GetTaskRunner(true))); |
112 storage_->set_http_user_agent_settings( | |
113 new net::StaticHttpUserAgentSettings( | |
114 "en-us,en", GetShellUserAgent())); | |
115 | 118 |
116 scoped_ptr<net::HostResolver> host_resolver( | 119 scoped_ptr<net::HostResolver> host_resolver( |
117 net::HostResolver::CreateDefaultResolver( | 120 net::HostResolver::CreateDefaultResolver( |
118 url_request_context_->net_log())); | 121 url_request_context_->net_log())); |
119 | 122 |
120 storage_->set_cert_verifier(net::CertVerifier::CreateDefault()); | 123 storage_->set_cert_verifier(net::CertVerifier::CreateDefault()); |
121 storage_->set_transport_security_state(new net::TransportSecurityState); | 124 storage_->set_transport_security_state(new net::TransportSecurityState); |
122 if (command_line.HasSwitch(switches::kDumpRenderTree)) { | 125 if (command_line.HasSwitch(switches::kDumpRenderTree)) { |
123 storage_->set_proxy_service(net::ProxyService::CreateDirect()); | 126 storage_->set_proxy_service(net::ProxyService::CreateDirect()); |
124 } else { | 127 } else { |
(...skipping 17 matching lines...) Expand all Loading... |
142 net::DISK_CACHE, | 145 net::DISK_CACHE, |
143 #if defined(OS_ANDROID) | 146 #if defined(OS_ANDROID) |
144 // TODO(rdsmith): Remove when default backend for Android is | 147 // TODO(rdsmith): Remove when default backend for Android is |
145 // changed to simple cache. | 148 // changed to simple cache. |
146 net::CACHE_BACKEND_SIMPLE, | 149 net::CACHE_BACKEND_SIMPLE, |
147 #else | 150 #else |
148 net::CACHE_BACKEND_DEFAULT, | 151 net::CACHE_BACKEND_DEFAULT, |
149 #endif | 152 #endif |
150 cache_path, | 153 cache_path, |
151 0, | 154 0, |
152 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::CACHE)); | 155 content::BrowserThread::GetMessageLoopProxyForThread( |
| 156 content::BrowserThread::CACHE)); |
153 | 157 |
154 net::HttpNetworkSession::Params network_session_params; | 158 net::HttpNetworkSession::Params network_session_params; |
155 network_session_params.cert_verifier = | 159 network_session_params.cert_verifier = |
156 url_request_context_->cert_verifier(); | 160 url_request_context_->cert_verifier(); |
157 network_session_params.transport_security_state = | 161 network_session_params.transport_security_state = |
158 url_request_context_->transport_security_state(); | 162 url_request_context_->transport_security_state(); |
159 network_session_params.channel_id_service = | 163 network_session_params.channel_id_service = |
160 url_request_context_->channel_id_service(); | 164 url_request_context_->channel_id_service(); |
161 network_session_params.proxy_service = | 165 network_session_params.proxy_service = |
162 url_request_context_->proxy_service(); | 166 url_request_context_->proxy_service(); |
163 network_session_params.ssl_config_service = | 167 network_session_params.ssl_config_service = |
164 url_request_context_->ssl_config_service(); | 168 url_request_context_->ssl_config_service(); |
165 network_session_params.http_auth_handler_factory = | 169 network_session_params.http_auth_handler_factory = |
166 url_request_context_->http_auth_handler_factory(); | 170 url_request_context_->http_auth_handler_factory(); |
167 network_session_params.network_delegate = | 171 network_session_params.network_delegate = |
168 network_delegate_.get(); | 172 network_delegate_.get(); |
169 network_session_params.http_server_properties = | 173 network_session_params.http_server_properties = |
170 url_request_context_->http_server_properties(); | 174 url_request_context_->http_server_properties(); |
171 network_session_params.net_log = | 175 network_session_params.net_log = |
172 url_request_context_->net_log(); | 176 url_request_context_->net_log(); |
173 network_session_params.ignore_certificate_errors = | 177 network_session_params.ignore_certificate_errors = |
174 ignore_certificate_errors_; | 178 ignore_certificate_errors_; |
175 if (command_line.HasSwitch(switches::kTestingFixedHttpPort)) { | 179 if (command_line.HasSwitch(::switches::kTestingFixedHttpPort)) { |
176 int value; | 180 int value; |
177 base::StringToInt(command_line.GetSwitchValueASCII( | 181 base::StringToInt(command_line.GetSwitchValueASCII( |
178 switches::kTestingFixedHttpPort), &value); | 182 ::switches::kTestingFixedHttpPort), &value); |
179 network_session_params.testing_fixed_http_port = value; | 183 network_session_params.testing_fixed_http_port = value; |
180 } | 184 } |
181 if (command_line.HasSwitch(switches::kTestingFixedHttpsPort)) { | 185 if (command_line.HasSwitch(::switches::kTestingFixedHttpsPort)) { |
182 int value; | 186 int value; |
183 base::StringToInt(command_line.GetSwitchValueASCII( | 187 base::StringToInt(command_line.GetSwitchValueASCII( |
184 switches::kTestingFixedHttpsPort), &value); | 188 ::switches::kTestingFixedHttpsPort), &value); |
185 network_session_params.testing_fixed_https_port = value; | 189 network_session_params.testing_fixed_https_port = value; |
186 } | 190 } |
187 if (command_line.HasSwitch(switches::kHostResolverRules)) { | 191 if (command_line.HasSwitch(::switches::kHostResolverRules)) { |
188 scoped_ptr<net::MappedHostResolver> mapped_host_resolver( | 192 scoped_ptr<net::MappedHostResolver> mapped_host_resolver( |
189 new net::MappedHostResolver(host_resolver.Pass())); | 193 new net::MappedHostResolver(host_resolver.Pass())); |
190 mapped_host_resolver->SetRulesFromString( | 194 mapped_host_resolver->SetRulesFromString( |
191 command_line.GetSwitchValueASCII(switches::kHostResolverRules)); | 195 command_line.GetSwitchValueASCII(::switches::kHostResolverRules)); |
192 host_resolver = mapped_host_resolver.Pass(); | 196 host_resolver = mapped_host_resolver.Pass(); |
193 } | 197 } |
194 | 198 |
195 // Give |storage_| ownership at the end in case it's |mapped_host_resolver|. | 199 // Give |storage_| ownership at the end in case it's |mapped_host_resolver|. |
196 storage_->set_host_resolver(host_resolver.Pass()); | 200 storage_->set_host_resolver(host_resolver.Pass()); |
197 network_session_params.host_resolver = | 201 network_session_params.host_resolver = |
198 url_request_context_->host_resolver(); | 202 url_request_context_->host_resolver(); |
199 | 203 |
200 net::HttpCache* main_cache = new net::HttpCache( | 204 net::HttpCache* main_cache = new net::HttpCache( |
201 network_session_params, main_backend); | 205 network_session_params, main_backend); |
202 storage_->set_http_transaction_factory(main_cache); | 206 storage_->set_http_transaction_factory(main_cache); |
203 | 207 |
204 scoped_ptr<net::URLRequestJobFactoryImpl> job_factory( | 208 scoped_ptr<net::URLRequestJobFactoryImpl> job_factory( |
205 new net::URLRequestJobFactoryImpl()); | 209 new net::URLRequestJobFactoryImpl()); |
206 // Keep ProtocolHandlers added in sync with | 210 // Keep ProtocolHandlers added in sync with |
207 // ShellContentBrowserClient::IsHandledURL(). | 211 // ShellContentBrowserClient::IsHandledURL(). |
208 InstallProtocolHandlers(job_factory.get(), &protocol_handlers_); | 212 InstallProtocolHandlers(job_factory.get(), &protocol_handlers_); |
209 bool set_protocol = job_factory->SetProtocolHandler( | 213 bool set_protocol = job_factory->SetProtocolHandler( |
210 url::kDataScheme, new net::DataProtocolHandler); | 214 url::kDataScheme, new net::DataProtocolHandler); |
211 DCHECK(set_protocol); | 215 DCHECK(set_protocol); |
212 #if !defined(DISABLE_FILE_SUPPORT) | 216 #if !defined(DISABLE_FILE_SUPPORT) |
213 set_protocol = job_factory->SetProtocolHandler( | 217 set_protocol = job_factory->SetProtocolHandler( |
214 url::kFileScheme, | 218 url::kFileScheme, |
215 new net::FileProtocolHandler( | 219 new net::FileProtocolHandler( |
216 BrowserThread::GetBlockingPool()->GetTaskRunnerWithShutdownBehavior( | 220 content::BrowserThread::GetBlockingPool()-> |
217 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN))); | 221 GetTaskRunnerWithShutdownBehavior( |
| 222 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN))); |
218 DCHECK(set_protocol); | 223 DCHECK(set_protocol); |
219 #endif | 224 #endif |
220 | 225 |
221 // Set up interceptors in the reverse order. | 226 // Set up interceptors in the reverse order. |
222 scoped_ptr<net::URLRequestJobFactory> top_job_factory = | 227 scoped_ptr<net::URLRequestJobFactory> top_job_factory = |
223 job_factory.PassAs<net::URLRequestJobFactory>(); | 228 job_factory.PassAs<net::URLRequestJobFactory>(); |
224 for (URLRequestInterceptorScopedVector::reverse_iterator i = | 229 for (content::URLRequestInterceptorScopedVector::reverse_iterator i = |
225 request_interceptors_.rbegin(); | 230 request_interceptors_.rbegin(); |
226 i != request_interceptors_.rend(); | 231 i != request_interceptors_.rend(); |
227 ++i) { | 232 ++i) { |
228 top_job_factory.reset(new net::URLRequestInterceptingJobFactory( | 233 top_job_factory.reset(new net::URLRequestInterceptingJobFactory( |
229 top_job_factory.Pass(), make_scoped_ptr(*i))); | 234 top_job_factory.Pass(), make_scoped_ptr(*i))); |
230 } | 235 } |
231 request_interceptors_.weak_clear(); | 236 request_interceptors_.weak_clear(); |
232 | 237 |
233 storage_->set_job_factory(top_job_factory.release()); | 238 storage_->set_job_factory(top_job_factory.release()); |
234 } | 239 } |
235 | 240 |
236 return url_request_context_.get(); | 241 return url_request_context_.get(); |
237 } | 242 } |
238 | 243 |
239 scoped_refptr<base::SingleThreadTaskRunner> | 244 scoped_refptr<base::SingleThreadTaskRunner> |
240 ShellURLRequestContextGetter::GetNetworkTaskRunner() const { | 245 ExtensionURLRequestContextGetter::GetNetworkTaskRunner() const { |
241 return BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO); | 246 return content::BrowserThread::GetMessageLoopProxyForThread( |
| 247 content::BrowserThread::IO); |
242 } | 248 } |
243 | 249 |
244 net::HostResolver* ShellURLRequestContextGetter::host_resolver() { | 250 } // namespace extensions |
245 return url_request_context_->host_resolver(); | |
246 } | |
247 | |
248 } // namespace content | |
OLD | NEW |