1 /*
2 * Copyright (C) 2010 Apple Inc. All rights reserved.
3 * Portions Copyright (c) 2010 Motorola Mobility, Inc. All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
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.
13 *
14 * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
15 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
16 * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
17 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
18 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
19 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
20 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
21 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
22 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
23 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
24 * THE POSSIBILITY OF SUCH DAMAGE.
25 */
26
27 #include "config.h"
28 #include "RunLoop.h"
29
30 #include "WKBase.h"
31 #include <glib.h>
32
RunLoop()33 RunLoop::RunLoop()
34 {
35 m_runLoopContext = g_main_context_default();
36 ASSERT(m_runLoopContext);
37 m_runLoopMain = g_main_loop_new(m_runLoopContext, FALSE);
38 ASSERT(m_runLoopMain);
39 }
40
~RunLoop()41 RunLoop::~RunLoop()
42 {
43 if (m_runLoopMain) {
44 if (g_main_loop_is_running(m_runLoopMain))
45 g_main_loop_quit(m_runLoopMain);
46 g_main_loop_unref(m_runLoopMain);
47 }
48
49 if (m_runLoopContext)
50 g_main_context_unref(m_runLoopContext);
51 }
52
run()53 void RunLoop::run()
54 {
55 g_main_loop_run(RunLoop::main()->mainLoop());
56 }
57
mainLoop()58 GMainLoop* RunLoop::mainLoop()
59 {
60 return m_runLoopMain;
61 }
62
stop()63 void RunLoop::stop()
64 {
65 g_main_loop_quit(m_runLoopMain);
66 }
67
queueWork(RunLoop * runLoop)68 gboolean RunLoop::queueWork(RunLoop* runLoop)
69 {
70 runLoop->performWork();
71 return FALSE;
72 }
73
wakeUp()74 void RunLoop::wakeUp()
75 {
76 GRefPtr<GSource> source = adoptGRef(g_idle_source_new());
77 g_source_set_priority(source.get(), G_PRIORITY_DEFAULT);
78 g_source_set_callback(source.get(), reinterpret_cast<GSourceFunc>(&RunLoop::queueWork), this, 0);
79 g_source_attach(source.get(), m_runLoopContext);
80
81 g_main_context_wakeup(m_runLoopContext);
82 }
83
TimerBase(RunLoop * runLoop)84 RunLoop::TimerBase::TimerBase(RunLoop* runLoop)
85 : m_runLoop(runLoop)
86 , m_timerSource(0)
87 {
88 }
89
~TimerBase()90 RunLoop::TimerBase::~TimerBase()
91 {
92 stop();
93 }
94
clearTimerSource()95 void RunLoop::TimerBase::clearTimerSource()
96 {
97 m_timerSource = 0;
98 }
99
destroyNotifyCallback(RunLoop::TimerBase * timer)100 void RunLoop::TimerBase::destroyNotifyCallback(RunLoop::TimerBase* timer)
101 {
102 timer->clearTimerSource();
103 }
104
timerFiredCallback(RunLoop::TimerBase * timer)105 gboolean RunLoop::TimerBase::timerFiredCallback(RunLoop::TimerBase* timer)
106 {
107 timer->fired();
108 return timer->isRepeating();
109 }
110
start(double fireInterval,bool repeat)111 void RunLoop::TimerBase::start(double fireInterval, bool repeat)
112 {
113 if (m_timerSource)
114 stop();
115
116 m_timerSource = adoptGRef(g_timeout_source_new(static_cast<guint>(fireInterval * 1000)));
117 m_isRepeating = repeat;
118 g_source_set_callback(m_timerSource.get(), reinterpret_cast<GSourceFunc>(&RunLoop::TimerBase::timerFiredCallback), this,
119 reinterpret_cast<GDestroyNotify>(&RunLoop::TimerBase::destroyNotifyCallback));
120 g_source_attach(m_timerSource.get(), m_runLoop->m_runLoopContext);
121 }
122
stop()123 void RunLoop::TimerBase::stop()
124 {
125 if (!m_timerSource)
126 return;
127
128 g_source_destroy(m_timerSource.get());
129 clearTimerSource();
130 }
131
isActive() const132 bool RunLoop::TimerBase::isActive() const
133 {
134 return m_timerSource;
135 }
136