| 24 |
ClassImp(GL_PARAM); |
ClassImp(GL_PARAM); |
| 25 |
ClassImp(GL_S4_CALIB); |
ClassImp(GL_S4_CALIB); |
| 26 |
ClassImp(GL_CALO_CALIB); |
ClassImp(GL_CALO_CALIB); |
| 27 |
|
ClassImp(GL_CALOPULSE_CALIB); |
| 28 |
ClassImp(GL_TIMESYNC); |
ClassImp(GL_TIMESYNC); |
| 29 |
ClassImp(GL_TLE); |
ClassImp(GL_TLE); |
| 30 |
// |
// |
| 39 |
fPsw = new TString(psw.Data()); |
fPsw = new TString(psw.Data()); |
| 40 |
fSet = true; |
fSet = true; |
| 41 |
fNquery = 0; |
fNquery = 0; |
| 42 |
|
mh = host.Data(); |
| 43 |
|
mu = user.Data(); |
| 44 |
|
mp = psw.Data(); |
| 45 |
}; |
}; |
| 46 |
|
|
| 47 |
|
|
| 51 |
fPsw = new TString(psw.Data()); |
fPsw = new TString(psw.Data()); |
| 52 |
fSet = true; |
fSet = true; |
| 53 |
fNquery = 0; |
fNquery = 0; |
| 54 |
|
mh = host.Data(); |
| 55 |
|
mu = user.Data(); |
| 56 |
|
mp = psw.Data(); |
| 57 |
}; |
}; |
| 58 |
|
|
| 59 |
Bool_t GL_TABLES::IsConnected(TSQLServer *dbc){ |
Bool_t GL_TABLES::IsConnected(TSQLServer *&dbc){ |
| 60 |
// |
// |
| 61 |
// |
// |
| 62 |
// |
// |
| 64 |
return true; |
return true; |
| 65 |
}; |
}; |
| 66 |
// |
// |
| 67 |
// |
// printf(" host is %s \n",fHost->Data()); |
|
// |
|
|
// printf(" host is %s \n",fHost->Data()); |
|
| 68 |
// |
// |
| 69 |
stringstream myquery; |
stringstream myquery; |
| 70 |
myquery.str(""); |
myquery.str(""); |
| 71 |
myquery << "show databases;"; |
myquery << "show databases;"; |
| 72 |
dbc->Query(myquery.str().c_str()); |
if ( dbc ){ |
| 73 |
fNquery++; |
if ( dbc->IsConnected() ){ |
| 74 |
|
dbc->Query(myquery.str().c_str()); |
| 75 |
|
fNquery++; |
| 76 |
|
if ( !(dbc->GetErrorCode()) ){ |
| 77 |
|
// printf("ok\n"); |
| 78 |
|
// |
| 79 |
|
// if ( (dbc->GetErrorCode() != 2013 && dbc->GetErrorCode() != 2006) ){ |
| 80 |
|
// if ( !(dbc->GetErrorCode()) ){ |
| 81 |
|
// is connected |
| 82 |
|
return true; |
| 83 |
|
// }; |
| 84 |
|
}; |
| 85 |
|
}; |
| 86 |
|
}; |
| 87 |
// |
// |
| 88 |
if ( dbc->GetErrorCode() != 2013 && dbc->GetErrorCode() != 2006 ){ |
if ( true ) { |
|
// is connected |
|
|
return true; |
|
|
} else { |
|
| 89 |
// |
// |
| 90 |
printf(" WARNING: Lost connection to DB! try to recover... \n"); |
printf(" WARNING: Lost connection to DB! try to recover... \n"); |
| 91 |
// |
// |
| 92 |
TString host = fHost->Data(); |
TString host = fHost->Data(); |
| 93 |
TString user = fUser->Data(); |
TString user = fUser->Data(); |
| 94 |
TString psw = fPsw->Data(); |
TString psw = fPsw->Data(); |
| 95 |
|
dbc->Close(); |
| 96 |
delete dbc; |
delete dbc; |
| 97 |
dbc = TSQLServer::Connect(host.Data(),user.Data(),psw.Data()); |
dbc = TSQLServer::Connect(host.Data(),user.Data(),psw.Data()); |
| 98 |
// |
// |
| 100 |
myquery << "show databases;"; |
myquery << "show databases;"; |
| 101 |
dbc->Query(myquery.str().c_str()); |
dbc->Query(myquery.str().c_str()); |
| 102 |
fNquery++; |
fNquery++; |
| 103 |
// |
// if ( dbc->GetErrorCode() != 2013 && dbc->GetErrorCode() != 2006 ){ |
| 104 |
if ( dbc->GetErrorCode() != 2013 && dbc->GetErrorCode() != 2006 ){ |
if ( !(dbc->GetErrorCode()) ){ |
| 105 |
// |
// |
| 106 |
printf(" ...connection recovered, I can continue! \n"); |
printf(" ...connection recovered, I can continue! \n"); |
| 107 |
// |
// |
| 172 |
} |
} |
| 173 |
|
|
| 174 |
|
|
| 175 |
void GL_RUN::Clear() { |
void GL_RUN::Clear(Option_t *t) { |
| 176 |
ID = 0; |
ID = 0; |
| 177 |
ID_RUN_FRAG = 0; |
ID_RUN_FRAG = 0; |
| 178 |
ID_ROOT_L0 = 0; |
ID_ROOT_L0 = 0; |
| 247 |
FROM_TIME = 0; |
FROM_TIME = 0; |
| 248 |
TO_TIME = 0; |
TO_TIME = 0; |
| 249 |
SECTION = 0; |
SECTION = 0; |
| 250 |
|
OBT = 0; |
| 251 |
|
PKT = 0; |
| 252 |
|
BOOT_NUMBER = 0; |
| 253 |
|
VALIDATION = 0; |
| 254 |
|
} |
| 255 |
|
|
| 256 |
|
GL_CALOPULSE_CALIB::GL_CALOPULSE_CALIB(){ |
| 257 |
|
ID = 0; |
| 258 |
|
ID_ROOT_L0 = 0; |
| 259 |
|
EV_ROOT = 0; |
| 260 |
|
FROM_TIME = 0; |
| 261 |
|
TO_TIME = 0; |
| 262 |
|
SECTION = 0; |
| 263 |
|
PULSED_STRIP = 0; |
| 264 |
|
PULSE_AMPLITUDE = 0; |
| 265 |
|
OBT = 0; |
| 266 |
|
PKT = 0; |
| 267 |
|
BOOT_NUMBER = 0; |
| 268 |
|
VALIDATION = 0; |
| 269 |
} |
} |
| 270 |
|
|
| 271 |
GL_S4_CALIB::GL_S4_CALIB(){ |
GL_S4_CALIB::GL_S4_CALIB(){ |
| 274 |
EV_ROOT = 0; |
EV_ROOT = 0; |
| 275 |
FROM_TIME = 0; |
FROM_TIME = 0; |
| 276 |
TO_TIME = 0; |
TO_TIME = 0; |
| 277 |
PARAM_FIT0 = 0.; |
OBT = 0; |
| 278 |
PARAM_FIT1 = 0.; |
PKT = 0; |
| 279 |
|
BOOT_NUMBER = 0; |
| 280 |
} |
} |
| 281 |
|
|
| 282 |
GL_TIMESYNC::GL_TIMESYNC(){ |
GL_TIMESYNC::GL_TIMESYNC(){ |
| 283 |
obtfirst = 0; |
obtfirst = 0; |
| 284 |
pktfirst = 0; |
pktfirst = 0; |
| 285 |
toffset = 0; |
ID_RESURS_OFFSET = 0; |
| 286 |
// ID = 0; |
ID = 0; |
| 287 |
// ID_RAW = 0; |
ID_RAW = 0; |
| 288 |
OBT0 = 0; |
OBT0 = 0; |
| 289 |
TIMESYNC = 0; |
TIMESYNC = 0; |
| 290 |
TYPE = 0; |
TYPE = 0; |
| 1207 |
myquery.str(""); |
myquery.str(""); |
| 1208 |
myquery << "select ID,ID_ROOT_L0,EV_ROOT_CALIBTRK1,EV_ROOT_CALIBTRK2,FROM_TIME,TO_TIME,OBT1,OBT2,PKT1,PKT2,BOOT_NUMBER,VALIDATION from GL_TRK_CALIB where FROM_TIME <= "<< time; |
myquery << "select ID,ID_ROOT_L0,EV_ROOT_CALIBTRK1,EV_ROOT_CALIBTRK2,FROM_TIME,TO_TIME,OBT1,OBT2,PKT1,PKT2,BOOT_NUMBER,VALIDATION from GL_TRK_CALIB where FROM_TIME <= "<< time; |
| 1209 |
// myquery << " AND VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; // RIVEDERE LA VALIDAZIONE!!! |
// myquery << " AND VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; // RIVEDERE LA VALIDAZIONE!!! |
| 1210 |
|
myquery << " and EV_ROOT_CALIBTRK1>=0 and EV_ROOT_CALIBTRK2>=0 "; // EM! SE MANCA UN PACCHETTO DEI DUE IL PROCESSAMENTO CRASHA... DA RIVEDERE LA VALIDAZIONE |
| 1211 |
myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
| 1212 |
// myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
// myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
| 1213 |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
| 1280 |
// |
// |
| 1281 |
uptime = (UInt_t)atoll(Row->GetField(2)); |
uptime = (UInt_t)atoll(Row->GetField(2)); |
| 1282 |
// |
// |
| 1283 |
|
UInt_t myfromtime = (UInt_t)atoll(Row->GetField(1)); |
| 1284 |
|
UInt_t mytotime = (UInt_t)atoll(Row->GetField(2)); |
| 1285 |
|
// |
| 1286 |
// if it is corrupted validation is 0 and we have no results from the query... |
// if it is corrupted validation is 0 and we have no results from the query... |
| 1287 |
// |
// |
| 1288 |
if( atoi(Row->GetField(4)) == 0 ){ // if validation = 0 |
if( atoi(Row->GetField(4)) == 0 ){ // if validation = 0 |
| 1304 |
// |
// |
| 1305 |
Row = pResult->Next(); |
Row = pResult->Next(); |
| 1306 |
// |
// |
| 1307 |
|
myfromtime = (UInt_t)atoll(Row->GetField(1)); |
| 1308 |
|
// |
| 1309 |
|
}; |
| 1310 |
|
// |
| 1311 |
|
// if the selected calibration is too old (more than 5 orbits old) try to take the closest not corrupted one |
| 1312 |
|
// |
| 1313 |
|
if ( (time-myfromtime)>28500 ){ |
| 1314 |
|
// |
| 1315 |
|
myquery.str(""); |
| 1316 |
|
myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT from GL_CALO_CALIB where SECTION=" << section; |
| 1317 |
|
myquery << " and VALIDATION=1 ORDER BY ABS(" << time << "-FROM_TIME) asc limit 1;"; |
| 1318 |
|
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
| 1319 |
|
this->GetGLTABLES()->AddQ(); |
| 1320 |
|
pResult = dbc->Query(myquery.str().c_str()); |
| 1321 |
|
// printf(" mysquery is %s\n",myquery.str().c_str()); |
| 1322 |
|
// |
| 1323 |
|
// if no results yet quit with error |
| 1324 |
|
// |
| 1325 |
|
if( !pResult->GetRowCount() ) return (-54); |
| 1326 |
|
// |
| 1327 |
|
Row = pResult->Next(); |
| 1328 |
|
// |
| 1329 |
}; |
}; |
| 1330 |
// |
// |
| 1331 |
// store infos and exit |
// store infos and exit |
| 1333 |
if( Row == NULL ) return (-54); |
if( Row == NULL ) return (-54); |
| 1334 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
| 1335 |
if (t==0) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
if (t==0) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
| 1336 |
|
if (t==1) FROM_TIME = myfromtime; |
| 1337 |
|
if (t==2) TO_TIME = mytotime; |
| 1338 |
|
if (t==3) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); |
| 1339 |
|
}; |
| 1340 |
|
pResult->Delete(); |
| 1341 |
|
return 0; |
| 1342 |
|
}; |
| 1343 |
|
|
| 1344 |
|
|
| 1345 |
|
// **************************************************** |
| 1346 |
|
/** |
| 1347 |
|
* Function to query the GL_CALOPULSE_CALIB table of the DB. |
| 1348 |
|
* |
| 1349 |
|
* \param run starting time |
| 1350 |
|
* \return struct of type GL_CALOPULSE_CALIB_data, which stores the query result |
| 1351 |
|
*/ |
| 1352 |
|
Int_t GL_CALOPULSE_CALIB::Query_GL_CALOPULSE_CALIB(UInt_t time, UInt_t section, UInt_t pampli, TSQLServer *dbc){ |
| 1353 |
|
// MySQL variables |
| 1354 |
|
TSQLResult *pResult; |
| 1355 |
|
TSQLRow *Row; |
| 1356 |
|
int t; |
| 1357 |
|
stringstream myquery; |
| 1358 |
|
// |
| 1359 |
|
// select the correct calibration i.e. the closest to our time |
| 1360 |
|
// |
| 1361 |
|
myquery.str(""); |
| 1362 |
|
myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT from GL_CALOPULSE_CALIB where SECTION=" << section; |
| 1363 |
|
myquery << " and PULSE_AMPLITUDE=" << pampli; |
| 1364 |
|
myquery << " and VALIDATION=1 and (PULSED_STRIP IS NULL OR PULSED_STRIP<100) ORDER BY ABS(" << time << "-FROM_TIME) asc limit 1;"; |
| 1365 |
|
// printf(" myq is %s \n",myquery.str().c_str()); |
| 1366 |
|
// |
| 1367 |
|
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
| 1368 |
|
this->GetGLTABLES()->AddQ(); |
| 1369 |
|
pResult = dbc->Query(myquery.str().c_str()); |
| 1370 |
|
// |
| 1371 |
|
if( !pResult ) return(-54); |
| 1372 |
|
// |
| 1373 |
|
Row = pResult->Next(); |
| 1374 |
|
// |
| 1375 |
|
if( !Row ) return (-54); |
| 1376 |
|
// |
| 1377 |
|
// store infos and exit |
| 1378 |
|
// |
| 1379 |
|
for( t = 0; t < pResult->GetFieldCount(); t++){ |
| 1380 |
|
// printf(" field %i is %s \n",t,Row->GetField(t)); |
| 1381 |
|
if (t==0) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
| 1382 |
if (t==1) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t==1) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); |
| 1383 |
if (t==2) TO_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t==2) TO_TIME = (UInt_t)atoll(Row->GetField(t)); |
| 1384 |
if (t==3) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); |
if (t==3) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); |
| 1386 |
pResult->Delete(); |
pResult->Delete(); |
| 1387 |
return 0; |
return 0; |
| 1388 |
}; |
}; |
| 1389 |
|
|
| 1390 |
|
|
| 1391 |
// **************************************************** |
// **************************************************** |
| 1392 |
/** |
/** |
| 1393 |
* Function to query the GL_S4_CALIB table of the DB. |
* Function to query the GL_S4_CALIB table of the DB. |
| 1404 |
stringstream myquery; |
stringstream myquery; |
| 1405 |
// ---------------- |
// ---------------- |
| 1406 |
myquery.str(""); |
myquery.str(""); |
| 1407 |
myquery << "select * from GL_S4_CALIB where FROM_TIME <= "<< time; |
myquery << "select ID,ID_ROOT_L0,EV_ROOT,FROM_TIME,TO_TIME from GL_S4_CALIB where FROM_TIME <= "<< time; |
| 1408 |
myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
| 1409 |
// myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
// myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
| 1410 |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
| 1416 |
if( Row == NULL ) break; |
if( Row == NULL ) break; |
| 1417 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
| 1418 |
if (t==0) ID = (UInt_t)atoll(Row->GetField(t)); |
if (t==0) ID = (UInt_t)atoll(Row->GetField(t)); |
| 1419 |
if (t==1) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
if (t==1) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
| 1420 |
if (t==2) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); |
if (t==2) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); |
| 1421 |
if (t==3) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t==3) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); |
| 1422 |
if (t==4) TO_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t==4) TO_TIME = (UInt_t)atoll(Row->GetField(t)); |
|
if (t==5) PARAM_FIT0 = atof(Row->GetField(t)); |
|
|
if (t==6) PARAM_FIT1 = atof(Row->GetField(t)); |
|
| 1423 |
}; |
}; |
| 1424 |
}; |
}; |
| 1425 |
delete pResult; |
delete pResult; |
| 1588 |
TString name=rname.str().c_str(); |
TString name=rname.str().c_str(); |
| 1589 |
UInt_t dworbit = 0; |
UInt_t dworbit = 0; |
| 1590 |
Int_t nlength = name.Length(); |
Int_t nlength = name.Length(); |
|
if ( nlength < 5 ) return; |
|
|
TString dwo = 0; |
|
|
for (Int_t i = 0; i<5; i++){ |
|
|
dwo.Append(name[i],1); |
|
|
}; |
|
|
if ( dwo.IsDigit() ){ |
|
|
dworbit = (UInt_t)dwo.Atoi(); |
|
|
} else { |
|
|
dwo=""; |
|
|
for (Int_t i = 8; i<13; i++){ |
|
|
dwo.Append(name[i],1); |
|
|
}; |
|
|
if ( dwo.IsDigit() ){ |
|
|
dworbit = (UInt_t)dwo.Atoi(); |
|
|
} else { |
|
|
dworbit = 1; |
|
|
}; |
|
|
}; |
|
| 1591 |
// |
// |
| 1592 |
|
// Is not a special file |
| 1593 |
// |
// |
| 1594 |
if ( !Row ){ |
if ( !Row ){ |
| 1595 |
|
delete pResult; |
| 1596 |
|
// |
| 1597 |
|
// New code, we have one more column on GL_TIMESYNC so we can trust that one for the Resurs offset |
| 1598 |
|
// |
| 1599 |
oss.str(""); |
oss.str(""); |
| 1600 |
oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE FROM_ORBIT< " |
oss << "SELECT ID_RESURS_OFFSET from GL_TIMESYNC where ID_RAW=" << idraw <<";"; |
|
<< dworbit << " order by FROM_ORBIT desc limit 1;"; |
|
| 1601 |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; |
| 1602 |
this->GetGLTABLES()->AddQ(); |
this->GetGLTABLES()->AddQ(); |
| 1603 |
pResult = dbc->Query(oss.str().c_str()); |
pResult = dbc->Query(oss.str().c_str()); |
| 1604 |
Row = pResult->Next(); |
Bool_t fndit = false; |
| 1605 |
if ( !Row ){ |
if ( pResult ){ |
| 1606 |
printf(" ERROR FROM GLTables! cannot determine Resurs offset \n"); |
Row = pResult->Next(); |
| 1607 |
return; |
if ( Row ){ |
| 1608 |
|
oss.str(""); |
| 1609 |
|
oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE ID=" |
| 1610 |
|
<< Row->GetField(0) << ";"; |
| 1611 |
|
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; |
| 1612 |
|
this->GetGLTABLES()->AddQ(); |
| 1613 |
|
pResult = dbc->Query(oss.str().c_str()); |
| 1614 |
|
if ( pResult ){ |
| 1615 |
|
Row = pResult->Next(); |
| 1616 |
|
if ( Row ){ |
| 1617 |
|
// printf(" GREAT! the DB structure is the new one! \n"); |
| 1618 |
|
fndit = true; |
| 1619 |
|
dworbit = 1; |
| 1620 |
|
}; |
| 1621 |
|
}; |
| 1622 |
|
}; |
| 1623 |
|
}; |
| 1624 |
|
if ( !fndit ){ |
| 1625 |
|
delete pResult; |
| 1626 |
|
// |
| 1627 |
|
printf(" OK, you got an error because this is the old database\n Using backward compability code, hence you can continue safetly \n"); |
| 1628 |
|
// |
| 1629 |
|
// Old code, we must trust the filename |
| 1630 |
|
// |
| 1631 |
|
if ( nlength < 5 ) return; |
| 1632 |
|
TString dwo = 0; |
| 1633 |
|
for (Int_t i = 0; i<5; i++){ |
| 1634 |
|
dwo.Append(name[i],1); |
| 1635 |
|
}; |
| 1636 |
|
if ( dwo.IsDigit() ){ |
| 1637 |
|
dworbit = (UInt_t)dwo.Atoi(); |
| 1638 |
|
} else { |
| 1639 |
|
dwo=""; |
| 1640 |
|
for (Int_t i = 8; i<13; i++){ |
| 1641 |
|
dwo.Append(name[i],1); |
| 1642 |
|
}; |
| 1643 |
|
if ( dwo.IsDigit() ){ |
| 1644 |
|
dworbit = (UInt_t)dwo.Atoi(); |
| 1645 |
|
} else { |
| 1646 |
|
dworbit = 1; |
| 1647 |
|
}; |
| 1648 |
|
}; |
| 1649 |
|
// |
| 1650 |
|
oss.str(""); |
| 1651 |
|
oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE FROM_ORBIT< " |
| 1652 |
|
<< dworbit << " order by FROM_ORBIT desc limit 1;"; |
| 1653 |
|
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; |
| 1654 |
|
this->GetGLTABLES()->AddQ(); |
| 1655 |
|
pResult = dbc->Query(oss.str().c_str()); |
| 1656 |
|
Row = pResult->Next(); |
| 1657 |
|
if ( !Row ){ |
| 1658 |
|
printf(" ERROR FROM GLTables! cannot determine Resurs offset \n"); |
| 1659 |
|
return; |
| 1660 |
|
}; |
| 1661 |
}; |
}; |
| 1662 |
}; |
}; |
| 1663 |
// |
// |
| 1732 |
*/ |
*/ |
| 1733 |
Long64_t GL_TIMESYNC::DBobt(UInt_t obt){ |
Long64_t GL_TIMESYNC::DBobt(UInt_t obt){ |
| 1734 |
// |
// |
| 1735 |
if ( obt < (obtfirst/2) && obtfirst > (numeric_limits<UInt_t>::max()/2) ) return((Long64_t)(obt+numeric_limits<UInt_t>::max())); |
if ( obt < (obtfirst/2) && obtfirst > (numeric_limits<UInt_t>::max()/2) ){ |
| 1736 |
|
return((Long64_t)obt+(Long64_t)numeric_limits<UInt_t>::max()); |
| 1737 |
|
}; |
| 1738 |
// |
// |
| 1739 |
if ( obt > (obtfirst*2) && obt > (numeric_limits<UInt_t>::max()/2) ){ |
if ( obt > (obtfirst*2) && obt > (numeric_limits<UInt_t>::max()/2) ){ |
| 1740 |
return((Long64_t)obt-(Long64_t)numeric_limits<UInt_t>::max()); |
return((Long64_t)obt-(Long64_t)numeric_limits<UInt_t>::max()); |
| 1956 |
TSQLRow *row; |
TSQLRow *row; |
| 1957 |
|
|
| 1958 |
// Set the right time_zone (otherwise horrible things will occur! :) |
// Set the right time_zone (otherwise horrible things will occur! :) |
| 1959 |
|
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
| 1960 |
dbc->Query("SET time_zone = '+0:00'"); |
dbc->Query("SET time_zone = '+0:00'"); |
| 1961 |
|
|
| 1962 |
// Do the query |
// Do the query |
|
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
|
| 1963 |
this->GetGLTABLES()->AddQ(); |
this->GetGLTABLES()->AddQ(); |
| 1964 |
result = dbc->Query(myquery.Data()); |
result = dbc->Query(myquery.Data()); |
| 1965 |
if(! result->GetRowCount() ) { |
if(! result->GetRowCount() ) { |