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

Timestamp:

Aug 8, 2001, 12:01:41 PM (24 years ago)

Author:

ansari

Message:

• Ajout pthread_exit apres l'execution de run() ds TOIProcessor::ThreadStart()
• Ajout de la classe ProcSampleCounter<T> pour affichage continu de stats ds toimanager.h .cc
• correction mineure de toi2map.cc
• Utilisation de ProcSampleCounter<T> ds tsttoi2map.cc et simtst.cc

Reza 8/8/2001

File:

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

trunk/ArchTOIPipe/Kernel/toimanager.cc

@@ -43 +43 @@
   }
 }
+
+
+// -----------------------------------------------------------------
+//    Classe pour affichage de l'avancement des TOIProcessors 
+//                         Reza 08/2001 
+// -----------------------------------------------------------------
+
+RzProcSampleCounter::RzProcSampleCounter()
+{
+  _msg = "SampleCounter/Info";
+  _rate = 50;
+}
+
+RzProcSampleCounter::~RzProcSampleCounter()
+{
+}
+
+long RzProcSampleCounter::PrintStats()
+{
+  int istart = 0;
+  int iend = 0;
+  long dns_print = 1000;
+  int dns_print_fac = _rate;
+  int nbmax_dns_print = 2;
+
+  TOIManager* mgr = TOIManager::getManager();
+  
+  istart = mgr->getRequestedBegin();
+  iend = mgr->getRequestedEnd();
+  
+  dns_print = (iend-istart)/dns_print_fac;
+  if (dns_print < 1000) dns_print = ((iend-istart) < 1000) ? (iend-istart) : 1000;
+  if (dns_print < 1) dns_print = 1;
+  nbmax_dns_print = (iend-istart)/dns_print;
+
+  cout << "RzProcSampleCounter::PrintStats() InfoMessage=" << _msg 
+       << "\n ... " << _msg << " istart=" 
+       << istart << " iend= " << iend << " dns_print= " << dns_print
+       << " nbmax_dns_print= " << nbmax_dns_print << endl;
+  // ------------------- Impression continu de stat ------------------------ 
+  long nb_dns_print = 0;
+  int nb_sleep = 0;
+  long last_sample_count = 0;
+  long processed_samples = 0;
+  long total_sample_count = dns_print*nbmax_dns_print;
+  bool alldone = false;
+  while (!alldone) {
+    processed_samples = ProcessedSampleCount();
+    if ( (processed_samples-last_sample_count > dns_print) || 
+         (processed_samples > total_sample_count-10) ) {
+      last_sample_count = processed_samples;
+      if (nb_dns_print == 0) cout << "\n";
+      nb_dns_print++;
+      cout << ">>> " << _msg << ": ProcessedSampleCount()= " << last_sample_count 
+           << " Frac done = " << processed_samples*100/total_sample_count << " %" << endl;
+      if (last_sample_count > total_sample_count-10)  alldone = true;
+      nb_sleep = 0;
+    }
+    else if ((nb_sleep+1)%5 == 0) 
+      cout << "> " << _msg << ": ProcSamples()= " <<  processed_samples 
+           << " Done = " << " %" << processed_samples*100/total_sample_count
+           << " NbSleep(1) = " << nb_sleep << endl;
+    
+    sleep(1);  nb_sleep++;
+  }
+  
+  // -----------------------------------------------------------------------
+  
+  return last_sample_count;
+
+}