Support DevTools for off-main-thread-fetch

third_party/WebKit/Source/core/loader/BaseFetchContext.cpp

 // Copyright 2017 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "core/loader/BaseFetchContext.h"
 
 #include "core/dom/ExecutionContext.h"
 #include "core/frame/ContentSettingsClient.h"
 #include "core/frame/Settings.h"
 #include "core/inspector/ConsoleMessage.h"
 #include "core/loader/SubresourceFilter.h"
 #include "core/loader/private/FrameClientHintsPreferencesContext.h"
+#include "core/probe/CoreProbes.h"
 #include "platform/exported/WrappedResourceRequest.h"
 #include "platform/loader/fetch/FetchInitiatorTypeNames.h"
 #include "platform/loader/fetch/Resource.h"
 #include "platform/loader/fetch/ResourceLoadPriority.h"
 #include "platform/loader/fetch/ResourceLoadingLog.h"
 #include "platform/weborigin/SchemeRegistry.h"
 #include "platform/weborigin/SecurityPolicy.h"
 
 namespace blink {
 
@@ skipping 23 matching lines @@
   if (execution_context_) {
     request.SetExternalRequestStateFromRequestorAddressSpace(
         execution_context_->GetSecurityContext().AddressSpace());
   }
 }
 
 SecurityOrigin* BaseFetchContext::GetSecurityOrigin() const {
   return execution_context_ ? execution_context_->GetSecurityOrigin() : nullptr;
 }
 
+void BaseFetchContext::DispatchDidReceiveEncodedData(unsigned long identifier,
+                                                     int encoded_data_length) {
+  probe::didReceiveEncodedDataLength(execution_context_, identifier,
+                                     encoded_data_length);
+}
+
 ResourceRequestBlockedReason BaseFetchContext::CanRequest(
     Resource::Type type,
     const ResourceRequest& resource_request,
     const KURL& url,
     const ResourceLoaderOptions& options,
     SecurityViolationReportingPolicy reporting_policy,
     FetchParameters::OriginRestriction origin_restriction) const {
   ResourceRequestBlockedReason blocked_reason = CanRequestInternal(
       type, resource_request, url, options, reporting_policy,
       origin_restriction, resource_request.GetRedirectStatus());
@@ skipping 104 matching lines @@
 }
 
 ResourceRequestBlockedReason BaseFetchContext::CanRequestInternal(
     Resource::Type type,
     const ResourceRequest& resource_request,
     const KURL& url,
     const ResourceLoaderOptions& options,
     SecurityViolationReportingPolicy reporting_policy,
     FetchParameters::OriginRestriction origin_restriction,
     ResourceRequest::RedirectStatus redirect_status) const {
-  if (ShouldBlockRequestByInspector(resource_request))
+  bool should_block_request = false;
+  probe::shouldBlockRequest(execution_context_, resource_request,
+                            &should_block_request);
+  if (should_block_request)
     return ResourceRequestBlockedReason::kInspector;
 
   SecurityOrigin* security_origin = options.security_origin.Get();
   if (!security_origin && execution_context_)
     security_origin = execution_context_->GetSecurityOrigin();
 
   if (origin_restriction != FetchParameters::kNoOriginRestriction &&
       security_origin && !security_origin->CanDisplay(url)) {
     if (reporting_policy == SecurityViolationReportingPolicy::kReport)
       ReportLocalLoadFailed(url);
@@ skipping 125 matching lines @@
 
   return ResourceRequestBlockedReason::kNone;
 }
 
 DEFINE_TRACE(BaseFetchContext) {
   visitor->Trace(execution_context_);
   FetchContext::Trace(visitor);
 }
 
 }  // namespace blink