tokio-uring-xitca 0.2.0

a fork of tokio-uring with miniaml maintenance
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

use crate::runtime::CONTEXT;
use crate::runtime::driver::op::{Completable, CqeResult, Op};

use super::util::cstr;

use std::ffi::CString;
use std::io;
use std::path::Path;

/// Create a directory at path relative to the current working directory
/// of the caller's process.
pub(crate) struct Mkdir {
    pub(crate) _path: CString,
}

impl Op<Mkdir> {
    /// Submit a request to create a directory
    pub(crate) fn make_dir(path: &Path, mode: u32) -> io::Result<Op<Mkdir>> {
        use io_uring::{opcode, types};

        let _path = cstr(path)?;

        CONTEXT.with(|x| {
            x.handle()
                .expect("Not in a runtime context")
                .submit_op(Mkdir { _path }, |mkdir| {
                    let p_ref = mkdir._path.as_c_str().as_ptr();

                    opcode::MkDirAt::new(types::Fd(libc::AT_FDCWD), p_ref)
                        .mode(mode)
                        .build()
                })
        })
    }
}

impl Completable for Mkdir {
    type Output = io::Result<()>;

    fn complete(self, cqe: CqeResult) -> Self::Output {
        cqe.result.map(|_| ())
    }
}