Struct ReliableReader

Source

pub struct ReliableReader { /* private fields */ }

Expand description

Ein Reliable-Reader mit 0..N Writer-Proxies.

Implementations§

Source §

impl ReliableReader

Source

pub fn new(cfg: ReliableReaderConfig) -> Self

Erzeugt einen frischen Reader.

§Panics

Wenn cfg.assembler_caps.max_pending_sns == 0.

Source

pub fn guid(&self) -> Guid

GUID.

Source

pub fn writer_proxies(&self) -> &[WriterProxyState]

Read-only-Slice der Writer-Proxy-States.

Source

pub fn writer_proxy_count(&self) -> usize

Anzahl registrierter Writer-Proxies.

Source

pub fn acknack_count(&self) -> i32

Zaehler der gesendeten ACKNACKs.

Source

pub fn nackfrag_count(&self) -> i32

Zaehler der gesendeten NACK_FRAGs.

Source

pub fn pending_fragment_count(&self) -> usize

Summe der aktiven (unvollstaendigen) Fragment-Buffer ueber alle Proxies.

Source

pub fn dropped_fragment_count(&self) -> u64

Summe der verworfenen Fragmente ueber alle Proxies (DoS-/Inkonsistenz-Diagnose).

Source

pub fn duplicate_fragment_count(&self) -> u64

Anzahl DATA_FRAGs, die fuer bereits-bekannte SNs eintrafen (Duplicate-Fragments, Re-Sends).

Source

pub fn unknown_src_count(&self) -> u64

Anzahl Submessages, deren writer_id keinem registrierten Proxy zuzuordnen war (Misrouting / Spoofing-Diagnose).

Source

pub fn add_writer_proxy(&mut self, proxy: WriterProxy)

Fuegt einen Writer-Proxy hinzu. Idempotent: gleiche GUID ersetzt.

Setzt sofort ein preemptives ACKNACK als pending, damit der Writer beim naechsten Tick ein “Hallo, ich bin hier”-ACKNACK bekommt. Cyclone DDS reagiert darauf mit einem HEARTBEAT und beginnt mit DATA-Resends — ohne diesen Impuls wartet der Writer passiv.

Source

pub fn remove_writer_proxy(&mut self, guid: Guid) -> Option<WriterProxy>

Entfernt einen Writer-Proxy.

Source

pub fn reset_diagnostics(&mut self)

Nulliert alle Diagnose-Zaehler. Beruehrt keine State-Maschine.

Source

pub fn handle_data(&mut self, data: &DataSubmessage) -> Vec<DeliveredSample>

DATA verarbeiten. Dispatch nach writer_id auf den passenden Proxy. Liefert die reassemblierten Samples dieses Proxies.

Spec §9.6.3.9 PID_STATUS_INFO: bei key_flag=true + Inline-QoS mit gesetztem STATUS_INFO wird der CacheChange mit NotAliveDisposed / NotAliveUnregistered / NotAliveDisposedUnregistered markiert, statt Alive.

Source

pub fn handle_data_frag( &mut self, df: &DataFragSubmessage, now: Duration, ) -> Vec<DeliveredSample>

DATA_FRAG verarbeiten. now triggert NACK_FRAG-Scheduling direkt, ohne auf HEARTBEAT zu warten.

Source

pub fn handle_heartbeat( &mut self, hb: &HeartbeatSubmessage, now: Duration, ) -> Vec<DeliveredSample>

HEARTBEAT verarbeiten. Dispatch nach writer_id.

Source

pub fn handle_gap(&mut self, gap: &GapSubmessage) -> Vec<DeliveredSample>

GAP verarbeiten. Dispatch nach writer_id.

Source

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

Tick: liefert faellige ACKNACK/NACK_FRAG-Datagramme ueber alle Proxies hinweg. Pro Proxy ein eigenes ACKNACK/NACK_FRAG, weil SN-Spaces pro Writer sind.

§Errors

Wire-Encode-Fehler.

Source

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

Wie Self::tick, aber mit Ziel-Locators fuer jedes Datagram. Bevorzugt fuer Transport-Integration, weil jeder AckNack an den konkreten Writer-Proxy-Unicast-Locator gehen muss.