Struct ReaderProxy 

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

Writer-seitiger State fuer einen Remote-Reader.

Fields

remote_reader_guid: Guid

GUID des Remote-Reader-Endpoints.

unicast_locators: Vec<Locator>

Unicast-Empfangs-Locator(s) des Readers.

multicast_locators: Vec<Locator>

Multicast-Empfangs-Locator(s).

is_reliable: bool

Reliable-Kind (immer true in WP 1.1).

Implementations

impl ReaderProxy

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

Erzeugt einen frischen Proxy.

pub fn set_negotiated_data_representation(&mut self, id: i16)

Setzt das ausgehandelte Wire-Format fuer diesen Reader. Wird vom DCPS-SEDP-Match-Pfad nach negotiate(...) aufgerufen.

pub fn negotiated_data_representation(&self) -> i16

Liefert das ausgehandelte Wire-Format.

pub fn note_activity(&mut self, now: Duration)

Spec §8.4.15.6 — markiert eingehende Reader-Aktivitaet (jeder ACKNACK / NACK_FRAG ruft das aus dem Receiver-Pfad).

pub fn is_inactive(&self, now: Duration, threshold: Duration) -> bool

Spec §8.4.15.6 — true wenn der Reader laenger als threshold keine Aktivitaet gezeigt hat. Caller (z.B. ReliableWriter) nutzt das, um den Proxy aus der matched_readers-Liste zu reclaimen, sodass Strict-Reliability nicht den Cache OOM laufen laesst.

pub fn last_activity(&self) -> Duration

Liefert den Last-Activity-Zeitpunkt (Diagnose).

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

Markiert Samples bis zu und einschliesslich sn als “nicht mehr relevant” fuer diesen Proxy — sowohl gesendet als auch acked. Wird z.B. bei Volatile-Durability aufgerufen, wenn ein neuer Reader-Proxy hinzukommt: der soll keine Historic-Samples bekommen, also springen wir direkt auf den aktuellen Cache- Stand.

Spec-Bezug: OMG DDS 1.4 §2.2.3.4 DurabilityQosPolicy Volatile: “The Service will not attempt to retain old data beyond what is currently held by the DataWriter for live Readers”.

pub fn acked_changes_set(&mut self, base: SequenceNumber)

Aktualisiert auf ACKNACK-Base — Reader hat alle SNs < base acked. base entspricht reader_sn_state.bitmap_base.

pub fn requested_changes_set( &mut self, sns: impl IntoIterator<Item = SequenceNumber>, )

Merkt sich die im ACKNACK-Bitmap angefragten SNs fuer Re-Send.

pub fn next_requested_change(&mut self) -> Option<SequenceNumber>

Zieht die kleinste offene Requested-SN und entfernt sie.

pub fn next_unsent_change( &mut self, cache_max: SequenceNumber, ) -> Option<SequenceNumber>

Liefert die naechste noch nicht gesendete SN, falls im Cache vorhanden.

cache_max ist die groesste SN, die aktuell im Writer-Cache liegt.

pub fn unacked_changes(&self, cache_max: SequenceNumber) -> bool

True wenn zwischen highest_acked und cache_max noch unbestaetigte Samples liegen.

pub fn highest_acked_sn(&self) -> SequenceNumber

Getter fuer highest_acked_sn.

pub fn highest_sent_sn(&self) -> SequenceNumber

Getter fuer highest_sent_sn.

pub fn pending_requested_count(&self) -> usize

Anzahl vorgemerkter Resend-Requests.

pub fn requested_fragments_set( &mut self, sn: SequenceNumber, fragments: impl IntoIterator<Item = FragmentNumber>, )

Merkt sich Fragment-granulare Resend-Requests aus einem NACK_FRAG. SN-Werte ≤ highest_acked_sn werden ignoriert.

pub fn next_requested_fragment( &mut self, ) -> Option<(SequenceNumber, FragmentNumber)>

Zieht das kleinste offene (SN, FragmentNumber)-Paar und entfernt es.

pub fn pending_requested_fragment_count(&self) -> usize

Anzahl vorgemerkter Fragment-Resends (Summe ueber alle SNs).

Trait Implementations

impl Clone for ReaderProxy

fn clone(&self) -> ReaderProxy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReaderProxy

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

Formats the value using the given formatter.