edm::limited::OutputModuleBase Class Reference

#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)
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 &&)=default
	EDConsumerBase (EDConsumerBase const &)=delete
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 &	operator= (EDConsumerBase &&)=default
EDConsumerBase const &	operator= (EDConsumerBase const &)=delete
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
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>
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)
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	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

ModuleType

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

Definition at line 74 of file OutputModuleBase.h.

Constructor & Destructor Documentation

OutputModuleBase() [1/2]

OutputModuleBase::OutputModuleBase ( ParameterSet const &  pset )

explicit

Definition at line 42 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 190 of file OutputModuleBase.cc.

{}

OutputModuleBase() [2/2]

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

delete

Member Function Documentation

baseType()

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

static

Definition at line 357 of file OutputModuleBase.cc.

{ return kBaseType; }

References edm::limited::kBaseType().

beginJob()

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

inlineprivatevirtual

Definition at line 244 of file OutputModuleBase.h.

{}

Referenced by doBeginJob().

branchIDLists()

BranchIDLists const * OutputModuleBase::branchIDLists

(

)

const

Definition at line 327 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 116 of file OutputModuleBase.h.

{ return queue_.concurrencyLimit(); }

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

configure()

void OutputModuleBase::configure ( OutputModuleDescription const &  desc )

protected

Definition at line 77 of file OutputModuleBase.cc.

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

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

description()

ModuleDescription const & OutputModuleBase::description ( ) const

protected

Definition at line 338 of file OutputModuleBase.cc.

{ return moduleDescription_; }

References moduleDescription_.

doBeginJob()

void OutputModuleBase::doBeginJob ( )

protected

Definition at line 209 of file OutputModuleBase.cc.

{ this->beginJob(); }

References beginJob().

doBeginLuminosityBlock()

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

protected

Definition at line 285 of file OutputModuleBase.cc.

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

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

doBeginLuminosityBlock_()

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

inlineprivatevirtual

Definition at line 267 of file OutputModuleBase.h.

{}

Referenced by doBeginLuminosityBlock().

doBeginLuminosityBlockSummary_()

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

inlineprivatevirtual

Definition at line 268 of file OutputModuleBase.h.

{}

doBeginRun()

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

protected

Definition at line 263 of file OutputModuleBase.cc.

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

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

doBeginRun_()

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

inlineprivatevirtual

Definition at line 263 of file OutputModuleBase.h.

{}

Referenced by doBeginRun().

doBeginRunSummary_()

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

inlineprivatevirtual

Definition at line 264 of file OutputModuleBase.h.

{}

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.

{}

doCloseFile()

void OutputModuleBase::doCloseFile ( )

private

Tell the OutputModule that is must end the current file.

Definition at line 319 of file OutputModuleBase.cc.

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

References isFileOpen(), and reallyCloseFile().

doEndJob()

void OutputModuleBase::doEndJob ( )

protected

Definition at line 211 of file OutputModuleBase.cc.

{ endJob(); }

References endJob().

doEndLuminosityBlock()

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

protected

Definition at line 294 of file OutputModuleBase.cc.

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

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

doEndLuminosityBlock_()

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

inlineprivatevirtual

Definition at line 269 of file OutputModuleBase.h.

{}

Referenced by doEndLuminosityBlock().

doEndLuminosityBlockSummary_()

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

inlineprivatevirtual

Definition at line 270 of file OutputModuleBase.h.

{}

doEndRun()

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

protected

Definition at line 270 of file OutputModuleBase.cc.

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

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

doEndRun_()

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

inlineprivatevirtual

Definition at line 265 of file OutputModuleBase.h.

{}

Referenced by doEndRun().

doEndRunSummary_()

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

inlineprivatevirtual

Definition at line 266 of file OutputModuleBase.h.

{}

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.

{}

doEvent()

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

protected

Definition at line 238 of file OutputModuleBase.cc.

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

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

doOpenFile()

void OutputModuleBase::doOpenFile ( FileBlock const &  fb )

private

Definition at line 310 of file OutputModuleBase.cc.

{ openFile(fb); }

References benchmark_cfg::fb, and openFile().

doPreallocate()

void OutputModuleBase::doPreallocate ( PreallocationConfiguration const &  iPC )

protected

Definition at line 192 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 223 of file OutputModuleBase.h.

{}

doRespondToCloseInputFile()

void OutputModuleBase::doRespondToCloseInputFile ( FileBlock const &  fb )

private

Definition at line 317 of file OutputModuleBase.cc.

{ doRespondToCloseInputFile_(fb); }

References doRespondToCloseInputFile_(), and benchmark_cfg::fb.

doRespondToCloseInputFile_()

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

doRespondToOpenInputFile()

void OutputModuleBase::doRespondToOpenInputFile ( FileBlock const &  fb )

private

Definition at line 312 of file OutputModuleBase.cc.

                                                                       {
      updateBranchIDListsWithKeptAliases();
      doRespondToOpenInputFile_(fb);
    }

References doRespondToOpenInputFile_(), benchmark_cfg::fb, 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.

{}

Referenced by doRespondToOpenInputFile().

doStreamBeginLuminosityBlock()

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

protected

doStreamBeginLuminosityBlock_()

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

inlineprivatevirtual

Definition at line 259 of file OutputModuleBase.h.

{}

doStreamBeginRun()

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

protected

doStreamBeginRun_()

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

inlineprivatevirtual

Definition at line 256 of file OutputModuleBase.h.

{}

doStreamEndLuminosityBlock()

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

protected

doStreamEndLuminosityBlock_()

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

inlineprivatevirtual

Definition at line 260 of file OutputModuleBase.h.

{}

doStreamEndLuminosityBlockSummary_()

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

inlineprivatevirtual

Definition at line 261 of file OutputModuleBase.h.

{}

doStreamEndRun()

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

protected

doStreamEndRun_()

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

inlineprivatevirtual

Definition at line 257 of file OutputModuleBase.h.

{}

doStreamEndRunSummary_()

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

inlineprivatevirtual

Definition at line 258 of file OutputModuleBase.h.

{}

doWriteLuminosityBlock()

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

private

Definition at line 303 of file OutputModuleBase.cc.

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

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

doWriteRun()

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

private

Definition at line 277 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 164 of file OutputModuleBase.h.

                                                                                            {
        return droppedBranchIDToKeptBranchID_;
      }

References droppedBranchIDToKeptBranchID_.

endJob()

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

inlineprivatevirtual

Definition at line 245 of file OutputModuleBase.h.

{}

Referenced by doEndJob().

fillDescription()

void OutputModuleBase::fillDescription ( ParameterSetDescription &  desc )

static

Definition at line 348 of file OutputModuleBase.cc.

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

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

fillDescriptions()

void OutputModuleBase::fillDescriptions ( ConfigurationDescriptions &  descriptions )

static

Definition at line 342 of file OutputModuleBase.cc.

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

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

hasAccumulator()

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

inlineprivate

Definition at line 277 of file OutputModuleBase.h.

{ return false; }

hasAcquire()

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

inlineprivate

Definition at line 276 of file OutputModuleBase.h.

{ return false; }

hasNewlyDroppedBranch()

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

inline

Definition at line 95 of file OutputModuleBase.h.

{ return hasNewlyDroppedBranch_; }

References hasNewlyDroppedBranch_.

isFileOpen()

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

inlineprivatevirtual

Definition at line 249 of file OutputModuleBase.h.

{ 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 155 of file OutputModuleBase.cc.

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

References cms::cuda::assert(), edm::BranchDescription::branchID(), edm::BranchDescription::branchType(), edm::ProductSelector::checkForDuplicateKeptBranch(), edm::EDConsumerBase::consumes(), edm::InEvent, edm::InLumi, HLT_2018_cff::InputTag, edm::InRun, keptProducts_, edm::BranchDescription::moduleLabel(), edm::BranchDescription::originalBranchID(), edm::BranchDescription::processName(), edm::BranchDescription::produced(), edm::PRODUCT_TYPE, edm::BranchDescription::productInstanceName(), unpackBuffers-CaloStage2::token, and edm::BranchDescription::unwrappedTypeID().

Referenced by selectProducts().

keptProducts()

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

inline

Definition at line 94 of file OutputModuleBase.h.

{ return keptProducts_; }

References keptProducts_.

limitReached()

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

inlineprivate

Definition at line 285 of file OutputModuleBase.h.

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

{ return maxEvents_; }

References maxEvents_.

moduleDescription()

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

inline

Definition at line 108 of file OutputModuleBase.h.

{ return moduleDescription_; }

References moduleDescription_.

needToRunSelection()

bool OutputModuleBase::needToRunSelection ( ) const

private

Definition at line 213 of file OutputModuleBase.cc.

{ return !wantAllEvents_; }

References wantAllEvents_.

openFile()

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

inlineprivatevirtual

Definition at line 248 of file OutputModuleBase.h.

{}

Referenced by doOpenFile().

operator=()

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

delete

preActionBeforeRunEventAsync()

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

inlineprotected

Definition at line 145 of file OutputModuleBase.h.

                                                                                       {}

preallocate()

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

inlineprivatevirtual

Definition at line 253 of file OutputModuleBase.h.

{}

Referenced by doPreallocate().

preallocLumis()

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

inlineprivatevirtual

Definition at line 252 of file OutputModuleBase.h.

{}

Referenced by doPreallocate().

preallocStreams()

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

inlineprivatevirtual

Definition at line 251 of file OutputModuleBase.h.

{}

Referenced by doPreallocate().

prePrefetchSelection()

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

private

Definition at line 227 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 354 of file OutputModuleBase.cc.

{}

processName()

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

inline

Definition at line 93 of file OutputModuleBase.h.

{ return process_name_; }

References process_name_.

productsUsedBySelection()

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

private

Definition at line 215 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 118 of file OutputModuleBase.h.

{ return queue_; }

References queue_.

reallyCloseFile()

void OutputModuleBase::reallyCloseFile ( )

privatevirtual

Definition at line 325 of file OutputModuleBase.cc.

{}

Referenced by doCloseFile().

registerProductsAndCallbacks()

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

inlineprivate

Definition at line 230 of file OutputModuleBase.h.

{}

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

{ return remainingEvents_; }

References remainingEvents_.

Referenced by doEvent().

selected()

bool OutputModuleBase::selected

(

BranchDescription const &

desc

)

const

Definition at line 340 of file OutputModuleBase.cc.

{ return productSelector_.selected(desc); }

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

Referenced by selectProducts().

selectorConfig()

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

inlineprotected

Definition at line 123 of file OutputModuleBase.h.

{ return selector_config_id_; }

References selector_config_id_.

selectProducts()

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

Definition at line 82 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;
 
      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_);
    }

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(), thinnedAssociationsHelper_, edm::BranchDescription::transient(), and edm::BranchDescription::unwrappedType().

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.

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

{}

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

{ return false; }

thinnedAssociationsHelper()

ThinnedAssociationsHelper const * OutputModuleBase::thinnedAssociationsHelper

(

)

const

Definition at line 334 of file OutputModuleBase.cc.

                                                                                       {
      return thinnedAssociationsHelper_.get();
    }

References thinnedAssociationsHelper_.

Referenced by selectProducts().

updateBranchIDListsWithKeptAliases()

void OutputModuleBase::updateBranchIDListsWithKeptAliases ( )

private

Definition at line 136 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 102 of file OutputModuleBase.h.

{ return wantAllEvents_; }

References wantAllEvents_.

wantsGlobalLuminosityBlocks()

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

inline

Definition at line 112 of file OutputModuleBase.h.

{ return true; }

wantsGlobalRuns()

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

inline

Definition at line 111 of file OutputModuleBase.h.

{ return true; }

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

{ 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().

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

::edm::WorkerT

template<typename T >

friend class ::edm::WorkerT

friend

Definition at line 71 of file OutputModuleBase.h.

edm::maker::ModuleHolderT

template<typename U >

friend class edm::maker::ModuleHolderT

friend

Definition at line 69 of file OutputModuleBase.h.

Member Data Documentation

branchIDLists_

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

private

Definition at line 205 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 204 of file OutputModuleBase.h.

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

hasNewlyDroppedBranch_

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

private

Definition at line 188 of file OutputModuleBase.h.

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

keepAssociation_

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

private

Definition at line 209 of file OutputModuleBase.h.

Referenced by selectProducts().

keptProducts_

SelectedProductsForBranchType edm::limited::OutputModuleBase::keptProducts_

private

Definition at line 187 of file OutputModuleBase.h.

Referenced by keepThisBranch(), and keptProducts().

maxEvents_

int edm::limited::OutputModuleBase::maxEvents_

private

Definition at line 169 of file OutputModuleBase.h.

Referenced by configure(), and maxEvents().

moduleDescription_

ModuleDescription edm::limited::OutputModuleBase::moduleDescription_

private

Definition at line 193 of file OutputModuleBase.h.

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

origBranchIDLists_

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

private

Definition at line 206 of file OutputModuleBase.h.

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

process_name_

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

private

Definition at line 190 of file OutputModuleBase.h.

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

productSelector_

ProductSelector edm::limited::OutputModuleBase::productSelector_

private

Definition at line 192 of file OutputModuleBase.h.

Referenced by selected(), and selectProducts().

productSelectorRules_

ProductSelectorRules edm::limited::OutputModuleBase::productSelectorRules_

private

Definition at line 191 of file OutputModuleBase.h.

Referenced by selectProducts().

queue_

LimitedTaskQueue edm::limited::OutputModuleBase::queue_

private

Definition at line 210 of file OutputModuleBase.h.

Referenced by concurrencyLimit(), and queue().

remainingEvents_

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

private

Definition at line 170 of file OutputModuleBase.h.

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

selectEvents_

ParameterSet edm::limited::OutputModuleBase::selectEvents_

private

Definition at line 197 of file OutputModuleBase.h.

Referenced by doPreallocate(), and OutputModuleBase().

selector_config_id_

ParameterSetID edm::limited::OutputModuleBase::selector_config_id_

private

Definition at line 200 of file OutputModuleBase.h.

Referenced by OutputModuleBase(), and selectorConfig().

selectors_

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

private

Definition at line 196 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 208 of file OutputModuleBase.h.

Referenced by selectProducts(), and thinnedAssociationsHelper().

wantAllEvents_

bool edm::limited::OutputModuleBase::wantAllEvents_

private

Definition at line 195 of file OutputModuleBase.h.

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