a10 0.4.2

This library is meant as a low-level library safely exposing different OS's abilities to perform non-blocking I/O.
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

use std::io;
use std::task::{self, Poll};

use crate::SubmissionQueue;
use crate::io_uring::libc;
use crate::io_uring::op::{Multishot, State, fallback, poll_next};
use crate::poll::PollableState;

pub(crate) struct PollableOp;

impl crate::op::Iter for PollableOp {
    type Output = io::Result<()>;
    type Resources = PollableState;
    type Args = ();
    type State = State<Multishot, Self::Resources, Self::Args>;

    fn poll_next(
        state: &mut Self::State,
        ctx: &mut task::Context<'_>,
        sq: &SubmissionQueue,
    ) -> Poll<Option<Self::Output>> {
        poll_next(
            sq,
            state,
            ctx,
            |_, state, (), submission| {
                submission.0.opcode = libc::IORING_OP_POLL_ADD as u8;
                submission.0.fd = state.sq.submissions().ring_fd();
                submission.0.__bindgen_anon_3 = libc::io_uring_sqe__bindgen_ty_3 {
                    poll32_events: (libc::EPOLLIN
                        | libc::EPOLLHUP
                        | libc::EPOLLERR
                        | libc::EPOLLET
                        | libc::EPOLLEXCLUSIVE)
                        .cast_unsigned(),
                };
                submission.0.len = libc::IORING_POLL_ADD_MULTI;
            },
            |_, _, _| (),
            |_, _, (), err| Err(fallback(err)),
        )
    }
}