RawDataProcessorConcept.hpp

Go to the documentation of this file.

#ifndef DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_RAWDATAPROCESSORCONCEPT_HPP_
#define DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_RAWDATAPROCESSORCONCEPT_HPP_
 
#include "appfwk/DAQModule.hpp"
#include "daqdataformats/SourceID.hpp"
#include "appmodel/DataHandlerModule.hpp"
#include "opmonlib/MonitorableObject.hpp"
 
#include <string>
 
namespace dunedaq {
namespace datahandlinglibs {
 
template<class ReadoutType>
class RawDataProcessorConcept : public opmonlib::MonitorableObject
{
public:
  RawDataProcessorConcept(){}
  virtual ~RawDataProcessorConcept() {}
  
  RawDataProcessorConcept(const RawDataProcessorConcept&) =
    delete; 
  RawDataProcessorConcept& operator=(const RawDataProcessorConcept&) =
    delete;                                                    
  RawDataProcessorConcept(RawDataProcessorConcept&&) = delete; 
  RawDataProcessorConcept& operator=(RawDataProcessorConcept&&) =
    delete; 

  virtual void start(const appfwk::DAQModule::CommandData_t& args) = 0;
  virtual void stop(const appfwk::DAQModule::CommandData_t& args) = 0;
  virtual void conf(const appmodel::DataHandlerModule* conf) = 0;
  virtual void scrap(const appfwk::DAQModule::CommandData_t& args) = 0;
  virtual std::uint64_t get_last_daq_time() = 0; // NOLINT(build/unsigned)
  virtual void preprocess_item(ReadoutType* item) = 0;
  virtual void postprocess_item(const ReadoutType* item) = 0;
  virtual void invoke_postprocess_schedule_timeout_policy(std::uint64_t accumulated_timeout_ticks) = 0;
 
};
 
} // namespace datahandlinglibs
} // namespace dunedaq
 
#endif // DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_RAWDATAPROCESSORCONCEPT_HPP_