#include <RootPrimaryFileSequence.h>

Inheritance diagram for edm::RootPrimaryFileSequence:

Public Member Functions
void	closeFile_ () override

void	endJob ()

ProcessingController::ForwardState	forwardState () const

InputSource::ItemType	getNextItemType (RunNumber_t &run, LuminosityBlockNumber_t &lumi, EventNumber_t &event)

bool	goToEvent (EventID const &eventID)

RootPrimaryFileSequence &	operator= (RootPrimaryFileSequence const &)=delete

std::shared_ptr< FileBlock >	readFile_ ()

ProcessingController::ReverseState	reverseState () const

void	rewind_ ()

	RootPrimaryFileSequence (ParameterSet const &pset, PoolSource &input, InputFileCatalog const &catalog)

	RootPrimaryFileSequence (RootPrimaryFileSequence const &)=delete

void	skipEvents (int offset)

void	skipEventsAtBeginning (int offset)

	~RootPrimaryFileSequence () override

Public Member Functions inherited from edm::RootInputFileSequence
bool	containedInCurrentFile (RunNumber_t run, LuminosityBlockNumber_t lumi, EventNumber_t event) const

std::shared_ptr< BranchIDListHelper const >	fileBranchIDListHelper () const

std::shared_ptr< ProductRegistry const >	fileProductRegistry () const

void	fillProcessBlockHelper_ ()

bool	nextProcessBlock_ (ProcessBlockPrincipal &)

RootInputFileSequence &	operator= (RootInputFileSequence const &)=delete

bool	readEvent (EventPrincipal &cache)

void	readLuminosityBlock_ (LuminosityBlockPrincipal &lumiPrincipal)

std::shared_ptr< LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()

void	readProcessBlock_ (ProcessBlockPrincipal &)

void	readRun_ (RunPrincipal &runPrincipal)

std::shared_ptr< RunAuxiliary >	readRunAuxiliary_ ()

	RootInputFileSequence (ParameterSet const &pset, InputFileCatalog const &catalog)

	RootInputFileSequence (RootInputFileSequence const &)=delete

bool	skipToItem (RunNumber_t run, LuminosityBlockNumber_t lumi, EventNumber_t event, size_t fileNameHash=0U, bool currentFileFirst=true)

virtual	~RootInputFileSequence ()

Static Public Member Functions
static void	fillDescription (ParameterSetDescription &desc)

Private Member Functions
std::shared_ptr< DuplicateChecker > &	duplicateChecker ()

std::shared_ptr< DuplicateChecker const >	duplicateChecker () const

std::shared_ptr< EventSkipperByID > &	eventSkipperByID ()

std::shared_ptr< EventSkipperByID const >	eventSkipperByID () const

void	initFile_ (bool skipBadFiles) override

RootFileSharedPtr	makeRootFile (std::shared_ptr< InputFile > filePtr) override

bool	nextFile ()

bool	previousFile ()

int	remainingEvents () const

int	remainingLuminosityBlocks () const

void	rewindFile ()

Private Attributes
BranchDescription::MatchMode	branchesMustMatch_

edm::propagate_const< std::shared_ptr< DuplicateChecker > >	duplicateChecker_

bool	enablePrefetching_

bool	enforceGUIDInFileName_

edm::propagate_const< std::shared_ptr< EventSkipperByID > >	eventSkipperByID_

edm::propagate_const< std::shared_ptr< FileBlock > >	fb_

bool	firstFile_

EventID	goToEventID_

bool	goToEventInNewFile_ = false

size_t	goToFileSequenceOffset_ = 0

int	initialNumberOfEventsToSkip_

PoolSource &	input_

bool	noEventSort_

std::vector< ProcessHistoryID >	orderedProcessHistoryIDs_

bool	skipIntoNewFile_ = false

size_t	skipToFileSequenceNumber_ = 0

int	skipToOffsetInFinalFile_ = 0

bool	skipToStop_ = false

unsigned int	treeCacheSize_

bool	usingGoToEvent_

Additional Inherited Members
Protected Types inherited from edm::RootInputFileSequence
typedef std::shared_ptr< RootFile >	RootFileSharedPtr

Protected Member Functions inherited from edm::RootInputFileSequence
bool	atFirstFile () const

bool	atLastFile () const

std::vector< FileCatalogItem > const &	fileCatalogItems () const

std::vector< std::string > const &	fileNames () const

std::vector< std::shared_ptr< IndexIntoFile > > const &	indexesIntoFiles () const

void	initFile (bool skipBadFiles)

void	initTheFile (bool skipBadFiles, bool deleteIndexIntoFile, InputSource input, char const inputTypeName, InputType inputType)

std::string const &	lfn () const

size_t	lfnHash () const

std::string const &	logicalFileName () const

bool	noFiles () const

bool	noMoreFiles () const

size_t	numberOfFiles () const

std::shared_ptr< RootFile > &	rootFile ()

std::shared_ptr< RootFile const >	rootFile () const

size_t	sequenceNumberOfFile () const

void	setAtFileSequenceNumber (size_t offset)

void	setAtFirstFile ()

void	setAtNextFile ()

void	setAtPreviousFile ()

void	setIndexIntoFile (size_t index)

void	setNoMoreFiles ()

bool	skipToItemInNewFile (RunNumber_t run, LuminosityBlockNumber_t lumi, EventNumber_t event)

bool	skipToItemInNewFile (RunNumber_t run, LuminosityBlockNumber_t lumi, EventNumber_t event, size_t fileNameHash)

bool	usedFallback () const

Detailed Description

Definition at line 34 of file RootPrimaryFileSequence.h.

Constructor & Destructor Documentation

◆ RootPrimaryFileSequence() [1/2]

edm::RootPrimaryFileSequence::RootPrimaryFileSequence	(	ParameterSet const &	pset,
		PoolSource &	input,
		InputFileCatalog const &	catalog
	)

explicit

Definition at line 22 of file RootPrimaryFileSequence.cc.

       : RootInputFileSequence(pset, catalog),
         input_(input),
         firstFile_(true),
         branchesMustMatch_(BranchDescription::Permissive),
         orderedProcessHistoryIDs_(),
         eventSkipperByID_(EventSkipperByID::create(pset).release()),
         initialNumberOfEventsToSkip_(pset.getUntrackedParameter<unsigned int>("skipEvents")),
         noEventSort_(pset.getUntrackedParameter<bool>("noEventSort")),
         treeCacheSize_(noEventSort_ ? pset.getUntrackedParameter<unsigned int>("cacheSize") : 0U),
         duplicateChecker_(new DuplicateChecker(pset)),
         usingGoToEvent_(false),
         enablePrefetching_(false),
         enforceGUIDInFileName_(pset.getUntrackedParameter<bool>("enforceGUIDInFileName")) {
     // The SiteLocalConfig controls the TTreeCache size and the prefetching settings.
     Service<SiteLocalConfig> pSLC;
     if (pSLC.isAvailable()) {
       if (treeCacheSize_ != 0U && pSLC->sourceTTreeCacheSize()) {
         treeCacheSize_ = *(pSLC->sourceTTreeCacheSize());
       }
       enablePrefetching_ = pSLC->enablePrefetching();
     }
  
     std::string branchesMustMatch =
         pset.getUntrackedParameter<std::string>("branchesMustMatch", std::string("permissive"));
     if (branchesMustMatch == std::string("strict"))
       branchesMustMatch_ = BranchDescription::Strict;
  
     // Prestage the files
     for (setAtFirstFile(); !noMoreFiles(); setAtNextFile()) {
       StorageFactory::get()->stagein(fileNames()[0]);
     }
     // Open the first file.
     for (setAtFirstFile(); !noMoreFiles(); setAtNextFile()) {
       initFile(input_.skipBadFiles());
       if (rootFile())
         break;
     }
     if (rootFile()) {
       input_.productRegistryUpdate().updateFromInput(rootFile()->productRegistry()->productList());
       if (initialNumberOfEventsToSkip_ != 0) {
         skipEventsAtBeginning(initialNumberOfEventsToSkip_);
       }
     }
   }

References branchesMustMatch_, enablePrefetching_, edm::RootInputFileSequence::fileNames(), StorageFactory::get(), edm::RootInputFileSequence::initFile(), initialNumberOfEventsToSkip_, input_, edm::Service< T >::isAvailable(), edm::RootInputFileSequence::noMoreFiles(), edm::PoolSource::productRegistryUpdate(), muonDTDigis_cfi::pset, edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtFirstFile(), edm::RootInputFileSequence::setAtNextFile(), edm::PoolSource::skipBadFiles(), skipEventsAtBeginning(), StorageFactory::stagein(), edm::BranchDescription::Strict, AlCaHLTBitMon_QueryRunRegistry::string, treeCacheSize_, mitigatedMETSequence_cff::U, and edm::ProductRegistry::updateFromInput().

◆ ~RootPrimaryFileSequence()

edm::RootPrimaryFileSequence::~RootPrimaryFileSequence ( )

override

Definition at line 70 of file RootPrimaryFileSequence.cc.

70 {}

◆ RootPrimaryFileSequence() [2/2]

edm::RootPrimaryFileSequence::RootPrimaryFileSequence ( RootPrimaryFileSequence const & )

delete

Member Function Documentation

◆ closeFile_()

void edm::RootPrimaryFileSequence::closeFile_ ( )

overridevirtual

Implements edm::RootInputFileSequence.

Definition at line 117 of file RootPrimaryFileSequence.cc.

                                            {
     // close the currently open file, if any, and delete the RootFile object.
     if (rootFile()) {
       auto sentry = std::make_unique<InputSource::FileCloseSentry>(input_, lfn(), usedFallback());
       rootFile()->close();
       if (duplicateChecker_)
         duplicateChecker_->inputFileClosed();
       rootFile().reset();
     }
   }

References duplicateChecker_, input_, edm::RootInputFileSequence::lfn(), edm::RootInputFileSequence::rootFile(), and edm::RootInputFileSequence::usedFallback().

Referenced by endJob(), and rewind_().

◆ duplicateChecker() [1/2]

std::shared_ptr<DuplicateChecker>& edm::RootPrimaryFileSequence::duplicateChecker ( )

inlineprivate

Definition at line 72 of file RootPrimaryFileSequence.h.

72 { return get_underlying_safe(duplicateChecker_); }

References duplicateChecker_, and edm::get_underlying_safe().

◆ duplicateChecker() [2/2]

std::shared_ptr<DuplicateChecker const> edm::RootPrimaryFileSequence::duplicateChecker ( ) const

inlineprivate

Definition at line 71 of file RootPrimaryFileSequence.h.

71 { return get_underlying_safe(duplicateChecker_); }

References duplicateChecker_, and edm::get_underlying_safe().

Referenced by makeRootFile().

◆ endJob()

void edm::RootPrimaryFileSequence::endJob ( void )

Definition at line 72 of file RootPrimaryFileSequence.cc.

72 { closeFile_(); }

References closeFile_().

◆ eventSkipperByID() [1/2]

std::shared_ptr<EventSkipperByID>& edm::RootPrimaryFileSequence::eventSkipperByID ( )

inlineprivate

Definition at line 70 of file RootPrimaryFileSequence.h.

70 { return get_underlying_safe(eventSkipperByID_); }

References eventSkipperByID_, and edm::get_underlying_safe().

◆ eventSkipperByID() [2/2]

std::shared_ptr<EventSkipperByID const> edm::RootPrimaryFileSequence::eventSkipperByID ( ) const

inlineprivate

Definition at line 69 of file RootPrimaryFileSequence.h.

69 { return get_underlying_safe(eventSkipperByID_); }

References eventSkipperByID_, and edm::get_underlying_safe().

Referenced by makeRootFile().

◆ fillDescription()

void edm::RootPrimaryFileSequence::fillDescription ( ParameterSetDescription & desc )

static

Definition at line 403 of file RootPrimaryFileSequence.cc.

                                                                              {
     desc.addUntracked<unsigned int>("skipEvents", 0U)
         ->setComment("Skip the first 'skipEvents' events that otherwise would have been processed.");
     desc.addUntracked<bool>("noEventSort", true)
         ->setComment(
             "True:  Process runs, lumis and events in the order they appear in the file (but see notes 1 and 2).\n"
             "False: Process runs, lumis and events in each file in numerical order (run#, lumi#, event#) (but see note "
             "3).\n"
             "Note 1: Events within the same lumi will always be processed contiguously.\n"
             "Note 2: Lumis within the same run will always be processed contiguously.\n"
             "Note 3: Any sorting occurs independently in each input file (no sorting across input files).");
     desc.addUntracked<unsigned int>("cacheSize", roottree::defaultCacheSize)
         ->setComment("Size of ROOT TTree prefetch cache.  Affects performance.");
     std::string defaultString("permissive");
     desc.addUntracked<std::string>("branchesMustMatch", defaultString)
         ->setComment(
             "'strict':     Branches in each input file must match those in the first file.\n"
             "'permissive': Branches in each input file may be any subset of those in the first file.");
     desc.addUntracked<bool>("enforceGUIDInFileName", false)
         ->setComment(
             "True:  file name part is required to be equal to the GUID of the file\n"
             "False: file name can be anything");
  
     EventSkipperByID::fillDescription(desc);
     DuplicateChecker::fillDescription(desc);
   }

References edm::roottree::defaultCacheSize, submitPVResolutionJobs::desc, edm::EventSkipperByID::fillDescription(), edm::DuplicateChecker::fillDescription(), AlCaHLTBitMon_QueryRunRegistry::string, and mitigatedMETSequence_cff::U.

Referenced by edm::PoolSource::fillDescriptions().

◆ forwardState()

ProcessingController::ForwardState edm::RootPrimaryFileSequence::forwardState ( ) const

Definition at line 430 of file RootPrimaryFileSequence.cc.

                                                                                {
     if (rootFile()) {
       if (!rootFile()->wasLastEventJustRead()) {
         return ProcessingController::kEventsAheadInFile;
       }
       if (noMoreFiles() || atLastFile()) {
         return ProcessingController::kAtLastEvent;
       } else {
         return ProcessingController::kNextFileExists;
       }
     }
     return ProcessingController::kUnknownForward;
   }

References edm::RootInputFileSequence::atLastFile(), edm::ProcessingController::kAtLastEvent, edm::ProcessingController::kEventsAheadInFile, edm::ProcessingController::kNextFileExists, edm::ProcessingController::kUnknownForward, edm::RootInputFileSequence::noMoreFiles(), and edm::RootInputFileSequence::rootFile().

◆ getNextItemType()

InputSource::ItemType edm::RootPrimaryFileSequence::getNextItemType	(	RunNumber_t &	run,
		LuminosityBlockNumber_t &	lumi,
		EventNumber_t &	event
	)

Definition at line 219 of file RootPrimaryFileSequence.cc.

                                                                                        {
     if (noMoreFiles() || skipToStop_) {
       skipToStop_ = false;
       return InputSource::IsStop;
     }
     if (firstFile_ || goToEventInNewFile_ || skipIntoNewFile_) {
       return InputSource::IsFile;
     }
     if (rootFile()) {
       IndexIntoFile::EntryType entryType = rootFile()->getNextItemType(run, lumi, event);
       if (entryType == IndexIntoFile::kEvent) {
         return InputSource::IsEvent;
       } else if (entryType == IndexIntoFile::kLumi) {
         return InputSource::IsLumi;
       } else if (entryType == IndexIntoFile::kRun) {
         return InputSource::IsRun;
       }
       assert(entryType == IndexIntoFile::kEnd);
     }
     if (atLastFile()) {
       return InputSource::IsStop;
     }
     return InputSource::IsFile;
   }

References cms::cuda::assert(), edm::RootInputFileSequence::atLastFile(), firstFile_, goToEventInNewFile_, edm::InputSource::IsEvent, edm::InputSource::IsFile, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, edm::IndexIntoFile::kEnd, edm::IndexIntoFile::kEvent, edm::IndexIntoFile::kLumi, edm::IndexIntoFile::kRun, edm::RootInputFileSequence::noMoreFiles(), edm::RootInputFileSequence::rootFile(), writedatasetfile::run, skipIntoNewFile_, and skipToStop_.

◆ goToEvent()

bool edm::RootPrimaryFileSequence::goToEvent ( EventID const & eventID )

Definition at line 346 of file RootPrimaryFileSequence.cc.

                                                                 {
     usingGoToEvent_ = true;
     if (rootFile()) {
       if (rootFile()->goToEvent(eventID)) {
         return true;
       }
       // If only one input file, give up now, to save time.
       if (rootFile() && indexesIntoFiles().size() == 1) {
         return false;
       }
       // Look for item (run/lumi/event) in files previously opened without reopening unnecessary files.
       for (auto it = indexesIntoFiles().begin(), itEnd = indexesIntoFiles().end(); it != itEnd; ++it) {
         if (*it && (*it)->containsItem(eventID.run(), eventID.luminosityBlock(), eventID.event())) {
           goToEventInNewFile_ = true;
           goToFileSequenceOffset_ = it - indexesIntoFiles().begin();
           goToEventID_ = eventID;
           return true;
         }
       }
  
       // Save the current file and position so that we can restore them
       bool closedOriginalFile = false;
       size_t const originalFileSequenceNumber = sequenceNumberOfFile();
       IndexIntoFile::IndexIntoFileItr originalPosition = rootFile()->indexIntoFileIter();
  
       // Look for item in files not yet opened.
       bool foundIt = false;
       for (auto it = indexesIntoFiles().begin(), itEnd = indexesIntoFiles().end(); it != itEnd; ++it) {
         if (!*it) {
           setAtFileSequenceNumber(it - indexesIntoFiles().begin());
           initFile(false);
           assert(rootFile());
           closedOriginalFile = true;
           if ((*it)->containsItem(eventID.run(), eventID.luminosityBlock(), eventID.event())) {
             foundIt = true;
             goToEventInNewFile_ = true;
             goToFileSequenceOffset_ = it - indexesIntoFiles().begin();
             goToEventID_ = eventID;
           }
         }
       }
       if (closedOriginalFile) {
         setAtFileSequenceNumber(originalFileSequenceNumber);
         initFile(false);
         assert(rootFile());
         rootFile()->setPosition(originalPosition);
         rootFile()->updateFileBlock(*fb_);
       }
       return foundIt;
     }
     return false;
   }

References cms::cuda::assert(), mps_fire::end, edm::EventID::event(), fb_, goToEventID_, goToEventInNewFile_, goToFileSequenceOffset_, edm::RootInputFileSequence::indexesIntoFiles(), edm::RootInputFileSequence::initFile(), edm::EventID::luminosityBlock(), edm::RootInputFileSequence::rootFile(), edm::EventID::run(), edm::RootInputFileSequence::sequenceNumberOfFile(), edm::RootInputFileSequence::setAtFileSequenceNumber(), findQualityFiles::size, and usingGoToEvent_.

◆ initFile_()

void edm::RootPrimaryFileSequence::initFile_ ( bool skipBadFiles )

overrideprivatevirtual

Implements edm::RootInputFileSequence.

Definition at line 128 of file RootPrimaryFileSequence.cc.

                                                            {
     // If we are not duplicate checking across files and we are not using random access to find events,
     // then we can delete the IndexIntoFile for the file we are closing.
     // If we can't delete all of it, then we can delete the parts we do not need.
     bool deleteIndexIntoFile = !usingGoToEvent_ && !(duplicateChecker_ && duplicateChecker_->checkingAllFiles() &&
                                                      !duplicateChecker_->checkDisabled());
     initTheFile(skipBadFiles, deleteIndexIntoFile, &input_, "primaryFiles", InputType::Primary);
   }

References duplicateChecker_, edm::RootInputFileSequence::initTheFile(), input_, edm::Primary, remoteMonitoring_LED_IterMethod_cfg::skipBadFiles, and usingGoToEvent_.

◆ makeRootFile()

RootPrimaryFileSequence::RootFileSharedPtr edm::RootPrimaryFileSequence::makeRootFile ( std::shared_ptr< InputFile > filePtr )

overrideprivatevirtual

Implements edm::RootInputFileSequence.

Definition at line 137 of file RootPrimaryFileSequence.cc.

                                                                                                                  {
     size_t currentIndexIntoFile = sequenceNumberOfFile();
     return std::make_shared<RootFile>(fileNames()[0],
                                       input_.processConfiguration(),
                                       logicalFileName(),
                                       filePtr,
                                       eventSkipperByID(),
                                       initialNumberOfEventsToSkip_ != 0,
                                       remainingEvents(),
                                       remainingLuminosityBlocks(),
                                       input_.nStreams(),
                                       treeCacheSize_,
                                       input_.treeMaxVirtualSize(),
                                       input_.processingMode(),
                                       input_.runHelper(),
                                       noEventSort_,
                                       input_.productSelectorRules(),
                                       InputType::Primary,
                                       input_.branchIDListHelper(),
                                       input_.processBlockHelper().get(),
                                       input_.thinnedAssociationsHelper(),
                                       nullptr,  // associationsFromSecondary
                                       duplicateChecker(),
                                       input_.dropDescendants(),
                                       input_.processHistoryRegistryForUpdate(),
                                       indexesIntoFiles(),
                                       currentIndexIntoFile,
                                       orderedProcessHistoryIDs_,
                                       input_.bypassVersionCheck(),
                                       input_.labelRawDataLikeMC(),
                                       usingGoToEvent_,
                                       enablePrefetching_,
                                       enforceGUIDInFileName_);
   }

References edm::InputSource::branchIDListHelper(), edm::PoolSource::bypassVersionCheck(), edm::PoolSource::dropDescendants(), duplicateChecker(), enablePrefetching_, enforceGUIDInFileName_, eventSkipperByID(), edm::RootInputFileSequence::fileNames(), edm::RootInputFileSequence::indexesIntoFiles(), initialNumberOfEventsToSkip_, input_, edm::PoolSource::labelRawDataLikeMC(), edm::RootInputFileSequence::logicalFileName(), noEventSort_, edm::PoolSource::nStreams(), orderedProcessHistoryIDs_, edm::Primary, edm::InputSource::processBlockHelper(), edm::InputSource::processConfiguration(), edm::PoolSource::processHistoryRegistryForUpdate(), edm::InputSource::processingMode(), edm::PoolSource::productSelectorRules(), remainingEvents(), remainingLuminosityBlocks(), edm::PoolSource::runHelper(), edm::RootInputFileSequence::sequenceNumberOfFile(), edm::InputSource::thinnedAssociationsHelper(), treeCacheSize_, edm::PoolSource::treeMaxVirtualSize(), and usingGoToEvent_.

◆ nextFile()

bool edm::RootPrimaryFileSequence::nextFile ( )

private

Definition at line 172 of file RootPrimaryFileSequence.cc.

                                          {
     do {
       if (!noMoreFiles())
         setAtNextFile();
       if (noMoreFiles()) {
         return false;
       }
  
       initFile(input_.skipBadFiles());
       if (rootFile()) {
         break;
       }
       // If we are not skipping bad files and the file
       // open failed, then initFile should have thrown
       assert(input_.skipBadFiles());
     } while (true);
  
     // make sure the new product registry is compatible with the main one
     std::string mergeInfo =
         input_.productRegistryUpdate().merge(*rootFile()->productRegistry(), fileNames()[0], branchesMustMatch_);
     if (!mergeInfo.empty()) {
       throw Exception(errors::MismatchedInputFiles, "RootPrimaryFileSequence::nextFile()") << mergeInfo;
     }
     return true;
   }

References cms::cuda::assert(), branchesMustMatch_, Exception, edm::RootInputFileSequence::fileNames(), edm::RootInputFileSequence::initFile(), input_, edm::ProductRegistry::merge(), edm::errors::MismatchedInputFiles, edm::RootInputFileSequence::noMoreFiles(), edm::PoolSource::productRegistryUpdate(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtNextFile(), edm::PoolSource::skipBadFiles(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by readFile_(), skipEvents(), and skipEventsAtBeginning().

◆ operator=()

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

delete

◆ previousFile()

bool edm::RootPrimaryFileSequence::previousFile ( )

private

Definition at line 198 of file RootPrimaryFileSequence.cc.

                                              {
     if (atFirstFile()) {
       return false;
     }
     setAtPreviousFile();
  
     initFile(false);
  
     if (rootFile()) {
       // make sure the new product registry is compatible to the main one
       std::string mergeInfo =
           input_.productRegistryUpdate().merge(*rootFile()->productRegistry(), fileNames()[0], branchesMustMatch_);
       if (!mergeInfo.empty()) {
         throw Exception(errors::MismatchedInputFiles, "RootPrimaryFileSequence::previousEvent()") << mergeInfo;
       }
     }
     if (rootFile())
       rootFile()->setToLastEntry();
     return true;
   }

References edm::RootInputFileSequence::atFirstFile(), branchesMustMatch_, Exception, edm::RootInputFileSequence::fileNames(), edm::RootInputFileSequence::initFile(), input_, edm::ProductRegistry::merge(), edm::errors::MismatchedInputFiles, edm::PoolSource::productRegistryUpdate(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtPreviousFile(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by skipEvents().

◆ readFile_()

std::shared_ptr< FileBlock > edm::RootPrimaryFileSequence::readFile_ ( )

Definition at line 74 of file RootPrimaryFileSequence.cc.

                                                               {
     std::shared_ptr<FileBlock> fileBlock;
     if (firstFile_) {
       firstFile_ = false;
       // Usually the first input file will already be open
       if (!rootFile()) {
         initFile(input_.skipBadFiles());
       }
     } else if (goToEventInNewFile_) {
       goToEventInNewFile_ = false;
       setAtFileSequenceNumber(goToFileSequenceOffset_);
       initFile(false);
       assert(rootFile());
       bool found = rootFile()->goToEvent(goToEventID_);
       assert(found);
     } else if (skipIntoNewFile_) {
       skipIntoNewFile_ = false;
       setAtFileSequenceNumber(skipToFileSequenceNumber_);
       initFile(false);
       assert(rootFile());
       if (skipToOffsetInFinalFile_ < 0) {
         rootFile()->setToLastEntry();
       }
       bool atEnd = rootFile()->skipEvents(skipToOffsetInFinalFile_);
       assert(!atEnd && skipToOffsetInFinalFile_ == 0);
     } else {
       if (!nextFile()) {
         // handle case with last file bad and
         // skipBadFiles true
         fb_ = fileBlock;
         return fileBlock;
       }
     }
     if (!rootFile()) {
       fileBlock = std::make_shared<FileBlock>();
       fb_ = fileBlock;
       return fileBlock;
     }
     fileBlock = rootFile()->createFileBlock();
     fb_ = fileBlock;
     return fileBlock;
   }

References cms::cuda::assert(), fb_, firstFile_, newFWLiteAna::found, goToEventID_, goToEventInNewFile_, goToFileSequenceOffset_, edm::RootInputFileSequence::initFile(), input_, nextFile(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtFileSequenceNumber(), edm::PoolSource::skipBadFiles(), skipIntoNewFile_, skipToFileSequenceNumber_, and skipToOffsetInFinalFile_.

◆ remainingEvents()

int edm::RootPrimaryFileSequence::remainingEvents ( ) const

private

Definition at line 399 of file RootPrimaryFileSequence.cc.

399 { return input_.remainingEvents(); }

References input_, and edm::InputSource::remainingEvents().

Referenced by makeRootFile().

◆ remainingLuminosityBlocks()

int edm::RootPrimaryFileSequence::remainingLuminosityBlocks ( ) const

private

Definition at line 401 of file RootPrimaryFileSequence.cc.

401 { return input_.remainingLuminosityBlocks(); }

References input_, and edm::InputSource::remainingLuminosityBlocks().

Referenced by makeRootFile().

◆ reverseState()

ProcessingController::ReverseState edm::RootPrimaryFileSequence::reverseState ( ) const

Definition at line 444 of file RootPrimaryFileSequence.cc.

                                                                                {
     if (rootFile()) {
       if (!rootFile()->wasFirstEventJustRead()) {
         return ProcessingController::kEventsBackwardsInFile;
       }
       if (!atFirstFile()) {
         return ProcessingController::kPreviousFileExists;
       }
       return ProcessingController::kAtFirstEvent;
     }
     return ProcessingController::kUnknownReverse;
   }

References edm::RootInputFileSequence::atFirstFile(), edm::ProcessingController::kAtFirstEvent, edm::ProcessingController::kEventsBackwardsInFile, edm::ProcessingController::kPreviousFileExists, edm::ProcessingController::kUnknownReverse, and edm::RootInputFileSequence::rootFile().

◆ rewind_()

void edm::RootPrimaryFileSequence::rewind_ ( )

Definition at line 247 of file RootPrimaryFileSequence.cc.

                                         {
     if (!atFirstFile()) {
       closeFile_();
       setAtFirstFile();
     }
     if (!rootFile()) {
       initFile(false);
     }
     rewindFile();
     firstFile_ = true;
     goToEventInNewFile_ = false;
     skipIntoNewFile_ = false;
     skipToStop_ = false;
     if (rootFile()) {
       if (initialNumberOfEventsToSkip_ != 0) {
         skipEventsAtBeginning(initialNumberOfEventsToSkip_);
       }
     }
   }

References edm::RootInputFileSequence::atFirstFile(), closeFile_(), firstFile_, goToEventInNewFile_, edm::RootInputFileSequence::initFile(), initialNumberOfEventsToSkip_, rewindFile(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtFirstFile(), skipEventsAtBeginning(), skipIntoNewFile_, and skipToStop_.

◆ rewindFile()

void edm::RootPrimaryFileSequence::rewindFile ( )

private

Definition at line 268 of file RootPrimaryFileSequence.cc.

                                            {
     if (rootFile())
       rootFile()->rewind();
   }

References edm::RootInputFileSequence::rootFile().

Referenced by rewind_().

◆ skipEvents()

void edm::RootPrimaryFileSequence::skipEvents ( int offset )

Definition at line 286 of file RootPrimaryFileSequence.cc.

                                                      {
     assert(rootFile());
  
     bool atEnd = rootFile()->skipEvents(offset);
     if (!atEnd && offset == 0) {
       // successfully completed skip within current file
       return;
     }
  
     // Return, if without closing the current file we know the skip cannot be completed
     skipToStop_ = false;
     if (offset > 0 || atEnd) {
       if (atLastFile() || noMoreFiles()) {
         skipToStop_ = true;
         return;
       }
     }
     if (offset < 0 && atFirstFile()) {
       skipToStop_ = true;
       return;
     }
  
     // Save the current file and position so that we can restore them
     size_t const originalFileSequenceNumber = sequenceNumberOfFile();
     IndexIntoFile::IndexIntoFileItr originalPosition = rootFile()->indexIntoFileIter();
  
     if ((offset > 0 || atEnd) && !nextFile()) {
       skipToStop_ = true;  // Can only get here if skipBadFiles is true
     }
     if (offset < 0 && !previousFile()) {
       skipToStop_ = true;  // Can't actually get here
     }
  
     if (!skipToStop_) {
       while (offset != 0) {
         skipToOffsetInFinalFile_ = offset;
         bool atEnd = rootFile()->skipEvents(offset);
         if ((offset > 0 || atEnd) && !nextFile()) {
           skipToStop_ = true;
           break;
         }
         if (offset < 0 && !previousFile()) {
           skipToStop_ = true;
           break;
         }
       }
       if (!skipToStop_) {
         skipIntoNewFile_ = true;
       }
     }
     skipToFileSequenceNumber_ = sequenceNumberOfFile();
  
     // Restore the original file and position
     setAtFileSequenceNumber(originalFileSequenceNumber);
     initFile(false);
     assert(rootFile());
     rootFile()->setPosition(originalPosition);
     rootFile()->updateFileBlock(*fb_);
   }

References cms::cuda::assert(), edm::RootInputFileSequence::atFirstFile(), edm::RootInputFileSequence::atLastFile(), fb_, edm::RootInputFileSequence::initFile(), nextFile(), edm::RootInputFileSequence::noMoreFiles(), hltrates_dqm_sourceclient-live_cfg::offset, previousFile(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::sequenceNumberOfFile(), edm::RootInputFileSequence::setAtFileSequenceNumber(), skipIntoNewFile_, skipToFileSequenceNumber_, skipToOffsetInFinalFile_, and skipToStop_.

◆ skipEventsAtBeginning()

void edm::RootPrimaryFileSequence::skipEventsAtBeginning ( int offset )

Definition at line 274 of file RootPrimaryFileSequence.cc.

                                                                 {
     assert(rootFile());
     assert(offset >= 0);
     while (offset != 0) {
       bool atEnd = rootFile()->skipEvents(offset);
       if ((offset > 0 || atEnd) && !nextFile()) {
         return;
       }
     }
   }

References cms::cuda::assert(), nextFile(), hltrates_dqm_sourceclient-live_cfg::offset, and edm::RootInputFileSequence::rootFile().

Referenced by rewind_(), and RootPrimaryFileSequence().

Member Data Documentation

◆ branchesMustMatch_

BranchDescription::MatchMode edm::RootPrimaryFileSequence::branchesMustMatch_

private

Definition at line 66 of file RootPrimaryFileSequence.h.

Referenced by nextFile(), previousFile(), and RootPrimaryFileSequence().

◆ duplicateChecker_

edm::propagate_const<std::shared_ptr<DuplicateChecker> > edm::RootPrimaryFileSequence::duplicateChecker_

private

Definition at line 79 of file RootPrimaryFileSequence.h.

Referenced by closeFile_(), duplicateChecker(), and initFile_().

◆ enablePrefetching_

bool edm::RootPrimaryFileSequence::enablePrefetching_

private

Definition at line 88 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile(), and RootPrimaryFileSequence().

◆ enforceGUIDInFileName_

bool edm::RootPrimaryFileSequence::enforceGUIDInFileName_

private

Definition at line 89 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

◆ eventSkipperByID_

edm::propagate_const<std::shared_ptr<EventSkipperByID> > edm::RootPrimaryFileSequence::eventSkipperByID_

private

Definition at line 75 of file RootPrimaryFileSequence.h.

Referenced by eventSkipperByID().

◆ fb_

edm::propagate_const<std::shared_ptr<FileBlock> > edm::RootPrimaryFileSequence::fb_

private

Definition at line 74 of file RootPrimaryFileSequence.h.

Referenced by goToEvent(), readFile_(), and skipEvents().

◆ firstFile_

bool edm::RootPrimaryFileSequence::firstFile_

private

Definition at line 65 of file RootPrimaryFileSequence.h.

Referenced by getNextItemType(), readFile_(), and rewind_().

◆ goToEventID_

EventID edm::RootPrimaryFileSequence::goToEventID_

private

Definition at line 83 of file RootPrimaryFileSequence.h.

Referenced by goToEvent(), and readFile_().

◆ goToEventInNewFile_

bool edm::RootPrimaryFileSequence::goToEventInNewFile_ = false

private

Definition at line 81 of file RootPrimaryFileSequence.h.

Referenced by getNextItemType(), goToEvent(), readFile_(), and rewind_().

◆ goToFileSequenceOffset_

size_t edm::RootPrimaryFileSequence::goToFileSequenceOffset_ = 0

private

Definition at line 82 of file RootPrimaryFileSequence.h.

Referenced by goToEvent(), and readFile_().

◆ initialNumberOfEventsToSkip_

int edm::RootPrimaryFileSequence::initialNumberOfEventsToSkip_

private

Definition at line 76 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile(), rewind_(), and RootPrimaryFileSequence().

◆ input_

PoolSource& edm::RootPrimaryFileSequence::input_

private

Definition at line 64 of file RootPrimaryFileSequence.h.

Referenced by closeFile_(), initFile_(), makeRootFile(), nextFile(), previousFile(), readFile_(), remainingEvents(), remainingLuminosityBlocks(), and RootPrimaryFileSequence().

◆ noEventSort_

bool edm::RootPrimaryFileSequence::noEventSort_

private

Definition at line 77 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

◆ orderedProcessHistoryIDs_

std::vector<ProcessHistoryID> edm::RootPrimaryFileSequence::orderedProcessHistoryIDs_

private

Definition at line 67 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

◆ skipIntoNewFile_

bool edm::RootPrimaryFileSequence::skipIntoNewFile_ = false

private

Definition at line 85 of file RootPrimaryFileSequence.h.

Referenced by getNextItemType(), readFile_(), rewind_(), and skipEvents().

◆ skipToFileSequenceNumber_

size_t edm::RootPrimaryFileSequence::skipToFileSequenceNumber_ = 0

private

Definition at line 86 of file RootPrimaryFileSequence.h.

Referenced by readFile_(), and skipEvents().

◆ skipToOffsetInFinalFile_

int edm::RootPrimaryFileSequence::skipToOffsetInFinalFile_ = 0

private

Definition at line 87 of file RootPrimaryFileSequence.h.

Referenced by readFile_(), and skipEvents().

◆ skipToStop_

bool edm::RootPrimaryFileSequence::skipToStop_ = false

private

Definition at line 84 of file RootPrimaryFileSequence.h.

Referenced by getNextItemType(), rewind_(), and skipEvents().

◆ treeCacheSize_

unsigned int edm::RootPrimaryFileSequence::treeCacheSize_

private

Definition at line 78 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile(), and RootPrimaryFileSequence().

◆ usingGoToEvent_

bool edm::RootPrimaryFileSequence::usingGoToEvent_

private

Definition at line 80 of file RootPrimaryFileSequence.h.

Referenced by goToEvent(), initFile_(), and makeRootFile().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ RootPrimaryFileSequence() [1/2]

◆ ~RootPrimaryFileSequence()

◆ RootPrimaryFileSequence() [2/2]

Member Function Documentation

◆ closeFile_()

◆ duplicateChecker() [1/2]

◆ duplicateChecker() [2/2]

◆ endJob()

◆ eventSkipperByID() [1/2]

◆ eventSkipperByID() [2/2]

◆ fillDescription()

◆ forwardState()

◆ getNextItemType()

◆ goToEvent()

◆ initFile_()

◆ makeRootFile()

◆ nextFile()

◆ operator=()

◆ previousFile()

◆ readFile_()

◆ remainingEvents()

◆ remainingLuminosityBlocks()

◆ reverseState()

◆ rewind_()

◆ rewindFile()

◆ skipEvents()

◆ skipEventsAtBeginning()

Member Data Documentation

◆ branchesMustMatch_

◆ duplicateChecker_

◆ enablePrefetching_

◆ enforceGUIDInFileName_

◆ eventSkipperByID_

◆ fb_

◆ firstFile_

◆ goToEventID_

◆ goToEventInNewFile_

◆ goToFileSequenceOffset_

◆ initialNumberOfEventsToSkip_

◆ input_

◆ noEventSort_

◆ orderedProcessHistoryIDs_

◆ skipIntoNewFile_

◆ skipToFileSequenceNumber_

◆ skipToOffsetInFinalFile_

◆ skipToStop_

◆ treeCacheSize_

◆ usingGoToEvent_