linux-aio-tokio 0.2.1

Tokio bindings for Linux kernel AIO
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

use crate::{aio, LockedBuf};

/// Represents AIO operation. See [`io_submit`](https://manpages.debian.org/testing/manpages-dev/io_submit.2.en.html)
#[derive(Copy, Clone, Debug)]
pub enum Opcode {
    /// Read
    Pread,

    /// Write
    Pwrite,

    /// Sync data only
    Fdsync,

    /// Sync data and metadata
    Fsync,
}

impl Opcode {
    #[inline]
    pub(crate) fn aio_const(self) -> u32 {
        use Opcode::*;

        match self {
            Pread => aio::IOCB_CMD_PREAD,
            Pwrite => aio::IOCB_CMD_PWRITE,
            Fdsync => aio::IOCB_CMD_FDSYNC,
            Fsync => aio::IOCB_CMD_FSYNC,
        }
    }
}

/// Raw AIO command
#[derive(Debug)]
pub struct RawCommand {
    /// Operation
    pub opcode: Opcode,

    /// Offset in the file
    pub offset: u64,

    /// Optional buffer
    pub buf: Option<LockedBuf>,

    /// ReadFlags or WriteFlags, depending on the operation
    pub flags: u32,
}