cond::persistency::ConnectionPool Class Reference

#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	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_authPath = std::string("")
int	m_authSys = 0
std::map< std::string, int >	m_dbTypes
std::string	m_frontierSecurity = std::string("")
bool	m_loggingEnabled = false
coral::MsgLevel	m_messageLevel = coral::Error
cond::CoralServiceManager *	m_pluginManager = 0

Detailed Description

Definition at line 31 of file ConnectionPool.h.

Constructor & Destructor Documentation

cond::persistency::ConnectionPool::ConnectionPool

(

)

Definition at line 25 of file ConnectionPool.cc.

References configure(), and m_pluginManager.

                                   {
      m_pluginManager = new cond::CoralServiceManager;
      configure();
    }

cond::persistency::ConnectionPool::~ConnectionPool

(

)

Definition at line 30 of file ConnectionPool.cc.

References m_pluginManager.

{ delete m_pluginManager; }

Member Function Documentation

void cond::persistency::ConnectionPool::configure

(

)

Definition at line 121 of file ConnectionPool.cc.

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< TRcd, TData >::L1ConfigOnlineProdBase(), L1ConfigOnlineProdBaseExt< TRcd, TData >::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());
    }

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

private

Definition at line 72 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_authPath, m_authSys, m_messageLevel, m_pluginManager, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                    {
      coralConfig.disablePoolAutomaticCleanUp();
      coralConfig.disableConnectionSharing();
      // message streaming
      coral::MessageStream::setMsgVerbosity(m_messageLevel);
      std::string authServiceName("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()) {
        authServiceName = servName;
        coral::Context::instance().PropertyManager().property(cond::auth::COND_AUTH_PATH_PROPERTY)->set(authPath);
        coral::Context::instance().loadComponent(authServiceName, m_pluginManager);
      }

      coralConfig.setAuthenticationService(authServiceName);
    }

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

Definition at line 163 of file ConnectionPool.cc.

Referenced by SiStripPayloadMapTableCreator::analyze(), createSession(), RPCDCCLinkMapHandler::getNewObjects(), RPCLBLinkMapHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), SiStripPayloadHandler< SiStripPayload >::queryConfigMap(), RunInfoRead::readData(), and SiStripPayloadHandler< SiStripPayload >::updateConfigMap().

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

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

private

Definition at line 126 of file ConnectionPool.cc.

References cond::auth::COND_READER_ROLE, cond::auth::COND_WRITER_ROLE, 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));
    }

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

Definition at line 158 of file ConnectionPool.cc.

References createSession().

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

                                                                                  {
      return createSession(connectionString, transactionId);
    }

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

Definition at line 154 of file ConnectionPool.cc.

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), SiStripDetVOffTrendPlotter::analyze(), BeamSpotRcdPrinter::analyze(), l1t::DataManager::connect(), popcon::L1RPCHwConfigSourceHandler::ConnectOnlineDB(), popcon::RPCEMapSourceHandler::ConnectOnlineDB(), createReadOnlySession(), CondDBESSource::fillTagCollectionFromGT(), LHCInfoPopConSourceHandler::getNewObjects(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), SiStripCoralIface::initialize(), popcon::PopCon::initialize(), L1ConfigOnlineProdBase< TRcd, TData >::L1ConfigOnlineProdBase(), L1ConfigOnlineProdBaseExt< TRcd, TData >::L1ConfigOnlineProdBaseExt(), cond::payloadInspector::PlotBase::process(), and cond::payloadInspector::PlotBase::processTwoTags().

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

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

private

Definition at line 146 of file ConnectionPool.cc.

References createCoralSession().

                                                             {
      std::shared_ptr<coral::ISessionProxy> coralSession =
          createCoralSession(connectionString, transactionId, writeCapable);
      return Session(std::make_shared<SessionImpl>(coralSession, connectionString));
    }

bool cond::persistency::ConnectionPool::isLoggingEnabled

(

)

const

Definition at line 70 of file ConnectionPool.cc.

References m_loggingEnabled.

{ return m_loggingEnabled; }

void cond::persistency::ConnectionPool::setAuthenticationPath

(

const std::string &

p

)

Definition at line 32 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(), SiStripCoralIface::initialize(), popcon::PopCon::initialize(), L1ConfigOnlineProdBase< TRcd, TData >::L1ConfigOnlineProdBase(), L1ConfigOnlineProdBaseExt< TRcd, TData >::L1ConfigOnlineProdBaseExt(), L1RCTOmdsFedVectorProducer::produce(), and setParameters().

{ m_authPath = p; }

void cond::persistency::ConnectionPool::setAuthenticationSystem

(

int

authSysCode

)

Definition at line 34 of file ConnectionPool.cc.

References m_authSys.

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

{ m_authSys = authSysCode; }

void cond::persistency::ConnectionPool::setFrontierSecurity

(

const std::string &

signature

)

Definition at line 36 of file ConnectionPool.cc.

References m_frontierSecurity, and signature.

Referenced by setParameters().

{ m_frontierSecurity = signature; }

void cond::persistency::ConnectionPool::setLogging

(

bool

flag

)

Definition at line 38 of file ConnectionPool.cc.

References RemoveAddSevLevel::flag, and m_loggingEnabled.

Referenced by setParameters().

{ m_loggingEnabled = flag; }

void cond::persistency::ConnectionPool::setMessageVerbosity

(

coral::MsgLevel

level

)

Definition at line 168 of file ConnectionPool.cc.

References personalPlayback::level, and m_messageLevel.

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

{ m_messageLevel = level; }

void cond::persistency::ConnectionPool::setParameters

(

const edm::ParameterSet &

connectionPset

)

Definition at line 40 of file ConnectionPool.cc.

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

Referenced by BeamSpotRcdPrinter::BeamSpotRcdPrinter(), CondDBESSource::CondDBESSource(), cond::service::PoolDBOutputService::PoolDBOutputService(), 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);
      setLogging(connectionPset.getUntrackedParameter<bool>("logging", m_loggingEnabled));
    }

Member Data Documentation

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

private

Definition at line 59 of file ConnectionPool.h.

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

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

private

Definition at line 60 of file ConnectionPool.h.

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

std::map<std::string, int> cond::persistency::ConnectionPool::m_dbTypes

private

Definition at line 68 of file ConnectionPool.h.

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

private

Definition at line 65 of file ConnectionPool.h.

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

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

private

Definition at line 62 of file ConnectionPool.h.

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

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

private

Definition at line 61 of file ConnectionPool.h.

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

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

private

Definition at line 67 of file ConnectionPool.h.

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