From ed9851ab0f885795d73e70dbeb459886a5dce3ca Mon Sep 17 00:00:00 2001 From: David Svensson Fors Date: Fri, 22 Sep 2017 17:45:28 +0200 Subject: [PATCH] port: schedule reuse-buffer Handle reuse-buffer in output-port tee nodes and input-port mix nodes. In both cases, reuse-buffer is forwarded to the input ports of the tee/mix node. Change-Id: Ifbe8bcf07f0adc6400accc64a9bfb63a5c70e215 --- src/pipewire/port.c | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/src/pipewire/port.c b/src/pipewire/port.c index ddf8beb12..b1c7fd826 100644 --- a/src/pipewire/port.c +++ b/src/pipewire/port.c @@ -83,6 +83,15 @@ static int schedule_tee_output(struct spa_node *data) static int schedule_tee_reuse_buffer(struct spa_node *data, uint32_t port_id, uint32_t buffer_id) { + struct impl *impl = SPA_CONTAINER_OF(data, struct impl, mix_node); + struct pw_port *this = &impl->this; + struct spa_graph_node *node = &this->rt.mix_node; + struct spa_graph_port *p, *pp; + + spa_list_for_each(p, &node->ports[SPA_DIRECTION_INPUT], link) + if ((pp = p->peer) != NULL) + spa_node_port_reuse_buffer(pp->node->implementation, port_id, buffer_id); + return SPA_RESULT_OK; } @@ -131,6 +140,15 @@ static int schedule_mix_output(struct spa_node *data) static int schedule_mix_reuse_buffer(struct spa_node *data, uint32_t port_id, uint32_t buffer_id) { + struct impl *impl = SPA_CONTAINER_OF(data, struct impl, mix_node); + struct pw_port *this = &impl->this; + struct spa_graph_node *node = &this->rt.mix_node; + struct spa_graph_port *p, *pp; + + spa_list_for_each(p, &node->ports[SPA_DIRECTION_INPUT], link) + if ((pp = p->peer) != NULL) + spa_node_port_reuse_buffer(pp->node->implementation, port_id, buffer_id); + return SPA_RESULT_OK; }