#include "config.h"
#include "RunLoop.h"
#include <CoreFoundation/CoreFoundation.h>
#include <dispatch/dispatch.h>
#include <wtf/AutodrainedPool.h>
namespace WebCore {
void RunLoop::performWork(void* context)
{
AutodrainedPool pool;
static_cast<RunLoop*>(context)->performWork();
}
RunLoop::RunLoop()
: m_runLoop(CFRunLoopGetCurrent())
, m_nestingLevel(0)
{
CFRunLoopSourceContext context = { 0, this, 0, 0, 0, 0, 0, 0, 0, performWork };
m_runLoopSource = adoptCF(CFRunLoopSourceCreate(kCFAllocatorDefault, 0, &context));
CFRunLoopAddSource(m_runLoop.get(), m_runLoopSource.get(), kCFRunLoopCommonModes);
}
RunLoop::~RunLoop()
{
CFRunLoopSourceInvalidate(m_runLoopSource.get());
}
void RunLoop::runForDuration(double duration)
{
CFRunLoopRunInMode(kCFRunLoopDefaultMode, duration, true);
}
void RunLoop::wakeUp()
{
CFRunLoopSourceSignal(m_runLoopSource.get());
CFRunLoopWakeUp(m_runLoop.get());
}
#if !PLATFORM(MAC) || PLATFORM(IOS)
void RunLoop::run()
{
current()->m_nestingLevel++;
{
AutodrainedPool pool;
CFRunLoopRun();
}
current()->m_nestingLevel--;
}
void RunLoop::stop()
{
ASSERT(m_runLoop == CFRunLoopGetCurrent());
CFRunLoopStop(m_runLoop.get());
}
#endif
void RunLoop::TimerBase::timerFired(CFRunLoopTimerRef, void* context)
{
TimerBase* timer = static_cast<TimerBase*>(context);
AutodrainedPool pool;
timer->fired();
}
RunLoop::TimerBase::TimerBase(RunLoop* runLoop)
: m_runLoop(runLoop)
{
}
RunLoop::TimerBase::~TimerBase()
{
stop();
}
void RunLoop::TimerBase::start(double nextFireInterval, bool repeat)
{
if (m_timer)
stop();
CFRunLoopTimerContext context = { 0, this, 0, 0, 0 };
CFTimeInterval repeatInterval = repeat ? nextFireInterval : 0;
m_timer = adoptCF(CFRunLoopTimerCreate(kCFAllocatorDefault, CFAbsoluteTimeGetCurrent() + nextFireInterval, repeatInterval, 0, 0, timerFired, &context));
CFRunLoopAddTimer(m_runLoop->m_runLoop.get(), m_timer.get(), kCFRunLoopCommonModes);
}
void RunLoop::TimerBase::stop()
{
if (!m_timer)
return;
CFRunLoopTimerInvalidate(m_timer.get());
m_timer = nullptr;
}
bool RunLoop::TimerBase::isActive() const
{
return m_timer && CFRunLoopTimerIsValid(m_timer.get());
}
}