X-Git-Url: https://git.dogcows.com/gitweb?a=blobdiff_plain;f=src%2Ftimer.cc;fp=src%2Ftimer.cc;h=0000000000000000000000000000000000000000;hb=9259ec5732851dd66f7c598d629e3808ac7ab3d8;hp=856ac8f7141fa2a1f3e844da8879d60ddf2296a1;hpb=ad80ef0f667e3b72d9e35d7a93451a1e2dfa0ab6;p=chaz%2Fopenbox diff --git a/src/timer.cc b/src/timer.cc deleted file mode 100644 index 856ac8f7..00000000 --- a/src/timer.cc +++ /dev/null @@ -1,150 +0,0 @@ -// -*- mode: C++; indent-tabs-mode: nil; -*- - -#ifdef HAVE_CONFIG_H -# include "../config.h" -#endif // HAVE_CONFIG_H - -#include "otk/display.hh" -#include "openbox.hh" -#include "timer.hh" -#include "util.hh" - -namespace ob { - -OBTimer::OBTimer(TimeoutHandler *h) { - handler = h; - - recur = timing = False; -} - - -OBTimer::~OBTimer(void) { - if (timing) stop(); -} - - -void OBTimer::setTimeout(long t) { - _timeout.tv_sec = t / 1000; - _timeout.tv_usec = t % 1000; - _timeout.tv_usec *= 1000; -} - - -void OBTimer::setTimeout(const timeval &t) { - _timeout.tv_sec = t.tv_sec; - _timeout.tv_usec = t.tv_usec; -} - - -void OBTimer::start(void) { - gettimeofday(&_start, 0); - - if (! timing) { - timing = True; - Openbox::instance->timerManager()->addTimer(this); - } -} - - -void OBTimer::stop(void) { - timing = False; - - Openbox::instance->timerManager()->removeTimer(this); -} - - -void OBTimer::halt(void) { - timing = False; -} - - -void OBTimer::fireTimeout(void) { - if (handler) - handler->timeout(); -} - - -timeval OBTimer::timeRemaining(const timeval &tm) const { - timeval ret = endpoint(); - - ret.tv_sec -= tm.tv_sec; - ret.tv_usec -= tm.tv_usec; - - return normalizeTimeval(ret); -} - - -timeval OBTimer::endpoint(void) const { - timeval ret; - - ret.tv_sec = _start.tv_sec + _timeout.tv_sec; - ret.tv_usec = _start.tv_usec + _timeout.tv_usec; - - return normalizeTimeval(ret); -} - - -bool OBTimer::shouldFire(const timeval &tm) const { - timeval end = endpoint(); - - return ! ((tm.tv_sec < end.tv_sec) || - (tm.tv_sec == end.tv_sec && tm.tv_usec < end.tv_usec)); -} - - -void OBTimerQueueManager::fire() -{ - fd_set rfds; - timeval now, tm, *timeout = (timeval *) 0; - - const int xfd = ConnectionNumber(otk::OBDisplay::display); - - FD_ZERO(&rfds); - FD_SET(xfd, &rfds); // break on any x events - - if (! timerList.empty()) { - const OBTimer* const timer = timerList.top(); - - gettimeofday(&now, 0); - tm = timer->timeRemaining(now); - - timeout = &tm; - } - - select(xfd + 1, &rfds, 0, 0, timeout); - - // check for timer timeout - gettimeofday(&now, 0); - - // there is a small chance for deadlock here: - // *IF* the timer list keeps getting refreshed *AND* the time between - // timer->start() and timer->shouldFire() is within the timer's period - // then the timer will keep firing. This should be VERY near impossible. - while (! timerList.empty()) { - OBTimer *timer = timerList.top(); - if (! timer->shouldFire(now)) - break; - - timerList.pop(); - - timer->fireTimeout(); - timer->halt(); - if (timer->isRecurring()) - timer->start(); - } -} - - -void OBTimerQueueManager::addTimer(OBTimer *timer) -{ - assert(timer); - timerList.push(timer); -} - -void OBTimerQueueManager::removeTimer(OBTimer* timer) -{ - assert(timer); - timerList.release(timer); -} - -}