#include <LHCInfoPerFillPopConSourceHandler.h>
Public Member Functions | |
void | getNewObjects () override |
std::string | id () const override |
LHCInfoPerFillPopConSourceHandler (edm::ParameterSet const &pset) | |
~LHCInfoPerFillPopConSourceHandler () override=default | |
Public Member Functions inherited from popcon::PopConSourceHandler< LHCInfoPerFill > | |
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 Member Functions | |
void | addEmptyPayload (cond::Time_t iov) |
void | addPayloadToBuffer (cond::OMSServiceResultRef &row) |
void | convertBufferedIovsToLumiid (std::map< cond::Time_t, cond::Time_t > timestampToLumiid) |
bool | getCTPPSData (cond::persistency::Session &session, const boost::posix_time::ptime &beginFillTime, const boost::posix_time::ptime &endFillTime) |
void | getDipData (const cond::OMSService &oms, const boost::posix_time::ptime &beginFillTime, const boost::posix_time::ptime &endFillTime) |
bool | getEcalData (cond::persistency::Session &session, const boost::posix_time::ptime &lowerTime, const boost::posix_time::ptime &upperTime) |
size_t | getLumiData (const cond::OMSService &oms, unsigned short fillId, const boost::posix_time::ptime &beginFillTime, const boost::posix_time::ptime &endFillTime) |
Private Attributes | |
std::string | m_authpath |
std::string | m_connectionString |
bool | m_debug |
std::string | m_ecalConnectionString |
bool | m_endFillMode = true |
boost::posix_time::ptime | m_endTime |
std::unique_ptr< LHCInfoPerFill > | m_fillPayload |
bool | m_lastPayloadEmpty = false |
std::string | m_name |
std::string | m_omsBaseUrl |
std::shared_ptr< LHCInfoPerFill > | m_prevPayload |
boost::posix_time::ptime | m_startTime |
std::map< cond::Time_t, cond::Time_t > | m_timestampToLumiid |
std::vector< std::pair< cond::Time_t, std::shared_ptr< LHCInfoPerFill > > > | m_tmpBuffer |
Additional Inherited Members | |
Public Types inherited from popcon::PopConSourceHandler< LHCInfoPerFill > | |
typedef std::map< Time_t, std::shared_ptr< LHCInfoPerFill > > | Container |
typedef std::unique_ptr< LHCInfoPerFill > | Ref |
typedef PopConSourceHandler< LHCInfoPerFill > | self |
typedef cond::Time_t | Time_t |
typedef LHCInfoPerFill | value_type |
Protected Member Functions inherited from popcon::PopConSourceHandler< LHCInfoPerFill > | |
cond::persistency::Session & | dbSession () const |
Protected Attributes inherited from popcon::PopConSourceHandler< LHCInfoPerFill > | |
Container | m_iovs |
std::vector< std::pair< LHCInfoPerFill *, Time_t > > | m_to_transfer |
std::string | m_userTextLog |
Definition at line 6 of file LHCInfoPerFillPopConSourceHandler.h.
LHCInfoPerFillPopConSourceHandler::LHCInfoPerFillPopConSourceHandler | ( | edm::ParameterSet const & | pset | ) |
Definition at line 197 of file LHCInfoPerFillPopConSourceHandler.cc.
References m_endTime, m_startTime, submitPVValidationJobs::now, muonDTDigis_cfi::pset, and AlCaHLTBitMon_QueryRunRegistry::string.
|
overridedefault |
|
private |
Definition at line 389 of file LHCInfoPerFillPopConSourceHandler.cc.
References PVValHelper::add(), popcon::PopConSourceHandler< LHCInfoPerFill >::m_iovs, m_lastPayloadEmpty, m_name, m_prevPayload, and cond::time::to_boost().
Referenced by getNewObjects().
|
private |
Definition at line 410 of file LHCInfoPerFillPopConSourceHandler.cc.
References EcalPhiSymFlatTableProducers_cfi::delivLumi, cond::time::from_boost(), cond::OMSServiceResultRef::get(), cond::lumiid, cond::time::lumiTime(), m_endFillMode, m_fillPayload, m_timestampToLumiid, m_tmpBuffer, jetsAK4_Puppi_cff::payload, EcalPhiSymFlatTableProducers_cfi::recLumi, convertSQLiteXML::runNumber, dcs_print_summary_cfg::startTime, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by getLumiData().
|
private |
Definition at line 428 of file LHCInfoPerFillPopConSourceHandler.cc.
References Exception, B2GTnPMonitor_cfi::item, and m_tmpBuffer.
Referenced by getNewObjects().
|
private |
Definition at line 532 of file LHCInfoPerFillPopConSourceHandler.cc.
References ALCARECOTkAlBeamHalo_cff::filter, cond::time::from_boost(), ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, m_debug, m_name, m_tmpBuffer, jetsAK4_Puppi_cff::payload, runTheMatrix::ret, convertSQLiteXML::runNumber, run_AlCaRecoTriggerBitsUpdateWorkflow::session, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by getNewObjects().
|
private |
Definition at line 470 of file LHCInfoPerFillPopConSourceHandler.cc.
References m_fillPayload, cond::OMSService::query(), and FCDTask_cfi::slot.
Referenced by getNewObjects().
|
private |
Definition at line 639 of file LHCInfoPerFillPopConSourceHandler.cc.
References ECAL, ALCARECOTkAlBeamHalo_cff::filter, cond::time::from_boost(), CommonMethods::isnan(), ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, m_debug, m_name, m_prevPayload, m_tmpBuffer, jetsAK4_Puppi_cff::payload, runTheMatrix::ret, run_AlCaRecoTriggerBitsUpdateWorkflow::session, theLHCInfoPerFillImpl::setElementData(), AlCaHLTBitMon_QueryRunRegistry::string, hcalRecHitTable_cff::time, and cond::time::to_boost().
Referenced by getNewObjects().
|
private |
Definition at line 441 of file LHCInfoPerFillPopConSourceHandler.cc.
References addPayloadToBuffer(), cond::lhcInfoHelper::kLumisectionsQueryLimit, m_endFillMode, m_name, and cond::OMSService::query().
Referenced by getNewObjects().
|
overridevirtual |
Implements popcon::PopConSourceHandler< LHCInfoPerFill >.
Definition at line 222 of file LHCInfoPerFillPopConSourceHandler.cc.
References addEmptyPayload(), cond::persistency::Transaction::commit(), theLHCInfoPerFillImpl::comparePayloads(), cond::persistency::ConnectionPool::configure(), cond::OMSService::connect(), convertBufferedIovsToLumiid(), cond::persistency::ConnectionPool::createSession(), popcon::PopConSourceHandler< LHCInfoPerFill >::dbSession(), Debug, Exception, cond::persistency::Session::fetchPayload(), cond::time::from_boost(), getCTPPSData(), getDipData(), getEcalData(), cond::lhcInfoHelper::getFillLastLumiIOV(), getLumiData(), cond::TagInfo_t::lastInterval, m_authpath, m_connectionString, m_debug, m_ecalConnectionString, m_endFillMode, m_endTime, m_fillPayload, popcon::PopConSourceHandler< LHCInfoPerFill >::m_iovs, m_name, m_omsBaseUrl, m_prevPayload, m_startTime, m_timestampToLumiid, m_tmpBuffer, theLHCInfoPerFillImpl::makeFillPayload(), WZElectronSkims53X_cff::max, cond::TagInfo_t::name, cond::Iov_t::payloadId, cond::OMSService::query(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, cond::persistency::ConnectionPool::setAuthenticationPath(), cond::persistency::ConnectionPool::setMessageVerbosity(), cond::Iov_t::since, cond::TagInfo_t::size, findQualityFiles::size, cond::OMSServiceQuery::SNULL, cond::persistency::Transaction::start(), popcon::PopConSourceHandler< LHCInfoPerFill >::tagInfo(), cond::time::to_boost(), cond::persistency::Session::transaction(), and theLHCInfoPerFillImpl::transferPayloads().
|
overridevirtual |
Implements popcon::PopConSourceHandler< LHCInfoPerFill >.
Definition at line 387 of file LHCInfoPerFillPopConSourceHandler.cc.
References m_name.
|
private |
Definition at line 47 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by getNewObjects().
|
private |
Definition at line 46 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by getNewObjects().
|
private |
Definition at line 39 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by getCTPPSData(), getEcalData(), and getNewObjects().
|
private |
Definition at line 46 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by getNewObjects().
|
private |
Definition at line 43 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by addPayloadToBuffer(), getLumiData(), and getNewObjects().
|
private |
Definition at line 42 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by getNewObjects(), and LHCInfoPerFillPopConSourceHandler().
|
private |
Definition at line 49 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by addPayloadToBuffer(), getDipData(), and getNewObjects().
|
private |
Definition at line 52 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by addEmptyPayload().
|
private |
Definition at line 44 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by addEmptyPayload(), getCTPPSData(), getEcalData(), getLumiData(), getNewObjects(), and id().
|
private |
Definition at line 48 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by getNewObjects().
|
private |
Definition at line 50 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by addEmptyPayload(), getEcalData(), and getNewObjects().
|
private |
Definition at line 41 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by getNewObjects(), and LHCInfoPerFillPopConSourceHandler().
|
private |
Definition at line 54 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by addPayloadToBuffer(), and getNewObjects().
|
private |
Definition at line 51 of file LHCInfoPerFillPopConSourceHandler.h.
Referenced by addPayloadToBuffer(), convertBufferedIovsToLumiid(), getCTPPSData(), getEcalData(), and getNewObjects().