diff options
| author | Wessel Dankers <wsl@fruit.je> | 2022-10-30 20:04:05 +0100 |
|---|---|---|
| committer | David Oberhollenzer <goliath@infraroot.at> | 2022-11-04 13:03:23 +0100 |
| commit | b7877c45fc7fe47709c963e15214a3dd5fc71e32 (patch) | |
| tree | 1c183d0e5870495cdd8777ff0c0f779b2596a0a8 /lib/common/writer | |
| parent | f3d87d9b78e28e2a6ad2676cce2b064f0bca6bd1 (diff) | |
Only use available CPUs
Not all CPUs may be available for the current process. Some CPUs
may be offline, others may not be included in the process affinity
mask. In such cases too many threads will be created, which will
then compete unnecessarily for CPU time.
Use sched_getaffinity() to determine the correct number of threads
to create.
Diffstat (limited to 'lib/common/writer')
| -rw-r--r-- | lib/common/writer/init.c | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/lib/common/writer/init.c b/lib/common/writer/init.c index 06726ce..7940c3f 100644 --- a/lib/common/writer/init.c +++ b/lib/common/writer/init.c @@ -10,16 +10,20 @@ #include <string.h> #include <stdlib.h> +#include <unistd.h> -#ifdef HAVE_SYS_SYSINFO_H -#include <sys/sysinfo.h> +#ifdef HAVE_SCHED_GETAFFINITY +#include <sched.h> static size_t os_get_num_jobs(void) { - int nprocs; + cpu_set_t cpu_set; + CPU_ZERO(&cpu_set); - nprocs = get_nprocs_conf(); - return nprocs < 1 ? 1 : nprocs; + if (sched_getaffinity(0, sizeof cpu_set, &cpu_set) == -1) + return 1; + else + return CPU_COUNT(&cpu_set); } #else static size_t os_get_num_jobs(void) |