Changeset 3671 in Sophya

Timestamp:

Nov 13, 2009, 11:54:04 AM (16 years ago)

Author:

ansari

Message:

• Nettoyage complet des programmes d'acquisition
• Ajout methode BRPaquet::CopyFrom() pour reduction de paquet
• Introduction des classes BRParList , BRConfList , BRAcqConfig
• Introduction du nouveau programme acquisition mfacq.cc (MultiFibresAcq)

Reza, 13/11/2009

Location:

trunk/AddOn/TAcq

Files:

• bracqvers.h (added)
• brpaqu.cc (modified) (23 diffs)
• brpaqu.h (modified) (6 diffs)
• brparam.cc (added)
• brparam.h (added)
• makefile (modified) (3 diffs)
• mfacq.cc (added)
• mfacq.h (added)
• minifits.cc (modified) (5 diffs)
• pciewrap.cc (modified) (1 diff)
• racqumem.cc (modified) (1 diff)
• racquproc.cc (modified) (3 diffs)
• racqurw.cc (modified) (13 diffs)
• racqurw.h (modified) (7 diffs)
• tmtacq.cc (modified) (12 diffs)
• tmtacq.h (modified) (1 diff)

trunk/AddOn/TAcq/brpaqu.cc

@@ -3 +3 @@
 #include "brpaqu.h"
 
+/* ----------------------------------------
+     Projet BAORadio --- LAL - 2008-2010 
+     R. Ansari , M.Taurigna 
+-------------------------------------------  */
+
+/* --Methode-- */
+BAORadioException::BAORadioException(const char * m)   throw()
+{
+  if (m!=NULL) { 
+    strncpy(msg_, m, BREX_MAXMSGLEN-1);
+    msg_[BREX_MAXMSGLEN-1] = '\0';
+  }
+  else msg_[0] = '\0';
+}
+/* --Methode-- */
+BAORadioException::BAORadioException(const string& m)   throw()
+{
+  strncpy(msg_, m.c_str(), BREX_MAXMSGLEN-1);
+  msg_[BREX_MAXMSGLEN-1] = '\0';
+}
+
+/* --Methode-- */
+BAORadioException::~BAORadioException()  throw()
+{
+}
+
+/* --Methode-- */
+const char* BAORadioException::what() const throw()
+{
+  return msg_;
+}
+
+/* --Methode-- */
+string const BAORadioException::Msg() const 
+{
+  return (string(msg_));
+}
+
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
 
 static inline void bswap4(void* p)
@@ -14 +54 @@
 
 /* --Methode__ */
-BRPaquet::BRPaquet(Byte* src, Byte* dst, int paqsz, BRDataFmtConv fgswap,int binMin,int nbBin )
+BRPaquet::BRPaquet(Byte* src, Byte* dst, int paqsz, BRDataFmtConv fgconv)
   // swapall = true -> on swap tout le paquet, sinon swap entete seulement
 {
   dst_ = dst;
   sz_ = paqsz;
-  if ((src == NULL) || (dst == NULL)) return;
-  // Il faut mettre une protection (throw) si dst==NULL ou sz==0
+  /*
+  if ((dst == NULL) || (paqsz<=(BRHDRSIZE+BRTRLSIZE)) ) 
+    throw BAORadioException("BRPaquet::BRPaquet(src,dst...) NULL src or dst pointer OR paqsz<HDR+TRLSize");
+  */
+  if ((dst==NULL)||(src==NULL))  return;
 
   UInt32* src32 = (UInt32*)src;
   UInt32* dst32 = (UInt32*)dst;
-  Byte* tmp = new Byte[sz_];
  
-  switch ( fgswap ) {
+ 
+  switch ( fgconv ) {
   case BR_DoNothing :  // rien a faire
     break;
@@ -32 +75 @@
     memcpy(dst_, src, sz_); 
     break;
-  case BR_Copy_Reduc : // copie directe 
-   memcpy(dst_, src, HeaderSize()); 
-   
-    memcpy(dst_+ HeaderSize(), src+(binMin+ HeaderSize()), nbBin); 
-   memcpy(dst_+ (HeaderSize()+ nbBin ), src+(binMin+ HeaderSize()+sz_/2), nbBin); 
-   memcpy(dst_+( HeaderSize()+( 2* nbBin)),src+(HeaderSize()+DataSize()),TrailerSize());
- 
-    SetPaqLen( nbBin/2);
-   break;
-   
   case BR_Swap32 : // On swappe toutes les donnees du paquet 
   //  les bytes sont dans l'ordre par paquet de 4 octets (Int32) , les deux Int32 de 
-  // On copie la zone donnees en faisant un byte-swap correspondant a 8 octets (4->8 Reza/firmware SGDMA) 
+  // On copie la zone donnees en faisant un byte-swap correspondant a 8 octets (4->8 Reza/firmware SGDMA)
     for(int ka=0; ka<sz_/4; ka+=2) {
       dst32[ka] = src32[ka+1];
@@ -51 +84 @@
     break;
   case BR_SwapAll:
-  for(int ka=0; ka<sz_; ka+=8) {
+    // Byte swap complet sur 8 bytes 
+    for(int ka=0; ka<sz_; ka+=8) {
       for(int kb=0; kb<4; kb++) {
         dst_[ka+kb] = src[ka+3-kb+4];    
@@ -57 +91 @@
       }
     }
-  for(int ka=HeaderSize()+DataSize(); ka<sz_; ka+=8) {
+    break;
+  case BR_CopyHDR:
+    for(int ka=0; ka<BRHDRSIZE/4; ka++)  dst32[ka] = src32[ka];
+    for(int ka=(HeaderSize()+DataSize())/4;ka < sz_/4; ka++)  dst32[ka] = src32[ka];
+    break;
+  case BR_SwapHDR :
+    // ByteSwap 8 (4->8 Reza/firmware SGDMA) de l'enete 
+    for(int ka=0; ka<BRHDRSIZE; ka+=8) {
       for(int kb=0; kb<4; kb++) {
         dst_[ka+kb] = src[ka+3-kb+4];    
@@ -63 +104 @@
       }
     }
-    break;
-  case BR_SwapHDR :
+    // Byte swap (sur 8 octets) du trailer 
+    for(int ka=HeaderSize()+DataSize(); ka<sz_; ka+=8) {
+      for(int kb=0; kb<4; kb++) {
+        dst_[ka+kb] = src[ka+3-kb+4];    
+        dst_[ka+kb+4] = src[ka+3-kb];    
+      }
+    }
+    break;
+
+    //  --------------------
+    //  --- Copie/remise en ordre des donnees FFT 
   case BR_FFTOneChan :
   case BR_FFTTwoChan :
+    // copie du header uniquement 
+    for(int ka=0; ka<BRHDRSIZE/4; ka++)  dst32[ka] = src32[ka];
+    // on reoordonne les coeff FFT (pas de swap) 
+    if (fgconv == BR_FFTOneChan) 
+      ReorderFFTData((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize());
+    else  {
+      ReorderFFTData((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize()/2);
+      ReorderFFTData((SByte*)(src+HeaderSize()+DataSize()/2), (SByte*)(dst_+HeaderSize()+DataSize()/2), DataSize()/2);
+    }
+    // copie du trailler uniquement : 
+    for(int ka=(HeaderSize()+DataSize())/4;ka < sz_/4; ka++)  dst32[ka] = src32[ka];
+    break;
+
+  case BR_FFTOneChanSwapAll :
+  case BR_FFTTwoChanSwapAll :
     // Byte swap (sur 8 octets) de l'entete
     // ByteSwap 8 (4->8 Reza/firmware SGDMA) de l'enete 
@@ -75 +140 @@
       }
     }
-
     // on reoordonne les coeff FFT et on swappe en mem temps  (Byte-swap sur 8 octets)
-    if (fgswap == BR_FFTOneChan) ReorderFFTData((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize());
-    else if (fgswap == BR_FFTTwoChan) {
-      ReorderFFTData((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize()/2);
-      ReorderFFTData((SByte*)(src+HeaderSize()+DataSize()/2), (SByte*)(dst_+HeaderSize()+DataSize()/2), DataSize()/2);
+    if (fgconv == BR_FFTOneChanSwapAll) 
+      ReorderFFTDataSwapAll((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize());
+    else  {
+      ReorderFFTDataSwapAll((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize()/2);
+      ReorderFFTDataSwapAll((SByte*)(src+HeaderSize()+DataSize()/2), (SByte*)(dst_+HeaderSize()+DataSize()/2), DataSize()/2);
     }
     // Byte swap (sur 8 octets) du trailer 
@@ -91 +156 @@
     break;
  
-  case BR_FFTOneChan32 :
-  case BR_FFTTwoChan32 :
+  case BR_FFTOneChanSwap32 :
+  case BR_FFTTwoChanSwap32 :
     // swap du header uniquement : Echange de deux mots de 4 octets
     for(int ka=0; ka<BRHDRSIZE/4; ka+=2) {
@@ -98 +163 @@
       dst32[ka+1] = src32[ka];
     }
-  
     // on reoordonne et on swappe en mem temps (Echange de deux mots de 4 octets)
-    if (fgswap == BR_FFTOneChan32) ReorderFFTData32((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize());
-    else if (fgswap == BR_FFTTwoChan32) {
-      ReorderFFTData32((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize()/2);
-      ReorderFFTData32((SByte*)(src+HeaderSize()+DataSize()/2), (SByte*)(dst_+HeaderSize()+DataSize()/2), DataSize()/2);
+    if (fgconv == BR_FFTOneChanSwap32) 
+      ReorderFFTDataSwap32((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize());
+    else  {
+      ReorderFFTDataSwap32((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize()/2);
+      ReorderFFTDataSwap32((SByte*)(src+HeaderSize()+DataSize()/2), (SByte*)(dst_+HeaderSize()+DataSize()/2), DataSize()/2);
     }
     // swap du trailler uniquement : Echange de deux mots de 4 octets
@@ -111 +176 @@
     }
     break;
-  case BR_FFTOneChanNoSwap :
-  case BR_FFTTwoChanNoSwap :
-    // copie du header uniquement 
-    for(int ka=0; ka<BRHDRSIZE/4; ka++)  dst32[ka] = src32[ka];
-
-    //DEL  on a plus de swapdonc il faut copier dans dst
-    //DEL    memcpy(dst_, src, sz_); 
-
-    // on reoordonne les coeff FFT (pas de swap) 
-    if (fgswap == BR_FFTOneChanNoSwap) ReorderFFTDataNoSwap((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize());
-    else if (fgswap == BR_FFTTwoChanNoSwap) {
-      ReorderFFTDataNoSwap((SByte*)(src+HeaderSize()), (SByte*)(dst_+HeaderSize()), DataSize()/2);
-      ReorderFFTDataNoSwap((SByte*)(src+HeaderSize()+DataSize()/2), (SByte*)(dst_+HeaderSize()+DataSize()/2), DataSize()/2);
-    }
-    // copie du trailler uniquement : 
-     for(int ka=(HeaderSize()+DataSize())/4;ka < sz_/4; ka++)  dst32[ka] = src32[ka];
-     break;
-  case BR_CpHdrTrl :
-    for(int ka=0; ka<BRHDRSIZE/4; ka++)  dst32[ka] = src32[ka];
-    for(int ka=(HeaderSize()+DataSize())/4;ka < sz_/4; ka++)  dst32[ka] = src32[ka];
-    break;
-
- case BR_FFTOneChanNoSwapReduct :
-  case BR_FFTTwoChanNoSwapReduct :
-    // copie du header uniquement 
-   
-    for(int ka=0; ka<BRHDRSIZE/4; ka++)  dst32[ka] = src32[ka];
-
-    //DEL  on a plus de swapdonc il faut copier dans dst
-    //DEL    memcpy(dst_, src, sz_); 
-
-    // on reoordonne les coeff FFT (pas de swap) 
-    if (fgswap == BR_FFTOneChanNoSwap) ReorderFFTDataNoSwap((SByte*)(src+HeaderSize()), (SByte*)(tmp+HeaderSize()), DataSize());
-    else if (fgswap == BR_FFTTwoChanNoSwap) {
-      ReorderFFTDataNoSwap((SByte*)(src+HeaderSize()), (SByte*)(tmp+HeaderSize()), DataSize()/2);
-      ReorderFFTDataNoSwap((SByte*)(src+HeaderSize()+DataSize()/2), (SByte*)(tmp+HeaderSize()+DataSize()/2), DataSize()/2);
-    }
-    memcpy(tmp+ HeaderSize(), src+(binMin+ HeaderSize()), nbBin); 
-   memcpy(tmp+ (HeaderSize()+ nbBin ), src+(binMin+ HeaderSize()+sz_/2), nbBin); 
-   memcpy(tmp+( HeaderSize()+( 2* nbBin)),src+(HeaderSize()+DataSize()),TrailerSize());
-   memcpy(dst_+ HeaderSize(),tmp+ HeaderSize(),( 2* nbBin)+TrailerSize());
-    SetPaqLen( nbBin/2);
-
-    // copie du trailler uniquement : 
-    //  for(int ka=(HeaderSize()+DataSize())/4;ka < sz_/4; ka++)  dst32[ka] = src32[ka];
-     break;
+
+  default:
+    // on ne fait rien 
+    break;
   }  // Fin switch 
-
+  
 }
 
@@ -164 +187 @@
 BRPaquet::BRPaquet(Byte* srcdst, int paqsz)
 {
+  /*
+  if ((srcdst==NULL)||(paqsz<=(BRHDRSIZE+BRTRLSIZE))) 
+    throw BAORadioException("BRPaquet::BRPaquet(srcdst) NULL pointer OR paqsz<HDR+TRLSize");  
+  */
   dst_ = srcdst;
   sz_ = paqsz;
-  // Il faut mettre une protection (throw) si srcdst==NULL ou sz==0
+}
+
+/* --Methode__ */
+BRPaquet::BRPaquet(int paqsz)
+{
+  /*
+  if (paqsz<=(BRHDRSIZE+BRTRLSIZE))
+    throw BAORadioException("BRPaquet::BRPaquet(paqsz) paqsz<HDR+TRLSize");  
+  */
+  dst_ = NULL;
+  sz_ = paqsz;
+}
+
+/* --Methode__ */
+void BRPaquet::CopyFrom(BRPaquet& pq, BRPaqReducAction ract, int offset)
+{
+  if (ract==BR_CopyRA) {
+    if (PaquetSize()!=pq.PaquetSize()) 
+      throw BAORadioException("BRPaquet::CopyFrom(BR_CopyRA) - NOT equal paquet size");
+      memcpy(Begin(), pq.Begin(), PaquetSize()); 
+      return;
+  }
+  // Recopie de l'entete HDR et trailer TRL 
+  memcpy(Header(), pq.Header(), HeaderSize()); 
+  memcpy(Trailer(), pq.Trailer(), TrailerSize());
+  // Recopie partielle des donnees 
+  size_t szc, szcmx;
+  switch (ract) {
+  case BR_OneChanReduc:
+  case BR_OneChanReducK0:
+    szc = DataSize();
+    szcmx = pq.DataSize()-offset;
+    if (szcmx<szc) szc=szcmx;
+    memcpy(Data1(), pq.Data1(), szc);
+    if (ract==BR_OneChanReducK0)   *(Data1C()) = *(pq.Data1C());  // On garde le continu et le nyquist   
+    SetPaqLen(szc/4);  
+    break;
+  case BR_TwoChanReduc:
+  case BR_TwoChanReducK0:
+    szc = DataSize()/2;
+    szcmx = pq.DataSize()/2-offset;
+    if (szcmx<szc) szc=szcmx;
+    memcpy(Data1(), pq.Data1(), szc);
+    memcpy(Data2(), pq.Data2(), szc);
+    if (ract==BR_TwoChanReducK0)  {   // On garde le continu et le nyquist  
+      *(Data1C()) = *(pq.Data1C()); 
+      *(Data2C()) = *(pq.Data2C()); 
+    }
+    SetPaqLen(szc/2);  
+    break;
+  default:
+    break;
+  }
 }
 
@@ -294 +373 @@
 
 /* --Methode__ */
-void BRPaquet::ReorderFFTData(SByte* src, SByte* dst, int N)
-{
+void BRPaquet::ReorderFFTDataSwapAll(SByte* src, SByte* dst, int N)
+{
+  // Remise en ordre des donnees avec swap complet sur 8 bytes 
   // Code recopie depuis /Dev/DisplayData/HistoWindow.cc 
   // fonction TraceWind::DisplayBaoDatasFFT() et adapte aux structures BRPaquet et Cie 
@@ -342 +422 @@
 }
 
-void BRPaquet::ReorderFFTData32(SByte* src, SByte* dst, int N)
-{
+/* --Methode__ */
+void BRPaquet::ReorderFFTDataSwap32(SByte* src, SByte* dst, int N)
+{
+  // Remise en ordre avec echange (swap) des mots de 32 bits 
   // Code recopie depuis /Dev/DisplayData/HistoWindow.cc 
   // fonction TraceWind::DisplayBaoDatasFFT() et adapte aux structures BRPaquet et Cie 
@@ -384 +466 @@
   return ; 
 }
-void BRPaquet::ReorderFFTDataNoSwap(SByte* src, SByte* dst, int N)
-{
+
+/* --Methode__ */
+void BRPaquet::ReorderFFTData(SByte* src, SByte* dst, int N)
+{
+  // Remise en ordre des donnees FFT (sans swap) 
   // Code recopie depuis /Dev/DisplayData/HistoWindow.cc 
   // fonction TraceWind::DisplayBaoDatasFFT() et adapte aux structures BRPaquet et Cie 
@@ -428 +513 @@
 
 /* --Methode__ */
-const char* BRPaquet::FmtConvToString(BRDataFmtConv fgswap)
+const char* BRPaquet::FmtConvToString(BRDataFmtConv fgconv)
 {
   const char * rs="";
-  switch ( fgswap ) {
+  switch ( fgconv ) {
   case BR_DoNothing :  
     rs = "BR_DoNothing";
@@ -441 +526 @@
     rs = "BR_SwapAll";
     break;
+  case BR_Swap32 :
+    rs = "BR_Swap32";
+    break;
+  case BR_CopyHDR :
+    rs = "BR_CopyHDR";
+    break;
   case BR_SwapHDR :
     rs = "BR_SwapHDR";
@@ -450 +541 @@
     rs = "BR_FFTTwoChan";
     break;
-  case BR_Swap32 :
-    rs = "BR_Swap32";
-    break;
-  case BR_FFTOneChan32 :
-    rs = "BR_FFTOneChan32";
-    break;
-  case BR_FFTTwoChan32 :
-    rs = "BR_FFTTwoChan32";
-    break;
-  case BR_FFTOneChanNoSwap :
-    rs = "BR_FFTOneChanNoSwap";
-    break;
-  case BR_FFTTwoChanNoSwap :
-    rs = "BR_FFTTwoChanNoSwap";
+  case BR_FFTOneChanSwapAll :
+    rs = "BR_FFTOneChanSwapAll";
+    break;
+  case BR_FFTTwoChanSwapAll :
+    rs = "BR_FFTTwoChanSwapAll";
+    break;
+  case BR_FFTOneChanSwap32 :
+    rs = "BR_FFTOneChanSwap32";
+    break;
+  case BR_FFTTwoChanSwap32 :
+    rs = "BR_FFTTwoChanSwap32";
     break;
   default:
@@ -476 +564 @@
 // --------------------------------------------------------------------------
 
+/* --Methode__ */
 BRPaqChecker::BRPaqChecker(bool cktrl, int maxprt)
 {
@@ -490 +579 @@
 }
 
+/* --Methode__ */
 BRPaqChecker::~BRPaqChecker()
 {
@@ -500 +590 @@
 }
 
+/* --Methode__ */
 UInt64 BRPaqChecker::DefineTRLTag(UInt32 trl1, UInt32 trl2)
 {
@@ -506 +597 @@
 }
 
-
+/* --Methode__ */
 bool BRPaqChecker::Check(BRPaquet& paq, UInt64& numframe)
 {
@@ -543 +634 @@
 }
 
+/* --Methode__ */
 ostream& BRPaqChecker::Print(ostream& os) const
 {
@@ -556 +648 @@
   return os;
 }
+
+/* --Methode__ */
+string BRPaqChecker::Summary(bool detail) const
+{
+  double meangap = (cnt_saut>0)?((double)lostframes/(double)cnt_saut):0.;
+  double lossrate= (double)lostframes*100./(double)totnframes;
+  char buff[256];
+  if (detail) 
+    sprintf(buff, " TotNPaq= %ld  HDR/TRL OK= %ld LostFrames= %ld LossRate= %lg NbGaps= %ld MeanGap= %lg",
+            (long)totnframes, (long)nframeok, (long)lostframes, lossrate, (long)cnt_saut, meangap);
+  else 
+    sprintf(buff, "TotNPaq=%ld  N_Ok=%ld LossRate=%lg", (long)totnframes, (long)nframeok, lossrate); 
+  return buff;
+}
+

trunk/AddOn/TAcq/brpaqu.h

@@ -9 +9 @@
 #include <stdio.h>
 #include <iostream>
+#include <exception>
 #include <string>
 #include "brtypes.h"
@@ -14 +15 @@
 
 using namespace std;
+
+// ---------------------------------------------------------
+// ----- Classe d'exception pour Acquisition BAORadio ------
+#define BREX_MAXMSGLEN 160
+
+class BAORadioException : public std::exception {
+  public:
+  explicit BAORadioException(const char * m) throw() ; 
+  explicit BAORadioException(const string& m) throw() ;
+  virtual ~BAORadioException() throw() ; 
+  //! Implementation of std::exception what() method, returning the exception message
+  virtual const char* what() const throw();
+  virtual string const Msg() const ; 
+ private:
+  char msg_[BREX_MAXMSGLEN];
+};
+
+
 
 // ------------------------------------------------
@@ -38 +57 @@
 
   inline double realD() { return  (double)(val_)[0]; }
-      inline double imagD() { return  (double)(val_)[1]; }
+  inline double imagD() { return  (double)(val_)[1]; }
 
   SByte val_[2];
 };
 
-// ------------------------------------------------
+// --------------------------------------------------------
+// ----- Classe BRPaquet , constante et enum associe ------
+//     Representation, manipulation des paquets/frames 
+//     envoyes par les cartes ADC  
+// --------------------------------------------------------
 
 // OFFSET : au cas ou le firmware reception ajoute des mots avant le header 
@@ -68 +91 @@
 //#define BRPCOFF 16
 
-enum ChannelID
-  {
-    None=0,
-    Ch1,
-    Ch2,
-    Ch1_2,
-    Ch3,
-    Ch4,
-    Ch3_4
-  };
-enum ModeAcq
-  {
-    RawData=1,
-    FFT
-  };
+enum ChannelID { None=0, Ch1, Ch2, Ch1_2, Ch3, Ch4, Ch3_4 };
+enum ModeAcq { RawData=1, FFT };
 
 // Definition des actions sur la conversion de format (swap...) des donnees arrivant
 enum BRDataFmtConv {
-  BR_DoNothing,
-  BR_Copy,
-  BR_SwapAll,
-  BR_SwapHDR,
-  BR_FFTOneChan,
-  BR_FFTTwoChan,
-  BR_Swap32,
-  BR_FFTOneChan32,
-  BR_FFTTwoChan32,
-  BR_FFTOneChanNoSwap,
-  BR_FFTTwoChanNoSwap,
-  BR_CpHdrTrl,
-  BR_Copy_Reduc,
-  BR_FFTOneChanNoSwapReduct,
-  BR_FFTTwoChanNoSwapReduct
-};
-
+  BR_DoNothing, BR_Copy, BR_SwapAll, BR_Swap32, BR_CopyHDR, BR_SwapHDR, 
+  BR_FFTOneChan, BR_FFTTwoChan,  
+  BR_FFTOneChanSwapAll, BR_FFTTwoChanSwapAll, 
+  BR_FFTOneChanSwap32, BR_FFTTwoChanSwap32,
+};
+
+// Definition des action pour recopie de paquet avec reduction de taille de paquet
+//    Copie complete (--> egalite de taille, 1,2 canaux, K0 -> Keep first two bytes (Continu/Nyquist) 
+enum BRPaqReducAction {
+  BR_CopyRA, BR_OneChanReduc, BR_TwoChanReduc, BR_OneChanReducK0, BR_TwoChanReducK0
+};
+
+//---- Classe BRPaquet 
 // Structure correspondant a HEADER-DATA-TRAILER
 class BRPaquet {
  public:
 // Cree d'un objet BRPaquet avec copie/swap depuis src -> dst (si src != NULL)
-  BRPaquet(Byte* src, Byte* dst, int paqsz=16424, BRDataFmtConv fgswap=BR_Copy,int minBin=0,int nbBin=0);
+  BRPaquet(Byte* src, Byte* dst, int paqsz, BRDataFmtConv fgconv=BR_Copy);
   // Cree d'un objet BRPaquet de taille paqsz sur la zone dst   
-  BRPaquet(Byte* srcdst, int paqsz=16424);
+  BRPaquet(Byte* srcdst, int paqsz);
+  BRPaquet(int paqsz);
+
   //  ~BRPaquet();
+
+  // Pour la copie/reduction de taille de paquet 
+  void CopyFrom(BRPaquet& pq, BRPaqReducAction ract=BR_CopyRA, int offset=0);
 
   // Acces diverses tailles 
@@ -175 +186 @@
 
   // fonction appelee par le constructeur pour reordonner les donnees FFT 
+  // --- Remise en ordre avec swap complet sur 8 bytes 
+  static void ReorderFFTDataSwapAll(SByte* src, SByte* dst, int sz);
+  // --- Remise en ordre avec echanges des mots de 4 bytes 
+  static void ReorderFFTDataSwap32(SByte* src, SByte* dst, int sz);
+  // --- Remise en ordre seulement 
   static void ReorderFFTData(SByte* src, SByte* dst, int sz);
-  static void ReorderFFTData32(SByte* src, SByte* dst, int sz);
-  static void ReorderFFTDataNoSwap(SByte* src, SByte* dst, int sz);
-  static const char* FmtConvToString(BRDataFmtConv fgswap);
+  static const char* FmtConvToString(BRDataFmtConv fgconv);
 // protected:
   // donnees membres
@@ -209 +223 @@
   ostream & Print(ostream& os) const;
   inline ostream & Print() const { return Print(cout); }
+  // renvoie le resume de la statistique paquets sous forme de chaine
+  string Summary(bool detail=false) const;
 
   // Acces aux differents compteurs 

trunk/AddOn/TAcq/makefile

@@ -6 +6 @@
 # all : traidio  tmtfft tstminifits tbrpaq tpciew tmtacq tstrdfits mfits2spec tsok 
 # all : traidio  tmtfft tstminifits tmtacq tstrdfits mfits2spec tsok mcrd
-all : traidio tstminifits tmtacq mfits2spec mcrd svv2mtx tsok
+all :  mfacq tmtacq mfits2spec mcrd svv2mtx tsok traidio tstminifits
 
 clean :
@@ -18 +18 @@
 
 ##   --------------
+mfacq : $(EXE)mfacq
+        echo '---mfacq made'
+
+$(EXE)mfacq : $(OBJ)mfacq.o $(OBJ)brparam.o $(OBJ)racqumem.o $(OBJ)racqurw.o $(OBJ)racquproc.o \
+               $(OBJ)brpaqu.o $(OBJ)pciewrap.o $(OBJ)minifits.o
+        $(CXXLINK) -o $(EXE)mfacq $(OBJ)mfacq.o $(OBJ)brparam.o $(OBJ)racqumem.o $(OBJ)racqurw.o \
+              $(OBJ)racquproc.o $(OBJ)brpaqu.o $(OBJ)pciewrap.o $(OBJ)minifits.o $(SOPHYAALLSLBLIST)
+
+$(OBJ)mfacq.o : mfacq.cc brparam.h racquproc.h racqurw.h racqumem.h brpaqu.h
+        $(CXXCOMPILE) -c -DNOPCIECARD -o $(OBJ)mfacq.o mfacq.cc 
+
+
 tmtacq : $(EXE)tmtacq
         echo '---tmtacq made'
 
-$(EXE)tmtacq : $(OBJ)tmtacq.o  $(OBJ)racqumem.o $(OBJ)racqurw.o $(OBJ)racquproc.o \
+$(EXE)tmtacq : $(OBJ)tmtacq.o  $(OBJ)brparam.o $(OBJ)racqumem.o $(OBJ)racqurw.o $(OBJ)racquproc.o \
                $(OBJ)brpaqu.o $(OBJ)pciewrap.o $(OBJ)minifits.o
-        $(CXXLINK) -o $(EXE)tmtacq $(OBJ)tmtacq.o $(OBJ)racqumem.o $(OBJ)racqurw.o $(OBJ)racquproc.o \
-                      $(OBJ)brpaqu.o $(OBJ)pciewrap.o $(OBJ)minifits.o $(SOPHYAALLSLBLIST)
+        $(CXXLINK) -o $(EXE)tmtacq $(OBJ)tmtacq.o $(OBJ)brparam.o $(OBJ)racqumem.o $(OBJ)racqurw.o \
+               $(OBJ)racquproc.o $(OBJ)brpaqu.o $(OBJ)pciewrap.o $(OBJ)minifits.o $(SOPHYAALLSLBLIST)
 
 $(OBJ)tmtacq.o : tmtacq.cc racquproc.h racqurw.h racqumem.h brpaqu.h
         $(CXXCOMPILE) -c -DNOPCIECARD -o $(OBJ)tmtacq.o tmtacq.cc 
+
+$(OBJ)brparam.o : brparam.cc brparam.h
+        $(CXXCOMPILE) -c -o $(OBJ)brparam.o brparam.cc 
 
 $(OBJ)racqumem.o : racqumem.cc racqumem.h
@@ -43 +58 @@
         echo '---mcrd made'
 
-$(EXE)mcrd : $(OBJ)mcrd.o  $(OBJ)racqumem.o $(OBJ)brfitsrd.o $(OBJ)brproc.o $(OBJ)racquproc.o $(OBJ)brpaqu.o \
+$(EXE)mcrd : $(OBJ)mcrd.o  $(OBJ)brparam.o $(OBJ)racqumem.o $(OBJ)brfitsrd.o $(OBJ)brproc.o $(OBJ)racquproc.o $(OBJ)brpaqu.o \
              $(OBJ)racqurw.o $(OBJ)pciewrap.o $(OBJ)minifits.o
-        $(CXXLINK) -o $(EXE)mcrd $(OBJ)mcrd.o $(OBJ)racqumem.o $(OBJ)brfitsrd.o $(OBJ)brproc.o $(OBJ)racquproc.o \
+        $(CXXLINK) -o $(EXE)mcrd $(OBJ)mcrd.o $(OBJ)brparam.o  $(OBJ)racqumem.o $(OBJ)brfitsrd.o $(OBJ)brproc.o $(OBJ)racquproc.o \
                       $(OBJ)brpaqu.o $(OBJ)racqurw.o $(OBJ)pciewrap.o $(OBJ)minifits.o $(SOPHYAALLSLBLIST)
 

trunk/AddOn/TAcq/minifits.cc

@@ -97 +97 @@
   if (fip != NULL) throw MiniFITSException("MiniFITSFile::Open() - fip != NULL");
   if (rwm == MF_Write) {
+    for(int i=0; i<MFITSHLEN; i++)  header[i]=' ';
+    nkeya_ = 0;
     FillHeader();
     fip = fopen(nom, "w");
@@ -119 +121 @@
 {
   if (fip) { 
-        if (rwmode == MF_Write)  {  
-          // on remplit avec des zeros pour avoir une longueur multiple de 2880 
-          size_t padsz = MFITSHLEN-(totwsz%MFITSHLEN);
-          char zeros[160];
-          for(size_t k=0; k<160; k++) zeros[k]=0;
-          while(padsz>160) {
-            fwrite(zeros, 1, 160, fip);
-            padsz-=160;
-          }
-          if (padsz>0)  fwrite(zeros, 1, padsz, fip);
-          // On reecrit l'entete 
-          FillHeader();
-          fseek(fip, 0, SEEK_SET);
-          fwrite(header, 1, MFITSHLEN, fip);
-        }       
-        fclose(fip);
+    if (rwmode == MF_Write)  {  
+      // on remplit avec des zeros pour avoir une longueur multiple de 2880     
+      size_t padsz = MFITSHLEN-(totwsz%MFITSHLEN);
+      char zeros[160];
+      for(size_t k=0; k<160; k++) zeros[k]=0;
+      while(padsz>160) {
+        fwrite(zeros, 1, 160, fip);
+        padsz-=160;
+      }
+      if (padsz>0)  fwrite(zeros, 1, padsz, fip);
+      // On reecrit l'entete 
+      FillHeader();
+      fseek(fip, 0, SEEK_SET);
+      fwrite(header, 1, MFITSHLEN, fip);
+    }   
+    fclose(fip);
   }
   fip = NULL;
@@ -187 +189 @@
   else if (dtype == MF_Float32) bpix = -32;
   char * buff = header+80;
-  sprintf(buff, "BITPIX  = %20d /   number of bits per data pixel", bpix);
+  sprintf(buff, "BITPIX  = %20d / number of bits per data pixel", bpix);
   buff[strlen(buff)] = ' ';
   buff = header+160;
@@ -193 +195 @@
   buff[strlen(buff)] = ' ';
   buff = header+240;
-  sprintf(buff, "NAXIS1  = %20ld /   number of bits per data pixel", (long)nax1);
+  sprintf(buff, "NAXIS1  = %20ld / nb of pixels along X = PaquetSize", (long)nax1);
   buff[strlen(buff)] = ' ';
   buff = header+320;
-  sprintf(buff, "NAXIS2  = %20ld /   number of bits per data pixel", (long)nax2);
+  sprintf(buff, "NAXIS2  = %20ld / nb of rows = NumberOfPaquets", (long)nax2);
   buff[strlen(buff)] = ' ';
   buff = header+400+nkeya_*80;
@@ -248 +250 @@
     sprintf(buff,"%s %20lg / %s", cle, val, tcom);
   }
-  else  sprintf(buff,"%s %20ld / ", cle, val);
+  else  sprintf(buff,"%s %20lg / ", cle, val);
   buff[strlen(buff)] = ' ';
   nkeya_++;

trunk/AddOn/TAcq/pciewrap.cc

@@ -57 +57 @@
   paq.SetHDRMarker64(pchk_.HDRTag());
   paq.SetTRLMarker64(pchk_.TRLTag());
-  paq.SetFrameCounter(frame_counter_);
+  UInt16 cfc = (frame_counter_%65535);
+  paq.SetFrameCounter(cfc);
   paq.SetTimeTag(timetag_);
   paq.SetPaqLen((UInt16)((size_ - BRHDRSIZE - BRTRLSIZE)/4));

trunk/AddOn/TAcq/racqumem.cc

@@ -89 +89 @@
         for(uint_4 k=0; k<NbZones(); k++) {
           if ((states[k].act == MemZA_None) && 
-              (states[k].stat & MemZS_Filled) && !(states[k].stat & MemZS_Proc) ) { 
+              (states[k].stat & MemZS_Saved) && !(states[k].stat & MemZS_Proc) ) { 
             if (states[k].serial < bestserial) { rid=k; bestserial=states[k].serial; } 
           }

trunk/AddOn/TAcq/racquproc.cc

@@ -123 +123 @@
     }
   }
-  catch (PException& exc) {
-    cout << " DataProc::run()/catched PException " << exc.Msg() << endl;
+  catch (std::exception& exc) {
+    cout << " DataProc::run()/catched std::exception " << exc.what() << endl;
     setRC(3);   
     return; 
@@ -242 +242 @@
     }
   }
-  catch (PException& exc) {
-    cout << " DataProc2C::run()/catched PException " << exc.Msg() << endl;
+  catch (std::exception& exc) {
+    cout << " DataProc::run()/catched std::exception " << exc.what() << endl;
     setRC(3);   
     return; 
@@ -360 +360 @@
     }
   }
-  catch (PException& exc) {
-    cout << " DataProcFFT2C::run()/catched PException " << exc.Msg() << endl;
+  catch (std::exception& exc) {
+    cout << " DataProc::run()/catched std::exception " << exc.what() << endl;
     setRC(3);   
     return; 

trunk/AddOn/TAcq/racqurw.cc

@@ -464 +464 @@
 
 /* --Methode-- */
-PCIEMultiReader::PCIEMultiReader(vector<PCIEWrapperInterface*> vec_pciw,uint_4 sizeFrame,uint_4 packSize ,RAcqMemZoneMgr& mem, uint_4 nmax, BRDataFmtConv swapall,int binMin, int nbBin)
+PCIEMultiReader::PCIEMultiReader(vector<PCIEWrapperInterface*> vec_pciw,uint_4 sizeFrame,uint_4 packSize ,RAcqMemZoneMgr& mem, uint_4 nmax, BRDataFmtConv swapall)
   :   memgr(mem) , vec_pciw_ (vec_pciw)
 {
@@ -473 +473 @@
   packSizeInMgr_=memgr.PaqSize();
   sizeFr_ =sizeFrame;
-  binMin_= binMin;
-  nbBin_= nbBin;
   if (vec_pciw.size() != memgr.NbFibres()) {
     cout << " PCIEMultiReader()PbArgs: vec_pciw.size()= " << vec_pciw.size() << " memgr.NbFibres()=" <<memgr.NbFibres()<< endl;
@@ -572 +570 @@
             setRC(9);  fgarret=true; break;
           }
-          BRPaquet paq(tampon[fib], nextpaq, paqsz, swapall_,binMin_,nbBin_);
+          BRPaquet paq(tampon[fib], nextpaq, paqsz, swapall_);
+          // CHECK  S'il faut faire une reduction de taille de paquet
           npaqfait[fib]++;
           if (fib==nbDma_-1) npaqfaitg++;  // Ne pas oublier le compteur de paquets faits 
@@ -601 +600 @@
           setRC(9);  fgarret=true; break;
         }
-        BRPaquet paq(Datas[fib]+curoff, nextpaq, paqsz, swapall_,binMin_,nbBin_);
+        BRPaquet paq(Datas[fib]+curoff, nextpaq, paqsz, swapall_);
+        // CHECK  S'il faut faire une reduction de taille de paquet
         npaqfait[fib]++;
         if (fib==nbDma_-1) npaqfaitg++;  // Ne pas oublier le compteur de paquets faits 
@@ -688 +688 @@
 //--------------------------------------------------------------------
 
-MultiDataSaver::MultiDataSaver(RAcqMemZoneMgr& mem, string& path, uint_4 nfiles, uint_4 nblocperfile, bool savesig)
-  :  memgr(mem) 
+MultiDataSaver::MultiDataSaver(RAcqMemZoneMgr& mem, string path, uint_4 nfiles, uint_4 nblocperfile, bool savesig)
+  :  memgr(mem)
 {
   nfiles_ = nfiles;
@@ -708 +708 @@
   setRC(1);     
   BRPaqChecker pcheck[MAXNBFIB];  // Verification/comptage des paquets 
-
+  BRAcqConfig bpar;
   try {
     TimeStamp ts; 
@@ -732 +732 @@
       fgnulldev = true;
     }
+    BRPaquet paq0(NULL, NULL, paqsz); 
     for (uint_4 nbFile=0;nbFile<nfiles_ ;nbFile++) {
       if (stop_ )   break;
@@ -742 +743 @@
           header[fib].open(fname);
         }
-      BRPaquet paq0(NULL, NULL, paqsz); 
+    
       uint_4 npaqperfile = memgr.NbPaquets()*nblocperfile_;  // Nombre de paquets ecrits dans un fichier 
 
       if (savesig_) { //Reza - Ouverture conditionnel fichier 
-        for(uint_4 fib=0; fib<memgr.NbFibres(); fib++) {
+        for(uint_4 fib=0; fib<memgr.NbFibres(); fib++)    {
           if (fgnulldev) strcpy(fname,"/dev/null");
           else sprintf(fname,"%s/Fibre%d/signal%d.fits",path_.c_str(),fib+1,(int)fnum);
           mff[fib].Open(fname,MF_Write);  //Reza - Ouverture conditionnel fichier 
           // Entete correspondant a l'ecriture tout le paquet - trailer compris (modif Mai 2009)
-          mff[fib].setDTypeNaxis(MF_Byte, paq0.PaquetSize(), npaqperfile);
-        }
+          mff[fib].setDTypeNaxis(MF_Byte, paq0.PaquetSize(), npaqperfile);      
+        // Sans TRAILER de paquet mff.setDTypeNaxis(MF_Byte, paq0.DataSize()+paq0.HeaderSize(), npaqperfile); 
+        }
+        // Ajout mots-cle additionnels a tous les fichiers FITS
+        AddFitsKW(mff,bpar);
         fnum++;
-        // Sans TRAILER de paquet mff.setDTypeNaxis(MF_Byte, paq0.DataSize()+paq0.HeaderSize(), npaqperfile); 
       }
       else sprintf(fname,"MemDataBloc[%d]-NoDataFile",(int)fnum++);
@@ -765 +768 @@
         if (buffg == NULL) {
           cout << " MultiDataSaver::run()/ERROR memgr.GetMemZone(" << mid << ") -> NULL" << endl;
-          setRC(2);     
+          setRC(21);    
           return;       
         }
@@ -772 +775 @@
           if (buff == NULL) {  // Ceci ne devrait pas arriver - suite au test buffg ci-dessus
             cout << " MultiDataSaver::run()/ERROR memgr.GetMemZone(" << mid << "," << fib << ") -> NULL" << endl;
-            setRC(2);   
+            setRC(22);  
             return;     
           }
@@ -797 +800 @@
         }
         else sprintf(fname,"MemDataBloc[%d]-NoDataFile",(int)fnum-1);
-        filog << "    Fib " << fib << " -> " << fname << endl;
-        cout << "    Fib " << fib << " -> " << fname << endl;
+        string pcsum = pcheck[fib].Summary();
+        filog << "    Fib " << fib << " -> " << fname << " Stat:" << pcsum << endl;
+        cout  << "    Fib " << fib << " -> " << fname << " Stat:" << pcsum << endl;
       }
       if (savesig_)
@@ -805 +809 @@
           mff[fib].Close();       
         }
+    
+     
     }  // Fin de boucle sur les fichiers 
     cout << " --------------------  MultiDataSaver::run() -------------------- " << endl;
@@ -832 +838 @@
 }   
 
+
+/* --Methode-- */
+int MultiDataSaver::AddFitsKW(MiniFITSFile* mff, BRAcqConfig& acpar)
+{ 
+  TimeStamp ts;
+  string cdtu=ts.ToString();
+  for(uint_4 fib=0; fib<memgr.NbFibres(); fib++) {
+    mff[fib].AddKeyS("DATE", cdtu.c_str(), " File Creation time(YYYY-MM-DDThh:mm:ss UT) ");       
+    mff[fib].AddKeyS("DATEOBS", cdtu.c_str(), " Observation Time (YYYY-MM-DDThh:mm:ss UT) ");
+    mff[fib].AddKeyD("ACQVER", acpar.AcqVersion(), " BAORadio Acq Software version ") ;
+    mff[fib].AddKeyS("ACQCONF", acpar.GetParams().AcqMode, " BAORadio Acq run  mode" );
+  }
+  return 0;
+}
+

trunk/AddOn/TAcq/racqurw.h

@@ -15 +15 @@
 #include "zthread.h"
 #include "pciewrap.h"
-
 #include "brtypes.h"
 #include "brpaqu.h"
+#include "brparam.h"
+#include "minifits.h"
 
 using namespace std;
@@ -61 +62 @@
   uint_4 max_targ_npaq; // =  mmgr.NbPaquets() = Max de targ_npaq_
   Byte* mmbuf_;  // Pointeur zone memoire rendu par RAcqMemZoneMgr 
+
 };
 
@@ -113 +115 @@
 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);  
+                   uint_4 nmax=100, BRDataFmtConv swapall=BR_SwapAll);  
   virtual void run(); 
    void Stop();
@@ -142 +144 @@
   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 
@@ -160 +160 @@
 class MultiDataSaver : public ZThread {
 public: 
-  MultiDataSaver(RAcqMemZoneMgr& mem, string& path, uint_4 nfiles=100, uint_4 nblocperfile=1, bool savesig=true);
+  MultiDataSaver(RAcqMemZoneMgr& mem, string path, uint_4 nfiles=100, uint_4 nblocperfile=1, bool savesig=true);
 
   virtual void run(); 
@@ -166 +166 @@
   inline void STOP() { stop_ = true; }  
 protected:
+  int  AddFitsKW(MiniFITSFile* mff, BRAcqConfig& acpar);
+
   RAcqMemZoneMgr& memgr;
   uint_4 nfiles_;  // Nombre maxi de fichiers cree
@@ -174 +176 @@
   string path_;  
   struct sigaction act;
- 
 };
 

trunk/AddOn/TAcq/tmtacq.cc

@@ -29 +29 @@
 
 
-//--------------------------------------------------------
+//-----------------------------------------------------------------------
 // Programme test acquisition BAORadio multi-thread 
 //  LAL -   R. Ansari Juillet -  2008
 //          M.Taurigna    2009
-//--------------------------------------------------------
+// == Programme reste a la version de Mai 2009 (1er tests Pittsburgh) ==
+//-----------------------------------------------------------------------
 
 
@@ -115 +116 @@
 static  bool activate_pattern=false;  // true -> on active le pattern du firmware au lieu de la fibre
 static  uint_4 NMaxBloc = 10; 
+static  double nopciLossRate = 0.; // Taux de perte simule des paquets par TestPCIWrapperNODMA 
 //---------------------------- FIN parametres de controle -----------------
 
@@ -178 +180 @@
   if (fgshort) {
     cout << " Usage: tmtacq CardNum PaquetSize NFrameDMA NFiles NBlocPerFile \n"
-         << "                 NMaxProc DataDirPath [AcqMode] [MemZoneMgr][HardCtlC]" << endl;
+        << "             NMaxProc DataDirPath [AcqMode] [MemZoneMgr] [HardCtlC] [NoPCILossRate]" << endl;
     cout << "   type tmtacq -h for detailed usage " << endl;
     return;
@@ -184 +186 @@
 
    cout << "\n Usage: tmtacq CardNum PaquetSize NFrameDMA NFiles NBlocPerFile \n"
-        << "                 NMaxProc DataDirPath [AcqMode] [MemZoneMgr][HardCtlC]" << endl;
+        << "             NMaxProc DataDirPath [AcqMode] [MemZoneMgr] [HardCtlC] [NoPCILossRate]" << endl;
    cout << " - CardNum : PCI-Express card number (=1 OR 2 OR 1,2)" << endl;
    cout << " - PaquetSize or FrameSize (=DATA+HDR+TRL_Size)  " << endl;
@@ -209 +211 @@
    cout << " - MemZoneMgr: nZones,NPaq =Number of Zones and number of paquet \n"
         << "               in each zone (Default=4,128) "<< endl;
-   cout << " -HardCtlC : Y y (direct interrpution by CtrlC ) default (no) " << endl;
+   cout << " - HardCtlC : Y y (direct interrpution by CtrlC ) or no  (default=no) " << endl;
+   cout << " - NoPCILossRate : Simulated NO-PCI loss rate (0<rate<1 default=0.) " << endl;
+
    cout << endl;
    cout << " - AcqMode for previous firmware with 32bits-byteswap"<<endl;
@@ -315 +319 @@
   }
 
-  nZones = 8;  // Nombre de zones memoires
+  nZones = 4;  // Nombre de zones memoires
   nPaqZone = 128;  // 128 Paquets / zone memoire - valeur par defaut
   if (narg > 9)  { 
@@ -333 +337 @@
     sigaction(SIGINT,&act,NULL);        
   }
+
+  nopciLossRate = 0.; // Taux de perte simule des paquets par TestPCIWrapperNODMA 
+  if (narg > 11)  nopciLossRate=atof(arg[11]);
 
   PaqSZ =sizeFrame;  // Taille de paquets 
@@ -360 +367 @@
   if (acqmode == "nosw")   swapall = BR_Copy ;
   if (acqmode == "nof")  { swapall = BR_Copy ; savesigfits = false; }
-  if (acqmode == "fft1c")  swapall = BR_FFTOneChanNoSwap;
-  if (acqmode == "fft2c")  swapall = BR_FFTTwoChanNoSwap;
-  if (acqmode == "fft1cnof")  { swapall = BR_FFTOneChanNoSwap;  savesigfits = false; }
-  if (acqmode == "fft2cnof")  { swapall = BR_FFTTwoChanNoSwap;  savesigfits = false; }
+  if (acqmode == "fft1c")  swapall = BR_FFTOneChan;
+  if (acqmode == "fft2c")  swapall = BR_FFTTwoChan;
+  if (acqmode == "fft1cnof")  { swapall = BR_FFTOneChan;  savesigfits = false; }
+  if (acqmode == "fft2cnof")  { swapall = BR_FFTTwoChan;  savesigfits = false; }
   if (acqmode == "mono")  { monothr = true;   swapall = BR_Copy; }
   if (acqmode == "patmono")  { monothr = true;   swapall = BR_Copy; activate_pattern=true; }
@@ -370 +377 @@
 
   if (acqmode == "swapall")  swapall = BR_SwapAll;
-  if (acqmode == "fft1csw")  swapall = BR_FFTOneChan;
-  if (acqmode == "fft2csw")  swapall = BR_FFTTwoChan;
-  if (acqmode == "fft1cswnof")  { swapall = BR_FFTOneChan;  savesigfits = false; }
-  if (acqmode == "fft2cswnof")  { swapall = BR_FFTTwoChan;  savesigfits = false; }
+  if (acqmode == "fft1csw")  swapall = BR_FFTOneChanSwapAll;
+  if (acqmode == "fft2csw")  swapall = BR_FFTTwoChanSwapAll;
+  if (acqmode == "fft1cswnof")  { swapall = BR_FFTOneChanSwapAll;  savesigfits = false; }
+  if (acqmode == "fft2cswnof")  { swapall = BR_FFTTwoChanSwapAll;  savesigfits = false; }
   if ((acqmode == "swh") || (acqmode == "mxs") || (acqmode == "monoswh") )  swapall = BR_SwapHDR;
   if ((acqmode == "swapallnof") || (acqmode == "mxs") )  savesigfits = false;
@@ -381 +388 @@
   if (acqmode == "swap32")   swapall = BR_Swap32 ;
   if (acqmode == "nof32")   { swapall = BR_Swap32 ; savesigfits = false; }
-  if (acqmode == "fft1c32")  swapall = BR_FFTOneChan32;
-  if (acqmode == "fft2c32")  swapall = BR_FFTTwoChan32;
-  if (acqmode == "fft1cnof32")  { swapall = BR_FFTOneChan32;  savesigfits = false; }
-  if (acqmode == "fft2cnof32")  { swapall = BR_FFTTwoChan32;  savesigfits = false; }
+  if (acqmode == "fft1c32")  swapall = BR_FFTOneChanSwap32;
+  if (acqmode == "fft2c32")  swapall = BR_FFTTwoChanSwap32;
+  if (acqmode == "fft1cnof32")  { swapall = BR_FFTOneChanSwap32;  savesigfits = false; }
+  if (acqmode == "fft2cnof32")  { swapall = BR_FFTTwoChanSwap32;  savesigfits = false; }
 
 }
@@ -398 +405 @@
   PCIEWrapperInterface* pciwp=NULL;
 #ifdef NOPCIECARD
-  TestPCIWrapperNODMA pciw(PaqSZ);
+  TestPCIWrapperNODMA pciw(PaqSZ,nopciLossRate);
   pciwp = &pciw;
 #else
@@ -494 +501 @@
 
 #ifdef NOPCIECARD
-  TestPCIWrapperNODMA pciw1(PaqSZ);
-  TestPCIWrapperNODMA pciw2(PaqSZ);
+  TestPCIWrapperNODMA pciw1(PaqSZ,nopciLossRate);
+  TestPCIWrapperNODMA pciw2(PaqSZ,nopciLossRate);
   pciwp1 = &pciw1;
   pciwp2 = &pciw2;

trunk/AddOn/TAcq/tmtacq.h

@@ -2 +2 @@
 #define TMTACQ_H
 #include <signal.h>
-#define BAOR_ACQ_VER 5.0
-#define BAOR_ACQ_VER_STR "BaoAcq_v5_Mai09 "
+#include "bracqvers.h"
 // ajout d'une gestion plus sure de l'arret par Controle C
 #endif