dope-uring 0.43.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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

use std::{mem, ptr};

use dope_sys::io::socket::{
    How,
    option::{Kind, Source as _},
};

use crate::{
    Uring,
    reactor::{op, ring, sq},
};

pub(crate) const CREATE: op::Code = op::Code::new(ring::ffi::SOCKET);

pub(crate) const CONNECT: op::Code = op::Code::new(ring::ffi::CONNECT);

pub(crate) const ACCEPT: op::Code = op::Code::new(ring::ffi::ACCEPT);

pub(crate) const SHUTDOWN: op::Code = op::Code::new(ring::ffi::SHUTDOWN);

pub(crate) const SET_OPTION: op::Code = op::Code::new(ring::ffi::URING_CMD);

/// Direct descriptors use the ring's nonblocking issue and asynchronous retry path.
pub(crate) fn accept(file: sq::Fixed) -> sq::Entry {
    use crate::reactor::ring::ffi;

    let mut entry = sq::Entry::new(ACCEPT, sq::Descriptor::Fixed(file));
    entry.fields().index = ffi::FILE_INDEX_ALLOC;
    entry
}

pub(crate) fn shutdown(file: sq::Fixed, how: How) -> sq::Entry {
    let mut entry = sq::Entry::new(SHUTDOWN, sq::Descriptor::Fixed(file));
    entry.fields().length = how.raw() as u32;
    entry
}

pub(crate) fn set_option(file: sq::Fixed, option: Kind, value: &libc::c_int) -> sq::Borrowed<'_> {
    use crate::reactor::ring::ffi;

    let (level, name) = Uring::option(option);
    let mut pair = [0; 8];
    pair[..4].copy_from_slice(&level.to_ne_bytes());
    pair[4..].copy_from_slice(&name.to_ne_bytes());
    let mut entry = sq::Entry::new(SET_OPTION, sq::Descriptor::Fixed(file));
    let fields = entry.fields();
    fields.offset[..4].copy_from_slice(&ffi::SOCKET_SETSOCKOPT.to_ne_bytes());
    fields.address = u64::from_ne_bytes(pair);
    fields.index = mem::size_of::<libc::c_int>() as u32;
    fields.address3 = ptr::from_ref(value) as u64;
    sq::Borrowed::new(entry)
}