Safe DDS
eprosima::safedds::protocol::rtps::Writer Member List

This is the complete list of members for eprosima::safedds::protocol::rtps::Writer, including all inherited members.

add_data_submsg(const SequenceNumber &sn, const CacheChangeInfo &change_info, const memory::IConstByteArrayView &payload, const memory::IConstByteArrayView &inline_qos, Submessage< Data > &data, MessageHandler< MAX_MESSAGE_ELEMENTS > &message_handler) const noexcepteprosima::safedds::protocol::rtps::Writerprotected
add_datafrag_submsg(const CacheChangeInfo &change_info, const SequenceNumber &sn, const FragmentNumber &fragment_number, bool is_last_fragment, const memory::IConstByteArrayView &payload, const memory::IConstByteArrayView &inline_qos, Submessage< DataFrag > &datafrag, MessageHandler< MAX_MESSAGE_ELEMENTS > &message_handler) const noexcepteprosima::safedds::protocol::rtps::Writerprotected
add_gap_submsg(const SequenceNumber &first_irrelevant, const SequenceNumber &first_relevant, Submessage< Gap > &gap, MessageHandler< MAX_MESSAGE_ELEMENTS > &message_handler) const noexcepteprosima::safedds::protocol::rtps::Writerprotected
add_heartbeat_submsg(Submessage< Heartbeat > &heartbeat, MessageHandler< MAX_MESSAGE_ELEMENTS > &message_handler, bool final_flag, bool liveliness_flag, const SequenceNumber &first_available_sn) noexcepteprosima::safedds::protocol::rtps::Writerprotected
assert_protocol_liveliness() noexcepteprosima::safedds::protocol::rtps::Writervirtual
check_guid(const GUID &target_guid) const noexcepteprosima::safedds::protocol::rtps::Writerprotected
database_querier_eprosima::safedds::protocol::rtps::Writerprotected
first_unacknowledged_sn_eprosima::safedds::protocol::rtps::Writerprotected
fragment_max_size_eprosima::safedds::protocol::rtps::Writerprotected
get_first_proxyreader_with_work() const noexcepteprosima::safedds::protocol::rtps::Writerprotected
get_last_sequence_number() const noexcept overrideeprosima::safedds::protocol::rtps::Writer
get_next_work_timepoint() const noexcept overrideeprosima::safedds::protocol::rtps::Writer
guid() const noexcept overrideeprosima::safedds::protocol::rtps::Writer
guid_eprosima::safedds::protocol::rtps::Writerprotected
handle_heartbeat_timer() noexcepteprosima::safedds::protocol::rtps::Writerprotected
has_pending_work() const noexcept overrideeprosima::safedds::protocol::rtps::Writer
heartbeat_timer_eprosima::safedds::protocol::rtps::Writerprotected
integrity_sink_eprosima::safedds::protocol::rtps::Writerprotected
is_reliable_communication(const ProxyReader &proxy_reader) const noexcepteprosima::safedds::protocol::rtps::Writerprotected
last_sent_heartbeat_count_eprosima::safedds::protocol::rtps::Writerprotected
last_sequence_number_eprosima::safedds::protocol::rtps::Writerprotected
matched_reader_add(const GUID &reader_guid, const Reliability &reader_reliability, bool send_historical_data) noexcept overrideeprosima::safedds::protocol::rtps::Writer
matched_reader_exists(const GUID &reader_guid) const noexcept overrideeprosima::safedds::protocol::rtps::Writer
matched_reader_remove(const GUID &reader_guid) noexcept overrideeprosima::safedds::protocol::rtps::Writer
matched_reader_set_group(const GUID &reader_guid, const EndpointGroup &group) noexcept overrideeprosima::safedds::protocol::rtps::Writer
matched_readers_eprosima::safedds::protocol::rtps::Writerprotected
MAX_MESSAGE_ELEMENTSeprosima::safedds::protocol::rtps::Writerstatic
message_sink_eprosima::safedds::protocol::rtps::Writerprotected
need_confirmation_check_eprosima::safedds::protocol::rtps::Writerprotected
next_proxyreader_index_eprosima::safedds::protocol::rtps::Writermutableprotected
notify_acknowledged_sequence_numbers() noexcepteprosima::safedds::protocol::rtps::Writerprotected
operator=(const Writer &) noexcept=deleteeprosima::safedds::protocol::rtps::Writer
operator=(Writer &&) noexcept=deleteeprosima::safedds::protocol::rtps::Writer
payload_max_size_eprosima::safedds::protocol::rtps::Writerprotected
process_acknack(const ProcessorState &processor_state, const Submessage< AckNack > &acknack) noexcept overrideeprosima::safedds::protocol::rtps::Writer
process_nackfrag(const ProcessorState &processor_state, const Submessage< NackFrag > &nackfrag) noexcept overrideeprosima::safedds::protocol::rtps::Writer
process_proxyreader(ProxyReader &reader, const execution::TimePoint &timepoint) noexcepteprosima::safedds::protocol::rtps::Writerprotected
ProcessProxyReaderStatuseprosima::safedds::protocol::rtps::Writerfriend
properties_eprosima::safedds::protocol::rtps::Writerprotected
proxyreader_with_work_eprosima::safedds::protocol::rtps::Writermutableprotected
relevance_querier_eprosima::safedds::protocol::rtps::Writerprotected
reliability() const noexcept overrideeprosima::safedds::protocol::rtps::Writer
request_remote_acknowledgements() noexcept overrideeprosima::safedds::protocol::rtps::Writer
set_last_sequence_number(const SequenceNumber &sn) noexcept overrideeprosima::safedds::protocol::rtps::Writer
spin(const execution::TimePoint &timepoint) noexcept overrideeprosima::safedds::protocol::rtps::Writer
stop_timer_if_required() noexcepteprosima::safedds::protocol::rtps::Writerprotected
Writer(const GUID &writer_guid, const WriterProperties &properties, ICacheChangeDatabaseQuerier &database_querier, IMessageSink &message_sink, ICacheChangeRelevanceQuerier &relevance_querier, IWriterObserver &writer_observer, memory::IMap< GUID, ProxyReader > &proxy_map) noexcepteprosima::safedds::protocol::rtps::Writerexplicit
Writer(const Writer &) noexcept=deleteeprosima::safedds::protocol::rtps::Writer
Writer(Writer &&) noexcept=deleteeprosima::safedds::protocol::rtps::Writer
writer_observer_eprosima::safedds::protocol::rtps::Writerprotected
~Writer() noexcept=defaulteprosima::safedds::protocol::rtps::Writervirtual