Changeset 1689 in Sophya for trunk/ArchTOIPipe/Kernel/toiprocessor.cc

Timestamp:

Oct 14, 2001, 1:56:14 AM (24 years ago)

Author:

aubourg

Message:

segmented buffers...

File:

• trunk/ArchTOIPipe/Kernel/toiprocessor.cc (modified) (1 diff)

trunk/ArchTOIPipe/Kernel/toiprocessor.cc

@@ -242 +242 @@
 }
 
+void TOIProcessor::warnPutDone() {
+  int n = outIx.size();
+  for (int i=0; i<n; i++) {
+    TOI* toi = outTOIs[i];
+    toi->putDone();
+  }
+}
+
 void* TOIProcessor::ThreadStart(void* arg) {
   TOIProcessor* p = (TOIProcessor*) arg;
   //  cout << p->name << " new thread running " << pthread_self() << endl;
   p->run();
+  p->warnPutDone();
   pthread_exit(NULL);
   //  cout << p->name << " thread done " << pthread_self() << endl;