We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent db35c6b commit cedf91bCopy full SHA for cedf91b
src/docker.rs
@@ -2080,11 +2080,17 @@ mod tests {
2080
let count2 = count.clone();
2081
std::thread::spawn(move || {
2082
let docker = Docker::connect_with_defaults().unwrap();
2083
- while count2.fetch_add(1, Ordering::Relaxed) < 2000 {
+ while count2.fetch_add(1, Ordering::Relaxed) < 500 {
2084
let _events = docker.events(None, None, None).unwrap();
2085
}
2086
});
2087
- std::thread::sleep(std::time::Duration::from_secs(10));
2088
- assert_eq!(count.load(Ordering::Relaxed), 2001);
+ loop {
+ let c = count.load(Ordering::Relaxed);
2089
+ if c == 501 {
2090
+ break;
2091
+ }
2092
+ std::thread::sleep(std::time::Duration::from_secs(5));
2093
+ assert_ne!(count.load(Ordering::Relaxed), c);
2094
2095
2096
0 commit comments