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>
#include <variant>
 
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() {
    }
 
    struct LastError {
        std::optional<CorrelationError> correlation;
        ShmPublisherIf::PublisherError publish;
    };
 
    virtual void RunAsync() RTCTK_NOEXCEPT = 0;
 
    virtual void IdleAsync() RTCTK_NOEXCEPT = 0;
 
    virtual LastError GetLastError() const RTCTK_NOEXCEPT = 0;
 
    virtual uint64_t GetErrorCount() const RTCTK_NOEXCEPT = 0;
};
 
}  // namespace rtctk::telSub
 
#endif  // RTCKT_TELSUB_OPERATIONALLOGICIF_HPP