fdo-mirrors/wireplumber
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/wireplumber.git synced 2026-05-06 08:18:03 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

reserve-device: clean jack device activation logic

Browse source
This commit is contained in:
Julian Bouzas 2020-06-04 10:32:01 -04:00
parent be8629fbec
commit 371e6f90ac
3 changed files with 40 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
modules/module-device-activation.c
View file

@ -116,8 +116,8 @@ add_reserve_device_data (WpDeviceActivation * self, WpProxy *device,
app_dev_name = wp_properties_get (props, SPA_KEY_API_ALSA_PATH);
/* Create the dbus device reservation */
reservation = wp_dbus_device_reservation_new (card_id, "PipeWire", 10,
app_dev_name);
reservation = wp_dbus_device_reservation_new (card_id,
PIPEWIRE_APPLICATION_NAME, 10, app_dev_name);
/* Create the reserve device data */
device_data = wp_reserve_device_new (device, reservation);

4
modules/module-device-activation/dbus-device-reservation.h
View file

@ -13,6 +13,10 @@
G_BEGIN_DECLS
#define JACK_APPLICATION_NAME "Jack audio server"
#define PULSEAUDIO_APPLICATION_NAME "PulseAudio Sound Server"
#define PIPEWIRE_APPLICATION_NAME "PipeWire"
#define WP_TYPE_DBUS_DEVICE_RESERVATION (wp_dbus_device_reservation_get_type ())
G_DECLARE_FINAL_TYPE (WpDbusDeviceReservation, wp_dbus_device_reservation, WP,
DBUS_DEVICE_RESERVATION, GObject)

51
modules/module-device-activation/reserve-device.c
View file

@ -66,6 +66,36 @@ increment_jack_n_acquired (WpProxy *device)
return val;
}
static void
enable_jack_device (WpReserveDevice *self) {
g_autoptr (WpProxy) jack_device = NULL;
g_return_if_fail (self);
/* Get the JACK device and increment the jack acquisition. We only enable the
* JACK device if this is the first acquisition */
jack_device = wp_object_manager_lookup (self->jack_device_om, WP_TYPE_DEVICE,
NULL);
if (jack_device && increment_jack_n_acquired (jack_device) == 1) {
set_device_profile (jack_device, 1);
wp_info_object (self, "jack device enabled");
}
}
static void
disable_jack_device (WpReserveDevice *self) {
g_autoptr (WpProxy) jack_device = NULL;
g_return_if_fail (self);
/* Get the JACK device and decrement the jack acquisition. We only disable the
* JACK device if there is no more acquisitions */
jack_device = wp_object_manager_lookup (self->jack_device_om, WP_TYPE_DEVICE,
NULL);
if (jack_device && decrement_jack_n_acquired (jack_device) == 0) {
set_device_profile (jack_device, 0);
wp_info_object (self, "jack device disabled");
}
}
static void
on_device_done (WpCore *core, GAsyncResult *res, WpReserveDevice *self)
{
@ -81,7 +111,6 @@ on_application_name_done (GObject *obj, GAsyncResult *res, gpointer user_data)
WpReserveDevice *self = user_data;
g_autoptr (GError) e = NULL;
g_autofree gchar *name = NULL;
g_autoptr (WpProxy) jack_device = NULL;
/* Note that the ApplicationName property is optional as described in the
* specification (http://git.0pointer.net/reserve.git/tree/reserve.txt), so
@ -95,15 +124,8 @@ on_application_name_done (GObject *obj, GAsyncResult *res, gpointer user_data)
wp_info_object (self, "owner: %s", name ? name : "unknown");
/* Only enable the JACK device if the owner is the JACK audio server */
if (!name || g_strcmp0 (name, "Jack audio server") != 0)
return;
/* Get the JACK device and increment the jack acquisition. We only enable the
* JACK device if this is the first acquisition */
jack_device = wp_object_manager_lookup (self->jack_device_om, WP_TYPE_DEVICE,
NULL);
if (jack_device && increment_jack_n_acquired (jack_device) == 1)
set_device_profile (jack_device, 1);
if (name && g_strcmp0 (name, JACK_APPLICATION_NAME) == 0)
enable_jack_device (self);
}
static void
@ -111,7 +133,6 @@ on_reservation_acquired (GObject *obj, GAsyncResult *res, gpointer user_data)
{
WpReserveDevice *self = user_data;
g_autoptr (GError) e = NULL;
g_autoptr (WpProxy) jack_device = NULL;
g_autoptr (WpProxy) device = NULL;
/* If the audio device could not be acquired, check who owns it and maybe
@ -123,12 +144,8 @@ on_reservation_acquired (GObject *obj, GAsyncResult *res, gpointer user_data)
return;
}
/* Get the JACK device and decrement the jack acquisition. We only disable the
* JACK device if there is no acquisitions */
jack_device = wp_object_manager_lookup (self->jack_device_om, WP_TYPE_DEVICE,
NULL);
if (jack_device && decrement_jack_n_acquired (jack_device) == 0)
set_device_profile (jack_device, 0);
/* Always disable the JACK device because we are the owner */
disable_jack_device (self);
/* Enable Audio device */
device = g_weak_ref_get (&self->device);