// Timer.cc for Blackbox - An X11 Window Manager // Copyright (c) 1997 - 2000 Brad Hughes (bhughes@tcac.net) // // Permission is hereby granted, free of charge, to any person obtaining a // copy of this software and associated documentation files (the "Software"), // to deal in the Software without restriction, including without limitation // the rights to use, copy, modify, merge, publish, distribute, sublicense, // and/or sell copies of the Software, and to permit persons to whom the // Software is furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL // THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING // FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER // DEALINGS IN THE SOFTWARE. //use GNU extensions #ifndef _GNU_SOURCE #define _GNU_SOURCE #endif // _GNU_SOURCE #ifdef HAVE_CONFIG_H #include "../config.h" #endif // HAVE_CONFIG_H #include "Timer.hh" #include <sys/types.h> #include <unistd.h> #include <cassert> //static var BTimer::TimerList BTimer::m_timerlist; BTimer::BTimer(TimeoutHandler *h): m_handler(h), m_timing(false), m_once(false) { } BTimer::~BTimer(void) { if (isTiming()) stop(); } void BTimer::setTimeout(long t) { m_timeout.tv_sec = t / 1000; m_timeout.tv_usec = t; m_timeout.tv_usec -= (m_timeout.tv_sec * 1000); m_timeout.tv_usec *= 1000; } void BTimer::setTimeout(timeval t) { m_timeout.tv_sec = t.tv_sec; m_timeout.tv_usec = t.tv_usec; } void BTimer::start(void) { gettimeofday(&m_start, 0); if (! m_timing) { m_timing = true; addTimer(this); //add us to the list } } void BTimer::stop(void) { m_timing = false; removeTimer(this); //remove us from the list } void BTimer::fireTimeout(void) { if (m_handler) m_handler->timeout(); } void BTimer::updateTimers(int fd) { fd_set rfds; timeval now, tm, *timeout = 0; FD_ZERO(&rfds); FD_SET(fd, &rfds); if (m_timerlist.size() > 0) { gettimeofday(&now, 0); tm.tv_sec = tm.tv_usec = 0l; BTimer *timer = m_timerlist.front(); tm.tv_sec = timer->getStartTime().tv_sec + timer->getTimeout().tv_sec - now.tv_sec; tm.tv_usec = timer->getStartTime().tv_usec + timer->getTimeout().tv_usec - now.tv_usec; while (tm.tv_usec >= 1000000) { tm.tv_sec++; tm.tv_usec -= 1000000; } while (tm.tv_usec < 0) { if (tm.tv_sec > 0) { tm.tv_sec--; tm.tv_usec += 1000000; } else { tm.tv_usec = 0; break; } } timeout = &tm; } select(fd + 1, &rfds, 0, 0, timeout); // check for timer timeout gettimeofday(&now, 0); TimerList::iterator it = m_timerlist.begin(); //must check end ...the timer might remove //it self from the list (should be fixed in the future) for(; it != m_timerlist.end(); ++it) { tm.tv_sec = (*it)->getStartTime().tv_sec + (*it)->getTimeout().tv_sec; tm.tv_usec = (*it)->getStartTime().tv_usec + (*it)->getTimeout().tv_usec; if ((now.tv_sec < tm.tv_sec) || (now.tv_sec == tm.tv_sec && now.tv_usec < tm.tv_usec)) break; (*it)->fireTimeout(); // restart the current timer so that the start time is updated if (! (*it)->doOnce()) (*it)->start(); else { (*it)->stop(); it--; } } } void BTimer::addTimer(BTimer *timer) { assert(timer); TimerList::iterator it = m_timerlist.begin(); TimerList::iterator it_end = m_timerlist.end(); int index = 0; for (; it != it_end; ++it, ++index) { if (((*it)->getTimeout().tv_sec > timer->getTimeout().tv_sec) || (((*it)->getTimeout().tv_sec == timer->getTimeout().tv_sec) && ((*it)->getTimeout().tv_usec >= timer->getTimeout().tv_usec))) { break; } } m_timerlist.insert(it, timer); } void BTimer::removeTimer(BTimer *timer) { assert(timer); m_timerlist.remove(timer); }