DTHVStatusHandler Class Reference

#include <DTHVStatusHandler.h>

Inheritance diagram for DTHVStatusHandler:

Public Member Functions
	DTHVStatusHandler (const edm::ParameterSet &ps)
void	getNewObjects ()
std::string	id () const
virtual	~DTHVStatusHandler ()
Public Member Functions inherited from popcon::PopConSourceHandler< DTHVStatus >
void	convertFromOld ()
Summary *	dummySummary (typename OldContainer::value_type const &) const
void	initialize (const cond::persistency::Session &dbSession, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry)
Ref	lastPayload () const
cond::LogDBEntry_t const &	logDBEntry () const
std::pair< Container const *, std::string const >	operator() (const cond::persistency::Session &session, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry) const
	PopConSourceHandler ()
Container const &	returnData ()
void	sort ()
cond::TagInfo_t const &	tagInfo () const
std::string const &	userTextLog () const
virtual	~PopConSourceHandler ()

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

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< DTHVStatus >
typedef std::vector< Triplet >	Container
typedef std::vector< std::pair < DTHVStatus *, cond::Time_t > >	OldContainer
typedef PopConSourceHandler < DTHVStatus >	self
typedef cond::Summary	Summary
typedef cond::Time_t	Time_t
typedef DTHVStatus	value_type
Protected Member Functions inherited from popcon::PopConSourceHandler< DTHVStatus >
int	add (value_type *payload, Summary *summary, Time_t time)
Protected Attributes inherited from popcon::PopConSourceHandler< DTHVStatus >
OldContainer	m_to_transfer
std::string	m_userTextLog

Detailed Description

Description: Class to copy HV status via PopCon

Date:

2010/07/21 16:06:52

Revision:

1.6

Author

Paolo Ronchese INFN Padova

Definition at line 41 of file DTHVStatusHandler.h.

Member Typedef Documentation

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.

Constructor & Destructor Documentation

DTHVStatusHandler::DTHVStatusHandler

(

const edm::ParameterSet &

ps

)

Constructor

Definition at line 53 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

Destructor

Definition at line 95 of file DTHVStatusHandler.cc.

                                      {
}

Member Function Documentation

int DTHVStatusHandler::checkForPeriod ( cond::Time_t  condSince, cond::Time_t  condUntil, int &  missingChannels, bool  copyOffline  )

private

Definition at line 878 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 239 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 1219 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 )

staticprivate

Definition at line 1407 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 )

staticprivate

Definition at line 1414 of file DTHVStatusHandler.cc.

                                                                          {
  cond::Time_t cTime = ( ( time                     / 1000000000 )  << 32 ) + 
                       ( ( time                     % 1000000000 ) / 1000 );
  return cTime;
}

void DTHVStatusHandler::copyHVData ( )

private

Definition at line 1009 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 )

staticprivate

Definition at line 1399 of file DTHVStatusHandler.cc.

Referenced by checkForPeriod(), checkNewData(), getNewObjects(), and updateHVStatus().

                                                                        {
  long long int iTime = ( ( ( ( time >> 32 ) & 0xFFFFFFFF ) * 1000000000 ) +
                          ( (   time         & 0xFFFFFFFF ) * 1000       ) );
  coral::TimeStamp cTime( iTime );
  return cTime;
}

void DTHVStatusHandler::createSnapshot ( )

private

Definition at line 576 of file DTHVStatusHandler.cc.

References aliasMap, buff_session, gather_cfg::cout, getDQMSummary::iter, 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 446 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 798 of file DTHVStatusHandler.cc.

References aliasMap, buff_session, gather_cfg::cout, DTLayerId::layer(), cond::DbSession::nominalSchema(), fileCollector::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 1303 of file DTHVStatusHandler.cc.

References DTHVStatus::begin(), gather_cfg::cout, diffTreeTool::diff, DTHVStatus::end(), getDQMSummary::iter, popcon::PopConSourceHandler< DTHVStatus >::m_to_transfer, GetRecoTauVFromDQM_MC_cff::next, 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 301 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 374 of file DTHVStatusHandler.cc.

References channelSplit, gather_cfg::cout, getDQMSummary::iter, 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 329 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 1117 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 101 of file DTHVStatusHandler.cc.

References aliasMap, buff_conn, buff_session, bufferConnect, checkNewData(), cond::DbSession::close(), cond::DbTransaction::commit(), 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_t::lastInterval, popcon::PopConSourceHandler< DTHVStatus >::lastPayload(), lastStamp, layerId(), layerMap, popcon::PopConSourceHandler< DTHVStatus >::m_to_transfer, mSince, mUntil, nextFound, fileCollector::now, omds_conn, omds_session, onlineAuthentication, onlineConnect, cond::DbSession::open(), procSince, procUntil, pSince, pUntil, DTHVStatusId::sectorId, cond::DbConnectionConfiguration::setAuthenticationPath(), DTHVAbstractCheck::setStatus(), snapshotValues, sSince, cond::DbTransaction::start(), 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 296 of file DTHVStatusHandler.cc.

Referenced by getNewObjects().

                                      {
  return "DTHVStatusHandler";
}

DTWireId DTHVStatusHandler::layerId ( int  rawId, int  l_p  )

staticprivate

Definition at line 1387 of file DTHVStatusHandler.cc.

References DTLayerId::layer(), DTChamberId::sector(), DTChamberId::station(), DTSuperLayerId::superLayer(), and DTChamberId::wheel().

Referenced by checkStatusChange(), getLayerValues(), getNewObjects(), and offlineList().

                                                        {
  DTWireId chlId( rawId );
  int whe = chlId.wheel     ();
  int sta = chlId.station   ();
  int sec = chlId.sector    ();
  int qua = chlId.superLayer();
  int lay = chlId.layer     ();
  DTWireId chl( whe, sta, sec, qua, lay, 10 + l_p );
  return chl;
}

DTHVStatus * DTHVStatusHandler::offlineList ( )

private

Definition at line 1041 of file DTHVStatusHandler.cc.

References DTHVAbstractCheck::flag::a, aliasMap, DTHVAbstractCheck::flag::c, channelSplit, DTHVAbstractCheck::checkCurrentStatus(), dataTag, archive::flag, getLayerValues(), AnalysisDataFormats_SUSYBSMObjects::hv, 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 772 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 727 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 1187 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 674 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;
}

Member Data Documentation

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().

cond::DbConnection DTHVStatusHandler::buff_conn

private

Definition at line 136 of file DTHVStatusHandler.h.

Referenced by getNewObjects().

cond::DbSession DTHVStatusHandler::buff_session

private

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().

cond::DbConnection DTHVStatusHandler::omds_conn

private

Definition at line 134 of file DTHVStatusHandler.h.

Referenced by getNewObjects().

cond::DbSession DTHVStatusHandler::omds_session

private

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().

cond::DbConnection DTHVStatusHandler::util_conn

private

Definition at line 135 of file DTHVStatusHandler.h.

Referenced by getNewObjects().

cond::DbSession DTHVStatusHandler::util_session

private

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().