source: Sophya/trunk/AddOn/TAcq/brparam.cc@ 3761

Last change on this file since 3761 was 3760, checked in by ansari, 15 years ago

Ajout parametre taille de bloc de transfert sur ethernet Reza 30/04/2010

File size: 13.3 KB
Line 
1#include <stdlib.h>
2
3#include "brparam.h"
4#include "strutilxx.h"
5#include "bracqvers.h"
6
7#ifndef BRSPORTID
8#define BRSPORTID 6912
9#endif
10
11/* --Methode-- */
12ADCBoardDesc::ADCBoardDesc(int id, string sbid, string cyc_firmw, string str1_firmw, string str2_firmw)
13 : id_(id), sbid_(sbid), cyclone_firmware_(cyc_firmw), stratix1_firmware_(str1_firmw), stratix2_firmware_(str2_firmw)
14{
15
16}
17
18/* --Methode-- */
19ADCBoardDesc::ADCBoardDesc(ADCBoardDesc const& bdes)
20 : id_(bdes.id_), sbid_(bdes.sbid_), cyclone_firmware_(bdes.cyclone_firmware_),
21 stratix1_firmware_(bdes.stratix1_firmware_), stratix2_firmware_(bdes.stratix2_firmware_)
22{
23}
24
25/* --Methode-- */
26ADCBoardDesc& ADCBoardDesc::Set(ADCBoardDesc const & bdes)
27{
28 id_ = bdes.id_;
29 sbid_ = bdes.sbid_;
30 cyclone_firmware_ = bdes.cyclone_firmware_;
31 stratix1_firmware_ = bdes.stratix1_firmware_;
32 stratix2_firmware_ = bdes.stratix2_firmware_;
33 return(*this);
34}
35
36/* --Methode-- */
37ostream& ADCBoardDesc::Print(ostream& os)
38{
39 os << "ADCBoard#" << id_ << "(" << sbid_ << ") Cyclone:" << cyclone_firmware_
40 << " Stratix1: " << stratix1_firmware_ << " Stratix2: " << stratix2_firmware_ << endl;
41 return os;
42}
43
44/* --Methode-- */
45BRConfList::BRConfList()
46 : basedir_("./")
47{
48}
49
50/* --Methode-- */
51BRConfList::BRConfList(string basedir)
52 : basedir_(basedir)
53{
54}
55
56/* --Methode-- */
57BRConfList::BRConfList(string basedir, vector<ADCBoardDesc> boards)
58 : basedir_(basedir), boards_(boards)
59{
60 size_t len = basedir_.length();
61 if ((len>1)&&(basedir_[len-1]!='/')) basedir_ += '/';
62}
63
64/* --Methode-- */
65BRConfList::BRConfList(BRConfList const & cf)
66 : basedir_(cf.basedir_), boards_(cf.boards_)
67{
68}
69
70/* --Methode-- */
71void BRConfList::SetBaseDirectory(string basedir)
72{
73 basedir_=basedir;
74 size_t len = basedir_.length();
75 if ((len>1)&&(basedir_[len-1]!='/')) basedir_ += '/';
76}
77
78/* --Methode-- */
79void BRConfList::Set(BRConfList const & cf)
80{
81 basedir_=cf.basedir_;
82 boards_=cf.boards_;
83}
84
85/* --Methode-- */
86ostream& BRConfList::Print(ostream& os)
87{
88 os << " ----- BRConfList:: BaseDir:" << basedir_ << " NBoards= " << boards_.size() << endl;
89 for(size_t k=0; k<boards_.size(); k++) boards_[k].Print(os);
90 return os;
91}
92
93/* --Methode-- */
94void BRConfList::ReadDCFile(string file)
95{
96 // A FAIRE
97}
98
99// Classe qui memorise tous les parametres importants de l'acquisition
100
101/* --Methode-- */
102BRParList::BRParList(string acqmod, string fibres,unsigned int paqsz,
103 unsigned int dmaszkb, int nfiles, int nblocfile,
104 string outpath, uint_4 nzon , uint_4 npaqzon)
105{
106 AcqMode=acqmod;
107 fgdatafft=false;
108 fgsinglechannel=false;
109
110 FiberListS=fibres;
111 NbFibers=0;
112 for (int fib=0; fib<PMAXNBFIBRES;fib++) FiberNum[fib]=0;
113 PaqSize=paqsz;
114 dmasizekb=dmaszkb;
115
116 NbFiles=nfiles;
117 NBlocPerFile=nblocfile;
118 OutPathName=outpath;
119
120 nZones=nzon;
121 nPaqZone=npaqzon;
122
123 swapall=BR_Copy;
124 savesigfits=true;
125 fgnulldev4fits=false;
126
127 fg_hard_ctrlc=false;
128
129 fgreducpsize=false;
130 reducneedcopy=false;
131 pqreducmode=BR_CopyRA;
132 redpqsize=PaqSize;
133 reducoffset=0;
134
135 tcpportid=BRSPORTID;
136 eth_transfer_blksz=1024;
137 pci2eth_fgdirect=false;
138 ethr_nlink = 0;
139
140 skysource="";
141
142 fgdoProc=false;
143 nmeanProc=512;
144 stepProc=5;
145 nmaxProc=0;
146
147 monothr=false;
148 activate_pattern=false;
149 nopciLossRate=0.;
150
151 Decode(); // On decode et on complete les parametres
152}
153
154/* --Methode-- */
155BRParList::BRParList(BRParList const & p)
156{
157 Set(p);
158}
159
160/* --Methode-- */
161void BRParList::Set(BRParList const & p)
162{
163 AcqMode=p.AcqMode;
164 fgdatafft=p.fgdatafft;
165 fgsinglechannel=p.fgsinglechannel;
166
167 FiberListS=p.FiberListS;
168 NbFibers=p.NbFibers;
169 for (int fib=0; fib<PMAXNBFIBRES;fib++) FiberNum[fib]=p.FiberNum[fib];
170
171 PaqSize=p.PaqSize;
172 dmasizekb=p.dmasizekb;
173
174 NbFiles=p.NbFiles;
175 NBlocPerFile=p.NBlocPerFile;
176 OutPathName=p.OutPathName;
177
178 nZones=p.nZones;
179 nPaqZone=p.nPaqZone;
180
181 swapall=p.swapall;
182 savesigfits=p.savesigfits;
183 fgnulldev4fits=p.fgnulldev4fits;
184 fg_hard_ctrlc=p.fg_hard_ctrlc;
185 fgnulldev4fits=p.fgnulldev4fits;
186
187 fgreducpsize=p.fgreducpsize;
188 reducneedcopy=p.reducneedcopy;
189 pqreducmode=p.pqreducmode;
190 redpqsize=p.redpqsize;
191 reducoffset=p.reducoffset;
192
193 tcpportid=p.tcpportid;
194 eth_transfer_blksz=p.eth_transfer_blksz;
195 pci2eth_fgdirect=p.pci2eth_fgdirect;
196 eths_targets=p.eths_targets;
197 ethr_nlink=p.ethr_nlink;
198
199 skysource=p.skysource;
200
201 fgdoProc=p.fgdoProc;
202 nmeanProc=p.nmeanProc;
203 stepProc=p.stepProc;
204 nmaxProc=p.nmaxProc;
205
206 monothr=p.monothr;
207 activate_pattern=p.activate_pattern;
208
209 nopciLossRate=p.nopciLossRate;
210 return;
211}
212
213/* --Methode-- */
214void BRParList::ReadDCFile(string file)
215{
216 DataCards conf(file);
217 FiberListS= conf.SParam("fibres",0,"1");
218 OutPathName= conf.SParam("outpathname",0,"TstAcq");
219 skysource= conf.SParam("skysource",0,"");
220 PaqSize=(uint_4)conf.IParam("paqsize",0,16424);
221 dmasizekb =(uint_4) conf.IParam("dmasizekb",0,32);
222 NbFiles=conf.IParam("nbfiles",0,1);
223 NBlocPerFile=conf.IParam("nblocperfile",0,10);
224 AcqMode =conf.SParam("acqmode",0,"std");
225 nZones=(uint_4)conf.IParam("memmgr",0,4);
226 nPaqZone=(uint_4)conf.IParam("memmgr",1,128);
227 if (conf.HasKey("reducpaqsz")) { // reduction des tailles de paquets
228 fgreducpsize=true;
229 redpqsize=(uint_4)conf.IParam("reducpaqsz",0,PaqSize/4);
230 reducoffset=(uint_4)conf.IParam("reducpaqsz",1,0);
231 }
232 // Mot cle pour le mode envoi-reception sur ethernet
233 tcpportid=conf.IParam("tcpportid",0,BRSPORTID);
234 eth_transfer_blksz=(size_t)conf.IParam("ethtrbsz",0,1024);
235 if (conf.HasKey("pci2ethdirect")) pci2eth_fgdirect = true; // Transfer direct DMA -> Ethernet
236 if (conf.HasKey("ethrtargets")) { // Machines destinations des paquets
237 for(int it=0; it<conf.NbParam("ethrtargets"); it++)
238 eths_targets.push_back(conf.SParam("ethrtargets",it));
239 }
240 ethr_nlink=conf.IParam("ethrnlink",0,0); // Nombre de sources de paquets en reception ethernet
241
242
243 if (conf.HasKey("monitor")) {
244 fgdoProc=true;
245 nmeanProc=conf.IParam("monitor",0,512);
246 stepProc=conf.IParam("monitor",1,10);
247 nmaxProc=conf.IParam("monitor",2,0);
248 }
249 nopciLossRate=conf.DParam("nopcilossrate",0,0.);
250 fg_hard_ctrlc=conf.HasKey("hard_ctrlc");
251 if (conf.HasKey("nosavesigfits")) savesigfits=false;
252 Decode();
253}
254
255/* --Methode-- */
256void BRParList::Decode()
257{
258 vector<string> fiblist;
259 FillVStringFrString(FiberListS, fiblist, ',');
260 NbFibers=fiblist.size();
261 for (int fib=0; fib<fiblist.size(); fib++) {
262 FiberNum[fib]=atoi(fiblist[fib].c_str());
263 }
264 if (OutPathName == "/dev/null") {
265 fgnulldev4fits=true;
266 }
267 else {
268 size_t len = OutPathName.length();
269 if ((len>1)&&(OutPathName[len-1]!='/')) OutPathName+='/';
270 fgnulldev4fits=false;
271 }
272 string acqmode = AcqMode;
273 fgdatafft=false; fgsinglechannel=false;
274 reducneedcopy=false; pqreducmode=BR_TwoChanReduc;
275 if ((acqmode == "std")||(acqmode=="raw2c")) swapall = BR_Copy ;
276 if (acqmode == "nosw") swapall = BR_Copy ;
277 if (acqmode == "nof") { swapall = BR_Copy ; savesigfits = false; }
278 if (acqmode == "fft1c") { swapall = BR_FFTOneChan; reducneedcopy=true; pqreducmode=BR_OneChanReducK0; }
279 if (acqmode == "fft2c") { swapall = BR_FFTTwoChan; reducneedcopy=true; pqreducmode=BR_TwoChanReducK0; }
280 if (acqmode == "fft1cnof")
281 { swapall = BR_FFTOneChan; savesigfits = false; reducneedcopy=true; pqreducmode=BR_OneChanReducK0; }
282 if (acqmode == "fft2cnof")
283 { swapall = BR_FFTTwoChan; savesigfits = false; reducneedcopy=true; pqreducmode=BR_TwoChanReducK0; }
284 if (acqmode == "mono") { monothr = true; swapall = BR_Copy; }
285 if (acqmode == "monodirect") { monothr = true; swapall = BR_CopyHDR;}
286 if (acqmode == "patmonodirect") { monothr = true; swapall = BR_CopyHDR; activate_pattern=true; }
287 if (acqmode == "patmono") { monothr = true; swapall = BR_Copy; activate_pattern=true; }
288 if (acqmode == "patnof") { savesigfits = false; swapall = BR_Copy; activate_pattern=true; }
289 if (acqmode == "pattern") { savesigfits = true; swapall = BR_Copy; activate_pattern=true; }
290
291 if (acqmode == "swapall") swapall = BR_SwapAll;
292 if (acqmode == "fft1csw")
293 { swapall = BR_FFTOneChanSwapAll; reducneedcopy=true; pqreducmode=BR_OneChanReducK0; }
294 if (acqmode == "fft2csw")
295 { swapall = BR_FFTTwoChanSwapAll; reducneedcopy=true; pqreducmode=BR_TwoChanReducK0; }
296 if (acqmode == "fft1cswnof")
297 { swapall = BR_FFTOneChanSwapAll; savesigfits = false; reducneedcopy=true; pqreducmode=BR_OneChanReducK0; }
298 if (acqmode == "fft2cswnof")
299 { swapall = BR_FFTTwoChanSwapAll; savesigfits = false; reducneedcopy=true; pqreducmode=BR_TwoChanReducK0; }
300 if ((acqmode == "swh") || (acqmode == "mxs") || (acqmode == "monoswh") ) swapall = BR_SwapHDR;
301 if ((acqmode == "swapallnof") || (acqmode == "mxs") ) savesigfits = false;
302 if (acqmode == "monoswh") { monothr = true; swapall = BR_SwapHDR;; }
303 if (acqmode == "monosw") { monothr = true; swapall = BR_SwapAll; }
304
305 if (acqmode == "swap32") swapall = BR_Swap32 ;
306 if (acqmode == "nof32") { swapall = BR_Swap32 ; savesigfits = false; }
307 if (acqmode == "fft1c32")
308 { swapall = BR_FFTOneChanSwap32; reducneedcopy=true; pqreducmode=BR_OneChanReducK0; }
309 if (acqmode == "fft2c32")
310 { swapall = BR_FFTTwoChanSwap32; reducneedcopy=true; pqreducmode=BR_TwoChanReducK0; }
311 if (acqmode == "fft1cnof32")
312 { swapall = BR_FFTOneChanSwap32; savesigfits = false; reducneedcopy=true; pqreducmode=BR_OneChanReducK0; }
313 if (acqmode == "fft2cnof32")
314 { swapall = BR_FFTTwoChanSwap32; savesigfits = false; reducneedcopy=true; pqreducmode=BR_TwoChanReducK0; }
315
316 if ((swapall==BR_FFTTwoChan)||(swapall==BR_FFTTwoChanSwapAll)||(swapall==BR_FFTTwoChanSwap32)) {
317 fgdatafft=true;
318 }
319 if ((swapall==BR_FFTOneChan)||(swapall==BR_FFTOneChanSwapAll)||(swapall==BR_FFTOneChanSwap32)) {
320 fgdatafft=true; fgsinglechannel=true;
321 }
322
323 if (fgreducpsize) {
324 if (redpqsize>=PaqSize) fgreducpsize=false;
325 else {
326 if(reducoffset>(PaqSize-redpqsize)/2) reducoffset=(PaqSize-redpqsize)/2;
327 }
328 }
329}
330
331/* --Methode-- */
332ostream& BRParList::Print(ostream& os)
333{
334 os << " ------ BRParList::Print() ----- " << endl;
335 os << " FiberListS=" << FiberListS ;
336 os << " PaqSize=" <<PaqSize;
337 os << " DMA_Size_kb=" <<dmasizekb << endl;
338 os << " AcqMode="<<AcqMode;
339 os << " Type of acquisition :" << BRPaquet::FmtConvToString( swapall) << endl;
340 os << " SkySource=" << skysource;
341 os << " NbFiles="<<NbFiles;
342 os << " NBlocPerFile="<<NBlocPerFile;
343 os << " OutPathName="<<OutPathName << endl;
344 os << " MemMgr: nZones="<<nZones;
345 os << " nPaqZone="<<nPaqZone<<endl;
346 if (fgreducpsize) {
347 os << " PaquetSize Reduction, ReducedSize=" << redpqsize << " Offset=" << reducoffset << endl;
348 }
349 if (eths_targets.size()>0) {
350 cout << " DMA->Ethernet NbTargets=" << eths_targets.size() << ((pci2eth_fgdirect)?" (DirectTransferMode) " : " " ) << " :" << endl;
351 for(size_t it=0; it<eths_targets.size(); it++) cout << eths_targets[it] << " , ";
352 cout << endl;
353 }
354 cout << " EthernetRead NbSources (=NbLinks)= " << ethr_nlink << endl;
355 if (fgdoProc>0)
356 os << " Monitoring NMeanProc=" << nmeanProc << " StepProc=" << stepProc << " NMaxProc=" << nmaxProc << endl;
357 else os << " No monotoring thread " << endl;
358 os << " fg_hard_ctrlc=" << ((fg_hard_ctrlc)?"true":"false");
359 os << " Save to fits " << ((savesigfits)?"true":"false") << endl;
360 os << " monothr y(1)/n(0) " << ((monothr)?"true":"false");
361 os << " ActivatePattern " << ((activate_pattern)?"true":"false") << endl;
362
363 return os;
364}
365
366
367//-------------------- Classe BRAcqConfig -----------------------
368
369BRParList* BRAcqConfig::param_=NULL;
370BRConfList* BRAcqConfig::config_=NULL;
371
372/* --Methode-- */
373BRAcqConfig::BRAcqConfig()
374{
375 if (param_==NULL) param_ = new BRParList;
376 if (config_==NULL) config_ = new BRConfList;
377}
378
379/* --Methode-- */
380ostream& BRAcqConfig::Print(ostream& os)
381{
382 os << " ------------ BAORadio Acq Run/Configuration -------- " << endl;
383 config_->Print(os);
384 param_->Print(os);
385 os << " ----------------------------------------------------- " << endl;
386}
387
388/* --Methode-- */
389int BRAcqConfig::CreateOutputDirectories()
390{
391 char cmd[1024];
392 if (param_->fgnulldev4fits!=true) {
393 sprintf(cmd,"mkdir %s%s",config_->BaseDirectory().c_str(), param_->OutPathName.c_str());
394 if (system(cmd) < 0) {
395 cout << "CreateOutputDirectories()/Error: Can not create subdirectory "
396 << cmd << " -> stop" << endl;
397 return 2;
398 }
399 cout << "CreateOutputDirectories() - Executed command " << cmd << endl;
400
401 memset(cmd,0,1024);
402 for (int i= 0; i< NFibers() ; i++) {
403 sprintf(cmd,"mkdir %s%s/Fiber%d",config_->BaseDirectory().c_str(), param_->OutPathName.c_str(),param_->FiberNum[i]);
404 if (system(cmd) < 0) {
405 cout << "CreateOutputDirectories()/Error: Can not create subdirectory "
406 << cmd << " -> stop" << endl;
407 return 3;
408 }
409 else cout << "CreateOutputDirectories() - Executed command " << cmd << endl;
410 }
411 }
412 else {
413 string ProcPathName = "./XZXZXZX/";
414 cout << " Using " << ProcPathName << " for other processed files ... " << endl;
415 char cmd[512];
416 sprintf(cmd,"mkdir %s",ProcPathName.c_str());
417 if (system(cmd) < 0) {
418 cout << "CreateOutputDirectories()/Error: Can not create subdirectory ./XZXZXZX/"
419 << "-> stop" << endl;
420 return 3;
421 }
422 else cout << "CreateOutputDirectories() - Executed command " << cmd << endl;
423 }
424 return 0;
425}
426
427/* --Methode-- */
428string BRAcqConfig::OutputDirectoryFib(int ifib)
429{
430 char buff[24];
431 sprintf(buff,"Fiber%d/",param_->FiberNum[ifib]);
432 return ( config_->BaseDirectory() + param_->OutPathName + buff );
433}
Note: See TracBrowser for help on using the repository browser.