[WIP] off-main-thread loading

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

 /*
  * Copyright (C) 2013 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 61 matching lines @@
 #include "platform/loader/fetch/Resource.h"
 #include "platform/loader/fetch/ResourceLoadPriority.h"
 #include "platform/loader/fetch/ResourceLoadingLog.h"
 #include "platform/loader/fetch/ResourceTimingInfo.h"
 #include "platform/loader/fetch/UniqueIdentifier.h"
 #include "platform/mhtml/MHTMLArchive.h"
 #include "platform/network/NetworkStateNotifier.h"
 #include "platform/network/NetworkUtils.h"
 #include "platform/weborigin/SchemeRegistry.h"
 #include "platform/weborigin/SecurityPolicy.h"
+#include "public/platform/Platform.h"
 #include "public/platform/WebCachePolicy.h"
 #include "public/platform/WebInsecureRequestPolicy.h"
 #include "public/platform/WebViewScheduler.h"
 #include "public/platform/modules/serviceworker/WebServiceWorkerNetworkProvider.h"
 #include "wtf/Vector.h"
 
 namespace blink {
 
 namespace {
 
@@ skipping 221 matching lines @@
 FrameFetchContext::FrameFetchContext(DocumentLoader* loader, Document* document)
     : m_document(document), m_documentLoader(loader) {
   DCHECK(frame());
 }
 
 FrameFetchContext::~FrameFetchContext() {
   m_document = nullptr;
   m_documentLoader = nullptr;
 }
 
+WebURLLoader* FrameFetchContext::createURLLoader() {
+  return Platform::current()->createURLLoader();
+}
+
 LocalFrame* FrameFetchContext::frameOfImportsController() const {
   DCHECK(m_document);
   HTMLImportsController* importsController = m_document->importsController();
   DCHECK(importsController);
   LocalFrame* frame = importsController->master()->frame();
   DCHECK(frame);
   return frame;
 }
 
+int FrameFetchContext::applicationCacheHostID() const {
+  if (!m_documentLoader)
+    return 0;
+  return m_documentLoader->applicationCacheHost()->getHostID();
+}
+
 LocalFrame* FrameFetchContext::frame() const {
   if (!m_documentLoader)
     return frameOfImportsController();
 
   LocalFrame* frame = m_documentLoader->frame();
   DCHECK(frame);
   return frame;
 }
 
 LocalFrameClient* FrameFetchContext::localFrameClient() const {
@@ skipping 131 matching lines @@
     unsigned long identifier,
     ResourceRequest& request,
     const ResourceResponse& redirectResponse,
     const FetchInitiatorInfo& initiatorInfo) {
   if (redirectResponse.isNull()) {
     // Progress doesn't care about redirects, only notify it when an
     // initial request is sent.
     frame()->loader().progress().willStartLoading(identifier,
                                                   request.priority());
   }
-  probe::willSendRequest(frame(), identifier, masterDocumentLoader(), request,
-                         redirectResponse, initiatorInfo);
+  probe::willSendRequest(frame()->document(), identifier,
+                         masterDocumentLoader(), request, redirectResponse,
+                         initiatorInfo);
   if (frame()->frameScheduler())
     frame()->frameScheduler()->didStartLoading(identifier);
 }
 
 void FrameFetchContext::dispatchDidReceiveResponse(
     unsigned long identifier,
     const ResourceResponse& response,
     WebURLRequest::FrameType frameType,
     WebURLRequest::RequestContext requestContext,
     Resource* resource,
@@ skipping 28 matching lines @@
       LinkLoader::LoadAll, nullptr);
 
   if (response.hasMajorCertificateErrors()) {
     MixedContentChecker::handleCertificateError(frame(), response, frameType,
                                                 requestContext);
   }
 
   frame()->loader().progress().incrementProgress(identifier, response);
   localFrameClient()->dispatchDidReceiveResponse(response);
   DocumentLoader* documentLoader = masterDocumentLoader();
-  probe::didReceiveResourceResponse(frame(), identifier, documentLoader,
-                                    response, resource);
+  probe::didReceiveResourceResponse(frame()->document(), identifier,
+                                    documentLoader, response, resource);
   // It is essential that inspector gets resource response BEFORE console.
   frame()->console().reportResourceResponseReceived(documentLoader, identifier,
                                                     response);
 }
 
 void FrameFetchContext::dispatchDidReceiveData(unsigned long identifier,
                                                const char* data,
                                                int dataLength) {
   frame()->loader().progress().incrementProgress(identifier, dataLength);
-  probe::didReceiveData(frame(), identifier, data, dataLength);
+  probe::didReceiveData(frame()->document(), identifier, masterDocumentLoader(),
+                        data, dataLength);
 }
 
 void FrameFetchContext::dispatchDidReceiveEncodedData(unsigned long identifier,
                                                       int encodedDataLength) {
-  probe::didReceiveEncodedDataLength(frame(), identifier, encodedDataLength);
+  probe::didReceiveEncodedDataLength(frame()->document(), identifier,
+                                     encodedDataLength);
 }
 
 void FrameFetchContext::dispatchDidDownloadData(unsigned long identifier,
                                                 int dataLength,
                                                 int encodedDataLength) {
   frame()->loader().progress().incrementProgress(identifier, dataLength);
-  probe::didReceiveData(frame(), identifier, 0, dataLength);
-  probe::didReceiveEncodedDataLength(frame(), identifier, encodedDataLength);
+  probe::didReceiveData(frame()->document(), identifier, masterDocumentLoader(),
+                        0, dataLength);
+  probe::didReceiveEncodedDataLength(frame()->document(), identifier,
+                                     encodedDataLength);
 }
 
 void FrameFetchContext::dispatchDidFinishLoading(unsigned long identifier,
                                                  double finishTime,
                                                  int64_t encodedDataLength,
                                                  int64_t decodedBodyLength) {
   frame()->loader().progress().completeProgress(identifier);
-  probe::didFinishLoading(frame(), identifier, finishTime, encodedDataLength,
+  probe::didFinishLoading(frame()->document(), identifier,
+                          masterDocumentLoader(), finishTime, encodedDataLength,
                           decodedBodyLength);
   if (frame()->frameScheduler())
     frame()->frameScheduler()->didStopLoading(identifier);
 }
 
 void FrameFetchContext::dispatchDidFail(unsigned long identifier,
                                         const ResourceError& error,
                                         int64_t encodedDataLength,
                                         bool isInternalRequest) {
   frame()->loader().progress().completeProgress(identifier);
-  probe::didFailLoading(frame(), identifier, error);
+  probe::didFailLoading(frame()->document(), identifier, error);
   // Notification to FrameConsole should come AFTER InspectorInstrumentation
   // call, DevTools front-end relies on this.
   if (!isInternalRequest)
     frame()->console().didFailLoading(identifier, error);
   if (frame()->frameScheduler())
     frame()->frameScheduler()->didStopLoading(identifier);
 }
 
 void FrameFetchContext::dispatchDidLoadResourceFromMemoryCache(
     unsigned long identifier,
@@ skipping 98 matching lines @@
     const ResourceRequest& resourceRequest,
     const KURL& url,
     const ResourceLoaderOptions& options,
     SecurityViolationReportingPolicy reportingPolicy,
     FetchRequest::OriginRestriction originRestriction) const {
   ResourceRequestBlockedReason blockedReason =
       canRequestInternal(type, resourceRequest, url, options, reportingPolicy,
                          originRestriction, resourceRequest.redirectStatus());
   if (blockedReason != ResourceRequestBlockedReason::None &&
       reportingPolicy == SecurityViolationReportingPolicy::Report) {
-    probe::didBlockRequest(frame(), resourceRequest, masterDocumentLoader(),
+    probe::didBlockRequest(m_document, resourceRequest, masterDocumentLoader(),
                            options.initiatorInfo, blockedReason);
   }
   return blockedReason;
 }
 
 ResourceRequestBlockedReason FrameFetchContext::allowResponse(
     Resource::Type type,
     const ResourceRequest& resourceRequest,
     const KURL& url,
     const ResourceLoaderOptions& options) const {
   ResourceRequestBlockedReason blockedReason =
       canRequestInternal(type, resourceRequest, url, options,
                          SecurityViolationReportingPolicy::Report,
                          FetchRequest::UseDefaultOriginRestrictionForType,
                          RedirectStatus::FollowedRedirect);
   if (blockedReason != ResourceRequestBlockedReason::None) {
-    probe::didBlockRequest(frame(), resourceRequest, masterDocumentLoader(),
+    probe::didBlockRequest(m_document, resourceRequest, masterDocumentLoader(),
                            options.initiatorInfo, blockedReason);
   }
   return blockedReason;
 }
 
 ResourceRequestBlockedReason FrameFetchContext::canRequestInternal(
     Resource::Type type,
     const ResourceRequest& resourceRequest,
     const KURL& url,
     const ResourceLoaderOptions& options,
     SecurityViolationReportingPolicy reportingPolicy,
     FetchRequest::OriginRestriction originRestriction,
     ResourceRequest::RedirectStatus redirectStatus) const {
   bool shouldBlockRequest = false;
-  probe::shouldBlockRequest(frame(), resourceRequest, &shouldBlockRequest);
+  probe::shouldBlockRequest(m_document, resourceRequest, &shouldBlockRequest);
   if (shouldBlockRequest)
     return ResourceRequestBlockedReason::Inspector;
 
   SecurityOrigin* securityOrigin = options.securityOrigin.get();
   if (!securityOrigin && m_document)
     securityOrigin = m_document->getSecurityOrigin();
 
   if (originRestriction != FetchRequest::NoOriginRestriction &&
       securityOrigin && !securityOrigin->canDisplay(url)) {
     if (reportingPolicy == SecurityViolationReportingPolicy::Report)
@@ skipping 316 matching lines @@
   if (!frame()->settings())
     return priority;
 
   // If enabled, drop the priority of all resources in a subframe.
   if (frame()->settings()->getLowPriorityIframes() && !frame()->isMainFrame())
     return ResourceLoadPriorityVeryLow;
 
   return priority;
 }
 
+RefPtr<WebTaskRunner> FrameFetchContext::timerTaskRunner() const {
+  return frame()->frameScheduler()->timerTaskRunner();
+}
+
 RefPtr<WebTaskRunner> FrameFetchContext::loadingTaskRunner() const {
   return frame()->frameScheduler()->loadingTaskRunner();
 }
 
 DEFINE_TRACE(FrameFetchContext) {
   visitor->trace(m_document);
   visitor->trace(m_documentLoader);
   FetchContext::trace(visitor);
 }
 
 }  // namespace blink