dope-net 0.33.0

Owned network transports for dope
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use std::cell;

use dope_core::io::transfer;
use o3::buffer::segments::scatter;

use crate::link::egress::{self, data};

/// The immutable owner and its exact unconsumed suffix from one occupied cell.
pub(in crate::link::egress) struct View<'a, T> {
    pub(super) source: &'a egress::NonEmpty<T>,
    pub(super) remaining: transfer::NonZero,
    pub(super) position: &'a cell::Cell<scatter::raw::Position>,
}

impl<'a, T> View<'a, T> {
    pub(in crate::link::egress) fn chunks<'d>(self) -> T::Cursor<'a>
    where
        T: data::raw::Payload<'d>,
    {
        let total = transfer::Len::from_nonzero(self.source.geometry().wire());
        let rest = transfer::Len::from_nonzero(self.remaining);
        let offset = data::Offset::from_len(total.abs_diff(rest));
        let mut position = self.position.get();
        // SAFETY: this cell resets its checkpoint whenever it replaces the owner.
        // Positive stored credit proves this exact immutable source has a suffix.
        let cursor = unsafe { self.source.as_inner().resume(&mut position, offset) };
        self.position.set(position);
        cursor
    }
}

const _: () = assert!(size_of::<View<'static, ()>>() == 3 * size_of::<usize>());