AVXFrugalPedestalSubtractProcessor.hpp

Go to the documentation of this file.

 
#include "tpglibs/AVXFactory.hpp"
#include "tpglibs/ProcessorMetricArray.hpp"
#include <atomic>
#include <memory>
 
#ifndef TPGLIBS_AVXFRUGALPEDESTALSUBTRACTPROCESSOR_HPP_
#define TPGLIBS_AVXFRUGALPEDESTALSUBTRACTPROCESSOR_HPP_
 
namespace tpglibs {
 
class AVXFrugalPedestalSubtractProcessor : public AVXProcessor {
  protected:
    __m256i m_pedestal = _mm256_set1_epi16(0x4000);  // Set initial start to 14-bit max. Prevents garbage TPs at start.
 
    __m256i m_accum = _mm256_setzero_si256();
 
    int16_t m_accum_limit{10};
 
    uint64_t m_sample_period{512};
    uint64_t m_samples{0};
    bool m_collect_metric_flag{false};
 
  private:
    ProcessorMetricArray<__m256i> m_metric_store_buffers[2]{};
    // Initialize always to buffer 0 to make it safe, always points to one of buffer 0 and 1
    std::atomic<ProcessorMetricArray<__m256i>*> m_active_buffer = &m_metric_store_buffers[0];
 
    std::atomic<uint16_t>seq{0};
 
  public:
    AVXFrugalPedestalSubtractProcessor();
    ~AVXFrugalPedestalSubtractProcessor() noexcept;
 
    __m256i process(const __m256i& signal) override;
 
    void configure(const nlohmann::json& config, const int16_t* plane_numbers) override;
 
    void save_metric_to_store_buffer() override;
 
    virtual std::vector<std::string> get_metric_items() override;
 
    ProcessorMetricArray<__m256i> read_from_metric_store_buffer() override;
};
 
} // namespace tpglibs
 
#endif // TPGLIBS_AVXFRUGALPEDESTALSUBTRACTPROCESSOR_HPP_