art::PathsInfo Class Reference

#include "PathsInfo.h"

Public Member Functions
	~PathsInfo ()
std::map< std::string, std::shared_ptr< Worker > > &	workers ()
std::map< std::string, std::shared_ptr< Worker > > const &	workers () const
void	add_path (ActionTable const &, ActivityRegistry const &, PathContext const &, std::vector< WorkerInPath > &&, GlobalTaskGroup &)
std::vector< Path > &	paths ()
std::vector< Path > const &	paths () const
std::vector< std::string >	pathNames () const
HLTGlobalStatus &	pathResults ()
void	reset ()
void	reset_for_event ()
void	incrementTotalEventCount ()
void	incrementPassedEventCount ()
std::size_t	passedEvents () const
std::size_t	failedEvents () const
std::size_t	totalEvents () const

Private Attributes
std::map< std::string, std::shared_ptr< Worker > >	workers_ {}
std::vector< Path >	paths_ {}
HLTGlobalStatus	pathResults_ {}
std::atomic< std::size_t >	totalEvents_ {}
std::atomic< std::size_t >	passedEvents_ {}

Detailed Description

Definition at line 16 of file PathsInfo.h.

Constructor & Destructor Documentation

art::PathsInfo::~PathsInfo ( )

default

Member Function Documentation

void art::PathsInfo::add_path	(	ActionTable const &	actions,
		ActivityRegistry const &	registry,
		PathContext const &	pc,
		std::vector< WorkerInPath > &&	wips,
		GlobalTaskGroup &	task_group
	)

Definition at line 34 of file PathsInfo.cc.

References art::PathContext::pathID(), art::PathContext::pathName(), art::PathContext::scheduleID(), util::size(), TDEBUG_FUNC_SI, and util::to_string().

  {
    if (pc.pathName() == PathContext::end_path()) {
      paths_.emplace_back(
        actions, registry, pc, std::move(wips), nullptr, task_group);
    } else {
      paths_.emplace_back(
        actions, registry, pc, std::move(wips), &pathResults_, task_group);
      pathResults_ = HLTGlobalStatus(size(paths_));
    }
    TDEBUG_FUNC_SI(5, pc.scheduleID())
      << "Made path " << std::hex << &paths_.back() << std::dec
      << " pathID: " << to_string(pc.pathID()) << " name: " << pc.pathName();
  }

size_t art::PathsInfo::failedEvents

(

)

const

Definition at line 116 of file PathsInfo.cc.

  {
    // MT: This is fragile!
    return totalEvents_.load() - passedEvents_.load();
  }

void art::PathsInfo::incrementPassedEventCount

(

)

Definition at line 104 of file PathsInfo.cc.

Referenced by art::EndPathExecutor::process(), and art::TriggerPathsExecutor::process_event_paths_done().

  {
    ++passedEvents_;
  }

void art::PathsInfo::incrementTotalEventCount

(

)

Definition at line 98 of file PathsInfo.cc.

Referenced by art::TriggerPathsExecutor::process_event(), and art::EndPathExecutor::process_event().

  {
    ++totalEvents_;
  }

size_t art::PathsInfo::passedEvents

(

)

const

Definition at line 110 of file PathsInfo.cc.

  {
    return passedEvents_.load();
  }

vector< string > art::PathsInfo::pathNames

(

)

const

Definition at line 66 of file PathsInfo.cc.

References util::begin(), and util::end().

  {
    vector<string> result;
    std::transform(begin(paths_),
                   end(paths_),
                   back_inserter(result),
                   [](auto const& path) { return path.name(); });
    return result;
  }

HLTGlobalStatus & art::PathsInfo::pathResults

(

)

Definition at line 92 of file PathsInfo.cc.

Referenced by art::TriggerPathsExecutor::process_event_paths_done().

  {
    return pathResults_;
  }

vector< Path > & art::PathsInfo::paths

(

)

Definition at line 54 of file PathsInfo.cc.

Referenced by art::TriggerPathsExecutor::process(), art::EndPathExecutor::process(), art::TriggerPathsExecutor::process_event(), and art::EndPathExecutor::process_event().

  {
    return paths_;
  }

vector< Path > const & art::PathsInfo::paths

(

)

const

Definition at line 60 of file PathsInfo.cc.

  {
    return paths_;
  }

void art::PathsInfo::reset

(

)

Definition at line 77 of file PathsInfo.cc.

References util::values().

Referenced by art::TriggerPathsExecutor::process().

  {
    for (auto const& worker : workers_ | ::ranges::views::values) {
      worker->reset();
    }
  }

void art::PathsInfo::reset_for_event

(

)

Definition at line 85 of file PathsInfo.cc.

Referenced by art::TriggerPathsExecutor::process_event(), and art::EndPathExecutor::process_event().

  {
    reset();
    pathResults_.reset();
  }

size_t art::PathsInfo::totalEvents

(

)

const

Definition at line 123 of file PathsInfo.cc.

  {
    return totalEvents_.load();
  }

map< string, std::shared_ptr< Worker > > & art::PathsInfo::workers

(

)

Definition at line 22 of file PathsInfo.cc.

Referenced by art::EndPathExecutor::EndPathExecutor().

  {
    return workers_;
  }

map< string, std::shared_ptr< Worker > > const & art::PathsInfo::workers

(

)

const

Definition at line 28 of file PathsInfo.cc.

  {
    return workers_;
  }

Member Data Documentation

std::atomic<std::size_t> art::PathsInfo::passedEvents_ {}

private

Definition at line 44 of file PathsInfo.h.

HLTGlobalStatus art::PathsInfo::pathResults_ {}

private

Definition at line 42 of file PathsInfo.h.

std::vector<Path> art::PathsInfo::paths_ {}

private

Definition at line 41 of file PathsInfo.h.

std::atomic<std::size_t> art::PathsInfo::totalEvents_ {}

private

Definition at line 43 of file PathsInfo.h.

std::map<std::string, std::shared_ptr<Worker> > art::PathsInfo::workers_ {}

private

Definition at line 40 of file PathsInfo.h.

---

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

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