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