This source file includes following definitions.
- m_phase
- instance
- enqueue
- enqueue
- importDidFinish
- ensureMicrotaskScheduled
- dispatch
- doDispatch
#include "config.h"
#include "core/dom/custom/CustomElementMicrotaskDispatcher.h"
#include "core/dom/Microtask.h"
#include "core/dom/custom/CustomElementCallbackDispatcher.h"
#include "core/dom/custom/CustomElementCallbackQueue.h"
#include "core/dom/custom/CustomElementMicrotaskImportStep.h"
#include "core/dom/custom/CustomElementScheduler.h"
#include "core/html/imports/HTMLImport.h"
#include "wtf/MainThread.h"
namespace WebCore {
static const CustomElementCallbackQueue::ElementQueueId kMicrotaskQueueId = 0;
CustomElementMicrotaskDispatcher::CustomElementMicrotaskDispatcher()
: m_hasScheduledMicrotask(false)
, m_phase(Quiescent)
{
}
CustomElementMicrotaskDispatcher& CustomElementMicrotaskDispatcher::instance()
{
DEFINE_STATIC_LOCAL(CustomElementMicrotaskDispatcher, instance, ());
return instance;
}
void CustomElementMicrotaskDispatcher::enqueue(HTMLImport* import, PassOwnPtr<CustomElementMicrotaskStep> step)
{
ASSERT(m_phase == Quiescent || m_phase == DispatchingCallbacks);
ensureMicrotaskScheduled();
if (import && import->customElementMicrotaskStep())
import->customElementMicrotaskStep()->enqueue(step);
else
m_resolutionAndImports.enqueue(step);
}
void CustomElementMicrotaskDispatcher::enqueue(CustomElementCallbackQueue* queue)
{
ASSERT(m_phase == Quiescent || m_phase == Resolving);
ensureMicrotaskScheduled();
queue->setOwner(kMicrotaskQueueId);
m_elements.append(queue);
}
void CustomElementMicrotaskDispatcher::importDidFinish(CustomElementMicrotaskImportStep* step)
{
ASSERT(m_phase == Quiescent || m_phase == DispatchingCallbacks);
ensureMicrotaskScheduled();
}
void CustomElementMicrotaskDispatcher::ensureMicrotaskScheduled()
{
if (!m_hasScheduledMicrotask) {
Microtask::enqueueMicrotask(&dispatch);
m_hasScheduledMicrotask = true;
}
}
void CustomElementMicrotaskDispatcher::dispatch()
{
instance().doDispatch();
}
void CustomElementMicrotaskDispatcher::doDispatch()
{
ASSERT(isMainThread());
ASSERT(m_phase == Quiescent && m_hasScheduledMicrotask);
m_hasScheduledMicrotask = false;
ASSERT_WITH_SECURITY_IMPLICATION(!CustomElementCallbackDispatcher::inCallbackDeliveryScope());
m_phase = Resolving;
m_resolutionAndImports.dispatch();
m_phase = DispatchingCallbacks;
for (Vector<CustomElementCallbackQueue*>::iterator it = m_elements.begin();it != m_elements.end(); ++it) {
CustomElementCallbackDispatcher::CallbackDeliveryScope scope;
(*it)->processInElementQueue(kMicrotaskQueueId);
}
m_elements.clear();
CustomElementScheduler::microtaskDispatcherDidFinish();
m_phase = Quiescent;
}
}