aboutsummaryrefslogtreecommitdiff
path: root/examples/async-task-multiple-prios.rs
diff options
context:
space:
mode:
authorGravatar Emil Fresk <emil.fresk@gmail.com> 2022-08-05 08:59:16 +0200
committerGravatar Emil Fresk <emil.fresk@gmail.com> 2022-08-05 09:00:46 +0200
commitb48a95e87930fa51ef6fb47ad08a95d3159d9bac (patch)
treeb2475335911408e0b59751980823bd11db742308 /examples/async-task-multiple-prios.rs
parent4488ac0421b53ffa5b97e6dddd396cbdb52c6283 (diff)
downloadrtic-b48a95e87930fa51ef6fb47ad08a95d3159d9bac.tar.gz
rtic-b48a95e87930fa51ef6fb47ad08a95d3159d9bac.tar.zst
rtic-b48a95e87930fa51ef6fb47ad08a95d3159d9bac.zip
Fix codegen when having executor at multiple priorities
The codegen generated code for all executors in all dispatchers, which caused some weird bugs. Also the definition of an executor was not generated globally, this caused use after free errors when having multiple priority levels.
Diffstat (limited to 'examples/async-task-multiple-prios.rs')
-rw-r--r--examples/async-task-multiple-prios.rs73
1 files changed, 73 insertions, 0 deletions
diff --git a/examples/async-task-multiple-prios.rs b/examples/async-task-multiple-prios.rs
new file mode 100644
index 00000000..a90c11bd
--- /dev/null
+++ b/examples/async-task-multiple-prios.rs
@@ -0,0 +1,73 @@
+#![no_main]
+#![no_std]
+#![feature(type_alias_impl_trait)]
+
+use panic_semihosting as _;
+
+// NOTES:
+//
+// - Async tasks cannot have `#[lock_free]` resources, as they can interleve and each async
+// task can have a mutable reference stored.
+// - Spawning an async task equates to it being polled once.
+
+#[rtic::app(device = lm3s6965, dispatchers = [SSI0, UART0], peripherals = true)]
+mod app {
+ use cortex_m_semihosting::{debug, hprintln};
+ use systick_monotonic::*;
+
+ #[shared]
+ struct Shared {}
+
+ #[local]
+ struct Local {}
+
+ #[monotonic(binds = SysTick, default = true)]
+ type MyMono = Systick<100>;
+
+ #[init]
+ fn init(cx: init::Context) -> (Shared, Local, init::Monotonics) {
+ hprintln!("init").unwrap();
+
+ normal_task::spawn().ok();
+ async_task::spawn().ok();
+ normal_task2::spawn().ok();
+ async_task2::spawn().ok();
+
+ (
+ Shared {},
+ Local {},
+ init::Monotonics(Systick::new(cx.core.SYST, 12_000_000)),
+ )
+ }
+
+ #[idle]
+ fn idle(_: idle::Context) -> ! {
+ // debug::exit(debug::EXIT_SUCCESS);
+ loop {
+ // hprintln!("idle");
+ cortex_m::asm::wfi(); // put the MCU in sleep mode until interrupt occurs
+ }
+ }
+
+ #[task(priority = 1)]
+ fn normal_task(_cx: normal_task::Context) {
+ hprintln!("hello from normal 1").ok();
+ }
+
+ #[task(priority = 1)]
+ async fn async_task(_cx: async_task::Context) {
+ hprintln!("hello from async 1").ok();
+
+ debug::exit(debug::EXIT_SUCCESS);
+ }
+
+ #[task(priority = 2)]
+ fn normal_task2(_cx: normal_task2::Context) {
+ hprintln!("hello from normal 2").ok();
+ }
+
+ #[task(priority = 2)]
+ async fn async_task2(_cx: async_task2::Context) {
+ hprintln!("hello from async 2").ok();
+ }
+}