Home
last modified time | relevance | path

Searched defs:wakers (Results 1 – 9 of 9) sorted by relevance

/external/rust/android-crates-io/crates/futures-util/src/future/future/
Dshared.rs28 wakers: Mutex<Option<Slab<Option<Waker>>>>, field
211 let wakers = match wakers_guard.as_mut() { in record_waker() localVariable
349 let mut wakers = wakers_guard.take().unwrap(); in poll() localVariable
390 let wakers = &mut *arc_self.wakers.lock().unwrap(); in wake_by_ref() localVariable
/external/pigweed/pw_async2/
Ddispatcher_test.cc103 CounterTask(pw::span<Waker> wakers, in TEST()
135 std::array<Waker, kNumTasks> wakers; in TEST() local
/external/rust/crates/v4l2r/lib/src/device/
Dpoller.rs153 wakers: BTreeMap<u32, Arc<Waker>>, field
/external/rust/android-crates-io/crates/tokio/src/runtime/tests/
Dtask.rs282 wakers: Vec<Waker>, in spawn_niche_in_task() field
/external/rust/android-crates-io/crates/tokio/src/runtime/io/
Dscheduled_io.rs239 let mut wakers = WakeList::new(); in wake() localVariable
/external/rust/android-crates-io/crates/tokio/src/sync/
Dbatch_semaphore.rs307 let mut wakers = WakeList::new(); in add_permits_locked() localVariable
Dnotify.rs697 let mut wakers = WakeList::new(); in notify_waiters() localVariable
Dbroadcast.rs896 let mut wakers = WakeList::new(); in notify_rx() localVariable
/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/current_thread/
Dmod.rs351 let wakers = context.defer.take_deferred(); in wake_deferred_tasks_and_free() localVariable