#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

◆ PathsAndConsumesOfModules()

edm::PathsAndConsumesOfModules::PathsAndConsumesOfModules ( )

default

◆ ~PathsAndConsumesOfModules()

edm::PathsAndConsumesOfModules::~PathsAndConsumesOfModules ( )

overridedefault

Member Function Documentation

◆ doAllModules()

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

inlineoverrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 48 of file PathsAndConsumesOfModules.h.

48 { return allModuleDescriptions_; }

References allModuleDescriptions_.

◆ doConsumesInfo()

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

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 121 of file PathsAndConsumesOfModules.cc.

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

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

◆ doEndPaths()

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

inlineoverrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 46 of file PathsAndConsumesOfModules.h.

46 { return endPaths_; }

References endPaths_.

◆ doLargestModuleID()

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

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 126 of file PathsAndConsumesOfModules.cc.

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

References moduleIDToIndex_.

◆ doModuleDescription()

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

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 95 of file PathsAndConsumesOfModules.cc.

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

References allModuleDescriptions_, Exception, edm::errors::LogicError, pfDeepBoostedJetPreprocessParams_cfi::lower_bound, moduleIDToIndex_, and filterCSVwithJSON::target.

◆ doModulesOnEndPath()

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

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 111 of file PathsAndConsumesOfModules.cc.

                                        {
     return modulesOnEndPaths_.at(endPathIndex);
   }

References modulesOnEndPaths_.

◆ doModulesOnPath()

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

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 107 of file PathsAndConsumesOfModules.cc.

                                                                                                                     {
     return modulesOnPaths_.at(pathIndex);
   }

References modulesOnPaths_.

◆ doModulesWhoseProductsAreConsumedBy()

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

overrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 116 of file PathsAndConsumesOfModules.cc.

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

References moduleIndex(), and modulesWhoseProductsAreConsumedBy_.

◆ doPaths()

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

inlineoverrideprivatevirtual

Implements edm::PathsAndConsumesOfModulesBase.

Definition at line 45 of file PathsAndConsumesOfModules.h.

45 { return paths_; }

References paths_.

◆ initialize()

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

Definition at line 16 of file PathsAndConsumesOfModules.cc.

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

References allModuleDescriptions_, endPaths_, mps_fire::i, moduleIDToIndex_, modulesInPreviousProcessesWhoseProductsAreConsumedBy_, modulesOnEndPaths_, modulesOnPaths_, modulesWhoseProductsAreConsumedBy_, castor_dqm_sourceclient_file_cfg::path, paths_, preg_, filterRecHits_cfg::schedule, and schedule_.

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

◆ moduleIndex()

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

private

Definition at line 131 of file PathsAndConsumesOfModules.cc.

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

References Exception, edm::errors::LogicError, pfDeepBoostedJetPreprocessParams_cfi::lower_bound, moduleIDToIndex_, and filterCSVwithJSON::target.

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

◆ modulesInPreviousProcessesWhoseProductsAreConsumedBy()

std::vector< ModuleProcessName > const & edm::PathsAndConsumesOfModules::modulesInPreviousProcessesWhoseProductsAreConsumedBy ( unsigned int moduleID ) const

Definition at line 90 of file PathsAndConsumesOfModules.cc.

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

References moduleIndex(), and modulesInPreviousProcessesWhoseProductsAreConsumedBy_.

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

◆ removeModules()

void edm::PathsAndConsumesOfModules::removeModules ( std::vector< ModuleDescription const * > const & modules )

Definition at line 53 of file PathsAndConsumesOfModules.cc.

                                                                                                   {
     // 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;
       }
     }
   }