svod-device 0.1.0-alpha.3

Device abstraction layer for the Svod ML compiler
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

use super::*;
use std::sync::Arc;
use std::thread;

#[test]
fn test_cpu_signal_basic() {
    let signal = CpuTimelineSignal::new();
    assert_eq!(signal.value(), 0);

    signal.set(5);
    assert_eq!(signal.value(), 5);

    assert!(signal.is_reached(5));
    assert!(signal.is_reached(3));
    assert!(!signal.is_reached(10));
}

#[test]
fn test_cpu_signal_set_is_monotonic() {
    let signal = CpuTimelineSignal::new();
    signal.set(5);
    signal.set(3);

    assert_eq!(signal.value(), 5);
    signal.wait(5, 100).unwrap();
}

#[test]
fn test_cpu_signal_wait_already_reached() {
    let signal = CpuTimelineSignal::new();
    signal.set(10);

    // Should return immediately
    signal.wait(5, 100).unwrap();
    signal.wait(10, 100).unwrap();
}

#[test]
fn test_cpu_signal_wait_concurrent() {
    let signal = Arc::new(CpuTimelineSignal::new());
    let signal_clone = Arc::clone(&signal);

    let waiter = thread::spawn(move || {
        signal_clone.wait(5, 5000).unwrap();
        signal_clone.value()
    });

    // Give waiter time to block
    thread::sleep(std::time::Duration::from_millis(10));

    // Set the signal
    signal.set(5);

    let result = waiter.join().unwrap();
    assert!(result >= 5);
}

#[test]
fn test_cpu_signal_timeout() {
    let signal = CpuTimelineSignal::new();

    // Should timeout waiting for value 10
    let result = signal.wait(10, 50);
    assert!(result.is_err());
}