mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-31 22:25:38 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

media-session: use core metadata implementation

Browse source 
Use the core metadata implementation and export that one.
This commit is contained in:
Wim Taymans 2021-06-16 10:53:11 +02:00
parent 80ef77f994
commit beb80a06e8
1 changed files with 10 additions and 214 deletions
Download patch file Download diff file Expand all files Collapse all files

224
src/examples/media-session/metadata.c
View file

@ -33,214 +33,15 @@
#define NAME "metadata" #define NAME "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;
};
static void clear_item(struct item *item)
{
free(item->key);
free(item->type);
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 = type ? strdup(type) : NULL;
item->value = strdup(value);
}
static int change_item(struct item *item, const char *type, const char *value)
{
int changed = 0;
if (!spa_streq(item->type, type)) {
free((char*)item->type);
item->type = type ? strdup(type) : NULL;
changed++;
}
if (!spa_streq(item->value, value)) {
free((char*)item->value);
item->value = value ? strdup(value) : NULL;
changed++;
}
return changed;
}
struct metadata { struct metadata {
struct spa_interface iface; struct pw_impl_metadata *impl;
struct pw_metadata *metadata;
struct spa_hook_list hooks;
struct pw_array metadata;
struct sm_media_session *session; struct sm_media_session *session;
struct spa_hook session_listener; struct spa_hook session_listener;
struct pw_proxy *proxy; struct pw_proxy *proxy;
unsigned int shutdown:1;
}; };
static void emit_properties(struct metadata *this)
{
struct item *item;
pw_array_for_each(item, &this->metadata) {
pw_log_debug("metadata %p: %d %s %s %s",
this, item->subject, item->key, item->type, item->value);
pw_metadata_emit_property(&this->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)
{
struct metadata *this = object;
struct spa_hook_list save;
spa_return_val_if_fail(this != NULL, -EINVAL);
spa_return_val_if_fail(events != NULL, -EINVAL);
pw_log_debug("metadata %p:", this);
spa_hook_list_isolate(&this->hooks, &save, listener, events, data);
emit_properties(this);
spa_hook_list_join(&this->hooks, &save);
return 0;
}
static struct item *find_item(struct metadata *this, uint32_t subject, const char *key)
{
struct item *item;
pw_array_for_each(item, &this->metadata) {
if (item->subject == subject && (key == NULL || spa_streq(item->key, key)))
return item;
}
return NULL;
}
static int clear_subjects(struct metadata *this, uint32_t subject)
{
struct item *item;
uint32_t removed = 0;
while (true) {
item = find_item(this, subject, NULL);
if (item == NULL)
break;
pw_log_debug(NAME" %p: remove id:%d key:%s", this, subject, item->key);
clear_item(item);
pw_array_remove(&this->metadata, item);
removed++;
}
if (removed > 0 && !this->shutdown)
pw_metadata_emit_property(&this->hooks, subject, NULL, NULL, NULL);
return 0;
}
static void clear_items(struct metadata *this)
{
struct item *item;
pw_array_consume(item, &this->metadata)
clear_subjects(this, item->subject);
pw_array_reset(&this->metadata);
}
static int impl_set_property(void *object,
uint32_t subject,
const char *key,
const char *type,
const char *value)
{
struct metadata *this = object;
struct item *item = NULL;
int changed = 0;
pw_log_debug(NAME" %p: id:%d key:%s type:%s value:%s", this, subject, key, type, value);
if (key == NULL)
return clear_subjects(this, subject);
item = find_item(this, subject, key);
if (value == NULL) {
if (item != NULL) {
clear_item(item);
pw_array_remove(&this->metadata, item);
type = NULL;
changed++;
pw_log_info(NAME" %p: remove id:%d key:%s", this,
subject, key);
}
} else if (item == NULL) {
item = pw_array_add(&this->metadata, sizeof(*item));
if (item == NULL)
return -errno;
set_item(item, subject, key, type, value);
changed++;
pw_log_info(NAME" %p: add id:%d key:%s type:%s value:%s", this,
subject, key, type, value);
} else {
if (type == NULL)
type = item->type;
changed = change_item(item, type, value);
if (changed)
pw_log_info(NAME" %p: change id:%d key:%s type:%s value:%s", this,
subject, key, type, value);
}
if (changed)
pw_metadata_emit_property(&this->hooks,
subject, key, type, value);
return 0;
}
static int impl_clear(void *object)
{
struct metadata *this = object;
clear_items(this);
return 0;
}
static const struct pw_metadata_methods impl_metadata = {
PW_VERSION_METADATA_METHODS,
.add_listener = impl_add_listener,
.set_property = impl_set_property,
.clear = impl_clear,
};
static void session_remove(void *data, struct sm_object *object)
{
struct metadata *this = data;
clear_subjects(this, object->id);
}
static void session_shutdown(void *data)
{
struct metadata *this = data;
this->shutdown = true;
}
static void session_destroy(void *data) static void session_destroy(void *data)
{ {
struct metadata *this = data; struct metadata *this = data;
@ -248,16 +49,13 @@ static void session_destroy(void *data)
spa_hook_remove(&this->session_listener); spa_hook_remove(&this->session_listener);
pw_proxy_destroy(this->proxy); pw_proxy_destroy(this->proxy);
clear_items(this); pw_impl_metadata_destroy(this->impl);
pw_array_clear(&this->metadata);
free(this); free(this);
} }
static const struct sm_media_session_events session_events = { static const struct sm_media_session_events session_events = {
SM_VERSION_MEDIA_SESSION_EVENTS, SM_VERSION_MEDIA_SESSION_EVENTS,
.shutdown = session_shutdown,
.destroy = session_destroy, .destroy = session_destroy,
.remove = session_remove,
}; };
struct pw_metadata *sm_media_session_export_metadata(struct sm_media_session *sess, struct pw_metadata *sm_media_session_export_metadata(struct sm_media_session *sess,
@ -271,13 +69,12 @@ struct pw_metadata *sm_media_session_export_metadata(struct sm_media_session *se
if (this == NULL) if (this == NULL)
goto error_errno; goto error_errno;
pw_array_init(&this->metadata, 4096); this->impl = pw_context_create_metadata(sess->context,
name, NULL, 0);
if (this->impl == NULL)
goto error_errno;
this->iface = SPA_INTERFACE_INIT( this->metadata = pw_impl_metadata_get_implementation(this->impl);
PW_TYPE_INTERFACE_Metadata,
PW_VERSION_METADATA,
&impl_metadata, this);
spa_hook_list_init(&this->hooks);
items[0] = SPA_DICT_ITEM_INIT(PW_KEY_METADATA_NAME, name); items[0] = SPA_DICT_ITEM_INIT(PW_KEY_METADATA_NAME, name);
@ -285,15 +82,14 @@ struct pw_metadata *sm_media_session_export_metadata(struct sm_media_session *se
this->proxy = sm_media_session_export(sess, this->proxy = sm_media_session_export(sess,
PW_TYPE_INTERFACE_Metadata, PW_TYPE_INTERFACE_Metadata,
&SPA_DICT_INIT_ARRAY(items), &SPA_DICT_INIT_ARRAY(items),
&this->iface, this->metadata, 0);
0);
if (this->proxy == NULL) if (this->proxy == NULL)
goto error_errno; goto error_errno;
sm_media_session_add_listener(sess, &this->session_listener, sm_media_session_add_listener(sess, &this->session_listener,
&session_events, this); &session_events, this);
return (struct pw_metadata*)&this->iface; return this->metadata;
error_errno: error_errno:
res = -errno; res = -errno;