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
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

// TODO test various error conditions

mod no_client;
mod no_server;
mod stream;
mod timeout;

use {
    crate::{local_socket::prelude::*, tests::util::*},
    color_eyre::eyre::bail,
    std::io,
};

fn test_stream(id: &'static str, path: bool) -> TestResult {
    use {io::ErrorKind::*, stream::*};
    let scl = |s, n| server(id, handle_client, s, n, path);
    let name = drive_server_and_multiple_clients(scl, |_| Ok(()), client)?;
    match LocalSocketStream::connect(name.borrow()) {
        Err(e) if matches!(e.kind(), NotFound | ConnectionRefused) => Ok(()),
        Err(e) => bail!(
            "expected NotFound or ConnectionRefused when connecting to dropped listener, got {e}"
        ),
        Ok(s) => bail!("unexpectedly succeeded in connecting to dropped listener: {s:?}"),
    }
}

#[allow(unused_imports)]
use {
    no_client::run_and_verify_error as test_no_client,
    no_server::run_and_verify_error as test_no_server, timeout::main as test_timeout,
};

macro_rules! tests {
    ($fn:ident $nm:ident $path:ident) => {
        #[test]
        fn $nm() -> TestResult {
            test_wrapper(|| { $fn(make_id!(), $path) })
        }
    };
    ($fn:ident $($nm:ident $path:ident)+) => { $(tests!($fn $nm $path);)+ };
}

tests! {test_stream
    stream_file       true
    stream_namespaced false
}

tests! {test_no_server
    no_server_file       true
    no_server_namespaced false
}

tests! {test_no_client
    no_client_file       true
    no_client_namespaced false
}

#[cfg(not(windows))]
tests! {test_timeout
    timeout_file       true
    timeout_namespaced false
}