RunInfoHandler Class Reference

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

override

Definition at line 16 of file RunInfoHandler.cc.

{}

RunInfoHandler()

RunInfoHandler::RunInfoHandler

(

const edm::ParameterSet &

pset

)

Definition at line 8 of file RunInfoHandler.cc.

    : 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

getNewObjects()

void RunInfoHandler::getNewObjects ( )

overridevirtual

Implements popcon::PopConSourceHandler< RunInfo >.

Definition at line 18 of file RunInfoHandler.cc.

                                   {
  //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.since << ", hash "
                                 << tagInfo().lastInterval.payloadId << 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.since >= m_since) {
    edm::LogWarning("RunInfoHandler") << "["
                                      << "RunInfoHandler::" << __func__ << "]:" << m_name << ": "
                                      << "last IOV " << tagInfo().lastInterval.since
                                      << (tagInfo().lastInterval.since == 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.since + 1) < m_since) {
    n_empty_run = m_since - tagInfo().lastInterval.since - 1;
    edm::LogInfo("RunInfoHandler") << "["
                                   << "RunInfoHandler::" << __func__ << "]:" << m_name << ": "
                                   << "entering fake run from " << tagInfo().lastInterval.since + 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.since + 1));
    ss << "fake run number: " << tagInfo().lastInterval.since + 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);
}

References RunInfoUpdate::appendNewRun(), popcon::PopConSourceHandler< RunInfo >::dbSession(), cond::TagInfo_t::lastInterval, 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, cond::Iov_t::payloadId, alignCSCRings::r, RunInfoRead::readData(), cond::Iov_t::since, cond::TagInfo_t::size, findQualityFiles::size, contentValuesCheck::ss, and popcon::PopConSourceHandler< RunInfo >::tagInfo().

id()

std::string RunInfoHandler::id ( ) const

inlineoverridevirtual

Implements popcon::PopConSourceHandler< RunInfo >.

Definition at line 13 of file RunInfoHandler.h.

{ return m_name; }

References m_name.

Member Data Documentation

m_connectionPset

edm::ParameterSet RunInfoHandler::m_connectionPset

private

Definition at line 25 of file RunInfoHandler.h.

Referenced by getNewObjects().

m_connectionString

std::string RunInfoHandler::m_connectionString

private

Definition at line 24 of file RunInfoHandler.h.

Referenced by getNewObjects().

m_dcsenv_schema

std::string RunInfoHandler::m_dcsenv_schema

private

Definition at line 23 of file RunInfoHandler.h.

Referenced by getNewObjects().

m_name

std::string RunInfoHandler::m_name

private

Definition at line 19 of file RunInfoHandler.h.

Referenced by getNewObjects(), and id().

m_runinfo_schema

std::string RunInfoHandler::m_runinfo_schema

private

Definition at line 22 of file RunInfoHandler.h.

Referenced by getNewObjects().

m_since

unsigned long long RunInfoHandler::m_since

private

Definition at line 18 of file RunInfoHandler.h.

Referenced by getNewObjects().