edm::DelayedReader Class Reference

#include <DelayedReader.h>

Inheritance diagram for edm::DelayedReader:

Public Member Functions
std::shared_ptr< WrapperBase >	getProduct (BranchID const &k, EDProductGetter const *ep, ModuleCallingContext const *mcc=nullptr)
void	mergeReaders (DelayedReader *other)
virtual signalslot::Signal < void(StreamContext const &, ModuleCallingContext const &)> const *	postEventReadFromSourceSignal () const =0
virtual signalslot::Signal < void(StreamContext const &, ModuleCallingContext const &)> const *	preEventReadFromSourceSignal () const =0
void	reset ()
std::pair < SharedResourcesAcquirer *, std::recursive_mutex * >	sharedResources () const
virtual	~DelayedReader ()

Private Member Functions
virtual std::shared_ptr < WrapperBase >	getProduct_ (BranchID const &k, EDProductGetter const *ep)=0
virtual void	mergeReaders_ (DelayedReader *)=0
virtual void	reset_ ()=0
virtual std::pair < SharedResourcesAcquirer *, std::recursive_mutex * >	sharedResources_ () const

Detailed Description

Definition at line 29 of file DelayedReader.h.

Constructor & Destructor Documentation

edm::DelayedReader::~DelayedReader ( )

virtual

Definition at line 15 of file DelayedReader.cc.

{}

Member Function Documentation

std::shared_ptr< WrapperBase > edm::DelayedReader::getProduct	(	BranchID const &	k,
		EDProductGetter const *	ep,
		ModuleCallingContext const *	mcc = nullptr
	)

Definition at line 17 of file DelayedReader.cc.

References getProduct_(), edm::ModuleCallingContext::getStreamContext(), postEventReadFromSourceSignal(), and preEventReadFromSourceSignal().

                                                                                          {
    auto preSignal = preEventReadFromSourceSignal();
    if (mcc and preSignal) {
      preSignal->emit(*(mcc->getStreamContext()), *mcc);
    }
    auto postSignal = postEventReadFromSourceSignal();

    auto sentryCall = [&postSignal](ModuleCallingContext const* iContext) {
      if (postSignal) {
        postSignal->emit(*(iContext->getStreamContext()), *iContext);
      }
    };
    std::unique_ptr<ModuleCallingContext const, decltype(sentryCall)> sentry(mcc, sentryCall);

    return getProduct_(k, ep);
  }

virtual std::shared_ptr<WrapperBase> edm::DelayedReader::getProduct_ ( BranchID const &  k, EDProductGetter const *  ep  )

privatepure virtual

Implemented in edm::root::FWLiteDelayedReader, edm::RootDelayedReader, and edm::RepeatingCachedRootSource::RCDelayedReader.

Referenced by getProduct().

void edm::DelayedReader::mergeReaders ( DelayedReader *  other )

inline

Definition at line 36 of file DelayedReader.h.

References mergeReaders_().

Referenced by edm::Principal::recombine().

{ mergeReaders_(other); }

virtual void edm::DelayedReader::mergeReaders_ ( DelayedReader *  )

privatepure virtual

Implemented in edm::root::FWLiteDelayedReader, edm::RepeatingCachedRootSource::RCDelayedReader, and edm::RootDelayedReader.

Referenced by mergeReaders().

virtual signalslot::Signal<void(StreamContext const&, ModuleCallingContext const&)> const* edm::DelayedReader::postEventReadFromSourceSignal ( ) const

pure virtual

Implemented in edm::root::FWLiteDelayedReader, edm::RepeatingCachedRootSource::RCDelayedReader, and edm::RootDelayedReader.

Referenced by getProduct(), and edm::FullProvenanceReader::readProvenanceAsync().

virtual signalslot::Signal<void(StreamContext const&, ModuleCallingContext const&)> const* edm::DelayedReader::preEventReadFromSourceSignal ( ) const

pure virtual

Implemented in edm::root::FWLiteDelayedReader, edm::RepeatingCachedRootSource::RCDelayedReader, and edm::RootDelayedReader.

Referenced by getProduct(), and edm::FullProvenanceReader::readProvenanceAsync().

void edm::DelayedReader::reset ( void  )

inline

Definition at line 37 of file DelayedReader.h.

References reset_().

{ reset_(); }

virtual void edm::DelayedReader::reset_ ( )

privatepure virtual

Implemented in edm::root::FWLiteDelayedReader, edm::RepeatingCachedRootSource::RCDelayedReader, and edm::RootDelayedReader.

Referenced by reset().

std::pair<SharedResourcesAcquirer*, std::recursive_mutex*> edm::DelayedReader::sharedResources ( ) const

inline

Definition at line 39 of file DelayedReader.h.

References sharedResources_().

{ return sharedResources_(); }

std::pair< SharedResourcesAcquirer *, std::recursive_mutex * > edm::DelayedReader::sharedResources_ ( ) const

privatevirtual

Reimplemented in edm::RootDelayedReader.

Definition at line 36 of file DelayedReader.cc.

Referenced by sharedResources().

                                                                                               {
    return std::pair<SharedResourcesAcquirer*, std::recursive_mutex*>(nullptr, nullptr);
  }