jay-compositor 1.13.0

The Jay compositor
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

use {
    crate::{
        io_uring::{
            IoUringData, IoUringTaskId, Task,
            sys::{IORING_OP_ASYNC_CANCEL, io_uring_sqe},
        },
        utils::errorfmt::ErrorFmt,
    },
    uapi::c,
};

#[derive(Default)]
pub struct AsyncCancelTask {
    id: IoUringTaskId,
    target: IoUringTaskId,
}

impl IoUringData {
    pub fn cancel_task_in_kernel(&self, target: IoUringTaskId) {
        let id = self.id_raw();
        let mut task = self.cached_cancels.pop().unwrap_or_default();
        task.id = id;
        task.target = target;
        self.schedule(task);
    }
}

unsafe impl Task for AsyncCancelTask {
    fn id(&self) -> IoUringTaskId {
        self.id
    }

    fn complete(self: Box<Self>, ring: &IoUringData, res: i32) {
        if let Err(e) = map_err!(res) {
            if e.0 != c::ENOENT {
                log::debug!("Could not cancel task: {}", ErrorFmt(e));
            }
        }
        ring.cached_cancels.push(self);
    }

    fn encode(&self, sqe: &mut io_uring_sqe) {
        sqe.opcode = IORING_OP_ASYNC_CANCEL;
        sqe.u2.addr = self.target.raw();
    }

    fn is_cancel(&self) -> bool {
        true
    }
}