|
|
|
#include <DTHVStatusHandler.h>
Public Member Functions | |
| DTHVStatusHandler (const edm::ParameterSet &ps) | |
| void | getNewObjects () |
| std::string | id () const |
| virtual | ~DTHVStatusHandler () |
Private Types | |
| typedef std::pair< int, float > | channelValue |
| typedef DTHVAbstractCheck::timedMeasurement | timedMeasurement |
Private Member Functions | |
| int | checkForPeriod (cond::Time_t condSince, cond::Time_t condUntil, int &missingChannels, bool copyOffline) |
| void | checkNewData () |
| int | checkStatusChange (int type, float oldValue, float newValue) |
| void | copyHVData () |
| void | createSnapshot () |
| void | dumpHVAliases () |
| void | dumpSnapshot (const coral::TimeStamp &time) |
| void | filterData () |
| void | getChannelMap () |
| void | getChannelSplit () |
| void | getLayerSplit () |
| void | getLayerValues (int rawId, int type, float &valueL, float &valueR, float &valueS, float &valueC) |
| DTHVStatus * | offlineList () |
| cond::Time_t | recoverLastTime () |
| int | recoverSnapshot () |
| void | setChannelFlag (DTHVStatus *hv, int whe, int sta, int sec, int qua, int lay, int l_p, const DTHVAbstractCheck::flag &flag) |
| void | updateHVStatus () |
Static Private Member Functions | |
| static cond::Time_t | condTime (const coral::TimeStamp &time) |
| static cond::Time_t | condTime (long long int time) |
| static coral::TimeStamp | coralTime (const cond::Time_t &time) |
| static DTWireId | layerId (int rawId, int l_p) |
Private Attributes | |
| std::map< int, int > | aliasMap |
| cond::DbConnection | buff_conn |
| cond::DbSession | buff_session |
| std::string | bufferConnect |
| long long int | bwdTime |
| std::map< int, std::vector < int > * > | channelSplit |
| std::string | dataTag |
| int | dSince |
| bool | dumpAtEnd |
| bool | dumpAtStart |
| int | dUntil |
| long long int | fwdTime |
| int | hSince |
| int | hUntil |
| DTHVAbstractCheck * | hvChecker |
| cond::Time_t | lastFound |
| long long int | lastStamp |
| DTHVStatus * | lastStatus |
| std::map< int, int > | layerMap |
| std::map< int, int > | laySplit |
| std::string | mapVersion |
| int | maxPayload |
| long long int | minTime |
| int | mSince |
| int | mUntil |
| cond::Time_t | nextFound |
| cond::DbConnection | omds_conn |
| cond::DbSession | omds_session |
| std::string | onlineAuthentication |
| std::string | onlineConnect |
| cond::Time_t | procSince |
| cond::Time_t | procUntil |
| int | pSince |
| int | pUntil |
| std::map< int, timedMeasurement > | snapshotValues |
| std::string | splitVersion |
| int | sSince |
| int | sUntil |
| bool | switchOff |
| cond::Time_t | timeLimit |
| std::vector< std::pair < DTHVStatus *, cond::Time_t > > | tmpContainer |
| cond::DbConnection | util_conn |
| cond::DbSession | util_session |
| std::string | utilConnect |
| int | ySince |
| int | yUntil |
Description: Class to copy HV status via PopCon
Definition at line 41 of file DTHVStatusHandler.h.
typedef std::pair<int,float> DTHVStatusHandler::channelValue [private] |
Definition at line 62 of file DTHVStatusHandler.h.
typedef DTHVAbstractCheck::timedMeasurement DTHVStatusHandler::timedMeasurement [private] |
Definition at line 61 of file DTHVStatusHandler.h.
| DTHVStatusHandler::DTHVStatusHandler | ( | const edm::ParameterSet & | ps | ) |
Constructor
Definition at line 54 of file DTHVStatusHandler.cc.
References gather_cfg::cout, DTHVAbstractCheck::getInstance(), hvChecker, maxPayload, and onlineAuthentication.
: dataTag( ps.getParameter<std::string> ( "tag" ) ), onlineConnect( ps.getParameter<std::string> ( "onlineDB" ) ), utilConnect( ps.getParameter<std::string> ( "utilDB" ) ), onlineAuthentication( ps.getParameter<std::string> ( "onlineAuthentication" ) ), bufferConnect( ps.getParameter<std::string> ( "bufferDB" ) ), ySince( ps.getParameter<int> ( "sinceYear" ) ), mSince( ps.getParameter<int> ( "sinceMonth" ) ), dSince( ps.getParameter<int> ( "sinceDay" ) ), hSince( ps.getParameter<int> ( "sinceHour" ) ), pSince( ps.getParameter<int> ( "sinceMinute" ) ), sSince( ps.getParameter<int> ( "sinceSecond" ) ), yUntil( ps.getParameter<int> ( "untilYear" ) ), mUntil( ps.getParameter<int> ( "untilMonth" ) ), dUntil( ps.getParameter<int> ( "untilDay" ) ), hUntil( ps.getParameter<int> ( "untilHour" ) ), pUntil( ps.getParameter<int> ( "untilMinute" ) ), sUntil( ps.getParameter<int> ( "untilSecond" ) ), dumpAtStart( ps.getParameter<bool>( "dumpAtStart" ) ), dumpAtEnd( ps.getParameter<bool>( "dumpAtEnd" ) ), bwdTime( ps.getParameter<long long int> ( "bwdTime" ) ), fwdTime( ps.getParameter<long long int> ( "fwdTime" ) ), minTime( ps.getParameter<long long int> ( "minTime" ) ), omds_conn(), util_conn(), buff_conn(), omds_session(), util_session(), buff_session(), mapVersion( ps.getParameter<std::string> ( "mapVersion" ) ), splitVersion( ps.getParameter<std::string> ( "splitVersion" ) ) { std::cout << " PopCon application for DT HV data export " << onlineAuthentication << std::endl; hvChecker = DTHVAbstractCheck::getInstance(); maxPayload = 1000; }
| DTHVStatusHandler::~DTHVStatusHandler | ( | ) | [virtual] |
| int DTHVStatusHandler::checkForPeriod | ( | cond::Time_t | condSince, |
| cond::Time_t | condUntil, | ||
| int & | missingChannels, | ||
| bool | copyOffline | ||
| ) | [private] |
Definition at line 879 of file DTHVStatusHandler.cc.
References DTHVStatus::begin(), checkStatusChange(), condTime(), cont, coralTime(), gather_cfg::cout, DTHVStatus::end(), lastFound, lastStamp, maxPayload, minTime, nextFound, cond::DbSession::nominalSchema(), offlineList(), omds_session, procUntil, snapshotValues, timeLimit, and tmpContainer.
Referenced by copyHVData(), and updateHVStatus().
{
std::map<int,timedMeasurement>::iterator mapIter = snapshotValues.begin();
std::map<int,timedMeasurement>::iterator mapIend = snapshotValues.end();
std::map<long long int,channelValue> periodBuffer;
coral::ITable& fwccTable =
omds_session.nominalSchema().tableHandle( "FWCAENCHANNEL" );
std::auto_ptr<coral::IQuery> fwccQuery( fwccTable.newQuery() );
fwccQuery->addToOutputList( "DPID" );
fwccQuery->addToOutputList( "CHANGE_DATE" );
fwccQuery->addToOutputList( "ACTUAL_VMON" );
fwccQuery->addToOutputList( "ACTUAL_IMON" );
fwccQuery->addToOutputList( "ACTUAL_ISON" );
fwccQuery->addToOutputList( "ACTUAL_STATUS" );
fwccQuery->addToOutputList( "ACTUAL_OVC" );
coral::AttributeList timeBindVariableList;
timeBindVariableList.extend( "since", typeid(coral::TimeStamp) );
timeBindVariableList.extend( "until", typeid(coral::TimeStamp) );
coral::TimeStamp coralSince = coralTime( condSince );
coral::TimeStamp coralUntil = coralTime( condUntil );
std::cout << "look for data since "
<< coralSince.year( ) << " "
<< coralSince.month( ) << " "
<< coralSince.day( ) << " "
<< coralSince.hour( ) << ":"
<< coralSince.minute() << ":"
<< coralSince.second() << " until "
<< coralUntil.year( ) << " "
<< coralUntil.month( ) << " "
<< coralUntil.day( ) << " "
<< coralUntil.hour( ) << ":"
<< coralUntil.minute() << ":"
<< coralUntil.second() << std::endl;
timeBindVariableList["since"].data<coral::TimeStamp>() =
coralTime( condSince );
timeBindVariableList["until"].data<coral::TimeStamp>() =
coralTime( condUntil );
fwccQuery->setCondition( "CHANGE_DATE>:since and CHANGE_DATE<:until",
timeBindVariableList );
fwccQuery->addToOrderList( "CHANGE_DATE" );
coral::ICursor& fwccCursor = fwccQuery->execute();
int nrows = 0;
while ( fwccCursor.next() ) {
nrows++;
const coral::Attribute& dp = fwccCursor.currentRow()["DPID" ];
const coral::Attribute& vmon = fwccCursor.currentRow()["ACTUAL_VMON" ];
const coral::Attribute& imon = fwccCursor.currentRow()["ACTUAL_IMON" ];
coral::TimeStamp changeTime =
fwccCursor.currentRow()["CHANGE_DATE"].data<coral::TimeStamp>();
long long int cTimeValue = changeTime.total_nanoseconds();
if ( !copyOffline ) cTimeValue = -cTimeValue;
if ( dp.isNull() ) {
std::cout << "------- " << nrows << std::endl;
continue;
}
int dpId = 10 * static_cast<int>( 0.01 +
fwccCursor.currentRow()["DPID"].data<float>() );
if ( !( vmon.isNull() ) ) {
while ( periodBuffer.find( cTimeValue ) !=
periodBuffer.end() ) cTimeValue++;
int chan = dpId + 1;
periodBuffer.insert( std::pair<long long int,channelValue> (
cTimeValue, channelValue( chan,
vmon.data<float>() ) ) );
}
if ( !( imon.isNull() ) ) {
while ( periodBuffer.find( cTimeValue ) !=
periodBuffer.end() ) cTimeValue++;
int chan = dpId + 2;
periodBuffer.insert( std::pair<long long int,channelValue> (
cTimeValue, channelValue( chan,
imon.data<float>() ) ) );
}
}
long long int dTime = minTime;
dTime <<= 32;
std::cout << "data found in period: " << periodBuffer.size() << std::endl;
std::map<long long int,channelValue>::const_iterator bufIter =
periodBuffer.begin();
std::map<long long int,channelValue>::const_iterator bufIend =
periodBuffer.end();
bool changedStatus = false;
while ( bufIter != bufIend ) {
const std::pair<long long int,channelValue>& entry = *bufIter++;
long long int mTime = entry.first;
if ( !copyOffline ) mTime = -mTime;
channelValue cValue = entry.second;
int chan = cValue.first;
float cont = cValue.second;
mapIter = snapshotValues.find( chan );
if ( ( mapIter != mapIend ) &&
( mapIter->second.first < mTime ) ) {
nextFound = condTime( mTime );
if ( changedStatus ) {
if ( nextFound > timeLimit ) {
DTHVStatus* hvStatus = offlineList();
std::cout << "new payload "
<< hvStatus->end() - hvStatus->begin() << std::endl;
tmpContainer.push_back( std::make_pair( hvStatus, lastFound ) );
changedStatus = false;
if ( !( --maxPayload ) ) {
procUntil = lastFound;
std::cout << "max payload number reached" << std::endl;
break;
}
}
}
if ( copyOffline && !changedStatus &&
checkStatusChange( chan, mapIter->second.second, cont ) ) {
timeLimit = nextFound + dTime;
changedStatus = true;
}
mapIter->second = timedMeasurement( lastStamp = mTime, cont );
lastFound = nextFound;
missingChannels--;
}
}
std::cout << nrows << std::endl;
return nrows;
}
| void DTHVStatusHandler::checkNewData | ( | ) | [private] |
Definition at line 240 of file DTHVStatusHandler.cc.
References buff_session, coralTime(), gather_cfg::cout, createSnapshot(), getChannelMap(), getChannelSplit(), getLayerSplit(), cond::DbSession::nominalSchema(), omds_session, procSince, procUntil, AlCaHLTBitMon_QueryRunRegistry::string, updateHVStatus(), and util_session.
Referenced by getNewObjects().
{
//to access the information on last successful log entry for this tag:
// cond::LogDBEntry const & lde = logDBEntry();
//to access the lastest payload (Ref is a smart pointer)
// Ref payload = lastPayload();
std::cout << "check for new data since "
<< procSince << " "
<< coralTime( procSince ).total_nanoseconds() << " "
<< coralTime( procSince ).year( ) << " "
<< coralTime( procSince ).month( ) << " "
<< coralTime( procSince ).day( ) << " "
<< coralTime( procSince ).hour( ) << " "
<< coralTime( procSince ).minute() << " "
<< coralTime( procSince ).second() << std::endl;
std::cout << " until "
<< procUntil << " "
<< coralTime( procUntil ).total_nanoseconds() << " "
<< coralTime( procUntil ).year( ) << " "
<< coralTime( procUntil ).month( ) << " "
<< coralTime( procUntil ).day( ) << " "
<< coralTime( procUntil ).hour( ) << " "
<< coralTime( procUntil ).minute() << " "
<< coralTime( procUntil ).second() << std::endl;
std::set<std::string> omds_lt( omds_session.nominalSchema().listTables() );
std::set<std::string>::const_iterator omds_iter = omds_lt.begin();
std::set<std::string>::const_iterator omds_iend = omds_lt.end();
while ( omds_iter != omds_iend ) {
const std::string& istr = *omds_iter++;
std::cout << "TABLE: " << istr << std::endl;
}
std::set<std::string> util_lt( util_session.nominalSchema().listTables() );
std::set<std::string>::const_iterator util_iter = util_lt.begin();
std::set<std::string>::const_iterator util_iend = util_lt.end();
while ( util_iter != util_iend ) {
const std::string& istr = *util_iter++;
std::cout << "TABLE: " << istr << std::endl;
}
getLayerSplit();
getChannelMap();
getChannelSplit();
std::cout << "open buffer db..." << std::endl;
if ( !( buff_session.nominalSchema().existsTable( "HVSNAPSHOT" ) ) )
createSnapshot();
updateHVStatus();
return;
}
| int DTHVStatusHandler::checkStatusChange | ( | int | type, |
| float | oldValue, | ||
| float | newValue | ||
| ) | [private] |
Definition at line 1220 of file DTHVStatusHandler.cc.
References aliasMap, DTHVAbstractCheck::checkCurrentStatus(), DTHVAbstractCheck::compare(), gather_cfg::cout, getLayerValues(), hvChecker, layerId(), layerMap, snapshotValues, and DTWireId::wire().
Referenced by checkForPeriod().
{
int dpId = chan / 10;
int type = chan % 10;
std::map<int,int>::const_iterator aliasIter = aliasMap.find( dpId );
std::map<int,int>::const_iterator aliasIend = aliasMap.end();
if ( aliasIter == aliasIend ) return false;
int rawId = aliasIter->second;
DTWireId chlId( rawId );
int l_p = chlId.wire();
float valueL = 0.0;
float valueR = 0.0;
float valueS = 0.0;
float valueC = 0.0;
getLayerValues( rawId, type, valueL, valueR, valueS, valueC );
// std::cout << "layer values: " << type << " " << valueL << " "
// << valueR << " "
// << valueS << " "
// << valueC << std::endl;
DTHVAbstractCheck::flag
oldStatusL = hvChecker->checkCurrentStatus( layerId( rawId, 0 ).rawId(),
type,
valueL, valueC, valueS,
snapshotValues,
aliasMap, layerMap );
DTHVAbstractCheck::flag
oldStatusR = hvChecker->checkCurrentStatus( layerId( rawId, 1 ).rawId(),
type,
valueR, valueC, valueS,
snapshotValues,
aliasMap, layerMap );
switch ( l_p ) {
case 10:
if ( valueL != oldValue ) std::cout << "*** INCONSISTENT DATA!!!!! "
<< type << " " << l_p << " "
<< oldValue << " " << valueL << " "
<< std::endl;
valueL = newValue;
break;
case 11:
if ( valueR != oldValue ) std::cout << "*** INCONSISTENT DATA!!!!! "
<< type << " " << l_p << " "
<< oldValue << " " << valueR << " "
<< std::endl;
valueR = newValue;
break;
case 12:
if ( valueS != oldValue ) std::cout << "*** INCONSISTENT DATA!!!!! "
<< type << " " << l_p << " "
<< oldValue << " " << valueS << " "
<< std::endl;
valueS = newValue;
break;
case 13:
if ( valueC != oldValue ) std::cout << "*** INCONSISTENT DATA!!!!! "
<< type << " " << l_p << " "
<< oldValue << " " << valueC << " "
<< std::endl;
valueC = newValue;
break;
default:
break;
}
DTHVAbstractCheck::flag
newStatusL = hvChecker->checkCurrentStatus( layerId( rawId, 0 ).rawId(),
type,
valueL, valueC, valueS,
snapshotValues,
aliasMap, layerMap );
DTHVAbstractCheck::flag
newStatusR = hvChecker->checkCurrentStatus( layerId( rawId, 1 ).rawId(),
type,
valueR, valueC, valueS,
snapshotValues,
aliasMap, layerMap );
if ( DTHVAbstractCheck::compare( newStatusL, oldStatusL ) &&
DTHVAbstractCheck::compare( newStatusR, oldStatusR ) ) return 0;
std::cout << "changed status: " << chan << " from "
<< oldValue << " to " << newValue << std::endl;
return 1;
}
| cond::Time_t DTHVStatusHandler::condTime | ( | const coral::TimeStamp & | time | ) | [static, private] |
Definition at line 1408 of file DTHVStatusHandler.cc.
Referenced by checkForPeriod(), getNewObjects(), and recoverLastTime().
{
cond::Time_t cTime = ( ( time.total_nanoseconds() / 1000000000 ) << 32 ) +
( ( time.total_nanoseconds() % 1000000000 ) / 1000 );
return cTime;
}
| cond::Time_t DTHVStatusHandler::condTime | ( | long long int | time | ) | [static, private] |
Definition at line 1415 of file DTHVStatusHandler.cc.
{
cond::Time_t cTime = ( ( time / 1000000000 ) << 32 ) +
( ( time % 1000000000 ) / 1000 );
return cTime;
}
| void DTHVStatusHandler::copyHVData | ( | ) | [private] |
Definition at line 1010 of file DTHVStatusHandler.cc.
References checkForPeriod(), gather_cfg::cout, filterData(), fwdTime, lastFound, lastStatus, popcon::PopConSourceHandler< DTHVStatus >::m_to_transfer, maxPayload, offlineList(), procSince, procUntil, and switchOff.
Referenced by updateHVStatus().
{
long long int dTime = fwdTime;
dTime <<= 32;
cond::Time_t condSince = procSince;
cond::Time_t condUntil = condSince + dTime;
if ( condUntil > procUntil ) condUntil = procUntil;
int dum = 0;
lastStatus = 0;
while ( condSince < condUntil ) {
checkForPeriod( condSince, condUntil, dum, true );
condSince = condUntil;
condUntil = condSince + dTime;
if ( condUntil > procUntil ) condUntil = procUntil;
}
std::cout << "call filterData " << std::endl;
filterData();
std::cout << "filterData return "
<< switchOff << " "
<< lastFound << " "
<< maxPayload << " "
<< m_to_transfer.size() << std::endl;
if ( switchOff || ( ( lastFound != 0 ) && ( maxPayload > 0 ) ) ) {
DTHVStatus* hvStatus = offlineList();
m_to_transfer.push_back( std::make_pair( hvStatus, lastFound ) );
}
return;
}
| coral::TimeStamp DTHVStatusHandler::coralTime | ( | const cond::Time_t & | time | ) | [static, private] |
Definition at line 1400 of file DTHVStatusHandler.cc.
Referenced by checkForPeriod(), checkNewData(), getNewObjects(), and updateHVStatus().
| void DTHVStatusHandler::createSnapshot | ( | ) | [private] |
Definition at line 577 of file DTHVStatusHandler.cc.
References aliasMap, buff_session, gather_cfg::cout, DTLayerId::layer(), cond::DbSession::nominalSchema(), DTChamberId::sector(), DTChamberId::station(), DTSuperLayerId::superLayer(), DTChamberId::wheel(), and DTWireId::wire().
Referenced by checkNewData().
{
std::cout << "create snapshot description..." << std::endl;
coral::TableDescription hvssDesc;
hvssDesc.setName( "HVSNAPSHOT" );
hvssDesc.insertColumn( "TIME",
coral::AttributeSpecification::typeNameForId(
typeid(coral::TimeStamp) ) );
hvssDesc.insertColumn( "WHEEL",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
hvssDesc.insertColumn( "STATION",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
hvssDesc.insertColumn( "SECTOR",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
hvssDesc.insertColumn( "SUPERLAYER",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
hvssDesc.insertColumn( "LAYER",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
hvssDesc.insertColumn( "CHAN",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
hvssDesc.insertColumn( "TYPE",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
hvssDesc.insertColumn( "VALUE",
coral::AttributeSpecification::typeNameForId(
typeid(float) ) );
std::cout << "create snapshot table..." << std::endl;
buff_session.nominalSchema().createTable( hvssDesc );
coral::ITable& bufferTable =
buff_session.nominalSchema().tableHandle( "HVSNAPSHOT" );
coral::AttributeList newMeas;
newMeas.extend( "TIME", typeid(coral::TimeStamp) );
newMeas.extend( "WHEEL", typeid(int) );
newMeas.extend( "STATION", typeid(int) );
newMeas.extend( "SECTOR", typeid(int) );
newMeas.extend( "SUPERLAYER", typeid(int) );
newMeas.extend( "LAYER", typeid(int) );
newMeas.extend( "CHAN", typeid(int) );
newMeas.extend( "TYPE", typeid(int) );
newMeas.extend( "VALUE", typeid(float) );
long long int zeroTime = 0LL;
newMeas["TIME" ].data<coral::TimeStamp>() =
coral::TimeStamp( zeroTime );
newMeas["VALUE" ].data<float>() = -999999.0;
std::map<int,int>::const_iterator iter = aliasMap.begin();
std::map<int,int>::const_iterator iend = aliasMap.end();
while ( iter != iend ) {
const std::pair<int,int>& entry= *iter++;
int detId = entry.second;
DTWireId chlId( detId );
newMeas["WHEEL" ].data<int>() = chlId.wheel ();
newMeas["STATION" ].data<int>() = chlId.station ();
newMeas["SECTOR" ].data<int>() = chlId.sector ();
newMeas["SUPERLAYER"].data<int>() = chlId.superLayer();
newMeas["LAYER" ].data<int>() = chlId.layer ();
newMeas["CHAN" ].data<int>() = chlId.wire () - 10;
int itype;
for ( itype = 1; itype <= 2; itype++ ) {
newMeas["TYPE" ].data<int>() = itype;
bufferTable.dataEditor().insertRow( newMeas );
}
}
std::cout << "create logging info..." << std::endl;
if ( buff_session.nominalSchema().existsTable( "LOG" ) )
buff_session.nominalSchema(). dropTable( "LOG" );
coral::TableDescription infoDesc;
infoDesc.setName( "LOG" );
infoDesc.insertColumn( "EXECTIME",
coral::AttributeSpecification::typeNameForId(
typeid(coral::TimeStamp) ) );
infoDesc.insertColumn( "SNAPSHOT",
coral::AttributeSpecification::typeNameForId(
typeid(coral::TimeStamp) ) );
buff_session.nominalSchema().createTable( infoDesc );
coral::AttributeList newInfo;
newInfo.extend( "EXECTIME", typeid(coral::TimeStamp) );
newInfo.extend( "SNAPSHOT", typeid(coral::TimeStamp) );
newInfo["EXECTIME"].data<coral::TimeStamp>() =
coral::TimeStamp( zeroTime );
newInfo["SNAPSHOT"].data<coral::TimeStamp>() =
coral::TimeStamp( zeroTime );
coral::ITable& infoTable =
buff_session.nominalSchema().tableHandle( "LOG" );
infoTable.dataEditor().insertRow( newInfo );
return;
}
| void DTHVStatusHandler::dumpHVAliases | ( | ) | [private] |
Definition at line 447 of file DTHVStatusHandler.cc.
References aliasMap, buff_session, gather_cfg::cout, layerMap, cond::DbSession::nominalSchema(), omds_session, DetId::rawId(), and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by getChannelMap().
{
std::cout << "DTHVStatusHandler::dumpHVAliases - begin" << std::endl;
std::cout << "create aliases description..." << std::endl;
coral::TableDescription hvalDesc;
hvalDesc.setName( "HVALIASES" );
hvalDesc.insertColumn( "DETID",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
hvalDesc.insertColumn( "DPID",
coral::AttributeSpecification::typeNameForId(
typeid(int) ) );
std::cout << "create aliases table..." << std::endl;
coral::ITable& hvalTable =
buff_session.nominalSchema().createTable( hvalDesc );
std::cout << "open DPNAME table..." << std::endl;
std::map<int,std::string> idMap;
coral::ITable& dpidTable =
omds_session.nominalSchema().tableHandle( "DP_NAME2ID" );
std::auto_ptr<coral::IQuery> dpidQuery( dpidTable.newQuery() );
dpidQuery->addToOutputList( "ID" );
dpidQuery->addToOutputList( "DPNAME" );
coral::ICursor& dpidCursor = dpidQuery->execute();
while( dpidCursor.next() ) {
const coral::AttributeList& row = dpidCursor.currentRow();
int id = static_cast<int>( 0.01 +
row["ID" ].data<float>() );
std::string dp = row["DPNAME"].data<std::string>();
idMap.insert( std::pair<int,std::string>( id, dp ) );
}
std::cout << "DPNAME table read... " << idMap.size() << std::endl;
std::cout << "open ALIASES table..." << std::endl;
std::map<std::string,std::string> cnMap;
coral::ITable& nameTable =
omds_session.nominalSchema().tableHandle( "ALIASES" );
std::auto_ptr<coral::IQuery> nameQuery( nameTable.newQuery() );
nameQuery->addToOutputList( "DPE_NAME" );
nameQuery->addToOutputList( "ALIAS" );
coral::ICursor& nameCursor = nameQuery->execute();
while( nameCursor.next() ) {
const coral::AttributeList& row = nameCursor.currentRow();
std::string dp = row["DPE_NAME"].data<std::string>();
std::string an = row["ALIAS" ].data<std::string>();
if ( an.length() < 20 ) continue;
cnMap.insert( std::pair<std::string,std::string>( dp, an ) );
}
std::cout << "ALIASES table read... " << cnMap.size() << std::endl;
std::map<int,std::string>::const_iterator idIter = idMap.begin();
std::map<int,std::string>::const_iterator idIend = idMap.end();
std::string outChk( "/outputChannel" );
while ( idIter != idIend ) {
const std::pair<int,std::string>& ientry = *idIter++;
int dpId = ientry.first;
std::string dp = ientry.second;
int ldp = dp.length();
if ( ldp < 20 ) continue;
std::string subOut( dp.substr( ldp - 17, 17 ) );
std::string subChk( subOut.substr( 0, 14 ) );
if ( subChk != outChk ) continue;
std::string chName( dp.substr( 0, ldp - 17 ) );
chName += ".actual.OvC";
int chCode = subOut.c_str()[16] - '0';
std::map<std::string,std::string>::const_iterator jter =
cnMap.find( chName );
if ( jter == cnMap.end() ) continue;
const std::pair<std::string,std::string>& jentry = *jter;
std::cout << dp << std::endl << chName << " " << chCode << std::endl;
std::string an( jentry.second );
int al = an.length();
int iofw = 7 + an.find( "DT_HV_W", 0 );
int iofc = 3 + an.find( "_MB", 0 );
int iofs = 2 + an.find( "_S" , 0 );
int iofq = 3 + an.find( "_SL", 0 );
int iofl = 2 + an.find( "_L" , 0 );
if ( ( iofw == al ) ||
( iofc == al ) ||
( iofs == al ) ||
( iofq == al ) ||
( iofl == al ) ) {
break;
}
int ioew = an.find( "_", iofw );
int ioec = an.find( "_", iofc );
int ioes = an.find( "_", iofs );
int ioeq = an.find( "_", iofq );
int ioel = an.find( "_", iofl );
std::string swhe( an.substr( iofw, ioew - iofw ) );
const char* cwhe = swhe.c_str();
int whe = cwhe[1] - '0';
if ( *cwhe != 'P' ) whe = -whe;
std::string scha( an.substr( iofc, ioec - iofc ) );
const char* ccha = scha.c_str();
int cha = *ccha - '0';
std::string ssec( an.substr( iofs, ioes - iofs ) );
const char* csec = ssec.c_str();
int sec = ( ( *csec - '0' ) * 10 ) + ( csec[1] - '0' );
if ( ( csec[2] == 'R' ) && ( sec == 10 ) ) sec = 14;
if ( ( csec[2] == 'L' ) && ( sec == 4 ) ) sec = 13;
std::string squa( an.substr( iofq, ioeq - iofq ) );
const char* cqua = squa.c_str();
int qua = *cqua - '0';
std::string slay( an.substr( iofl, ioel - iofl ) );
const char* clay = slay.c_str();
int lay = *clay - '0';
DTWireId wireId( whe, cha, sec, qua, lay, 10 + chCode );
int chId = wireId.rawId();
coral::AttributeList newChan;
newChan.extend( "DETID", typeid(int) );
newChan.extend( "DPID", typeid(int) );
newChan["DETID"].data<int>() = chId;
newChan[ "DPID"].data<int>() = dpId;
hvalTable.dataEditor().insertRow( newChan );
aliasMap.insert( std::pair<int,int>( dpId, chId ) );
layerMap.insert( std::pair<int,int>( chId, dpId ) );
}
std::cout << "DTHVStatusHandler::dumpHVAliases - end" << std::endl;
return;
}
| void DTHVStatusHandler::dumpSnapshot | ( | const coral::TimeStamp & | time | ) | [private] |
Definition at line 799 of file DTHVStatusHandler.cc.
References aliasMap, buff_session, gather_cfg::cout, DTLayerId::layer(), cond::DbSession::nominalSchema(), cmsPerfSuiteHarvest::now, DTChamberId::sector(), snapshotValues, DTChamberId::station(), AlCaHLTBitMon_QueryRunRegistry::string, DTSuperLayerId::superLayer(), DTChamberId::wheel(), and DTWireId::wire().
Referenced by updateHVStatus().
{
std::cout << "dump snapshot to buffer db..." << std::endl;
std::string emptyCondition( "" );
coral::AttributeList emptyBindVariableList;
std::map<int,int>::const_iterator mapIter = aliasMap.begin();
std::map<int,int>::const_iterator mapIend = aliasMap.end();
coral::ITable& hvssTable =
buff_session.nominalSchema().tableHandle( "HVSNAPSHOT" );
coral::ITableDataEditor& hvssEditor( hvssTable.dataEditor() );
long nRows = hvssEditor.deleteRows( emptyCondition, emptyBindVariableList );
std::cout << nRows << " rows deleted" << std::endl;
coral::AttributeList newMeas;
newMeas.extend( "TIME", typeid(coral::TimeStamp) );
newMeas.extend( "WHEEL", typeid(int) );
newMeas.extend( "STATION", typeid(int) );
newMeas.extend( "SECTOR", typeid(int) );
newMeas.extend( "SUPERLAYER", typeid(int) );
newMeas.extend( "LAYER", typeid(int) );
newMeas.extend( "CHAN", typeid(int) );
newMeas.extend( "TYPE", typeid(int) );
newMeas.extend( "VALUE", typeid(float) );
nRows = 0;
std::map<int,timedMeasurement>::const_iterator ssvIter =
snapshotValues.begin();
std::map<int,timedMeasurement>::const_iterator ssvIend =
snapshotValues.end();
while ( ssvIter != ssvIend ) {
const std::pair<int,timedMeasurement>& entry = *ssvIter++;
int dpty = entry.first;
int dpId = dpty / 10;
int type = dpty % 10;
mapIter = aliasMap.find( dpId );
if ( mapIter == mapIend ) continue;
DTWireId chlId( mapIter->second );
const timedMeasurement& tMeas = entry.second;
long long int newTime = tMeas.first;
newMeas["TIME" ].data<coral::TimeStamp>() =
coral::TimeStamp( newTime );
newMeas["WHEEL" ].data<int>() = chlId.wheel ();
newMeas["STATION" ].data<int>() = chlId.station ();
newMeas["SECTOR" ].data<int>() = chlId.sector ();
newMeas["SUPERLAYER"].data<int>() = chlId.superLayer();
newMeas["LAYER" ].data<int>() = chlId.layer ();
newMeas["CHAN" ].data<int>() = chlId.wire () - 10;
newMeas["TYPE" ].data<int>() = type;
newMeas["VALUE" ].data<float>() = tMeas.second;
hvssEditor.insertRow( newMeas );
nRows++;
}
std::cout << nRows << " rows updated" << std::endl;
std::cout << "create logging info..." << std::endl;
if ( buff_session.nominalSchema().existsTable( "LOG" ) )
buff_session.nominalSchema(). dropTable( "LOG" );
coral::TableDescription infoDesc;
infoDesc.setName( "LOG" );
infoDesc.insertColumn( "EXECTIME",
coral::AttributeSpecification::typeNameForId(
typeid(coral::TimeStamp) ) );
infoDesc.insertColumn( "SNAPSHOT",
coral::AttributeSpecification::typeNameForId(
typeid(coral::TimeStamp) ) );
buff_session.nominalSchema().createTable( infoDesc );
coral::AttributeList newInfo;
newInfo.extend( "EXECTIME", typeid(coral::TimeStamp) );
newInfo.extend( "SNAPSHOT", typeid(coral::TimeStamp) );
newInfo["EXECTIME"].data<coral::TimeStamp>() = coral::TimeStamp::now();
newInfo["SNAPSHOT"].data<coral::TimeStamp>() = time;
coral::ITable& infoTable =
buff_session.nominalSchema().tableHandle( "LOG" );
infoTable.dataEditor().insertRow( newInfo );
return;
}
| void DTHVStatusHandler::filterData | ( | ) | [private] |
Definition at line 1304 of file DTHVStatusHandler.cc.
References DTHVStatus::begin(), gather_cfg::cout, diffTreeTool::diff, DTHVStatus::end(), popcon::PopConSourceHandler< DTHVStatus >::m_to_transfer, switchOff, and tmpContainer.
Referenced by copyHVData().
{
int maxTime = 100;
int maxTtot = 600;
int minDiff = 88;
int iTime = 0;
int pTime = 0;
int nTime = 0;
int iSize;
int pSize;
int nSize;
std::vector< std::pair<DTHVStatus*, cond::Time_t> >::const_iterator iter =
tmpContainer.begin();
std::vector< std::pair<DTHVStatus*, cond::Time_t> >::const_iterator iend =
tmpContainer.end();
std::vector< std::pair<DTHVStatus*, cond::Time_t> >::const_iterator prev;
std::vector< std::pair<DTHVStatus*, cond::Time_t> >::const_iterator next;
while ( iter != iend ) {
switchOff = false;
next = iter;
prev = next++;
if ( next == iend ) next = prev;
const DTHVStatus* iPtr = iter->first;
const DTHVStatus* pPtr = prev->first;
const DTHVStatus* nPtr = next->first;
iSize = std::distance( iPtr->begin(), iPtr->end() );
pSize = std::distance( pPtr->begin(), pPtr->end() );
nSize = std::distance( nPtr->begin(), nPtr->end() );
int dtot = nSize - pSize;
prev = next;
while ( ++next != iend ) {
pPtr = prev->first;
nPtr = next->first;
pSize = std::distance( pPtr->begin(), pPtr->end() );
nSize = std::distance( nPtr->begin(), nPtr->end() );
int diff = nSize - pSize;
iTime = static_cast<int>( ( iter->second >> 32 ) & 0xffffffff );
pTime = static_cast<int>( ( prev->second >> 32 ) & 0xffffffff );
nTime = static_cast<int>( ( next->second >> 32 ) & 0xffffffff );
if ( ( nTime - pTime ) > maxTime ) break;
if ( ( nTime - iTime ) > maxTtot ) break;
if ( ( dtot * diff ) < 0 ) break;
prev = next;
}
pPtr = prev->first;
iSize = std::distance( iPtr->begin(), iPtr->end() );
pSize = std::distance( pPtr->begin(), pPtr->end() );
dtot = pSize - iSize;
int dist = pTime - iTime;
if ( ( dtot < -minDiff ) &&
( dist < maxTtot ) ) {
std::cout << " ******** SWITCH ON "
<< std::distance( iter, prev ) << " "
<< iTime << " " << pTime << " "
<< iSize << " " << pSize << std::endl;
m_to_transfer.push_back( std::make_pair( prev->first, prev->second ) );
while ( iter != prev ) delete ( iter++->first );
}
if ( ( dtot > minDiff ) &&
( dist < maxTtot ) ) {
std::cout << " ******** SWITCH OFF "
<< std::distance( iter, prev ) << " "
<< iTime << " " << pTime << " "
<< iSize << " " << pSize << std::endl;
m_to_transfer.push_back( std::make_pair( prev->first, iter->second ) );
switchOff = true;
while ( iter != prev ) delete ( iter++->first );
}
if ( ( ( dtot >= -minDiff ) && ( dtot <= minDiff ) ) ||
( dist >= maxTtot ) ) {
while ( iter != next ) {
const std::pair<DTHVStatus*, cond::Time_t>& entry = *iter++;
m_to_transfer.push_back( std::make_pair( entry.first, entry.second ) );
}
}
iter = next;
}
}
| void DTHVStatusHandler::getChannelMap | ( | ) | [private] |
Definition at line 302 of file DTHVStatusHandler.cc.
References aliasMap, buff_session, gather_cfg::cout, dumpHVAliases(), layerMap, and cond::DbSession::nominalSchema().
Referenced by checkNewData().
{
if ( !( buff_session.nominalSchema().existsTable( "HVALIASES" ) ) ) {
dumpHVAliases();
}
else {
std::cout << "retrieve aliases table..." << std::endl;
coral::ITable& hvalTable =
buff_session.nominalSchema().tableHandle( "HVALIASES" );
std::auto_ptr<coral::IQuery> hvalQuery( hvalTable.newQuery() );
hvalQuery->addToOutputList( "DETID" );
hvalQuery->addToOutputList( "DPID" );
coral::ICursor& hvalCursor = hvalQuery->execute();
int chId;
int dpId;
while ( hvalCursor.next() ) {
chId = hvalCursor.currentRow()["DETID"].data<int>();
dpId = hvalCursor.currentRow()[ "DPID"].data<int>();
aliasMap.insert( std::pair<int,int>( dpId, chId ) );
layerMap.insert( std::pair<int,int>( chId, dpId ) );
}
}
return;
}
| void DTHVStatusHandler::getChannelSplit | ( | ) | [private] |
Definition at line 375 of file DTHVStatusHandler.cc.
References channelSplit, gather_cfg::cout, cond::DbSession::nominalSchema(), DetId::rawId(), splitVersion, AlCaHLTBitMon_QueryRunRegistry::string, and util_session.
Referenced by checkNewData().
{
std::cout << "retrieve channel split table..." << std::endl;
int pwhe;
int psec;
int psta;
int pqua;
int play;
int pl_p;
int swhe;
int ssec;
int ssta;
int squa;
int slay;
int sl_p;
coral::ITable& csplTable =
util_session.nominalSchema().tableHandle( "DT_HV_CHANNEL_SPLIT" );
std::auto_ptr<coral::IQuery> csplQuery( csplTable.newQuery() );
coral::AttributeList versionBindVariableList;
versionBindVariableList.extend( "version", typeid(std::string) );
versionBindVariableList["version"].data<std::string>() = splitVersion;
csplQuery->setCondition( "VERSION=:version", versionBindVariableList );
csplQuery->addToOutputList( "P_WHEEL" );
csplQuery->addToOutputList( "P_SECTOR" );
csplQuery->addToOutputList( "P_STATION" );
csplQuery->addToOutputList( "P_SUPERLAYER" );
csplQuery->addToOutputList( "P_LAYER" );
csplQuery->addToOutputList( "P_PART" );
csplQuery->addToOutputList( "S_NUMBER" );
csplQuery->addToOutputList( "S_WHEEL" );
csplQuery->addToOutputList( "S_SECTOR" );
csplQuery->addToOutputList( "S_STATION" );
csplQuery->addToOutputList( "S_SUPERLAYER" );
csplQuery->addToOutputList( "S_LAYER" );
csplQuery->addToOutputList( "S_PART" );
coral::ICursor& csplCursor = csplQuery->execute();
while ( csplCursor.next() ) {
pwhe = csplCursor.currentRow()["P_WHEEL" ].data<int>();
psec = csplCursor.currentRow()["P_SECTOR" ].data<int>();
psta = csplCursor.currentRow()["P_STATION" ].data<int>();
pqua = csplCursor.currentRow()["P_SUPERLAYER"].data<int>();
play = csplCursor.currentRow()["P_LAYER" ].data<int>();
pl_p = csplCursor.currentRow()["P_PART" ].data<int>();
csplCursor.currentRow()["S_NUMBER" ].data<int>();
swhe = csplCursor.currentRow()["S_WHEEL" ].data<int>();
ssec = csplCursor.currentRow()["S_SECTOR" ].data<int>();
ssta = csplCursor.currentRow()["S_STATION" ].data<int>();
squa = csplCursor.currentRow()["S_SUPERLAYER"].data<int>();
slay = csplCursor.currentRow()["S_LAYER" ].data<int>();
sl_p = csplCursor.currentRow()["S_PART" ].data<int>();
DTWireId pId( pwhe, psta, psec, pqua, play, 10 + pl_p );
DTWireId sId( swhe, ssta, ssec, squa, slay, 10 + sl_p );
int pRaw = pId.rawId();
int sRaw = sId.rawId();
std::vector<int>* splitList = 0;
std::map< int,std::vector<int>* >::iterator iter =
channelSplit.find( pRaw );
std::map< int,std::vector<int>* >::iterator iend =
channelSplit.end();
if ( iter == iend ) {
channelSplit.insert( std::pair< int,
std::vector<int>* >( pRaw, splitList =
new std::vector<int> ) );
}
else {
splitList = iter->second;
}
splitList->push_back( sRaw );
}
return;
}
| void DTHVStatusHandler::getLayerSplit | ( | ) | [private] |
Definition at line 330 of file DTHVStatusHandler.cc.
References gather_cfg::cout, laySplit, mapVersion, cond::DbSession::nominalSchema(), AlCaHLTBitMon_QueryRunRegistry::string, and util_session.
Referenced by checkNewData().
{
std::cout << "retrieve layer split table..." << std::endl;
int whe;
int sec;
int sta;
int qua;
int lay;
int l_p;
int f_c;
int l_c;
coral::ITable& lsplTable =
util_session.nominalSchema().tableHandle( "DT_HV_LAYER_SPLIT" );
std::cout << " layer split table got..." << std::endl;
std::auto_ptr<coral::IQuery> lsplQuery( lsplTable.newQuery() );
coral::AttributeList versionBindVariableList;
versionBindVariableList.extend( "version", typeid(std::string) );
versionBindVariableList["version"].data<std::string>() = mapVersion;
lsplQuery->setCondition( "VERSION=:version", versionBindVariableList );
lsplQuery->addToOutputList( "WHEEL" );
lsplQuery->addToOutputList( "SECTOR" );
lsplQuery->addToOutputList( "STATION" );
lsplQuery->addToOutputList( "SUPERLAYER" );
lsplQuery->addToOutputList( "LAYER" );
lsplQuery->addToOutputList( "PART" );
lsplQuery->addToOutputList( "FIRST_CELL" );
lsplQuery->addToOutputList( "LAST_CELL" );
coral::ICursor& lsplCursor = lsplQuery->execute();
while ( lsplCursor.next() ) {
whe = lsplCursor.currentRow()["WHEEL" ].data<int>();
sec = lsplCursor.currentRow()["SECTOR" ].data<int>();
sta = lsplCursor.currentRow()["STATION" ].data<int>();
qua = lsplCursor.currentRow()["SUPERLAYER"].data<int>();
lay = lsplCursor.currentRow()["LAYER" ].data<int>();
l_p = lsplCursor.currentRow()["PART" ].data<int>();
f_c = lsplCursor.currentRow()["FIRST_CELL"].data<int>();
l_c = lsplCursor.currentRow()[ "LAST_CELL"].data<int>();
DTWireId wireId( whe, sta, sec, qua, lay, 10 + l_p );
laySplit.insert( std::pair<int,int>( wireId.rawId(),
( f_c * 10000 ) + l_c ) );
}
std::cout << "channel split table retrieved" << std::endl;
return;
}
| void DTHVStatusHandler::getLayerValues | ( | int | rawId, |
| int | type, | ||
| float & | valueL, | ||
| float & | valueR, | ||
| float & | valueS, | ||
| float & | valueC | ||
| ) | [private] |
Definition at line 1118 of file DTHVStatusHandler.cc.
References gather_cfg::cout, layerId(), layerMap, DetId::rawId(), and snapshotValues.
Referenced by checkStatusChange(), and offlineList().
{
valueL =
valueR =
valueS =
valueC = 0.0;
DTWireId chlId( rawId );
std::map<int,timedMeasurement>::const_iterator snapIter =
snapshotValues.begin();
std::map<int,timedMeasurement>::const_iterator snapIend =
snapshotValues.end();
int rawL = layerId( rawId, 0 ).rawId();
int rawR = layerId( rawId, 1 ).rawId();
int rawS = layerId( rawId, 2 ).rawId();
int rawC = layerId( rawId, 3 ).rawId();
std::map<int,int>::const_iterator layerIter;
std::map<int,int>::const_iterator layerIend = layerMap.end();
if ( ( layerIter = layerMap.find( rawL ) ) != layerIend ) {
const std::pair<int,int>& layerEntry = *layerIter;
int dpId = layerEntry.second;
snapIter = snapshotValues.find( ( dpId * 10 ) + type );
if ( snapIter != snapIend ) {
const std::pair<int,timedMeasurement>& snapEntry = *snapIter;
valueL = snapEntry.second.second;
}
else std::cout << "snapR not found" << std::endl;
}
else std::cout << "rawR not found" << std::endl;
if ( ( layerIter = layerMap.find( rawR ) ) != layerIend ) {
const std::pair<int,int>& layerEntry = *layerIter;
int dpId = layerEntry.second;
snapIter = snapshotValues.find( ( dpId * 10 ) + type );
if ( snapIter != snapIend ) {
const std::pair<int,timedMeasurement>& snapEntry = *snapIter;
valueR = snapEntry.second.second;
}
else std::cout << "snapL not found" << std::endl;
}
else std::cout << "rawL not found" << std::endl;
if ( ( layerIter = layerMap.find( rawS ) ) != layerIend ) {
const std::pair<int,int>& layerEntry = *layerIter;
int dpId = layerEntry.second;
snapIter = snapshotValues.find( ( dpId * 10 ) + type );
if ( snapIter != snapIend ) {
const std::pair<int,timedMeasurement>& snapEntry = *snapIter;
valueS = snapEntry.second.second;
}
else std::cout << "snapS not found" << std::endl;
}
else std::cout << "rawS not found" << std::endl;
if ( ( layerIter = layerMap.find( rawC ) ) != layerIend ) {
const std::pair<int,int>& layerEntry = *layerIter;
int dpId = layerEntry.second;
snapIter = snapshotValues.find( ( dpId * 10 ) + type );
if ( snapIter != snapIend ) {
const std::pair<int,timedMeasurement>& snapEntry = *snapIter;
valueC = snapEntry.second.second;
}
else std::cout << "snapC not found" << std::endl;
}
else std::cout << "rawC not found" << std::endl;
// std::cout << "layer values... " << type << " " << valueL << " "
// << valueR << " "
// << valueS << " "
// << valueC << std::endl;
return;
}
| void DTHVStatusHandler::getNewObjects | ( | ) | [virtual] |
Operations
Implements popcon::PopConSourceHandler< DTHVStatus >.
Definition at line 102 of file DTHVStatusHandler.cc.
References aliasMap, buff_conn, buff_session, bufferConnect, checkNewData(), cond::DbSession::close(), condTime(), cond::DbConnection::configuration(), cond::DbConnection::configure(), coralTime(), gather_cfg::cout, cond::DbConnection::createSession(), data, dataTag, dSince, dUntil, DTHVStatusData::flagA, DTHVStatusData::flagC, DTHVStatusData::flagS, hSince, hUntil, hvChecker, id(), prof2calltree::last, lastFound, cond::TagInfo::lastInterval, popcon::PopConSourceHandler< DTHVStatus >::lastPayload(), lastStamp, layerId(), layerMap, popcon::PopConSourceHandler< DTHVStatus >::m_to_transfer, mSince, mUntil, nextFound, cmsPerfSuiteHarvest::now, omds_conn, omds_session, onlineAuthentication, onlineConnect, cond::DbSession::open(), procSince, procUntil, pSince, pUntil, DTHVStatusId::sectorId, DTHVAbstractCheck::setStatus(), snapshotValues, sSince, DTHVStatusId::stationId, sUntil, popcon::PopConSourceHandler< DTHVStatus >::tagInfo(), timeLimit, cond::DbSession::transaction(), util_conn, util_session, DTHVStatusId::wheelId, ySince, and yUntil.
{
std::cout << "get new objects..." << std::endl;
// online DB connection - data
std::cout << "configure omds DbConnection" << std::endl;
// conn->configure( cond::CmsDefaults );
omds_conn.configuration().setAuthenticationPath( onlineAuthentication );
omds_conn.configure();
std::cout << "create omds DbSession" << std::endl;
omds_session = omds_conn.createSession();
std::cout << "open omds session" << std::endl;
omds_session.open( onlineConnect );
std::cout << "start omds transaction" << std::endl;
omds_session.transaction().start();
std::cout << "" << std::endl;
// online DB connection - util
std::cout << "configure util DbConnection" << std::endl;
// conn->configure( cond::CmsDefaults );
util_conn.configuration().setAuthenticationPath( onlineAuthentication );
util_conn.configure();
std::cout << "create util DbSession" << std::endl;
util_session = util_conn.createSession();
std::cout << "open util session" << std::endl;
util_session.open( onlineConnect );
std::cout << "startutil transaction" << std::endl;
util_session.transaction().start();
std::cout << "" << std::endl;
// buffer DB connection
std::cout << "configure buffer DbConnection" << std::endl;
buff_conn.configuration().setAuthenticationPath( onlineAuthentication );
buff_conn.configure();
std::cout << "create buffer DbSession" << std::endl;
buff_session = buff_conn.createSession();
std::cout << "open buffer session" << std::endl;
buff_session.open( bufferConnect );
std::cout << "start buffer transaction" << std::endl;
buff_session.transaction().start();
// offline info
//to access the information on the tag inside the offline database:
cond::TagInfo const & ti = tagInfo();
cond::Time_t last = ti.lastInterval.first;
std::cout << "latest DCS data (HV) already copied until: "
<< last << std::endl;
coral::TimeStamp coralSince( ySince, mSince, dSince,
hSince, pSince, sSince, 0 );
procSince = condTime( coralSince );
coral::TimeStamp coralUntil( yUntil, mUntil, dUntil,
hUntil, pUntil, sUntil, 0 );
procUntil = condTime( coralUntil );
lastFound = 0;
nextFound = 0;
timeLimit = 0;
lastStamp = 0;
if ( last == 0 ) {
DTHVStatus* dummyStatus = new DTHVStatus( dataTag );
cond::Time_t snc = 1;
m_to_transfer.push_back( std::make_pair( dummyStatus, snc ) );
last = procSince + 1;
std::cout << "no old data... " << last << std::endl;
}
else {
Ref payload = lastPayload();
DTHVStatus::const_iterator paylIter = payload->begin();
DTHVStatus::const_iterator paylIend = payload->end();
while ( paylIter != paylIend ) {
const std::pair<DTHVStatusId,DTHVStatusData>& entry = *paylIter++;
const DTHVStatusId& chan = entry.first;
const DTHVStatusData& data = entry.second;
DTWireId id( chan.wheelId, chan.stationId, chan.sectorId,
chan. slId, chan. layerId, chan. partId + 10 );
hvChecker->setStatus( id.rawId(),
data.flagA, data.flagC, data.flagS,
snapshotValues,
aliasMap, layerMap );
}
}
coral::TimeStamp coralLast = coralTime( last );
coral::TimeStamp coralProc = coral::TimeStamp::now();
cond::Time_t condProc = condTime( coralProc );
if ( procSince > condProc ) {
std::cout << "Required time interval in the future: "
<< std::endl
<< " copy since " << ySince << " "
<< mSince << " "
<< dSince
<< " ( " << procSince << " )" << std::endl
<< " current time " << coralProc.year( ) << " "
<< coralProc.month() << " "
<< coralProc.day( ) << std::endl;
}
if ( procUntil > condProc ) procUntil = condProc;
if ( last > procSince ) {
if ( last < procUntil ) {
procSince = last;
checkNewData();
}
else {
std::cout << "Required time interval already copied: "
<< std::endl
<< " copy until " << yUntil << " "
<< mUntil << " "
<< dUntil
<< " ( " << procUntil << " )" << std::endl
<< " data until " << coralLast.year( ) << " "
<< coralLast.month() << " "
<< coralLast.day( ) << std::endl;
}
}
else {
std::cout << "Required time interval not contiguous with copied data: "
<< std::endl
<< " data until " << coralLast.year( ) << " "
<< coralLast.month() << " "
<< coralLast.day( ) << std::endl
<< " copy since " << ySince << " "
<< mSince << " "
<< dSince
<< " ( " << procSince << " )" << std::endl;
}
buff_session.transaction().commit();
buff_session.close();
omds_session.close();
util_session.close();
return;
}
| std::string DTHVStatusHandler::id | ( | void | ) | const [virtual] |
Implements popcon::PopConSourceHandler< DTHVStatus >.
Definition at line 297 of file DTHVStatusHandler.cc.
Referenced by getNewObjects().
{
return "DTHVStatusHandler";
}
| DTWireId DTHVStatusHandler::layerId | ( | int | rawId, |
| int | l_p | ||
| ) | [static, private] |
Definition at line 1388 of file DTHVStatusHandler.cc.
References DTLayerId::layer(), DTChamberId::sector(), DTChamberId::station(), DTSuperLayerId::superLayer(), and DTChamberId::wheel().
Referenced by checkStatusChange(), getLayerValues(), getNewObjects(), and offlineList().
| DTHVStatus * DTHVStatusHandler::offlineList | ( | ) | [private] |
Definition at line 1042 of file DTHVStatusHandler.cc.
References DTHVAbstractCheck::flag::a, aliasMap, DTHVAbstractCheck::flag::c, channelSplit, DTHVAbstractCheck::checkCurrentStatus(), dataTag, getLayerValues(), hvChecker, DTLayerId::layer(), layerId(), layerMap, DetId::rawId(), DTHVAbstractCheck::flag::s, DTChamberId::sector(), setChannelFlag(), snapshotValues, DTChamberId::station(), DTSuperLayerId::superLayer(), DTChamberId::wheel(), and DTWireId::wire().
Referenced by checkForPeriod(), and copyHVData().
{
DTHVStatus* hv = new DTHVStatus( dataTag );
int type;
float valueA = 0.0;
float valueL = 0.0;
float valueR = 0.0;
float valueS = 0.0;
float valueC = 0.0;
std::map<int,int>::const_iterator layerIter = layerMap.begin();
std::map<int,int>::const_iterator layerIend = layerMap.end();
while ( layerIter != layerIend ) {
const std::pair<int,int>& chanEntry = *layerIter++;
int rawId = chanEntry.first;
DTWireId chlId( rawId );
int whe = chlId.wheel ();
int sta = chlId.station ();
int sec = chlId.sector ();
int qua = chlId.superLayer();
int lay = chlId.layer ();
int l_p = chlId.wire();
if ( l_p != 10 ) continue;
for ( type = 1; type <= 2; type++ ) {
getLayerValues( rawId, type, valueL, valueR, valueS, valueC );
for ( l_p = 0; l_p <= 1; l_p++ ) {
int rPart = layerId( rawId, l_p ).rawId();
switch ( l_p ) {
case 0:
valueA = valueL;
break;
case 1:
valueA = valueR;
break;
default:
break;
}
// std::cout << "layer values: " << type << " " << valueA << " "
// << valueS << " "
// << valueC << std::endl;
DTHVAbstractCheck::flag flag = hvChecker->checkCurrentStatus(
rPart, type,
valueA, valueC, valueS,
snapshotValues,
aliasMap, layerMap );
if ( !flag.a && !flag.c && !flag.s ) continue;
setChannelFlag( hv, whe, sta, sec, qua, lay, l_p, flag );
std::map< int,std::vector<int>* >::const_iterator m_iter =
channelSplit.find( rPart );
std::map< int,std::vector<int>* >::const_iterator m_iend =
channelSplit.end();
if ( m_iter != m_iend ) {
std::vector<int>* cList = m_iter->second;
std::vector<int>::const_iterator l_iter = cList->begin();
std::vector<int>::const_iterator l_iend = cList->end();
while ( l_iter != l_iend ) {
DTWireId chlId( *l_iter++ );
int wh2 = chlId.wheel ();
int st2 = chlId.station ();
int se2 = chlId.sector ();
int qu2 = chlId.superLayer();
int la2 = chlId.layer ();
int lp2 = chlId.wire() - 10;
// std::cout << "duplicate "
// << whe << " " << sta << " " << sec << " "
// << qua << " " << lay << " " << l_p << " ---> "
// << wh2 << " " << st2 << " " << se2 << " "
// << qu2 << " " << la2 << " " << lp2 << std::endl;
setChannelFlag( hv, wh2, st2, se2, qu2, la2, lp2, flag );
}
}
}
}
}
return hv;
}
| cond::Time_t DTHVStatusHandler::recoverLastTime | ( | ) | [private] |
Definition at line 773 of file DTHVStatusHandler.cc.
References condTime(), and snapshotValues.
Referenced by updateHVStatus().
{
long long int lastTime = 0LL;
long long int chanTime = 0LL;
std::map<int,timedMeasurement>::iterator mapIter = snapshotValues.begin();
std::map<int,timedMeasurement>::iterator mapIend = snapshotValues.end();
while ( mapIter != mapIend ) {
const std::pair<int,timedMeasurement>& entry = *mapIter++;
chanTime = entry.second.first;
if ( lastTime < chanTime ) lastTime = chanTime;
}
return condTime( lastTime );
/*
coral::ITable& infoTable =
buff_session.nominalSchema().tableHandle( "LOG" );
std::auto_ptr<coral::IQuery> infoQuery( infoTable.newQuery() );
infoQuery->addToOutputList( "SNAPSHOT" );
coral::ICursor& infoCursor = infoQuery->execute();
coral::TimeStamp time;
while ( infoCursor.next() ) {
time = infoCursor.currentRow()["SNAPSHOT"].data<coral::TimeStamp>();
}
return condTime( time );
*/
}
| int DTHVStatusHandler::recoverSnapshot | ( | ) | [private] |
Definition at line 728 of file DTHVStatusHandler.cc.
References buff_session, gather_cfg::cout, layerMap, cond::DbSession::nominalSchema(), DetId::rawId(), snapshotValues, cond::rpcobgas::time, and relativeConstraints::value.
Referenced by updateHVStatus().
{
int missingChannels = 0;
std::map<int,int>::const_iterator layIter = layerMap.begin();
std::map<int,int>::const_iterator layIend = layerMap.end();
std::cout << "retrieve snapshot table..." << std::endl;
coral::ITable& hvssTable =
buff_session.nominalSchema().tableHandle( "HVSNAPSHOT" );
std::auto_ptr<coral::IQuery> hvssQuery( hvssTable.newQuery() );
hvssQuery->addToOutputList( "TIME" );
hvssQuery->addToOutputList( "WHEEL" );
hvssQuery->addToOutputList( "STATION" );
hvssQuery->addToOutputList( "SECTOR" );
hvssQuery->addToOutputList( "SUPERLAYER" );
hvssQuery->addToOutputList( "LAYER" );
hvssQuery->addToOutputList( "CHAN" );
hvssQuery->addToOutputList( "TYPE" );
hvssQuery->addToOutputList( "VALUE" );
coral::ICursor& hvssCursor = hvssQuery->execute();
while ( hvssCursor.next() ) {
coral::TimeStamp time =
hvssCursor.currentRow()["TIME"].data<coral::TimeStamp>();
int whe = hvssCursor.currentRow()["WHEEL" ].data<int>();
int sta = hvssCursor.currentRow()["STATION" ].data<int>();
int sec = hvssCursor.currentRow()["SECTOR" ].data<int>();
int qua = hvssCursor.currentRow()["SUPERLAYER"].data<int>();
int lay = hvssCursor.currentRow()["LAYER" ].data<int>();
int l_p = hvssCursor.currentRow()["CHAN" ].data<int>();
int mty = hvssCursor.currentRow()["TYPE" ].data<int>();
float value = hvssCursor.currentRow()["VALUE" ].data<float>();
if ( mty > 2 ) continue;
DTWireId wireId( whe, sta, sec, qua, lay, 10 + l_p );
layIter = layerMap.find( wireId.rawId() );
if ( layIter == layIend ) {
continue;
}
int dpId = ( layIter->second * 10 ) + mty;
snapshotValues.insert( std::pair<int,timedMeasurement>(
dpId, timedMeasurement(
time.total_nanoseconds(), value ) ) );
missingChannels++;
}
return missingChannels;
}
| void DTHVStatusHandler::setChannelFlag | ( | DTHVStatus * | hv, |
| int | whe, | ||
| int | sta, | ||
| int | sec, | ||
| int | qua, | ||
| int | lay, | ||
| int | l_p, | ||
| const DTHVAbstractCheck::flag & | flag | ||
| ) | [private] |
Definition at line 1188 of file DTHVStatusHandler.cc.
References DTHVAbstractCheck::flag::a, DTHVAbstractCheck::flag::c, DTHVStatus::get(), laySplit, DetId::rawId(), DTHVAbstractCheck::flag::s, and DTHVStatus::set().
Referenced by offlineList().
{
int fCell = 0;
int lCell = 99;
int flagA = 0;
int flagC = 0;
int flagS = 0;
int searchStatus = hv->get( whe, sta, sec, qua, lay, l_p,
fCell, lCell, flagA, flagC, flagS );
if ( searchStatus ) {
DTWireId wireId( whe, sta, sec, qua, lay, 10 + l_p );
std::map<int,int>::const_iterator splitIter =
laySplit.find( wireId.rawId() );
std::map<int,int>::const_iterator splitIend =
laySplit.end();
if ( splitIter != splitIend ) {
int code = splitIter->second;
fCell = code / 10000;
lCell = code % 10000;
}
}
flagA |= flag.a;
flagC |= flag.c;
flagS |= flag.s;
hv->set( whe, sta, sec, qua, lay, l_p,
fCell, lCell, flagA, flagC, flagS );
return;
}
| void DTHVStatusHandler::updateHVStatus | ( | ) | [private] |
Definition at line 675 of file DTHVStatusHandler.cc.
References bwdTime, checkForPeriod(), copyHVData(), coralTime(), gather_cfg::cout, dSince, dumpAtEnd, dumpAtStart, dumpSnapshot(), lastFound, mSince, procSince, recoverLastTime(), recoverSnapshot(), and ySince.
Referenced by checkNewData().
{
int missingChannels = recoverSnapshot();
cond::Time_t snapshotTime = recoverLastTime();
std::cout << " snapshot at " << snapshotTime << " ( "
<< coralTime( snapshotTime )
.total_nanoseconds() << " ) "
<< std::endl;
if ( snapshotTime > procSince ) {
coral::TimeStamp coralSnap = coralTime( snapshotTime );
std::cout << "too recent snapshot: " << std::endl
<< " snapshot at " << coralSnap.year( ) << " "
<< coralSnap.month() << " "
<< coralSnap.day( ) << std::endl
<< " copy since " << ySince << " "
<< mSince << " "
<< dSince
<< " ( " << procSince << " )" << std::endl;
return;
}
long long int dTime = bwdTime;
dTime <<= 32;
cond::Time_t condUntil = procSince;
cond::Time_t condSince = condUntil - dTime;
while ( missingChannels ) {
std::cout << "back iteration: "
<< condSince << " ( " << coralTime( condSince )
.total_nanoseconds() << " ) -> "
<< condUntil << " ( " << coralTime( condUntil )
.total_nanoseconds() << " ) "
<< std::endl;
if ( condSince <= snapshotTime ) condSince = snapshotTime;
std::cout << "corrected since: "
<< condSince << " ( " << coralTime( condSince )
.total_nanoseconds() << " ) "
<< std::endl;
if ( condSince >= condUntil ) break;
std::cout << "missing... " << missingChannels << std::endl;
checkForPeriod( condSince, condUntil, missingChannels, false );
condUntil = condSince;
condSince = condUntil - dTime;
}
if ( dumpAtStart ) dumpSnapshot( coralTime( procSince ) );
copyHVData();
if ( dumpAtEnd ) dumpSnapshot( coralTime( lastFound ) );
return;
}
std::map<int,int> DTHVStatusHandler::aliasMap [private] |
Definition at line 143 of file DTHVStatusHandler.h.
Referenced by checkStatusChange(), createSnapshot(), dumpHVAliases(), dumpSnapshot(), getChannelMap(), getNewObjects(), and offlineList().
Definition at line 136 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
Definition at line 139 of file DTHVStatusHandler.h.
Referenced by checkNewData(), createSnapshot(), dumpHVAliases(), dumpSnapshot(), getChannelMap(), getNewObjects(), and recoverSnapshot().
std::string DTHVStatusHandler::bufferConnect [private] |
Definition at line 102 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
long long int DTHVStatusHandler::bwdTime [private] |
Definition at line 119 of file DTHVStatusHandler.h.
Referenced by updateHVStatus().
std::map< int, std::vector<int>* > DTHVStatusHandler::channelSplit [private] |
Definition at line 146 of file DTHVStatusHandler.h.
Referenced by getChannelSplit(), and offlineList().
std::string DTHVStatusHandler::dataTag [private] |
Definition at line 98 of file DTHVStatusHandler.h.
Referenced by getNewObjects(), and offlineList().
int DTHVStatusHandler::dSince [private] |
Definition at line 107 of file DTHVStatusHandler.h.
Referenced by getNewObjects(), and updateHVStatus().
bool DTHVStatusHandler::dumpAtEnd [private] |
Definition at line 118 of file DTHVStatusHandler.h.
Referenced by updateHVStatus().
bool DTHVStatusHandler::dumpAtStart [private] |
Definition at line 117 of file DTHVStatusHandler.h.
Referenced by updateHVStatus().
int DTHVStatusHandler::dUntil [private] |
Definition at line 113 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
long long int DTHVStatusHandler::fwdTime [private] |
Definition at line 120 of file DTHVStatusHandler.h.
Referenced by copyHVData().
int DTHVStatusHandler::hSince [private] |
Definition at line 108 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
int DTHVStatusHandler::hUntil [private] |
Definition at line 114 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
DTHVAbstractCheck* DTHVStatusHandler::hvChecker [private] |
Definition at line 124 of file DTHVStatusHandler.h.
Referenced by checkStatusChange(), DTHVStatusHandler(), getNewObjects(), and offlineList().
cond::Time_t DTHVStatusHandler::lastFound [private] |
Definition at line 128 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), copyHVData(), getNewObjects(), and updateHVStatus().
long long int DTHVStatusHandler::lastStamp [private] |
Definition at line 131 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), and getNewObjects().
DTHVStatus* DTHVStatusHandler::lastStatus [private] |
Definition at line 103 of file DTHVStatusHandler.h.
Referenced by copyHVData().
std::map<int,int> DTHVStatusHandler::layerMap [private] |
Definition at line 144 of file DTHVStatusHandler.h.
Referenced by checkStatusChange(), dumpHVAliases(), getChannelMap(), getLayerValues(), getNewObjects(), offlineList(), and recoverSnapshot().
std::map<int,int> DTHVStatusHandler::laySplit [private] |
Definition at line 145 of file DTHVStatusHandler.h.
Referenced by getLayerSplit(), and setChannelFlag().
std::string DTHVStatusHandler::mapVersion [private] |
Definition at line 141 of file DTHVStatusHandler.h.
Referenced by getLayerSplit().
int DTHVStatusHandler::maxPayload [private] |
Definition at line 132 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), copyHVData(), and DTHVStatusHandler().
long long int DTHVStatusHandler::minTime [private] |
Definition at line 121 of file DTHVStatusHandler.h.
Referenced by checkForPeriod().
int DTHVStatusHandler::mSince [private] |
Definition at line 106 of file DTHVStatusHandler.h.
Referenced by getNewObjects(), and updateHVStatus().
int DTHVStatusHandler::mUntil [private] |
Definition at line 112 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
cond::Time_t DTHVStatusHandler::nextFound [private] |
Definition at line 129 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), and getNewObjects().
Definition at line 134 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
Definition at line 137 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), checkNewData(), dumpHVAliases(), and getNewObjects().
std::string DTHVStatusHandler::onlineAuthentication [private] |
Definition at line 101 of file DTHVStatusHandler.h.
Referenced by DTHVStatusHandler(), and getNewObjects().
std::string DTHVStatusHandler::onlineConnect [private] |
Definition at line 99 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
cond::Time_t DTHVStatusHandler::procSince [private] |
Definition at line 126 of file DTHVStatusHandler.h.
Referenced by checkNewData(), copyHVData(), getNewObjects(), and updateHVStatus().
cond::Time_t DTHVStatusHandler::procUntil [private] |
Definition at line 127 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), checkNewData(), copyHVData(), and getNewObjects().
int DTHVStatusHandler::pSince [private] |
Definition at line 109 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
int DTHVStatusHandler::pUntil [private] |
Definition at line 115 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
std::map<int,timedMeasurement> DTHVStatusHandler::snapshotValues [private] |
Definition at line 123 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), checkStatusChange(), dumpSnapshot(), getLayerValues(), getNewObjects(), offlineList(), recoverLastTime(), and recoverSnapshot().
std::string DTHVStatusHandler::splitVersion [private] |
Definition at line 142 of file DTHVStatusHandler.h.
Referenced by getChannelSplit().
int DTHVStatusHandler::sSince [private] |
Definition at line 110 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
int DTHVStatusHandler::sUntil [private] |
Definition at line 116 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
bool DTHVStatusHandler::switchOff [private] |
Definition at line 148 of file DTHVStatusHandler.h.
Referenced by copyHVData(), and filterData().
cond::Time_t DTHVStatusHandler::timeLimit [private] |
Definition at line 130 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), and getNewObjects().
std::vector< std::pair<DTHVStatus*, cond::Time_t> > DTHVStatusHandler::tmpContainer [private] |
Definition at line 147 of file DTHVStatusHandler.h.
Referenced by checkForPeriod(), and filterData().
Definition at line 135 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
Definition at line 138 of file DTHVStatusHandler.h.
Referenced by checkNewData(), getChannelSplit(), getLayerSplit(), and getNewObjects().
std::string DTHVStatusHandler::utilConnect [private] |
Definition at line 100 of file DTHVStatusHandler.h.
int DTHVStatusHandler::ySince [private] |
Definition at line 105 of file DTHVStatusHandler.h.
Referenced by getNewObjects(), and updateHVStatus().
int DTHVStatusHandler::yUntil [private] |
Definition at line 111 of file DTHVStatusHandler.h.
Referenced by getNewObjects().
1.7.3