| 26 |
#include <stdlib.h> |
#include <stdlib.h> |
| 27 |
#include <math.h> |
#include <math.h> |
| 28 |
// |
// |
| 29 |
|
// RunInfo header |
| 30 |
|
// |
| 31 |
|
#include <RunInfo.h> |
| 32 |
|
#include <GLTables.h> |
| 33 |
|
// |
| 34 |
// YODA headers |
// YODA headers |
| 35 |
// |
// |
| 36 |
#include <PamelaRun.h> |
#include <PamelaRun.h> |
| 39 |
#include <EventHeader.h> |
#include <EventHeader.h> |
| 40 |
#include <physics/neutronDetector/NeutronEvent.h> |
#include <physics/neutronDetector/NeutronEvent.h> |
| 41 |
#include <physics/neutronDetector/NeutronRecord.h> |
#include <physics/neutronDetector/NeutronRecord.h> |
|
//#include <yodaUtility.h> |
|
| 42 |
// |
// |
| 43 |
// RunInfo header |
// RunInfo header |
| 44 |
// |
// |
| 45 |
#include <RunInfo.h> |
//#include <RunInfo.h> |
| 46 |
#include <GLTables.h> |
//#include <GLTables.h> |
| 47 |
// |
// |
| 48 |
// This program headers |
// This program headers |
| 49 |
// |
// |
| 58 |
// |
// |
| 59 |
// |
// |
| 60 |
int NDCore(UInt_t run, TFile *file, TSQLServer *dbc, Int_t NDargc, char *NDargv[]){ |
int NDCore(UInt_t run, TFile *file, TSQLServer *dbc, Int_t NDargc, char *NDargv[]){ |
|
// |
|
|
Int_t i = 0; |
|
|
// |
|
|
TString processFolder = "NDFolder"; |
|
| 61 |
// |
// |
| 62 |
// Set these to true to have a very verbose output. |
// Set these to true to have a verbose output. |
| 63 |
// |
// |
| 64 |
Bool_t debug = false; |
Bool_t debug = false; |
|
// |
|
| 65 |
Bool_t verbose = false; |
Bool_t verbose = false; |
| 66 |
// |
// |
| 67 |
|
// Output directory is the working directoy. |
| 68 |
|
// |
| 69 |
|
const char* outDir = gSystem->DirName(gSystem->DirName(file->GetPath())); |
| 70 |
|
// |
| 71 |
|
Int_t i = 0; |
| 72 |
|
TString processFolder = Form("NDFolder_%u",run); |
| 73 |
if ( NDargc > 0 ){ |
if ( NDargc > 0 ){ |
| 74 |
i = 0; |
i = 0; |
| 75 |
while ( i < NDargc ){ |
while ( i < NDargc ){ |
| 84 |
verbose = true; |
verbose = true; |
| 85 |
}; |
}; |
| 86 |
if ( (!strcmp(NDargv[i],"--debug")) || (!strcmp(NDargv[i],"-g")) ) { |
if ( (!strcmp(NDargv[i],"--debug")) || (!strcmp(NDargv[i],"-g")) ) { |
| 87 |
|
debug = true; |
| 88 |
verbose= true; |
verbose= true; |
| 89 |
}; |
}; |
| 90 |
i++; |
i++; |
| 91 |
}; |
}; |
| 92 |
}; |
}; |
| 93 |
// |
// |
| 94 |
const char* outDir = gSystem->DirName(gSystem->DirName(file->GetPath())); |
|
| 95 |
// Variables for level2 |
// Variables for level2 |
| 96 |
// |
// |
| 97 |
TTree *NDtr = 0; |
TTree *NDtr = 0; |
| 98 |
UInt_t nevents = 0; |
UInt_t nevents = 0; |
| 99 |
// |
// |
| 100 |
// variables needed to reprocess data |
// Variables needed to reprocess data |
| 101 |
// |
// |
| 102 |
TString NDversion; |
TString NDversion; |
| 103 |
ItoRunInfo *runinfo = 0; |
ItoRunInfo *runinfo = 0; |
| 122 |
Int_t code = 0; |
Int_t code = 0; |
| 123 |
Int_t sgnl; |
Int_t sgnl; |
| 124 |
// |
// |
| 125 |
|
Long64_t maxsize = 10000000000LL; |
| 126 |
|
TTree::SetMaxTreeSize(maxsize); |
| 127 |
|
// |
| 128 |
|
// |
| 129 |
// ND level2 classes |
// ND level2 classes |
| 130 |
// |
// |
| 131 |
NDLevel2 *nd = new NDLevel2(); |
NDLevel2 *nd = new NDLevel2(); |
| 231 |
// |
// |
| 232 |
numbofrun = runinfo->GetNoRun(); |
numbofrun = runinfo->GetNoRun(); |
| 233 |
// |
// |
| 234 |
|
// |
| 235 |
|
// |
| 236 |
|
UInt_t totnorun = runinfo->GetRunEntries(); |
| 237 |
|
// |
| 238 |
// 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 |
| 239 |
// |
// |
| 240 |
NDtrclone = (TTree*)file->Get("NeutronD"); |
NDtrclone = (TTree*)file->Get("NeutronD"); |
| 252 |
} |
} |
| 253 |
} else { |
} else { |
| 254 |
// |
// |
| 255 |
|
NDtrclone->SetAutoSave(900000000000000LL); |
| 256 |
|
// |
| 257 |
// tree exists, we are reprocessing data. Are we reprocessing a single run or all the file? |
// tree exists, we are reprocessing data. Are we reprocessing a single run or all the file? |
| 258 |
// |
// |
| 259 |
reproc = true; |
reproc = true; |
| 262 |
// |
// |
| 263 |
if (verbose) printf("\n Preparing the pre-processing...\n"); |
if (verbose) printf("\n Preparing the pre-processing...\n"); |
| 264 |
// |
// |
| 265 |
if ( run == 0 ){ |
if ( run == 0 || totnorun == 1 ){ |
| 266 |
// |
// |
| 267 |
// we are reprocessing all the file |
// we are reprocessing all the file |
| 268 |
// if we are reprocessing everything we don't need to copy any old event and we can just work with the new tree and delete the old one immediately |
// if we are reprocessing everything we don't need to copy any old event and we can just work with the new tree and delete the old one immediately |
| 300 |
// |
// |
| 301 |
file->cd(); |
file->cd(); |
| 302 |
NDtr = new TTree("NeutronD-new","PAMELA Level2 NeutronD data"); |
NDtr = new TTree("NeutronD-new","PAMELA Level2 NeutronD data"); |
| 303 |
|
NDtr->SetAutoSave(900000000000000LL); |
| 304 |
NDtr->Branch("NDLevel2","NDLevel2",&nd); |
NDtr->Branch("NDLevel2","NDLevel2",&nd); |
| 305 |
// |
// |
| 306 |
if ( reproc && !reprocall ){ |
if ( reproc && !reprocall ){ |
| 309 |
// |
// |
| 310 |
tempfile = new TFile(tempname.str().c_str(),"READ"); |
tempfile = new TFile(tempname.str().c_str(),"READ"); |
| 311 |
NDtrclone = (TTree*)tempfile->Get("NeutronD-old"); |
NDtrclone = (TTree*)tempfile->Get("NeutronD-old"); |
| 312 |
|
NDtrclone->SetAutoSave(900000000000000LL); |
| 313 |
NDtrclone->SetBranchAddress("NDLevel2",&ndclone); |
NDtrclone->SetBranchAddress("NDLevel2",&ndclone); |
| 314 |
// |
// |
| 315 |
if ( nobefrun > 0 ){ |
if ( nobefrun > 0 ){ |
| 378 |
// |
// |
| 379 |
// prepare the timesync for the db |
// prepare the timesync for the db |
| 380 |
// |
// |
| 381 |
|
if ( !dbc->IsConnected() ) throw -604; |
| 382 |
dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc); |
dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc); |
| 383 |
// |
// |
| 384 |
// 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. |
| 385 |
// |
// |
| 386 |
|
if ( !dbc->IsConnected() ) throw -604; |
| 387 |
glroot->Query_GL_ROOT(runinfo->ID_ROOT_L0,dbc); |
glroot->Query_GL_ROOT(runinfo->ID_ROOT_L0,dbc); |
| 388 |
// |
// |
| 389 |
ftmpname.str(""); |
ftmpname.str(""); |
| 481 |
// |
// |
| 482 |
l0ND->GetEntry(re); |
l0ND->GetEntry(re); |
| 483 |
tmpSize = l0ne->Records->GetEntries(); |
tmpSize = l0ne->Records->GetEntries(); |
| 484 |
if (!tmpSize) continue; |
if ( tmpSize && l0ne->unpackError == 0 ){ |
| 485 |
if (l0ne->unpackError == 1) continue; |
for (Int_t j = 0; j < tmpSize; j++){ |
| 486 |
for (Int_t j = 0; j < tmpSize; j++){ |
l0nr = (pamela::neutron::NeutronRecord*)l0ne->Records->At(j); |
| 487 |
l0nr = (pamela::neutron::NeutronRecord*)l0ne->Records->At(j); |
yTrig = yTrig + (float)l0nr->trigPhysics; |
| 488 |
yTrig = yTrig + (float)l0nr->trigPhysics; |
yUpperBackground = yUpperBackground + (float)l0nr->upperBack; |
| 489 |
yUpperBackground = yUpperBackground + (float)l0nr->upperBack; |
yBottomBackground = yBottomBackground + (float)l0nr->bottomBack; |
| 490 |
yBottomBackground = yBottomBackground + (float)l0nr->bottomBack; |
} |
| 491 |
} |
nd->upperBack = yUpperBackground; |
| 492 |
nd->upperBack = yUpperBackground; |
nd->bottomBack = yBottomBackground; |
| 493 |
nd->bottomBack = yBottomBackground; |
nd->trigPhysics = yTrig; |
| 494 |
nd->trigPhysics = yTrig; |
}; |
| 495 |
|
// |
| 496 |
|
nd->unpackError = l0ne->unpackError; |
| 497 |
|
// |
| 498 |
NDtr->Fill(); // Fill tree NDLevel2 in the root file |
NDtr->Fill(); // Fill tree NDLevel2 in the root file |
| 499 |
|
// |
| 500 |
yUpperBackground =0; |
yUpperBackground =0; |
| 501 |
yBottomBackground =0; |
yBottomBackground =0; |
| 502 |
yTrig=0; |
yTrig=0; |