OpenE2K
/
rust
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

rt: Add some lock_and_signal assertions 

Assert that locks are not reentered on the same thread, unlocked by a
different thread, or deleted while locked.
This commit is contained in:
Chris Peterson 2012-02-19 23:15:35 -08:00
parent 9f49293232
commit fed81c2cfc
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/rt/sync/lock_and_signal.cpp
View File

@ -43,6 +43,7 @@ lock_and_signal::lock_and_signal()
#endif
lock_and_signal::~lock_and_signal() {
assert(_holding_thread == INVALID_THREAD);
#if defined(__WIN32__)
CloseHandle(_event);
DeleteCriticalSection(&_cs);
@ -53,6 +54,7 @@ lock_and_signal::~lock_and_signal() {
}
void lock_and_signal::lock() {
assert(!lock_held_by_current_thread());
#if defined(__WIN32__)
EnterCriticalSection(&_cs);
_holding_thread = GetCurrentThreadId();
@ -63,6 +65,7 @@ void lock_and_signal::lock() {
}
void lock_and_signal::unlock() {
assert(lock_held_by_current_thread());
_holding_thread = INVALID_THREAD;
#if defined(__WIN32__)
LeaveCriticalSection(&_cs);
@ -81,9 +84,11 @@ void lock_and_signal::wait() {
LeaveCriticalSection(&_cs);
WaitForSingleObject(_event, INFINITE);
EnterCriticalSection(&_cs);
assert(_holding_thread == INVALID_THREAD);
_holding_thread = GetCurrentThreadId();
#else
CHECKED(pthread_cond_wait(&_cond, &_mutex));
assert(_holding_thread == INVALID_THREAD);
_holding_thread = pthread_self();
#endif
}