Struct ReliableStatelessWriter 

pub struct ReliableStatelessWriter { /* private fields */ }

ReliableStatelessWriter — Spec §8.4.8.2.

Implementations

impl ReliableStatelessWriter

pub fn new( prefix: GuidPrefix, entity_id: EntityId, vendor_id: VendorId, history: HistoryKind, capacity: usize, heartbeat_period: Duration, ) -> Self

Konstruktor.

pub fn guid(&self) -> Guid

Eigene GUID.

pub fn set_locators(&mut self, locators: Vec<Locator>)

Setzt eine neue Locator-Liste (T11).

pub fn set_max_per_tick(&mut self, n: usize)

Setzt das DoS-Cap fuer Retransmits-pro-Tick.

pub fn new_change( &mut self, kind: ChangeKind, payload: Vec<u8>, ) -> Result<SequenceNumber, WireError>

T1 — new_change: legt einen Sample im Cache an. Liefert die vergebene Sequence-Number.

Errors

ValueOutOfRange bei SN-Overflow oder Cache-Capacity-Limit.

pub fn handle_acknack(&mut self, ack: &AckNackSubmessage)

T4/T5 — verarbeitet eine eingehende ACKNACK. Aktualisiert lowest_unacked (max der jemals gesehenen base — once-acked- always-acked) und nimmt requested-SNs in den Retransmit-Pool.

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

T7 — is_acked_to(sn): alle SNs bis einschliesslich sn sind von mindestens einem Reader bestaetigt.

pub fn purge_acked(&mut self) -> usize

T8 — purgt alle Cache-Eintraege, die lowest_unacked - 1 oder kleiner sind. Liefert die Anzahl entfernter Samples.

pub fn tick( &mut self, now: Duration, ) -> Result<Vec<OutboundDatagram>, WireError>

T2/T3/T6 — Tick. Liefert eine Liste von Datagrams, die der Caller via UDP an alle locators senden soll. Reihenfolge:

1. Pending-Retransmits (max max_per_tick).
2. Wenn now >= last_heartbeat + heartbeat_period UND Cache nicht leer: ein HEARTBEAT.

Errors

Wire-Encode-Fehler bei DATA/HEARTBEAT-Encoding.

pub fn shutdown(&mut self)

T10 — Shutdown: leert den Cache + Retransmit-Pool.

pub fn stats(&self) -> ReliableStatelessStats

T12 — Diagnose-Snapshot.