dope-net 0.39.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
58
59
60
61
62

use dope_core::driver::{
    receive::credit,
    route::{SLOT_MASK, table::conn},
    settings,
};
pub use loan::Loan;
use o3::depot::queue::pool;
pub(in crate::link::pool::recv) use seal::Seal;

use crate::link::event;

mod loan;
pub mod queue;
pub mod raw;
mod seal;
pub mod tail;

pub enum Extent {
    Empty,
    Lanes(usize),
}

pub struct Parking<'d, R = ()> {
    pub(crate) events: pool::Lanes<event::Completion<'d, R>>,
}

impl<'d, R> Parking<'d, R> {
    pub(crate) fn try_new(conns: conn::Capacity, bufs: settings::Buffers) -> crate::Result<Self> {
        let conns = conns.entries().get();
        let events = usize::from(bufs.into_nonzero().get()) + conns;
        let plan = pool::Plan::new(events, conns)
            .map_err(crate::ConfigError::ReceiveLayout)
            .map_err(crate::Resource::Config)?;
        Ok(Self {
            events: pool::Lanes::try_new(plan).map_err(crate::Resource::Allocation)?,
        })
    }
}

pub struct Retained<'d, R = ()> {
    pub(crate) events: Parking<'d, R>,
    pub(crate) credit: credit::Storage<'d>,
}

impl<'d, R> Retained<'d, R> {
    pub(crate) fn try_new(
        conns: conn::Capacity,
        bufs: settings::Buffers,
        credit: credit::Storage<'d>,
    ) -> crate::Result<Self> {
        Ok(Self {
            events: Parking::try_new(conns, bufs)?,
            credit,
        })
    }
}

const _: () = assert!(
    (SLOT_MASK as usize)
        .checked_add(u16::MAX as usize)
        .is_some()
);