402 lines
9.1 KiB
C
402 lines
9.1 KiB
C
/* PipeWire */
|
|
/* SPDX-FileCopyrightText: Copyright © 2018 Wim Taymans */
|
|
/* SPDX-License-Identifier: MIT */
|
|
|
|
#include "config.h"
|
|
|
|
#include <stdio.h>
|
|
#include <unistd.h>
|
|
#include <sys/mman.h>
|
|
|
|
#include <spa/utils/string.h>
|
|
|
|
#include <jack/metadata.h>
|
|
#include <jack/uuid.h>
|
|
|
|
#include <pipewire/pipewire.h>
|
|
#include <pipewire/extensions/metadata.h>
|
|
|
|
static jack_description_t *find_description(jack_uuid_t subject)
|
|
{
|
|
jack_description_t *desc;
|
|
pw_array_for_each(desc, &globals.descriptions) {
|
|
if (jack_uuid_compare(desc->subject, subject) == 0)
|
|
return desc;
|
|
}
|
|
return NULL;
|
|
}
|
|
|
|
static void set_property(jack_property_t *prop, const char *key, const char *value, const char *type)
|
|
{
|
|
prop->key = strdup(key);
|
|
prop->data = strdup(value);
|
|
prop->type = strdup(type);
|
|
}
|
|
|
|
static void clear_property(jack_property_t *prop)
|
|
{
|
|
free((char*)prop->key);
|
|
free((char*)prop->data);
|
|
free((char*)prop->type);
|
|
}
|
|
|
|
static jack_property_t *copy_properties(jack_property_t *src, uint32_t cnt)
|
|
{
|
|
jack_property_t *dst;
|
|
uint32_t i;
|
|
dst = malloc(sizeof(jack_property_t) * cnt);
|
|
if (dst != NULL) {
|
|
for (i = 0; i < cnt; i++)
|
|
set_property(&dst[i], src[i].key, src[i].data, src[i].type);
|
|
}
|
|
return dst;
|
|
}
|
|
|
|
static int copy_description(jack_description_t *dst, jack_description_t *src)
|
|
{
|
|
dst->properties = copy_properties(src->properties, src->property_cnt);
|
|
if (dst->properties == NULL)
|
|
return -errno;
|
|
jack_uuid_copy(&dst->subject, src->subject);
|
|
dst->property_cnt = src->property_cnt;
|
|
dst->property_size = src->property_size;
|
|
return dst->property_cnt;
|
|
}
|
|
|
|
static jack_description_t *add_description(jack_uuid_t subject)
|
|
{
|
|
jack_description_t *desc;
|
|
desc = pw_array_add(&globals.descriptions, sizeof(*desc));
|
|
if (desc != NULL) {
|
|
spa_zero(*desc);
|
|
jack_uuid_copy(&desc->subject, subject);
|
|
}
|
|
return desc;
|
|
}
|
|
|
|
static void remove_description(jack_description_t *desc)
|
|
{
|
|
jack_free_description(desc, false);
|
|
pw_array_remove(&globals.descriptions, desc);
|
|
}
|
|
|
|
static jack_property_t *find_property(jack_description_t *desc, const char *key)
|
|
{
|
|
uint32_t i;
|
|
for (i = 0; i < desc->property_cnt; i++) {
|
|
jack_property_t *prop = &desc->properties[i];
|
|
if (spa_streq(prop->key, key))
|
|
return prop;
|
|
}
|
|
return NULL;
|
|
}
|
|
|
|
static jack_property_t *add_property(jack_description_t *desc, const char *key,
|
|
const char *value, const char *type)
|
|
{
|
|
jack_property_t *prop;
|
|
void *np;
|
|
size_t ns;
|
|
|
|
if (desc->property_cnt == desc->property_size) {
|
|
ns = desc->property_size > 0 ? desc->property_size * 2 : 8;
|
|
np = pw_reallocarray(desc->properties, ns, sizeof(*prop));
|
|
if (np == NULL)
|
|
return NULL;
|
|
desc->property_size = ns;
|
|
desc->properties = np;
|
|
}
|
|
prop = &desc->properties[desc->property_cnt++];
|
|
set_property(prop, key, value, type);
|
|
return prop;
|
|
}
|
|
|
|
static void remove_property(jack_description_t *desc, jack_property_t *prop)
|
|
{
|
|
clear_property(prop);
|
|
desc->property_cnt--;
|
|
memmove(desc->properties, SPA_PTROFF(prop, sizeof(*prop), void),
|
|
SPA_PTRDIFF(SPA_PTROFF(desc->properties, sizeof(*prop) * desc->property_cnt, void),
|
|
prop));
|
|
|
|
if (desc->property_cnt == 0)
|
|
remove_description(desc);
|
|
}
|
|
|
|
static int change_property(jack_property_t *prop, const char *value, const char *type)
|
|
{
|
|
int changed = 0;
|
|
if (!spa_streq(prop->data, value)) {
|
|
free((char*)prop->data);
|
|
prop->data = strdup(value);
|
|
changed++;
|
|
}
|
|
if (!spa_streq(prop->type, type)) {
|
|
free((char*)prop->type);
|
|
prop->type = strdup(type);
|
|
changed++;
|
|
}
|
|
return changed;
|
|
}
|
|
|
|
static int update_property(struct client *c,
|
|
jack_uuid_t subject,
|
|
const char* key,
|
|
const char* type,
|
|
const char* value)
|
|
{
|
|
jack_property_change_t change;
|
|
jack_description_t *desc;
|
|
int changed = 0;
|
|
|
|
pthread_mutex_lock(&globals.lock);
|
|
desc = find_description(subject);
|
|
|
|
if (key == NULL) {
|
|
if (desc != NULL) {
|
|
remove_description(desc);
|
|
change = PropertyDeleted;
|
|
changed++;
|
|
}
|
|
} else {
|
|
jack_property_t *prop;
|
|
|
|
prop = desc ? find_property(desc, key) : NULL;
|
|
|
|
if (value == NULL || type == NULL) {
|
|
if (prop != NULL) {
|
|
remove_property(desc, prop);
|
|
change = PropertyDeleted;
|
|
changed++;
|
|
}
|
|
} else if (prop == NULL) {
|
|
if (desc == NULL)
|
|
desc = add_description(subject);
|
|
if (desc == NULL) {
|
|
changed = -errno;
|
|
pw_log_warn("add_description failed: %m");
|
|
} else if (add_property(desc, key, value, type) == NULL) {
|
|
changed = -errno;
|
|
pw_log_warn("add_property failed: %m");
|
|
} else {
|
|
change = PropertyCreated;
|
|
changed++;
|
|
}
|
|
} else {
|
|
changed = change_property(prop, value, type);
|
|
change = PropertyChanged;
|
|
}
|
|
}
|
|
pthread_mutex_unlock(&globals.lock);
|
|
|
|
if (c->property_callback && changed > 0) {
|
|
pw_log_info("emit %"PRIu64" %s", (uint64_t)subject, key);
|
|
c->property_callback(subject, key, change, c->property_arg);
|
|
}
|
|
return changed;
|
|
}
|
|
|
|
|
|
SPA_EXPORT
|
|
int jack_set_property(jack_client_t*client,
|
|
jack_uuid_t subject,
|
|
const char* key,
|
|
const char* value,
|
|
const char* type)
|
|
{
|
|
struct client *c = (struct client *) client;
|
|
struct object *o;
|
|
uint32_t serial;
|
|
int res = -1;
|
|
|
|
spa_return_val_if_fail(c != NULL, -EINVAL);
|
|
spa_return_val_if_fail(key != NULL, -EINVAL);
|
|
spa_return_val_if_fail(value != NULL, -EINVAL);
|
|
|
|
pw_thread_loop_lock(c->context.loop);
|
|
if (c->metadata == NULL)
|
|
goto done;
|
|
|
|
if (subject & (1<<30))
|
|
goto done;
|
|
|
|
serial = jack_uuid_to_index(subject);
|
|
if ((o = find_by_serial(c, serial)) == NULL)
|
|
goto done;
|
|
|
|
if (type == NULL)
|
|
type = "";
|
|
|
|
pw_log_info("set id:%u (%"PRIu64") '%s' to '%s@%s'", o->id, subject, key, value, type);
|
|
if (update_property(c, subject, key, type, value))
|
|
pw_metadata_set_property(c->metadata->proxy, o->id, key, type, value);
|
|
res = 0;
|
|
done:
|
|
pw_thread_loop_unlock(c->context.loop);
|
|
|
|
return res;
|
|
}
|
|
|
|
SPA_EXPORT
|
|
int jack_get_property(jack_uuid_t subject,
|
|
const char* key,
|
|
char** value,
|
|
char** type)
|
|
{
|
|
jack_description_t *desc;
|
|
jack_property_t *prop;
|
|
int res = -1;
|
|
|
|
pthread_mutex_lock(&globals.lock);
|
|
desc = find_description(subject);
|
|
if (desc == NULL)
|
|
goto done;
|
|
|
|
prop = find_property(desc, key);
|
|
if (prop == NULL)
|
|
goto done;
|
|
|
|
*value = strdup(prop->data);
|
|
*type = strdup(prop->type);
|
|
res = 0;
|
|
|
|
pw_log_debug("subject:%"PRIu64" key:'%s' value:'%s' type:'%s'",
|
|
subject, key, *value, *type);
|
|
done:
|
|
pthread_mutex_unlock(&globals.lock);
|
|
return res;
|
|
}
|
|
|
|
SPA_EXPORT
|
|
void jack_free_description (jack_description_t* desc, int free_description_itself)
|
|
{
|
|
uint32_t n;
|
|
|
|
for (n = 0; n < desc->property_cnt; ++n)
|
|
clear_property(&desc->properties[n]);
|
|
free(desc->properties);
|
|
if (free_description_itself)
|
|
free(desc);
|
|
}
|
|
|
|
SPA_EXPORT
|
|
int jack_get_properties (jack_uuid_t subject,
|
|
jack_description_t* desc)
|
|
{
|
|
jack_description_t *d;
|
|
int res = -1;
|
|
|
|
spa_return_val_if_fail(desc != NULL, -EINVAL);
|
|
|
|
pthread_mutex_lock(&globals.lock);
|
|
d = find_description(subject);
|
|
if (d == NULL)
|
|
goto done;
|
|
|
|
res = copy_description(desc, d);
|
|
done:
|
|
pthread_mutex_unlock(&globals.lock);
|
|
return res;
|
|
}
|
|
|
|
SPA_EXPORT
|
|
int jack_get_all_properties (jack_description_t** result)
|
|
{
|
|
uint32_t i;
|
|
jack_description_t *dst, *src;
|
|
struct pw_array *descriptions;
|
|
uint32_t len;
|
|
|
|
pthread_mutex_lock(&globals.lock);
|
|
descriptions = &globals.descriptions;
|
|
len = pw_array_get_len(descriptions, jack_description_t);
|
|
src = descriptions->data;
|
|
dst = malloc(descriptions->size);
|
|
for (i = 0; i < len; i++)
|
|
copy_description(&dst[i], &src[i]);
|
|
*result = dst;
|
|
pthread_mutex_unlock(&globals.lock);
|
|
|
|
return len;
|
|
}
|
|
|
|
SPA_EXPORT
|
|
int jack_remove_property (jack_client_t* client, jack_uuid_t subject, const char* key)
|
|
{
|
|
struct client *c = (struct client *) client;
|
|
uint32_t id;
|
|
int res = -1;
|
|
|
|
spa_return_val_if_fail(c != NULL, -EINVAL);
|
|
spa_return_val_if_fail(key != NULL, -EINVAL);
|
|
|
|
pw_thread_loop_lock(c->context.loop);
|
|
|
|
if (c->metadata == NULL)
|
|
goto done;
|
|
|
|
id = jack_uuid_to_index(subject);
|
|
|
|
pw_log_info("remove id:%u (%"PRIu64") '%s'", id, subject, key);
|
|
pw_metadata_set_property(c->metadata->proxy,
|
|
id, key, NULL, NULL);
|
|
res = 0;
|
|
done:
|
|
pw_thread_loop_unlock(c->context.loop);
|
|
|
|
return res;
|
|
}
|
|
|
|
SPA_EXPORT
|
|
int jack_remove_properties (jack_client_t* client, jack_uuid_t subject)
|
|
{
|
|
struct client *c = (struct client *) client;
|
|
uint32_t id;
|
|
int res = -1;
|
|
|
|
spa_return_val_if_fail(c != NULL, -EINVAL);
|
|
|
|
pw_thread_loop_lock(c->context.loop);
|
|
if (c->metadata == NULL)
|
|
goto done;
|
|
|
|
id = jack_uuid_to_index(subject);
|
|
|
|
pw_log_info("remove id:%u (%"PRIu64")", id, subject);
|
|
pw_metadata_set_property(c->metadata->proxy,
|
|
id, NULL, NULL, NULL);
|
|
res = 0;
|
|
done:
|
|
pw_thread_loop_unlock(c->context.loop);
|
|
|
|
return res;
|
|
}
|
|
|
|
SPA_EXPORT
|
|
int jack_remove_all_properties (jack_client_t* client)
|
|
{
|
|
struct client *c = (struct client *) client;
|
|
|
|
spa_return_val_if_fail(c != NULL, -EINVAL);
|
|
|
|
pw_thread_loop_lock(c->context.loop);
|
|
pw_metadata_clear(c->metadata->proxy);
|
|
pw_thread_loop_unlock(c->context.loop);
|
|
|
|
return 0;
|
|
}
|
|
|
|
SPA_EXPORT
|
|
int jack_set_property_change_callback (jack_client_t* client,
|
|
JackPropertyChangeCallback callback,
|
|
void* arg)
|
|
{
|
|
struct client *c = (struct client *) client;
|
|
|
|
spa_return_val_if_fail(c != NULL, -EINVAL);
|
|
|
|
c->property_callback = callback;
|
|
c->property_arg = arg;
|
|
return 0;
|
|
}
|