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

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;

pub(crate) struct Symlink {
    pub(crate) _from: CString,
    pub(crate) _to: CString,
}

impl Op<Symlink> {
    pub(crate) fn symlink<P: AsRef<Path>, Q: AsRef<Path>>(from: P, to: Q) -> io::Result<Op<Symlink>> {
        use io_uring::{opcode, types};

        let _from = cstr(from.as_ref())?;
        let _to = cstr(to.as_ref())?;

        CONTEXT.with(|x| {
            x.handle()
                .expect("Not in a runtime context")
                .submit_op(Symlink { _from, _to }, |symlink| {
                    let from_ref = symlink._from.as_c_str().as_ptr();
                    let to_ref = symlink._to.as_c_str().as_ptr();

                    opcode::SymlinkAt::new(types::Fd(libc::AT_FDCWD), from_ref, to_ref).build()
                })
        })
    }
}

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

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