2 |
#include <sstream> |
#include <sstream> |
3 |
// |
// |
4 |
#include <TObject.h> |
#include <TObject.h> |
5 |
|
#include <TChain.h> |
6 |
#include <TSystem.h> |
#include <TSystem.h> |
7 |
#include <TArrayL.h> |
#include <TSystemFile.h> |
8 |
|
#include <TArrayI.h> |
9 |
#include <TFile.h> |
#include <TFile.h> |
10 |
#include <TTree.h> |
#include <TTree.h> |
11 |
#include <TDirectory.h> |
#include <TDirectory.h> |
30 |
CAL_ver = ""; |
CAL_ver = ""; |
31 |
ND_ver = ""; |
ND_ver = ""; |
32 |
S4_ver = ""; |
S4_ver = ""; |
33 |
|
DV_ver = ""; |
34 |
} |
} |
35 |
|
|
36 |
|
void SoftInfo::Clear(){ |
37 |
|
TRIG_ver = ""; |
38 |
|
TOF_ver = ""; |
39 |
|
AC_ver = ""; |
40 |
|
TRK_ver = ""; |
41 |
|
ORB_ver = ""; |
42 |
|
CAL_ver = ""; |
43 |
|
ND_ver = ""; |
44 |
|
S4_ver = ""; |
45 |
|
DV_ver = ""; |
46 |
|
} |
47 |
|
|
48 |
|
UInt_t SoftInfo::GetSWinfo(TString Detector){ |
49 |
|
TString sver; |
50 |
|
UInt_t version = 0; |
51 |
|
if ( !strcmp(Detector.Data(),"TRIG") ){ |
52 |
|
sver = TRIG_ver; |
53 |
|
}; |
54 |
|
if ( !strcmp(Detector.Data(),"TOF") ){ |
55 |
|
sver = TOF_ver; |
56 |
|
}; |
57 |
|
if ( !strcmp(Detector.Data(),"AC") ){ |
58 |
|
sver = AC_ver; |
59 |
|
}; |
60 |
|
if ( !strcmp(Detector.Data(),"TRK") ){ |
61 |
|
sver = TRK_ver; |
62 |
|
}; |
63 |
|
if ( !strcmp(Detector.Data(),"CALO") ){ |
64 |
|
sver = CAL_ver; |
65 |
|
}; |
66 |
|
if ( !strcmp(Detector.Data(),"S4") ){ |
67 |
|
sver = S4_ver; |
68 |
|
}; |
69 |
|
if ( !strcmp(Detector.Data(),"DV") ){ |
70 |
|
sver = DV_ver; |
71 |
|
}; |
72 |
|
if ( !strcmp(Detector.Data(),"ND") ){ |
73 |
|
sver = ND_ver; |
74 |
|
}; |
75 |
|
if ( !strcmp(Detector.Data(),"ORB") ){ |
76 |
|
sver = ORB_ver; |
77 |
|
}; |
78 |
|
sver.ReplaceAll("v",1," ",1); |
79 |
|
sver.ReplaceAll("r",1," ",1); |
80 |
|
version = (UInt_t)sver.Atoi(); |
81 |
|
return(version); |
82 |
|
}; |
83 |
|
|
84 |
/** |
/** |
85 |
* Fills a struct cSoftInfo with values from a SoftInfo object (to put data into a F77 common). |
* Fills a struct cSoftInfo with values from a SoftInfo object (to put data into a F77 common). |
86 |
*/ |
*/ |
102 |
isreadonly = true; |
isreadonly = true; |
103 |
first_file_entry = 0; |
first_file_entry = 0; |
104 |
last_file_entry = 0; |
last_file_entry = 0; |
105 |
file_entries = 0ULL; |
file_entries = 0; |
106 |
totnorun = 0LL; |
totnorun = 0; |
107 |
|
this->GL_RUN::Clear(); |
108 |
version = new SoftInfo(); |
version = new SoftInfo(); |
|
version->TRIG_ver = ""; |
|
|
version->TOF_ver = ""; |
|
|
version->AC_ver = ""; |
|
|
version->TRK_ver = ""; |
|
|
version->CAL_ver = ""; |
|
|
version->ND_ver = ""; |
|
|
version->S4_ver = ""; |
|
|
version->ORB_ver = ""; |
|
109 |
norun = 0; |
norun = 0; |
110 |
// runlist = new TArrayL(0,NULL); |
runlist = new TArrayI(500); |
111 |
runlist = new TArrayL(500); |
file = NULL; |
|
// file = new TFile(); |
|
|
file = NULL;//new TFile(); |
|
112 |
newtree = new TTree(); |
newtree = new TTree(); |
113 |
} |
} |
114 |
|
|
117 |
file=(TFile*)processFl; |
file=(TFile*)processFl; |
118 |
dbc=NULL; |
dbc=NULL; |
119 |
processFolder = ""; |
processFolder = ""; |
120 |
idRun = 0ULL; |
idRun = 0; |
121 |
Detector = "NONE"; |
Detector = "NONE"; |
122 |
// |
// |
123 |
reprocessing = false; |
reprocessing = false; |
124 |
updating = false; |
updating = false; |
125 |
first_file_entry = 0; |
first_file_entry = 0; |
126 |
last_file_entry = 0; |
last_file_entry = 0; |
127 |
file_entries = 0ULL; |
file_entries = 0; |
128 |
version = new SoftInfo(); |
version = new SoftInfo(); |
129 |
version->TRIG_ver = ""; |
// glrun = new GL_RUN(); |
|
version->TOF_ver = ""; |
|
|
version->AC_ver = ""; |
|
|
version->TRK_ver = ""; |
|
|
version->ORB_ver = ""; |
|
|
version->CAL_ver = ""; |
|
|
version->ND_ver = ""; |
|
|
version->S4_ver = ""; |
|
130 |
norun = 0; |
norun = 0; |
131 |
totnorun = 0; |
totnorun = 0; |
132 |
runlist = new TArrayL(500); |
runlist = new TArrayI(500); |
133 |
// runlist = new TArrayL(0,NULL); |
// |
134 |
|
} |
135 |
|
|
136 |
|
|
137 |
|
|
138 |
|
TChain *ItoRunInfo::GetRunTree(TList *fl){ |
139 |
|
// |
140 |
|
TChain *Tout = new TChain("Run"); |
141 |
|
// loop over files and create chains |
142 |
|
TIter next(fl); |
143 |
|
TSystemFile *questo = 0; |
144 |
|
while ( (questo = (TSystemFile*) next()) ) { |
145 |
|
TString name = questo->GetName(); |
146 |
|
Tout->Add(name); |
147 |
|
}; |
148 |
|
// |
149 |
|
Tout->SetBranchAddress("RunInfo", GetPointerToRI()); |
150 |
|
printf("Run : set branch address RunInfo\n"); |
151 |
|
Tout->SetBranchAddress("SoftInfo", GetPointerToSI()); |
152 |
|
printf("Software : set branch address SoftInfo\n"); |
153 |
|
// |
154 |
|
return Tout; |
155 |
// |
// |
156 |
} |
} |
157 |
|
|
165 |
updating = false; |
updating = false; |
166 |
first_file_entry = 0; |
first_file_entry = 0; |
167 |
last_file_entry = 0; |
last_file_entry = 0; |
168 |
file_entries = 0ULL; |
file_entries = 0; |
169 |
version = new SoftInfo(); |
version = new SoftInfo(); |
|
version->TRIG_ver = ""; |
|
|
version->TOF_ver = ""; |
|
|
version->AC_ver = ""; |
|
|
version->TRK_ver = ""; |
|
|
version->ORB_ver = ""; |
|
|
version->CAL_ver = ""; |
|
|
version->ND_ver = ""; |
|
|
version->S4_ver = ""; |
|
170 |
norun = 0; |
norun = 0; |
171 |
totnorun = 0; |
totnorun = 0; |
172 |
// runlist = new TArrayL(0,NULL); |
runlist = new TArrayI(500); |
|
runlist = new TArrayL(500); |
|
173 |
// |
// |
174 |
} |
} |
175 |
|
|
176 |
Int_t ItoRunInfo::Update(ULong64_t run, TString Detector, TString Version){ |
void ItoRunInfo::CopyFromTo(GL_RUN *glrun,GL_RUN *newrun,SoftInfo *sinfo, SoftInfo *newver){ |
177 |
|
// |
178 |
|
if ( glrun && newrun ){ |
179 |
|
// |
180 |
|
// printf("copy \n"); |
181 |
|
// |
182 |
|
newrun->ID = glrun->ID ; |
183 |
|
newrun->ID_RUN_FRAG = glrun-> ID_RUN_FRAG ; |
184 |
|
newrun->ID_ROOT_L0 = glrun->ID_ROOT_L0 ; |
185 |
|
newrun->ID_ROOT_L2 = glrun->ID_ROOT_L2 ; |
186 |
|
newrun->RUNHEADER_TIME = glrun->RUNHEADER_TIME ; |
187 |
|
newrun->RUNTRAILER_TIME = glrun->RUNTRAILER_TIME ; |
188 |
|
newrun->EV_FROM = glrun->EV_FROM ; |
189 |
|
newrun->EV_TO = glrun->EV_TO ; |
190 |
|
newrun->TRK_CALIB_USED = glrun->TRK_CALIB_USED ; |
191 |
|
newrun->EFF_WRK_SCHEDULE = glrun->EFF_WRK_SCHEDULE ; |
192 |
|
newrun->PRH_VAR_TRG_MODE_A = glrun->PRH_VAR_TRG_MODE_A ; |
193 |
|
newrun->PRH_VAR_TRG_MODE_B = glrun->PRH_VAR_TRG_MODE_B ; |
194 |
|
newrun->ACQ_BUILD_INFO =glrun->ACQ_BUILD_INFO ; |
195 |
|
newrun->ACQ_VAR_INFO = glrun->ACQ_VAR_INFO ; |
196 |
|
newrun->RUNHEADER_OBT = glrun->RUNHEADER_OBT ; |
197 |
|
newrun->RUNTRAILER_OBT = glrun->RUNTRAILER_OBT ; |
198 |
|
newrun->RUNHEADER_PKT = glrun->RUNHEADER_PKT ; |
199 |
|
newrun->RUNTRAILER_PKT = glrun->RUNTRAILER_PKT ; |
200 |
|
newrun->NEVENTS = glrun->NEVENTS ; |
201 |
|
newrun->LAST_TIMESYNC = glrun->LAST_TIMESYNC ; |
202 |
|
newrun->OBT_TIMESYNC = glrun->OBT_TIMESYNC ; |
203 |
|
newrun->COMPILATIONTIMESTAMP = glrun->COMPILATIONTIMESTAMP ; |
204 |
|
newrun->FAV_WRK_SCHEDULE = glrun->FAV_WRK_SCHEDULE ; |
205 |
|
newrun->RM_ACQ_AFTER_CALIB = glrun->RM_ACQ_AFTER_CALIB ; |
206 |
|
newrun->RM_ACQ_SETTING_MODE = glrun->RM_ACQ_SETTING_MODE ; |
207 |
|
newrun->PKT_COUNTER = glrun->PKT_COUNTER ; |
208 |
|
newrun->PKT_READY_COUNTER = glrun->PKT_READY_COUNTER ; |
209 |
|
newrun->TRK_CALIB_USED = glrun->TRK_CALIB_USED ; |
210 |
|
newrun->CAL_DSP_MASK = glrun->CAL_DSP_MASK ; |
211 |
|
newrun->BOOT_NUMBER = glrun->BOOT_NUMBER ; |
212 |
|
newrun->VALIDATION = glrun->VALIDATION ; |
213 |
|
// |
214 |
|
}; |
215 |
|
// |
216 |
|
if ( newver && sinfo ){ |
217 |
|
// |
218 |
|
newver->TRIG_ver = sinfo->TRIG_ver; |
219 |
|
newver->TOF_ver = sinfo->TOF_ver; |
220 |
|
newver->AC_ver = sinfo->AC_ver; |
221 |
|
newver->TRK_ver = sinfo->TRK_ver; |
222 |
|
newver->ORB_ver = sinfo->ORB_ver; |
223 |
|
newver->CAL_ver = sinfo->CAL_ver; |
224 |
|
newver->S4_ver = sinfo->S4_ver; |
225 |
|
newver->DV_ver = sinfo->DV_ver; |
226 |
|
newver->ND_ver = sinfo->ND_ver; |
227 |
|
// |
228 |
|
}; |
229 |
|
} |
230 |
|
|
231 |
|
Int_t ItoRunInfo::Update(UInt_t run, TString Detector, TString Version){ |
232 |
// |
// |
233 |
isreadonly = false; |
isreadonly = false; |
234 |
idRun = run; |
idRun = run; |
247 |
SoftInfo *oldver = new SoftInfo(); |
SoftInfo *oldver = new SoftInfo(); |
248 |
SoftInfo *newver = new SoftInfo(); |
SoftInfo *newver = new SoftInfo(); |
249 |
// |
// |
250 |
ID = 0ULL; |
this->GL_RUN::Clear(); |
251 |
ID_REG_RUN = 0ULL; |
version->Clear(); |
|
ID_REG_RUN_L2 = 0ULL; |
|
|
RUNHEADER_TIME = 0ULL; |
|
|
RUNTRAILER_TIME = 0ULL; |
|
|
EV_REG_PHYS_FROM = 0; |
|
|
EV_REG_PHYS_TO = 0; |
|
|
EV_REG_RUNHEADER = 0; |
|
|
EV_REG_RUNTRAILER = 0; |
|
|
TRK_CALIB_USED = 0; |
|
|
EFF_WRK_SCHEDULE = 0; |
|
|
PRH_VAR_TRG_MODE_A = 0; |
|
|
PRH_VAR_TRG_MODE_B = 0; |
|
|
ACQ_BUILD_INFO = 0; |
|
|
ACQ_VAR_INFO = 0; |
|
|
version->TRIG_ver = ""; |
|
|
version->TOF_ver = ""; |
|
|
version->AC_ver = ""; |
|
|
version->TRK_ver = ""; |
|
|
version->ORB_ver = ""; |
|
|
version->CAL_ver = ""; |
|
|
version->ND_ver = ""; |
|
|
version->S4_ver = ""; |
|
252 |
// |
// |
253 |
norun = 0; |
norun = 0; |
|
// runlist = new TArrayL(0,NULL); |
|
|
//runlist->Reset(); |
|
254 |
// |
// |
255 |
Bool_t found = false; |
Bool_t found = false; |
256 |
Int_t error = 0; |
Int_t error = 0; |
257 |
// |
// |
|
// TFile *temprfile = 0; |
|
|
// TTree *temprrun = 0; |
|
|
// stringstream temprname; |
|
|
// stringstream tempdir; |
|
|
// const char* routdir = gSystem->DirName(gSystem->DirName(file->GetPath())); |
|
|
// |
|
258 |
TTree *oldtree = 0; |
TTree *oldtree = 0; |
259 |
// |
// |
|
// |
|
260 |
// Try to get the tree Run in the processed file |
// Try to get the tree Run in the processed file |
261 |
// |
// |
262 |
oldtree = (TTree*)file->Get("Run"); |
oldtree = (TTree*)file->Get("Run"); |
272 |
version->ORB_ver = Version; |
version->ORB_ver = Version; |
273 |
version->CAL_ver = Version; |
version->CAL_ver = Version; |
274 |
version->S4_ver = Version; |
version->S4_ver = Version; |
275 |
|
version->DV_ver = Version; |
276 |
version->ND_ver = Version; |
version->ND_ver = Version; |
277 |
} else { |
} else { |
278 |
if ( !strcmp(Detector.Data(),"TRIG") ) version->TRIG_ver = Version; |
if ( !strcmp(Detector.Data(),"TRIG") ) version->TRIG_ver = Version; |
281 |
if ( !strcmp(Detector.Data(),"TRK") ) version->TRK_ver = Version; |
if ( !strcmp(Detector.Data(),"TRK") ) version->TRK_ver = Version; |
282 |
if ( !strcmp(Detector.Data(),"CALO") ) version->CAL_ver = Version; |
if ( !strcmp(Detector.Data(),"CALO") ) version->CAL_ver = Version; |
283 |
if ( !strcmp(Detector.Data(),"S4") ) version->S4_ver = Version; |
if ( !strcmp(Detector.Data(),"S4") ) version->S4_ver = Version; |
284 |
|
if ( !strcmp(Detector.Data(),"DV") ) version->DV_ver = Version; |
285 |
if ( !strcmp(Detector.Data(),"ND") ) version->ND_ver = Version; |
if ( !strcmp(Detector.Data(),"ND") ) version->ND_ver = Version; |
286 |
if ( !strcmp(Detector.Data(),"ORB") ) version->ORB_ver = Version; |
if ( !strcmp(Detector.Data(),"ORB") ) version->ORB_ver = Version; |
287 |
if ( strcmp(Detector.Data(),"TRIG") && strcmp(Detector.Data(),"TOF") && strcmp(Detector.Data(),"AC") && strcmp(Detector.Data(),"TRK") && strcmp(Detector.Data(),"CALO") && strcmp(Detector.Data(),"S4") && strcmp(Detector.Data(),"ND") && strcmp(Detector.Data(),"ORB") ) return(-804); |
if ( strcmp(Detector.Data(),"TRIG") && strcmp(Detector.Data(),"TOF") && strcmp(Detector.Data(),"AC") && strcmp(Detector.Data(),"TRK") && strcmp(Detector.Data(),"CALO") && strcmp(Detector.Data(),"S4") && strcmp(Detector.Data(),"ND") && strcmp(Detector.Data(),"ORB") && strcmp(Detector.Data(),"DV") ) return(-804); |
288 |
}; |
}; |
289 |
// |
// |
290 |
if ( !oldtree ) { |
if ( !oldtree ) { |
295 |
// |
// |
296 |
} else { |
} else { |
297 |
// |
// |
|
// temprname.str(""); |
|
|
// temprname << routdir; |
|
|
// temprname << "/" << processFolder.Data(); |
|
|
// gSystem->MakeDirectory(temprname.str().c_str()); |
|
|
// tempdir.str(""); |
|
|
// tempdir << temprname.str().c_str(); |
|
|
// temprname << "/runinfo_run"; |
|
|
// temprname << idRun << ".root"; |
|
|
// if ( debug ) printf(" file temporaneo is %s \n",temprname.str().c_str()); |
|
|
// // |
|
|
// temprfile = new TFile(temprname.str().c_str(),"RECREATE"); |
|
|
// // |
|
|
// temprrun = new TTree(); |
|
|
// // |
|
|
// if ( !temprfile ) return(-805); |
|
|
// if ( !oldtree ) return(-806); |
|
|
// if ( !temprrun ) return(-807); |
|
|
// // |
|
|
// temprrun = oldtree->CloneTree(-1,"fast"); |
|
|
// // |
|
|
// temprfile->cd(); |
|
|
// temprrun->SetName("Run-old"); |
|
|
// temprfile->Write(); |
|
|
// if ( temprrun ) temprrun->Delete(); |
|
|
// temprfile->Close(); |
|
|
// // |
|
|
// oldtree->Delete("all"); |
|
|
// |
|
298 |
updating = true; |
updating = true; |
299 |
if ( debug ) printf(" RunInfo: updating versioning information \n"); |
if ( debug ) printf(" RunInfo: updating versioning information \n"); |
300 |
// |
// |
310 |
// |
// |
311 |
// |
// |
312 |
if ( !updating ){ |
if ( !updating ){ |
313 |
if ( idRun == 0ULL ){ |
if ( idRun == 0 ){ |
314 |
if ( debug ) printf("\n RUNINFO - ERROR: reprocessing data but no RunInfo tree in Level2 file. \n"); |
if ( debug ) printf("\n RUNINFO - ERROR: reprocessing data but no RunInfo tree in Level2 file. \n"); |
315 |
return(-805); |
return(-805); |
316 |
}; |
}; |
317 |
// |
// |
|
// runlist = new TArrayL(1); |
|
|
// |
|
318 |
error = Query_GL_RUN(idRun, dbc); |
error = Query_GL_RUN(idRun, dbc); |
319 |
// |
// |
320 |
if ( error ){ |
if ( error ){ |
321 |
if ( debug ) printf("\n RUNINFO - ERROR: Query_GL_RUN exited with non zero error\n"); |
if ( debug ) printf("\n RUNINFO - ERROR: Query_GL_RUN exited with non zero error\n"); |
322 |
return(error); |
return(error); |
323 |
}; |
}; |
324 |
if ( ID == 0ULL ){ |
if ( ID == 0 ){ |
325 |
if ( debug ) printf("\n RUNINFO - ERROR: no run with ID_RUN = %llu \n",idRun); |
if ( debug ) printf("\n RUNINFO - ERROR: no run with ID_RUN = %u \n",idRun); |
326 |
return(-5); |
return(-5); |
327 |
}; |
}; |
328 |
// |
// |
329 |
// |
// |
330 |
// |
CopyFromTo((GL_RUN*)this,newrun,version,newver); |
|
newrun->ID = ID; |
|
|
newrun->ID_REG_RUN = ID_REG_RUN; |
|
|
newrun->ID_REG_RUN_L2 = ID_REG_RUN_L2; |
|
|
newrun->RUNHEADER_TIME = RUNHEADER_TIME; |
|
|
newrun->RUNTRAILER_TIME = RUNTRAILER_TIME; |
|
|
newrun->EV_REG_PHYS_FROM = EV_REG_PHYS_FROM; |
|
|
newrun->EV_REG_PHYS_TO = EV_REG_PHYS_TO; |
|
|
newrun->EV_REG_RUNHEADER = EV_REG_RUNHEADER; |
|
|
newrun->EV_REG_RUNTRAILER = EV_REG_RUNTRAILER; |
|
|
newrun->TRK_CALIB_USED = TRK_CALIB_USED; |
|
|
newrun->EFF_WRK_SCHEDULE = EFF_WRK_SCHEDULE; |
|
|
newrun->PRH_VAR_TRG_MODE_A = PRH_VAR_TRG_MODE_A; |
|
|
newrun->PRH_VAR_TRG_MODE_B = PRH_VAR_TRG_MODE_B; |
|
|
newrun->ACQ_BUILD_INFO = ACQ_BUILD_INFO; |
|
|
newrun->ACQ_VAR_INFO = ACQ_VAR_INFO; |
|
|
newver->TRIG_ver = version->TRIG_ver; |
|
|
newver->TOF_ver = version->TOF_ver; |
|
|
newver->AC_ver = version->AC_ver; |
|
|
newver->TRK_ver = version->TRK_ver; |
|
|
newver->ORB_ver = version->ORB_ver; |
|
|
newver->CAL_ver = version->CAL_ver; |
|
|
newver->S4_ver = version->S4_ver; |
|
|
newver->ND_ver = version->ND_ver; |
|
331 |
// |
// |
332 |
// fill the tree; |
// fill the tree; |
333 |
// |
// |
336 |
totnorun = 1; |
totnorun = 1; |
337 |
reprocessing = false; |
reprocessing = false; |
338 |
first_file_entry = 0; |
first_file_entry = 0; |
339 |
last_file_entry = (UInt_t)(EV_REG_PHYS_TO - EV_REG_PHYS_FROM); |
if ( EV_TO >= EV_FROM ) last_file_entry = (UInt_t)(EV_TO - EV_FROM); |
340 |
norun = 1; |
norun = 1; |
341 |
runlist->AddAt((Long64_t)ID,0); |
runlist->AddAt((Int_t)ID,0); |
342 |
// |
// |
343 |
newtree->SetName("Run"); |
newtree->SetName("Run"); |
344 |
// |
// |
345 |
file->cd(); |
file->cd(); |
346 |
// file->Write("Run"); |
// |
|
//newtree->Delete(); |
|
347 |
delete newver; |
delete newver; |
348 |
delete newrun; |
delete newrun; |
349 |
delete oldver; |
delete oldver; |
353 |
// |
// |
354 |
} else { |
} else { |
355 |
// |
// |
|
// temprfile = new TFile(temprname.str().c_str(),"READ"); |
|
|
// oldtree = (TTree*)temprfile->Get("Run-old"); |
|
356 |
// |
// |
357 |
oldtree->SetBranchAddress("RunInfo",&oldrun); |
oldtree->SetBranchAddress("RunInfo",&oldrun); |
358 |
oldtree->SetBranchAddress("SoftInfo",&oldver); |
oldtree->SetBranchAddress("SoftInfo",&oldver); |
363 |
if ( debug ) printf("\n RUNINFO - ERROR: can not handle more than 500 runs!\n"); |
if ( debug ) printf("\n RUNINFO - ERROR: can not handle more than 500 runs!\n"); |
364 |
return(-806); |
return(-806); |
365 |
}; |
}; |
|
// runlist = new TArrayL((Int_t)totnorun); |
|
366 |
// |
// |
367 |
found = false; |
found = false; |
368 |
// |
// |
370 |
// |
// |
371 |
oldtree->GetEntry(run); |
oldtree->GetEntry(run); |
372 |
// |
// |
373 |
newrun->ID = oldrun->ID; |
CopyFromTo(oldrun,newrun,oldver,newver); |
|
newrun->ID_REG_RUN = oldrun->ID_REG_RUN; |
|
|
newrun->ID_REG_RUN_L2 = oldrun->ID_REG_RUN_L2; |
|
|
newrun->RUNHEADER_TIME = oldrun->RUNHEADER_TIME; |
|
|
newrun->RUNTRAILER_TIME = oldrun->RUNTRAILER_TIME; |
|
|
newrun->EV_REG_PHYS_FROM = oldrun->EV_REG_PHYS_FROM; |
|
|
newrun->EV_REG_PHYS_TO = oldrun->EV_REG_PHYS_TO; |
|
|
newrun->EV_REG_RUNHEADER = oldrun->EV_REG_RUNHEADER; |
|
|
newrun->EV_REG_RUNTRAILER = oldrun->EV_REG_RUNTRAILER; |
|
|
newrun->TRK_CALIB_USED = oldrun->TRK_CALIB_USED; |
|
|
newrun->EFF_WRK_SCHEDULE = oldrun->EFF_WRK_SCHEDULE; |
|
|
newrun->PRH_VAR_TRG_MODE_A = oldrun->PRH_VAR_TRG_MODE_A; |
|
|
newrun->PRH_VAR_TRG_MODE_B = oldrun->PRH_VAR_TRG_MODE_B; |
|
|
newrun->ACQ_BUILD_INFO = oldrun->ACQ_BUILD_INFO; |
|
|
newrun->ACQ_VAR_INFO = oldrun->ACQ_VAR_INFO; |
|
|
newver->TRIG_ver = oldver->TRIG_ver; |
|
|
newver->TOF_ver = oldver->TOF_ver; |
|
|
newver->AC_ver = oldver->AC_ver; |
|
|
newver->TRK_ver = oldver->TRK_ver; |
|
|
newver->ORB_ver = oldver->ORB_ver; |
|
|
newver->CAL_ver = oldver->CAL_ver; |
|
|
newver->S4_ver = oldver->S4_ver; |
|
|
newver->ND_ver = oldver->ND_ver; |
|
374 |
// |
// |
375 |
file_entries += (oldrun->EV_REG_PHYS_TO - oldrun->EV_REG_PHYS_FROM + 1); |
file_entries += (oldrun->EV_TO - oldrun->EV_FROM + 1); |
376 |
// |
// |
377 |
if ( debug ) printf("totnorun %i idRun %i newrun->ID %i \n",(int)totnorun,(int)idRun,(int)newrun->ID); |
if ( debug ) printf("totnorun %i idRun %i newrun->ID %i \n",(int)totnorun,(int)idRun,(int)newrun->ID); |
378 |
// |
// |
379 |
if ( idRun == 0ULL || idRun == newrun->ID ) { |
if ( idRun == 0 || idRun == newrun->ID ) { |
380 |
// |
// |
381 |
if ( debug ) printf(" Updating run number %llu \n",idRun); |
if ( debug ) printf(" Updating run number %u \n",idRun); |
382 |
// |
// |
383 |
found = true; |
found = true; |
384 |
// |
// |
396 |
return(error); |
return(error); |
397 |
}; |
}; |
398 |
// |
// |
399 |
newrun->ID = ID; |
CopyFromTo((GL_RUN*)this,newrun,NULL,NULL); |
400 |
newrun->ID_REG_RUN = ID_REG_RUN; |
// |
|
newrun->ID_REG_RUN_L2 = ID_REG_RUN_L2; |
|
|
newrun->RUNHEADER_TIME = RUNHEADER_TIME; |
|
|
newrun->RUNTRAILER_TIME = RUNTRAILER_TIME; |
|
|
newrun->EV_REG_PHYS_FROM = EV_REG_PHYS_FROM; |
|
|
newrun->EV_REG_PHYS_TO = EV_REG_PHYS_TO; |
|
|
newrun->EV_REG_RUNHEADER = EV_REG_RUNHEADER; |
|
|
newrun->EV_REG_RUNTRAILER = EV_REG_RUNTRAILER; |
|
|
newrun->TRK_CALIB_USED = TRK_CALIB_USED; |
|
|
newrun->EFF_WRK_SCHEDULE = EFF_WRK_SCHEDULE; |
|
|
newrun->PRH_VAR_TRG_MODE_A = PRH_VAR_TRG_MODE_A; |
|
|
newrun->PRH_VAR_TRG_MODE_B = PRH_VAR_TRG_MODE_B; |
|
|
newrun->ACQ_BUILD_INFO = ACQ_BUILD_INFO; |
|
|
newrun->ACQ_VAR_INFO = ACQ_VAR_INFO; |
|
401 |
} else { |
} else { |
402 |
// |
// |
403 |
if ( !strcmp(Detector.Data(),"TRIG") ){ |
if ( !strcmp(Detector.Data(),"TRIG") ){ |
408 |
newver->ORB_ver = oldver->ORB_ver; |
newver->ORB_ver = oldver->ORB_ver; |
409 |
newver->CAL_ver = oldver->CAL_ver; |
newver->CAL_ver = oldver->CAL_ver; |
410 |
newver->S4_ver = oldver->S4_ver; |
newver->S4_ver = oldver->S4_ver; |
411 |
|
newver->DV_ver = oldver->DV_ver; |
412 |
newver->ND_ver = oldver->ND_ver; |
newver->ND_ver = oldver->ND_ver; |
413 |
if ( strcmp(oldver->TRIG_ver.Data(),"") ) reprocessing = true; |
if ( strcmp(oldver->TRIG_ver.Data(),"") ) reprocessing = true; |
414 |
}; |
}; |
419 |
newver->TRK_ver = oldver->TRK_ver; |
newver->TRK_ver = oldver->TRK_ver; |
420 |
newver->ORB_ver = oldver->ORB_ver; |
newver->ORB_ver = oldver->ORB_ver; |
421 |
newver->CAL_ver = oldver->CAL_ver; |
newver->CAL_ver = oldver->CAL_ver; |
422 |
|
newver->DV_ver = oldver->DV_ver; |
423 |
newver->S4_ver = oldver->S4_ver; |
newver->S4_ver = oldver->S4_ver; |
424 |
newver->ND_ver = oldver->ND_ver; |
newver->ND_ver = oldver->ND_ver; |
425 |
if ( strcmp(oldver->TOF_ver.Data(),"") ) reprocessing = true; |
if ( strcmp(oldver->TOF_ver.Data(),"") ) reprocessing = true; |
430 |
newver->TRK_ver = oldver->TRK_ver; |
newver->TRK_ver = oldver->TRK_ver; |
431 |
newver->ORB_ver = oldver->ORB_ver; |
newver->ORB_ver = oldver->ORB_ver; |
432 |
newver->CAL_ver = oldver->CAL_ver; |
newver->CAL_ver = oldver->CAL_ver; |
433 |
|
newver->DV_ver = oldver->DV_ver; |
434 |
newver->S4_ver = oldver->S4_ver; |
newver->S4_ver = oldver->S4_ver; |
435 |
newver->ND_ver = oldver->ND_ver; |
newver->ND_ver = oldver->ND_ver; |
436 |
newver->AC_ver = version->AC_ver; |
newver->AC_ver = version->AC_ver; |
441 |
newver->TOF_ver = oldver->TOF_ver; |
newver->TOF_ver = oldver->TOF_ver; |
442 |
newver->CAL_ver = oldver->CAL_ver; |
newver->CAL_ver = oldver->CAL_ver; |
443 |
newver->ORB_ver = oldver->ORB_ver; |
newver->ORB_ver = oldver->ORB_ver; |
444 |
|
newver->DV_ver = oldver->DV_ver; |
445 |
newver->S4_ver = oldver->S4_ver; |
newver->S4_ver = oldver->S4_ver; |
446 |
newver->ND_ver = oldver->ND_ver; |
newver->ND_ver = oldver->ND_ver; |
447 |
newver->AC_ver = oldver->AC_ver; |
newver->AC_ver = oldver->AC_ver; |
453 |
newver->TOF_ver = oldver->TOF_ver; |
newver->TOF_ver = oldver->TOF_ver; |
454 |
newver->CAL_ver = oldver->CAL_ver; |
newver->CAL_ver = oldver->CAL_ver; |
455 |
newver->TRK_ver = oldver->TRK_ver; |
newver->TRK_ver = oldver->TRK_ver; |
456 |
|
newver->DV_ver = oldver->DV_ver; |
457 |
newver->S4_ver = oldver->S4_ver; |
newver->S4_ver = oldver->S4_ver; |
458 |
newver->ND_ver = oldver->ND_ver; |
newver->ND_ver = oldver->ND_ver; |
459 |
newver->AC_ver = oldver->AC_ver; |
newver->AC_ver = oldver->AC_ver; |
463 |
if ( !strcmp(Detector.Data(),"CALO") ){ |
if ( !strcmp(Detector.Data(),"CALO") ){ |
464 |
newver->TRIG_ver = oldver->TRIG_ver; |
newver->TRIG_ver = oldver->TRIG_ver; |
465 |
newver->TOF_ver = oldver->TOF_ver; |
newver->TOF_ver = oldver->TOF_ver; |
466 |
|
newver->DV_ver = oldver->DV_ver; |
467 |
newver->S4_ver = oldver->S4_ver; |
newver->S4_ver = oldver->S4_ver; |
468 |
newver->ORB_ver = oldver->ORB_ver; |
newver->ORB_ver = oldver->ORB_ver; |
469 |
newver->ND_ver = oldver->ND_ver; |
newver->ND_ver = oldver->ND_ver; |
480 |
newver->TRK_ver = oldver->TRK_ver; |
newver->TRK_ver = oldver->TRK_ver; |
481 |
newver->ORB_ver = oldver->ORB_ver; |
newver->ORB_ver = oldver->ORB_ver; |
482 |
newver->CAL_ver = oldver->CAL_ver; |
newver->CAL_ver = oldver->CAL_ver; |
483 |
|
newver->DV_ver = oldver->DV_ver; |
484 |
newver->S4_ver = version->S4_ver; |
newver->S4_ver = version->S4_ver; |
485 |
if ( strcmp(oldver->S4_ver.Data(),"") ) reprocessing = true; |
if ( strcmp(oldver->S4_ver.Data(),"") ) reprocessing = true; |
486 |
}; |
}; |
487 |
|
if ( !strcmp(Detector.Data(),"DV") ){ |
488 |
|
newver->TRIG_ver = oldver->TRIG_ver; |
489 |
|
newver->TOF_ver = oldver->TOF_ver; |
490 |
|
newver->ND_ver = oldver->ND_ver; |
491 |
|
newver->AC_ver = oldver->AC_ver; |
492 |
|
newver->TRK_ver = oldver->TRK_ver; |
493 |
|
newver->ORB_ver = oldver->ORB_ver; |
494 |
|
newver->CAL_ver = oldver->CAL_ver; |
495 |
|
newver->S4_ver = oldver->S4_ver; |
496 |
|
newver->DV_ver = version->DV_ver; |
497 |
|
if ( strcmp(oldver->DV_ver.Data(),"") ) reprocessing = true; |
498 |
|
}; |
499 |
if ( !strcmp(Detector.Data(),"ND") ){ |
if ( !strcmp(Detector.Data(),"ND") ){ |
500 |
newver->TRIG_ver = oldver->TRIG_ver; |
newver->TRIG_ver = oldver->TRIG_ver; |
501 |
newver->TOF_ver = oldver->TOF_ver; |
newver->TOF_ver = oldver->TOF_ver; |
502 |
|
newver->DV_ver = oldver->DV_ver; |
503 |
newver->S4_ver = oldver->S4_ver; |
newver->S4_ver = oldver->S4_ver; |
504 |
newver->AC_ver = oldver->AC_ver; |
newver->AC_ver = oldver->AC_ver; |
505 |
newver->ORB_ver = oldver->ORB_ver; |
newver->ORB_ver = oldver->ORB_ver; |
510 |
}; |
}; |
511 |
}; |
}; |
512 |
// |
// |
513 |
last_file_entry = first_file_entry + (oldrun->EV_REG_PHYS_TO - oldrun->EV_REG_PHYS_FROM + 1); |
if ( oldrun->EV_TO >= oldrun->EV_FROM ) last_file_entry = first_file_entry + (oldrun->EV_TO - oldrun->EV_FROM + 1); |
514 |
// |
// |
515 |
} else { |
} else { |
516 |
if ( !found ) first_file_entry += (oldrun->EV_REG_PHYS_TO - oldrun->EV_REG_PHYS_FROM + 1); |
if ( !found ) first_file_entry += (oldrun->EV_TO - oldrun->EV_FROM + 1); |
517 |
}; |
}; |
518 |
// |
// |
519 |
file->cd(); |
file->cd(); |
521 |
// |
// |
522 |
}; |
}; |
523 |
// |
// |
|
// temprfile->Close(); |
|
|
// gSystem->Unlink(temprname.str().c_str()); |
|
|
// if ( ismydir ) gSystem->Unlink(tempdir.str().c_str()); |
|
524 |
file->cd(); |
file->cd(); |
525 |
if ( oldtree ) oldtree->Delete("all"); |
if ( oldtree ) oldtree->Delete("all"); |
526 |
newtree->SetName("Run"); |
newtree->SetName("Run"); |
527 |
// file->Write("Run"); |
// |
|
// newtree->Delete(); |
|
528 |
delete newver; |
delete newver; |
529 |
delete newrun; |
delete newrun; |
530 |
delete oldver; |
delete oldver; |
531 |
delete oldrun; |
delete oldrun; |
532 |
// |
// |
533 |
if ( !found ){ |
if ( !found ){ |
534 |
if ( debug ) printf("\n RUNINFO - ERROR: no run with ID_RUN = %llu \n",idRun); |
if ( debug ) printf("\n RUNINFO - ERROR: no run with ID_RUN = %u \n",idRun); |
535 |
return(-5); |
return(-5); |
536 |
}; |
}; |
537 |
// |
// |
540 |
return(0); |
return(0); |
541 |
} |
} |
542 |
|
|
543 |
Int_t ItoRunInfo::Read(ULong64_t idRun){ |
Int_t ItoRunInfo::Read(UInt_t idRun){ |
544 |
// |
// |
545 |
isreadonly = true; |
isreadonly = true; |
546 |
// |
// |
571 |
if ( debug ) printf("\n RUNINFO - ERROR: can not handle more than 500 runs!\n"); |
if ( debug ) printf("\n RUNINFO - ERROR: can not handle more than 500 runs!\n"); |
572 |
return(-806); |
return(-806); |
573 |
}; |
}; |
|
// runlist = new TArrayL((Int_t)totnorun); |
|
574 |
// |
// |
575 |
first_file_entry = 0; |
first_file_entry = 0; |
576 |
// |
// |
578 |
// |
// |
579 |
newtree->GetEntry(run); |
newtree->GetEntry(run); |
580 |
// |
// |
581 |
file_entries += (newrun->EV_REG_PHYS_TO - newrun->EV_REG_PHYS_FROM + 1); |
file_entries += (newrun->EV_TO - newrun->EV_FROM + 1); |
582 |
// |
// |
583 |
if ( debug ) printf("totnorun %i newrun->ID %i \n",(int)totnorun,(int)newrun->ID); |
if ( debug ) printf("totnorun %i newrun->ID %i \n",(int)totnorun,(int)newrun->ID); |
584 |
// |
// |
585 |
ID = newrun->ID; |
CopyFromTo(newrun,(GL_RUN*)this,newver,version); |
586 |
ID_REG_RUN = newrun->ID_REG_RUN; |
if ( idRun == ID || idRun == 0 ){ |
|
ID_REG_RUN_L2 = newrun->ID_REG_RUN_L2; |
|
|
RUNHEADER_TIME = newrun->RUNHEADER_TIME; |
|
|
RUNTRAILER_TIME = newrun->RUNTRAILER_TIME; |
|
|
EV_REG_PHYS_FROM = newrun->EV_REG_PHYS_FROM; |
|
|
EV_REG_PHYS_TO = newrun->EV_REG_PHYS_TO; |
|
|
EV_REG_RUNHEADER = newrun->EV_REG_RUNHEADER; |
|
|
EV_REG_RUNTRAILER = newrun->EV_REG_RUNTRAILER; |
|
|
TRK_CALIB_USED = newrun->TRK_CALIB_USED; |
|
|
EFF_WRK_SCHEDULE = newrun->EFF_WRK_SCHEDULE; |
|
|
PRH_VAR_TRG_MODE_A = newrun->PRH_VAR_TRG_MODE_A; |
|
|
PRH_VAR_TRG_MODE_B = newrun->PRH_VAR_TRG_MODE_B; |
|
|
ACQ_BUILD_INFO = newrun->ACQ_BUILD_INFO; |
|
|
ACQ_VAR_INFO = newrun->ACQ_VAR_INFO; |
|
|
version->TRIG_ver = newver->TRIG_ver; |
|
|
version->TOF_ver = newver->TOF_ver; |
|
|
version->AC_ver = newver->AC_ver; |
|
|
version->TRK_ver = newver->TRK_ver; |
|
|
version->ORB_ver = newver->ORB_ver; |
|
|
version->CAL_ver = newver->CAL_ver; |
|
|
version->S4_ver = newver->S4_ver; |
|
|
version->ND_ver = newver->ND_ver; |
|
|
if ( idRun == ID || idRun == 0ULL ){ |
|
587 |
runlist->AddAt(newrun->ID,norun); |
runlist->AddAt(newrun->ID,norun); |
588 |
norun++; |
norun++; |
589 |
}; |
}; |
590 |
last_file_entry = first_file_entry + (newrun->EV_REG_PHYS_TO - newrun->EV_REG_PHYS_FROM + 1); |
if ( newrun->EV_TO >= newrun->EV_FROM ) last_file_entry = first_file_entry + (newrun->EV_TO - newrun->EV_FROM + 1); |
591 |
}; |
}; |
592 |
}; |
}; |
593 |
if ( debug ) printf("norun %i \n",(int)norun); |
if ( debug ) printf("norun %i \n",(int)norun); |
604 |
updating = false; |
updating = false; |
605 |
first_file_entry = 0; |
first_file_entry = 0; |
606 |
last_file_entry = 0; |
last_file_entry = 0; |
607 |
file_entries = 0ULL; |
file_entries = 0; |
608 |
norun = 0; |
norun = 0; |
|
// runlist = new TArrayL(0,NULL); |
|
609 |
delete runlist; |
delete runlist; |
610 |
//if ( file ) delete file; |
// file = new TFile(); |
611 |
file = new TFile(); |
file = 0; |
612 |
if ( isreadonly ) newtree->Delete(); |
if ( isreadonly ) newtree->Delete(); |
613 |
} |
} |
614 |
|
|
624 |
// |
// |
625 |
if ( entry > (UInt_t)last_file_entry ){ |
if ( entry > (UInt_t)last_file_entry ){ |
626 |
for ( UInt_t nrun = 0; nrun < norun; nrun++){ |
for ( UInt_t nrun = 0; nrun < norun; nrun++){ |
627 |
if ( ID == (ULong64_t)runlist->At(nrun) ) { |
if ( ID == (UInt_t)runlist->At(nrun) ) { |
628 |
startfrom = nrun+1; |
startfrom = nrun+1; |
629 |
break; |
break; |
630 |
}; |
}; |
638 |
retry: |
retry: |
639 |
// |
// |
640 |
for ( UInt_t nrun = startfrom; nrun < norun; nrun++){ |
for ( UInt_t nrun = startfrom; nrun < norun; nrun++){ |
641 |
GetRunInfo((ULong64_t)runlist->At(nrun)); |
GetRunInfo((UInt_t)runlist->At(nrun)); |
642 |
if ( entry >= (UInt_t)first_file_entry && entry <= (UInt_t)last_file_entry ){ |
if ( entry >= (UInt_t)first_file_entry && entry <= (UInt_t)last_file_entry ){ |
643 |
return((UInt_t)runlist->At(nrun)); |
return((UInt_t)runlist->At(nrun)); |
644 |
}; |
}; |
651 |
return(0); |
return(0); |
652 |
} |
} |
653 |
|
|
654 |
Int_t ItoRunInfo::GetRunInfo(ULong64_t run){ |
Int_t ItoRunInfo::GetRunInfo(UInt_t run){ |
655 |
Bool_t found = false; |
Bool_t found = false; |
656 |
SoftInfo *nwver = new SoftInfo(); |
SoftInfo *nwver = new SoftInfo(); |
657 |
GL_RUN *nwrun = new GL_RUN(); |
GL_RUN *nwrun = new GL_RUN(); |
667 |
for ( UInt_t nrun = 0; nrun < totnorun; nrun++){ |
for ( UInt_t nrun = 0; nrun < totnorun; nrun++){ |
668 |
newtree->GetEntry(nrun); |
newtree->GetEntry(nrun); |
669 |
// |
// |
670 |
if ( nwrun->ID == run || run == 0ULL ){ |
if ( nwrun->ID == run || run == 0 ){ |
671 |
ID = nwrun->ID; |
CopyFromTo(nwrun,(GL_RUN*)this,nwver,version); |
|
ID_REG_RUN = nwrun->ID_REG_RUN; |
|
|
ID_REG_RUN_L2 = nwrun->ID_REG_RUN_L2; |
|
|
RUNHEADER_TIME = nwrun->RUNHEADER_TIME; |
|
|
RUNTRAILER_TIME = nwrun->RUNTRAILER_TIME; |
|
|
EV_REG_PHYS_FROM = nwrun->EV_REG_PHYS_FROM; |
|
|
EV_REG_PHYS_TO = nwrun->EV_REG_PHYS_TO; |
|
|
EV_REG_RUNHEADER = nwrun->EV_REG_RUNHEADER; |
|
|
EV_REG_RUNTRAILER = nwrun->EV_REG_RUNTRAILER; |
|
|
TRK_CALIB_USED = nwrun->TRK_CALIB_USED; |
|
|
EFF_WRK_SCHEDULE = nwrun->EFF_WRK_SCHEDULE; |
|
|
PRH_VAR_TRG_MODE_A = nwrun->PRH_VAR_TRG_MODE_A; |
|
|
PRH_VAR_TRG_MODE_B = nwrun->PRH_VAR_TRG_MODE_B; |
|
|
ACQ_BUILD_INFO = nwrun->ACQ_BUILD_INFO; |
|
|
ACQ_VAR_INFO = nwrun->ACQ_VAR_INFO; |
|
|
version->TRIG_ver = nwver->TRIG_ver; |
|
|
version->TOF_ver = nwver->TOF_ver; |
|
|
version->AC_ver = nwver->AC_ver; |
|
|
version->TRK_ver = nwver->TRK_ver; |
|
|
version->ORB_ver = nwver->ORB_ver; |
|
|
version->CAL_ver = nwver->CAL_ver; |
|
|
version->S4_ver = nwver->S4_ver; |
|
|
version->ND_ver = nwver->ND_ver; |
|
672 |
found = true; |
found = true; |
673 |
last_file_entry = first_file_entry + (nwrun->EV_REG_PHYS_TO - nwrun->EV_REG_PHYS_FROM + 1); |
if ( nwrun->EV_TO >= nwrun->EV_FROM ) last_file_entry = first_file_entry + (nwrun->EV_TO - nwrun->EV_FROM + 1); |
674 |
}; |
}; |
675 |
if ( !found ) first_file_entry += (nwrun->EV_REG_PHYS_TO - nwrun->EV_REG_PHYS_FROM + 1); |
if ( !found ) first_file_entry += (nwrun->EV_TO - nwrun->EV_FROM + 1); |
676 |
}; |
}; |
677 |
delete nwver; |
delete nwver; |
678 |
delete nwrun; |
delete nwrun; |