operationalLogic.hpp

Go to the documentation of this file.

#ifndef RTCKT_TELSUB_OPERATIONALLOGIC_HPP
#define RTCKT_TELSUB_OPERATIONALLOGIC_HPP
#include <atomic>
#include <mutex>
#include <optional>
#include <thread>
 
#include <rtctk/componentFramework/alertServiceIf.hpp>
#include <rtctk/componentFramework/componentMetricsIf.hpp>
#include <rtctk/telSub/correlatorIf.hpp>
#include <rtctk/telSub/operationalLogicIf.hpp>
#include <rtctk/telSub/shmPublisherIf.hpp>
 
namespace rtctk::telSub {

class OperationalLogic final : public OperationalLogicIf {
public:
    OperationalLogic(OperationalParams params,
                     std::unique_ptr<CorrelatorIf>&& correlator,
                     std::unique_ptr<ShmPublisherIf>&& shm_publisher,
                     componentFramework::ComponentMetricsIf& metrics,
                     componentFramework::AlertServiceIf& alerts,
                     std::unique_ptr<std::pmr::monotonic_buffer_resource>&& resource = {},
                     std::unique_ptr<std::byte[]>&& memory = {});

    ~OperationalLogic() noexcept override;

    void RunAsync() noexcept override;

    void IdleAsync() noexcept override;
 
    LastError GetLastError() const noexcept override;
    uint64_t GetErrorCount() const noexcept override;
 
private:
    enum class State : uint8_t { Idle = 0, Run, Exit };

    void ProcessingLoop();
    void MonitoringLoop();
 
    log4cplus::Logger& m_logger;
 
    // First members because other members might have memory allocated to these
    std::unique_ptr<std::byte[]> m_mem;
    std::unique_ptr<std::pmr::monotonic_buffer_resource> m_resource;
    componentFramework::ComponentMetricsIf& m_metrics;
 
    const OperationalParams m_params;


    std::mutex mutable m_error_mutex;
    std::optional<CorrelationError> m_last_corr_error;
    ShmPublisherIf::PublisherError m_last_pub_error;
    uint64_t m_error_count{0};
    componentFramework::AlertSource m_dds_alert;
    componentFramework::AlertSource m_correlator_alert;
    componentFramework::AlertSource m_blender_alert;
    componentFramework::AlertSource m_shm_alert;

    std::atomic<State> m_requested_state;
    std::unique_ptr<CorrelatorIf> m_correlator;
    std::unique_ptr<ShmPublisherIf> m_shm_publisher;
    std::thread m_processing_thread;
    std::thread m_monitoring_thread;
};
 
}  // namespace rtctk::telSub
 
#endif  // RTCKT_TELSUB_OPERATIONALLOGIC_HPP