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

use {
    crate::utils::{
        oserror::{OsError, OsErrorExt},
        pipe::pipe,
    },
    std::{rc::Rc, slice},
    uapi::{OwnedFd, c},
};

pub struct FdBlocker(#[expect(dead_code)] pub Rc<OwnedFd>);

pub struct FdBarrier(pub Rc<OwnedFd>);

pub fn create_fd_blocker() -> Result<(FdBlocker, FdBarrier), OsError> {
    let pipe = pipe()?;
    let blocker = FdBlocker(Rc::new(pipe.read));
    let barrier = FdBarrier(Rc::new(pipe.write));
    Ok((blocker, barrier))
}

impl FdBarrier {
    pub fn wait_blocking(&self) -> Result<(), OsError> {
        loop {
            let mut pollfd = c::pollfd {
                fd: self.0.raw(),
                events: 0,
                revents: 0,
            };
            let res = uapi::poll(slice::from_mut(&mut pollfd), -1).to_os_error();
            if let Err(e) = res {
                if e.0 == c::EINTR {
                    continue;
                }
                return Err(e);
            }
            if pollfd.revents & (c::POLLHUP | c::POLLERR) != 0 {
                return Ok(());
            }
        }
    }
}