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

jack: improve acquire/drop_rt methods

Browse source 
Instead of calling the default implementation that does not implement
these methods, keep the last thread-utils around in a global and use
that instead.
This commit is contained in:
Wim Taymans 2022-10-13 12:09:36 +02:00
parent 38e3c2be6c
commit f0753ffdf9
1 changed files with 13 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -98,6 +98,7 @@ struct globals {
pthread_mutex_t lock;
struct pw_array descriptions;
struct spa_list free_objects;
struct spa_thread_utils *thread_utils;
};
static struct globals globals;
@ -3310,6 +3311,8 @@ jack_client_t * jack_client_open (const char *client_name,
if (client->context.old_thread_utils == NULL)
client->context.old_thread_utils = pw_thread_utils_get();
globals.thread_utils = client->context.old_thread_utils;
client->context.thread_utils.iface = SPA_INTERFACE_INIT(
SPA_TYPE_INTERFACE_ThreadUtils,
SPA_VERSION_THREAD_UTILS,
@ -6118,15 +6121,21 @@ int jack_client_max_real_time_priority (jack_client_t *client)
SPA_EXPORT
int jack_acquire_real_time_scheduling (jack_native_thread_t thread, int priority)
{
pw_log_info("acquire");
return pw_thread_utils_acquire_rt((struct spa_thread*)thread, priority);
struct spa_thread *t = (struct spa_thread*)thread;
pw_log_info("acquire %p", t);
spa_return_val_if_fail(globals.thread_utils != NULL, -1);
spa_return_val_if_fail(t != NULL, -1);
return spa_thread_utils_acquire_rt(globals.thread_utils, t, priority);
}
SPA_EXPORT
int jack_drop_real_time_scheduling (jack_native_thread_t thread)
{
pw_log_info("drop");
return pw_thread_utils_drop_rt((struct spa_thread*)thread);
struct spa_thread *t = (struct spa_thread*)thread;
pw_log_info("drop %p", t);
spa_return_val_if_fail(globals.thread_utils != NULL, -1);
spa_return_val_if_fail(t != NULL, -1);
return spa_thread_utils_drop_rt(globals.thread_utils, t);
}
/**