Struct VolatileSecureMessageReader 

pub struct VolatileSecureMessageReader { /* private fields */ }

Reader fuer DCPSParticipantVolatileMessageSecure.

Implementations

impl VolatileSecureMessageReader

pub fn new(participant_prefix: GuidPrefix, vendor_id: VendorId) -> Self

Erzeugt einen Reader fuer den lokalen Participant.

pub fn guid(&self) -> Guid

GUID des Readers.

pub fn writer_proxy_count(&self) -> usize

Anzahl registrierter Writer-Proxies.

pub fn inner(&self) -> &ReliableReader

Read-only-Zugriff auf den ReliableReader (Tests/Diagnose).

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

Fuegt einen Writer-Proxy hinzu.

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

Entfernt einen Writer-Proxy.

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

Verarbeitet eine eingehende DATA-Submessage und liefert dekodierte Generic-Messages.

Errors

BadArgument wenn die Encapsulation/CDR-Decode scheitert.

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

DATA_FRAG verarbeiten.

Errors

siehe handle_data.

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

GAP verarbeiten.

Errors

siehe handle_data.

pub fn handle_heartbeat(&mut self, hb: &HeartbeatSubmessage, now: Duration)

HEARTBEAT verarbeiten.

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

Tick (ACKNACK / NACK_FRAG-Outbound).

Errors

Wire-Encode-Fehler.

Trait Implementations

impl Debug for VolatileSecureMessageReader

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

Formats the value using the given formatter.