mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

client-node: handle _set_io on the node

Browse source
This commit is contained in:
Wim Taymans 2019-01-31 17:50:55 +01:00
parent bad9b15a92
commit baa6b1472d
1 changed files with 50 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

62
src/modules/module-client-node/client-node.c
View file

@ -131,6 +131,7 @@ struct node {
const struct spa_node_callbacks *callbacks; const struct spa_node_callbacks *callbacks;
void *callbacks_data; void *callbacks_data;
struct io ios[MAX_IO];
struct pw_resource *resource; struct pw_resource *resource;
@ -230,16 +231,21 @@ static struct mix *find_mix(struct port *p, uint32_t mix_id)
return mix; return mix;
} }
static void mix_init(struct mix *mix, struct port *p, uint32_t id) static void init_ios(struct io *ios)
{ {
int i; int i;
for (i = 0; i < MAX_IO; i++)
ios[i].id = SPA_ID_INVALID;
}
static void mix_init(struct mix *mix, struct port *p, uint32_t id)
{
mix->valid = true; mix->valid = true;
mix->id = id; mix->id = id;
mix->port = p; mix->port = p;
mix->active = false; mix->active = false;
mix->n_buffers = 0; mix->n_buffers = 0;
for (i = 0; i < MAX_IO; i++) init_ios(mix->ios);
mix->ios[i].id = SPA_ID_INVALID;
} }
@ -264,15 +270,14 @@ static void clear_io(struct node *node, struct io *io)
io->id = SPA_ID_INVALID; io->id = SPA_ID_INVALID;
} }
static struct io *update_io(struct impl *impl, struct port *port, static struct io *update_io(struct node *this,
struct mix *mix, uint32_t id, uint32_t memid) struct io *ios, uint32_t id, uint32_t memid)
{ {
struct node *this = &impl->node;
int i; int i;
struct io *io, *f = NULL; struct io *io, *f = NULL;
for (i = 0; i < MAX_IO; i++) { for (i = 0; i < MAX_IO; i++) {
io = &mix->ios[i]; io = &ios[i];
if (io->id == SPA_ID_INVALID) if (io->id == SPA_ID_INVALID)
f = io; f = io;
else if (io->id == id) { else if (io->id == id) {
@ -296,12 +301,12 @@ static struct io *update_io(struct impl *impl, struct port *port,
return io; return io;
} }
static void clear_ios(struct node *this, struct mix *mix) static void clear_ios(struct node *this, struct io *ios)
{ {
int i; int i;
for (i = 0; i < MAX_IO; i++) { for (i = 0; i < MAX_IO; i++) {
struct io *io = &mix->ios[i]; struct io *io = &ios[i];
if (io->id != SPA_ID_INVALID) if (io->id != SPA_ID_INVALID)
clear_io(this, io); clear_io(this, io);
} }
@ -347,7 +352,7 @@ static void mix_clear(struct node *this, struct mix *mix)
return; return;
do_port_use_buffers(this->impl, port->direction, port->id, do_port_use_buffers(this->impl, port->direction, port->id,
mix->id, NULL, 0); mix->id, NULL, 0);
clear_ios(this, mix); clear_ios(this, mix->ios);
mix->valid = false; mix->valid = false;
} }
@ -402,15 +407,44 @@ static int impl_node_set_param(struct spa_node *node, uint32_t id, uint32_t flag
static int impl_node_set_io(struct spa_node *node, uint32_t id, void *data, size_t size) static int impl_node_set_io(struct spa_node *node, uint32_t id, void *data, size_t size)
{ {
struct node *this; struct node *this;
struct impl *impl;
struct pw_memblock *mem;
struct mem *m;
uint32_t memid, mem_offset, mem_size;
spa_return_val_if_fail(node != NULL, -EINVAL); spa_return_val_if_fail(node != NULL, -EINVAL);
this = SPA_CONTAINER_OF(node, struct node, node); this = SPA_CONTAINER_OF(node, struct node, node);
impl = this->impl;
if (this->resource == NULL) if (this->resource == NULL)
return 0; return 0;
return -ENOTSUP; if (data) {
if ((mem = pw_memblock_find(data)) == NULL)
return -EINVAL;
mem_offset = SPA_PTRDIFF(data, mem->ptr);
mem_size = mem->size;
if (mem_size - mem_offset < size)
return -EINVAL;
mem_offset += mem->offset;
m = ensure_mem(impl, mem->fd, SPA_DATA_MemFd, mem->flags);
memid = m->id;
}
else {
memid = SPA_ID_INVALID;
mem_offset = mem_size = 0;
}
update_io(this, this->ios, id, memid);
pw_client_node_resource_set_io(this->resource,
id,
memid,
mem_offset, mem_size);
return 0;
} }
static int impl_node_send_command(struct spa_node *node, const struct spa_command *command) static int impl_node_send_command(struct spa_node *node, const struct spa_command *command)
@ -744,7 +778,7 @@ static int do_port_set_io(struct impl *impl,
mem_offset = mem_size = 0; mem_offset = mem_size = 0;
} }
update_io(impl, port, mix, id, memid); update_io(this, mix->ios, id, memid);
pw_client_node_resource_port_set_io(this->resource, pw_client_node_resource_port_set_io(this->resource,
this->seq, this->seq,
@ -1185,6 +1219,8 @@ node_init(struct node *this,
this->node = impl_node; this->node = impl_node;
init_ios(this->ios);
this->data_source.func = node_on_data_fd_events; this->data_source.func = node_on_data_fd_events;
this->data_source.data = this; this->data_source.data = this;
this->data_source.fd = -1; this->data_source.fd = -1;
@ -1200,6 +1236,8 @@ static int node_clear(struct node *this)
{ {
uint32_t i; uint32_t i;
clear_ios(this, this->ios);
for (i = 0; i < this->n_params; i++) for (i = 0; i < this->n_params; i++)
free(this->params[i]); free(this->params[i]);
free(this->params); free(this->params);