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: make it possible to set a custom create function

Browse source 
Make a property to pass a custom function pointer to create threads
instead of pthread_create.

Use this in jack instead of bypassing the thread utils create function,
which gives the wrong thread rt priority with rtkit.

Fixes #4099
This commit is contained in:
Wim Taymans 2024-07-09 17:04:35 +02:00
parent f357798715
commit 16f629d224
3 changed files with 23 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

34
pipewire-jack/src/pipewire-jack.c
View file

@ -3182,31 +3182,27 @@ static struct spa_thread *impl_create(void *object,
void *(*start)(void*), void *arg)
{
struct client *c = (struct client *) object;
struct spa_thread *thr;
int res = 0;
struct spa_dict_item *items;
struct spa_dict copy;
char creator_ptr[64];
pw_log_info("create thread");
if (globals.creator != NULL) {
pthread_t pt;
pthread_attr_t *attr = NULL, attributes;
uint32_t i, n_items = props ? props->n_items : 0;
attr = pw_thread_fill_attr(props, &attributes);
items = alloca((n_items) + 1 * sizeof(*items));
res = -globals.creator(&pt, attr, start, arg);
if (attr)
pthread_attr_destroy(attr);
if (res != 0)
goto error;
thr = (struct spa_thread*)pt;
} else {
thr = spa_thread_utils_create(c->context.old_thread_utils, props, start, arg);
for (i = 0; i < n_items; i++)
items[i] = props->items[i];
snprintf(creator_ptr, sizeof(creator_ptr), "pointer:%p", globals.creator);
items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_THREAD_CREATOR,
creator_ptr);
copy = SPA_DICT_INIT(items, n_items);
props = &copy;
}
return thr;
error:
pw_log_warn("create RT thread failed: %s", strerror(res));
errno = -res;
return NULL;
return spa_thread_utils_create(c->context.old_thread_utils, props, start, arg);
}
static int impl_join(void *object,