split the OBTimerQueueManager and TimerQueue into their own files
[dana/openbox.git] / otk / timerqueuemanager.cc
1 // -*- mode: C++; indent-tabs-mode: nil; -*-
2
3 #ifdef    HAVE_CONFIG_H
4 #  include "../config.h"
5 #endif // HAVE_CONFIG_H
6
7 #include "timerqueuemanager.hh"
8 #include "display.hh"
9
10 namespace otk {
11
12 void OBTimerQueueManager::fire()
13 {
14   fd_set rfds;
15   timeval now, tm, *timeout = (timeval *) 0;
16
17   const int xfd = ConnectionNumber(otk::OBDisplay::display);
18   
19   FD_ZERO(&rfds);
20   FD_SET(xfd, &rfds); // break on any x events
21
22   if (! timerList.empty()) {
23     const OBTimer* const timer = timerList.top();
24
25     gettimeofday(&now, 0);
26     tm = timer->timeRemaining(now);
27
28     timeout = &tm;
29   }
30
31   select(xfd + 1, &rfds, 0, 0, timeout);
32
33   // check for timer timeout
34   gettimeofday(&now, 0);
35
36   // there is a small chance for deadlock here:
37   // *IF* the timer list keeps getting refreshed *AND* the time between
38   // timer->start() and timer->shouldFire() is within the timer's period
39   // then the timer will keep firing.  This should be VERY near impossible.
40   while (! timerList.empty()) {
41     OBTimer *timer = timerList.top();
42     if (! timer->shouldFire(now))
43       break;
44
45     timerList.pop();
46
47     timer->fireTimeout();
48     timer->halt();
49     if (timer->isRecurring())
50       timer->start();
51   }
52 }
53
54
55 void OBTimerQueueManager::addTimer(OBTimer *timer)
56 {
57   assert(timer);
58   timerList.push(timer);
59 }
60
61 void OBTimerQueueManager::removeTimer(OBTimer* timer)
62 {
63   assert(timer);
64   timerList.release(timer);
65 }
66
67 }