Changeset 15 in flair-src for trunk/lib/FlairCore/src/ConditionVariable_impl.cpp

Timestamp:

04/08/16 15:40:57 (8 years ago)

Author:

Bayard Gildas

Message:

sources reformatted with flair-format-dir script

File:

• trunk/lib/FlairCore/src/ConditionVariable_impl.cpp (modified) (1 diff)

trunk/lib/FlairCore/src/ConditionVariable_impl.cpp

@@ -24 +24 @@
 using namespace flair::core;
 
-ConditionVariable_impl::ConditionVariable_impl(ConditionVariable* self) {
-    this->self=self;
-    int status;
+ConditionVariable_impl::ConditionVariable_impl(ConditionVariable *self) {
+  this->self = self;
+  int status;
 
 #ifdef __XENO__
-    status=rt_cond_create(&m_ResumeCond,NULL);
+  status = rt_cond_create(&m_ResumeCond, NULL);
 #else
-    status=pthread_cond_init(&m_ResumeCond, 0);
+  status = pthread_cond_init(&m_ResumeCond, 0);
 #endif
-    if(status!=0) self->Err("error creating condition variable (%s)\n",strerror(-status));
+  if (status != 0)
+    self->Err("error creating condition variable (%s)\n", strerror(-status));
 }
 
 ConditionVariable_impl::~ConditionVariable_impl() {
-    int status;
+  int status;
 
 #ifdef __XENO__
-    status=rt_cond_delete(&m_ResumeCond);
+  status = rt_cond_delete(&m_ResumeCond);
 #else
-    status=pthread_cond_destroy(&m_ResumeCond);
+  status = pthread_cond_destroy(&m_ResumeCond);
 #endif
-    if(status!=0) self->Err("error destroying condition variable (%s)\n",strerror(-status));
+  if (status != 0)
+    self->Err("error destroying condition variable (%s)\n", strerror(-status));
 }
 
 void ConditionVariable_impl::CondWait(void) {
-    int status;
+  int status;
 #ifdef __XENO__
-    status=rt_cond_wait(&m_ResumeCond, &self->Mutex::pimpl_->mutex,TM_INFINITE);
+  status =
+      rt_cond_wait(&m_ResumeCond, &self->Mutex::pimpl_->mutex, TM_INFINITE);
 #else
-    status=pthread_cond_wait(&m_ResumeCond, &self->Mutex::pimpl_->mutex);
+  status = pthread_cond_wait(&m_ResumeCond, &self->Mutex::pimpl_->mutex);
 #endif
-    if(status!=0) self->Err("error (%s)\n",strerror(-status));
+  if (status != 0)
+    self->Err("error (%s)\n", strerror(-status));
 }
 
 bool ConditionVariable_impl::CondWaitUntil(Time date) {
-    int status;
+  int status;
 #ifdef __XENO__
-    status=rt_cond_wait_until(&m_ResumeCond, &self->Mutex::pimpl_->mutex,date);
+  status = rt_cond_wait_until(&m_ResumeCond, &self->Mutex::pimpl_->mutex, date);
 #else
-    struct timespec restrict;
-    restrict.tv_sec=date/1000000000;
-    restrict.tv_nsec=date%1000000000;
-    status=pthread_cond_timedwait(&m_ResumeCond, &self->Mutex::pimpl_->mutex,&restrict);
+  struct timespec restrict;
+  restrict.tv_sec = date / 1000000000;
+  restrict.tv_nsec = date % 1000000000;
+  status = pthread_cond_timedwait(&m_ResumeCond, &self->Mutex::pimpl_->mutex,
+                                  &restrict);
 #endif
-    if (status==0) return true;
-    if(status!=ETIMEDOUT) self->Err("error (%s)\n",strerror(-status));
-    return false;
+  if (status == 0)
+    return true;
+  if (status != ETIMEDOUT)
+    self->Err("error (%s)\n", strerror(-status));
+  return false;
 }
 
 void ConditionVariable_impl::CondSignal(void) {
-     int status;
+  int status;
 #ifdef __XENO__
-    status=rt_cond_signal(&m_ResumeCond);
+  status = rt_cond_signal(&m_ResumeCond);
 #else
-    status=pthread_cond_signal(&m_ResumeCond);
+  status = pthread_cond_signal(&m_ResumeCond);
 #endif
-    if(status!=0) self->Err("error (%s)\n",strerror(-status));
+  if (status != 0)
+    self->Err("error (%s)\n", strerror(-status));
 }