#include <RootEmbeddedFileSequence.h>

Inheritance diagram for edm::RootEmbeddedFileSequence:

Public Member Functions
void	closeFile_ () override

void	endJob ()

RootEmbeddedFileSequence &	operator= (RootEmbeddedFileSequence const &)=delete

bool	readOneEvent (EventPrincipal &cache, size_t &fileNameHash, CLHEP::HepRandomEngine , EventID const id, bool recycleFiles)

bool	readOneRandom (EventPrincipal &cache, size_t &fileNameHash, CLHEP::HepRandomEngine , EventID const , bool)

bool	readOneRandomWithID (EventPrincipal &cache, size_t &fileNameHash, CLHEP::HepRandomEngine , EventID const id, bool)

bool	readOneSequential (EventPrincipal &cache, size_t &fileNameHash, CLHEP::HepRandomEngine , EventID const , bool recycleFiles)

bool	readOneSequentialWithID (EventPrincipal &cache, size_t &fileNameHash, CLHEP::HepRandomEngine , EventID const id, bool)

void	readOneSpecified (EventPrincipal &cache, size_t &fileNameHash, SecondaryEventIDAndFileInfo const &id)

	RootEmbeddedFileSequence (ParameterSet const &pset, EmbeddedRootSource &input, InputFileCatalog const &catalog)

	RootEmbeddedFileSequence (RootEmbeddedFileSequence const &)=delete

void	skipEntries (unsigned int offset)

	~RootEmbeddedFileSequence () 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
void	initFile_ (bool skipBadFiles) override

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

Private Attributes
bool	enablePrefetching_

bool	enforceGUIDInFileName_

int	eventsRemainingInFile_

bool(RootEmbeddedFileSequence::*	fptr_ )(EventPrincipal &, size_t &, CLHEP::HepRandomEngine , EventID const , bool)

int	initialNumberOfEventsToSkip_

EmbeddedRootSource &	input_

unsigned int	maxFileSkips_

std::vector< ProcessHistoryID >	orderedProcessHistoryIDs_

bool	sameLumiBlock_

bool	sequential_

unsigned int	treeCacheSize_

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 32 of file RootEmbeddedFileSequence.h.

Constructor & Destructor Documentation

◆ RootEmbeddedFileSequence() [1/2]

edm::RootEmbeddedFileSequence::RootEmbeddedFileSequence	(	ParameterSet const &	pset,
		EmbeddedRootSource &	input,
		InputFileCatalog const &	catalog
	)

explicit

Definition at line 34 of file RootEmbeddedFileSequence.cc.

       : RootInputFileSequence(pset, catalog),
         input_(input),
         orderedProcessHistoryIDs_(),
         sequential_(pset.getUntrackedParameter<bool>("sequential", false)),
         sameLumiBlock_(pset.getUntrackedParameter<bool>("sameLumiBlock", false)),
         fptr_(nullptr),
         eventsRemainingInFile_(0),
         // The default value provided as the second argument to the getUntrackedParameter function call
         // is not used when the ParameterSet has been validated and the parameters are not optional
         // in the description.  This is currently true when PoolSource is the primary input source.
         // The modules that use PoolSource as a SecSource have not defined their fillDescriptions function
         // yet, so the ParameterSet does not get validated yet.  As soon as all the modules with a SecSource
         // have defined descriptions, the defaults in the getUntrackedParameterSet function calls can
         // and should be deleted from the code.
         initialNumberOfEventsToSkip_(pset.getUntrackedParameter<unsigned int>("skipEvents", 0U)),
         treeCacheSize_(pset.getUntrackedParameter<unsigned int>("cacheSize", roottree::defaultCacheSize)),
         enablePrefetching_(false),
         enforceGUIDInFileName_(pset.getUntrackedParameter<bool>("enforceGUIDInFileName", false)),
         maxFileSkips_(pset.getUntrackedParameter<unsigned int>("maxFileSkips", std::min(3_uz, numberOfFiles()))) {
     if (noFiles()) {
       throw Exception(errors::NoSecondaryFiles)
           << "RootEmbeddedFileSequence no input files specified for secondary input source.\n";
     }
     //
     // 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();
     }
  
     // Set the pointer to the function that reads an event.
     if (sameLumiBlock_) {
       if (sequential_) {
         fptr_ = &RootEmbeddedFileSequence::readOneSequentialWithID;
       } else {
         fptr_ = &RootEmbeddedFileSequence::readOneRandomWithID;
       }
     } else {
       if (sequential_) {
         fptr_ = &RootEmbeddedFileSequence::readOneSequential;
       } else {
         fptr_ = &RootEmbeddedFileSequence::readOneRandom;
       }
     }
  
     // For the secondary input source we do not stage in.
     if (sequential_) {
       // We open the first file
       if (!atFirstFile()) {
         setAtFirstFile();
         initFile(false);
       }
       assert(rootFile());
       rootFile()->setAtEventEntry(IndexIntoFile::invalidEntry);
       if (!sameLumiBlock_) {
         skipEntries(initialNumberOfEventsToSkip_);
       }
     } else {
       // We randomly choose the first file to open.
       // We cannot use the random number service yet.
       std::ifstream f("/dev/urandom");
       unsigned int seed;
       f.read(reinterpret_cast<char*>(&seed), sizeof(seed));
       std::default_random_engine dre(seed);
       std::uniform_int_distribution<int> distribution(0, numberOfFiles() - 1);
       while (!rootFile() && badFilesSkipped_ < maxFileSkips_) {
         int offset = distribution(dre);
         setAtFileSequenceNumber(offset);
         initFile(input_.skipBadFiles());
         if (not rootFile()) {
           ++badFilesSkipped_;
         }
       }
     }
     if (rootFile()) {
       input_.productRegistryUpdate().updateFromInput(rootFile()->productRegistry()->productList());
     } else {
       throw Exception(errors::FileOpenError) << "RootEmbeddedFileSequence::RootEmbeddedFileSequence(): "
                                              << " input file retries exhausted.\n";
     }
   }

References cms::cuda::assert(), edm::RootInputFileSequence::atFirstFile(), enablePrefetching_, Exception, f, edm::errors::FileOpenError, fptr_, edm::RootInputFileSequence::initFile(), initialNumberOfEventsToSkip_, input_, edm::IndexIntoFile::invalidEntry, edm::Service< T >::isAvailable(), maxFileSkips_, edm::RootInputFileSequence::noFiles(), edm::errors::NoSecondaryFiles, edm::RootInputFileSequence::numberOfFiles(), hltrates_dqm_sourceclient-live_cfg::offset, edm::EmbeddedRootSource::productRegistryUpdate(), readOneRandom(), readOneRandomWithID(), readOneSequential(), readOneSequentialWithID(), edm::RootInputFileSequence::rootFile(), sameLumiBlock_, fileCollector::seed, sequential_, edm::RootInputFileSequence::setAtFileSequenceNumber(), edm::RootInputFileSequence::setAtFirstFile(), edm::EmbeddedRootSource::skipBadFiles(), skipEntries(), treeCacheSize_, mitigatedMETSequence_cff::U, and edm::ProductRegistry::updateFromInput().

◆ ~RootEmbeddedFileSequence()

edm::RootEmbeddedFileSequence::~RootEmbeddedFileSequence ( )

override

Definition at line 122 of file RootEmbeddedFileSequence.cc.

122 {}

◆ RootEmbeddedFileSequence() [2/2]

edm::RootEmbeddedFileSequence::RootEmbeddedFileSequence ( RootEmbeddedFileSequence const & )

delete

Member Function Documentation

◆ closeFile_()

void edm::RootEmbeddedFileSequence::closeFile_ ( )

overridevirtual

Implements edm::RootInputFileSequence.

Definition at line 126 of file RootEmbeddedFileSequence.cc.

                                             {
     // delete the RootFile object.
     if (rootFile()) {
       rootFile().reset();
     }
   }

References edm::RootInputFileSequence::rootFile().

Referenced by endJob().

◆ endJob()

void edm::RootEmbeddedFileSequence::endJob ( void )

Definition at line 124 of file RootEmbeddedFileSequence.cc.

124 { closeFile_(); }

References closeFile_().

◆ fillDescription()

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

static

Definition at line 366 of file RootEmbeddedFileSequence.cc.

                                                                               {
     desc.addUntracked<bool>("sequential", false)
         ->setComment(
             "True: loopEvents() reads events sequentially from beginning of first file.\n"
             "False: loopEvents() first reads events beginning at random event. New files also chosen randomly");
     desc.addUntracked<bool>("sameLumiBlock", false)
         ->setComment(
             "True: loopEvents() reads events only in same lumi as the specified event.\n"
             "False: loopEvents() reads events regardless of lumi.");
     desc.addUntracked<unsigned int>("skipEvents", 0U)
         ->setComment(
             "Skip the first 'skipEvents' events. Used only if 'sequential' is True and 'sameLumiBlock' is False");
     desc.addUntracked<unsigned int>("maxFileSkips")
         ->setComment(
             "How many files to try if 'sequential' is False and 'skipBadFiles' is True.\n"
             "Defaults to 3 (or # of files if smaller).");
     desc.addUntracked<unsigned int>("cacheSize", roottree::defaultCacheSize)
         ->setComment("Size of ROOT TTree prefetch cache.  Affects performance.");
     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");
   }

References edm::roottree::defaultCacheSize, submitPVResolutionJobs::desc, and mitigatedMETSequence_cff::U.

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

◆ initFile_()

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

overrideprivatevirtual

Implements edm::RootInputFileSequence.

Definition at line 133 of file RootEmbeddedFileSequence.cc.

                                                             {
     initTheFile(skipBadFiles, false, nullptr, "mixingFiles", InputType::SecondarySource);
   }

References edm::RootInputFileSequence::initTheFile(), edm::SecondarySource, and remoteMonitoring_LED_IterMethod_cfg::skipBadFiles.

◆ makeRootFile()

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

overrideprivatevirtual

Implements edm::RootInputFileSequence.

Definition at line 137 of file RootEmbeddedFileSequence.cc.

                                         {
     size_t currentIndexIntoFile = sequenceNumberOfFile();
     return std::make_shared<RootFile>(fileNames()[0],
                                       ProcessConfiguration(),
                                       logicalFileName(),
                                       filePtr,
                                       input_.nStreams(),
                                       treeCacheSize_,
                                       input_.treeMaxVirtualSize(),
                                       input_.runHelper(),
                                       input_.productSelectorRules(),
                                       InputType::SecondarySource,
                                       input_.processHistoryRegistryForUpdate(),
                                       indexesIntoFiles(),
                                       currentIndexIntoFile,
                                       orderedProcessHistoryIDs_,
                                       input_.bypassVersionCheck(),
                                       enablePrefetching_,
                                       enforceGUIDInFileName_);
   }

References edm::EmbeddedRootSource::bypassVersionCheck(), enablePrefetching_, enforceGUIDInFileName_, edm::RootInputFileSequence::fileNames(), edm::RootInputFileSequence::indexesIntoFiles(), input_, edm::RootInputFileSequence::logicalFileName(), edm::EmbeddedRootSource::nStreams(), orderedProcessHistoryIDs_, edm::EmbeddedRootSource::processHistoryRegistryForUpdate(), edm::EmbeddedRootSource::productSelectorRules(), edm::EmbeddedRootSource::runHelper(), edm::SecondarySource, edm::RootInputFileSequence::sequenceNumberOfFile(), treeCacheSize_, and edm::EmbeddedRootSource::treeMaxVirtualSize().

◆ operator=()

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

delete

◆ readOneEvent()

bool edm::RootEmbeddedFileSequence::readOneEvent	(	EventPrincipal &	cache,
		size_t &	fileNameHash,
		CLHEP::HepRandomEngine *	engine,
		EventID const *	id,
		bool	recycleFiles
	)

Definition at line 356 of file RootEmbeddedFileSequence.cc.

                                                                  {
     assert(!sameLumiBlock_ || id != nullptr);
     assert(sequential_ || engine != nullptr);
     return (this->*fptr_)(cache, fileNameHash, engine, id, recycleFiles);
   }

References cms::cuda::assert(), utilities::cache(), fptr_, triggerObjects_cff::id, sameLumiBlock_, and sequential_.

◆ readOneRandom()

bool edm::RootEmbeddedFileSequence::readOneRandom	(	EventPrincipal &	cache,
		size_t &	fileNameHash,
		CLHEP::HepRandomEngine *	engine,
		EventID const *	,
		bool
	)

Definition at line 261 of file RootEmbeddedFileSequence.cc.

                                                                                                        {
     assert(rootFile());
     assert(engine);
     unsigned int currentSeqNumber = sequenceNumberOfFile();
     while (eventsRemainingInFile_ == 0) {
       bool opened{false};
       while (!opened && badFilesSkipped_ < maxFileSkips_) {
         unsigned int newSeqNumber = CLHEP::RandFlat::shootInt(engine, fileCatalogItems().size());
         setAtFileSequenceNumber(newSeqNumber);
         if (newSeqNumber != currentSeqNumber) {
           initFile(input_.skipBadFiles());
           currentSeqNumber = newSeqNumber;
         }
         if (rootFile()) {
           eventsRemainingInFile_ = rootFile()->eventTree().entries();
           if (eventsRemainingInFile_ == 0) {
             if (!input_.skipBadFiles()) {
               throw Exception(errors::NotFound) << "RootEmbeddedFileSequence::readOneRandom(): Secondary Input file "
                                                 << fileNames()[0] << " contains no events.\n";
             }
             LogWarning("RootEmbeddedFileSequence") << "RootEmbeddedFileSequence::readOneRandom(): Secondary Input file "
                                                    << fileNames()[0] << " contains no events and will be skipped.\n";
             ++badFilesSkipped_;
           } else {
             opened = true;
           }
         } else {
           if (newSeqNumber != currentSeqNumber) {
             ++badFilesSkipped_;
           }
         }
       }
       if (not opened) {
         throw Exception(errors::FileOpenError) << "RootEmbeddedFileSequence::readOneRandom(): "
                                                << " input file retries exhausted.\n";
       }
       rootFile()->setAtEventEntry(CLHEP::RandFlat::shootInt(engine, eventsRemainingInFile_) - 1);
     }
     rootFile()->nextEventEntry();
  
     auto [found, succeeded] = rootFile()->readCurrentEvent(cache);
     if (!found) {
       rootFile()->setAtEventEntry(0);
       auto [found2, succeeded] = rootFile()->readCurrentEvent(cache);
       assert(found2);
     }
     fileNameHash = lfnHash();
     --eventsRemainingInFile_;
     return true;
   }

References cms::cuda::assert(), utilities::cache(), eventsRemainingInFile_, Exception, edm::RootInputFileSequence::fileCatalogItems(), edm::RootInputFileSequence::fileNames(), edm::errors::FileOpenError, newFWLiteAna::found, edm::RootInputFileSequence::initFile(), input_, edm::RootInputFileSequence::lfnHash(), maxFileSkips_, edm::errors::NotFound, edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::sequenceNumberOfFile(), edm::RootInputFileSequence::setAtFileSequenceNumber(), findQualityFiles::size, edm::EmbeddedRootSource::skipBadFiles(), and summarizeEdmComparisonLogfiles::succeeded.

Referenced by RootEmbeddedFileSequence().

◆ readOneRandomWithID()

bool edm::RootEmbeddedFileSequence::readOneRandomWithID	(	EventPrincipal &	cache,
		size_t &	fileNameHash,
		CLHEP::HepRandomEngine *	engine,
		EventID const *	id,
		bool	recycleFiles
	)

Definition at line 313 of file RootEmbeddedFileSequence.cc.

                                                                         {
     assert(engine);
     assert(idp);
     EventID const& id = *idp;
     if (noMoreFiles() || !rootFile() || rootFile()->indexIntoFileIter().run() != id.run() ||
         rootFile()->indexIntoFileIter().lumi() != id.luminosityBlock()) {
       bool found = skipToItem(id.run(), id.luminosityBlock(), 0);
       if (!found) {
         return false;
       }
       int eventsInLumi = 0;
       assert(rootFile());
       while (rootFile()->setEntryAtNextEventInLumi(id.run(), id.luminosityBlock()))
         ++eventsInLumi;
       found = skipToItem(id.run(), id.luminosityBlock(), 0);
       assert(found);
       int eventInLumi = CLHEP::RandFlat::shootInt(engine, eventsInLumi);
       for (int i = 0; i < eventInLumi; ++i) {
         bool foundEventInLumi = rootFile()->setEntryAtNextEventInLumi(id.run(), id.luminosityBlock());
         assert(foundEventInLumi);
       }
     }
     assert(rootFile());
     bool found = rootFile()->setEntryAtNextEventInLumi(id.run(), id.luminosityBlock());
     if (found) {
       auto [found2, succeeded] = rootFile()->readCurrentEvent(cache);
       found = found2;
     }
     if (!found) {
       found = rootFile()->setEntryAtItem(id.run(), id.luminosityBlock(), 0);
       if (!found) {
         return false;
       }
       return readOneRandomWithID(cache, fileNameHash, engine, idp, recycleFiles);
     }
     fileNameHash = lfnHash();
     return true;
   }

References cms::cuda::assert(), utilities::cache(), newFWLiteAna::found, mps_fire::i, edm::RootInputFileSequence::lfnHash(), BXlumiParameters_cfi::lumi, edm::RootInputFileSequence::noMoreFiles(), edm::RootInputFileSequence::rootFile(), writedatasetfile::run, edm::RootInputFileSequence::skipToItem(), and summarizeEdmComparisonLogfiles::succeeded.

Referenced by RootEmbeddedFileSequence().

◆ readOneSequential()

bool edm::RootEmbeddedFileSequence::readOneSequential	(	EventPrincipal &	cache,
		size_t &	fileNameHash,
		CLHEP::HepRandomEngine *	,
		EventID const *	,
		bool	recycleFiles
	)

Definition at line 174 of file RootEmbeddedFileSequence.cc.

                                                                                                              {
     assert(rootFile());
     bool found = rootFile()->nextEventEntry();
     if (found) {
       auto [found2, succeeded] = rootFile()->readCurrentEvent(cache);
       found = found2;
     }
     if (!found) {
       setAtNextFile();
       if (noMoreFiles()) {
         if (recycleFiles) {
           setAtFirstFile();
         } else {
           return false;
         }
       }
       initFile(false);
       assert(rootFile());
       rootFile()->setAtEventEntry(IndexIntoFile::invalidEntry);
       return readOneSequential(cache, fileNameHash, nullptr, nullptr, recycleFiles);
     }
     fileNameHash = lfnHash();
     return true;
   }

References cms::cuda::assert(), utilities::cache(), newFWLiteAna::found, edm::RootInputFileSequence::initFile(), edm::IndexIntoFile::invalidEntry, edm::RootInputFileSequence::lfnHash(), edm::RootInputFileSequence::noMoreFiles(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtFirstFile(), edm::RootInputFileSequence::setAtNextFile(), and summarizeEdmComparisonLogfiles::succeeded.

Referenced by RootEmbeddedFileSequence().

◆ readOneSequentialWithID()

bool edm::RootEmbeddedFileSequence::readOneSequentialWithID	(	EventPrincipal &	cache,
		size_t &	fileNameHash,
		CLHEP::HepRandomEngine *	,
		EventID const *	id,
		bool	recycleFiles
	)

Definition at line 200 of file RootEmbeddedFileSequence.cc.

                                                                                                                  {
     assert(idp);
     EventID const& id = *idp;
     int offset = initialNumberOfEventsToSkip_;
     initialNumberOfEventsToSkip_ = 0;
     if (offset > 0) {
       assert(rootFile());
       while (offset > 0) {
         bool found = readOneSequentialWithID(cache, fileNameHash, nullptr, idp, recycleFiles);
         if (!found) {
           return false;
         }
         --offset;
       }
     }
     assert(rootFile());
     if (noMoreFiles() || rootFile()->indexIntoFileIter().run() != id.run() ||
         rootFile()->indexIntoFileIter().lumi() != id.luminosityBlock()) {
       bool found = skipToItem(id.run(), id.luminosityBlock(), 0, 0, false);
       if (!found) {
         return false;
       }
     }
     assert(rootFile());
     bool found = rootFile()->setEntryAtNextEventInLumi(id.run(), id.luminosityBlock());
     if (found) {
       auto [found2, succeeded] = rootFile()->readCurrentEvent(cache);
       found = found2;
     }
     if (!found) {
       found = skipToItemInNewFile(id.run(), id.luminosityBlock(), 0);
       if (!found) {
         return false;
       }
       return readOneSequentialWithID(cache, fileNameHash, nullptr, idp, recycleFiles);
     }
     fileNameHash = lfnHash();
     return true;
   }

References cms::cuda::assert(), utilities::cache(), newFWLiteAna::found, initialNumberOfEventsToSkip_, edm::RootInputFileSequence::lfnHash(), BXlumiParameters_cfi::lumi, edm::RootInputFileSequence::noMoreFiles(), hltrates_dqm_sourceclient-live_cfg::offset, edm::RootInputFileSequence::rootFile(), writedatasetfile::run, edm::RootInputFileSequence::skipToItem(), edm::RootInputFileSequence::skipToItemInNewFile(), and summarizeEdmComparisonLogfiles::succeeded.

Referenced by RootEmbeddedFileSequence().

◆ readOneSpecified()

void edm::RootEmbeddedFileSequence::readOneSpecified	(	EventPrincipal &	cache,
		size_t &	fileNameHash,
		SecondaryEventIDAndFileInfo const &	id
	)

Definition at line 241 of file RootEmbeddedFileSequence.cc.

                                                                                           {
     EventID const& id = idx.eventID();
     bool found = skipToItem(id.run(), id.luminosityBlock(), id.event(), idx.fileNameHash());
     if (!found) {
       throw Exception(errors::NotFound) << "RootEmbeddedFileSequence::readOneSpecified(): Secondary Input files"
                                         << " do not contain specified event:\n"
                                         << id << " in file id " << idx.fileNameHash() << "\n";
     }
     assert(rootFile());
     auto [found2, succeeded] = rootFile()->readCurrentEvent(cache);
     found = found2;
     assert(found);
     fileNameHash = idx.fileNameHash();
     if (fileNameHash == 0U) {
       fileNameHash = lfnHash();
     }
   }

References cms::cuda::assert(), utilities::cache(), edmPickEvents::event, Exception, newFWLiteAna::found, heavyIonCSV_trainingSettings::idx, edm::RootInputFileSequence::lfnHash(), edm::errors::NotFound, edm::RootInputFileSequence::rootFile(), writedatasetfile::run, edm::RootInputFileSequence::skipToItem(), summarizeEdmComparisonLogfiles::succeeded, and mitigatedMETSequence_cff::U.

◆ skipEntries()

void edm::RootEmbeddedFileSequence::skipEntries ( unsigned int offset )

Definition at line 159 of file RootEmbeddedFileSequence.cc.

                                                                 {
     // offset is decremented by the number of events actually skipped.
     bool completed = rootFile()->skipEntries(offset);
     while (!completed) {
       setAtNextFile();
       if (noMoreFiles()) {
         setAtFirstFile();
       }
       initFile(false);
       assert(rootFile());
       rootFile()->setAtEventEntry(IndexIntoFile::invalidEntry);
       completed = rootFile()->skipEntries(offset);
     }
   }

References cms::cuda::assert(), edm::RootInputFileSequence::initFile(), edm::IndexIntoFile::invalidEntry, edm::RootInputFileSequence::noMoreFiles(), hltrates_dqm_sourceclient-live_cfg::offset, edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtFirstFile(), and edm::RootInputFileSequence::setAtNextFile().

Referenced by RootEmbeddedFileSequence().

Member Data Documentation

◆ enablePrefetching_

bool edm::RootEmbeddedFileSequence::enablePrefetching_

private

Definition at line 72 of file RootEmbeddedFileSequence.h.

Referenced by makeRootFile(), and RootEmbeddedFileSequence().

◆ enforceGUIDInFileName_

bool edm::RootEmbeddedFileSequence::enforceGUIDInFileName_

private

Definition at line 73 of file RootEmbeddedFileSequence.h.

Referenced by makeRootFile().

◆ eventsRemainingInFile_

int edm::RootEmbeddedFileSequence::eventsRemainingInFile_

private

Definition at line 69 of file RootEmbeddedFileSequence.h.

Referenced by readOneRandom().

◆ fptr_

bool(RootEmbeddedFileSequence::* edm::RootEmbeddedFileSequence::fptr_) (EventPrincipal &, size_t &, CLHEP::HepRandomEngine *, EventID const *, bool)

private

Definition at line 68 of file RootEmbeddedFileSequence.h.

Referenced by readOneEvent(), and RootEmbeddedFileSequence().

◆ initialNumberOfEventsToSkip_

int edm::RootEmbeddedFileSequence::initialNumberOfEventsToSkip_

private

Definition at line 70 of file RootEmbeddedFileSequence.h.

Referenced by readOneSequentialWithID(), and RootEmbeddedFileSequence().

◆ input_

EmbeddedRootSource& edm::RootEmbeddedFileSequence::input_

private

Definition at line 62 of file RootEmbeddedFileSequence.h.

Referenced by makeRootFile(), readOneRandom(), and RootEmbeddedFileSequence().

◆ maxFileSkips_

unsigned int edm::RootEmbeddedFileSequence::maxFileSkips_

private

Definition at line 74 of file RootEmbeddedFileSequence.h.

Referenced by readOneRandom(), and RootEmbeddedFileSequence().

◆ orderedProcessHistoryIDs_

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

private

Definition at line 64 of file RootEmbeddedFileSequence.h.

Referenced by makeRootFile().

◆ sameLumiBlock_

bool edm::RootEmbeddedFileSequence::sameLumiBlock_

private

Definition at line 67 of file RootEmbeddedFileSequence.h.

Referenced by readOneEvent(), and RootEmbeddedFileSequence().

◆ sequential_

bool edm::RootEmbeddedFileSequence::sequential_

private

Definition at line 66 of file RootEmbeddedFileSequence.h.

Referenced by readOneEvent(), and RootEmbeddedFileSequence().

◆ treeCacheSize_

unsigned int edm::RootEmbeddedFileSequence::treeCacheSize_

private

Definition at line 71 of file RootEmbeddedFileSequence.h.

Referenced by makeRootFile(), and RootEmbeddedFileSequence().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ RootEmbeddedFileSequence() [1/2]

◆ ~RootEmbeddedFileSequence()

◆ RootEmbeddedFileSequence() [2/2]

Member Function Documentation

◆ closeFile_()

◆ endJob()

◆ fillDescription()

◆ initFile_()

◆ makeRootFile()

◆ operator=()

◆ readOneEvent()

◆ readOneRandom()

◆ readOneRandomWithID()

◆ readOneSequential()

◆ readOneSequentialWithID()

◆ readOneSpecified()

◆ skipEntries()

Member Data Documentation

◆ enablePrefetching_

◆ enforceGUIDInFileName_

◆ eventsRemainingInFile_

◆ fptr_

◆ initialNumberOfEventsToSkip_

◆ input_

◆ maxFileSkips_

◆ orderedProcessHistoryIDs_

◆ sameLumiBlock_

◆ sequential_

◆ treeCacheSize_