#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 const int	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

◆ ResultSet

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

Definition at line 16 of file RunDCSLVDat.h.

Constructor & Destructor Documentation

◆ RunDCSLVDat()

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::~RunDCSLVDat ( )

override

Definition at line 23 of file RunDCSLVDat.cc.

23 {}

Member Function Documentation

◆ fetchData()

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

privatenoexcept

Definition at line 29 of file RunDCSLVDat.cc.

                                                                                                {
   fetchLastData(fillMap);
 }

◆ fetchLastData()

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

privatenoexcept

Definition at line 167 of file RunDCSLVDat.cc.

                                                                                       {
   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
   }
 }

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

◆ fillTheMap()

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

private

Definition at line 87 of file RunDCSLVDat.cc.

                                                                                     {
   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
   }
 }

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

◆ getBarrelRset()

ResultSet * RunDCSLVDat::getBarrelRset ( )

private

Definition at line 33 of file RunDCSLVDat.cc.

                                       {
   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;
 }

References MillePedeFileConverter_cfg::e, contentValuesFiles::query, and AlCaHLTBitMon_QueryRunRegistry::string.

◆ getEBAccount()

std::string RunDCSLVDat::getEBAccount ( )

inline

Definition at line 32 of file RunDCSLVDat.h.

32 { return "CMS_ECAL_LV_PVSS_COND"; }

◆ getEEAccount()

std::string RunDCSLVDat::getEEAccount ( )

inline

Definition at line 33 of file RunDCSLVDat.h.

33 { return "CMS_ECAL_LV_PVSS_COND"; }

◆ getEndcapRset()

ResultSet * RunDCSLVDat::getEndcapRset ( )

private

Definition at line 60 of file RunDCSLVDat.cc.

                                       {
   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;
 }

References MillePedeFileConverter_cfg::e, contentValuesFiles::query, and AlCaHLTBitMon_QueryRunRegistry::string.

◆ getLV()

float RunDCSLVDat::getLV ( ) const

inline

Definition at line 37 of file RunDCSLVDat.h.

37 { return m_lv; }

References m_lv.

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

◆ getLVNominal()

float RunDCSLVDat::getLVNominal ( ) const

inline

Definition at line 38 of file RunDCSLVDat.h.

38 { return m_lvnom; }

References m_lvnom.

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

◆ getStatus()

int RunDCSLVDat::getStatus ( ) const

inline

Definition at line 39 of file RunDCSLVDat.h.

39 { return m_status; }

References m_status.

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

◆ getTable()

std::string RunDCSLVDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 31 of file RunDCSLVDat.h.

31 { return ""; }

◆ getTimeStatus()

int RunDCSLVDat::getTimeStatus ( )

inline

Definition at line 40 of file RunDCSLVDat.h.

40 { return m_tstatus; }

References m_tstatus.

◆ nowMicroseconds()

int RunDCSLVDat::nowMicroseconds ( )

private

Definition at line 123 of file RunDCSLVDat.cc.

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

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

◆ prepareWrite()

void RunDCSLVDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 25 of file RunDCSLVDat.cc.

25 {}

◆ setLV()

void RunDCSLVDat::setLV ( float t )

inline

Definition at line 34 of file RunDCSLVDat.h.

34 { m_lv = t; }

References m_lv, and submitPVValidationJobs::t.

Referenced by fillTheMap().

◆ setLVNominal()

void RunDCSLVDat::setLVNominal ( float t )

inline

Definition at line 36 of file RunDCSLVDat.h.

36 { m_lvnom = t; }

References m_lvnom, and submitPVValidationJobs::t.

Referenced by fillTheMap().

◆ setStatus()

void RunDCSLVDat::setStatus ( int t )

inline

Definition at line 35 of file RunDCSLVDat.h.

35 { m_status = t; }

References m_status, and submitPVValidationJobs::t.

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

◆ setStatusForBarrel()

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

private

Definition at line 131 of file RunDCSLVDat.cc.

                                                                         {
   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);
 }

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

◆ setStatusForEndcaps()

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

private

Definition at line 149 of file RunDCSLVDat.cc.

                                                                          {
   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);
 }

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

◆ setTimeStatus()

void RunDCSLVDat::setTimeStatus ( int t )

inline

Definition at line 41 of file RunDCSLVDat.h.

41 { m_tstatus = t; }

References m_tstatus, and submitPVValidationJobs::t.

Referenced by setStatusForBarrel(), and setStatusForEndcaps().

◆ writeDB()

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

privatenoexcept

Definition at line 27 of file RunDCSLVDat.cc.

27 {}

Friends And Related Function Documentation

◆ EcalCondDBInterface

friend class EcalCondDBInterface

friend

Definition at line 26 of file RunDCSLVDat.h.

Member Data Documentation

◆ LVNOTNOMINAL

const int RunDCSLVDat::LVNOTNOMINAL = 1

static

Definition at line 23 of file RunDCSLVDat.h.

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

◆ LVOFF

const int RunDCSLVDat::LVOFF = 2

static

Definition at line 24 of file RunDCSLVDat.h.

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

◆ m_lv

float RunDCSLVDat::m_lv

private

Definition at line 59 of file RunDCSLVDat.h.

Referenced by getLV(), and setLV().

◆ m_lvnom

float RunDCSLVDat::m_lvnom

private

Definition at line 60 of file RunDCSLVDat.h.

Referenced by getLVNominal(), and setLVNominal().

◆ m_status

int RunDCSLVDat::m_status

private

Definition at line 61 of file RunDCSLVDat.h.

Referenced by getStatus(), and setStatus().

◆ m_tstatus

int RunDCSLVDat::m_tstatus

private

Definition at line 62 of file RunDCSLVDat.h.

Referenced by getTimeStatus(), and setTimeStatus().

◆ maxDifference

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

static

Definition at line 18 of file RunDCSLVDat.h.

◆ maxLVDifferenceEB

const int RunDCSLVDat::maxLVDifferenceEB = 1000

static

Definition at line 19 of file RunDCSLVDat.h.

◆ maxLVDifferenceEE

const int RunDCSLVDat::maxLVDifferenceEE = 1000

static

Definition at line 20 of file RunDCSLVDat.h.

◆ minLV

const int RunDCSLVDat::minLV = 2000

static

Definition at line 21 of file RunDCSLVDat.h.

Public Types

Public Member Functions

Static Public Attributes

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ResultSet

Constructor & Destructor Documentation

◆ RunDCSLVDat()

◆ ~RunDCSLVDat()

Member Function Documentation

◆ fetchData()

◆ fetchLastData()

◆ fillTheMap()

◆ getBarrelRset()

◆ getEBAccount()

◆ getEEAccount()

◆ getEndcapRset()

◆ getLV()

◆ getLVNominal()

◆ getStatus()

◆ getTable()

◆ getTimeStatus()

◆ nowMicroseconds()

◆ prepareWrite()

◆ setLV()

◆ setLVNominal()

◆ setStatus()

◆ setStatusForBarrel()

◆ setStatusForEndcaps()

◆ setTimeStatus()

◆ writeDB()

Friends And Related Function Documentation

◆ EcalCondDBInterface

Member Data Documentation

◆ LVNOTNOMINAL

◆ LVOFF

◆ m_lv

◆ m_lvnom

◆ m_status

◆ m_tstatus

◆ maxDifference

◆ maxLVDifferenceEB

◆ maxLVDifferenceEE

◆ minLV