dope-core 0.22.0

Owned native I/O and completion driver 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

use dope_sys::io::socket::option::tuning::device::Reserve;
use o3::depot::arena::slab;

use crate::driver::{
    retained::flight,
    route::{self, kind},
};

/// Retains the route proof until the native queue admits its complete chain.
pub(crate) struct Request<'a, 'd, Tag: route::Tag, C: kind::Class> {
    slots: &'a flight::Slots<'d, Tag>,
    target: route::Operation<'d, Tag, C>,
}

impl<'a, 'd, Tag: route::Tag, C: kind::Class> Request<'a, 'd, Tag, C> {
    pub(crate) fn new(
        slots: &'a flight::Slots<'d, Tag>,
        target: route::Operation<'d, Tag, C>,
    ) -> Self {
        Self { slots, target }
    }
}

impl<'a, 'd, Tag: route::Tag, C: kind::Flight> Reserve for Request<'a, 'd, Tag, C> {
    type Key = flight::raw::Echo;
    type Vacant = flight::Vacant<'a, 'd, Tag, C>;
    type Reservation = flight::Reserved<'d, C>;
    type Error = slab::Vacancy;

    fn try_vacancy(self) -> Result<Self::Vacant, Self::Error> {
        self.slots.try_vacancy(self.target)
    }

    fn reserve(vacant: Self::Vacant) -> (Self::Key, Self::Reservation) {
        let target = vacant.reserve();
        (target.key(), target)
    }
}