Changeset 3909 in Sophya for trunk/AddOn/TAcq/racqurw.cc

Timestamp:

Nov 21, 2010, 2:26:12 PM (15 years ago)

Author:

ansari

Message:

---

1/ Mise en place d'informations auxiliaires au niveau de RAcqMemZoneMgr ,

FillTime (DATEOBS) pour chaque zone et identificateur des fibres

2/ remplissage de FillTime(DATEOBS) Et FiberId's de MemZoneMgr par

les classes PCIEMultiReader et EthernetReader

3/ Ajout de mots-cle (ds les datacards) pour numeros d'identification des

fibres et parametres de controles du DMA (@fiberids @waitenddma)
et corrections/ameliorations des modes acq (raw1c ordfft2c ...)

4/ Parametrage des WaitEndDMA ds PCIEWrapperInterface et implementation

au niveau de DMAMgrV6 (dmamgrv6.h .cc)

5/ Gestion d'echec DMA -> arret acquisition ds PCIEMultiReader,EthernetReader

modification TimeOut DMA entre le premier DMA et les suivants pour permettre
un arret propre rapide

6/ Adaptation de la classe BRVisibilityCalculator pour utilisation

FillTime (DATEOBS) et FiberIds de MemZoneMgr - amelioration de
l'identification des numeros de canaux pour les matrices de visibilites

7/ Petites ameliorations (ecriture mot-cles) pour MultiDataSaver et

amelioration classe BRMultiFitsReader pour lecture FillTime (DATEOBS)
et FiberIds depuis les fichiers FITS et remplissage de RAcqMemZoneMgr

Reza, 21/11/2010

File:

• trunk/AddOn/TAcq/racqurw.cc (modified) (16 diffs)

trunk/AddOn/TAcq/racqurw.cc

@@ -487 +487 @@
   mmbuf_=NULL;
   max_targ_npaq = memgr.NbPaquets();
-  for (int fid=0 ; fid<(int)nbDma_ ;fid++) mmbufib_[fid]=NULL;
+  for (int fid=0 ; fid<(int)nbDma_ ;fid++) { 
+    memgr.FiberId(fid)=vec_pciw[fid]->FiberId(); 
+    mmbufib_[fid]=NULL;
+  }
 }
 
@@ -507 +510 @@
   uint_4 paqsz =  packSize_;
   uint_4 dmasz = vec_pciw_[0]->TransferSize();
-  vec_pciw_[0]->StartTransfers();
+  //DEL   vec_pciw_[0]->StartTransfers();
 
   BRPaqChecker pcheck[MAXNBFIB];  // Verification/comptage des paquets  
@@ -516 +519 @@
   uint_4 off_acheval=0;
   
-  int nerrdma = 0;
-  int maxerrdma = 10;
   bool fgarret = false;
   
@@ -523 +524 @@
   for (int i=0;i< (int)nbDma_ ;i++) {  
     tampon[i]=   new Byte[paqsz];
+    vec_pciw_[i]->SetMaxWaitEndDMA(par_.first_maxkwedma_,par_.first_nretrydma_);
   }
   bool fgredpaq=par_.fgreducpsize;
@@ -551 +553 @@
     // Lancement des DMA 
     for (int dma=0; dma < (int)nbDma_ ;dma++) vec_pciw_[dma]->StartTransfers();
-    
+    if (npaqfaitg==1)  { 
+      for (int i=0;i< (int)nbDma_ ;i++)
+        vec_pciw_[i]->SetMaxWaitEndDMA(par_.maxkwedma_,par_.nretrydma_);
+    }
     // On pointe vers le debut de la zone a remplir aver le prochain DMA
     //-- Zone memoire locale Byte* nextdma = buff+i*paqsz;
@@ -560 +565 @@
       Datas[dma]=vec_pciw_[dma]->GetData();
       if (Datas[dma] == NULL) { // No data Read in DMA 
-        nerrdma ++;   fgbaddma=true;
-        cout << "PCIEMultiReaderChecker/Erreur Waiting for datas ..." << endl;
+        fgbaddma=true;
+        cout << "PCIEMultiReaderChecker/Error Waiting for datas ..." << endl;
         vec_pciw_[dma]->PrintStatus(cout);
-        if (nerrdma>=maxerrdma) { fgarret = true; break; }
+        fgarret = true;  break; 
       }
     }
@@ -681 +686 @@
   cout << " --------------------------------------------------------------------" << endl;
 
-  // //// Nettoyage final
+  //---- Nettoyage final et arret 
   MZoneManage(true);
+  memgr.Stop();   // Pour arreter les autres threads 
+
   for (int i=0;i< (int)nbDma_ ;i++) delete[] tampon[i]; 
   if ((fgredpaq)&&predtampon) delete[] predtampon;
@@ -700 +707 @@
        << " max_targ_npaq=" << max_targ_npaq << endl;
   */
-  if (mid_ >= 0)  memgr.FreeMemZone(mid_, MemZS_Filled);
+  if (mid_ >= 0)  { 
+    memgr.GetAuxData(mid_)->filltime_.SetNow(); 
+    memgr.FreeMemZone(mid_, MemZS_Filled);
+  }
   mmbuf_ = NULL;  targ_npaq_ = 0;  mid_ = -2;
   for (int fid=0;fid<(int)nbDma_ ;fid++) mmbufib_[fid]=NULL;
@@ -790 +800 @@
     }
     BRPaquet paq0(NULL, NULL, paqsz); 
+    TimeStamp tsmz;
     for (uint_4 nbFile=0;nbFile<nfiles_ ;nbFile++) {
       if (stop_ )   break;
@@ -813 +824 @@
         // Sans TRAILER de paquet mff.setDTypeNaxis(MF_Byte, paq0.DataSize()+paq0.HeaderSize(), npaqperfile); 
         }
-        AddFitsKWStart(mff,bpar);
         fnum++;   fgfirstfctt=true;
       }
@@ -828 +838 @@
           return;       
         }
+        tsmz = memgr.GetAuxData(mid)->filltime_;
         for(uint_4 fib=0; fib<memgr.NbFibres(); fib++)  {  // Boucle sur les fibres 
           Byte* buff = memgr.GetMemZone(mid,fib);
@@ -841 +852 @@
               framecnt_first_[fib] = pcheck[fib].LastFrameNum();
               timetag_first_[fib] = paq.TimeTag();
+              AddFitsKWStart(mff,bpar,tsmz);
               fgfirstfctt=false;
             }
@@ -871 +883 @@
           framecnt_last_[fib] = pcheck[fib].LastFrameNum(); 
 
-        AddFitsKWEnd(mff,bpar);
+        AddFitsKWEnd(mff,bpar,tsmz);
         for(uint_4 fib=0; fib<memgr.NbFibres(); fib++) {
           header[fib].close();
@@ -907 +919 @@
 
 /* --Methode-- */
-int MultiDataSaver::AddFitsKWStart(MiniFITSFile* mff, BRAcqConfig& acpar)
+int MultiDataSaver::AddFitsKWStart(MiniFITSFile* mff, BRAcqConfig& acpar, TimeStamp& ts)
 { 
-  TimeStamp ts;
   string cdtu=ts.ToString();
   string& skysrc=acpar.SkySource();
@@ -922 +933 @@
     mff[fib].AddKeyS("BRPAQCFMT", BRPaquet::FmtConvToString(acpar.GetParams().GetDataConvFg()), 
                          " BAORadio BRPaquet DataFormatConversion" );
-    mff[fib].AddKeyI("FIBERNUM", acpar.GetParams().FiberNum[fib], " Fiber number/id") ;
+    mff[fib].AddKeyI("FIBERNUM", acpar.GetParams().FiberNum[fib], " Fiber number") ;
+    mff[fib].AddKeyI("FIBERID",memgr.FiberId(fib), " Fiber identifier (absolute id)"); 
     if (hassrc) 
       mff[fib].AddKeyS("SKYSOURC", skysrc, " Source identification" );
@@ -935 +947 @@
 
 /* --Methode-- */
-int MultiDataSaver::AddFitsKWEnd(MiniFITSFile* mff, BRAcqConfig& acpar)
+int MultiDataSaver::AddFitsKWEnd(MiniFITSFile* mff, BRAcqConfig& acpar, TimeStamp& ts)
 { 
-  TimeStamp ts;
   string cdtu=ts.ToString();
   for(uint_4 fib=0; fib<memgr.NbFibres(); fib++) {