Allow posting a Task to Microtasks

Source/core/dom/MutationObserver.cpp

 /*
  * Copyright (C) 2011 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 24 matching lines @@
 #include "bindings/v8/Dictionary.h"
 #include "bindings/v8/ExceptionState.h"
 #include "core/dom/Document.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/Microtask.h"
 #include "core/dom/MutationCallback.h"
 #include "core/dom/MutationObserverRegistration.h"
 #include "core/dom/MutationRecord.h"
 #include "core/dom/Node.h"
 #include "core/inspector/InspectorInstrumentation.h"
+#include "platform/Task.h"
 #include "wtf/MainThread.h"
 
 namespace WebCore {
 
 static unsigned s_observerPriority = 0;
 
 struct MutationObserver::ObserverLessThan {
     bool operator()(const RefPtr<MutationObserver>& lhs, const RefPtr<MutationObserver>& rhs)
     {
         return lhs->m_priority < rhs->m_priority;
@@ skipping 124 matching lines @@
 
 static MutationObserverSet& suspendedMutationObservers()
 {
     DEFINE_STATIC_LOCAL(MutationObserverSet, suspendedObservers, ());
     return suspendedObservers;
 }
 
 static void activateObserver(PassRefPtr<MutationObserver> observer)
 {
     if (activeMutationObservers().isEmpty())
-        Microtask::enqueueMicrotask(&MutationObserver::deliverMutations);
+        Microtask::enqueueMicrotask(new Task(WTF::bind(&MutationObserver::deliverMutations)));

[abarth-chromium, 2014/04/18 16:01:04]

Maybe Microtask::enqueueMicrotask should have an overload that takes a
WTF::Closure and wraps it in a Task for you?

 
     activeMutationObservers().add(observer);
 }
 
 void MutationObserver::enqueueMutationRecord(PassRefPtr<MutationRecord> mutation)
 {
     ASSERT(isMainThread());
     m_records.append(mutation);
     activateObserver(this);
     InspectorInstrumentation::didEnqueueMutationRecord(m_callback->executionContext(), this);
@@ skipping 68 matching lines @@
     std::sort(observers.begin(), observers.end(), ObserverLessThan());
     for (size_t i = 0; i < observers.size(); ++i) {
         if (observers[i]->canDeliver())
             observers[i]->deliver();
         else
             suspendedMutationObservers().add(observers[i]);
     }
 }
 
 } // namespace WebCore