dope-net 0.13.0

The manifold runtime
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
33
34
35
36

use crate::wire::send::{StableVectoredSource, Vectored};
use dope_core::io::socket::msg::{IoVec, MsgHdr};

pub(in crate::link::egress) struct Preparation<'a> {
    iovs: &'a [IoVec],
    storage: &'a mut [IoVec],
    msghdr: &'a mut MsgHdr,
}

impl<'a> Preparation<'a> {
    pub(in crate::link::egress) fn new(
        iovs: &'a [IoVec],
        storage: &'a mut [IoVec],
        msghdr: &'a mut MsgHdr,
    ) -> Self {
        Self {
            iovs,
            storage,
            msghdr,
        }
    }

    pub(in crate::link::egress) fn prepare(self) -> Vectored<'a> {
        Vectored::from_stable(self)
    }
}

// SAFETY: every descriptor is derived from this queue's live entry storage.
// The consuming send protocol retains those entries and the queue-owned
// descriptor storage unchanged until completion.
unsafe impl<'a> StableVectoredSource<'a> for Preparation<'a> {
    #[inline(always)]
    fn into_parts(self) -> (&'a [IoVec], &'a mut [IoVec], &'a mut MsgHdr) {
        (self.iovs, self.storage, self.msghdr)
    }
}