source: Sophya/trunk/AddOn/TAcq/brproc.cc@ 3708

Last change on this file since 3708 was 3708, checked in by ansari, 16 years ago

Correction-2 pour checktimetag, Reza 9/12/2009
File size: 31.3 KB
Line 
1#include "racquproc.h"
2
3#include <stdlib.h>
4#include <string.h>
5#include <unistd.h>
6#include <fstream>
7#include <signal.h>
8
9#include "pexceptions.h"
10#include "tvector.h"
11#include "ntuple.h"
12#include "datatable.h"
13#include "histos.h"
14#include "fioarr.h"
15#include "matharr.h"
16#include "timestamp.h"
17#include "ctimer.h"
18#include "fftpserver.h"
19#include "fftwserver.h"
20
21#include "FFTW/fftw3.h"
22
23
24#include "pciewrap.h"
25#include "brpaqu.h"
26#include "brproc.h"
27
28//---------------------------------------------------------------------
29// Classe de traitement - calcul de visibilite pour n fibres
30//---------------------------------------------------------------------
31
32/* --Methode-- */
33BRVisibilityCalculator::BRVisibilityCalculator(RAcqMemZoneMgr& memgr, string outpath, uint_4 nmean,
34 uint_4 freq1, uint_4 freq2, uint_4 nbfreq)
35 : BRBaseProcessor(memgr), outpath_(outpath), nmean_(nmean), numfreq1_(freq1), numfreq2_(freq2), nbinfreq_(nbfreq),
36 vpdata_(2*memgr.NbFibres())
37 // , dtfos_(outpath+"visdt.fits", Fits_Create), visdt_(dtfos_, 1024, true);
38
39{
40 BRPaquet paq(memgr_.PaqSize());
41
42 vismtx_.SetSize((2*memgr_.NbFibres()+1)*memgr_.NbFibres(), paq.DataSize()/4);
43 chanum_.SetSize(vismtx_.NRows());
44 sa_size_t k=0;
45 for(size_t i=0; i<2*memgr_.NbFibres(); i++) vpdata_[i]=NULL;
46 for(size_t i=0; i<2*memgr_.NbFibres(); i++) {
47 for(size_t j=i; j<2*memgr_.NbFibres(); j++) {
48 chanum_(k) = (i+1)*100+(j+1); k++;
49 }
50 }
51 // visdt_.AddFloatColumn("mfc");
52 visdt_.AddDoubleColumn("mfc");
53 visdt_.AddDoubleColumn("mtt");
54 visdt_.AddIntegerColumn("jfreq");
55 visdt_.AddIntegerColumn("numch");
56 visdt_.AddFloatColumn("vre");
57 visdt_.AddFloatColumn("vim");
58
59 if (nmean_ < 1) nmean_=memgr_.NbPaquets();
60 if (nmean_ < 1) nmean_=1;
61
62 totnbpaq_=0;
63 numfile_=0;
64 moyfc_=moytt_=0.;
65
66 jf1_=numfreq1_; jf2_=numfreq2_;
67 if ((jf1_<1)||(jf1_>=vismtx_.NCols())) jf1_=1;
68 if ((jf2_<1)||(jf2_>=vismtx_.NCols())||(jf2_<jf1_)) jf2_=vismtx_.NCols()-1;
69 if (nbinfreq_<1) nbinfreq_=1;
70 djf_=(jf2_-jf1_)/nbinfreq_;
71 if (djf_<1) djf_=0;
72 xnt_ = new double[vismtx_.NRows()+20];
73 for(int kk=0; kk<vismtx_.NRows(); kk++) xnt_[kk]=0.;
74
75 cout << " BRVisibilityCalculator/Info NMean= " << nmean_ << " JF1=" << jf1_
76 << " JF2=" << jf2_ << " DJF=" << djf_ << endl;
77
78 fgcktt_=false;
79}
80
81/* --Methode-- */
82BRVisibilityCalculator::~BRVisibilityCalculator()
83{
84 cout << " BRVisibilityCalculator - Visibility Datatable : " << endl;
85 cout << visdt_;
86 POutPersist po(outpath_+"visdt.ppf");
87 po << visdt_;
88 POutPersist poc(outpath_+"chanum.ppf");
89 poc << chanum_;
90
91 if (fgcktt_) {
92 cout << " BRVisibilityCalculator - Check TimeTag done: " << endl;
93 for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
94 cout << " BRTTCheck-Fiber[" << fib << "] NBadTT=" << vbadtt_[fib]
95 << " NotSameTT=" << vnsamett_[fib] << endl;
96 }
97 POutPersist pott(outpath_+"ttfcmtx.ppf");
98 pott << PPFNameTag("FC") << fcmtx_;
99 pott << PPFNameTag("TT") << ttmtx_;
100 }
101 delete[] xnt_;
102}
103
104/* --Methode-- */
105int BRVisibilityCalculator::ActivateTimeTagCheck(uint_8 maxnpaq)
106{
107 mindeltatt_=memgr_.PaqSize()/2;
108 if (mindeltatt_<1) mindeltatt_=1;
109 fcmtx_.SetSize(memgr_.NbFibres(), maxnpaq);
110 ttmtx_.SetSize(memgr_.NbFibres(), maxnpaq);
111 vlasttt_.resize(memgr_.NbFibres(), 0);
112 vbadtt_.resize(memgr_.NbFibres(), 0);
113 vnsamett_.resize(memgr_.NbFibres(), 0);
114 fgcktt_=true;
115 cout << " BRVisibilityCalculator::ActivateTimeTagCheck() - TT/Fc matrix NCols=" << maxnpaq
116 << " MinDeltaTT=" << mindeltatt_ << endl;
117
118 return 0;
119}
120
121/* --Methode-- */
122int BRVisibilityCalculator::Process()
123{
124
125 for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
126 vpdata_[2*fib] = vpaq_[fib].Data1C();
127 vpdata_[2*fib+1] = vpaq_[fib].Data2C();
128 }
129
130 if (totnbpaq_%nmean_ == 0) {
131 if (totnbpaq_ > 0) {
132 moyfc_/=nmean_;
133 moytt_/=nmean_;
134 vismtx_.Info()["MeanFC"] = moyfc_;
135 vismtx_.Info()["MeanTT"] = moytt_;
136 vismtx_.Info()["NPAQSUM"] = nmean_;
137
138 // ATTENTION : Matrice visibilites non moyennee
139 char nfile[32];
140 sprintf(nfile,"vismtx%d.ppf",numfile_);
141 string flnm=outpath_+nfile;
142 POutPersist po(flnm);
143 po << vismtx_;
144 cout << numfile_ << "-BRVisibilityCalculator::Process() NPaqProc="
145 << totnbpaq_ << " -> Visibility Matrix in " << flnm << endl;
146 FillVisibTable(moyfc_, moytt_);
147 numfile_++;
148 }
149 vismtx_ = complex<r_4>((r_4)0.,(r_4)0.);
150 moyfc_=moytt_=0.;
151 }
152
153 sa_size_t k=0;
154 for(size_t i=0; i<vpdata_.size(); i++) {
155 for(size_t j=i; j<vpdata_.size(); j++) {
156 TVector< complex<r_4> > vis = vismtx_.Row(k); k++;
157 for(sa_size_t f=1; f<vis.Size(); f++) {
158 vis(f) += complex<r_4>((r_4)vpdata_[i][f].realB(), (r_4)vpdata_[i][f].imagB()) *
159 complex<r_4>((r_4)vpdata_[j][f].realB(), -(r_4)vpdata_[j][f].imagB());
160 }
161 }
162 }
163
164 moyfc_ += curfc_[0];
165 moytt_ += (vpaq_[0].TimeTag()-ttfirst_[0]);
166 if (fgcktt_) CheckTimeTag();
167 totnbpaq_++;
168 return 0;
169}
170
171/* --Methode-- */
172int BRVisibilityCalculator::FillVisibTable(double fcm, double ttm)
173{
174 xnt_[0]=fcm; xnt_[1]=ttm/1.25e8;
175
176 if (djf_<2) {
177 for(sa_size_t rv=0; rv<vismtx_.NRows(); rv++) {
178 for(sa_size_t jf=jf1_; jf<jf2_; jf++) {
179 xnt_[2]=jf;
180 xnt_[3]=chanum_(rv);
181 xnt_[4]=vismtx_(rv,jf).real()/(r_4)(nmean_);
182 xnt_[5]=vismtx_(rv,jf).imag()/(r_4)(nmean_);
183 visdt_.AddRow(xnt_);
184 }
185 }
186 }
187 else {
188 for(sa_size_t rv=0; rv<vismtx_.NRows(); rv++) {
189 for(sa_size_t jf=jf1_; jf<jf2_; jf+=djf_) {
190 r_4 moyreal=0.;
191 r_4 moyimag=0.;
192 sa_size_t jjfmx=jf+djf_;
193 if (jjfmx > vismtx_.NCols()) jjfmx=vismtx_.NCols();
194 for(sa_size_t jjf=jf; jjf<jjfmx; jjf++) {
195 moyreal+=vismtx_(rv,jjf).real();
196 moyimag+=vismtx_(rv,jjf).imag();
197 }
198 xnt_[2]=jf+djf_/2;
199 xnt_[3]=chanum_(rv);
200 xnt_[4]=moyreal/(r_4)(nmean_*djf_);
201 xnt_[5]=moyimag/(r_4)(nmean_*djf_);
202 visdt_.AddRow(xnt_);
203 }
204 }
205 }
206 return 0;
207}
208
209/* --Methode-- */
210int BRVisibilityCalculator::CheckTimeTag()
211{
212 if (totnbpaq_==0) {
213 for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
214 vlasttt_[fib]=ttfirst_[fib];
215 if (ttmtx_.NCols()>0) {
216 fcmtx_(fib,totnbpaq_) = curfc_[fib];
217 ttmtx_(fib,totnbpaq_) = vlasttt_[fib];
218 }
219 }
220 return 0;
221 }
222 for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
223 uint_8 ld = vpaq_[fib].TimeTag()-vlasttt_[fib];
224 uint_8 fd = vpaq_[fib].TimeTag()-ttfirst_[fib]-vpaq_[0].TimeTag()+ttfirst_[0];
225 /* if ( (ld < mindeltatt_) || (fd<-5) || (fd>5)) { vbadtt_[fib]++; vnsamett_[fib]++; }
226 else {
227 if (fd!=0) vnsamett_[fib]++;
228 }
229 */
230 if (ld < mindeltatt_) vbadtt_[fib]++;
231 if (fd != 0) vnsamett_[fib]++;
232 vlasttt_[fib]=vpaq_[fib].TimeTag();
233 if (totnbpaq_<ttmtx_.NCols()) {
234 fcmtx_(fib,totnbpaq_) = curfc_[fib];
235 ttmtx_(fib,totnbpaq_) = vlasttt_[fib];
236 }
237 }
238 return 0;
239}
240
241//---------------------------------------------------------------
242// Classe thread de traitement donnees ADC avec 2 voies par frame
243//---------------------------------------------------------------
244
245// Mutex pour eviter le plantage du a FFTW qui ne semble pas thread-safe
246static ZMutex* pmutfftw=NULL;
247
248/* --Methode-- */
249BRProcA2C::BRProcA2C(RAcqMemZoneMgr& mem, string& path, bool fgraw, uint_4 nmean,
250 uint_4 nmax, bool fghist, uint_4 nfsmap, bool fgnotrl, int card)
251 : memgr(mem)
252{
253 fgraw_ = fgraw;
254 nmax_ = nmax;
255 nmean_ = nmean;
256 if (fgraw_) cout << " BRProcA2C::BRProcA2C() - constructeur RAW data - NMean=" << nmean_ << endl;
257 else cout << " BRProcA2C::BRProcA2C() - constructeur FFT data - NMean=" << nmean_ << endl;
258 nfsmap_ = nfsmap;
259 stop_ = false;
260 path_ = path;
261 fgnotrl_ = fgnotrl;
262 fghist_ = fghist;
263 card_ = card;
264 if (pmutfftw==NULL) pmutfftw=new ZMutex;
265}
266
267/* --Methode-- */
268void BRProcA2C::Stop()
269{
270 stop_=true;
271 // cout <<" BRProcA2C::Stop ... > STOP " << endl;
272}
273
274
275static inline r_4 Zmod2(complex<r_4> z)
276{ return (z.real()*z.real()+z.imag()*z.imag()); }
277
278static inline string card2name_(int card)
279{
280 if (card==2) return " (Chan3,4) ";
281 else return " (Chan1,2) ";
282}
283/* --Methode-- */
284void BRProcA2C::run()
285{
286 setRC(1);
287 try {
288 Timer tm("BRProcA2C", false);
289 TimeStamp ts;
290 BRPaqChecker pcheck(!fgnotrl_); // Verification/comptage des paquets
291
292 size_t totnbytesout = 0;
293 size_t totnbytesproc = 0;
294
295 cout << " BRProcA2C::run() - Starting " << ts << " NMaxMemZones=" << nmax_
296 << " NMean=" << nmean_ << card2name_(card_) << endl;
297 cout << " BRProcA2C::run()... - Output Data Path: " << path_ << endl;
298 char fname[512];
299// sprintf(fname,"%s/proc.log",path_.c_str());
300// ofstream filog(fname);
301// filog << " BRProcA2C::run() - starting log file " << ts << endl;
302// filog << " ... NMaxMemZones=" << nmax_ << " NMean=" << nmean_ << " Step=" << step_ << endl;
303
304/*----DELETE NTuple
305 const char* nnames[8] = {"fcs","tts","s1","s2","s12","s12re","s12im","s12phi"};
306 NTuple nt(8, nnames);
307 double xnt[10];
308 uint_4 nmnt = 0;
309 double ms1,ms2,ms12,ms12re,ms12im,ms12phi;
310----*/
311// Time sample (raw data) /FFT coeff histograms
312 Histo* ph1=NULL;
313 Histo* ph2=NULL;
314 if (fghist_) {
315 if (fgraw_) {
316 ph1 = new Histo(-0.5, 255.5, 256);
317 ph2 = new Histo(-0.5, 255.5, 256);
318 }
319 else {
320 ph1 = new Histo(-128.5, 128.5, 257);
321 ph2 = new Histo(-128.5, 128.5, 257);
322 }
323 }
324
325// Initialisation pour calcul FFT
326 TVector< complex<r_4> > cfour1; // composant TF
327 uint_4 paqsz = memgr.PaqSize();
328 uint_4 procpaqsz = memgr.ProcPaqSize();
329
330
331 BRPaquet pq(NULL, NULL, paqsz);
332 TVector<r_4> vx(pq.DataSize()/2);
333 int szfour = pq.DataSize()/2/2+1;
334 cfour1.SetSize(szfour);
335/*
336 vx = (r_4)(0.);
337 FFTPackServer ffts;
338 ffts.FFTForward(vx, cfour1);
339 szfour = cfour1.Size();
340*/
341
342 bool fgtimfreq = false; // true->cartes temps<>frequences
343 if (nfsmap_>0) fgtimfreq=true;
344
345 TVector< complex<r_4> > cfour2(cfour1.Size());
346
347 TVector<r_4> spectreV1(cfour1.Size());
348 TVector<r_4> spectreV2(cfour1.Size());
349 TVector<r_4> moyspecV1(cfour1.Size()); // Moyenne des Spectres
350 TVector<r_4> moyspecV2(cfour1.Size());
351 TVector<r_4> sigspecV1(cfour1.Size()); // Sigma des Spectres
352 TVector<r_4> sigspecV2(cfour1.Size());
353 TVector< complex<r_4> > visiV12( cfour1.Size() );
354
355 TMatrix<r_4> timfreqV1, timfreqV2; // Cartes temps<>frequences
356 if (fgtimfreq) {
357 timfreqV1.SetSize(nmean_, spectreV1.Size()/nfsmap_);
358 timfreqV2.SetSize(nmean_, spectreV2.Size()/nfsmap_);
359 }
360 cout << " *DBG*BRProcA2C PaqSz=" << paqsz << " ProcPaqSize=" << procpaqsz
361 << " procpaqsz/2=" << procpaqsz/2 << " cfour1.Size()=" << cfour1.Size()
362 << " *8=" << cfour1.Size()*8 << endl;
363
364 pmutfftw->lock();
365 fftwf_plan plan1 = fftwf_plan_dft_r2c_1d(vx.Size(), vx.Data(),
366 (fftwf_complex*)cfour1.Data(), FFTW_ESTIMATE);
367 fftwf_plan plan2 = fftwf_plan_dft_r2c_1d(vx.Size(), vx.Data(),
368 (fftwf_complex*)cfour2.Data(), FFTW_ESTIMATE);
369 pmutfftw->unlock();
370
371 uint_4 ifile = 0;
372 uint_4 nzm = 0; // Nb de paquets moyennes pour le calcul de chaque spectre
373 uint_4 nmoyspec = 0; // Nb de spectres moyennes
374
375 uint_4 curfc=0;
376 uint_8 curtt=0;
377 uint_8 firsttt=0;
378 bool fgfirst=true;
379 double moysig[2]={0.,0.};
380 double sigsig[2]={0.,0.};
381 uint_8 nbsig[2]={0,0};
382
383 for (uint_4 kmz=0; kmz<nmax_; kmz++) {
384 if (stop_) break;
385 int mid = memgr.FindMemZoneId(MemZA_ProcA);
386 Byte* buff = memgr.GetMemZone(mid);
387 if (buff == NULL) {
388 cout << " BRProcA2C::run()/ERROR memgr.GetMemZone(" << mid << ") -> NULL" << endl;
389 break;
390 }
391 Byte* procbuff = memgr.GetProcMemZone(mid);
392 if (procbuff == NULL) {
393 cout << " BRProcA2C::run()/ERROR memgr.GetProcMemZone(" << mid << ") -> NULL" << endl;
394 break;
395 }
396//---- DELETE nmnt=0; ms1=ms2=ms12=ms12re=ms12im=ms12phi=0.;
397 for(uint_4 i=0; i<memgr.NbPaquets(); i++) {
398 BRPaquet paq(NULL, buff+i*paqsz, paqsz);
399 if (!pcheck.Check(paq)) continue; // on ne traite que les paquets OK
400 if (fgfirst) { firsttt=paq.TimeTag(); fgfirst=false; }
401 curfc=paq.FrameCounter();
402 curtt=paq.TimeTag()-firsttt;
403// Traitement voie 1
404 if (fghist_) {
405 for(sa_size_t j=0; j<vx.Size(); j++) {
406 r_4 vts=(fgraw_)?((r_4)(*(paq.Data1()+j))):((r_4)(*(paq.Data1S()+j)));
407 ph1->Add((r_8)vts);
408 moysig[0] += (double)vts;
409 sigsig[0] += ((double)vts)*((double)vts);
410 nbsig[0]++;
411 }
412 for(sa_size_t j=0; j<vx.Size(); j++) {
413 r_4 vts=(fgraw_)?((r_4)(*(paq.Data2()+j))):((r_4)(*(paq.Data2S()+j)));
414 ph2->Add((r_8)vts);
415 moysig[1] += (double)vts;
416 sigsig[1] += ((double)vts)*((double)vts);
417 nbsig[1]++;
418 }
419 }
420 if (fgraw_) {
421 for(sa_size_t j=0; j<vx.Size(); j++)
422 vx(j) = (r_4)(*(paq.Data1()+j))-127.5;
423 // fftwf_complex* coeff1 = (fftwf_complex*)(procbuff+i*procpaqsz);
424 fftwf_execute(plan1);
425 // Traitement voie 2
426 for(sa_size_t j=0; j<vx.Size(); j++)
427 vx(j) = (r_4)(*(paq.Data2()+j))-127.5;
428 fftwf_execute(plan2);
429 }
430 else {
431 for(sa_size_t j=1; j<cfour1.Size()-1; j++) {
432 cfour1(j) = complex<r_4>((r_4)paq.Data1C()[j].realB(), (r_4)paq.Data1C()[j].imagB());
433 cfour2(j) = complex<r_4>((r_4)paq.Data2C()[j].realB(), (r_4)paq.Data2C()[j].imagB());
434 }
435 cfour1(0) = complex<r_4>((r_4)paq.Data1C()[0].realB(), (r_4)0.);
436 cfour1(cfour1.Size()-1) = complex<r_4>((r_4)paq.Data1C()[0].imagB(), (r_4)0.);
437 cfour2(0) = complex<r_4>((r_4)paq.Data2C()[0].realB(), (r_4)0.);
438 cfour2(cfour2.Size()-1) = complex<r_4>((r_4)paq.Data2C()[0].imagB(), (r_4)0.);
439 }
440 for(sa_size_t j=0; j<spectreV1.Size(); j++)
441 spectreV1(j) += Zmod2(cfour1(j));
442 memcpy(procbuff+i*procpaqsz, cfour1.Data(), sizeof(complex<r_4>)*cfour1.Size());
443 if (fgtimfreq) { // Remplissage tableau temps-frequence
444 for(sa_size_t c=1; c<timfreqV1.NCols(); c++) {
445 for(sa_size_t j=c*nfsmap_; j<(c+1)*nfsmap_; j++)
446 timfreqV1(nzm, c) += Zmod2(cfour1(j));
447 }
448 }
449 for(sa_size_t j=0; j<spectreV2.Size(); j++)
450 spectreV2(j) += Zmod2(cfour2(j)); // Zmod2(zp2[j]);
451 memcpy(procbuff+i*procpaqsz+procpaqsz/2, cfour2.Data(), sizeof(complex<r_4>)*cfour2.Size());
452 if (fgtimfreq) { // Remplissage tableau temps-frequence
453 for(sa_size_t c=1; c<timfreqV2.NCols(); c++) {
454 for(sa_size_t j=c*nfsmap_; j<(c+1)*nfsmap_; j++)
455 timfreqV2(nzm,c) += Zmod2(cfour2(j));
456 }
457 }
458
459// Calcul correlation (visibilite V1 * V2)
460 for(sa_size_t j=0; j<visiV12.Size(); j++)
461 visiV12(j)+=cfour1(j)*conj(cfour2(j));
462// for(sa_size_t j=0; j<visiV12.Size(); j++) visiV12(j)+=zp1[j]*zp2[j];
463 if (nzm==0) {
464 spectreV1.Info()["StartFC"] = curfc;
465 spectreV2.Info()["StartFC"] = curfc;
466 visiV12.Info()["StartFC"] = curfc;
467 spectreV1.Info()["StartTT"] = curtt;
468 spectreV2.Info()["StartTT"] = curtt;
469 visiV12.Info()["StartTT"] = curtt;
470 }
471 nzm++;
472/*----DELETE
473 if (nmnt==0) { xnt[0]=paq.FrameCounter(); xnt[1]=paq.TimeTag(); }
474 for(sa_size_t j=2700; j<2800; j++) {
475 ms1 += Zmod2(cfour1(j)); ms2 += Zmod2(cfour2(j));
476 complex<r_4> zvis = cfour1(j)*conj(cfour2(j));
477 ms12 += Zmod2(zvis); ms12re += zvis.real(); ms12im += zvis.imag();
478 ms12phi+= atan2(zvis.imag(),zvis.real());
479 }
480 nmnt++;
481----*/
482 totnbytesproc += paq.DataSize();
483 totnbytesout += (2*sizeof(complex<r_4>)*cfour1.Size());
484
485 } // Fin de boucle sur les paquets d'une zone
486
487/*---- DELETE
488 if (nmnt>0) {
489 double fnorm = (double)nmnt*(2800-2700);
490 xnt[2] = ms1 /= fnorm;
491 xnt[3] = ms2 /= fnorm;
492 xnt[4] = ms12 /= fnorm;
493 xnt[5] = ms12re /= fnorm;
494 xnt[6] = ms12im /= fnorm;
495 xnt[7] = ms12phi /= fnorm;
496 nt.Fill(xnt);
497 }
498----*/
499 if ((nzm >= nmean_) || ((kmz==(nmax_-1))&&(nzm>1))) {
500 spectreV1 /= (r_4)(nzm);
501 spectreV2 /= (r_4)(nzm);
502
503 // pour le calcul des moyennes et sigmas de ces spectres
504 moyspecV1 += spectreV1;
505 moyspecV2 += spectreV2;
506 sigspecV1 += (spectreV1 && spectreV1);
507 sigspecV2 += (spectreV2 && spectreV2);
508 nmoyspec++;
509
510 visiV12 /= complex<r_4>((r_4)nzm, 0.);
511
512 spectreV1.Info()["NPaqMoy"] = nzm;
513 spectreV2.Info()["NPaqMoy"] = nzm;
514 visiV12.Info()["NPaqMoy"] = nzm;
515 spectreV1.Info()["EndFC"] = curfc;
516 spectreV2.Info()["EndFC"] = curfc;
517 visiV12.Info()["EndFC"] = curfc;
518 spectreV1.Info()["EndTT"] = curtt;
519 spectreV2.Info()["EndTT"] = curtt;
520 visiV12.Info()["EndTT"] = curtt;
521 {
522 sprintf(fname,"%s_%d.ppf",path_.c_str(),(int)ifile);
523 POutPersist po(fname);
524 string tag1="specV1";
525 string tag2="specV2";
526 string tag12="visiV12";
527 string tagh1="tshV1";
528 string tagh2="tshV2";
529 string tagtf1="timfreqV1";
530 string tagtf2="timfreqV2";
531 if (card_==2) {
532 tag1 = "specV3";
533 tag2 = "specV4";
534 tagh1 = "tshV1";
535 tagh2 = "tshV2";
536 tag12="visiV34";
537 tagtf1="timfreqV3";
538 tagtf2="timfreqV4";
539 }
540 po << PPFNameTag(tag1) << spectreV1;
541 po << PPFNameTag(tag2) << spectreV2;
542 po << PPFNameTag(tag12) << visiV12;
543 if (fghist_) {
544 po << PPFNameTag(tagh1) << (*ph1);
545 po << PPFNameTag(tagh2) << (*ph2);
546
547 double sspvmax[3] = {0.,0.,0.};
548 int_4 sspvmaxidx[3] = {-1,-1,-1};
549 for(int jji=1;jji<visiV12.Size()-1;jji++) {
550 r_4 zmv2 = Zmod2(visiV12(jji));
551 if (zmv2>sspvmax[2]) { sspvmax[2]=zmv2; sspvmaxidx[2]=jji; }
552 }
553 TVector<r_4>& sspv = spectreV1;
554 for(int ic=0; ic<2; ic++) {
555 if (ic==1) sspv = spectreV2;
556 for(int jji=1;jji<sspv.Size()-1;jji++)
557 if (sspv(jji)>sspvmax[ic]) { sspvmax[ic]=sspv(jji); sspvmaxidx[ic]=jji; }
558 if (nbsig[ic] < 1) { moysig[ic]=sigsig[ic]=-1.; }
559 else {
560 moysig[ic] /= (double)nbsig[ic];
561 sigsig[ic] /= (double)nbsig[ic];
562 sigsig[ic] -= (moysig[ic]*moysig[ic]);
563 sigsig[ic] = sqrt(sigsig[ic]);
564 cout << "===Voie " << ic << " Moy=" << moysig[ic] << " Sig=" << sigsig[ic]
565 << " MaxSpec Amp= " << sqrt(sspvmax[ic])/double(pq.DataSize()/2/2)
566 << " Pos=" << sspvmaxidx[ic] << " (NPts=" << nbsig[ic] << ")" << endl;
567 }
568 }
569 cout << "=== Voie1x2 MaxSpec Amp= " << sqrt(sqrt(sspvmax[2])/double(pq.DataSize()/2/2))
570 << " Pos=" << sspvmaxidx[2] << endl;
571 } // fin if (fghist_)
572
573 if (fgtimfreq) {
574 timfreqV1 /= (r_4)nzm;
575 timfreqV2 /= (r_4)nzm;
576 po << PPFNameTag(tagtf1) << timfreqV1;
577 po << PPFNameTag(tagtf2) << timfreqV2;
578 }
579 }
580 spectreV1 = (r_4)(0.);
581 spectreV2 = (r_4)(0.);
582 visiV12 = complex<r_4>(0., 0.);
583 if (fghist_) {
584 ph1->Zero();
585 ph2->Zero();
586 moysig[0]=moysig[1]=0.;
587 sigsig[0]=sigsig[1]=0.;
588 nbsig[0]=nbsig[1]=0;
589 }
590 if (fgtimfreq) {
591 timfreqV1 = (r_4)(0.);
592 timfreqV2 = (r_4)(0.);
593 }
594 nzm = 0; ifile++;
595// ts.SetNow();
596// filog << ts << " : proc file " << fname << endl;
597 cout << " BRProcA2C::run() created file " << fname << card2name_(card_) << endl;
598 }
599
600 memgr.FreeMemZone(mid, MemZS_ProcA);
601 } // Fin de boucle sur les zones a traiter
602 cout << " ------------ BRProcA2C::run() END " << card2name_(card_)
603 << " ------------ " << endl;
604/*---- DELETE
605 {
606 nt.Info()["FirstTT"]=firsttt;
607 cout << nt;
608 sprintf(fname,"%s_nt.ppf",path_.c_str());
609 POutPersist po(fname);
610 po << PPFNameTag("ntv12") << nt;
611 cout << " BRProcA2C::run() created NTuple file " << fname << card2name_(card_) << endl;
612 }
613---- */
614 if (nmoyspec>0) { // Calcul des moyennes et sigmas des spectres
615 r_4 fnms = nmoyspec;
616 moyspecV1 /= fnms;
617 moyspecV2 /= fnms;
618 sigspecV1 /= fnms;
619 sigspecV2 /= fnms;
620 sigspecV1 -= (moyspecV1 && moyspecV1);
621 sigspecV2 -= (moyspecV2 && moyspecV2);
622 sigspecV1 = Sqrt(sigspecV1);
623 sigspecV2 = Sqrt(sigspecV2);
624 TVector<r_4> rsbV1, rsbV2; // Rapport signal/bruit
625 moyspecV1.DivElt(sigspecV1, rsbV1, false, true);
626 moyspecV2.DivElt(sigspecV2, rsbV2, false, true);
627 sprintf(fname,"%s_ms.ppf",path_.c_str());
628 POutPersist po(fname);
629 po << PPFNameTag("moyspecV1") << moyspecV1;
630 po << PPFNameTag("moyspecV2") << moyspecV2;
631 po << PPFNameTag("sigspecV1") << sigspecV1;
632 po << PPFNameTag("sigspecV2") << sigspecV2;
633 po << PPFNameTag("rsbV1") << rsbV1;
634 po << PPFNameTag("rsbV2") << rsbV2;
635 cout << " BRProcA2C::run() created moysigspec file " << fname << card2name_(card_) << endl;
636 }
637
638 if (fghist_) {
639 delete ph1;
640 delete ph2;
641 }
642 ts.SetNow();
643 tm.SplitQ();
644 cout << " TotalProc= " << totnbytesproc/(1024*1024) << " MBytes, rate= "
645 << (double)(totnbytesproc)/1024./tm.PartialElapsedTimems() << " MB/s"
646 << " ProcDataOut=" << totnbytesout/(1024*1024) << " MB" << endl;
647 cout << pcheck;
648 cout << " BRProcA2C::run()/Timing: " << card2name_(card_) << endl;
649 tm.Print();
650 cout << " ---------------------------------------------------------- " << endl;
651
652 }
653 catch (PException& exc) {
654 cout << " BRProcA2C::run()/catched PException " << exc.Msg() << endl;
655 setRC(3);
656 return;
657 }
658 catch(...) {
659 cout << " BRProcA2C::run()/catched unknown ... exception " << endl;
660 setRC(4);
661 return;
662 }
663 setRC(0);
664 return;
665}
666
667//---------------------------------------------------------------------
668// Classe thread de traitement 2 x 2 voies/frames (Apres BRProcA2C)
669//---------------------------------------------------------------------
670
671/* --Methode-- */
672BRProcB4C::BRProcB4C(RAcqMemZoneMgr& mem1, RAcqMemZoneMgr& mem2, string& path,
673 bool fgraw, uint_4 nmean, uint_4 nmax, bool fgnotrl)
674 : memgr1(mem1), memgr2(mem2)
675{
676 fgraw_ = fgraw;
677 nmax_ = nmax;
678 nmean_ = nmean;
679 if (fgraw_) cout << " BRProcB4C::BRProcB4C() - constructeur RAW data - NMean= " << nmean_ << endl;
680 else cout << " BRProcB4C::BRProcB4C() - constructeur FFT data - NMean= " << nmean_ << endl;
681 stop_ = false;
682 path_ = path;
683 fgnotrl_ = fgnotrl;
684}
685
686/* --Methode-- */
687void BRProcB4C::Stop()
688{
689 stop_=true;
690 // cout <<" BRProcB4C::Stop ... > STOP " << endl;
691}
692
693
694/* --Methode-- */
695void BRProcB4C::run()
696{
697 setRC(1);
698 try {
699 Timer tm("BRProcB4C", false);
700 TimeStamp ts;
701 BRPaqChecker pcheck1(!fgnotrl_); // Verification/comptage des paquets
702 BRPaqChecker pcheck2(!fgnotrl_); // Verification/comptage des paquets
703
704 size_t totnbytesout = 0;
705 size_t totnbytesproc = 0;
706
707 cout << " BRProcB4C::run() - Starting " << ts << " NMaxMemZones=" << nmax_
708 << " NMean=" << nmean_ << endl;
709 cout << " BRProcB4C::run()... - Output Data Path: " << path_ << endl;
710
711 uint_4 paqsz = memgr1.PaqSize();
712 uint_4 procpaqsz = memgr1.ProcPaqSize();
713 if ((paqsz != memgr2.PaqSize())||(procpaqsz!= memgr2.ProcPaqSize())) {
714 cout << "BRProcB4C::run()/ERROR : different paquet size -> stop \n ...(PaqSz1="
715 << paqsz << " Sz2=" << memgr2.PaqSize() << " ProcPaqSz1="
716 << procpaqsz << " Sz2=" << memgr2.ProcPaqSize() << " )" << endl;
717 setRC(9);
718 return;
719 }
720
721 TVector< complex<r_4> > cfour; // composant TF
722 BRPaquet pq(NULL, NULL, paqsz);
723/*
724 TVector<r_4> vx(pq.DataSize()/2);
725 vx = (r_4)(0.);
726 FFTPackServer ffts;
727 ffts.FFTForward(vx, cfour);
728
729 TVector< complex<r_4> > visiV13( cfour.Size() );
730 TVector< complex<r_4> > visiV14( cfour.Size() );
731 TVector< complex<r_4> > visiV23( cfour.Size() );
732 TVector< complex<r_4> > visiV24( cfour.Size() );
733*/
734 int szfour = pq.DataSize()/2/2+1;
735// int szfour = (paqsz-40)/2+1;
736 TVector< complex<r_4> > visiV13( szfour );
737 TVector< complex<r_4> > visiV14( szfour );
738 TVector< complex<r_4> > visiV23( szfour );
739 TVector< complex<r_4> > visiV24( szfour );
740 // cout << " *DBG*AAAAA ---- Vectors OK" << endl;
741 cout << " *DBG*BRProcB4C PaqSz=" << paqsz << " ProcPaqSize=" << procpaqsz
742 << " procpaqsz/2=" << procpaqsz/2 << " cfour.Size()=" << szfour
743 << " *8=" << szfour*8 << endl;
744
745 DataTable dt;
746 dt.AddLongColumn("fc1");
747 dt.AddLongColumn("tt1");
748 dt.AddLongColumn("fc2");
749 dt.AddLongColumn("tt2");
750 DataTableRow dtr = dt.EmptyRow();
751
752 uint_4 nzm = 0;
753 uint_4 totnoksfc = 0;
754 uint_4 totnokpaq = 0;
755 uint_4 totnpaq = 0;
756 uint_4 ifile = 0;
757
758 uint_4 curfc=0;
759 uint_8 curtt=0;
760 uint_4 curfc2=0;
761 uint_8 curtt2=0;
762 uint_8 firsttt=0;
763 uint_8 firsttt2=0;
764 bool fgfirst=true;
765 for (uint_4 kmz=0; kmz<nmax_; kmz++) {
766 uint_4 noksfc = 0;
767 uint_4 nokpaq = 0;
768 if (stop_) break;
769 // cout << " *DBG*BBBBB" << kmz << endl;
770
771 int mid1 = memgr1.FindMemZoneId(MemZA_ProcB);
772 Byte* buff1 = memgr1.GetMemZone(mid1);
773 if (buff1 == NULL) {
774 cout << " BRProcB4C::run()/ERROR memgr.GetMemZone(" << mid1 << ") -> NULL" << endl;
775 break;
776 }
777 Byte* procbuff1 = memgr1.GetProcMemZone(mid1);
778 if (procbuff1 == NULL) {
779 cout << " BRProcB4C::run()/ERROR memgr.GetProcMemZone(" << mid1 << ") -> NULL" << endl;
780 break;
781 }
782 int mid2 = memgr2.FindMemZoneId(MemZA_ProcB);
783 Byte* buff2 = memgr2.GetMemZone(mid2);
784 if (buff1 == NULL) {
785 cout << " BRProcB4C::run()/ERROR memgr.GetMemZone(" << mid2 << ") -> NULL" << endl;
786 break;
787 }
788 Byte* procbuff2 = memgr2.GetProcMemZone(mid2);
789 if (procbuff2 == NULL) {
790 cout << " BRProcB4C::run()/ERROR memgr.GetProcMemZone(" << mid2 << ") -> NULL" << endl;
791 break;
792 }
793 uint_4 i1,i2;
794 i1=i2=0;
795// cout << " *DBG*CCCCCC " << kmz << " memgr1.NbPaquets() =" << memgr1.NbPaquets() << endl;
796 while((i1<memgr1.NbPaquets())&&(i2<memgr2.NbPaquets())) {
797 BRPaquet paq1(NULL, buff1+i1*paqsz, paqsz);
798 BRPaquet paq2(NULL, buff2+i2*paqsz, paqsz);
799 totnpaq++;
800// cout << " DBG["<<kmz<<"] i1,i2=" << i1 <<","<<i2<<" FC1,FC2=" <<paq1.FrameCounter()
801//<<","<<paq2.FrameCounter()<<endl;
802 // on ne traite que les paquets OK
803 if (!pcheck1.Check(paq1)) { i1++; continue; }
804 if (!pcheck2.Check(paq2)) { i2++; continue; }
805 nokpaq++;
806 if (paq1.FrameCounter()<paq2.FrameCounter()) { i1++; continue; }
807 if (paq2.FrameCounter()<paq1.FrameCounter()) { i2++; continue; }
808// cout << " DBG["<<kmz<<"]OKOK i1,i2=" << i1 <<","<<i2<<" FC1,FC2=" <<paq1.FrameCounter()
809// <<","<<paq2.FrameCounter()<<endl;
810
811 if ((i1>=memgr1.NbPaquets())||(i2>=memgr1.NbPaquets())) {
812 cout << " *BUG*BUG i1=" << i1 << " i2=" << i2 << endl;
813 break;
814 }
815 // Les deux framecounters sont identiques ...
816 noksfc++;
817 curfc=paq1.FrameCounter();
818 curfc2=paq2.FrameCounter();
819 if (fgfirst) {
820 firsttt=paq1.TimeTag(); firsttt2=paq2.TimeTag();
821 cout << " BRProcB4C()/Info First FC="<<curfc<<" , "<<curfc2<<" -> TT="
822 << firsttt<<" , "<<firsttt2 <<endl;
823 fgfirst=false;
824 }
825 curtt=paq1.TimeTag()-firsttt;
826 curtt2=paq2.TimeTag()-firsttt2;
827 dtr[0]=curfc; dtr[1]=curtt;
828 dtr[2]=curfc2; dtr[3]=curtt2;
829 dt.AddRow(dtr);
830
831 complex<r_4>* zp1 = (complex<r_4>*)(procbuff1+i1*procpaqsz);
832 complex<r_4>* zp2 = (complex<r_4>*)(procbuff1+i1*procpaqsz+procpaqsz/2);
833 complex<r_4>* zp3 = (complex<r_4>*)(procbuff2+i2*procpaqsz);
834 complex<r_4>* zp4 = (complex<r_4>*)(procbuff2+i2*procpaqsz+procpaqsz/2);
835 for(sa_size_t j=0; j<visiV13.Size(); j++) {
836 visiV13(j)+=zp1[j]*conj(zp3[j]);
837 visiV14(j)+=zp1[j]*conj(zp4[j]);
838 visiV23(j)+=zp2[j]*conj(zp3[j]);
839 visiV24(j)+=zp2[j]*conj(zp4[j]);
840 }
841 if (nzm==0) {
842 visiV13.Info()["StartFC"] = curfc;
843 visiV14.Info()["StartFC"] = curfc;
844 visiV23.Info()["StartFC"] = curfc;
845 visiV24.Info()["StartFC"] = curfc;
846 visiV13.Info()["StartTT"] = curtt;
847 visiV14.Info()["StartTT"] = curtt;
848 visiV23.Info()["StartTT"] = curtt;
849 visiV24.Info()["StartTT"] = curtt;
850 }
851 nzm++; i1++; i2++;
852 totnbytesproc += 2*paq1.DataSize();
853 } // Fin de boucle sur les paquets d'une zone
854 memgr1.FreeMemZone(mid1, MemZS_ProcB);
855 memgr2.FreeMemZone(mid2, MemZS_ProcB);
856
857 if ((nzm >= nmean_) || ((kmz==(nmax_-1))&&(nzm>1))) {
858 visiV13 /= complex<r_4>((r_4)nzm, 0.);
859 visiV14 /= complex<r_4>((r_4)nzm, 0.);
860 visiV23 /= complex<r_4>((r_4)nzm, 0.);
861 visiV24 /= complex<r_4>((r_4)nzm, 0.);
862 visiV13.Info()["NPaqMoy"] = nzm;
863 visiV14.Info()["NPaqMoy"] = nzm;
864 visiV23.Info()["NPaqMoy"] = nzm;
865 visiV24.Info()["NPaqMoy"] = nzm;
866 visiV13.Info()["EndFC"] = curfc;
867 visiV14.Info()["EndFC"] = curfc;
868 visiV23.Info()["EndFC"] = curfc;
869 visiV24.Info()["EndFC"] = curfc;
870 visiV13.Info()["EndTT"] = curtt;
871 visiV14.Info()["EndTT"] = curtt;
872 visiV23.Info()["EndTT"] = curtt;
873 visiV24.Info()["EndTT"] = curtt;
874 char fname[512];
875 {
876 sprintf(fname,"%s_%d.ppf",path_.c_str(),(int)ifile);
877 POutPersist po(fname);
878 po << PPFNameTag("visiV13") << visiV13;
879 po << PPFNameTag("visiV14") << visiV14;
880 po << PPFNameTag("visiV23") << visiV23;
881 po << PPFNameTag("visiV24") << visiV24;
882 }
883 visiV13 = complex<r_4>(0., 0.);
884 visiV14 = complex<r_4>(0., 0.);
885 visiV23 = complex<r_4>(0., 0.);
886 visiV24 = complex<r_4>(0., 0.);
887 nzm = 0; ifile++;
888// ts.SetNow();
889// filog << ts << " : proc file " << fname << endl;
890 cout << " BRProcB4C::run() created file " << fname << endl;
891 }
892 double okfrac = (nokpaq>1)?((double)noksfc/(double)nokpaq*100.):0.;
893 cout << "BRProcB4C ["<<kmz<<"] NOKPaq=" << nokpaq << " NSameFC=" << noksfc
894 << " (" << okfrac << " %)" << endl;
895 totnokpaq += nokpaq;
896 totnoksfc += noksfc;
897 } // Fin de boucle sur les zones a traiter
898 cout << " ------------------ BRProcB4C::run() END ----------------- " << endl;
899 {
900 dt.Info()["FirstTT1"]=firsttt;
901 dt.Info()["FirstTT2"]=firsttt2;
902 cout << dt;
903 char fname[512];
904 sprintf(fname,"%s_fctt.ppf",path_.c_str());
905 POutPersist po(fname);
906 po << PPFNameTag("ttfc") << dt;
907 cout << " BRProcB4C::run() created TimeTag/FrameCounter file " << fname << endl;
908 }
909 ts.SetNow();
910 tm.SplitQ();
911 cout << " TotalProc= " << totnbytesproc/(1024*1024) << " MBytes, rate= "
912 << (double)(totnbytesproc)/1024./tm.PartialElapsedTimems() << " MB/s" << endl;
913 double totokfrac = (totnokpaq>1)?((double)totnoksfc/(double)totnokpaq*100.):0.;
914 cout << " NOkPaq1,2=" << totnokpaq << " /TotNPaq=" << totnpaq << " TotNSameFC="
915 << totnoksfc << " (" << totokfrac << " %)" << endl;
916// cout << pcheck1;
917// cout << pcheck2;
918 cout << " BRProcB4C::run()/Timing: \n";
919 tm.Print();
920 cout << " ---------------------------------------------------------- " << endl;
921}
922 catch (PException& exc) {
923 cout << " BRProcB4C::run()/catched PException " << exc.Msg() << endl;
924 setRC(3);
925 return;
926 }
927 catch(...) {
928 cout << " BRProcB4C::run()/catched unknown ... exception " << endl;
929 setRC(4);
930 return;
931 }
932 setRC(0);
933 return;
934}
935
936
Note: See TracBrowser for help on using the repository browser.