edm::ConditionalTaskHelper Class Reference

Public Types
using	AliasInfo = StreamSchedule::AliasInfo

Public Member Functions
std::unordered_multimap< std::string, AliasInfo > const &	aliasMap () const
std::unordered_multimap< std::string, edm::BranchDescription const * >	conditionalModuleBranches (std::unordered_set< std::string > const &conditionalmods) const
	ConditionalTaskHelper (ParameterSet &proc_pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration const > processConfiguration, WorkerManager &workerManager, std::vector< std::string > const &trigPathNames)

Private Member Functions
void	fillAliasMap (ParameterSet const &proc_pset, std::unordered_set< std::string > const &allConditionalMods)
void	processSwitchEDAliases (ParameterSet const &proc_pset, ProductRegistry &preg, ProcessConfiguration const &processConfiguration, std::unordered_set< std::string > const &allConditionalMods)

Private Attributes
std::unordered_multimap< std::string, AliasInfo >	aliasMap_
std::unordered_multimap< std::string, edm::BranchDescription const * >	conditionalModsBranches_

Detailed Description

Definition at line 238 of file StreamSchedule.cc.

Member Typedef Documentation

AliasInfo

using edm::ConditionalTaskHelper::AliasInfo = StreamSchedule::AliasInfo

Definition at line 240 of file StreamSchedule.cc.

Constructor & Destructor Documentation

ConditionalTaskHelper()

edm::ConditionalTaskHelper::ConditionalTaskHelper ( ParameterSet &  proc_pset, ProductRegistry &  preg, PreallocationConfiguration const *  prealloc, std::shared_ptr< ProcessConfiguration const >  processConfiguration, WorkerManager &  workerManager, std::vector< std::string > const &  trigPathNames  )

inline

Definition at line 242 of file StreamSchedule.cc.

References conditionalModsBranches_, fillAliasMap(), edm::ParameterSet::getParameter(), hltMonBTagIPClient_cfi::pathName, processSwitchEDAliases(), dumpMFGeometry_cfg::prod, edm::ProductRegistry::productList(), and funct::void.

                                                                     {
      std::unordered_set<std::string> allConditionalMods;
      for (auto const& pathName : trigPathNames) {
        auto const modnames = proc_pset.getParameter<vstring>(pathName);

        //Pull out ConditionalTask modules
        auto condRange = findConditionalTaskModulesRange(modnames);
        if (condRange.first == condRange.second)
          continue;

        //the last entry should be ignored since it is required to be "@"
        allConditionalMods.insert(condRange.first, condRange.second);
      }

      for (auto const& cond : allConditionalMods) {
        //force the creation of the conditional modules so alias check can work
        (void)getWorker(cond, proc_pset, workerManager, preg, prealloc, processConfiguration);
      }

      fillAliasMap(proc_pset, allConditionalMods);
      processSwitchEDAliases(proc_pset, preg, *processConfiguration, allConditionalMods);

      //find branches created by the conditional modules
      for (auto const& prod : preg.productList()) {
        if (allConditionalMods.find(prod.first.moduleLabel()) != allConditionalMods.end()) {
          conditionalModsBranches_.emplace(prod.first.moduleLabel(), &prod.second);
        }
      }
    }

Member Function Documentation

aliasMap()

std::unordered_multimap<std::string, AliasInfo> const& edm::ConditionalTaskHelper::aliasMap ( ) const

inline

Definition at line 277 of file StreamSchedule.cc.

References aliasMap_.

Referenced by edm::StreamSchedule::fillWorkers().

{ return aliasMap_; }

conditionalModuleBranches()

std::unordered_multimap<std::string, edm::BranchDescription const*> edm::ConditionalTaskHelper::conditionalModuleBranches ( std::unordered_set< std::string > const &  conditionalmods ) const

inline

Definition at line 279 of file StreamSchedule.cc.

References conditionalModsBranches_, mod(), FastTimerService_cff::range, and runTheMatrix::ret.

Referenced by edm::StreamSchedule::fillWorkers().

                                                                  {
      std::unordered_multimap<std::string, edm::BranchDescription const*> ret;
      for (auto const& mod : conditionalmods) {
        auto range = conditionalModsBranches_.equal_range(mod);
        ret.insert(range.first, range.second);
      }
      return ret;
    }

fillAliasMap()

void edm::ConditionalTaskHelper::fillAliasMap ( ParameterSet const &  proc_pset, std::unordered_set< std::string > const &  allConditionalMods  )

inlineprivate

Definition at line 290 of file StreamSchedule.cc.

References SiStripOfflineCRack_cfg::alias, aliasMap_, edm::ParameterSet::getParameter(), info(), instance, mod(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by ConditionalTaskHelper().

                                                                                                            {
      auto aliases = proc_pset.getParameter<std::vector<std::string>>("@all_aliases");
      std::string const star("*");
      for (auto const& alias : aliases) {
        auto info = proc_pset.getParameter<edm::ParameterSet>(alias);
        auto aliasedToModuleLabels = info.getParameterNames();
        for (auto const& mod : aliasedToModuleLabels) {
          if (not mod.empty() and mod[0] != '@' and allConditionalMods.find(mod) != allConditionalMods.end()) {
            auto aliasVPSet = info.getParameter<std::vector<edm::ParameterSet>>(mod);
            for (auto const& aliasPSet : aliasVPSet) {
              std::string type = star;
              std::string instance = star;
              std::string originalInstance = star;
              if (aliasPSet.exists("type")) {
                type = aliasPSet.getParameter<std::string>("type");
              }
              if (aliasPSet.exists("toProductInstance")) {
                instance = aliasPSet.getParameter<std::string>("toProductInstance");
              }
              if (aliasPSet.exists("fromProductInstance")) {
                originalInstance = aliasPSet.getParameter<std::string>("fromProductInstance");
              }

              aliasMap_.emplace(alias, AliasInfo{type, instance, originalInstance, mod});
            }
          }
        }
      }
    }

processSwitchEDAliases()

void edm::ConditionalTaskHelper::processSwitchEDAliases ( ParameterSet const &  proc_pset, ProductRegistry &  preg, ProcessConfiguration const &  processConfiguration, std::unordered_set< std::string > const &  allConditionalMods  )

inlineprivate

Definition at line 320 of file StreamSchedule.cc.

References aliasMap_, edm::ParameterSet::getParameter(), callgraph::module, edm::detail::processEDAliases(), edm::ProcessConfiguration::processName(), FastTimerService_cff::range, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by ConditionalTaskHelper().

                                                                                       {
      auto const& all_modules = proc_pset.getParameter<std::vector<std::string>>("@all_modules");
      std::vector<std::string> switchEDAliases;
      for (auto const& module : all_modules) {
        auto const& mod_pset = proc_pset.getParameter<edm::ParameterSet>(module);
        if (mod_pset.getParameter<std::string>("@module_type") == "SwitchProducer") {
          auto const& all_cases = mod_pset.getParameter<std::vector<std::string>>("@all_cases");
          for (auto const& case_label : all_cases) {
            auto range = aliasMap_.equal_range(case_label);
            if (range.first != range.second) {
              switchEDAliases.push_back(case_label);
            }
          }
        }
      }
      detail::processEDAliases(
          switchEDAliases, allConditionalMods, proc_pset, processConfiguration.processName(), preg);
    }

Member Data Documentation

aliasMap_

std::unordered_multimap<std::string, AliasInfo> edm::ConditionalTaskHelper::aliasMap_

private

Definition at line 342 of file StreamSchedule.cc.

Referenced by aliasMap(), fillAliasMap(), and processSwitchEDAliases().

conditionalModsBranches_

std::unordered_multimap<std::string, edm::BranchDescription const*> edm::ConditionalTaskHelper::conditionalModsBranches_

private

Definition at line 343 of file StreamSchedule.cc.

Referenced by conditionalModuleBranches(), and ConditionalTaskHelper().