Changeset 3899 in Sophya for trunk

Timestamp:

Oct 4, 2010, 11:15:02 PM (15 years ago)

Author:

ansari

Message:

Ajout flag waitendmsg (Wait for END message) pour le controle de la fin d'execution de EthernetReader , Reza 04/10/2010

Location:

trunk/AddOn/TAcq

Files:

• acqparam_exemple.d (modified) (1 diff)
• brparam.cc (modified) (4 diffs)
• brparam.h (modified) (1 diff)
• mfacq.cc (modified) (1 diff)
• racqueth.cc (modified) (1 diff)
• racqueth.h (modified) (2 diffs)

trunk/AddOn/TAcq/acqparam_exemple.d

@@ -58 +58 @@
 #  de resynchronisation succesive
 ethrforcesamefc 50 50 
+#####
+# En activant la carte suivante, le lecteur (EthernetReader) attend les messages END sur chaque lien 
+# avant de terminer l'execuction 
+#  @ethrwaitendmsg
+ethrwaitendmsg
 ## No de port TCP/IP   
 #  @tcpportid 6912

trunk/AddOn/TAcq/brparam.cc

@@ -139 +139 @@
   ethr_sfc_maxdpc_=50;
   ethr_sfc_maxresync_=50;
+  ethr_waitendmsg_=false;
 
   skysource="";
@@ -212 +213 @@
   ethr_sfc_maxdpc_=p.ethr_sfc_maxdpc_;
   ethr_sfc_maxresync_=p.ethr_sfc_maxresync_;
+  ethr_waitendmsg_=p.ethr_waitendmsg_;
 
   skysource=p.skysource;
@@ -263 +265 @@
     ethr_sfc_maxresync_=conf.IParam("ethrforcesamefc",1,50);
   }
+  if (conf.HasKey("ethrwaitendmsg"))  ethr_waitendmsg_=true;
 
   //  Parametre de controle du monitoring 
@@ -398 +401 @@
   if (ethr_forcesamefc_)
     cout << "EthernetReader mode: ForceSameFrameCounter read mode with Max_PaquetCounterDiff= " 
-         << ethr_sfc_maxdpc_ << " MaxNbResync=" << ethr_sfc_maxresync_ << endl;
+         << ethr_sfc_maxdpc_ << " MaxNbResync=" << ethr_sfc_maxresync_ 
+         << ((ethr_waitendmsg_)?" Wait_For_END_Message_Before_Terminate ":" ") << endl;
   else
-    cout << "EthernetReader mode: AllOKPaquets read mode " << endl;
+    cout << "EthernetReader mode: AllOKPaquets read mode " 
+         << ((ethr_waitendmsg_)?" Wait_For_END_Message_Before_Terminate ":" ") << endl;
 
   if (fgdoProc>0) 

trunk/AddOn/TAcq/brparam.h

@@ -168 +168 @@
   uint_4 ethr_sfc_maxdpc_;   // valeur maximum de difference tolere entre compteurs de paquets de differentes fibres 
   uint_4 ethr_sfc_maxresync_;   // Nombre maximum de tentative de resynchronisation avant echec
- 
+  bool ethr_waitendmsg_;   // true -> EthernetReader attend le message END avant de s'arreter 
+
   // Identification source observee dans le ciel
   string skysource;

trunk/AddOn/TAcq/mfacq.cc

@@ -389 +389 @@
   EthernetReader ethrdr(mmgr, bpar.GetParams(), bpar.GetParams().tcpportid);
   ethrdr.SetReadMode(acpar.ethr_forcesamefc_, acpar.ethr_sfc_maxdpc_,acpar.ethr_sfc_maxresync_);
+  ethrdr.WaitENDMsg4Terminate(acpar.ethr_waitendmsg_);
   ethrdr.SetPrintLevel(acpar.prtlevel_, acpar.prtmodulo_); 
 

trunk/AddOn/TAcq/racqueth.cc

@@ -514 +514 @@
     usleep(50000);       // Attente de traitement du dernier paquet
     memgr_.Stop();        // Arret 
-    CleanUpAllSockets();  // On lit tous les liens jusqu'a la reception du message END
-    cout << " EthernetReader::run(): done CleanUpAllSockets()" << endl;
+    if (waitendmsg_)  {
+      CleanUpAllSockets();  // On lit tous les liens jusqu'a la reception du message END
+      cout << " EthernetReader::run(): done CleanUpAllSockets()" << endl;
+    }
   }  // Fin du bloc try 
   catch (std::exception& exc) {

trunk/AddOn/TAcq/racqueth.h

@@ -98 +98 @@
   inline void SetReadMode(bool force_samefc=false, uint_4 maxdiff_paqnum=50, uint_4 maxresync=50)
   { rdsamefc_=force_samefc; sfc_maxdpc_=maxdiff_paqnum; sfc_maxresync_=maxresync; }
+  //  En activant le flag, le reader ne se termine qu'avec la reception des message END sur chaque lien 
+  inline void WaitENDMsg4Terminate(bool waitendmsg=false) 
+  { waitendmsg_=waitendmsg; }
 
   virtual void run();
@@ -165 +168 @@
   string stopreason_;   // message descriptif de la raison d'arret 
 
+  bool waitendmsg_;   // si true, attendre le message  END message sur chaque lien avant de s'arreter 
+ 
   int prtlev_;   // print level 
   uint_8 prtmodulo_;   // print periodicity (modulo)