Changeset 3776 in Sophya for trunk/AddOn/TAcq/brproc.h

Timestamp:

May 18, 2010, 10:22:10 AM (15 years ago)

Author:

ansari

Message:

Ajout classes / modification pour permettre le calcul des visibilites ave plusieurs objets BRVisibilityCalculator s'executant en parallele, Reza 18/05/2010

File:

• trunk/AddOn/TAcq/brproc.h (modified) (4 diffs)

trunk/AddOn/TAcq/brproc.h

@@ -28 +28 @@
 class BRVisibilityCalculator : public BRBaseProcessor, ParallelTaskInterface {
 public: 
-  BRVisibilityCalculator(RAcqMemZoneMgr& memgr, string outpath, uint_4 nmean=1000, 
-                         uint_4 freq1=0, uint_4 freq2=0, uint_4 nbfreq=1, size_t nthr=1);
+  BRVisibilityCalculator(RAcqMemZoneMgr& memgr, string outpath, uint_4 nmean=1000, size_t nthr=1);
   virtual ~BRVisibilityCalculator(); // Fait le nettoyage final , sauvegarde des objets ...
 
-  virtual void run();
+  // Pour definir le rang de l'objet lors d'un traitement avec plusieurs BRVisibilityCalculator en //
+  void DefineRank(uint_4 nbc, uint_4 cid);
+
+  // Pour limiter le calcul des visibilites a certaines fibres 
+  uint_4 SelectPairs(uint_4 pair1=0, uint_4 nbpairs=99999999);
+  // pour definir le binning en frequence pour la VisibDataTable 
+  int SelectFreqBinning(uint_4 freq1=0, uint_4 freq2=0, uint_4 nbfreq=1);
+
   // Pour activer la verification des timetag
   // Creation / sauvegarde d'une matrice de TimeTag / FrameCounter avec NCols=maxnpaq (nb de paquets/trigger)  
   int ActivateTimeTagCheck(uint_8 maxnpaq);
-  
+
+  // Methode d'execution standard du thread (on redefinit la methode de BRBaseProcessor)
+  virtual void run();  
   // Methode de la classe ParallelTaskInterface 
   virtual int    execute(int tid);
@@ -50 +58 @@
   uint_4 nmean_;  // Nombre de spectres pour le calcul des moyennes 
   string outpath_;  // directory pour fichiers de sortie
-  uint_4 numfreq1_,numfreq2_,nbinfreq_;
-  uint_4 jf1_,jf2_,djf_;
+  uint_4 nbcalc_, calcid_;  // Nombre total de threads/objets BRVisibilityCalculator parallèles, l'identificateur de l'objet  
+
+  uint_4 pairst_, nbpairs_;   // Numero de la premiere paire, nombre de paires 
+  uint_4 jf1_,jf2_,djf_;  // binning en frequence pour la datatable
 
   vector<TwoByteComplex*> vpdata_;
@@ -64 +74 @@
   uint_4 numfile_;
   uint_8 totnbpaq_;
-  double* xnt_;
 
   // Variables/objets pour la verifications des timetag
@@ -79 +88 @@
 
 
+//-------------------------------------------------------------------------------
+// Classe Groupe (ensemble) de Calculateur de Visibilites, tourant en parallele
+//-------------------------------------------------------------------------------
+
+class BRVisCalcGroup {
+public: 
+  BRVisCalcGroup(size_t nbcalc, RAcqMemZoneMgr& memgr, string outpath, uint_4 nmean=1000, size_t nthr=1);
+  ~BRVisCalcGroup();
+  int SelectFreqBinning(uint_4 freq1=0, uint_4 freq2=0, uint_4 nbfreq=1);
+  inline int ActivateTimeTagCheck(uint_8 maxnpaq)
+  { return viscalcp_[0]->ActivateTimeTagCheck(maxnpaq); }
+
+  void start();
+  void join();
+protected:
+  vector<BRVisibilityCalculator *> viscalcp_; 
+};
+ 
 //---------------------------------------------------------------------
 // Classe de traitement simple - calcul de spectres moyennes / voie