#include <OutputModule.h>

Inheritance diagram for edm::OutputModule:

Public Types
typedef OutputModule	ModuleType

typedef OutputWorker	WorkerType

Public Member Functions
BranchChildren const &	branchChildren () const

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

SelectionsArray const &	keptProducts () const

int	maxEvents () const

	OutputModule (ParameterSet const &pset)

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

void	selectProducts ()

bool	wantAllEvents () const

virtual	~OutputModule ()

Static Public Member Functions
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Protected Member Functions
CurrentProcessingContext const *	currentContext () const

ModuleDescription const &	description () const

void	doBeginJob ()

bool	doBeginLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, CurrentProcessingContext const *cpc)

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

void	doEndJob ()

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

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

bool	doEvent (EventPrincipal const &ep, EventSetup const &c, CurrentProcessingContext const *cpc)

Trig	getTriggerResults (Event const &ep) const

Trig	getTriggerResults (EventPrincipal const &ep) const

ParameterSetID	selectorConfig () const

Private Types
typedef std::map< BranchID, std::set< ParentageID > >	BranchParents

Private Member Functions
virtual void	beginJob ()

virtual void	beginLuminosityBlock (LuminosityBlockPrincipal const &lb)

virtual void	beginRun (RunPrincipal const &r)

void	configure (OutputModuleDescription const &desc)

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

void	doOpenFile (FileBlock const &fb)

virtual void	doOpenFile ()

void	doPostForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren)

void	doPreForkReleaseResources ()

void	doRespondToCloseInputFile (FileBlock const &fb)

void	doRespondToCloseOutputFiles (FileBlock const &fb)

void	doRespondToOpenInputFile (FileBlock const &fb)

void	doRespondToOpenOutputFiles (FileBlock const &fb)

void	doWriteLuminosityBlock (LuminosityBlockPrincipal const &lbp)

void	doWriteRun (RunPrincipal const &rp)

virtual void	endJob ()

virtual void	endLuminosityBlock (LuminosityBlockPrincipal const &lb)

virtual void	endRun (RunPrincipal const &r)

void	fillDependencyGraph ()

virtual void	finishEndFile ()

virtual bool	isFileOpen () const

bool	limitReached () const

void	maybeOpenFile ()

virtual void	openFile (FileBlock const &fb)

virtual void	postForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren)

virtual void	preForkReleaseResources ()

void	reallyCloseFile ()

void	registerAnyProducts (OutputModule const , ProductRegistry const )

virtual void	respondToCloseInputFile (FileBlock const &fb)

virtual void	respondToCloseOutputFiles (FileBlock const &fb)

virtual void	respondToOpenInputFile (FileBlock const &fb)

virtual void	respondToOpenOutputFiles (FileBlock const &fb)

void	setModuleDescription (ModuleDescription const &md)

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

virtual void	startEndFile ()

void	updateBranchParents (EventPrincipal const &ep)

std::string	workerType () const

virtual void	write (EventPrincipal const &e)=0

virtual void	writeBranchIDListRegistry ()

virtual void	writeBranchMapper ()

virtual void	writeFileFormatVersion ()

virtual void	writeFileIdentifier ()

virtual void	writeIndexIntoFile ()

virtual void	writeLuminosityBlock (LuminosityBlockPrincipal const &lb)=0

virtual void	writeParameterSetRegistry ()

virtual void	writeParentageRegistry ()

virtual void	writeProcessConfigurationRegistry ()

virtual void	writeProcessHistoryRegistry ()

virtual void	writeProductDependencies ()

virtual void	writeProductDescriptionRegistry ()

virtual void	writeRun (RunPrincipal const &r)=0

Private Attributes
BranchChildren	branchChildren_

BranchParents	branchParents_

CurrentProcessingContext const *	current_context_

GroupSelector	groupSelector_

GroupSelectorRules	groupSelectorRules_

boost::array< bool, NumBranchTypes >	hasNewlyDroppedBranch_

SelectionsArray	keptProducts_

int	maxEvents_

ModuleDescription	moduleDescription_

std::string	process_name_

bool	prodsValid_

int	remainingEvents_

ParameterSetID	selector_config_id_

detail::CachedProducts	selectors_

bool	wantAllEvents_

Friends
class	OutputWorker

template<typename T >
class	WorkerT

Detailed Description

Definition at line 35 of file OutputModule.h.

Member Typedef Documentation

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

private

Definition at line 139 of file OutputModule.h.

typedef OutputModule edm::OutputModule::ModuleType

Definition at line 39 of file OutputModule.h.

typedef OutputWorker edm::OutputModule::WorkerType

Definition at line 40 of file OutputModule.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 113 of file OutputModule.cc.

References edm::ParameterSet::empty(), edm::getAllTriggerNames(), edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameterSet(), hasNewlyDroppedBranch_, i, edm::ParameterSet::id(), process_name_, edm::ParameterSet::registerIt(), selector_config_id_, selectors_, edm::detail::CachedProducts::setup(), edm::detail::CachedProducts::setupDefault(), and wantAllEvents_.

                                                      : 
     maxEvents_(-1),
     remainingEvents_(maxEvents_),
     keptProducts_(),
     hasNewlyDroppedBranch_(),
     process_name_(),
     groupSelectorRules_(pset, "outputCommands", "OutputModule"),
     groupSelector_(),
     moduleDescription_(),
     current_context_(0),
     prodsValid_(false),
     wantAllEvents_(false),
     selectors_(),
     selector_config_id_(),
     branchParents_(),
     branchChildren_() {
 
     hasNewlyDroppedBranch_.assign(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();
     // If selectevents is an emtpy ParameterSet, then we are to write
     // all events, or one which contains a vstrig 'SelectEvents' that
     // is empty, we are to write all events. We have no need for any
     // EventSelectors.
     if (selectevents.empty()) {
         wantAllEvents_ = true;
         selectors_.setupDefault(getAllTriggerNames());
         return;
     }
 
     std::vector<std::string> path_specs = 
       selectevents.getParameter<std::vector<std::string> >("SelectEvents");
 
     if (path_specs.empty()) {
         wantAllEvents_ = true;
         selectors_.setupDefault(getAllTriggerNames());
         return;
     }
 
     // If we get here, we have the possibility of having to deal with
     // path_specs that look at more than one process.
     std::vector<parsed_path_spec_t> parsed_paths(path_specs.size());
     for (size_t i = 0; i < path_specs.size(); ++i) {
       parse_path_spec(path_specs[i], parsed_paths[i]);
     }
     selectors_.setup(parsed_paths, getAllTriggerNames(), process_name_);
   }

edm::OutputModule::~OutputModule ( )

virtual

Definition at line 205 of file OutputModule.cc.

205 { }

Member Function Documentation

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

static

Definition at line 427 of file OutputModule.cc.

References edm::kBaseType().

                          {
     return kBaseType;
   }

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

inlineprivatevirtual

Reimplemented in edm::SubProcess, and edm::StreamerOutputModuleBase.

Definition at line 178 of file OutputModule.h.

Referenced by doBeginJob().

178 {}

virtual void edm::OutputModule::beginLuminosityBlock ( LuminosityBlockPrincipal const & lb )

inlineprivatevirtual

Reimplemented in edm::SubProcess.

Definition at line 183 of file OutputModule.h.

Referenced by doBeginLuminosityBlock().

183 {}

virtual void edm::OutputModule::beginRun ( RunPrincipal const & r )

inlineprivatevirtual

Reimplemented in edm::SubProcess, DQMRootOutputModule, FRDEventOutputModule< Consumer >, and edm::StreamerOutputModuleBase.

Definition at line 180 of file OutputModule.h.

Referenced by doBeginRun().

180 {}

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

inline

Definition at line 63 of file OutputModule.h.

References branchChildren_.

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

63 {return branchChildren_;}

edm::OutputModule::branchChildren_

BranchChildren branchChildren_

Definition: OutputModule.h:142

void edm::OutputModule::configure ( OutputModuleDescription const & desc )

private

Definition at line 169 of file OutputModule.cc.

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

Referenced by edm::OutputWorker::configure().

                                                                   {
     remainingEvents_ = maxEvents_ = desc.maxEvents_;
   }

CurrentProcessingContext const * edm::OutputModule::currentContext ( ) const

protected

Definition at line 398 of file OutputModule.cc.

References current_context_.

                                      {
     return current_context_;
   }

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

protected

Definition at line 403 of file OutputModule.cc.

References moduleDescription_.

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

                                   {
     return moduleDescription_;
   }

void edm::OutputModule::doBeginJob ( )

protected

Definition at line 207 of file OutputModule.cc.

References beginJob(), and selectProducts().

                                 {
     selectProducts();
     this->beginJob();
   }

bool edm::OutputModule::doBeginLuminosityBlock	(	LuminosityBlockPrincipal const &	lbp,
		EventSetup const &	c,
		CurrentProcessingContext const *	cpc
	)

protected

Definition at line 316 of file OutputModule.cc.

References beginLuminosityBlock(), current_context_, and FDEBUG.

                                                                                  {
     detail::CPCSentry sentry(current_context_, cpc);
     FDEBUG(2) << "beginLuminosityBlock called\n";
     beginLuminosityBlock(lbp);
     return true;
   }

bool edm::OutputModule::doBeginRun	(	RunPrincipal const &	rp,
		EventSetup const &	c,
		CurrentProcessingContext const *	cpc
	)

protected

Definition at line 290 of file OutputModule.cc.

References beginRun(), current_context_, and FDEBUG.

                                                                      {
     detail::CPCSentry sentry(current_context_, cpc);
     FDEBUG(2) << "beginRun called\n";
     beginRun(rp);
     return true;
   }

void edm::OutputModule::doCloseFile ( )

private

Tell the OutputModule that is must end the current file.

Definition at line 374 of file OutputModule.cc.

References isFileOpen(), and reallyCloseFile().

Referenced by edm::OutputWorker::closeFile().

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

void edm::OutputModule::doEndJob ( )

protected

Definition at line 212 of file OutputModule.cc.

References endJob().

Referenced by edm::EventProcessor::endJob().

                               {
     endJob();
   }

bool edm::OutputModule::doEndLuminosityBlock	(	LuminosityBlockPrincipal const &	lbp,
		EventSetup const &	c,
		CurrentProcessingContext const *	cpc
	)

protected

Definition at line 326 of file OutputModule.cc.

References current_context_, endLuminosityBlock(), and FDEBUG.

                                                                                {
     detail::CPCSentry sentry(current_context_, cpc);
     FDEBUG(2) << "endLuminosityBlock called\n";
     endLuminosityBlock(lbp);
     return true;
   }

bool edm::OutputModule::doEndRun	(	RunPrincipal const &	rp,
		EventSetup const &	c,
		CurrentProcessingContext const *	cpc
	)

protected

Definition at line 300 of file OutputModule.cc.

References current_context_, endRun(), and FDEBUG.

                                                                    {
     detail::CPCSentry sentry(current_context_, cpc);
     FDEBUG(2) << "endRun called\n";
     endRun(rp);
     return true;
   }

bool edm::OutputModule::doEvent	(	EventPrincipal const &	ep,
		EventSetup const &	c,
		CurrentProcessingContext const *	cpc
	)

protected

Definition at line 249 of file OutputModule.cc.

References current_context_, FDEBUG, moduleDescription_, prodsValid_, remainingEvents_, selectors_, updateBranchParents(), wantAllEvents_, edm::detail::CachedProducts::wantEvent(), and write().

                                                              {
     detail::CPCSentry sentry(current_context_, cpc);
     PVSentry          products_sentry(selectors_, prodsValid_);
 
     FDEBUG(2) << "writeEvent called\n";
 
     if (!wantAllEvents_) {
       // use module description and const_cast unless interface to
       // event is changed to just take a const EventPrincipal
       Event e(const_cast<EventPrincipal&>(ep), moduleDescription_);
       if (!selectors_.wantEvent(e)) {
         return true;
       }
     }
     write(ep);
     updateBranchParents(ep);
     if (remainingEvents_ > 0) {
       --remainingEvents_;
     }
     return true;
   }

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

private

Definition at line 340 of file OutputModule.cc.

References openFile().

Referenced by edm::OutputWorker::openFile().

                                                    {
     openFile(fb);
   }

virtual void edm::OutputModule::doOpenFile ( )

inlineprivatevirtual

Reimplemented in edm::PoolOutputModule.

Definition at line 196 of file OutputModule.h.

Referenced by maybeOpenFile().

196 { }

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

private

Definition at line 366 of file OutputModule.cc.

References postForkReacquireResources().

                                                                                                      {
     postForkReacquireResources(iChildIndex, iNumberOfChildren);
   }

void edm::OutputModule::doPreForkReleaseResources ( )

private

Definition at line 361 of file OutputModule.cc.

References preForkReleaseResources().

                                           {
     preForkReleaseResources();
   }

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

private

Definition at line 348 of file OutputModule.cc.

References respondToCloseInputFile().

                                                                   {
     respondToCloseInputFile(fb);
   }

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

private

Definition at line 356 of file OutputModule.cc.

References respondToCloseOutputFiles().

                                                                     {
     respondToCloseOutputFiles(fb);
   }

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

private

Definition at line 344 of file OutputModule.cc.

References respondToOpenInputFile().

                                                                  {
     respondToOpenInputFile(fb);
   }

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

private

Definition at line 352 of file OutputModule.cc.

References respondToOpenOutputFiles().

                                                                    {
     respondToOpenOutputFiles(fb);
   }

void edm::OutputModule::doWriteLuminosityBlock ( LuminosityBlockPrincipal const & lbp )

private

Definition at line 335 of file OutputModule.cc.

References FDEBUG, and writeLuminosityBlock().

Referenced by edm::OutputWorker::writeLumi().

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

void edm::OutputModule::doWriteRun ( RunPrincipal const & rp )

private

Definition at line 310 of file OutputModule.cc.

References FDEBUG, and writeRun().

Referenced by edm::OutputWorker::writeRun().

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

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

inlineprivatevirtual

Reimplemented in edm::SubProcess, and edm::StreamerOutputModuleBase.

Definition at line 179 of file OutputModule.h.

Referenced by doEndJob().

179 {}

virtual void edm::OutputModule::endLuminosityBlock ( LuminosityBlockPrincipal const & lb )

inlineprivatevirtual

Reimplemented in edm::SubProcess.

Definition at line 184 of file OutputModule.h.

Referenced by doEndLuminosityBlock().

184 {}

virtual void edm::OutputModule::endRun ( RunPrincipal const & r )

inlineprivatevirtual

Reimplemented in edm::SubProcess, FRDEventOutputModule< Consumer >, and edm::StreamerOutputModuleBase.

Definition at line 181 of file OutputModule.h.

Referenced by doEndRun().

181 {}

void edm::OutputModule::fillDependencyGraph ( )

private

Definition at line 447 of file OutputModule.cc.

References branchChildren_, branchParents_, edm::detail::ThreadSafeRegistry< KEY, T, E >::getMapped(), i, edm::BranchChildren::insertChild(), edm::detail::ThreadSafeRegistry< KEY, T, E >::instance(), j, parents, and edm::Parentage::parents().

Referenced by reallyCloseFile().

                                     {
     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 420 of file OutputModule.cc.

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

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

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

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

static

Definition at line 413 of file OutputModule.cc.

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

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

virtual void edm::OutputModule::finishEndFile ( )

inlineprivatevirtual

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 222 of file OutputModule.h.

Referenced by reallyCloseFile().

222 {}

Trig edm::OutputModule::getTriggerResults ( Event const & ep ) const

protected

Definition at line 217 of file OutputModule.cc.

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

Referenced by getTriggerResults(), and edm::StreamerOutputModuleBase::setHltMask().

                                                             {
     return selectors_.getOneTriggerResults(ev);
   }

Trig edm::OutputModule::getTriggerResults ( EventPrincipal const & ep ) const

protected

Definition at line 221 of file OutputModule.cc.

References current_context_, getTriggerResults(), and edm::CurrentProcessingContext::moduleDescription().

                                                                      {
     // This is bad, because we're returning handles into an Event that
     // is destructed before the return. It might not fail, because the
     // actual EventPrincipal is not destroyed, but it still needs to
     // be cleaned up.
     Event ev(const_cast<EventPrincipal&>(ep), 
              *current_context_->moduleDescription());
     return getTriggerResults(ev);
   }

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

inline

Definition at line 57 of file OutputModule.h.

References hasNewlyDroppedBranch_.

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

57 {return hasNewlyDroppedBranch_;}

edm::OutputModule::hasNewlyDroppedBranch_

boost::array< bool, NumBranchTypes > hasNewlyDroppedBranch_

Definition: OutputModule.h:119

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

inlineprivatevirtual

Reimplemented in edm::PoolOutputModule.

Definition at line 194 of file OutputModule.h.

Referenced by doCloseFile(), and maybeOpenFile().

194 { return true; }

SelectionsArray const& edm::OutputModule::keptProducts ( ) const

inline

Definition at line 56 of file OutputModule.h.

References keptProducts_.

Referenced by edm::SubProcess::beginJob(), edm::PoolOutputModule::fillSelectedItemList(), edm::RootOutputFile::finishEndFile(), edm::SubProcess::propagateProducts(), and edm::XMLOutputModule::write().

56 {return keptProducts_;}

edm::OutputModule::keptProducts_

SelectionsArray keptProducts_

Definition: OutputModule.h:118

bool edm::OutputModule::limitReached ( ) const

inlineprivate

Definition at line 205 of file OutputModule.h.

References remainingEvents_.

Referenced by edm::OutputWorker::limitReached().

205 {return remainingEvents_ == 0;}

edm::OutputModule::remainingEvents_

int remainingEvents_

Definition: OutputModule.h:101

int edm::OutputModule::maxEvents ( ) const

inline

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

Definition at line 46 of file OutputModule.h.

References maxEvents_.

Referenced by edm::SubProcess::SubProcess().

46 {return maxEvents_;}

edm::OutputModule::maxEvents_

int maxEvents_

Definition: OutputModule.h:100

void edm::OutputModule::maybeOpenFile ( )

private

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

Definition at line 370 of file OutputModule.cc.

References doOpenFile(), and isFileOpen().

Referenced by edm::OutputWorker::openNewFileIfNeeded().

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

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

inlineprivatevirtual

Reimplemented in edm::PoolOutputModule.

Definition at line 186 of file OutputModule.h.

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

186 {}

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

inlineprivatevirtual

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

Definition at line 192 of file OutputModule.h.

Referenced by doPostForkReacquireResources().

192 {}

virtual void edm::OutputModule::preForkReleaseResources ( )

inlineprivatevirtual

Reimplemented in edm::SubProcess.

Definition at line 191 of file OutputModule.h.

Referenced by doPreForkReleaseResources().

191 {}

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

inline

Definition at line 55 of file OutputModule.h.

References process_name_.

Referenced by edm::StreamerOutputModuleBase::serializeRegistry(), and DQMRootOutputModule::startEndFile().

55 {return process_name_;}

edm::OutputModule::process_name_

std::string process_name_

Definition: OutputModule.h:121

void edm::OutputModule::reallyCloseFile ( )

private

Definition at line 378 of file OutputModule.cc.

References branchChildren_, branchParents_, edm::BranchChildren::clear(), fillDependencyGraph(), finishEndFile(), startEndFile(), writeBranchIDListRegistry(), writeBranchMapper(), writeFileFormatVersion(), writeFileIdentifier(), writeIndexIntoFile(), writeParameterSetRegistry(), writeParentageRegistry(), writeProcessConfigurationRegistry(), writeProcessHistoryRegistry(), writeProductDependencies(), and writeProductDescriptionRegistry().

Referenced by doCloseFile().

                                      {
     fillDependencyGraph();
     startEndFile();
     writeFileFormatVersion();
     writeFileIdentifier();
     writeIndexIntoFile();
     writeProcessConfigurationRegistry();
     writeProcessHistoryRegistry();
     writeParameterSetRegistry();
     writeProductDescriptionRegistry();
     writeParentageRegistry();
     writeBranchIDListRegistry();
     writeProductDependencies();
     writeBranchMapper();
     finishEndFile();
     branchParents_.clear();
     branchChildren_.clear();
   }

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

inlineprivate

Definition at line 172 of file OutputModule.h.

172 {}

int edm::OutputModule::remainingEvents ( ) const

inline

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

Definition at line 50 of file OutputModule.h.

References remainingEvents_.

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

50 {return remainingEvents_;}

edm::OutputModule::remainingEvents_

int remainingEvents_

Definition: OutputModule.h:101

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

inlineprivatevirtual

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

Definition at line 188 of file OutputModule.h.

Referenced by doRespondToCloseInputFile().

188 {}

virtual void edm::OutputModule::respondToCloseOutputFiles ( FileBlock const & fb )

inlineprivatevirtual

Reimplemented in edm::SubProcess.

Definition at line 190 of file OutputModule.h.

Referenced by doRespondToCloseOutputFiles().

190 {}

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

inlineprivatevirtual

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

Definition at line 187 of file OutputModule.h.

Referenced by doRespondToOpenInputFile().

187 {}

virtual void edm::OutputModule::respondToOpenOutputFiles ( FileBlock const & fb )

inlineprivatevirtual

Reimplemented in edm::SubProcess.

Definition at line 189 of file OutputModule.h.

Referenced by doRespondToOpenOutputFiles().

189 {}

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

Definition at line 408 of file OutputModule.cc.

References groupSelector_, and edm::GroupSelector::selected().

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

                                                             {
     return groupSelector_.selected(desc);
   }

ParameterSetID edm::OutputModule::selectorConfig ( ) const

inlineprotected

Definition at line 83 of file OutputModule.h.

References selector_config_id_.

Referenced by edm::StreamerOutputModuleBase::serializeEvent(), and edm::RootOutputFile::writeOne().

83 { return selector_config_id_; }

edm::OutputModule::selector_config_id_

ParameterSetID selector_config_id_

Definition: OutputModule.h:137

void edm::OutputModule::selectProducts ( )

Definition at line 173 of file OutputModule.cc.

References edm::BranchDescription::branchType(), end, edm::getAllBranchDescriptions(), groupSelector_, groupSelectorRules_, hasNewlyDroppedBranch_, edm::GroupSelector::initialize(), edm::GroupSelector::initialized(), keptProducts_, edm::BranchDescription::present(), edm::BranchDescription::produced(), selected(), and edm::BranchDescription::transient().

Referenced by doBeginJob().

                                     {
     if (groupSelector_.initialized()) return;
     groupSelector_.initialize(groupSelectorRules_, getAllBranchDescriptions());
     Service<ConstProductRegistry> reg;
 
     // TODO: See if we can collapse keptProducts_ and groupSelector_ into a
     // single object. See the notes in the header for GroupSelector
     // for more information.
 
     ProductRegistry::ProductList::const_iterator it  = 
       reg->productList().begin();
     ProductRegistry::ProductList::const_iterator end = 
       reg->productList().end();
 
     for (; it != end; ++it) {
       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
         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;
       }
     }
   }

void edm::OutputModule::setModuleDescription ( ModuleDescription const & md )

inlineprivate

Definition at line 198 of file OutputModule.h.

References moduleDescription_.

                                                            {
       moduleDescription_ = md;
     }

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

inlineprivatevirtual

Ask the OutputModule if we should end the current file.

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

Definition at line 175 of file OutputModule.h.

Referenced by edm::OutputWorker::shouldWeCloseFile().

175 {return false;}

virtual void edm::OutputModule::startEndFile ( )

inlineprivatevirtual

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 210 of file OutputModule.h.

Referenced by reallyCloseFile().

210 {}

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

private

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