All functionallty needed to create DDS entities for DDS data publishing is concentrated in this class. More...

#include <ddsPub.hpp>

Inheritance diagram for rtctk::componentFramework::DdsPub:

Public Member Functions
	DdsPub (const std::string &qos_file, std::string qos_profile=DEFAULT_QOS_PROFILE, DomainId_t domain_id=DEFAULT_DOMAIN_ID)
	DDS Publsiher class that takes care for handling all DDS entities to publish samples. More...

virtual	~DdsPub ()

void	CreatePublisher ()
	Creates DDS publisher. More...

void	DestroyPublisher ()
	Destroys DDS publisher. More...

DataWriter *	CreateDataWriter (Topic topic, DataWriterListener listener=nullptr)
	Creates DDS writer for particular topic for topic of type: rtctk::AgnosticTopic. More...

void	DestroyDataWriter (DataWriter *dw, bool to_be_removed=true, std::chrono::milliseconds wait_acks_timeout=5000ms)
	Destroys DDS data writer, and also its listener. More...

void	CreateDataWriters ()
	Creates DDS Data Writer for all DDS topics. More...

void	DestroyAllDataWriters (std::chrono::milliseconds wait_acks_timeout=5000ms)
	Destroys DDS Data Writer for all DDS topics. More...

void	CreateManyDataWriters (std::vector< DdsWriterParams > const &)
	create DDS topics and DDS writers for the given list (vector) of topic names and rtctk::componentFramework::DdsWriterListener Internally it calls for each topic name CreateTopic, and on the created topic CreateDataWriter. More...

void	CreateManyDataWriters (std::vector< std::string > const &topic_names)
	create DDS topics and DDS writers for the given list of topic names Internally it calls for each topic name CreateTopic, and on the created topic CreateDataWriter. More...

void	DumpDDSstatistics ()
	Dumps / logs varios DDS statistic like NACks, ACKs, ... More...

std::vector< DataWriter * > &	GetDataWriters ()
	returns vector of all DDS Data writers More...

void	WaitForAcks (DataWriter *dw, std::chrono::milliseconds wait_acks_timeout=5000ms)
	Wait for ACKs for the given DDS Data Writer. More...

Public Member Functions inherited from rtctk::componentFramework::Dds
	Dds (std::string qos_file, std::string qos_profile=DEFAULT_QOS_PROFILE, DomainId_t domain_id=DEFAULT_DOMAIN_ID)
	Constructor for Base class for both DDS Publisher and DDS Subscriber. More...

virtual	~Dds () noexcept

	Dds (Dds &&rhs)=delete

Dds &	operator= (Dds &&rhs)=delete

void	SetQosProfile (std::string &qos_profile)
	Set FastDDS QoS profile after creation. More...

void	SetInterfaceWhiteList (const std::vector< std::string > &iwl)
	Sets the interfaces that can be used for DDS sample traffic. More...

void	CreateParticipant ()
	Creates DDS participant. More...

void	DestroyParticipant ()
	Destroys DDS participant created in CreateParticipant. More...

Topic *	CreateTopic (const std::string &topic_name)
	Creates DDS topic. More...

void	DestroyTopic (Topic *topic, bool to_be_removed=true)
	Destroys DDS topic. More...

void	CreateManyTopics (std::vector< std::string > &topic_names)
	Creates many DDS topics. More...

void	DestroyAllTopics ()
	Destroys all DDS topics from internal map. More...

size_t	GetNumberOfTopics () const noexcept

const std::string	GetTopicName (size_t index) const noexcept

Additional Inherited Members
Static Public Attributes inherited from rtctk::componentFramework::Dds
static const std::string	TELEM_DP_QOS_FILE = "telemDataPathDdsQos.xml"
	default file name for different DDS QoSs More...

static const std::string	DEFAULT_QOS_PROFILE = "RtcTk_Default_Profile"
	default profile name for different DDS QoSs More...

static const DomainId_t	DEFAULT_DOMAIN_ID = 0
	default Domain Id for different DDS More...

Protected Attributes inherited from rtctk::componentFramework::Dds
DomainParticipantFactory *	m_factory

DomainParticipant *	m_participant

std::string	m_qos_profile

DomainId_t	m_domain_id =0

std::vector< std::string >	m_interfaceWhiteList

std::vector< Topic * >	m_topics

log4cplus::Logger	m_logger

Detailed Description

All functionallty needed to create DDS entities for DDS data publishing is concentrated in this class.

Note: Please refer to FastDDS documentation for details of DDS

Constructor & Destructor Documentation

◆ DdsPub()

rtctk::componentFramework::DdsPub::DdsPub	(	const std::string &	qos_file,
		std::string	qos_profile = `DEFAULT_QOS_PROFILE`,
		DomainId_t	domain_id = `DEFAULT_DOMAIN_ID`
	)

DDS Publsiher class that takes care for handling all DDS entities to publish samples.

Parameters

qos_file	name of QoS XML file. That needs to be located in subfolder: resource/config/rtctk/dds of $CFGPATH.
qos_profile	DDS QoS profile (please refer to DDS documentation for details)
domain_id	DDS domain Id (see FastDDS documentation for details)

Note: Intended to be used just internally by RTC Toolkit.

◆ ~DdsPub()

rtctk::componentFramework::DdsPub::~DdsPub ( )

virtual

Member Function Documentation

◆ CreateDataWriter()

DataWriter * rtctk::componentFramework::DdsPub::CreateDataWriter	(	Topic *	topic,
		DataWriterListener *	listener = `nullptr`
	)

Creates DDS writer for particular topic for topic of type: rtctk::AgnosticTopic.

Parameters

topic	DDS topic for which DDS writer shall be created
listener	pointer to DDS Writer Listener (optional). If not specified a default one is created/used: rtctk::componentFramework::DdsWriterListener

Returns: created DDS data writer

◆ CreateDataWriters()

void rtctk::componentFramework::DdsPub::CreateDataWriters ( )

Creates DDS Data Writer for all DDS topics.

Internal it calls CreateDataWriter for each topic from the internal topic map.

◆ CreateManyDataWriters() [1/2]

void rtctk::componentFramework::DdsPub::CreateManyDataWriters ( std::vector< DdsWriterParams > const & topics_listeners )

create DDS topics and DDS writers for the given list (vector) of topic names and rtctk::componentFramework::DdsWriterListener Internally it calls for each topic name CreateTopic, and on the created topic CreateDataWriter.

◆ CreateManyDataWriters() [2/2]

void rtctk::componentFramework::DdsPub::CreateManyDataWriters ( std::vector< std::string > const & topic_names )

create DDS topics and DDS writers for the given list of topic names Internally it calls for each topic name CreateTopic, and on the created topic CreateDataWriter.

◆ CreatePublisher()

void rtctk::componentFramework::DdsPub::CreatePublisher ( )

Creates DDS publisher.

It is enough to have one publisher, so this shall be called just once. It has to be called after DS particpant has been created.

◆ DestroyAllDataWriters()

void rtctk::componentFramework::DdsPub::DestroyAllDataWriters ( std::chrono::milliseconds wait_acks_timeout = 5000ms )

Destroys DDS Data Writer for all DDS topics.

Internal it calls DestroyDataWriter for each data write for each topic from the internal topic map.

Parameters

wait_acks_timeout timeout for wait_for_acknowledgments in milliseconds - it makes sure that all reliable subscribers ACKs samples before deleting each DataWriter. Default is 5000ms. Parameter is passed to DestroyDataWriter method.

◆ DestroyDataWriter()

void rtctk::componentFramework::DdsPub::DestroyDataWriter	(	DataWriter *	dw,
		bool	to_be_removed = `true`,
		std::chrono::milliseconds	wait_acks_timeout = `5000ms`
	)

Destroys DDS data writer, and also its listener.

Parameters

dw	DDS Data writter to be destroyed
to_be_removed	flag that indicates if the data writer should be also removed from internal vector. Default is to be removed.
wait_acks_timeout	timeout for wait_for_acknowledgments in miliseconds - it makes sure that all reliable subscribers ACKs samples before deleting each DAtaWriter. Default is 5000ms. If 0 wait_for_acknowledgments is not called.

◆ DestroyPublisher()

void rtctk::componentFramework::DdsPub::DestroyPublisher ( )

Destroys DDS publisher.

As there is just one publisher is should be called at most once.

◆ DumpDDSstatistics()

void rtctk::componentFramework::DdsPub::DumpDDSstatistics ( )

virtual

Dumps / logs varios DDS statistic like NACks, ACKs, ...

for each DDS writer

Reimplemented from rtctk::componentFramework::Dds.

◆ GetDataWriters()

std::vector<DataWriter *>& rtctk::componentFramework::DdsPub::GetDataWriters ( )

inline

returns vector of all DDS Data writers

◆ WaitForAcks()

void rtctk::componentFramework::DdsPub::WaitForAcks	(	DataWriter *	dw,
		std::chrono::milliseconds	wait_acks_timeout = `5000ms`
	)

Wait for ACKs for the given DDS Data Writer.

Parameters

dw	DDS Data writer where wait for ACKs is perfromed.
wait_acks_timeout	timeout in ms

The documentation for this class was generated from the following files:

componentFramework/services/dataPath/dds/src/include/rtctk/componentFramework/ddsPub.hpp
componentFramework/services/dataPath/dds/src/ddsPub.cpp

Public Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DdsPub()

◆ ~DdsPub()

Member Function Documentation

◆ CreateDataWriter()

◆ CreateDataWriters()

◆ CreateManyDataWriters() [1/2]

◆ CreateManyDataWriters() [2/2]

◆ CreatePublisher()

◆ DestroyAllDataWriters()

◆ DestroyDataWriter()

◆ DestroyPublisher()

◆ DumpDDSstatistics()

◆ GetDataWriters()

◆ WaitForAcks()