#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
Trig	getTriggerResults (EventPrincipal const &ep) const
Trig	getTriggerResults (Event 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	doBeginJob ()
bool	doBeginLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, CurrentProcessingContext const *cpc)
bool	doBeginRun (RunPrincipal const &rp, EventSetup const &c, CurrentProcessingContext const *cpc)
void	doCloseFile ()
	Tell the OutputModule that is must end the current file.
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)
virtual void	doOpenFile ()
void	doOpenFile (FileBlock const &fb)
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.
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
class	WorkerT

Detailed Description

Definition at line 36 of file OutputModule.h.

Member Typedef Documentation

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

Definition at line 127 of file OutputModule.h.

typedef OutputModule edm::OutputModule::ModuleType

Definition at line 40 of file OutputModule.h.

typedef OutputWorker edm::OutputModule::WorkerType

Definition at line 41 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::getUntrackedParameter(), hasNewlyDroppedBranch_, i, edm::ParameterSet::id(), process_name_, 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.getUntrackedParameter("SelectEvents", ParameterSet());

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

{ }

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 ) [inline, private, virtual]

Reimplemented in edm::StreamerOutputModuleBase.

Definition at line 178 of file OutputModule.h.

Referenced by doBeginJob().

{}

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

Definition at line 183 of file OutputModule.h.

Referenced by doBeginLuminosityBlock().

{}

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

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

Definition at line 180 of file OutputModule.h.

Referenced by doBeginRun().

{}

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

Definition at line 64 of file OutputModule.h.

References branchChildren_.

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

{return branchChildren_;}

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

Definition at line 167 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 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 ( ) [private]

Definition at line 205 of file OutputModule.cc.

References beginJob(), and selectProducts().

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

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

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
	)		`[private]`

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 ( ) [private]

Definition at line 210 of file OutputModule.cc.

References endJob().

                              {
    endJob();
  }

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

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
	)		`[private]`

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
	)		`[private]`

Definition at line 247 of file OutputModule.cc.

References current_context_, ExpressReco_HICollisions_FallBack::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";

    // This ugly little bit is here to prevent making the Event
    // if we don't need it.
    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 ( ) [inline, private, virtual]

Reimplemented in edm::PoolOutputModule.

Definition at line 196 of file OutputModule.h.

Referenced by maybeOpenFile().

{ }

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 ) [inline, private, virtual]

Reimplemented in edm::StreamerOutputModuleBase.

Definition at line 179 of file OutputModule.h.

Referenced by doEndJob().

{}

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

Definition at line 184 of file OutputModule.h.

Referenced by doEndLuminosityBlock().

{}

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

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

Definition at line 181 of file OutputModule.h.

Referenced by doEndRun().

{}

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

Definition at line 447 of file OutputModule.cc.

References branchChildren_, branchParents_, 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]

Reimplemented in edm::StreamerOutputModuleBase.

Definition at line 420 of file OutputModule.cc.

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

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

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

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

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 ( ) [inline, private, virtual]

Reimplemented in edm::PoolOutputModule.

Definition at line 222 of file OutputModule.h.

Referenced by reallyCloseFile().

{}

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

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

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

Definition at line 215 of file OutputModule.cc.

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

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

                                                            {
    return selectors_.getOneTriggerResults(ev);
  }

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

Definition at line 58 of file OutputModule.h.

References hasNewlyDroppedBranch_.

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

{return hasNewlyDroppedBranch_;}

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

Reimplemented in edm::PoolOutputModule.

Definition at line 194 of file OutputModule.h.

Referenced by doCloseFile(), and maybeOpenFile().

{ return true; }

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

Definition at line 57 of file OutputModule.h.

References keptProducts_.

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

{return keptProducts_;}

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

Definition at line 205 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 47 of file OutputModule.h.

References maxEvents_.

{return maxEvents_;}

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 ) [inline, private, virtual]

Reimplemented in edm::PoolOutputModule.

Definition at line 186 of file OutputModule.h.

Referenced by doOpenFile().

{}

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

Reimplemented in edm::PoolOutputModule.

Definition at line 192 of file OutputModule.h.

Referenced by doPostForkReacquireResources().

{}

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

Definition at line 191 of file OutputModule.h.

Referenced by doPreForkReleaseResources().

{}

std::string const& edm::OutputModule::processName ( ) const [inline]

Definition at line 56 of file OutputModule.h.

References process_name_.

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

{return process_name_;}

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

Definition at line 172 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 51 of file OutputModule.h.

References remainingEvents_.

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

{return remainingEvents_;}

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

Reimplemented in edm::PoolOutputModule.

Definition at line 188 of file OutputModule.h.

Referenced by doRespondToCloseInputFile().

{}

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

Definition at line 190 of file OutputModule.h.

Referenced by doRespondToCloseOutputFiles().

{}

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

Reimplemented in edm::PoolOutputModule.

Definition at line 187 of file OutputModule.h.

Referenced by doRespondToOpenInputFile().

{}

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

Definition at line 189 of file OutputModule.h.

Referenced by doRespondToOpenOutputFiles().

{}

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 [inline, protected]

Definition at line 84 of file OutputModule.h.

References selector_config_id_.

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

{ return selector_config_id_; }

void edm::OutputModule::selectProducts ( )

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

Definition at line 198 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 175 of file OutputModule.h.

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

{return false;}

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

Reimplemented in edm::PoolOutputModule.

Definition at line 210 of file OutputModule.h.

Referenced by reallyCloseFile().

{}

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);
      }
    }
  }