| /third_party/musl/porting/liteos_a/user/src/thread/ |
| H A 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()
|
| H A 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()
|
| H A 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()
|
| H A D | pthread_create.c | 104 int waiters = m->_m_waiters; in __pthread_exit() local
110 if (cont < 0 || waiters) in __pthread_exit()
|
| /third_party/musl/src/thread/ |
| H A 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()
21 if (waiters) a_dec(waiters); in __wait()
|
| H A D | sem_post.c | 7 int val, new, waiters, priv = sem->__val[2]; in sem_post() local
10 waiters = sem->__val[1]; in sem_post()
16 if (waiters <= 1) in sem_post()
19 if (val<0) __wake(sem->__val, waiters>1 ? 1 : -1, priv); in sem_post()
|
| H A 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()
|
| H A D | pthread_mutex_unlock.c | 6 int waiters = m->_m_waiters; in __pthread_mutex_unlock() local
48 waiters = 0; in __pthread_mutex_unlock()
58 if (waiters || cont<0) in __pthread_mutex_unlock()
|
| H A D | pthread_barrier_wait.c | 56 volatile int waiters; member
103 if (inst->waiters) in pthread_barrier_wait()
108 __wait(&inst->last, &inst->waiters, 0, 1); in pthread_barrier_wait()
|
| H A D | pthread_create.c | 137 int waiters = m->_m_waiters; in __pthread_exit() local
143 if (cont < 0 || waiters) in __pthread_exit()
|
| /third_party/mesa3d/src/util/ |
| H A 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/ltp/testcases/kernel/syscalls/futex/ |
| H A D | futex2test.h | 18 * @waiters: Array of waiters
19 * @nr_waiters: Length of waiters array
23 static inline int futex_waitv(volatile struct futex_waitv *waiters, in futex_waitv() argument
27 return tst_syscall(__NR_futex_waitv, waiters, nr_waiters, flags, timo, clockid); in futex_waitv()
|
| /third_party/python/Lib/asyncio/ |
| H A D | queues.py | 58 def _wakeup_next(self, waiters):
60 while waiters:
61 waiter = waiters.popleft()
|
| H A D | base_events.py | 304 waiters = self._waiters
306 for waiter in waiters:
|
| /third_party/node/deps/v8/src/execution/ |
| H A D | futex-emulation.cc | 173 // Nullify the timeout time; this distinguishes timed out waiters from in NotifyAsyncWaiter()
801 // When waiters are notified, their async_timeout_time_ is reset. Having a in ResolveAsyncWaiterPromise()
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()
[all...] |
| /third_party/alsa-lib/aserver/ |
| H A D | aserver.c | 122 waiter_t *waiters; variable
127 waiter_t *w = &waiters[fd]; in add_waiter()
141 waiter_t *w = &waiters[fd]; in del_waiter()
939 waiters = calloc((size_t) open_max, sizeof(*waiters)); in server()
990 waiter_t *w = &waiters[pfd->fd]; in server()
1005 free(waiters); in server()
|
| /third_party/musl/src/thread/liteos_a/ |
| H A D | pthread_create.c | 104 int waiters = m->_m_waiters; in __pthread_exit() local
110 if (cont < 0 || waiters) in __pthread_exit()
|
| /third_party/python/Lib/ |
| H A D | threading.py | 371 waiters = self._waiters
372 while waiters and n > 0:
373 waiter = waiters[0]
385 waiters.remove(waiter)
667 f" waiters={self.n_waiting}/{self.parties}>")
|
| /third_party/musl/src/thread/linux/ |
| H A D | pthread_create.c | 278 int waiters = m->_m_waiters; in __pthread_exit() local
284 if (cont < 0 || waiters) in __pthread_exit()
|
| /third_party/musl/porting/linux/user/src/thread/ |
| H A D | pthread_create.c | 216 int waiters = m->_m_waiters; in __pthread_exit() local
222 if (cont < 0 || waiters) in __pthread_exit()
|
| /third_party/python/Lib/importlib/ |
| H A D | _bootstrap.py | 77 self.waiters = 0
118 self.waiters += 1
134 if self.waiters:
135 self.waiters -= 1
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_locks.py | 15 r'(, waiters:\d+)?'
16 r'(, waiters:\d+\/\d+)?' # barrier
298 self.assertTrue('waiters:1' in repr(ev))
677 self.assertTrue('waiters:1' in repr(cond))
681 self.assertTrue('waiters:2' in repr(cond))
775 self.assertTrue('waiters' not in repr(sem))
782 self.assertTrue('waiters:1' in repr(sem))
786 self.assertTrue('waiters:2' in repr(sem))
1080 waiters = []
1086 waiters
[all...] |
| /third_party/vk-gl-cts/modules/egl/ |
| H A 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/rust/crates/libc/src/unix/haiku/ |
| H A D | mod.rs | 295 waiters: [*mut ::c_void; 2],
1200 waiters: [0 as *mut _; 2],
|