edm::DelayedReader Class Reference

#include <DelayedReader.h>

Inheritance diagram for edm::DelayedReader:

Public Member Functions
std::unique_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::unique_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

~DelayedReader()

edm::DelayedReader::~DelayedReader ( )

virtual

Definition at line 15 of file DelayedReader.cc.

{}

Member Function Documentation

getProduct()

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

Definition at line 17 of file DelayedReader.cc.

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

References SiStripBadComponentsDQMServiceTemplate_cfg::ep, getProduct_(), edm::ModuleCallingContext::getStreamContext(), dqmdumpme::k, postEventReadFromSourceSignal(), and preEventReadFromSourceSignal().

getProduct_()

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

privatepure virtual

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

Referenced by getProduct().

mergeReaders()

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

inline

Definition at line 36 of file DelayedReader.h.

{ mergeReaders_(other); }

References mergeReaders_(), and trackingPlots::other.

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

mergeReaders_()

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

privatepure virtual

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

Referenced by mergeReaders().

postEventReadFromSourceSignal()

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

pure virtual

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

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

preEventReadFromSourceSignal()

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

pure virtual

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

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

reset()

void edm::DelayedReader::reset ( void  )

inline

Definition at line 37 of file DelayedReader.h.

{ reset_(); }

References reset_().

reset_()

virtual void edm::DelayedReader::reset_ ( )

privatepure virtual

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

Referenced by reset().

sharedResources()

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

inline

Definition at line 39 of file DelayedReader.h.

{ return sharedResources_(); }

References sharedResources_().

sharedResources_()

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

privatevirtual

Reimplemented in edm::RootDelayedReader.

Definition at line 36 of file DelayedReader.cc.

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

Referenced by sharedResources().