#include <RunInfoHandler.h>

Inheritance diagram for RunInfoHandler:

Public Member Functions
void	getNewObjects () override

std::string	id () const override

	RunInfoHandler (const edm::ParameterSet &pset)

	~RunInfoHandler () override

Public Member Functions inherited from popcon::PopConSourceHandler< RunInfo >
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 Attributes
edm::ParameterSet	m_connectionPset

std::string	m_connectionString

std::string	m_dcsenv_schema

std::string	m_name

std::string	m_runinfo_schema

unsigned long long	m_since

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< RunInfo >
typedef std::vector< Triplet >	Container

typedef std::vector< std::pair< RunInfo *, cond::Time_t > >	OldContainer

typedef PopConSourceHandler< RunInfo >	self

typedef cond::Summary	Summary

typedef cond::Time_t	Time_t

typedef RunInfo	value_type

Protected Member Functions inherited from popcon::PopConSourceHandler< RunInfo >
int	add (value_type payload, Summary summary, Time_t time)

cond::persistency::Session &	dbSession () const

Protected Attributes inherited from popcon::PopConSourceHandler< RunInfo >
OldContainer	m_to_transfer

std::string	m_userTextLog

Detailed Description

Definition at line 10 of file RunInfoHandler.h.

Constructor & Destructor Documentation

RunInfoHandler::~RunInfoHandler ( )

override

Definition at line 16 of file RunInfoHandler.cc.

Referenced by id().

16 {}

RunInfoHandler::RunInfoHandler ( const edm::ParameterSet & pset )

Definition at line 8 of file RunInfoHandler.cc.

Referenced by id().

     : m_since(pset.getParameter<unsigned long long>("runNumber")),
       m_name(pset.getUntrackedParameter<std::string>("name", "RunInfoHandler")),
       m_runinfo_schema(pset.getUntrackedParameter<std::string>("RunInfoSchema", "CMS_RUNINFO")),
       m_dcsenv_schema(pset.getUntrackedParameter<std::string>("DCSEnvSchema", "CMS_DCS_ENV_PVSS_COND")),
       m_connectionString(pset.getParameter<std::string>("connect")),
       m_connectionPset(pset.getParameter<edm::ParameterSet>("DBParameters")) {}

Member Function Documentation

void RunInfoHandler::getNewObjects ( )

overridevirtual

Implements popcon::PopConSourceHandler< RunInfo >.

Definition at line 18 of file RunInfoHandler.cc.

References RunInfoUpdate::appendNewRun(), popcon::PopConSourceHandler< RunInfo >::dbSession(), RunInfo::Fake_RunInfo(), cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, m_connectionPset, m_connectionString, m_dcsenv_schema, m_name, m_runinfo_schema, m_since, popcon::PopConSourceHandler< RunInfo >::m_to_transfer, popcon::PopConSourceHandler< RunInfo >::m_userTextLog, cond::TagInfo_t::name, alignCSCRings::r, RunInfoRead::readData(), cond::TagInfo_t::size, findQualityFiles::size, contentValuesCheck::ss, and popcon::PopConSourceHandler< RunInfo >::tagInfo().

                                    {
   //check whats already inside of database
   edm::LogInfo("RunInfoHandler") << "["
                                  << "RunInfoHandler::" << __func__ << "]:" << m_name << ": "
                                  << "Destination Tag Info: name " << tagInfo().name << ", size " << tagInfo().size
                                  << ", last object valid since " << tagInfo().lastInterval.first << ", hash "
                                  << tagInfo().lastPayloadToken << std::endl;
   edm::LogInfo("RunInfoHandler") << "["
                                  << "RunInfoHandler::" << __func__ << "]:" << m_name
                                  << ": runnumber/first since = " << m_since << std::endl;
 
   //check if a transfer is needed:
   //if the new run number is smaller than or equal to the latest IOV, exit.
   //This is needed as now the IOV Editor does not always protect for insertions:
   //ANY and VALIDATION sychronizations are allowed to write in the past.
   if (tagInfo().size > 0 && tagInfo().lastInterval.first >= m_since) {
     edm::LogWarning("RunInfoHandler") << "["
                                       << "RunInfoHandler::" << __func__ << "]:" << m_name << ": "
                                       << "last IOV " << tagInfo().lastInterval.first
                                       << (tagInfo().lastInterval.first == m_since ? " is equal to" : " is larger than")
                                       << " the run proposed for insertion " << m_since << ". No transfer needed."
                                       << std::endl;
     return;
   }
 
   RunInfo* r = new RunInfo();
 
   //fill with null runinfo if empty run are found beetween the two last valid ones
   size_t n_empty_run = 0;
   if (tagInfo().size > 0 && (tagInfo().lastInterval.first + 1) < m_since) {
     n_empty_run = m_since - tagInfo().lastInterval.first - 1;
     edm::LogInfo("RunInfoHandler") << "["
                                    << "RunInfoHandler::" << __func__ << "]:" << m_name << ": "
                                    << "entering fake run from " << tagInfo().lastInterval.first + 1 << " to "
                                    << m_since - 1 << std::endl;
   }
   std::ostringstream ss;
   // transfer fake run for 1 to since for the first time
   if (tagInfo().size == 0 && m_since != 1) {
     m_to_transfer.push_back(std::make_pair((RunInfo*)(r->Fake_RunInfo()), 1));
     ss << "fake run number: " << 1 << ", ";
   }
   if (n_empty_run != 0) {
     m_to_transfer.push_back(std::make_pair((RunInfo*)(r->Fake_RunInfo()), tagInfo().lastInterval.first + 1));
     ss << "fake run number: " << tagInfo().lastInterval.first + 1 << ", ";
   }
 
   //reading from omds
   RunInfoRead rn(m_connectionString, m_connectionPset);
   *r = rn.readData(m_runinfo_schema, m_dcsenv_schema, (int)m_since);
   m_to_transfer.push_back(std::make_pair((RunInfo*)r, m_since));
   ss << "run number: " << m_since << ";";
   m_userTextLog = ss.str();
   edm::LogInfo("RunInfoHandler") << "["
                                  << "RunInfoHandler::" << __func__ << "]:" << m_name << ": END." << std::endl;
   // update runinfo table in conditions db
   RunInfoUpdate updater(dbSession());
   updater.appendNewRun(*r);
 }