perf/bench/futex-wake-parallel.c

46 static unsigned int nwakes = 1;
64 	OPT_UINTEGER('w', "nwakers", &params.nwakes, "Specify amount of waking threads"),
86 	waker->nwoken = futex_wake(&futex, nwakes, futex_flag);
87 	if (waker->nwoken != nwakes)
89 		      waker->nwoken, nwakes);
106 	pthread_barrier_init(&barrier, NULL, params.nwakes + 1);
109 	for (i = 0; i < params.nwakes; i++) {
122 	for (i = 0; i < params.nwakes; i++)
192 	for (i = 0; i < params.nwakes; i++) {
228 	for (i = 0; i < params.nwakes; i++) {
275 	if (params.nwakes > params.nthreads ||
276 	    !params.nwakes)
277 		params.nwakes = params.nthreads;
279 	if (params.nthreads % params.nwakes)
282 	 * Each thread will wakeup nwakes tasks in
285 	nwakes = params.nthreads/params.nwakes;
297 	       &futex, params.nwakes, nwakes);
307 		waking_worker = calloc(params.nwakes, sizeof(*waking_worker));