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

impl-node: sync current rate and quantum with position

Browse source
This commit is contained in:
Wim Taymans 2021-12-14 20:47:36 +01:00
parent dbe61af543
commit c903c2ca08
1 changed files with 6 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/pipewire/impl-node.c
View file

@ -658,6 +658,9 @@ static void update_io(struct pw_impl_node *node)
sizeof(struct spa_io_position)) >= 0) { sizeof(struct spa_io_position)) >= 0) {
pw_log_debug("%p: set position %p", node, &node->rt.activation->position); pw_log_debug("%p: set position %p", node, &node->rt.activation->position);
node->rt.position = &node->rt.activation->position; node->rt.position = &node->rt.activation->position;
node->current_rate = node->rt.position->clock.rate;
node->current_quantum = node->rt.position->clock.duration;
} else if (node->driver) { } else if (node->driver) {
pw_log_warn("%p: can't set position on driver", node); pw_log_warn("%p: can't set position on driver", node);
} }
@ -780,6 +783,9 @@ do_move_nodes(struct spa_loop *loop,
pw_log_trace("%p: set position %p", node, &driver->rt.activation->position); pw_log_trace("%p: set position %p", node, &driver->rt.activation->position);
node->rt.position = &driver->rt.activation->position; node->rt.position = &driver->rt.activation->position;
node->current_rate = node->rt.position->clock.rate;
node->current_quantum = node->rt.position->clock.duration;
if (node->source.loop != NULL) { if (node->source.loop != NULL) {
remove_node(node); remove_node(node);
add_node(node, driver); add_node(node, driver);