operationalLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCKT_TELSUB_OPERATIONALLOGIC_HPP
#define RTCKT_TELSUB_OPERATIONALLOGIC_HPP
#include <atomic>
#include <chrono>
#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::AlertSourceFactoryIf& alerts,
                     std::unique_ptr<std::pmr::monotonic_buffer_resource>&& resource = {},
                     std::unique_ptr<std::byte[]>&& memory = {});
 
    ~OperationalLogic() noexcept;
 
    void RunAsync() RTCTK_NOEXCEPT override;
 
    void IdleAsync() RTCTK_NOEXCEPT override;
 
    LastError GetLastError() const RTCTK_NOEXCEPT override;
    uint64_t GetErrorCount() const RTCTK_NOEXCEPT override;
 
private:
    enum class State : int { Idle = 0, Run, Exit };
 
    void ProcessingLoop();
    void MonitoringLoop();
 
    // 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;
 
    OperationalParams const m_params;
 
    std::mutex mutable m_error_mutex;
    std::error_code m_last_corr_error;
    std::error_code m_last_pub_error;
    uint64_t m_error_count;
    componentFramework::AlertSource m_input_alert;
    componentFramework::AlertSource m_output_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  // #ifndef RTCKT_TELSUB_OPERATIONALLOGIC_HPP