#include <OutputModule.h>

Inheritance diagram for edm::OutputModule:

Public Types
typedef OutputModule	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

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

OutputModule &	operator= (OutputModule const &)=delete

	OutputModule (ParameterSet const &pset)

	OutputModule (OutputModule 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	~OutputModule ()

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 *mcc)

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

void	doEndJob ()

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

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

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

void	doPreallocate (PreallocationConfiguration const &)

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

Trig	getTriggerResults (EDGetTokenT< TriggerResults > const &token, EventPrincipal const &ep, ModuleCallingContext const *) const

ModuleDescription const &	moduleDescription () 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 void	beginLuminosityBlock (LuminosityBlockPrincipal const &, ModuleCallingContext const *)

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

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

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)

void	doRespondToOpenInputFile (FileBlock const &fb)

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

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

virtual void	endJob ()

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

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

void	fillDependencyGraph ()

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

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

virtual void	reallyCloseFile ()

virtual void	reallyOpenFile ()

void	registerProductsAndCallbacks (OutputModule const , ProductRegistry const )

virtual void	respondToCloseInputFile (FileBlock const &)

virtual void	respondToOpenInputFile (FileBlock 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_

std::map< BranchID, bool >	keepAssociation_

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	resourceAcquirer_

ParameterSet	selectEvents_

ParameterSetID	selector_config_id_

std::vector < detail::TriggerResultsBasedEventSelector >	selectors_

std::unique_ptr < ThinnedAssociationsHelper >	thinnedAssociationsHelper_

bool	wantAllEvents_

Friends
template<typename T >
class	maker::ModuleHolderT

template<typename T >
class	OutputModuleCommunicatorT

template<typename T >
class	WorkerT

Detailed Description

Definition at line 52 of file OutputModule.h.

Member Typedef Documentation

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

private

Definition at line 176 of file OutputModule.h.

typedef OutputModule edm::OutputModule::ModuleType

Definition at line 57 of file OutputModule.h.

Constructor & Destructor Documentation

edm::OutputModule::OutputModule ( ParameterSet const & pset )

explicit

Definition at line 35 of file OutputModule.cc.

References edm::detail::configureEventSelector(), edm::getAllTriggerNames(), edm::ParameterSet::getUntrackedParameterSet(), hasNewlyDroppedBranch_, edm::ParameterSet::id(), edm::SharedResourcesRegistry::instance(), edm::SharedResourcesRegistry::kLegacyModuleResourceName, process_name_, edm::ParameterSet::registerIt(), edm::SharedResourcesRegistry::registerSharedResource(), 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),
     branchParents_(),
     branchChildren_() {
 
     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();
     selectors_.resize(1);
     //need to set wantAllEvents_ in constructor
     // we will make the remaining selectors once we know how many streams
     wantAllEvents_ = detail::configureEventSelector(selectEvents_,
                                                           process_name_,
                                                           getAllTriggerNames(),
                                                           selectors_[0]);
 
     SharedResourcesRegistry::instance()->registerSharedResource(
                                                                 SharedResourcesRegistry::kLegacyModuleResourceName);
 
   }

edm::OutputModule::~OutputModule ( )

virtual

Definition at line 177 of file OutputModule.cc.

177 { }

edm::OutputModule::OutputModule ( OutputModule const & )

delete

Member Function Documentation

const std::string & edm::OutputModule::baseType ( )

static

Definition at line 408 of file OutputModule.cc.

References edm::kBaseType().

                          {
     return kBaseType;
   }

virtual void edm::OutputModule::beginJob ( void )

inlineprivatevirtual

Definition at line 219 of file OutputModule.h.

Referenced by doBeginJob().

219 {}

virtual void edm::OutputModule::beginLuminosityBlock	(	LuminosityBlockPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprivatevirtual

Reimplemented in RawEventOutputModuleForBU< Consumer >.

Definition at line 224 of file OutputModule.h.

Referenced by doBeginLuminosityBlock().

224 {}

virtual void edm::OutputModule::beginRun	(	RunPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprivatevirtual

Reimplemented in RawEventOutputModuleForBU< Consumer >.

Definition at line 221 of file OutputModule.h.

Referenced by doBeginRun().

221 {}

BranchChildren const& edm::OutputModule::branchChildren ( ) const

inline

Definition at line 85 of file OutputModule.h.

References branchChildren_.

85 {return branchChildren_;}

edm::OutputModule::branchChildren_

BranchChildren branchChildren_

Definition: OutputModule.h:179

BranchIDLists const * edm::OutputModule::branchIDLists ( ) const

Definition at line 354 of file OutputModule.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 edm::OutputModule::configure ( OutputModuleDescription const & desc )

protected

Definition at line 78 of file OutputModule.cc.

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

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

ModuleDescription const & edm::OutputModule::description ( ) const

protected

Definition at line 379 of file OutputModule.cc.

References moduleDescription_.

Referenced by setEventSelectionInfo().

                                   {
     return moduleDescription_;
   }

void edm::OutputModule::doBeginJob ( )

protected

Definition at line 196 of file OutputModule.cc.

References beginJob(), edm::SharedResourcesRegistry::createAcquirer(), edm::SharedResourcesRegistry::instance(), edm::SharedResourcesRegistry::kLegacyModuleResourceName, and resourceAcquirer_.

                                 {
     std::vector<std::string> res = {SharedResourcesRegistry::kLegacyModuleResourceName};
     resourceAcquirer_ = SharedResourcesRegistry::instance()->createAcquirer(res);
 
     this->beginJob();
   }

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

protected

Definition at line 292 of file OutputModule.cc.

References beginLuminosityBlock(), and FDEBUG.

                                                                         {
     FDEBUG(2) << "beginLuminosityBlock called\n";
     beginLuminosityBlock(lbp, mcc);
     return true;
   }

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

protected

Definition at line 267 of file OutputModule.cc.

References beginRun(), and FDEBUG.

                                                             {
     FDEBUG(2) << "beginRun called\n";
     beginRun(rp, mcc);
     return true;
   }

void edm::OutputModule::doCloseFile ( )

private

Tell the OutputModule that is must end the current file.

Definition at line 341 of file OutputModule.cc.

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

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

void edm::OutputModule::doEndJob ( )

protected

Definition at line 203 of file OutputModule.cc.

References endJob().

                               {
     endJob();
   }

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

protected

Definition at line 301 of file OutputModule.cc.

References endLuminosityBlock(), and FDEBUG.

                                                                       {
     FDEBUG(2) << "endLuminosityBlock called\n";
     endLuminosityBlock(lbp, mcc);
     return true;
   }

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

protected

Definition at line 276 of file OutputModule.cc.

References endRun(), and FDEBUG.

                                                           {
     FDEBUG(2) << "endRun called\n";
     endRun(rp, mcc);
     return true;
   }

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

protected

Definition at line 227 of file OutputModule.cc.

References FDEBUG, mutex_, remainingEvents_, resourceAcquirer_, updateBranchParents(), and write().

                                                          {
 
     FDEBUG(2) << "writeEvent called\n";
 
     {
       std::lock_guard<std::mutex> guard(mutex_);
       
       {
         std::lock_guard<SharedResourcesAcquirer> guardAcq(resourceAcquirer_);
         EventSignalsSentry signals(act,mcc);
         write(ep, mcc);
       }
       updateBranchParents(ep);
     }
     if(remainingEvents_ > 0) {
       --remainingEvents_;
     }
     return true;
   }

void edm::OutputModule::doOpenFile ( FileBlock const & fb )

private

Definition at line 315 of file OutputModule.cc.

References openFile().

                                                    {
     openFile(fb);
   }

void edm::OutputModule::doPostForkReacquireResources	(	unsigned int	iChildIndex,
		unsigned int	iNumberOfChildren
	)

private

Definition at line 333 of file OutputModule.cc.

References postForkReacquireResources().

                                                                                                      {
     postForkReacquireResources(iChildIndex, iNumberOfChildren);
   }

void edm::OutputModule::doPreallocate ( PreallocationConfiguration const & iPC )

protected

Definition at line 179 of file OutputModule.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);
       }
       seenFirst = true;
     }
   }

void edm::OutputModule::doPreForkReleaseResources ( )

private

Definition at line 328 of file OutputModule.cc.

References preForkReleaseResources().

                                           {
     preForkReleaseResources();
   }

void edm::OutputModule::doRegisterThinnedAssociations	(	ProductRegistry const &	,
		ThinnedAssociationsHelper &
	)

inlineprivate

Definition at line 194 of file OutputModule.h.

195 { }

void edm::OutputModule::doRespondToCloseInputFile ( FileBlock const & fb )

private

Definition at line 323 of file OutputModule.cc.

References respondToCloseInputFile().

                                                                   {
     respondToCloseInputFile(fb);
   }

void edm::OutputModule::doRespondToOpenInputFile ( FileBlock const & fb )

private

Definition at line 319 of file OutputModule.cc.

References respondToOpenInputFile().

                                                                  {
     respondToOpenInputFile(fb);
   }

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

private

Definition at line 309 of file OutputModule.cc.

References FDEBUG, and writeLuminosityBlock().

                                                                              {
     FDEBUG(2) << "writeLuminosityBlock called\n";
     writeLuminosityBlock(lbp, mcc);
   }

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

private

Definition at line 285 of file OutputModule.cc.

References FDEBUG, and writeRun().

                                                             {
     FDEBUG(2) << "writeRun called\n";
     writeRun(rp, mcc);
   }

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

inlineprotected

Definition at line 128 of file OutputModule.h.

References droppedBranchIDToKeptBranchID_.

                                                                                           {
       return droppedBranchIDToKeptBranchID_;
     }

virtual void edm::OutputModule::endJob ( void )

inlineprivatevirtual

Definition at line 220 of file OutputModule.h.

Referenced by doEndJob().

220 {}

virtual void edm::OutputModule::endLuminosityBlock	(	LuminosityBlockPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprivatevirtual

Reimplemented in RawEventOutputModuleForBU< Consumer >.

Definition at line 225 of file OutputModule.h.

Referenced by doEndLuminosityBlock().

225 {}

virtual void edm::OutputModule::endRun	(	RunPrincipal const &	,
		ModuleCallingContext const *
	)

inlineprivatevirtual

Reimplemented in RawEventOutputModuleForBU< Consumer >.

Definition at line 222 of file OutputModule.h.

Referenced by doEndRun().

222 {}

void edm::OutputModule::fillDependencyGraph ( )

private

Definition at line 437 of file OutputModule.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 edm::OutputModule::fillDescription ( ParameterSetDescription & desc )

static

Definition at line 396 of file OutputModule.cc.

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

Referenced by edm::StreamerOutputModuleBase::fillDescription(), edm::PoolOutputModule::fillDescription(), edm::AsciiOutputModule::fillDescriptions(), edm::ProvenanceCheckerOutputModule::fillDescriptions(), and edm::GetProductCheckerOutputModule::fillDescriptions().

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

void edm::OutputModule::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 389 of file OutputModule.cc.

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

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

Trig edm::OutputModule::getTriggerResults	(	EDGetTokenT< TriggerResults > const &	token,
		EventPrincipal const &	ep,
		ModuleCallingContext const *	mcc
	)		const

protected

Definition at line 208 of file OutputModule.cc.

References edm::convert_handle(), edm::PrincipalGetAdapter::getByToken_(), moduleDescription_, edm::PRODUCT_TYPE, query::result, and edm::PrincipalGetAdapter::setConsumer().

                                                                                                                                                 {
     //This cast is safe since we only call const functions of the EventPrincipal after this point
     PrincipalGetAdapter adapter(const_cast<EventPrincipal&>(ep), moduleDescription_);
     adapter.setConsumer(this);
     Trig result;
     auto bh = adapter.getByToken_(TypeID(typeid(TriggerResults)),PRODUCT_TYPE, token, mcc);
     convert_handle(std::move(bh), result);
     return result;
   }

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

inline

Definition at line 78 of file OutputModule.h.

References hasNewlyDroppedBranch_.

78 {return hasNewlyDroppedBranch_;}

edm::OutputModule::hasNewlyDroppedBranch_

std::array< bool, NumBranchTypes > hasNewlyDroppedBranch_

Definition: OutputModule.h:153

virtual bool edm::OutputModule::isFileOpen ( ) const

inlineprivatevirtual

Definition at line 233 of file OutputModule.h.

Referenced by doCloseFile(), and maybeOpenFile().

233 { return true; }

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

private

Definition at line 132 of file OutputModule.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::OutputModule::keptProducts ( ) const

inline

Definition at line 77 of file OutputModule.h.

References keptProducts_.

77 {return keptProducts_;}

edm::OutputModule::keptProducts_

SelectedProductsForBranchType keptProducts_

Definition: OutputModule.h:152

bool edm::OutputModule::limitReached ( ) const

inlineprivate

Definition at line 248 of file OutputModule.h.

References remainingEvents_.

248 {return remainingEvents_ == 0;}

edm::OutputModule::remainingEvents_

std::atomic< int > remainingEvents_

Definition: OutputModule.h:135

int edm::OutputModule::maxEvents ( ) const

inline

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

Definition at line 67 of file OutputModule.h.

References maxEvents_.

67 {return maxEvents_;}

edm::OutputModule::maxEvents_

int maxEvents_

Definition: OutputModule.h:134

void edm::OutputModule::maybeOpenFile ( )

private

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

Definition at line 337 of file OutputModule.cc.

References isFileOpen(), and reallyOpenFile().

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

ModuleDescription const& edm::OutputModule::moduleDescription ( ) const

inlineprotected

Definition at line 102 of file OutputModule.h.

References moduleDescription_.

102 { return moduleDescription_;

103 }

edm::OutputModule::moduleDescription_

ModuleDescription moduleDescription_

Definition: OutputModule.h:158

virtual void edm::OutputModule::openFile ( FileBlock const & )

inlineprivatevirtual

Definition at line 227 of file OutputModule.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().

227 {}

OutputModule& edm::OutputModule::operator= ( OutputModule const & )

delete

virtual void edm::OutputModule::postForkReacquireResources	(	unsigned	int,
		unsigned	int
	)

inlineprivatevirtual

Definition at line 231 of file OutputModule.h.

Referenced by doPostForkReacquireResources().

231 {}

virtual void edm::OutputModule::preForkReleaseResources ( )

inlineprivatevirtual

Definition at line 230 of file OutputModule.h.

Referenced by doPreForkReleaseResources().

230 {}

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

private

Definition at line 218 of file OutputModule.cc.

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

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

void edm::OutputModule::prevalidate ( ConfigurationDescriptions & )

static

Definition at line 402 of file OutputModule.cc.

402 {

403 }

std::string const& edm::OutputModule::processName ( ) const

inline

Definition at line 76 of file OutputModule.h.

References process_name_.

Referenced by edm::StreamerOutputModuleBase::serializeRegistry().

76 {return process_name_;}

edm::OutputModule::process_name_

std::string process_name_

Definition: OutputModule.h:155

void edm::OutputModule::reallyCloseFile ( )

privatevirtual

Definition at line 350 of file OutputModule.cc.

Referenced by doCloseFile().

350 {

351 }

virtual void edm::OutputModule::reallyOpenFile ( )

inlineprivatevirtual

Definition at line 235 of file OutputModule.h.

Referenced by maybeOpenFile().

235 {}

void edm::OutputModule::registerProductsAndCallbacks	(	OutputModule const *	,
		ProductRegistry const *
	)

inlineprivate

Definition at line 211 of file OutputModule.h.

211 {}

int edm::OutputModule::remainingEvents ( ) const

inline

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

Definition at line 71 of file OutputModule.h.

References remainingEvents_.

71 {return remainingEvents_;}

edm::OutputModule::remainingEvents_

std::atomic< int > remainingEvents_

Definition: OutputModule.h:135

virtual void edm::OutputModule::respondToCloseInputFile ( FileBlock const & )

inlineprivatevirtual

Definition at line 229 of file OutputModule.h.

Referenced by doRespondToCloseInputFile().

229 {}

virtual void edm::OutputModule::respondToOpenInputFile ( FileBlock const & )

inlineprivatevirtual

Definition at line 228 of file OutputModule.h.

Referenced by doRespondToOpenInputFile().

228 {}

bool edm::OutputModule::selected ( BranchDescription const & desc ) const

Definition at line 384 of file OutputModule.cc.

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

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

                                                             {
     return productSelector_.selected(desc);
   }

ParameterSetID edm::OutputModule::selectorConfig ( ) const

inlineprotected

Definition at line 105 of file OutputModule.h.

References selector_config_id_.

105 { return selector_config_id_; }

edm::OutputModule::selector_config_id_

ParameterSetID selector_config_id_

Definition: OutputModule.h:165

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

Definition at line 83 of file OutputModule.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 edm::OutputModule::setEventSelectionInfo	(	std::map< std::string, std::vector< std::pair< std::string, int > > > const &	outputModulePathPositions,
		bool	anyProductProduced
	)

protected

Definition at line 413 of file OutputModule.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::OutputModule::setModuleDescription ( ModuleDescription const & md )

inlineprivate

Definition at line 241 of file OutputModule.h.

References popcon2dropbox_job_conf::md, and moduleDescription_.

                                                            {
       moduleDescription_ = md;
     }

virtual bool edm::OutputModule::shouldWeCloseFile ( ) const

inlineprivatevirtual

Ask the OutputModule if we should end the current file.

Definition at line 216 of file OutputModule.h.

216 {return false;}

ThinnedAssociationsHelper const * edm::OutputModule::thinnedAssociationsHelper ( ) const

Definition at line 374 of file OutputModule.cc.

References thinnedAssociationsHelper_.

                                                 {
     return thinnedAssociationsHelper_.get();
   }

void edm::OutputModule::updateBranchParents ( EventPrincipal const & ep )

private

Definition at line 422 of file OutputModule.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);
       }
     }
   }