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

impl-node: recalc when node flag change

Browse source
This commit is contained in:
Wim Taymans 2020-08-10 16:48:42 +02:00
parent 2362953931
commit db93135ff7
1 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1213,16 +1213,19 @@ static void node_info(void *data, const struct spa_node_info *info)
{ {
struct pw_impl_node *node = data; struct pw_impl_node *node = data;
uint32_t changed_ids[MAX_PARAMS], n_changed_ids = 0; uint32_t changed_ids[MAX_PARAMS], n_changed_ids = 0;
bool recalc = false;
node->info.max_input_ports = info->max_input_ports; node->info.max_input_ports = info->max_input_ports;
node->info.max_output_ports = info->max_output_ports; node->info.max_output_ports = info->max_output_ports;
pw_log_debug(NAME" %p: change_mask %08"PRIx64" max_in:%u max_out:%u", pw_log_debug(NAME" %p: flags:%08"PRIx64" change_mask:%08"PRIx64" max_in:%u max_out:%u",
node, info->change_mask, info->max_input_ports, node, info->flags, info->change_mask, info->max_input_ports,
info->max_output_ports); info->max_output_ports);
if (info->change_mask & SPA_NODE_CHANGE_MASK_FLAGS) { if (info->change_mask & SPA_NODE_CHANGE_MASK_FLAGS) {
recalc = node->spa_flags != info->flags;
node->spa_flags = info->flags; node->spa_flags = info->flags;
node->info.change_mask |= PW_NODE_CHANGE_MASK_PROPS;
} }
if (info->change_mask & SPA_NODE_CHANGE_MASK_PROPS) { if (info->change_mask & SPA_NODE_CHANGE_MASK_PROPS) {
update_properties(node, info->props); update_properties(node, info->props);
@ -1250,6 +1253,9 @@ static void node_info(void *data, const struct spa_node_info *info)
if (n_changed_ids > 0) if (n_changed_ids > 0)
emit_params(node, changed_ids, n_changed_ids); emit_params(node, changed_ids, n_changed_ids);
if (recalc)
pw_context_recalc_graph(node->context, "node info changed");
} }
static void node_port_info(void *data, enum spa_direction direction, uint32_t port_id, static void node_port_info(void *data, enum spa_direction direction, uint32_t port_id,