323 |
} |
} |
324 |
for (UInt_t j = 0; j < nobefrun; j++){ |
for (UInt_t j = 0; j < nobefrun; j++){ |
325 |
// |
// |
326 |
NDtrclone->GetEntry(j); |
if ( NDtrclone->GetEntry(j) <= 0 ) throw -36; |
327 |
// |
// |
328 |
// copy ndclone to mydec |
// copy ndclone to mydec |
329 |
// |
// |
389 |
stringstream myquery; |
stringstream myquery; |
390 |
myquery.str(""); |
myquery.str(""); |
391 |
myquery << "SET time_zone='+0:00'"; |
myquery << "SET time_zone='+0:00'"; |
392 |
dbc->Query(myquery.str().c_str()); |
delete dbc->Query(myquery.str().c_str()); |
393 |
dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc); |
dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc); |
394 |
// |
// |
395 |
// 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. |
416 |
// |
// |
417 |
// Open Level0 file |
// Open Level0 file |
418 |
// |
// |
419 |
|
if ( l0File ) l0File->Close(); |
420 |
l0File = new TFile(fname.Data()); |
l0File = new TFile(fname.Data()); |
421 |
if ( !l0File ) { |
if ( !l0File ) { |
422 |
if ( debug ) printf(" ND - ERROR: problems opening Level0 file\n"); |
if ( debug ) printf(" ND - ERROR: problems opening Level0 file\n"); |
471 |
// |
// |
472 |
if ( dbc ){ |
if ( dbc ){ |
473 |
dbc->Close(); |
dbc->Close(); |
474 |
// delete dbc; |
delete dbc; |
475 |
|
dbc = 0; |
476 |
}; |
}; |
477 |
// |
// |
478 |
for ( re = runinfo->EV_FROM; re < (runinfo->EV_FROM+runinfo->NEVENTS); re++){ |
for ( re = runinfo->EV_FROM; re < (runinfo->EV_FROM+runinfo->NEVENTS); re++){ |
479 |
// |
// |
480 |
if ( procev%1000 == 0 && procev > 0 && verbose ) printf(" %iK \n",procev/1000); |
if ( procev%1000 == 0 && procev > 0 && verbose ) printf(" %iK \n",procev/1000); |
481 |
// |
// |
482 |
l0head->GetEntry(re); |
if ( l0head->GetEntry(re) <= 0 ) throw -36; |
483 |
// |
// |
484 |
// absolute time of this event |
// absolute time of this event |
485 |
// |
// |
499 |
// |
// |
500 |
nd->Clear(); |
nd->Clear(); |
501 |
// |
// |
502 |
l0ND->GetEntry(re); |
if ( l0ND->GetEntry(re) <= 0 ) throw -36; |
503 |
tmpSize = l0ne->Records->GetEntries(); |
tmpSize = l0ne->Records->GetEntries(); |
504 |
if ( tmpSize && l0ne->unpackError == 0 ){ |
if ( tmpSize && l0ne->unpackError == 0 ){ |
505 |
for (Int_t j = 0; j < tmpSize; j++){ |
for (Int_t j = 0; j < tmpSize; j++){ |
549 |
// |
// |
550 |
// Get entry from old tree |
// Get entry from old tree |
551 |
// |
// |
552 |
NDtrclone->GetEntry(j); |
if ( NDtrclone->GetEntry(j) <= 0 ) throw -36; |
553 |
// |
// |
554 |
// copy ndclone to nd |
// copy ndclone to nd |
555 |
// |
// |
570 |
if ( tempfile ) tempfile->Close(); |
if ( tempfile ) tempfile->Close(); |
571 |
if ( myfold ) gSystem->Unlink(tempname.str().c_str()); |
if ( myfold ) gSystem->Unlink(tempname.str().c_str()); |
572 |
// |
// |
|
if ( runinfo ) runinfo->Close(); |
|
573 |
if ( NDtr ) NDtr->SetName("NeutronD"); |
if ( NDtr ) NDtr->SetName("NeutronD"); |
574 |
if ( file ){ |
if ( file ){ |
575 |
file->cd(); |
file->cd(); |
576 |
file->Write(); |
NDtr->Write("NeutronD", TObject::kOverwrite); |
577 |
}; |
}; |
578 |
// |
// |
579 |
if ( myfold ) gSystem->Unlink(NDfolder.str().c_str()); |
if ( myfold ) gSystem->Unlink(NDfolder.str().c_str()); |
581 |
// the end |
// the end |
582 |
// |
// |
583 |
if ( verbose ) printf("\n Exiting...\n"); |
if ( verbose ) printf("\n Exiting...\n"); |
584 |
if ( NDtr ) NDtr->Delete(); |
// if ( NDtr ) NDtr->Delete(); |
585 |
// |
// |
586 |
if ( nd ) delete nd; |
// if ( nd ) delete nd; |
587 |
if ( ndclone ) delete ndclone; |
//if ( ndclone ) delete ndclone; |
588 |
if ( glroot ) delete glroot; |
if ( glroot ) delete glroot; |
589 |
|
if ( runinfo ) runinfo->Close(); |
590 |
if ( runinfo ) delete runinfo; |
if ( runinfo ) delete runinfo; |
591 |
// |
// |
592 |
if(code < 0) throw code; |
if(code < 0) throw code; |