#include <DataProxy.h>

Inheritance diagram for edm::eventsetup::DataProxy:

Public Member Functions
bool	cacheIsValid () const

	DataProxy ()

void	doGet (EventSetupRecordImpl const &iRecord, DataKey const &iKey, bool iTransiently, ActivityRegistry const *) const

void const *	get (EventSetupRecordImpl const &, DataKey const &iKey, bool iTransiently, ActivityRegistry const *) const

void	invalidate ()

ComponentDescription const *	providerDescription () const
	returns the description of the DataProxyProvider which owns this Proxy More...

void	resetIfTransient ()

void	setProviderDescription (ComponentDescription const *iDesc)

virtual	~DataProxy ()

Protected Member Functions
void	clearCacheIsValid ()

virtual void const *	getImpl (EventSetupRecordImpl const &, DataKey const &iKey)=0

virtual void	invalidateCache ()=0

virtual void	invalidateTransientCache ()

Private Member Functions
	DataProxy (DataProxy const &)=delete

DataProxy const &	operator= (DataProxy const &)=delete

Private Attributes
void const *	cache_

std::atomic< bool >	cacheIsValid_

ComponentDescription const *	description_

std::atomic< bool >	nonTransientAccessRequested_

Detailed Description

Definition at line 37 of file DataProxy.h.

Constructor & Destructor Documentation

DataProxy< RecordT, DataT, Initializer >::DataProxy ( )

Definition at line 39 of file DataProxy.cc.

Referenced by setProviderDescription().

         : cache_(nullptr),
           cacheIsValid_(false),
           nonTransientAccessRequested_(false),
           description_(dummyDescription()) {}

DataProxy< RecordT, DataT, Initializer >::~DataProxy ( )

virtual

Definition at line 50 of file DataProxy.cc.

50 {}

edm::eventsetup::DataProxy::DataProxy ( DataProxy const & )

privatedelete

Member Function Documentation

bool edm::eventsetup::DataProxy::cacheIsValid ( ) const

inline

Definition at line 43 of file DataProxy.h.

References cacheIsValid_, and doGet().

Referenced by get(), and edm::eventsetup::EventSetupRecordImpl::wasGotten().

43 { return cacheIsValid_.load(std::memory_order_acquire); }

edm::eventsetup::DataProxy::cacheIsValid_

std::atomic< bool > cacheIsValid_

Definition: DataProxy.h:98

void DataProxy< RecordT, DataT, Initializer >::clearCacheIsValid ( )

protected

Definition at line 67 of file DataProxy.cc.

References cache_, cacheIsValid_, and nonTransientAccessRequested_.

Referenced by invalidate(), resetIfTransient(), and setProviderDescription().

                                       {
       cacheIsValid_.store(false, std::memory_order_release);
       nonTransientAccessRequested_.store(false, std::memory_order_release);
       cache_ = nullptr;
     }

void DataProxy< RecordT, DataT, Initializer >::doGet	(	EventSetupRecordImpl const &	iRecord,
		DataKey const &	iKey,
		bool	iTransiently,
		ActivityRegistry const *
	)		const

Definition at line 148 of file DataProxy.cc.

Referenced by cacheIsValid(), and edm::eventsetup::EventSetupRecordImpl::doGet().

                                                                           {
       get(iRecord, iKey, iTransiently, activityRegistry);
     }

const void * DataProxy< RecordT, DataT, Initializer >::get	(	EventSetupRecordImpl const &	,
		DataKey const &	iKey,
		bool	iTransiently,
		ActivityRegistry const *
	)		const

Definition at line 122 of file DataProxy.cc.

References cache_, cacheIsValid(), cacheIsValid_, getImpl(), nonTransientAccessRequested_, and providerDescription().

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), rrapi.RRApi::columns(), rrapi.RRApi::count(), rrapi.RRApi::data(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), rrapi.RRApi::report(), rrapi.RRApi::reports(), rrapi.RRApi::tables(), rrapi.RRApi::tags(), rrapi.RRApi::templates(), edm::eventsetup::EventSetupRecordImpl::transientReset(), and rrapi.RRApi::workspaces().

                                                                                {
       if (!cacheIsValid()) {
         ESSignalSentry signalSentry(iRecord, iKey, providerDescription(), activityRegistry);
         std::lock_guard<std::recursive_mutex> guard(s_esGlobalMutex);
         signalSentry.sendPostLockSignal();
         if (!cacheIsValid()) {
           cache_ = const_cast<DataProxy*>(this)->getImpl(iRecord, iKey);
           cacheIsValid_.store(true, std::memory_order_release);
         }
       }
       //We need to set the AccessType for each request so this can't be called in the if block above.
       //This also must be before the cache_ check since we want to setCacheIsValid before a possible
       // exception throw. If we don't, 'getImpl' will be called again on a second request for the data.
       if (!iTransiently) {
         nonTransientAccessRequested_.store(true, std::memory_order_release);
       }
 
       if (nullptr == cache_) {
         throwMakeException(iRecord, iKey);
       }
       return cache_;
     }

virtual void const* edm::eventsetup::DataProxy::getImpl	(	EventSetupRecordImpl const &	,
		DataKey const &	iKey
	)

protectedpure virtual

This is the function which does the real work of getting the data if it is not already cached. The returning 'void const*' must point to an instance of the class type corresponding to the type designated in iKey. So if iKey refers to a base class interface the pointer must be a pointer to that base class interface and not a pointer to an inheriting class instance.

Implemented in edm::test::TestDataProxy< T >.

Referenced by get(), and setProviderDescription().

void edm::eventsetup::DataProxy::invalidate ( )

inline

Definition at line 59 of file DataProxy.h.

References clearCacheIsValid(), invalidateCache(), and resetIfTransient().

                         {
         clearCacheIsValid();
         invalidateCache();
       }

virtual void edm::eventsetup::DataProxy::invalidateCache ( )

protectedpure virtual

indicates that the Proxy should invalidate any cached information as that information has 'expired' (i.e. we have moved to a new IOV)

Implemented in edm::eventsetup::CallbackProxy< CallbackT, RecordT, DataT >, edm::test::TestDataProxy< T >, and DataProxy< RecordT, DataT, Initializer >.

Referenced by invalidate(), invalidateTransientCache(), and setProviderDescription().

void DataProxy< RecordT, DataT, Initializer >::invalidateTransientCache ( )

protectedvirtual

indicates that the Proxy should invalidate any cached information as that information was accessed transiently and therefore is not intended to be kept over the entire IOV. Default is to call invalidateCache().

Reimplemented in DataProxy< RecordT, DataT, Initializer >.

Definition at line 80 of file DataProxy.cc.

References activityRegistry_, calledPostLock_, componentDescription_, dataKey_, eventSetupRecord_, invalidateCache(), edm::eventsetup::EventSetupRecordImpl::key(), noexcept, and edm::ActivityRegistry::preLockEventSetupGetSignal_.

Referenced by resetIfTransient(), and setProviderDescription().

80 { invalidateCache(); }

edm::eventsetup::DataProxy::invalidateCache

virtual void invalidateCache()=0

DataProxy const& edm::eventsetup::DataProxy::operator= ( DataProxy const & )

privatedelete

Referenced by setProviderDescription().

ComponentDescription const* edm::eventsetup::DataProxy::providerDescription ( ) const

inline

returns the description of the DataProxyProvider which owns this Proxy

Definition at line 55 of file DataProxy.h.

References description_.

Referenced by edm::eventsetup::EventSetupRecordImpl::add(), edm::eventsetup::EventSetupRecordImpl::doGet(), get(), edm::eventsetup::EventSetupRecordImpl::providerDescription(), and edm::eventsetup::EventSetupRecordImpl::transientReset().

55 { return description_; }

edm::eventsetup::DataProxy::description_

ComponentDescription const * description_

Definition: DataProxy.h:100

void DataProxy< RecordT, DataT, Initializer >::resetIfTransient ( )

Definition at line 73 of file DataProxy.cc.

References clearCacheIsValid(), invalidateTransientCache(), and nonTransientAccessRequested_.

Referenced by invalidate().

                                      {
       if (!nonTransientAccessRequested_.load(std::memory_order_acquire)) {
         clearCacheIsValid();
         invalidateTransientCache();
       }
     }