mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-03 09:01:54 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

port: don't schedule disabled ports

Browse source
This commit is contained in:
Wim Taymans 2018-03-02 13:24:55 +01:00
parent 2ea9addcf2
commit c0865581b9
1 changed files with 14 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/pipewire/port.c
View file

@ -58,8 +58,11 @@ static int schedule_tee_input(struct spa_node *data)
if (!spa_list_is_empty(&node->ports[SPA_DIRECTION_OUTPUT])) { if (!spa_list_is_empty(&node->ports[SPA_DIRECTION_OUTPUT])) {
pw_log_trace("node %p: tee input %d %d", node, io->status, io->buffer_id); pw_log_trace("node %p: tee input %d %d", node, io->status, io->buffer_id);
spa_list_for_each(p, &node->ports[SPA_DIRECTION_OUTPUT], link) spa_list_for_each(p, &node->ports[SPA_DIRECTION_OUTPUT], link) {
if (p->flags & SPA_GRAPH_PORT_FLAG_DISABLED)
continue;
*p->io = *io; *p->io = *io;
}
io->buffer_id = SPA_ID_INVALID; io->buffer_id = SPA_ID_INVALID;
} }
else else
@ -74,8 +77,11 @@ static int schedule_tee_output(struct spa_node *data)
struct spa_graph_port *p; struct spa_graph_port *p;
struct spa_io_buffers *io = this->rt.mix_port.io; struct spa_io_buffers *io = this->rt.mix_port.io;
spa_list_for_each(p, &node->ports[SPA_DIRECTION_OUTPUT], link) spa_list_for_each(p, &node->ports[SPA_DIRECTION_OUTPUT], link) {
if (p->flags & SPA_GRAPH_PORT_FLAG_DISABLED)
continue;
*io = *p->io; *io = *p->io;
}
pw_log_trace("node %p: tee output %d %d", node, io->status, io->buffer_id); pw_log_trace("node %p: tee output %d %d", node, io->status, io->buffer_id);
return io->status; return io->status;
} }
@ -109,6 +115,8 @@ static int schedule_mix_input(struct spa_node *data)
struct spa_io_buffers *io = this->rt.mix_port.io; struct spa_io_buffers *io = this->rt.mix_port.io;
spa_list_for_each(p, &node->ports[SPA_DIRECTION_INPUT], link) { spa_list_for_each(p, &node->ports[SPA_DIRECTION_INPUT], link) {
if (p->flags & SPA_GRAPH_PORT_FLAG_DISABLED)
continue;
pw_log_trace("mix %p: input %p %p->%p %d %d", node, pw_log_trace("mix %p: input %p %p->%p %d %d", node,
p, p->io, io, p->io->status, p->io->buffer_id); p, p->io, io, p->io->status, p->io->buffer_id);
*io = *p->io; *io = *p->io;
@ -126,9 +134,12 @@ static int schedule_mix_output(struct spa_node *data)
struct spa_io_buffers *io = this->rt.mix_port.io; struct spa_io_buffers *io = this->rt.mix_port.io;
if (!spa_list_is_empty(&node->ports[SPA_DIRECTION_INPUT])) { if (!spa_list_is_empty(&node->ports[SPA_DIRECTION_INPUT])) {
spa_list_for_each(p, &node->ports[SPA_DIRECTION_INPUT], link) spa_list_for_each(p, &node->ports[SPA_DIRECTION_INPUT], link) {
if (p->flags & SPA_GRAPH_PORT_FLAG_DISABLED)
continue;
*p->io = *io; *p->io = *io;
} }
}
else { else {
io->status = SPA_STATUS_HAVE_BUFFER; io->status = SPA_STATUS_HAVE_BUFFER;
io->buffer_id = SPA_ID_INVALID; io->buffer_id = SPA_ID_INVALID;