icinga2/base/timer.cpp

123 lines
2.0 KiB
C++
Raw Normal View History

2012-03-28 13:24:49 +02:00
#include <functional>
#include <algorithm>
#include "i2-base.h"
using namespace icinga;
2012-03-30 19:56:54 +02:00
time_t Timer::NextCall;
list<Timer::WeakPtr> Timer::Timers;
2012-03-28 13:24:49 +02:00
Timer::Timer(void)
{
m_Interval = 0;
}
time_t Timer::GetNextCall(void)
{
2012-03-30 19:56:54 +02:00
if (NextCall < time(NULL))
2012-03-28 13:24:49 +02:00
Timer::RescheduleTimers();
2012-03-30 19:56:54 +02:00
return NextCall;
2012-03-28 13:24:49 +02:00
}
void Timer::RescheduleTimers(void)
{
/* Make sure we wake up at least once every 30 seconds */
2012-03-30 19:56:54 +02:00
NextCall = time(NULL) + 30;
2012-03-28 13:24:49 +02:00
for (list<Timer::WeakPtr>::iterator i = Timers.begin(); i != Timers.end(); i++) {
Timer::Ptr timer = i->lock();
2012-03-28 13:24:49 +02:00
if (timer == NULL)
continue;
2012-03-30 19:56:54 +02:00
if (timer->m_Next < NextCall)
NextCall = timer->m_Next;
2012-03-28 13:24:49 +02:00
}
}
void Timer::CallExpiredTimers(void)
{
time_t now;
time(&now);
for (list<Timer::WeakPtr>::iterator i = Timers.begin(); i != Timers.end(); ) {
Timer::Ptr timer = Timer::Ptr(*i);
2012-03-28 13:24:49 +02:00
i++;
if (timer == NULL)
continue;
if (timer->m_Next <= now) {
timer->Call();
timer->Reschedule(now + timer->GetInterval());
}
}
}
void Timer::StopAllTimers(void)
{
for (list<Timer::WeakPtr>::iterator i = Timers.begin(); i != Timers.end(); ) {
Timer::Ptr timer = i->lock();
2012-03-28 13:24:49 +02:00
i++;
if (timer == NULL)
continue;
timer->Stop();
}
}
/* Note: the timer delegate must not call Disable() on any other timers than
* the timer that originally invoked the delegate */
void Timer::Call(void)
{
2012-04-03 15:16:11 +02:00
TimerEventArgs::Ptr ea = make_shared<TimerEventArgs>();
2012-03-28 13:24:49 +02:00
ea->Source = shared_from_this();
ea->UserArgs = m_UserArgs;
OnTimerExpired(ea);
}
void Timer::SetInterval(unsigned int interval)
{
m_Interval = interval;
}
unsigned int Timer::GetInterval(void) const
{
return m_Interval;
}
void Timer::SetUserArgs(const EventArgs::Ptr& userArgs)
{
m_UserArgs = userArgs;
}
EventArgs::Ptr Timer::GetUserArgs(void) const
{
return m_UserArgs;
}
2012-03-28 13:24:49 +02:00
void Timer::Start(void)
{
Stop();
Timers.push_front(static_pointer_cast<Timer>(shared_from_this()));
Reschedule(time(NULL) + m_Interval);
}
void Timer::Stop(void)
{
Timers.remove_if(weak_ptr_eq_raw<Timer>(this));
}
void Timer::Reschedule(time_t next)
{
m_Next = next;
RescheduleTimers();
}