fwlite::ChainEvent Class Reference

#include <ChainEvent.h>

Inheritance diagram for fwlite::ChainEvent:

Public Member Functions
bool	atEnd () const override
	ChainEvent (std::vector< std::string > const &iFileNames)
Event const *	event () const
edm::EventAuxiliary const &	eventAuxiliary () const override
Long64_t	eventIndex () const
Long64_t	fileIndex () const override
void	fillParameterSetRegistry () const
std::vector< edm::BranchDescription > const &	getBranchDescriptions () const
const std::string	getBranchNameFor (std::type_info const &, char const *, char const *, char const *) const override
bool	getByLabel (std::type_info const &, char const *, char const *, char const *, void *) const override
edm::WrapperBase const *	getByProductID (edm::ProductID const &) const override
fwlite::LuminosityBlock const &	getLuminosityBlock ()
std::vector< std::string > const &	getProcessHistory () const
fwlite::Run const &	getRun ()
TFile *	getTFile () const
edm::WrapperBase const *	getThinnedProduct (edm::ProductID const &pid, unsigned int &key) const
void	getThinnedProducts (edm::ProductID const &pid, std::vector< edm::WrapperBase const * > &foundContainers, std::vector< unsigned int > &keys) const
bool	isValid () const
	operator bool () const
ChainEvent const &	operator++ () override
edm::ParameterSet const *	parameterSet (edm::ParameterSetID const &psID) const override
edm::ProcessHistory const &	processHistory () const override
void	setGetter (std::shared_ptr< edm::EDProductGetter const > getter)
Long64_t	size () const
bool	to (const edm::EventID &id)
	Go to event with event id "id". More...
bool	to (edm::RunNumber_t run, edm::EventNumber_t event)
bool	to (edm::RunNumber_t run, edm::LuminosityBlockNumber_t lumi, edm::EventNumber_t event)
bool	to (Long64_t iIndex)
	Go to the event at index iIndex. More...
ChainEvent const &	toBegin () override
edm::TriggerNames const &	triggerNames (edm::TriggerResults const &triggerResults) const override
edm::TriggerResultsByName	triggerResultsByName (edm::TriggerResults const &triggerResults) const override
	~ChainEvent () override
Public Member Functions inherited from fwlite::EventBase
	EventBase ()
virtual Long64_t	secondaryFileIndex () const
	~EventBase () override
Public Member Functions inherited from edm::EventBase
int	bunchCrossing () const
	EventBase ()
edm::EventAuxiliary::ExperimentType	experimentType () const
template<typename T >
bool	get (ProductID const &, Handle< T > &) const
template<>
bool	getByLabel (edm::InputTag const &tag, Handle< FWGenericObject > &result) const
	Specialize the getByLabel method to work with a Handle<FWGenericObject> More...
template<typename T >
bool	getByLabel (InputTag const &, Handle< T > &) const
edm::EventID	id () const
bool	isRealData () const
edm::LuminosityBlockNumber_t	luminosityBlock () const
int	orbitNumber () const
edm::Timestamp	time () const

Static Public Member Functions
static void	throwProductNotFoundException (std::type_info const &, char const *, char const *, char const *)

Private Member Functions
	ChainEvent (Event const &)
void	findSizes ()
ChainEvent const &	operator= (Event const &)
void	switchToFile (Long64_t)

Private Attributes
std::vector< Long64_t >	accumulatedSize_
edm::propagate_const< std::shared_ptr< Event > >	event_
Long64_t	eventIndex_
edm::propagate_const< std::shared_ptr< TFile > >	file_
std::vector< std::string >	fileNames_
edm::propagate_const< std::shared_ptr< edm::EDProductGetter > >	getter_

Friends
class	MultiChainEvent

Additional Inherited Members
Static Protected Member Functions inherited from edm::EventBase
static edm::ParameterSet const *	parameterSetForID_ (edm::ParameterSetID const &psID)
static TriggerNames const *	triggerNames_ (edm::TriggerResults const &triggerResults)

Detailed Description

Definition at line 46 of file ChainEvent.h.

Constructor & Destructor Documentation

ChainEvent() [1/2]

ChainEvent::ChainEvent

(

std::vector< std::string > const &

iFileNames

)

Definition at line 35 of file ChainEvent.cc.

      : fileNames_(), file_(), event_(), eventIndex_(0), accumulatedSize_() {
    Long64_t summedSize = 0;
    accumulatedSize_.reserve(iFileNames.size() + 1);
    fileNames_.reserve(iFileNames.size());
 
    for (auto const& fileName : iFileNames) {
      TFile* tfilePtr = TFile::Open(fileName.c_str());
      file_ = std::shared_ptr<TFile>(tfilePtr);
      gROOT->GetListOfFiles()->Remove(tfilePtr);
      TTree* tree = dynamic_cast<TTree*>(file_->Get(edm::poolNames::eventTreeName().c_str()));
      if (nullptr == tree) {
        throw cms::Exception("NotEdmFile")
            << "The file " << fileName << " has no 'Events' TTree and therefore is not an EDM ROOT file";
      }
      Long64_t nEvents = tree->GetEntries();
      if (nEvents > 0) {  // skip empty files
        fileNames_.push_back(fileName);
        // accumulatedSize_ is the entry # at the beginning of this file
        accumulatedSize_.push_back(summedSize);
        summedSize += nEvents;
      }
    }
    // total accumulated size (last enry + 1) at the end of last file
    accumulatedSize_.push_back(summedSize);
 
    if (!fileNames_.empty())
      switchToFile(0);
  }

References accumulatedSize_, edm::poolNames::eventTreeName(), Exception, file_, MillePedeFileConverter_cfg::fileName, fileNames_, nEvents, and switchToFile().

~ChainEvent()

ChainEvent::~ChainEvent ( )

override

Definition at line 70 of file ChainEvent.cc.

{}

ChainEvent() [2/2]

fwlite::ChainEvent::ChainEvent ( Event const &  )

private

Member Function Documentation

atEnd()

bool ChainEvent::atEnd ( ) const

overridevirtual

Implements fwlite::EventBase.

Definition at line 234 of file ChainEvent.cc.

                               {
    if (!size())
      return true;
    if (eventIndex_ == static_cast<Long64_t>(fileNames_.size()) - 1) {
      return event_->atEnd();
    }
    return false;
  }

References event_, eventIndex_, fileNames_, and size().

event()

Event const* fwlite::ChainEvent::event ( ) const

inline

Definition at line 98 of file ChainEvent.h.

{ return &*event_; }

References event_.

Referenced by Types.EventID::cppID(), and to().

eventAuxiliary()

edm::EventAuxiliary const & ChainEvent::eventAuxiliary ( ) const

overridevirtual

Implements edm::EventBase.

Definition at line 203 of file ChainEvent.cc.

{ return event_->eventAuxiliary(); }

References event_.

eventIndex()

Long64_t fwlite::ChainEvent::eventIndex ( ) const

inline

Definition at line 93 of file ChainEvent.h.

{ return eventIndex_; }

References eventIndex_.

fileIndex()

Long64_t fwlite::ChainEvent::fileIndex ( ) const

inlineoverridevirtual

Reimplemented from fwlite::EventBase.

Definition at line 94 of file ChainEvent.h.

{ return eventIndex_; }

References eventIndex_.

Referenced by python.Events::fileIndicies().

fillParameterSetRegistry()

void ChainEvent::fillParameterSetRegistry

(

)

const

Definition at line 253 of file ChainEvent.cc.

{ event_->fillParameterSetRegistry(); }

References event_.

findSizes()

void fwlite::ChainEvent::findSizes ( )

private

getBranchDescriptions()

std::vector< edm::BranchDescription > const & ChainEvent::getBranchDescriptions

(

)

const

Definition at line 195 of file ChainEvent.cc.

                                                                                 {
    return event_->getBranchDescriptions();
  }

References event_.

getBranchNameFor()

const std::string ChainEvent::getBranchNameFor ( std::type_info const &  iType, char const *  iModule, char const *  iInstance, char const *  iProcess  ) const

overridevirtual

Implements fwlite::EventBase.

Definition at line 188 of file ChainEvent.cc.

                                                                             {
    return event_->getBranchNameFor(iType, iModule, iInstance, iProcess);
  }

References event_.

getByLabel()

bool ChainEvent::getByLabel ( std::type_info const &  iType, char const *  iModule, char const *  iInstance, char const *  iProcess, void *  iValue  ) const

overridevirtual

Implements fwlite::EventBase.

Definition at line 209 of file ChainEvent.cc.

                                                  {
    return event_->getByLabel(iType, iModule, iInstance, iProcess, iValue);
  }

References event_.

getByProductID()

edm::WrapperBase const * ChainEvent::getByProductID ( edm::ProductID const &  iID ) const

overridevirtual

Implements fwlite::EventBase.

Definition at line 217 of file ChainEvent.cc.

                                                                                {
    return event_->getByProductID(iID);
  }

References event_.

getLuminosityBlock()

fwlite::LuminosityBlock const & ChainEvent::getLuminosityBlock

(

)

Definition at line 205 of file ChainEvent.cc.

{ return event_->getLuminosityBlock(); }

References event_.

getProcessHistory()

std::vector< std::string > const & ChainEvent::getProcessHistory

(

)

const

Definition at line 199 of file ChainEvent.cc.

{ return event_->getProcessHistory(); }

References event_.

getRun()

fwlite::Run const & ChainEvent::getRun

(

)

Definition at line 207 of file ChainEvent.cc.

{ return event_->getRun(); }

References event_.

getTFile()

TFile* fwlite::ChainEvent::getTFile ( ) const

inline

Definition at line 85 of file ChainEvent.h.

{ return event_->getTFile(); }

References event_.

getThinnedProduct()

edm::WrapperBase const * ChainEvent::getThinnedProduct	(	edm::ProductID const &	pid,
		unsigned int &	key
	)		const

Definition at line 221 of file ChainEvent.cc.

                                                                                                      {
    return event_->getThinnedProduct(pid, key);
  }

References event_, and crabWrapper::key.

getThinnedProducts()

void ChainEvent::getThinnedProducts	(	edm::ProductID const &	pid,
		std::vector< edm::WrapperBase const * > &	foundContainers,
		std::vector< unsigned int > &	keys
	)		const

Definition at line 225 of file ChainEvent.cc.

                                                                           {
    event_->getThinnedProducts(pid, foundContainers, keys);
  }

References event_, and relativeConstraints::keys.

isValid()

bool ChainEvent::isValid

(

void

)

const

Definition at line 231 of file ChainEvent.cc.

{ return event_->isValid(); }

References event_.

Referenced by ntupleDataFormat._Object::_checkIsValid(), and core.AutoHandle.AutoHandle::ReallyLoad().

operator bool()

ChainEvent::operator bool

(

)

const

Definition at line 232 of file ChainEvent.cc.

{ return *event_; }

References event_().

operator++()

ChainEvent const & ChainEvent::operator++ ( )

overridevirtual

Implements fwlite::EventBase.

Definition at line 88 of file ChainEvent.cc.

                                           {
    if (eventIndex_ != static_cast<Long64_t>(fileNames_.size()) - 1) {
      ++(*event_);
      if (event_->atEnd()) {
        switchToFile(++eventIndex_);
      }
    } else {
      if (*event_) {
        ++(*event_);
      }
    }
    return *this;
  }

References event_, eventIndex_, fileNames_, and switchToFile().

operator=()

ChainEvent const& fwlite::ChainEvent::operator= ( Event const &  )

private

parameterSet()

edm::ParameterSet const * ChainEvent::parameterSet ( edm::ParameterSetID const &  psID ) const

overridevirtual

Implements edm::EventBase.

Definition at line 249 of file ChainEvent.cc.

                                                                                     {
    return event_->parameterSet(psID);
  }

References event_.

processHistory()

edm::ProcessHistory const & ChainEvent::processHistory ( ) const

overridevirtual

Implements edm::EventBase.

Definition at line 201 of file ChainEvent.cc.

{ return event_->processHistory(); }

References event_.

setGetter()

void fwlite::ChainEvent::setGetter ( std::shared_ptr< edm::EDProductGetter const >  getter )

inline

Definition at line 96 of file ChainEvent.h.

{ event_->setGetter(getter); }

References event_.

size()

Long64_t ChainEvent::size

(

void

)

const

Definition at line 243 of file ChainEvent.cc.

{ return accumulatedSize_.empty() ? 0 : accumulatedSize_.back(); }

References accumulatedSize_.

Referenced by ntupleDataFormat._Collection::__iter__(), ntupleDataFormat._Collection::__len__(), atEnd(), and toBegin().

switchToFile()

void ChainEvent::switchToFile ( Long64_t  iIndex )

private

Definition at line 177 of file ChainEvent.cc.

                                               {
    eventIndex_ = iIndex;
    TFile* tfilePtr = TFile::Open(fileNames_[iIndex].c_str());
    file_ = std::shared_ptr<TFile>(tfilePtr);
    gROOT->GetListOfFiles()->Remove(tfilePtr);
    event_ = std::make_shared<Event>(file_.get());
  }

References event_, eventIndex_, file_, fileNames_, and edm::propagate_const< T >::get().

Referenced by ChainEvent(), operator++(), to(), and toBegin().

throwProductNotFoundException()

void ChainEvent::throwProductNotFoundException ( std::type_info const &  iType, char const *  iModule, char const *  iInstance, char const *  iProcess  )

static

Definition at line 262 of file ChainEvent.cc.

                                                                       {
    Event::throwProductNotFoundException(iType, iModule, iInstance, iProcess);
  }

References fwlite::Event::throwProductNotFoundException().

Referenced by fwlite::MultiChainEvent::throwProductNotFoundException().

to() [1/4]

bool ChainEvent::to

(

const edm::EventID &

id

)

Go to event with event id "id".

Definition at line 130 of file ChainEvent.cc.

{ return to(id.run(), id.luminosityBlock(), id.event()); }

References event(), edm::EventBase::luminosityBlock(), writedatasetfile::run, and to().

to() [2/4]

bool ChainEvent::to	(	edm::RunNumber_t	run,
		edm::EventNumber_t	event
	)

Definition at line 163 of file ChainEvent.cc.

{ return to(run, 0U, event); }

References writedatasetfile::run, to(), and mitigatedMETSequence_cff::U.

to() [3/4]

bool ChainEvent::to	(	edm::RunNumber_t	run,
		edm::LuminosityBlockNumber_t	lumi,
		edm::EventNumber_t	event
	)

If lumi is non-zero, go to event with given run, lumi, and event number If lumi is zero, go to event with given run and event number

Definition at line 134 of file ChainEvent.cc.

                                                                                                 {
    // First try this file
    if (event_->to(run, lumi, event)) {
      // found it, return
      return true;
    } else {
      // Did not find it, try the other files sequentially.
      // Someday I can make this smarter. For now... we get something working.
      Long64_t thisFile = eventIndex_;
      std::vector<std::string>::const_iterator filesBegin = fileNames_.begin(), filesEnd = fileNames_.end(),
                                               ifile = filesBegin;
      for (; ifile != filesEnd; ++ifile) {
        // skip the "first" file that we tried
        if (ifile - filesBegin != thisFile) {
          // switch to the next file
          switchToFile(ifile - filesBegin);
          // check that tree for the desired event
          if (event_->to(run, lumi, event)) {
            // found it, return
            return true;
          }
        }  // end ignore "first" file that we tried
      }    // end loop over files
 
      // did not find the event with id "id".
      return false;
    }  // end if we did not find event id in "first" file
  }

References event_, eventIndex_, fileNames_, compare_using_db::ifile, writedatasetfile::run, and switchToFile().

to() [4/4]

bool ChainEvent::to

(

Long64_t

iIndex

)

Go to the event at index iIndex.

Definition at line 103 of file ChainEvent.cc.

                                     {
    if (iIndex >= accumulatedSize_.back()) {
      // if we're here, then iIndex was not valid
      return false;
    }
 
    Long64_t offsetIndex = eventIndex_;
 
    // we're going backwards, so start from the beginning
    if (iIndex < accumulatedSize_[offsetIndex]) {
      offsetIndex = 0;
    }
 
    // is it past the end of this file?
    while (iIndex >= accumulatedSize_[offsetIndex + 1]) {
      ++offsetIndex;
    }
 
    if (offsetIndex != eventIndex_) {
      switchToFile(eventIndex_ = offsetIndex);
    }
 
    // adjust to entry # in this file
    return event_->to(iIndex - accumulatedSize_[offsetIndex]);
  }

References accumulatedSize_, event_, eventIndex_, and switchToFile().

Referenced by to().

toBegin()

ChainEvent const & ChainEvent::toBegin ( )

overridevirtual

Go to the very first Event

Implements fwlite::EventBase.

Definition at line 167 of file ChainEvent.cc.

                                        {
    if (!size())
      return *this;
    if (eventIndex_ != 0) {
      switchToFile(0);
    }
    event_->toBegin();
    return *this;
  }

References event_, eventIndex_, size(), and switchToFile().

triggerNames()

edm::TriggerNames const & ChainEvent::triggerNames ( edm::TriggerResults const &  triggerResults ) const

overridevirtual

Implements edm::EventBase.

Definition at line 245 of file ChainEvent.cc.

                                                                                               {
    return event_->triggerNames(triggerResults);
  }

References event_, and triggerResults.

triggerResultsByName()

edm::TriggerResultsByName ChainEvent::triggerResultsByName ( edm::TriggerResults const &  triggerResults ) const

overridevirtual

Implements edm::EventBase.

Definition at line 255 of file ChainEvent.cc.

                                                                                                        {
    return event_->triggerResultsByName(triggerResults);
  }

References event_, and triggerResults.

Friends And Related Function Documentation

MultiChainEvent

friend class MultiChainEvent

friend

Definition at line 122 of file ChainEvent.h.

Member Data Documentation

accumulatedSize_

std::vector<Long64_t> fwlite::ChainEvent::accumulatedSize_

private

Definition at line 135 of file ChainEvent.h.

Referenced by ChainEvent(), size(), and to().

event_

edm::propagate_const<std::shared_ptr<Event> > fwlite::ChainEvent::event_

private

Definition at line 133 of file ChainEvent.h.

Referenced by atEnd(), event(), eventAuxiliary(), fillParameterSetRegistry(), getBranchDescriptions(), getBranchNameFor(), getByLabel(), getByProductID(), getLuminosityBlock(), getProcessHistory(), getRun(), getTFile(), getThinnedProduct(), getThinnedProducts(), isValid(), operator++(), parameterSet(), processHistory(), setGetter(), switchToFile(), to(), toBegin(), triggerNames(), and triggerResultsByName().

eventIndex_

Long64_t fwlite::ChainEvent::eventIndex_

private

Definition at line 134 of file ChainEvent.h.

Referenced by atEnd(), eventIndex(), fileIndex(), operator++(), switchToFile(), to(), and toBegin().

file_

edm::propagate_const<std::shared_ptr<TFile> > fwlite::ChainEvent::file_

private

Definition at line 132 of file ChainEvent.h.

Referenced by ChainEvent(), and switchToFile().

fileNames_

std::vector<std::string> fwlite::ChainEvent::fileNames_

private

Definition at line 131 of file ChainEvent.h.

Referenced by atEnd(), ChainEvent(), operator++(), switchToFile(), and to().

getter_

edm::propagate_const<std::shared_ptr<edm::EDProductGetter> > fwlite::ChainEvent::getter_

private

Definition at line 136 of file ChainEvent.h.