[WIP2] 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 375 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
     cross_origin_request.SetServiceWorkerMode(
         WebURLRequest::ServiceWorkerMode::kNone);
 
     bool should_force_preflight = request.IsExternalRequest();
     if (!should_force_preflight)
       probe::shouldForceCORSPreflight(GetDocument(), &should_force_preflight);
+    // TODO(horo): Move CrossOriginPreflightResultCache to
+    // ThreadableLoadingContext
     bool can_skip_preflight =
+        IsMainThread() &&
         CrossOriginPreflightResultCache::Shared().CanSkipPreflight(
             GetSecurityOrigin()->ToString(), cross_origin_request.Url(),
             EffectiveAllowCredentials(), cross_origin_request.HttpMethod(),
             cross_origin_request.HttpHeaderFields());
     if (can_skip_preflight && !should_force_preflight) {
       PrepareCrossOriginRequest(cross_origin_request);
       LoadRequest(cross_origin_request, cross_origin_options);
     } else {
       ResourceRequest preflight_request =
           CreateAccessControlPreflightRequest(cross_origin_request);
@@ skipping 355 matching lines @@
       !preflight_result->AllowsCrossOriginMethod(
           actual_request_.HttpMethod(), access_control_error_description) ||
       !preflight_result->AllowsCrossOriginHeaders(
           actual_request_.HttpHeaderFields(),
           access_control_error_description)) {
     HandlePreflightFailure(response.Url().GetString(),
                            access_control_error_description);
     return;
   }
 
-  CrossOriginPreflightResultCache::Shared().AppendEntry(
-      GetSecurityOrigin()->ToString(), actual_request_.Url(),
-      std::move(preflight_result));
+  if (IsMainThread()) {
+    // TODO(horo): Move CrossOriginPreflightResultCache to
+    // ThreadableLoadingContext
+    CrossOriginPreflightResultCache::Shared().AppendEntry(
+        GetSecurityOrigin()->ToString(), actual_request_.Url(),
+        std::move(preflight_result));
+  }
 }
 
 void DocumentThreadableLoader::ReportResponseReceived(
     unsigned long identifier,
     const ResourceResponse& response) {
   LocalFrame* frame = GetDocument() ? GetDocument()->GetFrame() : nullptr;
   if (!frame)
     return;
   DocumentLoader* loader = frame->Loader().GetDocumentLoader();
-  probe::didReceiveResourceResponse(frame, identifier, loader, response,
+  probe::didReceiveResourceResponse(GetDocument(), identifier, loader, response,
                                     GetResource());
   frame->Console().ReportResourceResponseReceived(loader, identifier, response);
 }
 
 void DocumentThreadableLoader::HandleResponse(
     unsigned long identifier,
     const ResourceResponse& response,
     std::unique_ptr<WebDataConsumerHandle> handle) {
   DCHECK(client_);
 
@@ skipping 361 matching lines @@
 }
 
 DEFINE_TRACE(DocumentThreadableLoader) {
   visitor->Trace(resource_);
   visitor->Trace(loading_context_);
   ThreadableLoader::Trace(visitor);
   RawResourceClient::Trace(visitor);
 }
 
 }  // namespace blink