#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

Detailed Description

Definition at line 35 of file ConnectionPool.h.

Constructor & Destructor Documentation

◆ ConnectionPool()

cond::persistency::ConnectionPool::ConnectionPool ( )

Definition at line 26 of file ConnectionPool.cc.

References configure(), m_msgReporter, and m_pluginManager.

                                    {
       m_pluginManager = new cond::CoralServiceManager;
       m_msgReporter = new CoralMsgReporter;
       coral::MessageStream::installMsgReporter(m_msgReporter);
       configure();
     }

◆ ~ConnectionPool()

cond::persistency::ConnectionPool::~ConnectionPool ( )

Definition at line 33 of file ConnectionPool.cc.

References m_pluginManager.

33 { delete m_pluginManager; }

cond::persistency::ConnectionPool::m_pluginManager

cond::CoralServiceManager * m_pluginManager

Definition: ConnectionPool.h:76

Member Function Documentation

◆ configure() [1/2]

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(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::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().

                                    {
       coral::ConnectionService connServ;
       configure(connServ.configuration());
     }

◆ configure() [2/2]

void cond::persistency::ConnectionPool::configure ( coral::IConnectionServiceConfiguration & coralConfig )

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.

                                                                                     {
       coralConfig.disablePoolAutomaticCleanUp();
       coralConfig.disableConnectionSharing();
       coralConfig.setConnectionTimeOut(m_connectionTimeout);
       // message streaming
       coral::MessageStream::setMsgVerbosity(m_messageLevel);
       m_msgReporter->setOutputLevel(m_messageLevel);
 
       // authentication
       m_authenticationService = std::string("CORAL/Services/EnvironmentAuthenticationService");
       std::string authPath = m_authPath;
       // authentication
       if (authPath.empty()) {
         // first try to check the env...
         const char* authEnv = std::getenv(cond::auth::COND_AUTH_PATH);
         if (authEnv) {
           authPath += authEnv;
         }
       }
       int authSys = m_authSys;
       // first attempt, look at the env...
       const char* authSysEnv = std::getenv(cond::auth::COND_AUTH_SYS);
       if (authSysEnv) {
         authSys = ::atoi(authSysEnv);
       }
       if (authSys != CondDbKey && authSys != CoralXMLFile) {
         // take the default
         authSys = CondDbKey;
       }
       std::string servName("");
       if (authSys == CondDbKey) {
         if (authPath.empty()) {
           const char* authEnv = std::getenv("HOME");
           if (authEnv) {
             authPath += authEnv;
           }
         }
         servName = "COND/Services/RelationalAuthenticationService";
       } else if (authSys == CoralXMLFile) {
         if (authPath.empty()) {
           authPath = ".";
         }
         servName = "COND/Services/XMLAuthenticationService";
       }
       if (!authPath.empty()) {
         m_authenticationService = servName;
         coral::Context::instance().PropertyManager().property(cond::auth::COND_AUTH_PATH_PROPERTY)->set(authPath);
         coral::Context::instance().loadComponent(m_authenticationService, m_pluginManager);
       }
 
       coralConfig.setAuthenticationService(m_authenticationService);
     }

◆ createCoralSession() [1/2]

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().

                                                                                                 {
       return createCoralSession(connectionString, "", writeCapable);
     }

◆ createCoralSession() [2/2]

std::shared_ptr< coral::ISessionProxy > cond::persistency::ConnectionPool::createCoralSession	(	const std::string &	connectionString,
		const std::string &	transactionId,
		bool	writeCapable = `false`
	)

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.

                                                                                                 {
       coral::ConnectionService connServ;
       //all sessions opened with this connection service will share the same frontier security option.
       std::pair<std::string, std::string> fullConnectionPars =
           getConnectionParams(connectionString, transactionId, m_frontierSecurity);
       if (!fullConnectionPars.second.empty()) {
         //all sessions opened with this connection service will share the same TTL settings for TAG, IOV, and PAYLOAD tables.
         connServ.webCacheControl().setTableTimeToLive(fullConnectionPars.second, TAG::tname, 1);
         connServ.webCacheControl().setTableTimeToLive(fullConnectionPars.second, IOV::tname, 1);
         connServ.webCacheControl().setTableTimeToLive(fullConnectionPars.second, PAYLOAD::tname, 3);
       }
 
       return std::shared_ptr<coral::ISessionProxy>(
           connServ.connect(fullConnectionPars.first,
                            writeCapable ? auth::COND_WRITER_ROLE : auth::COND_READER_ROLE,
                            writeCapable ? coral::Update : coral::ReadOnly));
     }

◆ createReadOnlySession()

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().

                                                                                   {
       return createSession(connectionString, transactionId);
     }

◆ createSession() [1/2]

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(), popcon::PopCon::initialize(), SiStripCoralIface::initialize(), L1ConfigOnlineProdBase< L1HtMissScaleRcd, L1CaloEtScale >::L1ConfigOnlineProdBase(), and L1ConfigOnlineProdBaseExt< L1TCaloParamsO2ORcd, l1t::CaloParams >::L1ConfigOnlineProdBaseExt().

                                                                                               {
       return createSession(connectionString, "", writeCapable);
     }

◆ createSession() [2/2]

Session cond::persistency::ConnectionPool::createSession	(	const std::string &	connectionString,
		const std::string &	transactionId,
		bool	writeCapable = `false`
	)

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.

                                                              {
       std::shared_ptr<coral::ISessionProxy> coralSession =
           createCoralSession(connectionString, transactionId, writeCapable);
 
       std::string principalName("");
       if (!m_authenticationService.empty()) {
         // need to hard-code somewhere the target name...
         if (m_authenticationService == "COND/Services/RelationalAuthenticationService") {
           coral::IHandle<coral::IAuthenticationService> authSvc =
               coral::Context::instance().query<coral::IAuthenticationService>(m_authenticationService);
           IDbAuthentication* dbAuth = dynamic_cast<IDbAuthentication*>(authSvc.get());
           principalName = dbAuth->principalName();
         }
       }
 
       return Session(std::make_shared<SessionImpl>(coralSession, connectionString, principalName));
     }

◆ isLoggingEnabled()

bool cond::persistency::ConnectionPool::isLoggingEnabled ( ) const

Definition at line 74 of file ConnectionPool.cc.

References m_loggingEnabled.

74 { return m_loggingEnabled; }

cond::persistency::ConnectionPool::m_loggingEnabled

bool m_loggingEnabled

Definition: ConnectionPool.h:71

◆ setAuthenticationPath()

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(), popcon::PopCon::initialize(), SiStripCoralIface::initialize(), L1ConfigOnlineProdBase< L1HtMissScaleRcd, L1CaloEtScale >::L1ConfigOnlineProdBase(), L1ConfigOnlineProdBaseExt< L1TCaloParamsO2ORcd, l1t::CaloParams >::L1ConfigOnlineProdBaseExt(), L1RCTOmdsFedVectorProducer::produce(), and setParameters().

35 { m_authPath = p; }

cond::persistency::ConnectionPool::m_authPath

std::string m_authPath

Definition: ConnectionPool.h:65

AlCaHLTBitMon_ParallelJobs.p

def p

Definition: AlCaHLTBitMon_ParallelJobs.py:153

◆ setAuthenticationSystem()

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().

37 { m_authSys = authSysCode; }

cond::persistency::ConnectionPool::m_authSys

int m_authSys

Definition: ConnectionPool.h:66

◆ setConnectionTimeout()

void cond::persistency::ConnectionPool::setConnectionTimeout ( int seconds )

Definition at line 190 of file ConnectionPool.cc.

References m_connectionTimeout, and seconds().

Referenced by setParameters().

190 { m_connectionTimeout = seconds; }

seconds

double seconds()

cond::persistency::ConnectionPool::m_connectionTimeout

int m_connectionTimeout

Definition: ConnectionPool.h:69

◆ setFrontierSecurity()

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().

39 { m_frontierSecurity = signature; }

cond::persistency::ConnectionPool::m_frontierSecurity

std::string m_frontierSecurity

Definition: ConnectionPool.h:74

signature

The Signals That Services Can Subscribe To This is based on ActivityRegistry and is current per Services can connect to the signals distributed by the ActivityRegistry in order to monitor the activity of the application Each possible callback has some defined signature

Definition: Activities.doc:4

◆ setLogDestination()

void cond::persistency::ConnectionPool::setLogDestination ( Logger & logger )

Definition at line 192 of file ConnectionPool.cc.

References m_msgReporter, and cond::persistency::CoralMsgReporter::subscribe().

192 { m_msgReporter->subscribe(logger); }

cond::persistency::ConnectionPool::m_msgReporter

CoralMsgReporter * m_msgReporter

Definition: ConnectionPool.h:70

cond::persistency::CoralMsgReporter::subscribe

void subscribe(Logger &logger)

Definition: CoralMsgReporter.cc:143

logger

Definition: logger.py:1

◆ setLogging()

void cond::persistency::ConnectionPool::setLogging ( bool flag )

Definition at line 41 of file ConnectionPool.cc.

References RemoveAddSevLevel::flag, and m_loggingEnabled.

Referenced by setParameters().

41 { m_loggingEnabled = flag; }

cond::persistency::ConnectionPool::m_loggingEnabled

bool m_loggingEnabled

Definition: ConnectionPool.h:71

RemoveAddSevLevel.flag

flag

Definition: RemoveAddSevLevel.py:117

◆ setMessageVerbosity()

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(), and setParameters().

188 { m_messageLevel = level; }

cond::persistency::ConnectionPool::m_messageLevel

coral::MsgLevel m_messageLevel

Definition: ConnectionPool.h:68

personalPlayback.level

level

Definition: personalPlayback.py:22

◆ 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().

                                                                             {
       //set the connection parameters from a ParameterSet
       //if a parameter is not defined, keep the values already set in the data members
       //(i.e. default if no other setters called, or the ones currently available)
       setAuthenticationPath(connectionPset.getUntrackedParameter<std::string>("authenticationPath", m_authPath));
       setAuthenticationSystem(connectionPset.getUntrackedParameter<int>("authenticationSystem", m_authSys));
       setFrontierSecurity(connectionPset.getUntrackedParameter<std::string>("security", m_frontierSecurity));
       int messageLevel =
           connectionPset.getUntrackedParameter<int>("messageLevel", 0);  //0 corresponds to Error level, current default
       coral::MsgLevel level = m_messageLevel;
       switch (messageLevel) {
         case 0:
           level = coral::Error;
           break;
         case 1:
           level = coral::Warning;
           break;
         case 2:
           level = coral::Info;
           break;
         case 3:
           level = coral::Debug;
           break;
         default:
           level = coral::Error;
       }
       setMessageVerbosity(level);
       setConnectionTimeout(connectionPset.getUntrackedParameter<int>("connectionTimeout", m_connectionTimeout));
       setLogging(connectionPset.getUntrackedParameter<bool>("logging", m_loggingEnabled));
     }

Member Data Documentation

◆ m_authenticationService

std::string cond::persistency::ConnectionPool::m_authenticationService = std::string("")

private

Definition at line 67 of file ConnectionPool.h.

Referenced by configure(), and createSession().

◆ m_authPath

std::string cond::persistency::ConnectionPool::m_authPath = std::string("")

private

Definition at line 65 of file ConnectionPool.h.

Referenced by configure(), setAuthenticationPath(), and setParameters().

◆ m_authSys

int cond::persistency::ConnectionPool::m_authSys = 0

private

Definition at line 66 of file ConnectionPool.h.

Referenced by configure(), setAuthenticationSystem(), and setParameters().

◆ m_connectionTimeout

int cond::persistency::ConnectionPool::m_connectionTimeout = 0

private

Definition at line 69 of file ConnectionPool.h.

Referenced by configure(), setConnectionTimeout(), and setParameters().

◆ m_frontierSecurity

std::string cond::persistency::ConnectionPool::m_frontierSecurity = std::string("")

private

Definition at line 74 of file ConnectionPool.h.

Referenced by createCoralSession(), setFrontierSecurity(), and setParameters().

◆ m_loggingEnabled

bool cond::persistency::ConnectionPool::m_loggingEnabled = false

private

Definition at line 71 of file ConnectionPool.h.

Referenced by isLoggingEnabled(), setLogging(), and setParameters().

◆ m_messageLevel

coral::MsgLevel cond::persistency::ConnectionPool::m_messageLevel = coral::Error

private

Definition at line 68 of file ConnectionPool.h.

Referenced by configure(), setMessageVerbosity(), and setParameters().

◆ m_msgReporter

CoralMsgReporter* cond::persistency::ConnectionPool::m_msgReporter = nullptr

private

Definition at line 70 of file ConnectionPool.h.

Referenced by configure(), ConnectionPool(), and setLogDestination().

◆ m_pluginManager

cond::CoralServiceManager* cond::persistency::ConnectionPool::m_pluginManager = nullptr

private

Definition at line 76 of file ConnectionPool.h.

Referenced by configure(), ConnectionPool(), and ~ConnectionPool().

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ ConnectionPool()

◆ ~ConnectionPool()

Member Function Documentation

◆ configure() [1/2]

◆ configure() [2/2]

◆ createCoralSession() [1/2]

◆ createCoralSession() [2/2]

◆ createReadOnlySession()

◆ createSession() [1/2]

◆ createSession() [2/2]

◆ isLoggingEnabled()

◆ setAuthenticationPath()

◆ setAuthenticationSystem()

◆ setConnectionTimeout()

◆ setFrontierSecurity()

◆ setLogDestination()

◆ setLogging()

◆ setMessageVerbosity()

◆ setParameters()

Member Data Documentation

◆ m_authenticationService

◆ m_authPath

◆ m_authSys

◆ m_connectionTimeout

◆ m_frontierSecurity

◆ m_loggingEnabled

◆ m_messageLevel

◆ m_msgReporter

◆ m_pluginManager