dvander@592: /**
ds@653:  * vim: set ts=4 :
ds@1330:  * =============================================================================
dvander@1231:  * SourceMod
dvander@1231:  * Copyright (C) 2004-2007 AlliedModders LLC.  All rights reserved.
ds@1330:  * =============================================================================
ds@653:  *
ds@1330:  * This program is free software; you can redistribute it and/or modify it under
ds@1330:  * the terms of the GNU General Public License, version 3.0, as published by the
ds@1330:  * Free Software Foundation.
dvander@1231:  * 
ds@1330:  * This program is distributed in the hope that it will be useful, but WITHOUT
ds@1330:  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
ds@1330:  * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
ds@1330:  * details.
dvander@1231:  *
ds@1330:  * You should have received a copy of the GNU General Public License along with
ds@1330:  * this program.  If not, see <http://www.gnu.org/licenses/>.
dvander@1231:  *
ds@1330:  * As a special exception, AlliedModders LLC gives you permission to link the
ds@1330:  * code of this program (as well as its derivative works) to "Half-Life 2," the
ds@1330:  * "Source Engine," the "SourcePawn JIT," and any Game MODs that run on software
ds@1330:  * by the Valve Corporation.  You must obey the GNU General Public License in
ds@1330:  * all respects for all other code used.  Additionally, AlliedModders LLC grants
ds@1330:  * this exception to all derivative works.  AlliedModders LLC defines further
ds@1330:  * exceptions, found in LICENSE.txt (as of this writing, version JULY-31-2007),
ds@1330:  * or <http://www.sourcemod.net/license.php>.
ds@653:  *
ds@653:  * Version: $Id$
ds@653:  */
dvander@592: 
dvander@592: #include "TimerSys.h"
dvander@592: 
dvander@616: TimerSystem g_Timers;
dvander@727: TickInfo g_SimTicks;
dvander@727: 
dvander@727: inline float GetSimulatedTime()
dvander@727: {
dvander@727: 	if (g_SimTicks.ticking)
dvander@727: 	{
dvander@727: 		return gpGlobals->curtime;
dvander@727: 	} else {
dvander@727: 		return g_SimTicks.ticktime;
dvander@727: 	}
dvander@727: }
dvander@592: 
dvander@592: void ITimer::Initialize(ITimedEvent *pCallbacks, float fInterval, float fToExec, void *pData, int flags)
dvander@592: {
dvander@592: 	m_Listener = pCallbacks;
dvander@592: 	m_Interval = fInterval;
dvander@592: 	m_ToExec = fToExec;
dvander@592: 	m_pData = pData;
dvander@592: 	m_Flags = flags;
dvander@592: 	m_InExec = false;
dvander@592: 	m_KillMe = false;
dvander@592: }
dvander@592: 
faluco@641: TimerSystem::~TimerSystem()
faluco@641: {
faluco@641: 	CStack<ITimer *>::iterator iter;
faluco@641: 	for (iter=m_FreeTimers.begin(); iter!=m_FreeTimers.end(); iter++)
faluco@641: 	{
faluco@641: 		delete (*iter);
faluco@641: 	}
faluco@641: 	m_FreeTimers.popall();
faluco@641: }
faluco@641: 
dvander@616: void TimerSystem::OnSourceModAllInitialized()
dvander@592: {
dvander@592: 	g_ShareSys.AddInterface(NULL, this);
dvander@592: }
dvander@592: 
dvander@673: void TimerSystem::OnSourceModLevelChange(const char *mapName)
dvander@673: {
dvander@1142: 	MapChange(true);
dvander@673: }
dvander@673: 
dvander@616: void TimerSystem::RunFrame()
dvander@592: {
dvander@592: 	ITimer *pTimer;
dvander@592: 	TimerIter iter;
dvander@592: 
dvander@727: 	float curtime = GetSimulatedTime();
dvander@592: 	for (iter=m_SingleTimers.begin(); iter!=m_SingleTimers.end(); )
dvander@592: 	{
dvander@592: 		pTimer = (*iter);
dvander@727: 		if (curtime >= pTimer->m_ToExec)
dvander@592: 		{
dvander@592: 			pTimer->m_InExec = true;
dvander@592: 			pTimer->m_Listener->OnTimer(pTimer, pTimer->m_pData);
faluco@612: 			pTimer->m_Listener->OnTimerEnd(pTimer, pTimer->m_pData);
dvander@592: 			iter = m_SingleTimers.erase(iter);
dvander@592: 			m_FreeTimers.push(pTimer);
dvander@592: 		} else {
dvander@592: 			break;
dvander@592: 		}
dvander@592: 	}
dvander@592: 
dvander@592: 	ResultType res;
dvander@592: 	for (iter=m_LoopTimers.begin(); iter!=m_LoopTimers.end(); )
dvander@592: 	{
dvander@592: 		pTimer = (*iter);
dvander@727: 		if (curtime >= pTimer->m_ToExec)
dvander@592: 		{
dvander@592: 			pTimer->m_InExec = true;
dvander@592: 			res = pTimer->m_Listener->OnTimer(pTimer, pTimer->m_pData);
dvander@592: 			if (pTimer->m_KillMe || (res == Pl_Stop))
dvander@592: 			{
dvander@592: 				pTimer->m_Listener->OnTimerEnd(pTimer, pTimer->m_pData);
dvander@592: 				iter = m_LoopTimers.erase(iter);
dvander@592: 				m_FreeTimers.push(pTimer);
dvander@592: 				continue;
dvander@592: 			}
dvander@592: 			pTimer->m_InExec = false;
dvander@727: 			pTimer->m_ToExec = curtime + pTimer->m_Interval;
dvander@592: 		}
dvander@592: 		iter++;
dvander@592: 	}
dvander@592: 
dvander@727: 	m_LastExecTime = curtime;
dvander@592: }
dvander@592: 
dvander@616: ITimer *TimerSystem::CreateTimer(ITimedEvent *pCallbacks, float fInterval, void *pData, int flags)
dvander@592: {
dvander@592: 	ITimer *pTimer;
dvander@592: 	TimerIter iter;
dvander@727: 	float to_exec = GetSimulatedTime() + fInterval;
dvander@592: 
dvander@592: 	if (m_FreeTimers.empty())
dvander@592: 	{
dvander@592: 		pTimer = new ITimer;
dvander@592: 	} else {
dvander@592: 		pTimer = m_FreeTimers.front();
dvander@592: 		m_FreeTimers.pop();
dvander@592: 	}
dvander@592: 
dvander@592: 	pTimer->Initialize(pCallbacks, fInterval, to_exec, pData, flags);
dvander@592: 
dvander@592: 	if (flags & TIMER_FLAG_REPEAT)
dvander@592: 	{
dvander@592: 		m_LoopTimers.push_back(pTimer);
dvander@592: 		goto return_timer;
dvander@592: 	}
dvander@592: 
dvander@592: 	if (m_SingleTimers.size() >= 1)
dvander@592: 	{
dvander@592: 		iter = --m_SingleTimers.end();
dvander@592: 		if ((*iter)->m_ToExec <= to_exec)
dvander@592: 		{
dvander@592: 			goto insert_end;
dvander@592: 		}
dvander@592: 	}
dvander@592: 
dvander@592: 	for (iter=m_SingleTimers.begin(); iter!=m_SingleTimers.end(); iter++)
dvander@592: 	{
dvander@592: 		if ((*iter)->m_ToExec >= to_exec)
dvander@592: 		{
dvander@592: 			m_SingleTimers.insert(iter, pTimer);
dvander@592: 			goto return_timer;
dvander@592: 		}
dvander@592: 	}
dvander@592: 
dvander@592: insert_end:
dvander@592: 	m_SingleTimers.push_back(pTimer);
dvander@592: 
dvander@592: return_timer:
dvander@592: 	return pTimer;
dvander@592: }
dvander@592: 
dvander@616: void TimerSystem::FireTimerOnce(ITimer *pTimer, bool delayExec)
dvander@592: {
dvander@592: 	ResultType res;
dvander@592: 
dvander@592: 	if (pTimer->m_InExec)
dvander@592: 	{
dvander@592: 		return;
dvander@592: 	}
dvander@592: 
dvander@592: 	pTimer->m_InExec = true;
dvander@592: 	res = pTimer->m_Listener->OnTimer(pTimer, pTimer->m_pData);
dvander@592: 
dvander@592: 	if (!(pTimer->m_Flags & TIMER_FLAG_REPEAT))
dvander@592: 	{
dvander@592: 		pTimer->m_Listener->OnTimerEnd(pTimer, pTimer->m_pData);
dvander@592: 		m_SingleTimers.remove(pTimer);
dvander@592: 		m_FreeTimers.push(pTimer);
dvander@592: 	} else {
faluco@612: 		if ((res != Pl_Stop) && !pTimer->m_KillMe)
dvander@592: 		{
faluco@612: 			if (delayExec)
faluco@612: 			{
dvander@727: 				pTimer->m_ToExec = GetSimulatedTime() + pTimer->m_Interval;
faluco@612: 			}
dvander@592: 			pTimer->m_InExec = false;
dvander@592: 			return;
dvander@592: 		}
dvander@592: 		pTimer->m_Listener->OnTimerEnd(pTimer, pTimer->m_pData);
dvander@592: 		m_LoopTimers.remove(pTimer);
dvander@592: 		m_FreeTimers.push(pTimer);
dvander@592: 	}
dvander@592: }
dvander@592: 
dvander@616: void TimerSystem::KillTimer(ITimer *pTimer)
dvander@592: {
dvander@592: 	TimerList *pList;
dvander@592: 
dvander@592: 	if (pTimer->m_KillMe)
dvander@592: 	{
dvander@592: 		return;
dvander@592: 	}
dvander@592: 
dvander@592: 	if (pTimer->m_InExec)
dvander@592: 	{
dvander@592: 		pTimer->m_KillMe = true;
dvander@592: 		return;
dvander@592: 	}
dvander@592: 
dvander@592: 	pTimer->m_InExec = true; /* The timer it's not really executed but this check needs to be done */
dvander@592: 	pTimer->m_Listener->OnTimerEnd(pTimer, pTimer->m_pData);
dvander@592: 
dvander@592: 	pList = (pTimer->m_Flags & TIMER_FLAG_REPEAT) ? &m_LoopTimers : &m_SingleTimers;
dvander@592: 
dvander@592: 	pList->remove(pTimer);
dvander@592: 	m_FreeTimers.push(pTimer);
dvander@592: }
dvander@592: 
dvander@1108: CStack<ITimer *> s_tokill;
dvander@1142: void TimerSystem::MapChange(bool real_mapchange)
dvander@592: {
dvander@592: 	ITimer *pTimer;
dvander@592: 	TimerIter iter;
dvander@592: 
dvander@592: 	for (iter=m_SingleTimers.begin(); iter!=m_SingleTimers.end(); iter++)
dvander@592: 	{
dvander@592: 		pTimer = (*iter);
dvander@1142: 		if (real_mapchange && (pTimer->m_Flags & TIMER_FLAG_NO_MAPCHANGE))
dvander@1108: 		{
dvander@1108: 			s_tokill.push(pTimer);
dvander@1108: 		} else {
dvander@1108: 			pTimer->m_ToExec = pTimer->m_ToExec - m_LastExecTime + GetSimulatedTime();
dvander@1108: 		}
dvander@592: 	}
dvander@592: 
dvander@592: 	for (iter=m_LoopTimers.begin(); iter!=m_LoopTimers.end(); iter++)
dvander@592: 	{
dvander@592: 		pTimer = (*iter);
dvander@1142: 		if (real_mapchange && (pTimer->m_Flags & TIMER_FLAG_NO_MAPCHANGE))
dvander@1108: 		{
dvander@1108: 			s_tokill.push(pTimer);
dvander@1108: 		} else {
dvander@1108: 			pTimer->m_ToExec = pTimer->m_ToExec - m_LastExecTime + GetSimulatedTime();
dvander@1108: 		}
dvander@1108: 	}
dvander@1108: 
dvander@1108: 	while (!s_tokill.empty())
dvander@1108: 	{
dvander@1108: 		KillTimer(s_tokill.front());
dvander@1108: 		s_tokill.pop();
dvander@592: 	}
dvander@727: 
dvander@727: 	m_LastExecTime = GetSimulatedTime();
dvander@592: }