Go to the documentation of this file. 1 #ifndef FWCore_Framework_limited_OutputModuleBase_h
2 #define FWCore_Framework_limited_OutputModuleBase_h
48 class MergeableRunProductMetadata;
49 class ModuleCallingContext;
50 class PreallocationConfiguration;
52 class ThinnedAssociationsHelper;
56 class OutputModuleCommunicatorT;
70 friend class ::edm::WorkerT;
72 friend class ::edm::OutputModuleCommunicatorT;
149 bool anyProductProduced);
185 std::vector<detail::TriggerResultsBasedEventSelector>
selectors_;
270 std::map<BranchID, BranchDescription const*>& trueBranchIDToKeptBranchDesc,
271 std::set<BranchID>& keptProductsInEvent);
bool doBeginRun(RunTransitionInfo const &, ModuleCallingContext const *)
LimitedTaskQueue & queue()
bool wantAllEvents() const
void doOpenFile(FileBlock const &fb)
unsigned int concurrencyLimit() const
virtual bool wantsStreamLuminosityBlocks() const =0
virtual void preallocLumis(unsigned int)
virtual void doStreamEndRunSummary_(StreamID, RunForOutput const &, EventSetup const &)
bool doEvent(EventTransitionInfo const &, ActivityRegistry *, ModuleCallingContext const *)
std::map< BranchID::value_type, BranchID::value_type > const & droppedBranchIDToKeptBranchID()
virtual void doStreamEndLuminosityBlockSummary_(StreamID, LuminosityBlockForOutput const &, EventSetup const &)
virtual void preallocate(PreallocationConfiguration const &)
OutputModuleBase ModuleType
virtual void doBeginLuminosityBlockSummary_(LuminosityBlockForOutput const &, EventSetup const &)
virtual bool isFileOpen() const
static void fillDescription(ParameterSetDescription &desc)
std::string workerType() const
ParameterSetID selectorConfig() const
BranchIDLists const * branchIDLists() const
virtual void writeRun(RunForOutput const &)=0
void doRespondToCloseInputFile(FileBlock const &fb)
ModuleDescription const & description() const
const ModuleDescription & moduleDescription() const
bool doEndLuminosityBlock(LumiTransitionInfo const &, ModuleCallingContext const *)
virtual void doEndLuminosityBlock_(LuminosityBlockForOutput const &)
bool needToRunSelection() const
virtual void doEndLuminosityBlockSummary_(LuminosityBlockForOutput const &, EventSetup const &)
bool wantsGlobalRuns() const
virtual void doStreamEndLuminosityBlock_(StreamID, LuminosityBlockForOutput const &, EventSetup const &)
virtual void doBeginRunSummary_(RunForOutput const &, EventSetup const &)
std::vector< detail::TriggerResultsBasedEventSelector > selectors_
virtual bool shouldWeCloseFile() const
Ask the OutputModule if we should end the current file.
virtual void openFile(FileBlock const &) const
static const std::string & baseType()
std::array< bool, NumBranchTypes > hasNewlyDroppedBranch_
void selectProducts(ProductRegistry const &preg, ThinnedAssociationsHelper const &)
virtual bool wantsStreamRuns() const =0
ParameterSet selectEvents_
virtual void doStreamEndRun_(StreamID, RunForOutput const &, EventSetup const &)
ModuleDescription moduleDescription_
ProductSelectorRules productSelectorRules_
virtual void reallyCloseFile()
OutputModuleBase(ParameterSet const &pset)
void doAccessInputProcessBlock(ProcessBlockPrincipal const &, ModuleCallingContext const *)
void doBeginProcessBlock(ProcessBlockPrincipal const &, ModuleCallingContext const *)
std::vector< ProductResolverIndexAndSkipBit > productsUsedBySelection() const
SelectedProductsForBranchType keptProducts_
void doEndProcessBlock(ProcessBlockPrincipal const &, ModuleCallingContext const *)
bool doBeginLuminosityBlock(LumiTransitionInfo const &, ModuleCallingContext const *)
void registerProductsAndCallbacks(OutputModuleBase const *, ProductRegistry const *)
std::vector< BranchIDList > BranchIDLists
edm::propagate_const< std::unique_ptr< BranchIDLists > > branchIDLists_
unsigned int concurrencyLimit() const
static void prevalidate(ConfigurationDescriptions &)
virtual bool wantsInputProcessBlocks() const =0
static void fillDescriptions(ConfigurationDescriptions &descriptions)
~OutputModuleBase() override
std::map< BranchID::value_type, BranchID::value_type > droppedBranchIDToKeptBranchID_
virtual void doStreamBeginRun_(StreamID, RunForOutput const &, EventSetup const &)
virtual void doEndRunSummary_(RunForOutput const &, EventSetup const &)
ThinnedAssociationsHelper const * thinnedAssociationsHelper() const
ParameterSetID selector_config_id_
edm::propagate_const< std::unique_ptr< ThinnedAssociationsHelper > > thinnedAssociationsHelper_
virtual void write(EventForOutput const &)=0
SelectedProductsForBranchType const & keptProducts() const
void doRegisterThinnedAssociations(ProductRegistry const &, ThinnedAssociationsHelper &)
virtual void doStreamBeginLuminosityBlock_(StreamID, LuminosityBlockForOutput const &, EventSetup const &)
void doCloseFile()
Tell the OutputModule that is must end the current file.
bool wantsGlobalLuminosityBlocks() const
virtual void writeLuminosityBlock(LuminosityBlockForOutput const &)=0
void configure(OutputModuleDescription const &desc)
bool prePrefetchSelection(StreamID id, EventPrincipal const &, ModuleCallingContext const *)
virtual void doRespondToOpenInputFile_(FileBlock const &)
ProductSelector productSelector_
std::string const & processName() const
std::array< bool, NumBranchTypes > const & hasNewlyDroppedBranch() const
int remainingEvents() const
BranchIDLists const * origBranchIDLists_
virtual void doBeginStream_(StreamID)
void doWriteLuminosityBlock(LuminosityBlockPrincipal const &lbp, ModuleCallingContext const *)
void doPreallocate(PreallocationConfiguration const &)
std::array< SelectedProducts, NumBranchTypes > SelectedProductsForBranchType
virtual void doEndStream_(StreamID)
OutputModuleBase & operator=(OutputModuleBase const &)=delete
std::atomic< int > remainingEvents_
bool limitReached() const
std::string process_name_
void doRespondToOpenInputFile(FileBlock const &fb)
void setModuleDescription(ModuleDescription const &md)
void updateBranchIDListsWithKeptAliases()
virtual bool wantsProcessBlocks() const =0
bool selected(BranchDescription const &desc) const
virtual void preallocStreams(unsigned int)
void doBeginStream(StreamID id)
void preActionBeforeRunEventAsync(WaitingTask *, ModuleCallingContext const &, Principal const &) const
virtual void doBeginLuminosityBlock_(LuminosityBlockForOutput const &)
void doWriteProcessBlock(ProcessBlockPrincipal const &, ModuleCallingContext const *)
bool doEndRun(RunTransitionInfo const &, ModuleCallingContext const *)
virtual void setProcessesWithSelectedMergeableRunProducts(std::set< std::string > const &)
std::map< BranchID, bool > keepAssociation_
bool hasAccumulator() const
void doWriteRun(RunPrincipal const &rp, ModuleCallingContext const *, MergeableRunProductMetadata const *)
virtual void doEndRun_(RunForOutput const &)
void keepThisBranch(BranchDescription const &desc, std::map< BranchID, BranchDescription const * > &trueBranchIDToKeptBranchDesc, std::set< BranchID > &keptProductsInEvent)
virtual void doRespondToCloseInputFile_(FileBlock const &)
void setEventSelectionInfo(std::map< std::string, std::vector< std::pair< std::string, int >>> const &outputModulePathPositions, bool anyProductProduced)
void doEndStream(StreamID id)
virtual void doBeginRun_(RunForOutput const &)