diff options
author | Alan Conway <aconway@apache.org> | 2006-11-13 19:28:23 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2006-11-13 19:28:23 +0000 |
commit | 922d1249a1a48c13a2e37f1efc1b3204ca5e9813 (patch) | |
tree | 0a5284b22967b19a97d02284d3bafe2ae9d79df0 /cpp/src/qpid/sys/Monitor.h | |
parent | fc5ad32cc8f2d4d793c0cf79382755e9fca2357c (diff) | |
download | qpid-python-922d1249a1a48c13a2e37f1efc1b3204ca5e9813.tar.gz |
EventChannel classes, start of epoll-based posix implementation.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@474452 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/sys/Monitor.h')
-rw-r--r-- | cpp/src/qpid/sys/Monitor.h | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/cpp/src/qpid/sys/Monitor.h b/cpp/src/qpid/sys/Monitor.h index 54956777de..a3abe37748 100644 --- a/cpp/src/qpid/sys/Monitor.h +++ b/cpp/src/qpid/sys/Monitor.h @@ -164,46 +164,46 @@ struct PODMutex void PODMutex::lock() { - CHECK(pthread_mutex_lock(&mutex)); + CHECK0(pthread_mutex_lock(&mutex)); } void PODMutex::unlock() { - CHECK(pthread_mutex_unlock(&mutex)); + CHECK0(pthread_mutex_unlock(&mutex)); } void PODMutex::trylock() { - CHECK(pthread_mutex_trylock(&mutex)); + CHECK0(pthread_mutex_trylock(&mutex)); } Mutex::Mutex() { - CHECK(pthread_mutex_init(&mutex, 0)); + CHECK0(pthread_mutex_init(&mutex, 0)); } Mutex::~Mutex(){ - CHECK(pthread_mutex_destroy(&mutex)); + CHECK0(pthread_mutex_destroy(&mutex)); } void Mutex::lock() { - CHECK(pthread_mutex_lock(&mutex)); + CHECK0(pthread_mutex_lock(&mutex)); } void Mutex::unlock() { - CHECK(pthread_mutex_unlock(&mutex)); + CHECK0(pthread_mutex_unlock(&mutex)); } void Mutex::trylock() { - CHECK(pthread_mutex_trylock(&mutex)); + CHECK0(pthread_mutex_trylock(&mutex)); } Monitor::Monitor() { - CHECK(pthread_cond_init(&condition, 0)); + CHECK0(pthread_cond_init(&condition, 0)); } Monitor::~Monitor() { - CHECK(pthread_cond_destroy(&condition)); + CHECK0(pthread_cond_destroy(&condition)); } void Monitor::wait() { - CHECK(pthread_cond_wait(&condition, &mutex)); + CHECK0(pthread_cond_wait(&condition, &mutex)); } bool Monitor::wait(int64_t nsecs){ @@ -211,17 +211,17 @@ bool Monitor::wait(int64_t nsecs){ int status = pthread_cond_timedwait(&condition, &mutex, &t.getTimespec()); if(status != 0) { if (errno == ETIMEDOUT) return false; - CHECK(status); + CHECK0(status); } return true; } void Monitor::notify(){ - CHECK(pthread_cond_signal(&condition)); + CHECK0(pthread_cond_signal(&condition)); } void Monitor::notifyAll(){ - CHECK(pthread_cond_broadcast(&condition)); + CHECK0(pthread_cond_broadcast(&condition)); } |