56 	int ret;  member
76 	int ret;  in create_rt_thread()  local
83 	ret = pthread_attr_setinheritsched(&attr, PTHREAD_EXPLICIT_SCHED);  in create_rt_thread()
84 	if (ret) {  in create_rt_thread()
85 		error("pthread_attr_setinheritsched\n", ret);  in create_rt_thread()
89 	ret = pthread_attr_setschedpolicy(&attr, policy);  in create_rt_thread()
90 	if (ret) {  in create_rt_thread()
91 		error("pthread_attr_setschedpolicy\n", ret);  in create_rt_thread()
96 	ret = pthread_attr_setschedparam(&attr, &schedp);  in create_rt_thread()
97 	if (ret) {  in create_rt_thread()
98 		error("pthread_attr_setschedparam\n", ret);  in create_rt_thread()
102 	ret = pthread_create(pth, &attr, func, arg);  in create_rt_thread()
103 	if (ret) {  in create_rt_thread()
104 		error("pthread_create\n", ret);  in create_rt_thread()
126 	args->ret = futex_wait_requeue_pi(&f1, old_val, &f2, args->timeout,  in waiterfn()
129 	info("waiter %ld woke with %d %s\n", args->id, args->ret,  in waiterfn()
130 	     args->ret < 0 ? strerror(errno) : "");  in waiterfn()
132 	if (args->ret < 0) {  in waiterfn()
134 			args->ret = 0;  in waiterfn()
136 			args->ret = RET_ERROR;  in waiterfn()
143 	info("Waiter %ld: exiting with %d\n", args->id, args->ret);  in waiterfn()
144 	pthread_exit((void *)&args->ret);  in waiterfn()
168 	args->ret = futex_cmp_requeue_pi(&f1, old_val, &f2, nr_wake, nr_requeue,  in broadcast_wakerfn()
170 	if (args->ret < 0) {  in broadcast_wakerfn()
171 		args->ret = RET_ERROR;  in broadcast_wakerfn()
174 		task_count += args->ret;  in broadcast_wakerfn()
180 		args->ret = RET_ERROR;  in broadcast_wakerfn()
188 	if (args->ret > 0)  in broadcast_wakerfn()
189 		args->ret = task_count;  in broadcast_wakerfn()
191 	info("Waker: exiting with %d\n", args->ret);  in broadcast_wakerfn()
192 	pthread_exit((void *)&args->ret);  in broadcast_wakerfn()
220 		args->ret = futex_cmp_requeue_pi(&f1, old_val, &f2,  in signal_wakerfn()
223 		if (args->ret < 0)  in signal_wakerfn()
224 			args->ret = -errno;  in signal_wakerfn()
232 		if (args->ret < 0) {  in signal_wakerfn()
234 			args->ret = RET_ERROR;  in signal_wakerfn()
238 		task_count += args->ret;  in signal_wakerfn()
245 			args->ret = RET_ERROR;  in signal_wakerfn()
252 	if (args->ret >= 0)  in signal_wakerfn()
253 		args->ret = task_count;  in signal_wakerfn()
255 	info("Waker: exiting with %d\n", args->ret);  in signal_wakerfn()
257 	pthread_exit((void *)&args->ret);  in signal_wakerfn()
265 	args->ret = futex_lock_pi(&f2, NULL, 0, FUTEX_PRIVATE_FLAG);  in third_party_blocker()
266 	if (args->ret)  in third_party_blocker()
268 	args->ret = futex_wait(&wake_complete, wake_complete, NULL,  in third_party_blocker()
273 	if (args->ret || ret2) {  in third_party_blocker()
275 		args->ret = RET_ERROR;  in third_party_blocker()
278 	pthread_exit((void *)&args->ret);  in third_party_blocker()
290 	int i, ret = RET_PASS;  in unit_test()  local
296 		ret = clock_gettime(CLOCK_MONOTONIC, &ts);  in unit_test()
313 			ret = RET_ERROR;  in unit_test()
326 			ret = RET_ERROR;  in unit_test()
334 		ret = RET_ERROR;  in unit_test()
340 	waiter_ret = &args[0].ret;  in unit_test()
350 	if (!ret) {  in unit_test()
352 			ret = *waiter_ret;  in unit_test()
353 		else if (waker_arg.ret < 0)  in unit_test()
354 			ret = waker_arg.ret;  in unit_test()
355 		else if (blocker_arg.ret)  in unit_test()
356 			ret = blocker_arg.ret;  in unit_test()
359 	return ret;  in unit_test()
364 	int c, ret;  in main()  local
405 	ret = unit_test(broadcast, locked, owner, timeout_ns);  in main()
407 	print_result(ret);  in main()
408 	return ret;  in main()