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()
104 pthread_barrier_init(&barrier, NULL, params.nwakes + 1); in wakeup_threads()
107 for (i = 0; i < params.nwakes; i++) { in wakeup_threads()
120 for (i = 0; i < params.nwakes; i++) in wakeup_threads()
186 for (i = 0; i < params.nwakes; i++) { in print_run()
222 for (i = 0; i < params.nwakes; i++) { in do_run_stats()
270 if (params.nwakes > params.nthreads || in bench_futex_wake_parallel()
271 !params.nwakes) in bench_futex_wake_parallel()
272 params.nwakes = params.nthreads; in bench_futex_wake_parallel()
274 if (params.nthreads % params.nwakes) in bench_futex_wake_parallel()
280 nwakes = params.nthreads/params.nwakes; in bench_futex_wake_parallel()
292 &futex, params.nwakes, nwakes); in bench_futex_wake_parallel()
303 waking_worker = calloc(params.nwakes, sizeof(*waking_worker)); in bench_futex_wake_parallel()