edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator > Class Template Reference

#include <CallbackBase.h>

Inheritance diagram for edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >:

Public Member Functions
	CallbackBase (T *iProd, std::shared_ptr< TProduceFunc > iProduceFunc, unsigned int iID, const TDecorator &iDec)
	CallbackBase (const CallbackBase &)=delete
	CallbackBase (CallbackBase &&)=delete
ESModuleCallingContext &	callingContext ()
TDecorator const &	decorator () const
ESResolverIndex const *	getTokenIndices () const
template<class DataT >
void	holdOntoPointer (DataT *iData)
template<typename ProduceFunctor >
WaitingTaskHolder	makeProduceTask (oneapi::tbb::task_group *group, ServiceWeakToken const &serviceToken, EventSetupRecordImpl const *record, EventSetupImpl const *eventSetupImpl, bool emitPostPrefetchingSignal, ProduceFunctor &&produceFunctor)
void	newRecordComing ()
CallbackBase &	operator= (const CallbackBase &)=delete
CallbackBase &	operator= (CallbackBase &&)=delete
std::optional< std::vector< ESResolverIndex > > const &	postMayGetResolvers () const
template<typename RunModuleFnctr >
void	prefetchAsyncImpl (RunModuleFnctr &&runModuleFnctr, WaitingTaskHolder iTask, EventSetupRecordImpl const *iRecord, EventSetupImpl const *iEventSetupImpl, ServiceToken const &token, ESParentContext const &iParent)
std::shared_ptr< TProduceFunc > const &	produceFunction ()
T *	producer ()
SerialTaskQueueChain &	queue ()
template<class RemainingContainerT , class DataT , class ProductsT >
void	setData (ProductsT &iProducts)
WaitingTaskList &	taskList ()
unsigned int	transitionID () const

Protected Member Functions
	~CallbackBase ()=default

Private Member Functions
bool	handleMayGet (EventSetupRecordImpl const *iRecord, EventSetupImpl const *iEventSetupImpl)
void	prefetchNeededDataAsync (WaitingTaskHolder task, EventSetupImpl const *iImpl, ESResolverIndex const *proxies, ServiceToken const &token) const
void	storeReturnedValues (TReturn iReturn)

Private Attributes
ESModuleCallingContext	callingContext_
TDecorator	decorator_
const unsigned int	id_
std::optional< std::vector< ESResolverIndex > >	postMayGetResolvers_
std::shared_ptr< TProduceFunc >	produceFunction_
propagate_const< T * >	producer_
std::array< void *, produce::size< TReturn >::value >	proxyData_
WaitingTaskList	taskList_
std::atomic< bool >	wasCalledForThisRecord_

Detailed Description

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>
class edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >

Description: Functional object used as the 'callback' for the CallbackESProductResolver

Usage: Produces data objects for ESProducers in EventSetup system

Definition at line 68 of file CallbackBase.h.

Constructor & Destructor Documentation

CallbackBase() [1/3]

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::CallbackBase ( T *  iProd, std::shared_ptr< TProduceFunc >  iProduceFunc, unsigned int  iID, const TDecorator &  iDec  )

inline

Definition at line 70 of file CallbackBase.h.

          : proxyData_{},
            producer_(iProd),
            callingContext_(&iProd->description()),
            produceFunction_(std::move(iProduceFunc)),
            id_(iID),
            wasCalledForThisRecord_(false),
            decorator_(iDec) {}

CallbackBase() [2/3]

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::CallbackBase ( const CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator > &  )

delete

CallbackBase() [3/3]

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::CallbackBase ( CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator > &&  )

delete

~CallbackBase()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::~CallbackBase ( )

protecteddefault

Member Function Documentation

callingContext()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

ESModuleCallingContext& edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::callingContext ( )

inline

Definition at line 229 of file CallbackBase.h.

{ return callingContext_; }

decorator()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

TDecorator const& edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::decorator ( ) const

inline

Definition at line 232 of file CallbackBase.h.

Referenced by edm::eventsetup::Callback< T, TProduceFunc, TReturn, TRecord, TDecorator >::clone().

{ return decorator_; }

getTokenIndices()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

ESResolverIndex const* edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::getTokenIndices ( ) const

inline

Definition at line 225 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::handleMayGet(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::makeProduceTask(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchAsyncImpl().

{ return producer_->getTokenIndices(id_); }

handleMayGet()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

bool edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::handleMayGet ( EventSetupRecordImpl const *  iRecord, EventSetupImpl const *  iEventSetupImpl  )

inlineprivate

Definition at line 258 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchAsyncImpl().

                                                                                                    {
        //Handle mayGets
        TRecord rec;
        ESParentContext pc{&callingContext_};
        rec.setImpl(iRecord, transitionID(), getTokenIndices(), iEventSetupImpl, &pc);
        postMayGetResolvers_ = producer_->updateFromMayConsumes(id_, rec);
        return static_cast<bool>(postMayGetResolvers_);
      }

holdOntoPointer()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

template<class DataT >

void edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::holdOntoPointer ( DataT *  iData )

inline

Definition at line 204 of file CallbackBase.h.

                                         {
        proxyData_[produce::find_index<TReturn, DataT>::value] = iData;
      }

makeProduceTask()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

template<typename ProduceFunctor >

WaitingTaskHolder edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::makeProduceTask ( oneapi::tbb::task_group *  group, ServiceWeakToken const &  serviceToken, EventSetupRecordImpl const *  record, EventSetupImpl const *  eventSetupImpl, bool  emitPostPrefetchingSignal, ProduceFunctor &&  produceFunctor  )

inline

Definition at line 85 of file CallbackBase.h.

Referenced by edm::eventsetup::Callback< T, TProduceFunc, TReturn, TRecord, TDecorator >::prefetchAsync().

                                                                         {
        return WaitingTaskHolder(
            *group,
            make_waiting_task([this,
                               group,
                               serviceToken,
                               record,
                               eventSetupImpl,
                               emitPostPrefetchingSignal,
                               produceFunctor =
                                   std::forward<ProduceFunctor>(produceFunctor)](std::exception_ptr const* iException) {
              std::exception_ptr excptr;
              if (iException) {
                excptr = *iException;
              }
              if (emitPostPrefetchingSignal) {
                try {
                  convertException::wrap([this, &serviceToken, &record] {
                    ServiceRegistry::Operate guard(serviceToken.lock());
                    record->activityRegistry()->postESModulePrefetchingSignal_.emit(record->key(), callingContext_);
                  });
                } catch (cms::Exception& caughtException) {
                  if (not excptr) {
                    exceptionContext(caughtException, callingContext_);
                    excptr = std::current_exception();
                  }
                }
              }
              if (excptr) {
                taskList_.doneWaiting(excptr);
                return;
              }

              producer_->queue().push(
                  *group, [this, serviceToken, record, eventSetupImpl, produceFunctor = std::move(produceFunctor)]() {
                    callingContext_.setState(ESModuleCallingContext::State::kRunning);
                    std::exception_ptr exceptPtr;
                    try {
                      convertException::wrap([this, &serviceToken, &record, &eventSetupImpl, &produceFunctor] {
                        ESModuleCallingContext const& context = callingContext_;
                        auto proxies = getTokenIndices();
                        if (postMayGetResolvers_) {
                          proxies = &((*postMayGetResolvers_).front());
                        }
                        TRecord rec;
                        ESParentContext pc{&context};
                        rec.setImpl(record, transitionID(), proxies, eventSetupImpl, &pc);
                        ServiceRegistry::Operate operate(serviceToken.lock());
                        record->activityRegistry()->preESModuleSignal_.emit(record->key(), context);
                        struct EndGuard {
                          EndGuard(EventSetupRecordImpl const* iRecord, ESModuleCallingContext const& iContext)
                              : record_{iRecord}, context_{iContext} {}
                          ~EndGuard() {
                            record_->activityRegistry()->postESModuleSignal_.emit(record_->key(), context_);
                          }
                          EventSetupRecordImpl const* record_;
                          ESModuleCallingContext const& context_;
                        };
                        EndGuard guard(record, context);
                        decorator_.pre(rec);
                        storeReturnedValues(produceFunctor(rec));
                        decorator_.post(rec);
                      });
                    } catch (cms::Exception& iException) {
                      exceptionContext(iException, callingContext_);
                      exceptPtr = std::current_exception();
                    }
                    taskList_.doneWaiting(exceptPtr);
                  });
            }));
      }

newRecordComing()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

void edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::newRecordComing ( )

inline

Definition at line 219 of file CallbackBase.h.

                             {
        wasCalledForThisRecord_ = false;
        taskList_.reset();
      }

operator=() [1/2]

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

CallbackBase& edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::operator= ( const CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator > &  )

delete

operator=() [2/2]

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

CallbackBase& edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::operator= ( CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator > &&  )

delete

postMayGetResolvers()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

std::optional<std::vector<ESResolverIndex> > const& edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::postMayGetResolvers ( ) const

inline

Definition at line 227 of file CallbackBase.h.

{ return postMayGetResolvers_; }

prefetchAsyncImpl()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

template<typename RunModuleFnctr >

void edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::prefetchAsyncImpl ( RunModuleFnctr &&  runModuleFnctr, WaitingTaskHolder  iTask, EventSetupRecordImpl const *  iRecord, EventSetupImpl const *  iEventSetupImpl, ServiceToken const &  token, ESParentContext const &  iParent  )

inline

Definition at line 163 of file CallbackBase.h.

Referenced by edm::eventsetup::Callback< T, TProduceFunc, TReturn, TRecord, TDecorator >::prefetchAsync().

                                                             {
        bool expected = false;
        auto doPrefetch = wasCalledForThisRecord_.compare_exchange_strong(expected, true);
        taskList_.add(iTask);
        if (doPrefetch) {
          auto group = iTask.group();
          ServiceWeakToken weakToken(token);
          WaitingTaskHolder runModuleTaskHolder = runModuleFnctr(group, weakToken, iRecord, iEventSetupImpl);
          callingContext_.setContext(ESModuleCallingContext::State::kPrefetching, iParent);
          iRecord->activityRegistry()->preESModulePrefetchingSignal_.emit(iRecord->key(), callingContext_);
          if UNLIKELY (producer_->hasMayConsumes()) {
            //after prefetching need to do the mayGet
            auto mayGetTask = make_waiting_task(
                [this, iRecord, iEventSetupImpl, weakToken, runModuleTaskHolder = std::move(runModuleTaskHolder)](
                    std::exception_ptr const* iExcept) mutable {
                  if (iExcept) {
                    runModuleTaskHolder.doneWaiting(*iExcept);
                    return;
                  }
                  if (handleMayGet(iRecord, iEventSetupImpl)) {
                    prefetchNeededDataAsync(
                        runModuleTaskHolder, iEventSetupImpl, &((*postMayGetResolvers_).front()), weakToken.lock());
                  } else {
                    runModuleTaskHolder.doneWaiting(std::exception_ptr{});
                  }
                });

            //Get everything we can before knowing about the mayGets
            prefetchNeededDataAsync(WaitingTaskHolder(*group, mayGetTask), iEventSetupImpl, getTokenIndices(), token);
          } else {
            prefetchNeededDataAsync(runModuleTaskHolder, iEventSetupImpl, getTokenIndices(), token);
          }
        }
      }

prefetchNeededDataAsync()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

void edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::prefetchNeededDataAsync ( WaitingTaskHolder  task, EventSetupImpl const *  iImpl, ESResolverIndex const *  proxies, ServiceToken const &  token  ) const

inlineprivate

Definition at line 244 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchAsyncImpl().

                                                                    {
        auto recs = producer_->getTokenRecordIndices(id_);
        auto n = producer_->numberOfTokenIndices(id_);
        for (size_t i = 0; i != n; ++i) {
          auto rec = iImpl->findImpl(recs[i]);
          if (rec) {
            rec->prefetchAsync(task, proxies[i], iImpl, token, ESParentContext{&callingContext_});
          }
        }
      }

produceFunction()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

std::shared_ptr<TProduceFunc> const& edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::produceFunction ( )

inline

Definition at line 231 of file CallbackBase.h.

Referenced by edm::eventsetup::Callback< T, TProduceFunc, TReturn, TRecord, TDecorator >::clone(), and edm::eventsetup::Callback< T, TProduceFunc, TReturn, TRecord, TDecorator >::prefetchAsync().

{ return produceFunction_; }

producer()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

T* edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::producer ( )

inline

Definition at line 228 of file CallbackBase.h.

Referenced by edm::eventsetup::Callback< T, TProduceFunc, TReturn, TRecord, TDecorator >::clone().

{ return producer_.get(); }

queue()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

SerialTaskQueueChain& edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::queue ( )

inline

Definition at line 233 of file CallbackBase.h.

{ return producer_->queue(); }

setData()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

template<class RemainingContainerT , class DataT , class ProductsT >

void edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::setData ( ProductsT &  iProducts )

inline

Definition at line 209 of file CallbackBase.h.

                                         {
        DataT* temp = reinterpret_cast<DataT*>(proxyData_[produce::find_index<TReturn, DataT>::value]);
        if (nullptr != temp) {
          moveFromTo(iProducts, *temp);
        }
        if constexpr (not std::is_same_v<produce::Null, RemainingContainerT>) {
          setData<typename RemainingContainerT::head_type, typename RemainingContainerT::tail_type>(iProducts);
        }
      }

storeReturnedValues()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

void edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::storeReturnedValues ( TReturn  iReturn )

inlineprivate

Definition at line 239 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::makeProduceTask().

                                                {
        using type = typename produce::product_traits<TReturn>::type;
        setData<typename type::head_type, typename type::tail_type>(iReturn);
      }

taskList()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

WaitingTaskList& edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::taskList ( )

inline

Definition at line 230 of file CallbackBase.h.

{ return taskList_; }

transitionID()

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

unsigned int edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::transitionID ( ) const

inline

Definition at line 224 of file CallbackBase.h.

Referenced by edm::eventsetup::Callback< T, TProduceFunc, TReturn, TRecord, TDecorator >::clone(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::handleMayGet(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::makeProduceTask().

{ return id_; }

Member Data Documentation

callingContext_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

ESModuleCallingContext edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::callingContext_

private

Definition at line 270 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::callingContext(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::handleMayGet(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::makeProduceTask(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchAsyncImpl(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchNeededDataAsync().

decorator_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

TDecorator edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::decorator_

private

Definition at line 278 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::decorator(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::makeProduceTask().

id_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

const unsigned int edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::id_

private

Definition at line 276 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::getTokenIndices(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::handleMayGet(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchNeededDataAsync(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::transitionID().

postMayGetResolvers_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

std::optional<std::vector<ESResolverIndex> > edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::postMayGetResolvers_

private

Definition at line 268 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::handleMayGet(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::makeProduceTask(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::postMayGetResolvers().

produceFunction_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

std::shared_ptr<TProduceFunc> edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::produceFunction_

private

Definition at line 274 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::produceFunction().

producer_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

propagate_const<T*> edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::producer_

private

Definition at line 269 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::getTokenIndices(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::handleMayGet(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::makeProduceTask(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchAsyncImpl(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchNeededDataAsync(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::producer(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::queue().

proxyData_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

std::array<void*, produce::size<TReturn>::value> edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::proxyData_

private

Definition at line 267 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::holdOntoPointer(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::setData().

taskList_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

WaitingTaskList edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::taskList_

private

Definition at line 271 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::makeProduceTask(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::newRecordComing(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchAsyncImpl(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::taskList().

wasCalledForThisRecord_

template<typename T, typename TProduceFunc, typename TReturn, typename TRecord, typename TDecorator>

std::atomic<bool> edm::eventsetup::CallbackBase< T, TProduceFunc, TReturn, TRecord, TDecorator >::wasCalledForThisRecord_

private

Definition at line 277 of file CallbackBase.h.

Referenced by edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::newRecordComing(), and edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >::prefetchAsyncImpl().