Function test_unix_msg_with_combo

tests/net/unix.rs:753–963

()

#[cfg(not(target_os = "freebsd"))] // TODO: Investigate why these tests fail on FreeBSD.
#[test]
fn test_unix_msg_with_combo() {
    crate::init();

    use rustix::fd::AsFd as _;
    use rustix::io::{IoSlice, IoSliceMut};
    use rustix::net::{
        recvmsg, sendmsg, RecvAncillaryBuffer, RecvAncillaryMessage, RecvFlags, ReturnFlags,
        SendAncillaryBuffer, SendAncillaryMessage, SendFlags,
    };
    use rustix::pipe::pipe;
    use std::string::ToString as _;

    let tmpdir = tempfile::tempdir().unwrap();
    let path = tmpdir.path().join("scp_4804");

    let server = {
        let path = path.clone();

        let connection_socket = socket(AddressFamily::UNIX, SocketType::SEQPACKET, None).unwrap();

        let name = SocketAddrUnix::new(&path).unwrap();
        bind(&connection_socket, &name).unwrap();
        listen(&connection_socket, 1).unwrap();

        move || {
            let mut pipe_end = None;
            let mut another_pipe_end = None;
            let mut yet_another_pipe_end = None;

            let mut buffer = [0; BUFFER_SIZE];
            let mut cmsg_space =
                [MaybeUninit::uninit(); rustix::cmsg_space!(ScmRights(2), ScmRights(1))];

            'exit: loop {
                let data_socket = accept(&connection_socket).unwrap();
                let mut sum = 0;
                loop {
                    let mut cmsg_buffer = RecvAncillaryBuffer::new(cmsg_space.as_mut_slice());
                    let result = recvmsg(
                        &data_socket,
                        &mut [IoSliceMut::new(&mut buffer)],
                        &mut cmsg_buffer,
                        RecvFlags::empty(),
                    )
                    .unwrap();
                    let nread = result.bytes;

                    assert_eq!(result.flags, ReturnFlags::empty());

                    // Read out the pipe if we got it.
                    for cmsg in cmsg_buffer.drain() {
                        match cmsg {
                            RecvAncillaryMessage::ScmRights(rights) => {
                                for right in rights {
                                    if pipe_end.is_none() {
                                        pipe_end = Some(right);
                                    } else if another_pipe_end.is_none() {
                                        another_pipe_end = Some(right);