1 files changed, 14 insertions, 9 deletions

diff --git a/tools/perf/bench/futex-lock-pi.c b/tools/perf/bench/futex-lock-pi.c
index 08653ae8a8c4..8e9c4753e304 100644
--- a/tools/perf/bench/futex-lock-pi.c
+++ b/tools/perf/bench/futex-lock-pi.c
@@ -15,6 +15,7 @@
 #include <errno.h>
 #include "bench.h"
 #include "futex.h"
+#include "cpumap.h"
 
 #include <err.h>
 #include <stdlib.h>
@@ -32,7 +33,7 @@ static struct worker *worker;
 static unsigned int nsecs = 10;
 static bool silent = false, multi = false;
 static bool done = false, fshared = false;
-static unsigned int ncpus, nthreads = 0;
+static unsigned int nthreads = 0;
 static int futex_flag = 0;
 struct timeval start, end, runtime;
 static pthread_mutex_t thread_lock;
@@ -113,9 +114,10 @@ static void *workerfn(void *arg)
         return NULL;
 }
 
-static void create_threads(struct worker *w, pthread_attr_t thread_attr)
+static void create_threads(struct worker *w, pthread_attr_t thread_attr,
+                           struct cpu_map *cpu)
 {
-        cpu_set_t cpu;
+        cpu_set_t cpuset;
         unsigned int i;
 
         threads_starting = nthreads;
@@ -130,10 +132,10 @@ static void create_threads(struct worker *w, pthread_attr_t thread_attr)
                 } else
                         worker[i].futex = &global_futex;
 
-                CPU_ZERO(&cpu);
-                CPU_SET(i % ncpus, &cpu);
+                CPU_ZERO(&cpuset);
+                CPU_SET(cpu->map[i % cpu->nr], &cpuset);
 
-                if (pthread_attr_setaffinity_np(&thread_attr, sizeof(cpu_set_t), &cpu))
+                if (pthread_attr_setaffinity_np(&thread_attr, sizeof(cpu_set_t), &cpuset))
                         err(EXIT_FAILURE, "pthread_attr_setaffinity_np");
 
                 if (pthread_create(&w[i].thread, &thread_attr, workerfn, &worker[i]))
@@ -147,19 +149,22 @@ int bench_futex_lock_pi(int argc, const char **argv)
         unsigned int i;
         struct sigaction act;
         pthread_attr_t thread_attr;
+        struct cpu_map *cpu;
 
         argc = parse_options(argc, argv, options, bench_futex_lock_pi_usage, 0);
         if (argc)
                 goto err;
 
-        ncpus = sysconf(_SC_NPROCESSORS_ONLN);
+        cpu = cpu_map__new(NULL);
+        if (!cpu)
+                err(EXIT_FAILURE, "calloc");
 
         sigfillset(&act.sa_mask);
         act.sa_sigaction = toggle_done;
         sigaction(SIGINT, &act, NULL);
 
         if (!nthreads)
-                nthreads = ncpus;
+                nthreads = cpu->nr;
 
         worker = calloc(nthreads, sizeof(*worker));
         if (!worker)
@@ -180,7 +185,7 @@ int bench_futex_lock_pi(int argc, const char **argv)
         pthread_attr_init(&thread_attr);
         gettimeofday(&start, NULL);
 
-        create_threads(worker, thread_attr);
+        create_threads(worker, thread_attr, cpu);
         pthread_attr_destroy(&thread_attr);
 
         pthread_mutex_lock(&thread_lock);