#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::unique_ptr< FileBlock >	readFile_ ()

ProcessingController::ReverseState	reverseState () const

void	rewind_ ()

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

	RootPrimaryFileSequence (RootPrimaryFileSequence const &)=delete

bool	skipEvents (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

RootInputFileSequence &	operator= (RootInputFileSequence const &)=delete

void	readEvent (EventPrincipal &cache)

void	readLuminosityBlock_ (LuminosityBlockPrincipal &lumiPrincipal)

std::shared_ptr< LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()

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_

bool	firstFile_

int	initialNumberOfEventsToSkip_

PoolSource &	input_

bool	noEventSort_

std::vector< ProcessHistoryID >	orderedProcessHistoryIDs_

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) {
         skipEvents(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(), skipEvents(), 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 92 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 71 of file RootPrimaryFileSequence.h.

71 { 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 70 of file RootPrimaryFileSequence.h.

70 { 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 69 of file RootPrimaryFileSequence.h.

69 { 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 68 of file RootPrimaryFileSequence.h.

68 { 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 312 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 339 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 189 of file RootPrimaryFileSequence.cc.

                                                                                        {
     if (noMoreFiles()) {
       return InputSource::IsStop;
     }
     if (firstFile_) {
       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_, 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(), and writedatasetfile::run.

◆ goToEvent()

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

Definition at line 255 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;
       }
       // Save the current file and position so that we can restore them
       // if we fail to restore the desired event
       bool closedOriginalFile = false;
       size_t const originalFileSequenceNumber = sequenceNumberOfFile();
       IndexIntoFile::IndexIntoFileItr originalPosition = rootFile()->indexIntoFileIter();
  
       // 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())) {
           // We found it. Close the currently open file, and open the correct one.
           setAtFileSequenceNumber(it - indexesIntoFiles().begin());
           initFile(false);
           // Now get the item from the correct file.
           assert(rootFile());
           bool found = rootFile()->goToEvent(eventID);
           assert(found);
           return true;
         }
       }
       // Look for item in files not yet opened.
       for (auto it = indexesIntoFiles().begin(), itEnd = indexesIntoFiles().end(); it != itEnd; ++it) {
         if (!*it) {
           setAtFileSequenceNumber(it - indexesIntoFiles().begin());
           initFile(false);
           closedOriginalFile = true;
           if ((*it)->containsItem(eventID.run(), eventID.luminosityBlock(), eventID.event())) {
             assert(rootFile());
             if (rootFile()->goToEvent(eventID)) {
               return true;
             }
           }
         }
       }
       if (closedOriginalFile) {
         setAtFileSequenceNumber(originalFileSequenceNumber);
         initFile(false);
         assert(rootFile());
         rootFile()->setPosition(originalPosition);
       }
     }
     return false;
   }

References cms::cuda::assert(), mps_fire::end, edm::EventID::event(), newFWLiteAna::found, 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 103 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 112 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_.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::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 146 of file RootPrimaryFileSequence.cc.

                                          {
     if (!noMoreFiles())
       setAtNextFile();
     if (noMoreFiles()) {
       return false;
     }
  
     initFile(input_.skipBadFiles());
  
     if (not rootFile()) {
       return false;
     }
  
     // 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 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_(), and skipEvents().

◆ operator=()

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

delete

◆ previousFile()

bool edm::RootPrimaryFileSequence::previousFile ( )

private

Definition at line 168 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::unique_ptr< FileBlock > edm::RootPrimaryFileSequence::readFile_ ( )

Definition at line 74 of file RootPrimaryFileSequence.cc.

                                                               {
     if (firstFile_) {
       // The first input file has already been opened.
       firstFile_ = false;
       if (!rootFile()) {
         initFile(input_.skipBadFiles());
       }
     } else {
       if (!nextFile()) {
         assert(0);
       }
     }
     if (!rootFile()) {
       return std::make_unique<FileBlock>();
     }
     return rootFile()->createFileBlock();
   }

References cms::cuda::assert(), firstFile_, edm::RootInputFileSequence::initFile(), input_, nextFile(), edm::RootInputFileSequence::rootFile(), and edm::PoolSource::skipBadFiles().

◆ remainingEvents()

int edm::RootPrimaryFileSequence::remainingEvents ( ) const

private

Definition at line 308 of file RootPrimaryFileSequence.cc.

308 { return input_.remainingEvents(); }

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

Referenced by makeRootFile().

◆ remainingLuminosityBlocks()

int edm::RootPrimaryFileSequence::remainingLuminosityBlocks ( ) const

private

Definition at line 310 of file RootPrimaryFileSequence.cc.

310 { return input_.remainingLuminosityBlocks(); }

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

Referenced by makeRootFile().

◆ reverseState()

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

Definition at line 353 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 216 of file RootPrimaryFileSequence.cc.

                                         {
     if (!atFirstFile()) {
       closeFile_();
       setAtFirstFile();
     }
     if (!rootFile()) {
       initFile(false);
     }
     rewindFile();
     firstFile_ = true;
     if (rootFile()) {
       if (initialNumberOfEventsToSkip_ != 0) {
         skipEvents(initialNumberOfEventsToSkip_);
       }
     }
   }

References edm::RootInputFileSequence::atFirstFile(), closeFile_(), firstFile_, edm::RootInputFileSequence::initFile(), initialNumberOfEventsToSkip_, rewindFile(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtFirstFile(), and skipEvents().

◆ rewindFile()

void edm::RootPrimaryFileSequence::rewindFile ( )

private

Definition at line 234 of file RootPrimaryFileSequence.cc.

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

References edm::RootInputFileSequence::rootFile().

Referenced by rewind_().

◆ skipEvents()

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

Definition at line 240 of file RootPrimaryFileSequence.cc.

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

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

Referenced by rewind_(), and RootPrimaryFileSequence().

Member Data Documentation

◆ branchesMustMatch_

BranchDescription::MatchMode edm::RootPrimaryFileSequence::branchesMustMatch_

private

Definition at line 65 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 77 of file RootPrimaryFileSequence.h.

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

◆ enablePrefetching_

bool edm::RootPrimaryFileSequence::enablePrefetching_

private

Definition at line 79 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile(), and RootPrimaryFileSequence().

◆ enforceGUIDInFileName_

bool edm::RootPrimaryFileSequence::enforceGUIDInFileName_

private

Definition at line 80 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

◆ eventSkipperByID_

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

private

Definition at line 73 of file RootPrimaryFileSequence.h.

Referenced by eventSkipperByID().

◆ firstFile_

bool edm::RootPrimaryFileSequence::firstFile_

private

Definition at line 64 of file RootPrimaryFileSequence.h.

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

◆ initialNumberOfEventsToSkip_

int edm::RootPrimaryFileSequence::initialNumberOfEventsToSkip_

private

Definition at line 74 of file RootPrimaryFileSequence.h.

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

◆ input_

PoolSource& edm::RootPrimaryFileSequence::input_

private

Definition at line 63 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 75 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

◆ orderedProcessHistoryIDs_

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

private

Definition at line 66 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

◆ treeCacheSize_

unsigned int edm::RootPrimaryFileSequence::treeCacheSize_

private

Definition at line 76 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile(), and RootPrimaryFileSequence().

◆ usingGoToEvent_

bool edm::RootPrimaryFileSequence::usingGoToEvent_

private

Definition at line 78 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()

Member Data Documentation

◆ branchesMustMatch_

◆ duplicateChecker_

◆ enablePrefetching_

◆ enforceGUIDInFileName_

◆ eventSkipperByID_

◆ firstFile_

◆ initialNumberOfEventsToSkip_

◆ input_

◆ noEventSort_

◆ orderedProcessHistoryIDs_

◆ treeCacheSize_

◆ usingGoToEvent_