mirror of
https://github.com/rtic-rs/rtic.git
synced 2024-11-26 05:29:38 +01:00
4060c3def8
* Rebase to master * using interrupt_mod * bug fixes * fix other backends * Add changelog * forgot about rtic-macros * backend-specific configuration * core peripherals optional over macro argument * pre_init_preprocessing binding * CI for RISC-V (WIP) * separation of concerns * add targets for RISC-V examples * remove qemu feature * prepare examples folder * move examples all together * move ci out of examples * minor changes * add cortex-m * new xtask: proof of concept * fix build.yml * feature typo * clean rtic examples * reproduce weird issue * remove unsafe code in user app * update dependencies * allow builds on riscv32imc * let's fix QEMU * Update .github/workflows/build.yml Co-authored-by: Henrik Tjäder <henrik@tjaders.com> * New build.rs * removing test features * adapt ui test to new version of clippy * add more examples to RISC-V backend * proper configuration of heapless for riscv32imc * opt-out examples for riscv32imc * point to new version of riscv-slic * adapt new macro bindings * adapt examples and CI to stable * fix cortex-m CI * Review --------- Co-authored-by: Henrik Tjäder <henrik@tjaders.com>
56 lines
1.5 KiB
Rust
56 lines
1.5 KiB
Rust
//! examples/async-channel-try.rs
|
|
|
|
#![no_main]
|
|
#![no_std]
|
|
#![deny(warnings)]
|
|
#![deny(unsafe_code)]
|
|
#![deny(missing_docs)]
|
|
|
|
use panic_semihosting as _;
|
|
|
|
#[rtic::app(device = lm3s6965, dispatchers = [SSI0])]
|
|
mod app {
|
|
use cortex_m_semihosting::{debug, hprintln};
|
|
use rtic_sync::{channel::*, make_channel};
|
|
|
|
#[shared]
|
|
struct Shared {}
|
|
|
|
#[local]
|
|
struct Local {
|
|
sender: Sender<'static, u32, CAPACITY>,
|
|
}
|
|
|
|
const CAPACITY: usize = 1;
|
|
#[init]
|
|
fn init(_: init::Context) -> (Shared, Local) {
|
|
let (s, r) = make_channel!(u32, CAPACITY);
|
|
|
|
receiver::spawn(r).unwrap();
|
|
sender1::spawn(s.clone()).unwrap();
|
|
|
|
(Shared {}, Local { sender: s.clone() })
|
|
}
|
|
|
|
#[task]
|
|
async fn receiver(_c: receiver::Context, mut receiver: Receiver<'static, u32, CAPACITY>) {
|
|
while let Ok(val) = receiver.recv().await {
|
|
hprintln!("Receiver got: {}", val);
|
|
}
|
|
}
|
|
|
|
#[task]
|
|
async fn sender1(_c: sender1::Context, mut sender: Sender<'static, u32, CAPACITY>) {
|
|
hprintln!("Sender 1 sending: 1");
|
|
sender.send(1).await.unwrap();
|
|
hprintln!("Sender 1 try sending: 2 {:?}", sender.try_send(2));
|
|
debug::exit(debug::EXIT_SUCCESS); // Exit QEMU simulator
|
|
}
|
|
|
|
// This interrupt is never triggered, but is used to demonstrate that
|
|
// one can (try to) send data into a channel from a hardware task.
|
|
#[task(binds = GPIOA, local = [sender])]
|
|
fn hw_task(cx: hw_task::Context) {
|
|
cx.local.sender.try_send(3).ok();
|
|
}
|
|
}
|