diff --git a/src/pipewire/node.c b/src/pipewire/node.c index f95211e56..c042be3af 100644 --- a/src/pipewire/node.c +++ b/src/pipewire/node.c @@ -384,47 +384,6 @@ int pw_node_register(struct pw_node *this, return 0; } -static void node_have_output(void *data); -static void node_need_input(void *data); - -static int impl_node_process(struct pw_node *node) -{ - struct spa_graph_port *p; - int res = 0, old; - - old = node->rt.activation->state.status; - - pw_log_trace("node %p: process %d", node, old); - - if (old == SPA_STATUS_NEED_BUFFER) { - if (!spa_list_is_empty(&node->rt.node.ports[SPA_DIRECTION_INPUT])) { - spa_list_for_each(p, &node->rt.node.ports[SPA_DIRECTION_INPUT], link) - spa_node_process_input(p->peer->node->implementation); - - if (node->node->process_input) - res = spa_node_process_input(node->node); - } - else { - if (node->node->process_output) - res = spa_node_process_output(node->node); - } - } - pw_log_trace("node %p: process %d", node, res); - - if (res == SPA_STATUS_HAVE_BUFFER) { - node_have_output(node); - } - else if (res == SPA_STATUS_NEED_BUFFER) { - spa_list_for_each(p, &node->rt.node.ports[SPA_DIRECTION_INPUT], link) - spa_node_process_output(p->peer->node->implementation); - } - pw_log_trace("node %p: process %d", node, res); - - node->rt.activation->state.status = res; - - return res; -} - static void check_properties(struct pw_node *node) { struct impl *impl = SPA_CONTAINER_OF(node, struct impl, this); @@ -491,8 +450,6 @@ struct pw_node *pw_node_new(struct pw_core *core, spa_list_init(&this->rt.links[SPA_DIRECTION_OUTPUT]); impl->activation.state.status = SPA_STATUS_NEED_BUFFER; - this->process = impl_node_process; - return this; no_mem: diff --git a/src/pipewire/private.h b/src/pipewire/private.h index 7de2a9a26..8bb12a7ce 100644 --- a/src/pipewire/private.h +++ b/src/pipewire/private.h @@ -274,8 +274,6 @@ struct pw_node { struct pw_loop *data_loop; /**< the data loop for this node */ - int (*process) (struct pw_node *node); - struct { struct spa_graph *graph; struct spa_graph_node node;