loopCmdsImpl.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_LOOPCMDSIMPL_HPP
#define RTCTK_COMPONENTFRAMEWORK_LOOPCMDSIMPL_HPP
 
#include <Rtctkif.hpp>
#include <rtctk/componentFramework/commandReplier.hpp>
#include <rtctk/componentFramework/events.rad.hpp>
#include <rtctk/componentFramework/logger.hpp>
#include <rtctk/componentFramework/malEventInjector.hpp>
#include <rtctk/componentFramework/stateMachineEngine.hpp>
 
#include <mal/Cii.hpp>
 
#include <memory>
#include <string>
 
namespace rtctk::componentFramework {
 
class LoopCmdsImpl : public rtctkif::AsyncLoopCmds {
public:
    static void Register(CommandReplier& replier, StateMachineEngine& engine) {
        std::shared_ptr<elt::mal::rr::RrEntity> rr_service = std::make_shared<LoopCmdsImpl>(engine);
        replier.RegisterService<rtctkif::AsyncLoopCmds>("LoopCmds", rr_service);
    }
 
    LoopCmdsImpl(StateMachineEngine& engine) : m_engine(engine) {
    }
 
    ::elt::mal::future<std::string> Open() override {
        LOG4CPLUS_TRACE(GetLogger(), "Received command 'Open'");
        return InjectReqRepEvent<events::Open>(m_engine);
    }
 
    ::elt::mal::future<std::string> Close() override {
        LOG4CPLUS_TRACE(GetLogger(), "Received command 'Close'");
        return InjectReqRepEvent<events::Close>(m_engine);
    }
 
private:
    StateMachineEngine& m_engine;
};
 
}  // namespace rtctk::componentFramework
 
#endif