mirror of
https://github.com/rtic-rs/rtic.git
synced 2024-11-25 21:19:35 +01:00
270 lines
7.8 KiB
Rust
270 lines
7.8 KiB
Rust
#![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<bool>,
|
|
}
|
|
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<R>(&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()
|
|
}
|
|
}
|
|
};
|