#include <OutputModuleBase.h>

Inheritance diagram for edm::global::OutputModuleBase:

Public Types
typedef OutputModuleBase	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Public Member Functions
BranchIDLists const *	branchIDLists ()

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

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

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

ThinnedAssociationsHelper const *	thinnedAssociationsHelper () const

bool	wantAllEvents () const

virtual	~OutputModuleBase ()

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

	EDConsumerBase ()

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

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

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

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) const

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

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

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, EventSetup const &c, ModuleCallingContext const *)

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

void	doBeginStream (StreamID id)

void	doEndJob ()

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

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

void	doEndStream (StreamID id)

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

void	doPreallocate (PreallocationConfiguration const &)

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

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

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

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

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

ParameterSetID	selectorConfig () const

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

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

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

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

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

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

void	consumesMany (const TypeToGet &id)

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

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

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

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

Private Member Functions
virtual void	beginJob ()

virtual void	doBeginLuminosityBlock_ (LuminosityBlockPrincipal const &, ModuleCallingContext const *)

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

virtual void	doBeginRun_ (RunPrincipal const &, ModuleCallingContext const *)

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

virtual void	doBeginStream_ (StreamID)

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

virtual void	doEndLuminosityBlock_ (LuminosityBlockPrincipal const &, ModuleCallingContext const *)

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

virtual void	doEndRun_ (RunPrincipal const &, ModuleCallingContext const *)

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

virtual void	doEndStream_ (StreamID)

void	doOpenFile (FileBlock const &fb)

void	doPostForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren)

void	doPreForkReleaseResources ()

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, LuminosityBlock const &, EventSetup const &)

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

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

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

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

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

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

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

virtual void	endJob ()

virtual bool	isFileOpen () const

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

bool	limitReached () const

void	maybeOpenFile ()

virtual void	openFile (FileBlock const &)

virtual void	postForkReacquireResources (unsigned int, unsigned int)

virtual void	preallocStreams (unsigned int)

virtual void	preForkReleaseResources ()

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

virtual void	reallyCloseFile ()

virtual void	reallyOpenFile ()

void	registerProductsAndCallbacks (OutputModuleBase const , ProductRegistry const )

void	setModuleDescription (ModuleDescription const &md)

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

std::string	workerType () const

virtual void	write (EventPrincipal const &e, ModuleCallingContext const *)=0

virtual void	writeLuminosityBlock (LuminosityBlockPrincipal const &, ModuleCallingContext const *)=0

virtual void	writeRun (RunPrincipal const &, ModuleCallingContext const *)=0

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

std::atomic< int >	remainingEvents_

ParameterSet	selectEvents_

ParameterSetID	selector_config_id_

std::vector < detail::TriggerResultsBasedEventSelector >	selectors_

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

Member Typedef Documentation

typedef OutputModuleBase edm::global::OutputModuleBase::ModuleType

Definition at line 64 of file OutputModuleBase.h.

Constructor & Destructor Documentation

OutputModuleBase::OutputModuleBase ( ParameterSet const & pset )

explicit

Definition at line 40 of file OutputModuleBase.cc.

References edm::detail::configureEventSelector(), 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) {
       
       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]);
 
     }

OutputModuleBase::~OutputModuleBase ( )

virtual

Definition at line 178 of file OutputModuleBase.cc.

178 { }

edm::global::OutputModuleBase::OutputModuleBase ( OutputModuleBase const & )

delete

Member Function Documentation

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

static

Definition at line 376 of file OutputModuleBase.cc.

References edm::global::kBaseType().

                                {
       return kBaseType;
     }

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

inlineprivatevirtual

Definition at line 232 of file OutputModuleBase.h.

Referenced by doBeginJob().

232 {}

BranchIDLists const * OutputModuleBase::branchIDLists ( )

Definition at line 322 of file OutputModuleBase.cc.

References branchIDLists_, droppedBranchIDToKeptBranchID_, and origBranchIDLists_.

                                     {
       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;
             }
           }
         }
         return branchIDLists_.get();
       }
       return origBranchIDLists_;
     }

void OutputModuleBase::configure ( OutputModuleDescription const & desc )

protected

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

References moduleDescription_.

Referenced by setEventSelectionInfo().

                                         {
       return moduleDescription_;
     }

void OutputModuleBase::doBeginJob ( )

protected

Definition at line 197 of file OutputModuleBase.cc.

References beginJob().

                                       {
       this->beginJob();
     }

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

protected

Definition at line 259 of file OutputModuleBase.cc.

References doBeginLuminosityBlock_().

                                                                               {
       doBeginLuminosityBlock_(lbp, mcc);
       return true;
     }

virtual void edm::global::OutputModuleBase::doBeginLuminosityBlock_	(	LuminosityBlockPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprivatevirtual

Definition at line 257 of file OutputModuleBase.h.

Referenced by doBeginLuminosityBlock().

257 {}

virtual void edm::global::OutputModuleBase::doBeginLuminosityBlockSummary_	(	LuminosityBlock const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 258 of file OutputModuleBase.h.

258 {}

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

protected

Definition at line 237 of file OutputModuleBase.cc.

References doBeginRun_().

                                                                   {
       doBeginRun_(rp, mcc);
       return true;
     }

virtual void edm::global::OutputModuleBase::doBeginRun_	(	RunPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprivatevirtual

Definition at line 253 of file OutputModuleBase.h.

Referenced by doBeginRun().

253 {}

virtual void edm::global::OutputModuleBase::doBeginRunSummary_	(	Run const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 254 of file OutputModuleBase.h.

254 {}

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

protected

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

inlineprivatevirtual

Definition at line 244 of file OutputModuleBase.h.

244 {}

void OutputModuleBase::doCloseFile ( )

private

Tell the OutputModule that is must end the current file.

Definition at line 312 of file OutputModuleBase.cc.

References isFileOpen(), and reallyCloseFile().

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

void OutputModuleBase::doEndJob ( )

protected

Definition at line 201 of file OutputModuleBase.cc.

References endJob().

                                     {
       endJob();
     }

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

protected

Definition at line 267 of file OutputModuleBase.cc.

References doEndLuminosityBlock_().

                                                                             {
       doEndLuminosityBlock_(lbp, mcc);
       return true;
     }

virtual void edm::global::OutputModuleBase::doEndLuminosityBlock_	(	LuminosityBlockPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprivatevirtual

Definition at line 259 of file OutputModuleBase.h.

Referenced by doEndLuminosityBlock().

259 {}

virtual void edm::global::OutputModuleBase::doEndLuminosityBlockSummary_	(	LuminosityBlock const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 260 of file OutputModuleBase.h.

260 {}

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

protected

Definition at line 245 of file OutputModuleBase.cc.

References doEndRun_().

                                                                 {
       doEndRun_(rp, mcc);
       return true;
     }

virtual void edm::global::OutputModuleBase::doEndRun_	(	RunPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprivatevirtual

Definition at line 255 of file OutputModuleBase.h.

Referenced by doEndRun().

255 {}

virtual void edm::global::OutputModuleBase::doEndRunSummary_	(	Run const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 256 of file OutputModuleBase.h.

256 {}

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

protected

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

inlineprivatevirtual

Definition at line 245 of file OutputModuleBase.h.

245 {}

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

protected

Definition at line 212 of file OutputModuleBase.cc.

References remainingEvents(), remainingEvents_, and write().

                                                                {
       
       {
           EventSignalsSentry sentry(act,mcc);
           write(ep, mcc);
       }
 
       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 279 of file OutputModuleBase.cc.

References openFile().

                                                          {
       openFile(fb);
     }

void OutputModuleBase::doPostForkReacquireResources	(	unsigned int	iChildIndex,
		unsigned int	iNumberOfChildren
	)

private

Definition at line 297 of file OutputModuleBase.cc.

References postForkReacquireResources().

                                                                                                            {
       postForkReacquireResources(iChildIndex, iNumberOfChildren);
     }

void OutputModuleBase::doPreallocate ( PreallocationConfiguration const & iPC )

protected

Definition at line 180 of file OutputModuleBase.cc.

References edm::detail::configureEventSelector(), edm::getAllTriggerNames(), edm::PreallocationConfiguration::numberOfStreams(), 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);
         } else {
           seenFirst = true;
         }
       }
     }

void OutputModuleBase::doPreForkReleaseResources ( )

private

Definition at line 292 of file OutputModuleBase.cc.

References preForkReleaseResources().

                                                 {
       preForkReleaseResources();
     }

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

inlineprivate

Definition at line 207 of file OutputModuleBase.h.

208 { }

void OutputModuleBase::doRespondToCloseInputFile ( FileBlock const & fb )

private

Definition at line 287 of file OutputModuleBase.cc.

References doRespondToCloseInputFile_().

                                                                         {
       doRespondToCloseInputFile_(fb);
     }

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

inlineprivatevirtual

Reimplemented in edm::global::outputmodule::InputFileWatcher.

Definition at line 262 of file OutputModuleBase.h.

Referenced by doRespondToCloseInputFile().

262 {}

void OutputModuleBase::doRespondToOpenInputFile ( FileBlock const & fb )

private

Definition at line 283 of file OutputModuleBase.cc.

References doRespondToOpenInputFile_().

                                                                        {
       doRespondToOpenInputFile_(fb);
     }

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

inlineprivatevirtual

Reimplemented in edm::global::outputmodule::InputFileWatcher.

Definition at line 261 of file OutputModuleBase.h.

Referenced by doRespondToOpenInputFile().

261 {}

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

protected

virtual void edm::global::OutputModuleBase::doStreamBeginLuminosityBlock_	(	StreamID	,
		LuminosityBlock const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 249 of file OutputModuleBase.h.

249 {}

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

protected

virtual void edm::global::OutputModuleBase::doStreamBeginRun_	(	StreamID	,
		Run const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 246 of file OutputModuleBase.h.

246 {}

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

protected

virtual void edm::global::OutputModuleBase::doStreamEndLuminosityBlock_	(	StreamID	,
		LuminosityBlock const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 250 of file OutputModuleBase.h.

250 {}

virtual void edm::global::OutputModuleBase::doStreamEndLuminosityBlockSummary_	(	StreamID	,
		LuminosityBlock const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 251 of file OutputModuleBase.h.

251 {}

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

protected

virtual void edm::global::OutputModuleBase::doStreamEndRun_	(	StreamID	,
		Run const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 247 of file OutputModuleBase.h.

247 {}

virtual void edm::global::OutputModuleBase::doStreamEndRunSummary_	(	StreamID	,
		Run const &	,
		EventSetup const &
	)

inlineprivatevirtual

Definition at line 248 of file OutputModuleBase.h.

248 {}

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

private

Definition at line 274 of file OutputModuleBase.cc.

References writeLuminosityBlock().

                                                                                    {
       writeLuminosityBlock(lbp, mcc);
     }

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

private

Definition at line 253 of file OutputModuleBase.cc.

References writeRun().

                                                                   {
       writeRun(rp, mcc);
     }

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

inlineprotected

Definition at line 148 of file OutputModuleBase.h.

References droppedBranchIDToKeptBranchID_.

                                                                                             {
         return droppedBranchIDToKeptBranchID_;
       }

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

inlineprivatevirtual

Definition at line 233 of file OutputModuleBase.h.

Referenced by doEndJob().

233 {}

void OutputModuleBase::fillDescription ( ParameterSetDescription & desc )

static

Definition at line 364 of file OutputModuleBase.cc.

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

                                                                    {
       ProductSelectorRules::fillDescription(desc, "outputCommands");
       EventSelector::fillDescription(desc);
     }

void OutputModuleBase::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 357 of file OutputModuleBase.cc.

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

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

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

inline

Definition at line 85 of file OutputModuleBase.h.

References hasNewlyDroppedBranch_.

85 {return hasNewlyDroppedBranch_;}

edm::global::OutputModuleBase::hasNewlyDroppedBranch_

std::array< bool, NumBranchTypes > hasNewlyDroppedBranch_

Definition: OutputModuleBase.h:173

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

inlineprivatevirtual

Definition at line 237 of file OutputModuleBase.h.

Referenced by doCloseFile(), and maybeOpenFile().

237 { return true; }

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

private

Definition at line 133 of file OutputModuleBase.cc.

Referenced by selectProducts().

                                                                {
 
       ProductSelector::checkForDuplicateKeptBranch(desc,
                                                    trueBranchIDToKeptBranchDesc);
 
       switch (desc.branchType()) {
       case InEvent:
         {
           if(desc.produced()) {
             keptProductsInEvent.insert(desc.originalBranchID());
           } else {
             keptProductsInEvent.insert(desc.branchID());
           }
           consumes(TypeToGet{desc.unwrappedTypeID(),PRODUCT_TYPE},
                    InputTag{desc.moduleLabel(),
                        desc.productInstanceName(),
                        desc.processName()});
           break;
         }
       case InLumi:
         {
           consumes<InLumi>(TypeToGet{desc.unwrappedTypeID(),PRODUCT_TYPE},
                            InputTag(desc.moduleLabel(),
                                     desc.productInstanceName(),
                                     desc.processName()));
           break;
         }
       case InRun:
         {
           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(&desc);
     }

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

inline

Definition at line 84 of file OutputModuleBase.h.

References keptProducts_.

84 {return keptProducts_;}

edm::global::OutputModuleBase::keptProducts_

SelectedProductsForBranchType keptProducts_

Definition: OutputModuleBase.h:172

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

inlineprivate

Definition at line 272 of file OutputModuleBase.h.

References remainingEvents_.

272 {return remainingEvents_ == 0;}

edm::global::OutputModuleBase::remainingEvents_

std::atomic< int > remainingEvents_

Definition: OutputModuleBase.h:155

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

inline

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

Definition at line 74 of file OutputModuleBase.h.

References maxEvents_.

74 {return maxEvents_;}

edm::global::OutputModuleBase::maxEvents_

int maxEvents_

Definition: OutputModuleBase.h:154

void OutputModuleBase::maybeOpenFile ( )

private

Tell the OutputModule to open an output file, if one is not already open.

Definition at line 308 of file OutputModuleBase.cc.

References isFileOpen(), and reallyOpenFile().

                                          {
       if(!isFileOpen()) reallyOpenFile();
     }

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

inline

Definition at line 98 of file OutputModuleBase.h.

References moduleDescription_.

                                                          {
         return moduleDescription_;
       }

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

inlineprivatevirtual

Definition at line 236 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().

236 {}

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

delete

void OutputModuleBase::postForkReacquireResources	(	unsigned	int,
		unsigned	int
	)

privatevirtual

Definition at line 305 of file OutputModuleBase.cc.

Referenced by doPostForkReacquireResources().

305 {}

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

inlineprivatevirtual

Definition at line 243 of file OutputModuleBase.h.

243 {}

void OutputModuleBase::preForkReleaseResources ( )

privatevirtual

Definition at line 302 of file OutputModuleBase.cc.

Referenced by doPreForkReleaseResources().

302 {}

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

private

Definition at line 205 of file OutputModuleBase.cc.

References or, alignCSCRings::s, selectors_, and wantAllEvents_.

                                                                                                                       {
       
       auto& s = selectors_[id.value()];
       return wantAllEvents_ or s.wantEvent(ep,mcc);
     }

void OutputModuleBase::prevalidate ( ConfigurationDescriptions & )

static

Definition at line 370 of file OutputModuleBase.cc.

370 {

371 }

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

inline

Definition at line 83 of file OutputModuleBase.h.

References process_name_.

83 {return process_name_;}

edm::global::OutputModuleBase::process_name_

std::string process_name_

Definition: OutputModuleBase.h:175

void OutputModuleBase::reallyCloseFile ( )

privatevirtual

Definition at line 318 of file OutputModuleBase.cc.

Referenced by doCloseFile().

318 {

319 }

virtual void edm::global::OutputModuleBase::reallyOpenFile ( )

inlineprivatevirtual

Definition at line 238 of file OutputModuleBase.h.

Referenced by maybeOpenFile().

238 {}

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

inlineprivate

Definition at line 219 of file OutputModuleBase.h.

219 {}

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

inline

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

Definition at line 78 of file OutputModuleBase.h.

References remainingEvents_.

Referenced by doEvent().

78 {return remainingEvents_;}

edm::global::OutputModuleBase::remainingEvents_

std::atomic< int > remainingEvents_

Definition: OutputModuleBase.h:155

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

Definition at line 352 of file OutputModuleBase.cc.

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

Referenced by selectProducts(), and edm::AsciiOutputModule::write().

                                                                   {
       return productSelector_.selected(desc);
     }

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

inlineprotected

Definition at line 105 of file OutputModuleBase.h.

References selector_config_id_.

105 { return selector_config_id_; }

edm::global::OutputModuleBase::selector_config_id_

ParameterSetID selector_config_id_

Definition: OutputModuleBase.h:185

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

Definition at line 84 of file OutputModuleBase.cc.

References edm::ProductRegistry::allBranchDescriptions(), edm::BranchDescription::branchType(), droppedBranchIDToKeptBranchID_, edm::ProductSelector::fillDroppedToKept(), hasNewlyDroppedBranch_, edm::ProductSelector::initialize(), edm::ProductSelector::initialized(), keepAssociation_, keepThisBranch(), edm::BranchDescription::present(), edm::BranchDescription::produced(), edm::ProductRegistry::productList(), productSelector_, productSelectorRules_, edm::ThinnedAssociationsHelper::selectAssociationProducts(), selected(), 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;
 
       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);
         } else {
           // otherwise, output nothing,
           // and mark the fact that there is a newly dropped branch of this type.
           hasNewlyDroppedBranch_[desc.branchType()] = true;
         }
       }
 
       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 OutputModuleBase::setEventSelectionInfo	(	std::map< std::string, std::vector< std::pair< std::string, int > > > const &	outputModulePathPositions,
		bool	anyProductProduced
	)

protected

Definition at line 381 of file OutputModuleBase.cc.

References description(), edm::getParameterSet(), edm::detail::registerProperSelectionInfo(), and selector_config_id_.

                                                                  {
       selector_config_id_ = detail::registerProperSelectionInfo(getParameterSet(selector_config_id_),
                                                                 description().moduleLabel(),
                                                                 outputModulePathPositions,
                                                                 anyProductProduced);
     }

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

inlineprivate

Definition at line 268 of file OutputModuleBase.h.

References popcon2dropbox_job_conf::md, and moduleDescription_.

                                                              {
         moduleDescription_ = md;
       }

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

inlineprivatevirtual

Ask the OutputModule if we should end the current file.

Definition at line 229 of file OutputModuleBase.h.

229 {return false;}

ThinnedAssociationsHelper const * OutputModuleBase::thinnedAssociationsHelper ( ) const

Definition at line 342 of file OutputModuleBase.cc.

References thinnedAssociationsHelper_.

                                                       {
       return thinnedAssociationsHelper_.get();
     }

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

inline

Definition at line 92 of file OutputModuleBase.h.

References wantAllEvents_.

92 {return wantAllEvents_;}

edm::global::OutputModuleBase::wantAllEvents_

bool wantAllEvents_

Definition: OutputModuleBase.h:180

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

inlineprivate

Definition at line 210 of file OutputModuleBase.h.

210 {return "WorkerT<edm::global::OutputModuleBase>";}

virtual void edm::global::OutputModuleBase::write	(	EventPrincipal const &	e,
		ModuleCallingContext const *
	)

privatepure virtual

Implemented in edm::AsciiOutputModule.

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

virtual void edm::global::OutputModuleBase::writeLuminosityBlock	(	LuminosityBlockPrincipal const &	,
		ModuleCallingContext const *
	)

privatepure virtual

Implemented in edm::AsciiOutputModule.

Referenced by doWriteLuminosityBlock().

virtual void edm::global::OutputModuleBase::writeRun	(	RunPrincipal const &	,
		ModuleCallingContext const *
	)

privatepure virtual

Implemented in edm::AsciiOutputModule.

Referenced by doWriteRun().

Friends And Related Function Documentation

template<typename T >

friend class ::edm::OutputModuleCommunicatorT

friend

Definition at line 63 of file OutputModuleBase.h.

template<typename T >

friend class ::edm::WorkerT

friend

Definition at line 62 of file OutputModuleBase.h.

template<typename U >

friend class edm::maker::ModuleHolderT

friend

Definition at line 61 of file OutputModuleBase.h.

Member Data Documentation

std::unique_ptr<BranchIDLists> edm::global::OutputModuleBase::branchIDLists_

private

Definition at line 190 of file OutputModuleBase.h.

Referenced by branchIDLists().

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

private

Definition at line 189 of file OutputModuleBase.h.

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

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

private

Definition at line 173 of file OutputModuleBase.h.

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

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

private

Definition at line 194 of file OutputModuleBase.h.

Referenced by selectProducts().

SelectedProductsForBranchType edm::global::OutputModuleBase::keptProducts_

private

Definition at line 172 of file OutputModuleBase.h.

Referenced by keepThisBranch(), and keptProducts().

int edm::global::OutputModuleBase::maxEvents_

private

Definition at line 154 of file OutputModuleBase.h.

Referenced by configure(), and maxEvents().

ModuleDescription edm::global::OutputModuleBase::moduleDescription_

private

Definition at line 178 of file OutputModuleBase.h.

Referenced by description(), moduleDescription(), and setModuleDescription().

BranchIDLists const* edm::global::OutputModuleBase::origBranchIDLists_

private

Definition at line 191 of file OutputModuleBase.h.

Referenced by branchIDLists(), and configure().

std::string edm::global::OutputModuleBase::process_name_

private

Definition at line 175 of file OutputModuleBase.h.

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

ProductSelector edm::global::OutputModuleBase::productSelector_

private

Definition at line 177 of file OutputModuleBase.h.

Referenced by selected(), and selectProducts().

ProductSelectorRules edm::global::OutputModuleBase::productSelectorRules_

private

Definition at line 176 of file OutputModuleBase.h.

Referenced by selectProducts().

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

private

Definition at line 155 of file OutputModuleBase.h.

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

ParameterSet edm::global::OutputModuleBase::selectEvents_

private

Definition at line 182 of file OutputModuleBase.h.

Referenced by doPreallocate(), and OutputModuleBase().

ParameterSetID edm::global::OutputModuleBase::selector_config_id_

private

Definition at line 185 of file OutputModuleBase.h.

Referenced by OutputModuleBase(), selectorConfig(), and setEventSelectionInfo().

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

private

Definition at line 181 of file OutputModuleBase.h.

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

std::unique_ptr<ThinnedAssociationsHelper> edm::global::OutputModuleBase::thinnedAssociationsHelper_

private

Definition at line 193 of file OutputModuleBase.h.

Referenced by selectProducts(), and thinnedAssociationsHelper().

bool edm::global::OutputModuleBase::wantAllEvents_

private

Definition at line 180 of file OutputModuleBase.h.

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

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation