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 28 of file DelayedReader.h.

Constructor & Destructor Documentation

edm::DelayedReader::~DelayedReader ( )

virtual

Definition at line 16 of file DelayedReader.cc.

{}

Member Function Documentation

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

Definition at line 19 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::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().

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

inline

Definition at line 35 of file DelayedReader.h.

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

{mergeReaders_(other);}

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

privatepure virtual

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

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().

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().

void edm::DelayedReader::reset ( void  )

inline

Definition at line 36 of file DelayedReader.h.

{reset_();}

virtual void edm::DelayedReader::reset_ ( )

privatepure virtual

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

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

inline

Definition at line 38 of file DelayedReader.h.

References edm::refcore::getProduct_().

                                                                                   {
      return sharedResources_();
    }

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

privatevirtual

Reimplemented in edm::RootDelayedReader.

Definition at line 40 of file DelayedReader.cc.

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