| /external/rust/crates/tokio/src/runtime/task/ |
| D | mod.rs | 48 pub(crate) struct Notified<S: 'static>(Task<S>); struct
50 unsafe impl<S: Schedule> Send for Notified<S> {} implementation
51 unsafe impl<S: Schedule> Sync for Notified<S> {} implementation
73 fn schedule(&self, task: Notified<Self>); in schedule()
77 fn yield_now(&self, task: Notified<Self>) { in yield_now()
84 pub(crate) fn joinable<T, S>(task: T) -> (Notified<S>, JoinHandle<T::Output>)
98 (Notified(task), join)
104 pub(crate) unsafe fn joinable_local<T, S>(task: T) -> (Notified<S>, JoinHandle<T::Output>)
118 (Notified(task), join)
136 impl<S: 'static> Notified<S> { impl
[all …]
|
| D | harness.rs | 4 use crate::runtime::task::{JoinError, Notified, Schedule, Task};
60 PollFuture::Notified => { in poll()
62 self.core().scheduler.yield_now(Notified(self.to_task())); in poll()
139 self.core().scheduler.schedule(Notified(self.to_task())); in wake_by_ref()
380 Notified, enumerator
433 PollFuture::Notified in poll_future()
|
| D | core.rs | 15 use crate::runtime::task::{Notified, Schedule, Task};
159 pub(super) fn schedule(&self, task: Notified<S>) { in schedule()
172 pub(super) fn yield_now(&self, task: Notified<S>) { in yield_now()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | queue.rs | 52 buffer: Box<[UnsafeCell<MaybeUninit<task::Notified<T>>>]>,
112 pub(super) fn push_back(&mut self, mut task: task::Notified<T>, inject: &Inject<T>) { in push_back()
169 task: task::Notified<T>, in push_overflow()
173 ) -> Result<(), task::Notified<T>> { in push_overflow()
254 pub(super) fn pop(&mut self) -> Option<task::Notified<T>> { in pop()
301 pub(super) fn steal_into(&self, dst: &mut Local<T>) -> Option<task::Notified<T>> { in steal_into()
507 pub(super) fn push(&self, task: task::Notified<T>) { in push()
539 batch_head: task::Notified<T>, in push_batch()
540 batch_tail: task::Notified<T>, in push_batch()
567 pub(super) fn pop(&self) -> Option<task::Notified<T>> { in pop()
[all …]
|
| D | basic_scheduler.rs | 66 queue: VecDeque<task::Notified<Arc<Shared>>>,
74 Schedule(task::Notified<Arc<Shared>>),
442 fn schedule(&self, task: task::Notified<Self>) { in schedule()
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | worker.rs | 44 lifo_slot: Option<Notified>,
123 type Notified = task::Notified<Arc<Worker>>; typedef
339 fn run_task(&self, task: Notified, mut core: Box<Core>) -> RunResult { in run_task() argument
447 fn next_task(&mut self, worker: &Worker) -> Option<Notified> { in next_task() argument
455 fn next_local_task(&mut self) -> Option<Notified> { in next_local_task() argument
459 fn steal_work(&mut self, worker: &Worker) -> Option<Notified> { in steal_work() argument
711 fn schedule(&self, task: Notified) { in schedule() argument
715 fn yield_now(&self, task: Notified) { in yield_now() argument
721 pub(super) fn schedule(&self, task: Notified, is_yield: bool) { in schedule() argument
740 fn schedule_local(&self, core: &mut Core, task: Notified, is_yield: bool) { in schedule_local() argument
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 145 pub struct Notified<'a> { struct
156 unsafe impl<'a> Send for Notified<'a> {} implementation
157 unsafe impl<'a> Sync for Notified<'a> {} implementation
265 pub fn notified(&self) -> Notified<'_> { in notified()
269 Notified { in notified()
512 impl Notified<'_> { implementation
528 impl Future for Notified<'_> { implementation
670 impl Drop for Notified<'_> { implementation
|
| /external/llvm-project/llvm/unittests/Support/ |
| D | Threading.cpp | 35 Notified = true; in notify()
48 return CV.wait_until(Lock, Deadline, [this] { return Notified; }); in wait()
52 bool Notified = false; member in __anoncd9f8e9e0111::Notification
|
| /external/rust/crates/tokio/src/task/ |
| D | local.rs | 239 queue: VecDeque<task::Notified<Arc<Shared>>>,
245 queue: Mutex<VecDeque<task::Notified<Arc<Shared>>>>,
525 fn next_task(&self) -> Option<task::Notified<Arc<Shared>>> { in next_task()
651 fn schedule(&self, task: task::Notified<Arc<Self>>) { in schedule()
692 fn schedule(&self, task: task::Notified<Self>) { in schedule()
|
| /external/rust/crates/rayon-core/src/ |
| D | log.rs | 278 Notified, enumerator
288 State::Notified => 'N', in letter()
335 assert_eq!(self.thread_states[worker], State::Notified); in simulate()
370 self.thread_states[worker] = State::Notified; in simulate()
396 .filter(|s| **s == State::Notified) in dump()
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | task.rs | 74 queue: VecDeque<task::Notified<Runtime>>,
103 fn next_task(&self) -> task::Notified<Runtime> { in next_task()
156 fn schedule(&self, task: task::Notified<Self>) { in schedule()
|
| D | queue.rs | 199 fn schedule(&self, _task: task::Notified<Self>) { in schedule()
|
| D | loom_queue.rs | 213 fn schedule(&self, _task: task::Notified<Self>) { in schedule()
|
| /external/llvm-project/clang-tools-extra/clangd/support/ |
| D | Threading.cpp | 22 Notified = true; in notify()
31 CV.wait(Lock, [this] { return Notified; }); in wait()
|
| D | Threading.h | 35 bool Notified = false;
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | schedule.rs | 21 fn schedule(&self, _task: task::Notified<Self>) { in schedule()
|
| D | pool.rs | 75 type Task = task::Notified<NoopSchedule>;
|
| /external/openscreen/cast/cast_core/api/v2/ |
| D | core_application_service.proto | 74 STOPPED = 2; // Notified that application has stopped or failed to
|