Changeset 30:1dde7e03353f in xplcommon for src/xplcommon/BlockingStream.cc

Timestamp:

01/02/13 11:54:56 (11 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

A little cleanup

File:

• src/xplcommon/BlockingStream.cc (modified) (3 diffs)

src/xplcommon/BlockingStream.cc

@@ -68 +68 @@
     ReadingBuffer& readingBuffer = stream.getReadingBuffer();
     while (length>0) {
-        size_t toCopy = min(readingBuffer.getLength() - readingOffset, length);
-        if (toCopy>0) {
-            memcpy(d, readingBuffer.getData() + readingOffset, toCopy);
-            readingOffset += toCopy;
-            length -= toCopy;
-            d += toCopy;
+        size_t copied = readingBuffer.extract(d, length, readingOffset);
+        readingOffset += copied;
+        length -= copied;
+        d += copied;
+
+        if (length!=0) {
+            if (!fill()) return false;
         }
-
-        if (length==0) break;
-
-        readingBuffer.reset();
-        readingOffset = 0;
-        while (!failed()) {
-            if (isInterrupted()) return false;
-
-            if (readingBuffer.read()) {
-                if (readingBuffer.isEmpty()) return false;
-                break;
-            } else if (readingBuffer.failed()) {
-                setErrorCode(readingBuffer.getErrorCode());
-            } else {
-                Waiter* waiter = stream.getWaiter();
-                waiter->wait();
-                if (waiter->failed()) {
-                    setErrorCode(waiter->getErrorCode());
-                }
-            }
-        }
-        if (failed()) return false;
     }
 
@@ -110 +89 @@
     WritingBuffer& writingBuffer = stream.getWritingBuffer();
     while(length>0) {
-        size_t toCopy = min(length, writingBuffer.getAvailable());
-        if (toCopy>0) {
-            memcpy(writingBuffer.getData() + writingBuffer.getLength(),
-                   s, toCopy);
-            writingBuffer.addLength(toCopy);
-            length -= toCopy;
-            s += toCopy;
-        }
+        size_t copied = writingBuffer.append(s, length);
+        length -= copied;
+        s += copied;
 
         if (length==0) break;
@@ -152 +126 @@
 //------------------------------------------------------------------------------
 
+bool BlockingStream::fill()
+{
+    ReadingBuffer& readingBuffer = stream.getReadingBuffer();
+
+    readingBuffer.reset();
+    readingOffset = 0;
+    while (true) {
+        if (isInterrupted()) return false;
+
+        if (readingBuffer.read()) {
+            return !readingBuffer.isEmpty();
+        } else if (readingBuffer.failed()) {
+            setErrorCode(readingBuffer.getErrorCode());
+            return false;
+        } else {
+            Waiter* waiter = stream.getWaiter();
+            waiter->wait();
+            if (waiter->failed()) {
+                setErrorCode(waiter->getErrorCode());
+                return false;
+            }
+        }
+    }
+}
+
+//------------------------------------------------------------------------------
+
 // Local Variables:
 // mode: C++