[WIP] off-main-thread loading

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

 /*
  * Copyright (C) 2011, 2012 Google Inc. All rights reserved.
  * Copyright (C) 2013, Intel Corporation
  *
  * 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.
@@ skipping 372 matching lines @@
     // request to the SW. https://crbug.com/604583
     // Similarly we don't want any requests that could involve a CORS preflight
     // to get intercepted by a foreign fetch service worker, even if we have the
     // result of the preflight cached already. https://crbug.com/674370
     crossOriginRequest.setServiceWorkerMode(
         WebURLRequest::ServiceWorkerMode::None);
 
     bool shouldForcePreflight = request.isExternalRequest();
     if (!shouldForcePreflight)
       probe::shouldForceCORSPreflight(document(), &shouldForcePreflight);
+    // TODO(horo): Move CrossOriginPreflightResultCache to
+    // ThreadableLoadingContext
     bool canSkipPreflight =
+        isMainThread() &&
         CrossOriginPreflightResultCache::shared().canSkipPreflight(
             getSecurityOrigin()->toString(), crossOriginRequest.url(),
             effectiveAllowCredentials(), crossOriginRequest.httpMethod(),
             crossOriginRequest.httpHeaderFields());
     if (canSkipPreflight && !shouldForcePreflight) {
       prepareCrossOriginRequest(crossOriginRequest);
       loadRequest(crossOriginRequest, crossOriginOptions);
     } else {
       ResourceRequest preflightRequest =
           createAccessControlPreflightRequest(crossOriginRequest);
@@ skipping 351 matching lines @@
           new CrossOriginPreflightResultCacheItem(effectiveAllowCredentials()));
   if (!preflightResult->parse(response, accessControlErrorDescription) ||
       !preflightResult->allowsCrossOriginMethod(
           m_actualRequest.httpMethod(), accessControlErrorDescription) ||
       !preflightResult->allowsCrossOriginHeaders(
           m_actualRequest.httpHeaderFields(), accessControlErrorDescription)) {
     handlePreflightFailure(response.url().getString(),
                            accessControlErrorDescription);
     return;
   }
-
-  CrossOriginPreflightResultCache::shared().appendEntry(
-      getSecurityOrigin()->toString(), m_actualRequest.url(),
-      std::move(preflightResult));
+  if (isMainThread()) {
+    // TODO(horo): Move CrossOriginPreflightResultCache to
+    // ThreadableLoadingContext
+    CrossOriginPreflightResultCache::shared().appendEntry(
+        getSecurityOrigin()->toString(), m_actualRequest.url(),
+        std::move(preflightResult));
+  }
 }
 
 void DocumentThreadableLoader::reportResponseReceived(
     unsigned long identifier,
     const ResourceResponse& response) {
   LocalFrame* frame = document() ? document()->frame() : nullptr;
   if (!frame)
     return;
   DocumentLoader* loader = frame->loader().documentLoader();
-  probe::didReceiveResourceResponse(frame, identifier, loader, response,
+  probe::didReceiveResourceResponse(document(), identifier, loader, response,
                                     resource());
   frame->console().reportResourceResponseReceived(loader, identifier, response);
 }
 
 void DocumentThreadableLoader::handleResponse(
     unsigned long identifier,
     const ResourceResponse& response,
     std::unique_ptr<WebDataConsumerHandle> handle) {
   DCHECK(m_client);
 
@@ skipping 357 matching lines @@
 }
 
 DEFINE_TRACE(DocumentThreadableLoader) {
   visitor->trace(m_resource);
   visitor->trace(m_loadingContext);
   ThreadableLoader::trace(visitor);
   RawResourceClient::trace(visitor);
 }
 
 }  // namespace blink