jay-compositor 1.15.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

use crate::io_uring::IoUringData;
use crate::io_uring::IoUringTaskId;
use crate::io_uring::Task;
use crate::io_uring::sys::IORING_OP_ASYNC_CANCEL;
use crate::io_uring::sys::io_uring_cqe;
use crate::io_uring::sys::io_uring_sqe;
use crate::utils::errorfmt::ErrorFmt;
use 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, cqe: &io_uring_cqe) {
        let res = cqe.res;
        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
    }
}