Changeset f5a51db for benchmark

Timestamp:

Feb 8, 2022, 11:53:13 AM (4 years ago)

Author:

Michael Brooks <mlbrooks@…>

Branches:

ADT, ast-experimental, enum, master, pthread-emulation, qualifiedEnum, stuck-waitfor-destruct

Children:

cc7bbe6

Parents:

97c215f (diff), 1cf8a9f (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

Location:

benchmark/io/http

Files:

• Makefile.am (modified) (1 diff)
• main.cfa (modified) (4 diffs)

benchmark/io/http/Makefile.am

@@ -21 +21 @@
 include $(top_srcdir)/tools/build/cfa.make
 
-AM_CFLAGS = -O2 -Wall -Wextra -I$(srcdir) -lrt -pthread # -Werror
+AM_CFLAGS = -O3 -Wall -Wextra -I$(srcdir) -lrt -pthread # -Werror
 AM_CFAFLAGS = -quiet -nodebug
 AM_LDFLAGS = -quiet -nodebug

benchmark/io/http/main.cfa

@@ -1 @@
-#define __USE_GNU
+#define _GNU_SOURCE
 
 #include <errno.h>
@@ -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__)
@@ -146 +168 @@
         int waited = 0;
         for() {
-                ret = bind( server_fd, (struct sockaddr *)&address, sizeof(address) );
+                int sockfd = server_fd;
+                __CONST_SOCKADDR_ARG addr;
+                addr.__sockaddr__ = (struct sockaddr *)&address;
+                socklen_t addrlen = sizeof(address);
+                ret = bind( sockfd, addr, addrlen );
                 if(ret < 0) {
                         if(errno == EADDRINUSE) {