53 FIXTURE(args)  in FIXTURE()  argument
57 FIXTURE_SETUP(args)  in FIXTURE_SETUP()  argument
61 FIXTURE_TEARDOWN(args)  in FIXTURE_TEARDOWN()  argument
65 FIXTURE_VARIANT(args)  in FIXTURE_VARIANT()  argument
79 FIXTURE_VARIANT_ADD(args, t_##timeout)			\
84 FIXTURE_VARIANT_ADD(args, t_##timeout##_broadcast)	\
90 FIXTURE_VARIANT_ADD(args, t_##timeout##_broadcast_locked) \
97 FIXTURE_VARIANT_ADD(args, t_##timeout##_broadcast_owner) \
104 FIXTURE_VARIANT_ADD(args, t_##timeout##_locked)		\
110 FIXTURE_VARIANT_ADD(args, t_##timeout##_owner)		\
161 	struct thread_arg *args = (struct thread_arg *)arg;  in waiterfn()  local
164 	ksft_print_dbg_msg("Waiter %ld: running\n", args->id);  in waiterfn()
168 	usleep(1000 * (long)args->id);  in waiterfn()
174 	args->ret = futex_wait_requeue_pi(&f1, old_val, &f2, args->timeout,  in waiterfn()
177 	ksft_print_dbg_msg("waiter %ld woke with %d %s\n", args->id, args->ret,  in waiterfn()
178 	     args->ret < 0 ? strerror(errno) : "");  in waiterfn()
180 	if (args->ret < 0) {  in waiterfn()
181 		if (args->timeout && errno == ETIMEDOUT)  in waiterfn()
182 			args->ret = 0;  in waiterfn()
190 	ksft_print_dbg_msg("Waiter %ld: exiting with %d\n", args->id, args->ret);  in waiterfn()
191 	pthread_exit((void *)&args->ret);  in waiterfn()
196 	struct thread_arg *args = (struct thread_arg *)arg;  in broadcast_wakerfn()  local
209 	if (args->lock) {  in broadcast_wakerfn()
215 	args->ret = futex_cmp_requeue_pi(&f1, old_val, &f2, nr_wake, nr_requeue,  in broadcast_wakerfn()
217 	if (args->ret < 0) {  in broadcast_wakerfn()
220 		task_count += args->ret;  in broadcast_wakerfn()
230 	if (args->lock)  in broadcast_wakerfn()
233 	if (args->ret > 0)  in broadcast_wakerfn()
234 		args->ret = task_count;  in broadcast_wakerfn()
236 	ksft_print_dbg_msg("Waker: exiting with %d\n", args->ret);  in broadcast_wakerfn()
237 	pthread_exit((void *)&args->ret);  in broadcast_wakerfn()
242 	struct thread_arg *args = (struct thread_arg *)arg;  in signal_wakerfn()  local
257 		if (args->lock) {  in signal_wakerfn()
265 		args->ret = futex_cmp_requeue_pi(&f1, old_val, &f2,  in signal_wakerfn()
268 		if (args->ret < 0)  in signal_wakerfn()
269 			args->ret = -errno;  in signal_wakerfn()
271 		if (args->lock) {  in signal_wakerfn()
277 		if (args->ret < 0)  in signal_wakerfn()
280 		task_count += args->ret;  in signal_wakerfn()
292 	if (args->ret >= 0)  in signal_wakerfn()
293 		args->ret = task_count;  in signal_wakerfn()
295 	ksft_print_dbg_msg("Waker: exiting with %d\n", args->ret);  in signal_wakerfn()
297 	pthread_exit((void *)&args->ret);  in signal_wakerfn()
302 	struct thread_arg *args = (struct thread_arg *)arg;  in third_party_blocker()  local
305 	args->ret = futex_lock_pi(&f2, NULL, 0, FUTEX_PRIVATE_FLAG);  in third_party_blocker()
306 	if (args->ret)  in third_party_blocker()
308 	args->ret = futex_wait(&wake_complete, wake_complete, NULL,  in third_party_blocker()
313 	if (args->ret || ret2)  in third_party_blocker()
316 	pthread_exit((void *)&args->ret);  in third_party_blocker()
319 TEST_F(args, futex_requeue_pi)  in TEST_F()  argument
328 	struct thread_arg args[THREAD_MAX];  in TEST_F()  local
362 		args[i].id = i;  in TEST_F()
363 		args[i].timeout = tsp;  in TEST_F()
365 		if (create_rt_thread(&waiter[i], waiterfn, (void *)&args[i],  in TEST_F()
378 	waiter_ret = &args[0].ret;  in TEST_F()