telRepubBusinessLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_TELREPUB_TELREPUBBUSINESSLOGIC_HPP
#define RTCTK_REUSABLECOMPONENT_TELREPUB_TELREPUBBUSINESSLOGIC_HPP
 
#include <fastdds/dds/publisher/DataWriter.hpp>
#include <rtctk/componentFramework/ddsPub.hpp>
#include <rtctk/telRepub/wrangler.hpp>
 
#include "numapp/numapolicies.hpp"
#include "rtctk/componentFramework/componentMetricsIf.hpp"
#include "rtctk/componentFramework/logger.hpp"
#include "rtctk/componentFramework/rtcComponent.hpp"
#include "rtctk/componentFramework/runnable.hpp"
#include <rtctk/componentFramework/alertServiceIf.hpp>
#include <rtctk/componentFramework/runtimeRepoIf.hpp>
 
#include <rad/logger.hpp>
#include <rad/mal/utils.hpp>
 
#include <cstdint>
 
namespace rtctk::telRepub {
 
using namespace rtctk::componentFramework;
 
using LifeCycle = Runnable<RtcComponent>;
 
using RepubWranglerFactory = std::function<WranglerFunction(int32_t)>;
 
class PubThread;
 
class PubThreadMudpi;
 
class MudpiProcessor;
 
class UdpReceiver;
 
class TelRepubBusinessLogic : public LifeCycle::BizLogicIf {
public:
    using ComponentType = LifeCycle;
    TelRepubBusinessLogic(
        std::string name, ServiceContainer& service, RepubWranglerFactory&& factory = [](auto x) {
            return nullptr;
        });
 
    virtual ~TelRepubBusinessLogic();
 
    void ActivityStarting(StopToken st) override;
 
    void ActionClearAlerts() override;
 
    void ActivityRecovering(StopToken st) override;
 
    void ActivityInitialising(StopToken st) override;
 
    void ActivityEnabling(StopToken st) override;
 
    void ActivityDisabling(StopToken st) override;
 
    void ActivityGoingRunning(StopToken st) override;
 
    void ActivityGoingIdle(StopToken st) override;
 
    void ActivityRunning(StopToken st) override;
 
    void ActivityUpdating(StopToken st, const JsonPayload& args) override;
 
    bool GuardUpdatingAllowed(const JsonPayload& args) override;
 
protected:
    void ReadGlobalCfg();
 
    void CreateMudpiReceivers();
 
    void DeleteMudpiReceivers();
 
    PubThreadMudpi& CreatePubThread(const std::string& dds_topic_path_static);
 
    void CreateSimPubThreads();
 
    void DeletePubThreads();
 
    void CreateDdsPubs();
 
    void DeleteDdsPubs();
 
    void Monitor();
 
    log4cplus::Logger& m_logger;
 
    const std::string m_name;
 
    std::unique_ptr<DdsPub> m_dds_pub;
 
    rtctk::componentFramework::ServiceContainer& m_service;
 
    componentFramework::RuntimeRepoIf& m_rtr;
 
    componentFramework::ComponentMetricsIf& m_metrics;
 
    AlertServiceIf& m_alerts;
 
    std::vector<std::unique_ptr<UdpReceiver>> m_udp_receivers;
 
    std::vector<std::unique_ptr<PubThread>> m_pub_threads;
 
    RepubWranglerFactory m_wrangler_factory;
 
    std::chrono::milliseconds m_monitor_report_interval_ms = std::chrono::milliseconds(1000);
 
    std::optional<numapp::NumaPolicies> monitoring_thread_policies = std::nullopt;
};
 
}  // namespace rtctk::telRepub
 
#endif  // RTCTK_REUSABLECOMPONENT_TELREPUB_TELREPUBBUSINESSLOGIC_HPP