ddsWaitSetIf.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_TELSUB_DDSWAITSETIF_HPP
#define RTCTK_TELSUB_DDSWAITSETIF_HPP
#include <rtctk/config.hpp>
 
#include <chrono>
#include <cstdint>
#include <functional>
#include <string>
#include <system_error>
#include <vector>
 
#include <rtctk/componentFramework/ddsCommon.hpp>
#include <rtctk/telSub/agnosticDataSamples.hpp>
 
 
 
namespace rtctk::telSub {
 
    using namespace rtctk::componentFramework;
 
struct DdsParams {
    int32_t m_domain_id  = Dds::DEFAULT_DOMAIN_ID;
    std::string m_qos_file = Dds::TELEM_DP_QOS_FILE;
    std::string m_qos_profile = Dds::DEFAULT_QOS_PROFILE;
 
// the size of m_topics and m_multicast_addresses (if defined) should be the same
    std::vector<std::string> m_topics = {};
    std::vector<std::string> m_multicast_addresses = {};
 
// size is the number of network interfaces that we want, not the same as size of m_topics/m_multicast_addresses
    std::vector<std::string> m_interface_white_list ={};
};
 
class DdsWaitSetIf {
public:
    DdsWaitSetIf() RTCTK_NOEXCEPT {};
    virtual ~DdsWaitSetIf() RTCTK_NOEXCEPT {};
 
    virtual AgnosticDataSamples& GetSamples() RTCTK_NOEXCEPT = 0;
 
    virtual std::error_code Take(std::chrono::nanoseconds timeout) RTCTK_NOEXCEPT = 0;
 
    virtual size_t GetNumberOfTopics() const RTCTK_NOEXCEPT = 0;
 
    virtual std::string GetTopicName(size_t index) const RTCTK_NOEXCEPT = 0;
};
 
} // namespace rtctk::telSub
#endif // RTCTK_TELSUB_DDSWAITSETIF_HPP