interprocess 2.4.0

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
22
23

use {
    super::{TestResult, WrapErrExt},
    color_eyre::eyre::bail,
    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()
}