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

//! Recv OpCodes API Surface

use crate::uring::UringBearerError;
use crate::Completion;
use crate::UringBearer;

use crate::slab::{RecvMultiRec, RecvRec};

use io_uring_opcode::OpCompletion;
use slabbable::Slabbable;

impl<C: core::fmt::Debug + Clone + OpCompletion> UringBearer<C> {
    /// Add Recv pending Completion. The referenced buffers index must hold only one buffer.
    pub fn add_recv(&mut self, fixed_fd: u32, buf_idx: usize) -> Result<usize, UringBearerError> {
        let taken_buf = self.take_one_mutable_buffer(buf_idx)?;
        if !self._fixed_fd_validate(fixed_fd) {
            return Err(UringBearerError::FdNotRegistered(fixed_fd));
        }
        let key = self
            .fd_slab
            .take_next_with(Completion::Recv(RecvRec::new(fixed_fd as u32, taken_buf)))
            .map_err(UringBearerError::Slabbable)?;

        self._push_to_completion(key)?;
        Ok(key)
    }
    /// Add RecvMulti pending Completion
    pub fn add_recv_multi(
        &mut self,
        fixed_fd: u32,
        buf_group: u16,
    ) -> Result<usize, UringBearerError> {
        if !self._fixed_fd_validate(fixed_fd) {
            return Err(UringBearerError::FdNotRegistered(fixed_fd));
        }
        let key = self
            .fd_slab
            .take_next_with(Completion::RecvMulti(RecvMultiRec::new(
                fixed_fd as u32,
                buf_group,
            )))
            .map_err(UringBearerError::Slabbable)?;

        self._push_to_completion(key)?;
        Ok(key)
    }
}