Partially implement WorkerFetchContext and WorkerThreadableLoadingContext and add virtual tests

third_party/WebKit/Source/platform/loader/fetch/ResourceFetcher.cpp

 /*
     Copyright (C) 1998 Lars Knoll (knoll@mpi-hd.mpg.de)
     Copyright (C) 2001 Dirk Mueller (mueller@kde.org)
     Copyright (C) 2002 Waldo Bastian (bastian@kde.org)
     Copyright (C) 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011 Apple Inc. All
     rights reserved.
     Copyright (C) 2009 Torch Mobile Inc. http://www.torchmobile.com/
 
     This library is free software; you can redistribute it and/or
     modify it under the terms of the GNU Library General Public
@@ skipping 586 matching lines @@
   bool is_static_data = is_data_url || substitute_data.IsValid() || archive_;
   if (is_static_data) {
     resource = ResourceForStaticData(params, factory, substitute_data);
     // Abort the request if the archive doesn't contain the resource, except in
     // the case of data URLs which might have resources such as fonts that need
     // to be decoded only on demand. These data URLs are allowed to be
     // processed using the normal ResourceFetcher machinery.
     if (!resource && !is_data_url && archive_)
       return nullptr;
   }
-  if (!resource) {
+  if (!resource && IsMainThread()) {
     resource =
         GetMemoryCache()->ResourceForURL(params.Url(), GetCacheIdentifier());
   }
 
   // If we got a preloaded resource from the cache for a non-preload request,
   // we may need to make it block the onload event.
   MakePreloadedResourceBlockOnloadIfNeeded(resource, params);
 
   const RevalidationPolicy policy = DetermineRevalidationPolicy(
       factory.GetType(), params, resource, is_static_data);
@@ skipping 126 matching lines @@
     revalidating_request.SetHTTPHeaderField(HTTPNames::If_None_Match, e_tag);
 
   resource->SetRevalidatingRequest(revalidating_request);
 }
 
 Resource* ResourceFetcher::CreateResourceForLoading(
     FetchParameters& params,
     const String& charset,
     const ResourceFactory& factory) {
   const String cache_identifier = GetCacheIdentifier();
-  DCHECK(!GetMemoryCache()->ResourceForURL(params.GetResourceRequest().Url(),
+  DCHECK(!IsMainThread() ||
+         !GetMemoryCache()->ResourceForURL(params.GetResourceRequest().Url(),
                                            cache_identifier));
 
   RESOURCE_LOADING_DVLOG(1) << "Loading Resource for "
                             << params.GetResourceRequest().Url().ElidedString();
 
   Resource* resource =
       factory.Create(params.GetResourceRequest(), params.Options(), charset);
   resource->SetLinkPreload(params.IsLinkPreload());
   if (params.IsSpeculativePreload()) {
     resource->SetPreloadDiscoveryTime(params.PreloadDiscoveryTime());
   }
   resource->SetCacheIdentifier(cache_identifier);
 
   // - Don't add main resource to cache to prevent reuse.
   // - Don't add the resource if its body will not be stored.
-  if (factory.GetType() != Resource::kMainResource &&
+  if (IsMainThread() && factory.GetType() != Resource::kMainResource &&
       params.Options().data_buffering_policy != kDoNotBufferData) {
     GetMemoryCache()->Add(resource);
   }
   return resource;
 }
 
 void ResourceFetcher::StorePerformanceTimingInitiatorInformation(
     Resource* resource) {
   const AtomicString& fetch_initiator = resource->Options().initiator_info.name;
   if (fetch_initiator == FetchInitiatorTypeNames::internal)
@@ skipping 488 matching lines @@
   ResourceRequest request(resource->GetResourceRequest());
   ResourceLoader* loader = nullptr;
 
   {
     // Forbids JavaScript/addClient/removeClient/revalidation until start()
     // to prevent unintended state transitions.
     Resource::ProhibitAddRemoveClientInScope
         prohibit_add_remove_client_in_scope(resource);
     Resource::RevalidationStartForbiddenScope
         revalidation_start_forbidden_scope(resource);
-    ScriptForbiddenScope script_forbidden_scope;
+    ScriptForbiddenIfMainThreadScope script_forbidden_scope;
 
-    if (!Context().ShouldLoadNewResource(resource->GetType())) {
+    if (!Context().ShouldLoadNewResource(resource->GetType()) &&
+        IsMainThread()) {
       GetMemoryCache()->Remove(resource);
       return false;
     }
 
     ResourceResponse response;
 
     blink::probe::PlatformSendRequest probe(&Context(), resource->Identifier(),
                                             request, response,
                                             resource->Options().initiator_info);
 
@@ skipping 266 matching lines @@
   visitor->Trace(context_);
   visitor->Trace(archive_);
   visitor->Trace(loaders_);
   visitor->Trace(non_blocking_loaders_);
   visitor->Trace(document_resources_);
   visitor->Trace(preloads_);
   visitor->Trace(resource_timing_info_map_);
 }
 
 }  // namespace blink