triggeralgs::TAMakerBundleNAlgorithm Class Reference

#include <TAMakerBundleNAlgorithm.hpp>

Inheritance diagram for triggeralgs::TAMakerBundleNAlgorithm:

Collaboration diagram for triggeralgs::TAMakerBundleNAlgorithm:

Public Member Functions
void	process (const TriggerPrimitive &input_tp, std::vector< TriggerActivity > &output_tas)
	TP processing function that creates & fills TAs.
void	configure (const nlohmann::json &config)
bool	bundle_condition ()
Public Member Functions inherited from triggeralgs::TriggerActivityMaker
virtual	~TriggerActivityMaker ()=default
void	operator() (const TriggerPrimitive &input_tp, std::vector< TriggerActivity > &output_ta)
virtual bool	preprocess (const TriggerPrimitive &input_tp)
	TP pre-processing/filtering.
virtual void	postprocess (std::vector< TriggerActivity > &output_ta)
	Post-processing/filtering of the TAs, e.g. prescale.
virtual void	flush (timestamp_t, std::vector< TriggerActivity > &)

Private Member Functions
void	set_ta_attributes ()

Private Attributes
uint64_t	m_bundle_size = 1
TriggerActivity	m_current_ta

Additional Inherited Members
Public Attributes inherited from triggeralgs::TriggerActivityMaker
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_ta_count = 0
	TA made count for prescaling.
uint32_t	m_max_samples_over_threshold = std::numeric_limits<uint32_t>::max()
	Time-over-threshold TP filtering.

Detailed Description

Definition at line 18 of file TAMakerBundleNAlgorithm.hpp.

Member Function Documentation

bundle_condition()

bool triggeralgs::TAMakerBundleNAlgorithm::bundle_condition

(

)

Definition at line 47 of file TAMakerBundleNAlgorithm.cpp.

                                               {
  return m_current_ta.inputs.size() == m_bundle_size;
}

configure()

void triggeralgs::TAMakerBundleNAlgorithm::configure ( const nlohmann::json & config )

virtual

Reimplemented from triggeralgs::TriggerActivityMaker.

Definition at line 78 of file TAMakerBundleNAlgorithm.cpp.

{
  if (config.is_object() && config.contains("bundle_size")) {
    m_bundle_size = config["bundle_size"];
  }
}

process()

void triggeralgs::TAMakerBundleNAlgorithm::process ( const TriggerPrimitive & input_tp, std::vector< TriggerActivity > & output_ta )

virtual

TP processing function that creates & fills TAs.

Parameters

input_tp[in]	Input TP for the triggering algorithm
output_ta[out]	Output vector of TAs to fill by the algorithm

Implements triggeralgs::TriggerActivityMaker.

Definition at line 52 of file TAMakerBundleNAlgorithm.cpp.

{
  // Expect that TPs are inherently time ordered.
  m_current_ta.inputs.push_back(input_tp);
 
  if (bundle_condition()) {
    TLOG_DEBUG(TLVL_DEBUG_HIGH) << "[TA:BN] Emitting BundleN TA with " << m_current_ta.inputs.size() << " TPs.";
    set_ta_attributes();
    output_tas.push_back(m_current_ta);
 
    // Reset the current.
    m_current_ta = TriggerActivity();
  }
 
  // Should never reach this step. In this case, send it out.
  if (m_current_ta.inputs.size() > m_bundle_size) {
    TLOG_DEBUG(TLVL_IMPORTANT) << "[TA:BN] Emitting large BundleN TriggerActivity with " << m_current_ta.inputs.size() << " TPs.";
    set_ta_attributes();
    output_tas.push_back(m_current_ta);
 
    // Reset the current.
    m_current_ta = TriggerActivity();
  }
}

set_ta_attributes()

void triggeralgs::TAMakerBundleNAlgorithm::set_ta_attributes ( )

private

Definition at line 19 of file TAMakerBundleNAlgorithm.cpp.

                                                {
    // Using the first TA as reference.
    TriggerPrimitive first_tp = m_current_ta.inputs.front();
    TriggerPrimitive last_tp = m_current_ta.inputs.back();
 
    m_current_ta.channel_start = first_tp.channel;
    m_current_ta.channel_end = last_tp.channel;
 
    m_current_ta.time_start = first_tp.time_start;
    m_current_ta.time_end = last_tp.time_start;
 
    m_current_ta.detid = first_tp.detid;
 
    m_current_ta.algorithm = TriggerActivity::Algorithm::kBundle;
    m_current_ta.type = TriggerActivity::Type::kTPC;
 
    m_current_ta.adc_peak = 0;
    for (const TriggerPrimitive& tp : m_current_ta.inputs) {
      m_current_ta.adc_integral += tp.adc_integral;
      if (tp.adc_peak <= m_current_ta.adc_peak) continue;
      m_current_ta.adc_peak = tp.adc_peak;
      m_current_ta.channel_peak = tp.channel;
      m_current_ta.time_peak = tp.samples_to_peak * 32 + tp.time_start;  // FIXME: Replace STP to `time_peak` conversion.
    }
    m_current_ta.time_activity = m_current_ta.time_peak;
    return;
}

Member Data Documentation

m_bundle_size

uint64_t triggeralgs::TAMakerBundleNAlgorithm::m_bundle_size = 1

private

Definition at line 26 of file TAMakerBundleNAlgorithm.hpp.

m_current_ta

TriggerActivity triggeralgs::TAMakerBundleNAlgorithm::m_current_ta

private

Definition at line 27 of file TAMakerBundleNAlgorithm.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/triggeralgs/include/triggeralgs/BundleN/TAMakerBundleNAlgorithm.hpp
• /github/workspace/dunedaq/sourcecode/triggeralgs/src/TAMakerBundleNAlgorithm.cpp