triggeralgs::TCMakerSupernovaAlgorithm Class Reference

#include <TCMakerSupernovaAlgorithm.hpp>

Inheritance diagram for triggeralgs::TCMakerSupernovaAlgorithm:

Collaboration diagram for triggeralgs::TCMakerSupernovaAlgorithm:

Public Member Functions
void	process (const TriggerActivity &, std::vector< TriggerCandidate > &)
	The function that gets call when there is a new activity.
Public Member Functions inherited from triggeralgs::TriggerCandidateMaker
virtual	~TriggerCandidateMaker ()=default
void	operator() (const TriggerActivity &input_ta, std::vector< TriggerCandidate > &output_tc)
virtual bool	preprocess (const TriggerActivity &)
	TA pre-processing/filtering.
virtual void	postprocess (std::vector< TriggerCandidate > &output_tc)
	Post-processing/filtering of the TCs, e.g. prescale.
virtual void	flush (timestamp_t, std::vector< TriggerCandidate > &)
virtual void	configure (const nlohmann::json &config)

Protected Member Functions
void	FlushOldActivity (timestamp_t time_now)
	this function gets rid of the old activities

Protected Attributes
std::vector< TriggerActivity::TriggerActivityData >	m_activity
std::atomic< int64_t >	m_time_window = { 500'000'000 }
	Slinding time window to count activities.
std::atomic< uint16_t >	m_threshold = { 3 }
	Minimum number of activities in the time window to issue a trigger.
std::atomic< uint16_t >	m_hit_threshold = { 2 }
	Minimum number of primities in an activity.

Additional Inherited Members
Public Attributes inherited from triggeralgs::TriggerCandidateMaker
std::atomic< uint64_t >	m_data_vs_system_time = 0
std::atomic< uint64_t >	m_initial_offset = 0
uint64_t	m_prescale = 1
	Configurable prescale factor.
uint64_t	m_tc_count = 0
	TC made count for prescaling.
TriggerCandidate::Type	m_tc_type_out = TriggerCandidate::Type::kUnknown
	Configurable TC type output.

Detailed Description

Definition at line 21 of file TCMakerSupernovaAlgorithm.hpp.

Member Function Documentation

FlushOldActivity()

void triggeralgs::TCMakerSupernovaAlgorithm::FlushOldActivity ( timestamp_t time_now )

inlineprotected

this function gets rid of the old activities

Definition at line 40 of file TCMakerSupernovaAlgorithm.hpp.

  {
    timestamp_diff_t how_far = time_now - m_time_window;
    auto end = std::remove_if(
                              m_activity.begin(), m_activity.end(), [how_far, this](auto& c) -> bool { return (static_cast<dunedaq::trgdataformats::timestamp_diff_t>(c.time_start) < how_far); });
    m_activity.erase(end, m_activity.end());
  }

process()

void TCMakerSupernovaAlgorithm::process ( const TriggerActivity & activity, std::vector< TriggerCandidate > & cand )

virtual

The function that gets call when there is a new activity.

This decision maker just counts the number of activities in the time_window and triggers if the number of activities exceeds that.

Implements triggeralgs::TriggerCandidateMaker.

Definition at line 17 of file TCMakerSupernovaAlgorithm.cpp.

{
  timestamp_t time = activity.time_start;
  FlushOldActivity(time); // get rid of old activities in the buffer
  if (activity.inputs.size() > m_hit_threshold)
    m_activity.push_back(static_cast<TriggerActivity::TriggerActivityData>(activity));
 
  // Yay! we have a trigger!
  if (m_activity.size() > m_threshold) {
 
    detid_t detid = dunedaq::trgdataformats::WHOLE_DETECTOR;
 
    TriggerCandidate tc;
    tc.time_start = time - 500'000'000; // time_start (10 seconds before the start of the activity)
    tc.time_end = activity.time_end;  // time_end; but that should probably be _at least_ this number
    tc.time_candidate = time;
    tc.detid = detid;
    tc.type = m_tc_type_out; // type ( flag that says what type of trigger might be (e.g. SN/Muon/Beam) )
    tc.algorithm = TriggerCandidate::Algorithm::kSupernova; // algorithm ( flag that says which algorithm created the trigger (e.g. SN/HE/Solar) )
    tc.inputs =  m_activity;
 
    m_activity.clear();
    // Give the trigger word back
    cand.push_back(tc);
  }
}

Member Data Documentation

m_activity

std::vector<TriggerActivity::TriggerActivityData> triggeralgs::TCMakerSupernovaAlgorithm::m_activity

protected

Definition at line 31 of file TCMakerSupernovaAlgorithm.hpp.

m_hit_threshold

std::atomic<uint16_t> triggeralgs::TCMakerSupernovaAlgorithm::m_hit_threshold = { 2 }

protected

Minimum number of primities in an activity.

Definition at line 37 of file TCMakerSupernovaAlgorithm.hpp.

{ 2 }; // NOLINT(build/unsigned)

m_threshold

std::atomic<uint16_t> triggeralgs::TCMakerSupernovaAlgorithm::m_threshold = { 3 }

protected

Minimum number of activities in the time window to issue a trigger.

Definition at line 35 of file TCMakerSupernovaAlgorithm.hpp.

{ 3 }; // NOLINT(build/unsigned)

m_time_window

std::atomic<int64_t> triggeralgs::TCMakerSupernovaAlgorithm::m_time_window = { 500'000'000 }

protected

Slinding time window to count activities.

Definition at line 33 of file TCMakerSupernovaAlgorithm.hpp.

{ 500'000'000 };

---

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

• /github/workspace/dunedaq/sourcecode/triggeralgs/include/triggeralgs/Supernova/TCMakerSupernovaAlgorithm.hpp
• /github/workspace/dunedaq/sourcecode/triggeralgs/src/TCMakerSupernovaAlgorithm.cpp