Changeset 3883 in Sophya for trunk/AddOn/TAcq/brfitsrd.cc

Timestamp:

Sep 23, 2010, 7:59:29 PM (15 years ago)

Author:

ansari

Message:

1/ Correction bug de lecture ds BRMultiFitsReader et EthernetReader lorsque lecture avec SameFrameCounter etait demande
2/ Amelioration des impressions ds ces deux classes et ajout possibilite de controle du flag "SameFC" avec les classes de parametres BRParList et BRAnaParam
3/ Nouveaux datacard @ethrforcesamefc et @prtlev pour acquisition

Reza, 23/09/2010

File:

• trunk/AddOn/TAcq/brfitsrd.cc (modified) (4 diffs)

trunk/AddOn/TAcq/brfitsrd.cc

@@ -78 +78 @@
          << " signalII.fits IMin=" << imin_ << " IMax=" << imax_ << " IStep=" << istep_ << endl;
 
+    uint_8  prtcnt=0;
     Byte* nextpaq=NULL;
     bool fgok=true;
@@ -95 +96 @@
       }
       if (ReadNextAllFibers()) { fgok=false;  break; }
+      prtcnt++;
+      if ((prtlev_>0)&&(prtcnt%prtmodulo_==0))  {
+          cout << "BRMultiFitsReader: NbPaqMFRead=" << prtcnt << " NSameFC=" 
+               << totsamefc_ << " / NPaqFib0Read=" << totnpqrd_[0] 
+               << " FracSameFC=" << 100*totsamefc_/totnpqrd_[0] << " %" <<  endl;
+      }
     }
 
     MoveToNextTarget();  // Pour faire traiter le dernier paquet si plein 
     MZoneManage(true);   // Nettoyage final 
-    usleep(50000);       // Attente de traitement du dernier paquet
-    memgr_.Stop();        // Arret 
 
     cout << " ------------------  BRMultiFitsReader::run() END ----------------- " << endl;
     ts.SetNow();
     tm.SplitQ();
-    cout << "  END reading : " << ts ;
-    if (rdsamefc_) cout << " NSameFC=" << totsamefc_ << endl;
-    else cout << endl;
+    cout << "BRMultiFitsReader::run():  END reading : " << ts << endl;
+    cout << "... NbPaqMFRead=" << prtcnt << " NSameFC=" 
+         << totsamefc_ << " / NPaqFib0Read=" << totnpqrd_[0] 
+         << " FracSameFC=" << 100*totsamefc_/totnpqrd_[0] << " %" << endl;
+
     for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)  {
       int perc=0;
@@ -121 +128 @@
     cout << " ---------------------------------------------------------- " << endl;
 
+    usleep(50000);       // Attente de traitement du dernier paquet
+    memgr_.Stop();        // Arret 
+
   }  // Fin du bloc try 
   catch (std::exception& exc) {
@@ -142 +152 @@
     if (ReadNext(fib)) return true;  // probleme 
   }
-  if (!rdsamefc_ || (memgr_.NbFibres()<2))  { 
-    totsamefc_++;  return false;  // c'est OK 
-  }
-  uint_8 cfc=curfc_[0];
-  bool fgsamefc=true;
-  for(size_t fib=1; fib<memgr_.NbFibres(); fib++) {
-    if (curfc_[fib]!=cfc) {
-      fgsamefc=false;
-      if (curfc_[fib] > cfc)  cfc=curfc_[fib]; 
-    }
-  }
-  if (fgsamefc) { 
-    totsamefc_++;  return false;  // c'est OK  , same framecounter
-  }
-  else {  // else !fgsame
-    for(uint_4 fib=0; fib<memgr_.NbFibres(); fib++) {
-      while (curfc_[fib]<cfc) {
-        if (ReadNext(fib)) return true;  // probleme 
-      }
-    }
-  }   // fin de  else !fgsame 
-  totsamefc_++; 
-  return false; // c'est OK
+  if (!rdsamefc_ || (memgr_.NbFibres()<2))  {
+    uint_8 cfc=curfc_[0];
+    bool fgsamefc=true;
+    for(size_t fib=1; fib<memgr_.NbFibres(); fib++) {
+      if (curfc_[fib]!=cfc)   fgsamefc=false;
+    }
+    if (fgsamefc)  totsamefc_++;  
+    return false;  // c'est OK 
+  }
+  //  On va essayer de lire jusqu'a avoir same_frame_counter 
+  bool echec=true;
+  while (echec) {
+    uint_8 cfc=curfc_[0];
+    bool fgsamefc=true;
+    for(size_t fib=1; fib<memgr_.NbFibres(); fib++) {
+      if (curfc_[fib]!=cfc) {
+        fgsamefc=false;
+        if (curfc_[fib] > cfc)  cfc=curfc_[fib]; 
+      }
+    }
+    if (fgsamefc) { 
+      totsamefc_++;  echec=false; return false;  // c'est OK  , same framecounter
+    }
+    else {  // else !fgsame
+      for(uint_4 fib=0; fib<memgr_.NbFibres(); fib++) {
+        while (curfc_[fib]<cfc) {
+          if (ReadNext(fib)) return true;  // probleme 
+        }
+      }
+    }   // fin de  else !fgsame 
+  }  // fin de while(echec): lecture jusqu'a same_frame_counter 
+
+  return true; // probleme 
 }