FakeCardReaderBase.hpp

Go to the documentation of this file.

#ifndef DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_FAKECARDREADERBASE_HPP_
#define DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_FAKECARDREADERBASE_HPP_
 
// package
#include "datahandlinglibs/concepts/SourceEmulatorConcept.hpp"
 
#include "appmodel/DataReaderConf.hpp"
#include "appmodel/DataReaderModule.hpp"
#include "confmodel/Connection.hpp"
#include "confmodel/DaqModule.hpp"
#include "confmodel/DetDataSender.hpp"
#include "confmodel/DetectorStream.hpp"
#include "confmodel/DetectorToDaqConnection.hpp"
#include "confmodel/QueueWithSourceId.hpp"
 
#include "appfwk/ConfigurationManager.hpp"
#include "appfwk/DAQModule.hpp"
 
#include "datahandlinglibs/utils/FileSourceBuffer.hpp"
#include "utilities/ReusableThread.hpp"
 
#include "rcif/cmd/Nljs.hpp"
 
// std
#include <cstdint>
#include <fstream>
#include <map>
#include <memory>
#include <string>
#include <vector>
 
namespace dunedaq {
namespace datahandlinglibs {
 
class FakeCardReaderBase
{
public:
  explicit FakeCardReaderBase(const std::string& name);
  virtual ~FakeCardReaderBase() {}
 
  FakeCardReaderBase(const FakeCardReaderBase&) = delete;            
  FakeCardReaderBase& operator=(const FakeCardReaderBase&) = delete; 
  FakeCardReaderBase(FakeCardReaderBase&&) = delete;                 
  FakeCardReaderBase& operator=(FakeCardReaderBase&&) = delete;      
 
  void init(std::shared_ptr<appfwk::ConfigurationManager> cfg);
 
  // To be implemented by final module
  virtual std::shared_ptr<datahandlinglibs::SourceEmulatorConcept> create_source_emulator(
    const appmodel::DataMoveCallbackConf* cb,
    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*/);
 
  std::string get_fcr_name() { return m_name; }
 
private:
  // Configuration
  bool m_configured;
  std::string m_name;
  std::shared_ptr<appfwk::ConfigurationManager> m_cfg;
 
  std::map<std::string, std::shared_ptr<datahandlinglibs::SourceEmulatorConcept>> m_source_emus;
 
  // Internals
  std::unique_ptr<datahandlinglibs::FileSourceBuffer> m_source_buffer;
 
  // Threading
  std::atomic<bool> m_run_marker;
};
 
} // namespace datahandlinglibs
} // namespace dunedaq
 
// Declarations
#include "detail/FakeCardReaderBase.hxx"
 
#endif // DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_FAKECARDREADERBASE_HPP_