| /external/ltp/testcases/kernel/syscalls/futex/ |
| D | futex_cmp_requeue01.c | 32 int num_waiters; member
78 int pid[tc->num_waiters]; in verify_futex_cmp_requeue()
83 for (i = 0; i < tc->num_waiters; i++) { in verify_futex_cmp_requeue()
89 for (i = 0; i < tc->num_waiters; i++) in verify_futex_cmp_requeue()
93 n, tc->num_waiters, tc->set_wakes, tc->set_requeues); in verify_futex_cmp_requeue()
118 num_requeues = futex_wake(&sd->futexes[1], tc->num_waiters, 0); in verify_futex_cmp_requeue()
119 num_waits = futex_wake(&sd->futexes[0], tc->num_waiters, 0); in verify_futex_cmp_requeue()
122 for (i = 0; i < tc->num_waiters; i++) { in verify_futex_cmp_requeue()
134 if (num_total != tc->num_waiters) { in verify_futex_cmp_requeue()
136 tc->num_waiters - num_total); in verify_futex_cmp_requeue()
|
| /external/llvm-project/libcxxabi/test/ |
| D | guard_threaded_test.pass.cpp | 190 void test_free_for_all(int num_waiters) { in test_free_for_all() argument
196 threads.CreateThreadsWithBarrier(num_waiters, in test_free_for_all()
207 assert(test_obj.get_count(COMPLETE) + test_obj.get_count(WAITED) == num_waiters - 1); in test_free_for_all()
211 void test_waiting_for_init(int num_waiters) { in test_waiting_for_init() argument
231 threads.CreateThreadsWithBarrier(num_waiters, in test_waiting_for_init()
242 assert(test_obj.get_count(COMPLETE) + test_obj.get_count(WAITED) == num_waiters); in test_waiting_for_init()
247 void test_aborted_init(int num_waiters) { in test_aborted_init() argument
262 threads.CreateThreadsWithBarrier(num_waiters, in test_aborted_init()
276 assert(test_obj.get_count(WAITED) + test_obj.get_count(COMPLETE) == num_waiters - 1); in test_aborted_init()
281 void test_completed_init(int num_waiters) { in test_completed_init() argument
[all …]
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 171 int num_waiters = state.range(1); in BM_ConditionWaiters() local
184 num_classes = num_waiters; in BM_ConditionWaiters()
187 absl::BlockingCounter init(num_waiters); in BM_ConditionWaiters()
192 absl::synchronization_internal::ThreadPool pool(num_waiters); in BM_ConditionWaiters()
194 for (int i = 0; i < num_waiters; i++) { in BM_ConditionWaiters()
|
| /external/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 171 int num_waiters = state.range(1); in BM_ConditionWaiters() local
184 num_classes = num_waiters; in BM_ConditionWaiters()
187 absl::BlockingCounter init(num_waiters); in BM_ConditionWaiters()
192 absl::synchronization_internal::ThreadPool pool(num_waiters); in BM_ConditionWaiters()
194 for (int i = 0; i < num_waiters; i++) { in BM_ConditionWaiters()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 172 int num_waiters = state.range(1); in BM_ConditionWaiters() local
185 num_classes = num_waiters; in BM_ConditionWaiters()
188 absl::BlockingCounter init(num_waiters); in BM_ConditionWaiters()
193 absl::synchronization_internal::ThreadPool pool(num_waiters); in BM_ConditionWaiters()
195 for (int i = 0; i < num_waiters; i++) { in BM_ConditionWaiters()
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | mutex_benchmark.cc | 172 int num_waiters = state.range(1); in BM_ConditionWaiters() local
185 num_classes = num_waiters; in BM_ConditionWaiters()
188 absl::BlockingCounter init(num_waiters); in BM_ConditionWaiters()
193 absl::synchronization_internal::ThreadPool pool(num_waiters); in BM_ConditionWaiters()
195 for (int i = 0; i < num_waiters; i++) { in BM_ConditionWaiters()
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 172 int num_waiters = state.range(1); in BM_ConditionWaiters() local
185 num_classes = num_waiters; in BM_ConditionWaiters()
188 absl::BlockingCounter init(num_waiters); in BM_ConditionWaiters()
193 absl::synchronization_internal::ThreadPool pool(num_waiters); in BM_ConditionWaiters()
195 for (int i = 0; i < num_waiters; i++) { in BM_ConditionWaiters()
|
| /external/squashfs-tools/kernel/fs/squashfs/ |
| D | cache.c | 85 cache->num_waiters++; in squashfs_cache_get()
89 cache->num_waiters--; in squashfs_cache_get()
116 entry->num_waiters = 0; in squashfs_cache_get()
136 if (entry->num_waiters) { in squashfs_cache_get()
161 entry->num_waiters++; in squashfs_cache_get()
196 if (cache->num_waiters) { in squashfs_cache_put()
256 cache->num_waiters = 0; in squashfs_cache_init()
|
| D | squashfs_fs_sb.h | 32 int num_waiters; member
48 int num_waiters; member
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 258 int num_waiters = state.range(1); in BM_ConditionWaiters() local
271 num_classes = num_waiters; in BM_ConditionWaiters()
274 absl::BlockingCounter init(num_waiters); in BM_ConditionWaiters()
279 absl::synchronization_internal::ThreadPool pool(num_waiters); in BM_ConditionWaiters()
281 for (int i = 0; i < num_waiters; i++) { in BM_ConditionWaiters()
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | synchronize.py | 226 num_waiters = (self._sleeping_count._semlock._get_value() -
229 num_waiters = 'unknown'
230 return '<Condition(%s, %s)>' % (self._lock, num_waiters)
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | synchronize.py | 241 num_waiters = (self._sleeping_count._semlock._get_value() -
244 num_waiters = 'unknown'
245 return '<%s(%s, %s)>' % (self.__class__.__name__, self._lock, num_waiters)
|