edm::RootDelayedReader Class Reference

#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 (RootTree const &tree, std::shared_ptr< InputFile > filePtr, InputType inputType)
	RootDelayedReader (RootDelayedReader const &)=delete
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

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

Definition at line 35 of file RootDelayedReader.h.

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

Definition at line 36 of file RootDelayedReader.h.

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

Definition at line 37 of file RootDelayedReader.h.

Constructor & Destructor Documentation

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

Definition at line 23 of file RootDelayedReader.cc.

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

      : tree_(tree),
        filePtr_(filePtr),
        nextReader_(),
        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;
    }
  }

edm::RootDelayedReader::~RootDelayedReader ( )

override

Definition at line 36 of file RootDelayedReader.cc.

{}

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

delete

Member Function Documentation

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

inlineprivate

Definition at line 67 of file RootDelayedReader.h.

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

Referenced by getBranchInfo().

{ return tree_.branches(); }

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

inlineprivate

Definition at line 68 of file RootDelayedReader.h.

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

Referenced by getProduct_().

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

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

overrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 42 of file RootDelayedReader.cc.

References cms::Exception::addContext(), beamvalidation::br, edm::RootTree::branchType(), CommonMethods::cp(), alignCSCRings::e, edm::RootTree::entryNumberForIndex(), getBranchInfo(), edm::RootTree::getEntry(), edm::getWrapperBasePtr(), edm::InEvent, inputType_, lastException_, nextReader_, AlCaHLTBitMon_ParallelJobs::p, edm::InputFile::reportReadBranch(), edm::setRefCoreStreamer(), AlCaHLTBitMon_QueryRunRegistry::string, edm::EDProductGetter::transitionIndex(), tree_, and wrapperBaseTClass_.

                                                                                                        {
    if (lastException_) {
      try {
        std::rethrow_exception(lastException_);
      } catch (cms::Exception& e) {
        e.addContext("Rethrowing an exception that happened on a different read request.");
        throw;
      }
    }
    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, Lumi, and ProcessBlock only have 1 entry number, which is index 0
      tree_.getEntry(br, tree_.entryNumberForIndex(tree_.branchType() == InEvent ? ep->transitionIndex() : 0));
    } catch (...) {
      lastException_ = std::current_exception();
      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;
  }

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

inlineoverrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 63 of file RootDelayedReader.h.

References nextReader_.

{ nextReader_ = other; }

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

delete

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

inlinefinalvirtual

Implements edm::DelayedReader.

Definition at line 49 of file RootDelayedReader.h.

References postEventReadFromSourceSignal_.

                    {
      return postEventReadFromSourceSignal_;
    }

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

inlinefinalvirtual

Implements edm::DelayedReader.

Definition at line 45 of file RootDelayedReader.h.

References preEventReadFromSourceSignal_.

                    {
      return preEventReadFromSourceSignal_;
    }

void edm::RootDelayedReader::reset_ ( )

inlineoverrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 64 of file RootDelayedReader.h.

References nextReader_.

{ nextReader_ = nullptr; }

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.

References postEventReadFromSourceSignal_, and preEventReadFromSourceSignal_.

                                                                                                              {
      preEventReadFromSourceSignal_ = preEventReadSource;
      postEventReadFromSourceSignal_ = postEventReadSource;
    }

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

overrideprivatevirtual

Reimplemented from edm::DelayedReader.

Definition at line 38 of file RootDelayedReader.cc.

References mutex_, and resourceAcquirer_.

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

Member Data Documentation

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

private

Definition at line 72 of file RootDelayedReader.h.

InputType edm::RootDelayedReader::inputType_

private

Definition at line 77 of file RootDelayedReader.h.

Referenced by getProduct_().

std::exception_ptr edm::RootDelayedReader::lastException_

mutableprivate

Definition at line 89 of file RootDelayedReader.h.

Referenced by getProduct_().

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

private

Definition at line 76 of file RootDelayedReader.h.

Referenced by RootDelayedReader(), and sharedResources_().

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

private

Definition at line 73 of file RootDelayedReader.h.

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

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

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

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

private

Definition at line 75 of file RootDelayedReader.h.

Referenced by RootDelayedReader(), and sharedResources_().

RootTree const& edm::RootDelayedReader::tree_

private

Definition at line 71 of file RootDelayedReader.h.

Referenced by branches(), and getProduct_().

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

private

Definition at line 78 of file RootDelayedReader.h.

Referenced by getProduct_().