mirror/rtic
1
0
Fork 0
mirror of https://github.com/rtic-rs/rtic.git synced 2024-11-23 20:22:51 +01:00
Code Issues Projects Releases Packages Wiki Activity

provide a Threshold token even when all resources are lockless

Browse source 
because the token will always be required for calling generic functions
This commit is contained in:
Jorge Aparicio 2017-07-26 19:30:47 -05:00
parent 4a1509cb53
commit dee2fcde71
1 changed files with 5 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
macros/src/trans.rs
View file

@ -59,12 +59,7 @@ fn idle(
let mut tys = vec![]; let mut tys = vec![];
let mut exprs = vec![]; let mut exprs = vec![];
if !app.idle.resources.is_empty() && if !app.idle.resources.is_empty() {
!app.idle
.resources
.iter()
.all(|resource| ownerships[resource].is_owned())
{
tys.push(quote!(&mut #krate::Threshold)); tys.push(quote!(&mut #krate::Threshold));
exprs.push(quote!(unsafe { &mut #krate::Threshold::new(0) })); exprs.push(quote!(unsafe { &mut #krate::Threshold::new(0) }));
} }
@ -508,6 +503,8 @@ fn tasks(app: &App, ownerships: &Ownerships, root: &mut Vec<Tokens>) {
let has_resources = !task.resources.is_empty(); let has_resources = !task.resources.is_empty();
if has_resources { if has_resources {
needs_threshold = !task.resources.is_empty();
for name in &task.resources { for name in &task.resources {
let _name = Ident::new(format!("_{}", name.as_ref())); let _name = Ident::new(format!("_{}", name.as_ref()));
@ -606,7 +603,8 @@ fn tasks(app: &App, ownerships: &Ownerships, root: &mut Vec<Tokens>) {
} }
let _name = Ident::new(format!("_{}", name)); let _name = Ident::new(format!("_{}", name));
let export_name = Lit::Str(name.as_ref().to_owned(), StrStyle::Cooked); let export_name =
Lit::Str(name.as_ref().to_owned(), StrStyle::Cooked);
root.push(quote! { root.push(quote! {
#[allow(non_snake_case)] #[allow(non_snake_case)]
#[allow(unsafe_code)] #[allow(unsafe_code)]