Method TimerThreadProc

cpp/src/TimerThread.cpp:90–138

----------------------------------------------------------------------------- Thread for timer based actions -----------------------------------------------------------------------------

// Thread for timer based actions
//-----------------------------------------------------------------------------
void TimerThread::TimerThreadProc
(
		Event* _exitEvent
)
{
	Log::Write( LogLevel_Info, "Timer: thread starting" );

	Wait* waitObjects[2];
	waitObjects[0] = _exitEvent;
	waitObjects[1] = m_timerEvent;
	uint32 count = 2;

	// Initially no timer events so infinite timeout.
	m_timerTimeout = Wait::Timeout_Infinite;

	while( 1 )
	{
		Log::Write( LogLevel_Detail, "Timer: waiting with timeout %d ms", m_timerTimeout );
		int32 res = Wait::Multiple( waitObjects, count, m_timerTimeout );

		if (res == 0)
		{
			// Exit has been signalled
			return;

		} else {
			// Timeout or new entry to timer list.
			m_timerTimeout = Wait::Timeout_Infinite;

			// Go through all waiting actions, and see if any need to be performed.
			LockGuard LG(m_timerMutex);
			list<TimerEventEntry *>::iterator it = m_timerEventList.begin();
			while( it != m_timerEventList.end() ) {
				int32 tr = (*it)->timestamp.TimeRemaining();
				if (tr <= 0) {
					// Expired so perform action and remove from list.
					Log::Write( LogLevel_Info, "Timer: delayed event" );
					TimerEventEntry *te = *(it++);
					te->instance->TimerFireEvent(te);
				} else {
					// Time remaining.
					m_timerTimeout = (m_timerTimeout == Wait::Timeout_Infinite) ? tr : std::min(m_timerTimeout, tr);
					++it;
				}
			}
			m_timerEvent->Reset();
		}
	} // while( 1 )
}

//-----------------------------------------------------------------------------
// <TimerThread::TimerSetEvent>