| /external/eigen/unsupported/test/ |
| D | cxx11_eventcount.cpp | 28 MaxSizeVector<EventCount::Waiter> waiters(1); in test_basic_eventcount() local
29 waiters.resize(1); in test_basic_eventcount()
30 EventCount ec(waiters); in test_basic_eventcount()
31 EventCount::Waiter& w = waiters[0]; in test_basic_eventcount()
85 MaxSizeVector<EventCount::Waiter> waiters(kThreads); in test_stress_eventcount() local
86 waiters.resize(kThreads); in test_stress_eventcount()
87 EventCount ec(waiters); in test_stress_eventcount()
108 consumers.emplace_back(new std::thread([&ec, &queues, &waiters, i]() { in test_stress_eventcount()
109 EventCount::Waiter& w = waiters[i]; in test_stress_eventcount()
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | EventCount.h | 53 EventCount(MaxSizeVector<Waiter>& waiters) : waiters_(waiters) { in EventCount() argument
54 eigen_assert(waiters.size() < (1 << kWaiterBits) - 1); in EventCount()
56 state_ = kStackMask | (kEpochMask - kEpochInc * waiters.size() * 2); in EventCount()
138 uint64_t waiters = (state & kWaiterMask) >> kWaiterShift; in Notify() local
142 newstate = (state & kEpochMask) + (kEpochInc * waiters) + kStackMask; in Notify()
143 } else if (waiters) { in Notify()
160 if (!all && waiters) return; // unblocked pre-wait thread in Notify()
212 void Unpark(Waiter* waiters) { in Unpark() argument
214 for (Waiter* w = waiters; w; w = next) { in Unpark()
|
| /external/virglrenderer/src/gallium/auxiliary/os/ |
| D | os_thread.h | 157 unsigned waiters; member
166 barrier->waiters = 0; in pipe_barrier_init()
174 assert(barrier->waiters == 0); in pipe_barrier_destroy()
183 assert(barrier->waiters < barrier->count); in pipe_barrier_wait()
184 barrier->waiters++; in pipe_barrier_wait()
186 if (barrier->waiters < barrier->count) { in pipe_barrier_wait()
193 barrier->waiters = 0; in pipe_barrier_wait()
|
| /external/mesa3d/src/util/ |
| D | u_thread.h | 275 unsigned waiters; member
284 barrier->waiters = 0; in util_barrier_init()
292 assert(barrier->waiters == 0); in util_barrier_destroy()
301 assert(barrier->waiters < barrier->count); in util_barrier_wait()
302 barrier->waiters++; in util_barrier_wait()
304 if (barrier->waiters < barrier->count) { in util_barrier_wait()
311 barrier->waiters = 0; in util_barrier_wait()
|
| /external/libusb/libusb/os/ |
| D | threads_windows.c | 115 list_init(&cond->waiters); in usbi_cond_init()
127 if (!list_empty(&cond->waiters)) in usbi_cond_destroy()
147 list_for_each_entry(pos, &cond->waiters, list, struct usbi_cond_perthread) { in usbi_cond_broadcast()
185 list_add(&pos->list, &cond->waiters); in usbi_cond_intwait()
|
| D | threads_windows.h | 32 struct list_head waiters; member
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/sync/ |
| D | MutexTest.kt | 63 val waiters = 10000 in testUnconfinedStackOverflow() constant
66 repeat(waiters) { in testUnconfinedStackOverflow()
74 assertEquals(waiters, done) in testUnconfinedStackOverflow()
|
| /external/python/cpython3/Lib/asyncio/ |
| D | queues.py | 65 def _wakeup_next(self, waiters): argument
67 while waiters:
68 waiter = waiters.popleft()
|
| D | base_events.py | 302 waiters = self._waiters
304 for waiter in waiters:
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 228 Waiter curr = waiters; in removeWaiter()
357 private volatile @Nullable Waiter waiters; field in AbstractFuture
413 Waiter oldHead = waiters; in get()
443 oldHead = waiters; // re-read and loop. in get()
515 Waiter oldHead = waiters; in get()
537 oldHead = waiters; // re-read and loop. in get()
1027 head = waiters; in releaseWaiters()
1317 if (future.waiters == expect) { in casWaiters()
1318 future.waiters = update; in casWaiters()
|
| D | Monitor.java | 1051 int waiters = guard.waiterCount++;
1052 if (waiters == 0) {
1062 int waiters = --guard.waiterCount;
1063 if (waiters == 0) {
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 228 Waiter curr = waiters; in removeWaiter()
357 @NullableDecl private volatile Waiter waiters; field in AbstractFuture
413 Waiter oldHead = waiters; in get()
443 oldHead = waiters; // re-read and loop. in get()
515 Waiter oldHead = waiters; in get()
537 oldHead = waiters; // re-read and loop. in get()
1027 head = waiters; in releaseWaiters()
1318 if (future.waiters == expect) { in casWaiters()
1319 future.waiters = update; in casWaiters()
|
| D | Monitor.java | 1033 int waiters = guard.waiterCount++; in beginWaitingFor() local
1034 if (waiters == 0) { in beginWaitingFor()
1044 int waiters = --guard.waiterCount; in endWaitingFor() local
1045 if (waiters == 0) { in endWaitingFor()
|
| /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
98 for (int i = 0; i < waiters; i++) { in testCurrentContendedMonitor001()
|
| /external/v8/src/execution/ |
| D | futex-emulation.cc | 894 int waiters = 0; in NumWaitersForTesting() local
900 waiters++; in NumWaitersForTesting()
906 return Smi::FromInt(waiters); in NumWaitersForTesting()
912 int waiters = 0; in NumAsyncWaitersForTesting() local
917 waiters++; in NumAsyncWaitersForTesting()
923 return Smi::FromInt(waiters); in NumAsyncWaitersForTesting()
933 int waiters = 0; in NumUnresolvedAsyncPromisesForTesting() local
942 waiters++; in NumUnresolvedAsyncPromisesForTesting()
949 return Smi::FromInt(waiters); in NumUnresolvedAsyncPromisesForTesting()
|
| /external/libxml2/ |
| D | threads.c | 112 unsigned int waiters; member
295 tok->waiters = 0; in xmlNewRMutex()
358 tok->waiters++; in xmlRMutexLock()
361 tok->waiters--; in xmlRMutexLock()
399 if (tok->waiters) in xmlRMutexUnlock()
|
| /external/oj-libjdwp/src/share/back/ |
| D | ObjectReferenceImpl.c | 224 (void)outStream_writeObjectRef(env, out, info.waiters[i]); in monitorInfo()
228 if (info.waiters != NULL ) in monitorInfo()
229 jvmtiDeallocate(info.waiters); in monitorInfo()
|
| /external/python/cpython3/Lib/importlib/ |
| D | _bootstrap.py | 64 self.waiters = 0
96 self.waiters += 1
112 if self.waiters:
113 self.waiters -= 1
|
| /external/python/cpython2/Lib/ |
| D | threading.py | 386 waiters = __waiters[:n]
387 if not waiters:
393 for waiter in waiters:
|
| /external/igt-gpu-tools/benchmarks/ezbench.d/ |
| D | gem_latency.test | 65 # Measure the wakeup delay for contended wakeups (multiple waiters per request)
|
| /external/deqp/modules/egl/ |
| D | teglMultiThreadTests.cpp | 294 const deInt32 waiters = deAtomicIncrement32(&m_barrierWaiters); in barrier() local
296 if (waiters == m_threadCount) in barrier()
309 const deInt32 waiters = deAtomicDecrement32(&m_barrierWaiters); in barrier() local
311 if (waiters == 0) in barrier()
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| D | ObjectReferenceImpl.java | 531 return Arrays.asList((ThreadReference[])jdwpMonitorInfo().waiters); in waitingThreads()
|
| /external/rust/crates/libc/src/unix/haiku/ |
| D | mod.rs | 240 waiters: [*mut ::c_void; 2],
989 waiters: [0 as *mut _; 2],
|
| /external/mesa3d/docs/relnotes/ |
| D | 17.0.0.rst | 121 waiters.
|
| D | 13.0.0.rst | 314 waiters.
|