SourceEmulatorConcept.hpp

Go to the documentation of this file.

#ifndef DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_SOURCEEMULATORCONCEPT_HPP_
#define DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_SOURCEEMULATORCONCEPT_HPP_
 
#include "datahandlinglibs/utils/RateLimiter.hpp"
#include "confmodel/DetectorStream.hpp"
#include "appmodel/StreamEmulationParameters.hpp"
#include "appmodel/DataMoveCallbackConf.hpp"
#include "opmonlib/MonitorableObject.hpp"
 
#include <map>
#include <string>
#include <thread>
 
namespace dunedaq {
namespace datahandlinglibs {
 
class SourceEmulatorConcept : public opmonlib::MonitorableObject
{
public:
  SourceEmulatorConcept() {}
 
  virtual ~SourceEmulatorConcept() {}
  SourceEmulatorConcept(const SourceEmulatorConcept&) = delete; 
  SourceEmulatorConcept& operator=(const SourceEmulatorConcept&) =
    delete;                                                
  SourceEmulatorConcept(SourceEmulatorConcept&&) = delete; 
  SourceEmulatorConcept& operator=(SourceEmulatorConcept&&) = delete; 
 
  virtual void conf(const confmodel::DetectorStream* conf, const appmodel::StreamEmulationParameters* emu_conf) = 0;
  virtual void start(const appfwk::DAQModule::CommandData_t& /*args*/) = 0;
  virtual void stop(const appfwk::DAQModule::CommandData_t& /*args*/) = 0;
  virtual void scrap(const appfwk::DAQModule::CommandData_t& /*args*/) = 0;
  virtual bool is_configured() = 0;
  
  void set_sink_config(const appmodel::DataMoveCallbackConf* sink_conf) { m_sink_conf = sink_conf; }
  virtual void acquire_callback() = 0;
  const appmodel::DataMoveCallbackConf* m_sink_conf;
 
private:
};
 
} // namespace datahandlinglibs
} // namespace dunedaq
 
#endif // DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_CONCEPTS_SOURCEEMULATORCONCEPT_HPP_