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

Timestamp:

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

Author:

aubourg

Message:

ring pipes

File:

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

trunk/ArchTOIPipe/Kernel/ringprocessor.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: ringprocessor.cc,v 1.1 2003-05-19 23:31:29 aubourg Exp $
+// $Id: ringprocessor.cc,v 1.2 2003-05-20 10:10:09 aubourg Exp $
 
 #include "ringprocessor.h"
 #include "ringpipe.h"
+#include "toimanager.h"
 
 #include <iostream>
@@ -37 +38 @@
 
   wontNeedRing = -1;
+  neededRingHistory = 3;
+  lastAWNR = -1;
+
+  TOIManager::getManager()->registerProcessor(this);
 }
 
@@ -57 +62 @@
 }
 
-
+void RingProcessor::setNeededRingHistory(int nr) {
+  neededRingHistory = nr;
+}
 
 int RingProcessor::declareRingInput(string ring) {
@@ -147 +154 @@
 }
 
+RingPipe* RingProcessor::getOutRing(string out)
+{
+  // recherche du nom de la sortie et verification si le toi existe deja
+  map<string, int>::iterator i = outRingIx.find(out);
+  if (i == outRingIx.end()) {
+    return NULL;
+  } else {
+    return outRings[(*i).second];
+  }
+}
+
+
 
 Ring const* RingProcessor::getRing(int index, int i) {
@@ -169 +188 @@
 }
 
+void RingProcessor::autoWontNeedRing(int iCur) {
+  if (neededRingHistory <=0) return;
+  if (iCur <= lastAWNR + neededRingHistory/10) return;
+  lastAWNR = iCur;
+  wontNeedRingBefore(iCur-neededRingHistory);
+}
+
 
 void RingProcessor::getRingRange(int& min, int&max) {