//! Interrupts use core::cell::UnsafeCell; /// A "mutex" based on critical sections pub struct Mutex { inner: UnsafeCell, } impl Mutex { /// Creates a new mutex pub const fn new(value: T) -> Self { Mutex { inner: UnsafeCell::new(value) } } } impl Mutex { /// Borrows the data for the duration of the critical section pub fn borrow<'cs>(&self, _ctxt: &'cs CriticalSection) -> &'cs T { unsafe { &*self.inner.get() } } } /// Interrupt number pub unsafe trait Nr { /// Returns the number associated with this interrupt fn nr(&self) -> u8; } // NOTE `Mutex` can be used as a channel so, the protected data must be `Send` // to prevent sending non-Sendable stuff (e.g. interrupt tokens) across // different execution contexts (e.g. interrupts) unsafe impl Sync for Mutex where T: Send, { } /// Disables all interrupts #[inline(always)] pub fn disable() { match () { #[cfg(target_arch = "arm")] () => unsafe { asm!("cpsid i" : : : : "volatile"); }, #[cfg(not(target_arch = "arm"))] () => {} } } /// Enables all the interrupts /// /// # Safety /// /// - Do not call this function inside an `interrupt::free` critical section #[inline(always)] pub unsafe fn enable() { match () { #[cfg(target_arch = "arm")] () => { asm!("cpsie i" : : : : "volatile"); } #[cfg(not(target_arch = "arm"))] () => {} } } /// Critical section context /// /// Indicates that you are executing code within a critical section pub struct CriticalSection { _0: (), } /// Execute closure `f` in an interrupt-free context. /// /// This as also known as a "critical section". pub fn free(f: F) -> R where F: FnOnce(&CriticalSection) -> R, { let primask = ::register::primask::read(); // disable interrupts disable(); let r = f(&CriticalSection { _0: () }); // If the interrupts were active before our `disable` call, then re-enable // them. Otherwise, keep them disabled if primask.is_active() { unsafe { enable() } } r }