OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 // Timer heap implemented as a array-based binary heap[0]. | 5 // Timer heap implemented as a array-based binary heap[0]. |
6 // This allows for O(1) `first`, O(log(n)) `remove`/`removeFirst` and O(log(n)) | 6 // This allows for O(1) `first`, O(log(n)) `remove`/`removeFirst` and O(log(n)) |
7 // `add`. | 7 // `add`. |
8 // | 8 // |
9 // To ensure the timers are ordered by insertion time, the _Timer class has a | 9 // To ensure the timers are ordered by insertion time, the _Timer class has a |
10 // `_id` field set when added to the heap. | 10 // `_id` field set when added to the heap. |
(...skipping 154 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
165 int milliSeconds, | 165 int milliSeconds, |
166 bool repeating) { | 166 bool repeating) { |
167 // Negative timeouts are treated as if 0 timeout. | 167 // Negative timeouts are treated as if 0 timeout. |
168 if (milliSeconds < 0) { | 168 if (milliSeconds < 0) { |
169 milliSeconds = 0; | 169 milliSeconds = 0; |
170 } | 170 } |
171 // Add one because DateTime.now() is assumed to round down | 171 // Add one because DateTime.now() is assumed to round down |
172 // to nearest millisecond, not up, so that time + duration is before | 172 // to nearest millisecond, not up, so that time + duration is before |
173 // duration milliseconds from now. Using microsecond timers like | 173 // duration milliseconds from now. Using microsecond timers like |
174 // Stopwatch allows detecting that the timer fires early. | 174 // Stopwatch allows detecting that the timer fires early. |
175 int now = new DateTime.now().millisecondsSinceEpoch; | 175 int now = VMLibraryHooks.timerMillisecondClock(); |
176 int wakeupTime = (milliSeconds == 0) ? now : (now + 1 + milliSeconds); | 176 int wakeupTime = (milliSeconds == 0) ? now : (now + 1 + milliSeconds); |
177 | 177 |
178 _Timer timer = new _Timer._internal(callback, | 178 _Timer timer = new _Timer._internal(callback, |
179 wakeupTime, | 179 wakeupTime, |
180 milliSeconds, | 180 milliSeconds, |
181 repeating); | 181 repeating); |
182 // Enqueue this newly created timer in the appropriate structure and | 182 // Enqueue this newly created timer in the appropriate structure and |
183 // notify if necessary. | 183 // notify if necessary. |
184 timer._enqueue(); | 184 timer._enqueue(); |
185 return timer; | 185 return timer; |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
225 } | 225 } |
226 | 226 |
227 | 227 |
228 void _advanceWakeupTime() { | 228 void _advanceWakeupTime() { |
229 // Recalculate the next wakeup time. For repeating timers with a 0 timeout | 229 // Recalculate the next wakeup time. For repeating timers with a 0 timeout |
230 // the next wakeup time is now. | 230 // the next wakeup time is now. |
231 _id = _nextId(); | 231 _id = _nextId(); |
232 if (_milliSeconds > 0) { | 232 if (_milliSeconds > 0) { |
233 _wakeupTime += _milliSeconds; | 233 _wakeupTime += _milliSeconds; |
234 } else { | 234 } else { |
235 _wakeupTime = new DateTime.now().millisecondsSinceEpoch; | 235 _wakeupTime = VMLibraryHooks.timerMillisecondClock(); |
236 } | 236 } |
237 } | 237 } |
238 | 238 |
239 | 239 |
240 // Adds a timer to the heap or timer list. Timers with the same wakeup time | 240 // Adds a timer to the heap or timer list. Timers with the same wakeup time |
241 // are enqueued in order and notified in FIFO order. | 241 // are enqueued in order and notified in FIFO order. |
242 void _enqueue() { | 242 void _enqueue() { |
243 if (_milliSeconds == 0) { | 243 if (_milliSeconds == 0) { |
244 if (_firstZeroTimer == null) { | 244 if (_firstZeroTimer == null) { |
245 _lastZeroTimer = this; | 245 _lastZeroTimer = this; |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
333 // timer are expired. The first zero timer will be dispatched when its | 333 // timer are expired. The first zero timer will be dispatched when its |
334 // corresponding message is delivered. | 334 // corresponding message is delivered. |
335 var timer; | 335 var timer; |
336 while (!_heap.isEmpty && (_heap.first._compareTo(_firstZeroTimer) < 0)) { | 336 while (!_heap.isEmpty && (_heap.first._compareTo(_firstZeroTimer) < 0)) { |
337 timer = _heap.removeFirst(); | 337 timer = _heap.removeFirst(); |
338 pendingTimers.add(timer); | 338 pendingTimers.add(timer); |
339 } | 339 } |
340 } else { | 340 } else { |
341 // Collect pending timers from the timer heap which have expired at this | 341 // Collect pending timers from the timer heap which have expired at this |
342 // time. | 342 // time. |
343 var currentTime = new DateTime.now().millisecondsSinceEpoch; | 343 var currentTime = VMLibraryHooks.timerMillisecondClock(); |
344 var timer; | 344 var timer; |
345 while (!_heap.isEmpty && (_heap.first._wakeupTime <= currentTime)) { | 345 while (!_heap.isEmpty && (_heap.first._wakeupTime <= currentTime)) { |
346 timer = _heap.removeFirst(); | 346 timer = _heap.removeFirst(); |
347 pendingTimers.add(timer); | 347 pendingTimers.add(timer); |
348 } | 348 } |
349 } | 349 } |
350 return pendingTimers; | 350 return pendingTimers; |
351 } | 351 } |
352 | 352 |
353 | 353 |
(...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
463 return new _Timer.periodic(milliSeconds, callback); | 463 return new _Timer.periodic(milliSeconds, callback); |
464 } | 464 } |
465 return new _Timer(milliSeconds, callback); | 465 return new _Timer(milliSeconds, callback); |
466 } | 466 } |
467 } | 467 } |
468 | 468 |
469 | 469 |
470 _setupHooks() { | 470 _setupHooks() { |
471 VMLibraryHooks.timerFactory = _Timer._factory; | 471 VMLibraryHooks.timerFactory = _Timer._factory; |
472 } | 472 } |
OLD | NEW |