TimingMasterControllerBase.hpp

Go to the documentation of this file.

 
#ifndef TIMINGLIBS_PLUGINS_TIMINGMASTERCONTROLLERBASE_HPP_
#define TIMINGLIBS_PLUGINS_TIMINGMASTERCONTROLLERBASE_HPP_
 
#include "timinglibs/TimingController.hpp"
#include "timinglibs/dal/TimingMasterControllerConf.hpp"
 
#include "timinglibs/timingcmd/Nljs.hpp"
#include "timinglibs/timingcmd/Structs.hpp"
 
#include "appfwk/DAQModule.hpp"
#include "ers/Issue.hpp"
#include "logging/Logging.hpp" // NOTE: if ISSUES ARE DECLARED BEFORE include logging/Logging.hpp, TLOG_DEBUG<<issue wont work.
#include "utilities/WorkerThread.hpp"
 
#include <memory>
#include <string>
#include <vector>
 
namespace dunedaq {
ERS_DECLARE_ISSUE(timinglibs,                                               
                  TimingMasterNotReady,                                     
                  master << " timing master did not become ready in time.", 
                  ((std::string)master))                                    
namespace timinglibs {

class TimingMasterControllerBase : public dunedaq::timinglibs::TimingController
{
public:
  explicit TimingMasterControllerBase(const std::string& name);
 
  TimingMasterControllerBase(const TimingMasterControllerBase&) =
    delete; 
  TimingMasterControllerBase& operator=(const TimingMasterControllerBase&) =
    delete; 
  TimingMasterControllerBase(TimingMasterControllerBase&&) =
    delete; 
  TimingMasterControllerBase& operator=(TimingMasterControllerBase&&) =
    delete; 
  virtual ~TimingMasterControllerBase()
  {
    if (endpoint_scan_thread.thread_running())
      endpoint_scan_thread.stop_working_thread();
  }
 
protected:
  // Commands
  void do_configure(const CommandData_t&) override;
  void do_start(const CommandData_t& data) override;
  void do_stop(const CommandData_t& data) override;
  void send_configure_hardware_commands(const CommandData_t& data) override;
 
  // timing master commands
  void do_master_set_timestamp(const CommandData_t&);
  void do_master_set_endpoint_delay(const CommandData_t& data);
  void do_master_send_fl_command(const CommandData_t& data);
  void do_master_measure_endpoint_rtt(const CommandData_t& data);
  void do_master_endpoint_scan(const CommandData_t& data);
 
  // pass op mon info
  //  void get_info(opmonlib::InfoCollector& ci, int level) override;
 
  timingcmd::TimingEndpointLocations m_monitored_endpoint_locations;
  uint m_endpoint_scan_period; // NOLINT(build/unsigned)
  dunedaq::utilities::WorkerThread endpoint_scan_thread;
  virtual void endpoint_scan(std::atomic<bool>&);
};
} // namespace timinglibs
} // namespace dunedaq
 
#endif // TIMINGLIBS_PLUGINS_TIMINGMASTERCONTROLLERBASE_HPP_
 
// Local Variables:
// c-basic-offset: 2
// End: