recCmdsImpl.hpp

Go to the documentation of this file.

 
#ifndef CONTROL_RECCMDSIMPL_HPP_
#define CONTROL_RECCMDSIMPL_HPP_
 
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
 
#include <ccf/control/recCmds.rad.hpp>
 
namespace ccf::control {
 
class RecCmdsImpl : public recif::AsyncRecCmds {
 public:
    explicit RecCmdsImpl(rad::SMAdapter& sm) : m_sm(sm) { CCFTRACE; }
 
    virtual ~RecCmdsImpl() { CCFTRACE; }
 
    virtual elt::mal::future<std::string> RecAbort() override {
        CCFTRACE;
        auto ev = std::make_shared<RecCmds::RecAbort>();
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<recif::RecStatus>> RecContinue() override {
        CCFTRACE;
        auto ev = std::make_shared<RecCmds::RecContinue>();
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<recif::RecStatus>> RecPause() override {
        CCFTRACE;
        auto ev = std::make_shared<RecCmds::RecPause>();
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<recif::RecStatus>> RecStart(
        const std::shared_ptr<recif::RecProperties>& mal_param) override {
        CCFTRACE;
        auto ev = std::make_shared<RecCmds::RecStart>(mal_param->clone());
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<recif::RecStatus>> RecStatus(
        const std::string& mal_param) override {
        CCFTRACE;
        auto ev = std::make_shared<RecCmds::RecStatus>(mal_param);
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<recif::RecStatus>> RecStop() override {
        CCFTRACE;
        auto ev = std::make_shared<RecCmds::RecStop>();
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<recif::RecWaitStatus>> RecWait(
        const std::shared_ptr<recif::RecWaitSpec>& mal_param) override {
        CCFTRACE;
        auto ev = std::make_shared<RecCmds::RecWait>(mal_param->clone());
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
   
 private:
    rad::SMAdapter& m_sm;
};
 
} // namespace ccf::control
 
#endif // CONTROL_RECCMDSIMPL_HPP_