linux-aio-tokio 0.1.0

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

use std::fs::OpenOptions;
use std::io;
use std::os::unix::prelude::*;
use std::path::PathBuf;

use async_trait::async_trait;

#[async_trait]
/// Extension trait to [`OpenOptions`] to support opening files
/// in AIO mode
///
/// [`OpenOptions`]: ../tokio/fs/struct.OpenOptions.html
pub trait AioOpenOptionsExt {
    /// Opens a file at `path` with the options specified by `self` in direct mode
    /// for usage with AIO. It always adds `O_DIRECT` flag
    ///
    /// If `is_sync` is true, additionALLY `O_SYNC` flag will be added
    ///
    /// # Errors
    /// Error codes are the same as in the tokio version
    ///
    /// ```
    async fn aio_open(mut self, path: PathBuf, is_sync: bool) -> io::Result<crate::fs::File>;
}

#[async_trait]
impl AioOpenOptionsExt for OpenOptions {
    async fn aio_open(mut self, path: PathBuf, is_sync: bool) -> io::Result<crate::fs::File> {
        self.custom_flags(libc::O_DIRECT);

        if is_sync {
            self.custom_flags(libc::O_SYNC);
        }

        let tokio_file = tokio::fs::OpenOptions::from(self).open(path).await?;

        Ok(crate::fs::File { inner: tokio_file })
    }
}