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

data-loop: support custom name and affinity

Browse source
This commit is contained in:
Wim Taymans 2024-04-18 17:46:22 +02:00
parent 2d87310b60
commit a97a9b737c
2 changed files with 20 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

26
src/pipewire/data-loop.c
View file

@ -108,10 +108,14 @@ static struct pw_data_loop *loop_new(struct pw_loop *loop, const struct spa_dict
} }
this->loop = loop; this->loop = loop;
if (props != NULL && if (props != NULL) {
(str = spa_dict_lookup(props, "loop.cancel")) != NULL) if ((str = spa_dict_lookup(props, "loop.cancel")) != NULL)
this->cancel = pw_properties_parse_bool(str); this->cancel = pw_properties_parse_bool(str);
if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_NAME)) != NULL)
this->name = strdup(str);
if ((str = spa_dict_lookup(props, SPA_KEY_THREAD_AFFINITY)) != NULL)
this->affinity = strdup(str);
}
spa_hook_list_init(&this->listener_list); spa_hook_list_init(&this->listener_list);
return this; return this;
@ -151,6 +155,8 @@ void pw_data_loop_destroy(struct pw_data_loop *loop)
spa_hook_list_clean(&loop->listener_list); spa_hook_list_clean(&loop->listener_list);
free(loop->name);
free(loop->affinity);
free(loop); free(loop);
} }
@ -183,17 +189,21 @@ int pw_data_loop_start(struct pw_data_loop *loop)
if (!loop->running) { if (!loop->running) {
struct spa_thread_utils *utils; struct spa_thread_utils *utils;
struct spa_thread *thr; struct spa_thread *thr;
struct spa_dict_item items[2];
uint32_t n_items = 0;
loop->running = true; loop->running = true;
if ((utils = loop->thread_utils) == NULL) if ((utils = loop->thread_utils) == NULL)
utils = pw_thread_utils_get(); utils = pw_thread_utils_get();
static const struct spa_dict_item items[] = { items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_THREAD_NAME,
{ SPA_KEY_THREAD_NAME, "pw-data-loop" }, loop->name ? loop->name : "pw-data-loop");
}; if (loop->affinity)
items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_THREAD_AFFINITY,
loop->affinity);
thr = spa_thread_utils_create(utils, &SPA_DICT_INIT_ARRAY(items), do_loop, loop); thr = spa_thread_utils_create(utils, &SPA_DICT_INIT(items, n_items), do_loop, loop);
loop->thread = (pthread_t)thr; loop->thread = (pthread_t)thr;
if (thr == NULL) { if (thr == NULL) {
pw_log_error("%p: can't create thread: %m", loop); pw_log_error("%p: can't create thread: %m", loop);

2
src/pipewire/private.h
View file

@ -442,6 +442,8 @@ struct pw_context {
struct pw_data_loop { struct pw_data_loop {
struct pw_loop *loop; struct pw_loop *loop;
char *name;
char *affinity;
struct spa_hook_list listener_list; struct spa_hook_list listener_list;
struct spa_thread_utils *thread_utils; struct spa_thread_utils *thread_utils;