Lines Matching refs:nwakes
46 static unsigned int nwakes = 1; variable
67 OPT_UINTEGER('w', "nwakers", ¶ms.nwakes, "Specify amount of waking threads"),
89 waker->nwoken = futex_wake(&futex, nwakes, futex_flag); in waking_workerfn()
90 if (waker->nwoken != nwakes) in waking_workerfn()
92 waker->nwoken, nwakes); in waking_workerfn()
109 pthread_barrier_init(&barrier, NULL, params.nwakes + 1); in wakeup_threads()
112 for (i = 0; i < params.nwakes; i++) { in wakeup_threads()
125 for (i = 0; i < params.nwakes; i++) in wakeup_threads()
195 for (i = 0; i < params.nwakes; i++) { in print_run()
232 for (i = 0; i < params.nwakes; i++) { in do_run_stats()
279 if (params.nwakes > params.nthreads || in bench_futex_wake_parallel()
280 !params.nwakes) in bench_futex_wake_parallel()
281 params.nwakes = params.nthreads; in bench_futex_wake_parallel()
283 if (params.nthreads % params.nwakes) in bench_futex_wake_parallel()
289 nwakes = params.nthreads/params.nwakes; in bench_futex_wake_parallel()
303 &futex, params.nwakes, nwakes); in bench_futex_wake_parallel()
313 waking_worker = calloc(params.nwakes, sizeof(*waking_worker)); in bench_futex_wake_parallel()