Lines Matching refs:nwakes
46 static unsigned int nwakes = 1; variable
64 OPT_UINTEGER('w', "nwakers", ¶ms.nwakes, "Specify amount of waking threads"),
86 waker->nwoken = futex_wake(&futex, nwakes, futex_flag); in waking_workerfn()
87 if (waker->nwoken != nwakes) in waking_workerfn()
89 waker->nwoken, nwakes); in waking_workerfn()
106 pthread_barrier_init(&barrier, NULL, params.nwakes + 1); in wakeup_threads()
109 for (i = 0; i < params.nwakes; i++) { in wakeup_threads()
122 for (i = 0; i < params.nwakes; i++) in wakeup_threads()
192 for (i = 0; i < params.nwakes; i++) { in print_run()
228 for (i = 0; i < params.nwakes; i++) { in do_run_stats()
275 if (params.nwakes > params.nthreads || in bench_futex_wake_parallel()
276 !params.nwakes) in bench_futex_wake_parallel()
277 params.nwakes = params.nthreads; in bench_futex_wake_parallel()
279 if (params.nthreads % params.nwakes) in bench_futex_wake_parallel()
285 nwakes = params.nthreads/params.nwakes; in bench_futex_wake_parallel()
297 &futex, params.nwakes, nwakes); in bench_futex_wake_parallel()
307 waking_worker = calloc(params.nwakes, sizeof(*waking_worker)); in bench_futex_wake_parallel()