i2o2 0.4.1

A io_uring based IO executor for sync and async runtimes
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

use std::io;
use std::os::fd::AsRawFd;

#[test]
fn test_madvise_op() {
    super::try_init_logging();

    let (scheduler, handle) = crate::create_for_current_thread::<()>().unwrap();

    let mut mem = memmap2::MmapOptions::new().len(128).map_anon().unwrap();

    let op = crate::opcode::Madvise::new(mem.as_mut_ptr(), 128, libc::MADV_RANDOM);

    let reply = unsafe { handle.submit(op, None).unwrap() };

    drop(handle);
    scheduler.run().unwrap();

    let result = reply.wait().unwrap();
    if result < 0 {
        panic!("got error: {}", io::Error::from_raw_os_error(-result))
    }
}

#[test]
fn test_fallocate_op() {
    super::try_init_logging();

    let (scheduler, handle) = crate::create_for_current_thread::<()>().unwrap();

    let file = tempfile::tempfile().unwrap();

    let op = crate::opcode::Fallocate::new(crate::types::Fd(file.as_raw_fd()), 0, 0, 64);

    let reply = unsafe { handle.submit(op, None).unwrap() };

    drop(handle);
    scheduler.run().unwrap();

    let result = reply.wait().unwrap();
    if result < 0 {
        panic!("got error: {}", io::Error::from_raw_os_error(-result))
    }
}

#[test]
fn test_ftruncate_op() {
    super::try_init_logging();

    let (scheduler, handle) = crate::create_for_current_thread::<()>().unwrap();

    let file = tempfile::tempfile().unwrap();

    let op = crate::opcode::Ftruncate::new(crate::types::Fd(file.as_raw_fd()), 64);

    let reply = unsafe { handle.submit(op, None).unwrap() };

    drop(handle);
    scheduler.run().unwrap();

    let result = reply.wait().unwrap();
    if result < 0 {
        panic!("got error: {}", io::Error::from_raw_os_error(-result))
    }
}

#[rstest::rstest]
#[case::fsync_mode_full(crate::opcode::FSyncMode::Full)]
#[case::fsync_mode_data(crate::opcode::FSyncMode::Data)]
fn test_fsync_op(#[case] mode: crate::opcode::FSyncMode) {
    super::try_init_logging();

    let (scheduler, handle) = crate::create_for_current_thread::<()>().unwrap();

    let file = tempfile::tempfile().unwrap();

    let op = crate::opcode::Fsync::new(crate::types::Fd(file.as_raw_fd()), mode);

    let reply = unsafe { handle.submit(op, None).unwrap() };

    drop(handle);
    scheduler.run().unwrap();

    let result = reply.wait().unwrap();
    if result < 0 {
        panic!("got error: {}", io::Error::from_raw_os_error(-result))
    }
}