rtcObject.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_RTCSUPERVISOR_RTCOBJECT_HPP
#define RTCTK_RTCSUPERVISOR_RTCOBJECT_HPP
 
#include <rtctk/componentFramework/logger.hpp>
 
#include <Rtctkif.hpp>
#include <Stdif.hpp>
 
#include <optional>
#include <string>
 
#include <fmt/format.h>
 
namespace rtctk::rtcSupervisor {
 
struct RtcObjectInfo {
    std::string name;
 
    std::string rr_uri;
 
    std::string ps_uri;
};
 
enum class RtcCommand {
    STOP,
    INIT,
    RESET,
    ENABLE,
    DISABLE,
    EXIT,
    GET_STATE,
    GET_VERSION,
    UPDATE,
};
 
class RtcObjectIf {
public:
    virtual ~RtcObjectIf() = default;
 
    virtual RtcObjectInfo GetInfo() const = 0;
 
    virtual void RunAsync(RtcCommand cmd) = 0;
 
    virtual std::string WaitAsync(std::optional<unsigned> timeout) = 0;
};
 
class RtcObject : public RtcObjectIf {
public:
    RtcObject(RtcObjectInfo const& obj_info);
    virtual ~RtcObject() = default;
    RtcObjectInfo GetInfo() const override;
    void RunAsync(RtcCommand cmd) override;
    std::string WaitAsync(std::optional<unsigned> timeout) override;
 
private:
    log4cplus::Logger& m_logger;
 
    RtcObjectInfo m_info;
    // reference to the name for convenience purpose
    std::string const& m_name;
 
    std::shared_ptr<stdif::StdCmdsAsync> m_stdif_async;
    std::shared_ptr<rtctkif::UpdateCmdsAsync> m_ucif_async;
 
    elt::mal::future<std::string> m_reply_future;
 
    bool m_component_caused_exception;
};
 
}  // namespace rtctk::rtcSupervisor
 
template <>
struct fmt::formatter<rtctk::rtcSupervisor::RtcCommand> : formatter<string_view> {
    template <typename FormatContext>
    auto format(rtctk::rtcSupervisor::RtcCommand c, FormatContext& ctx) const {
        string_view name = "unknown";
        switch (c) {
        case rtctk::rtcSupervisor::RtcCommand::STOP:
            name = "STOP";
            break;
        case rtctk::rtcSupervisor::RtcCommand::INIT:
            name = "INIT";
            break;
        case rtctk::rtcSupervisor::RtcCommand::RESET:
            name = "RESET";
            break;
        case rtctk::rtcSupervisor::RtcCommand::ENABLE:
            name = "ENABLE";
            break;
        case rtctk::rtcSupervisor::RtcCommand::DISABLE:
            name = "DISABLE";
            break;
        case rtctk::rtcSupervisor::RtcCommand::EXIT:
            name = "EXIT";
            break;
        case rtctk::rtcSupervisor::RtcCommand::GET_STATE:
            name = "GET_STATE";
            break;
        case rtctk::rtcSupervisor::RtcCommand::GET_VERSION:
            name = "GET_VERSION";
            break;
        case rtctk::rtcSupervisor::RtcCommand::UPDATE:
            name = "UPDATE";
            break;
        }
        return formatter<string_view>::format(name, ctx);
    }  // format
};     // struct fmt::formatter
 
#endif  // RTCTK_RTCSUPERVISOR_RTCOBJECT_HPP