Changeset 3909 in Sophya for trunk/AddOn/TAcq/racqueth.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/racqueth.cc (modified) (9 diffs)

trunk/AddOn/TAcq/racqueth.cc

@@ -55 +55 @@
       for(int ii=0; ii<BRTCPMSGLEN; ii++) msg[ii]='\0';
       uint_4 dmasz = (fgdirectsend_)  ? vec_pciw_[0]->TransferSize() : 0;
-      sprintf(msg,"BAORadio-PCIEToEthernet  %d %d %d %d %d", par_.MMgrNbPaquet(), par_.MMgrPaquetSize(), dmasz, 0,i);
+      sprintf(msg,"BAORadio-PCIEToEthernet  %d %d %d %d %d", par_.MMgrNbPaquet(), par_.MMgrPaquetSize(), 
+              vec_pciw_[i]->FiberId(), dmasz, i);
       //           123456789012345678901234567890
       sok.SendAll(msg,BRTCPMSGLEN);
@@ -72 +73 @@
     vvec_errorcnt_.push_back(verrcnt);
     vec_cntpaq_.push_back(0);
+    vfgmsgfin_.push_back(false);
+
   }
   totrdsnd_ = 0;
@@ -119 +122 @@
   uint_4 off_acheval=0;
   
-  int nerrdma = 0;
-  int maxerrdma = 10;
   bool fgarret = false;
   
@@ -170 +171 @@
   uint_4 npaqfaitg = 0; 
 
+  for (int i=0;i< (int)nbDma_ ;i++)
+    vec_pciw_[i]->SetMaxWaitEndDMA(par_.first_maxkwedma_,par_.first_nretrydma_);
+
   while (npaqfaitg < nmaxpaq_) {  // Boucle global G 
     if (fgarret) break;
     if (stop_) break;
+
+    if ((prtlev_>0)&&(npaqfaitg>1)&&((npaqfaitg-1)%prtmodulo_==0)) 
+      cout << " PCIEToEthernet::run()/Info NPaqFait= " << npaqfaitg << endl;
     
     // 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
@@ -185 +196 @@
       Datas[dma]=vec_pciw_[dma]->GetData();
       if (Datas[dma] == NULL) { // No data Read in DMA 
-        nerrdma ++;   fgbaddma=true;
-        cout << "PCIEToEthernetChecker/Erreur Waiting for datas ..." << endl;
+        fgbaddma=true;
+        cout << "PCIEToEthernetChecker/Error Waiting for datas ..." << endl;
         vec_pciw_[dma]->PrintStatus(cout);
-        if (nerrdma>=maxerrdma) { fgarret = true; break; }
+        fgarret = true;  break; 
       }
     }
     if (fgbaddma) continue;  
-    if ((prtlev_>0)&&(npaqfaitg%prtmodulo_==0)) 
-      cout << " PCIEToEthernet::run()/Info NPaqFait= " << npaqfaitg << endl;
+
     if (fgdirectsend_) {  // Pas de copie / reduction de taille de paquet, on rebalance tel quel ...
       for (int fib=0; fib<(int) nbDma_ ;fib++) {
@@ -283 +293 @@
   }  //   FIN  Boucle global G 
  
+  // ----- Nettoyage final et impression de resume -------
+  CleanUpEndSendAllLinks();
   setRC(0);
   gettimeofday(&tv2, NULL);
@@ -326 +338 @@
 static long cnt_prt=0;
 /* --Methode-- */
-size_t PCIEToEthernet::SendToTargets(int fib, Byte* data, size_t len)
+size_t PCIEToEthernet::SendToTargets(int fib, Byte* data, size_t len, bool fgfin)
 {
   //DBG    cout << " SendToTargets/DBG" << cnt_prt << " len=" << len << " data=" << hex << (unsigned long)data << dec << endl; cnt_prt++; 
@@ -360 +372 @@
   }
 #endif
-  if (vec_cntpaq_[fib]==nmaxpaq_) {  // fin de l'envoi pour cette fibre 
+  if ((vec_cntpaq_[fib]==nmaxpaq_)||(fgfin&&(vec_cntpaq_[fib]%par_.MMgrNbPaquet()==0))) {  // fin de l'envoi pour cette fibre 
     sprintf(msg,"PCIEToEthernet-Send-END %d",vec_cntpaq_[fib]);
     for(size_t j=0; j<vskt.size(); j++) {
       vskt[j].SendAll(msg, BRTCPMSGLEN2);
     }
-    
+    vfgmsgfin_[fib]=true;
   }
   return rc;
 }
+
+/* --Methode-- */
+void PCIEToEthernet::CleanUpEndSendAllLinks()
+{
+  cout << " PCIEToEthernet::CleanUpEndSendAllLinks() - Ending transmission on links ..." << endl;
+  Byte* tampon = new Byte[par_.MMgrPaquetSize()];
+  memset(tampon,0,(size_t)par_.MMgrPaquetSize());
+  for(size_t fib=0; fib<vfgmsgfin_.size(); fib++) {
+    while (!vfgmsgfin_[fib])  SendToTargets(fib,tampon,par_.MMgrPaquetSize(),true);
+    cout << " ... Ended transmission on links for Fiber " << fib << endl;
+  }
+  delete[] tampon;
+}
+
 //------------------------------------------------------------------
 // Classe thread de lecture sur interface reseau (Ethernet) 
@@ -429 +455 @@
     sok.SendAll(msg,BRTCPMSGLEN);
     vsok_.push_back(sok);
-    cout << " EthernetReader/Info connection/link" << fib << " established." << endl; 
+    vfibid_.push_back(ic);
+    cout << " EthernetReader/Info connection/link" << fib << " established - FiberId= " << ic << endl; 
     vec_cntpaq_.push_back(0);
     vec_fgsokend_.push_back(false);
   }
+  if (vsok_.size()>1) {
+    cout << " EthernetReader/Info: sorting socket according to FiberIds ..." << endl;
+    bool encore=true;
+    Socket tmpskt;
+    int tmpid;
+    while(encore) {
+      encore=false;
+      for(size_t ii=0; ii<vsok_.size()-1; ii++) {
+        if (vfibid_[ii]<vfibid_[ii+1]) {
+          tmpskt=vsok_[ii];  tmpid=vfibid_[ii];
+          vsok_[ii]=vsok_[ii+1];  vfibid_[ii]=vfibid_[ii+1];
+          vsok_[ii+1]=tmpskt;  vfibid_[ii+1]=tmpid;
+          encore=true;
+        }
+      }
+    }
+  }
+  cout << " EthernetReader/Info: Setting FiberIds in RAcqMemZoneMgr \n ... FiberIds= " ;
+  for(size_t ii=0; ii<vsok_.size(); ii++)  { 
+    memgr_.FiberId(ii)=vfibid_[ii];
+    cout << vfibid_[ii] << " ; ";
+  }
+  cout << endl;
+
   gl_fgsokend = true;
   stopreason_="??Unknown??";