dds.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDS_HPP_
#define RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDS_HPP_
 
#include <string>
#include <vector>
 
#include <rtctk/componentFramework/ddsCommon.hpp>
namespace rtctk::componentFramework {
 
class Dds {
protected:
    DomainParticipantFactory *m_factory;
    DomainParticipant *m_participant;
 
    std::string m_qos_library;
    std::string m_qos_profile;
 
    std::vector<std::string> m_interfaceWhiteList;
 
    // list of DDS topics
    std::vector<Topic *> m_topics;
 
    int PrintDDSParticipantQoSProperty(DomainParticipantQos &participant_qos,
                                       const char *prop,
                                       const char *sf = "");
    int SetDDSParticipantQoSProperty(DomainParticipantQos &participant_qos,
                                     const char *prop,
                                     const char *value,
                                     const char *sf = "");
 
public:
    Dds(std::string qos_library = "RtcTk_Default_Library",
        std::string qos_profile = "RtcTk_Default_Profile");
    virtual ~Dds() noexcept;
 
    Dds(Dds &&rhs) = delete;
    Dds &operator=(Dds &&rhs) = delete;
 
    void SetQosLibrary(std::string &qos_library) {
        m_qos_library = qos_library;
    }
 
    void SetQosProfile(std::string &qos_profile) {
        m_qos_profile = qos_profile;
    }
 
    void SetInterfaceWhiteList(const std::vector<std::string> &iwl);
 
    void CreateParticipant();
 
 
    void DestroyParticipant();
 
    Topic *CreateTopic(const std::string &topic_name);
 
    void DestroyTopic(Topic *topic, bool to_be_removed = true);
 
    void CreateManyTopics(std::vector<std::string> &topic_names);
 
    void DestroyAllTopics();
 
    virtual void DumpDDSstatistics();
 
    size_t GetNumberOfTopics() const noexcept;
 
    const std::string GetTopicName(size_t index) const noexcept;
};
 
}  // namespace rtctk::componentFramework
 
#endif  //#ifndef RTCTK_COMPONENTFRAMEWORK_dataPATH_DDS_HPP_