Introduce WebTaskRunner Patch 3/5

Source/web/WebKit.cpp

 /*
  * Copyright (C) 2009 Google Inc. All rights reserved.
  *
  * 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.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 63 matching lines @@
         AnimationClock::notifyTaskStart();
     }
     void didProcessTask() override
     {
         Microtask::performCheckpoint(mainThreadIsolate());
         V8GCController::reportDOMMemoryUsageToV8(mainThreadIsolate());
         V8Initializer::reportRejectedPromisesOnMainThread();
     }
 };
 
-class MainThreadTaskRunner: public WebThread::Task {
+class MainThreadTaskRunner: public WebTaskRunner::Task {
     WTF_MAKE_NONCOPYABLE(MainThreadTaskRunner);
 public:
     MainThreadTaskRunner(WTF::MainThreadFunction* function, void* context)
         : m_function(function)
         , m_context(context) { }
 
     void run() override
     {
         m_function(m_context);
     }
@@ skipping 54 matching lines @@
     Platform::current()->histogramEnumeration(name, sample, boundaryValue);
 }
 
 static void cryptographicallyRandomValues(unsigned char* buffer, size_t length)
 {
     Platform::current()->cryptographicallyRandomValues(buffer, length);
 }
 
 static void callOnMainThreadFunction(WTF::MainThreadFunction function, void* context)
 {
-    Platform::current()->mainThread()->postTask(FROM_HERE, new MainThreadTaskRunner(function, context));
+    Platform::current()->mainThread()->taskRunner()->postTask(FROM_HERE, new MainThreadTaskRunner(function, context));
 }
 
 static void adjustAmountOfExternalAllocatedMemory(int size)
 {
     v8::Isolate::GetCurrent()->AdjustAmountOfExternalAllocatedMemory(size);
 }
 
 void initializeWithoutV8(Platform* platform)
 {
     ASSERT(!s_webKitInitialized);
     s_webKitInitialized = true;
 
     ASSERT(platform);
     Platform::initialize(platform);
 
     WTF::setRandomSource(cryptographicallyRandomValues);
     WTF::initialize(currentTimeFunction, monotonicallyIncreasingTimeFunction, systemTraceTimeFunction, histogramEnumerationFunction, adjustAmountOfExternalAllocatedMemory);
     WTF::initializeMainThread(callOnMainThreadFunction);
     Heap::init();
 
     ThreadState::attachMainThread();
     // currentThread() is null if we are running on a thread without a message loop.
     if (WebThread* currentThread = platform->currentThread()) {
         ASSERT(!s_pendingGCRunner);
         s_pendingGCRunner = new PendingGCRunner;
         currentThread->addTaskObserver(s_pendingGCRunner);
 
-        OwnPtr<MessageLoopInterruptor> interruptor = adoptPtr(new MessageLoopInterruptor(currentThread));
+        OwnPtr<MessageLoopInterruptor> interruptor = adoptPtr(new MessageLoopInterruptor(currentThread->taskRunner()));
         ThreadState::current()->addInterruptor(interruptor.release());
     }
 
     DEFINE_STATIC_LOCAL(ModulesInitializer, initializer, ());
     initializer.init();
 
     setIndexedDBClientCreateFunction(IndexedDBClientImpl::create);
 }
 
 void shutdown()
@@ skipping 81 matching lines @@
     ASSERT(!reloadPages);
     Page::refreshPlugins();
 }
 
 void decommitFreeableMemory()
 {
     WTF::Partitions::decommitFreeableMemory();
 }
 
 } // namespace blink