Changeset 6117fc0 for benchmark

Timestamp:

Jan 20, 2022, 11:18:11 AM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, enum, forall-pointer-decay, master, pthread-emulation, qualifiedEnum

Children:

d3261710

Parents:

753fb978

Message:

Httpforall now pins kernel threads

File:

• benchmark/io/http/main.cfa (modified) (2 diffs)

benchmark/io/http/main.cfa

@@ -6 +6 @@
 #include <unistd.h>
 extern "C" {
+        #include <sched.h>
         #include <signal.h>
         #include <sys/socket.h>
@@ -67 +68 @@
         (this.self){ "Server Cluster", options.clopts.params };
 
+        cpu_set_t fullset;
+        CPU_ZERO(&fullset);
+        int ret = sched_getaffinity(getpid(), sizeof(fullset), &fullset);
+        if( ret != 0 ) abort | "sched_getaffinity failed with" | errno | strerror( errno );
+        int cnt = CPU_COUNT(&fullset);
+
         this.procs = alloc(options.clopts.nprocs);
         for(i; options.clopts.nprocs) {
                 (this.procs[i]){ "Benchmark Processor", this.self };
+
+                int c = 0;
+                int n = 1 + (i % cnt);
+                for(int j = 0; j < CPU_SETSIZE; j++) {
+                        if(CPU_ISSET(j, &fullset)) n--;
+                        if(n == 0) {
+                                c = j;
+                                break;
+                        }
+                }
+                cpu_set_t localset;
+                CPU_ZERO(&localset);
+                CPU_SET(c, &localset);
+                ret = pthread_setaffinity_np(this.procs[i].kernel_thread, sizeof(localset), &localset);
+                if( ret != 0 ) abort | "sched_getaffinity failed with" | ret | strerror( ret );
 
                 #if !defined(__CFA_NO_STATISTICS__)