actions/itgmania212121
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

add checkpoints, etc

Browse Source
This commit is contained in:
Glenn Maynard
2005-05-03 22:15:46 +00:00
parent d67bc9dd09
commit b9e16ed9c6
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
stepmania/src/RageUtil_WorkerThread.cpp
+11
View File
@@ -1,5 +1,6 @@
#include "global.h" #include "global.h"
#include "RageUtil_WorkerThread.h" #include "RageUtil_WorkerThread.h"
#include "RageUtil.h"
#include "RageLog.h" #include "RageLog.h"
WorkerThread::WorkerThread( const CString &sName ): WorkerThread::WorkerThread( const CString &sName ):
@@ -140,7 +141,11 @@ void WorkerThread::WorkerMain()
{ {
/* Handle the request. */ /* Handle the request. */
if( iRequest != REQ_SHUTDOWN ) if( iRequest != REQ_SHUTDOWN )
{
CHECKPOINT_M( ssprintf("HandleRequest(%i)", iRequest) );
HandleRequest( iRequest ); HandleRequest( iRequest );
CHECKPOINT_M( ssprintf("HandleRequest(%i) done", iRequest) );
}
/* Lock the mutex, to keep DoRequest where it is (if it's still running). */ /* Lock the mutex, to keep DoRequest where it is (if it's still running). */
/* The request is finished. If it timed out, clear the timeout flag and /* The request is finished. If it timed out, clear the timeout flag and
@@ -149,6 +154,8 @@ void WorkerThread::WorkerMain()
if( m_bTimedOut ) if( m_bTimedOut )
{ {
LOG->Trace( "Request %i timed out", iRequest );
/* The calling thread timed out. It's already gone and moved on, so /* The calling thread timed out. It's already gone and moved on, so
* it's our responsibility to clean up. No new requests will come in * it's our responsibility to clean up. No new requests will come in
* until we clear m_bTimedOut, so we can safely unlock and clean up. */ * until we clear m_bTimedOut, so we can safely unlock and clean up. */
@@ -158,9 +165,13 @@ void WorkerThread::WorkerMain()
/* Clear the time-out flag, indicating that we can work again. */ /* Clear the time-out flag, indicating that we can work again. */
m_bTimedOut = false; m_bTimedOut = false;
CHECKPOINT;
} }
else else
{ {
CHECKPOINT_M( ssprintf("HandleRequest(%i) OK", iRequest) );
m_bRequestFinished = true; m_bRequestFinished = true;
/* We're finished. Wake up the requester. */ /* We're finished. Wake up the requester. */