9812a02f87
There should no longer be any - read - write - connect - sendmsg - recvmsg - accept calls in the codebase. Previously we were using a mix of io_uring and these calls which had some negative effects: Since we were using the old system calls, we had to set the file descriptors to non-blocking. But our io_uring code did not handle EAGAIN. This lead to programs sometimes being killed when the wayland IO was actually blocking. Now all file descriptors are set to blocking, but io_uring makes it non-blocking from our perspective. The one exception are evdev files because they are read via libinput and libinput uses the old system calls.
72 lines
1.8 KiB
Rust
72 lines
1.8 KiB
Rust
use {
|
|
crate::{utils::buf::DynamicBuf, xcon::Message},
|
|
std::rc::Rc,
|
|
uapi::{AssertPacked, OwnedFd, Packed},
|
|
};
|
|
|
|
pub struct Formatter<'a> {
|
|
fds: &'a mut Vec<Rc<OwnedFd>>,
|
|
buf: &'a mut DynamicBuf,
|
|
ext_opcode: u8,
|
|
}
|
|
|
|
impl<'a> Formatter<'a> {
|
|
pub fn new(fds: &'a mut Vec<Rc<OwnedFd>>, buf: &'a mut DynamicBuf, ext_opcode: u8) -> Self {
|
|
Self {
|
|
fds,
|
|
buf,
|
|
ext_opcode,
|
|
}
|
|
}
|
|
|
|
pub fn ext_opcode(&self) -> u8 {
|
|
self.ext_opcode
|
|
}
|
|
|
|
pub fn pad(&mut self, pad: usize) {
|
|
static BUF: [u8; 8] = [0; 8];
|
|
self.buf.extend_from_slice(&BUF[..pad]);
|
|
}
|
|
|
|
pub fn pad_to(&mut self, size: usize) {
|
|
static BUF: [u8; 8] = [0; 8];
|
|
while self.buf.len() < size {
|
|
let len = (size - self.buf.len()).min(8);
|
|
self.buf.extend_from_slice(&BUF[..len]);
|
|
}
|
|
}
|
|
|
|
pub fn align(&mut self, alignment: usize) {
|
|
static BUF: [u8; 8] = [0; 8];
|
|
let len = self.buf.len().wrapping_neg() & (alignment - 1);
|
|
self.buf.extend_from_slice(&BUF[..len]);
|
|
}
|
|
|
|
pub fn write_packed<T: Packed + ?Sized>(&mut self, t: &T) {
|
|
self.buf.extend_from_slice(uapi::as_bytes(t));
|
|
}
|
|
|
|
pub fn write_list<'b, T: Message<'b>>(&mut self, t: &[T]) {
|
|
if T::IS_POD {
|
|
self.buf
|
|
.extend_from_slice(uapi::as_bytes(unsafe { AssertPacked::new(t) }));
|
|
} else {
|
|
for t in t {
|
|
t.serialize(self);
|
|
}
|
|
}
|
|
}
|
|
|
|
pub fn write_bytes(&mut self, b: &[u8]) {
|
|
self.buf.extend_from_slice(b);
|
|
}
|
|
|
|
pub fn write_request_length(&mut self) {
|
|
let len: u16 = (self.buf.len() / 4) as u16;
|
|
self.buf[2..4].copy_from_slice(&len.to_ne_bytes());
|
|
}
|
|
|
|
pub fn add_fd(&mut self, fd: &Rc<OwnedFd>) {
|
|
self.fds.push(fd.clone());
|
|
}
|
|
}
|