NaiveRunSumProcessor.cpp

Go to the documentation of this file.

 
#include "tpglibs/NaiveRunSumProcessor.hpp"
 
namespace tpglibs {
 
REGISTER_NAIVEPROCESSOR_CREATOR("NaiveRunSumProcessor", NaiveRunSumProcessor)
 
void NaiveRunSumProcessor::configure(const nlohmann::json& config, const int16_t* plane_numbers) {
  // Configure common metric collection parameters
  // Register pointers to the ACTUAL member variables, not copies
  // Use shared_ptr with no-op deleter to avoid double-free
  m_internal_state_name_registry.register_internal_state("r", 
    std::shared_ptr<naive_array_t>(&m_memory_factor, [](auto*){}));
  m_internal_state_name_registry.register_internal_state("s", 
    std::shared_ptr<naive_array_t>(&m_scale_factor, [](auto*){}));
  m_internal_state_name_registry.register_internal_state("rs", 
    std::shared_ptr<naive_array_t>(&m_running_sum, [](auto*){}));
    
  configure_internal_state_collection(config);
 
  int16_t config_memory[3] = {config["memory_factor_plane0"],
                              config["memory_factor_plane1"],
                              config["memory_factor_plane2"]};
  int16_t config_scale[3]  = {config["scale_factor_plane0"],
                              config["scale_factor_plane1"],
                              config["scale_factor_plane2"]};
 
  for (int i = 0; i < 16; i++) {
    m_memory_factor[i] = config_memory[plane_numbers[i]];
    m_scale_factor[i] = config_scale[plane_numbers[i]];
  }
}
 
NaiveRunSumProcessor::naive_array_t NaiveRunSumProcessor::process(const naive_array_t& signal) {
  // Update sample counter and write internal states to buffer for harvesting
  m_samples++;
  if (m_collect_internal_state_flag && (m_samples % m_sample_period == 0)) {
    m_internal_state_buffer_manager.write_to_active_buffer();
  }
 
  for (int i = 0; i < 16; i++) {
    int32_t scaled_rs = _naive_div_int16(m_running_sum[i], 10);
    scaled_rs *= m_memory_factor[i];
 
    int32_t scaled_signal = _naive_div_int16(signal[i], 10);
    scaled_signal *= m_scale_factor[i];
 
    int32_t intermediate = scaled_signal + scaled_rs;
    m_running_sum[i] = std::min(intermediate, INT16_MAX);
  }
  return NaiveProcessor::process(m_running_sum);
}
 
} // namespace tpglibs