#include <BeamSpotOnlinePopConSourceHandler.h>

Inheritance diagram for BeamSpotOnlinePopConSourceHandler:

Public Member Functions
	BeamSpotOnlinePopConSourceHandler (const edm::ParameterSet &pset)

void	getNewObjects () override

std::string	id () const override

	~BeamSpotOnlinePopConSourceHandler () override

Public Member Functions inherited from popcon::PopConSourceHandler< BeamSpotOnlineObjects >
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 ()

cond::TagInfo_t const &	tagInfo () const

std::string const &	userTextLog () const

virtual	~PopConSourceHandler ()

Private Attributes
bool	m_debug

unsigned int	m_maxAge

std::string	m_name

std::unique_ptr< BeamSpotOnlineObjects >	m_payload

unsigned int	m_runNumber

std::string	m_sourcePayloadTag

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< BeamSpotOnlineObjects >
typedef std::map< Time_t, std::shared_ptr< BeamSpotOnlineObjects > >	Container

typedef std::unique_ptr< BeamSpotOnlineObjects >	Ref

typedef PopConSourceHandler< BeamSpotOnlineObjects >	self

typedef cond::Time_t	Time_t

typedef BeamSpotOnlineObjects	value_type

Protected Member Functions inherited from popcon::PopConSourceHandler< BeamSpotOnlineObjects >
cond::persistency::Session &	dbSession () const

Protected Attributes inherited from popcon::PopConSourceHandler< BeamSpotOnlineObjects >
Container	m_iovs

std::vector< std::pair< BeamSpotOnlineObjects *, Time_t > >	m_to_transfer

std::string	m_userTextLog

Detailed Description

Definition at line 10 of file BeamSpotOnlinePopConSourceHandler.h.

Constructor & Destructor Documentation

◆ BeamSpotOnlinePopConSourceHandler()

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

Definition at line 9 of file BeamSpotOnlinePopConSourceHandler.cc.

     : m_debug(pset.getUntrackedParameter<bool>("debug", false)),
       m_name(pset.getUntrackedParameter<std::string>("name", "BeamSpotOnlineSourceHandler")),
       m_maxAge(pset.getUntrackedParameter<unsigned int>("maxAge", 86400)),
       m_runNumber(pset.getUntrackedParameter<unsigned int>("runNumber", 1)),
       m_sourcePayloadTag(pset.getUntrackedParameter<std::string>("sourcePayloadTag", "")) {}

◆ ~BeamSpotOnlinePopConSourceHandler()

BeamSpotOnlinePopConSourceHandler::~BeamSpotOnlinePopConSourceHandler ( )

override

Definition at line 16 of file BeamSpotOnlinePopConSourceHandler.cc.

16 {}

Member Function Documentation

◆ getNewObjects()

void BeamSpotOnlinePopConSourceHandler::getNewObjects ( )

overridevirtual

Implements popcon::PopConSourceHandler< BeamSpotOnlineObjects >.

Definition at line 36 of file BeamSpotOnlinePopConSourceHandler.cc.

References checkPayloadAge(), popcon::PopConSourceHandler< BeamSpotOnlineObjects >::dbSession(), cond::TagInfo_t::lastInterval, popcon::PopConSourceHandler< BeamSpotOnlineObjects >::lastPayload(), cond::time::lumiTime(), m_maxAge, m_name, m_payload, m_runNumber, m_sourcePayloadTag, popcon::PopConSourceHandler< BeamSpotOnlineObjects >::m_to_transfer, makeDummyPayload(), cond::TagInfo_t::name, run_AlCaRecoTriggerBitsUpdateWorkflow::session, cond::Iov_t::since, findQualityFiles::size, and popcon::PopConSourceHandler< BeamSpotOnlineObjects >::tagInfo().

                                                       {
   bool addNewPayload = false;
   if (!tagInfo().size) {
     edm::LogInfo(m_name) << "New tag " << tagInfo().name << "; from " << m_name << "::getNewObjects";
     addNewPayload = true;
   } else {
     edm::LogInfo(m_name) << "got info for tag " << tagInfo().name << ", last object valid since "
                          << tagInfo().lastInterval.since << "; from " << m_name << "::getNewObjects";
     if (!checkPayloadAge(*lastPayload(), m_maxAge)) {
       addNewPayload = true;
     }
   }
 
   if (addNewPayload) {
     if (!m_sourcePayloadTag.empty()) {
       edm::LogInfo(m_name) << "Reading target payload from tag " << m_sourcePayloadTag;
       auto session = dbSession();
       session.transaction().start(true);
       auto lastIov = session.readIov(m_sourcePayloadTag).getLast();
       m_payload = session.fetchPayload<BeamSpotOnlineObjects>(lastIov.payloadId);
       session.transaction().commit();
     } else {
       m_payload = makeDummyPayload();
     }
 
     cond::Time_t targetTime = cond::time::lumiTime(m_runNumber, 1);
     m_to_transfer.push_back(std::make_pair(m_payload.get(), targetTime));
 
     edm::LogInfo(m_name) << "Payload added with IOV since " << targetTime;
   } else {
     edm::LogInfo(m_name) << "Nothing to do, last payload satisfies maximum age requirement.";
   }
 }