#include <RootDelayedReader.h>

Inheritance diagram for edm::RootDelayedReader:

Public Types
typedef roottree::BranchInfo	BranchInfo

typedef roottree::BranchMap	BranchMap

typedef roottree::EntryNumber	EntryNumber

Public Member Functions
RootDelayedReader &	operator= (RootDelayedReader const &)=delete

signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> const *	postEventReadFromSourceSignal () const final

signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> const *	preEventReadFromSourceSignal () const final

	RootDelayedReader (RootDelayedReader const &)=delete

	RootDelayedReader (RootTree const &tree, std::shared_ptr< InputFile > filePtr, InputType inputType)

void	setSignals (signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> const preEventReadSource, signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> const postEventReadSource)

	~RootDelayedReader () override

Public Member Functions inherited from edm::DelayedReader
std::shared_ptr< WrapperBase >	getProduct (BranchID const &k, EDProductGetter const ep, ModuleCallingContext const mcc=nullptr)

void	mergeReaders (DelayedReader *other)

void	reset ()

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

virtual	~DelayedReader ()

Private Member Functions
BranchMap const &	branches () const

BranchInfo const *	getBranchInfo (BranchID const &k) const

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

void	mergeReaders_ (DelayedReader *other) override

void	reset_ () override

std::pair< SharedResourcesAcquirer , std::recursive_mutex >	sharedResources_ () const override

Private Attributes
edm::propagate_const< std::shared_ptr< InputFile > >	filePtr_

InputType	inputType_

std::exception_ptr	lastException_

std::shared_ptr< std::recursive_mutex >	mutex_

edm::propagate_const< DelayedReader * >	nextReader_

signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> const *	postEventReadFromSourceSignal_

signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> const *	preEventReadFromSourceSignal_

std::unique_ptr< SharedResourcesAcquirer >	resourceAcquirer_

RootTree const &	tree_

edm::propagate_const< TClass * >	wrapperBaseTClass_

Detailed Description

Definition at line 33 of file RootDelayedReader.h.

Member Typedef Documentation

◆ BranchInfo

typedef roottree::BranchInfo edm::RootDelayedReader::BranchInfo

Definition at line 35 of file RootDelayedReader.h.

◆ BranchMap

typedef roottree::BranchMap edm::RootDelayedReader::BranchMap

Definition at line 36 of file RootDelayedReader.h.

◆ EntryNumber

typedef roottree::EntryNumber edm::RootDelayedReader::EntryNumber

Definition at line 37 of file RootDelayedReader.h.

Constructor & Destructor Documentation

◆ RootDelayedReader() [1/2]

edm::RootDelayedReader::RootDelayedReader	(	RootTree const &	tree,
		std::shared_ptr< InputFile >	filePtr,
		InputType	inputType
	)

Definition at line 23 of file RootDelayedReader.cc.

       : tree_(tree),
         filePtr_(filePtr),
         nextReader_(),
         resourceAcquirer_(inputType == InputType::Primary ? new SharedResourcesAcquirer()
                                                           : static_cast<SharedResourcesAcquirer*>(nullptr)),
         inputType_(inputType),
         wrapperBaseTClass_(TClass::GetClass("edm::WrapperBase")) {
     if (inputType == InputType::Primary) {
       auto resources = SharedResourcesRegistry::instance()->createAcquirerForSourceDelayedReader();
       resourceAcquirer_ = std::make_unique<SharedResourcesAcquirer>(std::move(resources.first));
       mutex_ = resources.second;
     }
   }

References edm::SharedResourcesRegistry::createAcquirerForSourceDelayedReader(), edm::SharedResourcesRegistry::instance(), eostools::move(), mutex_, edm::Primary, resourceAcquirer_, and mps_fire::resources.

◆ ~RootDelayedReader()

edm::RootDelayedReader::~RootDelayedReader ( )

override

Definition at line 38 of file RootDelayedReader.cc.

38 {}

◆ RootDelayedReader() [2/2]

edm::RootDelayedReader::RootDelayedReader ( RootDelayedReader const & )

delete

Member Function Documentation

◆ branches()

BranchMap const& edm::RootDelayedReader::branches ( ) const

inlineprivate

Definition at line 67 of file RootDelayedReader.h.

67 { return tree_.branches(); }

References edm::RootTree::branches(), and tree_.

Referenced by getBranchInfo().

◆ getBranchInfo()

BranchInfo const* edm::RootDelayedReader::getBranchInfo ( BranchID const & k ) const

inlineprivate

Definition at line 68 of file RootDelayedReader.h.

68 { return branches().find(k); }

References branches(), edm::roottree::BranchMap::find(), and dqmdumpme::k.

Referenced by getProduct_().

◆ getProduct_()

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

overrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 44 of file RootDelayedReader.cc.

                                                                                                         {
     if (lastException_) {
       std::rethrow_exception(lastException_);
     }
     auto branchInfo = getBranchInfo(k);
     if (not branchInfo) {
       if (nextReader_) {
         return nextReader_->getProduct(k, ep);
       } else {
         return std::shared_ptr<WrapperBase>();
       }
     }
     TBranch* br = branchInfo->productBranch_;
     if (br == nullptr) {
       if (nextReader_) {
         return nextReader_->getProduct(k, ep);
       } else {
         return std::shared_ptr<WrapperBase>();
       }
     }
  
     setRefCoreStreamer(ep);
     //make code exception safe
     std::shared_ptr<void> refCoreStreamerGuard(nullptr, [](void*) {
       setRefCoreStreamer(false);
       ;
     });
     TClass* cp = branchInfo->classCache_;
     if (nullptr == cp) {
       branchInfo->classCache_ = TClass::GetClass(branchInfo->branchDescription_.wrappedName().c_str());
       cp = branchInfo->classCache_;
       branchInfo->offsetToWrapperBase_ = cp->GetBaseClassOffset(wrapperBaseTClass_);
     }
     void* p = cp->New();
     std::unique_ptr<WrapperBase> edp = getWrapperBasePtr(p, branchInfo->offsetToWrapperBase_);
     br->SetAddress(&p);
     try {
       //Run and Lumi only have 1 entry number, which is index 0
       tree_.getEntry(br, tree_.entryNumberForIndex(tree_.branchType() == InEvent ? ep->transitionIndex() : 0));
     } catch (edm::Exception& exception) {
       exception.addContext("Rethrowing an exception that happened on a different thread.");
       lastException_ = std::current_exception();
     } catch (...) {
       lastException_ = std::current_exception();
     }
     if (lastException_) {
       std::rethrow_exception(lastException_);
     }
     if (tree_.branchType() == InEvent) {
       // CMS-THREADING For the primary input source calls to this function need to be serialized
       InputFile::reportReadBranch(inputType_, std::string(br->GetName()));
     }
     return edp;
   }

References beamvalidation::br, edm::RootTree::branchType(), edm::RootTree::entryNumberForIndex(), SiStripBadComponentsDQMServiceTemplate_cfg::ep, cppFunctionSkipper::exception, getBranchInfo(), edm::RootTree::getEntry(), edm::getWrapperBasePtr(), edm::InEvent, inputType_, dqmdumpme::k, lastException_, nextReader_, AlCaHLTBitMon_ParallelJobs::p, edm::InputFile::reportReadBranch(), edm::setRefCoreStreamer(), AlCaHLTBitMon_QueryRunRegistry::string, tree_, and wrapperBaseTClass_.

◆ mergeReaders_()

void edm::RootDelayedReader::mergeReaders_ ( DelayedReader * other )

inlineoverrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 63 of file RootDelayedReader.h.

63 { nextReader_ = other; }

References nextReader_, and trackingPlots::other.

◆ operator=()

RootDelayedReader& edm::RootDelayedReader::operator= ( RootDelayedReader const & )

delete

◆ postEventReadFromSourceSignal()

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

inlinefinalvirtual

Implements edm::DelayedReader.

Definition at line 49 of file RootDelayedReader.h.

                     {
       return postEventReadFromSourceSignal_;
     }

References postEventReadFromSourceSignal_.

◆ preEventReadFromSourceSignal()

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

inlinefinalvirtual

Implements edm::DelayedReader.

Definition at line 45 of file RootDelayedReader.h.

                     {
       return preEventReadFromSourceSignal_;
     }

References preEventReadFromSourceSignal_.

◆ reset_()

void edm::RootDelayedReader::reset_ ( )

inlineoverrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 64 of file RootDelayedReader.h.

64 { nextReader_ = nullptr; }

References nextReader_.

◆ setSignals()

void edm::RootDelayedReader::setSignals	(	signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> const *	preEventReadSource,
		signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> const *	postEventReadSource
	)

inline

Definition at line 54 of file RootDelayedReader.h.

                                                                                                               {
       preEventReadFromSourceSignal_ = preEventReadSource;
       postEventReadFromSourceSignal_ = postEventReadSource;
     }

References postEventReadFromSourceSignal_, and preEventReadFromSourceSignal_.

◆ sharedResources_()

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

overrideprivatevirtual

Reimplemented from edm::DelayedReader.

Definition at line 40 of file RootDelayedReader.cc.

                                                                                                    {
     return std::make_pair(resourceAcquirer_.get(), mutex_.get());
   }

References mutex_, and resourceAcquirer_.

Member Data Documentation

◆ filePtr_

edm::propagate_const<std::shared_ptr<InputFile> > edm::RootDelayedReader::filePtr_

private

Definition at line 72 of file RootDelayedReader.h.

◆ inputType_

InputType edm::RootDelayedReader::inputType_

private

Definition at line 77 of file RootDelayedReader.h.

Referenced by getProduct_().

◆ lastException_

std::exception_ptr edm::RootDelayedReader::lastException_

mutableprivate

Definition at line 89 of file RootDelayedReader.h.

Referenced by getProduct_().

◆ mutex_

std::shared_ptr<std::recursive_mutex> edm::RootDelayedReader::mutex_

private

Definition at line 76 of file RootDelayedReader.h.

Referenced by RootDelayedReader(), and sharedResources_().

◆ nextReader_

edm::propagate_const<DelayedReader*> edm::RootDelayedReader::nextReader_

private

Definition at line 73 of file RootDelayedReader.h.

Referenced by getProduct_(), mergeReaders_(), and reset_().

◆ postEventReadFromSourceSignal_

signalslot::Signal<void(StreamContext const&, ModuleCallingContext const&)> const* edm::RootDelayedReader::postEventReadFromSourceSignal_

private

Initial value:

=

nullptr

Definition at line 82 of file RootDelayedReader.h.

Referenced by postEventReadFromSourceSignal(), and setSignals().

◆ preEventReadFromSourceSignal_

signalslot::Signal<void(StreamContext const&, ModuleCallingContext const&)> const* edm::RootDelayedReader::preEventReadFromSourceSignal_

private

Initial value:

=

nullptr

Definition at line 80 of file RootDelayedReader.h.

Referenced by preEventReadFromSourceSignal(), and setSignals().

◆ resourceAcquirer_

std::unique_ptr<SharedResourcesAcquirer> edm::RootDelayedReader::resourceAcquirer_

private

Definition at line 75 of file RootDelayedReader.h.

Referenced by RootDelayedReader(), and sharedResources_().

◆ tree_

RootTree const& edm::RootDelayedReader::tree_

private

Definition at line 71 of file RootDelayedReader.h.

Referenced by branches(), and getProduct_().

◆ wrapperBaseTClass_

edm::propagate_const<TClass*> edm::RootDelayedReader::wrapperBaseTClass_

private

Definition at line 78 of file RootDelayedReader.h.

Referenced by getProduct_().

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ BranchInfo

◆ BranchMap

◆ EntryNumber

Constructor & Destructor Documentation

◆ RootDelayedReader() [1/2]

◆ ~RootDelayedReader()

◆ RootDelayedReader() [2/2]

Member Function Documentation

◆ branches()

◆ getBranchInfo()

◆ getProduct_()

◆ mergeReaders_()

◆ operator=()

◆ postEventReadFromSourceSignal()

◆ preEventReadFromSourceSignal()

◆ reset_()

◆ setSignals()

◆ sharedResources_()

Member Data Documentation

◆ filePtr_

◆ inputType_

◆ lastException_

◆ mutex_

◆ nextReader_

◆ postEventReadFromSourceSignal_

◆ preEventReadFromSourceSignal_

◆ resourceAcquirer_

◆ tree_

◆ wrapperBaseTClass_