use core::cell::RefCell;
use critical_section::{CriticalSection, Mutex};
use peripherals::TIMG0;
use super::AlarmState;
use crate::{
clock::Clocks,
peripherals,
prelude::*,
timer::{Timer, Timer0},
};
pub const ALARM_COUNT: usize = 1;
pub type TimerType = Timer<Timer0<TIMG0>>;
pub struct EmbassyTimer {
pub(crate) alarms: Mutex<[AlarmState; ALARM_COUNT]>,
pub(crate) timer: Mutex<RefCell<Option<TimerType>>>,
}
const ALARM_STATE_NONE: AlarmState = AlarmState::new();
embassy_time::time_driver_impl!(static DRIVER: EmbassyTimer = EmbassyTimer {
alarms: Mutex::new([ALARM_STATE_NONE; ALARM_COUNT]),
timer: Mutex::new(RefCell::new(None)),
});
impl EmbassyTimer {
pub(crate) fn now() -> u64 {
critical_section::with(|cs| DRIVER.timer.borrow_ref(cs).as_ref().unwrap().now())
}
pub(crate) fn trigger_alarm(&self, n: usize, cs: CriticalSection) {
let alarm = &self.alarms.borrow(cs)[n];
let f: fn(*mut ()) = unsafe { core::mem::transmute(alarm.callback.get()) };
f(alarm.ctx.get());
}
fn on_interrupt(&self, id: u8) {
critical_section::with(|cs| {
let mut tg = self.timer.borrow_ref_mut(cs);
let tg = tg.as_mut().unwrap();
tg.clear_interrupt();
self.trigger_alarm(id as usize, cs);
});
}
pub fn init(clocks: &Clocks, mut timer: TimerType) {
use crate::{interrupt, interrupt::Priority};
timer.set_divider(clocks.apb_clock.to_MHz() as u16);
critical_section::with(|cs| DRIVER.timer.borrow_ref_mut(cs).replace(timer));
interrupt::enable(peripherals::Interrupt::TG0_T0_LEVEL, Priority::max()).unwrap();
#[interrupt]
fn TG0_T0_LEVEL() {
DRIVER.on_interrupt(0);
}
}
pub(crate) fn set_alarm(
&self,
alarm: embassy_time::driver::AlarmHandle,
timestamp: u64,
) -> bool {
critical_section::with(|cs| {
let now = Self::now();
let alarm_state = unsafe { self.alarms.borrow(cs).get_unchecked(alarm.id() as usize) };
let mut tg = self.timer.borrow_ref_mut(cs);
let tg = tg.as_mut().unwrap();
if timestamp < now {
tg.unlisten();
alarm_state.timestamp.set(u64::MAX);
return false;
}
alarm_state.timestamp.set(timestamp);
tg.load_alarm_value(timestamp);
tg.listen();
tg.set_counter_decrementing(false);
tg.set_auto_reload(false);
tg.set_counter_active(true);
tg.set_alarm_active(true);
true
})
}
}