#include <OutputModuleBase.h>

Inheritance diagram for edm::one::OutputModuleBase:

Public Types
typedef OutputModuleBase	ModuleType

Public Member Functions
BranchChildren const &	branchChildren () const

BranchIDLists const *	branchIDLists () const

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

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleBase &	operator= (OutputModuleBase const &)=delete

	OutputModuleBase (ParameterSet const &pset)

	OutputModuleBase (OutputModuleBase const &)=delete

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

void	selectProducts (ProductRegistry const &preg)

bool	wantAllEvents () const

virtual	~OutputModuleBase ()

Public Member Functions inherited from edm::EDConsumerBase
	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

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

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

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

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

void	doPreallocate (PreallocationConfiguration const &)

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

Trig	getTriggerResults (EventPrincipal const &ep, ModuleCallingContext const *) const

ParameterSetID	selectorConfig () const

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

Protected Member Functions inherited from edm::EDConsumerBase
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 Types
typedef std::map< BranchID, std::set< ParentageID > >	BranchParents

Private Member Functions
virtual void	beginJob ()

virtual SharedResourcesAcquirer	createAcquirer ()

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

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

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

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

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

void	doOpenFile (FileBlock const &fb)

void	doPostForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren)

void	doPreForkReleaseResources ()

void	doRespondToCloseInputFile (FileBlock const &fb)

virtual void	doRespondToCloseInputFile_ (FileBlock const &)

void	doRespondToOpenInputFile (FileBlock const &fb)

virtual void	doRespondToOpenInputFile_ (FileBlock const &)

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

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

virtual void	endJob ()

void	fillDependencyGraph ()

virtual bool	isFileOpen () const

bool	limitReached () const

void	maybeOpenFile ()

virtual void	openFile (FileBlock const &)

virtual void	postForkReacquireResources (unsigned int, unsigned int)

virtual void	preForkReleaseResources ()

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

void	updateBranchParents (EventPrincipal const &ep)

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
BranchChildren	branchChildren_

std::unique_ptr< BranchIDLists >	branchIDLists_

BranchParents	branchParents_

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

std::array< bool, NumBranchTypes >	hasNewlyDroppedBranch_

SelectedProductsForBranchType	keptProducts_

int	maxEvents_

ModuleDescription	moduleDescription_

std::mutex	mutex_

BranchIDLists const *	origBranchIDLists_

std::string	process_name_

ProductSelector	productSelector_

ProductSelectorRules	productSelectorRules_

std::atomic< int >	remainingEvents_

SharedResourcesAcquirer	resourcesAcquirer_

ParameterSetID	selector_config_id_

detail::TriggerResultsBasedEventSelector	selectors_

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

Member Typedef Documentation

typedef std::map<BranchID, std::set<ParentageID> > edm::one::OutputModuleBase::BranchParents

private

Definition at line 177 of file OutputModuleBase.h.

typedef OutputModuleBase edm::one::OutputModuleBase::ModuleType

Definition at line 67 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(), 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),
     branchParents_(),
     branchChildren_() {
       
       hasNewlyDroppedBranch_.fill(false);
       
       Service<service::TriggerNamesService> tns;
       process_name_ = tns->getProcessName();
       
       ParameterSet selectevents =
       pset.getUntrackedParameterSet("SelectEvents", ParameterSet());
       
       selectevents.registerIt(); // Just in case this PSet is not registered
       
       selector_config_id_ = selectevents.id();
       wantAllEvents_ = detail::configureEventSelector(selectevents,
                                                       process_name_,
                                                       getAllTriggerNames(),
                                                       selectors_);
     }

OutputModuleBase::~OutputModuleBase ( )

virtual

Definition at line 167 of file OutputModuleBase.cc.

167 { }

edm::one::OutputModuleBase::OutputModuleBase ( OutputModuleBase const & )

delete

Member Function Documentation

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

static

Definition at line 352 of file OutputModuleBase.cc.

References edm::one::kBaseType().

                                {
       return kBaseType;
     }

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

inlineprivatevirtual

Reimplemented in edm::PoolOutputModule.

Definition at line 219 of file OutputModuleBase.h.

Referenced by doBeginJob().

219 {}

BranchChildren const& edm::one::OutputModuleBase::branchChildren ( ) const

inline

Definition at line 95 of file OutputModuleBase.h.

References branchChildren_.

Referenced by edm::RootOutputFile::writeProductDependencies().

95 {return branchChildren_;}

edm::one::OutputModuleBase::branchChildren_

BranchChildren branchChildren_

Definition: OutputModuleBase.h:180

BranchIDLists const * OutputModuleBase::branchIDLists ( ) const

Definition at line 303 of file OutputModuleBase.cc.

References branchIDLists_, droppedBranchIDToKeptBranchID_, and origBranchIDLists_.

Referenced by edm::RootOutputFile::writeBranchIDListRegistry().

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

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

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

SharedResourcesAcquirer OutputModuleBase::createAcquirer ( )

privatevirtual

Definition at line 169 of file OutputModuleBase.cc.

Referenced by doBeginJob().

                                                              {
       return SharedResourcesAcquirer{};
     }

ModuleDescription const & OutputModuleBase::description ( ) const

protected

Definition at line 323 of file OutputModuleBase.cc.

References moduleDescription_.

Referenced by DQMRootOutputModule::openFile(), and setEventSelectionInfo().

                                         {
       return moduleDescription_;
     }

void OutputModuleBase::doBeginJob ( )

protected

Definition at line 173 of file OutputModuleBase.cc.

References beginJob(), createAcquirer(), and resourcesAcquirer_.

                                       {
       resourcesAcquirer_ = createAcquirer();
       this->beginJob();
     }

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

protected

Definition at line 237 of file OutputModuleBase.cc.

References doBeginLuminosityBlock_().

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

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

inlineprivatevirtual

Reimplemented in edm::one::outputmodule::LuminosityBlockWatcher.

Definition at line 232 of file OutputModuleBase.h.

Referenced by doBeginLuminosityBlock().

232 {}

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

protected

Definition at line 215 of file OutputModuleBase.cc.

References doBeginRun_().

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

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

inlineprivatevirtual

Reimplemented in edm::one::outputmodule::RunWatcher.

Definition at line 230 of file OutputModuleBase.h.

Referenced by doBeginRun().

230 {}

void OutputModuleBase::doCloseFile ( )

private

Tell the OutputModule that is must end the current file.

Definition at line 290 of file OutputModuleBase.cc.

References branchChildren_, branchParents_, edm::BranchChildren::clear(), fillDependencyGraph(), isFileOpen(), and reallyCloseFile().

                                        {
       if(isFileOpen()) {
         fillDependencyGraph();
         reallyCloseFile();
         branchParents_.clear();
         branchChildren_.clear();
       }
     }

void OutputModuleBase::doEndJob ( )

protected

Definition at line 178 of file OutputModuleBase.cc.

References endJob().

                                     {
       endJob();
     }

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

protected

Definition at line 245 of file OutputModuleBase.cc.

References doEndLuminosityBlock_().

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

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

inlineprivatevirtual

Reimplemented in edm::one::outputmodule::LuminosityBlockWatcher.

Definition at line 233 of file OutputModuleBase.h.

Referenced by doEndLuminosityBlock().

233 {}

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

protected

Definition at line 223 of file OutputModuleBase.cc.

References doEndRun_().

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

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

inlineprivatevirtual

Reimplemented in edm::one::outputmodule::RunWatcher.

Definition at line 231 of file OutputModuleBase.h.

Referenced by doEndRun().

231 {}

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

protected

Definition at line 188 of file OutputModuleBase.cc.

References mutex_, remainingEvents_, resourcesAcquirer_, selectors_, updateBranchParents(), wantAllEvents_, edm::detail::TriggerResultsBasedEventSelector::wantEvent(), and write().

                                                                {
       
       {
         std::lock_guard<std::mutex> guard(mutex_);
         detail::TRBESSentry products_sentry(selectors_);
         if(!wantAllEvents_) {
           if(!selectors_.wantEvent(ep, mcc)) {
             return true;
           }
         }
         {
           std::lock_guard<SharedResourcesAcquirer> guard(resourcesAcquirer_);
           EventSignalsSentry sentry(act,mcc);
           write(ep, mcc);
         }
         updateBranchParents(ep);
       }
       if(remainingEvents_ > 0) {
         --remainingEvents_;
       }
       return true;
     }

void OutputModuleBase::doOpenFile ( FileBlock const & fb )

private

Definition at line 257 of file OutputModuleBase.cc.

References openFile().

                                                          {
       openFile(fb);
     }

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

private

Definition at line 275 of file OutputModuleBase.cc.

References postForkReacquireResources().

                                                                                                            {
       postForkReacquireResources(iChildIndex, iNumberOfChildren);
     }

void edm::one::OutputModuleBase::doPreallocate ( PreallocationConfiguration const & )

inlineprotected

Definition at line 112 of file OutputModuleBase.h.

112 {}

void OutputModuleBase::doPreForkReleaseResources ( )

private

Definition at line 270 of file OutputModuleBase.cc.

References preForkReleaseResources().

                                                 {
       preForkReleaseResources();
     }

void OutputModuleBase::doRespondToCloseInputFile ( FileBlock const & fb )

private

Definition at line 265 of file OutputModuleBase.cc.

References doRespondToCloseInputFile_().

                                                                         {
       doRespondToCloseInputFile_(fb);
     }

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

inlineprivatevirtual

Reimplemented in edm::one::outputmodule::InputFileWatcher.

Definition at line 235 of file OutputModuleBase.h.

Referenced by doRespondToCloseInputFile().

235 {}

void OutputModuleBase::doRespondToOpenInputFile ( FileBlock const & fb )

private

Definition at line 261 of file OutputModuleBase.cc.

References doRespondToOpenInputFile_().

                                                                        {
       doRespondToOpenInputFile_(fb);
     }

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

inlineprivatevirtual

Reimplemented in edm::one::outputmodule::InputFileWatcher.

Definition at line 234 of file OutputModuleBase.h.

Referenced by doRespondToOpenInputFile().

234 {}

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

private

Definition at line 252 of file OutputModuleBase.cc.

References writeLuminosityBlock().

                                                                                    {
       writeLuminosityBlock(lbp, mcc);
     }

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

private

Definition at line 231 of file OutputModuleBase.cc.

References writeRun().

                                                                   {
       writeRun(rp, mcc);
     }

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

inlineprotected

Definition at line 133 of file OutputModuleBase.h.

References droppedBranchIDToKeptBranchID_.

                                                                                             {
         return droppedBranchIDToKeptBranchID_;
       }

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

inlineprivatevirtual

Definition at line 220 of file OutputModuleBase.h.

Referenced by doEndJob().

220 {}

void OutputModuleBase::fillDependencyGraph ( )

private

Definition at line 381 of file OutputModuleBase.cc.

References branchChildren_, branchParents_, edm::ParentageRegistry::getMapped(), i, edm::BranchChildren::insertChild(), edm::ParentageRegistry::instance(), j, parents, and edm::Parentage::parents().

Referenced by doCloseFile().

                                           {
       for(BranchParents::const_iterator i = branchParents_.begin(), iEnd = branchParents_.end();
           i != iEnd; ++i) {
         BranchID const& child = i->first;
         std::set<ParentageID> const& eIds = i->second;
         for(std::set<ParentageID>::const_iterator it = eIds.begin(), itEnd = eIds.end();
             it != itEnd; ++it) {
           Parentage entryDesc;
           ParentageRegistry::instance()->getMapped(*it, entryDesc);
           std::vector<BranchID> const& parents = entryDesc.parents();
           for(std::vector<BranchID>::const_iterator j = parents.begin(), jEnd = parents.end();
               j != jEnd; ++j) {
             branchChildren_.insertChild(*j, child);
           }
         }
       }
     }

void OutputModuleBase::fillDescription ( ParameterSetDescription & desc )

static

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

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

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

Trig OutputModuleBase::getTriggerResults	(	EventPrincipal const &	ep,
		ModuleCallingContext const *	mcc
	)		const

protected

Definition at line 183 of file OutputModuleBase.cc.

References edm::detail::TriggerResultsBasedEventSelector::getOneTriggerResults(), and selectors_.

184 {

185 return selectors_.getOneTriggerResults(ep, mcc); }

edm::detail::TriggerResultsBasedEventSelector::getOneTriggerResults

handle_t getOneTriggerResults(EventPrincipal const &e, ModuleCallingContext const *)

Definition: TriggerResultsBasedEventSelector.cc:193

edm::one::OutputModuleBase::selectors_

detail::TriggerResultsBasedEventSelector selectors_

Definition: OutputModuleBase.h:166

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

inline

Definition at line 88 of file OutputModuleBase.h.

References hasNewlyDroppedBranch_.

88 {return hasNewlyDroppedBranch_;}

edm::one::OutputModuleBase::hasNewlyDroppedBranch_

std::array< bool, NumBranchTypes > hasNewlyDroppedBranch_

Definition: OutputModuleBase.h:158

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

inlineprivatevirtual

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 224 of file OutputModuleBase.h.

Referenced by doCloseFile(), and maybeOpenFile().

224 { return true; }

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

inline

Definition at line 87 of file OutputModuleBase.h.

References keptProducts_.

Referenced by edm::PoolOutputModule::beginJob(), edm::PoolOutputModule::fillSelectedItemList(), and edm::RootOutputFile::finishEndFile().

87 {return keptProducts_;}

edm::one::OutputModuleBase::keptProducts_

SelectedProductsForBranchType keptProducts_

Definition: OutputModuleBase.h:157

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

inlineprivate

Definition at line 244 of file OutputModuleBase.h.

References remainingEvents_.

244 {return remainingEvents_ == 0;}

edm::one::OutputModuleBase::remainingEvents_

std::atomic< int > remainingEvents_

Definition: OutputModuleBase.h:140

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

inline

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

Definition at line 77 of file OutputModuleBase.h.

References maxEvents_.

77 {return maxEvents_;}

edm::one::OutputModuleBase::maxEvents_

int maxEvents_

Definition: OutputModuleBase.h:139

void OutputModuleBase::maybeOpenFile ( )

private

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

Definition at line 286 of file OutputModuleBase.cc.

References isFileOpen(), and reallyOpenFile().

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

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

inline

Definition at line 101 of file OutputModuleBase.h.

References moduleDescription_.

                                                          {
         return moduleDescription_;
       }

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

inlineprivatevirtual

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

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

223 {}

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

delete

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

privatevirtual

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 283 of file OutputModuleBase.cc.

Referenced by doPostForkReacquireResources().

283 {}

void OutputModuleBase::preForkReleaseResources ( )

privatevirtual

Definition at line 280 of file OutputModuleBase.cc.

Referenced by doPreForkReleaseResources().

280 {}

void OutputModuleBase::prevalidate ( ConfigurationDescriptions & )

static

Definition at line 346 of file OutputModuleBase.cc.

346 {

347 }

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

inline

Definition at line 86 of file OutputModuleBase.h.

References process_name_.

Referenced by DQMRootOutputModule::startEndFile().

86 {return process_name_;}

edm::one::OutputModuleBase::process_name_

std::string process_name_

Definition: OutputModuleBase.h:160

void OutputModuleBase::reallyCloseFile ( )

privatevirtual

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 299 of file OutputModuleBase.cc.

Referenced by doCloseFile().

299 {

300 }

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

inlineprivatevirtual

Reimplemented in edm::PoolOutputModule.

Definition at line 225 of file OutputModuleBase.h.

Referenced by maybeOpenFile().

225 {}

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

inlineprivate

Definition at line 207 of file OutputModuleBase.h.

207 {}

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

inline

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

Definition at line 81 of file OutputModuleBase.h.

References remainingEvents_.

Referenced by edm::PoolOutputModule::beginInputFile().

81 {return remainingEvents_;}

edm::one::OutputModuleBase::remainingEvents_

std::atomic< int > remainingEvents_

Definition: OutputModuleBase.h:140

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

Definition at line 328 of file OutputModuleBase.cc.

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

Referenced by selectProducts().

                                                                   {
       return productSelector_.selected(desc);
     }

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

inlineprotected

Definition at line 110 of file OutputModuleBase.h.

References selector_config_id_.

Referenced by edm::RootOutputFile::writeOne().

110 { return selector_config_id_; }

edm::one::OutputModuleBase::selector_config_id_

ParameterSetID selector_config_id_

Definition: OutputModuleBase.h:169

void OutputModuleBase::selectProducts ( ProductRegistry const & preg )

Definition at line 80 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;
       
       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(selected(desc)) {
           // else if the branch has been selected, put it in the list of selected branches.
           if(desc.produced()) {
             // First we check if an equivalent branch has already been selected due to an EDAlias.
             // We only need the check for products produced in this process.
             BranchID const& trueBranchID = desc.originalBranchID();
             std::map<BranchID, BranchDescription const*>::const_iterator iter = trueBranchIDToKeptBranchDesc.find(trueBranchID);
             if(iter != trueBranchIDToKeptBranchDesc.end()) {
               throw edm::Exception(errors::Configuration, "Duplicate Output Selection")
               << "Two (or more) equivalent branches have been selected for output.\n"
               << "#1: " << BranchKey(desc) << "\n"
               << "#2: " << BranchKey(*iter->second) << "\n"
               << "Please drop at least one of them.\n";
             }
             trueBranchIDToKeptBranchDesc.insert(std::make_pair(trueBranchID, &desc));
           }
           switch (desc.branchType()) {
             case InEvent:
             {
               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);
         } else {
           // otherwise, output nothing,
           // and mark the fact that there is a newly dropped branch of this type.
           hasNewlyDroppedBranch_[desc.branchType()] = true;
         }
       }
       // Now fill in a mapping needed in the case that a branch was dropped while its EDAlias was kept.
       for(auto const& it : preg.productList()) {
         BranchDescription const& desc = it.second;
         if(!desc.produced() || desc.isAlias()) continue;
         BranchID const& branchID = desc.branchID();
         std::map<BranchID, BranchDescription const*>::const_iterator iter = trueBranchIDToKeptBranchDesc.find(branchID);
         if(iter != trueBranchIDToKeptBranchDesc.end()) {
           // This branch, produced in this process, or an alias of it, was persisted.
           BranchID const& keptBranchID = iter->second->branchID();
           if(keptBranchID != branchID) {
             // An EDAlias branch was persisted.
             droppedBranchIDToKeptBranchID_.insert(std::make_pair(branchID.id(), keptBranchID.id()));
           }
         }
       }
     }

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

protected

Definition at line 357 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::one::OutputModuleBase::setModuleDescription ( ModuleDescription const & md )

inlineprivate

Definition at line 237 of file OutputModuleBase.h.

References moduleDescription_.

                                                              {
         moduleDescription_ = md;
       }

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

inlineprivatevirtual

Ask the OutputModule if we should end the current file.

Reimplemented in edm::PoolOutputModule, and edm::TimeoutPoolOutputModule.

Definition at line 216 of file OutputModuleBase.h.

216 {return false;}

void OutputModuleBase::updateBranchParents ( EventPrincipal const & ep )

private

Definition at line 366 of file OutputModuleBase.cc.

References edm::Principal::begin(), branchChildren_, branchParents_, edm::Principal::end(), i, and edm::BranchChildren::insertEmpty().

Referenced by doEvent().

                                                                   {
       for(EventPrincipal::const_iterator i = ep.begin(), iEnd = ep.end(); i != iEnd; ++i) {
         if((*i) && (*i)->productProvenancePtr() != 0) {
           BranchID const& bid = (*i)->branchDescription().branchID();
           BranchParents::iterator it = branchParents_.find(bid);
           if(it == branchParents_.end()) {
             it = branchParents_.insert(std::make_pair(bid, std::set<ParentageID>())).first;
           }
           it->second.insert((*i)->productProvenancePtr()->parentageID());
           branchChildren_.insertEmpty(bid);
         }
       }
     }