Struct ReaderProxy 

pub struct ReaderProxy {
    pub remote_reader_guid: Guid,
    pub unicast_locators: Vec<Locator>,
    pub multicast_locators: Vec<Locator>,
    pub is_reliable: bool,
    /* private fields */
}

Writer-side state for one remote reader.

Fields

remote_reader_guid: Guid

GUID of the remote reader endpoint.

unicast_locators: Vec<Locator>

Unicast receive locator(s) of the reader.

multicast_locators: Vec<Locator>

Multicast receive locator(s).

is_reliable: bool

Reliable kind (always true in WP 1.1).

Implementations

impl ReaderProxy

pub fn new( remote_reader_guid: Guid, unicast_locators: Vec<Locator>, multicast_locators: Vec<Locator>, is_reliable: bool, ) -> Self

Creates a fresh proxy.

pub fn set_negotiated_data_representation(&mut self, id: i16)

Sets the negotiated wire format for this reader. Called by the DCPS-SEDP match path after negotiate(...).

pub fn negotiated_data_representation(&self) -> i16

Returns the negotiated wire format.

pub fn note_activity(&mut self, now: Duration)

Spec §8.4.15.6 — marks incoming reader activity (every ACKNACK / NACK_FRAG calls this from the receiver path).

pub fn is_inactive(&self, now: Duration, threshold: Duration) -> bool

Spec §8.4.15.6 — true if the reader has shown no activity for longer than threshold. The caller (e.g. ReliableWriter) uses this to reclaim the proxy from the matched_readers list, so that strict reliability does not run the cache OOM.

pub fn last_activity(&self) -> Duration

Returns the last-activity timestamp (diagnosis).

pub fn skip_samples_up_to(&mut self, sn: SequenceNumber)

Marks samples up to and including sn as “no longer relevant” for this proxy — both sent and acked. Called e.g. for volatile durability when a new reader proxy is added: it should not get historic samples, so we jump directly to the current cache state.

Spec reference: OMG DDS 1.4 §2.2.3.4 DurabilityQosPolicy Volatile: “The Service will not attempt to retain old data beyond what is currently held by the DataWriter for live Readers”.

pub fn acked_changes_set(&mut self, base: SequenceNumber)

Updates to the ACKNACK base — the reader has acked all SNs < base. base corresponds to reader_sn_state.bitmap_base.

pub fn requested_changes_set( &mut self, sns: impl IntoIterator<Item = SequenceNumber>, )

Remembers the SNs requested in the ACKNACK bitmap for re-send.

pub fn next_requested_change(&mut self) -> Option<SequenceNumber>

Pulls the smallest open requested SN and removes it.

pub fn next_unsent_change( &mut self, cache_max: SequenceNumber, ) -> Option<SequenceNumber>

Returns the next not-yet-sent SN, if present in the cache.

cache_max is the largest SN currently in the writer cache.

pub fn unacked_changes(&self, cache_max: SequenceNumber) -> bool

True if there are still unacknowledged samples between highest_acked and cache_max.

pub fn highest_acked_sn(&self) -> SequenceNumber

Getter for highest_acked_sn.

pub fn highest_sent_sn(&self) -> SequenceNumber

Getter for highest_sent_sn.

pub fn pending_requested_count(&self) -> usize

Number of queued resend requests.

pub fn requested_fragments_set( &mut self, sn: SequenceNumber, fragments: impl IntoIterator<Item = FragmentNumber>, )

Remembers fragment-granular resend requests from a NACK_FRAG. SN values ≤ highest_acked_sn are ignored.

pub fn next_requested_fragment( &mut self, ) -> Option<(SequenceNumber, FragmentNumber)>

Pulls the smallest open (SN, FragmentNumber) pair and removes it.

pub fn pending_requested_fragment_count(&self) -> usize

Number of queued fragment resends (sum over all SNs).

Trait Implementations

impl Clone for ReaderProxy

fn clone(&self) -> ReaderProxy

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReaderProxy

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

Formats the value using the given formatter.