deviceFacade.hpp

Go to the documentation of this file.

#ifndef DEVMGR_COMMON_DEVICE_FACADE_HPP_
#define DEVMGR_COMMON_DEVICE_FACADE_HPP_

// System headers
#include <list>

// Local headers
#include <rad/SMAdapter.hpp>
#include <rad/TopicPub.hpp>
#include <rad/AnyEvent.hpp>
#include <rad/Activity.hpp>

#include <fcf/common/dispatcher.hpp>
#include <devmgr/common/device.hpp>
#include <devmgr/modif/requests.pb.h>
#include <devmgr/common/events.rad.hpp>


namespace devmgr {
  namespace common {

    class Config;
    class IDevice;
    
    class DeviceFacade {
    public:
      DeviceFacade(rad::SMAdapter& sm,
                   IConfig& config,
                   fcf::common::Dispatcher<>& failure,
                   fcf::common::Dispatcher<>& normal);

      virtual     ~DeviceFacade();

      virtual bool Init(rad::SMAdapter& sm, rad::Activity* activity);

      virtual bool Enable(rad::SMAdapter& sm, rad::Activity* activity);

      virtual bool Recover(rad::SMAdapter& sm, rad::Activity* activity);
      virtual bool Disable();

      virtual bool Setup(modif::ReqSetup setupMsg,
                         modif::TaskId& taskId,
                         rad::Activity* activity);
      virtual bool Stop();

      virtual bool Reset();

      virtual bool Status(modif::ReqStatus& statusMsg, std::string& buffer);


      virtual void Simulate(modif::ReqSimulate& msg);

      virtual void StopSim(modif::ReqStopSim& msg);

      virtual void Ignore(modif::ReqIgnore& msg);

      virtual void StopIgn(modif::ReqStopIgn& msg);

      virtual bool HwReset(modif::ReqHwReset& hwResetMsg);

      virtual bool HwInit(modif::ReqHwInit& hwInitMsg);

      virtual bool HwEnable(modif::ReqHwEnable& hwEnableMsg);

      virtual bool HwDisable(modif::ReqHwDisable& hwDisableMsg);

      virtual bool BeginAcq(modif::ReqBeginAcq& beginAcqMsg);

      virtual bool EndAcq(modif::ReqEndAcq& endAcqMsg);

      void    TriggerInternalEvent(rad::SMAdapter& sm, rad::UniqueEvent&& e);

      void    AddDevice(std::shared_ptr<IDevice> device);

      void    ClearDevices();

      fcf::common::Dispatcher<>& GetFailureCB();

      fcf::common::Dispatcher<>& GetNormalCB();

      const int GetNumDevices();

    private:

      DeviceFacade(const DeviceFacade&) = delete;             
      DeviceFacade& operator= (const DeviceFacade&) = delete; 

      void InitSync(rad::Activity* activity,
                    std::chrono::system_clock::time_point start_time,
                    bool& stopped,
                    bool& timeout);

      void EnableSync(rad::Activity* activity,
                    std::chrono::system_clock::time_point start_time,
                    bool& stopped,
                    bool& timeout);

      void DeviceFailureCB();

      void DeviceNormalCB();

      std::list<std::shared_ptr<IDevice> >  m_devices;   
      boost::asio::io_service               m_ios;       
      rad::SMAdapter&                       m_sm;        
      IConfig&                              m_config;
      std::shared_ptr<rad::TopicPub>        m_publisher; 
      std::string                           m_dp_filename; 

      fcf::common::Dispatcher<>   m_failure;

      fcf::common::Dispatcher<>   m_normal;
    };
  }
}  // namespace devmgr::Common

#endif  // DEVMGR_COMMON_DEVICE_FACADE_HPP_