#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 (ParameterSet const &pset)

	OutputModuleBase (OutputModuleBase const &)=delete

std::string const &	processName () const

LimitedTaskQueue &	queue ()

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

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

ThinnedAssociationsHelper const *	thinnedAssociationsHelper () const

bool	wantAllEvents () const

bool	wantsGlobalLuminosityBlocks () const

bool	wantsGlobalRuns () const

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

	EDConsumerBase (EDConsumerBase &&)=default

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

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

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

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

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

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

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

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

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Static Public Member Functions
static 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	doBeginJob ()

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

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

void	doBeginStream (StreamID id)

void	doEndJob ()

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

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

void	doEndStream (StreamID id)

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

void	doPreallocate (PreallocationConfiguration const &)

void	doStreamBeginLuminosityBlock (StreamID id, LuminosityBlockPrincipal &ep, EventSetupImpl const &c, ModuleCallingContext const *)

void	doStreamBeginRun (StreamID id, RunPrincipal &ep, EventSetupImpl const &c, ModuleCallingContext const *)

void	doStreamEndLuminosityBlock (StreamID id, LuminosityBlockPrincipal &ep, EventSetupImpl const &c, ModuleCallingContext const *)

void	doStreamEndRun (StreamID id, RunPrincipal &ep, EventSetupImpl const &c, ModuleCallingContext const *)

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

void	preActionBeforeRunEventAsync (WaitingTask *iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) 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
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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

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

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 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	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	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	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_

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 66 of file OutputModuleBase.h.

Member Typedef Documentation

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

Definition at line 74 of file OutputModuleBase.h.

Constructor & Destructor Documentation

OutputModuleBase::OutputModuleBase ( ParameterSet const & pset )

explicit

Definition at line 42 of file OutputModuleBase.cc.

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

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

OutputModuleBase::~OutputModuleBase ( )

override

Definition at line 190 of file OutputModuleBase.cc.

190 {}

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

delete

Member Function Documentation

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

static

Definition at line 357 of file OutputModuleBase.cc.

References description(), edm::getParameterSet(), edm::limited::kBaseType(), genParticles_cff::map, edm::detail::registerProperSelectionInfo(), selector_config_id_, setEventSelectionInfo(), and AlCaHLTBitMon_QueryRunRegistry::string.

357 { return kBaseType; }

edm::limited::kBaseType

static const std::string kBaseType("EDAnalyzer")

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

inlineprivatevirtual

Definition at line 244 of file OutputModuleBase.h.

Referenced by doBeginJob().

244 {}

BranchIDLists const * OutputModuleBase::branchIDLists ( ) const

Definition at line 327 of file OutputModuleBase.cc.

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

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

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

inline

Definition at line 116 of file OutputModuleBase.h.

116 { return queue_.concurrencyLimit(); }

edm::LimitedTaskQueue::concurrencyLimit

unsigned int concurrencyLimit() const

Definition: LimitedTaskQueue.h:115

edm::limited::OutputModuleBase::queue_

LimitedTaskQueue queue_

Definition: OutputModuleBase.h:210

void OutputModuleBase::configure ( OutputModuleDescription const & desc )

protected

Definition at line 77 of file OutputModuleBase.cc.

References edm::OutputModuleDescription::branchIDLists_, edm::OutputModuleDescription::maxEvents_, maxEvents_, origBranchIDLists_, and remainingEvents_.

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

ModuleDescription const & OutputModuleBase::description ( ) const

protected

Definition at line 338 of file OutputModuleBase.cc.

References moduleDescription_.

Referenced by baseType().

338 { return moduleDescription_; }

edm::limited::OutputModuleBase::moduleDescription_

ModuleDescription moduleDescription_

Definition: OutputModuleBase.h:193

void OutputModuleBase::doBeginJob ( )

protected

Definition at line 209 of file OutputModuleBase.cc.

References beginJob().

209 { this->beginJob(); }

edm::limited::OutputModuleBase::beginJob

virtual void beginJob()

Definition: OutputModuleBase.h:244

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

protected

Definition at line 285 of file OutputModuleBase.cc.

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

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

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

inlineprivatevirtual

Definition at line 267 of file OutputModuleBase.h.

Referenced by doBeginLuminosityBlock().

267 {}

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

inlineprivatevirtual

Definition at line 268 of file OutputModuleBase.h.

268 {}

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

protected

Definition at line 263 of file OutputModuleBase.cc.

References doBeginRun_(), moduleDescription_, alignCSCRings::r, and edm::OccurrenceForOutput::setConsumer().

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

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

inlineprivatevirtual

Definition at line 263 of file OutputModuleBase.h.

Referenced by doBeginRun().

263 {}

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

inlineprivatevirtual

Definition at line 264 of file OutputModuleBase.h.

264 {}

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

protected

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

inlineprivatevirtual

Definition at line 254 of file OutputModuleBase.h.

254 {}

void OutputModuleBase::doCloseFile ( )

private

Tell the OutputModule that is must end the current file.

Definition at line 319 of file OutputModuleBase.cc.

References isFileOpen(), and reallyCloseFile().

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

void OutputModuleBase::doEndJob ( )

protected

Definition at line 211 of file OutputModuleBase.cc.

References endJob().

211 { endJob(); }

edm::limited::OutputModuleBase::endJob

virtual void endJob()

Definition: OutputModuleBase.h:245

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

protected

Definition at line 294 of file OutputModuleBase.cc.

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

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

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

inlineprivatevirtual

Definition at line 269 of file OutputModuleBase.h.

Referenced by doEndLuminosityBlock().

269 {}

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

inlineprivatevirtual

Definition at line 270 of file OutputModuleBase.h.

270 {}

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

protected

Definition at line 270 of file OutputModuleBase.cc.

References doEndRun_(), moduleDescription_, alignCSCRings::r, and edm::OccurrenceForOutput::setConsumer().

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

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

inlineprivatevirtual

Definition at line 265 of file OutputModuleBase.h.

Referenced by doEndRun().

265 {}

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

inlineprivatevirtual

Definition at line 266 of file OutputModuleBase.h.

266 {}

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

protected

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

inlineprivatevirtual

Definition at line 255 of file OutputModuleBase.h.

255 {}

bool OutputModuleBase::doEvent	(	EventPrincipal const &	ep,
		EventSetupImpl const &	c,
		ActivityRegistry *	act,
		ModuleCallingContext const *	mcc
	)

protected

Definition at line 238 of file OutputModuleBase.cc.

References MillePedeFileConverter_cfg::e, moduleDescription_, remainingEvents(), remainingEvents_, edm::OccurrenceForOutput::setConsumer(), and write().

                                                                     {
       {
         EventForOutput e(ep, 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;
     }

void OutputModuleBase::doOpenFile ( FileBlock const & fb )

private

Definition at line 310 of file OutputModuleBase.cc.

References openFile().

310 { openFile(fb); }

benchmark_cfg.fb

fb

Definition: benchmark_cfg.py:14

edm::limited::OutputModuleBase::openFile

virtual void openFile(FileBlock const &) const

Definition: OutputModuleBase.h:248

void OutputModuleBase::doPreallocate ( PreallocationConfiguration const & iPC )

protected

Definition at line 192 of file OutputModuleBase.cc.

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_.

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

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

inlineprivate

Definition at line 223 of file OutputModuleBase.h.

223 {}

void OutputModuleBase::doRespondToCloseInputFile ( FileBlock const & fb )

private

Definition at line 317 of file OutputModuleBase.cc.

References doRespondToCloseInputFile_().

317 { doRespondToCloseInputFile_(fb); }

benchmark_cfg.fb

fb

Definition: benchmark_cfg.py:14

edm::limited::OutputModuleBase::doRespondToCloseInputFile_

virtual void doRespondToCloseInputFile_(FileBlock const &)

Definition: OutputModuleBase.h:272

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

inlineprivatevirtual

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

Definition at line 272 of file OutputModuleBase.h.

Referenced by doRespondToCloseInputFile().

272 {}

void OutputModuleBase::doRespondToOpenInputFile ( FileBlock const & fb )

private

Definition at line 312 of file OutputModuleBase.cc.

References doRespondToOpenInputFile_(), and updateBranchIDListsWithKeptAliases().

                                                                        {
       updateBranchIDListsWithKeptAliases();
       doRespondToOpenInputFile_(fb);
     }

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

inlineprivatevirtual

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

Definition at line 271 of file OutputModuleBase.h.

Referenced by doRespondToOpenInputFile().

271 {}

void edm::limited::OutputModuleBase::doStreamBeginLuminosityBlock	(	StreamID	id,
		LuminosityBlockPrincipal &	ep,
		EventSetupImpl const &	c,
		ModuleCallingContext const *
	)

protected

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

inlineprivatevirtual

Definition at line 259 of file OutputModuleBase.h.

259 {}

void edm::limited::OutputModuleBase::doStreamBeginRun	(	StreamID	id,
		RunPrincipal &	ep,
		EventSetupImpl const &	c,
		ModuleCallingContext const *
	)

protected

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

inlineprivatevirtual

Definition at line 256 of file OutputModuleBase.h.

256 {}

void edm::limited::OutputModuleBase::doStreamEndLuminosityBlock	(	StreamID	id,
		LuminosityBlockPrincipal &	ep,
		EventSetupImpl const &	c,
		ModuleCallingContext const *
	)

protected

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

inlineprivatevirtual

Definition at line 260 of file OutputModuleBase.h.

260 {}

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

inlineprivatevirtual

Definition at line 261 of file OutputModuleBase.h.

261 {}

void edm::limited::OutputModuleBase::doStreamEndRun	(	StreamID	id,
		RunPrincipal &	ep,
		EventSetupImpl const &	c,
		ModuleCallingContext const *
	)

protected

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

inlineprivatevirtual

Definition at line 257 of file OutputModuleBase.h.

257 {}

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

inlineprivatevirtual

Definition at line 258 of file OutputModuleBase.h.

258 {}

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

private

Definition at line 303 of file OutputModuleBase.cc.

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

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

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

private

Definition at line 277 of file OutputModuleBase.cc.

References moduleDescription_, alignCSCRings::r, edm::OccurrenceForOutput::setConsumer(), and writeRun().

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

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

inlineprotected

Definition at line 164 of file OutputModuleBase.h.

                                                                                             {
         return droppedBranchIDToKeptBranchID_;
       }

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

inlineprivatevirtual

Definition at line 245 of file OutputModuleBase.h.

Referenced by doEndJob().

245 {}

void OutputModuleBase::fillDescription ( ParameterSetDescription & desc )

static

Definition at line 348 of file OutputModuleBase.cc.

References edm::ParameterSetDescription::addUntracked(), edm::ProductSelectorRules::fillDescription(), and edm::EventSelector::fillDescription().

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

void OutputModuleBase::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 342 of file OutputModuleBase.cc.

References edm::ConfigurationDescriptions::addDefault(), and edm::ParameterSetDescription::setUnknown().

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

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

inlineprivate

Definition at line 277 of file OutputModuleBase.h.

277 { return false; }

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

inlineprivate

Definition at line 276 of file OutputModuleBase.h.

276 { return false; }

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

inline

Definition at line 95 of file OutputModuleBase.h.

References fillDescriptions(), and AlCaHLTBitMon_QueryRunRegistry::string.

95 { return hasNewlyDroppedBranch_; }

edm::limited::OutputModuleBase::hasNewlyDroppedBranch_

std::array< bool, NumBranchTypes > hasNewlyDroppedBranch_

Definition: OutputModuleBase.h:188

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

inlineprivatevirtual

Definition at line 249 of file OutputModuleBase.h.

Referenced by doCloseFile().

249 { return true; }

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

private

Definition at line 155 of file OutputModuleBase.cc.

References edm::BranchDescription::branchID(), edm::BranchDescription::branchType(), edm::ProductSelector::checkForDuplicateKeptBranch(), edm::EDConsumerBase::consumes(), edm::InEvent, edm::InLumi, edm::InRun, keptProducts_, edm::BranchDescription::moduleLabel(), edm::BranchDescription::originalBranchID(), edm::BranchDescription::processName(), edm::BranchDescription::produced(), edm::PRODUCT_TYPE, edm::BranchDescription::productInstanceName(), and edm::BranchDescription::unwrappedTypeID().

Referenced by selectProducts().

                                                                                  {
       ProductSelector::checkForDuplicateKeptBranch(desc, trueBranchIDToKeptBranchDesc);
 
       EDGetToken token;
       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;
         }
         default:
           assert(false);
           break;
       }
       // Now put it in the list of selected branches.
       keptProducts_[desc.branchType()].push_back(std::make_pair(&desc, token));
     }

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

inline

Definition at line 94 of file OutputModuleBase.h.

94 { return keptProducts_; }

edm::limited::OutputModuleBase::keptProducts_

SelectedProductsForBranchType keptProducts_

Definition: OutputModuleBase.h:187

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

inlineprivate

Definition at line 285 of file OutputModuleBase.h.

285 { return remainingEvents_ == 0; }

edm::limited::OutputModuleBase::remainingEvents_

std::atomic< int > remainingEvents_

Definition: OutputModuleBase.h:170

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

inline

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

Definition at line 84 of file OutputModuleBase.h.

84 { return maxEvents_; }

edm::limited::OutputModuleBase::maxEvents_

int maxEvents_

Definition: OutputModuleBase.h:169

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

inline

Definition at line 108 of file OutputModuleBase.h.

108 { return moduleDescription_; }

edm::limited::OutputModuleBase::moduleDescription_

ModuleDescription moduleDescription_

Definition: OutputModuleBase.h:193

bool OutputModuleBase::needToRunSelection ( ) const

private

Definition at line 213 of file OutputModuleBase.cc.

References wantAllEvents_.

213 { return !wantAllEvents_; }

edm::limited::OutputModuleBase::wantAllEvents_

bool wantAllEvents_

Definition: OutputModuleBase.h:195

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

inlineprivatevirtual

Definition at line 248 of file OutputModuleBase.h.

Referenced by Vispa.Main.Application.Application::_readCommandLineAttributes(), doOpenFile(), Vispa.Main.Application.Application::doubleClickOnFile(), Vispa.Main.Application.Application::openFileDialog(), and Vispa.Main.Application.Application::openRecentFileSlot().

248 {}

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

delete

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

inlineprotected

Definition at line 145 of file OutputModuleBase.h.

References genParticles_cff::map, and AlCaHLTBitMon_QueryRunRegistry::string.

147 {}

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

inlineprivatevirtual

Definition at line 253 of file OutputModuleBase.h.

Referenced by doPreallocate().

253 {}

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

inlineprivatevirtual

Definition at line 252 of file OutputModuleBase.h.

Referenced by doPreallocate().

252 {}

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

inlineprivatevirtual

Definition at line 251 of file OutputModuleBase.h.

Referenced by doPreallocate().

251 {}

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

private

Definition at line 227 of file OutputModuleBase.cc.

References MillePedeFileConverter_cfg::e, moduleDescription_, alignCSCRings::s, selectors_, edm::OccurrenceForOutput::setConsumer(), and wantAllEvents_.

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

void OutputModuleBase::prevalidate ( ConfigurationDescriptions & )

static

Definition at line 354 of file OutputModuleBase.cc.

References edm::limited::kBaseType(), and AlCaHLTBitMon_QueryRunRegistry::string.

354 {}

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

inline

Definition at line 93 of file OutputModuleBase.h.

93 { return process_name_; }

edm::limited::OutputModuleBase::process_name_

std::string process_name_

Definition: OutputModuleBase.h:190

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

private

Definition at line 215 of file OutputModuleBase.cc.

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

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

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

inline

Definition at line 118 of file OutputModuleBase.h.

References heppy_report::description.

118 { return queue_; }

edm::limited::OutputModuleBase::queue_

LimitedTaskQueue queue_

Definition: OutputModuleBase.h:210

void OutputModuleBase::reallyCloseFile ( )

privatevirtual

Definition at line 325 of file OutputModuleBase.cc.

Referenced by doCloseFile().

325 {}

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

inlineprivate

Definition at line 230 of file OutputModuleBase.h.

230 {}

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

inline

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

Definition at line 88 of file OutputModuleBase.h.

Referenced by doEvent().

88 { return remainingEvents_; }

edm::limited::OutputModuleBase::remainingEvents_

std::atomic< int > remainingEvents_

Definition: OutputModuleBase.h:170

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

Definition at line 340 of file OutputModuleBase.cc.

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

Referenced by selectProducts().

340 { return productSelector_.selected(desc); }

edm::ProductSelector::selected

bool selected(BranchDescription const &desc) const

Definition: ProductSelector.cc:55

edm::limited::OutputModuleBase::productSelector_

ProductSelector productSelector_

Definition: OutputModuleBase.h:192

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

inlineprotected

Definition at line 123 of file OutputModuleBase.h.

References EnergyCorrector::c.

123 { return selector_config_id_; }

edm::limited::OutputModuleBase::selector_config_id_

ParameterSetID selector_config_id_

Definition: OutputModuleBase.h:200

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

Definition at line 82 of file OutputModuleBase.cc.

References edm::ProductRegistry::allBranchDescriptions(), TrackValidation_cff::association, edm::BranchDescription::branchType(), droppedBranchIDToKeptBranchID_, edm::ProductSelector::fillDroppedToKept(), hasNewlyDroppedBranch_, edm::ProductSelector::initialize(), edm::ProductSelector::initialized(), edm::insertSelectedProcesses(), keepAssociation_, keepThisBranch(), edm::BranchDescription::present(), edm::BranchDescription::produced(), edm::ProductRegistry::productList(), productSelector_, productSelectorRules_, edm::ThinnedAssociationsHelper::selectAssociationProducts(), selected(), setProcessesWithSelectedMergeableRunProducts(), thinnedAssociationsHelper_, edm::BranchDescription::transient(), and edm::BranchDescription::unwrappedType().

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

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

protected

Referenced by baseType().

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

inlineprivate

Definition at line 283 of file OutputModuleBase.h.

283 { moduleDescription_ = md; }

edm::limited::OutputModuleBase::moduleDescription_

ModuleDescription moduleDescription_

Definition: OutputModuleBase.h:193

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

inlineprivatevirtual

Definition at line 274 of file OutputModuleBase.h.

Referenced by selectProducts().

274 {}

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

inlineprivatevirtual

Ask the OutputModule if we should end the current file.

Definition at line 241 of file OutputModuleBase.h.

References TriggerAnalyzer::write().

241 { return false; }

ThinnedAssociationsHelper const * OutputModuleBase::thinnedAssociationsHelper ( ) const

Definition at line 334 of file OutputModuleBase.cc.

References thinnedAssociationsHelper_.

                                                                                        {
       return thinnedAssociationsHelper_.get();
     }

void OutputModuleBase::updateBranchIDListsWithKeptAliases ( )

private

Definition at line 136 of file OutputModuleBase.cc.

References branchIDLists_, droppedBranchIDToKeptBranchID_, and origBranchIDLists_.

Referenced by doRespondToOpenInputFile().

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