#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	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

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.

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

References configure(), m_msgReporter, and m_pluginManager.

◆ ~ConnectionPool()

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

Definition at line 33 of file ConnectionPool.cc.

33 { delete m_pluginManager; }

References m_pluginManager.

Member Function Documentation

◆ configure() [1/2]

void cond::persistency::ConnectionPool::configure ( )

Definition at line 127 of file ConnectionPool.cc.

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

Referenced by BeamSpotRcdPrinter::BeamSpotRcdPrinter(), CondDBESSource::CondDBESSource(), l1t::DataManager::connect(), ConnectionPool(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), FillInfoPopConSourceHandler::getNewObjects(), LHCInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), SiStripCoralIface::initialize(), popcon::PopCon::initialize(), L1ConfigOnlineProdBase< L1HtMissScaleRcd, L1CaloEtScale >::L1ConfigOnlineProdBase(), L1ConfigOnlineProdBaseExt< L1TCaloParamsO2ORcd, l1t::CaloParams >::L1ConfigOnlineProdBaseExt(), popcon::PopConBTransitionSourceHandler< T >::PopConBTransitionSourceHandler(), popcon::PopConESTransitionSourceHandler< T >::PopConESTransitionSourceHandler(), L1RCTOmdsFedVectorProducer::produce(), RunInfoRead::readData(), RPCDCCLinkMapHandler::RPCDCCLinkMapHandler(), RPCLBLinkMapHandler::RPCLBLinkMapHandler(), SiStripDetVOffHandler::SiStripDetVOffHandler(), SiStripDetVOffPrinter::SiStripDetVOffPrinter(), SiStripDetVOffTkMapPlotter::SiStripDetVOffTkMapPlotter(), SiStripDetVOffTrendPlotter::SiStripDetVOffTrendPlotter(), SiStripPayloadHandler< SiStripPayload >::SiStripPayloadHandler(), and SiStripPayloadMapTableCreator::SiStripPayloadMapTableCreator().

◆ configure() [2/2]

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

private

Definition at line 75 of file ConnectionPool.cc.

                                                                                     {
       coralConfig.disablePoolAutomaticCleanUp();
       coralConfig.disableConnectionSharing();
       // 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);
     }

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_messageLevel, m_msgReporter, m_pluginManager, cond::persistency::CoralMsgReporter::setOutputLevel(), and AlCaHLTBitMon_QueryRunRegistry::string.

◆ createCoralSession() [1/2]

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

Definition at line 181 of file ConnectionPool.cc.

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

References l1RCTOmdsFedVectorProducer_cfi::connectionString.

Referenced by SiStripPayloadMapTableCreator::analyze(), createSession(), RPCDCCLinkMapHandler::getNewObjects(), RPCLBLinkMapHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), and RunInfoRead::readData().

◆ 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 132 of file ConnectionPool.cc.

                                                                                                 {
       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));
     }

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.

◆ createReadOnlySession()

Session cond::persistency::ConnectionPool::createReadOnlySession	(	const std::string &	connectionString,
		const std::string &	transactionId
	)

Definition at line 176 of file ConnectionPool.cc.

                                                                                   {
       return createSession(connectionString, transactionId);
     }

References l1RCTOmdsFedVectorProducer_cfi::connectionString, and createSession().

Referenced by CondDBESSource::CondDBESSource(), and CondDBESSource::setIntervalFor().

◆ createSession() [1/2]

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

Definition at line 172 of file ConnectionPool.cc.

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

References l1RCTOmdsFedVectorProducer_cfi::connectionString.

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripDetVOffTrendPlotter::analyze(), BeamSpotRcdPrinter::analyze(), l1t::DataManager::connect(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), createReadOnlySession(), cond::payloadInspector::PlotBase::exec_process(), CondDBESSource::fillTagCollectionFromGT(), LHCInfoPopConSourceHandler::getNewObjects(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), SiStripCoralIface::initialize(), popcon::PopCon::initialize(), L1ConfigOnlineProdBase< L1HtMissScaleRcd, L1CaloEtScale >::L1ConfigOnlineProdBase(), L1ConfigOnlineProdBaseExt< L1TCaloParamsO2ORcd, l1t::CaloParams >::L1ConfigOnlineProdBaseExt(), and L1RCTOmdsFedVectorProducer::produce().

◆ createSession() [2/2]

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

private

Definition at line 152 of file ConnectionPool.cc.

                                                              {
       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));
     }

References l1RCTOmdsFedVectorProducer_cfi::connectionString, createCoralSession(), instance, m_authenticationService, cond::persistency::IDbAuthentication::principalName(), and AlCaHLTBitMon_QueryRunRegistry::string.

◆ isLoggingEnabled()

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

Definition at line 73 of file ConnectionPool.cc.

73 { return m_loggingEnabled; }

References m_loggingEnabled.

◆ setAuthenticationPath()

void cond::persistency::ConnectionPool::setAuthenticationPath ( const std::string & p )

◆ setAuthenticationSystem()

void cond::persistency::ConnectionPool::setAuthenticationSystem ( int authSysCode )

Definition at line 37 of file ConnectionPool.cc.

37 { m_authSys = authSysCode; }

References m_authSys.

Referenced by DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), popcon::PopCon::initialize(), and setParameters().

◆ setFrontierSecurity()

void cond::persistency::ConnectionPool::setFrontierSecurity ( const std::string & signature )

Definition at line 39 of file ConnectionPool.cc.

39 { m_frontierSecurity = signature; }

References m_frontierSecurity, and signature.

Referenced by setParameters().

◆ setLogDestination()

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

Definition at line 188 of file ConnectionPool.cc.

188 { m_msgReporter->subscribe(logger); }

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

◆ setLogging()

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

Definition at line 41 of file ConnectionPool.cc.

41 { m_loggingEnabled = flag; }

References RemoveAddSevLevel::flag, and m_loggingEnabled.

Referenced by setParameters().

◆ setMessageVerbosity()

void cond::persistency::ConnectionPool::setMessageVerbosity ( coral::MsgLevel level )

Definition at line 186 of file ConnectionPool.cc.

186 { m_messageLevel = level; }

References personalPlayback::level, and m_messageLevel.

Referenced by l1t::DataManager::connect(), LHCInfoPopConSourceHandler::getNewObjects(), FillInfoPopConSourceHandler::getNewObjects(), and setParameters().

◆ setParameters()

void cond::persistency::ConnectionPool::setParameters ( const edm::ParameterSet & connectionPset )

Definition at line 43 of file ConnectionPool.cc.

                                                                             {
       //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);
       setLogging(connectionPset.getUntrackedParameter<bool>("logging", m_loggingEnabled));
     }

References Debug, edm::ParameterSet::getUntrackedParameter(), personalPlayback::level, m_authPath, m_authSys, m_frontierSecurity, m_loggingEnabled, m_messageLevel, beam_dqm_sourceclient-live_cfg::messageLevel, setAuthenticationPath(), setAuthenticationSystem(), setFrontierSecurity(), setLogging(), setMessageVerbosity(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by BeamSpotRcdPrinter::BeamSpotRcdPrinter(), CondDBESSource::CondDBESSource(), 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().

Member Data Documentation

◆ m_authenticationService

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

private

Definition at line 66 of file ConnectionPool.h.

Referenced by configure(), and createSession().

◆ m_authPath

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

private

Definition at line 64 of file ConnectionPool.h.

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

◆ m_authSys

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

private

Definition at line 65 of file ConnectionPool.h.

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

◆ m_frontierSecurity

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

private

Definition at line 72 of file ConnectionPool.h.

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

◆ m_loggingEnabled

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

private

Definition at line 69 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 67 of file ConnectionPool.h.

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

◆ m_msgReporter

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

private

Definition at line 68 of file ConnectionPool.h.

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

◆ m_pluginManager

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

private

Definition at line 74 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()

◆ setFrontierSecurity()

◆ setLogDestination()

◆ setLogging()

◆ setMessageVerbosity()

◆ setParameters()

Member Data Documentation

◆ m_authenticationService

◆ m_authPath

◆ m_authSys

◆ m_frontierSecurity

◆ m_loggingEnabled

◆ m_messageLevel

◆ m_msgReporter

◆ m_pluginManager