#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

ProductSelectorRules const &	productSelectorRules () const

RunHelperBase *	runHelper ()

bool	skipBadFiles () const

int	treeMaxVirtualSize () const

virtual	~EmbeddedRootSource ()

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)

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
virtual void	beginJob () override

virtual void	closeFile_ ()

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

virtual void	endJob () override

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

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

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

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_)) {
   }

edm::EmbeddedRootSource::~EmbeddedRootSource ( )

virtual

Definition at line 40 of file EmbeddedRootSource.cc.

40 {}

Member Function Documentation

void edm::EmbeddedRootSource::beginJob ( void )

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 43 of file EmbeddedRootSource.cc.

43 {

44 }

bool edm::EmbeddedRootSource::bypassVersionCheck ( ) const

inline

Definition at line 43 of file EmbeddedRootSource.h.

References bypassVersionCheck_.

43 {return bypassVersionCheck_;}

edm::EmbeddedRootSource::bypassVersionCheck_

bool bypassVersionCheck_

Definition: EmbeddedRootSource.h:63

void edm::EmbeddedRootSource::closeFile_ ( )

privatevirtual

Definition at line 52 of file EmbeddedRootSource.cc.

References fileSequence_.

                                       {
     fileSequence_->closeFile_();
   }

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

privatevirtual

Implements edm::VectorInputSource.

Definition at line 67 of file EmbeddedRootSource.cc.

References edm::ParameterSet::addUntrackedParameter(), productSelectorRules_, TrackValidation_cff::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");
   }

void edm::EmbeddedRootSource::endJob ( void )

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 47 of file EmbeddedRootSource.cc.

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

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

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

static

Definition at line 80 of file EmbeddedRootSource.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::ProductSelectorRules::fillDescription(), edm::RootEmbeddedFileSequence::fillDescription(), edm::ParameterSetDescription::setComment(), 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);
   }

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

inline

Definition at line 44 of file EmbeddedRootSource.h.

References nStreams_.

44 {return nStreams_;}

edm::EmbeddedRootSource::nStreams_

unsigned int nStreams_

Definition: EmbeddedRootSource.h:61

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

inline

Definition at line 46 of file EmbeddedRootSource.h.

References productSelectorRules_.

46 {return productSelectorRules_;}

edm::EmbeddedRootSource::productSelectorRules_

ProductSelectorRules productSelectorRules_

Definition: EmbeddedRootSource.h:65

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

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 57 of file EmbeddedRootSource.cc.

References fileSequence_.

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

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

privatevirtual

Implements edm::VectorInputSource.

Definition at line 62 of file EmbeddedRootSource.cc.

References fileSequence_.

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