#include <EmbeddedRootSource.h>

Inheritance diagram for edm::EmbeddedRootSource:

Public Member Functions
bool	bypassVersionCheck () const

	EmbeddedRootSource (ParameterSet const &pset, VectorInputSourceDescription const &desc)

unsigned int	nStreams () const

ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()

ProductRegistry &	productRegistryUpdate ()

ProductSelectorRules const &	productSelectorRules () const

RunHelperBase *	runHelper ()

bool	skipBadFiles () const

int	treeMaxVirtualSize () const

	~EmbeddedRootSource () override

Public Member Functions inherited from edm::VectorInputSource
void	doBeginJob ()
	Called at beginning of job. More...

void	doEndJob ()
	Called at end of job. More...

void	dropUnwantedBranches (std::vector< std::string > const &wantedBranches)

template<typename T >
size_t	loopOverEvents (EventPrincipal &cache, size_t &fileNameHash, size_t number, T eventOperator, CLHEP::HepRandomEngine =nullptr, EventID const id=nullptr, bool recycleFiles=true)

template<typename T , typename Iterator >
size_t	loopSpecified (EventPrincipal &cache, size_t &fileNameHash, Iterator const &begin, Iterator const &end, T eventOperator)

ProcessHistoryRegistry const &	processHistoryRegistry () const

ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()

std::shared_ptr< ProductRegistry const >	productRegistry () const

std::shared_ptr< ProductRegistry > &	productRegistry ()

ProductRegistry &	productRegistryUpdate ()

	VectorInputSource (ParameterSet const &pset, VectorInputSourceDescription const &desc)

virtual	~VectorInputSource ()

Static Public Member Functions
static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Private Member Functions
void	beginJob () override

virtual void	closeFile_ ()

void	dropUnwantedBranches_ (std::vector< std::string > const &wantedBranches) override

void	endJob () override

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

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

Private Attributes
bool	bypassVersionCheck_

InputFileCatalog	catalog_

edm::propagate_const< std::unique_ptr< RootEmbeddedFileSequence > >	fileSequence_

unsigned int	nStreams_

ProductSelectorRules	productSelectorRules_

RootServiceChecker	rootServiceChecker_

std::unique_ptr< RunHelperBase >	runHelper_

bool	skipBadFiles_

int const	treeMaxVirtualSize_

Detailed Description

Definition at line 34 of file EmbeddedRootSource.h.

Constructor & Destructor Documentation

◆ EmbeddedRootSource()

edm::EmbeddedRootSource::EmbeddedRootSource	(	ParameterSet const &	pset,
		VectorInputSourceDescription const &	desc
	)

explicit

Definition at line 16 of file EmbeddedRootSource.cc.

       : VectorInputSource(pset, desc),
         rootServiceChecker_(),
         nStreams_(desc.allocations_->numberOfStreams()),
         // 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)),
         productSelectorRules_(pset, "inputCommands", "InputSource"),
         runHelper_(new DefaultRunHelper()),
         catalog_(pset.getUntrackedParameter<std::vector<std::string> >("fileNames"),
                  pset.getUntrackedParameter<std::string>("overrideCatalog", std::string())),
         // Note: fileSequence_ needs to be initialized last, because it uses data members
         // initialized previously in its own initialization.
         fileSequence_(new RootEmbeddedFileSequence(pset, *this, catalog_)) {}

◆ ~EmbeddedRootSource()

edm::EmbeddedRootSource::~EmbeddedRootSource ( )

override

Definition at line 39 of file EmbeddedRootSource.cc.

39 {}

Member Function Documentation

◆ beginJob()

void edm::EmbeddedRootSource::beginJob ( void )

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 41 of file EmbeddedRootSource.cc.

41 {}

◆ bypassVersionCheck()

bool edm::EmbeddedRootSource::bypassVersionCheck ( ) const

inline

Definition at line 43 of file EmbeddedRootSource.h.

References bypassVersionCheck_.

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

43 { return bypassVersionCheck_; }

edm::EmbeddedRootSource::bypassVersionCheck_

bool bypassVersionCheck_

Definition: EmbeddedRootSource.h:67

◆ closeFile_()

void edm::EmbeddedRootSource::closeFile_ ( )

privatevirtual

Definition at line 48 of file EmbeddedRootSource.cc.

References fileSequence_.

48 { fileSequence_->closeFile(); }

edm::EmbeddedRootSource::fileSequence_

edm::propagate_const< std::unique_ptr< RootEmbeddedFileSequence > > fileSequence_

Definition: EmbeddedRootSource.h:73

◆ dropUnwantedBranches_()

void edm::EmbeddedRootSource::dropUnwantedBranches_ ( std::vector< std::string > const & wantedBranches )

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 64 of file EmbeddedRootSource.cc.

References MicroEventContent_cff::branch, productSelectorRules_, muonDTDigis_cfi::pset, cmsCodeRulesChecker::rules, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                            {
     std::vector<std::string> rules;
     rules.reserve(wantedBranches.size() + 1);
     rules.emplace_back("drop *");
     for (std::string const& branch : wantedBranches) {
       rules.push_back("keep " + branch + "_*");
     }
     ParameterSet pset;
     pset.addUntrackedParameter("inputCommands", rules);
     productSelectorRules_ = ProductSelectorRules(pset, "inputCommands", "InputSource");
   }

◆ endJob()

void edm::EmbeddedRootSource::endJob ( void )

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 43 of file EmbeddedRootSource.cc.

References fileSequence_, and edm::InputFile::reportReadBranches().

                                   {
     fileSequence_->endJob();
     InputFile::reportReadBranches();
   }

◆ fillDescriptions()

void edm::EmbeddedRootSource::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 76 of file EmbeddedRootSource.cc.

References edm::ConfigurationDescriptions::add(), submitPVResolutionJobs::desc, edm::ProductSelectorRules::fillDescription(), edm::RootEmbeddedFileSequence::fillDescription(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                    {
     ParameterSetDescription desc;
 
     std::vector<std::string> defaultStrings;
     desc.setComment("Reads EDM/Root files for mixing.");
     desc.addUntracked<std::vector<std::string> >("fileNames")->setComment("Names of files to be processed.");
     desc.addUntracked<std::string>("overrideCatalog", std::string());
     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<int>("treeMaxVirtualSize", -1)
         ->setComment("Size of ROOT TTree TBasket cache.  Affects performance.");
 
     ProductSelectorRules::fillDescription(desc, "inputCommands");
     RootEmbeddedFileSequence::fillDescription(desc);
 
     descriptions.add("source", desc);
   }

◆ nStreams()

unsigned int edm::EmbeddedRootSource::nStreams ( ) const

inline

Definition at line 44 of file EmbeddedRootSource.h.

References nStreams_.

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

44 { return nStreams_; }

edm::EmbeddedRootSource::nStreams_

unsigned int nStreams_

Definition: EmbeddedRootSource.h:65

◆ processHistoryRegistryForUpdate()

ProcessHistoryRegistry& edm::VectorInputSource::processHistoryRegistryForUpdate

inline

Definition at line 57 of file VectorInputSource.h.

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

57 { return *processHistoryRegistry_; }

edm::VectorInputSource::processHistoryRegistry_

edm::propagate_const< std::unique_ptr< ProcessHistoryRegistry > > processHistoryRegistry_

Definition: VectorInputSource.h:80

◆ productRegistryUpdate()

ProductRegistry& edm::VectorInputSource::productRegistryUpdate

inline

Definition at line 55 of file VectorInputSource.h.

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

55 { return *productRegistry_; }

edm::VectorInputSource::productRegistry_

edm::propagate_const< std::shared_ptr< ProductRegistry > > productRegistry_

Definition: VectorInputSource.h:79

◆ productSelectorRules()

ProductSelectorRules const& edm::EmbeddedRootSource::productSelectorRules ( ) const

inline

Definition at line 46 of file EmbeddedRootSource.h.

References productSelectorRules_.

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

46 { return productSelectorRules_; }

edm::EmbeddedRootSource::productSelectorRules_

ProductSelectorRules productSelectorRules_

Definition: EmbeddedRootSource.h:69

◆ readOneEvent()

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

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 50 of file EmbeddedRootSource.cc.

References utilities::cache(), and fileSequence_.

                                                            {
     return fileSequence_->readOneEvent(cache, fileNameHash, engine, id, recycleFiles);
   }

◆ readOneSpecified()

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

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 58 of file EmbeddedRootSource.cc.

References utilities::cache(), and fileSequence_.

                                                                                    {
     fileSequence_->readOneSpecified(cache, fileNameHash, id);
   }