ddsPub.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDSPUB_HPP_
#define RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDSPUB_HPP_
#include "rtctk/componentFramework/dds.hpp"
#include <list>
 
namespace rtctk::componentFramework {
 
using namespace std::chrono_literals;
 
struct DdsWriterParams {
    std::string topic_name;
    DataWriterListener *listener = nullptr;
 
    DdsWriterParams(const std::string &tn, DataWriterListener *l)
        : topic_name(tn), listener(l) {
    }
 
    DdsWriterParams(const std::string &tn) : topic_name(tn), listener(nullptr) {
    }
};
 
class DdsPub : public Dds {
    Publisher *m_publisher;
 
    std::vector<DataWriter *> m_data_writers;
 
public:
    DdsPub(const std::string &qos_file, 
           std::string qos_profile = DEFAULT_QOS_PROFILE,
           DomainId_t domain_id=DEFAULT_DOMAIN_ID);
    virtual ~DdsPub();
 
    void CreatePublisher();
 
    void DestroyPublisher();
 
    DataWriter *CreateDataWriter(Topic *topic, DataWriterListener *listener = nullptr);
 
    void DestroyDataWriter(DataWriter *dw, bool to_be_removed = true, std::chrono::milliseconds wait_acks_timeout=5000ms);
 
    void CreateDataWriters();
 
    void DestroyAllDataWriters(std::chrono::milliseconds  wait_acks_timeout=5000ms);
 
    void CreateManyDataWriters(std::vector<DdsWriterParams> const &);
 
    void CreateManyDataWriters(std::vector<std::string> const &topic_names);
 
    void DumpDDSstatistics();
 
    std::vector<DataWriter *> &GetDataWriters() {
        return m_data_writers;
    }
 
 
    void WaitForAcks(DataWriter *dw, std::chrono::milliseconds wait_acks_timeout=5000ms);
    
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDSPUB_HPP_