dope-net 0.28.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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

use std::{cell, mem};

use dope_core::driver::{
    route,
    route::{Identity, KeyTag},
};

use crate::link::pool;

pub(in crate::link::pool::pending) struct Node<'d, ID: Identity> {
    pub(in crate::link::pool::pending) epoch: cell::Cell<route::Epoch>,
    pub(in crate::link::pool::pending) next: cell::Cell<Next<'d, ID>>,
    pub(in crate::link::pool::pending) state: cell::Cell<State>,
    pub(in crate::link::pool::pending) capacity: cell::Cell<bool>,
}

#[derive(Clone, Copy)]
pub(in crate::link::pool::pending) enum Next<'d, ID: Identity> {
    End,
    Slot(pool::raw::Physical<'d, ID>),
}

#[derive(Clone, Copy)]
pub(in crate::link::pool::pending) enum State {
    Idle,
    Queued,
    Claimed,
    Awakened,
    Retired,
}

impl<'d, ID: Identity> Default for Node<'d, ID> {
    fn default() -> Self {
        Self {
            epoch: cell::Cell::new(route::Epoch::INITIAL),
            next: cell::Cell::new(Next::End),
            state: cell::Cell::new(State::Idle),
            capacity: cell::Cell::new(false),
        }
    }
}

const _: () = {
    assert!(mem::size_of::<Next<'static, KeyTag<0>>>() == mem::size_of::<u32>());
    assert!(mem::size_of::<State>() == 1);
    assert!(mem::size_of::<Node<'static, KeyTag<0>>>() == 2 * mem::size_of::<u64>());
};