Changeset 4:d061ad3be7fd in xplcommon for src

Timestamp:

12/27/12 18:52:39 (12 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

Added support for a waitable event for POSIX and a test program

Location:

src/xplcommon

Files:

• Makefile.am (modified) (1 diff)
• WaitableEvent.h (added)
• Waiter.h (added)
• posix/Makefile.am (modified) (2 diffs)
• posix/Thread.h (modified) (3 diffs)
• posix/Waitable.cc (modified) (1 diff)
• posix/Waitable.h (modified) (1 diff)
• posix/WaitableEvent.cc (added)
• posix/WaitableEvent.h (added)

src/xplcommon/Makefile.am

@@ -22 +22 @@
 include_xplcommon_HEADERS=\
         config.h        \
-        Thread.h
+        Thread.h        \
+        Waiter.h        \
+        WaitableEvent.h

src/xplcommon/posix/Makefile.am

@@ -4 +4 @@
         Thread.cc               \
         Waitable.cc     \
-        Waiter.cc
+        Waiter.cc       \
+        WaitableEvent.cc
 
 include_xplcommon_posixdir=$(includedir)/xplcommon/posix
@@ -10 +11 @@
         Thread.h                \
         Waitable.h              \
-        Waiter.h
+        Waiter.h                \
+        WaitableEvent.h

src/xplcommon/posix/Thread.h

@@ -33 +33 @@
 
 #include <pthread.h>
+#include <unistd.h>
 
 //------------------------------------------------------------------------------
@@ -45 +46 @@
 class Thread
 {
+public:
+    /**
+     * Sleep for the given number of milliseconds.
+     */
+    static void sleep(unsigned millis);
+
 private:
     /**
@@ -84 +91 @@
 //------------------------------------------------------------------------------
 
+inline void Thread::sleep(unsigned millis)
+{
+    usleep(static_cast<useconds_t>(millis)*1000);
+}
+
+//------------------------------------------------------------------------------
+
 inline Thread::~Thread()
 {

src/xplcommon/posix/Waitable.cc

@@ -34 +34 @@
 #include "Waiter.h"
 
+#include <fcntl.h>
+
 //------------------------------------------------------------------------------
 
 using xplcommon::posix::Waitable;
+
+//------------------------------------------------------------------------------
+
+void Waitable::setNonBlocking(int fd)
+{
+    fcntl(fd, F_SETFL, fcntl(fd, F_GETFL) | O_NONBLOCK);
+}
 
 //------------------------------------------------------------------------------

src/xplcommon/posix/Waitable.h

@@ -47 +47 @@
 class Waitable
 {
+public:
+    /**
+     * Set the given file descriptor to non-blocking.
+     */
+    static void setNonBlocking(int fd);
+
 protected:
     /**