| /external/rust/crates/tokio/src/park/ |
| D | mod.rs | 57 fn unpark(&self) -> Self::Unpark; in unpark() method
104 fn unpark(&self); in unpark() method
108 fn unpark(&self) { in unpark() method
109 (**self).unpark() in unpark()
114 fn unpark(&self) { in unpark() method
115 (**self).unpark() in unpark()
|
| D | either.rs | 21 fn unpark(&self) -> Self::Unpark { in unpark() function
23 Either::A(a) => Either::A(a.unpark()), in unpark()
24 Either::B(b) => Either::B(b.unpark()), in unpark()
55 fn unpark(&self) { in unpark() function
57 Either::A(a) => a.unpark(), in unpark()
58 Either::B(b) => b.unpark(), in unpark()
|
| D | thread.rs | 56 fn unpark(&self) -> Self::Unpark { in unpark() method
169 fn unpark(&self) { in unpark() method
212 fn unpark(&self) { in unpark() method
213 self.inner.unpark(); in unpark()
241 self.with_current(|park_thread| park_thread.unpark()) in get_unpark()
276 fn unpark(&self) -> Self::Unpark { in unpark() method
337 unparker.unpark(); in wake()
342 unparker.unpark(); in wake_by_ref()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | shell.rs | 21 unpark: Arc<Handle>, field
29 let unpark = Arc::new(Handle(driver.unpark())); in new() localVariable
34 unpark, in new()
92 arc_self.0.unpark(); in wake_by_ref()
107 let waker = waker_ref(&self.shell.unpark); in block_on()
|
| D | park.rs | 53 let handle = driver.unpark(); in new()
86 fn unpark(&self) -> Unparker { in unpark() method
114 fn unpark(&self) { in unpark() method
115 self.inner.unpark(); in unpark()
214 fn unpark(&self) { in unpark() method
247 self.shared.handle.unpark(); in unpark_driver()
|
| D | basic_scheduler.rs | 91 unpark: Box<dyn Unpark>, field
123 let unpark = Box::new(park.unpark()); in new() localVariable
128 unpark: unpark as Box<dyn Unpark>, in new()
433 self.unpark.unpark(); in release()
449 self.unpark.unpark(); in schedule()
463 arc_self.unpark.unpark(); in wake_by_ref()
|
| D | driver.rs | 193 fn unpark(&self) -> Self::Unpark { in unpark() method
194 self.inner.unpark() in unpark()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | TimeSource.kt | 22 fun unpark(thread: Thread) in currentTimeMillis() method
67 internal inline fun unpark(thread: Thread) { in unpark() method
68 timeSource?.unpark(thread) ?: LockSupport.unpark(thread) in unpark()
|
| D | EventLoop.kt | 10 protected actual fun unpark() { in unpark() method in kotlinx.coroutines.EventLoopImplPlatform
13 unpark(thread) in unpark()
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | mod.rs | 159 unpark: Box<dyn Unpark>, field
175 let inner = Inner::new(time_source.clone(), Box::new(park.unpark())); in new()
363 lock.unpark.unpark(); in reregister()
393 fn unpark(&self) -> Self::Unpark { in unpark() function
394 self.park.unpark() in unpark()
432 pub(self) fn new(time_source: ClockTime, unpark: Box<dyn Unpark>) -> Self { in new()
438 unpark, in new()
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | worker.rs | 99 unpark: Unparker, field
137 let unpark = park.unpark(); in create() localVariable
153 unpark, in create()
705 self.remote().unpark.unpark(); in release()
778 self.remotes[index].unpark.unpark(); in notify_parked()
784 remote.unpark.unpark(); in notify_all()
|
| /external/rust/crates/parking_lot_core/src/thread_parker/windows/ |
| D | mod.rs | 155 pub unsafe fn unpark(self) { in unpark() method
157 UnparkHandle::KeyedEvent(x) => x.unpark(), in unpark()
158 UnparkHandle::WaitAddress(x) => x.unpark(), in unpark()
|
| /external/rust/crates/crossbeam-utils/tests/ |
| D | parker.rs | 12 p.unparker().unpark(); in park_timeout_unpark_before()
34 u.unpark(); in park_timeout_unpark_called_other_thread()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | VirtualTimeSource.kt | 113 override fun unpark(thread: Thread) { in toString() method in kotlinx.coroutines.VirtualTimeSource
116 LockSupport.unpark(thread) in toString()
155 threads.keys.forEach { LockSupport.unpark(it) } in toString()
|
| /external/rust/crates/crossbeam-utils/src/sync/ |
| D | parker.rs | 247 pub fn unpark(&self) { in unpark() method
248 self.inner.unpark() in unpark()
386 pub(crate) fn unpark(&self) { in unpark() method
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | waker.rs | 95 self.selectors[i].cx.unpark(); in try_select()
144 entry.cx.unpark(); in notify()
159 entry.cx.unpark(); in disconnect()
|
| D | context.rs | 182 pub fn unpark(&self) { in unpark() method
183 self.inner.thread.unpark(); in unpark()
|
| /external/rust/crates/tokio/src/process/unix/ |
| D | driver.rs | 73 fn unpark(&self) -> Self::Unpark { in unpark() method
74 self.park.unpark() in unpark()
|
| /external/rust/crates/tokio/src/signal/unix/ |
| D | driver.rs | 145 fn unpark(&self) -> Self::Unpark { in unpark() method
146 self.park.unpark() in unpark()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 173 protected fun unpark() in delayNanosToMillis() method
285 unpark() in dispatch()
361 SCHEDULE_OK -> if (shouldUnpark(delayedTask)) unpark() in schedule()
|
| /external/rust/crates/parking_lot_core/src/thread_parker/ |
| D | wasm.rs | 49 unsafe fn unpark(self) {} in unpark() method
|
| D | mod.rs | 50 unsafe fn unpark(self); in unpark() method
|
| D | generic.rs | 72 unsafe fn unpark(self) {} in unpark() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | EventLoop.kt | 11 protected actual fun unpark() { /* does nothing */ } in unpark() method in kotlinx.coroutines.EventLoopImplPlatform
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | EventLoop.kt | 18 protected actual fun unpark(): Unit = unsupported() in unpark() method in kotlinx.coroutines.EventLoopImplPlatform
|