Changeset 3897 in Sophya for trunk/AddOn/TAcq/racqueth.h

Timestamp:

Oct 4, 2010, 4:19:59 PM (15 years ago)

Author:

ansari

Message:

Amelioration des classes PCIEToEthernet et EthernetReader pour eviter des situations de blocage lorsque lecture avec ForceSameFrameCounter, Reza 04/10/2010

File:

• trunk/AddOn/TAcq/racqueth.h (modified) (6 diffs)

trunk/AddOn/TAcq/racqueth.h

@@ -65 +65 @@
   BRParList par_;   // Parametres divers d'acquisition 
 
-  uint_8 nmaxpaq_;  // Nombre maxi de paquets traites
+  uint_8 nmaxpaq_;  // Nombre maxi de paquets traites - DOIT etre mutiple de mmgr.NbPaquets()
   BRDataFmtConv swapall_;  // select data swap/format conversion for BRPaquet
   bool stop_;  
@@ -73 +73 @@
   int tcpportid_;
   vector< vector<ClientSocket> > vvec_skt_;
-  vector< uint_4 > vec_cntpaq_; 
+  vector< vector<uint_8> > vvec_errorcnt_;
+  vector< uint_8 > vec_cntpaq_; 
   uint_4 packSize_;
   uint_4 packSizeInMgr_;
@@ -89 +90 @@
 class EthernetReader : public ZThread {
 public:
-  EthernetReader(RAcqMemZoneMgr& mem, BRParList const& par, int portid=BRSPORTID, bool rdsamefc=false);
+  EthernetReader(RAcqMemZoneMgr& mem, BRParList const& par, int portid=BRSPORTID);
+  virtual ~EthernetReader(); 
+
+  // Configuration du mode de lecture des paquets 
+  // Si force_samefc=true, on essaye de lire des paquets avec meme FrameCounter, sans depasser une 
+  // difference maximum de maxdiff_paqnum entre nombre de paquets lus sur chaque fibre
+  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; }
+
   virtual void run();
   inline void Stop() { stop_ = true; }
@@ -100 +109 @@
   bool ReadNextAllFibers();      // Renvoie true si probleme 
   bool ReadNext(int fib);   // Renvoie true si probleme 
+  void CleanUpAllSockets();  // pour finir la lecture de toutes les fibres 
   size_t ReceiveFromSocket(int fib, char* data, size_t len);
+
+// recale les links en cas d'ecart important entre nb de paquets lu sur chaque lien
+  int SkipAndSyncLinks();   // Renvoie 0 si rien fait, 1 si skip fait, 9 si probleme  
 
   // Permet d'avancer d'un paquet dans la zone - renvoie true si probleme
@@ -119 +132 @@
   BRParList par_;   // Parametres divers d'acquisition 
   int tcpportid_;
-  vector< Socket > vsok_;  //  Les sockets de lecture pour chaque fibre/lien 
-  vector< uint_4 > vec_cntpaq_; 
+  ServerSocket* srv_sokp_;  // Le socket serveur  
+  vector< Socket > vsok_;  //  Les sockets de lecture pour chaque lien ethernet (1 lien= 1 fibre a l'envoi) 
+  vector< uint_8 > vec_cntpaq_;   // vecteur de compteurs de paquet ( 1 compteur / lien ) 
+  vector< uint_4 > vec_fgsokend_;    // vecteur de flag, >0 : fin de reception (ou ereur) sur le lien 
+  bool gl_fgsokend;          // true -> au moins l'un de liens a termine 
   bool stop_;
   bool rdsamefc_;  // if true, read paquets with same value of FrameCounter on different fibers/link 
+  uint_4 sfc_maxdpc_;   // difference maxi entre nombre de paquets lu sur les liens 
+  uint_4 sfc_maxresync_;  // nb maximum de tentatives de resynchronisation 
+
   uint_8 totnbytesrd_;
   uint_8 totnpaqrd_;
   uint_8 totsamefc_;   // nombre total de paquets avec meme framecounter  
+
+  uint_8 totnbresync_;   // nombre total de saut+resynchronisation 
 
   vector<BRPaquet> vpaq_; 
@@ -140 +161 @@
   Byte* mmbufib_[MAXANAFIB];  // Pointeurs zone memoire de chaque fibre rendu par RAcqMemZoneMgr 
 
+  // zone tampon contenant zero si lecture sur fibre est fini 
+  char* dummybuff_;
+
   int prtlev_;   // print level 
   uint_8 prtmodulo_;   // print periodicity (modulo)