Changeset 1740 in Sophya for trunk/ArchTOIPipe/Kernel/toiprocessor.cc
- Timestamp:
- Nov 9, 2001, 12:23:58 AM (24 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/ArchTOIPipe/Kernel/toiprocessor.cc
r1738 r1740 3 3 // Christophe Magneville 4 4 // Reza Ansari 5 // $Id: toiprocessor.cc,v 1.1 3 2001-11-08 15:47:46aubourg Exp $5 // $Id: toiprocessor.cc,v 1.14 2001-11-08 23:23:58 aubourg Exp $ 6 6 7 7 #include "toiprocessor.h" … … 311 311 double TOIProcessor::getData(int toiIndex, int i) { 312 312 TOI* toi = getInputTOI(toiIndex); 313 toi->waitForData(i); 313 if (toi->needSyncOldWay()) toi->waitForData(i); // seulement pour autre que segmented 314 autoWontNeed(i); 314 315 return toi->getData(i); 315 316 } … … 318 319 { 319 320 TOI* toi = getInputTOI(toiIndex); 320 toi->waitForData(i);321 if (toi->needSyncOldWay()) toi->waitForData(i); // seulement pour autre que segmented 321 322 toi->getData(i, data, flag); 322 323 return; … … 359 360 360 361 void TOIProcessor::notify() { 361 lock(); 362 /* if (mutex.__m_lock.__status == 0) { 363 cout << "wait without lock" << endl; abort(); 364 }*/ 365 362 lock(); 366 363 pthread_cond_broadcast(&dataReady); 367 364 unlock(); … … 373 370 toi->putData(i, value, flg); 374 371 autoWontNeed(i); 375 notify();372 if (toi->needSyncOldWay()) notify(); // seulement pour non segmented 376 373 } 377 374
Note:
See TracChangeset
for help on using the changeset viewer.