(WIP) Worker: Merge ParentFrameTaskRunners into TaskRunnerHelper

third_party/WebKit/Source/core/workers/DedicatedWorkerTest.cpp

 // Copyright 2016 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/events/MessageEvent.h"
 #include "core/inspector/ConsoleMessageStorage.h"
 #include "core/testing/DummyPageHolder.h"
 #include "core/workers/DedicatedWorkerGlobalScope.h"
 #include "core/workers/DedicatedWorkerThread.h"
 #include "core/workers/InProcessWorkerMessagingProxy.h"
@@ skipping 40 matching lines @@
     return new DedicatedWorkerGlobalScope(
         startupData->m_scriptURL, startupData->m_userAgent, this, m_timeOrigin,
         std::move(startupData->m_starterOriginPrivilegeData),
         std::move(startupData->m_workerClients));
   }
 
   // Emulates API use on DedicatedWorkerGlobalScope.
   void countFeature(UseCounter::Feature feature) {
     EXPECT_TRUE(isCurrentThread());
     globalScope()->countFeature(feature);
-    getParentFrameTaskRunners()
-        ->get(TaskType::UnspecedTimer)
+    FrameTaskRunnerHelper::get(TaskType::UnspecedTimer, globalScope())
         ->postTask(BLINK_FROM_HERE, crossThreadBind(&testing::exitRunLoop));
   }
 
   // Emulates deprecated API use on DedicatedWorkerGlobalScope.
   void countDeprecation(UseCounter::Feature feature) {
     EXPECT_TRUE(isCurrentThread());
     EXPECT_EQ(0u, consoleMessageStorage()->size());
     globalScope()->countDeprecation(feature);
 
     // countDeprecation() should add a warning message.
     EXPECT_EQ(1u, consoleMessageStorage()->size());
     String consoleMessage = consoleMessageStorage()->at(0)->message();
     EXPECT_TRUE(consoleMessage.contains("deprecated"));
 
-    getParentFrameTaskRunners()
-        ->get(TaskType::UnspecedTimer)
+    FrameTaskRunnerHelper::get(TaskType::UnspecedTimer, globalScope())
         ->postTask(BLINK_FROM_HERE, crossThreadBind(&testing::exitRunLoop));
   }
 };
 
 class InProcessWorkerMessagingProxyForTest
     : public InProcessWorkerMessagingProxy {
  public:
   InProcessWorkerMessagingProxyForTest(ExecutionContext* executionContext)
       : InProcessWorkerMessagingProxy(executionContext,
                                       nullptr /* workerObject */,
@@ skipping 28 matching lines @@
                                    ContentSecurityPolicyHeaderTypeReport);
     headers->push_back(headerAndType);
     workerThread()->start(
         WorkerThreadStartupData::create(
             scriptURL, "fake user agent", source, nullptr /* cachedMetaData */,
             DontPauseWorkerGlobalScopeOnStart, headers.get(),
             "" /* referrerPolicy */, m_securityOrigin.get(),
             nullptr /* workerClients */, WebAddressSpaceLocal,
             nullptr /* originTrialTokens */, nullptr /* workerSettings */,
             WorkerV8Settings::Default()),
-        getParentFrameTaskRunners());
+        FrameTaskRunnersHolder::create(
+            toDocument(getExecutionContext())->frame()));
 
     workerInspectorProxy()->workerThreadCreated(
         toDocument(getExecutionContext()), m_workerThread.get(), scriptURL);
     workerThreadCreated();
   }
 
   enum class Notification {
     MessageConfirmed,
     PendingActivityReported,
     ThreadTerminated,
@@ skipping 261 matching lines @@
   EXPECT_FALSE(UseCounter::isCounted(document(), feature2));
   workerThread()->postTask(
       BLINK_FROM_HERE,
       crossThreadBind(&DedicatedWorkerThreadForTest::countDeprecation,
                       crossThreadUnretained(workerThread()), feature2));
   testing::enterRunLoop();
   EXPECT_TRUE(UseCounter::isCounted(document(), feature2));
 }
 
 }  // namespace blink