dope-uring 0.21.0

Owned io_uring backend 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

use std::marker;

use dope_sys::{memory, memory::buffer};

use crate::reactor::cq::Buffer;

#[derive(Debug)]
pub struct Selected<E: memory::raw::Extent, L> {
    pub(super) index: Buffer,
    pub(super) len: L,
    pub(super) extent: marker::PhantomData<fn(E) -> E>,
}

impl<E: memory::raw::Extent, L> buffer::Recycle for Selected<E, L> {
    type Deferred = Self;

    fn recycle(self) -> Option<Self> {
        Some(self)
    }
}

// SAFETY: construction requires unique slot ownership; completion consumes it.
unsafe impl<E: memory::raw::Extent, L: Copy> buffer::raw::Token for Selected<E, L> {
    type Index = Buffer;
    type Length = L;

    fn index(&self) -> Self::Index {
        self.index
    }

    fn length(&self) -> Self::Length {
        self.len
    }
}