Class RTPSWriter, manages the sending of data to the readers. More...
#include <RTPSWriter.hpp>
Public Member Functions | |
virtual FASTDDS_EXPORTED_API bool | matched_reader_add (const SubscriptionBuiltinTopicData &info)=0 |
Add a matched reader represented by its attributes. | |
virtual FASTDDS_EXPORTED_API bool | matched_reader_remove (const GUID_t &reader_guid)=0 |
Remove a matched reader. | |
virtual FASTDDS_EXPORTED_API bool | matched_reader_is_matched (const GUID_t &reader_guid)=0 |
Tells us if a specific Reader is matched against this writer. | |
virtual FASTDDS_EXPORTED_API void | reader_data_filter (IReaderDataFilter *filter)=0 |
Set a content filter to perform content filtering on this writer. | |
virtual FASTDDS_EXPORTED_API const IReaderDataFilter * | reader_data_filter () const =0 |
Get the content filter used to perform content filtering on this writer. | |
virtual FASTDDS_EXPORTED_API bool | has_been_fully_delivered (const SequenceNumber_t &seq_num) const =0 |
Check if a specific change has been delivered to the transport layer of every matched remote RTPSReader at least once. | |
virtual FASTDDS_EXPORTED_API bool | is_acked_by_all (const SequenceNumber_t &seq_num) const =0 |
Check if a specific change has been acknowledged by all Readers. | |
virtual FASTDDS_EXPORTED_API bool | wait_for_all_acked (const dds::Duration_t &max_wait)=0 |
Waits until all changes were acknowledged or max_wait. | |
virtual FASTDDS_EXPORTED_API void | update_attributes (const WriterAttributes &att)=0 |
Update the Attributes of the Writer. | |
virtual FASTDDS_EXPORTED_API WriterListener * | get_listener () const =0 |
Get listener. | |
virtual FASTDDS_EXPORTED_API bool | set_listener (WriterListener *listener)=0 |
Set the listener. | |
virtual FASTDDS_EXPORTED_API bool | is_async () const =0 |
Get the publication mode. | |
virtual FASTDDS_EXPORTED_API bool | get_disable_positive_acks () const =0 |
Returns if disable positive ACKs QoS is enabled. | |
![]() | |
FASTDDS_EXPORTED_API const GUID_t & | getGuid () const |
Get associated GUID. | |
FASTDDS_EXPORTED_API RecursiveTimedMutex & | getMutex () |
Get mutex. | |
FASTDDS_EXPORTED_API EndpointAttributes & | getAttributes () |
Get associated attributes. | |
Protected Member Functions | |
RTPSWriter (RTPSParticipantImpl *impl, const GUID_t &guid, const WriterAttributes &att) | |
virtual | ~RTPSWriter () |
![]() | |
Endpoint ()=default | |
Endpoint (RTPSParticipantImpl *pimpl, const GUID_t &guid, const EndpointAttributes &att) | |
virtual | ~Endpoint () |
Additional Inherited Members | |
![]() | |
RTPSParticipantImpl * | mp_RTPSParticipant |
Pointer to the RTPSParticipant containing this endpoint. | |
const GUID_t | m_guid |
Endpoint GUID. | |
EndpointAttributes | m_att |
Endpoint Attributes. | |
RecursiveTimedMutex | mp_mutex |
Endpoint Mutex. | |
uint32_t | fixed_payload_size_ = 0 |
Fixed size of payloads. | |
Class RTPSWriter, manages the sending of data to the readers.
Is always associated with a HistoryCache.
|
protected |
|
protectedvirtual |
|
pure virtual |
Returns if disable positive ACKs QoS is enabled.
|
pure virtual |
Get listener.
|
pure virtual |
Check if a specific change has been delivered to the transport layer of every matched remote RTPSReader at least once.
seq_num | Sequence number of the change to check. |
|
pure virtual |
Check if a specific change has been acknowledged by all Readers.
Is only useful in reliable Writer. In BE Writers returns false when pending to be sent.
seq_num | Sequence number to check. |
|
pure virtual |
Get the publication mode.
|
pure virtual |
Add a matched reader represented by its attributes.
info | Subscription info of the reader being matched. |
|
pure virtual |
Tells us if a specific Reader is matched against this writer.
reader_guid | GUID of the reader to check. |
|
pure virtual |
Remove a matched reader.
reader_guid | GUID of the reader to remove. |
|
pure virtual |
Get the content filter used to perform content filtering on this writer.
|
pure virtual |
Set a content filter to perform content filtering on this writer.
This method sets a content filter that will be used to check whether a cache change is relevant for a reader or not.
filter | The content filter to use on this writer. May be nullptr to remove the content filter (i.e. treat all samples as relevant). |
|
pure virtual |
Set the listener.
listener | Pointer to the listener. |
|
pure virtual |
Update the Attributes of the Writer.
att | New attributes |
|
pure virtual |
Waits until all changes were acknowledged or max_wait.
max_wait | Maximum time to wait. |