Changeset 3623 in Sophya for trunk/AddOn/TAcq/racqurw.h

Timestamp:

May 22, 2009, 9:59:38 AM (16 years ago)

Author:

ansari

Message:

Modifications et ameliorations diverses pour programme acquisition/traitement multifibres

Reza 22/05/2009

1- Extension/amelioration classe BRPaquet et BRPaqChecker
2- Correction BUG dans RAcqMemZoneMgr bloquant l'utilisation a une seule zone memoire
3- Classe PCIEWrapper devenue virtuelle pure et introduction de la classe TestPCIWrapperNODMA
pour les smulations.

File:

• trunk/AddOn/TAcq/racqurw.h (modified) (3 diffs)

trunk/AddOn/TAcq/racqurw.h

@@ -14 +14 @@
 #include "sopnamsp.h"
 #include "zthread.h"
+#include "pciewrap.h"
 
 #include "brtypes.h"
+#include "brpaqu.h"
 
 using namespace std;
@@ -27 +29 @@
 class PCIEReader : public ZThread {
 public:
-  PCIEReader(RAcqMemZoneMgr& mem, uint_4 nmax=100);     
+  PCIEReader( PCIEWrapper &pciw , uint_4 sizeFrame,uint_4 paqSize ,RAcqMemZoneMgr& mem, 
+              uint_4 nmax=100, BRDataFmtConv swapall=BR_SwapAll);       
   virtual void run(); 
+   void Stop();
   inline void STOP() { stop_ = true; }  
+    
 protected:
+  // Pour recuperer un pointeur sur la prochaine zone memoire devant recevoir un paquet
+  inline Byte* NextPaqTarget()  {
+    if ((mmbuf_ == NULL )||(targ_npaq_ >= max_targ_npaq)) 
+      if (MZoneManage()) return NULL;
+    Byte* rb=mmbuf_+targ_npaq_*packSize_;
+    targ_npaq_++;
+    return rb;
+  }
+  bool MZoneManage(bool clean=false);  // Renvoie true si probleme
+
   RAcqMemZoneMgr& memgr;
   uint_4 nmax_;  // Nombre maxi de blocs MemZone traites
+  BRDataFmtConv swapall_;  // select data swap/format conversion for BRPaquet
   bool stop_;  
+  unsigned int sizeFr_ ;
+  PCIEWrapper& pciw_;
+  uint_4 packSize_;
+  // Variables pour gerer la logique de  NextPaqTarget() qui cache l'acces a RAcqMemZoneMgr
+  int mid_;  // Identificateur zone memoire
+  uint_4 targ_npaq_;  // Numero de paquet dans une seule zone memoire 
+  uint_4 max_targ_npaq; // =  mmgr.NbPaquets() = Max de targ_npaq_
+  Byte* mmbuf_;  // Pointeur zone memoire rendu par RAcqMemZoneMgr 
 };
 
@@ -42 +66 @@
 class DataSaver : public ZThread {
 public: 
-  DataSaver(RAcqMemZoneMgr& mem, string& path, uint_4 nmax=100);
+  DataSaver(RAcqMemZoneMgr& mem, string& path, uint_4 nfiles=100, uint_4 nblocperfile=1, bool savesig=true);
+
   virtual void run(); 
+  void Stop(); 
+  inline void STOP() { stop_ = true; }  
+protected:
+  RAcqMemZoneMgr& memgr;
+  uint_4 nfiles_;  // Nombre maxi de fichiers cree
+  uint_4 nblocperfile_;  // Nombre de bloc (zone memoire) mis dans un fichier
+  uint_4 nmax_;  // Nombre maxi de blocs MemZone traites = nfiles * nblocperfile_
+  bool savesig_; // Si false, pas d'ecriture des fichiers FITS du signal 
+  bool stop_;  
+  string path_;  
+  struct sigaction act;
+ 
+};
+
+//-------------------------------------------------------
+// Classe thread de lecture PCI-Express + Check 
+//-------------------------------------------------------
+
+class PCIEReaderChecker : public ZThread {
+public:
+  PCIEReaderChecker( PCIEWrapper &pciw , uint_4 sizeFrame,uint_4 paqSize ,RAcqMemZoneMgr& mem, 
+                     uint_4 nmax=100, BRDataFmtConv swapall=BR_SwapAll);  
+  virtual void run(); 
+   void Stop();
   inline void STOP() { stop_ = true; }  
 protected:
   RAcqMemZoneMgr& memgr;
   uint_4 nmax_;  // Nombre maxi de blocs MemZone traites
+  BRDataFmtConv swapall_;  // select data swap/format conversion for BRPaquet
   bool stop_;  
-  string path_;  
+  unsigned int sizeFr_ ;
+  PCIEWrapper& pciw_;
+  uint_4 packSize_;
 };
 
-
 #endif