#include <ConnectionPool.h>
Public Member Functions | |
void | configure () |
ConnectionPool () | |
std::shared_ptr< coral::ISessionProxy > | createCoralSession (const std::string &connectionString, bool writeCapable=false) |
Session | createReadOnlySession (const std::string &connectionString, const std::string &transactionId) |
Session | createSession (const std::string &connectionString, bool writeCapable=false) |
bool | isLoggingEnabled () const |
void | setAuthenticationPath (const std::string &p) |
void | setAuthenticationSystem (int authSysCode) |
void | setConnectionTimeout (int seconds) |
void | setFrontierSecurity (const std::string &signature) |
void | setLogDestination (Logger &logger) |
void | setLogging (bool flag) |
void | setMessageVerbosity (coral::MsgLevel level) |
void | setParameters (const edm::ParameterSet &connectionPset) |
~ConnectionPool () | |
Private Member Functions | |
void | configure (coral::IConnectionServiceConfiguration &coralConfig) |
std::shared_ptr< coral::ISessionProxy > | createCoralSession (const std::string &connectionString, const std::string &transactionId, bool writeCapable=false) |
Session | createSession (const std::string &connectionString, const std::string &transactionId, bool writeCapable=false) |
Private Attributes | |
std::string | m_authenticationService = std::string("") |
std::string | m_authPath = std::string("") |
int | m_authSys = 0 |
int | m_connectionTimeout = 0 |
std::string | m_frontierSecurity = std::string("") |
bool | m_loggingEnabled = false |
coral::MsgLevel | m_messageLevel = coral::Error |
CoralMsgReporter * | m_msgReporter = nullptr |
cond::CoralServiceManager * | m_pluginManager = nullptr |
Definition at line 35 of file ConnectionPool.h.
cond::persistency::ConnectionPool::ConnectionPool | ( | ) |
Definition at line 26 of file ConnectionPool.cc.
References configure(), m_msgReporter, and m_pluginManager.
cond::persistency::ConnectionPool::~ConnectionPool | ( | ) |
Definition at line 33 of file ConnectionPool.cc.
References m_pluginManager.
void cond::persistency::ConnectionPool::configure | ( | ) |
Definition at line 129 of file ConnectionPool.cc.
Referenced by BeamSpotRcdPrinter::BeamSpotRcdPrinter(), CondDBESSource::CondDBESSource(), l1t::DataManager::connect(), ConnectionPool(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), FastSiPixelFEDChannelContainerFromQuality::FastSiPixelFEDChannelContainerFromQuality(), FillInfoPopConSourceHandler::getNewObjects(), LHCInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), LHCInfoPerLSPopConSourceHandler::getNewObjects(), LHCInfoPerFillPopConSourceHandler::getNewObjects(), popcon::PopCon::initialize(), SiStripCoralIface::initialize(), L1ConfigOnlineProdBase< L1HtMissScaleRcd, L1CaloEtScale >::L1ConfigOnlineProdBase(), L1ConfigOnlineProdBaseExt< L1TCaloParamsO2ORcd, l1t::CaloParams >::L1ConfigOnlineProdBaseExt(), popcon::PopConBTransitionSourceHandler< T >::PopConBTransitionSourceHandler(), popcon::PopConESTransitionSourceHandler< T >::PopConESTransitionSourceHandler(), RunInfoRead::readData(), RPCDCCLinkMapHandler::RPCDCCLinkMapHandler(), RPCLBLinkMapHandler::RPCLBLinkMapHandler(), SiStripDetVOffHandler::SiStripDetVOffHandler(), SiStripDetVOffPrinter::SiStripDetVOffPrinter(), SiStripDetVOffTkMapPlotter::SiStripDetVOffTkMapPlotter(), SiStripDetVOffTrendPlotter::SiStripDetVOffTrendPlotter(), SiStripPayloadHandler< SiStripPayload >::SiStripPayloadHandler(), and SiStripPayloadMapTableCreator::SiStripPayloadMapTableCreator().
|
private |
Definition at line 76 of file ConnectionPool.cc.
References lumi_dqm_sourceclient-live_cfg::authPath, cond::auth::COND_AUTH_PATH, cond::auth::COND_AUTH_PATH_PROPERTY, cond::auth::COND_AUTH_SYS, cond::persistency::CondDbKey, cond::persistency::CoralXMLFile, instance, m_authenticationService, m_authPath, m_authSys, m_connectionTimeout, m_messageLevel, m_msgReporter, m_pluginManager, cond::persistency::CoralMsgReporter::setOutputLevel(), and AlCaHLTBitMon_QueryRunRegistry::string.
std::shared_ptr< coral::ISessionProxy > cond::persistency::ConnectionPool::createCoralSession | ( | const std::string & | connectionString, |
bool | writeCapable = false |
||
) |
Definition at line 183 of file ConnectionPool.cc.
References l1RCTOmdsFedVectorProducer_cfi::connectionString.
Referenced by SiStripPayloadMapTableCreator::analyze(), createSession(), RPCDCCLinkMapHandler::getNewObjects(), RPCLBLinkMapHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), and RunInfoRead::readData().
|
private |
Definition at line 134 of file ConnectionPool.cc.
References cond::auth::COND_READER_ROLE, cond::auth::COND_WRITER_ROLE, l1RCTOmdsFedVectorProducer_cfi::connectionString, cond::persistency::getConnectionParams(), m_frontierSecurity, cond::persistency::TAG::tname, cond::persistency::PAYLOAD::tname, and cond::persistency::IOV::tname.
Session cond::persistency::ConnectionPool::createReadOnlySession | ( | const std::string & | connectionString, |
const std::string & | transactionId | ||
) |
Definition at line 178 of file ConnectionPool.cc.
References l1RCTOmdsFedVectorProducer_cfi::connectionString, and createSession().
Referenced by CondDBESSource::CondDBESSource(), and CondDBESSource::setIntervalFor().
Session cond::persistency::ConnectionPool::createSession | ( | const std::string & | connectionString, |
bool | writeCapable = false |
||
) |
Definition at line 174 of file ConnectionPool.cc.
References l1RCTOmdsFedVectorProducer_cfi::connectionString.
Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripDetVOffTrendPlotter::analyze(), BeamSpotRcdPrinter::analyze(), FastSiPixelFEDChannelContainerFromQuality::analyze(), l1t::DataManager::connect(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), createReadOnlySession(), CondDBESSource::fillTagCollectionFromGT(), FillInfoPopConSourceHandler::getNewObjects(), LHCInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), LHCInfoPerLSPopConSourceHandler::getNewObjects(), LHCInfoPerFillPopConSourceHandler::getNewObjects(), popcon::PopCon::initialize(), SiStripCoralIface::initialize(), L1ConfigOnlineProdBase< L1HtMissScaleRcd, L1CaloEtScale >::L1ConfigOnlineProdBase(), and L1ConfigOnlineProdBaseExt< L1TCaloParamsO2ORcd, l1t::CaloParams >::L1ConfigOnlineProdBaseExt().
|
private |
Definition at line 154 of file ConnectionPool.cc.
References l1RCTOmdsFedVectorProducer_cfi::connectionString, createCoralSession(), instance, m_authenticationService, cond::persistency::IDbAuthentication::principalName(), and AlCaHLTBitMon_QueryRunRegistry::string.
bool cond::persistency::ConnectionPool::isLoggingEnabled | ( | ) | const |
Definition at line 74 of file ConnectionPool.cc.
References m_loggingEnabled.
void cond::persistency::ConnectionPool::setAuthenticationPath | ( | const std::string & | p | ) |
Definition at line 35 of file ConnectionPool.cc.
References m_authPath, and AlCaHLTBitMon_ParallelJobs::p.
Referenced by l1t::DataManager::connect(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), FillInfoPopConSourceHandler::getNewObjects(), LHCInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), LHCInfoPerLSPopConSourceHandler::getNewObjects(), LHCInfoPerFillPopConSourceHandler::getNewObjects(), popcon::PopCon::initialize(), SiStripCoralIface::initialize(), L1ConfigOnlineProdBase< L1HtMissScaleRcd, L1CaloEtScale >::L1ConfigOnlineProdBase(), L1ConfigOnlineProdBaseExt< L1TCaloParamsO2ORcd, l1t::CaloParams >::L1ConfigOnlineProdBaseExt(), L1RCTOmdsFedVectorProducer::produce(), and setParameters().
void cond::persistency::ConnectionPool::setAuthenticationSystem | ( | int | authSysCode | ) |
Definition at line 37 of file ConnectionPool.cc.
References m_authSys.
Referenced by DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), popcon::PopCon::initialize(), and setParameters().
void cond::persistency::ConnectionPool::setConnectionTimeout | ( | int | seconds | ) |
Definition at line 190 of file ConnectionPool.cc.
References m_connectionTimeout, and seconds().
Referenced by setParameters().
void cond::persistency::ConnectionPool::setFrontierSecurity | ( | const std::string & | signature | ) |
Definition at line 39 of file ConnectionPool.cc.
References m_frontierSecurity, and signature.
Referenced by setParameters().
void cond::persistency::ConnectionPool::setLogDestination | ( | Logger & | logger | ) |
Definition at line 192 of file ConnectionPool.cc.
References m_msgReporter, and cond::persistency::CoralMsgReporter::subscribe().
void cond::persistency::ConnectionPool::setLogging | ( | bool | flag | ) |
Definition at line 41 of file ConnectionPool.cc.
References RemoveAddSevLevel::flag, and m_loggingEnabled.
Referenced by setParameters().
void cond::persistency::ConnectionPool::setMessageVerbosity | ( | coral::MsgLevel | level | ) |
Definition at line 188 of file ConnectionPool.cc.
References personalPlayback::level, and m_messageLevel.
Referenced by l1t::DataManager::connect(), FillInfoPopConSourceHandler::getNewObjects(), LHCInfoPopConSourceHandler::getNewObjects(), LHCInfoPerLSPopConSourceHandler::getNewObjects(), LHCInfoPerFillPopConSourceHandler::getNewObjects(), and setParameters().
void cond::persistency::ConnectionPool::setParameters | ( | const edm::ParameterSet & | connectionPset | ) |
Definition at line 43 of file ConnectionPool.cc.
References Debug, edm::ParameterSet::getUntrackedParameter(), personalPlayback::level, m_authPath, m_authSys, m_connectionTimeout, m_frontierSecurity, m_loggingEnabled, m_messageLevel, beam_dqm_sourceclient-live_cfg::messageLevel, setAuthenticationPath(), setAuthenticationSystem(), setConnectionTimeout(), setFrontierSecurity(), setLogging(), setMessageVerbosity(), and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by BeamSpotRcdPrinter::BeamSpotRcdPrinter(), CondDBESSource::CondDBESSource(), FastSiPixelFEDChannelContainerFromQuality::FastSiPixelFEDChannelContainerFromQuality(), popcon::PopConBTransitionSourceHandler< T >::PopConBTransitionSourceHandler(), popcon::PopConESTransitionSourceHandler< T >::PopConESTransitionSourceHandler(), RunInfoRead::readData(), RPCDCCLinkMapHandler::RPCDCCLinkMapHandler(), RPCLBLinkMapHandler::RPCLBLinkMapHandler(), SiStripDetVOffHandler::SiStripDetVOffHandler(), SiStripDetVOffPrinter::SiStripDetVOffPrinter(), SiStripDetVOffTkMapPlotter::SiStripDetVOffTkMapPlotter(), SiStripDetVOffTrendPlotter::SiStripDetVOffTrendPlotter(), SiStripPayloadHandler< SiStripPayload >::SiStripPayloadHandler(), and SiStripPayloadMapTableCreator::SiStripPayloadMapTableCreator().
|
private |
Definition at line 67 of file ConnectionPool.h.
Referenced by configure(), and createSession().
|
private |
Definition at line 65 of file ConnectionPool.h.
Referenced by configure(), setAuthenticationPath(), and setParameters().
|
private |
Definition at line 66 of file ConnectionPool.h.
Referenced by configure(), setAuthenticationSystem(), and setParameters().
|
private |
Definition at line 69 of file ConnectionPool.h.
Referenced by configure(), setConnectionTimeout(), and setParameters().
|
private |
Definition at line 74 of file ConnectionPool.h.
Referenced by createCoralSession(), setFrontierSecurity(), and setParameters().
|
private |
Definition at line 71 of file ConnectionPool.h.
Referenced by isLoggingEnabled(), setLogging(), and setParameters().
|
private |
Definition at line 68 of file ConnectionPool.h.
Referenced by configure(), setMessageVerbosity(), and setParameters().
|
private |
Definition at line 70 of file ConnectionPool.h.
Referenced by configure(), ConnectionPool(), and setLogDestination().
|
private |
Definition at line 76 of file ConnectionPool.h.
Referenced by configure(), ConnectionPool(), and ~ConnectionPool().