RawDataHandlerBase.hpp

Go to the documentation of this file.

 
#ifndef DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_DATALINKHANDLERBASE_HPP_
#define DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_DATALINKHANDLERBASE_HPP_
 
#include "datahandlinglibs/DataHandlingIssues.hpp"
#include "datahandlinglibs/concepts/DataHandlingConcept.hpp"
#include "datahandlinglibs/ReadoutLogging.hpp"
#include "daqdataformats/Types.hpp"
#include "logging/Logging.hpp"
 
#include "rcif/cmd/Nljs.hpp"
 
#include "appfwk/DAQModule.hpp"
#include "appfwk/ConfigurationManager.hpp"
#include "appmodel/DataHandlerModule.hpp"
 
#include <chrono>
#include <memory>
#include <string>
#include <vector>
 
namespace dunedaq {
namespace datahandlinglibs {
 
class RawDataHandlerBase
{
public:
  explicit RawDataHandlerBase(const std::string& name);
  virtual ~RawDataHandlerBase() {}
 
  RawDataHandlerBase(const RawDataHandlerBase&) = delete;            
  RawDataHandlerBase& operator=(const RawDataHandlerBase&) = delete; 
  RawDataHandlerBase(RawDataHandlerBase&&) = delete;                 
  RawDataHandlerBase& operator=(RawDataHandlerBase&&) = delete;      
 
  void init(std::shared_ptr<appfwk::ConfigurationManager> cfg);
  //  void get_info(opmonlib::InfoCollector& ci, int level);
 
  virtual std::shared_ptr<dunedaq::datahandlinglibs::DataHandlingConcept>
  create_readout(const appmodel::DataHandlerModule* modconf, std::atomic<bool>& run_marker) = 0;
 
  // Commands
  void do_conf(const appfwk::DAQModule::CommandData_t& /*args*/);
  void do_scrap(const appfwk::DAQModule::CommandData_t& /*args*/);
  void do_start(const appfwk::DAQModule::CommandData_t& /*args*/);
  void do_stop(const appfwk::DAQModule::CommandData_t& /*args*/);
  void do_record(const appfwk::DAQModule::CommandData_t& /*args*/);
 
  std::string get_dlh_name() { return m_name; }
 
private:
 
  // Configuration
  bool m_configured;
  daqdataformats::run_number_t m_run_number;
 
  // Name
  std::string m_name;
 
  // Internal
  std::shared_ptr<datahandlinglibs::DataHandlingConcept> m_readout_impl;
 
  // Threading
  std::atomic<bool> m_run_marker;
};
 
} // namespace datahandlinglibs
} // namespace dunedaq
 
// Declarations
#include "detail/RawDataHandlerBase.hxx"
 
#endif // DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_DATALINKHANDLERBASE_HPP_