generic.hpp

Go to the documentation of this file.

 
#ifndef SUP_SYSSUP_COMMON_GENERIC_HPP
#define SUP_SYSSUP_COMMON_GENERIC_HPP
 
#include <rad/mal/requestor.hpp>
#include <rad/mal/subscriber.hpp>
 
#include <ifw/sup/syssup/common/subsys.hpp>
#include <ifw/sup/syssup/common/subsysFactory.hpp>
#include <ifw/sup/syssup/common/dataContext.hpp>
 
 
#include <Stdif.hpp>
 
namespace ifw::sup::syssup::common {
   
  class Config;
 
 
  class Generic : public Subsys::Registrar<Generic> {
  public:
    Generic(const std::string name,
            Config&  config,
            DataContext& data_ctx);
 
    virtual ~Generic();
 
    virtual bool IsNotReady() const override;
    virtual bool IsReady() const override;
 
    virtual bool IsOperational() const override;
 
    virtual void CheckSubsysFailure() const override;
 
    virtual bool IsDisabling() const override;
 
    virtual std::optional<elt::mal::future<void>> Connect() override;
    
    virtual void Close() override;
    virtual elt::mal::future<std::string> Init() override;
 
    virtual elt::mal::future<std::string> Enable() override;
 
    virtual elt::mal::future<std::string> Disable() override;
 
    virtual elt::mal::future<std::string> Stop() override;
 
    virtual elt::mal::future<std::string> GetState() override;
 
    virtual elt::mal::future<std::string> GetStatus() override;
 
    virtual elt::mal::future<std::string> GetVersion() override;
 
    virtual elt::mal::future<std::string> Reset() override;
 
 
    virtual void Ignore(rad::AnyEvent const& last_event) override;
 
    virtual void StopIgn(rad::AnyEvent const& last_event) override;
 
    virtual void SubsysReset(rad::AnyEvent const& last_event) override;
 
    virtual void SubsysInit(rad::AnyEvent const& last_event) override;
 
    virtual void SubsysEnable(rad::AnyEvent const& last_event) override;
 
    virtual void SubsysDisable(rad::AnyEvent const& last_event) override;
 
    virtual void Setup(const std::any& payload) override;
 
    virtual void Status(const std::string& payload, std::string& buffer) override;
 
    virtual std::string GetName() const override;
 
    std::string GetPrefixName() const;
 
    std::string GetScopeStr() const;
 
    bool GetAccess() const;
 
    void SetAccess(const bool& access);
 
 
  protected:
 
    bool IsMsgForMe(const std::string& id) const;
 
    void UpdateDb(std::vector<std::string> attr_vector);
 
    void UpdateConfig() override;
 
    void SetIgnore(bool flag);
 
 
    void GetPrefix(const std::vector<std::string> prefix_list, std::string& prefix);
 
    bool CheckNameParam(const std::any& payload);
 
  protected:
    void StartSubscription() override;
 
    void StopSubscription();
 
 
  public:
      std::atomic<bool> m_initiated_connection {false};
      
  protected:
    std::string                m_name; 
    Config&                    m_config; 
    DataContext&               m_data_ctx; 
    Dispatcher<stdif::StdCmdsAsync> m_dispatcher;
 
    elt::mal::rr::ListenerRegistration m_connection_listener;
    std::unique_ptr<rad::cii::Subscriber<stdif::Status>> m_subscriber;
   
 
  private:
    log4cplus::Logger  m_logger;
 
  };
 
}
 
 
#endif //SUP_SYSSUP_COMMON_GENERIC_HPP