SourceConcept.hpp

Go to the documentation of this file.

 
#ifndef ASIOLIBS_SRC_SOURCECONCEPT_HPP_
#define ASIOLIBS_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 asiolibs {
 
    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_target_payload_size() const = 0;
 
      void set_sink_config(const appmodel::DataMoveCallbackConf* sink_conf) 
      { 
    m_sink_conf = sink_conf; 
      }
 
      const appmodel::DataMoveCallbackConf* m_sink_conf;
    };
 
  } // namespace asiolibs
} // namespace dunedaq
 
#endif // ASIOLIBS_SRC_SOURCECONCEPT_HPP_