#include <RootInputFileSequence.h>

Inheritance diagram for edm::RootInputFileSequence:

Public Member Functions
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 ()

Protected Types
typedef std::shared_ptr< RootFile >	RootFileSharedPtr

Protected Member Functions
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

Private Member Functions
virtual void	closeFile_ ()=0

virtual void	initFile_ (bool skipBadFiles)=0

virtual RootFileSharedPtr	makeRootFile (std::shared_ptr< InputFile > filePtr)=0

Private Attributes
InputFileCatalog const &	catalog_

std::vector< FileCatalogItem >::const_iterator	fileIter_

const std::vector< FileCatalogItem >::const_iterator	fileIterBegin_

const std::vector< FileCatalogItem >::const_iterator	fileIterEnd_

std::vector< FileCatalogItem >::const_iterator	fileIterLastOpened_

edm::propagate_const< std::unique_ptr< std::unordered_multimap< size_t, size_t > > >	findFileForSpecifiedID_

std::vector< std::shared_ptr< IndexIntoFile > >	indexesIntoFiles_

std::string	lfn_

size_t	lfnHash_

edm::propagate_const< RootFileSharedPtr >	rootFile_

bool	usedFallback_

Detailed Description

Definition at line 29 of file RootInputFileSequence.h.

Member Typedef Documentation

◆ RootFileSharedPtr

typedef std::shared_ptr<RootFile> edm::RootInputFileSequence::RootFileSharedPtr

protected

Definition at line 52 of file RootInputFileSequence.h.

Constructor & Destructor Documentation

◆ RootInputFileSequence() [1/2]

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

explicit

Definition at line 22 of file RootInputFileSequence.cc.

       : catalog_(catalog),
         lfn_("unknown"),
         lfnHash_(0U),
         usedFallback_(false),
         findFileForSpecifiedID_(nullptr),
         fileIterBegin_(fileCatalogItems().begin()),
         fileIterEnd_(fileCatalogItems().end()),
         fileIter_(fileIterEnd_),
         fileIterLastOpened_(fileIterEnd_),
         rootFile_(),
         indexesIntoFiles_(fileCatalogItems().size()) {}

◆ ~RootInputFileSequence()

edm::RootInputFileSequence::~RootInputFileSequence ( )

virtual

Definition at line 49 of file RootInputFileSequence.cc.

49 {}

◆ RootInputFileSequence() [2/2]

edm::RootInputFileSequence::RootInputFileSequence ( RootInputFileSequence const & )

delete

Member Function Documentation

◆ atFirstFile()

bool edm::RootInputFileSequence::atFirstFile ( ) const

inlineprotected

Definition at line 63 of file RootInputFileSequence.h.

63 { return fileIter_ == fileIterBegin_; }

References fileIter_, and fileIterBegin_.

Referenced by edm::RootPrimaryFileSequence::previousFile(), edm::RootPrimaryFileSequence::reverseState(), edm::RootPrimaryFileSequence::rewind_(), and edm::RootEmbeddedFileSequence::RootEmbeddedFileSequence().

◆ atLastFile()

bool edm::RootInputFileSequence::atLastFile ( ) const

inlineprotected

Definition at line 64 of file RootInputFileSequence.h.

64 { return fileIter_ + 1 == fileIterEnd_; }

References fileIter_, and fileIterEnd_.

Referenced by edm::RootPrimaryFileSequence::forwardState(), and edm::RootPrimaryFileSequence::getNextItemType().

◆ closeFile_()

virtual void edm::RootInputFileSequence::closeFile_ ( )

privatepure virtual

Implemented in edm::RootPrimaryFileSequence, edm::RootEmbeddedFileSequence, and edm::RootSecondaryFileSequence.

Referenced by initTheFile().

◆ containedInCurrentFile()

bool edm::RootInputFileSequence::containedInCurrentFile	(	RunNumber_t	run,
		LuminosityBlockNumber_t	lumi,
		EventNumber_t	event
	)		const

Definition at line 89 of file RootInputFileSequence.cc.

                                                                                 {
     if (!rootFile())
       return false;
     return rootFile()->containsItem(run, lumi, event);
   }

References rootFile(), and writedatasetfile::run.

◆ fileBranchIDListHelper()

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

Definition at line 44 of file RootInputFileSequence.cc.

                                                                                               {
     assert(rootFile());
     return rootFile()->branchIDListHelper();
   }

References cms::cuda::assert(), and rootFile().

◆ fileCatalogItems()

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

protected

Definition at line 35 of file RootInputFileSequence.cc.

                                                                                   {
     return catalog_.fileCatalogItems();
   }

References catalog_, and edm::InputFileCatalog::fileCatalogItems().

Referenced by edm::RootEmbeddedFileSequence::readOneRandom().

◆ fileNames()

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

inlineprotected

Definition at line 76 of file RootInputFileSequence.h.

76 { return fileIter_->fileNames(); }

References fileIter_.

Referenced by initTheFile(), edm::RootSecondaryFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::makeRootFile(), edm::RootEmbeddedFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::nextFile(), edm::RootPrimaryFileSequence::previousFile(), edm::RootEmbeddedFileSequence::readOneRandom(), edm::RootPrimaryFileSequence::RootPrimaryFileSequence(), and edm::RootSecondaryFileSequence::RootSecondaryFileSequence().

◆ fileProductRegistry()

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

Definition at line 39 of file RootInputFileSequence.cc.

                                                                                         {
     assert(rootFile());
     return rootFile()->productRegistry();
   }

References cms::cuda::assert(), and rootFile().

◆ indexesIntoFiles()

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

inlineprotected

Definition at line 82 of file RootInputFileSequence.h.

82 { return indexesIntoFiles_; }

References indexesIntoFiles_.

Referenced by edm::RootPrimaryFileSequence::goToEvent(), edm::RootSecondaryFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::makeRootFile(), and edm::RootEmbeddedFileSequence::makeRootFile().

◆ initFile()

void edm::RootInputFileSequence::initFile ( bool skipBadFiles )

inlineprotected

Definition at line 53 of file RootInputFileSequence.h.

53 { initFile_(skipBadFiles); }

References initFile_(), and remoteMonitoring_LED_IterMethod_cfg::skipBadFiles.

Referenced by edm::RootPrimaryFileSequence::goToEvent(), edm::RootPrimaryFileSequence::nextFile(), edm::RootPrimaryFileSequence::previousFile(), edm::RootPrimaryFileSequence::readFile_(), edm::RootEmbeddedFileSequence::readOneRandom(), edm::RootEmbeddedFileSequence::readOneSequential(), edm::RootPrimaryFileSequence::rewind_(), edm::RootEmbeddedFileSequence::RootEmbeddedFileSequence(), edm::RootPrimaryFileSequence::RootPrimaryFileSequence(), edm::RootSecondaryFileSequence::RootSecondaryFileSequence(), edm::RootEmbeddedFileSequence::skipEntries(), and skipToItem().

◆ initFile_()

virtual void edm::RootInputFileSequence::initFile_ ( bool skipBadFiles )

privatepure virtual

Implemented in edm::RootEmbeddedFileSequence, edm::RootPrimaryFileSequence, and edm::RootSecondaryFileSequence.

Referenced by initFile(), and skipToItemInNewFile().

◆ initTheFile()

void edm::RootInputFileSequence::initTheFile	(	bool	skipBadFiles,
		bool	deleteIndexIntoFile,
		InputSource *	input,
		char const *	inputTypeName,
		InputType	inputType
	)

protected

Definition at line 182 of file RootInputFileSequence.cc.

                                                                                                                        {
     // We are really going to close the open file.
  
     if (fileIterLastOpened_ != fileIterEnd_) {
       size_t currentIndexIntoFile = fileIterLastOpened_ - fileIterBegin_;
       if (deleteIndexIntoFile) {
         indexesIntoFiles_[currentIndexIntoFile].reset();
       } else {
         if (indexesIntoFiles_[currentIndexIntoFile])
           indexesIntoFiles_[currentIndexIntoFile]->inputFileClosed();
       }
       fileIterLastOpened_ = fileIterEnd_;
     }
     closeFile_();
  
     if (noMoreFiles()) {
       // No files specified
       return;
     }
  
     // Check if the logical file name was found.
     if (fileNames()[0].empty()) {
       // LFN not found in catalog.
       InputFile::reportSkippedFile(fileNames()[0], logicalFileName());
       if (!skipBadFiles) {
         throw cms::Exception("LogicalFileNameNotFound", "RootFileSequenceBase::initTheFile()\n")
             << "Logical file name '" << logicalFileName() << "' was not found in the file catalog.\n"
             << "If you wanted a local file, you forgot the 'file:' prefix\n"
             << "before the file name in your configuration file.\n";
       }
       LogWarning("") << "Input logical file: " << logicalFileName()
                      << " was not found in the catalog, and will be skipped.\n";
       return;
     }
  
     lfn_ = logicalFileName().empty() ? fileNames()[0] : logicalFileName();
     lfnHash_ = std::hash<std::string>()(lfn_);
  
     std::shared_ptr<InputFile> filePtr;
     std::list<std::string> originalInfo;
  
     std::vector<std::string> const& fNames = fileNames();
  
     //this tries to open the file using multiple PFNs corresponding to different data catalogs
     std::list<std::string> exInfo;
     for (std::vector<std::string>::const_iterator it = fNames.begin(); it != fNames.end(); ++it) {
       try {
         std::unique_ptr<InputSource::FileOpenSentry> sentry(
             input ? std::make_unique<InputSource::FileOpenSentry>(*input, lfn_, false) : nullptr);
         std::unique_ptr<char[]> name(gSystem->ExpandPathName(it->c_str()));
         filePtr = std::make_shared<InputFile>(name.get(), "  Initiating request to open file ", inputType);
         break;
       } catch (cms::Exception const& e) {
         if (!skipBadFiles && std::next(it) == fNames.end()) {
           InputFile::reportSkippedFile((*it), logicalFileName());
           Exception ex(errors::FileOpenError, "", e);
           ex.addContext("Calling RootInputFileSequence::initTheFile()");
           std::ostringstream out;
           out << "Input file " << (*it) << " could not be opened.";
           ex.addAdditionalInfo(out.str());
           //report previous exceptions when use other names to open file
           for (auto const& s : exInfo)
             ex.addAdditionalInfo(s);
           throw ex;
         } else {
           exInfo.push_back("Calling RootInputFileSequence::initTheFile(): fail to open the file with name " + (*it));
         }
       }
     }
  
     if (filePtr) {
       size_t currentIndexIntoFile = fileIter_ - fileIterBegin_;
       rootFile_ = makeRootFile(filePtr);
       if (input) {
         rootFile_->setSignals(&(input->preEventReadFromSourceSignal_), &(input->postEventReadFromSourceSignal_));
       }
       assert(rootFile_);
       fileIterLastOpened_ = fileIter_;
       setIndexIntoFile(currentIndexIntoFile);
       rootFile_->reportOpened(inputTypeName);
     } else {
       std::string fName = !fNames.empty() ? fNames[0] : "";
       InputFile::reportSkippedFile(fName, logicalFileName());  //0 cause exception?
       if (!skipBadFiles) {
         throw Exception(errors::FileOpenError) << "RootFileSequenceBase::initTheFile(): Input file " << fName
                                                << " was not found or could not be opened.\n";
       }
       LogWarning("RootInputFileSequence")
           << "Input file: " << fName << " was not found or could not be opened, and will be skipped.\n";
     }
   }

References cms::Exception::addAdditionalInfo(), cms::Exception::addContext(), cms::cuda::assert(), closeFile_(), MillePedeFileConverter_cfg::e, relativeConstraints::empty, Exception, fileIter_, fileIterBegin_, fileIterEnd_, fileIterLastOpened_, fileNames(), edm::errors::FileOpenError, MainPageGenerator::fName, indexesIntoFiles_, input, lfn_, lfnHash_, logicalFileName(), makeRootFile(), Skims_PA_cff::name, GetRecoTauVFromDQM_MC_cff::next, noMoreFiles(), MillePedeFileConverter_cfg::out, edm::InputFile::reportSkippedFile(), rootFile_, alignCSCRings::s, setIndexIntoFile(), remoteMonitoring_LED_IterMethod_cfg::skipBadFiles, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by edm::RootSecondaryFileSequence::initFile_(), edm::RootPrimaryFileSequence::initFile_(), and edm::RootEmbeddedFileSequence::initFile_().

◆ lfn()

std::string const& edm::RootInputFileSequence::lfn ( ) const

inlineprotected

Definition at line 79 of file RootInputFileSequence.h.

79 { return lfn_; }

References lfn_.

Referenced by edm::RootPrimaryFileSequence::closeFile_().

◆ lfnHash()

size_t edm::RootInputFileSequence::lfnHash ( ) const

inlineprotected

Definition at line 84 of file RootInputFileSequence.h.

84 { return lfnHash_; }

References lfnHash_.

Referenced by edm::RootEmbeddedFileSequence::readOneRandom(), edm::RootEmbeddedFileSequence::readOneRandomWithID(), edm::RootEmbeddedFileSequence::readOneSequential(), edm::RootEmbeddedFileSequence::readOneSequentialWithID(), and edm::RootEmbeddedFileSequence::readOneSpecified().

◆ logicalFileName()

std::string const& edm::RootInputFileSequence::logicalFileName ( ) const

inlineprotected

Definition at line 78 of file RootInputFileSequence.h.

78 { return fileIter_->logicalFileName(); }

References fileIter_.

Referenced by initTheFile(), edm::RootSecondaryFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::makeRootFile(), and edm::RootEmbeddedFileSequence::makeRootFile().

◆ makeRootFile()

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

privatepure virtual

Implemented in edm::RootEmbeddedFileSequence, edm::RootPrimaryFileSequence, and edm::RootSecondaryFileSequence.

Referenced by initTheFile().

◆ noFiles()

bool edm::RootInputFileSequence::noFiles ( ) const

inlineprotected

Definition at line 66 of file RootInputFileSequence.h.

66 { return fileIterBegin_ == fileIterEnd_; }

References fileIterBegin_, and fileIterEnd_.

Referenced by edm::RootEmbeddedFileSequence::RootEmbeddedFileSequence().

◆ noMoreFiles()

bool edm::RootInputFileSequence::noMoreFiles ( ) const

inlineprotected

Definition at line 65 of file RootInputFileSequence.h.

65 { return fileIter_ == fileIterEnd_; }

References fileIter_, and fileIterEnd_.

Referenced by edm::RootPrimaryFileSequence::forwardState(), edm::RootPrimaryFileSequence::getNextItemType(), initTheFile(), edm::RootPrimaryFileSequence::nextFile(), edm::RootEmbeddedFileSequence::readOneRandomWithID(), edm::RootEmbeddedFileSequence::readOneSequential(), edm::RootEmbeddedFileSequence::readOneSequentialWithID(), edm::RootPrimaryFileSequence::RootPrimaryFileSequence(), edm::RootSecondaryFileSequence::RootSecondaryFileSequence(), and edm::RootEmbeddedFileSequence::skipEntries().

◆ numberOfFiles()

size_t edm::RootInputFileSequence::numberOfFiles ( ) const

inlineprotected

Definition at line 68 of file RootInputFileSequence.h.

68 { return fileIterEnd_ - fileIterBegin_; }

References fileIterBegin_, and fileIterEnd_.

Referenced by edm::RootEmbeddedFileSequence::RootEmbeddedFileSequence().

◆ operator=()

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

delete

◆ readEvent()

void edm::RootInputFileSequence::readEvent ( EventPrincipal & cache )

Definition at line 84 of file RootInputFileSequence.cc.

                                                                       {
     assert(rootFile());
     rootFile()->readEvent(eventPrincipal);
   }

References cms::cuda::assert(), and rootFile().

◆ readLuminosityBlock_()

void edm::RootInputFileSequence::readLuminosityBlock_ ( LuminosityBlockPrincipal & lumiPrincipal )

Definition at line 66 of file RootInputFileSequence.cc.

                                                                                           {
     assert(rootFile());
     rootFile()->readLuminosityBlock_(lumiPrincipal);
   }

References cms::cuda::assert(), and rootFile().

◆ readLuminosityBlockAuxiliary_()

std::shared_ptr< LuminosityBlockAuxiliary > edm::RootInputFileSequence::readLuminosityBlockAuxiliary_ ( )

Definition at line 56 of file RootInputFileSequence.cc.

                                                                                                {
     assert(rootFile());
     return rootFile()->readLuminosityBlockAuxiliary_();
   }

References cms::cuda::assert(), and rootFile().

◆ readRun_()

void edm::RootInputFileSequence::readRun_ ( RunPrincipal & runPrincipal )

Definition at line 61 of file RootInputFileSequence.cc.

                                                                  {
     assert(rootFile());
     rootFile()->readRun_(runPrincipal);
   }

References cms::cuda::assert(), and rootFile().

◆ readRunAuxiliary_()

std::shared_ptr< RunAuxiliary > edm::RootInputFileSequence::readRunAuxiliary_ ( )

Definition at line 51 of file RootInputFileSequence.cc.

                                                                        {
     assert(rootFile());
     return rootFile()->readRunAuxiliary_();
   }

References cms::cuda::assert(), and rootFile().

◆ rootFile() [1/2]

std::shared_ptr<RootFile>& edm::RootInputFileSequence::rootFile ( )

inlineprotected

Definition at line 88 of file RootInputFileSequence.h.

88 { return get_underlying_safe(rootFile_); }

References edm::get_underlying_safe(), and rootFile_.

◆ rootFile() [2/2]

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

inlineprotected

Definition at line 87 of file RootInputFileSequence.h.

87 { return get_underlying_safe(rootFile_); }

References edm::get_underlying_safe(), and rootFile_.

◆ sequenceNumberOfFile()

size_t edm::RootInputFileSequence::sequenceNumberOfFile ( ) const

inlineprotected

Definition at line 67 of file RootInputFileSequence.h.

67 { return fileIter_ - fileIterBegin_; }

References fileIter_, and fileIterBegin_.

Referenced by edm::RootPrimaryFileSequence::goToEvent(), edm::RootSecondaryFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::makeRootFile(), edm::RootEmbeddedFileSequence::makeRootFile(), and edm::RootEmbeddedFileSequence::readOneRandom().

◆ setAtFileSequenceNumber()

void edm::RootInputFileSequence::setAtFileSequenceNumber ( size_t offset )

inlineprotected

Definition at line 71 of file RootInputFileSequence.h.

71 { fileIter_ = fileIterBegin_ + offset; }

References fileIter_, fileIterBegin_, and hltrates_dqm_sourceclient-live_cfg::offset.

Referenced by edm::RootPrimaryFileSequence::goToEvent(), edm::RootEmbeddedFileSequence::readOneRandom(), edm::RootEmbeddedFileSequence::RootEmbeddedFileSequence(), skipToItem(), and skipToItemInNewFile().

◆ setAtFirstFile()

void edm::RootInputFileSequence::setAtFirstFile ( )

inlineprotected

Definition at line 70 of file RootInputFileSequence.h.

70 { fileIter_ = fileIterBegin_; }

References fileIter_, and fileIterBegin_.

Referenced by edm::RootEmbeddedFileSequence::readOneSequential(), edm::RootPrimaryFileSequence::rewind_(), edm::RootEmbeddedFileSequence::RootEmbeddedFileSequence(), edm::RootPrimaryFileSequence::RootPrimaryFileSequence(), edm::RootSecondaryFileSequence::RootSecondaryFileSequence(), and edm::RootEmbeddedFileSequence::skipEntries().

◆ setAtNextFile()

void edm::RootInputFileSequence::setAtNextFile ( )

inlineprotected

Definition at line 73 of file RootInputFileSequence.h.

73 { ++fileIter_; }

References fileIter_.

Referenced by edm::RootPrimaryFileSequence::nextFile(), edm::RootEmbeddedFileSequence::readOneSequential(), edm::RootPrimaryFileSequence::RootPrimaryFileSequence(), edm::RootSecondaryFileSequence::RootSecondaryFileSequence(), and edm::RootEmbeddedFileSequence::skipEntries().

◆ setAtPreviousFile()

void edm::RootInputFileSequence::setAtPreviousFile ( )

inlineprotected

Definition at line 74 of file RootInputFileSequence.h.

74 { --fileIter_; }

References fileIter_.

Referenced by edm::RootPrimaryFileSequence::previousFile().

◆ setIndexIntoFile()

void edm::RootInputFileSequence::setIndexIntoFile ( size_t index )

protected

Definition at line 275 of file RootInputFileSequence.cc.

                                                            {
     indexesIntoFiles_[index] = rootFile()->indexIntoFileSharedPtr();
   }

References indexesIntoFiles_, and rootFile().

Referenced by initTheFile().

◆ setNoMoreFiles()

void edm::RootInputFileSequence::setNoMoreFiles ( )

inlineprotected

Definition at line 72 of file RootInputFileSequence.h.

72 { fileIter_ = fileIterEnd_; }

References fileIter_, and fileIterEnd_.

Referenced by edm::RootPrimaryFileSequence::skipEvents().

◆ skipToItem()

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

Definition at line 150 of file RootInputFileSequence.cc.

                                                                                                                       {
     // Attempt to find item in currently open input file.
     bool found = currentFileFirst && rootFile() && rootFile()->setEntryAtItem(run, lumi, event);
     if (!found) {
       // If only one input file, give up now, to save time.
       if (currentFileFirst && 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(run, lumi, event)) {
           // We found it. Close the currently open file, and open the correct one.
           std::vector<FileCatalogItem>::const_iterator currentIter = fileIter_;
           setAtFileSequenceNumber(it - indexesIntoFiles_.begin());
           if (fileIter_ != currentIter) {
             initFile(false);
           }
           // Now get the item from the correct file.
           assert(rootFile());
           found = rootFile()->setEntryAtItem(run, lumi, event);
           assert(found);
           return true;
         }
       }
       return (fileNameHash != 0U && skipToItemInNewFile(run, lumi, event, fileNameHash)) ||
              skipToItemInNewFile(run, lumi, event);
     }
     return true;
   }

References cms::cuda::assert(), fileIter_, newFWLiteAna::found, indexesIntoFiles_, initFile(), rootFile(), writedatasetfile::run, setAtFileSequenceNumber(), skipToItemInNewFile(), and mitigatedMETSequence_cff::U.

Referenced by edm::RootEmbeddedFileSequence::readOneRandomWithID(), edm::RootEmbeddedFileSequence::readOneSequentialWithID(), and edm::RootEmbeddedFileSequence::readOneSpecified().

◆ skipToItemInNewFile() [1/2]

bool edm::RootInputFileSequence::skipToItemInNewFile	(	RunNumber_t	run,
		LuminosityBlockNumber_t	lumi,
		EventNumber_t	event
	)

protected

Definition at line 132 of file RootInputFileSequence.cc.

                                                                                                                     {
     // Look for item in files not yet opened.  We do not have a valid hash of the logical file name.
     for (auto it = indexesIntoFiles_.begin(), itEnd = indexesIntoFiles_.end(); it != itEnd; ++it) {
       if (!*it) {
         // File not yet opened.
         setAtFileSequenceNumber(it - indexesIntoFiles_.begin());
         initFile_(false);
         assert(rootFile());
         bool found = rootFile()->setEntryAtItem(run, lumi, event);
         if (found) {
           return true;
         }
       }
     }
     // Not found
     return false;
   }

References cms::cuda::assert(), newFWLiteAna::found, indexesIntoFiles_, initFile_(), rootFile(), writedatasetfile::run, and setAtFileSequenceNumber().

Referenced by edm::RootEmbeddedFileSequence::readOneSequentialWithID(), and skipToItem().

◆ skipToItemInNewFile() [2/2]

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

protected

Definition at line 97 of file RootInputFileSequence.cc.

                                                                        {
     // Look for item in files not yet opened. We have a hash of the logical file name
     assert(fileNameHash != 0U);
     // If the lookup table is not yet filled in, fill it.
     if (!findFileForSpecifiedID_) {
       // We use a multimap because there may be hash collisions (Two different LFNs could have the same hash).
       // We map the hash of the LFN to the index into the list of files.
       findFileForSpecifiedID_ =
           std::make_unique<std::unordered_multimap<size_t, size_t>>();  // propagate_const<T> has no reset() function
       auto hasher = std::hash<std::string>();
       for (auto fileIter = fileIterBegin_; fileIter != fileIterEnd_; ++fileIter) {
         findFileForSpecifiedID_->insert(std::make_pair(hasher(fileIter->logicalFileName()), fileIter - fileIterBegin_));
       }
     }
     // Look up the logical file name in the table
     auto range = findFileForSpecifiedID_->equal_range(fileNameHash);
     for (auto iter = range.first; iter != range.second; ++iter) {
       // Don't look in files previously opened, because those have already been searched.
       if (!indexesIntoFiles_[iter->second]) {
         setAtFileSequenceNumber(iter->second);
         initFile_(false);
         assert(rootFile());
         bool found = rootFile()->setEntryAtItem(run, lumi, event);
         if (found) {
           return true;
         }
       }
     }
     // Not found
     return false;
   }

References cms::cuda::assert(), fileIterBegin_, fileIterEnd_, findFileForSpecifiedID_, newFWLiteAna::found, visDQMUpload::hasher, indexesIntoFiles_, initFile_(), FastTimerService_cff::range, rootFile(), writedatasetfile::run, setAtFileSequenceNumber(), and mitigatedMETSequence_cff::U.

◆ usedFallback()

bool edm::RootInputFileSequence::usedFallback ( ) const

inlineprotected

Definition at line 85 of file RootInputFileSequence.h.

85 { return usedFallback_; }

References usedFallback_.

Referenced by edm::RootPrimaryFileSequence::closeFile_().

Member Data Documentation

◆ catalog_

InputFileCatalog const& edm::RootInputFileSequence::catalog_

private

Definition at line 91 of file RootInputFileSequence.h.

Referenced by fileCatalogItems().

◆ fileIter_

std::vector<FileCatalogItem>::const_iterator edm::RootInputFileSequence::fileIter_

private

Definition at line 98 of file RootInputFileSequence.h.

Referenced by atFirstFile(), atLastFile(), fileNames(), initTheFile(), logicalFileName(), noMoreFiles(), sequenceNumberOfFile(), setAtFileSequenceNumber(), setAtFirstFile(), setAtNextFile(), setAtPreviousFile(), setNoMoreFiles(), and skipToItem().

◆ fileIterBegin_

const std::vector<FileCatalogItem>::const_iterator edm::RootInputFileSequence::fileIterBegin_

private

Definition at line 96 of file RootInputFileSequence.h.

Referenced by atFirstFile(), initTheFile(), noFiles(), numberOfFiles(), sequenceNumberOfFile(), setAtFileSequenceNumber(), setAtFirstFile(), and skipToItemInNewFile().

◆ fileIterEnd_

const std::vector<FileCatalogItem>::const_iterator edm::RootInputFileSequence::fileIterEnd_

private

Definition at line 97 of file RootInputFileSequence.h.

Referenced by atLastFile(), initTheFile(), noFiles(), noMoreFiles(), numberOfFiles(), setNoMoreFiles(), and skipToItemInNewFile().

◆ fileIterLastOpened_

std::vector<FileCatalogItem>::const_iterator edm::RootInputFileSequence::fileIterLastOpened_

private

Definition at line 99 of file RootInputFileSequence.h.

Referenced by initTheFile().

◆ findFileForSpecifiedID_

edm::propagate_const<std::unique_ptr<std::unordered_multimap<size_t, size_t> > > edm::RootInputFileSequence::findFileForSpecifiedID_

private

Definition at line 95 of file RootInputFileSequence.h.

Referenced by skipToItemInNewFile().

◆ indexesIntoFiles_

std::vector<std::shared_ptr<IndexIntoFile> > edm::RootInputFileSequence::indexesIntoFiles_

private

Definition at line 101 of file RootInputFileSequence.h.

Referenced by indexesIntoFiles(), initTheFile(), setIndexIntoFile(), skipToItem(), and skipToItemInNewFile().

◆ lfn_

std::string edm::RootInputFileSequence::lfn_

private

Definition at line 92 of file RootInputFileSequence.h.

Referenced by initTheFile(), and lfn().

◆ lfnHash_

size_t edm::RootInputFileSequence::lfnHash_

private

Definition at line 93 of file RootInputFileSequence.h.

Referenced by initTheFile(), and lfnHash().

◆ rootFile_

edm::propagate_const<RootFileSharedPtr> edm::RootInputFileSequence::rootFile_

private

Definition at line 100 of file RootInputFileSequence.h.

Referenced by initTheFile(), and rootFile().

◆ usedFallback_

bool edm::RootInputFileSequence::usedFallback_

private

Definition at line 94 of file RootInputFileSequence.h.

Referenced by usedFallback().

Public Member Functions

Protected Types

Protected Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ RootFileSharedPtr

Constructor & Destructor Documentation

◆ RootInputFileSequence() [1/2]

◆ ~RootInputFileSequence()

◆ RootInputFileSequence() [2/2]

Member Function Documentation

◆ atFirstFile()

◆ atLastFile()

◆ closeFile_()

◆ containedInCurrentFile()

◆ fileBranchIDListHelper()

◆ fileCatalogItems()

◆ fileNames()

◆ fileProductRegistry()

◆ indexesIntoFiles()

◆ initFile()

◆ initFile_()

◆ initTheFile()

◆ lfn()

◆ lfnHash()

◆ logicalFileName()

◆ makeRootFile()

◆ noFiles()

◆ noMoreFiles()

◆ numberOfFiles()

◆ operator=()

◆ readEvent()

◆ readLuminosityBlock_()

◆ readLuminosityBlockAuxiliary_()

◆ readRun_()

◆ readRunAuxiliary_()

◆ rootFile() [1/2]

◆ rootFile() [2/2]

◆ sequenceNumberOfFile()

◆ setAtFileSequenceNumber()

◆ setAtFirstFile()

◆ setAtNextFile()

◆ setAtPreviousFile()

◆ setIndexIntoFile()

◆ setNoMoreFiles()

◆ skipToItem()

◆ skipToItemInNewFile() [1/2]

◆ skipToItemInNewFile() [2/2]

◆ usedFallback()

Member Data Documentation

◆ catalog_

◆ fileIter_

◆ fileIterBegin_

◆ fileIterEnd_

◆ fileIterLastOpened_

◆ findFileForSpecifiedID_

◆ indexesIntoFiles_

◆ lfn_

◆ lfnHash_

◆ rootFile_

◆ usedFallback_