#include "config.h"
#include "RunLoop.h"
#include <Ecore.h>
static const int ecorePipeMessageSize = 1;
static const char wakupEcorePipeMessage[] = "W";
namespace WTF {
RunLoop::RunLoop()
: m_wakeUpEventRequested(false)
{
m_pipe = EflUniquePtr<Ecore_Pipe>(ecore_pipe_add(wakeUpEvent, this));
}
RunLoop::~RunLoop()
{
}
void RunLoop::run()
{
ecore_main_loop_begin();
}
void RunLoop::stop()
{
ecore_main_loop_quit();
}
void RunLoop::wakeUpEvent(void* data, void*, unsigned)
{
RunLoop* loop = static_cast<RunLoop*>(data);
{
MutexLocker locker(loop->m_wakeUpEventRequestedLock);
loop->m_wakeUpEventRequested = false;
}
loop->performWork();
}
void RunLoop::wakeUp()
{
{
MutexLocker locker(m_wakeUpEventRequestedLock);
if (m_wakeUpEventRequested)
return;
m_wakeUpEventRequested = true;
}
{
MutexLocker locker(m_pipeLock);
ecore_pipe_write(m_pipe.get(), wakupEcorePipeMessage, ecorePipeMessageSize);
}
}
RunLoop::TimerBase::TimerBase(RunLoop& runLoop)
: m_runLoop(runLoop)
, m_timer(0)
, m_isRepeating(false)
{
}
RunLoop::TimerBase::~TimerBase()
{
stop();
}
bool RunLoop::TimerBase::timerFired(void* data)
{
RunLoop::TimerBase* timer = static_cast<RunLoop::TimerBase*>(data);
if (!timer->m_isRepeating)
timer->m_timer = 0;
timer->fired();
return timer->m_isRepeating ? ECORE_CALLBACK_RENEW : ECORE_CALLBACK_CANCEL;
}
void RunLoop::TimerBase::start(double nextFireInterval, bool repeat)
{
if (isActive())
stop();
m_isRepeating = repeat;
ASSERT(!m_timer);
m_timer = ecore_timer_add(nextFireInterval, reinterpret_cast<Ecore_Task_Cb>(timerFired), this);
}
void RunLoop::TimerBase::stop()
{
if (m_timer) {
ecore_timer_del(m_timer);
m_timer = 0;
}
}
bool RunLoop::TimerBase::isActive() const
{
return (m_timer) ? true : false;
}
}