cond::DataProxyWrapperBase Class Reference

#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, edm::SerialTaskQueue *queue, std::mutex *mutex)=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 64 of file DataProxy.h.

Member Typedef Documentation

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

Definition at line 70 of file DataProxy.h.

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

Definition at line 67 of file DataProxy.h.

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

Definition at line 66 of file DataProxy.h.

Constructor & Destructor Documentation

cond::DataProxyWrapperBase::DataProxyWrapperBase

(

)

Definition at line 19 of file ProxyFactory.cc.

{}

cond::DataProxyWrapperBase::~DataProxyWrapperBase ( )

virtual

Definition at line 21 of file ProxyFactory.cc.

{}

Member Function Documentation

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

Definition at line 23 of file ProxyFactory.cc.

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

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

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

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

inline

Definition at line 93 of file DataProxy.h.

References m_connString.

{ return m_connString; }

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

inline

Definition at line 97 of file DataProxy.h.

References m_currentIov.

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

{ return m_currentIov; }

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

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

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

inline

Definition at line 95 of file DataProxy.h.

References m_iovProxy.

{ return m_iovProxy; }

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

inline

Definition at line 96 of file DataProxy.h.

References m_iovProxy.

{ return m_iovProxy; }

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

inline

Definition at line 92 of file DataProxy.h.

References m_label.

{ return m_label; }

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, edm::SerialTaskQueue *  queue, std::mutex *  mutex  )

pure virtual

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

void cond::DataProxyWrapperBase::loadTag

(

std::string const &

tag

)

Definition at line 29 of file ProxyFactory.cc.

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

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

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

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

void cond::DataProxyWrapperBase::reload

(

)

Definition at line 45 of file ProxyFactory.cc.

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

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

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

inline

Definition at line 100 of file DataProxy.h.

References m_requests.

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

{ return m_requests; }

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

inline

Definition at line 98 of file DataProxy.h.

References m_session.

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

{ return m_session; }

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

inline

Definition at line 99 of file DataProxy.h.

References m_session.

{ return m_session; }

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

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

inline

Definition at line 102 of file DataProxy.h.

References m_session, and findQualityFiles::v.

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

{ m_session = v; }

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

inline

Definition at line 94 of file DataProxy.h.

References m_tag.

Referenced by DTTtrigWorkflow.DTttrigWorkflow::prepare_timeboxes_correction().

{ return m_tag; }

TimeType cond::DataProxyWrapperBase::timeType ( ) const

inline

Definition at line 109 of file DataProxy.h.

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

{ return m_iovProxy.tagInfo().timeType; }

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

std::string cond::DataProxyWrapperBase::m_connString

private

Definition at line 113 of file DataProxy.h.

Referenced by connString().

Iov_t cond::DataProxyWrapperBase::m_currentIov

private

Definition at line 116 of file DataProxy.h.

Referenced by currentIov().

persistency::IOVProxy cond::DataProxyWrapperBase::m_iovProxy

private

Definition at line 115 of file DataProxy.h.

Referenced by iovProxy(), and timeType().

std::string cond::DataProxyWrapperBase::m_label

private

Definition at line 112 of file DataProxy.h.

Referenced by label().

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

private

Definition at line 118 of file DataProxy.h.

Referenced by requests().

persistency::Session cond::DataProxyWrapperBase::m_session

private

Definition at line 117 of file DataProxy.h.

Referenced by session(), and setSession().

std::string cond::DataProxyWrapperBase::m_tag

private

Definition at line 114 of file DataProxy.h.

Referenced by tag().