King_DuckZ/Loki
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Replaced local Checker with Loki::CheckFor.

Browse source 
git-svn-id: svn://svn.code.sf.net/p/loki-lib/code/trunk@1162 7ec92016-0320-0410-acc4-a06ded1c099a
This commit is contained in:
rich_sposato 2011-10-22 00:20:09 +00:00
parent 143a7f6d1c
commit 0abd979412
2 changed files with 22 additions and 35 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
include/loki/LevelMutex.h
View file

@ -51,6 +51,7 @@
#endif #endif
#include <loki/ThreadLocal.h> // Include Loki's form of thread_local declaration. #include <loki/ThreadLocal.h> // Include Loki's form of thread_local declaration.
#include <loki/Checker.h> // Needed to check class invariants.
#if !defined( LOKI_THREAD_LOCAL ) #if !defined( LOKI_THREAD_LOCAL )
#warning "Your compiler will not allow Loki::LevelMutex." #warning "Your compiler will not allow Loki::LevelMutex."
@ -264,26 +265,12 @@ public:
protected: protected:
/** @class Checker Performs validity check on mutex to insure no class invariants /** @note CheckFor performs validity checking in many functions to determine if the
were violated inside any member function. This class only gets used in debug code violated any invariants, if any content changed, or if the function threw an
builds, and any instance of it gets optimized away in release builds. A checker exception. The checkers only get used in debug builds, and get optimized away in
is created inside many of member functions so that it's destructor gets called release builds.
when the function exits. It determines if any class invariants were violated
during the function call.
*/ */
class Checker typedef ::Loki::CheckFor< LevelMutexInfo > CheckFor;
{
public:
inline explicit Checker( const volatile LevelMutexInfo * mutex ) :
m_mutex( mutex ) { Check(); }
inline ~Checker( void ) { Check(); }
inline bool Check( void ) const { return m_mutex->IsValid(); }
private:
Checker( void );
Checker( const Checker & );
Checker & operator = ( const Checker & );
const volatile LevelMutexInfo * m_mutex;
};
/** @class MutexUndoer /** @class MutexUndoer
Undoes actions by MultiLock if an exception occurs. It keeps track of Undoes actions by MultiLock if an exception occurs. It keeps track of
@ -778,7 +765,7 @@ public:
virtual MutexErrors::Type TryLock( void ) volatile virtual MutexErrors::Type TryLock( void ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::Invariants checker( this, &IsValid() ); (void)checker; )
MutexErrors::Type result = LevelMutexInfo::PreLockCheck( true ); MutexErrors::Type result = LevelMutexInfo::PreLockCheck( true );
if ( MutexErrors::Success == result ) if ( MutexErrors::Success == result )
@ -799,7 +786,7 @@ public:
virtual MutexErrors::Type Lock( void ) volatile virtual MutexErrors::Type Lock( void ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::Invariants checker( this, &IsValid() ); (void)checker; )
MutexErrors::Type result = LevelMutexInfo::PreLockCheck( false ); MutexErrors::Type result = LevelMutexInfo::PreLockCheck( false );
if ( MutexErrors::Success == result ) if ( MutexErrors::Success == result )
@ -818,7 +805,7 @@ public:
virtual MutexErrors::Type Lock( unsigned int milliSeconds ) volatile virtual MutexErrors::Type Lock( unsigned int milliSeconds ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::Invariants checker( this, &IsValid() ); (void)checker; )
MutexErrors::Type result = LevelMutexInfo::PreLockCheck( false ); MutexErrors::Type result = LevelMutexInfo::PreLockCheck( false );
if ( MutexErrors::Success == result ) if ( MutexErrors::Success == result )
@ -853,7 +840,7 @@ public:
virtual MutexErrors::Type Unlock( void ) volatile virtual MutexErrors::Type Unlock( void ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::Invariants checker( this, &IsValid() ); (void)checker; )
MutexErrors::Type result = LevelMutexInfo::PreUnlockCheck(); MutexErrors::Type result = LevelMutexInfo::PreUnlockCheck();
if ( MutexErrors::Success == result ) if ( MutexErrors::Success == result )
@ -898,7 +885,7 @@ private:
*/ */
virtual MutexErrors::Type LockThis( void ) volatile virtual MutexErrors::Type LockThis( void ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::Invariants checker( this, &IsValid() ); (void)checker; )
assert( this != LevelMutexInfo::GetCurrentMutex() ); assert( this != LevelMutexInfo::GetCurrentMutex() );
const MutexErrors::Type result = m_mutex.Lock(); const MutexErrors::Type result = m_mutex.Lock();
@ -918,7 +905,7 @@ private:
*/ */
virtual MutexErrors::Type LockThis( unsigned int milliSeconds ) volatile virtual MutexErrors::Type LockThis( unsigned int milliSeconds ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::Invariants checker( this, &IsValid() ); (void)checker; )
clock_t timeOut = clock() + milliSeconds; clock_t timeOut = clock() + milliSeconds;
while ( clock() < timeOut ) while ( clock() < timeOut )
@ -943,7 +930,7 @@ private:
*/ */
virtual MutexErrors::Type UnlockThis( void ) volatile virtual MutexErrors::Type UnlockThis( void ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::Invariants checker( this, &IsValid() ); (void)checker; )
assert( NULL != LevelMutexInfo::GetCurrentMutex() ); assert( NULL != LevelMutexInfo::GetCurrentMutex() );
if ( 1 < LevelMutexInfo::GetLockCount() ) if ( 1 < LevelMutexInfo::GetLockCount() )

18
src/LevelMutex.cpp
View file

@ -417,7 +417,7 @@ MutexErrors::Type LevelMutexInfo::MultiLock( MutexContainer & mutexes,
if ( 0 == milliSeconds ) if ( 0 == milliSeconds )
return MultiLock( mutexes ); return MultiLock( mutexes );
const std::size_t count = mutexes.size(); const std::size_t count = mutexes.size();
if ( 0 == count ) if ( 0 == count )
return MutexErrors::EmptyContainer; return MutexErrors::EmptyContainer;
@ -592,7 +592,7 @@ void LevelMutexInfo::DecrementCount( void ) volatile
bool LevelMutexInfo::IsLockedByCurrentThread( void ) const volatile bool LevelMutexInfo::IsLockedByCurrentThread( void ) const volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::NoChangeOrThrow checker( this, &IsValid() ); (void)checker; )
if ( !IsLocked() ) if ( !IsLocked() )
return false; return false;
@ -610,7 +610,7 @@ bool LevelMutexInfo::IsLockedByCurrentThread( void ) const volatile
bool LevelMutexInfo::IsRecentLock( void ) const volatile bool LevelMutexInfo::IsRecentLock( void ) const volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::NoChangeOrThrow checker( this, &IsValid() ); (void)checker; )
if ( 0 == m_count ) if ( 0 == m_count )
return false; return false;
@ -631,7 +631,7 @@ bool LevelMutexInfo::IsRecentLock( void ) const volatile
bool LevelMutexInfo::IsRecentLock( std::size_t count ) const volatile bool LevelMutexInfo::IsRecentLock( std::size_t count ) const volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::NoChangeOrThrow checker( this, &IsValid() ); (void)checker; )
if ( 0 == count ) if ( 0 == count )
return false; return false;
@ -651,7 +651,7 @@ bool LevelMutexInfo::IsRecentLock( std::size_t count ) const volatile
bool LevelMutexInfo::IsLockedByAnotherThread( void ) const volatile bool LevelMutexInfo::IsLockedByAnotherThread( void ) const volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::NoChangeOrThrow checker( this, &IsValid() ); (void)checker; )
if ( !IsLocked() ) if ( !IsLocked() )
return false; return false;
@ -666,7 +666,7 @@ bool LevelMutexInfo::IsLockedByAnotherThread( void ) const volatile
void LevelMutexInfo::PostLock( void ) volatile void LevelMutexInfo::PostLock( void ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::NoThrow checker( this, &IsValid() ); (void)checker; )
assert( 0 == m_count ); assert( 0 == m_count );
assert( nullptr == m_previous ); assert( nullptr == m_previous );
assert( this != s_currentMutex ); assert( this != s_currentMutex );
@ -681,7 +681,7 @@ void LevelMutexInfo::PostLock( void ) volatile
void LevelMutexInfo::PreUnlock( void ) volatile void LevelMutexInfo::PreUnlock( void ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::NoThrow checker( this, &IsValid() ); (void)checker; )
assert( 1 == m_count ); assert( 1 == m_count );
assert( nullptr != s_currentMutex ); assert( nullptr != s_currentMutex );
assert( this == s_currentMutex ); assert( this == s_currentMutex );
@ -696,7 +696,7 @@ void LevelMutexInfo::PreUnlock( void ) volatile
MutexErrors::Type LevelMutexInfo::PreLockCheck( bool forTryLock ) volatile MutexErrors::Type LevelMutexInfo::PreLockCheck( bool forTryLock ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::NoThrow checker( this, &IsValid() ); (void)checker; )
const unsigned int currentLevel = GetCurrentThreadsLevel(); const unsigned int currentLevel = GetCurrentThreadsLevel();
if ( currentLevel < LevelMutexInfo::GetLevel() ) if ( currentLevel < LevelMutexInfo::GetLevel() )
@ -730,7 +730,7 @@ MutexErrors::Type LevelMutexInfo::PreLockCheck( bool forTryLock ) volatile
MutexErrors::Type LevelMutexInfo::PreUnlockCheck( void ) volatile MutexErrors::Type LevelMutexInfo::PreUnlockCheck( void ) volatile
{ {
LOKI_MUTEX_DEBUG_CODE( Checker checker( this ); (void)checker; ) LOKI_MUTEX_DEBUG_CODE( CheckFor::NoThrow checker( this, &IsValid() ); (void)checker; )
if ( 0 == m_count ) if ( 0 == m_count )
return MutexErrors::WasntLocked; return MutexErrors::WasntLocked;