#include <RootSecondaryFileSequence.h>

Inheritance diagram for edm::RootSecondaryFileSequence:

Public Types
typedef std::shared_ptr< RootFile >	RootFileSharedPtr

Public Member Functions
virtual void	closeFile_ () override

void	endJob ()

void	initAssociationsFromSecondary (std::set< BranchID > const &)

RootSecondaryFileSequence &	operator= (RootSecondaryFileSequence const &)=delete

	RootSecondaryFileSequence (ParameterSet const &pset, PoolSource &input, InputFileCatalog const &catalog, unsigned int nStreams)

	RootSecondaryFileSequence (RootSecondaryFileSequence const &)=delete

virtual	~RootSecondaryFileSequence ()

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

Private Attributes
std::vector< BranchID >	associationsFromSecondary_

bool	bypassVersionCheck_

bool	dropDescendants_

bool	enablePrefetching_

bool	firstFile_

PoolSource &	input_

bool	labelRawDataLikeMC_

unsigned int	nStreams_

std::vector< ProcessHistoryID >	orderedProcessHistoryIDs_

ProductSelectorRules	productSelectorRules_

RunNumber_t	setRun_

bool	skipBadFiles_

int const	treeMaxVirtualSize_

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 29 of file RootSecondaryFileSequence.h.

Member Typedef Documentation

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

Definition at line 40 of file RootSecondaryFileSequence.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 21 of file RootSecondaryFileSequence.cc.

References StorageFactory::activateTimeout(), enablePrefetching_, edm::RootInputFileSequence::fileName(), StorageFactory::get(), edm::RootInputFileSequence::initFile(), input_, edm::Service< T >::isAvailable(), edm::RootInputFileSequence::noMoreFiles(), edm::InputSource::productRegistryUpdate(), edm::RootInputFileSequence::rootFile(), edm::RootInputFileSequence::setAtFirstFile(), edm::RootInputFileSequence::setAtNextFile(), skipBadFiles_, StorageFactory::stagein(), and edm::ProductRegistry::updateFromInput().

                                        :
     RootInputFileSequence(pset, catalog),
     input_(input),
     firstFile_(true),
     orderedProcessHistoryIDs_(),
     nStreams_(nStreams),
     // 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.
     skipBadFiles_(pset.getUntrackedParameter<bool>("skipBadFiles", false)),
     bypassVersionCheck_(pset.getUntrackedParameter<bool>("bypassVersionCheck", false)),
     treeMaxVirtualSize_(pset.getUntrackedParameter<int>("treeMaxVirtualSize", -1)),
     setRun_(pset.getUntrackedParameter<unsigned int>("setRunNumber", 0U)),
     productSelectorRules_(pset, "inputCommands", "InputSource"),
     dropDescendants_(pset.getUntrackedParameter<bool>("dropDescendantsOfDroppedBranches", true)),
     labelRawDataLikeMC_(pset.getUntrackedParameter<bool>("labelRawDataLikeMC", true)),
     enablePrefetching_(false) {
 
     // The SiteLocalConfig controls the TTreeCache size and the prefetching settings.
     Service<SiteLocalConfig> pSLC;
     if(pSLC.isAvailable()) {
       enablePrefetching_ = pSLC->enablePrefetching();
     }
 
     StorageFactory *factory = StorageFactory::get();
 
     // Prestage the files
     //NOTE: we do not want to stage in all secondary files since we can be given a list of
     // thousands of files and prestaging all those files can cause a site to fail.
     // So, we stage in the first secondary file only.
     setAtFirstFile();
     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());
     }
   }

edm::RootSecondaryFileSequence::~RootSecondaryFileSequence ( )

virtual

Definition at line 73 of file RootSecondaryFileSequence.cc.

73 {

74 }

edm::RootSecondaryFileSequence::RootSecondaryFileSequence ( RootSecondaryFileSequence const & )

delete

Member Function Documentation

void edm::RootSecondaryFileSequence::closeFile_ ( )

overridevirtual

Implements edm::RootInputFileSequence.

Definition at line 82 of file RootSecondaryFileSequence.cc.

References edm::RootInputFileSequence::rootFile().

Referenced by endJob().

                                         {
     // close the currently open file, if any, and delete the RootFile object.
     if(rootFile()) {
       rootFile()->close();
       rootFile().reset();
     }
   }

void edm::RootSecondaryFileSequence::endJob ( void )

Definition at line 77 of file RootSecondaryFileSequence.cc.

References closeFile_().

                                     {
     closeFile_();
   }

static void edm::RootSecondaryFileSequence::fillDescription ( ParameterSetDescription & desc )

static

void edm::RootSecondaryFileSequence::initAssociationsFromSecondary ( std::set< BranchID > const & associationsFromSecondary )

Definition at line 130 of file RootSecondaryFileSequence.cc.

References associationsFromSecondary_, and edm::RootInputFileSequence::rootFile().

                                                                                                             {
     for(auto const& branchID : associationsFromSecondary) {
       associationsFromSecondary_.push_back(branchID);
     }
     rootFile()->initAssociationsFromSecondary(associationsFromSecondary_);
   }

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

overrideprivatevirtual

Implements edm::RootInputFileSequence.

Definition at line 90 of file RootSecondaryFileSequence.cc.

References edm::RootInputFileSequence::initTheFile(), and edm::SecondaryFile.

                                                              {
     initTheFile(skipBadFiles, false, nullptr, "secondaryFiles", InputType::SecondaryFile);
   }

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

overrideprivatevirtual

Implements edm::RootInputFileSequence.

Definition at line 95 of file RootSecondaryFileSequence.cc.

References associationsFromSecondary_, edm::InputSource::branchIDListHelper(), bypassVersionCheck_, dropDescendants_, enablePrefetching_, edm::RootInputFileSequence::fileName(), edm::RootInputFileSequence::indexesIntoFiles(), input_, labelRawDataLikeMC_, edm::RootInputFileSequence::logicalFileName(), nStreams_, orderedProcessHistoryIDs_, edm::InputSource::processConfiguration(), edm::InputSource::processHistoryRegistryForUpdate(), edm::InputSource::processingMode(), productSelectorRules_, edm::SecondaryFile, edm::RootInputFileSequence::sequenceNumberOfFile(), setRun_, edm::InputSource::thinnedAssociationsHelper(), and treeMaxVirtualSize_.

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