2 * Copyright (C) 2012 ProFUSION embedded systems. All rights reserved.
3 * Copyright (C) 2012 Samsung Electronics
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
14 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
15 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
16 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
17 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
18 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
19 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
20 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
21 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
22 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
23 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
24 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
31 #include <wtf/OwnPtr.h>
32 #include <wtf/PassOwnPtr.h>
34 static const int ecorePipeMessageSize = 1;
35 static const char wakupEcorePipeMessage[] = "W";
40 : m_wakeUpEventRequested(false)
42 m_pipe = EflUniquePtr<Ecore_Pipe>(ecore_pipe_add(wakeUpEvent, this));
51 ecore_main_loop_begin();
56 ecore_main_loop_quit();
59 void RunLoop::wakeUpEvent(void* data, void*, unsigned)
61 RunLoop* loop = static_cast<RunLoop*>(data);
64 MutexLocker locker(loop->m_wakeUpEventRequestedLock);
65 loop->m_wakeUpEventRequested = false;
71 void RunLoop::wakeUp()
74 MutexLocker locker(m_wakeUpEventRequestedLock);
75 if (m_wakeUpEventRequested)
77 m_wakeUpEventRequested = true;
81 MutexLocker locker(m_pipeLock);
82 ecore_pipe_write(m_pipe.get(), wakupEcorePipeMessage, ecorePipeMessageSize);
86 RunLoop::TimerBase::TimerBase(RunLoop& runLoop)
89 , m_isRepeating(false)
93 RunLoop::TimerBase::~TimerBase()
98 bool RunLoop::TimerBase::timerFired(void* data)
100 RunLoop::TimerBase* timer = static_cast<RunLoop::TimerBase*>(data);
102 if (!timer->m_isRepeating)
107 return timer->m_isRepeating ? ECORE_CALLBACK_RENEW : ECORE_CALLBACK_CANCEL;
110 void RunLoop::TimerBase::start(double nextFireInterval, bool repeat)
115 m_isRepeating = repeat;
117 m_timer = ecore_timer_add(nextFireInterval, reinterpret_cast<Ecore_Task_Cb>(timerFired), this);
120 void RunLoop::TimerBase::stop()
123 ecore_timer_del(m_timer);
128 bool RunLoop::TimerBase::isActive() const
130 return (m_timer) ? true : false;