Method AdjustTimers

lib/base/timer.cpp:261–292

* Adjusts all periodic timers by adding the specified amount of time to their * next scheduled timestamp. * * @param adjustment The adjustment. */

 * @param adjustment The adjustment.
 */
void Timer::AdjustTimers(double adjustment)
{
	std::unique_lock<std::mutex> lock(l_TimerMutex);

	double now = Utility::GetTime();

	typedef boost::multi_index::nth_index<TimerSet, 1>::type TimerView;
	TimerView& idx = boost::get<1>(l_Timers);

	std::vector<Timer *> timers;

	for (Timer *timer : idx) {
		/* Don't schedule the next call if this is not a periodic timer. */
		if (timer->m_Interval <= 0) {
			continue;
		}

		if (std::fabs(now - (timer->m_Next + adjustment)) <
			std::fabs(now - timer->m_Next)) {
			timer->m_Next += adjustment;
			timers.push_back(timer);
		}
	}

	for (Timer *timer : timers) {
		l_Timers.erase(timer);
		l_Timers.insert(timer);
	}

	/* Notify the worker that we've rescheduled some timers. */
	l_TimerCV.notify_all();
}

/**
 * Worker thread proc for Timer objects.