| /external/cronet/net/socket/ |
| D | websocket_endpoint_lock_manager_unittest.cc | 90 FakeWaiter waiters[2]; in TEST_F() local
112 FakeWaiter waiters[2]; in TEST_F() local
125 FakeWaiter waiters[2]; in TEST_F() local
163 FakeWaiter waiters[2]; in TEST_F() local
198 FakeWaiter waiters[2]; in TEST_F() local
219 FakeWaiter waiters[3]; in TEST_F() local
242 FakeWaiter waiters[2]; in TEST_F() local
|
| /external/rust/crates/tokio/src/runtime/io/ |
| D | scheduled_io.rs | 31 waiters: Mutex<Waiters>, field
225 let mut waiters = self.waiters.lock(); in wake() localVariable
302 let mut waiters = self.waiters.lock(); in poll_readiness() localVariable
360 let mut waiters = self.waiters.lock(); in clear_wakers() localVariable
451 let mut waiters = scheduled_io.waiters.lock(); localVariable
491 let waiters = scheduled_io.waiters.lock(); localVariable
545 let mut waiters = self.scheduled_io.waiters.lock(); localVariable
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 206 waiters: Mutex<WaitList>, field
458 let mut waiters = self.waiters.lock(); in notify_one() localVariable
506 let mut waiters = self.waiters.lock(); in notify_waiters() localVariable
775 let mut waiters = notify.waiters.lock(); in poll_notified() localVariable
854 let waiters = notify.waiters.lock(); in poll_notified() localVariable
915 let mut waiters = notify.waiters.lock(); in drop() localVariable
|
| D | batch_semaphore.rs | 37 waiters: Mutex<Waitlist>, field
221 let mut waiters = self.waiters.lock(); in close() localVariable
289 let mut waiters = lock.take().unwrap_or_else(|| self.waiters.lock()); in add_permits_locked() localVariable
369 let mut waiters = loop { in poll_acquire() localVariable
646 let mut waiters = self.semaphore.waiters.lock(); in drop() localVariable
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | EventCount.h | 53 EventCount(MaxSizeVector<Waiter>& waiters) in EventCount()
135 const uint64_t waiters = (state & kWaiterMask) >> kWaiterShift; in Notify() local
211 const uint64_t waiters = (state & kWaiterMask) >> kWaiterShift; variable
|
| /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/musl/src/thread/ |
| D | sem_post.c | 6 int val, waiters, priv = sem->__val[2]; in sem_post() local
|
| D | __wait.c | 3 void __wait(volatile int *addr, volatile int *waiters, int val, int priv) in __wait()
|
| D | pthread_rwlock_unlock.c | 5 int val, cnt, waiters, new, priv = rw->_rw_shared^128; in __pthread_rwlock_unlock() local
|
| D | pthread_mutex_unlock.c | 6 int waiters = m->_m_waiters; in __pthread_mutex_unlock() local
|
| D | pthread_barrier_wait.c | 56 volatile int waiters; member
|
| D | pthread_create.c | 118 int waiters = m->_m_waiters; in __pthread_exit() local
|
| /external/ltp/testcases/kernel/syscalls/futex/ |
| D | futex2test.h | 23 static inline int futex_waitv(volatile struct futex_waitv *waiters, in futex_waitv()
|
| /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/linux-kselftest/tools/testing/selftests/futex/include/ |
| D | futex2test.h | 18 static inline int futex_waitv(volatile struct futex_waitv *waiters, unsigned long nr_waiters, in futex_waitv()
|
| /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 | 24 waiters: StdMutex<Slab<Waiter>>, field
164 let mut waiters = self.waiters.lock().unwrap(); in remove_waker() localVariable
189 let mut waiters = self.waiters.lock().unwrap(); in unlock() localVariable
241 let mut waiters = mutex.waiters.lock().unwrap(); in poll() localVariable
350 let mut waiters = mutex.waiters.lock().unwrap(); in poll() localVariable
|
| /external/tensorflow/tensorflow/core/tfrt/run_handler_thread_pool/ |
| D | run_handler_test.cc | 148 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST_P() local
194 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST_P() local
483 Eigen::MaxSizeVector<internal::Waiter> waiters(1); in TEST_P() local
554 Eigen::MaxSizeVector<internal::Waiter> waiters(2); in TEST_P() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/sync/ |
| D | MutexTest.kt | 64 val waiters = 10000 in testUnconfinedStackOverflow() constant
|
| /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 | 1031 int waiters = guard.waiterCount++; in beginWaitingFor() local
1042 int waiters = --guard.waiterCount; in endWaitingFor() local
|
| /external/mesa3d/src/util/ |
| D | u_thread.h | 275 unsigned waiters; member
|
| /external/python/cpython3/Lib/asyncio/ |
| D | queues.py | 59 def _wakeup_next(self, waiters): argument
|
| /external/virglrenderer/src/mesa/util/ |
| D | u_thread.h | 309 unsigned waiters; member
|
| /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
|