dope-uring 0.2.3

Thin io_uring adaptor with "Manifolds"
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

use std::future::Future;
use std::io;
use std::os::fd::{AsRawFd, RawFd};

use dope_core::Fd;
use dope_core::addr::SockAddr;
use dope_core::submit::{RecvMsgPacket, SendMsgPacket, SubmitOps};

use super::Driver;
use super::request::Request;

impl SubmitOps for &mut Driver {
    fn submit_accept(
        self,
        fd: Fd,
    ) -> impl Future<Output = io::Result<(RawFd, SockAddr)>> + 'static {
        let raw = fd.as_raw_fd();
        let req = self.try_submit_op(SockAddr::empty(), move |addr| {
            io_uring::opcode::Accept::new(
                io_uring::types::Fd(raw),
                addr.addr_mut_ptr(),
                addr.addr_len_ptr(),
            )
            .build()
        });
        async move {
            let (res, addr) = Request::await_submit(req).await;
            res.map(|n| (n as RawFd, addr))
        }
    }

    fn submit_read<B>(self, fd: Fd, buf: B) -> impl Future<Output = (io::Result<u32>, B)> + 'static
    where
        B: AsMut<[u8]> + Unpin + 'static,
    {
        let raw = fd.as_raw_fd();
        let req = self.try_submit_op(buf, move |buf| {
            let slice = buf.as_mut();
            io_uring::opcode::Read::new(
                io_uring::types::Fd(raw),
                slice.as_mut_ptr(),
                slice.len() as u32,
            )
            .build()
        });
        Request::await_submit(req)
    }

    fn submit_send_raw<B>(
        self,
        fd: Fd,
        buf: B,
        len: usize,
    ) -> impl Future<Output = (io::Result<u32>, B)> + 'static
    where
        B: AsRef<[u8]> + Unpin + 'static,
    {
        let raw = fd.as_raw_fd();
        let req = self.try_submit_op(buf, move |buf| {
            let full = buf.as_ref();
            let n = len.min(full.len());
            io_uring::opcode::Send::new(io_uring::types::Fd(raw), full.as_ptr(), n as u32).build()
        });
        Request::await_submit(req)
    }

    fn submit_sendmsg_raw<P>(
        self,
        fd: Fd,
        packet: P,
    ) -> impl Future<Output = (io::Result<u32>, P)> + 'static
    where
        P: SendMsgPacket + Unpin + 'static,
    {
        let raw = fd.as_raw_fd();
        let req = self.try_submit_op(packet, move |packet| {
            io_uring::opcode::SendMsg::new(io_uring::types::Fd(raw), packet.msg_ptr()).build()
        });
        Request::await_submit(req)
    }

    fn submit_recvmsg_raw<P>(
        self,
        fd: Fd,
        packet: P,
    ) -> impl Future<Output = (io::Result<u32>, P)> + 'static
    where
        P: RecvMsgPacket + Unpin + 'static,
    {
        let raw = fd.as_raw_fd();
        let req = self.try_submit_op(packet, move |packet| {
            io_uring::opcode::RecvMsg::new(io_uring::types::Fd(raw), packet.msg_mut_ptr()).build()
        });
        Request::await_submit(req)
    }
}