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::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;
 
    // Meant to process an incoming raw byte buffer and extract complete frames of arbitrary types in specialized models.
    virtual void handle_daq_frame(char* buffer) = 0;
    virtual std::size_t get_expected_frame_size() const = 0;
 
    void set_sink_config(const appmodel::DataMoveCallbackConf* sink_conf) 
    { 
      m_sink_conf = sink_conf; 
    }
 
    // Sink or destination related
    const appmodel::DataMoveCallbackConf* m_sink_conf;
  };
 
} // namespace dunedaq::asiolibs
 
#endif // ASIOLIBS_SRC_SOURCECONCEPT_HPP_