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

use crate::io_uring::IoUring;
use crate::io_uring::IoUringError;
use crate::utils::buf::Buf;
use crate::utils::vecdeque_ext::VecDequeExt;
use isnt::std_1::collections::IsntVecDequeExt;
use std::collections::VecDeque;
use std::rc::Rc;
use uapi::OwnedFd;

pub async fn log_lines(
    ring: &IoUring,
    fd: &Rc<OwnedFd>,
    mut f: impl FnMut(&[u8], &[u8]),
) -> Result<(), IoUringError> {
    let mut buf = VecDeque::<u8>::new();
    let mut buf2 = Buf::new(1024);
    let mut done = false;
    while !done {
        let n = ring.read(fd, buf2.clone()).await?;
        buf.extend(&buf2[..n]);
        if n == 0 {
            done = true;
        }
        while let Some(pos) = buf.iter().position(|b| b == &b'\n') {
            let (left, right) = buf.get_slices(..pos);
            f(left, right);
            buf.drain(..=pos);
        }
    }
    if buf.is_not_empty() {
        let (left, right) = buf.as_slices();
        f(left, right);
    }
    Ok(())
}