Changeset 8:dba41f33ddce in xplcommon for src/xplcommon/posix/WaitableEvent.cc

Timestamp:

12/29/12 08:01:50 (11 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

Clarified the blocking and non-blocking behaviour and extended the test program to test both

File:

• src/xplcommon/posix/WaitableEvent.cc (modified) (4 diffs)

src/xplcommon/posix/WaitableEvent.cc

@@ -48 +48 @@
 
 WaitableEvent::WaitableEvent(Waiter* waiter) :
-    Waitable(waiter, eventfd(0, EFD_NONBLOCK), POLLIN)
+    Waitable(waiter, eventfd(0, (waiter==0) ? 0 : EFD_NONBLOCK), POLLIN),
+    fired(false)
 {
     assert(fd>=0);
@@ -67 +68 @@
     if (write(fd, &one, sizeof(one))<0) {
         if (errno!=EAGAIN) {
-            perror("xplcommon::posix::WaitableEvent::fire: write");
-            assert(0);
+            setErrorCode(errno);
         }
     }
@@ -77 +77 @@
 bool WaitableEvent::check()
 {
-    if (fired) {
+    if (doCheck()) {
         fired = false;
         return true;
@@ -97 +97 @@
 {
     if ((events&POLLIN)==POLLIN) {
-        uint64_t value = 0;
-        if (read(fd, &value, sizeof(value))<0) {
-            if (errno!=EAGAIN) {
-                perror("xplcommon::posix::WaitableEvent::handleEvents: read");
-                assert(0);
-            }
-        } else {
-            fired = value>0;
+        doCheck();
+    }
+}
+
+//------------------------------------------------------------------------------
+
+bool WaitableEvent::doCheck(bool fromHandleEvents)
+{
+    if (failed()) return false;
+    if (!fromHandleEvents && fired) return true;
+
+    uint64_t value = 0;
+    if (read(fd, &value, sizeof(value))<0) {
+        if (errno!=EAGAIN) {
+            setErrorCode(errno);
         }
+    } else {
+        fired = fired || value>0;
     }
+
+    return fired;
 }