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)=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)
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

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

Definition at line 72 of file DataProxy.h.

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

Definition at line 69 of file DataProxy.h.

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

Definition at line 68 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, m_connString, m_label, m_tag, and tag().

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

{ return m_connString; }

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

inline

Definition at line 97 of file DataProxy.h.

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

{ return m_iovProxy; }

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

inline

Definition at line 96 of file DataProxy.h.

{ return m_iovProxy; }

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

inline

Definition at line 92 of file DataProxy.h.

Referenced by Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::_sort_list(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::foundIn(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::fullFilename(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::inputEventContent(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::outputEventContent(), Vispa.Plugins.ConfigEditor.ToolDataAccessor.ToolDataAccessor::properties(), Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::properties(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::properties(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::readConnections(), Vispa.Plugins.ConfigEditor.ToolDataAccessor.ToolDataAccessor::updateProcess(), and Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::usedBy().

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

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.

References cond::Iov_t::clear(), cond::persistency::Transaction::commit(), m_currentIov, m_iovProxy, m_requests, m_session, cond::persistency::Session::readIov(), cond::persistency::Transaction::start(), and cond::persistency::Session::transaction().

Referenced by reload().

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

References cond::Iov_t::clear(), cond::persistency::Transaction::commit(), m_currentIov, m_iovProxy, m_requests, m_session, cond::persistency::Session::readIov(), cond::persistency::Transaction::start(), and cond::persistency::Session::transaction().

                                                                                                     {
  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 loadTag(), m_iovProxy, AlCaHLTBitMon_QueryRunRegistry::string, tag(), and cond::persistency::IOVProxy::tag().

                                      {
  std::string tag = m_iovProxy.tag();
  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.

{ return m_requests; }

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

inline

Definition at line 98 of file DataProxy.h.

{ return m_session; }

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

inline

Definition at line 99 of file DataProxy.h.

{ return m_session; }

cond::ValidityInterval cond::DataProxyWrapperBase::setIntervalFor

(

Time_t

target

)

Definition at line 51 of file ProxyFactory.cc.

References cond::Iov_t::clear(), cond::persistency::Transaction::commit(), cond::persistency::IOVProxy::end(), cond::persistency::IOVProxy::find(), cond::Iov_t::isValidFor(), m_currentIov, m_iovProxy, m_session, cond::Iov_t::since, cond::persistency::Transaction::start(), cond::Iov_t::till, and cond::persistency::Session::transaction().

                                                                         {
  if (!m_currentIov.isValidFor(time)) {
    m_currentIov.clear();
    m_session.transaction().start(true);
    auto it = m_iovProxy.find(time);
    if (it != m_iovProxy.end()) {
      m_currentIov = *it;
    }
    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 loadRecoTauTagMVAsFromPrepDB_cfi::snapshotTime, AlCaHLTBitMon_QueryRunRegistry::string, GlobalPosition_Frontier_DevDB_cff::tag, filterCSVwithJSON::target, and findQualityFiles::v.

{ m_session = v; }

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

inline

Definition at line 94 of file DataProxy.h.

Referenced by addInfo(), and reload().

{ return m_tag; }

TimeType cond::DataProxyWrapperBase::timeType ( ) const

inline

Definition at line 109 of file DataProxy.h.

{ return m_iovProxy.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 >.

Referenced by Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::inputCommands(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::outputCommands(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::outputEventContent(), and Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::properties().

Member Data Documentation

std::string cond::DataProxyWrapperBase::m_connString

private

Definition at line 113 of file DataProxy.h.

Referenced by addInfo().

Iov_t cond::DataProxyWrapperBase::m_currentIov

private

Definition at line 116 of file DataProxy.h.

Referenced by loadTag(), and setIntervalFor().

persistency::IOVProxy cond::DataProxyWrapperBase::m_iovProxy

private

Definition at line 115 of file DataProxy.h.

Referenced by loadTag(), reload(), and setIntervalFor().

std::string cond::DataProxyWrapperBase::m_label

private

Definition at line 112 of file DataProxy.h.

Referenced by addInfo().

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

private

Definition at line 118 of file DataProxy.h.

Referenced by loadTag().

persistency::Session cond::DataProxyWrapperBase::m_session

private

Definition at line 117 of file DataProxy.h.

Referenced by loadTag(), and setIntervalFor().

std::string cond::DataProxyWrapperBase::m_tag

private

Definition at line 114 of file DataProxy.h.

Referenced by addInfo().