Refactor TimeBase to post tasks. Workers to use real Idle tasks.

Source/platform/Timer.h

Index: Source/platform/Timer.h
diff --git a/Source/platform/Timer.h b/Source/platform/Timer.h
index 504eb9f006122191065c86012c2bca83550581e0..e56449e7c1f4813128ef7ae8594f11c9f84b5c75 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; }
+    // NOTE we can't use CancellableTaskFactory here, because the destructor of
+    // CancellableTaskFactory::CancellableTask does some memory access (causes various tests to crash on shtdown).

[rmcilroy, 2015/04/17 12:59:33]

/s/shtdown/shutdown

[alex clarke (OOO till 29th), 2015/04/17 13:37:08]

Done.

+    // Normally that's fine but some of the unit tests leave don't shutdown cleanly, leaving dangling tasks
+    // pointing to deleted memory, which cause CancellableTaskFactory::CancellableTask's destructor to segfault.
+    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() { }
 
-    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;
@@ -156,7 +162,7 @@ private:
 inline bool TimerBase::isActive() const
 {
     ASSERT(m_thread == currentThread());
-    return m_nextFireTime;
+    return m_cancellableTimerTask;
 }
 
 }