Struct VolatileSecureMessageWriter 

pub struct VolatileSecureMessageWriter { /* private fields */ }

Writer for DCPSParticipantVolatileMessageSecure.

Implementations

impl VolatileSecureMessageWriter

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

Creates a writer for the local participant.

pub fn guid(&self) -> Guid

GUID of the writer.

pub fn reader_proxy_count(&self) -> usize

Number of registered reader proxies.

pub fn inner(&self) -> &ReliableWriter

Read-only access to the ReliableWriter (tests/diagnostics).

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

Adds a reader proxy.

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

Removes a reader proxy.

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

Sends a ParticipantGenericMessage. Returns one datagram per reader proxy.

Errors

WireError from the reliable writer (cache overflow on KeepAll, sequence overflow).

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

Write + piggyback HEARTBEAT in ONE operation (RTPS 2.5 §8.4.15.5).

Security tokens (Kx, per-endpoint crypto) are reliable and time-critical: the remote must NACK a loss IMMEDIATELY, not only at the periodic HEARTBEAT (VOLATILE_SECURE_HEARTBEAT_PERIOD = 250ms). Cross-vendor, the token otherwise falls behind Cyclone’s AUTHOK delete_pending_match and is never applied. The piggyback HEARTBEAT (final_flag=false) forces the prompt ACKNACK response — per-send, so robust for late joiners / rediscovery (no global state).

Errors

Wire encode errors.

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

Tick (HEARTBEAT + resends).

Errors

Wire encode errors.

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

Dispatch of an ACKNACK from the remote reader.

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

Dispatch of a NACK_FRAG from the remote reader.

Trait Implementations

impl Debug for VolatileSecureMessageWriter

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

Formats the value using the given formatter.