#include <PoolOutputModule.h>

Inheritance diagram for edm::PoolOutputModule:

Classes
struct	AuxItem

struct	OutputItem

struct	SpecialSplitLevelForBranch

Public Types
using	AuxItemArray = std::array< AuxItem, numberOfRunLumiEventProductTrees >

enum	DropMetaData { DropNone, DropDroppedPrior, DropPrior, DropAll }

using	OutputItemList = std::vector< OutputItem >

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

Public Types inherited from edm::core::OutputModuleCore
typedef OutputModuleCore	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Public Member Functions
AuxItemArray const &	auxItems () const

std::string const &	basketOrder () const

int	basketSize () const

BranchChildren const &	branchChildren () const

std::string const &	catalog () const

bool	compactEventAuxiliary () const

std::string const &	compressionAlgorithm () const

int	compressionLevel () const

std::string const &	currentFileName () const

DropMetaData const &	dropMetaData () const

int	eventAutoFlushSize () const

int	eventAuxiliaryBasketSize () const

std::string const &	fileName () const

int	inputFileCount () const

std::string const &	logicalFileName () const

unsigned int	maxFileSize () const

bool	mergeJob () const

std::string const &	moduleLabel () const

PoolOutputModule &	operator= (PoolOutputModule const &)=delete

bool	overrideInputFileSplitLevels () const

	PoolOutputModule (ParameterSet const &ps)

	PoolOutputModule (PoolOutputModule const &)=delete

std::vector< OutputItemList > const &	selectedOutputItemList () const

std::vector< OutputItemList > &	selectedOutputItemList ()

int	splitLevel () const

int	treeMaxVirtualSize () const

int	whyNotFastClonable () const

	~PoolOutputModule () override

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

SerialTaskQueue *	globalRunsQueue () final

const OutputModule &	operator= (const OutputModule &)=delete

	OutputModule (edm::ParameterSet const &iPSet)

	OutputModule (const OutputModule &)=delete

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

bool	wantsInputProcessBlocks () const final

bool	wantsProcessBlocks () const final

Public Member Functions inherited from edm::one::OutputModuleBase
OutputModuleBase &	operator= (OutputModuleBase const &)=delete

	OutputModuleBase (ParameterSet const &pset)

	OutputModuleBase (OutputModuleBase const &)=delete

SharedResourcesAcquirer &	sharedResourcesAcquirer ()

SubProcessParentageHelper const *	subProcessParentageHelper () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

Public Member Functions inherited from edm::core::OutputModuleCore
BranchIDLists const *	branchIDLists () const

void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

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

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleCore &	operator= (OutputModuleCore const &)=delete

	OutputModuleCore (ParameterSet const &pset)

	OutputModuleCore (OutputModuleCore const &)=delete

OutputProcessBlockHelper const &	outputProcessBlockHelper () const

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

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

ThinnedAssociationsHelper const *	thinnedAssociationsHelper () const

bool	wantAllEvents () const

	~OutputModuleCore () 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 const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

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

std::vector< ESResolverIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (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::array< std::vector< ModuleDescription const > , NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const *> const &labelsToDesc, std::string const &processName) const

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

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

void	updateLookup (eventsetup::ESRecordsToProductResolverIndices 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::core::OutputModuleCore
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)

void	doBeginJob ()

bool	doEvent (EventTransitionInfo const &, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate (PreallocationConfiguration const &)

Protected Member Functions inherited from edm::core::OutputModuleCore
void	configure (OutputModuleDescription const &desc)

ModuleDescription const &	description () const

void	doAccessInputProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)

void	doBeginJob_ ()

bool	doBeginLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)

void	doBeginProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)

bool	doBeginRun (RunTransitionInfo const &, ModuleCallingContext const *)

void	doEndJob ()

bool	doEndLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)

void	doEndProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)

bool	doEndRun (RunTransitionInfo const &, ModuleCallingContext const *)

bool	doEvent_ (EventTransitionInfo const &, 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
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

EDGetToken	consumes (const TypeToGet &id, 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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

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

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes ()

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag)

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

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

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

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

void	resetItemsToGetFrom (BranchType iType)

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

Private Member Functions
void	beginInputFile (FileBlock const &fb)

void	beginJob () override

void	fillDependencyGraph ()

void	fillSelectedItemList (BranchType branchtype, std::string const &processName, TTree *theInputTree, OutputItemList &)

void	finishEndFile ()

bool	isFileOpen () const override

void	openFile (FileBlock const &fb) override

void	preActionBeforeRunEventAsync (WaitingTaskHolder 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	writeEventAuxiliary ()

void	writeFileFormatVersion ()

void	writeFileIdentifier ()

void	writeIndexIntoFile ()

void	writeLuminosityBlock (LuminosityBlockForOutput const &) override

void	writeParameterSetRegistry ()

void	writeParentageRegistry ()

void	writeProcessBlock (ProcessBlockForOutput const &) override

void	writeProcessBlockHelper ()

void	writeProcessHistoryRegistry ()

void	writeProductDependencies ()

void	writeProductDescriptionRegistry ()

void	writeRun (RunForOutput const &) override

void	writeStoredMergeableRunProductMetadata ()

void	writeThinnedAssociationsHelper ()

Private Attributes
AuxItemArray	auxItems_

std::string	basketOrder_

int const	basketSize_

BranchChildren	branchChildren_

BranchParents	branchParents_

std::string const	catalog_

bool	compactEventAuxiliary_

std::string const	compressionAlgorithm_

int const	compressionLevel_

DropMetaData	dropMetaData_

int const	eventAutoFlushSize_

int const	eventAuxBasketSize_

std::string const	fileName_

bool	initializedFromInput_

int	inputFileCount_

std::string const	logicalFileName_

unsigned int const	maxFileSize_

bool	mergeJob_

std::string const	moduleLabel_

int	outputFileCount_

std::string	overrideGUID_

bool	overrideInputFileSplitLevels_

std::vector< std::string >	processesWithSelectedMergeableRunProducts_

std::vector< BranchID >	producedBranches_

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

RootServiceChecker	rootServiceChecker_

std::vector< OutputItemList >	selectedOutputItemList_

std::vector< SpecialSplitLevelForBranch >	specialSplitLevelForBranches_

int const	splitLevel_

std::string	statusFileName_

int const	treeMaxVirtualSize_

int	whyNotFastClonable_

Additional Inherited Members
Protected Attributes inherited from edm::core::OutputModuleCore
std::atomic< int >	remainingEvents_

Detailed Description

Definition at line 41 of file PoolOutputModule.h.

Member Typedef Documentation

◆ AuxItemArray

using edm::PoolOutputModule::AuxItemArray = std::array<AuxItem, numberOfRunLumiEventProductTrees>

Definition at line 80 of file PoolOutputModule.h.

◆ BranchParents

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

private

Definition at line 162 of file PoolOutputModule.h.

◆ OutputItemList

using edm::PoolOutputModule::OutputItemList = std::vector<OutputItem>

Definition at line 116 of file PoolOutputModule.h.

Member Enumeration Documentation

◆ DropMetaData

enum edm::PoolOutputModule::DropMetaData

Enumerator
DropNone
DropDroppedPrior
DropPrior
DropAll

Definition at line 43 of file PoolOutputModule.h.

43 { DropNone, DropDroppedPrior, DropPrior, DropAll };

edm::PoolOutputModule::DropAll

Definition: PoolOutputModule.h:43

edm::PoolOutputModule::DropDroppedPrior

Definition: PoolOutputModule.h:43

edm::PoolOutputModule::DropPrior

Definition: PoolOutputModule.h:43

edm::PoolOutputModule::DropNone

Definition: PoolOutputModule.h:43

Constructor & Destructor Documentation

◆ PoolOutputModule() [1/2]

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

explicit

Definition at line 36 of file PoolOutputModule.cc.

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::core::OutputModuleCore::wantAllEvents(), and whyNotFastClonable_.

       : 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")),
         eventAuxBasketSize_(pset.getUntrackedParameter<int>("eventAuxiliaryBasketSize")),
         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),
         branchParents_(),
         branchChildren_(),
         overrideInputFileSplitLevels_(pset.getUntrackedParameter<bool>("overrideInputFileSplitLevels")),
         compactEventAuxiliary_(pset.getUntrackedParameter<bool>("compactEventAuxiliary")),
         mergeJob_(pset.getUntrackedParameter<bool>("mergeJob")),
         rootOutputFile_(),
         statusFileName_(),
         overrideGUID_(pset.getUntrackedParameter<std::string>("overrideGUID")) {
     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");
   }

◆ ~PoolOutputModule()

edm::PoolOutputModule::~PoolOutputModule ( )

override

Definition at line 292 of file PoolOutputModule.cc.

292 {}

◆ PoolOutputModule() [2/2]

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

delete

Member Function Documentation

◆ auxItems()

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

inline

Definition at line 81 of file PoolOutputModule.h.

References auxItems_.

81 { return auxItems_; }

edm::PoolOutputModule::auxItems_

AuxItemArray auxItems_

Definition: PoolOutputModule.h:190

◆ basketOrder()

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

inline

Definition at line 56 of file PoolOutputModule.h.

References basketOrder_.

56 { return basketOrder_; }

edm::PoolOutputModule::basketOrder_

std::string basketOrder_

Definition: PoolOutputModule.h:203

◆ basketSize()

int edm::PoolOutputModule::basketSize ( ) const

inline

Definition at line 52 of file PoolOutputModule.h.

References basketSize_.

52 { return basketSize_; }

edm::PoolOutputModule::basketSize_

int const basketSize_

Definition: PoolOutputModule.h:199

◆ beginInputFile()

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

private

Definition at line 230 of file PoolOutputModule.cc.

References edm::FileBlock::branchChildren(), branchChildren_, edm::BranchChildren::childLookup(), edm::BranchChildren::insertChild(), isFileOpen(), edm::core::OutputModuleCore::remainingEvents(), and rootOutputFile_.

Referenced by openFile(), and respondToOpenInputFile().

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

◆ beginJob()

void edm::PoolOutputModule::beginJob ( void )

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 110 of file PoolOutputModule.cc.

References submitPVResolutionJobs::desc, edm::InEvent, dumpMFGeometry_cfg::prod, and producedBranches_.

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

◆ branchChildren()

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

inline

Definition at line 134 of file PoolOutputModule.h.

References branchChildren_.

134 { return branchChildren_; }

edm::PoolOutputModule::branchChildren_

BranchChildren branchChildren_

Definition: PoolOutputModule.h:212

◆ catalog()

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

inline

Definition at line 62 of file PoolOutputModule.h.

References catalog_.

62 { return catalog_; }

edm::PoolOutputModule::catalog_

std::string const catalog_

Definition: PoolOutputModule.h:195

◆ compactEventAuxiliary()

bool edm::PoolOutputModule::compactEventAuxiliary ( ) const

inline

Definition at line 59 of file PoolOutputModule.h.

References compactEventAuxiliary_.

59 { return compactEventAuxiliary_; }

edm::PoolOutputModule::compactEventAuxiliary_

bool compactEventAuxiliary_

Definition: PoolOutputModule.h:215

◆ compressionAlgorithm()

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

inline

Definition at line 51 of file PoolOutputModule.h.

References compressionAlgorithm_.

51 { return compressionAlgorithm_; }

edm::PoolOutputModule::compressionAlgorithm_

std::string const compressionAlgorithm_

Definition: PoolOutputModule.h:198

◆ compressionLevel()

int edm::PoolOutputModule::compressionLevel ( ) const

inline

Definition at line 50 of file PoolOutputModule.h.

References compressionLevel_.

50 { return compressionLevel_; }

edm::PoolOutputModule::compressionLevel_

int const compressionLevel_

Definition: PoolOutputModule.h:197

◆ currentFileName()

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

Definition at line 120 of file PoolOutputModule.cc.

References rootOutputFile_.

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

120 { return rootOutputFile_->fileName(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ doExtrasAfterCloseFile()

void edm::PoolOutputModule::doExtrasAfterCloseFile ( )

protectedvirtual

Reimplemented in dqmservices::JsonWritingTimeoutPoolOutputModule.

Definition at line 357 of file PoolOutputModule.cc.

Referenced by reallyCloseFile().

357 {}

◆ dropMetaData()

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

inline

Definition at line 61 of file PoolOutputModule.h.

References dropMetaData_.

Referenced by PoolOutputModule().

61 { return dropMetaData_; }

edm::PoolOutputModule::dropMetaData_

DropMetaData dropMetaData_

Definition: PoolOutputModule.h:206

◆ eventAutoFlushSize()

int edm::PoolOutputModule::eventAutoFlushSize ( ) const

inline

Definition at line 54 of file PoolOutputModule.h.

References eventAutoFlushSize_.

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

54 { return eventAutoFlushSize_; }

edm::PoolOutputModule::eventAutoFlushSize_

int const eventAutoFlushSize_

Definition: PoolOutputModule.h:201

◆ eventAuxiliaryBasketSize()

int edm::PoolOutputModule::eventAuxiliaryBasketSize ( ) const

inline

Definition at line 53 of file PoolOutputModule.h.

References eventAuxBasketSize_.

53 { return eventAuxBasketSize_; }

edm::PoolOutputModule::eventAuxBasketSize_

int const eventAuxBasketSize_

Definition: PoolOutputModule.h:200

◆ fileName()

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

inline

Definition at line 48 of file PoolOutputModule.h.

References fileName_.

Referenced by physicalAndLogicalNameForNewFile().

48 { return fileName_; }

edm::PoolOutputModule::fileName_

std::string const fileName_

Definition: PoolOutputModule.h:193

◆ fillDependencyGraph()

void edm::PoolOutputModule::fillDependencyGraph ( )

private

Definition at line 439 of file PoolOutputModule.cc.

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

Referenced by reallyCloseFile().

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

◆ fillDescription()

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

static

Definition at line 454 of file PoolOutputModule.cc.

References edm::ParameterSetDescription::addUntracked(), EgammaPostProcessor_cfi::dataSet, submitPVResolutionJobs::desc, and AlCaHLTBitMon_QueryRunRegistry::string.

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

                                                                       {
     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", 4)->setComment("ROOT compression level of output file.");
     desc.addUntracked<std::string>("compressionAlgorithm", "ZSTD")
         ->setComment(
             "Algorithm used to compress data in the ROOT output file, allowed values are ZLIB, LZMA, LZ4, and ZSTD");
     desc.addUntracked<int>("basketSize", 16384)->setComment("Default ROOT basket size in output file.");
     desc.addUntracked<int>("eventAuxiliaryBasketSize", 16384)
         ->setComment("Default ROOT basket size in output file for EventAuxiliary branch.");
     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. A value of -N changes the behavior to flush after every Nth event.");
     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("mergeJob", false)
         ->setComment(
             "If set to true and fast copying is disabled, copy input file compression and basket sizes to the output "
             "file.");
     desc.addUntracked<bool>("compactEventAuxiliary", false)
         ->setComment(
             "False: Write EventAuxiliary as we go like any other event metadata branch.\n"
             "True:  Optimize the file layout by deferring writing the EventAuxiliary branch until the output file is "
             "closed.");
     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.");
     desc.addUntracked<std::string>("overrideGUID", defaultString)
         ->setComment(
             "Allows to override the GUID of the file. Intended to be used only in Tier0 for re-creating files.\n"
             "The GUID needs to be of the proper format. If a new output file is started (see maxSize), the GUID of\n"
             "the first file only is overridden, i.e. the subsequent output files have different, generated GUID.");
     {
       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);
   }

◆ fillDescriptions()

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

static

Definition at line 536 of file PoolOutputModule.cc.

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

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

◆ fillSelectedItemList()

void edm::PoolOutputModule::fillSelectedItemList	(	BranchType	branchtype,
		std::string const &	processName,
		TTree *	theInputTree,
		OutputItemList &	outputItemList
	)

private

Definition at line 173 of file PoolOutputModule.cc.

References auxItems_, b, edm::PoolOutputModule::OutputItem::basketSize(), edm::PoolOutputModule::AuxItem::basketSize_, edm::PoolOutputModule::OutputItem::basketSize_, edm::BranchTypeToAuxiliaryBranchName(), eventAuxBasketSize_, edm::InEvent, edm::InProcess, edm::BranchDescription::invalidBasketSize, edm::BranchDescription::invalidSplitLevel, edm::core::OutputModuleCore::keptProducts(), overrideInputFileSplitLevels_, edm::core::OutputModuleCore::processName(), dumpMFGeometry_cfg::prod, edm::sort_all(), specialSplitLevelForBranches_, edm::PoolOutputModule::OutputItem::splitLevel(), and edm::PoolOutputModule::OutputItem::splitLevel_.

Referenced by respondToOpenInputFile().

                                                                               {
     SelectedProducts const& keptVector = keptProducts()[branchType];
 
     if (branchType != InProcess) {
       AuxItem& auxItem = auxItems_[branchType];
 
       auto basketSize = (InEvent == branchType) ? eventAuxBasketSize_ : basketSize_;
 
       // 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;
       if (branchType == InProcess && processName != prod.processName()) {
         continue;
       }
       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));
   }

◆ finishEndFile()

void edm::PoolOutputModule::finishEndFile ( )

private

Definition at line 353 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

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

◆ inputFileCount()

int edm::PoolOutputModule::inputFileCount ( ) const

inline

Definition at line 65 of file PoolOutputModule.h.

References inputFileCount_.

65 { return inputFileCount_; }

edm::PoolOutputModule::inputFileCount_

int inputFileCount_

Definition: PoolOutputModule.h:210

◆ isFileOpen()

bool edm::PoolOutputModule::isFileOpen ( ) const

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 358 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by beginInputFile(), and openFile().

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

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ logicalFileName()

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

inline

Definition at line 49 of file PoolOutputModule.h.

References logicalFileName_.

Referenced by physicalAndLogicalNameForNewFile().

49 { return logicalFileName_; }

edm::PoolOutputModule::logicalFileName_

std::string const logicalFileName_

Definition: PoolOutputModule.h:194

◆ maxFileSize()

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

inline

Definition at line 64 of file PoolOutputModule.h.

References maxFileSize_.

64 { return maxFileSize_; }

edm::PoolOutputModule::maxFileSize_

unsigned int const maxFileSize_

Definition: PoolOutputModule.h:196

◆ mergeJob()

bool edm::PoolOutputModule::mergeJob ( ) const

inline

Definition at line 60 of file PoolOutputModule.h.

References mergeJob_.

60 { return mergeJob_; }

edm::PoolOutputModule::mergeJob_

bool mergeJob_

Definition: PoolOutputModule.h:216

◆ moduleLabel()

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

inline

Definition at line 63 of file PoolOutputModule.h.

References moduleLabel_.

63 { return moduleLabel_; }

edm::PoolOutputModule::moduleLabel_

std::string const moduleLabel_

Definition: PoolOutputModule.h:207

◆ openFile()

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

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 244 of file PoolOutputModule.cc.

References beginInputFile(), isFileOpen(), and reallyOpenFile().

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

◆ operator=()

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

delete

◆ overrideInputFileSplitLevels()

bool edm::PoolOutputModule::overrideInputFileSplitLevels ( ) const

inline

Definition at line 58 of file PoolOutputModule.h.

References overrideInputFileSplitLevels_.

58 { return overrideInputFileSplitLevels_; }

edm::PoolOutputModule::overrideInputFileSplitLevels_

bool overrideInputFileSplitLevels_

Definition: PoolOutputModule.h:214

◆ physicalAndLogicalNameForNewFile()

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

protectedvirtual

Reimplemented in dqmservices::JsonWritingTimeoutPoolOutputModule.

Definition at line 361 of file PoolOutputModule.cc.

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

Referenced by reallyOpenFile().

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

◆ preActionBeforeRunEventAsync()

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

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 425 of file PoolOutputModule.cc.

References runTheMatrix::const, DropAll, dropMetaData_, and SiStripBadComponentsDQMServiceTemplate_cfg::ep.

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

◆ reallyCloseFile()

void edm::PoolOutputModule::reallyCloseFile ( )

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 312 of file PoolOutputModule.cc.

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

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

◆ reallyOpenFile()

void edm::PoolOutputModule::reallyOpenFile ( )

private

Definition at line 388 of file PoolOutputModule.cc.

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

Referenced by openFile().

                                         {
     auto names = physicalAndLogicalNameForNewFile();
     rootOutputFile_ = std::make_unique<RootOutputFile>(this,
                                                        names.first,
                                                        names.second,
                                                        processesWithSelectedMergeableRunProducts_,
                                                        overrideGUID_);  // propagate_const<T> has no reset() function
     // Override the GUID of the first file only, in order to avoid two
     // output files from one Output Module to have identical GUID.
     overrideGUID_.clear();
   }

◆ respondToCloseInputFile()

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

overrideprivate

Definition at line 283 of file PoolOutputModule.cc.

References rootOutputFile_.

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

◆ respondToOpenInputFile()

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

overrideprivate

Definition at line 251 of file PoolOutputModule.cc.

References beginInputFile(), fillSelectedItemList(), mps_fire::i, edm::InEvent, initializedFromInput_, edm::InLumi, edm::InProcess, inputFileCount_, dqmdumpme::k, edm::FileBlock::lumiTree(), edm::numberOfRunLumiEventProductTrees, edm::NumBranchTypes, edm::core::OutputModuleCore::outputProcessBlockHelper(), edm::FileBlock::processBlockTree(), edm::OutputProcessBlockHelper::processesWithProcessBlockProducts(), edm::core::OutputModuleCore::processName(), edm::FileBlock::runTree(), selectedOutputItemList_, AlCaHLTBitMon_QueryRunRegistry::string, and edm::FileBlock::tree().

                                                                    {
     if (!initializedFromInput_) {
       std::vector<std::string> const& processesWithProcessBlockProducts =
           outputProcessBlockHelper().processesWithProcessBlockProducts();
       unsigned int numberOfProcessesWithProcessBlockProducts = processesWithProcessBlockProducts.size();
       unsigned int numberOfTTrees = numberOfRunLumiEventProductTrees + numberOfProcessesWithProcessBlockProducts;
       selectedOutputItemList_.resize(numberOfTTrees);
 
       for (unsigned int i = InEvent; i < NumBranchTypes; ++i) {
         BranchType branchType = static_cast<BranchType>(i);
         if (branchType != InProcess) {
           std::string processName;
           TTree* theInputTree =
               (branchType == InEvent ? fb.tree() : (branchType == InLumi ? fb.lumiTree() : fb.runTree()));
           OutputItemList& outputItemList = selectedOutputItemList_[branchType];
           fillSelectedItemList(branchType, processName, theInputTree, outputItemList);
         } else {
           // Handle output items in ProcessBlocks
           for (unsigned int k = InProcess; k < numberOfTTrees; ++k) {
             OutputItemList& outputItemList = selectedOutputItemList_[k];
             std::string const& processName = processesWithProcessBlockProducts[k - InProcess];
             TTree* theInputTree = fb.processBlockTree(processName);
             fillSelectedItemList(branchType, processName, theInputTree, outputItemList);
           }
         }
       }
       initializedFromInput_ = true;
     }
     ++inputFileCount_;
     beginInputFile(fb);
   }

◆ selectedOutputItemList() [1/2]

std::vector<OutputItemList> const& edm::PoolOutputModule::selectedOutputItemList ( ) const

inline

Definition at line 130 of file PoolOutputModule.h.

References selectedOutputItemList_.

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

130 { return selectedOutputItemList_; }

edm::PoolOutputModule::selectedOutputItemList_

std::vector< OutputItemList > selectedOutputItemList_

Definition: PoolOutputModule.h:191

◆ selectedOutputItemList() [2/2]

std::vector<OutputItemList>& edm::PoolOutputModule::selectedOutputItemList ( )

inline

Definition at line 132 of file PoolOutputModule.h.

References selectedOutputItemList_.

132 { return selectedOutputItemList_; }

edm::PoolOutputModule::selectedOutputItemList_

std::vector< OutputItemList > selectedOutputItemList_

Definition: PoolOutputModule.h:191

◆ setProcessesWithSelectedMergeableRunProducts()

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

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 288 of file PoolOutputModule.cc.

References dqmiodatasetharvest::processes, and processesWithSelectedMergeableRunProducts_.

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

◆ 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::core::OutputModuleCore.

Reimplemented in edm::TimeoutPoolOutputModule.

Definition at line 359 of file PoolOutputModule.cc.

References rootOutputFile_.

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

359 { return rootOutputFile_->shouldWeCloseFile(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ splitLevel()

int edm::PoolOutputModule::splitLevel ( ) const

inline

Definition at line 55 of file PoolOutputModule.h.

References splitLevel_.

55 { return splitLevel_; }

edm::PoolOutputModule::splitLevel_

int const splitLevel_

Definition: PoolOutputModule.h:202

◆ startEndFile()

void edm::PoolOutputModule::startEndFile ( )

private

Definition at line 336 of file PoolOutputModule.cc.

Referenced by reallyCloseFile().

336 {}

◆ treeMaxVirtualSize()

int edm::PoolOutputModule::treeMaxVirtualSize ( ) const

inline

Definition at line 57 of file PoolOutputModule.h.

References treeMaxVirtualSize_.

57 { return treeMaxVirtualSize_; }

edm::PoolOutputModule::treeMaxVirtualSize_

int const treeMaxVirtualSize_

Definition: PoolOutputModule.h:204

◆ updateBranchParents()

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

private

Definition at line 412 of file PoolOutputModule.cc.

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

Referenced by write().

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

◆ updateBranchParentsForOneBranch()

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

private

Definition at line 400 of file PoolOutputModule.cc.

References edm::PoolOutputModule::OutputItem::branchID(), edm::ProductProvenanceLookup::branchIDToProvenanceForProducedOnly(), branchParents_, and crab_script::provenance.

Referenced by updateBranchParents().

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

◆ whyNotFastClonable()

int edm::PoolOutputModule::whyNotFastClonable ( ) const

inline

Definition at line 66 of file PoolOutputModule.h.

References whyNotFastClonable_.

66 { return whyNotFastClonable_; }

edm::PoolOutputModule::whyNotFastClonable_

int whyNotFastClonable_

Definition: PoolOutputModule.h:205

◆ write()

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

overrideprotectedvirtual

Implements edm::core::OutputModuleCore.

Reimplemented in edm::TimeoutPoolOutputModule.

Definition at line 294 of file PoolOutputModule.cc.

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

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

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

◆ writeBranchIDListRegistry()

void edm::PoolOutputModule::writeBranchIDListRegistry ( )

private

Definition at line 348 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

348 { rootOutputFile_->writeBranchIDListRegistry(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeEventAuxiliary()

void edm::PoolOutputModule::writeEventAuxiliary ( )

private

Definition at line 351 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

351 { rootOutputFile_->writeEventAuxiliary(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeFileFormatVersion()

void edm::PoolOutputModule::writeFileFormatVersion ( )

private

Definition at line 338 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

338 { rootOutputFile_->writeFileFormatVersion(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeFileIdentifier()

void edm::PoolOutputModule::writeFileIdentifier ( )

private

Definition at line 339 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

339 { rootOutputFile_->writeFileIdentifier(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeIndexIntoFile()

void edm::PoolOutputModule::writeIndexIntoFile ( )

private

Definition at line 340 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

340 { rootOutputFile_->writeIndexIntoFile(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeLuminosityBlock()

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

overrideprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 304 of file PoolOutputModule.cc.

References rootOutputFile_.

                                                                                 {
     rootOutputFile_->writeLuminosityBlock(lb);
   }

◆ writeParameterSetRegistry()

void edm::PoolOutputModule::writeParameterSetRegistry ( )

private

Definition at line 345 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

345 { rootOutputFile_->writeParameterSetRegistry(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeParentageRegistry()

void edm::PoolOutputModule::writeParentageRegistry ( )

private

Definition at line 347 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

347 { rootOutputFile_->writeParentageRegistry(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeProcessBlock()

void edm::PoolOutputModule::writeProcessBlock ( ProcessBlockForOutput const & pb )

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 310 of file PoolOutputModule.cc.

References rootOutputFile_.

310 { rootOutputFile_->writeProcessBlock(pb); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeProcessBlockHelper()

void edm::PoolOutputModule::writeProcessBlockHelper ( )

private

Definition at line 352 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

352 { rootOutputFile_->writeProcessBlockHelper(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeProcessHistoryRegistry()

void edm::PoolOutputModule::writeProcessHistoryRegistry ( )

private

Definition at line 344 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

344 { rootOutputFile_->writeProcessHistoryRegistry(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeProductDependencies()

void edm::PoolOutputModule::writeProductDependencies ( )

private

Definition at line 350 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

350 { rootOutputFile_->writeProductDependencies(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeProductDescriptionRegistry()

void edm::PoolOutputModule::writeProductDescriptionRegistry ( )

private

Definition at line 346 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

346 { rootOutputFile_->writeProductDescriptionRegistry(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeRun()

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

overrideprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 308 of file PoolOutputModule.cc.

References rootOutputFile_.

308 { rootOutputFile_->writeRun(r); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

◆ writeStoredMergeableRunProductMetadata()

void edm::PoolOutputModule::writeStoredMergeableRunProductMetadata ( )

private

Definition at line 341 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

                                                                 {
     rootOutputFile_->writeStoredMergeableRunProductMetadata();
   }

◆ writeThinnedAssociationsHelper()

void edm::PoolOutputModule::writeThinnedAssociationsHelper ( )

private

Definition at line 349 of file PoolOutputModule.cc.

References rootOutputFile_.

Referenced by reallyCloseFile().

349 { rootOutputFile_->writeThinnedAssociationsHelper(); }

edm::PoolOutputModule::rootOutputFile_

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

Definition: PoolOutputModule.h:217

Member Data Documentation

◆ auxItems_

AuxItemArray edm::PoolOutputModule::auxItems_

private

Definition at line 190 of file PoolOutputModule.h.

Referenced by auxItems(), and fillSelectedItemList().

◆ basketOrder_

std::string edm::PoolOutputModule::basketOrder_

private

Definition at line 203 of file PoolOutputModule.h.

Referenced by basketOrder().

◆ basketSize_

int const edm::PoolOutputModule::basketSize_

private

Definition at line 199 of file PoolOutputModule.h.

Referenced by basketSize().

◆ branchChildren_

BranchChildren edm::PoolOutputModule::branchChildren_

private

Definition at line 212 of file PoolOutputModule.h.

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

◆ branchParents_

BranchParents edm::PoolOutputModule::branchParents_

private

Definition at line 211 of file PoolOutputModule.h.

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

◆ catalog_

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

private

Definition at line 195 of file PoolOutputModule.h.

Referenced by catalog().

◆ compactEventAuxiliary_

bool edm::PoolOutputModule::compactEventAuxiliary_

private

Definition at line 215 of file PoolOutputModule.h.

Referenced by compactEventAuxiliary().

◆ compressionAlgorithm_

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

private

Definition at line 198 of file PoolOutputModule.h.

Referenced by compressionAlgorithm().

◆ compressionLevel_

int const edm::PoolOutputModule::compressionLevel_

private

Definition at line 197 of file PoolOutputModule.h.

Referenced by compressionLevel().

◆ dropMetaData_

DropMetaData edm::PoolOutputModule::dropMetaData_

private

Definition at line 206 of file PoolOutputModule.h.

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

◆ eventAutoFlushSize_

int const edm::PoolOutputModule::eventAutoFlushSize_

private

Definition at line 201 of file PoolOutputModule.h.

Referenced by eventAutoFlushSize().

◆ eventAuxBasketSize_

int const edm::PoolOutputModule::eventAuxBasketSize_

private

Definition at line 200 of file PoolOutputModule.h.

Referenced by eventAuxiliaryBasketSize(), and fillSelectedItemList().

◆ fileName_

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

private

Definition at line 193 of file PoolOutputModule.h.

Referenced by fileName().

◆ initializedFromInput_

bool edm::PoolOutputModule::initializedFromInput_

private

Definition at line 208 of file PoolOutputModule.h.

Referenced by respondToOpenInputFile().

◆ inputFileCount_

int edm::PoolOutputModule::inputFileCount_

private

Definition at line 210 of file PoolOutputModule.h.

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

◆ logicalFileName_

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

private

Definition at line 194 of file PoolOutputModule.h.

Referenced by logicalFileName().

◆ maxFileSize_

unsigned int const edm::PoolOutputModule::maxFileSize_

private

Definition at line 196 of file PoolOutputModule.h.

Referenced by maxFileSize().

◆ mergeJob_

bool edm::PoolOutputModule::mergeJob_

private

Definition at line 216 of file PoolOutputModule.h.

Referenced by mergeJob().

◆ moduleLabel_

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

private

Definition at line 207 of file PoolOutputModule.h.

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

◆ outputFileCount_

int edm::PoolOutputModule::outputFileCount_

private

Definition at line 209 of file PoolOutputModule.h.

Referenced by physicalAndLogicalNameForNewFile().

◆ overrideGUID_

std::string edm::PoolOutputModule::overrideGUID_

private

Definition at line 219 of file PoolOutputModule.h.

Referenced by reallyOpenFile().

◆ overrideInputFileSplitLevels_

bool edm::PoolOutputModule::overrideInputFileSplitLevels_

private

Definition at line 214 of file PoolOutputModule.h.

Referenced by fillSelectedItemList(), and overrideInputFileSplitLevels().

◆ processesWithSelectedMergeableRunProducts_

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

private

Definition at line 220 of file PoolOutputModule.h.

Referenced by reallyOpenFile(), and setProcessesWithSelectedMergeableRunProducts().

◆ producedBranches_

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

private

Definition at line 213 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 189 of file PoolOutputModule.h.

◆ selectedOutputItemList_

std::vector<OutputItemList> edm::PoolOutputModule::selectedOutputItemList_

private

Definition at line 191 of file PoolOutputModule.h.

Referenced by respondToOpenInputFile(), and selectedOutputItemList().

◆ specialSplitLevelForBranches_

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

private

Definition at line 192 of file PoolOutputModule.h.

Referenced by fillSelectedItemList(), and PoolOutputModule().

◆ splitLevel_

int const edm::PoolOutputModule::splitLevel_

private

Definition at line 202 of file PoolOutputModule.h.

Referenced by splitLevel().

◆ statusFileName_

std::string edm::PoolOutputModule::statusFileName_

private

Definition at line 218 of file PoolOutputModule.h.

Referenced by PoolOutputModule(), and write().

◆ treeMaxVirtualSize_

int const edm::PoolOutputModule::treeMaxVirtualSize_

private

Definition at line 204 of file PoolOutputModule.h.

Referenced by treeMaxVirtualSize().

◆ whyNotFastClonable_

int edm::PoolOutputModule::whyNotFastClonable_

private

Definition at line 205 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

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ AuxItemArray

◆ BranchParents

◆ OutputItemList

Member Enumeration Documentation

◆ DropMetaData

Constructor & Destructor Documentation

◆ PoolOutputModule() [1/2]

◆ ~PoolOutputModule()

◆ PoolOutputModule() [2/2]

Member Function Documentation

◆ auxItems()

◆ basketOrder()

◆ basketSize()

◆ beginInputFile()

◆ beginJob()

◆ branchChildren()

◆ catalog()

◆ compactEventAuxiliary()

◆ compressionAlgorithm()

◆ compressionLevel()

◆ currentFileName()

◆ doExtrasAfterCloseFile()

◆ dropMetaData()

◆ eventAutoFlushSize()

◆ eventAuxiliaryBasketSize()

◆ fileName()

◆ fillDependencyGraph()

◆ fillDescription()

◆ fillDescriptions()

◆ fillSelectedItemList()

◆ finishEndFile()

◆ inputFileCount()

◆ isFileOpen()

◆ logicalFileName()

◆ maxFileSize()

◆ mergeJob()

◆ 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()

◆ writeEventAuxiliary()

◆ writeFileFormatVersion()

◆ writeFileIdentifier()

◆ writeIndexIntoFile()

◆ writeLuminosityBlock()

◆ writeParameterSetRegistry()

◆ writeParentageRegistry()

◆ writeProcessBlock()

◆ writeProcessBlockHelper()

◆ writeProcessHistoryRegistry()

◆ writeProductDependencies()