Changeset 1740 in Sophya for trunk/ArchTOIPipe

Timestamp:

Nov 9, 2001, 12:23:58 AM (24 years ago)

Author:

aubourg

Message:

une optim pour quand on n'a que des segmented

Location:

trunk/ArchTOIPipe/Kernel

Files:

• toi.cc (modified) (2 diffs)
• toi.h (modified) (3 diffs)
• toiprocessor.cc (modified) (5 diffs)
• toisegment.cc (modified) (4 diffs)

trunk/ArchTOIPipe/Kernel/toi.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: toi.cc,v 1.7 2001-11-08 15:47:46 aubourg Exp $
+// $Id: toi.cc,v 1.8 2001-11-08 23:23:58 aubourg Exp $
 
 #include "toiprocessor.h"
@@ -37 +37 @@
   producer = NULL;
   dbg = false;
+  syncOldWay = true;
 }
 

trunk/ArchTOIPipe/Kernel/toi.h

@@ -5 +5 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: toi.h,v 1.9 2001-11-08 15:47:46 aubourg Exp $
+// $Id: toi.h,v 1.10 2001-11-08 23:23:58 aubourg Exp $
 
 #ifndef TOI_H
@@ -73 +73 @@
   string getName() const {return name;}
 
+  bool needSyncOldWay() const {return syncOldWay;}
+
 protected:
   TOI*                  errorTOI;
@@ -89 +91 @@
   vector<TOIProcessor*> consumers;
   double                defaultValue;
-  
+  bool  syncOldWay;
+
 #ifdef WITH_SOPHYA
   /* l'interface va etre modifiee, NE PAS UTILISER

trunk/ArchTOIPipe/Kernel/toiprocessor.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: toiprocessor.cc,v 1.13 2001-11-08 15:47:46 aubourg Exp $
+// $Id: toiprocessor.cc,v 1.14 2001-11-08 23:23:58 aubourg Exp $
 
 #include "toiprocessor.h"
@@ -311 +311 @@
 double TOIProcessor::getData(int toiIndex, int i) {
   TOI* toi = getInputTOI(toiIndex);
-  toi->waitForData(i);
+  if (toi->needSyncOldWay()) toi->waitForData(i); // seulement pour autre que segmented
+  autoWontNeed(i);
   return toi->getData(i);
 }
@@ -318 +319 @@
 {
   TOI* toi = getInputTOI(toiIndex);
-  toi->waitForData(i);
+  if (toi->needSyncOldWay()) toi->waitForData(i); // seulement pour autre que segmented
   toi->getData(i, data, flag);
   return;
@@ -359 +360 @@
 
 void TOIProcessor::notify() {
-  lock();
-/*  if (mutex.__m_lock.__status == 0) {
-    cout << "wait without lock" << endl; abort();
-  }*/
-  
+  lock();  
   pthread_cond_broadcast(&dataReady);
   unlock();
@@ -373 +370 @@
   toi->putData(i, value, flg);
   autoWontNeed(i);
-  notify();
+  if (toi->needSyncOldWay())  notify(); // seulement pour non segmented
 }
 

trunk/ArchTOIPipe/Kernel/toisegment.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: toisegment.cc,v 1.14 2001-11-08 15:47:46 aubourg Exp $
+// $Id: toisegment.cc,v 1.15 2001-11-08 23:23:58 aubourg Exp $
 
 #include "toisegment.h"
@@ -31 +31 @@
   master = new MasterView(bufsz, maxseg, "");
   setName("TOISegmented");
+  syncOldWay = false;
 }
 
@@ -36 +37 @@
   master = new MasterView(bufsz, maxseg, nm);
   setName(nm);
+  syncOldWay = false;
 }
 
@@ -42 +44 @@
   master = new MasterView(bufsz, maxseg, nm);
   setName(nm);
+  syncOldWay = false;
 }