diff options
| author | Dario Nieuwenhuis <[email protected]> | 2022-08-17 23:40:16 +0200 |
|---|---|---|
| committer | Dario Nieuwenhuis <[email protected]> | 2022-08-18 01:22:30 +0200 |
| commit | 5daa173ce4b153a532b4daa9e94c7a248231f25b (patch) | |
| tree | 2ef0b4d6f9b1c02dac2589e7b57982c20cbc0e66 /embassy-macros | |
| parent | 1c5b54a4823d596db730eb476c3ab78110557214 (diff) | |
Split embassy-time from embassy-executor.
Diffstat (limited to 'embassy-macros')
| -rw-r--r-- | embassy-macros/src/macros/main.rs | 8 | ||||
| -rw-r--r-- | embassy-macros/src/macros/task.rs | 4 |
2 files changed, 6 insertions, 6 deletions
diff --git a/embassy-macros/src/macros/main.rs b/embassy-macros/src/macros/main.rs index a0cb0f0b3..52987d7d2 100644 --- a/embassy-macros/src/macros/main.rs +++ b/embassy-macros/src/macros/main.rs | |||
| @@ -34,8 +34,8 @@ pub fn run(args: syn::AttributeArgs, f: syn::ItemFn) -> Result<TokenStream, Toke | |||
| 34 | let main = quote! { | 34 | let main = quote! { |
| 35 | #[wasm_bindgen::prelude::wasm_bindgen(start)] | 35 | #[wasm_bindgen::prelude::wasm_bindgen(start)] |
| 36 | pub fn main() -> Result<(), wasm_bindgen::JsValue> { | 36 | pub fn main() -> Result<(), wasm_bindgen::JsValue> { |
| 37 | static EXECUTOR: ::embassy_util::Forever<::embassy_executor::executor::Executor> = ::embassy_util::Forever::new(); | 37 | static EXECUTOR: ::embassy_util::Forever<::embassy_executor::Executor> = ::embassy_util::Forever::new(); |
| 38 | let executor = EXECUTOR.put(::embassy_executor::executor::Executor::new()); | 38 | let executor = EXECUTOR.put(::embassy_executor::Executor::new()); |
| 39 | 39 | ||
| 40 | executor.start(|spawner| { | 40 | executor.start(|spawner| { |
| 41 | spawner.spawn(__embassy_main(spawner)).unwrap(); | 41 | spawner.spawn(__embassy_main(spawner)).unwrap(); |
| @@ -48,7 +48,7 @@ pub fn run(args: syn::AttributeArgs, f: syn::ItemFn) -> Result<TokenStream, Toke | |||
| 48 | #[cfg(all(feature = "std", not(feature = "wasm")))] | 48 | #[cfg(all(feature = "std", not(feature = "wasm")))] |
| 49 | let main = quote! { | 49 | let main = quote! { |
| 50 | fn main() -> ! { | 50 | fn main() -> ! { |
| 51 | let mut executor = ::embassy_executor::executor::Executor::new(); | 51 | let mut executor = ::embassy_executor::Executor::new(); |
| 52 | let executor = unsafe { __make_static(&mut executor) }; | 52 | let executor = unsafe { __make_static(&mut executor) }; |
| 53 | 53 | ||
| 54 | executor.run(|spawner| { | 54 | executor.run(|spawner| { |
| @@ -61,7 +61,7 @@ pub fn run(args: syn::AttributeArgs, f: syn::ItemFn) -> Result<TokenStream, Toke | |||
| 61 | let main = quote! { | 61 | let main = quote! { |
| 62 | #[cortex_m_rt::entry] | 62 | #[cortex_m_rt::entry] |
| 63 | fn main() -> ! { | 63 | fn main() -> ! { |
| 64 | let mut executor = ::embassy_executor::executor::Executor::new(); | 64 | let mut executor = ::embassy_executor::Executor::new(); |
| 65 | let executor = unsafe { __make_static(&mut executor) }; | 65 | let executor = unsafe { __make_static(&mut executor) }; |
| 66 | 66 | ||
| 67 | executor.run(|spawner| { | 67 | executor.run(|spawner| { |
diff --git a/embassy-macros/src/macros/task.rs b/embassy-macros/src/macros/task.rs index 414e5cb09..573776f8c 100644 --- a/embassy-macros/src/macros/task.rs +++ b/embassy-macros/src/macros/task.rs | |||
| @@ -64,9 +64,9 @@ pub fn run(args: syn::AttributeArgs, f: syn::ItemFn) -> Result<TokenStream, Toke | |||
| 64 | // in the user's code. | 64 | // in the user's code. |
| 65 | #task_inner | 65 | #task_inner |
| 66 | 66 | ||
| 67 | #visibility fn #task_ident(#fargs) -> ::embassy_executor::executor::SpawnToken<impl Sized> { | 67 | #visibility fn #task_ident(#fargs) -> ::embassy_executor::SpawnToken<impl Sized> { |
| 68 | type Fut = impl ::core::future::Future + 'static; | 68 | type Fut = impl ::core::future::Future + 'static; |
| 69 | static POOL: ::embassy_executor::executor::raw::TaskPool<Fut, #pool_size> = ::embassy_executor::executor::raw::TaskPool::new(); | 69 | static POOL: ::embassy_executor::raw::TaskPool<Fut, #pool_size> = ::embassy_executor::raw::TaskPool::new(); |
| 70 | unsafe { POOL._spawn_async_fn(move || #task_inner_ident(#(#arg_names,)*)) } | 70 | unsafe { POOL._spawn_async_fn(move || #task_inner_ident(#(#arg_names,)*)) } |
| 71 | } | 71 | } |
| 72 | }; | 72 | }; |
