qubit-clock 0.12.0

Injectable wall and monotonic clocks with deterministic timers
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
63
64
65
66
67

// =============================================================================
//    Copyright (c) 2025 - 2026 Haixing Hu.
//
//    SPDX-License-Identifier: Apache-2.0
//
//    Licensed under the Apache License, Version 2.0.
// =============================================================================

// qubit-style: allow coverage-cfg

#[cfg(coverage)]
use qubit_clock::{
    StdMonotonicClock,
    StdTimer,
    Timer,
    reset_std_timer_worker_notification_count,
    std_timer_worker_notification_count,
};
#[cfg(coverage)]
use std::time::Duration;

/// Verifies the worker is notified only when the earliest deadline changes.
#[cfg(coverage)]
#[test]
fn test_std_timer_scheduler_notifies_only_for_next_deadline_changes() {
    let clock = StdMonotonicClock::new();
    let timer = StdTimer::from_clock(&clock);
    let anchor = timer
        .after(Duration::from_secs(60))
        .expect("anchor deadline should register");

    reset_std_timer_worker_notification_count();
    let later = timer
        .after(Duration::from_secs(120))
        .expect("later deadline should register");
    drop(later);
    assert_eq!(
        std_timer_worker_notification_count(),
        0,
        "a later registration and cancellation must not wake the worker",
    );

    let earlier = timer
        .after(Duration::from_secs(30))
        .expect("earlier deadline should register");
    assert_eq!(
        std_timer_worker_notification_count(),
        1,
        "an earlier registration must wake the worker",
    );

    reset_std_timer_worker_notification_count();
    drop(earlier);
    assert_eq!(
        std_timer_worker_notification_count(),
        1,
        "cancelling the earliest deadline must wake the worker",
    );

    reset_std_timer_worker_notification_count();
    drop(anchor);
    assert_eq!(
        std_timer_worker_notification_count(),
        1,
        "cancelling the last deadline must wake the worker",
    );
}