Searched defs:Notified (Results 1 – 8 of 8) sorted by relevance
| /external/rust/crates/tokio/src/runtime/task/ |
| D | mod.rs | 228 pub(crate) struct Notified<S: 'static>(Task<S>); struct
232 unsafe impl<S: Schedule> Send for Notified<S> {} implementation
233 unsafe impl<S: Schedule> Sync for Notified<S> {} implementation
366 impl<S: 'static> Notified<S> { impl
372 impl<S: 'static> Notified<S> { implementation
378 impl<S: 'static> Notified<S> { impl
473 impl<S> fmt::Debug for Notified<S> { implementation
|
| D | harness.rs | 444 Notified, enumerator
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 363 pub struct Notified<'a> { struct
377 unsafe impl<'a> Send for Notified<'a> {} argument
378 unsafe impl<'a> Sync for Notified<'a> {} implementation
753 impl Notified<'_> { implementation
1098 impl Future for Notified<'_> { implementation
1106 impl Drop for Notified<'_> { implementation
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | worker.rs | 234 type Notified = task::Notified<Arc<Handle>>; typedef
556 fn run_task(&self, task: Notified, mut core: Box<Core>) -> RunResult { in run_task()
753 fn next_task(&mut self, worker: &Worker) -> Option<Notified> { in next_task()
808 fn next_local_task(&mut self) -> Option<Notified> { in next_local_task()
817 fn steal_work(&mut self, worker: &Worker) -> Option<Notified> { in steal_work()
1002 fn schedule(&self, task: Notified) { in schedule()
1006 fn yield_now(&self, task: Notified) { in yield_now()
1012 pub(super) fn schedule_task(&self, task: Notified, is_yield: bool) { in schedule_task()
1031 pub(super) fn schedule_option_task_without_yield(&self, task: Option<Notified>) { in schedule_option_task_without_yield()
1037 fn schedule_local(&self, core: &mut Core, task: Notified, is_yield: bool) { in schedule_local()
[all …]
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | worker.rs | 248 type Notified = task::Notified<Arc<Handle>>; typedef
753 fn next_remote_task(&self, cx: &Context) -> Option<Notified> { in next_remote_task()
787 ) -> Option<Notified> { in next_remote_task_batch_synced()
863 fn steal_one_round(&self, cx: &Context, core: &mut Core, start: usize) -> Option<Notified> { in steal_one_round()
1320 fn next_local_task(&mut self) -> Option<Notified> { in next_local_task()
1324 fn next_lifo_task(&mut self) -> Option<Notified> { in next_lifo_task()
1330 fn next_remote_task_synced(&self, synced: &mut Synced) -> Option<Notified> { in next_remote_task_synced()
1335 pub(super) fn schedule_task(&self, task: Notified, is_yield: bool) { in schedule_task()
1364 fn schedule_local(&self, cx: &Context, core: &mut Core, task: Notified) { in schedule_local()
1391 fn schedule_remote(&self, task: Notified) { in schedule_remote()
[all …]
|
| /external/rust/crates/tokio/src/runtime/scheduler/current_thread/ |
| D | mod.rs | 107 type Notified = task::Notified<Arc<Handle>>; typedef
294 fn next_task(&mut self, handle: &Handle) -> Option<Notified> { in next_task()
305 fn next_local_task(&mut self, handle: &Handle) -> Option<Notified> { in next_local_task()
314 fn push_task(&mut self, handle: &Handle, task: Notified) { in push_task()
494 fn next_remote_task(&self) -> Option<Notified> { in next_remote_task()
|
| /external/cronet/net/nqe/ |
| D | event_creator_unittest.cc | 26 TEST(NetworkQualityEstimatorEventCreatorTest, Notified) { in TEST() argument
|
| /external/rust/crates/tokio/src/util/ |
| D | idle_notified_set.rs | 66 Notified, enumerator
|