| 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 noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| 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 noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| add_gap_submsg(const SequenceNumber &first_irrelevant, const SequenceNumber &first_relevant, Submessage< Gap > &gap, MessageHandler< MAX_MESSAGE_ELEMENTS > &message_handler) const noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| add_heartbeat_submsg(Submessage< Heartbeat > &heartbeat, MessageHandler< MAX_MESSAGE_ELEMENTS > &message_handler, bool final_flag, bool liveliness_flag, const SequenceNumber &first_available_sn) noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| assert_protocol_liveliness() noexcept | eprosima::safedds::protocol::rtps::Writer | virtual |
| check_guid(const GUID &target_guid) const noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| database_querier_ | eprosima::safedds::protocol::rtps::Writer | protected |
| first_unacknowledged_sn_ | eprosima::safedds::protocol::rtps::Writer | protected |
| fragment_max_size_ | eprosima::safedds::protocol::rtps::Writer | protected |
| get_first_proxyreader_with_work() const noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| get_last_sequence_number() const noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| get_next_work_timepoint() const noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| guid() const noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| guid_ | eprosima::safedds::protocol::rtps::Writer | protected |
| handle_heartbeat_timer() noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| has_pending_work() const noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| heartbeat_timer_ | eprosima::safedds::protocol::rtps::Writer | protected |
| integrity_sink_ | eprosima::safedds::protocol::rtps::Writer | protected |
| is_reliable_communication(const ProxyReader &proxy_reader) const noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| last_sent_heartbeat_count_ | eprosima::safedds::protocol::rtps::Writer | protected |
| last_sequence_number_ | eprosima::safedds::protocol::rtps::Writer | protected |
| matched_reader_add(const GUID &reader_guid, const Reliability &reader_reliability, bool send_historical_data) noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| matched_reader_exists(const GUID &reader_guid) const noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| matched_reader_remove(const GUID &reader_guid) noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| matched_reader_set_group(const GUID &reader_guid, const EndpointGroup &group) noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| matched_readers_ | eprosima::safedds::protocol::rtps::Writer | protected |
| MAX_MESSAGE_ELEMENTS | eprosima::safedds::protocol::rtps::Writer | static |
| message_sink_ | eprosima::safedds::protocol::rtps::Writer | protected |
| need_confirmation_check_ | eprosima::safedds::protocol::rtps::Writer | protected |
| next_proxyreader_index_ | eprosima::safedds::protocol::rtps::Writer | mutableprotected |
| notify_acknowledged_sequence_numbers() noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| operator=(const Writer &) noexcept=delete | eprosima::safedds::protocol::rtps::Writer | |
| operator=(Writer &&) noexcept=delete | eprosima::safedds::protocol::rtps::Writer | |
| payload_max_size_ | eprosima::safedds::protocol::rtps::Writer | protected |
| process_acknack(const ProcessorState &processor_state, const Submessage< AckNack > &acknack) noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| process_nackfrag(const ProcessorState &processor_state, const Submessage< NackFrag > &nackfrag) noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| process_proxyreader(ProxyReader &reader, const execution::TimePoint &timepoint) noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| ProcessProxyReaderStatus | eprosima::safedds::protocol::rtps::Writer | friend |
| properties_ | eprosima::safedds::protocol::rtps::Writer | protected |
| proxyreader_with_work_ | eprosima::safedds::protocol::rtps::Writer | mutableprotected |
| relevance_querier_ | eprosima::safedds::protocol::rtps::Writer | protected |
| reliability() const noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| request_remote_acknowledgements() noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| set_last_sequence_number(const SequenceNumber &sn) noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| spin(const execution::TimePoint &timepoint) noexcept override | eprosima::safedds::protocol::rtps::Writer | |
| stop_timer_if_required() noexcept | eprosima::safedds::protocol::rtps::Writer | protected |
| 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) noexcept | eprosima::safedds::protocol::rtps::Writer | explicit |
| Writer(const Writer &) noexcept=delete | eprosima::safedds::protocol::rtps::Writer | |
| Writer(Writer &&) noexcept=delete | eprosima::safedds::protocol::rtps::Writer | |
| writer_observer_ | eprosima::safedds::protocol::rtps::Writer | protected |
| ~Writer() noexcept=default | eprosima::safedds::protocol::rtps::Writer | virtual |