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

use std::marker;

use dope_sys::{
    memory,
    memory::{
        buffer,
        buffer::{Index as _, provided::Producer as _},
    },
};

use crate::reactor::{
    buffers::{Producer, Selected},
    cq::Buffer,
};

impl<L: memory::raw::Receive> buffer::raw::Select for Producer<L> {
    type Pending = Selected<L::Extent, <L::Extent as memory::raw::Extent>::Capacity>;
    type Index = Buffer;
    unsafe fn select(&self, buffer: Self::Index) -> Result<Self::Pending, Self::Index> {
        if buffer.is_within(self.layout().entries()) {
            return Ok(Selected {
                index: buffer,
                len: self.layout().limit(),
                extent: marker::PhantomData,
            });
        }
        Err(buffer)
    }
}