operationalLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCKT_TELSUB_OPERATIONALLOGIC_HPP
#define RTCKT_TELSUB_OPERATIONALLOGIC_HPP
#include <atomic>
#include <mutex>
#include <chrono>
#include <optional>
#include <thread>
 
#include "operationalLogicIf.hpp"
#include "shmPublisherIf.hpp"
#include "correlatorIf.hpp"
 
namespace rtctk::telSub {
 
class OperationalLogic final : public OperationalLogicIf {
public:
    OperationalLogic(OperationalParams params,
                     std::unique_ptr<CorrelatorIf>&& correlator,
                     std::unique_ptr<ShmPublisherIf>&& shm_publisher);
 
    ~OperationalLogic();
 
    void RunAsync() RTCTK_NOEXCEPT override;
 
    void IdleAsync() RTCTK_NOEXCEPT override;
 
    std::error_code 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();
 
    OperationalParams const m_params;
    std::mutex mutable m_error_mutex;
    std::error_code m_last_error;
    uint64_t m_error_count;
    std::thread m_monitoring_thread;
    std::atomic<State> m_requested_state;
    std::unique_ptr<CorrelatorIf> m_correlator;
    std::unique_ptr<ShmPublisherIf> m_shm_publisher;
    std::thread m_processing_thread;
};
 
}  // namespace rtctk::telSub
#endif  // #ifndef RTCKT_TELSUB_OPERATIONALLOGIC_HPP