AbstractProcessor.hpp

Go to the documentation of this file.

 
#ifndef TPGLIBS_ABSTRACTPROCESSOR_HPP_
#define TPGLIBS_ABSTRACTPROCESSOR_HPP_
 
#include <cstdint>
#include <nlohmann/json.hpp>
#include <memory>
#include "tpglibs/ProcessorMetricArray.hpp"
#include "tpglibs/ProcessorMetricCollector.hpp"
 
namespace tpglibs {
 
template <class T>
class AbstractProcessor {
  std::shared_ptr<AbstractProcessor<T>> m_next_processor;
 
  public:
    using signal_type_t = T;
 
    virtual ~AbstractProcessor() = default;
 
    virtual void configure(const nlohmann::json& config, const int16_t* plane_numbers) = 0;
 
    void set_next_processor(std::shared_ptr<AbstractProcessor<T>> next_processor) {
      m_next_processor = next_processor;
    }
 
    virtual T process(const T& signal) {
      if (m_next_processor) {
        return m_next_processor->process(signal);
      }
      return signal;
    }
 
    virtual void save_metric_to_store_buffer() {}
 
    virtual std::vector<std::string> get_metric_items() {
      return {};
    }
 
    virtual ProcessorMetricArray<signal_type_t> read_from_metric_store_buffer() {
      return {};
    }
 
    virtual void attach_to_metric_collector(ProcessorMetricCollector<signal_type_t>& collector, size_t pipeline_id) {
      collector.attach_processor(*this, pipeline_id);
      if (m_next_processor == nullptr) return;
      m_next_processor->attach_to_metric_collector(collector, pipeline_id);
    }
};
 
} // namespace tpglibs
 
#endif // TPGLIBS_ABSTRACTPROCESSOR_HPP_