| /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/mesa3d/src/gallium/auxiliary/os/ |
| D | os_thread.h | 195 unsigned waiters; member
204 barrier->waiters = 0; in pipe_barrier_init()
212 assert(barrier->waiters == 0); in pipe_barrier_destroy()
221 assert(barrier->waiters < barrier->count); in pipe_barrier_wait()
222 barrier->waiters++; in pipe_barrier_wait()
224 if (barrier->waiters < barrier->count) { in pipe_barrier_wait()
231 barrier->waiters = 0; in pipe_barrier_wait()
|
| /external/fio/ |
| D | mutex.c | 173 mutex->waiters++; in fio_mutex_down_timeout()
183 mutex->waiters--; in fio_mutex_down_timeout()
218 mutex->waiters++; in fio_mutex_down()
220 mutex->waiters--; in fio_mutex_down()
235 if (!mutex->value && mutex->waiters) in fio_mutex_up()
|
| D | mutex.h | 14 int waiters; member
|
| /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/valgrind/drd/ |
| D | drd_semaphore.c | 107 p->waiters = 0; in drd_semaphore_initialize()
121 if (p->waiters > 0) in semaphore_cleanup()
327 p->waiters++; in DRD_()
329 if ((Word)(p->waiters) <= 0) in DRD_()
359 p->waiters--; in DRD_()
370 if (p == NULL || (Int)(p->value) < 0 || (Word)(p->waiters) < 0) in DRD_()
|
| D | drd_clientobj.h | 110 UWord waiters; // Number of threads inside sem_wait(). member
|
| /external/python/cpython3/Lib/asyncio/ |
| D | queues.py | 69 def _wakeup_next(self, waiters): argument
71 while waiters:
72 waiter = waiters.popleft()
|
| D | base_events.py | 218 waiters = self._waiters
220 for waiter in waiters:
|
| /external/v8/src/ |
| D | futex-emulation.cc | 226 int waiters = 0; in NumWaitersForTesting() local
231 waiters++; in NumWaitersForTesting()
237 return Smi::FromInt(waiters); in NumWaitersForTesting()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 946 int waiters = guard.waiterCount++; in beginWaitingFor() local
947 if (waiters == 0) { in beginWaitingFor()
959 int waiters = --guard.waiterCount; in endWaitingFor() local
960 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/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 | 63 self.waiters = 0
95 self.waiters += 1
111 if self.waiters:
112 self.waiters -= 1
|
| /external/valgrind/drd/tests/ |
| D | bar_bad.stderr.exp-nohang | 28 Destruction of a barrier with active waiters: barrier 0x........
|
| D | bar_bad.stderr.exp-solaris | 28 Destruction of a barrier with active waiters: barrier 0x........
|
| /external/python/cpython2/Lib/ |
| D | threading.py | 386 waiters = __waiters[:n]
387 if not waiters:
393 for waiter in waiters:
|
| /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/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 605 waiters = []
611 waiters.append(asyncio.sleep(0.1, loop=loop))
612 yield from waiters[-1]
627 for w in waiters:
|
| /external/oj-libjdwp/make/data/jdwp/ |
| D | jdwp.spec | 1583 (Repeat waiters "The number of threads that are waiting for the monitor "
|
| /external/oj-libjdwp/src/share/javavm/export/ |
| D | jvmti.h | 613 jthread* waiters; member
|
| /external/python/cpython2/Doc/library/ |
| D | threading.rst | 540 possibly be a desired state for one of the waiters. For example, the following
|