fio 0.0.0-alpha.1

An io_uring-backed async runtime
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

use io_uring::{opcode, squeue, types};

use crate::{util::map_buf_result, BufResult, UringOp};

pub struct Read {
    pub buf: Vec<u8>,
    pub fd: crate::Fd,
}

unsafe impl UringOp for Read {
    type Output = BufResult<usize>;

    fn as_entry(&mut self) -> squeue::Entry {
        opcode::Read::new(
            types::Fd(self.fd.0),
            self.buf.as_mut_ptr(),
            u32::try_from(self.buf.len()).unwrap(),
        )
        .build()
    }

    fn into_result(self, result: i32) -> Self::Output {
        // TODO: Handle results greater than 2^31 - 1
        map_buf_result(result, self.buf, |n| n as usize)
    }
}