interprocess 2.4.0

Interprocess communication toolkit
Documentation 
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

use {
    super::{c_wrappers, unixprelude::*},
    crate::{AsBuf, OrErrno, TryClone},
    std::io::{self, prelude::*, IoSlice, IoSliceMut},
};

#[allow(clippy::cast_sign_loss)]
fn i2u(i: isize) -> usize { i as usize }

#[repr(transparent)]
pub(super) struct FdOps(pub(super) OwnedFd);
impl FdOps {
    pub(super) unsafe fn read_ptr(
        fd: BorrowedFd<'_>,
        ptr: *mut u8,
        len: usize,
    ) -> io::Result<usize> {
        let bytes_read = unsafe { libc::read(fd.as_raw_fd(), ptr.cast(), len) };
        (bytes_read >= 0).true_val_or_errno(i2u(bytes_read))
    }
    pub(super) fn read(fd: BorrowedFd<'_>, buf: &mut (impl AsBuf + ?Sized)) -> io::Result<usize> {
        unsafe { Self::read_ptr(fd, buf.as_ptr(), buf.len()) }
    }
    pub(super) fn write(fd: BorrowedFd<'_>, buf: &[u8]) -> io::Result<usize> {
        let length_to_write = buf.len();
        let bytes_written =
            unsafe { libc::write(fd.as_raw_fd(), buf.as_ptr().cast(), length_to_write) };
        (bytes_written >= 0).true_val_or_errno(i2u(bytes_written))
    }
}
impl Read for &FdOps {
    fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { FdOps::read(self.as_fd(), buf) }
    fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> {
        let num_bufs = c_int::try_from(bufs.len()).unwrap_or(c_int::MAX);
        let bytes_read =
            unsafe { libc::readv(self.0.as_raw_fd(), bufs.as_ptr().cast(), num_bufs) };
        (bytes_read >= 0).true_val_or_errno(i2u(bytes_read))
    }
    // FUTURE can_vector
}
impl Write for &FdOps {
    fn write(&mut self, buf: &[u8]) -> io::Result<usize> { FdOps::write(self.as_fd(), buf) }
    fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> {
        let num_bufs = c_int::try_from(bufs.len()).unwrap_or(c_int::MAX);
        let bytes_written =
            unsafe { libc::writev(self.0.as_raw_fd(), bufs.as_ptr().cast(), num_bufs) };
        (bytes_written >= 0).true_val_or_errno(i2u(bytes_written))
    }
    // FUTURE can_vector
    fn flush(&mut self) -> io::Result<()> {
        unsafe { libc::fsync(self.0.as_raw_fd()) >= 0 }.true_val_or_errno(())
    }
}

impl TryClone for FdOps {
    fn try_clone(&self) -> std::io::Result<Self> {
        let fd = c_wrappers::duplicate_fd(self.0.as_fd())?;
        Ok(Self(fd))
    }
}

multimacro! {
    FdOps,
    forward_handle,
    forward_debug,
    derive_raw,
}