boppo_wasm 0.1.1

Activity API for the Boppo Tablet, controlling the lights, buttons, and audio via a WASM module.
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
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
93

use std::{cell::RefCell, collections::BinaryHeap, sync::OnceLock, task::Waker, time::Instant};

use embassy_time_driver::Driver;

use embassy_time_driver::time_driver_impl;

thread_local! {
    static TIMERS: RefCell<BinaryHeap<TimerWithWaker>> = const { RefCell::new(BinaryHeap::new()) };
}

static START: OnceLock<Instant> = OnceLock::new();

pub(crate) struct TimerWithWaker {
    at: u64,
    waker: Waker,
}

// reverse ordering for TimerWithWaker based on end so that the nearest instant is on top of the heap
// This requires custom Ord, so partial_ord, partial_eq and eq to be implemented as well
impl PartialEq for TimerWithWaker {
    fn eq(&self, other: &Self) -> bool {
        self.at == other.at
    }
}

impl Eq for TimerWithWaker {}

impl PartialOrd for TimerWithWaker {
    fn partial_cmp(&self, other: &Self) -> Option<std::cmp::Ordering> {
        Some(self.cmp(other))
    }
}

impl Ord for TimerWithWaker {
    fn cmp(&self, other: &Self) -> std::cmp::Ordering {
        // intentionally reversed
        other.at.cmp(&self.at)
    }
}

/// Timer driver implementation for embassy-time
struct BoppoWasmDriver;

impl Driver for BoppoWasmDriver {
    fn now(&self) -> u64 {
        START.get_or_init(Instant::now).elapsed().as_micros() as u64
    }

    fn schedule_wake(&self, at: u64, waker: &Waker) {
        TIMERS.with(|cell| {
            cell.borrow_mut().push(TimerWithWaker {
                at,
                waker: waker.clone(),
            });
        })
    }
}

time_driver_impl!(static DRIVER : BoppoWasmDriver = BoppoWasmDriver);

/// Removes and wakes expired timers
/// This is meant to be called between poll loop iterations so that
/// it stays relevant (polling updates it)
pub(crate) fn wake_and_clean_expired_timers() {
    TIMERS.with(|cell| {
        let mut heap = cell.borrow_mut();
        let now = BoppoWasmDriver.now();
        while heap.peek().is_some_and(|e| e.at <= now) {
            if let Some(timer_with_waker) = heap.pop() {
                timer_with_waker.waker.wake();
            } else {
                break;
            }
        }
    });
}

/// Returns the timeout for the next boppo_wasm_poll function, which
/// is the remaining time in milliseconds before the next deadline.
pub(crate) fn next_timeout() -> i32 {
    TIMERS.with(|cell| {
        let heap = cell.borrow();
        let Some(timer_with_waker) = heap.peek() else {
            return -1;
        };
        let now = BoppoWasmDriver.now();
        if timer_with_waker.at <= now {
            return 0;
        }

        (((timer_with_waker.at - now) / 1000).min(i32::MAX as u64) as i32).max(1)
    })
}