#include <DataProxy.h>

Inheritance diagram for cond::DataProxyWrapperBase:

Public Types
typedef std::pair< std::string, std::string >	Args

typedef std::shared_ptr< edm::eventsetup::DataProxy >	edmProxyP

typedef std::shared_ptr< cond::persistency::BasePayloadProxy >	ProxyP

Public Member Functions
void	addInfo (std::string const &il, std::string const &cs, std::string const &tag)

std::string const &	connString () const

Iov_t const &	currentIov () const

	DataProxyWrapperBase ()

virtual edmProxyP	edmProxy (unsigned int iovIndex) const =0

virtual void	initConcurrentIOVs (unsigned int nConcurrentIOVs)=0

persistency::IOVProxy &	iovProxy ()

persistency::IOVProxy const &	iovProxy () const

std::string const &	label () const

virtual void	lateInit (persistency::Session &session, const std::string &tag, const boost::posix_time::ptime &snapshotTime, std::string const &il, std::string const &cs)=0

void	loadTag (std::string const &tag)

void	loadTag (std::string const &tag, boost::posix_time::ptime const &snapshotTime)

virtual ProxyP	proxy (unsigned int iovIndex) const =0

void	reload ()

std::shared_ptr< std::vector< Iov_t > > const &	requests () const

persistency::Session &	session ()

persistency::Session const &	session () const

ValidityInterval	setIntervalFor (Time_t target, Time_t defaultIovSize)

void	setSession (persistency::Session const &v)

std::string const &	tag () const

TimeType	timeType () const

virtual edm::eventsetup::TypeTag	type () const =0

virtual	~DataProxyWrapperBase ()

Private Attributes
std::string	m_connString

Iov_t	m_currentIov

persistency::IOVProxy	m_iovProxy

std::string	m_label

std::shared_ptr< std::vector< Iov_t > >	m_requests

persistency::Session	m_session

std::string	m_tag

Detailed Description

Definition at line 66 of file DataProxy.h.

Member Typedef Documentation

◆ Args

typedef std::pair<std::string, std::string> cond::DataProxyWrapperBase::Args

Definition at line 72 of file DataProxy.h.

◆ edmProxyP

typedef std::shared_ptr<edm::eventsetup::DataProxy> cond::DataProxyWrapperBase::edmProxyP

Definition at line 69 of file DataProxy.h.

◆ ProxyP

typedef std::shared_ptr<cond::persistency::BasePayloadProxy> cond::DataProxyWrapperBase::ProxyP

Definition at line 68 of file DataProxy.h.

Constructor & Destructor Documentation

◆ DataProxyWrapperBase()

cond::DataProxyWrapperBase::DataProxyWrapperBase ( )

Definition at line 19 of file ProxyFactory.cc.

19 {}

◆ ~DataProxyWrapperBase()

cond::DataProxyWrapperBase::~DataProxyWrapperBase ( )

virtual

Definition at line 21 of file ProxyFactory.cc.

21 {}

Member Function Documentation

◆ addInfo()

void cond::DataProxyWrapperBase::addInfo	(	std::string const &	il,
		std::string const &	cs,
		std::string const &	tag
	)

Definition at line 23 of file ProxyFactory.cc.

                                                                                                      {
   m_label = il;
   m_connString = cs;
   m_tag = tag;
 }

References fwrapper::cs, and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::lateInit().

◆ connString()

std::string const& cond::DataProxyWrapperBase::connString ( ) const

inline

Definition at line 93 of file DataProxy.h.

93 { return m_connString; }

References m_connString.

◆ currentIov()

Iov_t const& cond::DataProxyWrapperBase::currentIov ( ) const

inline

Definition at line 97 of file DataProxy.h.

97 { return m_currentIov; }

References m_currentIov.

Referenced by DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::initConcurrentIOVs(), and DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::lateInit().

◆ edmProxy()

virtual edmProxyP cond::DataProxyWrapperBase::edmProxy ( unsigned int iovIndex ) const

pure virtual

Implemented in DataProxyWrapper< RecordT, DataT, Initializer >, DataProxyWrapper< DTKeyedConfigListRcd, cond::persistency::KeyList >, and DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >.

◆ initConcurrentIOVs()

virtual void cond::DataProxyWrapperBase::initConcurrentIOVs ( unsigned int nConcurrentIOVs )

pure virtual

Implemented in DataProxyWrapper< RecordT, DataT, Initializer >, DataProxyWrapper< DTKeyedConfigListRcd, cond::persistency::KeyList >, and DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >.

◆ iovProxy() [1/2]

persistency::IOVProxy& cond::DataProxyWrapperBase::iovProxy ( )

inline

Definition at line 95 of file DataProxy.h.

95 { return m_iovProxy; }

References m_iovProxy.

◆ iovProxy() [2/2]

persistency::IOVProxy const& cond::DataProxyWrapperBase::iovProxy ( ) const

inline

Definition at line 96 of file DataProxy.h.

96 { return m_iovProxy; }

References m_iovProxy.

◆ label()

std::string const& cond::DataProxyWrapperBase::label ( ) const

inline

Definition at line 92 of file DataProxy.h.

92 { return m_label; }

References m_label.

◆ lateInit()

virtual void cond::DataProxyWrapperBase::lateInit	(	persistency::Session &	session,
		const std::string &	tag,
		const boost::posix_time::ptime &	snapshotTime,
		std::string const &	il,
		std::string const &	cs
	)

pure virtual

Implemented in DataProxyWrapper< RecordT, DataT, Initializer >, DataProxyWrapper< DTKeyedConfigListRcd, cond::persistency::KeyList >, and DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >.

◆ loadTag() [1/2]

void cond::DataProxyWrapperBase::loadTag ( std::string const & tag )

Definition at line 29 of file ProxyFactory.cc.

                                                            {
   m_session.transaction().start(true);
   m_iovProxy = m_session.readIov(tag);
   m_session.transaction().commit();
   m_currentIov.clear();
   m_requests = std::make_shared<std::vector<cond::Iov_t>>();
 }

References GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::lateInit().

◆ loadTag() [2/2]

void cond::DataProxyWrapperBase::loadTag	(	std::string const &	tag,
		boost::posix_time::ptime const &	snapshotTime
	)

Definition at line 37 of file ProxyFactory.cc.

                                                                                                      {
   m_session.transaction().start(true);
   m_iovProxy = m_session.readIov(tag, snapshotTime);
   m_session.transaction().commit();
   m_currentIov.clear();
   m_requests = std::make_shared<std::vector<cond::Iov_t>>();
 }

References GlobalTag_cfi::snapshotTime, and GlobalPosition_Frontier_DevDB_cff::tag.

◆ proxy()

virtual ProxyP cond::DataProxyWrapperBase::proxy ( unsigned int iovIndex ) const

pure virtual

Implemented in DataProxyWrapper< RecordT, DataT, Initializer >, DataProxyWrapper< DTKeyedConfigListRcd, cond::persistency::KeyList >, and DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >.

◆ reload()

void cond::DataProxyWrapperBase::reload ( )

Definition at line 45 of file ProxyFactory.cc.

                                       {
   std::string tag = m_iovProxy.tagInfo().name;
   if (!tag.empty())
     loadTag(tag);
 }

References AlCaHLTBitMon_QueryRunRegistry::string, and GlobalPosition_Frontier_DevDB_cff::tag.

◆ requests()

std::shared_ptr<std::vector<Iov_t> > const& cond::DataProxyWrapperBase::requests ( ) const

inline

Definition at line 100 of file DataProxy.h.

100 { return m_requests; }

References m_requests.

Referenced by DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::initConcurrentIOVs(), and DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::lateInit().

◆ session() [1/2]

persistency::Session& cond::DataProxyWrapperBase::session ( )

inline

Definition at line 98 of file DataProxy.h.

98 { return m_session; }

References m_session.

Referenced by DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::initConcurrentIOVs(), and DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::lateInit().

◆ session() [2/2]

persistency::Session const& cond::DataProxyWrapperBase::session ( ) const

inline

Definition at line 99 of file DataProxy.h.

99 { return m_session; }

References m_session.

◆ setIntervalFor()

cond::ValidityInterval cond::DataProxyWrapperBase::setIntervalFor	(	Time_t	target,
		Time_t	defaultIovSize
	)

Definition at line 51 of file ProxyFactory.cc.

                                                                                                 {
   if (!m_currentIov.isValidFor(time)) {
     m_currentIov.clear();
     m_session.transaction().start(true);
     m_currentIov = m_iovProxy.getInterval(time, defaultIovSize);
     m_session.transaction().commit();
   }
   return cond::ValidityInterval(m_currentIov.since, m_currentIov.till);
 }

References ntuplemaker::time.

◆ setSession()

void cond::DataProxyWrapperBase::setSession ( persistency::Session const & v )

inline

Definition at line 102 of file DataProxy.h.

102 { m_session = v; }

References m_session, and findQualityFiles::v.

Referenced by DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::lateInit().

◆ tag()

std::string const& cond::DataProxyWrapperBase::tag ( ) const

inline

Definition at line 94 of file DataProxy.h.

94 { return m_tag; }

References m_tag.

Referenced by DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >::lateInit().

◆ timeType()

TimeType cond::DataProxyWrapperBase::timeType ( ) const

inline

Definition at line 109 of file DataProxy.h.

109 { return m_iovProxy.tagInfo().timeType; }

References m_iovProxy, cond::persistency::IOVProxy::tagInfo(), and cond::Tag_t::timeType.

◆ type()

virtual edm::eventsetup::TypeTag cond::DataProxyWrapperBase::type ( ) const

pure virtual

Implemented in DataProxyWrapper< RecordT, DataT, Initializer >, DataProxyWrapper< DTKeyedConfigListRcd, cond::persistency::KeyList >, and DataProxyWrapper< ExDwarfListRcd, cond::persistency::KeyList >.

Member Data Documentation

◆ m_connString

std::string cond::DataProxyWrapperBase::m_connString

private

Definition at line 113 of file DataProxy.h.

Referenced by connString().

◆ m_currentIov

Iov_t cond::DataProxyWrapperBase::m_currentIov

private

Definition at line 116 of file DataProxy.h.

Referenced by currentIov().

◆ m_iovProxy

persistency::IOVProxy cond::DataProxyWrapperBase::m_iovProxy

private

Definition at line 115 of file DataProxy.h.

Referenced by iovProxy(), and timeType().

◆ m_label

std::string cond::DataProxyWrapperBase::m_label

private

Definition at line 112 of file DataProxy.h.

Referenced by label().

◆ m_requests

std::shared_ptr<std::vector<Iov_t> > cond::DataProxyWrapperBase::m_requests

private

Definition at line 118 of file DataProxy.h.

Referenced by requests().

◆ m_session

persistency::Session cond::DataProxyWrapperBase::m_session

private

Definition at line 117 of file DataProxy.h.

Referenced by session(), and setSession().

◆ m_tag

std::string cond::DataProxyWrapperBase::m_tag

private

Definition at line 114 of file DataProxy.h.

Referenced by tag().

Public Types

Public Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ Args

◆ edmProxyP

◆ ProxyP

Constructor & Destructor Documentation

◆ DataProxyWrapperBase()

◆ ~DataProxyWrapperBase()

Member Function Documentation

◆ addInfo()

◆ connString()

◆ currentIov()

◆ edmProxy()

◆ initConcurrentIOVs()

◆ iovProxy() [1/2]

◆ iovProxy() [2/2]

◆ label()

◆ lateInit()

◆ loadTag() [1/2]

◆ loadTag() [2/2]

◆ proxy()

◆ reload()

◆ requests()

◆ session() [1/2]

◆ session() [2/2]

◆ setIntervalFor()

◆ setSession()

◆ tag()

◆ timeType()

◆ type()

Member Data Documentation

◆ m_connString

◆ m_currentIov

◆ m_iovProxy

◆ m_label

◆ m_requests

◆ m_session

◆ m_tag