#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

std::string const	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 (Long64_t iIndex)
	Go to the event at index iIndex. More...

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)

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<typename T >
bool	getByLabel (InputTag 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...

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::ChainEvent ( std::vector< std::string > const & iFileNames )

Definition at line 35 of file ChainEvent.cc.

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

                                                             :
   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);
 }

ChainEvent::~ChainEvent ( )

override

Definition at line 74 of file ChainEvent.cc.

75 {

76 }

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

private

Member Function Documentation

bool ChainEvent::atEnd ( ) const

overridevirtual

Implements fwlite::EventBase.

Definition at line 301 of file ChainEvent.cc.

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

Referenced by fwlite::AnalyzerWrapper< T >::analyze(), and main().

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

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

inline

Definition at line 108 of file ChainEvent.h.

References event_(), edm::getThinnedProduct(), crabWrapper::key, relativeConstraints::keys, edm::parameterSet(), sysUtil::pid, edm::throwProductNotFoundException(), and edm::triggerResults().

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

108 { return &*event_; }

fwlite::ChainEvent::event_

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

Definition: ChainEvent.h:144

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

overridevirtual

Implements edm::EventBase.

Definition at line 250 of file ChainEvent.cc.

References event_.

 {
    return event_->eventAuxiliary();
 }

Long64_t fwlite::ChainEvent::eventIndex ( ) const

inline

Definition at line 101 of file ChainEvent.h.

101 { return eventIndex_; }

fwlite::ChainEvent::eventIndex_

Long64_t eventIndex_

Definition: ChainEvent.h:145

Long64_t fwlite::ChainEvent::fileIndex ( ) const

inlineoverridevirtual

Reimplemented from fwlite::EventBase.

Definition at line 102 of file ChainEvent.h.

Referenced by python.Events::fileIndicies().

102 { return eventIndex_; }

fwlite::ChainEvent::eventIndex_

Long64_t eventIndex_

Definition: ChainEvent.h:145

void ChainEvent::fillParameterSetRegistry ( ) const

Definition at line 328 of file ChainEvent.cc.

References event_.

 {
   event_->fillParameterSetRegistry();
 }

void fwlite::ChainEvent::findSizes ( )

private

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

Definition at line 232 of file ChainEvent.cc.

References event_.

 {
   return event_->getBranchDescriptions();
 }

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

overridevirtual

Implements fwlite::EventBase.

Definition at line 223 of file ChainEvent.cc.

References event_.

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

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 266 of file ChainEvent.cc.

References event_.

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

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

overridevirtual

Implements fwlite::EventBase.

Definition at line 275 of file ChainEvent.cc.

References event_.

 {
   return event_->getByProductID(iID);
 }

fwlite::LuminosityBlock const & ChainEvent::getLuminosityBlock ( )

Definition at line 255 of file ChainEvent.cc.

References event_.

 {
    return event_->getLuminosityBlock();
 }

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

Definition at line 238 of file ChainEvent.cc.

References event_.

 {
   return event_->getProcessHistory();
 }

fwlite::Run const & ChainEvent::getRun ( )

Definition at line 260 of file ChainEvent.cc.

References event_.

 {
    return event_->getRun();
 }

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

inline

Definition at line 91 of file ChainEvent.h.

References event_().

                               {
         return event_->getTFile();
       }

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

Definition at line 280 of file ChainEvent.cc.

References event_.

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

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

Definition at line 284 of file ChainEvent.cc.

References event_.

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

bool ChainEvent::isValid ( void ) const

Definition at line 291 of file ChainEvent.cc.

References event_.

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

 {
   return event_->isValid();
 }

ChainEvent::operator bool ( ) const

Definition at line 295 of file ChainEvent.cc.

References event_.

 {
   return *event_;
 }

ChainEvent const & ChainEvent::operator++ ( )

overridevirtual

Implements fwlite::EventBase.

Definition at line 95 of file ChainEvent.cc.

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

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

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

private

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

overridevirtual

Implements edm::EventBase.

Definition at line 323 of file ChainEvent.cc.

References event_.

                                                             {
   return event_->parameterSet(psID);
 }

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

overridevirtual

Implements edm::EventBase.

Definition at line 244 of file ChainEvent.cc.

References event_.

 {
   return event_->processHistory();
 }

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

inline

Definition at line 104 of file ChainEvent.h.

References event_().

                                                                     {
          event_->setGetter(getter);
       }

Long64_t ChainEvent::size ( void ) const

Definition at line 311 of file ChainEvent.cc.

References accumulatedSize_.

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

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

void ChainEvent::switchToFile ( Long64_t iIndex )

private

Definition at line 210 of file ChainEvent.cc.

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

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

 {
   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());
 }

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

static

Definition at line 342 of file ChainEvent.cc.

References fwlite::Event::throwProductNotFoundException().

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

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

bool ChainEvent::to ( Long64_t iIndex )

Go to the event at index iIndex.

Definition at line 113 of file ChainEvent.cc.

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

Referenced by to().

 {
    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]);
 }

bool ChainEvent::to ( const edm::EventID & id )

Go to event with event id "id".

Definition at line 144 of file ChainEvent.cc.

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

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

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

Definition at line 190 of file ChainEvent.cc.

References to(), and mitigatedMETSequence_cff::U.

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

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 152 of file ChainEvent.cc.

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

 {
 
    // 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
 }

ChainEvent const & ChainEvent::toBegin ( )

overridevirtual

Go to the very first Event

Implements fwlite::EventBase.

Definition at line 198 of file ChainEvent.cc.

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

Referenced by fwlite::AnalyzerWrapper< T >::analyze(), and main().

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

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

overridevirtual

Implements edm::EventBase.

Definition at line 317 of file ChainEvent.cc.

References event_.

 {
   return event_->triggerNames(triggerResults);
 }

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

overridevirtual

Implements edm::EventBase.

Definition at line 334 of file ChainEvent.cc.

References event_.

                                                                               {
   return event_->triggerResultsByName(triggerResults);
 }

Friends And Related Function Documentation

friend class MultiChainEvent

friend

Definition at line 133 of file ChainEvent.h.

Member Data Documentation

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

private

Definition at line 146 of file ChainEvent.h.

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

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

private

Definition at line 144 of file ChainEvent.h.

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

Long64_t fwlite::ChainEvent::eventIndex_

private

Definition at line 145 of file ChainEvent.h.

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

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

private

Definition at line 143 of file ChainEvent.h.

Referenced by ChainEvent(), and switchToFile().

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

private

Definition at line 142 of file ChainEvent.h.

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

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

private

Definition at line 147 of file ChainEvent.h.

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation