| /external/rust/crates/tokio/src/io/driver/ |
| D | scheduled_io.rs | 28 waiters: Mutex<Waiters>, field
220 let mut waiters = self.waiters.lock(); in wake0() localVariable
306 let mut waiters = self.waiters.lock(); in poll_readiness() localVariable
360 let mut waiters = self.waiters.lock(); in clear_wakers() localVariable
450 let mut waiters = scheduled_io.waiters.lock(); localVariable
489 let waiters = scheduled_io.waiters.lock(); localVariable
531 let mut waiters = self.scheduled_io.waiters.lock(); localVariable
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 117 waiters: Mutex<WaitList>, field
339 let mut waiters = self.waiters.lock(); in notify_one() localVariable
390 let mut waiters = self.waiters.lock(); in notify_waiters() localVariable
557 let mut waiters = notify.waiters.lock(); in poll() localVariable
634 let waiters = notify.waiters.lock(); in poll() localVariable
681 let mut waiters = notify.waiters.lock(); in drop() localVariable
|
| D | batch_semaphore.rs | 34 waiters: Mutex<Waitlist>, field
181 let mut waiters = self.waiters.lock(); in close() localVariable
246 let mut waiters = lock.take().unwrap_or_else(|| self.waiters.lock()); in add_permits_locked() localVariable
314 let mut waiters = loop { in poll_acquire() localVariable
500 let mut waiters = self.semaphore.waiters.lock(); in drop() localVariable
|
| D | broadcast.rs | 323 waiters: LinkedList<Waiter, <Waiter as linked_list::Link>::Target>, field
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | EventCount.h | 53 EventCount(MaxSizeVector<Waiter>& waiters) : waiters_(waiters) { in EventCount()
138 uint64_t waiters = (state & kWaiterMask) >> kWaiterShift; in Notify() local
212 void Unpark(Waiter* waiters) { in Unpark()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | BlockingCoroutineDispatcherMixedStealingStressTest.kt | 65 …val waiters = Thread.getAllStackTraces().keys.count { (it.state == Thread.State.TIMED_WAITING || i… in testBlockingProgressPreventedExternal() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/sync/ |
| D | MutexTest.kt | 63 val waiters = 10000 in testUnconfinedStackOverflow() constant
|
| /external/eigen/unsupported/test/ |
| D | cxx11_eventcount.cpp | 28 MaxSizeVector<EventCount::Waiter> waiters(1); in test_basic_eventcount() local
85 MaxSizeVector<EventCount::Waiter> waiters(kThreads); in test_stress_eventcount() local
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
| D | CurrentContendedMonitorTest.java | 95 int waiters = replyObj.getNextValueAsInt(); in testCurrentContendedMonitor001() local
|
| /external/rust/crates/futures-util/src/lock/ |
| D | mutex.rs | 22 waiters: StdMutex<Slab<Waiter>>, field
146 let mut waiters = self.waiters.lock().unwrap(); in remove_waker() localVariable
171 let mut waiters = self.waiters.lock().unwrap(); in unlock() localVariable
224 let mut waiters = mutex.waiters.lock().unwrap(); in poll() localVariable
|
| /external/llvm-project/debuginfo-tests/dexter-tests/ |
| D | dbg-arg.c | 14 int waiters; member
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | run_handler_test.cc | 119 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST() local
152 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST() local
438 Eigen::MaxSizeVector<internal::Waiter> waiters(1); in TEST() local
509 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST() local
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 1032 int waiters = guard.waiterCount++; in beginWaitingFor() local
1043 int waiters = --guard.waiterCount; in endWaitingFor() local
|
| D | AbstractFuture.java | 371 @NullableDecl private volatile Waiter waiters; field in AbstractFuture
|
| /external/mesa3d/src/util/ |
| D | u_thread.h | 275 unsigned waiters; member
|
| /external/python/cpython3/Lib/asyncio/ |
| D | queues.py | 65 def _wakeup_next(self, waiters): argument
|
| /external/libchromeos-rs/src/sync/ |
| D | cv.rs | 57 waiters: UnsafeCell<WaiterList>, field
222 let waiters = unsafe { &mut *self.waiters.get() }; in notify_one() localVariable
333 let waiters = unsafe { &mut *self.waiters.get() }; in cancel_waiter() localVariable
|
| D | mu.rs | 193 waiters: UnsafeCell<WaiterList>, field
458 let waiters = unsafe { &mut *self.waiters.get() }; in unlock_slow() localVariable
546 let waiters = unsafe { &mut *self.waiters.get() }; in transfer_waiters() localVariable
628 let waiters = unsafe { &mut *self.waiters.get() }; in cancel_waiter() localVariable
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 58 waiters: UnsafeCell<WaiterList>, field
232 let waiters = unsafe { &mut *self.waiters.get() }; in notify_one() localVariable
328 let waiters = unsafe { &mut *self.waiters.get() }; in cancel_waiter() localVariable
|
| D | mu.rs | 191 waiters: UnsafeCell<WaiterList>, field
456 let waiters = unsafe { &mut *self.waiters.get() }; in unlock_slow() localVariable
527 let waiters = unsafe { &mut *self.waiters.get() }; in cancel_waiter() localVariable
|
| /external/virglrenderer/src/gallium/auxiliary/os/ |
| D | os_thread.h | 157 unsigned waiters; member
|
| /external/kotlinx.atomicfu/atomicfu/src/nativeMain/kotlin/kotlinx/atomicfu/locks/ |
| D | Synchronized.kt | 145 val waiters: Int, constant in kotlinx.atomicfu.locks.SynchronizedObject.LockState
|
| /external/deqp/modules/egl/ |
| D | teglMultiThreadTests.cpp | 294 const deInt32 waiters = deAtomicIncrement32(&m_barrierWaiters); in barrier() local
309 const deInt32 waiters = deAtomicDecrement32(&m_barrierWaiters); in barrier() local
|
| /external/libxml2/ |
| D | threads.c | 112 unsigned int waiters; member
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 371 private volatile @Nullable Waiter waiters; field in AbstractFuture
|