edm::PathsAndConsumesOfModules Class Reference

#include <PathsAndConsumesOfModules.h>

Inheritance diagram for edm::PathsAndConsumesOfModules:

Public Member Functions
void	initialize (Schedule const *, std::shared_ptr< ProductRegistry const >)
std::vector< ModuleProcessName > const &	modulesInPreviousProcessesWhoseProductsAreConsumedBy (unsigned int moduleID) const
	PathsAndConsumesOfModules ()
void	removeModules (std::vector< ModuleDescription const * > const &modules)
	~PathsAndConsumesOfModules () override
Public Member Functions inherited from edm::PathsAndConsumesOfModulesBase
std::vector< ModuleDescription const * > const &	allModules () const
std::vector< ConsumesInfo >	consumesInfo (unsigned int moduleID) const
std::vector< std::string > const &	endPaths () const
unsigned int	largestModuleID () const
ModuleDescription const *	moduleDescription (unsigned int moduleID) const
std::vector< ModuleDescription const * > const &	modulesOnEndPath (unsigned int endPathIndex) const
std::vector< ModuleDescription const * > const &	modulesOnPath (unsigned int pathIndex) const
std::vector< ModuleDescription const * > const &	modulesWhoseProductsAreConsumedBy (unsigned int moduleID, BranchType branchType=InEvent) const
std::vector< std::string > const &	paths () const
virtual	~PathsAndConsumesOfModulesBase ()

Private Member Functions
std::vector< ModuleDescription const * > const &	doAllModules () const override
std::vector< ConsumesInfo >	doConsumesInfo (unsigned int moduleID) const override
std::vector< std::string > const &	doEndPaths () const override
unsigned int	doLargestModuleID () const override
ModuleDescription const *	doModuleDescription (unsigned int moduleID) const override
std::vector< ModuleDescription const * > const &	doModulesOnEndPath (unsigned int endPathIndex) const override
std::vector< ModuleDescription const * > const &	doModulesOnPath (unsigned int pathIndex) const override
std::vector< ModuleDescription const * > const &	doModulesWhoseProductsAreConsumedBy (unsigned int moduleID, BranchType branchType) const override
std::vector< std::string > const &	doPaths () const override
unsigned int	moduleIndex (unsigned int moduleID) const

Private Attributes
std::vector< ModuleDescription const * >	allModuleDescriptions_
std::vector< std::string >	endPaths_
std::vector< std::pair < unsigned int, unsigned int > >	moduleIDToIndex_
std::vector< std::vector < ModuleProcessName > >	modulesInPreviousProcessesWhoseProductsAreConsumedBy_
std::vector< std::vector < ModuleDescription const * > >	modulesOnEndPaths_
std::vector< std::vector < ModuleDescription const * > >	modulesOnPaths_
std::array< std::vector < std::vector < ModuleDescription const * > >, NumBranchTypes >	modulesWhoseProductsAreConsumedBy_
std::vector< std::string >	paths_
std::shared_ptr < ProductRegistry const >	preg_
Schedule const *	schedule_

Detailed Description

Description: See comments in the base class

Usage:

Definition at line 32 of file PathsAndConsumesOfModules.h.

Constructor & Destructor Documentation

edm::PathsAndConsumesOfModules::PathsAndConsumesOfModules ( )

default

edm::PathsAndConsumesOfModules::~PathsAndConsumesOfModules ( )

overridedefault

Member Function Documentation

std::vector<ModuleDescription const*> const& edm::PathsAndConsumesOfModules::doAllModules ( ) const

inlineoverrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 48 of file PathsAndConsumesOfModules.h.

References allModuleDescriptions_.

{ return allModuleDescriptions_; }

std::vector< ConsumesInfo > edm::PathsAndConsumesOfModules::doConsumesInfo ( unsigned int  moduleID ) const

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 122 of file PathsAndConsumesOfModules.cc.

References edm::Schedule::allWorkers(), edm::Worker::consumesInfo(), moduleIndex(), and schedule_.

                                                                                               {
    Worker const* worker = schedule_->allWorkers().at(moduleIndex(moduleID));
    return worker->consumesInfo();
  }

std::vector<std::string> const& edm::PathsAndConsumesOfModules::doEndPaths ( ) const

inlineoverrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 46 of file PathsAndConsumesOfModules.h.

References endPaths_.

{ return endPaths_; }

unsigned int edm::PathsAndConsumesOfModules::doLargestModuleID ( ) const

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 127 of file PathsAndConsumesOfModules.cc.

References moduleIDToIndex_.

                                                                  {
    // moduleIDToIndex_ is sorted, so last element has the largest ID
    return moduleIDToIndex_.empty() ? 0 : moduleIDToIndex_.back().first;
  }

ModuleDescription const * edm::PathsAndConsumesOfModules::doModuleDescription ( unsigned int  moduleID ) const

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 96 of file PathsAndConsumesOfModules.cc.

References allModuleDescriptions_, Exception, edm::errors::LogicError, cuda_std::lower_bound(), moduleIDToIndex_, and filterCSVwithJSON::target.

                                                                                                     {
    unsigned int dummy = 0;
    auto target = std::make_pair(moduleID, dummy);
    std::vector<std::pair<unsigned int, unsigned int>>::const_iterator iter =
        std::lower_bound(moduleIDToIndex_.begin(), moduleIDToIndex_.end(), target);
    if (iter == moduleIDToIndex_.end() || iter->first != moduleID) {
      throw Exception(errors::LogicError)
          << "PathsAndConsumesOfModules::moduleDescription: Unknown moduleID " << moduleID << "\n";
    }
    return allModuleDescriptions_.at(iter->second);
  }

std::vector< ModuleDescription const * > const & edm::PathsAndConsumesOfModules::doModulesOnEndPath ( unsigned int  endPathIndex ) const

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 112 of file PathsAndConsumesOfModules.cc.

References modulesOnEndPaths_.

                                       {
    return modulesOnEndPaths_.at(endPathIndex);
  }

std::vector< ModuleDescription const * > const & edm::PathsAndConsumesOfModules::doModulesOnPath ( unsigned int  pathIndex ) const

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 108 of file PathsAndConsumesOfModules.cc.

References modulesOnPaths_.

                                                                                                                    {
    return modulesOnPaths_.at(pathIndex);
  }

std::vector< ModuleDescription const * > const & edm::PathsAndConsumesOfModules::doModulesWhoseProductsAreConsumedBy ( unsigned int  moduleID, BranchType  branchType  ) const

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 117 of file PathsAndConsumesOfModules.cc.

References moduleIndex(), and modulesWhoseProductsAreConsumedBy_.

                                                          {
    return modulesWhoseProductsAreConsumedBy_[branchType].at(moduleIndex(moduleID));
  }

std::vector<std::string> const& edm::PathsAndConsumesOfModules::doPaths ( ) const

inlineoverrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 45 of file PathsAndConsumesOfModules.h.

References paths_.

{ return paths_; }

void edm::PathsAndConsumesOfModules::initialize	(	Schedule const *	schedule,
		std::shared_ptr< ProductRegistry const >	preg
	)

Definition at line 17 of file PathsAndConsumesOfModules.cc.

References allModuleDescriptions_, edm::Schedule::endPaths(), endPaths_, edm::Schedule::fillModuleAndConsumesInfo(), mps_fire::i, edm::Schedule::moduleDescriptionsInEndPath(), edm::Schedule::moduleDescriptionsInPath(), moduleIDToIndex_, modulesInPreviousProcessesWhoseProductsAreConsumedBy_, modulesOnEndPaths_, modulesOnPaths_, modulesWhoseProductsAreConsumedBy_, fed_dqm_sourceclient-live_cfg::path, paths_, edm::preg, preg_, Tree_ALCARECO_cff::schedule, schedule_, and edm::Schedule::triggerPaths().

Referenced by edm::EventProcessor::beginJob(), and edm::SubProcess::keepOnlyConsumedUnscheduledModules().

                                                                                                                {
    schedule_ = schedule;
    preg_ = preg;

    paths_.clear();
    schedule->triggerPaths(paths_);

    endPaths_.clear();
    schedule->endPaths(endPaths_);

    modulesOnPaths_.resize(paths_.size());
    unsigned int i = 0;
    unsigned int hint = 0;
    for (auto const& path : paths_) {
      schedule->moduleDescriptionsInPath(path, modulesOnPaths_.at(i), hint);
      if (!modulesOnPaths_.at(i).empty())
        ++hint;
      ++i;
    }

    modulesOnEndPaths_.resize(endPaths_.size());
    i = 0;
    hint = 0;
    for (auto const& endpath : endPaths_) {
      schedule->moduleDescriptionsInEndPath(endpath, modulesOnEndPaths_.at(i), hint);
      if (!modulesOnEndPaths_.at(i).empty())
        ++hint;
      ++i;
    }

    schedule->fillModuleAndConsumesInfo(allModuleDescriptions_,
                                        moduleIDToIndex_,
                                        modulesWhoseProductsAreConsumedBy_,
                                        modulesInPreviousProcessesWhoseProductsAreConsumedBy_,
                                        *preg);
  }

unsigned int edm::PathsAndConsumesOfModules::moduleIndex ( unsigned int  moduleID ) const

private

Definition at line 132 of file PathsAndConsumesOfModules.cc.

References Exception, edm::errors::LogicError, cuda_std::lower_bound(), moduleIDToIndex_, and filterCSVwithJSON::target.

Referenced by doConsumesInfo(), doModulesWhoseProductsAreConsumedBy(), and modulesInPreviousProcessesWhoseProductsAreConsumedBy().

                                                                                 {
    unsigned int dummy = 0;
    auto target = std::make_pair(moduleID, dummy);
    std::vector<std::pair<unsigned int, unsigned int>>::const_iterator iter =
        std::lower_bound(moduleIDToIndex_.begin(), moduleIDToIndex_.end(), target);
    if (iter == moduleIDToIndex_.end() || iter->first != moduleID) {
      throw Exception(errors::LogicError)
          << "PathsAndConsumesOfModules::moduleIndex: Unknown moduleID " << moduleID << "\n";
    }
    return iter->second;
  }

std::vector< ModuleProcessName > const & edm::PathsAndConsumesOfModules::modulesInPreviousProcessesWhoseProductsAreConsumedBy

(

unsigned int

moduleID

)

const

Definition at line 91 of file PathsAndConsumesOfModules.cc.

References moduleIndex(), and modulesInPreviousProcessesWhoseProductsAreConsumedBy_.

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

                                   {
    return modulesInPreviousProcessesWhoseProductsAreConsumedBy_.at(moduleIndex(moduleID));
  }

void edm::PathsAndConsumesOfModules::removeModules

(

std::vector< ModuleDescription const * > const &

modules

)

Definition at line 54 of file PathsAndConsumesOfModules.cc.

References allModuleDescriptions_, SplitLinear::begin, config::checkPath, getPayloadData::description, Exception, spr::find(), newFWLiteAna::found, moduleIDToIndex_, TrackingSourceConfig_Tier0_Cosmic_cff::modules, modulesInPreviousProcessesWhoseProductsAreConsumedBy_, modulesOnEndPaths_, modulesOnPaths_, modulesWhoseProductsAreConsumedBy_, edm::NumBranchTypes, fed_dqm_sourceclient-live_cfg::path, and edm::PathsAndConsumesOfModulesBase::paths().

Referenced by edm::EventProcessor::beginJob(), and edm::SubProcess::keepOnlyConsumedUnscheduledModules().

                                                                                                  {
    // First check that no modules on Paths are removed
    auto checkPath = [&modules](auto const& paths) {
      for (auto const& path : paths) {
        for (auto const& description : path) {
          if (std::find(modules.begin(), modules.end(), description) != modules.end()) {
            throw cms::Exception("Assert")
                << "PathsAndConsumesOfModules::removeModules() is trying to remove a module with label "
                << description->moduleLabel() << " id " << description->id() << " from a Path, this should not happen.";
          }
        }
      }
    };
    checkPath(modulesOnPaths_);
    checkPath(modulesOnEndPaths_);

    // Remove the modules and adjust the indices in idToIndex map
    for (auto iModule = 0U; iModule != allModuleDescriptions_.size(); ++iModule) {
      auto found = std::find(modules.begin(), modules.end(), allModuleDescriptions_[iModule]);
      if (found != modules.end()) {
        allModuleDescriptions_.erase(allModuleDescriptions_.begin() + iModule);
        for (auto iBranchType = 0U; iBranchType != NumBranchTypes; ++iBranchType) {
          modulesWhoseProductsAreConsumedBy_[iBranchType].erase(
              modulesWhoseProductsAreConsumedBy_[iBranchType].begin() + iModule);
        }
        modulesInPreviousProcessesWhoseProductsAreConsumedBy_.erase(
            modulesInPreviousProcessesWhoseProductsAreConsumedBy_.begin() + iModule);
        for (auto& idToIndex : moduleIDToIndex_) {
          if (idToIndex.second >= iModule) {
            idToIndex.second--;
          }
        }
        --iModule;
      }
    }
  }

Member Data Documentation

std::vector<ModuleDescription const*> edm::PathsAndConsumesOfModules::allModuleDescriptions_

private

Definition at line 67 of file PathsAndConsumesOfModules.h.

Referenced by doAllModules(), doModuleDescription(), initialize(), and removeModules().

std::vector<std::string> edm::PathsAndConsumesOfModules::endPaths_

private

Definition at line 65 of file PathsAndConsumesOfModules.h.

Referenced by doEndPaths(), and initialize().

std::vector<std::pair<unsigned int, unsigned int> > edm::PathsAndConsumesOfModules::moduleIDToIndex_

private

Definition at line 74 of file PathsAndConsumesOfModules.h.

Referenced by doLargestModuleID(), doModuleDescription(), initialize(), moduleIndex(), and removeModules().

std::vector<std::vector<ModuleProcessName> > edm::PathsAndConsumesOfModules::modulesInPreviousProcessesWhoseProductsAreConsumedBy_

private

Definition at line 77 of file PathsAndConsumesOfModules.h.

Referenced by initialize(), modulesInPreviousProcessesWhoseProductsAreConsumedBy(), and removeModules().

std::vector<std::vector<ModuleDescription const*> > edm::PathsAndConsumesOfModules::modulesOnEndPaths_

private

Definition at line 70 of file PathsAndConsumesOfModules.h.

Referenced by doModulesOnEndPath(), initialize(), and removeModules().

std::vector<std::vector<ModuleDescription const*> > edm::PathsAndConsumesOfModules::modulesOnPaths_

private

Definition at line 69 of file PathsAndConsumesOfModules.h.

Referenced by doModulesOnPath(), initialize(), and removeModules().

std::array<std::vector<std::vector<ModuleDescription const*> >, NumBranchTypes> edm::PathsAndConsumesOfModules::modulesWhoseProductsAreConsumedBy_

private

Definition at line 76 of file PathsAndConsumesOfModules.h.

Referenced by doModulesWhoseProductsAreConsumedBy(), initialize(), and removeModules().

std::vector<std::string> edm::PathsAndConsumesOfModules::paths_

private

Definition at line 64 of file PathsAndConsumesOfModules.h.

Referenced by Config.Process::_insertPaths(), doPaths(), Config.Process::dumpConfig(), Config.Process::dumpPython(), initialize(), Config.Process::pathNames(), and Config.Process::splitPython().

std::shared_ptr<ProductRegistry const> edm::PathsAndConsumesOfModules::preg_

private

Definition at line 80 of file PathsAndConsumesOfModules.h.

Referenced by initialize().

Schedule const* edm::PathsAndConsumesOfModules::schedule_

private

Definition at line 79 of file PathsAndConsumesOfModules.h.

Referenced by Config.Process::_insertPaths(), Config.Process::_replaceInSchedule(), Config.Process::_replaceInScheduleDirectly(), doConsumesInfo(), Config.Process::dumpPython(), initialize(), Config.Process::prune(), Config.Process::resolve(), and Config.Process::splitPython().