| 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 |
// |
// |
| 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 |
dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc); |
dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc); |
| 492 |
// |
// |
| 493 |
// 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. |
| 510 |
printf(" %i events to be processed for run %u: from %u to %u \n\n",totevent,idRun,runinfo->EV_FROM,(runinfo->EV_FROM+totevent)); |
printf(" %i events to be processed for run %u: from %u to %u \n\n",totevent,idRun,runinfo->EV_FROM,(runinfo->EV_FROM+totevent)); |
| 511 |
} |
} |
| 512 |
// |
// |
| 513 |
|
// if ( !totevent ) goto closeandexit; |
| 514 |
|
// |
| 515 |
// Open Level0 file |
// Open Level0 file |
| 516 |
// |
// |
| 517 |
|
if ( l0File ) l0File->Close(); |
| 518 |
l0File = new TFile(fname.Data()); |
l0File = new TFile(fname.Data()); |
| 519 |
if ( !l0File ) { |
if ( !l0File ) { |
| 520 |
if ( debug ) printf(" S4 - ERROR: problems opening Level0 file\n"); |
if ( debug ) printf(" S4 - ERROR: problems opening Level0 file\n"); |
| 549 |
// |
// |
| 550 |
nevents = l0S4->GetEntries(); |
nevents = l0S4->GetEntries(); |
| 551 |
// |
// |
| 552 |
if ( nevents < 1 ) { |
if ( nevents < 1 && totevent ) { |
| 553 |
if ( debug ) printf(" S4 - ERROR: Level0 file is empty\n\n"); |
if ( debug ) printf(" S4 - ERROR: Level0 file is empty\n\n"); |
| 554 |
l0File->Close(); |
l0File->Close(); |
| 555 |
code = -11; |
code = -11; |
| 556 |
goto closeandexit; |
goto closeandexit; |
| 557 |
}; |
}; |
| 558 |
// |
// |
| 559 |
if ( runinfo->EV_TO > nevents-1 ) { |
if ( runinfo->EV_TO > nevents-1 && totevent ) { |
| 560 |
if ( debug ) printf(" S4 - ERROR: too few entries in the S4 tree\n"); |
if ( debug ) printf(" S4 - ERROR: too few entries in the S4 tree\n"); |
| 561 |
l0File->Close(); |
l0File->Close(); |
| 562 |
code = -12; |
code = -12; |
| 582 |
// |
// |
| 583 |
if ( dbc ){ |
if ( dbc ){ |
| 584 |
dbc->Close(); |
dbc->Close(); |
| 585 |
// delete dbc; |
delete dbc; |
| 586 |
|
dbc = 0; |
| 587 |
}; |
}; |
| 588 |
// |
// |
| 589 |
for ( re = runinfo->EV_FROM; re < (runinfo->EV_FROM+runinfo->NEVENTS); re++){ |
for ( re = runinfo->EV_FROM; re < (runinfo->EV_FROM+runinfo->NEVENTS); re++){ |
| 590 |
// |
// |
| 591 |
if ( procev%1000 == 0 && procev > 0 && verbose ) printf(" %iK \n",procev/1000); |
if ( procev%1000 == 0 && procev > 0 && verbose ) printf(" %iK \n",procev/1000); |
| 592 |
// |
// |
| 593 |
l0head->GetEntry(re); |
if ( l0head->GetEntry(re) <= 0 ) throw -36; |
| 594 |
// |
// |
| 595 |
// absolute time of this event |
// absolute time of this event |
| 596 |
// |
// |
| 599 |
// |
// |
| 600 |
// paranoid check |
// paranoid check |
| 601 |
// |
// |
| 602 |
if ( (atime > runinfo->RUNTRAILER_TIME) || (atime < runinfo->RUNHEADER_TIME) ) { |
if ( (atime > (runinfo->RUNTRAILER_TIME+1)) || (atime < (runinfo->RUNHEADER_TIME-1)) ) { |
| 603 |
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"); |
| 604 |
goto jumpev; |
goto jumpev; |
| 605 |
}; |
}; |
| 609 |
// start processing |
// start processing |
| 610 |
// |
// |
| 611 |
s4->Clear(); |
s4->Clear(); |
| 612 |
l0S4->GetEntry(re); |
if ( l0S4->GetEntry(re) <= 0 ) throw -36; |
| 613 |
if (l0s4e->unpackError == 0){ |
if (l0s4e->unpackError == 0){ |
| 614 |
s4->S4adc = l0s4e->S4_DATA; |
s4->S4adc = l0s4e->S4_DATA; |
| 615 |
// |
// |
| 654 |
// |
// |
| 655 |
// Get entry from old tree |
// Get entry from old tree |
| 656 |
// |
// |
| 657 |
S4trclone->GetEntry(j); |
if ( S4trclone->GetEntry(j) <= 0 ) throw -36; |
| 658 |
// |
// |
| 659 |
// copy s4clone to s4 |
// copy s4clone to s4 |
| 660 |
// |
// |
| 661 |
// s4 = new S4Level2(); |
// s4 = new S4Level2(); |
| 662 |
s4->Clear(); |
// s4->Clear(); |
| 663 |
memcpy(&s4,&s4clone,sizeof(s4clone)); |
memcpy(&s4,&s4clone,sizeof(s4clone)); |
| 664 |
// |
// |
| 665 |
// Fill entry in the new tree |
// Fill entry in the new tree |
| 676 |
if ( tempfile ) tempfile->Close(); |
if ( tempfile ) tempfile->Close(); |
| 677 |
if ( myfold) gSystem->Unlink(tempname.str().c_str()); |
if ( myfold) gSystem->Unlink(tempname.str().c_str()); |
| 678 |
// |
// |
| 679 |
if ( runinfo ) runinfo->Close(); |
//runinfo->Write(); |
| 680 |
if ( S4tr ) S4tr->SetName("S4"); |
if ( S4tr ) S4tr->SetName("S4"); |
| 681 |
if ( file ){ |
if ( file ){ |
| 682 |
file->cd(); |
file->cd(); |
| 683 |
file->Write(); |
if ( S4tr ) S4tr->Write("S4", TObject::kOverwrite); // 10RED bug fixed |
| 684 |
|
//file->Write(); |
| 685 |
}; |
}; |
| 686 |
// |
// |
| 687 |
if ( myfold ) gSystem->Unlink(S4folder.str().c_str()); |
if ( myfold ) gSystem->Unlink(S4folder.str().c_str()); |
| 689 |
// the end |
// the end |
| 690 |
// |
// |
| 691 |
if (verbose) printf("\n Exiting...\n"); |
if (verbose) printf("\n Exiting...\n"); |
|
if ( S4tr ) S4tr->Delete(); |
|
| 692 |
// |
// |
|
if ( s4 ) delete s4; |
|
|
if ( s4clone ) delete s4clone; |
|
| 693 |
if ( glroot ) delete glroot; |
if ( glroot ) delete glroot; |
| 694 |
if ( runinfo ) delete runinfo; |
if ( runinfo ) runinfo->Close(); |
| 695 |
|
if ( runinfo ) delete runinfo; |
| 696 |
// |
// |
| 697 |
if(code < 0) throw code; |
if(code < 0) throw code; |
| 698 |
return(code); |
return(code); |