mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2026-03-27 07:58:16 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

thread: use pthread_setaffinity_np

Browse source 
The attribute version does not seem to be supported on alpine.
This commit is contained in:
Wim Taymans 2024-04-23 12:12:33 +02:00
parent 20b52d2082
commit 2eb9a7543a
1 changed files with 27 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

43
src/pipewire/thread.c
View file

@ -25,6 +25,23 @@ do { \
} \ } \
} while(false); } while(false);
static int parse_affinity(const char *affinity, cpu_set_t *set)
{
struct spa_json it[2];
int v;
CPU_ZERO(set);
spa_json_init(&it[0], affinity, strlen(affinity));
if (spa_json_enter_array(&it[0], &it[1]) <= 0)
spa_json_init(&it[1], affinity, strlen(affinity));
while (spa_json_get_int(&it[1], &v) > 0) {
if (v >= 0 && v < CPU_SETSIZE)
CPU_SET(v, set);
}
return 0;
}
SPA_EXPORT SPA_EXPORT
void *pw_thread_fill_attr(const struct spa_dict *props, void *_attr) void *pw_thread_fill_attr(const struct spa_dict *props, void *_attr)
{ {
@ -38,22 +55,6 @@ void *pw_thread_fill_attr(const struct spa_dict *props, void *_attr)
pthread_attr_init(attr); pthread_attr_init(attr);
if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_STACK_SIZE)) != NULL) if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_STACK_SIZE)) != NULL)
CHECK(pthread_attr_setstacksize(attr, atoi(str)), error); 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; return attr;
error: error:
errno = -res; errno = -res;
@ -74,6 +75,13 @@ int pthread_setname_np(pthread_t thread, const char *name)
int pthread_setname_np(pthread_t thread, const char *name) { return 0; } int pthread_setname_np(pthread_t thread, const char *name) { return 0; }
#endif #endif
static int thread_setaffinity(pthread_t thread, const char *affinity)
{
cpu_set_t set;
parse_affinity(affinity, &set);
return -pthread_setaffinity_np(thread, sizeof(set), &set);
}
static struct spa_thread *impl_create(void *object, static struct spa_thread *impl_create(void *object,
const struct spa_dict *props, const struct spa_dict *props,
void *(*start)(void*), void *arg) void *(*start)(void*), void *arg)
@ -98,6 +106,9 @@ static struct spa_thread *impl_create(void *object,
if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_NAME)) != NULL && if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_NAME)) != NULL &&
(err = pthread_setname_np(pt, str)) != 0) (err = pthread_setname_np(pt, str)) != 0)
pw_log_warn("pthread_setname error: %s", strerror(err)); pw_log_warn("pthread_setname error: %s", strerror(err));
if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_AFFINITY)) != NULL &&
(err = thread_setaffinity(pt, str)) != 0)
pw_log_warn("pthread_setaffinity error: %s", strerror(err));
} }
return (struct spa_thread*)pt; return (struct spa_thread*)pt;
} }