226 |
qu.str(""); |
qu.str(""); |
227 |
// qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< chlastts <<")<10000 AND ABS(REAL_TIME_INIT-"<< row2->GetField(10) <<")<7200 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; |
// qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< chlastts <<")<10000 AND ABS(REAL_TIME_INIT-"<< row2->GetField(10) <<")<7200 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; |
228 |
// qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< chlastts <<")<40000 AND ABS(REAL_TIME_INIT-"<< row2->GetField(10) <<")<40000 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; // relax conditions... 090112 [8RED: error -29] |
// qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< chlastts <<")<40000 AND ABS(REAL_TIME_INIT-"<< row2->GetField(10) <<")<40000 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; // relax conditions... 090112 [8RED: error -29] |
229 |
qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< chlastts <<")<50000 AND ABS(REAL_TIME_INIT-"<< row2->GetField(10) <<")<50000 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; // even more relaxed conditions... 091214 [9REDtest3: error -29] |
qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< (float)chlastts <<")<50000 AND ABS(REAL_TIME_INIT-"<< atof(row2->GetField(10)) <<")<50000 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; // even more relaxed conditions... 091214 [9REDtest3: error -29] // 10RED MYSQL operators BUG: |
230 |
|
/* |
231 |
|
|
232 |
|
mysql> select CAST(1322000646 AS UNSIGNED INTEGER)-1322017203.; |
233 |
|
+--------------------------------------------------+ |
234 |
|
| CAST(1322000646 AS UNSIGNED INTEGER)-1322017203. | |
235 |
|
+--------------------------------------------------+ |
236 |
|
| -16557 | |
237 |
|
+--------------------------------------------------+ |
238 |
|
1 row in set (0.06 sec) |
239 |
|
|
240 |
|
mysql> select CAST(1322000646 AS UNSIGNED INTEGER)-1322017203; |
241 |
|
+-------------------------------------------------+ |
242 |
|
| CAST(1322000646 AS UNSIGNED INTEGER)-1322017203 | |
243 |
|
+-------------------------------------------------+ |
244 |
|
| 18446744073709535059 | |
245 |
|
+-------------------------------------------------+ |
246 |
|
1 row in set (0.02 sec) |
247 |
|
|
248 |
|
*/ |
249 |
if ( debug ) printf(" chewbacca: query is %s \n",qu.str().c_str()); |
if ( debug ) printf(" chewbacca: query is %s \n",qu.str().c_str()); |
250 |
result3 = conn->Query(qu.str().c_str()); |
result3 = conn->Query(qu.str().c_str()); |
251 |
if ( result3 ){ |
if ( result3 ){ |
1366 |
stringstream oss; |
stringstream oss; |
1367 |
// |
// |
1368 |
oss.str(""); |
oss.str(""); |
1369 |
oss << "SET time_zone='+0:00';"; |
oss << "SET time_zone='+0:00'; SET sql_mode = 'NO_UNSIGNED_SUBTRACTION';"; |
1370 |
TSQLResult *result = 0; |
TSQLResult *result = 0; |
1371 |
result = conn->Query(oss.str().c_str()); |
result = conn->Query(oss.str().c_str()); |
1372 |
if ( !result ) throw -10; |
if ( !result ) throw -10; |
1658 |
Int_t PamelaDBOperations::insertPamelaGL_TIMESYNC(){ |
Int_t PamelaDBOperations::insertPamelaGL_TIMESYNC(){ |
1659 |
// |
// |
1660 |
Int_t signal = 0; |
Int_t signal = 0; |
1661 |
UInt_t idresof = 0; |
// UInt_t idresof = 0; |
1662 |
|
idresof = 0; |
1663 |
stringstream oss; |
stringstream oss; |
1664 |
TSQLResult *result = 0; |
TSQLResult *result = 0; |
1665 |
TSQLRow *row = 0; |
TSQLRow *row = 0; |
1750 |
TYPE = 0; |
TYPE = 0; |
1751 |
TSYNC = 0; |
TSYNC = 0; |
1752 |
// |
// |
1753 |
Double_t minimum = 0.; |
// Double_t minimum = 0.; |
1754 |
Double_t maximum = 0.; |
// Double_t maximum = 0.; |
1755 |
Double_t minimum2 = 0.; |
//Double_t minimum2 = 0.; |
1756 |
Double_t maximum2 = 0.; |
Double_t maximum2 = 0.; |
1757 |
// |
// |
1758 |
// |
// |
1760 |
pamela::McmdRecord *mcrc = 0; |
pamela::McmdRecord *mcrc = 0; |
1761 |
TArrayC *mcmddata = 0; |
TArrayC *mcmddata = 0; |
1762 |
// |
// |
1763 |
minimum = numeric_limits<Double_t>::max(); |
// minimum = numeric_limits<Double_t>::max(); |
1764 |
maximum = numeric_limits<Double_t>::min(); |
// maximum = numeric_limits<Double_t>::min(); |
1765 |
minimum2 = numeric_limits<Double_t>::max(); |
// minimum2 = numeric_limits<Double_t>::max(); |
1766 |
maximum2 = numeric_limits<Double_t>::min(); |
maximum2 = numeric_limits<Double_t>::min(); |
1767 |
// |
// |
1768 |
T = (TTree*)file->Get("Mcmd"); |
T = (TTree*)file->Get("Mcmd"); |
1973 |
// |
// |
1974 |
if ( chewbacca ){ |
if ( chewbacca ){ |
1975 |
oss.str(""); |
oss.str(""); |
1976 |
oss << " SELECT ID FROM GL_TIMESYNC where TIMESYNC="<<chlastts<<" AND OBT0="<<chobtts*1000<<" limit 1;"; |
oss << " SELECT ID FROM GL_TIMESYNC where TIMESYNC="<<chlastts<<" AND OBT0="<<chobtts*1000<<" and ID_RESURS_OFFSET="<< idresof <<" limit 1;"; // 10RED BUG!!!! without 'and ID_RESURS_OFFSET="<< idresof ' this query is not enough to ensure finding the correct line in GL_TIMSYNC... |
1977 |
if ( debug ) printf(" %s \n",oss.str().c_str()); |
if ( debug ) printf(" %s \n",oss.str().c_str()); |
1978 |
result = conn->Query(oss.str().c_str()); |
result = conn->Query(oss.str().c_str()); |
1979 |
// |
// |
2182 |
UInt_t lowerts = tsync-(obt0/1000)-5; |
UInt_t lowerts = tsync-(obt0/1000)-5; |
2183 |
if ( chewbacca ){ |
if ( chewbacca ){ |
2184 |
oss.str(""); |
oss.str(""); |
2185 |
oss << "select BOOT_NUMBER from ROOT_TABLE where LAST_TIME_SYNC_INFO-(OBT_TIME_SYNC)<" |
oss << "select BOOT_NUMBER from ROOT_TABLE where CAST((LAST_TIME_SYNC_INFO-(OBT_TIME_SYNC)) AS SIGNED INT)<" // 10RED MYSQL OPERATORS BUG |
2186 |
<< upperts |
<< upperts |
2187 |
<< " AND LAST_TIME_SYNC_INFO-(OBT_TIME_SYNC)>" |
<< " AND CAST((LAST_TIME_SYNC_INFO-(OBT_TIME_SYNC)) AS SIGNED INT)>" // 10RED MYSQL OPERATORS BUG |
2188 |
<< lowerts |
<< lowerts |
2189 |
<< " AND BOOT_NUMBER>1;"; |
<< " AND BOOT_NUMBER>1;"; |
2190 |
} else { |
} else { |
2191 |
oss.str(""); |
oss.str(""); |
2192 |
oss << "select GL_RAW.BOOT_NUMBER from GL_TIMESYNC LEFT JOIN GL_RAW ON GL_RAW.ID = GL_TIMESYNC.ID_RAW where TIMESYNC-(OBT0/1000)<" |
oss << "select GL_RAW.BOOT_NUMBER from GL_TIMESYNC LEFT JOIN GL_RAW ON GL_RAW.ID = GL_TIMESYNC.ID_RAW where CAST((TIMESYNC-(OBT0/1000)) AS SIGNED INT)<" // 10RED MYSQL OPERATORS BUG |
2193 |
<< upperts |
<< upperts |
2194 |
<< " AND TIMESYNC-(OBT0/1000)>" |
<< " AND CAST((TIMESYNC-(OBT0/1000)) AS SIGNED INT)>" // 10RED MYSQL OPERATORS BUG |
2195 |
<< lowerts |
<< lowerts |
2196 |
<< " AND GL_RAW.BOOT_NUMBER>0 GROUP BY GL_TIMESYNC.OBT0;"; |
<< " AND GL_RAW.BOOT_NUMBER>0 GROUP BY GL_TIMESYNC.OBT0;"; |
2197 |
}; |
}; |
2290 |
// |
// |
2291 |
// no runtrailers in the file! |
// no runtrailers in the file! |
2292 |
// |
// |
2293 |
if ( !rtev ){ |
if ( IsDebug() ) printf(" Start rtev %i rhev %i nrtev %i nrhev %i \n",rtev,rhev,nrtev,nrhev); |
2294 |
if ( !rhev ){ |
if ( !rtev || (chewbacca && !nrtev) ){ |
2295 |
|
if ( IsDebug() ) printf(" No runtrailers \n"); |
2296 |
|
if ( !rhev || (chewbacca && !nrhev) ){ |
2297 |
if ( IsDebug() ) printf(" No runheaders nor runtrailers!! \n"); |
if ( IsDebug() ) printf(" No runheaders nor runtrailers!! \n"); |
2298 |
if ( !(upperentry-chminentry) ){ |
if ( !(upperentry-chminentry) ){ |
2299 |
if ( IsDebug() ) printf(" No physics events nor runs in the file \n"); // di nuovo potrebbe esserci un runtrailer senza eventi (riempimento MM) |
if ( IsDebug() ) printf(" No physics events nor runs in the file \n"); // di nuovo potrebbe esserci un runtrailer senza eventi (riempimento MM) |
2330 |
// |
// |
2331 |
} else { |
} else { |
2332 |
// |
// |
2333 |
|
if ( IsDebug() ) printf(" We have runtrailers \n"); |
2334 |
Int_t conptt = -1; |
Int_t conptt = -1; |
2335 |
for (Int_t ptt=0; ptt<rtev; ptt++){ |
for (Int_t ptt=0; ptt<rtev; ptt++){ |
2336 |
// |
// |
2977 |
if ( IsDebug() ) printf(" here firstev is %i lastev is %i \n",firstev,lastev); |
if ( IsDebug() ) printf(" here firstev is %i lastev is %i \n",firstev,lastev); |
2978 |
// |
// |
2979 |
glrun->SetEV_FROM(firstev); |
glrun->SetEV_FROM(firstev); |
2980 |
|
glrun->SetEV_TO(lastev); // EM 10 RED ghost run bug |
2981 |
glrun->SetNEVENTS(lastev-firstev+1); |
glrun->SetNEVENTS(lastev-firstev+1); |
2982 |
// |
// |
2983 |
glrun->SetRUNHEADER_TIME(glrun1->GetRUNHEADER_TIME()); |
glrun->SetRUNHEADER_TIME(glrun1->GetRUNHEADER_TIME()); |
3173 |
}; |
}; |
3174 |
if ( IsDebug() ) printf(" Check overlapping events done: %u %u %llu %llu lastev is %i\n",apkt,bpkt,aobt,bobt,lastev); |
if ( IsDebug() ) printf(" Check overlapping events done: %u %u %llu %llu lastev is %i\n",apkt,bpkt,aobt,bobt,lastev); |
3175 |
// |
// |
3176 |
|
glrun->SetEV_FROM(firstev); // EM 10RED ghost run bug |
3177 |
glrun->SetEV_TO(lastev); |
glrun->SetEV_TO(lastev); |
3178 |
glrun->SetNEVENTS(lastev-firstev+1); |
glrun->SetNEVENTS(lastev-firstev+1); |
3179 |
glrun->SetPKT_COUNTER(glrun1->GetPKT_COUNTER()); |
glrun->SetPKT_COUNTER(glrun1->GetPKT_COUNTER()); |
3620 |
// |
// |
3621 |
EventCounter *code=0; |
EventCounter *code=0; |
3622 |
// |
// |
3623 |
UInt_t nevent = 0; |
// UInt_t nevent = 0; |
3624 |
UInt_t checkfirst = 0; |
UInt_t checkfirst = 0; |
3625 |
UInt_t checklast = 0; |
UInt_t checklast = 0; |
3626 |
UInt_t firstentry = 0; |
UInt_t firstentry = 0; |
3642 |
EventHeader *eh = 0; |
EventHeader *eh = 0; |
3643 |
PscuHeader *ph = 0; |
PscuHeader *ph = 0; |
3644 |
T->SetBranchAddress("Header", &eh); |
T->SetBranchAddress("Header", &eh); |
3645 |
nevent = T->GetEntries(); |
// nevent = T->GetEntries(); |
3646 |
// |
// |
3647 |
// |
// |
3648 |
if ( firstev == lastev+1 || lastev == firstev ) { // no events inside the run! |
if ( firstev == lastev+1 || lastev == firstev ) { // no events inside the run! |
4016 |
glrun1->SetRUNTRAILER_PKT(glrun->GetRUNTRAILER_PKT()); |
glrun1->SetRUNTRAILER_PKT(glrun->GetRUNTRAILER_PKT()); |
4017 |
// |
// |
4018 |
glrun->SetEV_FROM(firstev); |
glrun->SetEV_FROM(firstev); |
4019 |
|
glrun->SetEV_TO(lastev); // 10 RED ghost run bug |
4020 |
glrun->SetNEVENTS(lastev-firstev+1); |
glrun->SetNEVENTS(lastev-firstev+1); |
4021 |
// |
// |
4022 |
glrun->SetRUNHEADER_TIME(glrun1->GetRUNHEADER_TIME()); |
glrun->SetRUNHEADER_TIME(glrun1->GetRUNHEADER_TIME()); |
4164 |
EventCounter *code=0; |
EventCounter *code=0; |
4165 |
UInt_t firstev = 0; |
UInt_t firstev = 0; |
4166 |
UInt_t lastev = 0; |
UInt_t lastev = 0; |
4167 |
UInt_t nevent = 0; |
// UInt_t nevent = 0; |
4168 |
UInt_t checkfirst = 0; |
UInt_t checkfirst = 0; |
4169 |
UInt_t checklast = 0; |
UInt_t checklast = 0; |
4170 |
UInt_t firstentry = 0; |
UInt_t firstentry = 0; |
4189 |
EventHeader *eh = 0; |
EventHeader *eh = 0; |
4190 |
PscuHeader *ph = 0; |
PscuHeader *ph = 0; |
4191 |
T->SetBranchAddress("Header", &eh); |
T->SetBranchAddress("Header", &eh); |
4192 |
nevent = T->GetEntries(); |
// nevent = T->GetEntries(); |
4193 |
// |
// |
4194 |
codt = eht->GetCounter(); |
codt = eht->GetCounter(); |
4195 |
codh = ehh->GetCounter(); |
codh = ehh->GetCounter(); |
5472 |
|
|
5473 |
if ( IsDebug() ) cout << endl << ">>>> TRY TO RECOVER TRACKER CALIBRATIONS <<<<"<<endl; |
if ( IsDebug() ) cout << endl << ">>>> TRY TO RECOVER TRACKER CALIBRATIONS <<<<"<<endl; |
5474 |
|
|
5475 |
TSQLResult *result = 0; |
TSQLResult *rresult = 0; // 10RED bug, result is re-used inside result looop... |
5476 |
|
TSQLResult *result = 0; // 10RED bug, result is re-used inside result looop... |
5477 |
TSQLRow *row = 0; |
TSQLRow *row = 0; |
5478 |
// |
// |
5479 |
stringstream oss; |
stringstream oss; |
5503 |
oss << " ORDER BY ID DESC LIMIT "<<ncalib<<"; "; |
oss << " ORDER BY ID DESC LIMIT "<<ncalib<<"; "; |
5504 |
if ( IsDebug() ) cout << oss.str().c_str() << endl; |
if ( IsDebug() ) cout << oss.str().c_str() << endl; |
5505 |
|
|
5506 |
result = conn->Query(oss.str().c_str()); |
rresult = conn->Query(oss.str().c_str()); |
5507 |
if ( !result ) throw -4;; |
if ( !result ) throw -4;; |
5508 |
if ( IsDebug() ) cout <<"Rows: "<<result->GetRowCount()<<endl; |
if ( IsDebug() ) cout <<"Rows: "<<result->GetRowCount()<<endl; |
5509 |
|
|
5512 |
// ----------------------------------- |
// ----------------------------------- |
5513 |
UInt_t nn=0; |
UInt_t nn=0; |
5514 |
do { |
do { |
5515 |
row = result->Next(); |
row = rresult->Next(); |
5516 |
if(!row)break; |
if(!row)break; |
5517 |
|
|
5518 |
UInt_t id = (UInt_t)atoll(row->GetField(0)); |
UInt_t id = (UInt_t)atoll(row->GetField(0)); |
5551 |
TString path = ""; |
TString path = ""; |
5552 |
TString name = ""; |
TString name = ""; |
5553 |
TString raw = ""; |
TString raw = ""; |
5554 |
UInt_t obt0 = 0; |
// UInt_t obt0 = 0; |
5555 |
UInt_t timesync = 0; |
// UInt_t timesync = 0; |
5556 |
UInt_t boot_number = 0; |
// UInt_t boot_number = 0; |
5557 |
bool FOUND = false; |
bool FOUND = false; |
5558 |
|
|
5559 |
if ( IsDebug() ) cout << "------------------------------------------------------------" <<endl; |
if ( IsDebug() ) cout << "------------------------------------------------------------" <<endl; |
5626 |
path = (TString)row2->GetField(0); |
path = (TString)row2->GetField(0); |
5627 |
name = (TString)row2->GetField(1); |
name = (TString)row2->GetField(1); |
5628 |
raw = (TString)row2->GetField(5); |
raw = (TString)row2->GetField(5); |
5629 |
obt0 = (UInt_t)atoll(row2->GetField(2)); |
// obt0 = (UInt_t)atoll(row2->GetField(2)); |
5630 |
timesync = (UInt_t)atoll(row2->GetField(3)); |
// timesync = (UInt_t)atoll(row2->GetField(3)); |
5631 |
boot_number = (UInt_t)atoll(row2->GetField(4)); |
// boot_number = (UInt_t)atoll(row2->GetField(4)); |
5632 |
|
|
5633 |
if ( IsDebug() ) cout << "- - - - - - - - - - -" <<endl; |
if ( IsDebug() ) cout << "- - - - - - - - - - -" <<endl; |
5634 |
// cout << path <<endl; |
// cout << path <<endl; |
5692 |
if(FOUND)break; |
if(FOUND)break; |
5693 |
|
|
5694 |
}while(1);//endl loop over root table entries |
}while(1);//endl loop over root table entries |
5695 |
|
|
5696 |
|
delete result2; // 10RED potential memory leak |
5697 |
if(FOUND)break; |
if(FOUND)break; |
5698 |
|
|
5699 |
}//end loop over tables |
}//end loop over tables |
5746 |
// --------------------------------------------------------------------- |
// --------------------------------------------------------------------- |
5747 |
UInt_t idtimesync = 0; |
UInt_t idtimesync = 0; |
5748 |
oss.str(""); |
oss.str(""); |
5749 |
oss << " SELECT ID FROM GL_TIMESYNC where TIMESYNC="<<chlastts<<" AND OBT0="<<chobtts*1000<<" limit 1;"; |
oss << " SELECT ID FROM GL_TIMESYNC where TIMESYNC="<<chlastts<<" AND OBT0="<<chobtts*1000<<" and ID_RESURS_OFFSET="<< idresof <<" limit 1;"; // 10RED BUG!!!! without 'and ID_RESURS_OFFSET="<< idresof ' this query is not enough to ensure finding the correct line in GL_TIMSYNC... |
5750 |
if ( debug ) printf(" %s \n",oss.str().c_str()); |
if ( debug ) printf(" %s \n",oss.str().c_str()); |
5751 |
result = conn->Query(oss.str().c_str()); |
result = conn->Query(oss.str().c_str()); |
5752 |
if ( !result ) throw -3; |
if ( !result ) throw -3; |
5847 |
}while(1);//end loop over calibrations |
}while(1);//end loop over calibrations |
5848 |
|
|
5849 |
|
|
5850 |
if( result )delete result; |
if( rresult )delete rresult; // 10RED bug |
5851 |
if( row )delete row; |
if( row )delete row; |
5852 |
|
|
5853 |
|
|
6148 |
memset(myid,0,500*sizeof(UInt_t)); |
memset(myid,0,500*sizeof(UInt_t)); |
6149 |
// |
// |
6150 |
oss.str(""); |
oss.str(""); |
6151 |
oss << "SELECT ID,RUNTRAILER_TIME,RUNTRAILER_PKT,BOOT_NUMBER FROM GL_RUN_FRAGMENTS WHERE INSERT_TIME <= '" << clean_time->AsSQLString() << "'order BY RUNHEADER_TIME asc;"; |
oss << "SELECT ID,RUNTRAILER_TIME,RUNTRAILER_PKT,BOOT_NUMBER FROM GL_RUN_FRAGMENTS WHERE INSERT_TIME <= '" << clean_time->AsSQLString() << "' order BY RUNHEADER_TIME asc;"; |
6152 |
if ( IsDebug() ) printf(" Select from GL_RUN_FRAGMENTS runs older than %s : query is \n %s \n",clean_time->AsSQLString(),oss.str().c_str()); |
if ( IsDebug() ) printf(" Select from GL_RUN_FRAGMENTS runs older than %s : query is \n %s \n",clean_time->AsSQLString(),oss.str().c_str()); |
6153 |
nresult = conn->Query(oss.str().c_str()); |
nresult = conn->Query(oss.str().c_str()); |
6154 |
// |
// |
6179 |
while ( anr ){ |
while ( anr ){ |
6180 |
// |
// |
6181 |
oss.str(""); |
oss.str(""); |
6182 |
oss << "SELECT ID,RUNTRAILER_TIME,RUNTRAILER_PKT,BOOT_NUMBER FROM GL_RUN_FRAGMENTS WHERE BOOT_NUMBER=" << mbo << " AND RUNHEADER_PKT=" << mrhp << "+1 AND ABS(RUNHEADER_TIME-"<< mrht <<")<=1 AND INSERT_TIME <= '" << clean_time->AsSQLString() << "' order BY RUNHEADER_TIME asc;"; |
oss << "SELECT ID,RUNTRAILER_TIME,RUNTRAILER_PKT,BOOT_NUMBER FROM GL_RUN_FRAGMENTS WHERE BOOT_NUMBER=" << mbo << " AND RUNHEADER_PKT=" << mrhp << "+1 AND ABS(RUNHEADER_TIME-"<< (float)mrht <<")<=1 AND INSERT_TIME <= '" << clean_time->AsSQLString() << "' order BY RUNHEADER_TIME asc;"; // 10RED MYSQL OPERATOR BUG |
6183 |
if ( IsDebug() ) printf(" In the loop searching for fragmented runs : query is \n %s \n",oss.str().c_str()); |
if ( IsDebug() ) printf(" In the loop searching for fragmented runs : query is \n %s \n",oss.str().c_str()); |
6184 |
// |
// |
6185 |
nresult1 = conn->Query(oss.str().c_str()); |
nresult1 = conn->Query(oss.str().c_str()); |