#include <OutputModuleBase.h>

Inheritance diagram for edm::limited::OutputModuleBase:

Public Types
typedef OutputModuleBase	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Public Member Functions
BranchIDLists const *	branchIDLists () const

unsigned int	concurrencyLimit () const

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

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleBase &	operator= (OutputModuleBase const &)=delete

	OutputModuleBase (OutputModuleBase const &)=delete

	OutputModuleBase (ParameterSet const &pset)

OutputProcessBlockHelper const &	outputProcessBlockHelper () const

std::string const &	processName () const

LimitedTaskQueue &	queue ()

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

bool	wantsGlobalLuminosityBlocks () const

bool	wantsGlobalRuns () const

virtual bool	wantsInputProcessBlocks () const =0

virtual bool	wantsProcessBlocks () const =0

virtual bool	wantsStreamLuminosityBlocks () const =0

virtual bool	wantsStreamRuns () const =0

	~OutputModuleBase () override

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

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

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase &&)=default

	EDConsumerBase (EDConsumerBase const &)=delete

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

std::vector< ESProxyIndex > 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 &	operator= (EDConsumerBase &&)=default

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

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, 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::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Static Public Member Functions
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Protected Member Functions
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	doBeginStream (StreamID id)

void	doEndJob ()

bool	doEndLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)

void	doEndProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)

bool	doEndRun (RunTransitionInfo const &, ModuleCallingContext const *)

void	doEndStream (StreamID id)

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

void	doPreallocate (PreallocationConfiguration const &)

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

void	preActionBeforeRunEventAsync (WaitingTaskHolder, ModuleCallingContext const &, Principal const &) const

ParameterSetID	selectorConfig () const

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

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

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

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

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

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

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

void	consumesMany (const TypeToGet &id)

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

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

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

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

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

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

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

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

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

Private Member Functions
virtual void	beginJob ()

virtual void	doBeginLuminosityBlock_ (LuminosityBlockForOutput const &)

virtual void	doBeginLuminosityBlockSummary_ (LuminosityBlockForOutput const &, EventSetup const &)

virtual void	doBeginRun_ (RunForOutput const &)

virtual void	doBeginRunSummary_ (RunForOutput const &, EventSetup const &)

virtual void	doBeginStream_ (StreamID)

void	doCloseFile ()
	Tell the OutputModule that is must end the current file. More...

virtual void	doEndLuminosityBlock_ (LuminosityBlockForOutput const &)

virtual void	doEndLuminosityBlockSummary_ (LuminosityBlockForOutput const &, EventSetup const &)

virtual void	doEndRun_ (RunForOutput const &)

virtual void	doEndRunSummary_ (RunForOutput const &, EventSetup const &)

virtual void	doEndStream_ (StreamID)

void	doOpenFile (FileBlock const &fb)

void	doRegisterThinnedAssociations (ProductRegistry const &, ThinnedAssociationsHelper &)

void	doRespondToCloseInputFile (FileBlock const &fb)

virtual void	doRespondToCloseInputFile_ (FileBlock const &)

void	doRespondToCloseOutputFile ()

void	doRespondToOpenInputFile (FileBlock const &fb)

virtual void	doRespondToOpenInputFile_ (FileBlock const &)

virtual void	doStreamBeginLuminosityBlock_ (StreamID, LuminosityBlockForOutput const &, EventSetup const &)

virtual void	doStreamBeginRun_ (StreamID, RunForOutput const &, EventSetup const &)

virtual void	doStreamEndLuminosityBlock_ (StreamID, LuminosityBlockForOutput const &, EventSetup const &)

virtual void	doStreamEndLuminosityBlockSummary_ (StreamID, LuminosityBlockForOutput const &, EventSetup const &)

virtual void	doStreamEndRun_ (StreamID, RunForOutput const &, EventSetup const &)

virtual void	doStreamEndRunSummary_ (StreamID, RunForOutput const &, EventSetup const &)

void	doWriteLuminosityBlock (LuminosityBlockPrincipal const &lbp, ModuleCallingContext const *)

void	doWriteProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)

void	doWriteRun (RunPrincipal const &rp, ModuleCallingContext const , MergeableRunProductMetadata const )

virtual void	endJob ()

bool	hasAccumulator () const

bool	hasAcquire () const

virtual bool	isFileOpen () const

void	keepThisBranch (BranchDescription const &desc, std::map< BranchID, BranchDescription const * > &trueBranchIDToKeptBranchDesc, std::set< BranchID > &keptProductsInEvent)

bool	limitReached () const

bool	needToRunSelection () const

virtual void	openFile (FileBlock const &) const

virtual void	preallocate (PreallocationConfiguration const &)

virtual void	preallocLumis (unsigned int)

virtual void	preallocStreams (unsigned int)

bool	prePrefetchSelection (StreamID id, EventPrincipal const &, ModuleCallingContext const *)

std::vector< ProductResolverIndexAndSkipBit >	productsUsedBySelection () const

virtual void	reallyCloseFile ()

void	registerProductsAndCallbacks (OutputModuleBase const , ProductRegistry const )

void	setModuleDescription (ModuleDescription const &md)

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

virtual bool	shouldWeCloseFile () const
	Ask the OutputModule if we should end the current file. More...

void	updateBranchIDListsWithKeptAliases ()

std::string	workerType () const

virtual void	write (EventForOutput const &)=0

virtual void	writeLuminosityBlock (LuminosityBlockForOutput const &)=0

virtual void	writeProcessBlock (ProcessBlockForOutput const &)

virtual void	writeRun (RunForOutput const &)=0

Private Attributes
edm::propagate_const< std::unique_ptr< BranchIDLists > >	branchIDLists_

std::map< BranchID::value_type, BranchID::value_type >	droppedBranchIDToKeptBranchID_

std::array< bool, NumBranchTypes >	hasNewlyDroppedBranch_

std::map< BranchID, bool >	keepAssociation_

SelectedProductsForBranchType	keptProducts_

int	maxEvents_

ModuleDescription	moduleDescription_

BranchIDLists const *	origBranchIDLists_

OutputProcessBlockHelper	outputProcessBlockHelper_

std::string	process_name_

ProductSelector	productSelector_

ProductSelectorRules	productSelectorRules_

LimitedTaskQueue	queue_

std::atomic< int >	remainingEvents_

ParameterSet	selectEvents_

ParameterSetID	selector_config_id_

std::vector< detail::TriggerResultsBasedEventSelector >	selectors_

edm::propagate_const< std::unique_ptr< ThinnedAssociationsHelper > >	thinnedAssociationsHelper_

bool	wantAllEvents_

Friends
template<typename T >
class	::edm::OutputModuleCommunicatorT

template<typename T >
class	::edm::WorkerT

template<typename U >
class	edm::maker::ModuleHolderT

Detailed Description

Definition at line 67 of file OutputModuleBase.h.

Member Typedef Documentation

◆ ModuleType

typedef OutputModuleBase edm::limited::OutputModuleBase::ModuleType

Definition at line 75 of file OutputModuleBase.h.

Constructor & Destructor Documentation

◆ OutputModuleBase() [1/2]

OutputModuleBase::OutputModuleBase ( ParameterSet const & pset )

explicit

Definition at line 44 of file OutputModuleBase.cc.

         : maxEvents_(-1),
           remainingEvents_(maxEvents_),
           keptProducts_(),
           hasNewlyDroppedBranch_(),
           process_name_(),
           productSelectorRules_(pset, "outputCommands", "OutputModule"),
           productSelector_(),
           moduleDescription_(),
           wantAllEvents_(false),
           selectors_(),
           selector_config_id_(),
           droppedBranchIDToKeptBranchID_(),
           branchIDLists_(new BranchIDLists),
           origBranchIDLists_(nullptr),
           thinnedAssociationsHelper_(new ThinnedAssociationsHelper),
           queue_(pset.getUntrackedParameter<unsigned int>("concurrencyLimit")) {
       hasNewlyDroppedBranch_.fill(false);
  
       Service<service::TriggerNamesService> tns;
       process_name_ = tns->getProcessName();
  
       selectEvents_ = pset.getUntrackedParameterSet("SelectEvents", ParameterSet());
  
       selectEvents_.registerIt();  // Just in case this PSet is not registered
  
       selector_config_id_ = selectEvents_.id();
  
       //need to set wantAllEvents_ in constructor
       // we will make the remaining selectors once we know how many streams
       selectors_.resize(1);
       wantAllEvents_ = detail::configureEventSelector(
           selectEvents_, process_name_, getAllTriggerNames(), selectors_[0], consumesCollector());
     }

References edm::detail::configureEventSelector(), edm::EDConsumerBase::consumesCollector(), edm::getAllTriggerNames(), hasNewlyDroppedBranch_, edm::ParameterSet::id(), process_name_, muonDTDigis_cfi::pset, edm::ParameterSet::registerIt(), selectEvents_, selector_config_id_, selectors_, and wantAllEvents_.

◆ ~OutputModuleBase()

OutputModuleBase::~OutputModuleBase ( )

override

Definition at line 208 of file OutputModuleBase.cc.

208 {}

◆ OutputModuleBase() [2/2]

edm::limited::OutputModuleBase::OutputModuleBase ( OutputModuleBase const & )

delete

Member Function Documentation

◆ baseType()

const std::string & OutputModuleBase::baseType ( )

static

Definition at line 376 of file OutputModuleBase.cc.

376 { return kBaseType; }

References edm::limited::kBaseType().

◆ beginJob()

virtual void edm::limited::OutputModuleBase::beginJob ( void )

inlineprivatevirtual

Definition at line 243 of file OutputModuleBase.h.

243 {}

Referenced by doBeginJob().

◆ branchIDLists()

BranchIDLists const * OutputModuleBase::branchIDLists ( ) const

Definition at line 346 of file OutputModuleBase.cc.

                                                                {
       if (!droppedBranchIDToKeptBranchID_.empty()) {
         return branchIDLists_.get();
       }
       return origBranchIDLists_;
     }

References branchIDLists_, droppedBranchIDToKeptBranchID_, edm::propagate_const< T >::get(), and origBranchIDLists_.

◆ concurrencyLimit()

unsigned int edm::limited::OutputModuleBase::concurrencyLimit ( ) const

inline

Definition at line 121 of file OutputModuleBase.h.

121 { return queue_.concurrencyLimit(); }

References edm::LimitedTaskQueue::concurrencyLimit(), and queue_.

◆ configure()

void OutputModuleBase::configure ( OutputModuleDescription const & desc )

protected

Definition at line 79 of file OutputModuleBase.cc.

                                                                         {
       remainingEvents_ = maxEvents_ = desc.maxEvents_;
       origBranchIDLists_ = desc.branchIDLists_;
     }

References submitPVResolutionJobs::desc, maxEvents_, origBranchIDLists_, and remainingEvents_.

◆ description()

ModuleDescription const & OutputModuleBase::description ( ) const

protected

Definition at line 357 of file OutputModuleBase.cc.

357 { return moduleDescription_; }

References moduleDescription_.

◆ doAccessInputProcessBlock()

void edm::limited::OutputModuleBase::doAccessInputProcessBlock	(	ProcessBlockPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprotected

Definition at line 145 of file OutputModuleBase.h.

145 {}

◆ doBeginJob()

void OutputModuleBase::doBeginJob ( )

protected

Definition at line 227 of file OutputModuleBase.cc.

227 { this->beginJob(); }

References beginJob().

◆ doBeginLuminosityBlock()

bool OutputModuleBase::doBeginLuminosityBlock	(	LumiTransitionInfo const &	info,
		ModuleCallingContext const *	mcc
	)

protected

Definition at line 308 of file OutputModuleBase.cc.

                                                                                                                  {
       LuminosityBlockForOutput lb(info, moduleDescription_, mcc, false);
       lb.setConsumer(this);
       doBeginLuminosityBlock_(lb);
       return true;
     }

References doBeginLuminosityBlock_(), info(), moduleDescription_, and edm::OccurrenceForOutput::setConsumer().

◆ doBeginLuminosityBlock_()

virtual void edm::limited::OutputModuleBase::doBeginLuminosityBlock_ ( LuminosityBlockForOutput const & )

inlineprivatevirtual

Definition at line 267 of file OutputModuleBase.h.

267 {}

Referenced by doBeginLuminosityBlock().

◆ doBeginLuminosityBlockSummary_()

virtual void edm::limited::OutputModuleBase::doBeginLuminosityBlockSummary_	(	LuminosityBlockForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 268 of file OutputModuleBase.h.

268 {}

◆ doBeginProcessBlock()

void edm::limited::OutputModuleBase::doBeginProcessBlock	(	ProcessBlockPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprotected

Definition at line 144 of file OutputModuleBase.h.

144 {}

◆ doBeginRun()

bool OutputModuleBase::doBeginRun	(	RunTransitionInfo const &	info,
		ModuleCallingContext const *	mcc
	)

protected

Definition at line 280 of file OutputModuleBase.cc.

                                                                                                     {
       RunForOutput r(info, moduleDescription_, mcc, false);
       r.setConsumer(this);
       doBeginRun_(r);
       return true;
     }

References doBeginRun_(), info(), moduleDescription_, and alignCSCRings::r.

◆ doBeginRun_()

virtual void edm::limited::OutputModuleBase::doBeginRun_ ( RunForOutput const & )

inlineprivatevirtual

Definition at line 263 of file OutputModuleBase.h.

263 {}

Referenced by doBeginRun().

◆ doBeginRunSummary_()

virtual void edm::limited::OutputModuleBase::doBeginRunSummary_	(	RunForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 264 of file OutputModuleBase.h.

264 {}

◆ doBeginStream()

void edm::limited::OutputModuleBase::doBeginStream ( StreamID id )

protected

◆ doBeginStream_()

virtual void edm::limited::OutputModuleBase::doBeginStream_ ( StreamID )

inlineprivatevirtual

Definition at line 254 of file OutputModuleBase.h.

254 {}

◆ doCloseFile()

void OutputModuleBase::doCloseFile ( )

private

Tell the OutputModule that is must end the current file.

Definition at line 338 of file OutputModuleBase.cc.

                                        {
       if (isFileOpen()) {
         reallyCloseFile();
       }
     }

References isFileOpen(), and reallyCloseFile().

◆ doEndJob()

void OutputModuleBase::doEndJob ( )

protected

Definition at line 229 of file OutputModuleBase.cc.

229 { endJob(); }

References endJob().

◆ doEndLuminosityBlock()

bool OutputModuleBase::doEndLuminosityBlock	(	LumiTransitionInfo const &	info,
		ModuleCallingContext const *	mcc
	)

protected

Definition at line 315 of file OutputModuleBase.cc.

                                                                                                                {
       LuminosityBlockForOutput lb(info, moduleDescription_, mcc, true);
       lb.setConsumer(this);
       doEndLuminosityBlock_(lb);
       return true;
     }

References doEndLuminosityBlock_(), info(), moduleDescription_, and edm::OccurrenceForOutput::setConsumer().

◆ doEndLuminosityBlock_()

virtual void edm::limited::OutputModuleBase::doEndLuminosityBlock_ ( LuminosityBlockForOutput const & )

inlineprivatevirtual

Definition at line 269 of file OutputModuleBase.h.

269 {}

Referenced by doEndLuminosityBlock().

◆ doEndLuminosityBlockSummary_()

virtual void edm::limited::OutputModuleBase::doEndLuminosityBlockSummary_	(	LuminosityBlockForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 270 of file OutputModuleBase.h.

270 {}

◆ doEndProcessBlock()

void edm::limited::OutputModuleBase::doEndProcessBlock	(	ProcessBlockPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprotected

Definition at line 146 of file OutputModuleBase.h.

146 {}

◆ doEndRun()

bool OutputModuleBase::doEndRun	(	RunTransitionInfo const &	info,
		ModuleCallingContext const *	mcc
	)

protected

Definition at line 287 of file OutputModuleBase.cc.

                                                                                                   {
       RunForOutput r(info, moduleDescription_, mcc, true);
       r.setConsumer(this);
       doEndRun_(r);
       return true;
     }

References doEndRun_(), info(), moduleDescription_, and alignCSCRings::r.

◆ doEndRun_()

virtual void edm::limited::OutputModuleBase::doEndRun_ ( RunForOutput const & )

inlineprivatevirtual

Definition at line 265 of file OutputModuleBase.h.

265 {}

Referenced by doEndRun().

◆ doEndRunSummary_()

virtual void edm::limited::OutputModuleBase::doEndRunSummary_	(	RunForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 266 of file OutputModuleBase.h.

266 {}

◆ doEndStream()

void edm::limited::OutputModuleBase::doEndStream ( StreamID id )

protected

◆ doEndStream_()

virtual void edm::limited::OutputModuleBase::doEndStream_ ( StreamID )

inlineprivatevirtual

Definition at line 255 of file OutputModuleBase.h.

255 {}

◆ doEvent()

bool OutputModuleBase::doEvent	(	EventTransitionInfo const &	info,
		ActivityRegistry *	act,
		ModuleCallingContext const *	mcc
	)

protected

Definition at line 256 of file OutputModuleBase.cc.

                                                                     {
       {
         EventForOutput e(info, moduleDescription_, mcc);
         e.setConsumer(this);
         EventSignalsSentry sentry(act, mcc);
         write(e);
       }
  
       auto remainingEvents = remainingEvents_.load();
       bool keepTrying = remainingEvents > 0;
       while (keepTrying) {
         auto newValue = remainingEvents - 1;
         keepTrying = !remainingEvents_.compare_exchange_strong(remainingEvents, newValue);
         if (keepTrying) {
           // the exchange failed because the value was changed by another thread.
           // remainingEvents was changed to be the new value of remainingEvents_;
           keepTrying = remainingEvents > 0;
         }
       }
       return true;
     }

References MillePedeFileConverter_cfg::e, info(), moduleDescription_, remainingEvents(), remainingEvents_, and write().

◆ doOpenFile()

void OutputModuleBase::doOpenFile ( FileBlock const & fb )

private

Definition at line 329 of file OutputModuleBase.cc.

329 { openFile(fb); }

References openFile().

◆ doPreallocate()

void OutputModuleBase::doPreallocate ( PreallocationConfiguration const & iPC )

protected

Definition at line 210 of file OutputModuleBase.cc.

                                                                               {
       auto nstreams = iPC.numberOfStreams();
       selectors_.resize(nstreams);
  
       bool seenFirst = false;
       for (auto& s : selectors_) {
         if (seenFirst) {
           detail::configureEventSelector(selectEvents_, process_name_, getAllTriggerNames(), s, consumesCollector());
         } else {
           seenFirst = true;
         }
       }
       preallocStreams(nstreams);
       preallocLumis(iPC.numberOfLuminosityBlocks());
       preallocate(iPC);
     }

References edm::detail::configureEventSelector(), edm::EDConsumerBase::consumesCollector(), edm::getAllTriggerNames(), edm::PreallocationConfiguration::numberOfLuminosityBlocks(), edm::PreallocationConfiguration::numberOfStreams(), preallocate(), preallocLumis(), preallocStreams(), process_name_, alignCSCRings::s, selectEvents_, and selectors_.

◆ doRegisterThinnedAssociations()

void edm::limited::OutputModuleBase::doRegisterThinnedAssociations	(	ProductRegistry const &	,
		ThinnedAssociationsHelper &
	)

inlineprivate

Definition at line 222 of file OutputModuleBase.h.

222 {}

◆ doRespondToCloseInputFile()

void OutputModuleBase::doRespondToCloseInputFile ( FileBlock const & fb )

private

Definition at line 336 of file OutputModuleBase.cc.

336 { doRespondToCloseInputFile_(fb); }

References doRespondToCloseInputFile_().

◆ doRespondToCloseInputFile_()

virtual void edm::limited::OutputModuleBase::doRespondToCloseInputFile_ ( FileBlock const & )

inlineprivatevirtual

Reimplemented in edm::limited::outputmodule::InputFileWatcher.

Definition at line 272 of file OutputModuleBase.h.

272 {}

Referenced by doRespondToCloseInputFile().

◆ doRespondToCloseOutputFile()

void edm::limited::OutputModuleBase::doRespondToCloseOutputFile ( )

inlineprivate

Definition at line 221 of file OutputModuleBase.h.

221 {}

◆ doRespondToOpenInputFile()

void OutputModuleBase::doRespondToOpenInputFile ( FileBlock const & fb )

private

Definition at line 331 of file OutputModuleBase.cc.

                                                                        {
       updateBranchIDListsWithKeptAliases();
       doRespondToOpenInputFile_(fb);
     }

References doRespondToOpenInputFile_(), and updateBranchIDListsWithKeptAliases().

◆ doRespondToOpenInputFile_()

virtual void edm::limited::OutputModuleBase::doRespondToOpenInputFile_ ( FileBlock const & )

inlineprivatevirtual

Reimplemented in edm::limited::outputmodule::InputFileWatcher.

Definition at line 271 of file OutputModuleBase.h.

271 {}

Referenced by doRespondToOpenInputFile().

◆ doStreamBeginLuminosityBlock_()

virtual void edm::limited::OutputModuleBase::doStreamBeginLuminosityBlock_	(	StreamID	,
		LuminosityBlockForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 259 of file OutputModuleBase.h.

259 {}

◆ doStreamBeginRun_()

virtual void edm::limited::OutputModuleBase::doStreamBeginRun_	(	StreamID	,
		RunForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 256 of file OutputModuleBase.h.

256 {}

◆ doStreamEndLuminosityBlock_()

virtual void edm::limited::OutputModuleBase::doStreamEndLuminosityBlock_	(	StreamID	,
		LuminosityBlockForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 260 of file OutputModuleBase.h.

260 {}

◆ doStreamEndLuminosityBlockSummary_()

virtual void edm::limited::OutputModuleBase::doStreamEndLuminosityBlockSummary_	(	StreamID	,
		LuminosityBlockForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 261 of file OutputModuleBase.h.

261 {}

◆ doStreamEndRun_()

virtual void edm::limited::OutputModuleBase::doStreamEndRun_	(	StreamID	,
		RunForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 257 of file OutputModuleBase.h.

257 {}

◆ doStreamEndRunSummary_()

virtual void edm::limited::OutputModuleBase::doStreamEndRunSummary_	(	StreamID	,
		RunForOutput const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 258 of file OutputModuleBase.h.

258 {}

◆ doWriteLuminosityBlock()

void OutputModuleBase::doWriteLuminosityBlock	(	LuminosityBlockPrincipal const &	lbp,
		ModuleCallingContext const *	mcc
	)

private

Definition at line 322 of file OutputModuleBase.cc.

                                                                                    {
       LuminosityBlockForOutput lb(lbp, moduleDescription_, mcc, true);
       lb.setConsumer(this);
       writeLuminosityBlock(lb);
     }

References moduleDescription_, edm::OccurrenceForOutput::setConsumer(), and writeLuminosityBlock().

◆ doWriteProcessBlock()

void OutputModuleBase::doWriteProcessBlock	(	ProcessBlockPrincipal const &	pbp,
		ModuleCallingContext const *	mcc
	)

private

Definition at line 294 of file OutputModuleBase.cc.

                                                                                                                 {
       ProcessBlockForOutput pb(pbp, moduleDescription_, mcc, true);
       pb.setConsumer(this);
       writeProcessBlock(pb);
     }

References moduleDescription_, edm::OccurrenceForOutput::setConsumer(), and writeProcessBlock().

◆ doWriteRun()

void OutputModuleBase::doWriteRun	(	RunPrincipal const &	rp,
		ModuleCallingContext const *	mcc,
		MergeableRunProductMetadata const *	mrpm
	)

private

Definition at line 300 of file OutputModuleBase.cc.

                                                                                {
       RunForOutput r(rp, moduleDescription_, mcc, true, mrpm);
       r.setConsumer(this);
       writeRun(r);
     }

References moduleDescription_, alignCSCRings::r, and writeRun().

◆ droppedBranchIDToKeptBranchID()

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

inlineprotected

Definition at line 158 of file OutputModuleBase.h.

                                                                                             {
         return droppedBranchIDToKeptBranchID_;
       }

References droppedBranchIDToKeptBranchID_.

◆ endJob()

virtual void edm::limited::OutputModuleBase::endJob ( void )

inlineprivatevirtual

Definition at line 244 of file OutputModuleBase.h.

244 {}

Referenced by doEndJob().

◆ fillDescription()

void OutputModuleBase::fillDescription ( ParameterSetDescription & desc )

static

Definition at line 367 of file OutputModuleBase.cc.

                                                                         {
       ProductSelectorRules::fillDescription(desc, "outputCommands");
       EventSelector::fillDescription(desc);
       desc.addUntracked<unsigned int>("concurrencyLimit", 1);
     }

References submitPVResolutionJobs::desc, edm::ProductSelectorRules::fillDescription(), and edm::EventSelector::fillDescription().

◆ fillDescriptions()

void OutputModuleBase::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 361 of file OutputModuleBase.cc.

                                                                                    {
       ParameterSetDescription desc;
       desc.setUnknown();
       descriptions.addDefault(desc);
     }

References edm::ConfigurationDescriptions::addDefault(), and submitPVResolutionJobs::desc.

◆ hasAccumulator()

bool edm::limited::OutputModuleBase::hasAccumulator ( ) const

inlineprivate

Definition at line 277 of file OutputModuleBase.h.

277 { return false; }

◆ hasAcquire()

bool edm::limited::OutputModuleBase::hasAcquire ( ) const

inlineprivate

Definition at line 276 of file OutputModuleBase.h.

276 { return false; }

◆ hasNewlyDroppedBranch()

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

inline

Definition at line 96 of file OutputModuleBase.h.

96 { return hasNewlyDroppedBranch_; }

References hasNewlyDroppedBranch_.

◆ isFileOpen()

virtual bool edm::limited::OutputModuleBase::isFileOpen ( ) const

inlineprivatevirtual

Definition at line 249 of file OutputModuleBase.h.

249 { return true; }

Referenced by doCloseFile().

◆ keepThisBranch()

void OutputModuleBase::keepThisBranch	(	BranchDescription const &	desc,
		std::map< BranchID, BranchDescription const * > &	trueBranchIDToKeptBranchDesc,
		std::set< BranchID > &	keptProductsInEvent
	)

private

Definition at line 161 of file OutputModuleBase.cc.

                                                                                  {
       ProductSelector::checkForDuplicateKeptBranch(desc, trueBranchIDToKeptBranchDesc);
  
       EDGetToken token;
  
       std::vector<std::string> missingDictionaries;
       if (!checkDictionary(missingDictionaries, desc.className(), desc.unwrappedType())) {
         std::string context("Calling OutputModuleBase::keepThisBranch, checking dictionaries for kept types");
         throwMissingDictionariesException(missingDictionaries, context);
       }
  
       switch (desc.branchType()) {
         case InEvent: {
           if (desc.produced()) {
             keptProductsInEvent.insert(desc.originalBranchID());
           } else {
             keptProductsInEvent.insert(desc.branchID());
           }
           token = consumes(TypeToGet{desc.unwrappedTypeID(), PRODUCT_TYPE},
                            InputTag{desc.moduleLabel(), desc.productInstanceName(), desc.processName()});
           break;
         }
         case InLumi: {
           token = consumes<InLumi>(TypeToGet{desc.unwrappedTypeID(), PRODUCT_TYPE},
                                    InputTag(desc.moduleLabel(), desc.productInstanceName(), desc.processName()));
           break;
         }
         case InRun: {
           token = consumes<InRun>(TypeToGet{desc.unwrappedTypeID(), PRODUCT_TYPE},
                                   InputTag(desc.moduleLabel(), desc.productInstanceName(), desc.processName()));
           break;
         }
         case InProcess: {
           token = consumes<InProcess>(TypeToGet{desc.unwrappedTypeID(), PRODUCT_TYPE},
                                       InputTag(desc.moduleLabel(), desc.productInstanceName(), desc.processName()));
           break;
         }
         default:
           assert(false);
           break;
       }
       // Now put it in the list of selected branches.
       keptProducts_[desc.branchType()].push_back(std::make_pair(&desc, token));
     }

References cms::cuda::assert(), edm::checkDictionary(), edm::ProductSelector::checkForDuplicateKeptBranch(), edm::EDConsumerBase::consumes(), visDQMUpload::context, submitPVResolutionJobs::desc, edm::InEvent, edm::InLumi, edm::InProcess, HLT_FULL_cff::InputTag, edm::InRun, keptProducts_, edm::PRODUCT_TYPE, AlCaHLTBitMon_QueryRunRegistry::string, edm::throwMissingDictionariesException(), and unpackBuffers-CaloStage2::token.

Referenced by selectProducts().

◆ keptProducts()

SelectedProductsForBranchType const& edm::limited::OutputModuleBase::keptProducts ( ) const

inline

Definition at line 95 of file OutputModuleBase.h.

95 { return keptProducts_; }

References keptProducts_.

◆ limitReached()

bool edm::limited::OutputModuleBase::limitReached ( ) const

inlineprivate

Definition at line 285 of file OutputModuleBase.h.

285 { return remainingEvents_ == 0; }

References remainingEvents_.

◆ maxEvents()

int edm::limited::OutputModuleBase::maxEvents ( ) const

inline

Accessor for maximum number of events to be written. -1 is used for unlimited.

Definition at line 85 of file OutputModuleBase.h.

85 { return maxEvents_; }

References maxEvents_.

◆ moduleDescription()

const ModuleDescription& edm::limited::OutputModuleBase::moduleDescription ( ) const

inline

Definition at line 111 of file OutputModuleBase.h.

111 { return moduleDescription_; }

References moduleDescription_.

◆ needToRunSelection()

bool OutputModuleBase::needToRunSelection ( ) const

private

Definition at line 231 of file OutputModuleBase.cc.

231 { return !wantAllEvents_; }

References wantAllEvents_.

◆ openFile()

virtual void edm::limited::OutputModuleBase::openFile ( FileBlock const & ) const

inlineprivatevirtual

Definition at line 248 of file OutputModuleBase.h.

248 {}

Referenced by doOpenFile().

◆ operator=()

OutputModuleBase& edm::limited::OutputModuleBase::operator= ( OutputModuleBase const & )

delete

◆ outputProcessBlockHelper()

OutputProcessBlockHelper const& edm::limited::OutputModuleBase::outputProcessBlockHelper ( ) const

inline

Definition at line 107 of file OutputModuleBase.h.

107 { return outputProcessBlockHelper_; }

References outputProcessBlockHelper_.

◆ preActionBeforeRunEventAsync()

void edm::limited::OutputModuleBase::preActionBeforeRunEventAsync	(	WaitingTaskHolder	,
		ModuleCallingContext const &	,
		Principal const &
	)		const

inlineprotected

Definition at line 140 of file OutputModuleBase.h.

142 {}

◆ preallocate()

virtual void edm::limited::OutputModuleBase::preallocate ( PreallocationConfiguration const & )

inlineprivatevirtual

Definition at line 253 of file OutputModuleBase.h.

253 {}

Referenced by doPreallocate().

◆ preallocLumis()

virtual void edm::limited::OutputModuleBase::preallocLumis ( unsigned int )

inlineprivatevirtual

Definition at line 252 of file OutputModuleBase.h.

252 {}

Referenced by doPreallocate().

◆ preallocStreams()

virtual void edm::limited::OutputModuleBase::preallocStreams ( unsigned int )

inlineprivatevirtual

Definition at line 251 of file OutputModuleBase.h.

251 {}

Referenced by doPreallocate().

◆ prePrefetchSelection()

bool OutputModuleBase::prePrefetchSelection	(	StreamID	id,
		EventPrincipal const &	ep,
		ModuleCallingContext const *	mcc
	)

private

Definition at line 245 of file OutputModuleBase.cc.

                                                                                  {
       if (wantAllEvents_)
         return true;
       auto& s = selectors_[id.value()];
       EventForOutput e(ep, moduleDescription_, mcc);
       e.setConsumer(this);
       return s.wantEvent(e);
     }

References MillePedeFileConverter_cfg::e, SiStripBadComponentsDQMServiceTemplate_cfg::ep, moduleDescription_, alignCSCRings::s, selectors_, and wantAllEvents_.

◆ prevalidate()

void OutputModuleBase::prevalidate ( ConfigurationDescriptions & )

static

Definition at line 373 of file OutputModuleBase.cc.

373 {}

◆ processName()

std::string const& edm::limited::OutputModuleBase::processName ( ) const

inline

Definition at line 94 of file OutputModuleBase.h.

94 { return process_name_; }

References process_name_.

◆ productsUsedBySelection()

std::vector< ProductResolverIndexAndSkipBit > OutputModuleBase::productsUsedBySelection ( ) const

private

Definition at line 233 of file OutputModuleBase.cc.

                                                                                               {
       std::vector<ProductResolverIndexAndSkipBit> returnValue;
       auto const& s = selectors_[0];
       auto const n = s.numberOfTokens();
       returnValue.reserve(n);
  
       for (unsigned int i = 0; i < n; ++i) {
         returnValue.emplace_back(uncheckedIndexFrom(s.token(i)));
       }
       return returnValue;
     }

References mps_fire::i, dqmiodumpmetadata::n, alignCSCRings::s, selectors_, and edm::EDConsumerBase::uncheckedIndexFrom().

◆ queue()

LimitedTaskQueue& edm::limited::OutputModuleBase::queue ( )

inline

Definition at line 123 of file OutputModuleBase.h.

123 { return queue_; }

References queue_.

◆ reallyCloseFile()

void OutputModuleBase::reallyCloseFile ( )

privatevirtual

Definition at line 344 of file OutputModuleBase.cc.

344 {}

Referenced by doCloseFile().

◆ registerProductsAndCallbacks()

void edm::limited::OutputModuleBase::registerProductsAndCallbacks	(	OutputModuleBase const *	,
		ProductRegistry const *
	)

inlineprivate

Definition at line 229 of file OutputModuleBase.h.

229 {}

◆ remainingEvents()

int edm::limited::OutputModuleBase::remainingEvents ( ) const

inline

Accessor for remaining number of events to be written. -1 is used for unlimited.

Definition at line 89 of file OutputModuleBase.h.

89 { return remainingEvents_; }

References remainingEvents_.

Referenced by doEvent().

◆ selected()

bool OutputModuleBase::selected ( BranchDescription const & desc ) const

Definition at line 359 of file OutputModuleBase.cc.

359 { return productSelector_.selected(desc); }

References submitPVResolutionJobs::desc, productSelector_, and edm::ProductSelector::selected().

Referenced by selectProducts().

◆ selectorConfig()

ParameterSetID edm::limited::OutputModuleBase::selectorConfig ( ) const

inlineprotected

Definition at line 128 of file OutputModuleBase.h.

128 { return selector_config_id_; }

References selector_config_id_.

◆ selectProducts()

void OutputModuleBase::selectProducts	(	ProductRegistry const &	preg,
		ThinnedAssociationsHelper const &	thinnedAssociationsHelper,
		ProcessBlockHelperBase const &	processBlockHelper
	)

Definition at line 84 of file OutputModuleBase.cc.

                                                                                             {
       if (productSelector_.initialized())
         return;
       productSelector_.initialize(productSelectorRules_, preg.allBranchDescriptions());
  
       // TODO: See if we can collapse keptProducts_ and productSelector_ into a
       // single object. See the notes in the header for ProductSelector
       // for more information.
  
       std::map<BranchID, BranchDescription const*> trueBranchIDToKeptBranchDesc;
       std::vector<BranchDescription const*> associationDescriptions;
       std::set<BranchID> keptProductsInEvent;
       std::set<std::string> processesWithSelectedMergeableRunProducts;
       std::set<std::string> processesWithKeptProcessBlockProducts;
  
       for (auto const& it : preg.productList()) {
         BranchDescription const& desc = it.second;
         if (desc.transient()) {
           // if the class of the branch is marked transient, output nothing
         } else if (!desc.present() && !desc.produced()) {
           // else if the branch containing the product has been previously dropped,
           // output nothing
         } else if (desc.unwrappedType() == typeid(ThinnedAssociation)) {
           associationDescriptions.push_back(&desc);
         } else if (selected(desc)) {
           keepThisBranch(desc, trueBranchIDToKeptBranchDesc, keptProductsInEvent);
           insertSelectedProcesses(
               desc, processesWithSelectedMergeableRunProducts, processesWithKeptProcessBlockProducts);
         } else {
           // otherwise, output nothing,
           // and mark the fact that there is a newly dropped branch of this type.
           hasNewlyDroppedBranch_[desc.branchType()] = true;
         }
       }
  
       setProcessesWithSelectedMergeableRunProducts(processesWithSelectedMergeableRunProducts);
  
       thinnedAssociationsHelper.selectAssociationProducts(
           associationDescriptions, keptProductsInEvent, keepAssociation_);
  
       for (auto association : associationDescriptions) {
         if (keepAssociation_[association->branchID()]) {
           keepThisBranch(*association, trueBranchIDToKeptBranchDesc, keptProductsInEvent);
         } else {
           hasNewlyDroppedBranch_[association->branchType()] = true;
         }
       }
  
       // Now fill in a mapping needed in the case that a branch was dropped while its EDAlias was kept.
       ProductSelector::fillDroppedToKept(preg, trueBranchIDToKeptBranchDesc, droppedBranchIDToKeptBranchID_);
  
       thinnedAssociationsHelper_->updateFromParentProcess(
           thinnedAssociationsHelper, keepAssociation_, droppedBranchIDToKeptBranchID_);
       outputProcessBlockHelper_.updateAfterProductSelection(processesWithKeptProcessBlockProducts, processBlockHelper);
     }

References edm::ProductRegistry::allBranchDescriptions(), submitPVResolutionJobs::desc, droppedBranchIDToKeptBranchID_, edm::ProductSelector::fillDroppedToKept(), hasNewlyDroppedBranch_, edm::ProductSelector::initialize(), edm::ProductSelector::initialized(), edm::insertSelectedProcesses(), keepAssociation_, keepThisBranch(), outputProcessBlockHelper_, edm::ProductRegistry::productList(), productSelector_, productSelectorRules_, edm::ThinnedAssociationsHelper::selectAssociationProducts(), selected(), setProcessesWithSelectedMergeableRunProducts(), thinnedAssociationsHelper(), thinnedAssociationsHelper_, and edm::OutputProcessBlockHelper::updateAfterProductSelection().

◆ setEventSelectionInfo()

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

protected

◆ setModuleDescription()

void edm::limited::OutputModuleBase::setModuleDescription ( ModuleDescription const & md )

inlineprivate

Definition at line 283 of file OutputModuleBase.h.

283 { moduleDescription_ = md; }

References moduleDescription_.

◆ setProcessesWithSelectedMergeableRunProducts()

virtual void edm::limited::OutputModuleBase::setProcessesWithSelectedMergeableRunProducts ( std::set< std::string > const & )

inlineprivatevirtual

Definition at line 274 of file OutputModuleBase.h.

274 {}

Referenced by selectProducts().

◆ shouldWeCloseFile()

virtual bool edm::limited::OutputModuleBase::shouldWeCloseFile ( ) const

inlineprivatevirtual

Ask the OutputModule if we should end the current file.

Definition at line 240 of file OutputModuleBase.h.

240 { return false; }

◆ thinnedAssociationsHelper()

ThinnedAssociationsHelper const * OutputModuleBase::thinnedAssociationsHelper ( ) const

Definition at line 353 of file OutputModuleBase.cc.

                                                                                        {
       return thinnedAssociationsHelper_.get();
     }

References thinnedAssociationsHelper_.

Referenced by selectProducts().

◆ updateBranchIDListsWithKeptAliases()

void OutputModuleBase::updateBranchIDListsWithKeptAliases ( )

private

Definition at line 142 of file OutputModuleBase.cc.

                                                               {
       if (!droppedBranchIDToKeptBranchID_.empty()) {
         // Make a private copy of the BranchIDLists.
         *branchIDLists_ = *origBranchIDLists_;
         // Check for branches dropped while an EDAlias was kept.
         for (BranchIDList& branchIDList : *branchIDLists_) {
           for (BranchID::value_type& branchID : branchIDList) {
             // Replace BranchID of each dropped branch with that of the kept
             // alias, so the alias branch will have the product ID of the original branch.
             std::map<BranchID::value_type, BranchID::value_type>::const_iterator iter =
                 droppedBranchIDToKeptBranchID_.find(branchID);
             if (iter != droppedBranchIDToKeptBranchID_.end()) {
               branchID = iter->second;
             }
           }
         }
       }
     }

References branchIDLists_, droppedBranchIDToKeptBranchID_, and origBranchIDLists_.

Referenced by doRespondToOpenInputFile().

◆ wantAllEvents()

bool edm::limited::OutputModuleBase::wantAllEvents ( ) const

inline

Definition at line 103 of file OutputModuleBase.h.

103 { return wantAllEvents_; }

References wantAllEvents_.

◆ wantsGlobalLuminosityBlocks()

bool edm::limited::OutputModuleBase::wantsGlobalLuminosityBlocks ( ) const

inline

Definition at line 115 of file OutputModuleBase.h.

115 { return true; }

◆ wantsGlobalRuns()

bool edm::limited::OutputModuleBase::wantsGlobalRuns ( ) const

inline

Definition at line 114 of file OutputModuleBase.h.

114 { return true; }

◆ wantsInputProcessBlocks()

virtual bool edm::limited::OutputModuleBase::wantsInputProcessBlocks ( ) const

pure virtual

Implemented in edm::limited::OutputModule< T >.

◆ wantsProcessBlocks()

virtual bool edm::limited::OutputModuleBase::wantsProcessBlocks ( ) const

pure virtual

Implemented in edm::limited::OutputModule< T >.

◆ wantsStreamLuminosityBlocks()

virtual bool edm::limited::OutputModuleBase::wantsStreamLuminosityBlocks ( ) const

pure virtual

Implemented in edm::limited::OutputModule< T >.

◆ wantsStreamRuns()

virtual bool edm::limited::OutputModuleBase::wantsStreamRuns ( ) const

pure virtual

Implemented in edm::limited::OutputModule< T >.

◆ workerType()

std::string edm::limited::OutputModuleBase::workerType ( ) const

inlineprivate

Definition at line 224 of file OutputModuleBase.h.

224 { return "WorkerT<edm::limited::OutputModuleBase>"; }

◆ write()

virtual void edm::limited::OutputModuleBase::write ( EventForOutput const & )

privatepure virtual

Referenced by doEvent(), and pkg.AbstractPkg::generate().

◆ writeLuminosityBlock()

virtual void edm::limited::OutputModuleBase::writeLuminosityBlock ( LuminosityBlockForOutput const & )

privatepure virtual

Referenced by doWriteLuminosityBlock().

◆ writeProcessBlock()

virtual void edm::limited::OutputModuleBase::writeProcessBlock ( ProcessBlockForOutput const & )

inlineprivatevirtual

Definition at line 247 of file OutputModuleBase.h.

247 {}

Referenced by doWriteProcessBlock().

◆ writeRun()

virtual void edm::limited::OutputModuleBase::writeRun ( RunForOutput const & )

privatepure virtual

Referenced by doWriteRun().

Friends And Related Function Documentation

◆ ::edm::OutputModuleCommunicatorT

template<typename T >

friend class ::edm::OutputModuleCommunicatorT

friend

Definition at line 74 of file OutputModuleBase.h.

◆ ::edm::WorkerT

template<typename T >

friend class ::edm::WorkerT

friend

Definition at line 72 of file OutputModuleBase.h.

◆ edm::maker::ModuleHolderT

template<typename U >

friend class edm::maker::ModuleHolderT

friend

Definition at line 70 of file OutputModuleBase.h.

Member Data Documentation

◆ branchIDLists_

edm::propagate_const<std::unique_ptr<BranchIDLists> > edm::limited::OutputModuleBase::branchIDLists_

private

Definition at line 199 of file OutputModuleBase.h.

Referenced by branchIDLists(), and updateBranchIDListsWithKeptAliases().

◆ droppedBranchIDToKeptBranchID_

std::map<BranchID::value_type, BranchID::value_type> edm::limited::OutputModuleBase::droppedBranchIDToKeptBranchID_

private

Definition at line 198 of file OutputModuleBase.h.

Referenced by branchIDLists(), droppedBranchIDToKeptBranchID(), selectProducts(), and updateBranchIDListsWithKeptAliases().

◆ hasNewlyDroppedBranch_

std::array<bool, NumBranchTypes> edm::limited::OutputModuleBase::hasNewlyDroppedBranch_

private

Definition at line 182 of file OutputModuleBase.h.

Referenced by hasNewlyDroppedBranch(), OutputModuleBase(), and selectProducts().

◆ keepAssociation_

std::map<BranchID, bool> edm::limited::OutputModuleBase::keepAssociation_

private

Definition at line 203 of file OutputModuleBase.h.

Referenced by selectProducts().

◆ keptProducts_

SelectedProductsForBranchType edm::limited::OutputModuleBase::keptProducts_

private

Definition at line 181 of file OutputModuleBase.h.

Referenced by keepThisBranch(), and keptProducts().

◆ maxEvents_

int edm::limited::OutputModuleBase::maxEvents_

private

Definition at line 163 of file OutputModuleBase.h.

Referenced by configure(), and maxEvents().

◆ moduleDescription_

ModuleDescription edm::limited::OutputModuleBase::moduleDescription_

private

Definition at line 187 of file OutputModuleBase.h.

Referenced by description(), doBeginLuminosityBlock(), doBeginRun(), doEndLuminosityBlock(), doEndRun(), doEvent(), doWriteLuminosityBlock(), doWriteProcessBlock(), doWriteRun(), moduleDescription(), prePrefetchSelection(), and setModuleDescription().

◆ origBranchIDLists_

BranchIDLists const* edm::limited::OutputModuleBase::origBranchIDLists_

private

Definition at line 200 of file OutputModuleBase.h.

Referenced by branchIDLists(), configure(), and updateBranchIDListsWithKeptAliases().

◆ outputProcessBlockHelper_

OutputProcessBlockHelper edm::limited::OutputModuleBase::outputProcessBlockHelper_

private

Definition at line 205 of file OutputModuleBase.h.

Referenced by outputProcessBlockHelper(), and selectProducts().

◆ process_name_

std::string edm::limited::OutputModuleBase::process_name_

private

Definition at line 184 of file OutputModuleBase.h.

Referenced by doPreallocate(), OutputModuleBase(), and processName().

◆ productSelector_

ProductSelector edm::limited::OutputModuleBase::productSelector_

private

Definition at line 186 of file OutputModuleBase.h.

Referenced by selected(), and selectProducts().

◆ productSelectorRules_

ProductSelectorRules edm::limited::OutputModuleBase::productSelectorRules_

private

Definition at line 185 of file OutputModuleBase.h.

Referenced by selectProducts().

◆ queue_

LimitedTaskQueue edm::limited::OutputModuleBase::queue_

private

Definition at line 207 of file OutputModuleBase.h.

Referenced by concurrencyLimit(), and queue().

◆ remainingEvents_

std::atomic<int> edm::limited::OutputModuleBase::remainingEvents_

private

Definition at line 164 of file OutputModuleBase.h.

Referenced by configure(), doEvent(), limitReached(), and remainingEvents().

◆ selectEvents_

ParameterSet edm::limited::OutputModuleBase::selectEvents_

private

Definition at line 191 of file OutputModuleBase.h.

Referenced by doPreallocate(), and OutputModuleBase().

◆ selector_config_id_

ParameterSetID edm::limited::OutputModuleBase::selector_config_id_

private

Definition at line 194 of file OutputModuleBase.h.

Referenced by OutputModuleBase(), and selectorConfig().

◆ selectors_

std::vector<detail::TriggerResultsBasedEventSelector> edm::limited::OutputModuleBase::selectors_

private

Definition at line 190 of file OutputModuleBase.h.

Referenced by doPreallocate(), OutputModuleBase(), prePrefetchSelection(), and productsUsedBySelection().

◆ thinnedAssociationsHelper_

edm::propagate_const<std::unique_ptr<ThinnedAssociationsHelper> > edm::limited::OutputModuleBase::thinnedAssociationsHelper_

private

Definition at line 202 of file OutputModuleBase.h.

Referenced by selectProducts(), and thinnedAssociationsHelper().

◆ wantAllEvents_

bool edm::limited::OutputModuleBase::wantAllEvents_

private

Definition at line 189 of file OutputModuleBase.h.

Referenced by needToRunSelection(), OutputModuleBase(), prePrefetchSelection(), and wantAllEvents().

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ ModuleType

Constructor & Destructor Documentation

◆ OutputModuleBase() [1/2]

◆ ~OutputModuleBase()

◆ OutputModuleBase() [2/2]

Member Function Documentation

◆ baseType()

◆ beginJob()

◆ branchIDLists()

◆ concurrencyLimit()

◆ configure()

◆ description()

◆ doAccessInputProcessBlock()

◆ doBeginJob()

◆ doBeginLuminosityBlock()

◆ doBeginLuminosityBlock_()

◆ doBeginLuminosityBlockSummary_()

◆ doBeginProcessBlock()

◆ doBeginRun()

◆ doBeginRun_()

◆ doBeginRunSummary_()

◆ doBeginStream()

◆ doBeginStream_()

◆ doCloseFile()

◆ doEndJob()

◆ doEndLuminosityBlock()

◆ doEndLuminosityBlock_()

◆ doEndLuminosityBlockSummary_()

◆ doEndProcessBlock()

◆ doEndRun()

◆ doEndRun_()

◆ doEndRunSummary_()

◆ doEndStream()

◆ doEndStream_()

◆ doEvent()

◆ doOpenFile()

◆ doPreallocate()

◆ doRegisterThinnedAssociations()

◆ doRespondToCloseInputFile()

◆ doRespondToCloseInputFile_()

◆ doRespondToCloseOutputFile()

◆ doRespondToOpenInputFile()

◆ doRespondToOpenInputFile_()

◆ doStreamBeginLuminosityBlock_()

◆ doStreamBeginRun_()

◆ doStreamEndLuminosityBlock_()

◆ doStreamEndLuminosityBlockSummary_()

◆ doStreamEndRun_()

◆ doStreamEndRunSummary_()

◆ doWriteLuminosityBlock()

◆ doWriteProcessBlock()

◆ doWriteRun()

◆ droppedBranchIDToKeptBranchID()

◆ endJob()

◆ fillDescription()

◆ fillDescriptions()

◆ hasAccumulator()

◆ hasAcquire()

◆ hasNewlyDroppedBranch()

◆ isFileOpen()

◆ keepThisBranch()

◆ keptProducts()

◆ limitReached()

◆ maxEvents()

◆ moduleDescription()

◆ needToRunSelection()

◆ openFile()

◆ operator=()

◆ outputProcessBlockHelper()

◆ preActionBeforeRunEventAsync()

◆ preallocate()