| 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/content_browser_client.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_impl.h" | |
| 31 #include "webkit/browser/appcache/appcache_interceptor.h" | 30 #include "webkit/browser/appcache/appcache_interceptor.h" |
| 32 | 31 |
| 33 using base::TimeDelta; | 32 using base::TimeDelta; |
| 34 using base::TimeTicks; | 33 using base::TimeTicks; |
| 35 | 34 |
| 36 namespace content { | 35 namespace content { |
| 37 namespace { | 36 namespace { |
| 38 | 37 |
| 39 void PopulateResourceResponse(net::URLRequest* request, | 38 void PopulateResourceResponse(net::URLRequest* request, |
| 40 ResourceResponse* response) { | 39 ResourceResponse* response) { |
| (...skipping 20 matching lines...) Expand all Loading... |
| 61 if (request->load_flags() & net::LOAD_ENABLE_LOAD_TIMING) | 60 if (request->load_flags() & net::LOAD_ENABLE_LOAD_TIMING) |
| 62 request->GetLoadTimingInfo(&response->head.load_timing); | 61 request->GetLoadTimingInfo(&response->head.load_timing); |
| 63 } | 62 } |
| 64 | 63 |
| 65 } // namespace | 64 } // namespace |
| 66 | 65 |
| 67 ResourceLoader::ResourceLoader(scoped_ptr<net::URLRequest> request, | 66 ResourceLoader::ResourceLoader(scoped_ptr<net::URLRequest> request, |
| 68 scoped_ptr<ResourceHandler> handler, | 67 scoped_ptr<ResourceHandler> handler, |
| 69 ResourceLoaderDelegate* delegate) | 68 ResourceLoaderDelegate* delegate) |
| 70 : weak_ptr_factory_(this) { | 69 : weak_ptr_factory_(this) { |
| 71 scoped_ptr<net::ClientCertStore> client_cert_store; | 70 deferred_stage_ = DEFERRED_NONE; |
| 72 #if !defined(USE_OPENSSL) | 71 request_ = request.Pass(); |
| 73 client_cert_store.reset(new net::ClientCertStoreImpl()); | 72 handler_ = handler.Pass(); |
| 74 #endif | 73 delegate_ = delegate; |
| 75 Init(request.Pass(), handler.Pass(), delegate, client_cert_store.Pass()); | 74 last_upload_position_ = 0; |
| 75 waiting_for_upload_progress_ack_ = false; |
| 76 is_transferring_ = false; |
| 77 |
| 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(), request_.get(), cert_info); |
| 305 ssl_client_auth_handler_->SelectCertificate(); | 274 ssl_client_auth_handler_->SelectCertificate(); |
| 306 } | 275 } |
| 307 | 276 |
| 308 void ResourceLoader::OnSSLCertificateError(net::URLRequest* request, | 277 void ResourceLoader::OnSSLCertificateError(net::URLRequest* request, |
| 309 const net::SSLInfo& ssl_info, | 278 const net::SSLInfo& ssl_info, |
| 310 bool fatal) { | 279 bool fatal) { |
| 311 ResourceRequestInfoImpl* info = GetRequestInfo(); | 280 ResourceRequestInfoImpl* info = GetRequestInfo(); |
| 312 | 281 |
| 313 int render_process_id; | 282 int render_process_id; |
| 314 int render_view_id; | 283 int render_view_id; |
| (...skipping 338 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 653 // we resume. | 622 // we resume. |
| 654 deferred_stage_ = DEFERRED_FINISH; | 623 deferred_stage_ = DEFERRED_FINISH; |
| 655 } | 624 } |
| 656 } | 625 } |
| 657 | 626 |
| 658 void ResourceLoader::CallDidFinishLoading() { | 627 void ResourceLoader::CallDidFinishLoading() { |
| 659 delegate_->DidFinishLoading(this); | 628 delegate_->DidFinishLoading(this); |
| 660 } | 629 } |
| 661 | 630 |
| 662 } // namespace content | 631 } // namespace content |
| OLD | NEW |