diff --git a/examples/async-task-multiple-prios.rs b/examples/async-task-multiple-prios.rs index a90c11bd98..d47e87b1bc 100644 --- a/examples/async-task-multiple-prios.rs +++ b/examples/async-task-multiple-prios.rs @@ -16,7 +16,10 @@ mod app { use systick_monotonic::*; #[shared] - struct Shared {} + struct Shared { + a: u32, + b: u32, + } #[local] struct Local {} @@ -34,7 +37,7 @@ mod app { async_task2::spawn().ok(); ( - Shared {}, + Shared { a: 0, b: 0 }, Local {}, init::Monotonics(Systick::new(cx.core.SYST, 12_000_000)), ) @@ -49,24 +52,24 @@ mod app { } } - #[task(priority = 1)] + #[task(priority = 1, shared = [a, b])] fn normal_task(_cx: normal_task::Context) { hprintln!("hello from normal 1").ok(); } - #[task(priority = 1)] + #[task(priority = 1, shared = [a, b])] async fn async_task(_cx: async_task::Context) { hprintln!("hello from async 1").ok(); debug::exit(debug::EXIT_SUCCESS); } - #[task(priority = 2)] + #[task(priority = 2, shared = [a, b])] fn normal_task2(_cx: normal_task2::Context) { hprintln!("hello from normal 2").ok(); } - #[task(priority = 2)] + #[task(priority = 2, shared = [a, b])] async fn async_task2(_cx: async_task2::Context) { hprintln!("hello from async 2").ok(); } diff --git a/macros/src/codegen/dispatchers.rs b/macros/src/codegen/dispatchers.rs index cc9944025e..62df429370 100644 --- a/macros/src/codegen/dispatchers.rs +++ b/macros/src/codegen/dispatchers.rs @@ -10,17 +10,23 @@ pub fn codegen(app: &App, analysis: &Analysis, extra: &Extra) -> Vec> = rtic::RacyCell::new(rtic::export::executor::AsyncTaskExecutor::new()); + + // The executors priority, this can be any value - we will overwrite it when we + // start a task + static #prio_name: rtic::RacyCell = + unsafe { rtic::RacyCell::new(rtic::export::Priority::new(0)) }; )); } } @@ -92,6 +98,7 @@ pub fn codegen(app: &App, analysis: &Analysis, extra: &Extra) -> Vec Vec) + } else { + quote!() + }, + ) } else { - quote!() + (quote!(), quote!()) }; user_tasks.push(quote!( #(#attrs)* #(#cfgs)* #[allow(non_snake_case)] - #async_marker fn #name(#context: #name::Context #(,#inputs)*) { + #async_marker fn #name(#context: #name::Context #context_lifetime #(,#inputs)*) { use rtic::Mutex as _; use rtic::mutex::prelude::*; diff --git a/src/export.rs b/src/export.rs index 1d17d46b02..ec18c9cf41 100644 --- a/src/export.rs +++ b/src/export.rs @@ -242,7 +242,7 @@ impl Priority { /// /// Will overwrite the current Priority #[inline(always)] - pub unsafe fn new(value: u8) -> Self { + pub const unsafe fn new(value: u8) -> Self { Priority { inner: Cell::new(value), } diff --git a/xtask/src/command.rs b/xtask/src/command.rs index 2f719bf5c9..528401ae74 100644 --- a/xtask/src/command.rs +++ b/xtask/src/command.rs @@ -46,7 +46,14 @@ impl<'a> CargoCommand<'a> { features, mode, } => { - let mut args = vec![self.name(), "--example", example, "--target", target]; + let mut args = vec![ + "+nightly", + self.name(), + "--example", + example, + "--target", + target, + ]; if let Some(feature_name) = features { args.extend_from_slice(&["--features", feature_name]); @@ -61,7 +68,7 @@ impl<'a> CargoCommand<'a> { features, mode, } => { - let mut args = vec![self.name(), "--examples", "--target", target]; + let mut args = vec!["+nightly", self.name(), "--examples", "--target", target]; if let Some(feature_name) = features { args.extend_from_slice(&["--features", feature_name]);