Searched defs:Notified (Results 1 – 8 of 8) sorted by relevance
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/task/ |
| D | mod.rs | 230 pub(crate) struct Notified<S: 'static>(Task<S>); struct
234 unsafe impl<S: Schedule> Send for Notified<S> {} implementation
235 unsafe impl<S: Schedule> Sync for Notified<S> {} implementation
401 impl<S: 'static> Notified<S> { impl
407 impl<S: 'static> Notified<S> { impl
413 impl<S: 'static> Notified<S> { implementation
508 impl<S> fmt::Debug for Notified<S> { implementation
|
| D | harness.rs | 458 Notified, enumerator
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/ |
| D | notify.rs | 383 pub struct Notified<'a> { struct
397 unsafe impl<'a> Send for Notified<'a> {} argument
398 unsafe impl<'a> Sync for Notified<'a> {} implementation
805 impl Notified<'_> { implementation
1148 impl Future for Notified<'_> { implementation
1156 impl Drop for Notified<'_> { implementation
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | worker.rs | 233 type Notified = task::Notified<Arc<Handle>>; typedef
576 fn run_task(&self, task: Notified, mut core: Box<Core>) -> RunResult { in run_task()
783 fn next_task(&mut self, worker: &Worker) -> Option<Notified> { in next_task()
838 fn next_local_task(&mut self) -> Option<Notified> { in next_local_task()
847 fn steal_work(&mut self, worker: &Worker) -> Option<Notified> { in steal_work()
1038 fn schedule(&self, task: Notified) { in schedule()
1048 fn yield_now(&self, task: Notified) { in yield_now()
1054 pub(super) fn schedule_task(&self, task: Notified, is_yield: bool) { in schedule_task()
1073 pub(super) fn schedule_option_task_without_yield(&self, task: Option<Notified>) { in schedule_option_task_without_yield()
1079 fn schedule_local(&self, core: &mut Core, task: Notified, is_yield: bool) { in schedule_local()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | worker.rs | 248 type Notified = task::Notified<Arc<Handle>>; typedef
760 fn next_remote_task(&self, cx: &Context) -> Option<Notified> { in next_remote_task()
794 ) -> Option<Notified> { in next_remote_task_batch_synced()
870 fn steal_one_round(&self, cx: &Context, core: &mut Core, start: usize) -> Option<Notified> { in steal_one_round()
1330 fn next_local_task(&mut self) -> Option<Notified> { in next_local_task()
1334 fn next_lifo_task(&mut self) -> Option<Notified> { in next_lifo_task()
1340 fn next_remote_task_synced(&self, synced: &mut Synced) -> Option<Notified> { in next_remote_task_synced()
1345 pub(super) fn schedule_task(&self, task: Notified, is_yield: bool) { in schedule_task()
1374 fn schedule_local(&self, cx: &Context, core: &mut Core, task: Notified) { in schedule_local()
1401 fn schedule_remote(&self, task: Notified) { in schedule_remote()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/current_thread/ |
| D | mod.rs | 117 type Notified = task::Notified<Arc<Handle>>; typedef
315 fn next_task(&mut self, handle: &Handle) -> Option<Notified> { in next_task()
326 fn next_local_task(&mut self, handle: &Handle) -> Option<Notified> { in next_local_task()
335 fn push_task(&mut self, handle: &Handle, task: Notified) { in push_task()
546 fn next_remote_task(&self) -> Option<Notified> { in next_remote_task()
|
| /aosp_15_r20/external/cronet/net/nqe/ |
| H A D | event_creator_unittest.cc | 26 TEST(NetworkQualityEstimatorEventCreatorTest, Notified) { in TEST() argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/util/ |
| D | idle_notified_set.rs | 66 Notified, enumerator
|