mirror/rtic
1
0
Fork 0
mirror of https://github.com/rtic-rs/rtic.git synced 2025-12-18 22:05:37 +01:00
Code Issues Projects Releases Packages Wiki Activity

add example of using async from an interrupt triggered task

Browse source
This commit is contained in:
Jorge Aparicio 2018-05-01 15:33:01 +02:00
parent 9058a655dc
commit 20c5e277f7
12 changed files with 168 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

19
macros/src/trans.rs
View file

@ -335,6 +335,7 @@ pub fn app(ctxt: &Context, app: &App) -> Tokens {
let task = &app.tasks[name];
let priority = task.priority;
let __priority = Ident::from(format!("__{}", priority));
let interrupt = ctxt.dispatchers[&priority].interrupt();
let ty = &task.input;
let sqc = Ident::from(format!(
@ -370,8 +371,8 @@ pub fn app(ctxt: &Context, app: &App) -> Tokens {
#krate::Maximum<P, #krate::#qc>: #krate::Unsigned,
{
unsafe {
if let Some(slot) =
::#name::SQ::new().claim_mut(t, |sq, _| sq.dequeue()) {
let slot = ::#name::SQ::new().claim_mut(t, |sq, _| sq.dequeue());
if let Some(slot) = slot {
let tp = slot
.write(self.baseline, payload)
.tag(::#__priority::Task::#name);
@ -380,6 +381,8 @@ pub fn app(ctxt: &Context, app: &App) -> Tokens {
q.split().0.enqueue_unchecked(tp);
});
#krate::set_pending(#device::Interrupt::#interrupt);
Ok(())
} else {
Err(payload)
@ -424,6 +427,8 @@ pub fn app(ctxt: &Context, app: &App) -> Tokens {
q.split().0.enqueue_unchecked(tp);
});
#krate::set_pending(#device::Interrupt::#interrupt);
Ok(())
} else {
Err(payload)
@ -750,10 +755,12 @@ pub fn app(ctxt: &Context, app: &App) -> Tokens {
let async_exprs = app.init
.async
.iter()
.map(|task| if cfg!(feature = "timer-queue") {
quote!(#task: ::__async::#task::new(_bl))
} else {
quote!(#task: ::__async::#task::new())
.map(|task| {
if cfg!(feature = "timer-queue") {
quote!(#task: ::__async::#task::new(_bl))
} else {
quote!(#task: ::__async::#task::new())
}
})
.chain(
app.init