Index: Source/platform/Timer.h |
diff --git a/Source/platform/Timer.h b/Source/platform/Timer.h |
index e8015b6d5ca0cc4461b54fde74fad7fd1251f1a4..abab891a6f57406405240015b8042b3930be961b 100644 |
--- a/Source/platform/Timer.h |
+++ b/Source/platform/Timer.h |
@@ -63,44 +63,50 @@ public: |
double repeatInterval() const { return m_repeatInterval; } |
void augmentRepeatInterval(double delta) { |
- setNextFireTime(m_nextFireTime + delta); |
m_repeatInterval += delta; |
+ setNextFireTime(monotonicallyIncreasingTime(), m_repeatInterval); |
} |
- void didChangeAlignmentInterval(); |
+ void didChangeAlignmentInterval(double now); |
private: |
virtual void fired() = 0; |
virtual double alignedFireTime(double fireTime) const { return fireTime; } |
- void checkConsistency() const; |
- void checkHeapIndex() const; |
+ void setNextFireTime(double now, double delay); |
- void setNextFireTime(double); |
+ void runInternal(); |
- bool inHeap() const { return m_heapIndex != -1; } |
+ class CancellableTimerTask : public WebThread::Task { |
+ WTF_MAKE_NONCOPYABLE(CancellableTimerTask); |
- bool hasValidHeapPosition() const; |
- void updateHeapIfNeeded(double oldTime); |
+ public: |
+ explicit CancellableTimerTask(TimerBase* timer) : m_timer(timer) { } |
- void heapDecreaseKey(); |
- void heapDelete(); |
- void heapDeleteMin(); |
- void heapIncreaseKey(); |
- void heapInsert(); |
- void heapPop(); |
- void heapPopMin(); |
+ virtual ~CancellableTimerTask() |
+ { |
+ if (m_timer) |
+ m_timer->m_cancellableTimerTask = nullptr; |
+ } |
- Vector<TimerBase*>& timerHeap() const { ASSERT(m_cachedThreadGlobalTimerHeap); return *m_cachedThreadGlobalTimerHeap; } |
+ void run() override; |
+ |
+ void cancel() |
+ { |
+ m_timer = nullptr; |
+ } |
+ |
+ private: |
+ TimerBase* m_timer; // NOT OWNED |
+ }; |
double m_nextFireTime; // 0 if inactive |
double m_unalignedNextFireTime; // m_nextFireTime not considering alignment interval |
double m_repeatInterval; // 0 if not repeating |
- int m_heapIndex; // -1 if not in heap |
- unsigned m_heapInsertionOrder; // Used to keep order among equal-fire-time timers |
- Vector<TimerBase*>* m_cachedThreadGlobalTimerHeap; |
WebTraceLocation m_location; |
+ CancellableTimerTask* m_cancellableTimerTask; // NOT OWNED |
+ WebScheduler* m_webScheduler; // NOT OWNED |
#if ENABLE(ASSERT) |
ThreadIdentifier m_thread; |
@@ -157,7 +163,7 @@ private: |
inline bool TimerBase::isActive() const |
{ |
ASSERT(m_thread == currentThread()); |
- return m_nextFireTime; |
+ return m_cancellableTimerTask; |
} |
} |