triggeralgs::TAMakerDBSCANAlgorithm Class Reference

#include <TAMakerDBSCANAlgorithm.hpp>

Inheritance diagram for triggeralgs::TAMakerDBSCANAlgorithm:

Collaboration diagram for triggeralgs::TAMakerDBSCANAlgorithm:

Public Member Functions
void	process (const TriggerPrimitive &input_tp, std::vector< TriggerActivity > &output_ta)
	TP processing function that creates & fills TAs.
void	configure (const nlohmann::json &config)
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 Attributes
int	m_eps {10}
int	m_min_pts {3}
timestamp_t	m_first_timestamp {0}
timestamp_t	m_prev_timestamp {0}
std::vector< dbscan::Cluster >	m_dbscan_clusters
std::unique_ptr< dbscan::IncrementalDBSCAN >	m_dbscan

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 19 of file TAMakerDBSCANAlgorithm.hpp.

Member Function Documentation

configure()

void TAMakerDBSCANAlgorithm::configure ( const nlohmann::json & config )

virtual

Reimplemented from triggeralgs::TriggerActivityMaker.

Definition at line 76 of file TAMakerDBSCANAlgorithm.cpp.

{
  TriggerActivityMaker::configure(config);
 
  if (config.is_object())
  {
    if (config.contains("min_pts"))
      m_min_pts = config["min_pts"];
    if (config.contains("eps"))
      m_eps = config["eps"];
  }
  m_dbscan=std::make_unique<dbscan::IncrementalDBSCAN>(m_eps, m_min_pts, 10000);
}

process()

void TAMakerDBSCANAlgorithm::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 25 of file TAMakerDBSCANAlgorithm.cpp.

{
  if(input_tp.time_start < m_prev_timestamp){
    TLOG_DEBUG(TLVL_DEBUG_LOW) << "[TAM:DBS] Out-of-order TPs: prev " << m_prev_timestamp << ", current " << input_tp.time_start;
    return;
  }
  
  m_dbscan_clusters.clear();
  m_dbscan->add_primitive(input_tp, &m_dbscan_clusters);
 
  uint64_t t0=m_dbscan->get_first_prim_time();
  
  for(auto const& cluster : m_dbscan_clusters){
    auto& ta=output_ta.emplace_back();
 
    ta.time_start = std::numeric_limits<timestamp_t>::max();
    ta.time_end = 0;
    ta.channel_start = std::numeric_limits<channel_t>::max();
    ta.channel_end = 0;
    ta.adc_integral =  0;
    
    for(auto const& hit : cluster.hits){
      auto const& prim=hit->primitive;
 
      ta.inputs.push_back(prim);
      
      ta.time_start = std::min(prim.time_start, ta.time_start);
      ta.time_end = std::max(prim.time_start + prim.samples_over_threshold * 32, ta.time_end);  // FIXME: Replace the hard-coded SOT to TOT scaling.
 
      ta.channel_start = std::min(channel_t(prim.channel), ta.channel_start);
      ta.channel_end = std::max(channel_t(prim.channel), ta.channel_end);
 
      ta.adc_integral += prim.adc_integral;
 
      ta.detid = prim.detid;
      if (prim.adc_peak > ta.adc_peak) {
        ta.adc_peak = prim.adc_peak;
        ta.channel_peak = prim.channel;
        ta.time_peak = prim.samples_to_peak * 32 + prim.time_start;  // FIXME: Replace hard-coded STP to `time_peak` conversion.
      }
    }
    ta.time_activity = ta.time_peak;
 
    ta.type = TriggerActivity::Type::kTPC;
    ta.algorithm = TriggerActivity::Algorithm::kDBSCAN;
  }
 
  m_dbscan->trim_hits();
}

Member Data Documentation

m_dbscan

std::unique_ptr<dbscan::IncrementalDBSCAN> triggeralgs::TAMakerDBSCANAlgorithm::m_dbscan

private

Definition at line 33 of file TAMakerDBSCANAlgorithm.hpp.

m_dbscan_clusters

std::vector<dbscan::Cluster> triggeralgs::TAMakerDBSCANAlgorithm::m_dbscan_clusters

private

Definition at line 32 of file TAMakerDBSCANAlgorithm.hpp.

m_eps

int triggeralgs::TAMakerDBSCANAlgorithm::m_eps {10}

private

Definition at line 28 of file TAMakerDBSCANAlgorithm.hpp.

{10};

m_first_timestamp

timestamp_t triggeralgs::TAMakerDBSCANAlgorithm::m_first_timestamp {0}

private

Definition at line 30 of file TAMakerDBSCANAlgorithm.hpp.

{0};

m_min_pts

int triggeralgs::TAMakerDBSCANAlgorithm::m_min_pts {3}

private

Definition at line 29 of file TAMakerDBSCANAlgorithm.hpp.

{3}; // Minimum number of points to form a cluster

m_prev_timestamp

timestamp_t triggeralgs::TAMakerDBSCANAlgorithm::m_prev_timestamp {0}

private

Definition at line 31 of file TAMakerDBSCANAlgorithm.hpp.

{0};

---

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

• /github/workspace/dunedaq/sourcecode/triggeralgs/include/triggeralgs/dbscan/TAMakerDBSCANAlgorithm.hpp
• /github/workspace/dunedaq/sourcecode/triggeralgs/src/TAMakerDBSCANAlgorithm.cpp