Struct WriterProxy 

pub struct WriterProxy {
    pub remote_writer_guid: Guid,
    pub unicast_locators: Vec<Locator>,
    pub multicast_locators: Vec<Locator>,
    pub is_reliable: bool,
    /* private fields */
}

Reader-side state for one remote writer.

Fields

remote_writer_guid: Guid

GUID of the remote writer endpoint.

unicast_locators: Vec<Locator>

Unicast locators of the writer (e.g. for directed re-sends).

multicast_locators: Vec<Locator>

Multicast locators.

is_reliable: bool

Reliable kind.

Implementations

impl WriterProxy

pub fn new( remote_writer_guid: Guid, unicast_locators: Vec<Locator>, multicast_locators: Vec<Locator>, is_reliable: bool, ) -> Self

Creates a fresh proxy.

pub fn refresh_locators( &mut self, unicast_locators: Vec<Locator>, multicast_locators: Vec<Locator>, )

Updates only the locators (re-discovery of the same writer), without touching the reliability state (SN bounds, received/irrelevant). A renewed SPDP/SEDP announce must not discard the reader progress — otherwise the reader falsely reports “nothing missing” after a HEARTBEAT and the writer never delivers the DATA.

pub fn update_from_heartbeat( &mut self, first_sn: SequenceNumber, last_sn: SequenceNumber, )

Processes a HEARTBEAT.

Per §8.4.15: first_sn is the smallest SN the writer can re-deliver; last_sn the largest announced.

pub fn received_change_set(&mut self, sn: SequenceNumber)

Marks an SN as received.

pub fn irrelevant_change_set(&mut self, sn: SequenceNumber)

Marks an SN as irrelevant (via GAP).

pub fn is_known(&self, sn: SequenceNumber) -> bool

True if the SN is already received or marked irrelevant.

pub fn missing_changes(&self, max_count: usize) -> Vec<SequenceNumber>

Returns all missing SNs (neither received nor irrelevant) in the range [first_available_sn, last_available_sn].

The vector is sorted ascending by SN. Limited to max_count entries — the expected RTPS bitmap window is 256 SNs.

pub fn has_missing_changes(&self) -> bool

True if there are missing SNs.

pub fn first_available_sn(&self) -> SequenceNumber

Getter: smallest announced SN.

pub fn last_available_sn(&self) -> SequenceNumber

Getter: largest announced SN.

pub fn highest_received_sn(&self) -> SequenceNumber

Getter: highest received SN.

pub fn acknack_base(&self) -> SequenceNumber

Matching AckNack base: smallest not-yet-acked SN.

Convention: all SN < acknack_base are acked. We return the smallest not-yet-received-or-irrelevant SN in [first, last+1].

Trait Implementations

impl Clone for WriterProxy

fn clone(&self) -> WriterProxy

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WriterProxy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.