zbus 6.2.0

API for D-Bus communication and its wire format
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

//! The operations of one end of a pipe to a helper process.

use std::{
    io::{self, IoSlice},
    os::fd::BorrowedFd,
};

use super::SocketOps;
use crate::{connection::socket::RecvmsgResult, runtime::IoSource};

/// The operations of one end of a pipe.
///
/// A pipe carries a stream of bytes in one direction and nothing besides: it has no ancillary
/// data, no peer to ask about and no half that can be shut down on its own.
#[derive(Debug)]
pub(crate) struct PipeOps;

impl SocketOps for PipeOps {
    /// A read of nothing is the other end being gone, which ends the stream rather than failing
    /// it; a caller that needs more than it got says so itself.
    fn recv(&self, source: &IoSource, buffer: &mut [u8]) -> RecvmsgResult {
        let read = rustix::io::read(source, buffer)?;

        Ok((read, vec![]))
    }

    fn send(
        &self,
        source: &IoSource,
        buffers: &[IoSlice<'_>],
        fds: &[BorrowedFd<'_>],
    ) -> io::Result<usize> {
        if !fds.is_empty() {
            return Err(io::Error::new(
                io::ErrorKind::InvalidInput,
                "fds cannot be sent over a pipe",
            ));
        }

        Ok(rustix::io::writev(source, buffers)?)
    }

    /// A pipe ends when the writer lets go of its end, which is also how the write half of one
    /// closes, so there is nothing to shut down here.
    fn shutdown(&self, _source: &IoSource) -> io::Result<()> {
        Ok(())
    }
}