From 922d1249a1a48c13a2e37f1efc1b3204ca5e9813 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Mon, 13 Nov 2006 19:28:23 +0000 Subject: 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 --- cpp/src/qpid/sys/Monitor.h | 28 ++++++++++++++-------------- 1 file changed, 14 insertions(+), 14 deletions(-) (limited to 'cpp/src/qpid/sys/Monitor.h') 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)); } -- cgit v1.2.1