mirror/rtic
1
0
Fork 0
mirror of https://github.com/rtic-rs/rtic.git synced 2024-11-25 21:19:35 +01:00
Code Issues Projects Releases Packages Wiki Activity

ready queue now with RacyCell

Browse source
This commit is contained in:
Per Lindgren 2021-03-10 17:39:44 +01:00
parent db1574bf6b
commit b6c07ac1e4
3 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
macros/src/codegen/dispatchers.rs
View file

@ -59,7 +59,7 @@ pub fn codegen(app: &App, analysis: &Analysis, _extra: &Extra) -> Vec<TokenStrea
// ); // );
items.push(quote!( items.push(quote!(
#[doc(hidden)] #[doc(hidden)]
static mut #rq: #rq_ty = #rq_expr; static #rq: rtic::RacyCell<#rq_ty> = rtic::RacyCell::new(#rq_expr);
)); ));
let arms = channel let arms = channel
@ -100,7 +100,7 @@ pub fn codegen(app: &App, analysis: &Analysis, _extra: &Extra) -> Vec<TokenStrea
.collect::<Vec<_>>(); .collect::<Vec<_>>();
stmts.push(quote!( stmts.push(quote!(
while let Some((task, index)) = #rq.split().1.dequeue() { while let Some((task, index)) = #rq.get_mut_unchecked().split().1.dequeue() {
match task { match task {
#(#arms)* #(#arms)*
} }

2
macros/src/codegen/module.rs
View file

@ -215,7 +215,7 @@ pub fn codegen(
.write(input); .write(input);
rtic::export::interrupt::free(|_| { rtic::export::interrupt::free(|_| {
#app_path::#rq.enqueue_unchecked((#app_path::#t::#name, index)); #app_path::#rq.get_mut_unchecked().enqueue_unchecked((#app_path::#t::#name, index));
}); });
rtic::pend(#device::#enum_::#interrupt); rtic::pend(#device::#enum_::#interrupt);

3
src/lib.rs
View file

@ -75,4 +75,5 @@ impl<T> RacyCell<T> {
} }
// The type wrapped need to be Sync for RacyCell<T> to be Sync // The type wrapped need to be Sync for RacyCell<T> to be Sync
unsafe impl<T> Sync for RacyCell<T> where T: Sync {} //unsafe impl<T> Sync for RacyCell<T> where T: Sync {}
unsafe impl<T> Sync for RacyCell<T> {}