105 |
tr->SetBranchAddress("CalibS4", &S4CalibEvent); |
tr->SetBranchAddress("CalibS4", &S4CalibEvent); |
106 |
if ( tr->GetEntries() < glS4calib->EV_ROOT ) return(NULL); |
if ( tr->GetEntries() < glS4calib->EV_ROOT ) return(NULL); |
107 |
// |
// |
108 |
tr->GetEntry(glS4calib->EV_ROOT); |
if ( tr->GetEntry(glS4calib->EV_ROOT) <= 0 ) throw -36; |
109 |
// |
// |
110 |
// Variables initialization |
// Variables initialization |
111 |
// |
// |
275 |
S4folder << tempname.str().c_str(); |
S4folder << tempname.str().c_str(); |
276 |
tempname << "/S4tree_run"; |
tempname << "/S4tree_run"; |
277 |
tempname << run << ".root"; |
tempname << run << ".root"; |
278 |
|
UInt_t totnorun = 0; |
279 |
// |
// |
280 |
// DB classes |
// DB classes |
281 |
// |
// |
332 |
// |
// |
333 |
// number of run to be processed |
// number of run to be processed |
334 |
// |
// |
335 |
numbofrun = runinfo->GetNoRun(); |
numbofrun = runinfo->GetNoRun(); |
336 |
UInt_t totnorun = runinfo->GetRunEntries(); |
totnorun = runinfo->GetRunEntries(); |
337 |
// |
// |
338 |
// Try to access the S4 tree in the file, if it exists we are reprocessing data if not we are processing a new run |
// Try to access the S4 tree in the file, if it exists we are reprocessing data if not we are processing a new run |
339 |
// |
// |
421 |
} |
} |
422 |
for (UInt_t j = 0; j < nobefrun; j++){ |
for (UInt_t j = 0; j < nobefrun; j++){ |
423 |
// |
// |
424 |
S4trclone->GetEntry(j); |
if ( S4trclone->GetEntry(j) <= 0 ) throw -36; |
425 |
// |
// |
426 |
// copy s4clone to mydec |
// copy s4clone to mydec |
427 |
// |
// |
428 |
s4->Clear(); |
// s4->Clear(); |
429 |
// |
// |
430 |
memcpy(&s4,&s4clone,sizeof(s4clone)); |
memcpy(&s4,&s4clone,sizeof(s4clone)); |
431 |
// |
// |
486 |
if ( !dbc->IsConnected() ) throw -504; |
if ( !dbc->IsConnected() ) throw -504; |
487 |
stringstream myquery; |
stringstream myquery; |
488 |
myquery.str(""); |
myquery.str(""); |
489 |
myquery << "SET time_zone='+0:00'"; |
myquery << "SET time_zone='+0:00';"; |
490 |
dbc->Query(myquery.str().c_str()); |
delete dbc->Query(myquery.str().c_str()); |
491 |
|
delete dbc->Query("SET sql_mode = 'NO_UNSIGNED_SUBTRACTION';"); |
492 |
dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc); |
dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc); |
493 |
// |
// |
494 |
// Search in the DB the path and name of the LEVEL0 file to be processed. |
// Search in the DB the path and name of the LEVEL0 file to be processed. |
515 |
// |
// |
516 |
// Open Level0 file |
// Open Level0 file |
517 |
// |
// |
518 |
|
if ( l0File ) l0File->Close(); |
519 |
l0File = new TFile(fname.Data()); |
l0File = new TFile(fname.Data()); |
520 |
if ( !l0File ) { |
if ( !l0File ) { |
521 |
if ( debug ) printf(" S4 - ERROR: problems opening Level0 file\n"); |
if ( debug ) printf(" S4 - ERROR: problems opening Level0 file\n"); |
583 |
// |
// |
584 |
if ( dbc ){ |
if ( dbc ){ |
585 |
dbc->Close(); |
dbc->Close(); |
586 |
// delete dbc; |
delete dbc; |
587 |
|
dbc = 0; |
588 |
}; |
}; |
589 |
// |
// |
590 |
for ( re = runinfo->EV_FROM; re < (runinfo->EV_FROM+runinfo->NEVENTS); re++){ |
for ( re = runinfo->EV_FROM; re < (runinfo->EV_FROM+runinfo->NEVENTS); re++){ |
591 |
// |
// |
592 |
if ( procev%1000 == 0 && procev > 0 && verbose ) printf(" %iK \n",procev/1000); |
if ( procev%1000 == 0 && procev > 0 && verbose ) printf(" %iK \n",procev/1000); |
593 |
// |
// |
594 |
l0head->GetEntry(re); |
if ( l0head->GetEntry(re) <= 0 ) throw -36; |
595 |
// |
// |
596 |
// absolute time of this event |
// absolute time of this event |
597 |
// |
// |
600 |
// |
// |
601 |
// paranoid check |
// paranoid check |
602 |
// |
// |
603 |
if ( (atime > runinfo->RUNTRAILER_TIME) || (atime < runinfo->RUNHEADER_TIME) ) { |
if ( (atime > (runinfo->RUNTRAILER_TIME+1)) || (atime < (runinfo->RUNHEADER_TIME-1)) ) { |
604 |
if (verbose) printf(" S4 - WARNING: event at time outside the run time window, skipping it\n"); |
if (verbose) printf(" S4 - WARNING: event at time outside the run time window, skipping it\n"); |
605 |
goto jumpev; |
goto jumpev; |
606 |
}; |
}; |
610 |
// start processing |
// start processing |
611 |
// |
// |
612 |
s4->Clear(); |
s4->Clear(); |
613 |
l0S4->GetEntry(re); |
if ( l0S4->GetEntry(re) <= 0 ) throw -36; |
614 |
if (l0s4e->unpackError == 0){ |
if (l0s4e->unpackError == 0){ |
615 |
s4->S4adc = l0s4e->S4_DATA; |
s4->S4adc = l0s4e->S4_DATA; |
616 |
// |
// |
655 |
// |
// |
656 |
// Get entry from old tree |
// Get entry from old tree |
657 |
// |
// |
658 |
S4trclone->GetEntry(j); |
if ( S4trclone->GetEntry(j) <= 0 ) throw -36; |
659 |
// |
// |
660 |
// copy s4clone to s4 |
// copy s4clone to s4 |
661 |
// |
// |
662 |
// s4 = new S4Level2(); |
// s4 = new S4Level2(); |
663 |
s4->Clear(); |
// s4->Clear(); |
664 |
memcpy(&s4,&s4clone,sizeof(s4clone)); |
memcpy(&s4,&s4clone,sizeof(s4clone)); |
665 |
// |
// |
666 |
// Fill entry in the new tree |
// Fill entry in the new tree |
677 |
if ( tempfile ) tempfile->Close(); |
if ( tempfile ) tempfile->Close(); |
678 |
if ( myfold) gSystem->Unlink(tempname.str().c_str()); |
if ( myfold) gSystem->Unlink(tempname.str().c_str()); |
679 |
// |
// |
680 |
if ( runinfo ) runinfo->Close(); |
//runinfo->Write(); |
681 |
if ( S4tr ) S4tr->SetName("S4"); |
if ( S4tr ) S4tr->SetName("S4"); |
682 |
if ( file ){ |
if ( file ){ |
683 |
file->cd(); |
file->cd(); |
684 |
file->Write(); |
if ( S4tr ) S4tr->Write("S4", TObject::kOverwrite); // 10RED bug fixed |
685 |
|
//file->Write(); |
686 |
}; |
}; |
687 |
// |
// |
688 |
if ( myfold ) gSystem->Unlink(S4folder.str().c_str()); |
if ( myfold ) gSystem->Unlink(S4folder.str().c_str()); |
690 |
// the end |
// the end |
691 |
// |
// |
692 |
if (verbose) printf("\n Exiting...\n"); |
if (verbose) printf("\n Exiting...\n"); |
|
if ( S4tr ) S4tr->Delete(); |
|
693 |
// |
// |
|
if ( s4 ) delete s4; |
|
|
if ( s4clone ) delete s4clone; |
|
694 |
if ( glroot ) delete glroot; |
if ( glroot ) delete glroot; |
695 |
if ( runinfo ) delete runinfo; |
if ( runinfo ) runinfo->Close(); |
696 |
|
if ( runinfo ) delete runinfo; |
697 |
// |
// |
698 |
if(code < 0) throw code; |
if(code < 0) throw code; |
699 |
return(code); |
return(code); |