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

Timestamp:

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

Author:

aubourg

Message:

ring pipes

File:

• trunk/ArchTOIPipe/Kernel/toimanager.cc (modified) (8 diffs)

trunk/ArchTOIPipe/Kernel/toimanager.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: toimanager.cc,v 1.21 2003-05-19 23:31:29 aubourg Exp $
+// $Id: toimanager.cc,v 1.22 2003-05-20 10:10:09 aubourg Exp $
 
 #include "toimanager.h"
@@ -42 +42 @@
   cout << "Adding processor to TOIManager for group execution" << endl;
   processors.push_back(proc);
+  
+}
+
+void TOIManager::registerProcessor(RingProcessor* proc) {
+  
+  cout << "Adding processor to TOIManager for group execution" << endl;
+  ringProcessors.push_back(proc);
   
 }
@@ -80 +87 @@
     cout << "processor started " << endl;
   }
+
+  for (vector<RingProcessor*>::iterator i = ringProcessors.begin();
+       i != ringProcessors.end(); i++) {
+    RingProcessor* proc = *i;
+    cout << "**********************" <<  endl;
+    cout << "starting processor " <<  endl;
+    proc->start();
+    cout << "processor started " << endl;
+  }
   cout << "**********************" << endl;
+}
+
+void TOIManager::checkRingLimits() 
+{
+  int min=0;
+  int max = MAXINT;
+  for (int pass=0; pass<2; pass++) {
+    for (vector<RingProcessor*>::iterator i = ringProcessors.begin();
+         i != ringProcessors.end(); i++) {
+      RingProcessor* proc = *i;
+      proc->getRingRange(min, max);
+    }
+  }
 }
 
@@ -162 +191 @@
 } 
 
+RingPipe& TOIManager::connect(RingProcessor& pout, string out,
+                              RingProcessor& pin, string in) {
+  RingPipe* pipe;
+  char buff[128];
+  sprintf(buff, "Ring_[%s-%s]",  in.c_str(), out.c_str());
+  if ((pipe = pout.getOutRing(out)) == NULL) {
+    pipe = new RingPipe();
+    pout.addRingOutput(out, pipe);
+  }
+
+  pin.addRingInput(in, pipe);
+  return(*pipe);
+}
+
 // methode connect de cgt simplifiee et corrigee
 TOI& TOIManager::connect(TOIProcessor& prout, string out, 
@@ -169 +212 @@
   if (nom.length() < 1) {
     char buff[128];
-    sprintf(buff, "TOI%s_[%s-%s]", nom, in, out);
+    sprintf(buff, "TOI%s_[%s-%s]", nom.c_str(), in.c_str(), out.c_str());
     nom = buff;
   }
@@ -230 +273 @@
   int nbmax_dns_print = 2;
 
-  TOIManager* mgr = TOIManager::getManager();
+  //  TOIManager* mgr = TOIManager::getManager();
   
   //  istart = mgr->getRequestedBegin();
@@ -263 +306 @@
       nb_dns_print++;
       fracperc = (double)processed_samples*100./(double)total_sample_count;
-      fperc = fracperc*100;
+      fperc = (int)(fracperc*100);
       cout << ">>> " << _msg << ": ProcessedSampleCount()= " << last_sample_count 
            << " Frac done = " << (double)fperc/100. << " %" << endl;
@@ -271 +314 @@
     else if ((nb_sleep+1)%5 == 0) {
       fracperc = (double)processed_samples*100./(double)total_sample_count;
-      fperc = fracperc*100;
+      fperc = (int)(fracperc*100);
       cout << "> " << _msg << ": ProcSamples()= " <<  processed_samples 
            << " Done = " << " %" << (double)fperc/100.