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

node: always call output mix when HAVE_BUFFER

Browse source
This commit is contained in:
Wim Taymans 2019-07-11 11:20:04 +02:00
parent a6ce5e7eeb
commit 6f672c883e
1 changed files with 11 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/pipewire/node.c
View file

@ -675,18 +675,12 @@ static void dump_states(struct pw_node *driver)
static inline int resume_node(struct pw_node *this, int status) static inline int resume_node(struct pw_node *this, int status)
{ {
struct pw_port *p;
struct pw_node_target *t; struct pw_node_target *t;
struct timespec ts; struct timespec ts;
struct pw_node_activation *activation = this->rt.activation; struct pw_node_activation *activation = this->rt.activation;
struct spa_system *data_system = this->core->data_system; struct spa_system *data_system = this->core->data_system;
uint64_t nsec; uint64_t nsec;
if (status & SPA_STATUS_HAVE_BUFFER) {
spa_list_for_each(p, &this->rt.output_mix, rt.node_link)
spa_node_process(p->mix);
}
spa_system_clock_gettime(data_system, CLOCK_MONOTONIC, &ts); spa_system_clock_gettime(data_system, CLOCK_MONOTONIC, &ts);
nsec = SPA_TIMESPEC_TO_NSEC(&ts); nsec = SPA_TIMESPEC_TO_NSEC(&ts);
activation->status = FINISHED; activation->status = FINISHED;
@ -732,6 +726,11 @@ static inline int process_node(void *data)
status = spa_node_process(this->node); status = spa_node_process(this->node);
a->state[0].status = status; a->state[0].status = status;
if (status & SPA_STATUS_HAVE_BUFFER) {
spa_list_for_each(p, &this->rt.output_mix, rt.node_link)
spa_node_process(p->mix);
}
if (this == this->driver_node && !this->exported) { if (this == this->driver_node && !this->exported) {
spa_system_clock_gettime(data_system, CLOCK_MONOTONIC, &ts); spa_system_clock_gettime(data_system, CLOCK_MONOTONIC, &ts);
a->status = FINISHED; a->status = FINISHED;
@ -1060,6 +1059,7 @@ static int node_ready(void *data, int status)
struct pw_node *node = data; struct pw_node *node = data;
struct pw_node *driver = node->driver_node; struct pw_node *driver = node->driver_node;
struct pw_node_target *t; struct pw_node_target *t;
struct pw_port *p;
pw_log_trace_fp("node %p: ready driver:%d exported:%d %p status:%d", node, pw_log_trace_fp("node %p: ready driver:%d exported:%d %p status:%d", node,
node->driver, node->exported, driver, status); node->driver, node->exported, driver, status);
@ -1079,6 +1079,11 @@ static int node_ready(void *data, int status)
if (node->driver && !node->master) if (node->driver && !node->master)
return 0; return 0;
if (status & SPA_STATUS_HAVE_BUFFER) {
spa_list_for_each(p, &node->rt.output_mix, rt.node_link)
spa_node_process(p->mix);
}
return resume_node(node, status); return resume_node(node, status);
} }