mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-29 05:40:27 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-server: update all params only after enumeration complete

Browse source 
For params that don't emit change events, the param enumeration does not
start core sync, and its enumeration may be incomplete if a previous
core sync completes first.

Fix by always starting a core sync if we are updating params.

This fixes dev_info.active_port being sporadically SPA_ID_INVALID if
there is event pressure, which causes do_set_volume randomly set the
volume on the node instead of setting it on the device.  This can be
triggered e.g. by shaking the volume slider in Pavucontrol with mouse.
This commit is contained in:
Pauli Virtanen 2023-12-09 12:33:26 +02:00 • committed by Wim Taymans
parent 9d779300af
commit 4e2057930f
1 changed files with 10 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/modules/module-protocol-pulse/manager.c
View file

@ -290,6 +290,7 @@ static void device_event_info(void *data, const struct pw_device_info *info)
{
struct object *o = data;
uint32_t i, changed = 0;
bool enumerate = false;
pw_log_debug("object %p: id:%d change-mask:%08"PRIx64, o, o->this.id, info->change_mask);
@ -321,6 +322,9 @@ static void device_event_info(void *data, const struct pw_device_info *info)
default:
break;
}
enumerate = true;
add_param(&o->pending_list, info->params[i].seq, id, NULL);
if (!(info->params[i].flags & SPA_PARAM_INFO_READ))
continue;
@ -331,7 +335,7 @@ static void device_event_info(void *data, const struct pw_device_info *info)
info->params[i].seq = res;
}
}
if (changed) {
if (changed || enumerate) {
o->changed += changed;
core_sync(o->manager);
}
@ -410,6 +414,7 @@ static void node_event_info(void *data, const struct pw_node_info *info)
{
struct object *o = data;
uint32_t i, changed = 0;
bool enumerate = false;
pw_log_debug("object %p: id:%d change-mask:%08"PRIx64, o, o->this.id, info->change_mask);
@ -449,6 +454,9 @@ static void node_event_info(void *data, const struct pw_node_info *info)
default:
break;
}
enumerate = true;
add_param(&o->pending_list, info->params[i].seq, id, NULL);
if (!(info->params[i].flags & SPA_PARAM_INFO_READ))
continue;
@ -459,7 +467,7 @@ static void node_event_info(void *data, const struct pw_node_info *info)
info->params[i].seq = res;
}
}
if (changed) {
if (changed || enumerate) {
o->changed += changed;
core_sync(o->manager);
}