Function client

tests/net/unix.rs:64–95

(ready: Arc<(Mutex<bool>, Condvar)>, path: &Path, runs: &[(&[&str], i32)])

}

fn client(ready: Arc<(Mutex<bool>, Condvar)>, path: &Path, runs: &[(&[&str], i32)]) {
    {
        let (lock, cvar) = &*ready;
        let mut started = lock.lock().unwrap();
        while !*started {
            started = cvar.wait(started).unwrap();
        }
    }

    let addr = SocketAddrUnix::new(path).unwrap();
    let mut buffer = [0; BUFFER_SIZE];

    for (args, sum) in runs {
        let data_socket = socket(AddressFamily::UNIX, SocketType::SEQPACKET, None).unwrap();
        connect(&data_socket, &addr).unwrap();

        for arg in *args {
            write(&data_socket, arg.as_bytes()).unwrap();
        }
        write(&data_socket, b"sum").unwrap();

        let nread = read(&data_socket, &mut buffer).unwrap();
        assert_eq!(
            i32::from_str(&String::from_utf8_lossy(&buffer[..nread])).unwrap(),
            *sum
        );
    }

    let data_socket = socket(AddressFamily::UNIX, SocketType::SEQPACKET, None).unwrap();
    connect(&data_socket, &addr).unwrap();
    write(&data_socket, b"exit").unwrap();
}

#[test]
#[cfg(not(target_os = "freebsd"))] // TODO: Investigate why these tests fail on FreeBSD.