#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)
static void	prevalidate (ConfigurationDescriptions &)
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
void	setEventSelectionInfo (std::map< std::string, std::vector< std::pair< std::string, int > > > const &outputModulePathPositions, bool anyProductProduced)
Private Types
typedef std::map< BranchID, std::set< ParentageID > >	BranchParents
Private Member Functions
virtual void	beginJob ()
virtual void	beginLuminosityBlock (LuminosityBlockPrincipal const &)
virtual void	beginRun (RunPrincipal const &)
void	configure (OutputModuleDescription const &desc)
void	doCloseFile ()
	Tell the OutputModule that is must end the current file.
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 &)
virtual void	endRun (RunPrincipal const &)
void	fillDependencyGraph ()
virtual void	finishEndFile ()
virtual bool	isFileOpen () const
bool	limitReached () const
void	maybeOpenFile ()
virtual void	openFile (FileBlock const &)
virtual void	postForkReacquireResources (unsigned int, unsigned int)
virtual void	preForkReleaseResources ()
void	reallyCloseFile ()
void	registerAnyProducts (OutputModule const , ProductRegistry const )
virtual void	respondToCloseInputFile (FileBlock const &)
virtual void	respondToCloseOutputFiles (FileBlock const &)
virtual void	respondToOpenInputFile (FileBlock const &)
virtual void	respondToOpenOutputFiles (FileBlock const &)
void	setModuleDescription (ModuleDescription const &md)
virtual bool	shouldWeCloseFile () const
	Ask the OutputModule if we should end the current file.
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 &)=0
virtual void	writeParameterSetRegistry ()
virtual void	writeParentageRegistry ()
virtual void	writeProcessConfigurationRegistry ()
virtual void	writeProcessHistoryRegistry ()
virtual void	writeProductDependencies ()
virtual void	writeProductDescriptionRegistry ()
virtual void	writeRun (RunPrincipal const &)=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
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 145 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 114 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 206 of file OutputModule.cc.

{ }

Member Function Documentation

const std::string & edm::OutputModule::baseType ( ) [static]

Definition at line 433 of file OutputModule.cc.

References edm::kBaseType().

                         {
    return kBaseType;
  }

virtual void edm::OutputModule::beginJob ( void ) [inline, private, virtual]

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

Definition at line 184 of file OutputModule.h.

Referenced by doBeginJob().

{}

virtual void edm::OutputModule::beginLuminosityBlock ( LuminosityBlockPrincipal const & ) [inline, private, virtual]

Reimplemented in edm::SubProcess.

Definition at line 189 of file OutputModule.h.

Referenced by doBeginLuminosityBlock().

{}

virtual void edm::OutputModule::beginRun ( RunPrincipal const & ) [inline, private, virtual]

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

Definition at line 186 of file OutputModule.h.

Referenced by doBeginRun().

{}

BranchChildren const& edm::OutputModule::branchChildren ( ) const [inline]

Definition at line 66 of file OutputModule.h.

References branchChildren_.

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

{return branchChildren_;}

void edm::OutputModule::configure ( OutputModuleDescription const & desc ) [private]

Definition at line 170 of file OutputModule.cc.

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

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

                                                                  {
    remainingEvents_ = maxEvents_ = desc.maxEvents_;
  }

CurrentProcessingContext const * edm::OutputModule::currentContext ( ) const [protected]

Definition at line 399 of file OutputModule.cc.

References current_context_.

                                     {
    return current_context_;
  }

ModuleDescription const & edm::OutputModule::description ( ) const [protected]

Definition at line 404 of file OutputModule.cc.

References moduleDescription_.

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

                                  {
    return moduleDescription_;
  }

void edm::OutputModule::doBeginJob ( ) [protected]

Definition at line 208 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 317 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 291 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 375 of file OutputModule.cc.

References isFileOpen(), and reallyCloseFile().

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

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

void edm::OutputModule::doEndJob ( ) [protected]

Definition at line 213 of file OutputModule.cc.

References endJob().

                              {
    endJob();
  }

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

Definition at line 327 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 301 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 250 of file OutputModule.cc.

References current_context_, alignCSCRings::e, 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 341 of file OutputModule.cc.

References openFile().

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

                                                   {
    openFile(fb);
  }

virtual void edm::OutputModule::doOpenFile ( ) [inline, private, virtual]

Reimplemented in edm::PoolOutputModule.

Definition at line 202 of file OutputModule.h.

Referenced by maybeOpenFile().

{ }

void edm::OutputModule::doPostForkReacquireResources	(	unsigned int	iChildIndex,
		unsigned int	iNumberOfChildren
	)		`[private]`

Definition at line 367 of file OutputModule.cc.

References postForkReacquireResources().

                                                                                                     {
    postForkReacquireResources(iChildIndex, iNumberOfChildren);
  }

void edm::OutputModule::doPreForkReleaseResources ( ) [private]

Definition at line 362 of file OutputModule.cc.

References preForkReleaseResources().

                                          {
    preForkReleaseResources();
  }

void edm::OutputModule::doRespondToCloseInputFile ( FileBlock const & fb ) [private]

Definition at line 349 of file OutputModule.cc.

References respondToCloseInputFile().

                                                                  {
    respondToCloseInputFile(fb);
  }

void edm::OutputModule::doRespondToCloseOutputFiles ( FileBlock const & fb ) [private]

Definition at line 357 of file OutputModule.cc.

References respondToCloseOutputFiles().

                                                                    {
    respondToCloseOutputFiles(fb);
  }

void edm::OutputModule::doRespondToOpenInputFile ( FileBlock const & fb ) [private]

Definition at line 345 of file OutputModule.cc.

References respondToOpenInputFile().

                                                                 {
    respondToOpenInputFile(fb);
  }

void edm::OutputModule::doRespondToOpenOutputFiles ( FileBlock const & fb ) [private]

Definition at line 353 of file OutputModule.cc.

References respondToOpenOutputFiles().

                                                                   {
    respondToOpenOutputFiles(fb);
  }

void edm::OutputModule::doWriteLuminosityBlock ( LuminosityBlockPrincipal const & lbp ) [private]

Definition at line 336 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 311 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 ) [inline, private, virtual]

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

Definition at line 185 of file OutputModule.h.

Referenced by doEndJob().

{}

virtual void edm::OutputModule::endLuminosityBlock ( LuminosityBlockPrincipal const & ) [inline, private, virtual]

Reimplemented in edm::SubProcess.

Definition at line 190 of file OutputModule.h.

Referenced by doEndLuminosityBlock().

{}

virtual void edm::OutputModule::endRun ( RunPrincipal const & ) [inline, private, virtual]

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

Definition at line 187 of file OutputModule.h.

Referenced by doEndRun().

{}

void edm::OutputModule::fillDependencyGraph ( ) [private]

Definition at line 485 of file OutputModule.cc.

References branchChildren_, branchParents_, i, edm::BranchChildren::insertChild(), 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]

Reimplemented in edm::StreamerOutputModuleBase.

Definition at line 421 of file OutputModule.cc.

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

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

void edm::OutputModule::fillDescriptions ( ConfigurationDescriptions & descriptions ) [static]

Reimplemented in DQMRootOutputModule, edm::AsciiOutputModule, edm::GetProductCheckerOutputModule, edm::ProvenanceCheckerOutputModule, edm::XMLOutputModule, edm::PoolOutputModule, and edm::StreamerOutputModule< Consumer >.

Definition at line 414 of file OutputModule.cc.

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

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

virtual void edm::OutputModule::finishEndFile ( ) [inline, private, virtual]

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 228 of file OutputModule.h.

Referenced by reallyCloseFile().

{}

Trig edm::OutputModule::getTriggerResults ( Event const & ep ) const [protected]

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

{return hasNewlyDroppedBranch_;}

virtual bool edm::OutputModule::isFileOpen ( ) const [inline, private, virtual]

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 200 of file OutputModule.h.

Referenced by doCloseFile(), and maybeOpenFile().

{ return true; }

SelectionsArray const& edm::OutputModule::keptProducts ( ) const [inline]

Definition at line 56 of file OutputModule.h.

References keptProducts_.

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

{return keptProducts_;}

bool edm::OutputModule::limitReached ( ) const [inline, private]

Definition at line 211 of file OutputModule.h.

References remainingEvents_.

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

{return remainingEvents_ == 0;}

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

{return maxEvents_;}

void edm::OutputModule::maybeOpenFile ( ) [private]

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

Definition at line 371 of file OutputModule.cc.

References doOpenFile(), and isFileOpen().

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

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

virtual void edm::OutputModule::openFile ( FileBlock const & ) [inline, private, virtual]

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 192 of file OutputModule.h.

Referenced by doOpenFile().

{}

virtual void edm::OutputModule::postForkReacquireResources	(	unsigned int	,
		unsigned int
	)		`[inline, private, virtual]`

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

Definition at line 198 of file OutputModule.h.

Referenced by doPostForkReacquireResources().

{}

virtual void edm::OutputModule::preForkReleaseResources ( ) [inline, private, virtual]

Reimplemented in edm::SubProcess.

Definition at line 197 of file OutputModule.h.

Referenced by doPreForkReleaseResources().

{}

void edm::OutputModule::prevalidate ( ConfigurationDescriptions & ) [static]

Definition at line 427 of file OutputModule.cc.

                                                       {
  }

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

{return process_name_;}

void edm::OutputModule::reallyCloseFile ( ) [private]

Definition at line 379 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 *
	)		`[inline, private]`

Definition at line 178 of file OutputModule.h.

{}

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

{return remainingEvents_;}

virtual void edm::OutputModule::respondToCloseInputFile ( FileBlock const & ) [inline, private, virtual]

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

Definition at line 194 of file OutputModule.h.

Referenced by doRespondToCloseInputFile().

{}

virtual void edm::OutputModule::respondToCloseOutputFiles ( FileBlock const & ) [inline, private, virtual]

Reimplemented in edm::SubProcess.

Definition at line 196 of file OutputModule.h.

Referenced by doRespondToCloseOutputFiles().

{}

virtual void edm::OutputModule::respondToOpenInputFile ( FileBlock const & ) [inline, private, virtual]

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

Definition at line 193 of file OutputModule.h.

Referenced by doRespondToOpenInputFile().

{}

virtual void edm::OutputModule::respondToOpenOutputFiles ( FileBlock const & ) [inline, private, virtual]

Reimplemented in edm::SubProcess.

Definition at line 195 of file OutputModule.h.

Referenced by doRespondToOpenOutputFiles().

{}

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

Definition at line 409 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 [inline, protected]

Definition at line 86 of file OutputModule.h.

References selector_config_id_.

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

{ return selector_config_id_; }

void edm::OutputModule::selectProducts ( )

Definition at line 174 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::setEventSelectionInfo	(	std::map< std::string, std::vector< std::pair< std::string, int > > > const &	outputModulePathPositions,
		bool	anyProductProduced
	)		`[protected]`

Definition at line 438 of file OutputModule.cc.

References edm::ParameterSet::addParameter(), edm::ParameterSet::copyForModify(), description(), alignCSCRings::e, edm::ParameterSet::exists(), edm::getParameterSet(), i, edm::ParameterSet::id(), label, edm::ModuleDescription::moduleLabel(), edm::ParameterSet::registerIt(), and selector_config_id_.

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

                                                               {

    ParameterSet selectEventsInfo;
    selectEventsInfo.copyForModify(getParameterSet(selector_config_id_));
    selectEventsInfo.addParameter<bool>("InProcessHistory", anyProductProduced);
    std::string const& label = description().moduleLabel();
    std::vector<std::string> endPaths;
    std::vector<int> endPathPositions;

    // The label will be empty if and only if this is a SubProcess
    // SubProcess's do not appear on any end path
    if (!label.empty()) {
      std::map<std::string, std::vector<std::pair<std::string, int> > >::const_iterator iter = outputModulePathPositions.find(label);
      assert(iter != outputModulePathPositions.end());
      for (std::vector<std::pair<std::string, int> >::const_iterator i = iter->second.begin(), e = iter->second.end();
           i != e; ++i) {
        endPaths.push_back(i->first);
        endPathPositions.push_back(i->second);
      }
    }
    selectEventsInfo.addParameter<std::vector<std::string> >("EndPaths", endPaths);
    selectEventsInfo.addParameter<std::vector<int> >("EndPathPositions", endPathPositions);
    if (!selectEventsInfo.exists("SelectEvents")) {
      selectEventsInfo.addParameter<std::vector<std::string> >("SelectEvents", std::vector<std::string>());
    }
    selectEventsInfo.registerIt();

    selector_config_id_ = selectEventsInfo.id();
  }

void edm::OutputModule::setModuleDescription ( ModuleDescription const & md ) [inline, private]

Definition at line 204 of file OutputModule.h.

References moduleDescription_.

                                                           {
      moduleDescription_ = md;
    }

virtual bool edm::OutputModule::shouldWeCloseFile ( ) const [inline, private, virtual]

Ask the OutputModule if we should end the current file.

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

Definition at line 181 of file OutputModule.h.

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

{return false;}

virtual void edm::OutputModule::startEndFile ( ) [inline, private, virtual]

Reimplemented in DQMRootOutputModule, and edm::PoolOutputModule.

Definition at line 216 of file OutputModule.h.

Referenced by reallyCloseFile().

{}

void edm::OutputModule::updateBranchParents ( EventPrincipal const & ep ) [private]

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