mirror of
https://gitlab.freedesktop.org/pipewire/wireplumber.git
synced 2026-05-05 13:38:02 +02:00
metadata: improve implementation
* Implement the proxy properly with info caching, methods, etc * Get rid of useless variables and includes
This commit is contained in:
George Kiagiadakis
parent
e68f8d4ae2
commit
3f160b552c
2 changed files with 397 additions and 179 deletions
|
|
@ -10,169 +10,63 @@
|
|||
* SECTION: WpMetadata
|
||||
*
|
||||
* The #WpMetadata class allows accessing the properties and methods of
|
||||
* Pipewire Jack metadata object (`struct pw_metadata`).
|
||||
* Pipewire metadata object (`struct pw_metadata`).
|
||||
*
|
||||
*/
|
||||
|
||||
#define G_LOG_DOMAIN "wp-metadata"
|
||||
|
||||
#include "metadata.h"
|
||||
#include "spa-type.h"
|
||||
#include "spa-pod.h"
|
||||
#include "debug.h"
|
||||
#include "private.h"
|
||||
#include "error.h"
|
||||
#include "wpenums.h"
|
||||
|
||||
#include <pipewire/pipewire.h>
|
||||
#include <pipewire/array.h>
|
||||
#include <pipewire/extensions/metadata.h>
|
||||
|
||||
#include <spa/pod/builder.h>
|
||||
#include <spa/pod/parser.h>
|
||||
#include <spa/pod/filter.h>
|
||||
|
||||
/* WpMetadata */
|
||||
|
||||
typedef struct _WpMetadataPrivate WpMetadataPrivate;
|
||||
struct _WpMetadataPrivate
|
||||
{
|
||||
struct pw_metadata *iface;
|
||||
struct spa_hook listener;
|
||||
|
||||
struct spa_hook_list hooks;
|
||||
struct pw_properties *properties;
|
||||
struct pw_array metadata;
|
||||
struct pw_proxy *proxy;
|
||||
enum {
|
||||
SIGNAL_CHANGED,
|
||||
N_SIGNALS,
|
||||
};
|
||||
|
||||
G_DEFINE_TYPE_WITH_PRIVATE (WpMetadata, wp_metadata, WP_TYPE_PROXY)
|
||||
static guint32 signals[N_SIGNALS] = {0};
|
||||
|
||||
static void
|
||||
wp_metadata_init (WpMetadata * self)
|
||||
/* data structure */
|
||||
|
||||
struct item
|
||||
{
|
||||
}
|
||||
|
||||
static void
|
||||
wp_metadata_finalize (GObject * object)
|
||||
{
|
||||
G_OBJECT_CLASS (wp_metadata_parent_class)->finalize (object);
|
||||
}
|
||||
|
||||
static void
|
||||
wp_metadata_pw_proxy_created (WpProxy * proxy, struct pw_proxy * pw_proxy)
|
||||
{
|
||||
WpMetadata *self = WP_METADATA (proxy);
|
||||
WpMetadataPrivate *priv = wp_metadata_get_instance_private (self);
|
||||
priv->iface = (struct pw_metadata *) pw_proxy;
|
||||
}
|
||||
|
||||
static void
|
||||
wp_metadata_class_init (WpMetadataClass * klass)
|
||||
{
|
||||
GObjectClass *object_class = (GObjectClass *) klass;
|
||||
WpProxyClass *proxy_class = (WpProxyClass *) klass;
|
||||
|
||||
object_class->finalize = wp_metadata_finalize;
|
||||
|
||||
proxy_class->pw_iface_type = PW_TYPE_INTERFACE_Metadata;
|
||||
proxy_class->pw_iface_version = PW_VERSION_METADATA;
|
||||
|
||||
proxy_class->pw_proxy_created = wp_metadata_pw_proxy_created;
|
||||
}
|
||||
|
||||
/* WpImplMetadata */
|
||||
|
||||
typedef struct _WpImplMetadata WpImplMetadata;
|
||||
struct _WpImplMetadata
|
||||
{
|
||||
WpMetadata parent;
|
||||
|
||||
struct spa_interface iface;
|
||||
struct spa_hook_list hooks;
|
||||
gboolean subscribed;
|
||||
};
|
||||
|
||||
G_DEFINE_TYPE (WpImplMetadata, wp_impl_metadata, WP_TYPE_METADATA)
|
||||
|
||||
#define pw_metadata_emit(hooks,method,version,...) \
|
||||
spa_hook_list_call_simple(hooks, struct pw_metadata_events, \
|
||||
method, version, ##__VA_ARGS__)
|
||||
|
||||
#define pw_metadata_emit_property(hooks,...) \
|
||||
pw_metadata_emit(hooks,property, 0, ##__VA_ARGS__)
|
||||
|
||||
struct item {
|
||||
uint32_t subject;
|
||||
char *key;
|
||||
char *type;
|
||||
char *value;
|
||||
gchar *key;
|
||||
gchar *type;
|
||||
gchar *value;
|
||||
};
|
||||
|
||||
static void
|
||||
clear_item (struct item *item)
|
||||
set_item (struct item * item, uint32_t subject, const char * key,
|
||||
const char * type, const char * value)
|
||||
{
|
||||
free (item->key);
|
||||
free (item->type);
|
||||
free (item->value);
|
||||
item->subject = subject;
|
||||
item->key = g_strdup (key);
|
||||
item->type = g_strdup (type);
|
||||
item->value = g_strdup (value);
|
||||
}
|
||||
|
||||
static void
|
||||
clear_item (struct item * item)
|
||||
{
|
||||
g_free (item->key);
|
||||
g_free (item->type);
|
||||
g_free (item->value);
|
||||
spa_zero (*item);
|
||||
}
|
||||
|
||||
static void
|
||||
set_item(struct item *item, uint32_t subject, const char *key,
|
||||
const char *type, const char *value)
|
||||
{
|
||||
item->subject = subject;
|
||||
item->key = strdup(key);
|
||||
item->type = strdup(type);
|
||||
item->value = strdup(value);
|
||||
}
|
||||
|
||||
static void
|
||||
emit_properties(WpImplMetadata *self,
|
||||
const struct spa_dict *dict)
|
||||
{
|
||||
struct item *item;
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
|
||||
pw_array_for_each(item, &priv->metadata) {
|
||||
wp_info_object (self, "metadata : %d %s %s %s",
|
||||
item->subject, item->key, item->type, item->value);
|
||||
pw_metadata_emit_property (&priv->hooks,
|
||||
item->subject,
|
||||
item->key,
|
||||
item->type,
|
||||
item->value);
|
||||
}
|
||||
}
|
||||
|
||||
static int
|
||||
impl_add_listener(void *object,
|
||||
struct spa_hook *listener,
|
||||
const struct pw_metadata_events *events,
|
||||
void *data)
|
||||
{
|
||||
WpImplMetadata *self = WP_IMPL_METADATA (object);
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
struct spa_hook_list save;
|
||||
|
||||
spa_hook_list_isolate (&priv->hooks, &save, listener, events, data);
|
||||
emit_properties(self, &priv->properties->dict);
|
||||
spa_hook_list_join (&priv->hooks, &save);
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static struct item *
|
||||
find_item (WpImplMetadata *self, uint32_t subject, const char *key)
|
||||
find_item (struct pw_array * metadata, uint32_t subject, const char * key)
|
||||
{
|
||||
struct item *item;
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
|
||||
pw_array_for_each(item, &priv->metadata) {
|
||||
pw_array_for_each (item, metadata) {
|
||||
if (item->subject == subject && (key == NULL || !strcmp (item->key, key))) {
|
||||
return item;
|
||||
}
|
||||
|
|
@ -181,59 +75,85 @@ find_item (WpImplMetadata *self, uint32_t subject, const char *key)
|
|||
}
|
||||
|
||||
static int
|
||||
clear_subjects (WpImplMetadata *self, uint32_t subject)
|
||||
clear_subject (struct pw_array * metadata, uint32_t subject)
|
||||
{
|
||||
struct item *item;
|
||||
uint32_t removed = 0;
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
|
||||
while (true) {
|
||||
item = find_item(self, subject, NULL);
|
||||
item = find_item (metadata, subject, NULL);
|
||||
if (item == NULL)
|
||||
break;
|
||||
|
||||
wp_debug_object (self, "remove id:%d key:%s", subject, item->key);
|
||||
|
||||
clear_item (item);
|
||||
pw_array_remove (&priv->metadata, item);
|
||||
pw_array_remove (metadata, item);
|
||||
removed++;
|
||||
}
|
||||
|
||||
if (removed > 0)
|
||||
pw_metadata_emit_property (&priv->hooks, subject, NULL, NULL, NULL);
|
||||
|
||||
return 0;
|
||||
return removed;
|
||||
}
|
||||
|
||||
static void
|
||||
clear_items (WpImplMetadata *self)
|
||||
clear_items (struct pw_array * metadata)
|
||||
{
|
||||
struct item *item;
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
|
||||
pw_array_consume (item, &priv->metadata) {
|
||||
clear_subjects (self, item->subject);
|
||||
pw_array_consume (item, metadata) {
|
||||
clear_item (item);
|
||||
pw_array_remove (metadata, item);
|
||||
}
|
||||
pw_array_reset (&priv->metadata);
|
||||
pw_array_reset (metadata);
|
||||
}
|
||||
|
||||
/* WpMetadata */
|
||||
|
||||
typedef struct _WpMetadataPrivate WpMetadataPrivate;
|
||||
struct _WpMetadataPrivate
|
||||
{
|
||||
struct pw_metadata *iface;
|
||||
struct spa_hook listener;
|
||||
struct pw_array metadata;
|
||||
};
|
||||
|
||||
G_DEFINE_TYPE_WITH_PRIVATE (WpMetadata, wp_metadata, WP_TYPE_PROXY)
|
||||
|
||||
static void
|
||||
wp_metadata_init (WpMetadata * self)
|
||||
{
|
||||
WpMetadataPrivate *priv = wp_metadata_get_instance_private (self);
|
||||
pw_array_init (&priv->metadata, 4096);
|
||||
}
|
||||
|
||||
static void
|
||||
wp_metadata_finalize (GObject * object)
|
||||
{
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (object));
|
||||
|
||||
clear_items (&priv->metadata);
|
||||
pw_array_clear (&priv->metadata);
|
||||
|
||||
G_OBJECT_CLASS (wp_metadata_parent_class)->finalize (object);
|
||||
}
|
||||
|
||||
static int
|
||||
impl_set_property (void *object, uint32_t subject, const char *key,
|
||||
const char *type, const char *value)
|
||||
metadata_event_property (void *object, uint32_t subject, const char *key,
|
||||
const char *type, const char *value)
|
||||
{
|
||||
WpImplMetadata *self = WP_IMPL_METADATA (object);
|
||||
WpMetadataPrivate *priv;
|
||||
WpMetadata *self = WP_METADATA (object);
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
struct item *item = NULL;
|
||||
|
||||
g_return_val_if_fail (WP_IS_IMPL_METADATA (self), -1);
|
||||
priv = wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
if (key == NULL) {
|
||||
if (clear_subject (&priv->metadata, subject) > 0) {
|
||||
wp_debug_object (self, "remove id:%d", subject);
|
||||
g_signal_emit (self, signals[SIGNAL_CHANGED], 0, subject, NULL, NULL,
|
||||
NULL);
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
if (key == NULL)
|
||||
return clear_subjects (self, subject);
|
||||
|
||||
item = find_item (self, subject, key);
|
||||
item = find_item (&priv->metadata, subject, key);
|
||||
if (item == NULL) {
|
||||
if (value == NULL)
|
||||
return 0;
|
||||
|
|
@ -256,20 +176,307 @@ impl_set_property (void *object, uint32_t subject, const char *key,
|
|||
wp_debug_object (self, "remove id:%d key:%s", subject, key);
|
||||
}
|
||||
|
||||
pw_metadata_emit_property (&priv->hooks, subject, key, type, value);
|
||||
|
||||
g_signal_emit (self, signals[SIGNAL_CHANGED], 0, subject, key, type, value);
|
||||
return 0;
|
||||
}
|
||||
|
||||
static const struct pw_metadata_events metadata_events = {
|
||||
PW_VERSION_METADATA_EVENTS,
|
||||
.property = metadata_event_property,
|
||||
};
|
||||
|
||||
static void
|
||||
initial_sync_done (WpCore * core, GAsyncResult * res, WpMetadata * self)
|
||||
{
|
||||
g_autoptr (GError) error = NULL;
|
||||
if (!wp_core_sync_finish (core, res, &error)) {
|
||||
wp_warning_object (self, "core sync error: %s", error->message);
|
||||
return;
|
||||
}
|
||||
|
||||
wp_proxy_set_feature_ready (WP_PROXY (self), WP_PROXY_FEATURE_INFO);
|
||||
}
|
||||
|
||||
static void
|
||||
wp_metadata_pw_proxy_created (WpProxy * proxy, struct pw_proxy * pw_proxy)
|
||||
{
|
||||
WpMetadata *self = WP_METADATA (proxy);
|
||||
WpMetadataPrivate *priv = wp_metadata_get_instance_private (self);
|
||||
g_autoptr (WpCore) core = wp_proxy_get_core (proxy);
|
||||
|
||||
priv->iface = (struct pw_metadata *) pw_proxy;
|
||||
pw_metadata_add_listener (priv->iface, &priv->listener,
|
||||
&metadata_events, self);
|
||||
wp_core_sync (core, NULL, (GAsyncReadyCallback) initial_sync_done, self);
|
||||
}
|
||||
|
||||
static void
|
||||
wp_metadata_class_init (WpMetadataClass * klass)
|
||||
{
|
||||
GObjectClass *object_class = (GObjectClass *) klass;
|
||||
WpProxyClass *proxy_class = (WpProxyClass *) klass;
|
||||
|
||||
object_class->finalize = wp_metadata_finalize;
|
||||
|
||||
proxy_class->pw_iface_type = PW_TYPE_INTERFACE_Metadata;
|
||||
proxy_class->pw_iface_version = PW_VERSION_METADATA;
|
||||
|
||||
proxy_class->pw_proxy_created = wp_metadata_pw_proxy_created;
|
||||
|
||||
signals[SIGNAL_CHANGED] = g_signal_new ("changed", G_TYPE_FROM_CLASS (klass),
|
||||
G_SIGNAL_RUN_LAST, 0, NULL, NULL, NULL, G_TYPE_NONE, 4,
|
||||
G_TYPE_UINT, G_TYPE_STRING, G_TYPE_STRING, G_TYPE_STRING);
|
||||
}
|
||||
|
||||
struct metadata_iterator_data
|
||||
{
|
||||
WpMetadata *metadata;
|
||||
const struct item *item;
|
||||
guint32 subject;
|
||||
gchar *key;
|
||||
gchar *type;
|
||||
};
|
||||
|
||||
static void
|
||||
metadata_iterator_reset (WpIterator *it)
|
||||
{
|
||||
struct metadata_iterator_data *it_data = wp_iterator_get_user_data (it);
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (it_data->metadata);
|
||||
|
||||
it_data->item = pw_array_first (&priv->metadata);
|
||||
}
|
||||
|
||||
static gboolean
|
||||
metadata_iterator_next (WpIterator *it, GValue *item)
|
||||
{
|
||||
struct metadata_iterator_data *it_data = wp_iterator_get_user_data (it);
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (it_data->metadata);
|
||||
|
||||
while (pw_array_check (&priv->metadata, it_data->item)) {
|
||||
if ((it_data->subject == PW_ID_ANY ||
|
||||
it_data->subject == it_data->item->subject) &&
|
||||
(!it_data->key || !g_strcmp0 (it_data->key, it_data->item->key)) &&
|
||||
(!it_data->type || !g_strcmp0 (it_data->type, it_data->item->type))) {
|
||||
g_value_init (item, G_TYPE_POINTER);
|
||||
g_value_set_pointer (item, (gpointer) it_data->item);
|
||||
it_data->item++;
|
||||
return TRUE;
|
||||
}
|
||||
it_data->item++;
|
||||
}
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
metadata_iterator_fold (WpIterator *it, WpIteratorFoldFunc func, GValue *ret,
|
||||
gpointer data)
|
||||
{
|
||||
struct metadata_iterator_data *it_data = wp_iterator_get_user_data (it);
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (it_data->metadata);
|
||||
const struct item *i;
|
||||
|
||||
pw_array_for_each (i, &priv->metadata) {
|
||||
if ((it_data->subject == PW_ID_ANY ||
|
||||
it_data->subject == it_data->item->subject) &&
|
||||
(!it_data->key || !g_strcmp0 (it_data->key, it_data->item->key)) &&
|
||||
(!it_data->type || !g_strcmp0 (it_data->type, it_data->item->type))) {
|
||||
g_auto (GValue) item = G_VALUE_INIT;
|
||||
g_value_init (&item, G_TYPE_POINTER);
|
||||
g_value_set_pointer (&item, (gpointer) i);
|
||||
if (!func (&item, ret, data))
|
||||
return FALSE;
|
||||
}
|
||||
}
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static void
|
||||
metadata_iterator_finalize (WpIterator *it)
|
||||
{
|
||||
struct metadata_iterator_data *it_data = wp_iterator_get_user_data (it);
|
||||
g_object_unref (it_data->metadata);
|
||||
g_free (it_data->key);
|
||||
g_free (it_data->type);
|
||||
}
|
||||
|
||||
static const WpIteratorMethods metadata_iterator_methods = {
|
||||
.reset = metadata_iterator_reset,
|
||||
.next = metadata_iterator_next,
|
||||
.fold = metadata_iterator_fold,
|
||||
.finalize = metadata_iterator_finalize,
|
||||
};
|
||||
|
||||
/**
|
||||
* wp_metadata_find:
|
||||
* @self: a metadata object
|
||||
* @subject: the metadata subject id, or %PW_ID_ANY
|
||||
* @key: (nullable): the metadata key to find, or %NULL
|
||||
* @type: (nullable): the metadata type to find, or %NULL
|
||||
*
|
||||
* Find metadata that matches the given @subject, @key and @type. If no
|
||||
* constraints are specified, the returned iterator iterates over all the
|
||||
* stored metadata.
|
||||
*
|
||||
* Note that this method works on cached metadata. When you change metadata
|
||||
* with wp_metadata_set(), this cache will be updated on the next round-trip
|
||||
* with the pipewire server.
|
||||
*
|
||||
* Returns: (transfer full): an iterator that iterates over the found metadata.
|
||||
* Use wp_metadata_iterator_item_extract() to parse the items returned by
|
||||
* this iterator.
|
||||
*/
|
||||
WpIterator *
|
||||
wp_metadata_find (WpMetadata * self, guint32 subject,
|
||||
const gchar * key, const gchar * type)
|
||||
{
|
||||
WpMetadataPrivate *priv;
|
||||
g_autoptr (WpIterator) it = NULL;
|
||||
struct metadata_iterator_data *it_data;
|
||||
|
||||
g_return_val_if_fail (self != NULL, NULL);
|
||||
priv = wp_metadata_get_instance_private (self);
|
||||
|
||||
it = wp_iterator_new (&metadata_iterator_methods,
|
||||
sizeof (struct metadata_iterator_data));
|
||||
it_data = wp_iterator_get_user_data (it);
|
||||
it_data->metadata = g_object_ref (self);
|
||||
it_data->item = pw_array_first (&priv->metadata);
|
||||
it_data->subject = subject;
|
||||
it_data->key = g_strdup (key);
|
||||
it_data->type = g_strdup (type);
|
||||
return g_steal_pointer (&it);
|
||||
}
|
||||
|
||||
/**
|
||||
* wp_metadata_iterator_item_extract:
|
||||
* @item: a #GValue that was returned from the #WpIterator of wp_metadata_find()
|
||||
* @subject: (out)(optional): the subject id of the current item
|
||||
* @key: (out)(optional)(transfer none): the key of the current item
|
||||
* @type: (out)(optional)(transfer none): the type of the current item
|
||||
* @value: (out)(optional)(transfer none): the value of the current item
|
||||
*
|
||||
* Extracts the metadata subject, key, type and value out of a #GValue that was
|
||||
* returned from the #WpIterator of wp_metadata_find()
|
||||
*/
|
||||
void
|
||||
wp_metadata_iterator_item_extract (const GValue * item, guint32 * subject,
|
||||
const gchar ** key, const gchar ** type, const gchar ** value)
|
||||
{
|
||||
const struct item *i = g_value_get_pointer (item);
|
||||
g_return_if_fail (i != NULL);
|
||||
if (subject)
|
||||
*subject = i->subject;
|
||||
if (key)
|
||||
*key = i->key;
|
||||
if (type)
|
||||
*type = i->type;
|
||||
if (value)
|
||||
*value = i->value;
|
||||
}
|
||||
|
||||
/**
|
||||
* wp_metadata_set:
|
||||
* @self: the metadata object
|
||||
* @subject: the subject id for which this metadata property is being set
|
||||
* @key: (nullable): the key to set, or %NULL to remove all metadata for
|
||||
* @subject
|
||||
* @type: (nullable): the type of the value; %NULL is synonymous to "string"
|
||||
* @value: (nullable): the value to set, or %NULL to unset the given @key
|
||||
*
|
||||
* Sets the metadata associated with the given @subject and @key. Use %NULL as
|
||||
* a value to unset the given @key and use %NULL in both @key and @value to
|
||||
* remove all metadata associated with the given @subject.
|
||||
*/
|
||||
void
|
||||
wp_metadata_set (WpMetadata * self, guint32 subject,
|
||||
const gchar * key, const gchar * type, const gchar * value)
|
||||
{
|
||||
WpMetadataPrivate *priv = wp_metadata_get_instance_private (self);
|
||||
pw_metadata_set_property (priv->iface, subject, key, type, value);
|
||||
}
|
||||
|
||||
/**
|
||||
* wp_metadata_clear:
|
||||
* @self: the metadata object
|
||||
*
|
||||
* Clears permanently all stored metadata.
|
||||
*/
|
||||
void
|
||||
wp_metadata_clear (WpMetadata * self)
|
||||
{
|
||||
WpMetadataPrivate *priv = wp_metadata_get_instance_private (self);
|
||||
pw_metadata_clear (priv->iface);
|
||||
}
|
||||
|
||||
/* WpImplMetadata */
|
||||
|
||||
struct _WpImplMetadata
|
||||
{
|
||||
WpMetadata parent;
|
||||
|
||||
struct spa_interface iface;
|
||||
struct spa_hook_list hooks;
|
||||
};
|
||||
|
||||
G_DEFINE_TYPE (WpImplMetadata, wp_impl_metadata, WP_TYPE_METADATA)
|
||||
|
||||
#define pw_metadata_emit(hooks,method,version,...) \
|
||||
spa_hook_list_call_simple(hooks, struct pw_metadata_events, \
|
||||
method, version, ##__VA_ARGS__)
|
||||
|
||||
#define pw_metadata_emit_property(hooks,...) \
|
||||
pw_metadata_emit(hooks,property, 0, ##__VA_ARGS__)
|
||||
|
||||
static void
|
||||
emit_properties (WpImplMetadata *self)
|
||||
{
|
||||
struct item *item;
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
|
||||
pw_array_for_each(item, &priv->metadata) {
|
||||
wp_debug_object (self, "emit property: %d %s %s %s",
|
||||
item->subject, item->key, item->type, item->value);
|
||||
pw_metadata_emit_property (&self->hooks,
|
||||
item->subject,
|
||||
item->key,
|
||||
item->type,
|
||||
item->value);
|
||||
}
|
||||
}
|
||||
|
||||
static int
|
||||
impl_add_listener (void * object, struct spa_hook * listener,
|
||||
const struct pw_metadata_events * events, void * data)
|
||||
{
|
||||
WpImplMetadata *self = WP_IMPL_METADATA (object);
|
||||
struct spa_hook_list save;
|
||||
|
||||
spa_hook_list_isolate (&self->hooks, &save, listener, events, data);
|
||||
emit_properties (self);
|
||||
spa_hook_list_join (&self->hooks, &save);
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int
|
||||
impl_set_property (void * object, uint32_t subject, const char * key,
|
||||
const char * type, const char * value)
|
||||
{
|
||||
return metadata_event_property (object, subject, key, type, value);
|
||||
}
|
||||
|
||||
static int
|
||||
impl_clear (void *object)
|
||||
{
|
||||
WpImplMetadata *self = WP_IMPL_METADATA (object);
|
||||
WpMetadataPrivate *priv =
|
||||
wp_metadata_get_instance_private (WP_METADATA (self));
|
||||
clear_items (self);
|
||||
pw_array_clear (&priv->metadata);
|
||||
pw_properties_free (priv->properties);
|
||||
|
||||
wp_debug_object (self, "clearing all metadata");
|
||||
clear_items (&priv->metadata);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
|
@ -290,18 +497,19 @@ wp_impl_metadata_init (WpImplMetadata * self)
|
|||
PW_TYPE_INTERFACE_Metadata,
|
||||
PW_VERSION_METADATA,
|
||||
&impl_metadata, self);
|
||||
spa_hook_list_init (&priv->hooks);
|
||||
spa_hook_list_init (&self->hooks);
|
||||
|
||||
priv->iface = (struct pw_metadata *) &self->iface;
|
||||
|
||||
priv->properties = pw_properties_new (NULL, NULL);
|
||||
pw_array_init (&priv->metadata, 4096);
|
||||
wp_proxy_set_feature_ready (WP_PROXY (self), WP_PROXY_FEATURE_INFO);
|
||||
}
|
||||
|
||||
static void
|
||||
wp_impl_metadata_finalize (GObject * object)
|
||||
wp_impl_metadata_on_changed (WpImplMetadata * self, guint32 subject,
|
||||
const gchar * key, const gchar * type, const gchar * value, gpointer data)
|
||||
{
|
||||
G_OBJECT_CLASS (wp_impl_metadata_parent_class)->finalize (object);
|
||||
wp_debug_object (self, "emit property: %d %s %s %s",
|
||||
subject, key, type, value);
|
||||
pw_metadata_emit_property (&self->hooks, subject, key, type, value);
|
||||
}
|
||||
|
||||
static void
|
||||
|
|
@ -330,22 +538,18 @@ wp_impl_metadata_augment (WpProxy * proxy, WpProxyFeatures features)
|
|||
|
||||
wp_proxy_set_pw_proxy (proxy, pw_core_export (pw_core,
|
||||
PW_TYPE_INTERFACE_Metadata,
|
||||
&priv->properties->dict,
|
||||
priv->iface, 0));
|
||||
NULL, priv->iface, 0));
|
||||
g_signal_connect (self, "changed",
|
||||
(GCallback) wp_impl_metadata_on_changed, NULL);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
wp_impl_metadata_class_init (WpImplMetadataClass * klass)
|
||||
{
|
||||
GObjectClass *object_class = (GObjectClass *) klass;
|
||||
WpProxyClass *proxy_class = (WpProxyClass *) klass;
|
||||
|
||||
object_class->finalize = wp_impl_metadata_finalize;
|
||||
|
||||
proxy_class->augment = wp_impl_metadata_augment;
|
||||
proxy_class->enum_params = NULL;
|
||||
proxy_class->subscribe_params = NULL;
|
||||
proxy_class->pw_proxy_created = NULL;
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -31,6 +31,20 @@ struct _WpMetadataClass
|
|||
WpProxyClass parent_class;
|
||||
};
|
||||
|
||||
WP_API
|
||||
WpIterator * wp_metadata_find (WpMetadata * self, guint32 subject,
|
||||
const gchar * key, const gchar * type);
|
||||
|
||||
WP_API
|
||||
void wp_metadata_iterator_item_extract (const GValue * item, guint32 * subject,
|
||||
const gchar ** key, const gchar ** type, const gchar ** value);
|
||||
|
||||
WP_API
|
||||
void wp_metadata_set (WpMetadata * self, guint32 subject,
|
||||
const gchar * key, const gchar * type, const gchar * value);
|
||||
|
||||
WP_API
|
||||
void wp_metadata_clear (WpMetadata * self);
|
||||
|
||||
/**
|
||||
* WP_TYPE_IMPL_MEATADATA:
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue