diff options
| author | bors[bot] <bors[bot]@users.noreply.github.com> | 2018-11-03 16:31:11 +0000 |
|---|---|---|
| committer | bors[bot] <bors[bot]@users.noreply.github.com> | 2018-11-03 16:31:11 +0000 |
| commit | 777765e522949ebf84d05d4db075132172d81494 (patch) | |
| tree | 41bc00739da8f832eb5ba68ef99ec8b9d06111a4 /examples/late.rs | |
| parent | 653338e7997a0cdc5deaed98b1bb5f60006717ed (diff) | |
| parent | 3a867e70c3b1afc4943ec597e4f188432fba5a8b (diff) | |
Merge #97
97: v0.4.0 r=japaric a=japaric
closes #32
closes #33
Co-authored-by: Jorge Aparicio <jorge@japaric.io>
Diffstat (limited to 'examples/late.rs')
| -rw-r--r-- | examples/late.rs | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/examples/late.rs b/examples/late.rs new file mode 100644 index 0000000..6d76c58 --- /dev/null +++ b/examples/late.rs @@ -0,0 +1,65 @@ +//! examples/late.rs + +#![deny(unsafe_code)] +#![deny(warnings)] +#![no_main] +#![no_std] + +extern crate panic_semihosting; + +use cortex_m_semihosting::debug; +use heapless::{ + consts::*, + spsc::{Consumer, Producer, Queue}, +}; +use lm3s6965::Interrupt; +use rtfm::app; + +macro_rules! println { + ($($tt:tt)*) => { + if let Ok(mut stdout) = cortex_m_semihosting::hio::hstdout() { + use core::fmt::Write; + + writeln!(stdout, $($tt)*).ok(); + } + }; +} + +#[app(device = lm3s6965)] +const APP: () = { + // Late resources + static mut P: Producer<'static, u32, U4> = (); + static mut C: Consumer<'static, u32, U4> = (); + + #[init] + fn init() { + // NOTE: we use `Option` here to work around the lack of + // a stable `const` constructor + static mut Q: Option<Queue<u32, U4>> = None; + + *Q = Some(Queue::new()); + let (p, c) = Q.as_mut().unwrap().split(); + + // Initialization of late resources + P = p; + C = c; + } + + #[idle(resources = [C])] + fn idle() -> ! { + loop { + if let Some(byte) = resources.C.dequeue() { + println!("received message: {}", byte); + + debug::exit(debug::EXIT_SUCCESS); + } else { + rtfm::pend(Interrupt::UART0); + } + } + } + + #[interrupt(resources = [P])] + fn UART0() { + resources.P.enqueue(42).unwrap(); + } +}; |
