#include "PathsInfo.h"

Public Types
using	ModInfos = std::vector< detail::ModuleInPathInfo >

Public Member Functions
	PathsInfo (std::size_t const numPaths, detail::ModuleFactory &factory, fhicl::ParameterSet const &procPS, MasterProductRegistry &preg, ProductDescriptions &productsToProduce, ActionTable &actions, ActivityRegistry &areg)

HLTGlobalStatus &	pathResults ()

void	makeAndAppendPath (std::string const &pathName, ModInfos const &modInfos, bool trigResultsNeeded=true)

void	addEvent ()

void	addPass ()

WorkerMap const &	workers () const

PathPtrs const &	pathPtrs () const

size_t	passedEvents () const

size_t	failedEvents () const

size_t	totalEvents () const

Private Member Functions
void	makeWorker_ (detail::ModuleInPathInfo const &mipi, std::vector< WorkerInPath > &pathWorkers)

cet::exempt_ptr< Worker >	makeWorker_ (detail::ModuleConfigInfo const &mci)

Private Attributes
WorkerMap	workers_ {}

PathPtrs	pathPtrs_ {}

HLTGlobalStatus	pathResults_

size_t	totalEvents_ {}

size_t	passedEvents_ {}

detail::ModuleFactory &	fact_

fhicl::ParameterSet const &	procPS_

MasterProductRegistry &	preg_

ProductDescriptions &	productsToProduce_

ActionTable &	exceptActions_

ActivityRegistry &	areg_

std::vector< std::string >	configErrMsgs_

Detailed Description

Definition at line 15 of file PathsInfo.h.

Member Typedef Documentation

using art::PathsInfo::ModInfos = std::vector<detail::ModuleInPathInfo>

Definition at line 26 of file PathsInfo.h.

Constructor & Destructor Documentation

art::PathsInfo::PathsInfo	(	std::size_t const	numPaths,
		detail::ModuleFactory &	factory,
		fhicl::ParameterSet const &	procPS,
		MasterProductRegistry &	preg,
		ProductDescriptions &	productsToProduce,
		ActionTable &	actions,
		ActivityRegistry &	areg
	)

explicit

Definition at line 11 of file PathsInfo.cc.

References areg_, exceptActions_, fact_, preg_, procPS_, and productsToProduce_.

   : pathResults_{numPaths}
   , fact_{factory}
   , procPS_{procPS}
   , preg_{preg}
   , productsToProduce_{productsToProduce}
   , exceptActions_{actions}
   , areg_{areg}
 {}

Member Function Documentation

void art::PathsInfo::addEvent ( )

inline

Definition at line 69 of file PathsInfo.h.

References totalEvents_.

Referenced by art::EndPathExecutor::process(), and art::Schedule::process().

 {
   ++totalEvents_;
 }

void art::PathsInfo::addPass ( )

inline

Definition at line 75 of file PathsInfo.h.

References passedEvents_.

Referenced by art::EndPathExecutor::process(), and art::Schedule::process().

 {
   ++passedEvents_;
 }

size_t art::PathsInfo::failedEvents ( ) const

inline

Definition at line 99 of file PathsInfo.h.

References passedEvents_, and totalEvents_.

Referenced by art::detail::triggerReport().

 {
   return totalEvents_ - passedEvents_;
 }

void art::PathsInfo::makeAndAppendPath	(	std::string const &	pathName,
		ModInfos const &	modInfos,
		bool	trigResultsNeeded = `true`
	)

Definition at line 29 of file PathsInfo.cc.

References areg_, configErrMsgs_, art::errors::Configuration, exceptActions_, art::is_observer(), makeWorker_(), pathPtrs_, pathResults(), and pathResults_.

Referenced by art::PathManager::endPathInfo().

 {
   assert(!modInfos.empty());
   std::vector<WorkerInPath> pathWorkers;
   for (auto const& mci : modInfos) {
     makeWorker_(mci, pathWorkers);
   }
 
   if (!configErrMsgs_.empty()) {
     constexpr cet::HorizontalRule rule{100};
     std::ostringstream err_msg;
     err_msg << "\n"
             << rule('=') << "\n\n"
             << "!! The following modules have been misconfigured: !!"
             << "\n";
     for (auto const& err : configErrMsgs_) {
       err_msg << "\n" << rule('-') << "\n" << err;
     }
     err_msg << "\n" << rule('=') << "\n\n";
 
     throw art::Exception(art::errors::Configuration) << err_msg.str();
   }
 
   cet::exempt_ptr<HLTGlobalStatus> pathResults{
     trigResultsNeeded ? &pathResults_ : nullptr};
   auto const bit_position_for_new_path = pathPtrs_.size();
   auto path = std::make_unique<art::Path>(
     bit_position_for_new_path,
     pathName,
     std::move(pathWorkers),
     std::move(pathResults),
     exceptActions_,
     areg_,
     is_observer(modInfos.front().moduleConfigInfo().moduleType()));
   pathPtrs_.push_back(std::move(path));
 }

void art::PathsInfo::makeWorker_	(	detail::ModuleInPathInfo const &	mipi,
		std::vector< WorkerInPath > &	pathWorkers
	)

private

Definition at line 69 of file PathsInfo.cc.

References art::detail::ModuleInPathInfo::filterAction(), art::detail::ModuleInPathInfo::moduleConfigInfo(), and w.

Referenced by makeAndAppendPath().

 {
   auto w = makeWorker_(mipi.moduleConfigInfo());
   pathWorkers.emplace_back(w, mipi.filterAction());
 }

cet::exempt_ptr< art::Worker > art::PathsInfo::makeWorker_ ( detail::ModuleConfigInfo const & mci )

private

Definition at line 77 of file PathsInfo.cc.

References areg_, art::detail::bold_fontify(), configErrMsgs_, art::detail::ModuleConfigInfo::configPath(), e, exceptActions_, fact_, fhicl::ParameterSet::get(), art::getReleaseVersion(), fhicl::ParameterSet::id(), art::ModuleDescription::id(), art::detail::ModuleConfigInfo::label(), art::detail::ModuleFactory::makeWorker(), preg_, art::ProcessConfiguration::processName_, procPS_, productsToProduce_, art::ActivityRegistry::sPostModuleConstruction, art::ActivityRegistry::sPreModuleConstruction, fhicl::detail::validationException::what(), and workers_.

 {
   auto it = workers_.find(mci.label());
   if (it == workers_.end()) { // Need worker.
     auto moduleConfig =
       procPS_.get<fhicl::ParameterSet>(mci.configPath() + '.' + mci.label());
     WorkerParams const p{
       procPS_,
       moduleConfig,
       preg_,
       productsToProduce_,
       exceptActions_,
       ServiceHandle<TriggerNamesService const>{}->getProcessName()};
     ModuleDescription const md{
       moduleConfig.id(),
       p.pset_.get<std::string>("module_type"),
       p.pset_.get<std::string>("module_label"),
       ProcessConfiguration{p.processName_, procPS_.id(), getReleaseVersion()}};
     areg_.sPreModuleConstruction.invoke(md);
     try {
       auto worker = fact_.makeWorker(p, md);
       areg_.sPostModuleConstruction.invoke(md);
       it = workers_.emplace(mci.label(), std::move(worker)).first;
       it->second->setActivityRegistry(&areg_);
     }
     catch (fhicl::detail::validationException const& e) {
       std::ostringstream err_stream;
       err_stream << "\n\nModule label: "
                  << detail::bold_fontify(md.moduleLabel())
                  << "\nmodule_type : " << detail::bold_fontify(md.moduleName())
                  << "\n\n"
                  << e.what();
       configErrMsgs_.push_back(err_stream.str());
     }
   }
   return cet::exempt_ptr<Worker>{it->second.get()};
 }