RunDCSLVDat Class Reference

#include <RunDCSLVDat.h>

Inheritance diagram for RunDCSLVDat:

Public Types
typedef oracle::occi::ResultSet	ResultSet

Public Member Functions
std::string	getEBAccount ()
std::string	getEEAccount ()
float	getLV () const
float	getLVNominal () const
int	getStatus () const
std::string	getTable () override
int	getTimeStatus ()
	RunDCSLVDat ()
void	setLV (float t)
void	setLVNominal (float t)
void	setStatus (int t)
void	setTimeStatus (int t)
	~RunDCSLVDat () override
Public Member Functions inherited from IDataItem
	IDataItem ()
Public Member Functions inherited from IDBObject
oracle::occi::Connection *	getConn () const
oracle::occi::Environment *	getEnv () const
void	setConnection (oracle::occi::Environment *env, oracle::occi::Connection *conn)
virtual	~IDBObject ()

Static Public Attributes
static const int	LVNOTNOMINAL = 1
static const int	LVOFF = 2
static const int	maxDifference = 30*60*1000000
static const int	maxLVDifferenceEB = 1000
static const int	maxLVDifferenceEE = 1000
static const int	minLV = 2000
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS =1024

Private Member Functions
void	fetchData (std::map< EcalLogicID, RunDCSLVDat > *fillMap, RunIOV *iov) noexcept(false)
void	fetchLastData (std::map< EcalLogicID, RunDCSLVDat > *fillMap) noexcept(false)
void	fillTheMap (ResultSet *, std::map< EcalLogicID, RunDCSLVDat > *)
ResultSet *	getBarrelRset ()
ResultSet *	getEndcapRset ()
int	nowMicroseconds ()
void	prepareWrite () noexcept(false) override
void	setStatusForBarrel (RunDCSLVDat &, const Tm &)
void	setStatusForEndcaps (RunDCSLVDat &, const Tm &)
void	writeDB (const EcalLogicID *ecid, const RunDCSLVDat *item, RunIOV *iov) noexcept(false)

Private Attributes
float	m_lv
float	m_lvnom
int	m_status
int	m_tstatus

Friends
class	EcalCondDBInterface

Additional Inherited Members
Protected Member Functions inherited from IDataItem
void	checkPrepare () noexcept(false)
void	createReadStatement () noexcept(false)
void	setPrefetchRowCount (int ncount) noexcept(false)
void	terminateReadStatement () noexcept(false)
void	terminateWriteStatement () noexcept(false)
Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)
Protected Attributes inherited from IDataItem
oracle::occi::Statement *	m_readStmt
oracle::occi::Statement *	m_writeStmt
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Detailed Description

Definition at line 14 of file RunDCSLVDat.h.

Member Typedef Documentation

typedef oracle::occi::ResultSet RunDCSLVDat::ResultSet

Definition at line 16 of file RunDCSLVDat.h.

Constructor & Destructor Documentation

RunDCSLVDat::RunDCSLVDat

(

)

Definition at line 11 of file RunDCSLVDat.cc.

{
  m_env = nullptr;
  m_conn = nullptr;
  m_writeStmt = nullptr;
  m_readStmt = nullptr;

  m_lv = 0;
  m_lvnom = 0;
  m_status= 0;
  m_tstatus= 0;
}

RunDCSLVDat::~RunDCSLVDat ( )

override

Definition at line 26 of file RunDCSLVDat.cc.

{
}

Member Function Documentation

void RunDCSLVDat::fetchData ( std::map< EcalLogicID, RunDCSLVDat > *  fillMap, RunIOV *  iov  )

privatenoexcept

Definition at line 48 of file RunDCSLVDat.cc.

Referenced by setTimeStatus().

{
  fetchLastData(fillMap);

}

void RunDCSLVDat::fetchLastData ( std::map< EcalLogicID, RunDCSLVDat > *  fillMap )

privatenoexcept

Definition at line 184 of file RunDCSLVDat.cc.

References MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by setTimeStatus().

{
  this->checkConnection();

  fillMap->clear();

  try {
    std::pair< EcalLogicID, RunDCSLVDat > p;
    RunDCSLVDat dat;

    ResultSet* rset = getBarrelRset();
    
    fillTheMap(rset, fillMap);
    rset = getEndcapRset();
    
    fillTheMap(rset, fillMap);
  } 
  catch (SQLException &e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSLVDat::fetchData():  ")+e.getMessage()));
#else
    throw(std::runtime_error(std::string("RunDCSLVDat::fetchData():  error code ") + std::to_string(e.getErrorCode())));
#endif
  }
}

void RunDCSLVDat::fillTheMap ( ResultSet *  rset, std::map< EcalLogicID, RunDCSLVDat > *  fillMap  )

private

Definition at line 97 of file RunDCSLVDat.cc.

References DateHandler::dateToTm(), cuy::dh, MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, setLV(), setLVNominal(), setStatus(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by setTimeStatus().

                                                             {
  std::pair< EcalLogicID, RunDCSLVDat > p;
  RunDCSLVDat dat;
  DateHandler dh(m_env, m_conn);

  try {
    while(rset->next()) {
      p.first = EcalLogicID( rset->getString(1),     // name
                 rset->getInt(2),        // logic_id
                 rset->getInt(3),        // id1
                 rset->getInt(4),        // id2
                 rset->getInt(5),        // id3
                 rset->getString(6));    // maps_to
      
      dat.setLV(        rset->getFloat(7) );
      dat.setLVNominal( rset->getFloat(8) );
      Date sinceDate = rset->getDate(9);
      Tm  sinceTm = dh.dateToTm( sinceDate );
      dat.setStatus(0);
      if (p.first.getName() == "EB_LV_channel") {
    setStatusForBarrel(dat, sinceTm);      
      } else {
    setStatusForEndcaps(dat, sinceTm);      
      }
      p.second = dat;
      fillMap->insert(p);
    } 
  }
  catch (SQLException &e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSLVDat::fetchData():  ")+e.getMessage()));
#else
    throw(std::runtime_error(std::string("RunDCSLVDat::fetchData():  error code ") + std::to_string(e.getErrorCode())));
#endif
  }
}

ResultSet * RunDCSLVDat::getBarrelRset ( )

private

Definition at line 55 of file RunDCSLVDat.cc.

References MillePedeFileConverter_cfg::e, das::query(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by setTimeStatus().

                                      {
  ResultSet* rset = nullptr;
  string query = "SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
    " d.value_number , '5' NOMINAL_VALUE , d.VALUE_TIMESTAMP "
    "FROM "+ getEBAccount()+".FWWIENERMARATHONCHANNEL_LV d "
    " JOIN "+ getEBAccount()+".LV_MAPPING h on "
    " h.DPID = d.DPID join channelview cv on cv.logic_id=h.logic_id WHERE cv.maps_to = cv.name and dpe_name='MEASUREMENTSENSEVOLTAGE' "; 
  try {
    m_readStmt->setSQL(query);
    rset = m_readStmt->executeQuery();
  }
  catch (SQLException &e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSLVDat::getBarrelRset():  ") + e.getMessage() + " " + query));
#else
    throw(std::runtime_error(std::string("RunDCSLVDat::getBarrelRset():  error code ") + std::to_string(e.getErrorCode()) + " " + query));
#endif
  }
  return rset;
}

std::string RunDCSLVDat::getEBAccount ( )

inline

Definition at line 32 of file RunDCSLVDat.h.

{ return "CMS_ECAL_LV_PVSS_COND"; }

std::string RunDCSLVDat::getEEAccount ( )

inline

Definition at line 33 of file RunDCSLVDat.h.

{ return "CMS_ECAL_LV_PVSS_COND"; }

ResultSet * RunDCSLVDat::getEndcapRset ( )

private

Definition at line 76 of file RunDCSLVDat.cc.

References MillePedeFileConverter_cfg::e, das::query(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by setTimeStatus().

                                      {
  ResultSet* rset = nullptr;
  string query = "SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
    " d.VALUE_NUMBER, '5' NOMINAL_VALUE , d.VALUE_TIMESTAMP "
    "FROM "+ getEEAccount()+".FWWIENERMARATHONCHANNEL_LV d "
    " JOIN "+ getEEAccount()+".EE_LV_MAPPING h on "
    " h.DPID = d.DPID join channelview cv on cv.logic_id=h.logic_id WHERE cv.maps_to = cv.name and dpe_name='MEASUREMENTSENSEVOLTAGE' "; 
  try {
    m_readStmt->setSQL(query);
    rset = m_readStmt->executeQuery();
  }
  catch (SQLException &e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSLVDat::getEndcapRset():  ") + e.getMessage() + " " + query));
#else
    throw(std::runtime_error(std::string("RunDCSLVDat::getEndcapRset():  error code ") + std::to_string(e.getErrorCode()) + " " + query));
#endif
  }
  return rset;
}

float RunDCSLVDat::getLV ( ) const

inline

Definition at line 37 of file RunDCSLVDat.h.

References m_lv.

Referenced by popcon::EcalDCSHandler::insertLVDataSetToOffline(), popcon::EcalDCSHandler::printLVDataSet(), setStatusForBarrel(), and setStatusForEndcaps().

{ return m_lv; }

float RunDCSLVDat::getLVNominal ( ) const

inline

Definition at line 38 of file RunDCSLVDat.h.

References m_lvnom.

Referenced by popcon::EcalDCSHandler::insertLVDataSetToOffline(), popcon::EcalDCSHandler::printLVDataSet(), setStatusForBarrel(), and setStatusForEndcaps().

{ return m_lvnom; }

int RunDCSLVDat::getStatus ( ) const

inline

Definition at line 39 of file RunDCSLVDat.h.

References m_status.

Referenced by popcon::EcalDCSHandler::printLVDataSet(), and popcon::EcalDCSHandler::updateLV().

{ return m_status; }

std::string RunDCSLVDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 31 of file RunDCSLVDat.h.

{ return ""; }

int RunDCSLVDat::getTimeStatus ( )

inline

Definition at line 40 of file RunDCSLVDat.h.

References m_tstatus.

{return m_tstatus;}

int RunDCSLVDat::nowMicroseconds ( )

private

Definition at line 135 of file RunDCSLVDat.cc.

References Tm::microsTime(), and Tm::setToCurrentGMTime().

Referenced by setTimeStatus().

                                  {
  Tm t_now_gmt;
  
  t_now_gmt.setToCurrentGMTime();
  int t_now_gmt_micros = t_now_gmt.microsTime();
  return t_now_gmt_micros;
}

void RunDCSLVDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 32 of file RunDCSLVDat.cc.

Referenced by setTimeStatus().

{


}

void RunDCSLVDat::setLV ( float  t )

inline

Definition at line 34 of file RunDCSLVDat.h.

References m_lv, and protons_cff::t.

Referenced by fillTheMap().

{ m_lv = t; }

void RunDCSLVDat::setLVNominal ( float  t )

inline

Definition at line 36 of file RunDCSLVDat.h.

References m_lvnom, and protons_cff::t.

Referenced by fillTheMap().

{ m_lvnom = t; }

void RunDCSLVDat::setStatus ( int  t )

inline

Definition at line 35 of file RunDCSLVDat.h.

References m_status, and protons_cff::t.

Referenced by fillTheMap(), setStatusForBarrel(), and setStatusForEndcaps().

{ m_status = t; }

void RunDCSLVDat::setStatusForBarrel ( RunDCSLVDat &  dat, const Tm &  sinceTm  )

private

Definition at line 144 of file RunDCSLVDat.cc.

References edmIntegrityCheck::d, getLV(), getLVNominal(), createfilelist::int, Tm::microsTime(), mps_fire::result, setStatus(), and setTimeStatus().

Referenced by setTimeStatus().

                                                                        {
  int t_now_gmt_micros = nowMicroseconds();

  if (fabs(dat.getLV() - dat.getLVNominal())*1000 > maxLVDifferenceEB) {
    dat.setStatus(LVNOTNOMINAL);
  }
  if (dat.getLV()*1000 < minLV) {
    dat.setStatus(LVOFF);
  }

  int result=0;
  int d= ((int)t_now_gmt_micros - (int)sinceTm.microsTime()) ;
  if (d> maxDifference) {
    result= -d/1000000 ;
  }
  dat.setTimeStatus(result);


}

void RunDCSLVDat::setStatusForEndcaps ( RunDCSLVDat &  dat, const Tm &  sinceTm  )

private

Definition at line 164 of file RunDCSLVDat.cc.

References edmIntegrityCheck::d, getLV(), getLVNominal(), createfilelist::int, Tm::microsTime(), mps_fire::result, setStatus(), and setTimeStatus().

Referenced by setTimeStatus().

                                                                          {
  int t_now_gmt_micros = nowMicroseconds();

  if (fabs(dat.getLV() - dat.getLVNominal())*1000 > maxLVDifferenceEE) {
    dat.setStatus(LVNOTNOMINAL);
  }
  if (dat.getLV()*1000 < minLV) {
    dat.setStatus(LVOFF);
  }

  int result=0;
  int d= ((int)t_now_gmt_micros - (int)sinceTm.microsTime()) ;
  if (d> maxDifference) {
    result= -d/1000000 ;
  }
  dat.setTimeStatus(result);


}

void RunDCSLVDat::setTimeStatus ( int  t )

inline

Definition at line 41 of file RunDCSLVDat.h.

References fetchData(), fetchLastData(), fillTheMap(), getBarrelRset(), getEndcapRset(), m_tstatus, noexcept, nowMicroseconds(), prepareWrite(), setStatusForBarrel(), setStatusForEndcaps(), protons_cff::t, and writeDB().

Referenced by setStatusForBarrel(), and setStatusForEndcaps().

{m_tstatus=t; } 

void RunDCSLVDat::writeDB ( const EcalLogicID *  ecid, const RunDCSLVDat *  item, RunIOV *  iov  )

privatenoexcept

Definition at line 41 of file RunDCSLVDat.cc.

Referenced by setTimeStatus().

{
}

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 26 of file RunDCSLVDat.h.

Member Data Documentation

const int RunDCSLVDat::LVNOTNOMINAL = 1

static

Definition at line 23 of file RunDCSLVDat.h.

Referenced by popcon::EcalDCSHandler::updateLV().

const int RunDCSLVDat::LVOFF = 2

static

Definition at line 24 of file RunDCSLVDat.h.

Referenced by popcon::EcalDCSHandler::updateLV().

float RunDCSLVDat::m_lv

private

Definition at line 63 of file RunDCSLVDat.h.

Referenced by getLV(), and setLV().

float RunDCSLVDat::m_lvnom

private

Definition at line 64 of file RunDCSLVDat.h.

Referenced by getLVNominal(), and setLVNominal().

int RunDCSLVDat::m_status

private

Definition at line 65 of file RunDCSLVDat.h.

Referenced by getStatus(), and setStatus().

int RunDCSLVDat::m_tstatus

private

Definition at line 66 of file RunDCSLVDat.h.

Referenced by getTimeStatus(), and setTimeStatus().

const int RunDCSLVDat::maxDifference = 30*60*1000000

static

Definition at line 18 of file RunDCSLVDat.h.

const int RunDCSLVDat::maxLVDifferenceEB = 1000

static

Definition at line 19 of file RunDCSLVDat.h.

const int RunDCSLVDat::maxLVDifferenceEE = 1000

static

Definition at line 20 of file RunDCSLVDat.h.

const int RunDCSLVDat::minLV = 2000

static

Definition at line 21 of file RunDCSLVDat.h.