OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2009 Google Inc. All rights reserved. | 2 * Copyright (C) 2009 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
6 * met: | 6 * met: |
7 * | 7 * |
8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
(...skipping 18 matching lines...) Expand all Loading... |
29 */ | 29 */ |
30 | 30 |
31 #include "config.h" | 31 #include "config.h" |
32 #include "core/workers/WorkerRunLoop.h" | 32 #include "core/workers/WorkerRunLoop.h" |
33 | 33 |
34 #include "bindings/v8/WorkerScriptController.h" | 34 #include "bindings/v8/WorkerScriptController.h" |
35 #include "core/dom/ScriptExecutionContext.h" | 35 #include "core/dom/ScriptExecutionContext.h" |
36 #include "core/platform/SharedTimer.h" | 36 #include "core/platform/SharedTimer.h" |
37 #include "core/platform/ThreadGlobalData.h" | 37 #include "core/platform/ThreadGlobalData.h" |
38 #include "core/platform/ThreadTimers.h" | 38 #include "core/platform/ThreadTimers.h" |
39 #include "core/workers/WorkerContext.h" | 39 #include "core/workers/WorkerGlobalScope.h" |
40 #include "core/workers/WorkerThread.h" | 40 #include "core/workers/WorkerThread.h" |
41 #include <wtf/CurrentTime.h> | 41 #include <wtf/CurrentTime.h> |
42 | 42 |
43 namespace WebCore { | 43 namespace WebCore { |
44 | 44 |
45 class WorkerSharedTimer : public SharedTimer { | 45 class WorkerSharedTimer : public SharedTimer { |
46 public: | 46 public: |
47 WorkerSharedTimer() | 47 WorkerSharedTimer() |
48 : m_sharedTimerFunction(0) | 48 : m_sharedTimerFunction(0) |
49 , m_nextFireTime(0) | 49 , m_nextFireTime(0) |
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
120 ~RunLoopSetup() | 120 ~RunLoopSetup() |
121 { | 121 { |
122 m_runLoop.m_nestedCount--; | 122 m_runLoop.m_nestedCount--; |
123 if (!m_runLoop.m_nestedCount) | 123 if (!m_runLoop.m_nestedCount) |
124 threadGlobalData().threadTimers().setSharedTimer(0); | 124 threadGlobalData().threadTimers().setSharedTimer(0); |
125 } | 125 } |
126 private: | 126 private: |
127 WorkerRunLoop& m_runLoop; | 127 WorkerRunLoop& m_runLoop; |
128 }; | 128 }; |
129 | 129 |
130 void WorkerRunLoop::run(WorkerContext* context) | 130 void WorkerRunLoop::run(WorkerGlobalScope* context) |
131 { | 131 { |
132 RunLoopSetup setup(*this); | 132 RunLoopSetup setup(*this); |
133 ModePredicate modePredicate(defaultMode()); | 133 ModePredicate modePredicate(defaultMode()); |
134 MessageQueueWaitResult result; | 134 MessageQueueWaitResult result; |
135 do { | 135 do { |
136 result = runInMode(context, modePredicate, WaitForMessage); | 136 result = runInMode(context, modePredicate, WaitForMessage); |
137 } while (result != MessageQueueTerminated); | 137 } while (result != MessageQueueTerminated); |
138 runCleanupTasks(context); | 138 runCleanupTasks(context); |
139 } | 139 } |
140 | 140 |
141 MessageQueueWaitResult WorkerRunLoop::runInMode(WorkerContext* context, const St
ring& mode, WaitMode waitMode) | 141 MessageQueueWaitResult WorkerRunLoop::runInMode(WorkerGlobalScope* context, cons
t String& mode, WaitMode waitMode) |
142 { | 142 { |
143 RunLoopSetup setup(*this); | 143 RunLoopSetup setup(*this); |
144 ModePredicate modePredicate(mode); | 144 ModePredicate modePredicate(mode); |
145 MessageQueueWaitResult result = runInMode(context, modePredicate, waitMode); | 145 MessageQueueWaitResult result = runInMode(context, modePredicate, waitMode); |
146 return result; | 146 return result; |
147 } | 147 } |
148 | 148 |
149 MessageQueueWaitResult WorkerRunLoop::runInMode(WorkerContext* context, const Mo
dePredicate& predicate, WaitMode waitMode) | 149 MessageQueueWaitResult WorkerRunLoop::runInMode(WorkerGlobalScope* context, cons
t ModePredicate& predicate, WaitMode waitMode) |
150 { | 150 { |
151 ASSERT(context); | 151 ASSERT(context); |
152 ASSERT(context->thread()); | 152 ASSERT(context->thread()); |
153 ASSERT(context->thread()->isCurrentThread()); | 153 ASSERT(context->thread()->isCurrentThread()); |
154 | 154 |
155 double absoluteTime = 0.0; | 155 double absoluteTime = 0.0; |
156 if (waitMode == WaitForMessage) { | 156 if (waitMode == WaitForMessage) { |
157 absoluteTime = (predicate.isDefaultMode() && m_sharedTimer->isActive())
? m_sharedTimer->fireTime() : MessageQueue<Task>::infiniteTime(); | 157 absoluteTime = (predicate.isDefaultMode() && m_sharedTimer->isActive())
? m_sharedTimer->fireTime() : MessageQueue<Task>::infiniteTime(); |
158 if (m_messageQueue.isEmpty()) { | 158 if (m_messageQueue.isEmpty()) { |
159 idleNotification(absoluteTime - currentTime()); | 159 idleNotification(absoluteTime - currentTime()); |
(...skipping 16 matching lines...) Expand all Loading... |
176 | 176 |
177 case MessageQueueTimeout: | 177 case MessageQueueTimeout: |
178 if (!context->isClosing() && currentTime() >= m_sharedTimer->fireTime()) | 178 if (!context->isClosing() && currentTime() >= m_sharedTimer->fireTime()) |
179 m_sharedTimer->fire(); | 179 m_sharedTimer->fire(); |
180 break; | 180 break; |
181 } | 181 } |
182 | 182 |
183 return result; | 183 return result; |
184 } | 184 } |
185 | 185 |
186 void WorkerRunLoop::runCleanupTasks(WorkerContext* context) | 186 void WorkerRunLoop::runCleanupTasks(WorkerGlobalScope* context) |
187 { | 187 { |
188 ASSERT(context); | 188 ASSERT(context); |
189 ASSERT(context->thread()); | 189 ASSERT(context->thread()); |
190 ASSERT(context->thread()->isCurrentThread()); | 190 ASSERT(context->thread()->isCurrentThread()); |
191 ASSERT(m_messageQueue.killed()); | 191 ASSERT(m_messageQueue.killed()); |
192 | 192 |
193 while (true) { | 193 while (true) { |
194 OwnPtr<WorkerRunLoop::Task> task = m_messageQueue.tryGetMessageIgnoringK
illed(); | 194 OwnPtr<WorkerRunLoop::Task> task = m_messageQueue.tryGetMessageIgnoringK
illed(); |
195 if (!task) | 195 if (!task) |
196 return; | 196 return; |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
236 m_nextIdleNotificationTime = now + m_currentIdleIntervalInSeconds; | 236 m_nextIdleNotificationTime = now + m_currentIdleIntervalInSeconds; |
237 } | 237 } |
238 | 238 |
239 PassOwnPtr<WorkerRunLoop::Task> WorkerRunLoop::Task::create(PassOwnPtr<ScriptExe
cutionContext::Task> task, const String& mode) | 239 PassOwnPtr<WorkerRunLoop::Task> WorkerRunLoop::Task::create(PassOwnPtr<ScriptExe
cutionContext::Task> task, const String& mode) |
240 { | 240 { |
241 return adoptPtr(new Task(task, mode)); | 241 return adoptPtr(new Task(task, mode)); |
242 } | 242 } |
243 | 243 |
244 void WorkerRunLoop::Task::performTask(const WorkerRunLoop& runLoop, ScriptExecut
ionContext* context) | 244 void WorkerRunLoop::Task::performTask(const WorkerRunLoop& runLoop, ScriptExecut
ionContext* context) |
245 { | 245 { |
246 WorkerContext* workerContext = static_cast<WorkerContext *>(context); | 246 WorkerGlobalScope* workerGlobalScope = static_cast<WorkerGlobalScope*>(conte
xt); |
247 if ((!workerContext->isClosing() && !runLoop.terminated()) || m_task->isClea
nupTask()) | 247 if ((!workerGlobalScope->isClosing() && !runLoop.terminated()) || m_task->is
CleanupTask()) |
248 m_task->performTask(context); | 248 m_task->performTask(context); |
249 } | 249 } |
250 | 250 |
251 WorkerRunLoop::Task::Task(PassOwnPtr<ScriptExecutionContext::Task> task, const S
tring& mode) | 251 WorkerRunLoop::Task::Task(PassOwnPtr<ScriptExecutionContext::Task> task, const S
tring& mode) |
252 : m_task(task) | 252 : m_task(task) |
253 , m_mode(mode.isolatedCopy()) | 253 , m_mode(mode.isolatedCopy()) |
254 { | 254 { |
255 } | 255 } |
256 | 256 |
257 } // namespace WebCore | 257 } // namespace WebCore |
OLD | NEW |