63 lines
2.0 KiB
Rust
63 lines
2.0 KiB
Rust
//@ 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"
|
|
);
|
|
}
|
|
}
|