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

References expressLumiProducer_cff::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 = ::getenv( cond::auth::COND_AUTH_PATH );
     if(authEnv){
       authPath += authEnv;
     } 
       }
       int authSys = m_authSys;
       // first attempt, look at the env...
       const char* authSysEnv = ::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 = ::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 170 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 137 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 166 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 162 of file ConnectionPool.cc.

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripDetVOffTrendPlotter::analyze(), SiStripPayloadHandler< SiStripPayload >::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 155 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 79 of file ConnectionPool.cc.

References m_loggingEnabled.

                                                 {
       return m_loggingEnabled;
     }

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

Definition at line 34 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 38 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 42 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 46 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 175 of file ConnectionPool.cc.

References hcalDigis_cfi::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 50 of file ConnectionPool.cc.

References Debug, edm::ParameterSet::getUntrackedParameter(), hcalDigis_cfi::level, m_authPath, m_authSys, m_frontierSecurity, m_loggingEnabled, m_messageLevel, patTestJEC_local_cfi::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 ) );
     }