Changeset 3658 in Sophya for trunk/AddOn/TAcq/racqumem.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/racqumem.h (modified) (7 diffs)

trunk/AddOn/TAcq/racqumem.h

@@ -31 +31 @@
 } St_MemZ;
 
+
 // Les flags (bits) correspondant aux operations effectuees sur une zone
 // Free->libre, Filled->rempli(par DMA), Saved(ecrit sur disque), Proc(Traitement)
@@ -39 +40 @@
 enum MemZaction { MemZA_None=0, MemZA_Fill=1, MemZA_Save=2, MemZA_Proc=4, 
                   MemZA_ProcA=8, MemZA_ProcB=16, MemZA_ProcC=32 };
+
+// configuration du RAcqMemZoneMgr 
+enum MemZconfig { MemZConf_SingleFiberDataOnly=0, MemZConf_MultiFiberDataOnly=1,
+                  MemZConf_SingleFiberProcDataOnly=2, MemZConf_MultiFiberProcDataOnly=3,
+                  MemZConf_SingleFiberDataAndProcData=4, MemZConf_MultiFiberDataAndProcData=5 };
+// L'etat d'execution en cours : running, waiting, stopped
+enum MemZRunState { MemZR_Running=0, MemZR_Waiting=1, MemZR_Stopped=2};
+
+
 
 // -------------------------------------------------------------------
@@ -49 +59 @@
 //     Si procpsz>0 , on alloue aussi des zones memoire pour donnees traitees
 //      dans ce cas, procpsz à la taille memoire des donnees traites pour chaque paquet 
-  RAcqMemZoneMgr(uint_4 nz, uint_4 np=256, uint_4 psz=4096, uint_4 procpsz=0);
+// Constructeur 1 : l'objet ne contient que les donnees d'une fibre 
+//                  garde pour maintenir la compatibilite avec version TAcq v <= 6.0 
+  RAcqMemZoneMgr(uint_4 nz, uint_4 np, uint_4 psz);
+// Constructeur 2 : l'objet peut contenir plusieurs fibres, et des donnees processes en plus
+  RAcqMemZoneMgr(uint_4 nzon, uint_4 nfib, uint_4 npaq, uint_4 paqsz, uint_4 procsz=0);
+
   ~RAcqMemZoneMgr();
   
+  // Retourne le nombre de fibres dans chaque zone
+  inline uint_4 NbZones() { return nzones; }
   // Retourne le nombre de zones memoire
-  inline uint_4 NbZones() { return nzones; }
+  inline uint_4 NbFibres() { return nfibres; }
   // Retourne la taille de paquet
   inline uint_4 PaqSize() { return paqsz; }
@@ -59 +76 @@
   inline uint_4 NbPaquets() { return npaq; }
   // Retourne la taille totale d'une zone 
-  inline uint_4 ZoneSize() { return npaq*paqsz; }
+  inline uint_4 ZoneSize() { return nfibres*npaq*paqsz; }
+  inline uint_4 OneFiberZoneSize() { return npaq*paqsz; }
 
   // Retourne la taille de la zone memoire correspondant aux donnees traitees d'un paquet
   inline uint_4 ProcPaqSize() { return procpaqsz; }
   // Retourne la taille totale d'une zone de donnees traitees
-  inline uint_4 ProcZoneSize() { return npaq*procpaqsz; }
-  
+  inline uint_4 ProcZoneSize() { return nfibres*npaq*procpaqsz; }
+  inline uint_4 OneFiberProcZoneSize() { return npaq*procpaqsz; }
+
   // Definit l'etat des operations obligatoires avant qu'une zone 
   // remplie ne puisse etre recyclee (re-remplie)
@@ -76 +95 @@
   // Libere une zone memoire en marquant son etat
   int FreeMemZone(int id, MemZStatus st);
-  // Retourne le pointeur de la zone numero k
+  // Retourne le pointeur de la zone numero k pour les datas
+
+  // Retourne le pointeur de la zone numero k pour les datas pour une fibre donnee
+  inline Byte* GetMemZone(int id, int fib)  {
+    if ((id < 0) || (id >=(int) memzones.size()))  return NULL;
+    if ((fib < 0) || (fib >=(int) nfibres))  return NULL;
+    return memzones[id]+fib*OneFiberZoneSize();  
+    }
+  // Retourne le pointeur de la zone numero k pour les resultats de traitement pour une fibre donnee
+  inline Byte* GetProcMemZone(int id, int fib)  {
+    if ((id < 0) || (id >=(int) procmemzones.size()))  return NULL;
+    return procmemzones[id]+fib*OneFiberProcZoneSize();  
+    }
+  // Retourne le pointeur de la zone numero k pour les datas
   inline Byte* GetMemZone(int id)  {
     if ((id < 0) || (id >=(int) memzones.size()))  return NULL;
     return memzones[id];  
     }
+  // Retourne le pointeur de la zone numero k pour les resultats de traitement
   inline Byte* GetProcMemZone(int id)  {
     if ((id < 0) || (id >=(int) procmemzones.size()))  return NULL;
@@ -87 +120 @@
   
   ostream& Print(ostream& os);
+
   void Stop(); 
-        
+  inline MemZRunState GetRunState() 
+    { return runstate_; }
+  inline MemZRunState ChangeRunState( MemZRunState st) 
+    { runstate_ = st; return runstate_; }
+
 protected:
+  void Init();  // Fait l'allocation des differents buffers - est appele par les constructeurs
+
   // ... variables membres
   ZMutex mex;   
-  uint_4 nzones, npaq, paqsz, procpaqsz;
+  uint_4  nzones, nfibres, npaq, paqsz, procpaqsz;
 //  DMAMgrInterface &dma_;
   vector< Byte* > memzones;
@@ -98 +138 @@
   vector< Byte* > procmemzones;
   bool stop_;
+  MemZRunState runstate_;
   uint_4 mask_finalized_;
   uint_8 serial_;