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-seitiger State fuer einen Remote-Writer.

Fields

remote_writer_guid: Guid

GUID des Remote-Writer-Endpoints.

unicast_locators: Vec<Locator>

Unicast-Locators des Writers (z.B. fuer gerichtete 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

Erzeugt einen frischen Proxy.

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

Verarbeitet einen HEARTBEAT.

Gemaess §8.4.15: first_sn ist die kleinste SN, die der Writer re-liefern kann; last_sn die groesste annoncierte.

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

Markiert eine SN als empfangen.

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

Markiert eine SN als irrelevant (per GAP).

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

True wenn SN bereits empfangen oder als irrelevant markiert.

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

Liefert alle fehlenden SNs (weder empfangen noch irrelevant) im Bereich [first_available_sn, last_available_sn].

Vektor ist nach SN aufsteigend sortiert. Begrenzt auf max_count Eintraege — der erwartete RTPS-Bitmap-Window ist 256 SNs.

pub fn has_missing_changes(&self) -> bool

True wenn fehlende SNs vorhanden sind.

pub fn first_available_sn(&self) -> SequenceNumber

Getter: kleinste annoncierte SN.

pub fn last_available_sn(&self) -> SequenceNumber

Getter: groesste annoncierte SN.

pub fn highest_received_sn(&self) -> SequenceNumber

Getter: hoechste empfangene SN.

pub fn acknack_base(&self) -> SequenceNumber

Passender AckNack-Base: kleinste noch nicht acked SN.

Convention: alle SN < acknack_base sind acked. Wir liefern die kleinste noch-nicht-empfangene-oder-irrelevante 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.