#include <PoolOutputModule.h>

Inheritance diagram for edm::PoolOutputModule:

Classes
struct	AuxItem

struct	OutputItem

struct	SpecialSplitLevelForBranch

Public Types
typedef std::array< AuxItem, NumBranchTypes >	AuxItemArray

enum	DropMetaData { DropNone, DropDroppedPrior, DropPrior, DropAll }

typedef std::vector< OutputItem >	OutputItemList

typedef std::array< OutputItemList, NumBranchTypes >	OutputItemListArray

Public Types inherited from edm::one::OutputModuleBase
typedef OutputModuleBase	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Public Member Functions
AuxItemArray const &	auxItems () const

std::string const &	basketOrder () const

int const &	basketSize () const

BranchChildren const &	branchChildren () const

std::string const &	catalog () const

std::string const &	compressionAlgorithm () const

int const &	compressionLevel () const

std::string const &	currentFileName () const

DropMetaData const &	dropMetaData () const

int	eventAutoFlushSize () const

std::string const &	fileName () const

int const &	inputFileCount () const

std::string const &	logicalFileName () const

unsigned int const &	maxFileSize () const

std::string const &	moduleLabel () const

PoolOutputModule &	operator= (PoolOutputModule const &)=delete

bool const &	overrideInputFileSplitLevels () const

	PoolOutputModule (ParameterSet const &ps)

	PoolOutputModule (PoolOutputModule const &)=delete

OutputItemListArray &	selectedOutputItemList ()

OutputItemListArray const &	selectedOutputItemList () const

int const &	splitLevel () const

int const &	treeMaxVirtualSize () const

int const &	whyNotFastClonable () const

	~PoolOutputModule () override

Public Member Functions inherited from edm::one::OutputModule< WatchInputFiles >
SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

	OutputModule (edm::ParameterSet const &iPSet)

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

Public Member Functions inherited from edm::one::OutputModuleBase
BranchIDLists const *	branchIDLists ()

std::array< bool, NumBranchTypes > const &	hasNewlyDroppedBranch () const

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleBase &	operator= (OutputModuleBase const &)=delete

	OutputModuleBase (OutputModuleBase const &)=delete

	OutputModuleBase (ParameterSet const &pset)

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

void	selectProducts (ProductRegistry const &preg, ThinnedAssociationsHelper const &)

SharedResourcesAcquirer &	sharedResourcesAcquirer ()

SubProcessParentageHelper const *	subProcessParentageHelper () const

ThinnedAssociationsHelper const *	thinnedAssociationsHelper () const

bool	wantAllEvents () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

	~OutputModuleBase () override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase &&)=default

	EDConsumerBase (EDConsumerBase const &)=delete

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

EDConsumerBase &	operator= (EDConsumerBase &&)=default

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Static Public Member Functions
static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Static Public Member Functions inherited from edm::one::OutputModuleBase
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc, std::vector< std::string > const &iDefaultOutputCommands=ProductSelectorRules::defaultSelectionStrings())

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Protected Member Functions
virtual void	doExtrasAfterCloseFile ()

virtual std::pair< std::string, std::string >	physicalAndLogicalNameForNewFile ()

bool	shouldWeCloseFile () const override
	allow inheriting classes to override but still be able to call this method in the overridden version More...

void	write (EventForOutput const &e) override

Protected Member Functions inherited from edm::one::OutputModuleBase
void	configure (OutputModuleDescription const &desc)

ModuleDescription const &	description () const

void	doBeginJob ()

bool	doBeginLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *)

bool	doBeginRun (RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *)

void	doEndJob ()

bool	doEndLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *)

bool	doEndRun (RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *)

bool	doEvent (EventPrincipal const &ep, EventSetupImpl const &c, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate (PreallocationConfiguration const &)

std::map< BranchID::value_type, BranchID::value_type > const &	droppedBranchIDToKeptBranchID ()

virtual void	preallocLumis (unsigned int)

ParameterSetID	selectorConfig () const

void	setEventSelectionInfo (std::map< std::string, std::vector< std::pair< std::string, int >>> const &outputModulePathPositions, bool anyProductProduced)

Protected Member Functions inherited from edm::EDConsumerBase
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

Private Types
typedef std::map< BranchID, std::set< ParentageID > >	BranchParents

Private Member Functions
void	beginInputFile (FileBlock const &fb)

void	beginJob () override

void	fillDependencyGraph ()

void	fillSelectedItemList (BranchType branchtype, TTree *theInputTree)

void	finishEndFile ()

bool	isFileOpen () const override

void	openFile (FileBlock const &fb) override

void	preActionBeforeRunEventAsync (WaitingTask *iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) const override

void	reallyCloseFile () override

void	reallyOpenFile ()

void	respondToCloseInputFile (FileBlock const &fb) override

void	respondToOpenInputFile (FileBlock const &fb) override

void	setProcessesWithSelectedMergeableRunProducts (std::set< std::string > const &) override

void	startEndFile ()

void	updateBranchParents (EventForOutput const &e)

void	updateBranchParentsForOneBranch (ProductProvenanceRetriever const *provRetriever, BranchID const &branchID)

void	writeBranchIDListRegistry ()

void	writeFileFormatVersion ()

void	writeFileIdentifier ()

void	writeIndexIntoFile ()

void	writeLuminosityBlock (LuminosityBlockForOutput const &lb) override

void	writeParameterSetRegistry ()

void	writeParentageRegistry ()

void	writeProcessHistoryRegistry ()

void	writeProductDependencies ()

void	writeProductDescriptionRegistry ()

void	writeRun (RunForOutput const &r) override

void	writeStoredMergeableRunProductMetadata ()

void	writeThinnedAssociationsHelper ()

Private Attributes
AuxItemArray	auxItems_

std::string	basketOrder_

const int	basketSize_

BranchChildren	branchChildren_

BranchParents	branchParents_

const std::string	catalog_

unsigned int	childIndex_

const std::string	compressionAlgorithm_

const int	compressionLevel_

DropMetaData	dropMetaData_

const int	eventAutoFlushSize_

const std::string	fileName_

bool	initializedFromInput_

int	inputFileCount_

const std::string	logicalFileName_

unsigned const int	maxFileSize_

const std::string	moduleLabel_

unsigned int	numberOfDigitsInIndex_

int	outputFileCount_

bool	overrideInputFileSplitLevels_

std::vector< std::string >	processesWithSelectedMergeableRunProducts_

std::vector< BranchID >	producedBranches_

edm::propagate_const< std::unique_ptr< RootOutputFile > >	rootOutputFile_

RootServiceChecker	rootServiceChecker_

OutputItemListArray	selectedOutputItemList_

std::vector< SpecialSplitLevelForBranch >	specialSplitLevelForBranches_

const int	splitLevel_

std::string	statusFileName_

const int	treeMaxVirtualSize_

int	whyNotFastClonable_

Detailed Description

Definition at line 39 of file PoolOutputModule.h.

Member Typedef Documentation

◆ AuxItemArray

typedef std::array<AuxItem, NumBranchTypes> edm::PoolOutputModule::AuxItemArray

Definition at line 75 of file PoolOutputModule.h.

◆ BranchParents

typedef std::map<BranchID, std::set<ParentageID> > edm::PoolOutputModule::BranchParents

private

Definition at line 162 of file PoolOutputModule.h.

◆ OutputItemList

typedef std::vector<OutputItem> edm::PoolOutputModule::OutputItemList

Definition at line 115 of file PoolOutputModule.h.

◆ OutputItemListArray

typedef std::array<OutputItemList, NumBranchTypes> edm::PoolOutputModule::OutputItemListArray

Definition at line 117 of file PoolOutputModule.h.

Member Enumeration Documentation

◆ DropMetaData

enum edm::PoolOutputModule::DropMetaData

Enumerator
DropNone
DropDroppedPrior
DropPrior
DropAll

Definition at line 41 of file PoolOutputModule.h.

41 { DropNone, DropDroppedPrior, DropPrior, DropAll };

Constructor & Destructor Documentation

◆ PoolOutputModule() [1/2]

edm::PoolOutputModule::PoolOutputModule ( ParameterSet const & ps )

explicit

Definition at line 36 of file PoolOutputModule.cc.

       : edm::one::OutputModuleBase::OutputModuleBase(pset),
         one::OutputModule<WatchInputFiles>(pset),
         rootServiceChecker_(),
         auxItems_(),
         selectedOutputItemList_(),
         fileName_(pset.getUntrackedParameter<std::string>("fileName")),
         logicalFileName_(pset.getUntrackedParameter<std::string>("logicalFileName")),
         catalog_(pset.getUntrackedParameter<std::string>("catalog")),
         maxFileSize_(pset.getUntrackedParameter<int>("maxSize")),
         compressionLevel_(pset.getUntrackedParameter<int>("compressionLevel")),
         compressionAlgorithm_(pset.getUntrackedParameter<std::string>("compressionAlgorithm")),
         basketSize_(pset.getUntrackedParameter<int>("basketSize")),
         eventAutoFlushSize_(pset.getUntrackedParameter<int>("eventAutoFlushCompressedSize")),
         splitLevel_(std::min<int>(pset.getUntrackedParameter<int>("splitLevel") + 1, 99)),
         basketOrder_(pset.getUntrackedParameter<std::string>("sortBaskets")),
         treeMaxVirtualSize_(pset.getUntrackedParameter<int>("treeMaxVirtualSize")),
         whyNotFastClonable_(pset.getUntrackedParameter<bool>("fastCloning") ? FileBlock::CanFastClone
                                                                             : FileBlock::DisabledInConfigFile),
         dropMetaData_(DropNone),
         moduleLabel_(pset.getParameter<std::string>("@module_label")),
         initializedFromInput_(false),
         outputFileCount_(0),
         inputFileCount_(0),
         childIndex_(0U),
         numberOfDigitsInIndex_(0U),
         branchParents_(),
         branchChildren_(),
         overrideInputFileSplitLevels_(pset.getUntrackedParameter<bool>("overrideInputFileSplitLevels")),
         rootOutputFile_(),
         statusFileName_() {
     if (pset.getUntrackedParameter<bool>("writeStatusFile")) {
       std::ostringstream statusfilename;
       statusfilename << moduleLabel_ << '_' << getpid();
       statusFileName_ = statusfilename.str();
     }
  
     std::string dropMetaData(pset.getUntrackedParameter<std::string>("dropMetaData"));
     if (dropMetaData.empty())
       dropMetaData_ = DropNone;
     else if (dropMetaData == std::string("NONE"))
       dropMetaData_ = DropNone;
     else if (dropMetaData == std::string("DROPPED"))
       dropMetaData_ = DropDroppedPrior;
     else if (dropMetaData == std::string("PRIOR"))
       dropMetaData_ = DropPrior;
     else if (dropMetaData == std::string("ALL"))
       dropMetaData_ = DropAll;
     else {
       throw edm::Exception(errors::Configuration, "Illegal dropMetaData parameter value: ")
           << dropMetaData << ".\n"
           << "Legal values are 'NONE', 'DROPPED', 'PRIOR', and 'ALL'.\n";
     }
  
     if (!wantAllEvents()) {
       whyNotFastClonable_ += FileBlock::EventSelectionUsed;
     }
  
     auto const& specialSplit{pset.getUntrackedParameterSetVector("overrideBranchesSplitLevel")};
  
     specialSplitLevelForBranches_.reserve(specialSplit.size());
     for (auto const& s : specialSplit) {
       specialSplitLevelForBranches_.emplace_back(s.getUntrackedParameter<std::string>("branch"),
                                                  s.getUntrackedParameter<int>("splitLevel"));
     }
  
     // We don't use this next parameter, but we read it anyway because it is part
     // of the configuration of this module.  An external parser creates the
     // configuration by reading this source code.
     pset.getUntrackedParameterSet("dataset");
   }

References edm::errors::Configuration, DropAll, DropDroppedPrior, dropMetaData(), dropMetaData_, DropNone, DropPrior, edm::FileBlock::EventSelectionUsed, Exception, moduleLabel_, muonDTDigis_cfi::pset, alignCSCRings::s, specialSplitLevelForBranches_, statusFileName_, AlCaHLTBitMon_QueryRunRegistry::string, edm::one::OutputModuleBase::wantAllEvents(), and whyNotFastClonable_.

◆ ~PoolOutputModule()

edm::PoolOutputModule::~PoolOutputModule ( )

override

Definition at line 269 of file PoolOutputModule.cc.

269 {}

◆ PoolOutputModule() [2/2]

edm::PoolOutputModule::PoolOutputModule ( PoolOutputModule const & )

delete

Member Function Documentation

◆ auxItems()

AuxItemArray const& edm::PoolOutputModule::auxItems ( ) const

inline

Definition at line 76 of file PoolOutputModule.h.

76 { return auxItems_; }

References auxItems_.

◆ basketOrder()

std::string const& edm::PoolOutputModule::basketOrder ( ) const

inline

Definition at line 53 of file PoolOutputModule.h.

53 { return basketOrder_; }

References basketOrder_.

◆ basketSize()

int const& edm::PoolOutputModule::basketSize ( ) const

inline

Definition at line 50 of file PoolOutputModule.h.

50 { return basketSize_; }

References basketSize_.

◆ beginInputFile()

void edm::PoolOutputModule::beginInputFile ( FileBlock const & fb )

private

Definition at line 225 of file PoolOutputModule.cc.

                                                            {
     if (isFileOpen()) {
       //Faster to read ChildrenBranches directly from input
       // file than to build it every event
       auto const& branchToChildMap = fb.branchChildren().childLookup();
       for (auto const& parentToChildren : branchToChildMap) {
         for (auto const& child : parentToChildren.second) {
           branchChildren_.insertChild(parentToChildren.first, child);
         }
       }
       rootOutputFile_->beginInputFile(fb, remainingEvents());
     }
   }

References branchChildren_, benchmark_cfg::fb, edm::BranchChildren::insertChild(), isFileOpen(), edm::one::OutputModuleBase::remainingEvents(), and rootOutputFile_.

Referenced by openFile(), and respondToOpenInputFile().

◆ beginJob()

void edm::PoolOutputModule::beginJob ( void )

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 108 of file PoolOutputModule.cc.

                                   {
     Service<ConstProductRegistry> reg;
     for (auto const& prod : reg->productList()) {
       BranchDescription const& desc = prod.second;
       if (desc.produced() && desc.branchType() == InEvent && !desc.isAlias()) {
         producedBranches_.emplace_back(desc.branchID());
       }
     }
   }

References edm::BranchDescription::branchID(), edm::BranchDescription::branchType(), edm::InEvent, edm::BranchDescription::isAlias(), dumpMFGeometry_cfg::prod, edm::BranchDescription::produced(), and producedBranches_.

◆ branchChildren()

BranchChildren const& edm::PoolOutputModule::branchChildren ( ) const

inline

Definition at line 135 of file PoolOutputModule.h.

135 { return branchChildren_; }

References branchChildren_.

◆ catalog()

std::string const& edm::PoolOutputModule::catalog ( ) const

inline

Definition at line 57 of file PoolOutputModule.h.

57 { return catalog_; }

References catalog_.

◆ compressionAlgorithm()

std::string const& edm::PoolOutputModule::compressionAlgorithm ( ) const

inline

Definition at line 49 of file PoolOutputModule.h.

49 { return compressionAlgorithm_; }

References compressionAlgorithm_.

◆ compressionLevel()

int const& edm::PoolOutputModule::compressionLevel ( ) const

inline

Definition at line 48 of file PoolOutputModule.h.

48 { return compressionLevel_; }

References compressionLevel_.

◆ currentFileName()

std::string const & edm::PoolOutputModule::currentFileName ( ) const

Definition at line 118 of file PoolOutputModule.cc.

118 { return rootOutputFile_->fileName(); }

References rootOutputFile_.

Referenced by edm::TimeoutPoolOutputModule::shouldWeCloseFile().

◆ doExtrasAfterCloseFile()

void edm::PoolOutputModule::doExtrasAfterCloseFile ( )

protectedvirtual

Reimplemented in dqmservices::JsonWritingTimeoutPoolOutputModule.

Definition at line 328 of file PoolOutputModule.cc.

328 {}

Referenced by reallyCloseFile().

◆ dropMetaData()

DropMetaData const& edm::PoolOutputModule::dropMetaData ( ) const

inline

Definition at line 56 of file PoolOutputModule.h.

56 { return dropMetaData_; }

References dropMetaData_.

Referenced by PoolOutputModule().

◆ eventAutoFlushSize()

int edm::PoolOutputModule::eventAutoFlushSize ( ) const

inline

Definition at line 51 of file PoolOutputModule.h.

51 { return eventAutoFlushSize_; }

References eventAutoFlushSize_.

Referenced by edm::RootOutputFile::RootOutputFile().

◆ fileName()

std::string const& edm::PoolOutputModule::fileName ( ) const

inline

Definition at line 46 of file PoolOutputModule.h.

46 { return fileName_; }

References fileName_.

Referenced by physicalAndLogicalNameForNewFile().

◆ fillDependencyGraph()

void edm::PoolOutputModule::fillDependencyGraph ( )

private

Definition at line 413 of file PoolOutputModule.cc.

                                              {
     for (auto const& branchParent : branchParents_) {
       BranchID const& child = branchParent.first;
       std::set<ParentageID> const& eIds = branchParent.second;
       for (auto const& eId : eIds) {
         Parentage entryDesc;
         ParentageRegistry::instance()->getMapped(eId, entryDesc);
         std::vector<BranchID> const& parents = entryDesc.parents();
         for (auto const& parent : parents) {
           branchChildren_.insertChild(parent, child);
         }
       }
     }
   }

References branchChildren_, branchParents_, edm::ParentageRegistry::getMapped(), edm::BranchChildren::insertChild(), edm::ParentageRegistry::instance(), class-composition::parent, parents, and edm::Parentage::parents().

Referenced by reallyCloseFile().

◆ fillDescription()

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

static

Definition at line 428 of file PoolOutputModule.cc.

                                                                       {
     std::string defaultString;
  
     desc.setComment("Writes runs, lumis, and events into EDM/ROOT files.");
     desc.addUntracked<std::string>("fileName")->setComment("Name of output file.");
     desc.addUntracked<std::string>("logicalFileName", defaultString)
         ->setComment("Passed to job report. Otherwise unused by module.");
     desc.addUntracked<std::string>("catalog", defaultString)
         ->setComment("Passed to job report. Otherwise unused by module.");
     desc.addUntracked<int>("maxSize", 0x7f000000)
         ->setComment(
             "Maximum output file size, in kB.\n"
             "If over maximum, new output file will be started at next input file transition.");
     desc.addUntracked<int>("compressionLevel", 9)->setComment("ROOT compression level of output file.");
     desc.addUntracked<std::string>("compressionAlgorithm", "ZLIB")
         ->setComment("Algorithm used to compress data in the ROOT output file, allowed values are ZLIB and LZMA");
     desc.addUntracked<int>("basketSize", 16384)->setComment("Default ROOT basket size in output file.");
     desc.addUntracked<int>("eventAutoFlushCompressedSize", 20 * 1024 * 1024)
         ->setComment(
             "Set ROOT auto flush stored data size (in bytes) for event TTree. The value sets how large the compressed "
             "buffer is allowed to get. The uncompressed buffer can be quite a bit larger than this depending on the "
             "average compression ratio. The value of -1 just uses ROOT's default value. The value of 0 turns off this "
             "feature.");
     desc.addUntracked<int>("splitLevel", 99)->setComment("Default ROOT branch split level in output file.");
     desc.addUntracked<std::string>("sortBaskets", std::string("sortbasketsbyoffset"))
         ->setComment(
             "Legal values: 'sortbasketsbyoffset', 'sortbasketsbybranch', 'sortbasketsbyentry'.\n"
             "Used by ROOT when fast copying. Affects performance.");
     desc.addUntracked<int>("treeMaxVirtualSize", -1)
         ->setComment("Size of ROOT TTree TBasket cache.  Affects performance.");
     desc.addUntracked<bool>("fastCloning", true)
         ->setComment(
             "True:  Allow fast copying, if possible.\n"
             "False: Disable fast copying.");
     desc.addUntracked<bool>("overrideInputFileSplitLevels", false)
         ->setComment(
             "False: Use branch split levels and basket sizes from input file, if possible.\n"
             "True:  Always use specified or default split levels and basket sizes.");
     desc.addUntracked<bool>("writeStatusFile", false)
         ->setComment("Write a status file. Intended for use by workflow management.");
     desc.addUntracked<std::string>("dropMetaData", defaultString)
         ->setComment(
             "Determines handling of per product per event metadata.  Options are:\n"
             "'NONE':    Keep all of it.\n"
             "'DROPPED': Keep it for products produced in current process and all kept products. Drop it for dropped "
             "products produced in prior processes.\n"
             "'PRIOR':   Keep it for products produced in current process. Drop it for products produced in prior "
             "processes.\n"
             "'ALL':     Drop all of it.");
     {
       ParameterSetDescription dataSet;
       dataSet.setAllowAnything();
       desc.addUntracked<ParameterSetDescription>("dataset", dataSet)
           ->setComment("PSet is only used by Data Operations and not by this module.");
     }
     {
       ParameterSetDescription specialSplit;
       specialSplit.addUntracked<std::string>("branch")->setComment(
           "Name of branch needing a special split level. The name can contain wildcards '*' and '?'");
       specialSplit.addUntracked<int>("splitLevel")->setComment("The special split level for the branch");
       desc.addVPSetUntracked("overrideBranchesSplitLevel", specialSplit, std::vector<ParameterSet>());
     }
     OutputModule::fillDescription(desc);
   }

References edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::addVPSetUntracked(), EgammaPostProcessor_cfi::dataSet, edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by edm::TimeoutPoolOutputModule::fillDescriptions(), and fillDescriptions().

◆ fillDescriptions()

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

static

Definition at line 493 of file PoolOutputModule.cc.

                                                                                  {
     ParameterSetDescription desc;
     PoolOutputModule::fillDescription(desc);
     descriptions.add("edmOutput", desc);
   }

References edm::ConfigurationDescriptions::add(), and fillDescription().

◆ fillSelectedItemList()

void edm::PoolOutputModule::fillSelectedItemList	(	BranchType	branchtype,
		TTree *	theInputTree
	)

private

Definition at line 178 of file PoolOutputModule.cc.

                                                                                         {
     SelectedProducts const& keptVector = keptProducts()[branchType];
     OutputItemList& outputItemList = selectedOutputItemList_[branchType];
     AuxItem& auxItem = auxItems_[branchType];
  
     // Fill AuxItem
     if (theInputTree != nullptr && !overrideInputFileSplitLevels_) {
       TBranch* auxBranch = theInputTree->GetBranch(BranchTypeToAuxiliaryBranchName(branchType).c_str());
       if (auxBranch) {
         auxItem.basketSize_ = auxBranch->GetBasketSize();
       } else {
         auxItem.basketSize_ = basketSize_;
       }
     } else {
       auxItem.basketSize_ = basketSize_;
     }
  
     // Fill outputItemList with an entry for each branch.
     for (auto const& kept : keptVector) {
       int splitLevel = BranchDescription::invalidSplitLevel;
       int basketSize = BranchDescription::invalidBasketSize;
  
       BranchDescription const& prod = *kept.first;
       TBranch* theBranch = ((!prod.produced() && theInputTree != nullptr && !overrideInputFileSplitLevels_)
                                 ? theInputTree->GetBranch(prod.branchName().c_str())
                                 : nullptr);
  
       if (theBranch != nullptr) {
         splitLevel = theBranch->GetSplitLevel();
         basketSize = theBranch->GetBasketSize();
       } else {
         splitLevel = (prod.splitLevel() == BranchDescription::invalidSplitLevel ? splitLevel_ : prod.splitLevel());
         for (auto const& b : specialSplitLevelForBranches_) {
           if (b.match(prod.branchName())) {
             splitLevel = b.splitLevel_;
           }
         }
         basketSize = (prod.basketSize() == BranchDescription::invalidBasketSize ? basketSize_ : prod.basketSize());
       }
       outputItemList.emplace_back(&prod, kept.second, splitLevel, basketSize);
     }
  
     // Sort outputItemList to allow fast copying.
     // The branches in outputItemList must be in the same order as in the input tree, with all new branches at the end.
     sort_all(outputItemList, OutputItem::Sorter(theInputTree));
   }

References auxItems_, b, edm::PoolOutputModule::OutputItem::basketSize(), edm::PoolOutputModule::AuxItem::basketSize_, edm::PoolOutputModule::OutputItem::basketSize_, edm::BranchTypeToAuxiliaryBranchName(), edm::BranchDescription::invalidBasketSize, edm::BranchDescription::invalidSplitLevel, edm::one::OutputModuleBase::keptProducts(), overrideInputFileSplitLevels_, dumpMFGeometry_cfg::prod, selectedOutputItemList_, edm::sort_all(), specialSplitLevelForBranches_, edm::PoolOutputModule::OutputItem::splitLevel(), and edm::PoolOutputModule::OutputItem::splitLevel_.

Referenced by respondToOpenInputFile().

◆ finishEndFile()

void edm::PoolOutputModule::finishEndFile ( )

private

Definition at line 324 of file PoolOutputModule.cc.

                                        {
     rootOutputFile_->finishEndFile();
     rootOutputFile_ = nullptr;
   }  // propagate_const<T> has no reset() function

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ inputFileCount()

int const& edm::PoolOutputModule::inputFileCount ( ) const

inline

Definition at line 60 of file PoolOutputModule.h.

60 { return inputFileCount_; }

References inputFileCount_.

◆ isFileOpen()

bool edm::PoolOutputModule::isFileOpen ( ) const

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 329 of file PoolOutputModule.cc.

329 { return rootOutputFile_.get() != nullptr; }

References rootOutputFile_.

Referenced by beginInputFile(), and openFile().

◆ logicalFileName()

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

inline

Definition at line 47 of file PoolOutputModule.h.

47 { return logicalFileName_; }

References logicalFileName_.

Referenced by physicalAndLogicalNameForNewFile().

◆ maxFileSize()

unsigned int const& edm::PoolOutputModule::maxFileSize ( ) const

inline

Definition at line 59 of file PoolOutputModule.h.

59 { return maxFileSize_; }

References maxFileSize_.

◆ moduleLabel()

std::string const& edm::PoolOutputModule::moduleLabel ( ) const

inline

Definition at line 58 of file PoolOutputModule.h.

58 { return moduleLabel_; }

References moduleLabel_.

◆ openFile()

void edm::PoolOutputModule::openFile ( FileBlock const & fb )

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 239 of file PoolOutputModule.cc.

                                                      {
     if (!isFileOpen()) {
       reallyOpenFile();
       beginInputFile(fb);
     }
   }

References beginInputFile(), benchmark_cfg::fb, isFileOpen(), and reallyOpenFile().

◆ operator=()

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

delete

◆ overrideInputFileSplitLevels()

bool const& edm::PoolOutputModule::overrideInputFileSplitLevels ( ) const

inline

Definition at line 55 of file PoolOutputModule.h.

55 { return overrideInputFileSplitLevels_; }

References overrideInputFileSplitLevels_.

◆ physicalAndLogicalNameForNewFile()

std::pair< std::string, std::string > edm::PoolOutputModule::physicalAndLogicalNameForNewFile ( )

protectedvirtual

Reimplemented in dqmservices::JsonWritingTimeoutPoolOutputModule.

Definition at line 332 of file PoolOutputModule.cc.

                                                                                    {
     if (inputFileCount_ == 0) {
       throw edm::Exception(errors::LogicError) << "Attempt to open output file before input file. "
                                                << "Please report this to the core framework developers.\n";
     }
     std::string suffix(".root");
     std::string::size_type offset = fileName().rfind(suffix);
     bool ext = (offset == fileName().size() - suffix.size());
     if (!ext)
       suffix.clear();
     std::string fileBase(ext ? fileName().substr(0, offset) : fileName());
     std::ostringstream ofilename;
     std::ostringstream lfilename;
     ofilename << fileBase;
     lfilename << logicalFileName();
     if (numberOfDigitsInIndex_) {
       ofilename << '_' << std::setw(numberOfDigitsInIndex_) << std::setfill('0') << childIndex_;
       if (!logicalFileName().empty()) {
         lfilename << '_' << std::setw(numberOfDigitsInIndex_) << std::setfill('0') << childIndex_;
       }
     }
     if (outputFileCount_) {
       ofilename << std::setw(3) << std::setfill('0') << outputFileCount_;
       if (!logicalFileName().empty()) {
         lfilename << std::setw(3) << std::setfill('0') << outputFileCount_;
       }
     }
     ofilename << suffix;
     ++outputFileCount_;
  
     return std::make_pair(ofilename.str(), lfilename.str());
   }

References childIndex_, relativeConstraints::empty, Exception, fileName(), inputFileCount_, logicalFileName(), edm::errors::LogicError, numberOfDigitsInIndex_, hltrates_dqm_sourceclient-live_cfg::offset, outputFileCount_, AlCaHLTBitMon_QueryRunRegistry::string, and createPayload::suffix.

Referenced by reallyOpenFile().

◆ preActionBeforeRunEventAsync()

void edm::PoolOutputModule::preActionBeforeRunEventAsync	(	WaitingTask *	iTask,
		ModuleCallingContext const &	iModuleCallingContext,
		Principal const &	iPrincipal
	)		const

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 399 of file PoolOutputModule.cc.

                                                                                          {
     if (DropAll != dropMetaData_) {
       auto const* ep = dynamic_cast<EventPrincipal const*>(&iPrincipal);
       if (ep) {
         auto pr = ep->productProvenanceRetrieverPtr();
         if (pr) {
           pr->readProvenanceAsync(iTask, &iModuleCallingContext);
         }
       }
     }
   }

References DropAll, dropMetaData_, and SiStripBadComponentsDQMServiceTemplate_cfg::ep.

◆ reallyCloseFile()

void edm::PoolOutputModule::reallyCloseFile ( )

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 287 of file PoolOutputModule.cc.

                                          {
     fillDependencyGraph();
     branchParents_.clear();
     startEndFile();
     writeFileFormatVersion();
     writeFileIdentifier();
     writeIndexIntoFile();
     writeStoredMergeableRunProductMetadata();
     writeProcessHistoryRegistry();
     writeParameterSetRegistry();
     writeProductDescriptionRegistry();
     writeParentageRegistry();
     writeBranchIDListRegistry();
     writeThinnedAssociationsHelper();
     writeProductDependencies();  //branchChildren used here
     branchChildren_.clear();
     finishEndFile();
  
     doExtrasAfterCloseFile();
   }

References branchChildren_, branchParents_, edm::BranchChildren::clear(), doExtrasAfterCloseFile(), fillDependencyGraph(), finishEndFile(), startEndFile(), writeBranchIDListRegistry(), writeFileFormatVersion(), writeFileIdentifier(), writeIndexIntoFile(), writeParameterSetRegistry(), writeParentageRegistry(), writeProcessHistoryRegistry(), writeProductDependencies(), writeProductDescriptionRegistry(), writeStoredMergeableRunProductMetadata(), and writeThinnedAssociationsHelper().

◆ reallyOpenFile()

void edm::PoolOutputModule::reallyOpenFile ( )

private

Definition at line 365 of file PoolOutputModule.cc.

                                         {
     auto names = physicalAndLogicalNameForNewFile();
     rootOutputFile_ = std::make_unique<RootOutputFile>(
         this,
         names.first,
         names.second,
         processesWithSelectedMergeableRunProducts_);  // propagate_const<T> has no reset() function
   }

References names, physicalAndLogicalNameForNewFile(), processesWithSelectedMergeableRunProducts_, and rootOutputFile_.

Referenced by openFile().

◆ respondToCloseInputFile()

void edm::PoolOutputModule::respondToCloseInputFile ( FileBlock const & fb )

overrideprivate

Definition at line 260 of file PoolOutputModule.cc.

                                                                     {
     if (rootOutputFile_)
       rootOutputFile_->respondToCloseInputFile(fb);
   }

References benchmark_cfg::fb, and rootOutputFile_.

◆ respondToOpenInputFile()

void edm::PoolOutputModule::respondToOpenInputFile ( FileBlock const & fb )

overrideprivate

Definition at line 246 of file PoolOutputModule.cc.

                                                                    {
     if (!initializedFromInput_) {
       for (int i = InEvent; i < NumBranchTypes; ++i) {
         BranchType branchType = static_cast<BranchType>(i);
         TTree* theInputTree =
             (branchType == InEvent ? fb.tree() : (branchType == InLumi ? fb.lumiTree() : fb.runTree()));
         fillSelectedItemList(branchType, theInputTree);
       }
       initializedFromInput_ = true;
     }
     ++inputFileCount_;
     beginInputFile(fb);
   }

References beginInputFile(), benchmark_cfg::fb, fillSelectedItemList(), mps_fire::i, edm::InEvent, initializedFromInput_, edm::InLumi, inputFileCount_, and edm::NumBranchTypes.

◆ selectedOutputItemList() [1/2]

OutputItemListArray& edm::PoolOutputModule::selectedOutputItemList ( )

inline

Definition at line 133 of file PoolOutputModule.h.

133 { return selectedOutputItemList_; }

References selectedOutputItemList_.

◆ selectedOutputItemList() [2/2]

OutputItemListArray const& edm::PoolOutputModule::selectedOutputItemList ( ) const

inline

Definition at line 131 of file PoolOutputModule.h.

131 { return selectedOutputItemList_; }

References selectedOutputItemList_.

Referenced by edm::RootOutputFile::RootOutputFile().

◆ setProcessesWithSelectedMergeableRunProducts()

void edm::PoolOutputModule::setProcessesWithSelectedMergeableRunProducts ( std::set< std::string > const & processes )

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 265 of file PoolOutputModule.cc.

                                                                                                         {
     processesWithSelectedMergeableRunProducts_.assign(processes.begin(), processes.end());
   }

References dqmiodatasetharvest::processes, and processesWithSelectedMergeableRunProducts_.

◆ shouldWeCloseFile()

bool edm::PoolOutputModule::shouldWeCloseFile ( ) const

overrideprotectedvirtual

allow inheriting classes to override but still be able to call this method in the overridden version

Reimplemented from edm::one::OutputModuleBase.

Reimplemented in edm::TimeoutPoolOutputModule.

Definition at line 330 of file PoolOutputModule.cc.

330 { return rootOutputFile_->shouldWeCloseFile(); }

References rootOutputFile_.

Referenced by edm::TimeoutPoolOutputModule::shouldWeCloseFile().

◆ splitLevel()

int const& edm::PoolOutputModule::splitLevel ( ) const

inline

Definition at line 52 of file PoolOutputModule.h.

52 { return splitLevel_; }

References splitLevel_.

◆ startEndFile()

void edm::PoolOutputModule::startEndFile ( )

private

Definition at line 309 of file PoolOutputModule.cc.

309 {}

Referenced by reallyCloseFile().

◆ treeMaxVirtualSize()

int const& edm::PoolOutputModule::treeMaxVirtualSize ( ) const

inline

Definition at line 54 of file PoolOutputModule.h.

54 { return treeMaxVirtualSize_; }

References treeMaxVirtualSize_.

◆ updateBranchParents()

void edm::PoolOutputModule::updateBranchParents ( EventForOutput const & e )

private

Definition at line 386 of file PoolOutputModule.cc.

                                                                     {
     ProductProvenanceRetriever const* provRetriever = e.productProvenanceRetrieverPtr();
     for (auto const& bid : producedBranches_) {
       updateBranchParentsForOneBranch(provRetriever, bid);
     }
     SubProcessParentageHelper const* helper = subProcessParentageHelper();
     if (helper) {
       for (auto const& bid : subProcessParentageHelper()->producedProducts()) {
         updateBranchParentsForOneBranch(provRetriever, bid);
       }
     }
   }

References MillePedeFileConverter_cfg::e, producedBranches_, edm::one::OutputModuleBase::subProcessParentageHelper(), and updateBranchParentsForOneBranch().

Referenced by write().

◆ updateBranchParentsForOneBranch()

void edm::PoolOutputModule::updateBranchParentsForOneBranch	(	ProductProvenanceRetriever const *	provRetriever,
		BranchID const &	branchID
	)

private

Definition at line 374 of file PoolOutputModule.cc.

                                                                                    {
     ProductProvenance const* provenance = provRetriever->branchIDToProvenanceForProducedOnly(branchID);
     if (provenance != nullptr) {
       BranchParents::iterator it = branchParents_.find(branchID);
       if (it == branchParents_.end()) {
         it = branchParents_.insert(std::make_pair(branchID, std::set<ParentageID>())).first;
       }
       it->second.insert(provenance->parentageID());
     }
   }

References edm::PoolOutputModule::OutputItem::branchID(), edm::ProductProvenanceRetriever::branchIDToProvenanceForProducedOnly(), branchParents_, and edm::ProductProvenance::parentageID().

Referenced by updateBranchParents().

◆ whyNotFastClonable()

int const& edm::PoolOutputModule::whyNotFastClonable ( ) const

inline

Definition at line 61 of file PoolOutputModule.h.

61 { return whyNotFastClonable_; }

References whyNotFastClonable_.

◆ write()

void edm::PoolOutputModule::write ( EventForOutput const & e )

overrideprotectedvirtual

Implements edm::one::OutputModuleBase.

Reimplemented in edm::TimeoutPoolOutputModule.

Definition at line 271 of file PoolOutputModule.cc.

                                                       {
     updateBranchParents(e);
     rootOutputFile_->writeOne(e);
     if (!statusFileName_.empty()) {
       std::ofstream statusFile(statusFileName_.c_str());
       statusFile << e.id() << " time: " << std::setprecision(3) << TimeOfDay() << '\n';
       statusFile.close();
     }
   }

References MillePedeFileConverter_cfg::e, rootOutputFile_, statusFileName_, and updateBranchParents().

Referenced by edm::TimeoutPoolOutputModule::write().

◆ writeBranchIDListRegistry()

void edm::PoolOutputModule::writeBranchIDListRegistry ( )

private

Definition at line 321 of file PoolOutputModule.cc.

321 { rootOutputFile_->writeBranchIDListRegistry(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeFileFormatVersion()

void edm::PoolOutputModule::writeFileFormatVersion ( )

private

Definition at line 311 of file PoolOutputModule.cc.

311 { rootOutputFile_->writeFileFormatVersion(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeFileIdentifier()

void edm::PoolOutputModule::writeFileIdentifier ( )

private

Definition at line 312 of file PoolOutputModule.cc.

312 { rootOutputFile_->writeFileIdentifier(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeIndexIntoFile()

void edm::PoolOutputModule::writeIndexIntoFile ( )

private

Definition at line 313 of file PoolOutputModule.cc.

313 { rootOutputFile_->writeIndexIntoFile(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeLuminosityBlock()

void edm::PoolOutputModule::writeLuminosityBlock ( LuminosityBlockForOutput const & lb )

overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 281 of file PoolOutputModule.cc.

                                                                                 {
     rootOutputFile_->writeLuminosityBlock(lb);
   }

References rootOutputFile_.

◆ writeParameterSetRegistry()

void edm::PoolOutputModule::writeParameterSetRegistry ( )

private

Definition at line 318 of file PoolOutputModule.cc.

318 { rootOutputFile_->writeParameterSetRegistry(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeParentageRegistry()

void edm::PoolOutputModule::writeParentageRegistry ( )

private

Definition at line 320 of file PoolOutputModule.cc.

320 { rootOutputFile_->writeParentageRegistry(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeProcessHistoryRegistry()

void edm::PoolOutputModule::writeProcessHistoryRegistry ( )

private

Definition at line 317 of file PoolOutputModule.cc.

317 { rootOutputFile_->writeProcessHistoryRegistry(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeProductDependencies()

void edm::PoolOutputModule::writeProductDependencies ( )

private

Definition at line 323 of file PoolOutputModule.cc.

323 { rootOutputFile_->writeProductDependencies(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeProductDescriptionRegistry()

void edm::PoolOutputModule::writeProductDescriptionRegistry ( )

private

Definition at line 319 of file PoolOutputModule.cc.

319 { rootOutputFile_->writeProductDescriptionRegistry(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeRun()

void edm::PoolOutputModule::writeRun ( RunForOutput const & r )

overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 285 of file PoolOutputModule.cc.

285 { rootOutputFile_->writeRun(r); }

References alignCSCRings::r, and rootOutputFile_.

◆ writeStoredMergeableRunProductMetadata()

void edm::PoolOutputModule::writeStoredMergeableRunProductMetadata ( )

private

Definition at line 314 of file PoolOutputModule.cc.

                                                                 {
     rootOutputFile_->writeStoredMergeableRunProductMetadata();
   }

References rootOutputFile_.

Referenced by reallyCloseFile().

◆ writeThinnedAssociationsHelper()

void edm::PoolOutputModule::writeThinnedAssociationsHelper ( )

private

Definition at line 322 of file PoolOutputModule.cc.

322 { rootOutputFile_->writeThinnedAssociationsHelper(); }

References rootOutputFile_.

Referenced by reallyCloseFile().

Member Data Documentation

◆ auxItems_

AuxItemArray edm::PoolOutputModule::auxItems_

private

Definition at line 185 of file PoolOutputModule.h.

Referenced by auxItems(), and fillSelectedItemList().

◆ basketOrder_

std::string edm::PoolOutputModule::basketOrder_

private

Definition at line 197 of file PoolOutputModule.h.

Referenced by basketOrder().

◆ basketSize_

const int edm::PoolOutputModule::basketSize_

private

Definition at line 194 of file PoolOutputModule.h.

Referenced by basketSize().

◆ branchChildren_

BranchChildren edm::PoolOutputModule::branchChildren_

private

Definition at line 208 of file PoolOutputModule.h.

Referenced by beginInputFile(), branchChildren(), fillDependencyGraph(), and reallyCloseFile().

◆ branchParents_

BranchParents edm::PoolOutputModule::branchParents_

private

Definition at line 207 of file PoolOutputModule.h.

Referenced by fillDependencyGraph(), reallyCloseFile(), and updateBranchParentsForOneBranch().

◆ catalog_

const std::string edm::PoolOutputModule::catalog_

private

Definition at line 190 of file PoolOutputModule.h.

Referenced by catalog().

◆ childIndex_

unsigned int edm::PoolOutputModule::childIndex_

private

Definition at line 205 of file PoolOutputModule.h.

Referenced by physicalAndLogicalNameForNewFile().

◆ compressionAlgorithm_

const std::string edm::PoolOutputModule::compressionAlgorithm_

private

Definition at line 193 of file PoolOutputModule.h.

Referenced by compressionAlgorithm().

◆ compressionLevel_

const int edm::PoolOutputModule::compressionLevel_

private

Definition at line 192 of file PoolOutputModule.h.

Referenced by compressionLevel().

◆ dropMetaData_

DropMetaData edm::PoolOutputModule::dropMetaData_

private

Definition at line 200 of file PoolOutputModule.h.

Referenced by dropMetaData(), PoolOutputModule(), and preActionBeforeRunEventAsync().

◆ eventAutoFlushSize_

const int edm::PoolOutputModule::eventAutoFlushSize_

private

Definition at line 195 of file PoolOutputModule.h.

Referenced by eventAutoFlushSize().

◆ fileName_

const std::string edm::PoolOutputModule::fileName_

private

Definition at line 188 of file PoolOutputModule.h.

Referenced by fileName().

◆ initializedFromInput_

bool edm::PoolOutputModule::initializedFromInput_

private

Definition at line 202 of file PoolOutputModule.h.

Referenced by respondToOpenInputFile().

◆ inputFileCount_

int edm::PoolOutputModule::inputFileCount_

private

Definition at line 204 of file PoolOutputModule.h.

Referenced by inputFileCount(), physicalAndLogicalNameForNewFile(), and respondToOpenInputFile().

◆ logicalFileName_

const std::string edm::PoolOutputModule::logicalFileName_

private

Definition at line 189 of file PoolOutputModule.h.

Referenced by logicalFileName().

◆ maxFileSize_

unsigned const int edm::PoolOutputModule::maxFileSize_

private

Definition at line 191 of file PoolOutputModule.h.

Referenced by maxFileSize().

◆ moduleLabel_

const std::string edm::PoolOutputModule::moduleLabel_

private

Definition at line 201 of file PoolOutputModule.h.

Referenced by ExternalGeneratorFilter.ExternalGeneratorFilter::insertInto(), Modules.SwitchProducer::insertInto(), Mixins._TypedParameterizable::insertInto(), moduleLabel(), Modules.ESSource::nameInProcessDesc_(), Modules.ESProducer::nameInProcessDesc_(), and PoolOutputModule().

◆ numberOfDigitsInIndex_

unsigned int edm::PoolOutputModule::numberOfDigitsInIndex_

private

Definition at line 206 of file PoolOutputModule.h.

Referenced by physicalAndLogicalNameForNewFile().

◆ outputFileCount_

int edm::PoolOutputModule::outputFileCount_

private

Definition at line 203 of file PoolOutputModule.h.

Referenced by physicalAndLogicalNameForNewFile().

◆ overrideInputFileSplitLevels_

bool edm::PoolOutputModule::overrideInputFileSplitLevels_

private

Definition at line 210 of file PoolOutputModule.h.

Referenced by fillSelectedItemList(), and overrideInputFileSplitLevels().

◆ processesWithSelectedMergeableRunProducts_

std::vector<std::string> edm::PoolOutputModule::processesWithSelectedMergeableRunProducts_

private

Definition at line 213 of file PoolOutputModule.h.

Referenced by reallyOpenFile(), and setProcessesWithSelectedMergeableRunProducts().

◆ producedBranches_

std::vector<BranchID> edm::PoolOutputModule::producedBranches_

private

Definition at line 209 of file PoolOutputModule.h.

Referenced by beginJob(), and updateBranchParents().

◆ rootOutputFile_

edm::propagate_const<std::unique_ptr<RootOutputFile> > edm::PoolOutputModule::rootOutputFile_

private

◆ rootServiceChecker_

RootServiceChecker edm::PoolOutputModule::rootServiceChecker_

private

Definition at line 184 of file PoolOutputModule.h.

◆ selectedOutputItemList_

OutputItemListArray edm::PoolOutputModule::selectedOutputItemList_

private

Definition at line 186 of file PoolOutputModule.h.

Referenced by fillSelectedItemList(), and selectedOutputItemList().

◆ specialSplitLevelForBranches_

std::vector<SpecialSplitLevelForBranch> edm::PoolOutputModule::specialSplitLevelForBranches_

private

Definition at line 187 of file PoolOutputModule.h.

Referenced by fillSelectedItemList(), and PoolOutputModule().

◆ splitLevel_

const int edm::PoolOutputModule::splitLevel_

private

Definition at line 196 of file PoolOutputModule.h.

Referenced by splitLevel().

◆ statusFileName_

std::string edm::PoolOutputModule::statusFileName_

private

Definition at line 212 of file PoolOutputModule.h.

Referenced by PoolOutputModule(), and write().

◆ treeMaxVirtualSize_

const int edm::PoolOutputModule::treeMaxVirtualSize_

private

Definition at line 198 of file PoolOutputModule.h.

Referenced by treeMaxVirtualSize().

◆ whyNotFastClonable_

int edm::PoolOutputModule::whyNotFastClonable_

private

Definition at line 199 of file PoolOutputModule.h.

Referenced by PoolOutputModule(), and whyNotFastClonable().

Classes

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ AuxItemArray

◆ BranchParents

◆ OutputItemList

◆ OutputItemListArray

Member Enumeration Documentation

◆ DropMetaData

Constructor & Destructor Documentation

◆ PoolOutputModule() [1/2]

◆ ~PoolOutputModule()

◆ PoolOutputModule() [2/2]

Member Function Documentation

◆ auxItems()

◆ basketOrder()

◆ basketSize()

◆ beginInputFile()

◆ beginJob()

◆ branchChildren()

◆ catalog()

◆ compressionAlgorithm()

◆ compressionLevel()

◆ currentFileName()

◆ doExtrasAfterCloseFile()

◆ dropMetaData()

◆ eventAutoFlushSize()

◆ fileName()

◆ fillDependencyGraph()

◆ fillDescription()

◆ fillDescriptions()

◆ fillSelectedItemList()

◆ finishEndFile()

◆ inputFileCount()

◆ isFileOpen()

◆ logicalFileName()

◆ maxFileSize()

◆ moduleLabel()

◆ openFile()

◆ operator=()

◆ overrideInputFileSplitLevels()

◆ physicalAndLogicalNameForNewFile()

◆ preActionBeforeRunEventAsync()

◆ reallyCloseFile()

◆ reallyOpenFile()

◆ respondToCloseInputFile()

◆ respondToOpenInputFile()

◆ selectedOutputItemList() [1/2]

◆ selectedOutputItemList() [2/2]

◆ setProcessesWithSelectedMergeableRunProducts()

◆ shouldWeCloseFile()

◆ splitLevel()

◆ startEndFile()

◆ treeMaxVirtualSize()

◆ updateBranchParents()

◆ updateBranchParentsForOneBranch()

◆ whyNotFastClonable()

◆ write()

◆ writeBranchIDListRegistry()

◆ writeFileFormatVersion()

◆ writeFileIdentifier()

◆ writeIndexIntoFile()

◆ writeLuminosityBlock()

◆ writeParameterSetRegistry()

◆ writeParentageRegistry()

◆ writeProcessHistoryRegistry()

◆ writeProductDependencies()

◆ writeProductDescriptionRegistry()

◆ writeRun()

◆ writeStoredMergeableRunProductMetadata()

◆ writeThinnedAssociationsHelper()

Member Data Documentation

◆ auxItems_