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