| /third_party/musl/src/thread/ |
| D | __wait.c | 3 void __wait(volatile int *addr, volatile int *waiters, int val, int priv) in __wait() argument
7 while (spins-- && (!waiters || !*waiters)) { in __wait()
11 if (waiters) a_inc(waiters); in __wait()
16 if (waiters) a_dec(waiters); in __wait()
|
| D | sem_post.c | 6 int val, waiters, priv = sem->__val[2]; in sem_post() local
9 waiters = sem->__val[1]; in sem_post()
15 if (val<0 || waiters) __wake(sem->__val, 1, priv); in sem_post()
|
| D | pthread_rwlock_unlock.c | 5 int val, cnt, waiters, new, priv = rw->_rw_shared^128; in __pthread_rwlock_unlock() local
10 waiters = rw->_rw_waiters; in __pthread_rwlock_unlock()
14 if (!new && (waiters || val<0)) in __pthread_rwlock_unlock()
|
| D | pthread_mutex_unlock.c | 6 int waiters = m->_m_waiters; in __pthread_mutex_unlock() local
39 waiters = 0; in __pthread_mutex_unlock()
47 if (waiters || cont<0) in __pthread_mutex_unlock()
|
| D | pthread_barrier_wait.c | 56 volatile int waiters; member
98 if (inst->waiters) in pthread_barrier_wait()
103 __wait(&inst->last, &inst->waiters, 0, 1); in pthread_barrier_wait()
|
| D | pthread_create.c | 127 int waiters = m->_m_waiters; in __pthread_exit() local
133 if (cont < 0 || waiters) in __pthread_exit()
|
| /third_party/musl/porting/liteos_a/user/src/thread/ |
| D | __wait.c | 3 void __wait(volatile int *addr, volatile int *waiters, int val, int priv) in __wait() argument
7 while (spins-- && (!waiters || !*waiters)) { in __wait()
11 if (waiters) a_inc(waiters); in __wait()
16 if (waiters) a_dec(waiters); in __wait()
|
| D | pthread_barrier_wait.c | 56 volatile int waiters; member
98 if (inst->waiters) in pthread_barrier_wait()
103 __wait(&inst->last, &inst->waiters, 0, 1); in pthread_barrier_wait()
|
| D | pthread_mutex_unlock.c | 6 int waiters = m->_m_waiters; in __pthread_mutex_unlock() local
40 if (waiters || cont<0) in __pthread_mutex_unlock()
|
| D | pthread_create.c | 104 int waiters = m->_m_waiters; in __pthread_exit() local
110 if (cont < 0 || waiters) in __pthread_exit()
|
| /third_party/mesa3d/src/util/ |
| D | u_thread.h | 312 unsigned waiters; member
321 barrier->waiters = 0; in util_barrier_init()
329 assert(barrier->waiters == 0); in util_barrier_destroy()
338 assert(barrier->waiters < barrier->count); in util_barrier_wait()
339 barrier->waiters++; in util_barrier_wait()
341 if (barrier->waiters < barrier->count) { in util_barrier_wait()
348 barrier->waiters = 0; in util_barrier_wait()
|
| /third_party/node/test/fixtures/wpt/streams/piping/ |
| D | flow-control.any.js | 168 this.waiters = []; property
175 if (this.waiters[n] === undefined) {
176 this.waiters[n] = new Promise(resolve => {
179 this.waiters[n]
190 return this.waiters[n];
|
| /third_party/gstreamer/gstreamer/docs/random/wtay/ |
| D | poll-timeout | 79 if (g_atomic_int_get (&waiters) > 0) {
83 while (waiters)
98 g_atomic_int_dec (&waiters);
116 g_atomic_int_inc (&waiters)
|
| /third_party/gstreamer/gstreamer/tests/check/gst/ |
| D | gstpromise.c | 539 struct event_queue *waiters[N_QUEUES]; in GST_START_TEST() local
551 waiters[i] = event_queue_new (); in GST_START_TEST()
552 waiters[i]->user_data = &s_q; in GST_START_TEST()
553 _enqueue_task (waiters[i], (GSourceFunc) _wait_promise, waiters[i], NULL); in GST_START_TEST()
570 event_queue_stop (waiters[i]); in GST_START_TEST()
589 event_queue_free (waiters[i]); in GST_START_TEST()
|
| /third_party/python/Lib/asyncio/ |
| D | queues.py | 58 def _wakeup_next(self, waiters): argument
60 while waiters:
61 waiter = waiters.popleft()
|
| D | base_events.py | 302 waiters = self._waiters
304 for waiter in waiters:
|
| /third_party/node/deps/v8/src/execution/ |
| D | futex-emulation.cc | 930 int waiters = 0; in NumWaitersForTesting() local
936 waiters++; in NumWaitersForTesting()
942 return Smi::FromInt(waiters); in NumWaitersForTesting()
948 int waiters = 0; in NumAsyncWaitersForTesting() local
953 waiters++; in NumAsyncWaitersForTesting()
959 return Smi::FromInt(waiters); in NumAsyncWaitersForTesting()
969 int waiters = 0; in NumUnresolvedAsyncPromisesForTesting() local
978 waiters++; in NumUnresolvedAsyncPromisesForTesting()
985 return Smi::FromInt(waiters); in NumUnresolvedAsyncPromisesForTesting()
|
| /third_party/alsa-lib/aserver/ |
| D | aserver.c | 121 waiter_t *waiters; variable
126 waiter_t *w = &waiters[fd]; in add_waiter()
140 waiter_t *w = &waiters[fd]; in del_waiter()
934 waiters = calloc((size_t) open_max, sizeof(*waiters)); in server()
985 waiter_t *w = &waiters[pfd->fd]; in server()
1000 free(waiters); in server()
|
| /third_party/python/Lib/importlib/ |
| D | _bootstrap.py | 77 self.waiters = 0
118 self.waiters += 1
134 if self.waiters:
135 self.waiters -= 1
|
| /third_party/musl/porting/linux/user/src/thread/ |
| D | pthread_create.c | 216 int waiters = m->_m_waiters; in __pthread_exit() local
222 if (cont < 0 || waiters) in __pthread_exit()
|
| /third_party/vk-gl-cts/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()
|
| /third_party/skia/third_party/externals/egl-registry/extensions/KHR/ |
| D | EGL_KHR_reusable_sync.txt | 491 One way to do this while allowing multiple waiters at some future
538 - Clarify that all waiters are woken up on signalling a sync.
|
| /third_party/EGL/extensions/KHR/ |
| D | EGL_KHR_reusable_sync.txt | 491 One way to do this while allowing multiple waiters at some future
538 - Clarify that all waiters are woken up on signalling a sync.
|
| /third_party/rust/crates/libc/src/unix/haiku/ |
| D | mod.rs | 295 waiters: [*mut ::c_void; 2],
1200 waiters: [0 as *mut _; 2],
|
| /third_party/mesa3d/docs/relnotes/ |
| D | 17.0.0.rst | 121 waiters.
|