Struct ReliableStreamState 

pub struct ReliableStreamState { /* private fields */ }

State-Machine eines reliable XRCE-Streams.

Implementations

impl ReliableStreamState

pub fn new(stream_id: StreamId, config: ReliableConfig) -> Self

Konstruktor.

Panics

stream_id muss reliable sein (is_reliable()).

pub fn stream_id(&self) -> StreamId

StreamId.

pub fn in_flight_count(&self) -> usize

Anzahl in-flight Samples auf der Sender-Seite.

pub fn out_of_order_count(&self) -> usize

Anzahl out-of-order Samples auf der Receiver-Seite.

pub fn expected(&self) -> SerialNumber16

Aktuelle Empfangs-Erwartungs-Seqnr (Receiver).

pub fn submit(&mut self, payload: Vec<u8>) -> Result<SerialNumber16, XrceError>

Submit eines neuen Sample. Liefert die zugewiesene Seqnr.

Errors

• PayloadTooLarge, wenn payload.len() > RELIABLE_MAX_PAYLOAD.
• ValueOutOfRange, wenn das Sender-Window voll ist (sender_window in-flight Samples). Caller muss vorher ACKNACKs verarbeiten.

pub fn get_in_flight(&self, seq: SerialNumber16) -> Option<&[u8]>

Lookup eines in-flight Payloads (z.B. fuer Resend).

pub fn pending_heartbeat(&mut self, now: Duration) -> Option<HeartbeatPayload>

Tick: liefert Some(HEARTBEAT), falls die Heartbeat-Periode abgelaufen ist und in-flight Samples existieren.

pub fn recv_acknack(&mut self, payload: AckNackPayload)

Verarbeitet eingehendes ACKNACK auf der Sender-Seite.

first_unacked ist die kleinste seqnr, die der Receiver noch erwartet; alles strikt davor wird als bestaetigt entfernt. nack_bitmap ist 16-Bit; Bit i = “seqnr first_unacked + i fehlt noch”. Wir entfernen also alle Samples < first_unacked und alle Samples in [first_unacked, first_unacked+16), deren Bit nicht gesetzt ist.

pub fn recv_data( &mut self, seq: SerialNumber16, payload: Vec<u8>, ) -> Result<(), XrceError>

Receiver: ein Sample mit seq + payload ist eingelaufen. Speichert es im Out-Of-Order-Buffer (oder verwirft als Duplikat).

Errors

ValueOutOfRange, wenn der Receiver-Buffer voll ist (DoS-Schutz).

pub fn drain_in_order(&mut self) -> Vec<(SerialNumber16, Vec<u8>)>

Receiver: liefert alle in-Order verfuegbaren Samples ab expected_seq und schiebt expected_seq weiter.

pub fn pending_acknack( &self, hint_last_seen: Option<SerialNumber16>, ) -> AckNackPayload

Receiver: berechnet das passende ACKNACK-Payload, das die fehlenden Seqnrs ab expected_seq markiert. Liefert Some(ACKNACK), wenn out-of-order Samples vorliegen ODER last_recv_seen (HEARTBEAT-Hint) eine Luecke offenlegt.

pub fn reset(&mut self)

Setzt den Stream-State zurueck (z.B. nach RESET-Submessage).

Trait Implementations

impl Clone for ReliableStreamState

fn clone(&self) -> ReliableStreamState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReliableStreamState

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

Formats the value using the given formatter.