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
typedef roottree::BranchMap::const_iterator	iterator

Public Member Functions
RootDelayedReader &	operator= (RootDelayedReader const &)=delete
	RootDelayedReader (RootTree const &tree, std::shared_ptr< InputFile > filePtr, InputType inputType)
	RootDelayedReader (RootDelayedReader const &)=delete
virtual	~RootDelayedReader ()
Public Member Functions inherited from edm::DelayedReader
virtual std::unique_ptr < WrapperBase >	getProduct (BranchKey const &k, EDProductGetter const *ep)
void	mergeReaders (DelayedReader *other)
void	reset ()
SharedResourcesAcquirer *	sharedResources () const
virtual	~DelayedReader ()

Private Member Functions
BranchMap const &	branches () const
iterator	branchIter (BranchKey const &k) const
bool	found (iterator const &iter) const
BranchInfo const &	getBranchInfo (iterator const &iter) const
virtual std::unique_ptr < WrapperBase >	getProduct_ (BranchKey const &k, EDProductGetter const *ep) override
virtual void	mergeReaders_ (DelayedReader *other) override
virtual void	reset_ () override
SharedResourcesAcquirer *	sharedResources_ () const override

Private Attributes
edm::propagate_const < std::shared_ptr< InputFile > >	filePtr_
InputType	inputType_
std::unique_ptr< Exception >	lastException_
edm::propagate_const < DelayedReader * >	nextReader_
std::unique_ptr < SharedResourcesAcquirer >	resourceAcquirer_
RootTree const &	tree_
edm::propagate_const< TClass * >	wrapperBaseTClass_

Detailed Description

Definition at line 31 of file RootDelayedReader.h.

Member Typedef Documentation

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

Definition at line 33 of file RootDelayedReader.h.

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

Definition at line 34 of file RootDelayedReader.h.

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

Definition at line 36 of file RootDelayedReader.h.

typedef roottree::BranchMap::const_iterator edm::RootDelayedReader::iterator

Definition at line 35 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::Primary.

                           :
   tree_(tree),
   filePtr_(filePtr),
   nextReader_(),
   resourceAcquirer_(inputType == InputType::Primary ? new SharedResourcesAcquirer(SharedResourcesRegistry::instance()->createAcquirerForSourceDelayedReader()) : static_cast<SharedResourcesAcquirer*>(nullptr)),
   inputType_(inputType),
   wrapperBaseTClass_(TClass::GetClass("edm::WrapperBase")) {
  }

edm::RootDelayedReader::~RootDelayedReader ( )

virtual

Definition at line 35 of file RootDelayedReader.cc.

                                        {
  }

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

delete

Member Function Documentation

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

inlineprivate

Definition at line 53 of file RootDelayedReader.h.

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

Referenced by branchIter(), and found().

{return tree_.branches();}

iterator edm::RootDelayedReader::branchIter ( BranchKey const &  k ) const

inlineprivate

Definition at line 54 of file RootDelayedReader.h.

References branches().

Referenced by getProduct_().

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

bool edm::RootDelayedReader::found ( iterator const &  iter ) const

inlineprivate

Definition at line 55 of file RootDelayedReader.h.

References branches().

Referenced by pf_01_customizeAll.SeqVisitor::__init__(), pf_01_customizeSimulation.SeqVisitor::__init__(), pf_01_customizeAll.SeqVisitor::enter(), pf_01_customizeSimulation.SeqVisitor::enter(), getProduct_(), pf_01_customizeAll.SeqVisitor::prepareSearch(), and pf_01_customizeSimulation.SeqVisitor::prepareSearch().

{return iter != branches().end();}

BranchInfo const& edm::RootDelayedReader::getBranchInfo ( iterator const &  iter ) const

inlineprivate

Definition at line 56 of file RootDelayedReader.h.

Referenced by getProduct_().

{return iter->second; }

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

overrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 44 of file RootDelayedReader.cc.

References beamvalidation::br, edm::roottree::BranchInfo::branchDescription_, branchIter(), edm::RootTree::branchType(), edm::roottree::BranchInfo::classCache_, CommonMethods::cp(), edm::RootTree::entryNumberForIndex(), cppFunctionSkipper::exception, found(), getBranchInfo(), edm::RootTree::getEntry(), edm::getWrapperBasePtr(), edm::InEvent, inputType_, lastException_, nextReader_, edm::roottree::BranchInfo::offsetToWrapperBase_, AlCaHLTBitMon_ParallelJobs::p, edm::roottree::BranchInfo::productBranch_, edm::InputFile::reportReadBranch(), edm::setRefCoreStreamer(), AlCaHLTBitMon_QueryRunRegistry::string, edm::EDProductGetter::transitionIndex(), tree_, edm::BranchDescription::wrappedName(), and wrapperBaseTClass_.

                                                                              {
    if (lastException_) {
      throw *lastException_;
    }
    iterator iter = branchIter(k);
    if (!found(iter)) {
      if (nextReader_) {
        return nextReader_->getProduct(k, ep);
      } else {
        return std::unique_ptr<WrapperBase>();
      }
    }
    roottree::BranchInfo const& branchInfo = getBranchInfo(iter);
    TBranch* br = branchInfo.productBranch_;
    if (br == nullptr) {
      if (nextReader_) {
        return nextReader_->getProduct(k, ep);
      } else {
        return std::unique_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{
      tree_.getEntry(br, tree_.entryNumberForIndex(ep->transitionIndex()));
    } catch(const edm::Exception& exception) {
      lastException_ = std::make_unique<Exception>(exception);
      lastException_->addContext("Rethrowing an exception that happened on a different thread.");
      throw exception;
    }
    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;
  }

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

inlineoverrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 49 of file RootDelayedReader.h.

References nextReader_.

{nextReader_ = other;}

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

delete

virtual void edm::RootDelayedReader::reset_ ( )

inlineoverrideprivatevirtual

Implements edm::DelayedReader.

Definition at line 50 of file RootDelayedReader.h.

References nextReader_.

{nextReader_ = nullptr;}

SharedResourcesAcquirer * edm::RootDelayedReader::sharedResources_ ( ) const

overrideprivatevirtual

Reimplemented from edm::DelayedReader.

Definition at line 39 of file RootDelayedReader.cc.

References resourceAcquirer_.

                                            {
    return resourceAcquirer_.get();
  }

Member Data Documentation

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

private

Definition at line 60 of file RootDelayedReader.h.

InputType edm::RootDelayedReader::inputType_

private

Definition at line 63 of file RootDelayedReader.h.

Referenced by getProduct_().

std::unique_ptr<Exception> edm::RootDelayedReader::lastException_

mutableprivate

Definition at line 68 of file RootDelayedReader.h.

Referenced by getProduct_().

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

private

Definition at line 61 of file RootDelayedReader.h.

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

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

private

Definition at line 62 of file RootDelayedReader.h.

Referenced by sharedResources_().

RootTree const& edm::RootDelayedReader::tree_

private

Definition at line 59 of file RootDelayedReader.h.

Referenced by branches(), and getProduct_().

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

private

Definition at line 64 of file RootDelayedReader.h.

Referenced by getProduct_().