interprocess 2.2.2

Interprocess communication toolkit
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use super::{TestResult, WrapErrExt};
use color_eyre::eyre::bail;
use std::{sync::mpsc, thread, time::Duration};

const TIMEOUT: Duration = Duration::from_secs(2);

pub fn run_under_wachdog(f: impl (FnOnce() -> TestResult) + Send + 'static) -> TestResult {
	let (killswitch, timeout_joiner) = mpsc::channel();
	let joiner = thread::Builder::new()
		.name("test main (under watchdog)".to_owned())
		.spawn(move || {
			let ret = f();
			let _ = killswitch.send(());
			ret
		})
		.opname("watchdog scrutinee thread spawn")?;
	if let Err(mpsc::RecvTimeoutError::Timeout) = timeout_joiner.recv_timeout(TIMEOUT) {
		bail!("watchdog timer has run out");
	}
	joiner.join().unwrap()
}