Changeset 2386 in Sophya for trunk/ArchTOIPipe/Kernel/ringpipe.cc

Timestamp:

May 20, 2003, 12:10:09 PM (22 years ago)

Author:

aubourg

Message:

ring pipes

File:

• trunk/ArchTOIPipe/Kernel/ringpipe.cc (modified) (5 diffs)

trunk/ArchTOIPipe/Kernel/ringpipe.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: ringpipe.cc,v 1.1 2003-05-19 23:31:29 aubourg Exp $
+// $Id: ringpipe.cc,v 1.2 2003-05-20 10:10:08 aubourg Exp $
 
 #include "ringpipe.h"
@@ -15 +15 @@
 #endif
 
-RingPipe::RingPipe() {
+RingPipe::RingPipe(int ws) {
   i0 = -1;
+  winSize = ws;
   producer = NULL;
   pthread_cond_init(&ringReady, NULL);
@@ -38 +39 @@
 void RingPipe::putRing(int i, Ring const* ring) {
   lock();
+  waitForRoom(i);
   if (i0 == -1) {
     data.insert(data.begin(), 1, (Ring const*) NULL);
@@ -50 +52 @@
   notify();
   unlock();
+}
+
+void RingPipe::waitForRoom(int j) {
+  while (j-i0 >= winSize) {
+    wait();
+  }
 }
 
@@ -91 +99 @@
     data.erase(data.begin(), data.begin()+(i-i0));
     i0=i;
+    notify();
   }
   unlock();