| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/inject/ |
| D | synced.rs | 8 pub(crate) struct Synced { struct
19 unsafe impl Send for Synced {} implementation
20 unsafe impl Sync for Synced {} implementation
22 impl Synced { impl
|
| D | rt_multi_thread.rs | 8 impl<'a> Lock<Synced> for &'a mut Synced { implementation
16 impl AsMut<Synced> for Synced { implementation
17 fn as_mut(&mut self) -> &mut Synced { in as_mut()
31 L: Lock<Synced>, in push_batch()
73 L: Lock<Synced>, in push_batch_inner()
|
| D | shared.rs | 68 pub(crate) unsafe fn push(&self, synced: &mut Synced, task: task::Notified<T>) { in push()
106 pub(crate) unsafe fn pop_n<'a>(&'a self, synced: &'a mut Synced, n: usize) -> Pop<'a, T> { in pop_n()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/io/ |
| D | registration_set.rs | 14 pub(super) struct Synced { struct
30 pub(super) fn new() -> (RegistrationSet, Synced) { in new() argument
71 pub(super) fn deregister(&self, synced: &mut Synced, registration: &Arc<ScheduledIo>) -> bool { in deregister()
104 pub(super) fn release(&self, synced: &mut Synced) { in release()
117 pub(super) unsafe fn remove(&self, synced: &mut Synced, io: &Arc<ScheduledIo>) { in remove()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | idle.rs | 37 pub(super) struct Synced { struct
46 pub(super) fn new(cores: Vec<Box<Core>>, num_workers: usize) -> (Idle, Synced) { in new() argument
132 pub(super) fn notify_remote(&self, synced: MutexGuard<'_, worker::Synced>, shared: &Shared) { in notify_remote()
145 fn notify_synced(&self, mut synced: MutexGuard<'_, worker::Synced>, shared: &Shared) { in notify_synced()
183 synced: &mut worker::Synced, in notify_mult()
224 pub(super) fn shutdown(&self, synced: &mut worker::Synced, shared: &Shared) { in shutdown()
258 pub(super) fn release_core(&self, synced: &mut worker::Synced, core: Box<Core>) { in release_core()
280 pub(super) fn transition_worker_to_parked(&self, synced: &mut worker::Synced, index: usize) { in transition_worker_to_parked()
304 _synced: &mut Synced, in transition_worker_to_searching_if_needed()
|
| D | worker.rs | 182 pub(crate) struct Synced { struct
197 pub(super) idle: idle::Synced, argument
200 pub(crate) inject: inject::Synced, argument
610 synced: &mut Synced, in try_acquire_available_core()
628 mut synced: MutexGuard<'_, Synced>, in wait_for_core() argument
673 fn reset_acquired_core(&mut self, cx: &Context, synced: &mut Synced, core: &mut Core) { in reset_acquired_core()
791 synced: &mut Synced, in next_remote_task_batch_synced()
993 synced: impl FnOnce() -> MutexGuard<'a, Synced>, in schedule_deferred_with_core() argument
1049 fn schedule_deferred_without_core<'a>(&mut self, cx: &Context, synced: &mut Synced) { in schedule_deferred_without_core()
1091 fn update_global_flags(&mut self, cx: &Context, synced: &mut Synced) { in update_global_flags()
[all …]
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | idle.rs | 21 pub(super) struct Synced { struct
34 pub(super) fn new(num_workers: usize) -> (Idle, Synced) { in new() argument
|
| D | worker.rs | 191 pub(crate) struct Synced { struct
193 pub(super) idle: idle::Synced, argument
196 pub(crate) inject: inject::Synced, argument
1236 fn as_mut(&mut self) -> &mut inject::Synced { in as_mut()
|
| /external/rust/android-crates-io/crates/h2/src/proto/ |
| D | settings.rs | 27 Synced, enumerator
|