io-uring 0.3.3

The `io_uring` library for Rust.
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
89
90
91
92
93
94
95
96
97
98
99
100
101

mod common;

use std::io;
use std::os::unix::io::AsRawFd;
use io_uring::opcode::{ self, types };
use io_uring::IoUring;
use common::Fd;


#[test]
fn test_cancel_nop() -> anyhow::Result<()> {
    let mut ring = IoUring::new(4)?;

    let nop_e = opcode::Nop::new()
        .build()
        .user_data(0x01);
    let cancel_e = opcode::AsyncCancel::new(0x01)
        .build()
        .user_data(0x02);

    unsafe {
        let mut sq = ring.submission().available();
        sq.push(nop_e)
            .ok()
            .expect("squeue is full");
        sq.push(cancel_e)
            .ok()
            .expect("squeue is full");
    }

    ring.submit_and_wait(2)?;

    let mut cqes = ring
        .completion()
        .available()
        .collect::<Vec<_>>();
    cqes.sort_by_key(|cqe| cqe.user_data());

    assert_eq!(cqes[0].user_data(), 0x01);
    assert_eq!(cqes[0].result(), 0);
    assert_eq!(cqes[1].user_data(), 0x02);
    assert_eq!(cqes[1].result(), -libc::ENOENT);

    Ok(())
}

#[test]
fn test_cancel_pipe() -> anyhow::Result<()> {
    let mut ring = IoUring::new(4)?;
    let (rp, wp) = nix::unistd::pipe()?;
    let (rp, _wp) = (Fd(rp), Fd(wp));

    let mut buf = [0; 8];
    let mut bufs = [io::IoSliceMut::new(&mut buf)];
    let readv_e = {
        let rp = types::Target::Fd(rp.as_raw_fd());
        let bufs_ptr = bufs.as_mut_ptr() as *mut _;
        opcode::Readv::new(rp, bufs_ptr, 1)
    }
        .build()
        .user_data(0x01);

    let cancel_e = opcode::AsyncCancel::new(0x01)
        .build()
        .user_data(0x02);

    unsafe {
        ring
            .submission()
            .available()
            .push(readv_e)
            .ok()
            .expect("queue is full");
    }

    ring.submit()?;

    unsafe {
        ring
            .submission()
            .available()
            .push(cancel_e)
            .ok()
            .expect("queue is full");
    }

    ring.submit_and_wait(2)?;

    let mut cqes = ring
        .completion()
        .available()
        .collect::<Vec<_>>();
    cqes.sort_by_key(|cqe| cqe.user_data());

    assert_eq!(cqes[0].user_data(), 0x01);
    assert_eq!(cqes[0].result(), -libc::ECANCELED);
    assert_eq!(cqes[1].user_data(), 0x02);
    assert_eq!(cqes[1].result(), 0);

    Ok(())
}