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

core: retrieve and store core info

Browse source 
also delay the "connected" signal until info is there
This commit is contained in:
George Kiagiadakis 2020-06-15 17:49:21 +03:00
parent 0d1fcd48a1
commit 0596988945
1 changed files with 18 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
lib/wp/core.c
View file

@ -111,6 +111,7 @@ struct _WpCore
/* pipewire main objects */
struct pw_context *pw_context;
struct pw_core *pw_core;
struct pw_core_info *info;
/* pipewire main listeners */
struct spa_hook core_listener;
@ -143,6 +144,21 @@ static guint32 signals[NUM_SIGNALS];
*/
G_DEFINE_TYPE (WpCore, wp_core, G_TYPE_OBJECT)
static void
core_info (void *data, const struct pw_core_info * info)
{
WpCore *self = WP_CORE (data);
gboolean new_connection = (self->info == NULL);
self->info = pw_core_info_update (self->info, info);
wp_info_object (self, "connected to server: %s, cookie: %u",
self->info->name, self->info->cookie);
if (new_connection)
g_signal_emit (self, signals[SIGNAL_CONNECTED], 0);
}
static void
core_done (void *data, uint32_t id, int seq)
{
@ -179,6 +195,7 @@ core_error (void *data, uint32_t id, int seq, int res, const char *message)
static const struct pw_core_events core_events = {
PW_VERSION_CORE_EVENTS,
.info = core_info,
.done = core_done,
.error = core_error,
};
@ -199,6 +216,7 @@ proxy_core_destroy (void *data)
{
WpCore *self = WP_CORE (data);
g_hash_table_foreach_remove (self->async_tasks, async_tasks_finish, NULL);
g_clear_pointer (&self->info, pw_core_info_free);
self->pw_core = NULL;
wp_debug_object (self, "emit disconnected");
g_signal_emit (self, signals[SIGNAL_DISCONNECTED], 0);
@ -491,9 +509,6 @@ wp_core_connect (WpCore *self)
/* Add the registry listener */
wp_registry_attach (&self->registry, self->pw_core);
/* Emit the connected signal */
g_signal_emit (self, signals[SIGNAL_CONNECTED], 0);
return TRUE;
}