#include <PoolOutputModule.h>
Classes | |
struct | AuxItem |
struct | OutputItem |
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 |
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) |
static void | fillDescriptions (ConfigurationDescriptions &descriptions) |
static void | prevalidate (ConfigurationDescriptions &) |
Protected Member Functions | |
virtual void | doExtrasAfterCloseFile () |
virtual std::pair< std::string, std::string > | physicalAndLogicalNameForNewFile () |
virtual bool | shouldWeCloseFile () const override |
allow inheriting classes to override but still be able to call this method in the overridden version More... | |
virtual 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, EventSetup const &c, ModuleCallingContext const *) |
bool | doBeginRun (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *) |
void | doEndJob () |
bool | doEndLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *) |
bool | doEndRun (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *) |
bool | doEvent (EventPrincipal const &ep, EventSetup const &c, ActivityRegistry *, ModuleCallingContext const *) |
void | doPreallocate (PreallocationConfiguration const &) |
std::map< BranchID::value_type, BranchID::value_type > const & | droppedBranchIDToKeptBranchID () |
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) |
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 ProductType , BranchType B = InEvent> | |
void | consumesMany () |
void | consumesMany (const TypeToGet &id) |
template<BranchType B> | |
void | consumesMany (const TypeToGet &id) |
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) |
Private Types | |
typedef std::map< BranchID, std::set< ParentageID > > | BranchParents |
Private Member Functions | |
void | beginInputFile (FileBlock const &fb) |
virtual void | beginJob () override |
void | fillDependencyGraph () |
void | fillSelectedItemList (BranchType branchtype, TTree *theInputTree) |
void | finishEndFile () |
virtual bool | isFileOpen () const override |
virtual void | openFile (FileBlock const &fb) override |
virtual void | postForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren) override |
virtual void | preActionBeforeRunEventAsync (WaitingTask *iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) const override |
virtual void | reallyCloseFile () override |
virtual void | reallyOpenFile () override |
virtual void | respondToCloseInputFile (FileBlock const &fb) override |
virtual void | respondToOpenInputFile (FileBlock const &fb) override |
void | startEndFile () |
void | updateBranchParents (EventForOutput const &e) |
void | updateBranchParentsForOneBranch (ProductProvenanceRetriever const *provRetriever, BranchID const &branchID) |
void | writeBranchIDListRegistry () |
void | writeFileFormatVersion () |
void | writeFileIdentifier () |
void | writeIndexIntoFile () |
virtual void | writeLuminosityBlock (LuminosityBlockForOutput const &lb) override |
void | writeParameterSetRegistry () |
void | writeParentageRegistry () |
void | writeProcessHistoryRegistry () |
void | writeProductDependencies () |
void | writeProductDescriptionRegistry () |
virtual void | writeRun (RunForOutput const &r) override |
void | writeThinnedAssociationsHelper () |
Private Attributes | |
AuxItemArray | auxItems_ |
std::string | basketOrder_ |
int const | basketSize_ |
BranchChildren | branchChildren_ |
BranchParents | branchParents_ |
std::string const | catalog_ |
unsigned int | childIndex_ |
std::string const | compressionAlgorithm_ |
int const | compressionLevel_ |
DropMetaData | dropMetaData_ |
int const | eventAutoFlushSize_ |
std::string const | fileName_ |
bool | initializedFromInput_ |
int | inputFileCount_ |
std::string const | logicalFileName_ |
unsigned int const | maxFileSize_ |
std::string const | moduleLabel_ |
unsigned int | numberOfDigitsInIndex_ |
int | outputFileCount_ |
bool | overrideInputFileSplitLevels_ |
std::vector< BranchID > | producedBranches_ |
edm::propagate_const< std::unique_ptr< RootOutputFile > > | rootOutputFile_ |
RootServiceChecker | rootServiceChecker_ |
OutputItemListArray | selectedOutputItemList_ |
int const | splitLevel_ |
std::string | statusFileName_ |
int const | treeMaxVirtualSize_ |
int | whyNotFastClonable_ |
Definition at line 38 of file PoolOutputModule.h.
typedef std::array<AuxItem, NumBranchTypes> edm::PoolOutputModule::AuxItemArray |
Definition at line 74 of file PoolOutputModule.h.
|
private |
Definition at line 135 of file PoolOutputModule.h.
typedef std::vector<OutputItem> edm::PoolOutputModule::OutputItemList |
Definition at line 106 of file PoolOutputModule.h.
typedef std::array<OutputItemList, NumBranchTypes> edm::PoolOutputModule::OutputItemListArray |
Definition at line 108 of file PoolOutputModule.h.
Enumerator | |
---|---|
DropNone | |
DropDroppedPrior | |
DropPrior | |
DropAll |
Definition at line 40 of file PoolOutputModule.h.
|
explicit |
Definition at line 35 of file PoolOutputModule.cc.
References edm::errors::Configuration, DropAll, DropDroppedPrior, dropMetaData(), dropMetaData_, DropNone, DropPrior, edm::FileBlock::EventSelectionUsed, Exception, edm::ParameterSet::getUntrackedParameter(), edm::ParameterSet::getUntrackedParameterSet(), moduleLabel_, statusFileName_, AlCaHLTBitMon_QueryRunRegistry::string, edm::one::OutputModuleBase::wantAllEvents(), and whyNotFastClonable_.
|
virtual |
Definition at line 250 of file PoolOutputModule.cc.
|
delete |
|
inline |
|
inline |
|
inline |
Definition at line 49 of file PoolOutputModule.h.
References basketSize_.
Referenced by fillSelectedItemList().
|
private |
Definition at line 199 of file PoolOutputModule.cc.
References edm::FileBlock::branchChildren(), branchChildren_, edm::BranchChildren::childLookup(), edm::BranchChildren::insertChild(), isFileOpen(), edm::one::OutputModuleBase::remainingEvents(), and rootOutputFile_.
Referenced by openFile(), and respondToOpenInputFile().
|
overrideprivatevirtual |
Reimplemented from edm::one::OutputModuleBase.
Definition at line 94 of file PoolOutputModule.cc.
References edm::BranchDescription::branchID(), edm::BranchDescription::branchType(), edm::InEvent, edm::BranchDescription::isAlias(), parseEventContent::prod, edm::BranchDescription::produced(), and producedBranches_.
Referenced by branchChildren().
|
inline |
Definition at line 112 of file PoolOutputModule.h.
References beginJob(), branchChildren_, doExtrasAfterCloseFile(), MillePedeFileConverter_cfg::e, benchmark_cfg::fb, isFileOpen(), openFile(), physicalAndLogicalNameForNewFile(), postForkReacquireResources(), preActionBeforeRunEventAsync(), alignCSCRings::r, reallyCloseFile(), reallyOpenFile(), respondToCloseInputFile(), respondToOpenInputFile(), shouldWeCloseFile(), write(), writeLuminosityBlock(), and writeRun().
|
inline |
|
inline |
Definition at line 48 of file PoolOutputModule.h.
References compressionAlgorithm_.
|
inline |
Definition at line 47 of file PoolOutputModule.h.
References compressionLevel_.
std::string const & edm::PoolOutputModule::currentFileName | ( | ) | const |
Definition at line 104 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by edm::TimeoutPoolOutputModule::shouldWeCloseFile(), and whyNotFastClonable().
|
protectedvirtual |
Reimplemented in dqmservices::JsonWritingTimeoutPoolOutputModule.
Definition at line 306 of file PoolOutputModule.cc.
Referenced by branchChildren(), and reallyCloseFile().
|
inline |
Definition at line 55 of file PoolOutputModule.h.
References dropMetaData_.
Referenced by PoolOutputModule().
|
inline |
Definition at line 50 of file PoolOutputModule.h.
References eventAutoFlushSize_.
Referenced by edm::RootOutputFile::RootOutputFile().
|
inline |
Definition at line 45 of file PoolOutputModule.h.
References fileName_.
Referenced by physicalAndLogicalNameForNewFile().
|
private |
Definition at line 395 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().
|
static |
Definition at line 411 of file PoolOutputModule.cc.
References edm::ParameterSetDescription::addUntracked(), edm::OutputModule::fillDescription(), edm::ParameterSetDescription::setAllowAnything(), edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by fillDescriptions(), and whyNotFastClonable().
|
static |
Definition at line 461 of file PoolOutputModule.cc.
References edm::ConfigurationDescriptions::add(), and fillDescription().
Referenced by whyNotFastClonable().
|
private |
Definition at line 158 of file PoolOutputModule.cc.
References auxItems_, basketSize(), edm::BranchDescription::basketSize(), edm::PoolOutputModule::AuxItem::basketSize_, edm::PoolOutputModule::OutputItem::basketSize_, edm::BranchDescription::branchName(), revisionDML::branchType(), edm::BranchTypeToAuxiliaryBranchName(), edm::BranchDescription::invalidBasketSize, edm::BranchDescription::invalidSplitLevel, edm::one::OutputModuleBase::keptProducts(), overrideInputFileSplitLevels_, parseEventContent::prod, edm::BranchDescription::produced(), selectedOutputItemList_, edm::sort_all(), splitLevel(), edm::BranchDescription::splitLevel(), and edm::PoolOutputModule::OutputItem::splitLevel_.
Referenced by respondToOpenInputFile().
|
private |
Definition at line 305 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
inline |
|
overrideprivatevirtual |
Reimplemented from edm::one::OutputModuleBase.
Definition at line 307 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by beginInputFile(), branchChildren(), and openFile().
|
inline |
Definition at line 46 of file PoolOutputModule.h.
References logicalFileName_.
Referenced by physicalAndLogicalNameForNewFile().
|
inline |
Definition at line 58 of file PoolOutputModule.h.
References maxFileSize_.
|
inline |
|
overrideprivatevirtual |
Reimplemented from edm::one::OutputModuleBase.
Definition at line 213 of file PoolOutputModule.cc.
References beginInputFile(), isFileOpen(), and reallyOpenFile().
Referenced by branchChildren().
|
delete |
|
inline |
Definition at line 54 of file PoolOutputModule.h.
References overrideInputFileSplitLevels_.
|
protectedvirtual |
Reimplemented in dqmservices::JsonWritingTimeoutPoolOutputModule.
Definition at line 311 of file PoolOutputModule.cc.
References childIndex_, relativeConstraints::empty, Exception, fileName(), inputFileCount_, logicalFileName(), edm::errors::LogicError, numberOfDigitsInIndex_, PFRecoTauDiscriminationByIsolation_cfi::offset, outputFileCount_, AlCaHLTBitMon_QueryRunRegistry::string, and createPayload::suffix.
Referenced by branchChildren(), and reallyOpenFile().
|
overrideprivatevirtual |
Reimplemented from edm::one::OutputModuleBase.
Definition at line 239 of file PoolOutputModule.cc.
References childIndex_, and numberOfDigitsInIndex_.
Referenced by branchChildren().
|
overrideprivatevirtual |
Reimplemented from edm::one::OutputModuleBase.
Definition at line 381 of file PoolOutputModule.cc.
References DropAll, dropMetaData_, edm::EventPrincipal::productProvenanceRetrieverPtr(), and edm::ProductProvenanceRetriever::readProvenanceAsync().
Referenced by branchChildren().
|
overrideprivatevirtual |
Reimplemented from edm::one::OutputModuleBase.
Definition at line 271 of file PoolOutputModule.cc.
References branchChildren_, branchParents_, edm::BranchChildren::clear(), doExtrasAfterCloseFile(), fillDependencyGraph(), finishEndFile(), startEndFile(), writeBranchIDListRegistry(), writeFileFormatVersion(), writeFileIdentifier(), writeIndexIntoFile(), writeParameterSetRegistry(), writeParentageRegistry(), writeProcessHistoryRegistry(), writeProductDependencies(), writeProductDescriptionRegistry(), and writeThinnedAssociationsHelper().
Referenced by branchChildren().
|
overrideprivatevirtual |
Reimplemented from edm::one::OutputModuleBase.
Definition at line 344 of file PoolOutputModule.cc.
References cscdqm::h::names, physicalAndLogicalNameForNewFile(), and rootOutputFile_.
Referenced by branchChildren(), and openFile().
|
overrideprivatevirtual |
Definition at line 235 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by branchChildren().
|
overrideprivatevirtual |
Definition at line 220 of file PoolOutputModule.cc.
References beginInputFile(), revisionDML::branchType(), fillSelectedItemList(), mps_fire::i, edm::InEvent, initializedFromInput_, edm::InLumi, inputFileCount_, edm::FileBlock::lumiTree(), edm::NumBranchTypes, edm::FileBlock::runTree(), and edm::FileBlock::tree().
Referenced by branchChildren().
|
inline |
Definition at line 110 of file PoolOutputModule.h.
References selectedOutputItemList_.
Referenced by edm::RootOutputFile::RootOutputFile().
|
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 308 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by branchChildren(), and edm::TimeoutPoolOutputModule::shouldWeCloseFile().
|
inline |
Definition at line 51 of file PoolOutputModule.h.
References splitLevel_.
Referenced by fillSelectedItemList().
|
private |
|
inline |
Definition at line 53 of file PoolOutputModule.h.
References treeMaxVirtualSize_.
|
private |
Definition at line 366 of file PoolOutputModule.cc.
References producedBranches_, edm::EventForOutput::productProvenanceRetrieverPtr(), edm::one::OutputModuleBase::subProcessParentageHelper(), and updateBranchParentsForOneBranch().
Referenced by write().
|
private |
Definition at line 350 of file PoolOutputModule.cc.
References edm::ProductProvenanceRetriever::branchIDToProvenanceForProducedOnly(), branchParents_, and edm::ProductProvenance::parentageID().
Referenced by updateBranchParents().
|
inline |
Definition at line 60 of file PoolOutputModule.h.
References currentFileName(), fillDescription(), fillDescriptions(), edm::OutputModule::selectorConfig(), AlCaHLTBitMon_QueryRunRegistry::string, and whyNotFastClonable_.
|
overrideprotectedvirtual |
Implements edm::one::OutputModuleBase.
Reimplemented in edm::TimeoutPoolOutputModule.
Definition at line 253 of file PoolOutputModule.cc.
References edm::EventForOutput::id(), rootOutputFile_, statusFileName_, and updateBranchParents().
Referenced by branchChildren(), and edm::TimeoutPoolOutputModule::write().
|
private |
Definition at line 302 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
private |
Definition at line 295 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
private |
Definition at line 296 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
private |
Definition at line 297 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
overrideprivatevirtual |
Implements edm::one::OutputModuleBase.
Definition at line 263 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by branchChildren().
|
private |
Definition at line 299 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
private |
Definition at line 301 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
private |
Definition at line 298 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
private |
Definition at line 304 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
private |
Definition at line 300 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
overrideprivatevirtual |
Implements edm::one::OutputModuleBase.
Definition at line 267 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by branchChildren().
|
private |
Definition at line 303 of file PoolOutputModule.cc.
References rootOutputFile_.
Referenced by reallyCloseFile().
|
private |
Definition at line 158 of file PoolOutputModule.h.
Referenced by auxItems(), and fillSelectedItemList().
|
private |
Definition at line 169 of file PoolOutputModule.h.
Referenced by basketOrder().
|
private |
Definition at line 166 of file PoolOutputModule.h.
Referenced by basketSize().
|
private |
Definition at line 180 of file PoolOutputModule.h.
Referenced by beginInputFile(), branchChildren(), fillDependencyGraph(), and reallyCloseFile().
|
private |
Definition at line 179 of file PoolOutputModule.h.
Referenced by fillDependencyGraph(), reallyCloseFile(), and updateBranchParentsForOneBranch().
|
private |
Definition at line 162 of file PoolOutputModule.h.
Referenced by catalog().
|
private |
Definition at line 177 of file PoolOutputModule.h.
Referenced by physicalAndLogicalNameForNewFile(), and postForkReacquireResources().
|
private |
Definition at line 165 of file PoolOutputModule.h.
Referenced by compressionAlgorithm().
|
private |
Definition at line 164 of file PoolOutputModule.h.
Referenced by compressionLevel().
|
private |
Definition at line 172 of file PoolOutputModule.h.
Referenced by dropMetaData(), PoolOutputModule(), and preActionBeforeRunEventAsync().
|
private |
Definition at line 167 of file PoolOutputModule.h.
Referenced by eventAutoFlushSize().
|
private |
Definition at line 160 of file PoolOutputModule.h.
Referenced by fileName().
|
private |
Definition at line 174 of file PoolOutputModule.h.
Referenced by respondToOpenInputFile().
|
private |
Definition at line 176 of file PoolOutputModule.h.
Referenced by inputFileCount(), physicalAndLogicalNameForNewFile(), and respondToOpenInputFile().
|
private |
Definition at line 161 of file PoolOutputModule.h.
Referenced by logicalFileName().
|
private |
Definition at line 163 of file PoolOutputModule.h.
Referenced by maxFileSize().
|
private |
Definition at line 173 of file PoolOutputModule.h.
Referenced by Mixins._TypedParameterizable::insertInto(), moduleLabel(), Modules.ESSource::nameInProcessDesc_(), Modules.ESProducer::nameInProcessDesc_(), and PoolOutputModule().
|
private |
Definition at line 178 of file PoolOutputModule.h.
Referenced by physicalAndLogicalNameForNewFile(), and postForkReacquireResources().
|
private |
Definition at line 175 of file PoolOutputModule.h.
Referenced by physicalAndLogicalNameForNewFile().
|
private |
Definition at line 182 of file PoolOutputModule.h.
Referenced by fillSelectedItemList(), and overrideInputFileSplitLevels().
|
private |
Definition at line 181 of file PoolOutputModule.h.
Referenced by beginJob(), and updateBranchParents().
|
private |
Definition at line 183 of file PoolOutputModule.h.
Referenced by beginInputFile(), currentFileName(), finishEndFile(), isFileOpen(), reallyOpenFile(), respondToCloseInputFile(), shouldWeCloseFile(), write(), writeBranchIDListRegistry(), writeFileFormatVersion(), writeFileIdentifier(), writeIndexIntoFile(), writeLuminosityBlock(), writeParameterSetRegistry(), writeParentageRegistry(), writeProcessHistoryRegistry(), writeProductDependencies(), writeProductDescriptionRegistry(), writeRun(), and writeThinnedAssociationsHelper().
|
private |
Definition at line 157 of file PoolOutputModule.h.
|
private |
Definition at line 159 of file PoolOutputModule.h.
Referenced by fillSelectedItemList(), and selectedOutputItemList().
|
private |
Definition at line 168 of file PoolOutputModule.h.
Referenced by splitLevel().
|
private |
Definition at line 184 of file PoolOutputModule.h.
Referenced by PoolOutputModule(), and write().
|
private |
Definition at line 170 of file PoolOutputModule.h.
Referenced by treeMaxVirtualSize().
|
private |
Definition at line 171 of file PoolOutputModule.h.
Referenced by PoolOutputModule(), and whyNotFastClonable().