--- YodaProfiler/src/GLTables.cpp 2007/10/19 07:48:18 1.33 +++ YodaProfiler/src/GLTables.cpp 2008/03/07 13:24:24 1.39 @@ -24,6 +24,7 @@ ClassImp(GL_PARAM); ClassImp(GL_S4_CALIB); ClassImp(GL_CALO_CALIB); +ClassImp(GL_CALOPULSE_CALIB); ClassImp(GL_TIMESYNC); ClassImp(GL_TLE); // @@ -63,8 +64,6 @@ return true; }; // - // - // // printf(" host is %s \n",fHost->Data()); // stringstream myquery; @@ -85,7 +84,7 @@ }; }; }; - // printf("porca di quella \n"); + // if ( true ) { // printf(" WARNING: Lost connection to DB! try to recover... \n"); @@ -93,6 +92,7 @@ TString host = fHost->Data(); TString user = fUser->Data(); TString psw = fPsw->Data(); + dbc->Close(); delete dbc; dbc = TSQLServer::Connect(host.Data(),user.Data(),psw.Data()); // @@ -100,8 +100,6 @@ myquery << "show databases;"; dbc->Query(myquery.str().c_str()); fNquery++; - // printf(" e riporca di quella \n"); - // // if ( dbc->GetErrorCode() != 2013 && dbc->GetErrorCode() != 2006 ){ if ( !(dbc->GetErrorCode()) ){ // @@ -174,7 +172,7 @@ } -void GL_RUN::Clear() { +void GL_RUN::Clear(Option_t *t) { ID = 0; ID_RUN_FRAG = 0; ID_ROOT_L0 = 0; @@ -249,6 +247,25 @@ FROM_TIME = 0; TO_TIME = 0; SECTION = 0; + OBT = 0; + PKT = 0; + BOOT_NUMBER = 0; + VALIDATION = 0; +} + +GL_CALOPULSE_CALIB::GL_CALOPULSE_CALIB(){ + ID = 0; + ID_ROOT_L0 = 0; + EV_ROOT = 0; + FROM_TIME = 0; + TO_TIME = 0; + SECTION = 0; + PULSED_STRIP = 0; + PULSE_AMPLITUDE = 0; + OBT = 0; + PKT = 0; + BOOT_NUMBER = 0; + VALIDATION = 0; } GL_S4_CALIB::GL_S4_CALIB(){ @@ -257,8 +274,9 @@ EV_ROOT = 0; FROM_TIME = 0; TO_TIME = 0; - PARAM_FIT0 = 0.; - PARAM_FIT1 = 0.; + OBT = 0; + PKT = 0; + BOOT_NUMBER = 0; } GL_TIMESYNC::GL_TIMESYNC(){ @@ -1262,6 +1280,9 @@ // uptime = (UInt_t)atoll(Row->GetField(2)); // + UInt_t myfromtime = (UInt_t)atoll(Row->GetField(1)); + UInt_t mytotime = (UInt_t)atoll(Row->GetField(2)); + // // if it is corrupted validation is 0 and we have no results from the query... // if( atoi(Row->GetField(4)) == 0 ){ // if validation = 0 @@ -1283,6 +1304,28 @@ // Row = pResult->Next(); // + myfromtime = (UInt_t)atoll(Row->GetField(1)); + // + }; + // + // if the selected calibration is too old (more than 5 orbits old) try to take the closest not corrupted one + // + if ( (time-myfromtime)>28500 ){ + // + myquery.str(""); + myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT from GL_CALO_CALIB where SECTION=" << section; + myquery << " and VALIDATION=1 ORDER BY ABS(" << time << "-FROM_TIME) asc limit 1;"; + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); + pResult = dbc->Query(myquery.str().c_str()); + // printf(" mysquery is %s\n",myquery.str().c_str()); + // + // if no results yet quit with error + // + if( !pResult->GetRowCount() ) return (-54); + // + Row = pResult->Next(); + // }; // // store infos and exit @@ -1290,6 +1333,52 @@ if( Row == NULL ) return (-54); for( t = 0; t < pResult->GetFieldCount(); t++){ if (t==0) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); + if (t==1) FROM_TIME = myfromtime; + if (t==2) TO_TIME = mytotime; + if (t==3) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); + }; + pResult->Delete(); + return 0; +}; + + +// **************************************************** +/** + * Function to query the GL_CALOPULSE_CALIB table of the DB. + * + * \param run starting time + * \return struct of type GL_CALOPULSE_CALIB_data, which stores the query result + */ +Int_t GL_CALOPULSE_CALIB::Query_GL_CALOPULSE_CALIB(UInt_t time, UInt_t section, UInt_t pampli, TSQLServer *dbc){ + // MySQL variables + TSQLResult *pResult; + TSQLRow *Row; + int t; + stringstream myquery; + // + // select the correct calibration i.e. the closest to our time + // + myquery.str(""); + myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT from GL_CALOPULSE_CALIB where SECTION=" << section; + myquery << " and PULSE_AMPLITUDE=" << pampli; + myquery << " and VALIDATION=1 and (PULSED_STRIP IS NULL OR PULSED_STRIP<100) ORDER BY ABS(" << time << "-FROM_TIME) asc limit 1;"; + // printf(" myq is %s \n",myquery.str().c_str()); + // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); + pResult = dbc->Query(myquery.str().c_str()); + // + if( !pResult ) return(-54); + // + Row = pResult->Next(); + // + if( !Row ) return (-54); + // + // store infos and exit + // + for( t = 0; t < pResult->GetFieldCount(); t++){ + // printf(" field %i is %s \n",t,Row->GetField(t)); + if (t==0) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); if (t==1) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); if (t==2) TO_TIME = (UInt_t)atoll(Row->GetField(t)); if (t==3) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); @@ -1297,6 +1386,8 @@ pResult->Delete(); return 0; }; + + // **************************************************** /** * Function to query the GL_S4_CALIB table of the DB. @@ -1313,7 +1404,7 @@ stringstream myquery; // ---------------- myquery.str(""); - 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; myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; // myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; @@ -1325,12 +1416,10 @@ if( Row == NULL ) break; for( t = 0; t < pResult->GetFieldCount(); t++){ if (t==0) ID = (UInt_t)atoll(Row->GetField(t)); - if (t==1) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); - if (t==2) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); - if (t==3) FROM_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)); + if (t==1) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); + if (t==2) EV_ROOT = (UInt_t)atoll(Row->GetField(t)); + if (t==3) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); + if (t==4) TO_TIME = (UInt_t)atoll(Row->GetField(t)); }; }; delete pResult; @@ -1616,7 +1705,7 @@ */ UInt_t GL_TIMESYNC::ResursTime(UInt_t OBT){ // - return(((UInt_t)((Int_t)(this->DBobt(OBT)-this->DBobt(OBT0))/1000)+TIMESYNC)); + return(((UInt_t)((Int_t)(this->DBobt(OBT)-this->DBobt(OBT0)/1000))+TIMESYNC)); // }; @@ -1643,7 +1732,9 @@ */ Long64_t GL_TIMESYNC::DBobt(UInt_t obt){ // - if ( obt < (obtfirst/2) && obtfirst > (numeric_limits::max()/2) ) return((Long64_t)(obt+numeric_limits::max())); + if ( obt < (obtfirst/2) && obtfirst > (numeric_limits::max()/2) ){ + return((Long64_t)obt+(Long64_t)numeric_limits::max()); + }; // if ( obt > (obtfirst*2) && obt > (numeric_limits::max()/2) ){ return((Long64_t)obt-(Long64_t)numeric_limits::max());