Function test_port_delay_assumption

tests/event/port.rs:90–183

()

#[cfg(feature = "fs")]
#[test]
fn test_port_delay_assumption() {
    use rustix::fs;

    let tmpdir = tempfile::tempdir().unwrap();
    let fifo_path = tmpdir.path().join("fifo");
    fs::mknodat(
        fs::CWD,
        &fifo_path,
        fs::FileType::Fifo,
        fs::Mode::RUSR
            | fs::Mode::WUSR
            | fs::Mode::RGRP
            | fs::Mode::WGRP
            | fs::Mode::ROTH
            | fs::Mode::WOTH,
        0,
    )
    .unwrap();

    let fifo_path_clone = fifo_path.clone();
    let _mutater = std::thread::Builder::new()
        .name("mutater".to_string())
        .spawn(|| {
            let fifo = fs::openat(
                fs::CWD,
                fifo_path_clone,
                fs::OFlags::WRONLY,
                fs::Mode::empty(),
            )
            .unwrap();

            for i in 0..10 {
                let buf = [b'A' + (i % 26)];
                match rustix::io::write(&fifo, &buf) {
                    Ok(1) => {}
                    Ok(n) => panic!("unexpected write of length {}", n),
                    Err(rustix::io::Errno::PIPE) => return,
                    Err(err) => Err(err).unwrap(),
                }
                std::thread::sleep(std::time::Duration::new(0, 4_000_000));
            }
            panic!("Loop iterated too many times without completing!");
        })
        .unwrap();

    let fifo = fs::openat(fs::CWD, &fifo_path, fs::OFlags::RDONLY, fs::Mode::empty()).unwrap();

    unsafe {
        use rustix::fd::AsRawFd;
        use std::ffi::c_void;

        let port = libc::port_create();
        assert_ne!(port, -1);

        for i in 0..5 {
            let r = libc::port_associate(
                port,
                libc::PORT_SOURCE_FD,