slings 0.3.47

A small async runtime based on io-uring for Rust
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

use std::io;
use std::os::unix::io::RawFd;

use io_uring::{opcode, types};

use crate::driver::{Completable, CqeResult, Op};

pub(crate) struct Recv {
    buf: Vec<u8>,
}

impl Op<Recv> {
    pub(crate) fn recv(fd: RawFd, len: usize) -> io::Result<Op<Recv>> {
        let mut buf = Vec::with_capacity(len);
        let entry = opcode::Recv::new(types::Fd(fd), buf.as_mut_ptr(), len as u32).build();
        Op::submit(Recv { buf }, entry)
    }
}

impl Completable for Recv {
    type Output = io::Result<Vec<u8>>;

    fn complete(mut self, cqe: CqeResult) -> Self::Output {
        let n = cqe.result? as usize;
        unsafe { self.buf.set_len(n) };
        Ok(self.buf)
    }
}