(WIP) Worker: Merge ParentFrameTaskRunners into TaskRunnerHelper

third_party/WebKit/Source/modules/compositorworker/CompositorWorkerThreadTest.cpp

 // Copyright 2015 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 "modules/compositorworker/CompositorWorkerThread.h"
 
 #include "bindings/core/v8/ScriptSourceCode.h"
 #include "bindings/core/v8/SourceLocation.h"
 #include "bindings/core/v8/V8GCController.h"
 #include "bindings/core/v8/WorkerOrWorkletScriptController.h"
 #include "core/dom/CompositorWorkerProxyClient.h"
 #include "core/inspector/ConsoleMessage.h"
 #include "core/workers/InProcessWorkerObjectProxy.h"
-#include "core/workers/ParentFrameTaskRunners.h"
 #include "core/workers/WorkerBackingThread.h"
 #include "core/workers/WorkerLoaderProxy.h"
 #include "core/workers/WorkerOrWorkletGlobalScope.h"
 #include "core/workers/WorkerThreadStartupData.h"
 #include "platform/CrossThreadFunctional.h"
 #include "platform/WaitableEvent.h"
 #include "platform/WebThreadSupportingGC.h"
 #include "platform/heap/Handle.h"
 #include "platform/testing/TestingPlatformSupport.h"
 #include "platform/testing/UnitTestHelpers.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebAddressSpace.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include "wtf/PtrUtil.h"
 #include <memory>
 
 namespace blink {
 namespace {
 
 // A null InProcessWorkerObjectProxy, supplied when creating
 // CompositorWorkerThreads.
 class TestCompositorWorkerObjectProxy : public InProcessWorkerObjectProxy {
  public:
-  static std::unique_ptr<TestCompositorWorkerObjectProxy> create(
-      ParentFrameTaskRunners* parentFrameTaskRunners) {
-    return WTF::wrapUnique(
-        new TestCompositorWorkerObjectProxy(parentFrameTaskRunners));
+  static std::unique_ptr<TestCompositorWorkerObjectProxy> create() {
+    return WTF::wrapUnique(new TestCompositorWorkerObjectProxy);
   }
 
   // (Empty) WorkerReportingProxy implementation:
   virtual void dispatchErrorEvent(const String& errorMessage,
                                   std::unique_ptr<SourceLocation>,
                                   int exceptionId) {}
   void reportConsoleMessage(MessageSource,
                             MessageLevel,
                             const String& message,
                             SourceLocation*) override {}
   void postMessageToPageInspector(const String&) override {}
   void didCreateWorkerGlobalScope(WorkerOrWorkletGlobalScope*) override {}
   void didEvaluateWorkerScript(bool success) override {}
   void didCloseWorkerGlobalScope() override {}
   void willDestroyWorkerGlobalScope() override {}
   void didTerminateWorkerThread() override {}
 
  private:
-  explicit TestCompositorWorkerObjectProxy(
-      ParentFrameTaskRunners* parentFrameTaskRunners)
-      : InProcessWorkerObjectProxy(nullptr, parentFrameTaskRunners) {}
+  TestCompositorWorkerObjectProxy() : InProcessWorkerObjectProxy(nullptr) {}
 };
 
 class TestCompositorWorkerProxyClient : public CompositorWorkerProxyClient {
  public:
   TestCompositorWorkerProxyClient() {}
 
   void dispose() override {}
   void setGlobalScope(WorkerGlobalScope*) override {}
   void requestAnimationFrame() override {}
   void registerCompositorProxy(CompositorProxy*) override {}
@@ skipping 15 matching lines @@
   std::unique_ptr<WebThread> m_thread;
   TestingCompositorSupport m_compositorSupport;
 };
 
 }  // namespace
 
 class CompositorWorkerThreadTest : public ::testing::Test {
  public:
   void SetUp() override {
     CompositorWorkerThread::createSharedBackingThreadForTest();
-    m_parentFrameTaskRunners = ParentFrameTaskRunners::create(nullptr);
-    m_objectProxy =
-        TestCompositorWorkerObjectProxy::create(m_parentFrameTaskRunners.get());
+    m_objectProxy = TestCompositorWorkerObjectProxy::create();
     m_securityOrigin =
         SecurityOrigin::create(KURL(ParsedURLString, "http://fake.url/"));
   }
 
   void TearDown() override {
     CompositorWorkerThread::clearSharedBackingThread();
   }
 
   std::unique_ptr<CompositorWorkerThread> createCompositorWorker() {
     std::unique_ptr<CompositorWorkerThread> workerThread =
         CompositorWorkerThread::create(nullptr, *m_objectProxy, 0);
     WorkerClients* clients = WorkerClients::create();
     provideCompositorWorkerProxyClientTo(clients,
                                          new TestCompositorWorkerProxyClient);
     workerThread->start(
         WorkerThreadStartupData::create(
             KURL(ParsedURLString, "http://fake.url/"), "fake user agent",
             "//fake source code", nullptr, DontPauseWorkerGlobalScopeOnStart,
             nullptr, "", m_securityOrigin.get(), clients, WebAddressSpaceLocal,
             nullptr, nullptr, WorkerV8Settings::Default()),
-        m_parentFrameTaskRunners.get());
+        FrameTaskRunnersHolder::create(nullptr));
     return workerThread;
   }
 
   // Attempts to run some simple script for |worker|.
   void checkWorkerCanExecuteScript(WorkerThread* worker) {
     std::unique_ptr<WaitableEvent> waitEvent = WTF::makeUnique<WaitableEvent>();
     worker->workerBackingThread().backingThread().postTask(
         BLINK_FROM_HERE,
         crossThreadBind(&CompositorWorkerThreadTest::executeScriptInWorker,
                         crossThreadUnretained(this),
                         crossThreadUnretained(worker),
                         crossThreadUnretained(waitEvent.get())));
     waitEvent->wait();
   }
 
  private:
   void executeScriptInWorker(WorkerThread* worker, WaitableEvent* waitEvent) {
     WorkerOrWorkletScriptController* scriptController =
         worker->globalScope()->scriptController();
     bool evaluateResult = scriptController->evaluate(
         ScriptSourceCode("var counter = 0; ++counter;"));
     DCHECK(evaluateResult);
     waitEvent->signal();
   }
 
   RefPtr<SecurityOrigin> m_securityOrigin;
   std::unique_ptr<InProcessWorkerObjectProxy> m_objectProxy;
-  Persistent<ParentFrameTaskRunners> m_parentFrameTaskRunners;
   ScopedTestingPlatformSupport<CompositorWorkerTestPlatform> m_platform;
 };
 
 TEST_F(CompositorWorkerThreadTest, Basic) {
   std::unique_ptr<CompositorWorkerThread> compositorWorker =
       createCompositorWorker();
   checkWorkerCanExecuteScript(compositorWorker.get());
   compositorWorker->terminateAndWait();
 }
 
@@ skipping 79 matching lines @@
   ASSERT_TRUE(secondIsolate);
   EXPECT_EQ(firstIsolate, secondIsolate);
 
   // Verify that the isolate can run some scripts correctly in the second
   // worker.
   checkWorkerCanExecuteScript(secondWorker.get());
   secondWorker->terminateAndWait();
 }
 
 }  // namespace blink