82 lines
2.1 KiB
C++
82 lines
2.1 KiB
C++
#include <thread/thtimer.hpp>
|
|
|
|
ThreadTimer::ThreadTimer(void)
|
|
: mMinResolution(0), mIsOkay(FALSE), mHasTimedEvent(FALSE), mTimerID(0), mIsFirstBreak(TRUE)
|
|
{
|
|
if(::timeGetDevCaps(&mTimerCapability,sizeof(TIMECAPS)))return;
|
|
mMinResolution=mTimerCapability.wPeriodMin;
|
|
if(::timeBeginPeriod(mMinResolution))return;
|
|
mIsOkay=TRUE;
|
|
}
|
|
|
|
ThreadTimer::ThreadTimer(WORD minResolution)
|
|
: mMinResolution(minResolution), mIsOkay(FALSE), mHasTimedEvent(FALSE), mTimerID(0), mIsFirstBreak(TRUE)
|
|
{
|
|
if(::timeGetDevCaps(&mTimerCapability,sizeof(TIMECAPS)))return;
|
|
if(mMinResolution<mTimerCapability.wPeriodMin)mMinResolution=mTimerCapability.wPeriodMin;
|
|
if(::timeBeginPeriod(mMinResolution))return;
|
|
mIsOkay=TRUE;
|
|
}
|
|
|
|
ThreadTimer::~ThreadTimer()
|
|
{
|
|
if(mIsOkay){stopTimer();::timeEndPeriod(mMinResolution);}
|
|
mTimerMutex.requestMutex();
|
|
mTimerMutex.releaseMutex();
|
|
}
|
|
|
|
WORD ThreadTimer::startTimer(UINT deltaTime)
|
|
{
|
|
if(!mIsOkay)return FALSE;
|
|
if(mHasTimedEvent)return FALSE;
|
|
isFirstBreak(TRUE);
|
|
if(0==(mTimerID=::timeSetEvent(deltaTime,mMinResolution,(LPTIMECALLBACK)timerProc,(DWORD)this,TIME_PERIODIC)))return FALSE;
|
|
mHasTimedEvent=TRUE;
|
|
return TRUE;
|
|
}
|
|
|
|
WORD ThreadTimer::stopTimer(void)
|
|
{
|
|
WORD returnCode(FALSE);
|
|
|
|
if(!mIsOkay)return returnCode;
|
|
if(!mHasTimedEvent)return returnCode;
|
|
if(!::timeKillEvent(mTimerID))returnCode=TRUE;
|
|
isFirstBreak(FALSE);
|
|
mHasTimedEvent=FALSE;
|
|
mTimerID=FALSE;
|
|
return returnCode;
|
|
}
|
|
|
|
void CALLBACK ThreadTimer::timerProc(UINT /*wTimerID*/,UINT /*mMsg*/,DWORD dwUser,DWORD /*dummyOne*/,DWORD /*dummyTwo*/)
|
|
{
|
|
CallbackData callbackData;
|
|
|
|
if(!((ThreadTimer*)dwUser))return;
|
|
((ThreadTimer*)dwUser)->mTimerMutex.requestMutex();
|
|
if(((ThreadTimer*)dwUser)->isFirstBreak())
|
|
{
|
|
((ThreadTimer*)dwUser)->isFirstBreak(FALSE);
|
|
((ThreadTimer*)dwUser)->timerStarted();
|
|
}
|
|
if(((CallbackData::ReturnType)FALSE)==((ThreadTimer*)dwUser)->mCallbackPointer.callback(callbackData))
|
|
{
|
|
((ThreadTimer*)dwUser)->timerStopped();
|
|
((ThreadTimer*)dwUser)->stopTimer();
|
|
}
|
|
((ThreadTimer*)dwUser)->mTimerMutex.releaseMutex();
|
|
return;
|
|
}
|
|
|
|
// virtuals
|
|
|
|
void ThreadTimer::timerStarted(void)
|
|
{
|
|
return;
|
|
}
|
|
|
|
void ThreadTimer::timerStopped(void)
|
|
{
|
|
return;
|
|
}
|