| 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_dispatcher_host_login_delegate.h" | 19 #include "content/public/browser/resource_dispatcher_host_login_delegate.h" |
| 20 #include "content/public/browser/site_instance.h" | 20 #include "content/public/browser/site_instance.h" |
| 21 #include "content/public/common/content_client.h" | 21 #include "content/public/common/content_client.h" |
| 22 #include "content/public/common/content_switches.h" | 22 #include "content/public/common/content_switches.h" |
| 23 #include "content/public/common/process_type.h" | 23 #include "content/public/common/process_type.h" |
| 24 #include "content/public/common/resource_response.h" | 24 #include "content/public/common/resource_response.h" |
| 25 #include "content/public/common/url_constants.h" | 25 #include "content/public/common/url_constants.h" |
| 26 #include "net/base/io_buffer.h" | 26 #include "net/base/io_buffer.h" |
| 27 #include "net/base/load_flags.h" | 27 #include "net/base/load_flags.h" |
| 28 #include "net/http/http_response_headers.h" | 28 #include "net/http/http_response_headers.h" |
| 29 #include "net/ssl/client_cert_store.h" | |
| 30 #include "net/ssl/client_cert_store_impl.h" | |
| 31 #include "webkit/browser/appcache/appcache_interceptor.h" | 29 #include "webkit/browser/appcache/appcache_interceptor.h" |
| 32 | 30 |
| 33 using base::TimeDelta; | 31 using base::TimeDelta; |
| 34 using base::TimeTicks; | 32 using base::TimeTicks; |
| 35 | 33 |
| 36 namespace content { | 34 namespace content { |
| 37 namespace { | 35 namespace { |
| 38 | 36 |
| 39 void PopulateResourceResponse(net::URLRequest* request, | 37 void PopulateResourceResponse(net::URLRequest* request, |
| 40 ResourceResponse* response) { | 38 ResourceResponse* response) { |
| (...skipping 19 matching lines...) Expand all Loading... |
| 60 // TODO(mmenke): Figure out if LOAD_ENABLE_LOAD_TIMING is safe to remove. | 58 // TODO(mmenke): Figure out if LOAD_ENABLE_LOAD_TIMING is safe to remove. |
| 61 if (request->load_flags() & net::LOAD_ENABLE_LOAD_TIMING) | 59 if (request->load_flags() & net::LOAD_ENABLE_LOAD_TIMING) |
| 62 request->GetLoadTimingInfo(&response->head.load_timing); | 60 request->GetLoadTimingInfo(&response->head.load_timing); |
| 63 } | 61 } |
| 64 | 62 |
| 65 } // namespace | 63 } // namespace |
| 66 | 64 |
| 67 ResourceLoader::ResourceLoader(scoped_ptr<net::URLRequest> request, | 65 ResourceLoader::ResourceLoader(scoped_ptr<net::URLRequest> request, |
| 68 scoped_ptr<ResourceHandler> handler, | 66 scoped_ptr<ResourceHandler> handler, |
| 69 ResourceLoaderDelegate* delegate) | 67 ResourceLoaderDelegate* delegate) |
| 70 : weak_ptr_factory_(this) { | 68 : deferred_stage_(DEFERRED_NONE), |
| 71 scoped_ptr<net::ClientCertStore> client_cert_store; | 69 request_(request.Pass()), |
| 72 #if !defined(USE_OPENSSL) | 70 handler_(handler.Pass()), |
| 73 client_cert_store.reset(new net::ClientCertStoreImpl()); | 71 delegate_(delegate), |
| 74 #endif | 72 last_upload_position_(0), |
| 75 Init(request.Pass(), handler.Pass(), delegate, client_cert_store.Pass()); | 73 waiting_for_upload_progress_ack_(false), |
| 74 is_transferring_(false), |
| 75 weak_ptr_factory_(this) { |
| 76 request_->set_delegate(this); |
| 77 handler_->SetController(this); |
| 76 } | 78 } |
| 77 | 79 |
| 78 ResourceLoader::~ResourceLoader() { | 80 ResourceLoader::~ResourceLoader() { |
| 79 if (login_delegate_.get()) | 81 if (login_delegate_.get()) |
| 80 login_delegate_->OnRequestCancelled(); | 82 login_delegate_->OnRequestCancelled(); |
| 81 if (ssl_client_auth_handler_.get()) | 83 if (ssl_client_auth_handler_.get()) |
| 82 ssl_client_auth_handler_->OnRequestCancelled(); | 84 ssl_client_auth_handler_->OnRequestCancelled(); |
| 83 | 85 |
| 84 // Run ResourceHandler destructor before we tear-down the rest of our state | 86 // 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. | 87 // 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 } | 184 } |
| 183 | 185 |
| 184 void ResourceLoader::ClearSSLClientAuthHandler() { | 186 void ResourceLoader::ClearSSLClientAuthHandler() { |
| 185 ssl_client_auth_handler_ = NULL; | 187 ssl_client_auth_handler_ = NULL; |
| 186 } | 188 } |
| 187 | 189 |
| 188 void ResourceLoader::OnUploadProgressACK() { | 190 void ResourceLoader::OnUploadProgressACK() { |
| 189 waiting_for_upload_progress_ack_ = false; | 191 waiting_for_upload_progress_ack_ = false; |
| 190 } | 192 } |
| 191 | 193 |
| 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, | 194 void ResourceLoader::OnReceivedRedirect(net::URLRequest* unused, |
| 219 const GURL& new_url, | 195 const GURL& new_url, |
| 220 bool* defer) { | 196 bool* defer) { |
| 221 DCHECK_EQ(request_.get(), unused); | 197 DCHECK_EQ(request_.get(), unused); |
| 222 | 198 |
| 223 VLOG(1) << "OnReceivedRedirect: " << request_->url().spec(); | 199 VLOG(1) << "OnReceivedRedirect: " << request_->url().spec(); |
| 224 DCHECK(request_->status().is_success()); | 200 DCHECK(request_->status().is_success()); |
| 225 | 201 |
| 226 ResourceRequestInfoImpl* info = GetRequestInfo(); | 202 ResourceRequestInfoImpl* info = GetRequestInfo(); |
| 227 | 203 |
| (...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 282 void ResourceLoader::OnCertificateRequested( | 258 void ResourceLoader::OnCertificateRequested( |
| 283 net::URLRequest* unused, | 259 net::URLRequest* unused, |
| 284 net::SSLCertRequestInfo* cert_info) { | 260 net::SSLCertRequestInfo* cert_info) { |
| 285 DCHECK_EQ(request_.get(), unused); | 261 DCHECK_EQ(request_.get(), unused); |
| 286 | 262 |
| 287 if (!delegate_->AcceptSSLClientCertificateRequest(this, cert_info)) { | 263 if (!delegate_->AcceptSSLClientCertificateRequest(this, cert_info)) { |
| 288 request_->Cancel(); | 264 request_->Cancel(); |
| 289 return; | 265 return; |
| 290 } | 266 } |
| 291 | 267 |
| 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()) | 268 DCHECK(!ssl_client_auth_handler_.get()) |
| 302 << "OnCertificateRequested called with ssl_client_auth_handler pending"; | 269 << "OnCertificateRequested called with ssl_client_auth_handler pending"; |
| 303 ssl_client_auth_handler_ = new SSLClientAuthHandler(request_.get(), | 270 ssl_client_auth_handler_ = new SSLClientAuthHandler( |
| 304 cert_info); | 271 GetRequestInfo()->GetContext(), request_.get(), cert_info); |
| 305 ssl_client_auth_handler_->SelectCertificate(); | 272 ssl_client_auth_handler_->SelectCertificate(); |
| 306 } | 273 } |
| 307 | 274 |
| 308 void ResourceLoader::OnSSLCertificateError(net::URLRequest* request, | 275 void ResourceLoader::OnSSLCertificateError(net::URLRequest* request, |
| 309 const net::SSLInfo& ssl_info, | 276 const net::SSLInfo& ssl_info, |
| 310 bool fatal) { | 277 bool fatal) { |
| 311 ResourceRequestInfoImpl* info = GetRequestInfo(); | 278 ResourceRequestInfoImpl* info = GetRequestInfo(); |
| 312 | 279 |
| 313 int render_process_id; | 280 int render_process_id; |
| 314 int render_view_id; | 281 int render_view_id; |
| (...skipping 338 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 653 // we resume. | 620 // we resume. |
| 654 deferred_stage_ = DEFERRED_FINISH; | 621 deferred_stage_ = DEFERRED_FINISH; |
| 655 } | 622 } |
| 656 } | 623 } |
| 657 | 624 |
| 658 void ResourceLoader::CallDidFinishLoading() { | 625 void ResourceLoader::CallDidFinishLoading() { |
| 659 delegate_->DidFinishLoading(this); | 626 delegate_->DidFinishLoading(this); |
| 660 } | 627 } |
| 661 | 628 |
| 662 } // namespace content | 629 } // namespace content |
| OLD | NEW |