dope-net 0.37.0

Owned network transports for dope
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use std::mem;

use dope_core::{
    driver::{self, retained, retained::flight, route, route::Identity},
    io::{
        fd::handles,
        socket,
        socket::{option, pending},
        transfer,
    },
};
use setup::Setup;

mod duplex;
pub mod egress;
pub mod event;
pub mod oneshot;
pub mod pool;
mod setup;
pub mod slot;

/// Bytes proven to fit in the exact plain view handed to the wire.
#[derive(Clone, Copy, PartialEq, Eq)]
#[repr(transparent)]
pub struct Consumed(transfer::Len);

impl Consumed {
    pub const ZERO: Self = Self(transfer::Len::ZERO);

    pub const fn into_len(self) -> transfer::Len {
        self.0
    }

    pub(crate) const fn proven(amount: transfer::Len) -> Self {
        Self(amount)
    }
}

const _: () = assert!(mem::size_of::<Consumed>() == mem::size_of::<transfer::Len>());

fn connect<'addr, 'd, ID: Identity, A: socket::Prepared>(
    fd: handles::Descriptor<'d>,
    addr: &'addr A,
    target: route::Target<'d, ID>,
    slots: &flight::Slots<'d, ID>,
    driver: driver::Context<'_, 'd>,
    opts: option::Set,
) -> Result<pending::Connection<'d>, pending::Rejection<'d>>
where
    'd: 'addr,
{
    // SAFETY: the address is already installed in its slab-indexed stable
    // owner. That owner and this descriptor remain live through terminal
    // completion or quiescence.
    let op = retained::raw::Connect::new(fd, addr, target);
    unsafe { op.try_connect(driver, slots, &opts) }
}