Changeset 1690 in Sophya for trunk/ArchTOIPipe

Timestamp:

Oct 14, 2001, 2:30:18 AM (24 years ago)

Author:

aubourg

Message:

segmentes

Location:

trunk/ArchTOIPipe/Kernel

Files:

• toisegment.cc (modified) (3 diffs)
• toisegment.h (modified) (2 diffs)

trunk/ArchTOIPipe/Kernel/toisegment.cc

@@ -1 +1 @@
 #include "toisegment.h"
+
+#ifndef MAXINT
+#define MAXINT 2147483647
+#endif
 
 /******************************/
@@ -354 +358 @@
 TOISegmented::BufferView* TOISegmented::MasterView::createView() { /* reader thread */
   BufferView* bv =  new BufferView(this);
+  allViews.insert(bv);
   updateView(bv);
   return bv;
@@ -371 +376 @@
   bv->segments.clear();
 
-  // TODO : utiliser firstNeeded de toute les vues pour faire le menage chez
+  // utiliser firstNeeded de toutes les vues pour faire le menage chez
   // nous.
-
+  
+  int firstNeeded = MAXINT;
+  for (set<BufferView*>::iterator i = allViews.begin();
+       i != allViews.end(); i++) {
+    if ((*i)->firstNeeded < firstNeeded) firstNeeded = (*i)->firstNeeded;
+  }
+
+  cout << "firstNeeded = " << firstNeeded << endl;
+
+  vector<BufferSegment*>::iterator j = segments.begin();
+  bool clean = false;
+  for (vector<BufferSegment*>::iterator i = segments.begin();
+       i != segments.end(); i++) { 
+    if (((*i)->sn0+(*i)->bufferSize <= firstNeeded) && ((*i)->getRefCount() == 0)) {
+      clean = true;
+      j = i;
+    } else {}
+    if (clean) {
+      segments.erase(segments.begin(),j);
+      sn0 = (*segments.begin())->sn0;
+    }
+  } 
 
   for (vector<BufferSegment*>::iterator i = segments.begin();

trunk/ArchTOIPipe/Kernel/toisegment.h

@@ -28 +28 @@
   virtual void          putDone();
 
-
+  // Methodes ignorees car on reimplemente les methodes de base
   virtual DataStatus    isDataAvail(int iStart, int iEnd);
   virtual DataStatus    isDataAvail(int i);
@@ -137 +137 @@
 
     set<BufferView*>  waitingBuffers;
+    set<BufferView*>  allViews;
 
     void checkDeadLock();