Struct VolatileSecureMessageWriter 

pub struct VolatileSecureMessageWriter { /* private fields */ }

Writer fuer DCPSParticipantVolatileMessageSecure.

Implementations

impl VolatileSecureMessageWriter

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

Erzeugt einen Writer fuer den lokalen Participant.

pub fn guid(&self) -> Guid

GUID des Writers.

pub fn reader_proxy_count(&self) -> usize

Anzahl registrierter Reader-Proxies.

pub fn inner(&self) -> &ReliableWriter

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

pub fn add_reader_proxy(&mut self, proxy: ReaderProxy)

Fuegt einen Reader-Proxy hinzu.

pub fn remove_reader_proxy(&mut self, guid: Guid) -> Option<ReaderProxy>

Entfernt einen Reader-Proxy.

pub fn write( &mut self, msg: &ParticipantGenericMessage, ) -> Result<Vec<OutboundDatagram>, WireError>

Sendet eine ParticipantGenericMessage. Liefert pro Reader- Proxy ein Datagramm.

Errors

WireError aus dem Reliable-Writer (Cache-Overflow bei KeepAll, Sequence-Overflow).

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

Tick (HEARTBEAT + Resends).

Errors

Wire-Encode-Fehler.

pub fn handle_acknack( &mut self, src_guid: Guid, base: SequenceNumber, requested: impl IntoIterator<Item = SequenceNumber>, )

Dispatch eines ACKNACK vom Remote-Reader.

pub fn handle_nackfrag(&mut self, src_guid: Guid, nf: &NackFragSubmessage)

Dispatch eines NACK_FRAG vom Remote-Reader.

Trait Implementations

impl Debug for VolatileSecureMessageWriter

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

Formats the value using the given formatter.