summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/Monitor.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2006-11-13 19:28:23 +0000
committerAlan Conway <aconway@apache.org>2006-11-13 19:28:23 +0000
commit922d1249a1a48c13a2e37f1efc1b3204ca5e9813 (patch)
tree0a5284b22967b19a97d02284d3bafe2ae9d79df0 /cpp/src/qpid/sys/Monitor.h
parentfc5ad32cc8f2d4d793c0cf79382755e9fca2357c (diff)
downloadqpid-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.h28
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));
}