#include "config.h"
#include "RunLoop.h"
#include "WorkItem.h"
#include "WKBase.h"
#include <glib.h>
RunLoop::RunLoop()
{
m_runLoopContext = g_main_context_default();
ASSERT(m_runLoopContext);
m_runLoopMain = g_main_loop_new(m_runLoopContext, FALSE);
ASSERT(m_runLoopMain);
}
RunLoop::~RunLoop()
{
if (m_runLoopMain) {
if (g_main_loop_is_running(m_runLoopMain))
g_main_loop_quit(m_runLoopMain);
g_main_loop_unref(m_runLoopMain);
}
if (m_runLoopContext)
g_main_context_unref(m_runLoopContext);
}
void RunLoop::run()
{
g_main_loop_run(RunLoop::main()->mainLoop());
}
GMainLoop* RunLoop::mainLoop()
{
return m_runLoopMain;
}
void RunLoop::stop()
{
g_main_loop_quit(m_runLoopMain);
}
gboolean RunLoop::queueWork(RunLoop* runLoop)
{
runLoop->performWork();
return FALSE;
}
void RunLoop::wakeUp()
{
GRefPtr<GSource> source = adoptGRef(g_idle_source_new());
g_source_set_priority(source.get(), G_PRIORITY_DEFAULT);
g_source_set_callback(source.get(), reinterpret_cast<GSourceFunc>(&RunLoop::queueWork), this, 0);
g_source_attach(source.get(), m_runLoopContext);
g_main_context_wakeup(m_runLoopContext);
}
RunLoop::TimerBase::TimerBase(RunLoop* runLoop)
: m_runLoop(runLoop)
, m_timerSource(0)
{
}
RunLoop::TimerBase::~TimerBase()
{
stop();
}
void RunLoop::TimerBase::clearTimerSource()
{
m_timerSource = 0;
}
void RunLoop::TimerBase::destroyNotifyCallback(RunLoop::TimerBase* timer)
{
timer->clearTimerSource();
}
gboolean RunLoop::TimerBase::timerFiredCallback(RunLoop::TimerBase* timer)
{
timer->fired();
return timer->isRepeating();
}
void RunLoop::TimerBase::start(double fireInterval, bool repeat)
{
if (m_timerSource)
stop();
m_timerSource = adoptGRef(g_timeout_source_new(static_cast<guint>(fireInterval * 1000)));
m_isRepeating = repeat;
g_source_set_callback(m_timerSource.get(), reinterpret_cast<GSourceFunc>(&RunLoop::TimerBase::timerFiredCallback), this,
reinterpret_cast<GDestroyNotify>(&RunLoop::TimerBase::destroyNotifyCallback));
g_source_attach(m_timerSource.get(), m_runLoop->m_runLoopContext);
}
void RunLoop::TimerBase::stop()
{
if (!m_timerSource)
return;
g_source_destroy(m_timerSource.get());
clearTimerSource();
}
bool RunLoop::TimerBase::isActive() const
{
return m_timerSource;
}