io-uring-bearer 0.2.0-pre3

io_uring bearer
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

//! Recv Slab records

use io_uring_owner::Owner;

use crate::slab::buffer::TakenMutableBuffer;

/// Recv Record
#[derive(Clone, Debug)]
pub struct RecvRec {
    fixed_fd: u32,
    owner: Owner,
    buf_taken: TakenMutableBuffer,
}

impl RecvRec {
    #[inline]
    pub(crate) fn new(fixed_fd: u32, buf_taken: TakenMutableBuffer) -> Self {
        RecvRec {
            fixed_fd,
            owner: Owner::Created,
            buf_taken,
        }
    }
    #[inline]
    pub(crate) fn entry(&self) -> io_uring::squeue::Entry {
        io_uring::opcode::Recv::new(
            io_uring::types::Fixed(self.fixed_fd),
            self.buf_taken.buf_mut_u8,
            self.buf_taken.buf_size,
        )
        .build()
    }
    #[inline]
    pub(crate) fn owner(&self) -> Owner {
        self.owner.clone()
    }
    #[inline]
    pub(crate) fn force_owner_kernel(&mut self) -> bool {
        self.owner = Owner::Kernel;
        true
    }
}

/// RecvMulti Record
#[derive(Clone, Debug)]
pub struct RecvMultiRec {
    fixed_fd: u32,
    owner: Owner,
    buf_grp_id: u16,
}

impl RecvMultiRec {
    #[inline]
    pub(crate) fn new(fixed_fd: u32, buf_grp_id: u16) -> Self {
        Self {
            fixed_fd,
            buf_grp_id,
            owner: Owner::Created,
        }
    }
    #[inline]
    pub(crate) fn entry(&self) -> io_uring::squeue::Entry {
        io_uring::opcode::RecvMulti::new(io_uring::types::Fixed(self.fixed_fd), self.buf_grp_id)
            .build()
    }
    #[inline]
    pub(crate) fn owner(&self) -> Owner {
        self.owner.clone()
    }
    /// Buffer Group Id
    #[inline]
    pub fn buf_grp_id(&self) -> u16 {
        self.buf_grp_id
    }
    /// Fixed Filehandle Id
    #[inline]
    pub fn fixed_fd(&self) -> u32 {
        self.fixed_fd
    }
    #[inline]
    pub(crate) fn force_owner_kernel(&mut self) -> bool {
        self.owner = Owner::Kernel;
        true
    }
}