| [3704] | 1 | #include <stdlib.h> | 
|---|
|  | 2 |  | 
|---|
| [3671] | 3 | #include "brparam.h" | 
|---|
|  | 4 | #include "strutilxx.h" | 
|---|
|  | 5 | #include "bracqvers.h" | 
|---|
|  | 6 |  | 
|---|
| [3757] | 7 | #ifndef BRSPORTID | 
|---|
|  | 8 | #define BRSPORTID 6912 | 
|---|
|  | 9 | #endif | 
|---|
|  | 10 |  | 
|---|
| [4016] | 11 | /*! | 
|---|
|  | 12 | \class ADCBoardDesc | 
|---|
|  | 13 | \ingroup TAcq | 
|---|
|  | 14 |  | 
|---|
|  | 15 | \brief ADC board description (board Id, firmware type, version ...) | 
|---|
|  | 16 | */ | 
|---|
|  | 17 |  | 
|---|
|  | 18 |  | 
|---|
| [3672] | 19 | /* --Methode-- */ | 
|---|
|  | 20 | ADCBoardDesc::ADCBoardDesc(int id, string sbid, string cyc_firmw, string str1_firmw, string str2_firmw) | 
|---|
|  | 21 | : id_(id), sbid_(sbid), cyclone_firmware_(cyc_firmw), stratix1_firmware_(str1_firmw), stratix2_firmware_(str2_firmw) | 
|---|
|  | 22 | { | 
|---|
|  | 23 |  | 
|---|
|  | 24 | } | 
|---|
| [3671] | 25 |  | 
|---|
| [3672] | 26 | /* --Methode-- */ | 
|---|
|  | 27 | ADCBoardDesc::ADCBoardDesc(ADCBoardDesc const& bdes) | 
|---|
|  | 28 | : id_(bdes.id_), sbid_(bdes.sbid_), cyclone_firmware_(bdes.cyclone_firmware_), | 
|---|
|  | 29 | stratix1_firmware_(bdes.stratix1_firmware_), stratix2_firmware_(bdes.stratix2_firmware_) | 
|---|
|  | 30 | { | 
|---|
|  | 31 | } | 
|---|
|  | 32 |  | 
|---|
|  | 33 | /* --Methode-- */ | 
|---|
|  | 34 | ADCBoardDesc& ADCBoardDesc::Set(ADCBoardDesc const & bdes) | 
|---|
|  | 35 | { | 
|---|
|  | 36 | id_ = bdes.id_; | 
|---|
|  | 37 | sbid_ = bdes.sbid_; | 
|---|
|  | 38 | cyclone_firmware_ = bdes.cyclone_firmware_; | 
|---|
|  | 39 | stratix1_firmware_ = bdes.stratix1_firmware_; | 
|---|
|  | 40 | stratix2_firmware_ = bdes.stratix2_firmware_; | 
|---|
|  | 41 | return(*this); | 
|---|
|  | 42 | } | 
|---|
|  | 43 |  | 
|---|
|  | 44 | /* --Methode-- */ | 
|---|
|  | 45 | ostream& ADCBoardDesc::Print(ostream& os) | 
|---|
|  | 46 | { | 
|---|
|  | 47 | os << "ADCBoard#" << id_ << "(" << sbid_ << ") Cyclone:" << cyclone_firmware_ | 
|---|
|  | 48 | << " Stratix1: " << stratix1_firmware_ << " Stratix2: " << stratix2_firmware_ << endl; | 
|---|
|  | 49 | return os; | 
|---|
|  | 50 | } | 
|---|
|  | 51 |  | 
|---|
| [4016] | 52 | /*! | 
|---|
|  | 53 | \class BRConfList | 
|---|
|  | 54 | \ingroup TAcq | 
|---|
|  | 55 |  | 
|---|
|  | 56 | \brief Acquisition system configuration. | 
|---|
|  | 57 |  | 
|---|
|  | 58 | Environment variables: | 
|---|
|  | 59 | BRACQ_TMPDIR  / TMPDIR | 
|---|
|  | 60 | BRACQ_BASEDIR | 
|---|
|  | 61 | BRACQ_FIBERIDS | 
|---|
|  | 62 | */ | 
|---|
|  | 63 |  | 
|---|
| [3913] | 64 | #define PMAXNBFIBRES 64 | 
|---|
| [3672] | 65 | /* --Methode-- */ | 
|---|
|  | 66 | BRConfList::BRConfList() | 
|---|
| [3913] | 67 | : basedir_("./"), fiberIds_(PMAXNBFIBRES), tmpdir_("/tmp") | 
|---|
| [3672] | 68 | { | 
|---|
| [3913] | 69 | InitFromEnv(); | 
|---|
| [3672] | 70 | } | 
|---|
|  | 71 |  | 
|---|
|  | 72 | /* --Methode-- */ | 
|---|
|  | 73 | BRConfList::BRConfList(string basedir) | 
|---|
| [3913] | 74 | : basedir_("./"), fiberIds_(PMAXNBFIBRES), tmpdir_("/tmp") | 
|---|
| [3672] | 75 | { | 
|---|
| [3913] | 76 | InitFromEnv(); | 
|---|
|  | 77 | SetBaseDirectory(basedir); | 
|---|
| [3672] | 78 | } | 
|---|
|  | 79 |  | 
|---|
|  | 80 | /* --Methode-- */ | 
|---|
|  | 81 | BRConfList::BRConfList(string basedir, vector<ADCBoardDesc> boards) | 
|---|
| [3913] | 82 | : basedir_("./"), fiberIds_(PMAXNBFIBRES), tmpdir_("/tmp") | 
|---|
| [3672] | 83 | { | 
|---|
| [3913] | 84 | InitFromEnv(); | 
|---|
|  | 85 | SetBaseDirectory(basedir); | 
|---|
|  | 86 | boards_=boards; | 
|---|
| [3672] | 87 | } | 
|---|
|  | 88 |  | 
|---|
|  | 89 | /* --Methode-- */ | 
|---|
|  | 90 | BRConfList::BRConfList(BRConfList const & cf) | 
|---|
| [3913] | 91 | : basedir_(cf.basedir_), boards_(cf.boards_), fiberIdsS_(cf.fiberIdsS_), fiberIds_(cf.fiberIds_), tmpdir_(cf.tmpdir_) | 
|---|
| [3672] | 92 | { | 
|---|
|  | 93 | } | 
|---|
|  | 94 |  | 
|---|
|  | 95 | /* --Methode-- */ | 
|---|
| [3913] | 96 | void BRConfList::InitFromEnv() | 
|---|
| [3674] | 97 | { | 
|---|
| [3913] | 98 | const char* venvp = NULL; | 
|---|
|  | 99 | venvp=getenv("BRACQ_TMPDIR"); | 
|---|
|  | 100 | if (venvp!=NULL) tmpdir_=venvp; | 
|---|
|  | 101 | else { | 
|---|
|  | 102 | if (venvp!=NULL) tmpdir_=venvp; | 
|---|
|  | 103 | venvp = getenv("TMPDIR"); | 
|---|
|  | 104 | } | 
|---|
|  | 105 | venvp=getenv("BRACQ_BASEDIR"); | 
|---|
|  | 106 | if (venvp!=NULL) { | 
|---|
|  | 107 | string ebd=venvp; | 
|---|
|  | 108 | SetBaseDirectory(ebd); | 
|---|
|  | 109 | } | 
|---|
|  | 110 | string fibids="1,2,3,4,5,6,7,8"; | 
|---|
|  | 111 | venvp=getenv("BRACQ_FIBERIDS"); | 
|---|
|  | 112 | if (venvp!=NULL)  fibids=venvp; | 
|---|
|  | 113 | SetFiberIds(fibids); | 
|---|
|  | 114 | } | 
|---|
|  | 115 |  | 
|---|
|  | 116 | /* --Methode-- */ | 
|---|
|  | 117 | int BRConfList::SetFiberIds(string& sfids) | 
|---|
|  | 118 | { | 
|---|
|  | 119 | fiberIdsS_=sfids; | 
|---|
|  | 120 | vector<string> fibids; | 
|---|
|  | 121 | FillVStringFrString(sfids, fibids, ','); | 
|---|
|  | 122 | int rc=0; | 
|---|
|  | 123 | for (size_t fib=0; fib<fibids.size(); fib++) { | 
|---|
|  | 124 | if (fib>fiberIds_.size())  break; | 
|---|
|  | 125 | fiberIds_[fib]=atoi(fibids[fib].c_str()); | 
|---|
|  | 126 | rc++; | 
|---|
|  | 127 | } | 
|---|
|  | 128 | return rc; | 
|---|
|  | 129 | } | 
|---|
|  | 130 |  | 
|---|
|  | 131 | /* --Methode-- */ | 
|---|
|  | 132 | void BRConfList::SetBaseDirectory(string& basedir) | 
|---|
|  | 133 | { | 
|---|
|  | 134 | if (basedir.length()<1)  return; | 
|---|
| [3674] | 135 | basedir_=basedir; | 
|---|
|  | 136 | size_t len = basedir_.length(); | 
|---|
|  | 137 | if ((len>1)&&(basedir_[len-1]!='/')) basedir_ += '/'; | 
|---|
|  | 138 | } | 
|---|
|  | 139 |  | 
|---|
|  | 140 | /* --Methode-- */ | 
|---|
| [3913] | 141 | BRConfList& BRConfList::Set(BRConfList const & cf) | 
|---|
| [3672] | 142 | { | 
|---|
|  | 143 | basedir_=cf.basedir_; | 
|---|
|  | 144 | boards_=cf.boards_; | 
|---|
| [3913] | 145 | fiberIdsS_=cf.fiberIdsS_; | 
|---|
|  | 146 | fiberIds_=cf.fiberIds_; | 
|---|
|  | 147 | tmpdir_=cf.tmpdir_; | 
|---|
|  | 148 | return (*this); | 
|---|
| [3672] | 149 | } | 
|---|
|  | 150 |  | 
|---|
|  | 151 | /* --Methode-- */ | 
|---|
|  | 152 | ostream& BRConfList::Print(ostream& os) | 
|---|
|  | 153 | { | 
|---|
| [3913] | 154 | os << " ----- BRConfList:: BaseDir=" << basedir_ << " TmpDir=" << tmpdir_ | 
|---|
|  | 155 | << " NBoards= " << boards_.size() << endl; | 
|---|
| [3672] | 156 | for(size_t k=0; k<boards_.size(); k++)  boards_[k].Print(os); | 
|---|
| [3913] | 157 | os << " FiberIdString=" << fiberIdsS_ << endl; | 
|---|
| [3672] | 158 | return os; | 
|---|
|  | 159 | } | 
|---|
|  | 160 |  | 
|---|
|  | 161 | /* --Methode-- */ | 
|---|
|  | 162 | void BRConfList::ReadDCFile(string file) | 
|---|
|  | 163 | { | 
|---|
|  | 164 | //  A FAIRE | 
|---|
|  | 165 | } | 
|---|
|  | 166 |  | 
|---|
| [3671] | 167 | // Classe qui memorise tous les parametres importants de l'acquisition | 
|---|
| [4016] | 168 | /*! | 
|---|
|  | 169 | \class BRParList | 
|---|
|  | 170 | \ingroup TAcq | 
|---|
| [3671] | 171 |  | 
|---|
| [4016] | 172 | \brief Acquisition parameters ( see acqparam_exemple.d  datacard file ) | 
|---|
|  | 173 | */ | 
|---|
|  | 174 |  | 
|---|
| [3671] | 175 | /* --Methode-- */ | 
|---|
| [3681] | 176 | BRParList::BRParList(string acqmod, string fibres,unsigned int paqsz, | 
|---|
|  | 177 | unsigned int dmaszkb, int nfiles, int nblocfile, | 
|---|
|  | 178 | string outpath, uint_4 nzon , uint_4 npaqzon) | 
|---|
| [3671] | 179 | { | 
|---|
| [3681] | 180 | AcqMode=acqmod; | 
|---|
|  | 181 | fgdatafft=false; | 
|---|
| [3918] | 182 | fgfftshrink=false; | 
|---|
| [3681] | 183 | fgsinglechannel=false; | 
|---|
|  | 184 |  | 
|---|
| [3671] | 185 | FiberListS=fibres; | 
|---|
| [3909] | 186 |  | 
|---|
| [3671] | 187 | PaqSize=paqsz; | 
|---|
| [3909] | 188 |  | 
|---|
| [3674] | 189 | dmasizekb=dmaszkb; | 
|---|
| [3909] | 190 | maxkwedma_=1000; | 
|---|
|  | 191 | nretrydma_=3; | 
|---|
|  | 192 | first_maxkwedma_=20000; | 
|---|
|  | 193 | first_nretrydma_=9; | 
|---|
| [3681] | 194 |  | 
|---|
| [3671] | 195 | NbFiles=nfiles; | 
|---|
|  | 196 | NBlocPerFile=nblocfile; | 
|---|
|  | 197 | OutPathName=outpath; | 
|---|
| [3681] | 198 |  | 
|---|
| [3671] | 199 | nZones=nzon; | 
|---|
|  | 200 | nPaqZone=npaqzon; | 
|---|
| [3681] | 201 |  | 
|---|
| [3671] | 202 | swapall=BR_Copy; | 
|---|
|  | 203 | savesigfits=true; | 
|---|
|  | 204 | fgnulldev4fits=false; | 
|---|
| [3674] | 205 |  | 
|---|
| [3681] | 206 | fg_hard_ctrlc=false; | 
|---|
| [3674] | 207 |  | 
|---|
| [3671] | 208 | fgreducpsize=false; | 
|---|
| [3674] | 209 | reducneedcopy=false; | 
|---|
| [3673] | 210 | pqreducmode=BR_CopyRA; | 
|---|
| [3671] | 211 | redpqsize=PaqSize; | 
|---|
|  | 212 | reducoffset=0; | 
|---|
|  | 213 |  | 
|---|
| [3757] | 214 | tcpportid=BRSPORTID; | 
|---|
|  | 215 | pci2eth_fgdirect=false; | 
|---|
| [3897] | 216 | ethr_nlink=0; | 
|---|
|  | 217 | ethr_forcesamefc_=false; | 
|---|
| [3901] | 218 | ethr_sfc_maxdpc_=0; | 
|---|
|  | 219 | ethr_sfc_maxresync_=0; | 
|---|
| [3899] | 220 | ethr_waitendmsg_=false; | 
|---|
| [3757] | 221 |  | 
|---|
| [3674] | 222 | skysource=""; | 
|---|
| [3681] | 223 |  | 
|---|
| [3876] | 224 | //  --- variables de controle pour le monitoring | 
|---|
| [3681] | 225 | fgdoProc=false; | 
|---|
|  | 226 | nmeanProc=512; | 
|---|
|  | 227 | stepProc=5; | 
|---|
|  | 228 | nmaxProc=0; | 
|---|
| [3876] | 229 | //  --- variables de controle pour le calcul des visibilites | 
|---|
| [3920] | 230 | fgdoVisiC=false; | 
|---|
| [3876] | 231 | nmeanVisiC=1024; | 
|---|
| [4012] | 232 | fgtimeintervalVisiC=false; | 
|---|
|  | 233 | timeintervalVisiC=1.; | 
|---|
| [3876] | 234 | nbcalgrpVisiC=1; | 
|---|
|  | 235 | nthrVisiC=1; | 
|---|
| [3920] | 236 | fgfdtVisiC=false; | 
|---|
| [3915] | 237 | firstpairVisiC=0; | 
|---|
|  | 238 | nbpairsVisiC=999999999; | 
|---|
|  | 239 | fgpimpVisiC=false; | 
|---|
| [3876] | 240 | freqminVisiC=freqmaxVisiC=0; | 
|---|
|  | 241 | nbinfreqVisiC=1; | 
|---|
| [4010] | 242 | fgfitsVisiC=false; | 
|---|
| [3681] | 243 |  | 
|---|
| [3876] | 244 | // Autres variables / variables speciales | 
|---|
| [3671] | 245 | monothr=false; | 
|---|
|  | 246 | activate_pattern=false; | 
|---|
| [3681] | 247 | nopciLossRate=0.; | 
|---|
| [3671] | 248 |  | 
|---|
| [3883] | 249 | // niveau d'impression,debug ... | 
|---|
|  | 250 | prtlevel_=0; | 
|---|
|  | 251 | prtmodulo_=50000; | 
|---|
| [3923] | 252 | prtmodulo2_=50; | 
|---|
| [3671] | 253 | Decode();    // On decode et on complete les parametres | 
|---|
|  | 254 | } | 
|---|
|  | 255 |  | 
|---|
|  | 256 | /* --Methode-- */ | 
|---|
|  | 257 | BRParList::BRParList(BRParList const & p) | 
|---|
|  | 258 | { | 
|---|
|  | 259 | Set(p); | 
|---|
|  | 260 | } | 
|---|
|  | 261 |  | 
|---|
|  | 262 | /* --Methode-- */ | 
|---|
|  | 263 | void BRParList::Set(BRParList const & p) | 
|---|
|  | 264 | { | 
|---|
| [3681] | 265 | AcqMode=p.AcqMode; | 
|---|
|  | 266 | fgdatafft=p.fgdatafft; | 
|---|
| [3918] | 267 | fgfftshrink=p.fgfftshrink; | 
|---|
| [3681] | 268 | fgsinglechannel=p.fgsinglechannel; | 
|---|
|  | 269 |  | 
|---|
| [3671] | 270 | FiberListS=p.FiberListS; | 
|---|
| [3913] | 271 | fiberNum_=p.fiberNum_; | 
|---|
| [3681] | 272 |  | 
|---|
| [3671] | 273 | PaqSize=p.PaqSize; | 
|---|
| [3909] | 274 |  | 
|---|
| [3674] | 275 | dmasizekb=p.dmasizekb; | 
|---|
| [3909] | 276 | maxkwedma_=p.maxkwedma_; | 
|---|
|  | 277 | nretrydma_=p.nretrydma_; | 
|---|
|  | 278 | first_maxkwedma_=p.first_maxkwedma_; | 
|---|
|  | 279 | first_nretrydma_=p.first_nretrydma_; | 
|---|
| [3681] | 280 |  | 
|---|
| [3671] | 281 | NbFiles=p.NbFiles; | 
|---|
|  | 282 | NBlocPerFile=p.NBlocPerFile; | 
|---|
|  | 283 | OutPathName=p.OutPathName; | 
|---|
| [3681] | 284 |  | 
|---|
| [3671] | 285 | nZones=p.nZones; | 
|---|
|  | 286 | nPaqZone=p.nPaqZone; | 
|---|
| [3681] | 287 |  | 
|---|
| [3671] | 288 | swapall=p.swapall; | 
|---|
|  | 289 | savesigfits=p.savesigfits; | 
|---|
|  | 290 | fgnulldev4fits=p.fgnulldev4fits; | 
|---|
|  | 291 | fg_hard_ctrlc=p.fg_hard_ctrlc; | 
|---|
|  | 292 | fgnulldev4fits=p.fgnulldev4fits; | 
|---|
|  | 293 |  | 
|---|
|  | 294 | fgreducpsize=p.fgreducpsize; | 
|---|
| [3674] | 295 | reducneedcopy=p.reducneedcopy; | 
|---|
| [3673] | 296 | pqreducmode=p.pqreducmode; | 
|---|
| [3671] | 297 | redpqsize=p.redpqsize; | 
|---|
|  | 298 | reducoffset=p.reducoffset; | 
|---|
|  | 299 |  | 
|---|
| [3760] | 300 | tcpportid=p.tcpportid; | 
|---|
| [3757] | 301 | pci2eth_fgdirect=p.pci2eth_fgdirect; | 
|---|
|  | 302 | eths_targets=p.eths_targets; | 
|---|
| [3913] | 303 | eths_stargs=p.eths_stargs; | 
|---|
|  | 304 | eths_fibtargs=p.eths_fibtargs; | 
|---|
|  | 305 |  | 
|---|
| [3757] | 306 | ethr_nlink=p.ethr_nlink; | 
|---|
| [3883] | 307 | ethr_forcesamefc_=p.ethr_forcesamefc_; | 
|---|
| [3897] | 308 | ethr_sfc_maxdpc_=p.ethr_sfc_maxdpc_; | 
|---|
|  | 309 | ethr_sfc_maxresync_=p.ethr_sfc_maxresync_; | 
|---|
| [3899] | 310 | ethr_waitendmsg_=p.ethr_waitendmsg_; | 
|---|
| [3757] | 311 |  | 
|---|
| [3674] | 312 | skysource=p.skysource; | 
|---|
| [3681] | 313 |  | 
|---|
|  | 314 | fgdoProc=p.fgdoProc; | 
|---|
|  | 315 | nmeanProc=p.nmeanProc; | 
|---|
|  | 316 | stepProc=p.stepProc; | 
|---|
|  | 317 | nmaxProc=p.nmaxProc; | 
|---|
| [3674] | 318 |  | 
|---|
| [3915] | 319 | fgdoVisiC=p.fgdoVisiC; | 
|---|
| [4012] | 320 | nmeanVisiC=p.nmeanVisiC; | 
|---|
|  | 321 | fgtimeintervalVisiC=p.fgtimeintervalVisiC; | 
|---|
|  | 322 | timeintervalVisiC=p.timeintervalVisiC; | 
|---|
| [3915] | 323 | nbcalgrpVisiC=p.nbcalgrpVisiC; | 
|---|
| [3920] | 324 | nthrVisiC=p.nthrVisiC; | 
|---|
|  | 325 | fgfdtVisiC=p.fgfdtVisiC; | 
|---|
| [3915] | 326 | firstpairVisiC=p.firstpairVisiC; | 
|---|
|  | 327 | nbpairsVisiC=p.nbpairsVisiC; | 
|---|
|  | 328 | fgpimpVisiC=p.fgpimpVisiC; | 
|---|
|  | 329 | freqminVisiC=p.freqminVisiC; | 
|---|
|  | 330 | freqmaxVisiC=p.freqmaxVisiC; | 
|---|
|  | 331 | nbinfreqVisiC=p.nbinfreqVisiC; | 
|---|
| [4010] | 332 | fgfitsVisiC=p.fgfitsVisiC; | 
|---|
| [3915] | 333 |  | 
|---|
| [3671] | 334 | monothr=p.monothr; | 
|---|
|  | 335 | activate_pattern=p.activate_pattern; | 
|---|
| [3681] | 336 |  | 
|---|
|  | 337 | nopciLossRate=p.nopciLossRate; | 
|---|
| [3883] | 338 |  | 
|---|
|  | 339 | prtlevel_=p.prtlevel_; | 
|---|
| [3923] | 340 | prtmodulo_=p.prtmodulo_; | 
|---|
|  | 341 | prtmodulo2_=p.prtmodulo2_; | 
|---|
| [3883] | 342 |  | 
|---|
| [3671] | 343 | return; | 
|---|
|  | 344 | } | 
|---|
|  | 345 |  | 
|---|
|  | 346 | /* --Methode-- */ | 
|---|
|  | 347 | void BRParList::ReadDCFile(string file) | 
|---|
|  | 348 | { | 
|---|
|  | 349 | DataCards conf(file); | 
|---|
| [3909] | 350 | if(conf.HasKey("fibres")) | 
|---|
|  | 351 | FiberListS= conf.SParam("fibres",0,"1"); | 
|---|
|  | 352 | else if(conf.HasKey("fibers")) | 
|---|
|  | 353 | FiberListS= conf.SParam("fibers",0,"1"); | 
|---|
|  | 354 |  | 
|---|
| [3674] | 355 | OutPathName= conf.SParam("outpathname",0,"TstAcq"); | 
|---|
|  | 356 | skysource= conf.SParam("skysource",0,""); | 
|---|
|  | 357 | PaqSize=(uint_4)conf.IParam("paqsize",0,16424); | 
|---|
| [3909] | 358 |  | 
|---|
| [3674] | 359 | dmasizekb =(uint_4) conf.IParam("dmasizekb",0,32); | 
|---|
| [3909] | 360 | maxkwedma_=(unsigned int)conf.IParam("waitenddma",0,1000); | 
|---|
|  | 361 | nretrydma_=(unsigned int)conf.IParam("waitenddma",1,3); | 
|---|
|  | 362 | first_maxkwedma_=(unsigned int)conf.IParam("waitenddma",2,20*maxkwedma_); | 
|---|
|  | 363 | first_nretrydma_=(unsigned int)conf.IParam("waitenddma",3,3*nretrydma_); | 
|---|
|  | 364 |  | 
|---|
| [3674] | 365 | NbFiles=conf.IParam("nbfiles",0,1); | 
|---|
|  | 366 | NBlocPerFile=conf.IParam("nblocperfile",0,10); | 
|---|
| [3671] | 367 | AcqMode =conf.SParam("acqmode",0,"std"); | 
|---|
| [3674] | 368 | nZones=(uint_4)conf.IParam("memmgr",0,4); | 
|---|
|  | 369 | nPaqZone=(uint_4)conf.IParam("memmgr",1,128); | 
|---|
|  | 370 | if (conf.HasKey("reducpaqsz")) {  // reduction des tailles de paquets | 
|---|
|  | 371 | fgreducpsize=true; | 
|---|
|  | 372 | redpqsize=(uint_4)conf.IParam("reducpaqsz",0,PaqSize/4); | 
|---|
|  | 373 | reducoffset=(uint_4)conf.IParam("reducpaqsz",1,0); | 
|---|
|  | 374 | } | 
|---|
| [3757] | 375 | // Mot cle pour le mode envoi-reception sur ethernet | 
|---|
|  | 376 | tcpportid=conf.IParam("tcpportid",0,BRSPORTID); | 
|---|
|  | 377 | if (conf.HasKey("pci2ethdirect"))  pci2eth_fgdirect = true;   // Transfer direct DMA -> Ethernet | 
|---|
| [3913] | 378 | if (conf.HasKey("ethrtargets")) {    // Machines destinations des paquets - memes destinations pour toutes les fibres | 
|---|
| [3757] | 379 | for(int it=0; it<conf.NbParam("ethrtargets"); it++) | 
|---|
| [3913] | 380 | eths_stargs.push_back(conf.SParam("ethrtargets",it)); | 
|---|
| [3757] | 381 | } | 
|---|
| [3913] | 382 |  | 
|---|
|  | 383 | const char* ethtf[9]={"ethrtargetsf1","ethrtargetsf2","ethrtargetsf3","ethrtargetsf4", | 
|---|
|  | 384 | "ethrtargetsf5","ethrtargetsf6","ethrtargetsf7","ethrtargetsf8"}; | 
|---|
|  | 385 | for(int jj=0;jj<8;jj++) { | 
|---|
|  | 386 | if (conf.HasKey( ethtf[jj] )) { | 
|---|
|  | 387 | vector<string> ftargs; | 
|---|
|  | 388 | int fid=jj+1; | 
|---|
|  | 389 | for(int it=0; it<conf.NbParam( ethtf[jj] ); it++) | 
|---|
|  | 390 | ftargs.push_back(conf.SParam( ethtf[jj] ,it)); | 
|---|
|  | 391 | eths_fibtargs[fid]=ftargs; | 
|---|
|  | 392 | } | 
|---|
|  | 393 | } | 
|---|
|  | 394 |  | 
|---|
| [3757] | 395 | ethr_nlink=conf.IParam("ethrnlink",0,0);   // Nombre de sources de paquets en reception ethernet | 
|---|
| [3897] | 396 | if (conf.HasKey("ethrforcesamefc"))  { | 
|---|
|  | 397 | ethr_forcesamefc_=true;   // force SAME FrameCounter   on all links | 
|---|
| [3901] | 398 | ethr_sfc_maxdpc_=conf.IParam("ethrforcesamefc",0,0); | 
|---|
|  | 399 | ethr_sfc_maxresync_=conf.IParam("ethrforcesamefc",1,0); | 
|---|
| [3897] | 400 | } | 
|---|
| [3899] | 401 | if (conf.HasKey("ethrwaitendmsg"))  ethr_waitendmsg_=true; | 
|---|
| [3757] | 402 |  | 
|---|
| [3876] | 403 | //  Parametre de controle du monitoring | 
|---|
| [3681] | 404 | if (conf.HasKey("monitor")) { | 
|---|
|  | 405 | fgdoProc=true; | 
|---|
|  | 406 | nmeanProc=conf.IParam("monitor",0,512); | 
|---|
|  | 407 | stepProc=conf.IParam("monitor",1,10); | 
|---|
|  | 408 | nmaxProc=conf.IParam("monitor",2,0); | 
|---|
|  | 409 | } | 
|---|
| [3876] | 410 | // Parametres pour le calcul des visibilites - le flag fgdoVisiC ne peut etre active | 
|---|
|  | 411 | // qu'avec l'option de ligne de commande de mfacq | 
|---|
|  | 412 | if (conf.HasKey("visicalc")) { | 
|---|
|  | 413 | nmeanVisiC=conf.IParam("visicalc",0,1024); | 
|---|
|  | 414 | nbcalgrpVisiC=conf.IParam("visicalc",1,1); | 
|---|
|  | 415 | nthrVisiC=conf.IParam("visicalc",2,1); | 
|---|
|  | 416 | } | 
|---|
| [4012] | 417 | if (conf.HasKey("visitimeint")) { | 
|---|
|  | 418 | fgtimeintervalVisiC=true; | 
|---|
|  | 419 | timeintervalVisiC=conf.DParam("visitimeint",0,1.); | 
|---|
|  | 420 | } | 
|---|
| [3920] | 421 | if (conf.HasKey("visidtable"))  fgfdtVisiC=true; | 
|---|
| [3915] | 422 | if (conf.HasKey("visipairs")) { | 
|---|
|  | 423 | firstpairVisiC=conf.IParam("visipairs",0,0); | 
|---|
|  | 424 | nbpairsVisiC=conf.IParam("visipairs",1,999999999); | 
|---|
|  | 425 | fgpimpVisiC=(conf.IParam("visipairs",2,0)>0)?true:false; | 
|---|
| [3876] | 426 | } | 
|---|
| [3915] | 427 | if (conf.HasKey("visifreq")) { | 
|---|
|  | 428 | freqminVisiC=conf.IParam("visifreq",0,0); | 
|---|
|  | 429 | freqmaxVisiC=conf.IParam("visifreq",1,0); | 
|---|
|  | 430 | nbinfreqVisiC=conf.IParam("visifreq",2,1); | 
|---|
|  | 431 | } | 
|---|
| [4010] | 432 | if (conf.HasKey("visifitsout")) fgfitsVisiC=true; | 
|---|
|  | 433 | if (conf.HasKey("visippfout")) fgfitsVisiC=false; | 
|---|
| [3876] | 434 |  | 
|---|
| [3681] | 435 | nopciLossRate=conf.DParam("nopcilossrate",0,0.); | 
|---|
| [3674] | 436 | fg_hard_ctrlc=conf.HasKey("hard_ctrlc"); | 
|---|
| [3681] | 437 | if (conf.HasKey("nosavesigfits"))  savesigfits=false; | 
|---|
| [3883] | 438 | if (conf.HasKey("prtlev"))  { | 
|---|
|  | 439 | prtlevel_=conf.IParam("prtlev",0,0); | 
|---|
|  | 440 | prtmodulo_=conf.IParam("prtlev",1,50000); | 
|---|
| [3923] | 441 | prtmodulo2_=conf.IParam("prtlev",2,50); | 
|---|
| [3883] | 442 | } | 
|---|
|  | 443 |  | 
|---|
| [3671] | 444 | Decode(); | 
|---|
|  | 445 | } | 
|---|
|  | 446 |  | 
|---|
|  | 447 | /* --Methode-- */ | 
|---|
|  | 448 | void BRParList::Decode() | 
|---|
|  | 449 | { | 
|---|
|  | 450 | vector<string> fiblist; | 
|---|
|  | 451 | FillVStringFrString(FiberListS, fiblist, ','); | 
|---|
| [3913] | 452 | fiberNum_.resize(fiblist.size()); | 
|---|
| [3671] | 453 | for (int fib=0; fib<fiblist.size(); fib++) { | 
|---|
| [3913] | 454 | fiberNum_[fib]=atoi(fiblist[fib].c_str()); | 
|---|
| [3671] | 455 | } | 
|---|
| [3913] | 456 |  | 
|---|
|  | 457 | eths_targets.resize(fiberNum_.size()); | 
|---|
|  | 458 | for (int fib=0; fib<fiberNum_.size(); fib++) { | 
|---|
|  | 459 | map< int, vector<string> >::const_iterator itm=eths_fibtargs.find(fiberNum_[fib]); | 
|---|
|  | 460 | if (itm != eths_fibtargs.end())   eths_targets[fib]=itm->second; | 
|---|
|  | 461 | else eths_targets[fib]=eths_stargs; | 
|---|
| [3909] | 462 | } | 
|---|
|  | 463 |  | 
|---|
| [3672] | 464 | if (OutPathName == "/dev/null") { | 
|---|
|  | 465 | fgnulldev4fits=true; | 
|---|
|  | 466 | } | 
|---|
|  | 467 | else { | 
|---|
|  | 468 | size_t len = OutPathName.length(); | 
|---|
|  | 469 | if ((len>1)&&(OutPathName[len-1]!='/')) OutPathName+='/'; | 
|---|
|  | 470 | fgnulldev4fits=false; | 
|---|
|  | 471 | } | 
|---|
| [3671] | 472 | string acqmode = AcqMode; | 
|---|
| [3918] | 473 | fgdatafft=false;  fgfftshrink=false;  fgsinglechannel=false; | 
|---|
| [3674] | 474 | reducneedcopy=false;  pqreducmode=BR_TwoChanReduc; | 
|---|
| [4010] | 475 | if ((acqmode == "std")||(acqmode=="raw2c"))   swapall = BR_Copy ; | 
|---|
| [3909] | 476 | if (acqmode=="raw1c") { swapall = BR_Copy ;  fgsinglechannel=true;  pqreducmode=BR_OneChanReduc; } | 
|---|
|  | 477 |  | 
|---|
| [3918] | 478 | if (acqmode=="fft2c")  { swapall = BR_Copy;  fgdatafft=true; } | 
|---|
|  | 479 | if ((acqmode=="fft2cshrink")||(acqmode=="fftshrink"))  {  swapall = BR_Copy; fgdatafft=true; fgfftshrink=true; } | 
|---|
|  | 480 | if (acqmode=="fft1c")  { swapall = BR_Copy;  fgdatafft=true; fgsinglechannel=true; } | 
|---|
|  | 481 | if (acqmode=="fft1cshrink")  {  swapall = BR_Copy; fgdatafft=true; fgfftshrink=true; fgfftshrink=true; } | 
|---|
|  | 482 |  | 
|---|
| [3671] | 483 | if (acqmode == "nosw")   swapall = BR_Copy ; | 
|---|
|  | 484 | if (acqmode == "nof")  { swapall = BR_Copy ; savesigfits = false; } | 
|---|
| [3909] | 485 | if (acqmode == "ordfft1c")  { swapall = BR_FFTOneChan; reducneedcopy=true;  pqreducmode=BR_OneChanReducK0; } | 
|---|
|  | 486 | if (acqmode == "ordfft2c")  { swapall = BR_FFTTwoChan;  reducneedcopy=true;  pqreducmode=BR_TwoChanReducK0; } | 
|---|
|  | 487 |  | 
|---|
| [3674] | 488 | if (acqmode == "fft1cnof") | 
|---|
|  | 489 | { swapall = BR_FFTOneChan;  savesigfits = false; reducneedcopy=true;  pqreducmode=BR_OneChanReducK0;  } | 
|---|
|  | 490 | if (acqmode == "fft2cnof") | 
|---|
|  | 491 | { swapall = BR_FFTTwoChan;  savesigfits = false; reducneedcopy=true;  pqreducmode=BR_TwoChanReducK0; } | 
|---|
| [3671] | 492 | if (acqmode == "mono")  { monothr = true;   swapall = BR_Copy; } | 
|---|
|  | 493 | if (acqmode == "monodirect")  { monothr = true;  swapall =  BR_CopyHDR;} | 
|---|
|  | 494 | if (acqmode == "patmonodirect")  { monothr = true;  swapall =  BR_CopyHDR; activate_pattern=true; } | 
|---|
|  | 495 | if (acqmode == "patmono")  { monothr = true;   swapall = BR_Copy; activate_pattern=true; } | 
|---|
|  | 496 | if (acqmode == "patnof")  { savesigfits = false; swapall = BR_Copy; activate_pattern=true; } | 
|---|
|  | 497 | if (acqmode == "pattern")  { savesigfits = true; swapall = BR_Copy; activate_pattern=true; } | 
|---|
|  | 498 |  | 
|---|
|  | 499 | if (acqmode == "swapall")  swapall = BR_SwapAll; | 
|---|
| [3674] | 500 | if (acqmode == "fft1csw") | 
|---|
|  | 501 | { swapall = BR_FFTOneChanSwapAll;  reducneedcopy=true;  pqreducmode=BR_OneChanReducK0; } | 
|---|
|  | 502 | if (acqmode == "fft2csw") | 
|---|
|  | 503 | { swapall = BR_FFTTwoChanSwapAll;  reducneedcopy=true;  pqreducmode=BR_TwoChanReducK0; } | 
|---|
|  | 504 | if (acqmode == "fft1cswnof") | 
|---|
|  | 505 | { swapall = BR_FFTOneChanSwapAll;  savesigfits = false; reducneedcopy=true;  pqreducmode=BR_OneChanReducK0; } | 
|---|
|  | 506 | if (acqmode == "fft2cswnof") | 
|---|
|  | 507 | { swapall = BR_FFTTwoChanSwapAll;  savesigfits = false; reducneedcopy=true;  pqreducmode=BR_TwoChanReducK0; } | 
|---|
| [3671] | 508 | if ((acqmode == "swh") || (acqmode == "mxs") || (acqmode == "monoswh") )  swapall = BR_SwapHDR; | 
|---|
|  | 509 | if ((acqmode == "swapallnof") || (acqmode == "mxs") )  savesigfits = false; | 
|---|
|  | 510 | if (acqmode == "monoswh")  { monothr = true;   swapall = BR_SwapHDR;; } | 
|---|
|  | 511 | if (acqmode == "monosw")  { monothr = true;   swapall = BR_SwapAll; } | 
|---|
|  | 512 |  | 
|---|
|  | 513 | if (acqmode == "swap32")   swapall = BR_Swap32 ; | 
|---|
|  | 514 | if (acqmode == "nof32")   { swapall = BR_Swap32 ; savesigfits = false; } | 
|---|
| [3674] | 515 | if (acqmode == "fft1c32") | 
|---|
|  | 516 | { swapall = BR_FFTOneChanSwap32; reducneedcopy=true;  pqreducmode=BR_OneChanReducK0; } | 
|---|
|  | 517 | if (acqmode == "fft2c32") | 
|---|
|  | 518 | { swapall = BR_FFTTwoChanSwap32; reducneedcopy=true;  pqreducmode=BR_TwoChanReducK0; } | 
|---|
|  | 519 | if (acqmode == "fft1cnof32") | 
|---|
|  | 520 | { swapall = BR_FFTOneChanSwap32;  savesigfits = false; reducneedcopy=true;  pqreducmode=BR_OneChanReducK0; } | 
|---|
|  | 521 | if (acqmode == "fft2cnof32") | 
|---|
|  | 522 | { swapall = BR_FFTTwoChanSwap32;  savesigfits = false; reducneedcopy=true;  pqreducmode=BR_TwoChanReducK0; } | 
|---|
|  | 523 |  | 
|---|
| [3681] | 524 | if ((swapall==BR_FFTTwoChan)||(swapall==BR_FFTTwoChanSwapAll)||(swapall==BR_FFTTwoChanSwap32)) { | 
|---|
|  | 525 | fgdatafft=true; | 
|---|
|  | 526 | } | 
|---|
|  | 527 | if ((swapall==BR_FFTOneChan)||(swapall==BR_FFTOneChanSwapAll)||(swapall==BR_FFTOneChanSwap32)) { | 
|---|
|  | 528 | fgdatafft=true;  fgsinglechannel=true; | 
|---|
|  | 529 | } | 
|---|
|  | 530 |  | 
|---|
| [3674] | 531 | if (fgreducpsize) { | 
|---|
|  | 532 | if (redpqsize>=PaqSize) fgreducpsize=false; | 
|---|
|  | 533 | else { | 
|---|
|  | 534 | if(reducoffset>(PaqSize-redpqsize)/2) reducoffset=(PaqSize-redpqsize)/2; | 
|---|
|  | 535 | } | 
|---|
|  | 536 | } | 
|---|
| [3671] | 537 | } | 
|---|
|  | 538 |  | 
|---|
|  | 539 | /* --Methode-- */ | 
|---|
|  | 540 | ostream& BRParList::Print(ostream& os) | 
|---|
|  | 541 | { | 
|---|
|  | 542 | os << " ------ BRParList::Print() ----- " << endl; | 
|---|
|  | 543 | os << " FiberListS=" << FiberListS ; | 
|---|
|  | 544 | os << " PaqSize=" <<PaqSize; | 
|---|
| [3909] | 545 | os << " DMA_Size_kb=" <<dmasizekb << " (EndDMA: Maxkw=" << maxkwedma_ << " NRetry=" << nretrydma_ | 
|---|
|  | 546 | << " FirstDMA: Maxkw=" << first_maxkwedma_ << " NRetry=" << first_nretrydma_ << ")" << endl; | 
|---|
| [3671] | 547 | os << " AcqMode="<<AcqMode; | 
|---|
|  | 548 | os << " Type of acquisition :" << BRPaquet::FmtConvToString( swapall) << endl; | 
|---|
| [3918] | 549 | os << " Firmware: " << ((fgdatafft)?" FFT_Data ":" RawData "); | 
|---|
|  | 550 | os << ((fgfftshrink)?" ShrinkFFT ":" FULLFFT "); | 
|---|
|  | 551 | os << ((fgsinglechannel)?" SingleChannel":" TwoChannels") << endl; | 
|---|
| [3674] | 552 | os << " SkySource=" << skysource; | 
|---|
| [3671] | 553 | os << " NbFiles="<<NbFiles; | 
|---|
|  | 554 | os << " NBlocPerFile="<<NBlocPerFile; | 
|---|
|  | 555 | os << " OutPathName="<<OutPathName << endl; | 
|---|
|  | 556 | os << " MemMgr: nZones="<<nZones; | 
|---|
| [3674] | 557 | os << " nPaqZone="<<nPaqZone<<endl; | 
|---|
|  | 558 | if (fgreducpsize) { | 
|---|
|  | 559 | os << " PaquetSize Reduction, ReducedSize=" << redpqsize << " Offset=" << reducoffset << endl; | 
|---|
|  | 560 | } | 
|---|
| [3913] | 561 | if ((eths_stargs.size()>0)||(eths_fibtargs.size()>0))   { | 
|---|
|  | 562 | os << " DMA->Ethernet Targets=" << eths_targets.size() | 
|---|
|  | 563 | << ((pci2eth_fgdirect)?" (DirectTransferMode) " : " " ) << endl; | 
|---|
|  | 564 |  | 
|---|
|  | 565 | for(size_t fib=0; fib<eths_targets.size(); fib++) { | 
|---|
|  | 566 | os << " Fiber Num=" << fiberNum_[fib] << " --> eth_targets: "; | 
|---|
|  | 567 | for(size_t it=0; it<eths_targets[fib].size(); it++) | 
|---|
|  | 568 | os << eths_targets[fib][it] << " ; "; | 
|---|
|  | 569 | os << endl; | 
|---|
|  | 570 | } | 
|---|
| [3757] | 571 | } | 
|---|
| [3913] | 572 | os << " TCP-PortId=" << tcpportid << " EthernetRead NbSources (=NbLinks)= " << ethr_nlink << endl; | 
|---|
| [3897] | 573 | if (ethr_forcesamefc_) | 
|---|
| [3913] | 574 | os << "EthernetReader mode: ForceSameFrameCounter read mode with Max_PaquetCounterDiff= " | 
|---|
| [3899] | 575 | << ethr_sfc_maxdpc_ << " MaxNbResync=" << ethr_sfc_maxresync_ | 
|---|
|  | 576 | << ((ethr_waitendmsg_)?" Wait_For_END_Message_Before_Terminate ":" ") << endl; | 
|---|
| [3897] | 577 | else | 
|---|
| [3913] | 578 | os << "EthernetReader mode: AllOKPaquets read mode " | 
|---|
| [3899] | 579 | << ((ethr_waitendmsg_)?" Wait_For_END_Message_Before_Terminate ":" ") << endl; | 
|---|
| [3883] | 580 |  | 
|---|
| [3681] | 581 | if (fgdoProc>0) | 
|---|
|  | 582 | os << " Monitoring  NMeanProc=" << nmeanProc << " StepProc=" << stepProc << " NMaxProc=" << nmaxProc << endl; | 
|---|
|  | 583 | else os << " No monotoring thread " << endl; | 
|---|
| [3876] | 584 | if (fgdoVisiC) { | 
|---|
| [3920] | 585 | os << " Visibility calculation, nbCalGrp=" << nbcalgrpVisiC << " NThr/VisCal=" << nthrVisiC | 
|---|
|  | 586 | << ((fgfdtVisiC)?" Fill_VisiDTable":" ") << endl; | 
|---|
| [4012] | 587 | if (fgtimeintervalVisiC) os << " ... VisiCalc TimeIntervalMode : " << timeintervalVisiC << " seconds " << endl; | 
|---|
|  | 588 | else  os << " ... VisiCalc  NPaq=" << nmeanVisiC  << " IntervalMode " << endl; | 
|---|
| [3915] | 589 | os << " ... VisiCalc FirstPair= " << firstpairVisiC << " NbPairs= " << nbpairsVisiC | 
|---|
|  | 590 | << ((fgpimpVisiC)?" (Odd-Even visibilities+AutoCorrel only) ":"") << endl; | 
|---|
| [3876] | 591 | os << " ... VisiCalc FrequencyBinning FreqMin= " << freqminVisiC << " FreqMax= " << freqmaxVisiC | 
|---|
|  | 592 | << " NBinFreq= " << nbinfreqVisiC<< endl; | 
|---|
| [4010] | 593 | os << (fgfitsVisiC?" FITS output format for visibility files":" PPF output format for visibility files") << endl; | 
|---|
| [3876] | 594 | } | 
|---|
| [3671] | 595 | os << " fg_hard_ctrlc=" << ((fg_hard_ctrlc)?"true":"false"); | 
|---|
|  | 596 | os << " Save to fits " << ((savesigfits)?"true":"false") << endl; | 
|---|
|  | 597 | os << " monothr y(1)/n(0) " << ((monothr)?"true":"false"); | 
|---|
|  | 598 | os << " ActivatePattern " << ((activate_pattern)?"true":"false") <<  endl; | 
|---|
| [3923] | 599 | os << " PrtLevel=" << prtlevel_ << " PrtCntModulo=" <<  prtmodulo_ << " PrtCntModulo2=" <<  prtmodulo2_ << endl; | 
|---|
| [3883] | 600 |  | 
|---|
| [3671] | 601 | return os; | 
|---|
|  | 602 | } | 
|---|
|  | 603 |  | 
|---|
|  | 604 |  | 
|---|
| [3672] | 605 | //-------------------- Classe BRAcqConfig ----------------------- | 
|---|
| [4016] | 606 | /*! | 
|---|
|  | 607 | \class BRAcqConfig | 
|---|
|  | 608 | \ingroup TAcq | 
|---|
| [3672] | 609 |  | 
|---|
| [4016] | 610 | \brief Defines acquisition (mfacq.cc) configuration and parameters. | 
|---|
|  | 611 |  | 
|---|
|  | 612 | See BRParList and BRConfList classes. | 
|---|
|  | 613 | */ | 
|---|
|  | 614 |  | 
|---|
| [3671] | 615 | BRParList* BRAcqConfig::param_=NULL; | 
|---|
| [3672] | 616 | BRConfList* BRAcqConfig::config_=NULL; | 
|---|
| [3671] | 617 |  | 
|---|
|  | 618 | /* --Methode-- */ | 
|---|
|  | 619 | BRAcqConfig::BRAcqConfig() | 
|---|
|  | 620 | { | 
|---|
|  | 621 | if (param_==NULL)  param_ = new BRParList; | 
|---|
| [3672] | 622 | if (config_==NULL) config_ = new BRConfList; | 
|---|
| [3671] | 623 | } | 
|---|
|  | 624 |  | 
|---|
|  | 625 | /* --Methode-- */ | 
|---|
| [3672] | 626 | ostream& BRAcqConfig::Print(ostream& os) | 
|---|
|  | 627 | { | 
|---|
|  | 628 | os << " ------------  BAORadio Acq Run/Configuration -------- " << endl; | 
|---|
|  | 629 | config_->Print(os); | 
|---|
|  | 630 | param_->Print(os); | 
|---|
| [3913] | 631 | os << " Fibers f: Num->Id  "; | 
|---|
|  | 632 | for(size_t f=0; f<NbFibers(); f++) | 
|---|
|  | 633 | os << f << ": " << FiberNum(f) << " -> " << FiberId(f) << " ; " ; | 
|---|
|  | 634 | os << endl; | 
|---|
| [3672] | 635 | os << " ----------------------------------------------------- " << endl; | 
|---|
|  | 636 | } | 
|---|
|  | 637 |  | 
|---|
|  | 638 | /* --Methode-- */ | 
|---|
| [3671] | 639 | int BRAcqConfig::CreateOutputDirectories() | 
|---|
|  | 640 | { | 
|---|
| [3672] | 641 | char cmd[1024]; | 
|---|
| [3671] | 642 | if (param_->fgnulldev4fits!=true) { | 
|---|
| [3672] | 643 | sprintf(cmd,"mkdir %s%s",config_->BaseDirectory().c_str(), param_->OutPathName.c_str()); | 
|---|
| [3671] | 644 | if (system(cmd) < 0) { | 
|---|
| [3672] | 645 | cout << "CreateOutputDirectories()/Error: Can not create subdirectory " | 
|---|
|  | 646 | << cmd << " -> stop" << endl; | 
|---|
| [3671] | 647 | return 2; | 
|---|
|  | 648 | } | 
|---|
|  | 649 | cout << "CreateOutputDirectories() - Executed command " << cmd << endl; | 
|---|
|  | 650 |  | 
|---|
| [3672] | 651 | memset(cmd,0,1024); | 
|---|
| [3671] | 652 | for (int  i= 0; i< NFibers() ; i++)  { | 
|---|
| [3913] | 653 | sprintf(cmd,"mkdir %s%s/Fiber%d",config_->BaseDirectory().c_str(), param_->OutPathName.c_str(),param_->fiberNum_[i]); | 
|---|
| [3671] | 654 | if (system(cmd) < 0) { | 
|---|
|  | 655 | cout << "CreateOutputDirectories()/Error: Can not create subdirectory " | 
|---|
| [3672] | 656 | << cmd << " -> stop" << endl; | 
|---|
| [3671] | 657 | return 3; | 
|---|
|  | 658 | } | 
|---|
|  | 659 | else cout << "CreateOutputDirectories() - Executed command " << cmd << endl; | 
|---|
|  | 660 | } | 
|---|
|  | 661 | } | 
|---|
|  | 662 | else { | 
|---|
|  | 663 | string ProcPathName = "./XZXZXZX/"; | 
|---|
|  | 664 | cout << " Using " << ProcPathName << " for other processed files ... " << endl; | 
|---|
|  | 665 | char cmd[512]; | 
|---|
|  | 666 | sprintf(cmd,"mkdir %s",ProcPathName.c_str()); | 
|---|
|  | 667 | if (system(cmd) < 0) { | 
|---|
|  | 668 | cout << "CreateOutputDirectories()/Error: Can not create subdirectory ./XZXZXZX/" | 
|---|
|  | 669 | << "-> stop" << endl; | 
|---|
|  | 670 | return 3; | 
|---|
|  | 671 | } | 
|---|
|  | 672 | else cout << "CreateOutputDirectories() - Executed command " << cmd << endl; | 
|---|
|  | 673 | } | 
|---|
|  | 674 | return 0; | 
|---|
|  | 675 | } | 
|---|
|  | 676 |  | 
|---|
|  | 677 | /* --Methode-- */ | 
|---|
|  | 678 | string BRAcqConfig::OutputDirectoryFib(int ifib) | 
|---|
|  | 679 | { | 
|---|
|  | 680 | char buff[24]; | 
|---|
| [3913] | 681 | sprintf(buff,"Fiber%d/",param_->fiberNum_[ifib]); | 
|---|
| [3672] | 682 | return ( config_->BaseDirectory() + param_->OutPathName + buff ); | 
|---|
| [3671] | 683 | } | 
|---|