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

m-reserve-device: use a weak ref instead of raw pointer for transition

Browse source 
This always guarantees the transition is valid when g_weak_ref_get() does not
return NULL.
This commit is contained in:
Julian Bouzas 2021-06-25 10:06:34 -04:00
parent f7483ebd3d
commit 014ef05308
2 changed files with 18 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
modules/module-reserve-device/reserve-device.c
View file

@ -44,6 +44,7 @@ static void
wp_reserve_device_init (WpReserveDevice * self)
{
g_weak_ref_init (&self->plugin, NULL);
g_weak_ref_init (&self->transition, NULL);
}
static void
@ -92,8 +93,9 @@ on_name_appeared (GDBusConnection *connection, const gchar *name,
const gchar *owner, gpointer user_data)
{
WpReserveDevice *self = WP_RESERVE_DEVICE (user_data);
g_autoptr (WpTransition) t = g_weak_ref_get (&self->transition);
if (!self->transition) {
if (!t || wp_transition_get_completed (t)) {
self->state = WP_RESERVE_DEVICE_STATE_BUSY;
wp_info_object (self, "%s busy (by %s)", name, owner);
g_object_notify (G_OBJECT (self), "state");
@ -106,8 +108,9 @@ on_name_vanished (GDBusConnection *connection, const gchar *name,
gpointer user_data)
{
WpReserveDevice *self = WP_RESERVE_DEVICE (user_data);
g_autoptr (WpTransition) t = g_weak_ref_get (&self->transition);
if (!self->transition) {
if (!t || wp_transition_get_completed (t)) {
self->state = WP_RESERVE_DEVICE_STATE_AVAILABLE;
wp_info_object (self, "%s released", name);
g_object_notify (G_OBJECT (self), "state");
@ -145,6 +148,7 @@ wp_reserve_device_finalize (GObject * object)
g_bus_unown_name (self->owner_id);
g_weak_ref_clear (&self->plugin);
g_weak_ref_clear (&self->transition);
g_clear_pointer (&self->name, g_free);
g_clear_pointer (&self->app_name, g_free);
g_clear_pointer (&self->app_dev_name, g_free);
@ -168,7 +172,6 @@ on_acquire_transition_done (GObject *rd, GAsyncResult *res, gpointer data)
self->state = acquired ?
WP_RESERVE_DEVICE_STATE_ACQUIRED : WP_RESERVE_DEVICE_STATE_BUSY;
self->transition = NULL;
g_object_notify (G_OBJECT (self), "state");
update_owner_app_name (self);
}
@ -176,17 +179,19 @@ on_acquire_transition_done (GObject *rd, GAsyncResult *res, gpointer data)
static void
wp_reserve_device_acquire (WpReserveDevice * self)
{
g_autoptr (WpTransition) t = g_weak_ref_get (&self->transition);
if (self->state == WP_RESERVE_DEVICE_STATE_ACQUIRED ||
self->transition != NULL) {
(t && !wp_transition_get_completed (t))) {
wp_debug_object (self, "%s: already acquired or operation in progress",
self->name);
return;
}
g_autoptr (WpReserveDevicePlugin) plugin = g_weak_ref_get (&self->plugin);
self->transition = wp_reserve_device_acquire_transition_new (self,
WpTransition *transition = wp_reserve_device_acquire_transition_new (self,
plugin->cancellable, on_acquire_transition_done, self);
wp_transition_advance (self->transition);
g_weak_ref_set (&self->transition, transition);
wp_transition_advance (transition);
}
static void
@ -453,12 +458,12 @@ on_name_acquired (GDBusConnection *connection, const gchar *name,
gpointer user_data)
{
WpReserveDevice *self = WP_RESERVE_DEVICE (user_data);
g_autoptr (WpTransition) t = g_weak_ref_get (&self->transition);
wp_debug_object (self, "%s acquired", name);
if (WP_IS_RESERVE_DEVICE_ACQUIRE_TRANSITION (self->transition)) {
wp_reserve_device_acquire_transition_name_acquired (self->transition);
}
if (t)
wp_reserve_device_acquire_transition_name_acquired (t);
}
static void
@ -466,11 +471,12 @@ on_name_lost (GDBusConnection *connection, const gchar *name,
gpointer user_data)
{
WpReserveDevice *self = WP_RESERVE_DEVICE (user_data);
g_autoptr (WpTransition) t = g_weak_ref_get (&self->transition);
wp_debug_object (self, "%s lost", name);
if (WP_IS_RESERVE_DEVICE_ACQUIRE_TRANSITION (self->transition)) {
wp_reserve_device_acquire_transition_name_lost (self->transition);
if (t) {
wp_reserve_device_acquire_transition_name_lost (t);
return;
}

2
modules/module-reserve-device/reserve-device.h
View file

@ -37,7 +37,7 @@ struct _WpReserveDevice
gchar *service_name;
gchar *object_path;
WpTransition *transition;
GWeakRef transition;
GDBusMethodInvocation *req_rel_invocation;
WpReserveDeviceState state;
guint watcher_id;