| 1 | //----------------------------------------------------------------
|
|---|
| 2 | // Projet BAORadio - (C) LAL/IRFU 2008-2010
|
|---|
| 3 | // Classes de base pour les threads de traitememt donnees BAORadio
|
|---|
| 4 | //----------------------------------------------------------------
|
|---|
| 5 |
|
|---|
| 6 | #include <stdlib.h>
|
|---|
| 7 | #include <string.h>
|
|---|
| 8 | #include <unistd.h>
|
|---|
| 9 | #include <fstream>
|
|---|
| 10 | #include "brbaseproc.h"
|
|---|
| 11 |
|
|---|
| 12 |
|
|---|
| 13 | using namespace SOPHYA;
|
|---|
| 14 | //---------------------------------------------------------------------
|
|---|
| 15 | // Classe BRBaseProcessor : classe de base pour l'analyse des donnees
|
|---|
| 16 | // BAORadio - Les classes de traitement heritent de cette classe et
|
|---|
| 17 | // redefinissent la mathode Process() qui est appele paquet par paquet
|
|---|
| 18 | //---------------------------------------------------------------------
|
|---|
| 19 | /*!
|
|---|
| 20 | \class BRBaseProcessor
|
|---|
| 21 | \ingroup TAcq
|
|---|
| 22 |
|
|---|
| 23 | \brief Base class for BAORadio processing thread classes.
|
|---|
| 24 |
|
|---|
| 25 | Thread classes for BAORadio data processing and analysis can inherit from
|
|---|
| 26 | this class and redefine/implement the Process() method which is called
|
|---|
| 27 | for each BRpaquet.
|
|---|
| 28 | */
|
|---|
| 29 |
|
|---|
| 30 | /* --Methode-- */
|
|---|
| 31 | BRBaseProcessor::BRBaseProcessor(RAcqMemZoneMgr& memgr, MemZaction mmact)
|
|---|
| 32 | : memgr_(memgr), fbuff_(memgr.NbFibres()), fprocbuff_(memgr.NbFibres()),
|
|---|
| 33 | vpaq_(memgr.NbFibres()), vprocpaq_(memgr.NbFibres()),
|
|---|
| 34 | vpchk_(memgr.NbFibres()), vfgok_(memgr.NbFibres()),
|
|---|
| 35 | curfc_(memgr.NbFibres()), fcfirst_(memgr.NbFibres()), ttfirst_(memgr.NbFibres())
|
|---|
| 36 | {
|
|---|
| 37 | SetMemZAction(mmact);
|
|---|
| 38 | stop_ = false;
|
|---|
| 39 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
|
|---|
| 40 | fbuff_[fib]=NULL;
|
|---|
| 41 | fprocbuff_[fib]=NULL;
|
|---|
| 42 | vpaq_[fib]=BRPaquet(NULL,memgr_.PaqSize());
|
|---|
| 43 | vprocpaq_[fib]=NULL;
|
|---|
| 44 | vpchk_[fib]=BRPaqChecker(true,0);
|
|---|
| 45 | vfgok_[fib]=true;
|
|---|
| 46 | curfc_[fib]=0;
|
|---|
| 47 | fcfirst_[fib]=0;
|
|---|
| 48 | ttfirst_[fib]=0;
|
|---|
| 49 | }
|
|---|
| 50 | fgokallfibers_=true;
|
|---|
| 51 | totprocnpaq_=0;
|
|---|
| 52 | startdate_=0;
|
|---|
| 53 | setNameId("baseproc",0);
|
|---|
| 54 | ClearProcTimeWindow();
|
|---|
| 55 | SetPrintLevel();
|
|---|
| 56 | }
|
|---|
| 57 |
|
|---|
| 58 | /* --Methode-- */
|
|---|
| 59 | MemZStatus BRBaseProcessor::SetMemZAction(MemZaction mmact)
|
|---|
| 60 | {
|
|---|
| 61 | mmact_=mmact;
|
|---|
| 62 | mmsta_=MemZS_ProcA;
|
|---|
| 63 | switch (mmact) {
|
|---|
| 64 | case MemZA_ProcA:
|
|---|
| 65 | mmsta_=MemZS_ProcA;
|
|---|
| 66 | break;
|
|---|
| 67 | case MemZA_ProcB:
|
|---|
| 68 | mmsta_=MemZS_ProcB;
|
|---|
| 69 | break;
|
|---|
| 70 | case MemZA_ProcC:
|
|---|
| 71 | mmsta_=MemZS_ProcC;
|
|---|
| 72 | break;
|
|---|
| 73 | case MemZA_ProcD:
|
|---|
| 74 | mmsta_=MemZS_ProcD;
|
|---|
| 75 | break;
|
|---|
| 76 | case MemZA_ProcE:
|
|---|
| 77 | mmsta_=MemZS_ProcE;
|
|---|
| 78 | break;
|
|---|
| 79 | case MemZA_ProcF:
|
|---|
| 80 | mmsta_=MemZS_ProcF;
|
|---|
| 81 | break;
|
|---|
| 82 | case MemZA_ProcG:
|
|---|
| 83 | mmsta_=MemZS_ProcG;
|
|---|
| 84 | break;
|
|---|
| 85 | case MemZA_ProcH:
|
|---|
| 86 | mmsta_=MemZS_ProcH;
|
|---|
| 87 | break;
|
|---|
| 88 | case MemZA_ProcI:
|
|---|
| 89 | mmsta_=MemZS_ProcI;
|
|---|
| 90 | break;
|
|---|
| 91 | case MemZA_ProcJ:
|
|---|
| 92 | mmsta_=MemZS_ProcI;
|
|---|
| 93 | break;
|
|---|
| 94 | default:
|
|---|
| 95 | mmact_=MemZA_ProcA;
|
|---|
| 96 | mmsta_=MemZS_ProcA;
|
|---|
| 97 | break;
|
|---|
| 98 | }
|
|---|
| 99 | return mmsta_;
|
|---|
| 100 | }
|
|---|
| 101 |
|
|---|
| 102 | /* --Methode-- */
|
|---|
| 103 | void BRBaseProcessor::run()
|
|---|
| 104 | {
|
|---|
| 105 | setRC(1);
|
|---|
| 106 | int rc=0;
|
|---|
| 107 | try {
|
|---|
| 108 | cout << "BRBaseProcessor[" << bpnom_ << "," << bpid_ << "]::run() - Starting " << " NFibers="
|
|---|
| 109 | << memgr_.NbFibres() << endl;
|
|---|
| 110 | if (fgproctimewin_) cout << " BRBaseProcessor...TimeWindow Start=" << tmstart_ << " End=" << tmend_ << endl;
|
|---|
| 111 |
|
|---|
| 112 | size_t paqsz=memgr_.PaqSize();
|
|---|
| 113 | size_t procpaqsz=memgr_.ProcPaqSize();
|
|---|
| 114 |
|
|---|
| 115 | double tstartdays = tmstart_.ToDays();
|
|---|
| 116 | double tenddays = tmend_.ToDays();
|
|---|
| 117 |
|
|---|
| 118 | bool fgrun=true;
|
|---|
| 119 | while (fgrun) {
|
|---|
| 120 | if (stop_) break;
|
|---|
| 121 | if (memgr_.GetRunState() == MemZR_Stopped) break;
|
|---|
| 122 | mid_ = memgr_.FindMemZoneId(mmact_); // (MemZA_ProcA);
|
|---|
| 123 | // Byte* buffg = memgr_.GetMemZone(mid_);
|
|---|
| 124 | // if (buffg == NULL) {
|
|---|
| 125 | if (mid_ < 0) {
|
|---|
| 126 | cout << "BRBaseProcessor[" << bpnom_ << "," << bpid_ << "]::run()/ERROR FindMemZoneId("
|
|---|
| 127 | << (int)mmact_ << ") ->" << mid_ << ") -> NULL" << endl;
|
|---|
| 128 | setRC(7); fgrun=false;
|
|---|
| 129 | break;
|
|---|
| 130 | }
|
|---|
| 131 | cts_=memgr_.GetAuxData(mid_)->FillTime(); // get associated date/time (DATEOBS)
|
|---|
| 132 | if (startdate_==0) startdate_=cts_.DaysPart();
|
|---|
| 133 |
|
|---|
| 134 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
|
|---|
| 135 | fbuff_[fib] = memgr_.GetMemZone(mid_,fib);
|
|---|
| 136 | if (fbuff_[fib] == NULL) { // cela ne devrait pas arriver
|
|---|
| 137 | cout << "BRBaseProcessor[" << bpnom_ << "," << bpid_ << "]::run()/ERROR memgr.GetMemZone("
|
|---|
| 138 | << mid_ << "," << fib << ") -> NULL" << endl;
|
|---|
| 139 | setRC(9); fgrun=false;
|
|---|
| 140 | break;
|
|---|
| 141 | }
|
|---|
| 142 | if ((procpaqsz>0)&&((fprocbuff_[fib]=memgr_.GetProcMemZone(mid_,fib))==NULL)) { // cela ne devrait pas arriver non plus
|
|---|
| 143 | cout << "BRBaseProcessor[" << bpnom_ << "," << bpid_ << "]::run()/ERROR memgr.GetProcMemZone("
|
|---|
| 144 | << mid_ << "," << fib << ") -> NULL" << endl;
|
|---|
| 145 | setRC(9); fgrun=false;
|
|---|
| 146 | break;
|
|---|
| 147 | }
|
|---|
| 148 | }
|
|---|
| 149 |
|
|---|
| 150 | // On ne traite les paquets que si pas de fenetre en temps ou tmstart_ <= FillTime() <= tmend_
|
|---|
| 151 | double ftmdays = memgr_.GetAuxData(mid_)->FillTime().ToDays();
|
|---|
| 152 | if ((!fgproctimewin_) || ( (ftmdays<=tenddays)&&(ftmdays>=tstartdays) ) ) {
|
|---|
| 153 |
|
|---|
| 154 | for(size_t jp=0; jp<memgr_.NbPaquets(); jp++) { // boucle sur les paquets d'une zone
|
|---|
| 155 | fgokallfibers_=true;
|
|---|
| 156 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
|
|---|
| 157 | vpaq_[fib].Set(fbuff_[fib]+jp*paqsz);
|
|---|
| 158 | vfgok_[fib]=vpchk_[fib].Check(vpaq_[fib],curfc_[fib]);
|
|---|
| 159 | if (!vfgok_[fib]) fgokallfibers_=false;
|
|---|
| 160 | if (procpaqsz>0) vprocpaq_[fib] = fprocbuff_[fib]+jp*procpaqsz;
|
|---|
| 161 | }
|
|---|
| 162 | //--- Traitement
|
|---|
| 163 | int rcp=0;
|
|---|
| 164 | if (fgokallfibers_) {
|
|---|
| 165 | if (totprocnpaq_==0) {
|
|---|
| 166 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
|
|---|
| 167 | fcfirst_[fib]=curfc_[fib];
|
|---|
| 168 | ttfirst_[fib]=vpaq_[fib].TimeTag();
|
|---|
| 169 | }
|
|---|
| 170 | }
|
|---|
| 171 | rcp=Process();
|
|---|
| 172 | totprocnpaq_++;
|
|---|
| 173 | }
|
|---|
| 174 | // if (rcp != 0) { fgrun=false; break; }
|
|---|
| 175 | } // Fin de boucle sur les paquets
|
|---|
| 176 | } // Fin de test pour fenetre en temps de traitement des paquets
|
|---|
| 177 |
|
|---|
| 178 | memgr_.FreeMemZone(mid_, mmsta_); // (MemZS_ProcA);
|
|---|
| 179 | } // Fin de boucle sur les zones a traiter
|
|---|
| 180 | //------------------------------------
|
|---|
| 181 | cout << " ---- END BRBaseProcessor[" << bpnom_ << "," << bpid_ << "]::run() , TotNbProcPaq="
|
|---|
| 182 | << totprocnpaq_ << endl;
|
|---|
| 183 | /*
|
|---|
| 184 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) vpchk_[fib].Print();
|
|---|
| 185 | cout << " ------------------------------------ " << endl;
|
|---|
| 186 | */
|
|---|
| 187 | }
|
|---|
| 188 | catch (std::exception& exc) {
|
|---|
| 189 | cout << "BRBaseProcessor[" << bpnom_ << "," << bpid_ << "]::run()/catched std::exception " << exc.what() << endl;
|
|---|
| 190 | setRC(98);
|
|---|
| 191 | return;
|
|---|
| 192 | }
|
|---|
| 193 | catch(...) {
|
|---|
| 194 | cout << "BRBaseProcessor[" << bpnom_ << "," << bpid_ << "]::run()/catched unknown ... exception " << endl;
|
|---|
| 195 | setRC(99);
|
|---|
| 196 | return;
|
|---|
| 197 | }
|
|---|
| 198 |
|
|---|
| 199 | }
|
|---|
| 200 |
|
|---|
| 201 |
|
|---|
| 202 | /* --Methode-- */
|
|---|
| 203 | int BRBaseProcessor::Process()
|
|---|
| 204 | {
|
|---|
| 205 | // Cette methode est appele pour chaque "trigger', cad la serie de paquets pour toutes les fibres
|
|---|
| 206 | // la methode par defaut ne fait rien
|
|---|
| 207 | // if (fgokallfibers_) { faire le traitement }
|
|---|
| 208 | // return 0;
|
|---|
| 209 | /* Exemple de code test */
|
|---|
| 210 | if ((prtlev_>0)&&(totprocnpaq_ %prtmodulo_==0)) {
|
|---|
| 211 | cout << " BRBaseProcessor::Process(totnpaq=" << totprocnpaq_ << ") ObsTime=" << getObsTime()
|
|---|
| 212 | << " TimeTag=" << getCurTimeTagSeconds() << " s. FrameCounter=" << getCurFrameCounter() << endl;
|
|---|
| 213 | if (prtlev_<2) return 0;
|
|---|
| 214 | cout << " ... FrameCnt[0..." << memgr_.NbFibres()-1 << "]=" ;
|
|---|
| 215 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)
|
|---|
| 216 | cout << getCurFrameCounter(fib) << "," ;
|
|---|
| 217 | cout << endl;
|
|---|
| 218 | cout << " ... TimeTag[0..." << memgr_.NbFibres()-1 << "]=" ;
|
|---|
| 219 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)
|
|---|
| 220 | cout << getCurTimeTag(fib) << "," ;
|
|---|
| 221 | cout << endl;
|
|---|
| 222 | if (prtlev_<3) return 0;
|
|---|
| 223 | cout << " ... TimeTagSeconds[0..." << memgr_.NbFibres()-1 << "]=" ;
|
|---|
| 224 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)
|
|---|
| 225 | cout << getCurTimeTagSeconds(fib) << "," ;
|
|---|
| 226 | cout << endl;
|
|---|
| 227 | if (prtlev_<4) return 0;
|
|---|
| 228 | cout << " ... FileSequenceNumber[0..." << memgr_.NbFibres()-1 << "]=" ;
|
|---|
| 229 | for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)
|
|---|
| 230 | cout << memgr_.GetAuxData(mid_)->FileSequenceNumber(fib) << ",";
|
|---|
| 231 | cout << endl;
|
|---|
| 232 | }
|
|---|
| 233 | return 0;
|
|---|
| 234 | }
|
|---|
| 235 |
|
|---|
![(please configure the [header_logo] section in trac.ini)](/PI/chrome/site/your_project_logo.png){kind=logo}
