Remove MainThreadTaskRunner

third_party/WebKit/Source/core/dom/Document.cpp

 /*
  * Copyright (C) 1999 Lars Knoll (knoll@kde.org)
  *           (C) 1999 Antti Koivisto (koivisto@kde.org)
  *           (C) 2001 Dirk Mueller (mueller@kde.org)
  *           (C) 2006 Alexey Proskuryakov (ap@webkit.org)
  * Copyright (C) 2004, 2005, 2006, 2007, 2008, 2009, 2011, 2012 Apple Inc. All
  * rights reserved.
  * Copyright (C) 2008, 2009 Torch Mobile Inc. All rights reserved.
  * (http://www.torchmobile.com/)
  * Copyright (C) 2008, 2009, 2011, 2012 Google Inc. All rights reserved.
@@ skipping 70 matching lines @@
 #include "core/dom/ElementCreationOptions.h"
 #include "core/dom/ElementDataCache.h"
 #include "core/dom/ElementRegistrationOptions.h"
 #include "core/dom/ElementTraversal.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContextTask.h"
 #include "core/dom/FrameRequestCallback.h"
 #include "core/dom/IntersectionObserverController.h"
 #include "core/dom/LayoutTreeBuilderTraversal.h"
 #include "core/dom/LiveNodeList.h"
-#include "core/dom/MainThreadTaskRunner.h"
 #include "core/dom/MutationObserver.h"
 #include "core/dom/NodeChildRemovalTracker.h"
 #include "core/dom/NodeComputedStyle.h"
 #include "core/dom/NodeFilter.h"
 #include "core/dom/NodeIntersectionObserverData.h"
 #include "core/dom/NodeIterator.h"
 #include "core/dom/NodeRareData.h"
 #include "core/dom/NodeTraversal.h"
 #include "core/dom/NodeWithIndex.h"
 #include "core/dom/NthIndexCache.h"
@@ skipping 365 matching lines @@
       m_loadEventDelayCount(0),
       m_loadEventDelayTimer(TaskRunnerHelper::get(TaskType::Networking, this),
                             this,
                             &Document::loadEventDelayTimerFired),
       m_pluginLoadingTimer(TaskRunnerHelper::get(TaskType::Internal, this),
                            this,
                            &Document::pluginLoadingTimerFired),
       m_documentTiming(*this),
       m_writeRecursionIsTooDeep(false),
       m_writeRecursionDepth(0),
-      m_taskRunner(MainThreadTaskRunner::create(this)),
       m_registrationContext(initializer.registrationContext(this)),
       m_elementDataCacheClearTimer(
           TaskRunnerHelper::get(TaskType::Internal, this),
           this,
           &Document::elementDataCacheClearTimerFired),
       m_timeline(DocumentTimeline::create(this)),
       m_compositorPendingAnimations(new CompositorPendingAnimations()),
       m_templateDocumentHost(nullptr),
       m_didAssociateFormControlsTimer(
           TaskRunnerHelper::get(TaskType::Internal, this),
@@ skipping 3869 matching lines @@
   mojom::blink::SensitiveInputVisibilityServicePtr sensitiveInputServicePtr;
   frame()->interfaceProvider()->getInterface(
       mojo::GetProxy(&sensitiveInputServicePtr));
   if (m_passwordCount > 0) {
     sensitiveInputServicePtr->PasswordFieldVisibleInInsecureContext();
     return;
   }
   sensitiveInputServicePtr->AllPasswordFieldsInInsecureContextInvisible();
 }
 
+void Document::runExecutionContextTask(
+    std::unique_ptr<ExecutionContextTask> task,
+    bool isInstrumented) {
+  InspectorInstrumentation::AsyncTask asyncTask(this, task.get(),
+                                                isInstrumented);
+  task->performTask(this);
+}
+
 void Document::registerEventFactory(
     std::unique_ptr<EventFactoryBase> eventFactory) {
   DCHECK(!eventFactories().contains(eventFactory.get()));
   eventFactories().add(std::move(eventFactory));
 }
 
 Event* Document::createEvent(ExecutionContext* executionContext,
                              const String& eventType,
                              ExceptionState& exceptionState) {
   Event* event = nullptr;
@@ skipping 1337 matching lines @@
 
 static void runAddConsoleMessageTask(MessageSource source,
                                      MessageLevel level,
                                      const String& message,
                                      ExecutionContext* context) {
   context->addConsoleMessage(ConsoleMessage::create(source, level, message));
 }
 
 void Document::addConsoleMessage(ConsoleMessage* consoleMessage) {
   if (!isContextThread()) {
-    m_taskRunner->postTask(
-        BLINK_FROM_HERE,
-        createCrossThreadTask(&runAddConsoleMessageTask,
-                              consoleMessage->source(), consoleMessage->level(),
-                              consoleMessage->message()));
+    postTask(BLINK_FROM_HERE, createCrossThreadTask(&runAddConsoleMessageTask,
+                                                    consoleMessage->source(),
+                                                    consoleMessage->level(),
+                                                    consoleMessage->message()));
     return;
   }
 
   if (!m_frame)
     return;
 
   if (consoleMessage->location()->isUnknown()) {
     // TODO(dgozman): capture correct location at call places instead.
     unsigned lineNumber = 0;
     if (!isInDocumentWrite() && scriptableDocumentParser()) {
       ScriptableDocumentParser* parser = scriptableDocumentParser();
       if (parser->isParsingAtLineNumber())
         lineNumber = parser->lineNumber().oneBasedInt();
     }
     consoleMessage = ConsoleMessage::create(
         consoleMessage->source(), consoleMessage->level(),
         consoleMessage->message(),
         SourceLocation::create(url().getString(), lineNumber, 0, nullptr));
   }
   m_frame->console().addMessage(consoleMessage);
 }
 
-void Document::postTask(TaskType,
+void Document::postTask(TaskType taskType,
                         const WebTraceLocation& location,
                         std::unique_ptr<ExecutionContextTask> task,
                         const String& taskNameForInstrumentation) {
-  m_taskRunner->postTask(location, std::move(task), taskNameForInstrumentation);
+  if (!taskNameForInstrumentation.isEmpty()) {
+    InspectorInstrumentation::asyncTaskScheduled(
+        this, taskNameForInstrumentation, task.get());
+  }
+
+  TaskRunnerHelper::get(taskType, this)
+      ->postTask(location,
+                 crossThreadBind(&Document::runExecutionContextTask,
+                                 wrapCrossThreadWeakPersistent(this),
+                                 WTF::passed(std::move(task)),
+                                 !taskNameForInstrumentation.isEmpty()));
 }
 
 void Document::tasksWereSuspended() {
   scriptRunner()->suspend();
 
   if (m_parser)
     m_parser->suspendScheduledTasks();
   if (m_scriptedAnimationController)
     m_scriptedAnimationController->suspend();
 }
@@ skipping 513 matching lines @@
 void Document::setAutofocusElement(Element* element) {
   if (!element) {
     m_autofocusElement = nullptr;
     return;
   }
   if (m_hasAutofocused)
     return;
   m_hasAutofocused = true;
   DCHECK(!m_autofocusElement);
   m_autofocusElement = element;
-  m_taskRunner->postTask(BLINK_FROM_HERE,
-                         createSameThreadTask(&runAutofocusTask));
+  postTask(BLINK_FROM_HERE, createSameThreadTask(&runAutofocusTask));
 }
 
 Element* Document::activeElement() const {
   if (Element* element = adjustedFocusedElement())
     return element;
   return body();
 }
 
 bool Document::hasFocus() const {
   return page() && page()->focusController().isDocumentFocused(*this);
@@ skipping 262 matching lines @@
 }
 
 void showLiveDocumentInstances() {
   WeakDocumentSet& set = liveDocumentSet();
   fprintf(stderr, "There are %u documents currently alive:\n", set.size());
   for (Document* document : set)
     fprintf(stderr, "- Document %p URL: %s\n", document,
             document->url().getString().utf8().data());
 }
 #endif