DataProxyWrapper< RecordT, DataT, Initializer > Class Template Reference

#include <DataProxy.h>

Inheritance diagram for DataProxyWrapper< RecordT, DataT, Initializer >:

Public Types
typedef ::DataProxy< RecordT, DataT, Initializer >	DataProxy
Public Types inherited from cond::DataProxyWrapperBase
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
	DataProxyWrapper (const char *source=nullptr)
edmProxyP	edmProxy (unsigned int iovIndex) const override
void	initConcurrentIOVs (unsigned int nConcurrentIOVs) override
void	lateInit (cond::persistency::Session &iSession, const std::string &tag, const boost::posix_time::ptime &snapshotTime, std::string const &il, std::string const &cs, edm::SerialTaskQueue *queue, std::mutex *mutex) override
ProxyP	proxy (unsigned int iovIndex) const override
edm::eventsetup::TypeTag	type () const override
Public Member Functions inherited from cond::DataProxyWrapperBase
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 ()
persistency::IOVProxy &	iovProxy ()
persistency::IOVProxy const &	iovProxy () const
std::string const &	label () const
void	loadTag (std::string const &tag)
void	loadTag (std::string const &tag, boost::posix_time::ptime const &snapshotTime)
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	~DataProxyWrapperBase ()

Private Attributes
std::vector< std::shared_ptr < DataProxy > >	m_edmProxies
std::vector< std::shared_ptr < cond::persistency::PayloadProxy < DataT > > >	m_proxies
std::string	m_source
edm::eventsetup::TypeTag	m_type

Detailed Description

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>
class DataProxyWrapper< RecordT, DataT, Initializer >

Definition at line 126 of file DataProxy.h.

Member Typedef Documentation

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

typedef ::DataProxy<RecordT, DataT, Initializer> DataProxyWrapper< RecordT, DataT, Initializer >::DataProxy

Definition at line 128 of file DataProxy.h.

Constructor & Destructor Documentation

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

DataProxyWrapper< RecordT, DataT, Initializer >::DataProxyWrapper ( const char *  source = nullptr )

inlineexplicit

Definition at line 131 of file DataProxy.h.

                                                          : m_source(source ? source : "") {
    //NOTE: We do this so that the type 'DataT' will get registered
    // when the plugin is dynamically loaded
    m_type = edm::eventsetup::DataKey::makeTypeTag<DataT>();
  }

Member Function Documentation

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

edmProxyP DataProxyWrapper< RecordT, DataT, Initializer >::edmProxy ( unsigned int  iovIndex ) const

inlineoverridevirtual

Implements cond::DataProxyWrapperBase.

Definition at line 178 of file DataProxy.h.

{ return m_edmProxies.at(iovIndex); }

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

void DataProxyWrapper< RecordT, DataT, Initializer >::initConcurrentIOVs ( unsigned int  nConcurrentIOVs )

inlineoverridevirtual

Implements cond::DataProxyWrapperBase.

Definition at line 156 of file DataProxy.h.

                                                                 {
    // Create additional PayloadProxy objects if we are allowing
    // multiple IOVs to run concurrently.
    if (m_proxies.size() != nConcurrentIOVs) {
      assert(m_proxies.size() == 1);
      auto queue = m_edmProxies.front()->queue();
      auto mutex = m_edmProxies.front()->mutex();
      for (unsigned int i = 1; i < nConcurrentIOVs; ++i) {
        m_proxies.push_back(std::make_shared<cond::persistency::PayloadProxy<DataT>>(
            &currentIov(), &session(), &requests(), m_source.empty() ? (const char*)nullptr : m_source.c_str()));
        m_edmProxies.push_back(std::make_shared<DataProxy>(m_proxies[i], queue, mutex));
        // This does nothing except in the special case of a KeyList PayloadProxy.
        // They all need to have copies of the same IOVProxy object.
        m_proxies[i]->initKeyList(*m_proxies[0]);
      }
      assert(m_proxies.size() == nConcurrentIOVs);
    }
    assert(m_proxies.size() == m_edmProxies.size());
  }

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

void DataProxyWrapper< RecordT, DataT, Initializer >::lateInit ( cond::persistency::Session &  iSession, const std::string &  tag, const boost::posix_time::ptime &  snapshotTime, std::string const &  il, std::string const &  cs, edm::SerialTaskQueue *  queue, std::mutex *  mutex  )

inlineoverridevirtual

Implements cond::DataProxyWrapperBase.

Definition at line 138 of file DataProxy.h.

                                          {
    setSession(iSession);
    // set the IOVProxy
    loadTag(tag, snapshotTime);
    // Only make the first PayloadProxy object now because we don't know yet
    // how many we will need.
    m_proxies.push_back(std::make_shared<cond::persistency::PayloadProxy<DataT>>(
        &currentIov(), &session(), &requests(), m_source.empty() ? (const char*)nullptr : m_source.c_str()));
    m_edmProxies.push_back(std::make_shared<DataProxy>(m_proxies[0], queue, mutex));
    addInfo(il, cs, tag);
  }

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

ProxyP DataProxyWrapper< RecordT, DataT, Initializer >::proxy ( unsigned int  iovIndex ) const

inlineoverridevirtual

Implements cond::DataProxyWrapperBase.

Definition at line 177 of file DataProxy.h.

{ return m_proxies.at(iovIndex); }

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

edm::eventsetup::TypeTag DataProxyWrapper< RecordT, DataT, Initializer >::type ( ) const

inlineoverridevirtual

Implements cond::DataProxyWrapperBase.

Definition at line 176 of file DataProxy.h.

{ return m_type; }

Member Data Documentation

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

std::vector<std::shared_ptr<DataProxy> > DataProxyWrapper< RecordT, DataT, Initializer >::m_edmProxies

private

Definition at line 184 of file DataProxy.h.

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

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

std::vector<std::shared_ptr<cond::persistency::PayloadProxy<DataT> > > DataProxyWrapper< RecordT, DataT, Initializer >::m_proxies

private

Definition at line 183 of file DataProxy.h.

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

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

std::string DataProxyWrapper< RecordT, DataT, Initializer >::m_source

private

Definition at line 181 of file DataProxy.h.

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

template<class RecordT, class DataT, typename Initializer = cond::DefaultInitializer<DataT>>

edm::eventsetup::TypeTag DataProxyWrapper< RecordT, DataT, Initializer >::m_type

private

Definition at line 182 of file DataProxy.h.

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