tests/run-make/remove-dir-all-race/rmake.rs

//@ ignore-windows

// This test attempts to make sure that running `remove_dir_all`
// doesn't result in a NotFound error one of the files it
// is deleting is deleted concurrently.
//
// The windows implementation for `remove_dir_all` is significantly
// more complicated, and has not yet been brought up to par with
// the implementation on other platforms, so this test is marked as
// `ignore-windows` until someone more expirenced with windows can
// sort that out.

use std::fs::remove_dir_all;
use std::path::Path;
use std::thread;
use std::time::Duration;

use run_make_support::rfs::{create_dir, write};
use run_make_support::run_in_tmpdir;

fn main() {
    let mut race_happened = false;
    run_in_tmpdir(|| {
        for i in 0..150 {
            create_dir("outer");
            create_dir("outer/inner");
            write("outer/inner.txt", b"sometext");

            thread::scope(|scope| {
                let t1 = scope.spawn(|| {
                    thread::sleep(Duration::from_nanos(i));
                    remove_dir_all("outer").unwrap();
                });

                let race_happened_ref = &race_happened;
                let t2 = scope.spawn(|| {
                    let r1 = remove_dir_all("outer/inner");
                    let r2 = remove_dir_all("outer/inner.txt");
                    if r1.is_ok() && r2.is_err() {
                        race_happened = true;
                    }
                });
            });

            assert!(!Path::new("outer").exists());

            // trying to remove a nonexistant top-level directory should
            // still result in an error.
            let Err(err) = remove_dir_all("outer") else {
                panic!("removing nonexistant dir did not result in an error");
            };
            assert_eq!(err.kind(), std::io::ErrorKind::NotFound);
        }
    });
    if !race_happened {
        eprintln!(
            "WARNING: multithreaded deletion never raced, \
                   try increasing the number of attempts or \
                   adjusting the sleep timing"
        );
    }
}