SourceConcept.hpp

Go to the documentation of this file.

 
#ifndef CRTMODULES_SRC_SOURCECONCEPT_HPP_
#define CRTMODULES_SRC_SOURCECONCEPT_HPP_
 
//#include "DefaultParserImpl.hpp"
 
#include "opmonlib/MonitorableObject.hpp"
#include "appfwk/DAQModule.hpp"
#include "appmodel/DataMoveCallbackConf.hpp"
//#include "packetformat/detail/block_parser.hpp"
#include <nlohmann/json.hpp>
 
#include <memory>
#include <sstream>
#include <string>
 
namespace dunedaq {
  namespace crtmodules {
 
    class SourceConcept : public opmonlib::MonitorableObject
    {
    public:
      SourceConcept() {}
      virtual ~SourceConcept() {}
 
      SourceConcept(const SourceConcept&) = delete;            
      SourceConcept& operator=(const SourceConcept&) = delete; 
      SourceConcept(SourceConcept&&) = delete;                 
      SourceConcept& operator=(SourceConcept&&) = delete;      
 
      //  virtual void init(const nlohmann::json& args) = 0;
      virtual void acquire_callback() = 0;
      //  virtual void conf(const nlohmann::json& args) = 0;
      //  virtual void start(const nlohmann::json& args) = 0;
      //  virtual void stop(const nlohmann::json& args) = 0;
 
      virtual bool handle_payload(char* message, std::size_t size) = 0;
      virtual std::size_t get_frame_size() const = 0;
 
      void set_sink_config(const appmodel::DataMoveCallbackConf* sink_conf) { m_sink_conf = sink_conf; }
 
      const appmodel::DataMoveCallbackConf* m_sink_conf;
    };
 
  } // namespace crtmodules
} // namespace dunedaq
 
#endif // CRTMODULES_SRC_SOURCECONCEPT_HPP_