Changeset 31:bbd688924703 in xplcommon for src/xplcommon/BlockingStream.h

Timestamp:

01/02/13 13:58:25 (11 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

Implemented the data stream

File:

• src/xplcommon/BlockingStream.h (modified) (7 diffs)

src/xplcommon/BlockingStream.h

@@ -35 +35 @@
 
 #include "BufferedStream.h"
+
 #include "Waiter.h"
 #include "WaitableEvent.h"
@@ -76 +77 @@
     size_t readingOffset;
 
+    /**
+     * Indicate if the end-of-file has been reached while reading.
+     */
+    bool eof;
+
 public:
     /**
@@ -83 +89 @@
      */
     BlockingStream(BufferedStream& stream);
+
+    /**
+     * Determine if the stream has neither failed nor been
+     * interrupted.
+     */
+    operator bool() const;
 
     /**
@@ -102 +114 @@
      */
     bool read(void* dest, size_t length);
+
+    /**
+     * Skip the given number of bytes.
+     */
+    bool skip(size_t length);
 
     /**
@@ -125 +142 @@
      */
     bool fill();
+
+    /**
+     * Check for the stream being interrupted.
+     *
+     * @return if the stream is interrupted, false otherwise
+     */
+    bool checkInterrupted();
 };
 
@@ -135 +159 @@
     event(stream.getWaiter()),
     interrupted(false),
-    readingOffset(0)
+    readingOffset(0),
+    eof(false)
 {
+}
+
+//------------------------------------------------------------------------------
+
+inline BlockingStream::operator bool() const
+{
+    return !failed() && !interrupted && !eof;
 }
 
@@ -144 +176 @@
 {
     event.fire();
+}
+
+//------------------------------------------------------------------------------
+
+inline bool BlockingStream::isInterrupted()
+{
+    return interrupted;
 }