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

exported: delay export until the core is connected

Browse source 
This is useful to be able to call export() from a module init
function, which is called before the core is connected
This commit is contained in:
George Kiagiadakis 2019-12-11 23:43:53 +02:00
parent 787bd8d576
commit bb7b8daa17
1 changed files with 39 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
lib/wp/exported.c
View file

@ -23,6 +23,7 @@
*/
#include "exported.h"
#include "error.h"
#include "private.h"
typedef struct _WpExportedPrivate WpExportedPrivate;
@ -135,11 +136,34 @@ wp_exported_get_core (WpExported * self)
return g_weak_ref_get (&priv->core);
}
static void
on_remote_state_changed (WpCore * core, WpRemoteState state, WpExported * self)
{
WpExportedPrivate *priv = wp_exported_get_instance_private (self);
if (g_task_return_error_if_cancelled (priv->task)) {
g_clear_object (&priv->task);
g_signal_handlers_disconnect_by_func (core, on_remote_state_changed, self);
}
else if (state == WP_REMOTE_STATE_CONNECTED) {
WP_EXPORTED_GET_CLASS (self)->export (self);
g_signal_handlers_disconnect_by_func (core, on_remote_state_changed, self);
}
else if (state == WP_REMOTE_STATE_ERROR) {
g_task_return_new_error (priv->task, WP_DOMAIN_LIBRARY,
WP_LIBRARY_ERROR_OPERATION_FAILED,
"WirePlumber core connection error");
g_clear_object (&priv->task);
g_signal_handlers_disconnect_by_func (core, on_remote_state_changed, self);
}
}
void
wp_exported_export (WpExported * self, GCancellable * cancellable,
GAsyncReadyCallback callback, gpointer user_data)
{
WpExportedPrivate *priv;
g_autoptr (WpCore) core = NULL;
g_return_if_fail (WP_IS_EXPORTED (self));
g_return_if_fail (WP_EXPORTED_GET_CLASS (self)->export);
@ -147,7 +171,21 @@ wp_exported_export (WpExported * self, GCancellable * cancellable,
priv = wp_exported_get_instance_private (self);
priv->task = g_task_new (self, cancellable, callback, user_data);
WP_EXPORTED_GET_CLASS (self)->export (self);
core = g_weak_ref_get (&priv->core);
if (!core || wp_core_get_remote_state (core, NULL) == WP_REMOTE_STATE_ERROR) {
g_task_return_new_error (priv->task, WP_DOMAIN_LIBRARY,
WP_LIBRARY_ERROR_OPERATION_FAILED,
"WirePlumber core not available or in error");
g_clear_object (&priv->task);
return;
}
if (wp_core_get_remote_state (core, NULL) == WP_REMOTE_STATE_CONNECTED) {
WP_EXPORTED_GET_CLASS (self)->export (self);
} else {
g_signal_connect_object (core, "remote-state-changed",
(GCallback) on_remote_state_changed, self, 0);
}
}
gboolean