perf/bench/futex-requeue.c

44 static struct bench_futex_parameters params = {
54 	OPT_INTEGER( 'b', "buckets", &params.nbuckets, "Specify amount of hash buckets"),
55 	OPT_UINTEGER('t', "threads",  &params.nthreads, "Specify amount of threads"),
56 	OPT_UINTEGER('q', "nrequeue", &params.nrequeue, "Specify amount of threads to requeue at once"),
57 	OPT_BOOLEAN( 's', "silent",   &params.silent, "Silent mode: do not display data/details"),
58 	OPT_BOOLEAN( 'S', "shared",   &params.fshared, "Use shared futexes instead of private ones"),
59 	OPT_BOOLEAN( 'm', "mlockall", &params.mlockall, "Lock all current and future memory"),
60 	OPT_BOOLEAN( 'B', "broadcast", &params.broadcast, "Requeue all threads at once"),
61 	OPT_BOOLEAN( 'p', "pi", &params.pi, "Use PI-aware variants of FUTEX_CMP_REQUEUE"),
79 	       params.nthreads,
82 	futex_print_nbuckets(&params);
97 		if (!params.pi) {
103 				if (!params.silent)
117 				if (!params.silent)
134 	threads_starting = params.nthreads;
141 	for (i = 0; i < params.nthreads; i++) {
189 	if (params.mlockall) {
194 	if (!params.nthreads)
195 		params.nthreads = perf_cpu_map__nr(cpu);
197 	worker = calloc(params.nthreads, sizeof(*worker));
201 	if (!params.fshared)
204 	if (params.nrequeue > params.nthreads)
205 		params.nrequeue = params.nthreads;
207 	if (params.broadcast)
208 		params.nrequeue = params.nthreads;
210 	futex_set_nbuckets_param(&params);
213 	       "%d at a time.\n\n",  getpid(), params.nthreads,
214 	       params.fshared ? "shared":"private", &futex1,
215 	       params.pi ? "PI ": "", &futex2, params.nrequeue);
241 		while (nrequeued < params.nthreads) {
250 			if (!params.pi) {
252 						      params.nrequeue,
256 							 params.nrequeue,
274 		if (!params.silent) {
275 			if (!params.pi)
278 				       params.nthreads,
285 				       params.nthreads,
291 		if (!params.pi) {
294 			if (params.nthreads != nrequeued)
296 				      nrequeued, params.nthreads);
299 		for (i = 0; i < params.nthreads; i++) {