Changeset 3883 in Sophya for trunk/AddOn/TAcq/racqueth.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/racqueth.cc (modified) (3 diffs)

trunk/AddOn/TAcq/racqueth.cc

@@ -433 +433 @@
       if (ReadNextAllFibers()) { fgok=false;  break; }
       totnpaqrd_++;
+      if ((prtlev_>0)&&(totnpaqrd_%prtmodulo_==0))  {
+          cout << "EthernetReader: NbPaq/Link=" << totnpaqrd_ << " 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 << " ------------------  EthernetReader::run() END ----------------- " << endl;
     ts.SetNow();
     tm.SplitQ();
-    cout << "  END reading TotNPaq/Link=" << totnpaqrd_ << " :"  << ts ;
-    if (rdsamefc_) cout << " NSameFC=" << totsamefc_ << endl;
-    else cout << endl;
+    cout << "  END reading TotNPaq/Link=" << totnpaqrd_ << " :"  << ts << endl;
+    cout << "... NbPaq/Link=" << totnpaqrd_ << " NSameFC=" 
+         << totsamefc_ << " / NPaqLink[0]_Read=" << totnpqrd_[0] 
+         << " FracSameFC=" << 100*totsamefc_/totnpqrd_[0] << " %" << endl;
+
     for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)  {
       int perc=0;
@@ -459 +464 @@
     cout << " ---------------------------------------------------------- " << endl;
 
+    usleep(50000);       // Attente de traitement du dernier paquet
+    memgr_.Stop();        // Arret 
+
   }  // Fin du bloc try 
   catch (std::exception& exc) {
@@ -480 +488 @@
     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 
 }