Changeset 1501 in Sophya

Timestamp:

May 18, 2001, 4:58:17 PM (24 years ago)

Author:

ansari

Message:

Modifs mineures - Reza 18/5/2001

Location:

trunk/ArchTOIPipe

Files:

• Kernel/fitstoiwtr.cc (modified) (1 diff)
• Processors/nooppr.cc (modified) (1 diff)
• TestPipes/simtst.cc (modified) (5 diffs)

trunk/ArchTOIPipe/Kernel/fitstoiwtr.cc

@@ -61 +61 @@
 
   cout << " FITSTOIWriter::run() - Creating output FITS file: "
-       << name << endl;
+       << fname << endl;
 
   string * coln = new string[ncols];

trunk/ArchTOIPipe/Processors/nooppr.cc

@@ -114 +114 @@
 
     cout << " NoOpProcessor::run() - End of processing " 
-         << " NbFFTBlocks= " << totnbblock << endl;
+         << " TotNbBlocks= " << totnbblock << endl;
   }  // Bloc try 
 

trunk/ArchTOIPipe/TestPipes/simtst.cc

@@ -87 +87 @@
   int istart = 0;
   int iend = 0;
+  int_8 dns_print = 1000;
+  int dns_print_fac = 50;
+  int nbmax_dns_print = 2;
+
   double range_min = -16000;
   double range_max = 16000.;
@@ -203 +207 @@
     //  mgr->setRequestedSample(11680920,11710584);
     //  mgr->setRequestedSample(104121000, 104946120);
-    if (fgsetstart) 
+    if (fgsetstart) {
       mgr->setRequestedSample(istart, iend);
-  
+      dns_print = (iend-istart)/dns_print_fac;
+      if (dns_print < 1000) dns_print = 1000;
+      nbmax_dns_print = (iend-istart)/dns_print;
+    }
     //    FITSTOIReader r("/data/Archeops/bolo11.fits); 
     FITSTOIReader r(infile); 
@@ -372 +379 @@
     w.PrintStatus(cout);  
 
+    
+
     PrtTim("starting threads");
     r.start();
@@ -387 +396 @@
       noop[2].start();
 
+
+    // ------------------- Impression continu de stat ------------------------ 
+    int_8 nb_dns_print = 0;
+    int nb_sleep = 0;
+    int_8 last_sample_count = 0;
+    int_8 processed_samples = 0;
+    int_8 total_sample_count = dns_print*nbmax_dns_print;
+    bool alldone = false;
+    while (!alldone) {
+      processed_samples = filt.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 << ">>> simtst/Info: 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 << "> simtst/Info: ProcSamples()= " <<  processed_samples 
+             << " Done = " << " %" << processed_samples*100/total_sample_count
+             << " NbSleep(1) = " << nb_sleep << endl;
+        
+      sleep(1);  nb_sleep++;
+    }
+
+    // -----------------------------------------------------------------------
+
     /*
     for(int jj=0; jj<3; jj++) {
@@ -395 +434 @@
       sleep(1);
     }
-    
     */