kithara-test-utils 0.0.1-alpha4

kithara test runtime: probe/hang/mock helpers (no-op in release).
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

use std::{marker::PhantomData, path::PathBuf};

use kithara_platform::time::Duration;

pub trait HangDump {
    fn dump_json(&self) -> String;
    fn label(&self) -> Option<&str> {
        None
    }
}

impl<T> HangDump for T {
    fn dump_json(&self) -> String {
        String::new()
    }
}

#[derive(Debug, Default, Clone, Copy)]
pub struct NoContext;

pub struct HangDetector<C: HangDump = NoContext>(PhantomData<C>);

impl<C: HangDump> HangDetector<C> {
    #[inline(always)]
    #[must_use]
    pub fn new(_label: &'static str, _timeout: Duration) -> Self {
        Self(PhantomData)
    }

    /// No watchdog compiled in: bound an event wait by the fallback timeout
    /// rather than below it, so a no-`hang` build still re-checks instead of
    /// blocking forever on a lost wakeup. (`&mut self` mirrors the real
    /// detector, whose lazy deadline stamp needs it.)
    #[inline(always)]
    #[must_use]
    pub fn remaining(&mut self) -> Duration {
        default_timeout()
    }

    #[inline(always)]
    pub fn reset(&mut self) {}

    #[inline(always)]
    pub fn reset_from(&mut self, _file: &'static str, _line: u32) {}

    /// No watchdog compiled in: the context closure is dropped **uncalled**, so
    /// the app-context collection never executes in a no-`hang` (release) build —
    /// a semantic guarantee independent of the optimizer.
    #[inline(always)]
    pub fn reset_with<F: FnOnce() -> C>(&mut self, _ctx_fn: F) {}

    #[inline(always)]
    pub fn reset_with_from<F: FnOnce() -> C>(
        &mut self,
        _ctx_fn: F,
        _file: &'static str,
        _line: u32,
    ) {
    }

    #[inline(always)]
    pub fn tick(&mut self) {}

    #[inline(always)]
    pub fn tick_from(&mut self, _file: &'static str, _line: u32) {}

    /// See [`reset_with`](Self::reset_with): the closure is dropped uncalled.
    #[inline(always)]
    pub fn tick_with<F: FnOnce() -> C>(&mut self, _ctx_fn: F) {}

    #[inline(always)]
    pub fn tick_with_from<F: FnOnce() -> C>(
        &mut self,
        _ctx_fn: F,
        _file: &'static str,
        _line: u32,
    ) {
    }

    #[inline(always)]
    #[must_use]
    pub fn with_dump_dir(self, _dir: PathBuf) -> Self {
        self
    }
}

#[must_use]
pub fn default_timeout() -> Duration {
    // xtask-lint-ignore: retry_fallback
    const FALLBACK_SECS: u64 = 10;
    Duration::from_secs(FALLBACK_SECS)
}