| 1 | #include "mfacq.h"
 | 
|---|
| 2 | 
 | 
|---|
| 3 | //---------------------------------------------------------------
 | 
|---|
| 4 | // Programme d'acquisition BAORadio multi-fibres/multi-threads 
 | 
|---|
| 5 | //  LAL -   2009 - 2010
 | 
|---|
| 6 | //     R. Ansari, M.Taurigna
 | 
|---|
| 7 | //---------------------------------------------------------------
 | 
|---|
| 8 | 
 | 
|---|
| 9 | static RAcqMemZoneMgr* pMmgr=NULL;
 | 
|---|
| 10 | static  PCIEMultiReader* pPcierThr=NULL;
 | 
|---|
| 11 | static  PCIEToEthernet* pPcie2Eth=NULL;
 | 
|---|
| 12 | static  EthernetReader* pEthRdr=NULL;
 | 
|---|
| 13 | 
 | 
|---|
| 14 | void Stop(int s)
 | 
|---|
| 15 | { 
 | 
|---|
| 16 |   if (s == 9765) cout << " Stop after exception ..." << endl;
 | 
|---|
| 17 |   else printf("............. MAIN ... receive signal %d \n",s);
 | 
|---|
| 18 |   if (pMmgr != NULL) pMmgr->Stop();
 | 
|---|
| 19 |   if (pPcie2Eth !=NULL) pPcie2Eth->Stop();
 | 
|---|
| 20 |   if (pPcierThr !=NULL) pPcierThr->Stop();
 | 
|---|
| 21 |   if (pEthRdr !=NULL) pEthRdr->Stop();
 | 
|---|
| 22 | }
 | 
|---|
| 23 | 
 | 
|---|
| 24 | 
 | 
|---|
| 25 | //-----------------------------------------------------------------------
 | 
|---|
| 26 | //-------------------- le programme principal ---------------------------
 | 
|---|
| 27 | //-----------------------------------------------------------------------
 | 
|---|
| 28 | int main(int narg, char* arg[])
 | 
|---|
| 29 | { 
 | 
|---|
| 30 |   
 | 
|---|
| 31 |   int rc = 0;
 | 
|---|
| 32 |   cout << " ============= BAORadio / Acquisition : mfacq  =================" << endl;
 | 
|---|
| 33 |   cout << " ===============================================================" << endl;
 | 
|---|
| 34 |   cout << " =========  " <<BAOR_ACQ_VER_STR <<BAOR_ACQ_VER << " ===========" << endl;
 | 
|---|
| 35 |   cout << " ===============================================================" << endl;
 | 
|---|
| 36 |   
 | 
|---|
| 37 |  
 | 
|---|
| 38 |   InitTim();
 | 
|---|
| 39 |  
 | 
|---|
| 40 |   // Initialisation 
 | 
|---|
| 41 |   TArrayInitiator _arri;
 | 
|---|
| 42 |   FitsIOServerInitiator _fiosi;
 | 
|---|
| 43 | 
 | 
|---|
| 44 | 
 | 
|---|
| 45 |   if ((narg > 1)&&(strcmp(arg[1],"-h"))==0) {
 | 
|---|
| 46 |     Usage(false);
 | 
|---|
| 47 |     return 1;
 | 
|---|
| 48 |   }
 | 
|---|
| 49 |   if (narg < 3) {
 | 
|---|
| 50 |     Usage(true);
 | 
|---|
| 51 |     return 3;
 | 
|---|
| 52 |   }
 | 
|---|
| 53 |   
 | 
|---|
| 54 |   const char* desact[4] = {"PCIE_To_Ethernet", "Ethernet_To_Disk", "Ethernet_To_Visibilities","PCIE_DMA_To_Disk"};
 | 
|---|
| 55 |   string action=arg[1];
 | 
|---|
| 56 |   int act = 0;
 | 
|---|
| 57 |   if ((action != "-pci2eth")&&(action != "-pci2disk")&&(action != "-eth2disk")&&(action != "-eth2visib")) {
 | 
|---|
| 58 |     cout << " mfacq/Error , Bad action argument : " << action << endl;
 | 
|---|
| 59 |     return 2;
 | 
|---|
| 60 |   }
 | 
|---|
| 61 |   if (action == "-pci2eth")  act=0;
 | 
|---|
| 62 |   else if (action == "-eth2disk") act=1;  
 | 
|---|
| 63 |   else if (action == "-eth2visib") act=2; 
 | 
|---|
| 64 |   else if (action == "-pci2disk")  act=3;
 | 
|---|
| 65 | 
 | 
|---|
| 66 |   string pardcfile=arg[2];
 | 
|---|
| 67 | #ifndef NOPCIECARD  
 | 
|---|
| 68 |   string basedir="/Raid";
 | 
|---|
| 69 | #else 
 | 
|---|
| 70 |   string basedir="./";
 | 
|---|
| 71 | #endif 
 | 
|---|
| 72 |   vector<string> oargs;
 | 
|---|
| 73 |   if (narg>3)  {
 | 
|---|
| 74 |     basedir=arg[2];
 | 
|---|
| 75 |     for(int jj=3; jj<narg; jj++)  oargs.push_back(arg[jj]);
 | 
|---|
| 76 |   }
 | 
|---|
| 77 |   try {
 | 
|---|
| 78 |     // Creation/initialisation parametres Acq
 | 
|---|
| 79 |     BRAcqConfig acpar;
 | 
|---|
| 80 |     acpar.ReadParamFile(pardcfile);
 | 
|---|
| 81 |     acpar.GetConfig().SetBaseDirectory(basedir); 
 | 
|---|
| 82 |     if ((act==0)&&(oargs.size()>0))
 | 
|---|
| 83 |       acpar.GetParams().SetEthTargets(oargs);
 | 
|---|
| 84 |     // Creation des repertoires 
 | 
|---|
| 85 |     if (act > 0) 
 | 
|---|
| 86 |       if (acpar.CreateOutputDirectories()!=0)  return 9;
 | 
|---|
| 87 |     acpar.GetParams().fgdoVisiC=false;
 | 
|---|
| 88 |     if (act == 2)  acpar.GetParams().fgdoVisiC=true;
 | 
|---|
| 89 | 
 | 
|---|
| 90 |     acpar.Print(cout);
 | 
|---|
| 91 |     struct sigaction siact;  
 | 
|---|
| 92 |     if (!acpar.GetParams().fg_hard_ctrlc) {
 | 
|---|
| 93 |       siact.sa_handler=Stop;
 | 
|---|
| 94 |       sigaction(SIGINT,&siact,NULL);        
 | 
|---|
| 95 |     }
 | 
|---|
| 96 |     switch (act) {
 | 
|---|
| 97 |     case 0:
 | 
|---|
| 98 |       rc = PCIEToEthernetTransfer();
 | 
|---|
| 99 |       break;
 | 
|---|
| 100 |     case 1:    // ethernet --> disk 
 | 
|---|
| 101 |       rc = EthernetToMemoryAcq(false);
 | 
|---|
| 102 |       break;
 | 
|---|
| 103 |     case 2:   // ethernet --> visibility calculation 
 | 
|---|
| 104 |       rc = EthernetToMemoryAcq(true);
 | 
|---|
| 105 |       break;
 | 
|---|
| 106 |     case 3:
 | 
|---|
| 107 |       rc = MultiFibreAcq();
 | 
|---|
| 108 |       break;
 | 
|---|
| 109 |     }    
 | 
|---|
| 110 |   }
 | 
|---|
| 111 |   catch (MiniFITSException& exc) {
 | 
|---|
| 112 |     cerr << " mfacq.cc catched MiniFITSException " << exc.Msg() << endl;
 | 
|---|
| 113 |     rc = 77;
 | 
|---|
| 114 |   } 
 | 
|---|
| 115 |   catch (PCIEWException& exc) {
 | 
|---|
| 116 |     cerr << " mfacq.cc catched PCIEWException " << exc.Msg() << endl;
 | 
|---|
| 117 |     rc = 75;
 | 
|---|
| 118 |   }  
 | 
|---|
| 119 |   catch (PThrowable& exc) {
 | 
|---|
| 120 |     cerr << " mfacq.cc catched Exception " << exc.Msg() << endl;
 | 
|---|
| 121 |     rc = 76;
 | 
|---|
| 122 |   }  
 | 
|---|
| 123 |   catch (std::exception& sex) {
 | 
|---|
| 124 |     cerr << "\n mfacq.cc std::exception :" 
 | 
|---|
| 125 |          << (string)typeid(sex).name() << "\n msg= " 
 | 
|---|
| 126 |          << sex.what() << endl;
 | 
|---|
| 127 |     rc = 78;
 | 
|---|
| 128 |   }
 | 
|---|
| 129 |   catch (...) {
 | 
|---|
| 130 |     cerr << "  mfacq.cc : Catched ... exception " << endl;
 | 
|---|
| 131 |     rc = 79;
 | 
|---|
| 132 |   }
 | 
|---|
| 133 |   cout << "mfacq[9] ----- END --- stopping acq program " << endl;
 | 
|---|
| 134 |   return rc;
 | 
|---|
| 135 | }
 | 
|---|
| 136 | 
 | 
|---|
| 137 | 
 | 
|---|
| 138 | /* --Nouvelle-Fonction-- */
 | 
|---|
| 139 | void Usage(bool fgshort) 
 | 
|---|
| 140 | {
 | 
|---|
| 141 |   cout << " Usage: mfacq Action DataCardFile [BaseDirectory / TargetMachines]" << endl;
 | 
|---|
| 142 |   if (fgshort) return;
 | 
|---|
| 143 |   cout << " o Action = -pci2disk , -pci2eth , -eth2disk , -eth2visib \n " 
 | 
|---|
| 144 |        << "   DataCardFile : File name for parameters list (DataCards) : \n"
 | 
|---|
| 145 |        << "     fibres outpathname skysource paqsize dmasizekb nbfiles \n" 
 | 
|---|
| 146 |        << "     nblocperfile acqmode memmgr monitor reducpaqsz ... "<< endl;
 | 
|---|
| 147 |   cout << " o BaseDirectory (default= /Raid ) for -pci2disk , -eth2disk" << endl;
 | 
|---|
| 148 |   cout << " o TargetMachines : List of target machines for PCIe2Ethernet (-pci2eth) \n " << endl;
 | 
|---|
| 149 |   return;
 | 
|---|
| 150 | }
 | 
|---|
| 151 |  
 | 
|---|
| 152 |  
 | 
|---|
| 153 | /* --Nouvelle-Fonction-- */
 | 
|---|
| 154 | int MultiFibreAcq() 
 | 
|---|
| 155 | {
 | 
|---|
| 156 |   Timer tm("mfacq/MultiFibre");
 | 
|---|
| 157 |   cout << " ---------- mfacq/ MultiFibreAcq()  ------------- " << endl;
 | 
|---|
| 158 |   PCIEWrapperInterface* pciwp[16]={NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,
 | 
|---|
| 159 |                                    NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL};
 | 
|---|
| 160 |     
 | 
|---|
| 161 |   BRAcqConfig bpar;
 | 
|---|
| 162 |   BRParList& acpar=bpar.GetParams();
 | 
|---|
| 163 |   
 | 
|---|
| 164 |   cout << " mfacq[1]/Info: Creating RAcqMemZoneMgr for" << acpar.NbFibers() << " fibers , nZones=" 
 | 
|---|
| 165 |        << acpar.nZones << " NbPaquet/Zone=" << acpar.nPaqZone 
 | 
|---|
| 166 |        << " MmgrPaqSize=" << acpar.MMgrPaquetSize() << endl;
 | 
|---|
| 167 |   RAcqMemZoneMgr mmgr(acpar.nZones, bpar.NFibers(), acpar.nPaqZone, acpar.MMgrPaquetSize());
 | 
|---|
| 168 |   pMmgr=&mmgr;  
 | 
|---|
| 169 |   if (acpar.fgdoProc && (acpar.stepProc>0)) {
 | 
|---|
| 170 |     // Dans ce cas, toutes les zones doivent passer ds le thread de monitoring 
 | 
|---|
| 171 |     // pour etre au moins marque comme traite - seul 1/acpar.stepProc sont effectivement traite 
 | 
|---|
| 172 |     mmgr.SetFinalizedMask(((uint_4)MemZS_Saved) | ((uint_4)MemZS_Proc));
 | 
|---|
| 173 |     cout << " mfacq[1.b]/Info: Mmgr.SetFinalizedMask( MemZS_Saved | MemZS_Proc )" << endl;
 | 
|---|
| 174 |     //mmgr.SetFinalizedMask( (uint_4)MemZS_Saved );
 | 
|---|
| 175 |     //cout << " mfacq[1.b]/Info: Mmgr.SetFinalizedMask( MemZS_Saved  )" << endl;
 | 
|---|
| 176 |   }
 | 
|---|
| 177 |   
 | 
|---|
| 178 | #ifndef NOPCIECARD  
 | 
|---|
| 179 |   for (size_t i=0 ;i <acpar.NFibers() ;i++) {
 | 
|---|
| 180 |     UINT32 card=(acpar.FiberNum[i]-1)/2+1;
 | 
|---|
| 181 |     UINT32 cardfiber=(acpar.FiberNum[i]-1)%2;
 | 
|---|
| 182 |     cout <<"mfacq[2] CreatePCIEWrapperV6- indice " << i <<  "INIT card " << card 
 | 
|---|
| 183 |          << " fibre " << cardfiber << endl;
 | 
|---|
| 184 |     pciwp[i] =  CreatePCIEWrapperV6(card,acpar.PatternSize(),acpar.DMASizeBytes(),acpar.activate_pattern,cardfiber);
 | 
|---|
| 185 |   }
 | 
|---|
| 186 | #else 
 | 
|---|
| 187 |   TestPCIWrapperNODMA pciw1(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 188 |   TestPCIWrapperNODMA pciw2(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 189 |   TestPCIWrapperNODMA pciw3(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 190 |   TestPCIWrapperNODMA pciw4(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 191 |   TestPCIWrapperNODMA pciw5(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 192 |   TestPCIWrapperNODMA pciw6(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 193 |   TestPCIWrapperNODMA pciw7(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 194 |   TestPCIWrapperNODMA pciw8(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 195 |   pciwp[0] = &pciw1;
 | 
|---|
| 196 |   pciwp[1] = &pciw2;
 | 
|---|
| 197 |   pciwp[2] = &pciw3;
 | 
|---|
| 198 |   pciwp[3] = &pciw4;
 | 
|---|
| 199 |   pciwp[4] = &pciw5;
 | 
|---|
| 200 |   pciwp[5] = &pciw6;  
 | 
|---|
| 201 |   pciwp[6] = &pciw7;
 | 
|---|
| 202 |   pciwp[7] = &pciw8;  
 | 
|---|
| 203 | #endif 
 | 
|---|
| 204 | 
 | 
|---|
| 205 |   cout <<"mfacq[2] Creating MultiDataSaver and  MonitorProc thread objects ... " << endl;
 | 
|---|
| 206 |   MultiDataSaver DsThr(mmgr);   //   Utilise les parametres globaux BRAcqConfig
 | 
|---|
| 207 |   string ppath=bpar.OutputDirectory();
 | 
|---|
| 208 |   MonitorProc PrThr(mmgr);
 | 
|---|
| 209 |   cout << "mfacq[3] Creating   PCIEMultiReader thread object     " << endl;
 | 
|---|
| 210 |   vector<PCIEWrapperInterface*> vec_pciw;
 | 
|---|
| 211 |   for  (size_t i=0 ;i<bpar.NFibers();i++)  {
 | 
|---|
| 212 |     pciwp[i]->SetFiberNumId(acpar.FiberNum[i], acpar.FiberIds[i]);
 | 
|---|
| 213 |     vec_pciw.push_back( pciwp[i]);
 | 
|---|
| 214 |     //    cout << " mfacq[3.b]/Debug - pciwp[" << i << "] " << hex << pciwp[i] << dec << endl;
 | 
|---|
| 215 |   }
 | 
|---|
| 216 |   PCIEMultiReader PcierThr(vec_pciw, mmgr, bpar.GetParams());
 | 
|---|
| 217 |   //  usleep(200);  attente au cas ou ...
 | 
|---|
| 218 |   pPcierThr=&PcierThr;
 | 
|---|
| 219 |   tm.Split("Threads created");  
 | 
|---|
| 220 |   if (acpar.fgdoProc>0) 
 | 
|---|
| 221 |     cout << "mfacq[4] - starting three threads: PCIEMultiReader, MultiDataSaver, MonitorProc ... " << endl;
 | 
|---|
| 222 |   else 
 | 
|---|
| 223 |     cout << "mfacq[4] - starting two threads: PCIEMultiReader, MultiDataSaver  ... " << endl;
 | 
|---|
| 224 | 
 | 
|---|
| 225 |   PcierThr.start();
 | 
|---|
| 226 |   DsThr.start();
 | 
|---|
| 227 |   if (acpar.fgdoProc>0) { // On ne demarre que si au moins NMaxProc>0
 | 
|---|
| 228 |     PrThr.start();
 | 
|---|
| 229 |   }
 | 
|---|
| 230 |   
 | 
|---|
| 231 |   // On attend avant de declencher la terminaison des threads
 | 
|---|
| 232 |   usleep(200000);
 | 
|---|
| 233 |   
 | 
|---|
| 234 |   cout << "mfacq[5] -  Waiting for threads to finish ... " << endl;  
 | 
|---|
| 235 |   PcierThr.join();
 | 
|---|
| 236 |   DsThr.join();
 | 
|---|
| 237 |   mmgr.Stop();
 | 
|---|
| 238 |   if (acpar.fgdoProc) { // On n'attend la fin que si le thread a ete demarre (NMaxProc>0)
 | 
|---|
| 239 |     PrThr.join();
 | 
|---|
| 240 |   }
 | 
|---|
| 241 |   pMmgr=NULL;  
 | 
|---|
| 242 |   cout << "mfacq[6] ---------- threads finished ---------------- " << endl;
 | 
|---|
| 243 |   tm.Split("Threads Finished");  
 | 
|---|
| 244 |  
 | 
|---|
| 245 |   mmgr.Print(cout);
 | 
|---|
| 246 | #ifndef NOPCIECARD
 | 
|---|
| 247 |   for (size_t i=0; i<acpar.NbFibers(); i++) {
 | 
|---|
| 248 |     UINT32 card=(acpar.FiberNum[i]-1)/2+1;
 | 
|---|
| 249 |     UINT32 cardfiber=(acpar.FiberNum[i]-1)%2;
 | 
|---|
| 250 |     DeletePCIEWrapperV6(card,cardfiber);
 | 
|---|
| 251 |   }
 | 
|---|
| 252 | #endif    
 | 
|---|
| 253 | return 0;
 | 
|---|
| 254 | 
 | 
|---|
| 255 | }
 | 
|---|
| 256 | 
 | 
|---|
| 257 | /* --Nouvelle-Fonction-- */
 | 
|---|
| 258 | int PCIEToEthernetTransfer()
 | 
|---|
| 259 | {
 | 
|---|
| 260 |   Timer tm("mfacq/PCIEToEthernetTransfer");
 | 
|---|
| 261 |   cout << " ---------- mfacq/ PCIEToEthernetTransfer()  ------------- " << endl;
 | 
|---|
| 262 |   PCIEWrapperInterface* pciwp[16]={NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,
 | 
|---|
| 263 |                                    NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL};
 | 
|---|
| 264 | 
 | 
|---|
| 265 |   pMmgr=NULL;    
 | 
|---|
| 266 |   BRAcqConfig bpar;
 | 
|---|
| 267 |   BRParList& acpar=bpar.GetParams();
 | 
|---|
| 268 |   
 | 
|---|
| 269 |   cout << " mfacq[1]/Info: PCIEToEthernet for" << acpar.NbFibers() << " fibers , nZones=" 
 | 
|---|
| 270 |        << acpar.nZones << " NbPaquet/Zone=" << acpar.nPaqZone 
 | 
|---|
| 271 |        << " MmgrPaqSize=" << acpar.MMgrPaquetSize() << endl;
 | 
|---|
| 272 | #ifndef NOPCIECARD  
 | 
|---|
| 273 |   for (size_t i=0 ;i <acpar.NFibers() ;i++) {
 | 
|---|
| 274 |     UINT32 card=(acpar.FiberNum[i]-1)/2+1;
 | 
|---|
| 275 |     UINT32 cardfiber=(acpar.FiberNum[i]-1)%2;
 | 
|---|
| 276 |     cout <<"mfacq[2] CreatePCIEWrapperV6- indice " << i <<  "INIT card " << card 
 | 
|---|
| 277 |          << " fibre " << cardfiber << endl;
 | 
|---|
| 278 |     pciwp[i] =  CreatePCIEWrapperV6(card,acpar.PatternSize(),acpar.DMASizeBytes(),acpar.activate_pattern,cardfiber);
 | 
|---|
| 279 |   }
 | 
|---|
| 280 | #else 
 | 
|---|
| 281 |   TestPCIWrapperNODMA pciw1(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 282 |   TestPCIWrapperNODMA pciw2(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 283 |   TestPCIWrapperNODMA pciw3(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 284 |   TestPCIWrapperNODMA pciw4(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 285 |   TestPCIWrapperNODMA pciw5(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 286 |   TestPCIWrapperNODMA pciw6(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 287 |   TestPCIWrapperNODMA pciw7(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 288 |   TestPCIWrapperNODMA pciw8(bpar.RecvPaquetSize(), acpar.nopciLossRate);
 | 
|---|
| 289 |   pciwp[0] = &pciw1;
 | 
|---|
| 290 |   pciwp[1] = &pciw2;
 | 
|---|
| 291 |   pciwp[2] = &pciw3;
 | 
|---|
| 292 |   pciwp[3] = &pciw4;
 | 
|---|
| 293 |   pciwp[4] = &pciw5;
 | 
|---|
| 294 |   pciwp[5] = &pciw6;  
 | 
|---|
| 295 |   pciwp[6] = &pciw7;
 | 
|---|
| 296 |   pciwp[7] = &pciw8;  
 | 
|---|
| 297 | #endif 
 | 
|---|
| 298 | 
 | 
|---|
| 299 |   vector<PCIEWrapperInterface*> vec_pciw;
 | 
|---|
| 300 |   for  (size_t i=0 ;i<bpar.NFibers();i++)  { 
 | 
|---|
| 301 |     pciwp[i]->SetFiberNumId(acpar.FiberNum[i], acpar.FiberIds[i]);
 | 
|---|
| 302 |     vec_pciw.push_back( pciwp[i]);
 | 
|---|
| 303 |   }
 | 
|---|
| 304 |   cout <<"mfacq[2] Creating PCIEToEthernet  thread object " << endl;
 | 
|---|
| 305 |   PCIEToEthernet pci2eth(vec_pciw, bpar.GetParams().GetEthTargets(), bpar.GetParams(), bpar.GetParams().tcpportid);
 | 
|---|
| 306 |   pci2eth.SetPrintLevel(acpar.prtlevel_, acpar.prtmodulo_); 
 | 
|---|
| 307 |   //  usleep(200);  attente au cas ou ...
 | 
|---|
| 308 |   pPcie2Eth=&pci2eth;
 | 
|---|
| 309 |   tm.Split("Threads created");  
 | 
|---|
| 310 |   cout << "mfacq[3] - starting one threads: PCIEToEthernet... " << endl;
 | 
|---|
| 311 |   pci2eth.start();
 | 
|---|
| 312 |   
 | 
|---|
| 313 |   // On attend avant de declencher la terminaison des threads
 | 
|---|
| 314 |   usleep(200000);
 | 
|---|
| 315 |   
 | 
|---|
| 316 |   cout << "mfacq[5] -  Waiting for threads to finish ... " << endl;  
 | 
|---|
| 317 |   pci2eth.join();
 | 
|---|
| 318 |   cout << "mfacq[6] ---------- threads finished ---------------- " << endl;
 | 
|---|
| 319 |   tm.Split("Threads Finished");  
 | 
|---|
| 320 |  
 | 
|---|
| 321 | #ifndef NOPCIECARD
 | 
|---|
| 322 |   for (size_t i=0; i<acpar.NbFibers(); i++) {
 | 
|---|
| 323 |     UINT32 card=(acpar.FiberNum[i]-1)/2+1;
 | 
|---|
| 324 |     UINT32 cardfiber=(acpar.FiberNum[i]-1)%2;
 | 
|---|
| 325 |     DeletePCIEWrapperV6(card,cardfiber);
 | 
|---|
| 326 |   }
 | 
|---|
| 327 | #endif    
 | 
|---|
| 328 | return 0;
 | 
|---|
| 329 | }
 | 
|---|
| 330 | 
 | 
|---|
| 331 | 
 | 
|---|
| 332 | /* Fonction-Utilitaire : Voir en fin de fichier  */
 | 
|---|
| 333 | MemZaction ConvertMemZ_Status2Action( MemZStatus st );
 | 
|---|
| 334 | 
 | 
|---|
| 335 | /* --Nouvelle-Fonction-- */
 | 
|---|
| 336 | int EthernetToMemoryAcq(bool fgviscal) 
 | 
|---|
| 337 | {
 | 
|---|
| 338 |   Timer tm("mfacq/EthernetToMemoryAcq");
 | 
|---|
| 339 |   cout << " ---------- mfacq/ EthernetToMemoryAcq()  ------------- " << endl;
 | 
|---|
| 340 |     
 | 
|---|
| 341 |   BRAcqConfig bpar;
 | 
|---|
| 342 |   BRParList& acpar=bpar.GetParams();
 | 
|---|
| 343 | 
 | 
|---|
| 344 |   if (fgviscal)  cout << "mfacq[0]/EthernetToMemoryAcq() : On the fly Visibility Calculation " << endl;
 | 
|---|
| 345 |   else cout << "mfacq[0]/EthernetToMemoryAcq() : data dumped to disk  " << endl;  
 | 
|---|
| 346 |   cout << " mfacq[1]/Info: Creating RAcqMemZoneMgr for" << acpar.NbEthLinks() << " Eth-links , nZones=" 
 | 
|---|
| 347 |        << acpar.nZones << " NbPaquet/Zone=" << acpar.nPaqZone 
 | 
|---|
| 348 |        << " MmgrPaqSize=" << acpar.MMgrPaquetSize() << endl;
 | 
|---|
| 349 |   RAcqMemZoneMgr mmgr(acpar.nZones, acpar.NbEthLinks(), acpar.nPaqZone, acpar.MMgrPaquetSize());
 | 
|---|
| 350 |   pMmgr=&mmgr;  
 | 
|---|
| 351 | 
 | 
|---|
| 352 | 
 | 
|---|
| 353 |   string strfmask;
 | 
|---|
| 354 |   uint_4 fmask=0;
 | 
|---|
| 355 |   MemZStatus mskmon=MemZS_Proc;
 | 
|---|
| 356 |   if (fgviscal) {  // gestion de finalized_mask lors du calcul de visibilites 
 | 
|---|
| 357 |     if (acpar.nbcalgrpVisiC<1)  acpar.nbcalgrpVisiC=1;
 | 
|---|
| 358 |     if (acpar.nbcalgrpVisiC>4)  acpar.nbcalgrpVisiC=4;
 | 
|---|
| 359 |     cout << " mfacq[1.b]/Info: NbCalGrpVisiC = " << acpar.nbcalgrpVisiC << " (1<=NbCalGrpVisiC<=4)" << endl;
 | 
|---|
| 360 |     fmask=(uint_4)MemZS_ProcA;   strfmask="MemZS_ProcA";  mskmon=MemZS_ProcB;
 | 
|---|
| 361 |     if (acpar.nbcalgrpVisiC>1) 
 | 
|---|
| 362 |       { fmask |= (uint_4)MemZS_ProcB;  strfmask+=" | MemZS_ProcB";  mskmon=MemZS_ProcC; }
 | 
|---|
| 363 |     if (acpar.nbcalgrpVisiC>2) 
 | 
|---|
| 364 |       { fmask |= (uint_4)MemZS_ProcC;  strfmask+=" | MemZS_ProcC";  mskmon=MemZS_ProcD; }
 | 
|---|
| 365 |     if (acpar.nbcalgrpVisiC>3) 
 | 
|---|
| 366 |       { fmask |= (uint_4)MemZS_ProcD;  strfmask+=" | MemZS_ProcD";  mskmon=MemZS_ProcE; }
 | 
|---|
| 367 |   }
 | 
|---|
| 368 |   else { 
 | 
|---|
| 369 |     fmask=(uint_4)MemZS_Saved;  strfmask="MemZS_Saved";  mskmon=MemZS_Proc;
 | 
|---|
| 370 |   }
 | 
|---|
| 371 |   if (acpar.fgdoProc) 
 | 
|---|
| 372 |     { fmask |= (uint_4)mskmon; strfmask+=" | MemZS_Proc[Monotoring]"; }
 | 
|---|
| 373 |     // Dans ce cas, toutes les zones doivent passer ds le thread de monitoring 
 | 
|---|
| 374 |     // pour etre au moins marque comme traite - seul 1/acpar.stepProc sont effectivement traite 
 | 
|---|
| 375 | 
 | 
|---|
| 376 |   mmgr.SetFinalizedMask(fmask);
 | 
|---|
| 377 |   cout << " mfacq[1.b]/Info: Mmgr.SetFinalizedMask( " <<  strfmask << " )" << endl;
 | 
|---|
| 378 |   
 | 
|---|
| 379 |   if (fgviscal) 
 | 
|---|
| 380 |     cout <<"mfacq[2] Creating BRVisCalcGroup, NbVisibCalculator=" << acpar.nbcalgrpVisiC 
 | 
|---|
| 381 |          << " and MonitorProc " << endl;
 | 
|---|
| 382 |   else 
 | 
|---|
| 383 |     cout <<"mfacq[2] Creating MultiDataSaver and  MonitorProc thread objects ... " << endl;
 | 
|---|
| 384 |   MultiDataSaver DsThr(mmgr);   //   Utilise les parametres globaux BRAcqConfig
 | 
|---|
| 385 |   string ppath=bpar.OutputDirectory();
 | 
|---|
| 386 |   MonitorProc PrThr(mmgr);
 | 
|---|
| 387 |   PrThr.SetMemZAction( ConvertMemZ_Status2Action( mskmon ) );
 | 
|---|
| 388 |   BRVisCalcGroup VCGThr(acpar.nbcalgrpVisiC, mmgr, bpar.OutputDirectory(), acpar.nmeanVisiC, acpar.nthrVisiC);
 | 
|---|
| 389 |   VCGThr.SelectFreqBinning(acpar.freqminVisiC, acpar.freqmaxVisiC, acpar.nbinfreqVisiC);
 | 
|---|
| 390 | 
 | 
|---|
| 391 | 
 | 
|---|
| 392 |   cout << "mfacq[3] Creating   EthernetReader thread object     " << endl;
 | 
|---|
| 393 |   EthernetReader ethrdr(mmgr, bpar.GetParams(), bpar.GetParams().tcpportid);
 | 
|---|
| 394 |   ethrdr.SetReadMode(acpar.ethr_forcesamefc_, acpar.ethr_sfc_maxdpc_,acpar.ethr_sfc_maxresync_);
 | 
|---|
| 395 |   ethrdr.WaitENDMsg4Terminate(acpar.ethr_waitendmsg_);
 | 
|---|
| 396 |   ethrdr.SetPrintLevel(acpar.prtlevel_, acpar.prtmodulo_); 
 | 
|---|
| 397 | 
 | 
|---|
| 398 |   //  usleep(200);  attente au cas ou ...
 | 
|---|
| 399 |   pEthRdr=ðrdr;
 | 
|---|
| 400 |   tm.Split("Threads created"); 
 | 
|---|
| 401 |   cout << "mfacq[4] - starting EthernetReader thread object ..." << endl;
 | 
|---|
| 402 |   ethrdr.start();
 | 
|---|
| 403 |   if (fgviscal) {
 | 
|---|
| 404 |     cout << "mfacq[4.b] - starting  Visibility calculator threads " << endl;
 | 
|---|
| 405 |     VCGThr.start();
 | 
|---|
| 406 |   }
 | 
|---|
| 407 |   else {
 | 
|---|
| 408 |     cout << "mfacq[4.b] - starting  MultiDataSaver  " << endl;
 | 
|---|
| 409 |     DsThr.start();
 | 
|---|
| 410 |   }
 | 
|---|
| 411 |   if (acpar.fgdoProc) { // demarrage (optionnel) du thread de monitoring
 | 
|---|
| 412 |     cout << " mfacq[4.c] - starting MonitorProc thread object " << endl;
 | 
|---|
| 413 |     PrThr.start();
 | 
|---|
| 414 |   }
 | 
|---|
| 415 |   
 | 
|---|
| 416 |   // On attend avant de declencher la terminaison des threads
 | 
|---|
| 417 |   usleep(200000);
 | 
|---|
| 418 |   
 | 
|---|
| 419 |   cout << "mfacq[5] -  Waiting for threads to finish ... " << endl;  
 | 
|---|
| 420 |   ethrdr.join();
 | 
|---|
| 421 |   if (fgviscal)  VCGThr.join();
 | 
|---|
| 422 |   else DsThr.join();
 | 
|---|
| 423 |   mmgr.Stop();
 | 
|---|
| 424 |   if (acpar.fgdoProc) { // On n'attend la fin que si le thread a ete demarre (NMaxProc>0)
 | 
|---|
| 425 |     PrThr.join();
 | 
|---|
| 426 |   }
 | 
|---|
| 427 |   pMmgr=NULL;  
 | 
|---|
| 428 |   cout << "mfacq[6] ---------- threads finished ---------------- " << endl;
 | 
|---|
| 429 |   tm.Split("Threads Finished");  
 | 
|---|
| 430 |  
 | 
|---|
| 431 |   mmgr.Print(cout);
 | 
|---|
| 432 | 
 | 
|---|
| 433 | return 0;
 | 
|---|
| 434 | 
 | 
|---|
| 435 | }
 | 
|---|
| 436 | 
 | 
|---|
| 437 | 
 | 
|---|
| 438 | /* --Nouvelle-Fonction-Utilitaire */
 | 
|---|
| 439 | MemZaction ConvertMemZ_Status2Action( MemZStatus st )
 | 
|---|
| 440 | {
 | 
|---|
| 441 |   MemZaction ra=MemZA_None;
 | 
|---|
| 442 |   switch (st) {
 | 
|---|
| 443 |   case MemZS_Filled:
 | 
|---|
| 444 |     ra=MemZA_Fill;
 | 
|---|
| 445 |     break;
 | 
|---|
| 446 |   case MemZS_Saved:
 | 
|---|
| 447 |     ra=MemZA_Save;
 | 
|---|
| 448 |     break;
 | 
|---|
| 449 |   case MemZS_Proc:
 | 
|---|
| 450 |     ra=MemZA_Proc;
 | 
|---|
| 451 |     break;
 | 
|---|
| 452 |   case MemZS_ProcA:
 | 
|---|
| 453 |     ra=MemZA_ProcA;
 | 
|---|
| 454 |     break;
 | 
|---|
| 455 |   case MemZS_ProcB:
 | 
|---|
| 456 |     ra=MemZA_ProcB;
 | 
|---|
| 457 |     break;
 | 
|---|
| 458 |   case MemZS_ProcC:
 | 
|---|
| 459 |     ra=MemZA_ProcC;
 | 
|---|
| 460 |     break;
 | 
|---|
| 461 |   case MemZS_ProcD:
 | 
|---|
| 462 |     ra=MemZA_ProcD;
 | 
|---|
| 463 |     break;
 | 
|---|
| 464 |   case MemZS_ProcE:
 | 
|---|
| 465 |     ra=MemZA_ProcE;
 | 
|---|
| 466 |     break;
 | 
|---|
| 467 |   case MemZS_ProcF:
 | 
|---|
| 468 |     ra=MemZA_ProcF;
 | 
|---|
| 469 |     break;
 | 
|---|
| 470 |   default:
 | 
|---|
| 471 |     ra=MemZA_None;
 | 
|---|
| 472 |     break;
 | 
|---|
| 473 |   }
 | 
|---|
| 474 |   return ra;
 | 
|---|
| 475 | }
 | 
|---|