art::RPManager Class Reference

#include "RPManager.h"

Public Types
template<typename RET , typename... ARGS>
using	invoke_function_t = RET(ResultsProducer::*)(ARGS...)
using	on_rpworker_t = std::function< void(RPWorker &)>

Public Member Functions
	RPManager (fhicl::ParameterSet const &ps)
template<typename... ARGS>
void	invoke (invoke_function_t< void, ARGS... > mfunc, ARGS &&...args)
void	for_each_RPWorker (on_rpworker_t wfunc)

Private Attributes
std::map< std::string, std::vector< std::unique_ptr< RPWorker > > >	rpmap_

Detailed Description

Definition at line 19 of file RPManager.h.

Member Typedef Documentation

template<typename RET , typename... ARGS>

using art::RPManager::invoke_function_t = RET (ResultsProducer::*)(ARGS...)

Definition at line 22 of file RPManager.h.

using art::RPManager::on_rpworker_t = std::function<void(RPWorker&)>

Definition at line 24 of file RPManager.h.

Constructor & Destructor Documentation

art::RPManager::RPManager

(

fhicl::ParameterSet const &

ps

)

Definition at line 21 of file RPManager.cc.

References art::errors::Configuration, fhicl::ParameterSet::get(), fhicl::ParameterSet::get_names(), fhicl::ParameterSet::id(), art::Suffixes::plugin(), rpmap_, util::to_string(), value, and lar::dump::vector().

                                                  : rpmap_{}
  {
    string const omLabel(ps.get<string>("module_label"));
    auto results = ps.get<ParameterSet>("results", {});
    auto producers = results.get<ParameterSet>("producers", {});
    auto results_keys = results.get_names();
    auto producer_keys = producers.get_names();
    map<string, vector<string>> paths;
    string errMsg;
    if (producer_keys.empty() && !results.is_empty()) {
      throw Exception(errors::Configuration)
        << "Parameter set " << omLabel
        << ".results is non-empty, but does not contain\n"
        << "a non-empty producers parameter set.\n";
    }
    auto const path_keys_end =
      remove(results_keys.begin(), results_keys.end(), "producers");
    auto const& all_labels = producers.get_names();
    set<string> all_labels_set(all_labels.cbegin(), all_labels.cend());
    map<string, string> used_labels;
    for (auto path_key = results_keys.begin(); path_key != path_keys_end;
         ++path_key) {
      if (!results.is_key_to_sequence(*path_key)) {
        errMsg += "Parameter " + omLabel + ".results." + *path_key +
                  " does not describe a sequence (i.e. a path).\n";
        continue;
      }
      auto path = results.get<vector<string>>(*path_key);
      int idx = 0;
      for (auto const& l : path) {
        if (all_labels_set.find(l) == all_labels_set.end()) {
          // Bad label
          errMsg += omLabel + ".results."s + *path_key + '[' +
                    std::to_string(idx) + "] ("s + l + ')' +
                    " is not defined in "s + omLabel + ".results.producers.\n"s;
          ++idx;
          continue;
        }
        auto const ans = used_labels.emplace(l, *path_key);
        if (!ans.second) {
          // Duplicate
          errMsg += omLabel + ".results." + *path_key + '[' +
                    std::to_string(idx) + "] (" + l + ')' +
                    " is a duplicate: previously used in path " +
                    ans.first->second + ".\n";
        }
        ++idx;
      }
      if (errMsg.empty()) {
        paths.emplace(*path_key, std::move(path));
      }
    }
    if (paths.empty() && (errMsg.empty())) {
      paths.emplace("default_path", all_labels);
    }
    if (!errMsg.empty()) {
      throw Exception(errors::Configuration)
        << "Errors encountered while configuring ResultsProducers:\n"
        << errMsg;
    }
    cet::BasicPluginFactory pf{Suffixes::plugin(), "makeRP"};
    for (auto const& [path_name, module_names] : paths) {
      auto ins_res = rpmap_.emplace(path_name, vector<unique_ptr<RPWorker>>{});
      transform(module_names.cbegin(),
                module_names.cend(),
                back_inserter(ins_res.first->second),
                [&pf, &producers, &omLabel, &errMsg](string const& pkey) {
                  unique_ptr<RPWorker> result;
                  auto const& pconfig = producers.get<ParameterSet>(pkey);
                  auto libspec = pconfig.get<string>("plugin_type");
                  auto const& ptype = pf.pluginType(libspec);
                  if (ptype == cet::PluginTypeDeducer<ResultsProducer>::value) {
                    result = pf.makePlugin<unique_ptr<RPWorker>,
                                           RPParams const&,
                                           ParameterSet const&>(
                      libspec, {pconfig.id(), libspec, pkey}, pconfig);
                  } else {
                    errMsg +=
                      "Parameter set " + omLabel + ".results." + pkey +
                      " specifies a plugin " + libspec +
                      "\n  which is not of required type ResultsProducer.\n";
                  }
                  return result;
                });
    }
    if (!errMsg.empty()) {
      throw Exception(errors::Configuration)
        << "Errors encountered while instantiating ResultsProducers:\n"
        << errMsg;
    }
  }

Member Function Documentation

void art::RPManager::for_each_RPWorker

(

on_rpworker_t

wfunc

)

Definition at line 114 of file RPManager.cc.

References rpmap_, and w.

  {
    for (auto& path : rpmap_) {
      for (auto& w : path.second) {
        wfunc(*w);
      }
    }
  }

template<typename... ARGS>

void art::RPManager::invoke	(	invoke_function_t< void, ARGS... >	mfunc,
		ARGS &&...	args
	)

Definition at line 40 of file RPManager.h.

References rpmap_, and w.

  {
    for (auto& path : rpmap_) {
      for (auto& w : path.second) {
        (w->rp().*mfunc)(std::forward<ARGS>(args)...);
      }
    }
  }

Member Data Documentation

std::map<std::string, std::vector<std::unique_ptr<RPWorker> > > art::RPManager::rpmap_

private

Definition at line 35 of file RPManager.h.

Referenced by for_each_RPWorker(), invoke(), and RPManager().

---

The documentation for this class was generated from the following files:

• art/Framework/Core/RPManager.h
• art/Framework/Core/RPManager.cc