mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-29 05:40:27 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

thread: add support for thread affinity

Browse source
This commit is contained in:
Wim Taymans 2024-04-18 17:45:35 +02:00
parent 696cd8977a
commit 2d87310b60
2 changed files with 18 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
spa/include/spa/support/thread.h
View file

@ -117,6 +117,7 @@ static inline int spa_thread_utils_drop_rt(struct spa_thread_utils *o,
#define SPA_KEY_THREAD_NAME "thread.name" /* the thread name */
#define SPA_KEY_THREAD_STACK_SIZE "thread.stack-size" /* the stack size of the thread */
#define SPA_KEY_THREAD_AFFINITY "thread.affinity" /* array of CPUs for this thread */
/**
* \}

17
src/pipewire/thread.c
View file

@ -10,6 +10,7 @@
#include <spa/utils/dict.h>
#include <spa/utils/defs.h>
#include <spa/utils/list.h>
#include <spa/utils/json.h>
#include <pipewire/log.h>
#include <pipewire/private.h>
@ -37,6 +38,22 @@ void *pw_thread_fill_attr(const struct spa_dict *props, void *_attr)
pthread_attr_init(attr);
if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_STACK_SIZE)) != NULL)
CHECK(pthread_attr_setstacksize(attr, atoi(str)), error);
if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_AFFINITY)) != NULL) {
struct spa_json it[2];
int v;
cpu_set_t set;
CPU_ZERO(&set);
spa_json_init(&it[0], str, strlen(str));
if (spa_json_enter_array(&it[0], &it[1]) <= 0)
spa_json_init(&it[1], str, strlen(str));
while (spa_json_get_int(&it[1], &v) > 0) {
if (v >= 0 && v < CPU_SETSIZE)
CPU_SET(v, &set);
}
CHECK(pthread_attr_setaffinity_np(attr, sizeof(set), &set), error);
}
return attr;
error:
errno = -res;