| /aosp_15_r20/system/security/keystore2/src/ |
| H A D | gc.rs | 23 async_task,
28 use async_task::AsyncTask;
35 async_task: Arc<AsyncTask>, field
46 pub fn new_init_with<F>(async_task: Arc<AsyncTask>, init: F) -> Self in new_init_with()
55 let weak_at = Arc::downgrade(&async_task); in new_init_with()
59 async_task.queue_hi(move |shelf| { in new_init_with()
67 async_task: weak_at, in new_init_with()
72 Self { async_task, notified } in new_init_with()
80 self.async_task.queue_lo(|shelf| shelf.get_downcast_mut::<GcInternal>().unwrap().step()) in notify_gc()
90 async_task: std::sync::Weak<AsyncTask>, field
[all …]
|
| H A D | legacy_importer.rs | 30 use crate::{async_task::AsyncTask, legacy_blob::LegacyBlobLoader};
45 async_task: Arc<AsyncTask>, field
97 pub fn new(async_task: Arc<AsyncTask>) -> Self { in new()
99 async_task, in new()
166 self.async_task.queue_hi(move |shelf| { in check_state()
245 self.async_task.queue_hi(move |shelf| { in do_serialized()
|
| H A D | lib.rs | 19 pub mod async_task; module
|
| /aosp_15_r20/external/rust/android-crates-io/crates/async-task/tests/ |
| D | basic.rs | 8 use async_task::Runnable;
84 let (runnable, task) = async_task::spawn(f, s); in drop_and_detach()
108 let (runnable, task) = async_task::spawn(f, s); in detach_and_drop()
127 let (runnable, task) = async_task::spawn(f, s); in detach_and_run()
146 let (runnable, task) = async_task::spawn(f, s); in run_and_detach()
165 let (runnable, task) = async_task::spawn(f, s); in cancel_and_run()
184 let (runnable, task) = async_task::spawn(f, s); in run_and_cancel()
203 let (runnable, mut task) = async_task::spawn(f, s); in cancel_join()
234 let (runnable, _task) = async_task::spawn(future::poll_fn(|_| Poll::<()>::Pending), schedule); in schedule()
259 let (runnable, _task) = async_task::spawn(future::poll_fn(|_| Poll::<()>::Pending), schedule); in schedule_counter()
[all …]
|
| D | join.rs | 10 use async_task::Runnable;
101 let (runnable, task) = async_task::spawn(f, s); in drop_and_join()
120 let (runnable, task) = async_task::spawn(f, s); in run_and_join()
139 let (runnable, task) = async_task::spawn(f, s); in detach_and_run()
158 let (runnable, mut task) = async_task::spawn(f, s); in join_twice()
187 let (runnable, task) = async_task::spawn(f, s); in join_and_cancel()
218 let (runnable, task) = async_task::spawn(f, s); in join_and_run()
249 let (runnable, mut task) = async_task::spawn(f, s); in try_join_and_run_and_join()
287 let (runnable, mut task) = async_task::spawn(f, s); in try_join_and_cancel_and_run()
321 let (runnable, mut task) = async_task::spawn(f, s); in try_join_and_run_and_cancel()
[all …]
|
| D | panic.rs | 9 use async_task::Runnable;
87 let (runnable, task) = async_task::spawn(f, s); in cancel_during_run()
113 let (runnable, task) = async_task::spawn(f, s); in run_and_join()
132 let (runnable, mut task) = async_task::spawn(f, s); in try_join_and_run_and_join()
157 let (runnable, task) = async_task::spawn(f, s); in join_during_run()
187 let (runnable, mut task) = async_task::spawn(f, s); in try_join_during_run()
214 let (runnable, task) = async_task::spawn(f, s); in detach_during_run()
|
| D | waker_pending.rs | 8 use async_task::Runnable;
98 let (runnable, _task) = async_task::spawn(f, s); in wake_during_run()
142 let (runnable, task) = async_task::spawn(f, s); in cancel_during_run()
184 let (runnable, task) = async_task::spawn(f, s); in wake_and_cancel_during_run()
233 let (runnable, task) = async_task::spawn(f, s); in cancel_and_wake_during_run()
282 let (runnable, task) = async_task::spawn(f, s); in drop_last_waker()
313 let (runnable, task) = async_task::spawn(f, s); in cancel_last_task()
342 let (runnable, task) = async_task::spawn(f, s); in drop_last_task()
|
| D | waker_ready.rs | 9 use async_task::Runnable;
104 let (mut runnable, task) = async_task::spawn(f, s); in wake()
143 let (mut runnable, task) = async_task::spawn(f, s); in wake_by_ref()
183 let (mut runnable, task) = async_task::spawn(f, s); in clone()
222 let (runnable, task) = async_task::spawn(f, s); in wake_dropped()
254 let (runnable, task) = async_task::spawn(f, s); in wake_completed()
|
| D | ready.rs | 8 use async_task::Runnable;
99 let (runnable, task) = async_task::spawn(f, s); in cancel_during_run()
141 let (runnable, task) = async_task::spawn(f, s); in join_during_run()
174 let (runnable, mut task) = async_task::spawn(f, s); in try_join_during_run()
203 let (runnable, task) = async_task::spawn(f, s); in detach_during_run()
|
| D | waker_panic.rs | 10 use async_task::Runnable;
111 let (runnable, task) = async_task::spawn(f, s); in wake_during_run()
154 let (runnable, task) = async_task::spawn(f, s); in cancel_during_run()
196 let (runnable, task) = async_task::spawn(f, s); in wake_and_cancel_during_run()
250 let (runnable, task) = async_task::spawn(f, s); in cancel_and_wake_during_run()
299 let (runnable, task) = async_task::spawn(f, s); in panic_and_poll()
|
| D | cancel.rs | 8 use async_task::Runnable;
100 let (runnable, task) = async_task::spawn(f, s); in run_and_cancel()
121 let (runnable, task) = async_task::spawn(f, s); in cancel_and_run()
158 let (runnable, task) = async_task::spawn(f, s); in cancel_during_run()
|
| D | metadata.rs | 1 use async_task::{Builder, Runnable};
|
| /aosp_15_r20/external/rust/android-crates-io/crates/async-task/benches/ |
| D | spawn.rs | 11 let _ = async_task::spawn(async {}, drop); in task_create()
18 let (runnable, task) = async_task::spawn(async {}, drop); in task_run()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/async-task/examples/ |
| D | spawn-on-thread.rs | 7 use async_task::Task;
32 let (runnable, task) = async_task::spawn(future, schedule); in spawn_on_thread()
|
| D | spawn.rs | 7 use async_task::{Runnable, Task};
34 let (runnable, task) = async_task::spawn(future, schedule); in spawn()
|
| D | spawn-local.rs | 7 use async_task::{Runnable, Task};
22 let (runnable, task) = async_task::spawn_local(future, schedule); in spawn()
|
| /aosp_15_r20/external/crosvm/cros_async/src/ |
| H A D | common_executor.rs | 15 use async_task::Task;
168 let (runnable, task) = async_task::spawn(f, schedule); in spawn()
188 let (runnable, task) = async_task::spawn_local(f, schedule); in spawn_local()
|
| H A D | queue.rs | 7 use async_task::Runnable;
|
| /aosp_15_r20/system/security/keystore2/legacykeystore/ |
| H A D | lib.rs | 28 async_task::AsyncTask, error::anyhow_error_to_cstring, globals::SUPER_KEY,
270 async_task: AsyncTask, field
294 let legacy_keystore = Arc::new(Self { db_path, async_task: Default::default() }); in new_native_binder()
415 self.async_task.queue_hi(move |shelf| { in init_shelf()
428 self.async_task.queue_hi(move |shelf| { in do_serialized()
|
| /aosp_15_r20/out/soong/.intermediates/system/security/keystore2/libkeystore2/android_arm64_armv8-2a_cortex-a55_rlib_rlib-std/ |
| D | libkeystore2.rlib.clippy.d.raw | 1 ….rs system/security/keystore2/src/apc.rs system/security/keystore2/src/async_task.rs system/securi…
3 ….rs system/security/keystore2/src/apc.rs system/security/keystore2/src/async_task.rs system/securi…
7 system/security/keystore2/src/async_task.rs:
|
| D | libkeystore2.rlib.d.raw | 1 ….rs system/security/keystore2/src/apc.rs system/security/keystore2/src/async_task.rs system/securi…
3 ….rs system/security/keystore2/src/apc.rs system/security/keystore2/src/async_task.rs system/securi…
7 system/security/keystore2/src/async_task.rs:
|
| D | libkeystore2.rlib.d | 1 ….rs system/security/keystore2/src/apc.rs system/security/keystore2/src/async_task.rs system/securi…
|
| /aosp_15_r20/external/ot-br-posix/src/ncp/ |
| H A D | CMakeLists.txt | 32 async_task.cpp
33 async_task.hpp
|
| /aosp_15_r20/external/rust/android-crates-io/crates/async-task/ |
| D | Android.bp | 19 crate_name: "async_task",
|
| /aosp_15_r20/external/libwebsockets/include/libwebsockets/ |
| H A D | lws-threadpool.h | 81 char async_task; /**< set to allow the task to shrug off the loss member
|