Changeset 1437 in Sophya for trunk/ArchTOIPipe/Kernel/toi.cc

Timestamp:

Mar 12, 2001, 7:00:28 PM (25 years ago)

Author:

ansari

Message:

Protections diverses dans TOIProcessor et FITSTOIReader/Writer
Ajout d'un TOI (TOISeqBuffered) avec gestion d'un buffer entre put/get
Ajout de processeurs de test (RZTOIProc...) , programme test associe
et SMakefile (pour compil avec SOPHYA)

Reza 12/3/2001

File:

• trunk/ArchTOIPipe/Kernel/toi.cc (modified) (7 diffs)

trunk/ArchTOIPipe/Kernel/toi.cc

@@ -25 +25 @@
 void TOI::TOIInit() {
   pthread_mutex_init(&mutex, NULL);
+  //   ----- Rajouts Reza 12/3/2001
+  pthread_cond_init(&condv, NULL);
+  fgwaitput = fgwaitget = false;
+  fgsigput = fgsigget = false;
+  countwaitput = countwaitget = 0;
+  //  Fin rajouts Reza 12/3/2001 ------
 //  pthread_mutex_setname_np(&mutex, (name + "_toi_mutex").c_str(), 0);
   defaultValue = 0;
@@ -35 +41 @@
 }
 
+void TOI::PrintStatus(ostream & os) const
+{
+  os << "TOI::PrintStatus() - Name=" << getName() << endl;
+  os << " WaitStatus: Put/" ;
+  if (isPutWaiting()) os << "Waiting " ;
+  else os << "Running ";
+  os << " PutCountWait= " << getCountWaitPut() << endl;
+  os << " WaitStatus: Get/" ;
+  if (isGetWaiting()) os << "Waiting " ;
+  else os << "Running ";
+  os << " GetCountWait= " << getCountWaitGet() << endl;
+}
+
+
 void TOI::setProducer(TOIProcessor* p) {
   if (producer) 
@@ -76 +96 @@
   Array a = doGetData(iStart, iEnd);
   unlock();
+  if (fgsigput) { fgsigput = false; broadcast(); }
   return a;
 }
@@ -84 +105 @@
   double dat = doGetData(i);
   unlock();
+  if (fgsigput) { fgsigput = false; broadcast(); }
   return dat;
 }
@@ -93 +115 @@
   TArray<int_4> a = doGetFlag(iStart, iEnd);
   unlock();
+  if (fgsigput) { fgsigput = false; broadcast(); }
   return a;
 }
@@ -101 +124 @@
   int_4 f = doGetFlag(i);
   unlock();
+  if (fgsigput) { fgsigput = false; broadcast(); }
   return f;
 }
@@ -110 +134 @@
   doPutData(i, value, flag);
   unlock();
+  if (fgsigget) { fgsigget = false; broadcast(); }
 }