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

Timestamp:

Oct 18, 2009, 11:10:33 AM (16 years ago)

Author:

ansari

Message:

1/ Gestion multi-fibre ds RAcqMemZoneMgr et les DMAReader/DiskWriter (brproc.cc)
2/ Possibilite d'ajout de mot cle ds l'entete FITS par la classe MiniFITSFile

Reza , 18/10/2009

File:

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

trunk/AddOn/TAcq/racqurw.h

@@ -22 +22 @@
 
 
+// Quelques definitions globales
+// Nombre maximum de fibres geres par les classes MultiReader / MultiDiskWriter
+#define MAXNBFIB  4   
 
 //-------------------------------------------------------
@@ -89 +92 @@
 class PCIEReaderChecker : public ZThread {
 public:
-  PCIEReaderChecker( PCIEWrapperInterface &pciw , uint_4 sizeFrame,uint_4 paqSize ,RAcqMemZoneMgr& mem, 
+  PCIEReaderChecker( PCIEWrapperInterface &pciw , uint_4 sizeFrame,uint_4 paqSize, RAcqMemZoneMgr& mem, 
                      uint_4 nmax=100, BRDataFmtConv swapall=BR_SwapAll);  
   virtual void run(); 
@@ -103 +106 @@
   uint_4 packSize_;
 };
+//------------------------------------------------------------------
+// Classe thread de lecture PCI-Express multi fibre (ou multi DMA)
+//------------------------------------------------------------------
+
+class PCIEMultiReader : public ZThread {
+public:
+  PCIEMultiReader( vector<PCIEWrapperInterface*> vec_pciw , uint_4 sizeFrame,uint_4 paqSize, RAcqMemZoneMgr& mem, 
+                   uint_4 nmax=100, BRDataFmtConv swapall=BR_SwapAll,int binMin=0, int nbBin=0);  
+  virtual void run(); 
+   void Stop();
+  inline void STOP() { stop_ = true; }  
+
+protected: 
+  // Permet d'avancer d'un paquet dans la zone - renvoie true si probleme
+  inline bool MoveToNextTarget()  {
+    if ((mmbuf_ == NULL )||(targ_npaq_ >= max_targ_npaq)) 
+      if (MZoneManage()) return true;
+    targ_npaq_++;
+    return false;
+  }
+  inline Byte* GetPaquetTarget(int numfib)  {
+    if ((mmbufib_[numfib] == NULL )||(targ_npaq_ > max_targ_npaq)||(targ_npaq_ == 0))  return NULL; 
+    Byte* rb=mmbufib_[numfib]+(targ_npaq_-1)*packSizeInMgr_;
+    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_ ;
+  vector<PCIEWrapperInterface *> vec_pciw_;
+  uint_4 packSize_;
+  uint_4 packSizeInMgr_;
+  uint_4 nbDma_;
+  int nbBin_;
+  int binMin_;
+  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 
+  Byte* mmbufib_[MAXNBFIB];  // Pointeurs zone memoire de chaque fibre rendu par RAcqMemZoneMgr 
+
+};
+
+
+
+//----------------------------------------------------------------------------------------
+// Classe thread de sauvegarde sur fichiers - gerant plusieurs fibres dans RAcqMemZoneMgr
+//----------------------------------------------------------------------------------------
+
+class MultiDataSaver : public ZThread {
+public: 
+  MultiDataSaver(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;
+ 
+};
 
 #endif