| 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 <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/callback_helpers.h" | |
| 10 #include "base/command_line.h" | 9 #include "base/command_line.h" |
| 11 #include "base/location.h" | 10 #include "base/location.h" |
| 12 #include "base/metrics/histogram_macros.h" | 11 #include "base/metrics/histogram_macros.h" |
| 13 #include "base/profiler/scoped_tracker.h" | 12 #include "base/profiler/scoped_tracker.h" |
| 14 #include "base/single_thread_task_runner.h" | 13 #include "base/single_thread_task_runner.h" |
| 15 #include "base/threading/thread_task_runner_handle.h" | 14 #include "base/threading/thread_task_runner_handle.h" |
| 16 #include "base/time/time.h" | 15 #include "base/time/time.h" |
| 17 #include "base/trace_event/trace_event.h" | 16 #include "base/trace_event/trace_event.h" |
| 18 #include "content/browser/appcache/appcache_interceptor.h" | 17 #include "content/browser/appcache/appcache_interceptor.h" |
| 19 #include "content/browser/child_process_security_policy_impl.h" | 18 #include "content/browser/child_process_security_policy_impl.h" |
| 19 #include "content/browser/loader/cross_site_resource_handler.h" |
| 20 #include "content/browser/loader/detachable_resource_handler.h" | 20 #include "content/browser/loader/detachable_resource_handler.h" |
| 21 #include "content/browser/loader/resource_loader_delegate.h" | 21 #include "content/browser/loader/resource_loader_delegate.h" |
| 22 #include "content/browser/loader/resource_request_info_impl.h" | 22 #include "content/browser/loader/resource_request_info_impl.h" |
| 23 #include "content/browser/service_worker/service_worker_request_handler.h" | 23 #include "content/browser/service_worker/service_worker_request_handler.h" |
| 24 #include "content/browser/service_worker/service_worker_response_info.h" | 24 #include "content/browser/service_worker/service_worker_response_info.h" |
| 25 #include "content/browser/ssl/ssl_client_auth_handler.h" | 25 #include "content/browser/ssl/ssl_client_auth_handler.h" |
| 26 #include "content/browser/ssl/ssl_manager.h" | 26 #include "content/browser/ssl/ssl_manager.h" |
| 27 #include "content/browser/ssl/ssl_policy.h" | 27 #include "content/browser/ssl/ssl_policy.h" |
| 28 #include "content/public/browser/resource_dispatcher_host_login_delegate.h" | 28 #include "content/public/browser/resource_dispatcher_host_login_delegate.h" |
| 29 #include "content/public/common/content_client.h" | 29 #include "content/public/common/content_client.h" |
| (...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 191 CancelRequest(false); | 191 CancelRequest(false); |
| 192 } | 192 } |
| 193 | 193 |
| 194 void ResourceLoader::CancelWithError(int error_code) { | 194 void ResourceLoader::CancelWithError(int error_code) { |
| 195 TRACE_EVENT_WITH_FLOW0("loading", "ResourceLoader::CancelWithError", this, | 195 TRACE_EVENT_WITH_FLOW0("loading", "ResourceLoader::CancelWithError", this, |
| 196 TRACE_EVENT_FLAG_FLOW_IN); | 196 TRACE_EVENT_FLAG_FLOW_IN); |
| 197 CancelRequestInternal(error_code, false); | 197 CancelRequestInternal(error_code, false); |
| 198 } | 198 } |
| 199 | 199 |
| 200 void ResourceLoader::MarkAsTransferring( | 200 void ResourceLoader::MarkAsTransferring( |
| 201 const base::Closure& on_transfer_complete_callback) { | 201 const scoped_refptr<ResourceResponse>& response) { |
| 202 CHECK(IsResourceTypeFrame(GetRequestInfo()->GetResourceType())) | 202 CHECK(IsResourceTypeFrame(GetRequestInfo()->GetResourceType())) |
| 203 << "Can only transfer for navigations"; | 203 << "Can only transfer for navigations"; |
| 204 is_transferring_ = true; | 204 is_transferring_ = true; |
| 205 on_transfer_complete_callback_ = on_transfer_complete_callback; | |
| 206 | 205 |
| 207 int child_id = GetRequestInfo()->GetChildID(); | 206 int child_id = GetRequestInfo()->GetChildID(); |
| 208 AppCacheInterceptor::PrepareForCrossSiteTransfer(request(), child_id); | 207 AppCacheInterceptor::PrepareForCrossSiteTransfer(request(), child_id); |
| 209 ServiceWorkerRequestHandler* handler = | 208 ServiceWorkerRequestHandler* handler = |
| 210 ServiceWorkerRequestHandler::GetHandler(request()); | 209 ServiceWorkerRequestHandler::GetHandler(request()); |
| 211 if (handler) | 210 if (handler) |
| 212 handler->PrepareForCrossSiteTransfer(child_id); | 211 handler->PrepareForCrossSiteTransfer(child_id); |
| 213 } | 212 } |
| 214 | 213 |
| 215 void ResourceLoader::CompleteTransfer() { | 214 void ResourceLoader::CompleteTransfer() { |
| 216 // Although NavigationResourceThrottle defers at WillProcessResponse | 215 // Although CrossSiteResourceHandler defers at OnResponseStarted |
| 217 // (DEFERRED_READ), it may be seeing a replay of events via | 216 // (DEFERRED_READ), it may be seeing a replay of events via |
| 218 // MimeTypeResourceHandler, and so the request itself is actually deferred at | 217 // MimeTypeResourceHandler, and so the request itself is actually deferred |
| 219 // a later read stage. | 218 // at a later read stage. |
| 220 DCHECK(DEFERRED_READ == deferred_stage_ || | 219 DCHECK(DEFERRED_READ == deferred_stage_ || |
| 221 DEFERRED_RESPONSE_COMPLETE == deferred_stage_); | 220 DEFERRED_RESPONSE_COMPLETE == deferred_stage_); |
| 222 DCHECK(is_transferring_); | 221 DCHECK(is_transferring_); |
| 223 DCHECK(!on_transfer_complete_callback_.is_null()); | |
| 224 | 222 |
| 225 // In some cases, a process transfer doesn't really happen and the | 223 // In some cases, a process transfer doesn't really happen and the |
| 226 // request is resumed in the original process. Real transfers to a new process | 224 // request is resumed in the original process. Real transfers to a new process |
| 227 // are completed via ResourceDispatcherHostImpl::UpdateRequestForTransfer. | 225 // are completed via ResourceDispatcherHostImpl::UpdateRequestForTransfer. |
| 228 int child_id = GetRequestInfo()->GetChildID(); | 226 int child_id = GetRequestInfo()->GetChildID(); |
| 229 AppCacheInterceptor::MaybeCompleteCrossSiteTransferInOldProcess( | 227 AppCacheInterceptor::MaybeCompleteCrossSiteTransferInOldProcess( |
| 230 request(), child_id); | 228 request(), child_id); |
| 231 ServiceWorkerRequestHandler* handler = | 229 ServiceWorkerRequestHandler* handler = |
| 232 ServiceWorkerRequestHandler::GetHandler(request()); | 230 ServiceWorkerRequestHandler::GetHandler(request()); |
| 233 if (handler) | 231 if (handler) |
| 234 handler->MaybeCompleteCrossSiteTransferInOldProcess(child_id); | 232 handler->MaybeCompleteCrossSiteTransferInOldProcess(child_id); |
| 235 | 233 |
| 236 is_transferring_ = false; | 234 is_transferring_ = false; |
| 237 base::ResetAndReturn(&on_transfer_complete_callback_).Run(); | 235 GetRequestInfo()->cross_site_handler()->ResumeResponse(); |
| 238 } | 236 } |
| 239 | 237 |
| 240 ResourceRequestInfoImpl* ResourceLoader::GetRequestInfo() { | 238 ResourceRequestInfoImpl* ResourceLoader::GetRequestInfo() { |
| 241 return ResourceRequestInfoImpl::ForRequest(request_.get()); | 239 return ResourceRequestInfoImpl::ForRequest(request_.get()); |
| 242 } | 240 } |
| 243 | 241 |
| 244 void ResourceLoader::ClearLoginDelegate() { | 242 void ResourceLoader::ClearLoginDelegate() { |
| 245 login_delegate_ = NULL; | 243 login_delegate_ = NULL; |
| 246 } | 244 } |
| 247 | 245 |
| (...skipping 466 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 714 } | 712 } |
| 715 | 713 |
| 716 UMA_HISTOGRAM_ENUMERATION("Net.Prefetch.Pattern", status, STATUS_MAX); | 714 UMA_HISTOGRAM_ENUMERATION("Net.Prefetch.Pattern", status, STATUS_MAX); |
| 717 } else if (request_->response_info().unused_since_prefetch) { | 715 } else if (request_->response_info().unused_since_prefetch) { |
| 718 TimeDelta total_time = base::TimeTicks::Now() - request_->creation_time(); | 716 TimeDelta total_time = base::TimeTicks::Now() - request_->creation_time(); |
| 719 UMA_HISTOGRAM_TIMES("Net.Prefetch.TimeSpentOnPrefetchHit", total_time); | 717 UMA_HISTOGRAM_TIMES("Net.Prefetch.TimeSpentOnPrefetchHit", total_time); |
| 720 } | 718 } |
| 721 } | 719 } |
| 722 | 720 |
| 723 } // namespace content | 721 } // namespace content |
| OLD | NEW |