Changeset 29:54c2d451f8a0 in xplcommon for src

Timestamp:

01/02/13 11:37:15 (12 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

Implemented a blocking stream and a corresponding trst program

Location:

src/xplcommon

Files:

• BlockingStream.cc (added)
• BlockingStream.h (added)
• Buffer.h (modified) (2 diffs)
• BufferedStream.h (modified) (1 diff)
• Makefile.am (modified) (3 diffs)
• posix/ReadingBuffer.cc (modified) (1 diff)
• posix/Waiter.cc (modified) (1 diff)

src/xplcommon/Buffer.h

@@ -96 +96 @@
 
     /**
+     * Get whether the buffer is empty or not.
+     */
+    bool isEmpty() const;
+
+    /**
      * Get the available capacity in the buffer.
      */
@@ -172 +177 @@
 {
     return length;
+}
+
+//------------------------------------------------------------------------------
+
+inline bool Buffer::isEmpty() const
+{
+    return length==0;
 }
 

src/xplcommon/BufferedStream.h

@@ -93 +93 @@
 //------------------------------------------------------------------------------
 
-// #include "win32/BufferedStream.h"
+#include "win32/BufferedStream.h"
 
-// namespace xplcommon { typedef win32::BufferedStream BufferedStream; }
+namespace xplcommon { typedef win32::BufferedStream BufferedStream; }
 
 //------------------------------------------------------------------------------

src/xplcommon/Makefile.am

@@ -10 +10 @@
 
 libxplcommon_la_SOURCES= \
+        PseudoRandom.cc         \
         Buffer.cc               \
-        PseudoRandom.cc
+        BlockingStream.cc
 
 if TARGET_API_POSIX
@@ -25 +26 @@
         config.h                \
         types.h                 \
+        PseudoRandom.h          \
         Failable.h              \
         Thread.h                \
@@ -38 +40 @@
         LocalConnector.h        \
         LocalClientSocket.h     \
-        PseudoRandom.h
+        BlockingStream.h

src/xplcommon/posix/ReadingBuffer.cc

@@ -63 +63 @@
         stream.events &= ~POLLIN;
         size_t added = addLength(result);
-        assert(added==result);
-        assert(getLength()==result);
+        assert(static_cast<ssize_t>(added)==result);
+        assert(static_cast<ssize_t>(getLength())==result);
     }
     return result>=0;

src/xplcommon/posix/Waiter.cc

@@ -49 +49 @@
     {
         Waitable* waitable = i->second;
-        if (waitable->ready()) return true;
+        if (waitable->ready()) {
+            return true;
+        }
     }
     return false;