#include <RootPrimaryFileSequence.h>

Inheritance diagram for edm::RootPrimaryFileSequence:

Public Types
typedef std::shared_ptr< RootFile >	RootFileSharedPtr

Public Member Functions
virtual 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, unsigned int nStreams)

	RootPrimaryFileSequence (RootPrimaryFileSequence const &)=delete

bool	skipEvents (int offset)

virtual	~RootPrimaryFileSequence ()

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

virtual 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_

bool	bypassVersionCheck_

bool	dropDescendants_

std::shared_ptr< DuplicateChecker >	duplicateChecker_

bool	enablePrefetching_

std::shared_ptr< EventSkipperByID >	eventSkipperByID_

bool	firstFile_

int	initialNumberOfEventsToSkip_

PoolSource &	input_

bool	labelRawDataLikeMC_

bool	noEventSort_

unsigned int	nStreams_

std::vector< ProcessHistoryID >	orderedProcessHistoryIDs_

ProductSelectorRules	productSelectorRules_

RunNumber_t	setRun_

bool	skipBadFiles_

unsigned int	treeCacheSize_

int const	treeMaxVirtualSize_

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::string const &	fallbackFileName () const

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

std::string const &	fileName () 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

RootFileSharedPtr const &	rootFile () const

RootFileSharedPtr &	rootFile ()

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 33 of file RootPrimaryFileSequence.h.

Member Typedef Documentation

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

Definition at line 44 of file RootPrimaryFileSequence.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 21 of file RootPrimaryFileSequence.cc.

References StorageFactory::activateTimeout(), branchesMustMatch_, enablePrefetching_, edm::RootInputFileSequence::fileName(), StorageFactory::get(), edm::ParameterSet::getUntrackedParameter(), edm::RootInputFileSequence::initFile(), initialNumberOfEventsToSkip_, input_, edm::Service< T >::isAvailable(), edm::RootInputFileSequence::noMoreFiles(), edm::InputSource::productRegistryUpdate(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtFirstFile(), edm::RootInputFileSequence::setAtNextFile(), skipBadFiles_, skipEvents(), StorageFactory::stagein(), edm::BranchDescription::Strict, AlCaHLTBitMon_QueryRunRegistry::string, treeCacheSize_, and edm::ProductRegistry::updateFromInput().

                                        :
     RootInputFileSequence(pset, catalog),
     input_(input),
     firstFile_(true),
     branchesMustMatch_(BranchDescription::Permissive),
     orderedProcessHistoryIDs_(),
     nStreams_(nStreams),
     eventSkipperByID_(EventSkipperByID::create(pset).release()),
     // 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)),
     noEventSort_(pset.getUntrackedParameter<bool>("noEventSort", true)),
     skipBadFiles_(pset.getUntrackedParameter<bool>("skipBadFiles", false)),
     bypassVersionCheck_(pset.getUntrackedParameter<bool>("bypassVersionCheck", false)),
     treeCacheSize_(noEventSort_ ? pset.getUntrackedParameter<unsigned int>("cacheSize", roottree::defaultCacheSize) : 0U),
     treeMaxVirtualSize_(pset.getUntrackedParameter<int>("treeMaxVirtualSize", -1)),
     setRun_(pset.getUntrackedParameter<unsigned int>("setRunNumber", 0U)),
     productSelectorRules_(pset, "inputCommands", "InputSource"),
     duplicateChecker_(new DuplicateChecker(pset)),
     dropDescendants_(pset.getUntrackedParameter<bool>("dropDescendantsOfDroppedBranches", true)),
     labelRawDataLikeMC_(pset.getUntrackedParameter<bool>("labelRawDataLikeMC", true)),
     usingGoToEvent_(false),
     enablePrefetching_(false) {
 
     // 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;
 
     StorageFactory *factory = StorageFactory::get();
 
     // Prestage the files
     for (setAtFirstFile(); !noMoreFiles(); setAtNextFile()) {
       factory->activateTimeout(fileName());
       factory->stagein(fileName());
     }
     // Open the first file.
     for (setAtFirstFile(); !noMoreFiles(); setAtNextFile()) {
       initFile(skipBadFiles_);
       if(rootFile()) break;
     }
     if(rootFile()) {
       input_.productRegistryUpdate().updateFromInput(rootFile()->productRegistry()->productList());
       if(initialNumberOfEventsToSkip_ != 0) {
         skipEvents(initialNumberOfEventsToSkip_);
       }
     }
   }

edm::RootPrimaryFileSequence::~RootPrimaryFileSequence ( )

virtual

Definition at line 86 of file RootPrimaryFileSequence.cc.

86 {

87 }

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

delete

Member Function Documentation

void edm::RootPrimaryFileSequence::closeFile_ ( )

overridevirtual

Implements edm::RootInputFileSequence.

Definition at line 114 of file RootPrimaryFileSequence.cc.

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

Referenced by endJob(), and rewind_().

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

void edm::RootPrimaryFileSequence::endJob ( void )

Definition at line 90 of file RootPrimaryFileSequence.cc.

References closeFile_().

                                   {
     closeFile_();
   }

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

static

Definition at line 343 of file RootPrimaryFileSequence.cc.

References edm::ParameterSetDescription::addUntracked(), edm::roottree::defaultCacheSize, edm::EventSkipperByID::fillDescription(), edm::ProductSelectorRules::fillDescription(), edm::DuplicateChecker::fillDescription(), and AlCaHLTBitMon_QueryRunRegistry::string.

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

                                                                          {
     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<bool>("skipBadFiles", false)
         ->setComment("True:  Ignore any missing or unopenable input file.\n"
                      "False: Throw exception if missing or unopenable input file.");
     desc.addUntracked<bool>("bypassVersionCheck", false)
         ->setComment("True:  Bypass release version check.\n"
                      "False: Throw exception if reading file in a release prior to the release in which the file was written.");
     desc.addUntracked<unsigned int>("cacheSize", roottree::defaultCacheSize)
         ->setComment("Size of ROOT TTree prefetch cache.  Affects performance.");
     desc.addUntracked<int>("treeMaxVirtualSize", -1)
         ->setComment("Size of ROOT TTree TBasket cache.  Affects performance.");
     desc.addUntracked<unsigned int>("setRunNumber", 0U)
         ->setComment("If non-zero, change number of first run to this number. Apply same offset to all runs.  Allowed only for simulation.");
     desc.addUntracked<bool>("dropDescendantsOfDroppedBranches", true)
         ->setComment("If True, also drop on input any descendent of any branch dropped on input.");
     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>("labelRawDataLikeMC", true)
         ->setComment("If True: replace module label for raw data to match MC. Also use 'LHC' as process.");
 
     ProductSelectorRules::fillDescription(desc, "inputCommands");
     EventSkipperByID::fillDescription(desc);
     DuplicateChecker::fillDescription(desc);
   }

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

Definition at line 379 of file RootPrimaryFileSequence.cc.

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

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

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

Definition at line 211 of file RootPrimaryFileSequence.cc.

References 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(), and edm::RootInputFileSequence::rootFile().

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

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

Definition at line 278 of file RootPrimaryFileSequence.cc.

References assert(), begin, 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_.

                                                            {
     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.
       typedef std::vector<std::shared_ptr<IndexIntoFile> >::const_iterator Iter;
       for(Iter 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(Iter 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;
   }

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

overrideprivatevirtual

Implements edm::RootInputFileSequence.

Definition at line 126 of file RootPrimaryFileSequence.cc.

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

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

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

overrideprivatevirtual

Implements edm::RootInputFileSequence.

Definition at line 135 of file RootPrimaryFileSequence.cc.

References edm::InputSource::branchIDListHelper(), bypassVersionCheck_, dropDescendants_, duplicateChecker_, enablePrefetching_, eventSkipperByID_, edm::RootInputFileSequence::fileName(), edm::RootInputFileSequence::indexesIntoFiles(), initialNumberOfEventsToSkip_, input_, labelRawDataLikeMC_, edm::RootInputFileSequence::logicalFileName(), noEventSort_, nStreams_, orderedProcessHistoryIDs_, edm::Primary, edm::InputSource::processConfiguration(), edm::InputSource::processHistoryRegistryForUpdate(), edm::InputSource::processingMode(), productSelectorRules_, remainingEvents(), remainingLuminosityBlocks(), edm::RootInputFileSequence::sequenceNumberOfFile(), setRun_, edm::InputSource::thinnedAssociationsHelper(), treeCacheSize_, treeMaxVirtualSize_, and usingGoToEvent_.

                                                                         {
       size_t currentIndexIntoFile = sequenceNumberOfFile();
       return std::make_shared<RootFile>(
           fileName(),
           input_.processConfiguration(),
           logicalFileName(),
           filePtr,
           eventSkipperByID_,
           initialNumberOfEventsToSkip_ != 0,
           remainingEvents(),
           remainingLuminosityBlocks(),
       nStreams_,
           treeCacheSize_,
           treeMaxVirtualSize_,
           input_.processingMode(),
           setRun_,
           noEventSort_,
           productSelectorRules_,
           InputType::Primary,
           input_.branchIDListHelper(),
           input_.thinnedAssociationsHelper(),
           std::vector<BranchID>(), // associationsFromSecondary_
           duplicateChecker_,
           dropDescendants_,
           input_.processHistoryRegistryForUpdate(),
           indexesIntoFiles(),
           currentIndexIntoFile,
           orderedProcessHistoryIDs_,
           bypassVersionCheck_,
           labelRawDataLikeMC_,
           usingGoToEvent_,
           enablePrefetching_);
   }

bool edm::RootPrimaryFileSequence::nextFile ( )

private

Definition at line 169 of file RootPrimaryFileSequence.cc.

References branchesMustMatch_, Exception, edm::RootInputFileSequence::fileName(), edm::RootInputFileSequence::initFile(), input_, edm::ProductRegistry::merge(), edm::errors::MismatchedInputFiles, edm::RootInputFileSequence::noMoreFiles(), edm::InputSource::productRegistryUpdate(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtNextFile(), skipBadFiles_, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by readFile_(), and skipEvents().

                                          {
     if(!noMoreFiles()) setAtNextFile();
     if(noMoreFiles()) {
       return false;
     }
 
     initFile(skipBadFiles_);
 
     if(rootFile()) {
       // make sure the new product registry is compatible with the main one
       std::string mergeInfo = input_.productRegistryUpdate().merge(*rootFile()->productRegistry(),
                                                                    fileName(),
                                                                    branchesMustMatch_);
       if(!mergeInfo.empty()) {
         throw Exception(errors::MismatchedInputFiles,"RootPrimaryFileSequence::nextFile()") << mergeInfo;
       }
     }
     return true;
   }

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

delete

bool edm::RootPrimaryFileSequence::previousFile ( )

private

Definition at line 189 of file RootPrimaryFileSequence.cc.

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

Referenced by skipEvents().

                                              {
     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(),
                                                                    fileName(),
                                                                    branchesMustMatch_);
       if(!mergeInfo.empty()) {
         throw Exception(errors::MismatchedInputFiles,"RootPrimaryFileSequence::previousEvent()") << mergeInfo;
       }
     }
     if(rootFile()) rootFile()->setToLastEntry();
     return true;
   }

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

Definition at line 95 of file RootPrimaryFileSequence.cc.

References assert(), firstFile_, edm::RootInputFileSequence::initFile(), nextFile(), edm::RootInputFileSequence::rootFile(), and skipBadFiles_.

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

int edm::RootPrimaryFileSequence::remainingEvents ( ) const

private

Definition at line 333 of file RootPrimaryFileSequence.cc.

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

Referenced by makeRootFile().

                                                  {
     return input_.remainingEvents();
   }

int edm::RootPrimaryFileSequence::remainingLuminosityBlocks ( ) const

private

Definition at line 338 of file RootPrimaryFileSequence.cc.

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

Referenced by makeRootFile().

                                                            {
     return input_.remainingLuminosityBlocks();
   }

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

Definition at line 394 of file RootPrimaryFileSequence.cc.

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

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

void edm::RootPrimaryFileSequence::rewind_ ( )

Definition at line 237 of file RootPrimaryFileSequence.cc.

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

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

void edm::RootPrimaryFileSequence::rewindFile ( )

private

Definition at line 256 of file RootPrimaryFileSequence.cc.

References edm::RootInputFileSequence::rootFile().

Referenced by rewind_().

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

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

Definition at line 262 of file RootPrimaryFileSequence.cc.

References assert(), nextFile(), previousFile(), edm::RootInputFileSequence::rootFile(), and edm::RootInputFileSequence::setNoMoreFiles().

Referenced by rewind_(), and RootPrimaryFileSequence().

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

Member Data Documentation

BranchDescription::MatchMode edm::RootPrimaryFileSequence::branchesMustMatch_

private

Definition at line 67 of file RootPrimaryFileSequence.h.

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

bool edm::RootPrimaryFileSequence::bypassVersionCheck_

private

Definition at line 75 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

bool edm::RootPrimaryFileSequence::dropDescendants_

private

Definition at line 81 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

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

private

Definition at line 80 of file RootPrimaryFileSequence.h.

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

bool edm::RootPrimaryFileSequence::enablePrefetching_

private

Definition at line 84 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile(), and RootPrimaryFileSequence().

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

private

Definition at line 71 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

bool edm::RootPrimaryFileSequence::firstFile_

private

Definition at line 66 of file RootPrimaryFileSequence.h.

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

int edm::RootPrimaryFileSequence::initialNumberOfEventsToSkip_

private

Definition at line 72 of file RootPrimaryFileSequence.h.

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

PoolSource& edm::RootPrimaryFileSequence::input_

private

Definition at line 65 of file RootPrimaryFileSequence.h.

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

bool edm::RootPrimaryFileSequence::labelRawDataLikeMC_

private

Definition at line 82 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

bool edm::RootPrimaryFileSequence::noEventSort_

private

Definition at line 73 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

unsigned int edm::RootPrimaryFileSequence::nStreams_

private

Definition at line 70 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

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

private

Definition at line 68 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

ProductSelectorRules edm::RootPrimaryFileSequence::productSelectorRules_

private

Definition at line 79 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

RunNumber_t edm::RootPrimaryFileSequence::setRun_

private

Definition at line 78 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

bool edm::RootPrimaryFileSequence::skipBadFiles_

private

Definition at line 74 of file RootPrimaryFileSequence.h.

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

unsigned int edm::RootPrimaryFileSequence::treeCacheSize_

private

Definition at line 76 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile(), and RootPrimaryFileSequence().

int const edm::RootPrimaryFileSequence::treeMaxVirtualSize_

private

Definition at line 77 of file RootPrimaryFileSequence.h.

Referenced by makeRootFile().

bool edm::RootPrimaryFileSequence::usingGoToEvent_

private

Definition at line 83 of file RootPrimaryFileSequence.h.

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

Public Types

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation