operationalLogicIf.hpp

Go to the documentation of this file.

#ifndef RTCKT_TELSUB_OPERATIONALLOGICIF_HPP
#define RTCKT_TELSUB_OPERATIONALLOGICIF_HPP
#include "rtctk/telSub/correlatorIf.hpp"
#include "rtctk/telSub/shmPublisherIf.hpp"
#include <rtctk/config.hpp>
 
#include <chrono>
#include <optional>
#include <string>
 
#include <numapp/numapolicies.hpp>
 
#include <rtctk/telSub/ddsWaitSetIf.hpp>
 
namespace rtctk::telSub {

struct ShmParams {
    // cppcheck-suppress-begin unusedStructMember
 
    std::string topic_name;
    size_t capacity;
    std::optional<numapp::MemPolicy> mem_policy;
 
    // cppcheck-suppress-end unusedStructMember
};

struct OperationalParams {
    std::chrono::milliseconds close_detach_delay = std::chrono::milliseconds(0);
    std::chrono::milliseconds correlator_poll_timeout = std::chrono::milliseconds(100);
    std::chrono::milliseconds monitor_report_interval = std::chrono::milliseconds(500);
    std::optional<numapp::NumaPolicies> processing_thread_policies = std::nullopt;
    std::optional<numapp::NumaPolicies> monitoring_thread_policies = std::nullopt;
};

class OperationalLogicIf {
public:
    virtual ~OperationalLogicIf() = default;

    struct LastError {
        std::optional<CorrelationError> correlation;
        ShmPublisherIf::PublisherError publish;
    };

    virtual void RunAsync() noexcept = 0;

    virtual void IdleAsync() noexcept = 0;

    virtual LastError GetLastError() const noexcept = 0;

    virtual uint64_t GetErrorCount() const noexcept = 0;
};
 
}  // namespace rtctk::telSub
 
#endif  // RTCKT_TELSUB_OPERATIONALLOGICIF_HPP