#![feature(prelude_import)] //! examples/lock.rs #![deny(unsafe_code)] #![deny(warnings)] #![no_main] #![no_std] #[prelude_import] use core::prelude::v1::*; #[macro_use] extern crate core; #[macro_use] extern crate compiler_builtins; use cortex_m_semihosting::{debug, hprintln}; use lm3s6965::Interrupt; use panic_semihosting as _; #[allow(non_snake_case)] fn init(_: init::Context) { rtic::pend(Interrupt::GPIOA); } #[allow(non_snake_case)] fn gpioa(mut c: gpioa::Context) { use rtic::Mutex as _; ::cortex_m_semihosting::export::hstdout_str("A\n").unwrap(); c.resources.shared.lock(|shared| { *shared += 1; rtic::pend(Interrupt::GPIOB); ::cortex_m_semihosting::export::hstdout_fmt(::core::fmt::Arguments::new_v1( &["B - shared = ", "\n"], &match (&*shared,) { (arg0,) => [::core::fmt::ArgumentV1::new( arg0, ::core::fmt::Display::fmt, )], }, )) .unwrap(); rtic::pend(Interrupt::GPIOC); }); ::cortex_m_semihosting::export::hstdout_str("E\n").unwrap(); debug::exit(debug::EXIT_SUCCESS); } #[allow(non_snake_case)] fn gpiob(c: gpiob::Context) { use rtic::Mutex as _; *c.resources.shared += 1; ::cortex_m_semihosting::export::hstdout_fmt(::core::fmt::Arguments::new_v1( &["D - shared = ", "\n"], &match (&*c.resources.shared,) { (arg0,) => [::core::fmt::ArgumentV1::new( arg0, ::core::fmt::Display::fmt, )], }, )) .unwrap(); } #[allow(non_snake_case)] fn gpioc(_: gpioc::Context) { use rtic::Mutex as _; ::cortex_m_semihosting::export::hstdout_str("C\n").unwrap(); } #[allow(non_snake_case)] ///Initialization function pub mod init { /// Execution context pub struct Context { /// Core (Cortex-M) peripherals pub core: rtic::export::Peripherals, } impl Context { #[inline(always)] pub unsafe fn new(core: rtic::export::Peripherals) -> Self { Context { core } } } } mod resources { use core::cell::Cell; use rtic::export::Priority; #[allow(non_camel_case_types)] pub struct shared<'a> { priority: &'a Priority, locked: Cell, } impl<'a> shared<'a> { #[inline(always)] pub unsafe fn new(priority: &'a Priority) -> Self { shared { priority, locked: Cell::new(false), } } #[inline(always)] pub unsafe fn priority(&self) -> &Priority { self.priority } #[inline(always)] pub unsafe fn get_locked(&self) -> bool { self.locked.get() } pub unsafe fn set_locked(&self, b: bool) { self.locked.set(b); } } } #[allow(non_snake_case)] ///Resources `gpioa` has access to pub struct gpioaResources<'a> { pub shared: resources::shared<'a>, } #[allow(non_snake_case)] ///Hardware task pub mod gpioa { #[doc(inline)] pub use super::gpioaResources as Resources; /// Execution context pub struct Context<'a> { /// Resources this task has access to pub resources: Resources<'a>, } impl<'a> Context<'a> { #[inline(always)] pub unsafe fn new(priority: &'a rtic::export::Priority) -> Self { Context { resources: Resources::new(priority), } } } } #[allow(non_snake_case)] ///Resources `gpiob` has access to pub struct gpiobResources<'a> { pub shared: &'a mut u32, } #[allow(non_snake_case)] ///Hardware task pub mod gpiob { #[doc(inline)] pub use super::gpiobResources as Resources; /// Execution context pub struct Context<'a> { /// Resources this task has access to pub resources: Resources<'a>, } impl<'a> Context<'a> { #[inline(always)] pub unsafe fn new(priority: &'a rtic::export::Priority) -> Self { Context { resources: Resources::new(priority), } } } } #[allow(non_snake_case)] ///Hardware task pub mod gpioc { /// Execution context pub struct Context {} impl Context { #[inline(always)] pub unsafe fn new(priority: &rtic::export::Priority) -> Self { Context {} } } } /// Implementation details const APP: () = { #[doc = r" Always include the device crate which contains the vector table"] use lm3s6965 as _; #[allow(non_upper_case_globals)] static mut shared: u32 = 0; impl<'a> rtic::Mutex for resources::shared<'a> { type T = u32; #[inline(always)] fn lock(&self, f: impl FnOnce(&mut u32) -> R) -> R { #[doc = r" Priority ceiling"] const CEILING: u8 = 2u8; if unsafe { self.get_locked() } { ::core::panicking::panic("Resource locked in sequential context"); }; unsafe { self.set_locked(true); } let r = unsafe { rtic::export::lock( &mut shared, self.priority(), CEILING, lm3s6965::NVIC_PRIO_BITS, f, ) }; unsafe { self.set_locked(false); } r } } #[allow(non_snake_case)] #[no_mangle] unsafe fn GPIOA() { const PRIORITY: u8 = 1u8; rtic::export::run(PRIORITY, || { crate::gpioa(gpioa::Context::new(&rtic::export::Priority::new(PRIORITY))) }); } impl<'a> gpioaResources<'a> { #[inline(always)] unsafe fn new(priority: &'a rtic::export::Priority) -> Self { gpioaResources { shared: resources::shared::new(priority), } } } #[allow(non_snake_case)] #[no_mangle] unsafe fn GPIOB() { const PRIORITY: u8 = 2u8; rtic::export::run(PRIORITY, || { crate::gpiob(gpiob::Context::new(&rtic::export::Priority::new(PRIORITY))) }); } impl<'a> gpiobResources<'a> { #[inline(always)] unsafe fn new(priority: &'a rtic::export::Priority) -> Self { gpiobResources { shared: &mut shared, } } } #[allow(non_snake_case)] #[no_mangle] unsafe fn GPIOC() { const PRIORITY: u8 = 3u8; rtic::export::run(PRIORITY, || { crate::gpioc(gpioc::Context::new(&rtic::export::Priority::new(PRIORITY))) }); } #[no_mangle] unsafe extern "C" fn main() -> ! { let _TODO: () = (); rtic::export::interrupt::disable(); let mut core: rtic::export::Peripherals = core::mem::transmute(()); let _ = [(); ((1 << lm3s6965::NVIC_PRIO_BITS) - 1u8 as usize)]; core.NVIC.set_priority( lm3s6965::Interrupt::GPIOA, rtic::export::logical2hw(1u8, lm3s6965::NVIC_PRIO_BITS), ); rtic::export::NVIC::unmask(lm3s6965::Interrupt::GPIOA); let _ = [(); ((1 << lm3s6965::NVIC_PRIO_BITS) - 2u8 as usize)]; core.NVIC.set_priority( lm3s6965::Interrupt::GPIOB, rtic::export::logical2hw(2u8, lm3s6965::NVIC_PRIO_BITS), ); rtic::export::NVIC::unmask(lm3s6965::Interrupt::GPIOB); let _ = [(); ((1 << lm3s6965::NVIC_PRIO_BITS) - 3u8 as usize)]; core.NVIC.set_priority( lm3s6965::Interrupt::GPIOC, rtic::export::logical2hw(3u8, lm3s6965::NVIC_PRIO_BITS), ); rtic::export::NVIC::unmask(lm3s6965::Interrupt::GPIOC); core.SCB.scr.modify(|r| r | 1 << 1); let late = crate::init(init::Context::new(core.into())); rtic::export::interrupt::enable(); loop { rtic::export::wfi() } } };