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

node: the exported node and never finish the graph

Browse source 
That graph is always started and finished on the server, even when
the driver is remote.
This commit is contained in:
Wim Taymans 2019-03-07 18:36:23 +01:00
parent 264383cdd4
commit ae3178abfe
1 changed files with 3 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/pipewire/node.c
View file

@ -592,7 +592,7 @@ static int pw_node_trigger(struct pw_node *this, uint64_t nsec)
state = &t->activation->state[0]; state = &t->activation->state[0];
spa_debug("node %p: state %p pending %d/%d", t->data, state, spa_debug("node %p: state %p pending %d/%d", t->node, state,
state->pending, state->required); state->pending, state->required);
if (pw_node_activation_state_dec(state, 1)) { if (pw_node_activation_state_dec(state, 1)) {
@ -634,7 +634,7 @@ static inline int process_node(void *data)
this->rt.activation->awake_time - this->rt.activation->signal_time, this->rt.activation->awake_time - this->rt.activation->signal_time,
this->rt.activation->finish_time - this->rt.activation->awake_time); this->rt.activation->finish_time - this->rt.activation->awake_time);
if (this != this->driver_node) { if (this != this->driver_node || this->exported) {
pw_node_trigger(this, nsec); pw_node_trigger(this, nsec);
} else { } else {
pw_log_trace("node %p: graph completed", this); pw_log_trace("node %p: graph completed", this);
@ -944,9 +944,7 @@ static int node_ready(void *data, int status)
driver->rt.activation->status = TRIGGERED; driver->rt.activation->status = TRIGGERED;
driver->rt.activation->signal_time = nsec; driver->rt.activation->signal_time = nsec;
pw_node_trigger(driver, nsec); return pw_node_trigger(driver, nsec);
return 0;
} }
static int node_reuse_buffer(void *data, uint32_t port_id, uint32_t buffer_id) static int node_reuse_buffer(void *data, uint32_t port_id, uint32_t buffer_id)