Skip to main content

WriterProxyState

zerodds_rtps::reliable_reader

Struct WriterProxyState

pub struct WriterProxyState {
    pub proxy: WriterProxy,
    pub received_cache: HistoryCache,
    pub delivered_up_to: SequenceNumber,
    pub assembler: FragmentAssembler,
    pub pending_acknack_since: Option<Duration>,
}

Expand description

Per-writer state: the proxy + separate receive state.

Every remote writer has its own SN space (§8.3.5.4), so also its own received_cache, delivered_up_to and FragmentAssembler. This way two writers with colliding SNs (e.g. both starting at 1) can be received in parallel without issue.

Fields§

§proxy: WriterProxy

Writer-proxy protocol state.

§received_cache: HistoryCache

Receive cache for this writer.

§delivered_up_to: SequenceNumber

Highest SN delivered to the app.

§assembler: FragmentAssembler

Fragment reassembly for this writer.

§pending_acknack_since: Option<Duration>

Time since which an ACKNACK/NACK_FRAG to this writer is pending. None = nothing pending.

Trait Implementations§

impl Clone for WriterProxyState

fn clone(&self) -> WriterProxyState

Returns a duplicate of the value. Read more

1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more

impl Debug for WriterProxyState

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl Freeze for WriterProxyState

impl RefUnwindSafe for WriterProxyState

impl Send for WriterProxyState

impl Sync for WriterProxyState

impl Unpin for WriterProxyState

impl UnsafeUnpin for WriterProxyState

impl UnwindSafe for WriterProxyState

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> CloneToUninit for T
where T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> ToOwned for T
where T: Clone,

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.