Changeset 3681 in Sophya for trunk/AddOn/TAcq/racquproc.h

Timestamp:

Nov 20, 2009, 12:46:54 PM (16 years ago)

Author:

ansari

Message:

Ajout classe de traitement en ligne (monitoring) MonitorProc , Reza 20/11/2009

File:

• trunk/AddOn/TAcq/racquproc.h (modified) (2 diffs)

trunk/AddOn/TAcq/racquproc.h

@@ -4 +4 @@
 //----------------------------------------------------------------
 // ---- classe de thread de traitememt  acquisition BAORadio -----
-// LAL -      R. Ansari - Juin/Juillet 2008 
+// LAL -      R. Ansari - 2008-2010
+//  A/ Juin 2008 - Juin 2009 
+//       Classes DataProc, DataProc2C, DataProcFFT2C avec des 
+//       threads de traitement mono-fibre
+//  B/ Novembre 2009 
+//    MonitorProc : Classe de traitement pour monitoring multifibres
 //----------------------------------------------------------------
 
@@ -14 +19 @@
 #include "sopnamsp.h"
 #include "zthread.h"
+#include "tmatrix.h"
 
 #include "brtypes.h"
+#include "brparam.h"
 
 using namespace std;
 
+// Quelques definitions globales
+// Nombre maximum de fibres geres par les classes MonitorProc
+#ifndef MAXNBFIB
+#define MAXNBFIB  4   
+#endif
 
+//---------------------------------------------------------------------
+// Classe thread de traitement/monitoring multifibre Raw/FFT 
+//---------------------------------------------------------------------
+class MonitorProc : public ZThread {
+public: 
+  MonitorProc(RAcqMemZoneMgr& mem);
+  virtual ~MonitorProc();
+  virtual void run(); 
+  void Stop();
+  inline void STOP() { stop_ = true; }  
+protected:
+  int procData2C(ofstream& logf);
+  int procData1C(ofstream& logf);
+  int CheckFrameCounters();
+
+  RAcqMemZoneMgr& memgr;
+  BRParList par_;
+  bool stop_;  
+  uint_4 nmax_;  // Nombre maxi de blocs MemZone traites
+  uint_4 step_;  // 1/step_ paquet traite ds chaque bloc
+  uint_4 nmean_;  // Nombre de blocs pour le calcul des moyennes 
+  string path_;
+  uint_4 nfiles_;
+  TMatrix<r_4> spectre_;
+  vector<uint_4> nzm_;
+  uint_4 nblocproc_;         // nombre total de bloc MemMgr traites 
+  uint_8 nprocpaq_;          // nombre de paquets traites entre deux mises a zero
+  uint_8 npaqsamefc_;        // nombre de paquets avec meme framecounter  entre deux mises a zero
+  uint_8 totnprocpaq_;       // nombre de paquets traites entre deux mises a zero
+  uint_8 totnpaqsamefc_;     // nombre de paquets avec meme framecounter  entre deux mises a zero
+  TMatrix<uint_8> curfc_;    // Numeros de FrameCounter dans le bloc
+  TMatrix<uint_1> cpaqok_;   // Paquets OK ou pas dans le bloc
+};
+
+
+//-------------------------------------------------------------------
+//--------  Premieres version - pour tmtacq.cc 
+//-------------------------------------------------------------------
 //-------------------------------------------------------------------
 // Classe thread de traitement avec 1 voie par frame (donnees brutes)