OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/browser/loader/resource_loader.h" | 5 #include "content/browser/loader/resource_loader.h" |
6 | 6 |
7 #include "base/command_line.h" | 7 #include "base/command_line.h" |
8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
9 #include "base/metrics/histogram.h" | 9 #include "base/metrics/histogram.h" |
10 #include "base/time/time.h" | 10 #include "base/time/time.h" |
11 #include "content/browser/child_process_security_policy_impl.h" | 11 #include "content/browser/child_process_security_policy_impl.h" |
12 #include "content/browser/loader/cross_site_resource_handler.h" | 12 #include "content/browser/loader/cross_site_resource_handler.h" |
13 #include "content/browser/loader/resource_loader_delegate.h" | 13 #include "content/browser/loader/resource_loader_delegate.h" |
14 #include "content/browser/loader/resource_request_info_impl.h" | 14 #include "content/browser/loader/resource_request_info_impl.h" |
15 #include "content/browser/ssl/ssl_client_auth_handler.h" | 15 #include "content/browser/ssl/ssl_client_auth_handler.h" |
16 #include "content/browser/ssl/ssl_manager.h" | 16 #include "content/browser/ssl/ssl_manager.h" |
17 #include "content/common/ssl_status_serialization.h" | 17 #include "content/common/ssl_status_serialization.h" |
18 #include "content/public/browser/cert_store.h" | 18 #include "content/public/browser/cert_store.h" |
| 19 #include "content/public/browser/resource_context.h" |
19 #include "content/public/browser/resource_dispatcher_host_login_delegate.h" | 20 #include "content/public/browser/resource_dispatcher_host_login_delegate.h" |
20 #include "content/public/browser/site_instance.h" | 21 #include "content/public/browser/site_instance.h" |
21 #include "content/public/common/content_client.h" | 22 #include "content/public/common/content_client.h" |
22 #include "content/public/common/content_switches.h" | 23 #include "content/public/common/content_switches.h" |
23 #include "content/public/common/process_type.h" | 24 #include "content/public/common/process_type.h" |
24 #include "content/public/common/resource_response.h" | 25 #include "content/public/common/resource_response.h" |
25 #include "content/public/common/url_constants.h" | 26 #include "content/public/common/url_constants.h" |
26 #include "net/base/io_buffer.h" | 27 #include "net/base/io_buffer.h" |
27 #include "net/base/load_flags.h" | 28 #include "net/base/load_flags.h" |
28 #include "net/http/http_response_headers.h" | 29 #include "net/http/http_response_headers.h" |
29 #include "net/ssl/client_cert_store.h" | 30 #include "net/ssl/client_cert_store.h" |
30 #include "net/ssl/client_cert_store_impl.h" | |
31 #include "webkit/browser/appcache/appcache_interceptor.h" | 31 #include "webkit/browser/appcache/appcache_interceptor.h" |
32 | 32 |
33 using base::TimeDelta; | 33 using base::TimeDelta; |
34 using base::TimeTicks; | 34 using base::TimeTicks; |
35 | 35 |
36 namespace content { | 36 namespace content { |
37 namespace { | 37 namespace { |
38 | 38 |
39 void PopulateResourceResponse(net::URLRequest* request, | 39 void PopulateResourceResponse(net::URLRequest* request, |
40 ResourceResponse* response) { | 40 ResourceResponse* response) { |
(...skipping 19 matching lines...) Expand all Loading... |
60 // TODO(mmenke): Figure out if LOAD_ENABLE_LOAD_TIMING is safe to remove. | 60 // TODO(mmenke): Figure out if LOAD_ENABLE_LOAD_TIMING is safe to remove. |
61 if (request->load_flags() & net::LOAD_ENABLE_LOAD_TIMING) | 61 if (request->load_flags() & net::LOAD_ENABLE_LOAD_TIMING) |
62 request->GetLoadTimingInfo(&response->head.load_timing); | 62 request->GetLoadTimingInfo(&response->head.load_timing); |
63 } | 63 } |
64 | 64 |
65 } // namespace | 65 } // namespace |
66 | 66 |
67 ResourceLoader::ResourceLoader(scoped_ptr<net::URLRequest> request, | 67 ResourceLoader::ResourceLoader(scoped_ptr<net::URLRequest> request, |
68 scoped_ptr<ResourceHandler> handler, | 68 scoped_ptr<ResourceHandler> handler, |
69 ResourceLoaderDelegate* delegate) | 69 ResourceLoaderDelegate* delegate) |
70 : weak_ptr_factory_(this) { | 70 : deferred_stage_(DEFERRED_NONE), |
71 scoped_ptr<net::ClientCertStore> client_cert_store; | 71 request_(request.Pass()), |
72 #if !defined(USE_OPENSSL) | 72 handler_(handler.Pass()), |
73 client_cert_store.reset(new net::ClientCertStoreImpl()); | 73 delegate_(delegate), |
74 #endif | 74 last_upload_position_(0), |
75 Init(request.Pass(), handler.Pass(), delegate, client_cert_store.Pass()); | 75 waiting_for_upload_progress_ack_(false), |
| 76 is_transferring_(false), |
| 77 weak_ptr_factory_(this) { |
| 78 request_->set_delegate(this); |
| 79 handler_->SetController(this); |
76 } | 80 } |
77 | 81 |
78 ResourceLoader::~ResourceLoader() { | 82 ResourceLoader::~ResourceLoader() { |
79 if (login_delegate_.get()) | 83 if (login_delegate_.get()) |
80 login_delegate_->OnRequestCancelled(); | 84 login_delegate_->OnRequestCancelled(); |
81 if (ssl_client_auth_handler_.get()) | 85 if (ssl_client_auth_handler_.get()) |
82 ssl_client_auth_handler_->OnRequestCancelled(); | 86 ssl_client_auth_handler_->OnRequestCancelled(); |
83 | 87 |
84 // Run ResourceHandler destructor before we tear-down the rest of our state | 88 // Run ResourceHandler destructor before we tear-down the rest of our state |
85 // as the ResourceHandler may want to inspect the URLRequest and other state. | 89 // as the ResourceHandler may want to inspect the URLRequest and other state. |
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
182 } | 186 } |
183 | 187 |
184 void ResourceLoader::ClearSSLClientAuthHandler() { | 188 void ResourceLoader::ClearSSLClientAuthHandler() { |
185 ssl_client_auth_handler_ = NULL; | 189 ssl_client_auth_handler_ = NULL; |
186 } | 190 } |
187 | 191 |
188 void ResourceLoader::OnUploadProgressACK() { | 192 void ResourceLoader::OnUploadProgressACK() { |
189 waiting_for_upload_progress_ack_ = false; | 193 waiting_for_upload_progress_ack_ = false; |
190 } | 194 } |
191 | 195 |
192 ResourceLoader::ResourceLoader( | |
193 scoped_ptr<net::URLRequest> request, | |
194 scoped_ptr<ResourceHandler> handler, | |
195 ResourceLoaderDelegate* delegate, | |
196 scoped_ptr<net::ClientCertStore> client_cert_store) | |
197 : weak_ptr_factory_(this) { | |
198 Init(request.Pass(), handler.Pass(), delegate, client_cert_store.Pass()); | |
199 } | |
200 | |
201 void ResourceLoader::Init(scoped_ptr<net::URLRequest> request, | |
202 scoped_ptr<ResourceHandler> handler, | |
203 ResourceLoaderDelegate* delegate, | |
204 scoped_ptr<net::ClientCertStore> client_cert_store) { | |
205 deferred_stage_ = DEFERRED_NONE; | |
206 request_ = request.Pass(); | |
207 handler_ = handler.Pass(); | |
208 delegate_ = delegate; | |
209 last_upload_position_ = 0; | |
210 waiting_for_upload_progress_ack_ = false; | |
211 is_transferring_ = false; | |
212 client_cert_store_ = client_cert_store.Pass(); | |
213 | |
214 request_->set_delegate(this); | |
215 handler_->SetController(this); | |
216 } | |
217 | |
218 void ResourceLoader::OnReceivedRedirect(net::URLRequest* unused, | 196 void ResourceLoader::OnReceivedRedirect(net::URLRequest* unused, |
219 const GURL& new_url, | 197 const GURL& new_url, |
220 bool* defer) { | 198 bool* defer) { |
221 DCHECK_EQ(request_.get(), unused); | 199 DCHECK_EQ(request_.get(), unused); |
222 | 200 |
223 VLOG(1) << "OnReceivedRedirect: " << request_->url().spec(); | 201 VLOG(1) << "OnReceivedRedirect: " << request_->url().spec(); |
224 DCHECK(request_->status().is_success()); | 202 DCHECK(request_->status().is_success()); |
225 | 203 |
226 ResourceRequestInfoImpl* info = GetRequestInfo(); | 204 ResourceRequestInfoImpl* info = GetRequestInfo(); |
227 | 205 |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
282 void ResourceLoader::OnCertificateRequested( | 260 void ResourceLoader::OnCertificateRequested( |
283 net::URLRequest* unused, | 261 net::URLRequest* unused, |
284 net::SSLCertRequestInfo* cert_info) { | 262 net::SSLCertRequestInfo* cert_info) { |
285 DCHECK_EQ(request_.get(), unused); | 263 DCHECK_EQ(request_.get(), unused); |
286 | 264 |
287 if (!delegate_->AcceptSSLClientCertificateRequest(this, cert_info)) { | 265 if (!delegate_->AcceptSSLClientCertificateRequest(this, cert_info)) { |
288 request_->Cancel(); | 266 request_->Cancel(); |
289 return; | 267 return; |
290 } | 268 } |
291 | 269 |
292 #if !defined(USE_OPENSSL) | |
293 client_cert_store_->GetClientCerts(*cert_info, &cert_info->client_certs); | |
294 if (cert_info->client_certs.empty()) { | |
295 // No need to query the user if there are no certs to choose from. | |
296 request_->ContinueWithCertificate(NULL); | |
297 return; | |
298 } | |
299 #endif | |
300 | |
301 DCHECK(!ssl_client_auth_handler_.get()) | 270 DCHECK(!ssl_client_auth_handler_.get()) |
302 << "OnCertificateRequested called with ssl_client_auth_handler pending"; | 271 << "OnCertificateRequested called with ssl_client_auth_handler pending"; |
303 ssl_client_auth_handler_ = new SSLClientAuthHandler(request_.get(), | 272 ssl_client_auth_handler_ = new SSLClientAuthHandler( |
304 cert_info); | 273 GetRequestInfo()->GetContext()->CreateClientCertStore(), |
| 274 request_.get(), |
| 275 cert_info); |
305 ssl_client_auth_handler_->SelectCertificate(); | 276 ssl_client_auth_handler_->SelectCertificate(); |
306 } | 277 } |
307 | 278 |
308 void ResourceLoader::OnSSLCertificateError(net::URLRequest* request, | 279 void ResourceLoader::OnSSLCertificateError(net::URLRequest* request, |
309 const net::SSLInfo& ssl_info, | 280 const net::SSLInfo& ssl_info, |
310 bool fatal) { | 281 bool fatal) { |
311 ResourceRequestInfoImpl* info = GetRequestInfo(); | 282 ResourceRequestInfoImpl* info = GetRequestInfo(); |
312 | 283 |
313 int render_process_id; | 284 int render_process_id; |
314 int render_view_id; | 285 int render_view_id; |
(...skipping 338 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
653 // we resume. | 624 // we resume. |
654 deferred_stage_ = DEFERRED_FINISH; | 625 deferred_stage_ = DEFERRED_FINISH; |
655 } | 626 } |
656 } | 627 } |
657 | 628 |
658 void ResourceLoader::CallDidFinishLoading() { | 629 void ResourceLoader::CallDidFinishLoading() { |
659 delegate_->DidFinishLoading(this); | 630 delegate_->DidFinishLoading(this); |
660 } | 631 } |
661 | 632 |
662 } // namespace content | 633 } // namespace content |
OLD | NEW |