stateMachine.hpp

Go to the documentation of this file.

#ifndef OCM_SERVER_DAQ_STATE_MACHINE_HPP
#define OCM_SERVER_DAQ_STATE_MACHINE_HPP

#include <list>
#include <functional>

//#include <gsl/span>
#include <rad/AnyEvent.hpp>
#include <rad/Dispatcher.hpp>
#include <rad/ActionMgr.hpp>
#include <scxml4cpp/Action.h>
#include <scxml4cpp/Activity.h>
#include <scxml4cpp/Context.h>
#include <scxml4cpp/EventQueue.h>
#include <scxml4cpp/Executor.h>
#include <scxml4cpp/StateMachine.h>

namespace daq {
class Context : public scxml4cpp::Context {
public:
    Context(std::string daq_id);
    Context(Context const&) = delete;
    Context(Context &&) = default;

    std::string m_daq_id;
};



class StateMachine {
  public:
    explicit StateMachine(Context& ctx,
                          std::string const& model_file,
                          std::list<scxml4cpp::Action*>& actions,
                          std::list<scxml4cpp::Activity*>& activities);
    ~StateMachine();

    StateMachine(StateMachine&&) = default;
    StateMachine(StateMachine const&) = delete;
    StateMachine& operator=(StateMachine const&) = delete;


    void ProcessEvent(rad::AnyEvent const& ev);

  private:
    Context& m_context;
    scxml4cpp::EventQueue m_event_queue;
    scxml4cpp::StateMachine m_model;
    scxml4cpp::Executor m_executor;
    
};
    
class EventRegistry {
public:
    EventRegistry(rad::Dispatcher& dispatcher);
    ~EventRegistry();

    void RegisterEvents(std::vector<rad::EventInfo> const& events, StateMachine& sm);
    void UnregisterEvents();
   
    rad::Dispatcher& m_dispatcher; 
    std::vector<rad::Dispatcher::token_t> m_dispatcher_tokens;
};

class DaqSmManager {
public:
    rad::ActionMgr m_action_mgr;
    Context m_context;
    StateMachine m_sm;
};

std::function<StateMachine(std::string)>
MakeStateMachineFactory(Context& ctx,
                           std::string const& model_file,
                           std::list<scxml4cpp::Action*>& actions,
                           std::list<scxml4cpp::Activity*>& activities);

}
#endif  // #ifndef OCM_SERVER_DAQ_STATE_MACHINE_HPP