mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-31 22:25:38 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

alsa: emit param changes correctly

Browse source 
Use the param user field to tag changes in the params.
codec changes emits an EnumFormat and Props change.
Accumulate various param changes and emit them together.
This commit is contained in:
Wim Taymans 2021-09-01 12:57:47 +02:00
parent 01f640709e
commit ab3e265b2c
1 changed files with 37 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

45
spa/plugins/alsa/alsa-pcm-sink.c
View file

@ -63,7 +63,7 @@ static void emit_node_info(struct state *this, bool full)
this->info.change_mask = this->info_all;
if (this->info.change_mask) {
struct spa_dict_item items[4];
uint32_t n_items = 0;
uint32_t i, n_items = 0;
char latency[64];
items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_API, "alsa");
@ -75,6 +75,14 @@ static void emit_node_info(struct state *this, bool full)
}
this->info.props = &SPA_DICT_INIT(items, n_items);
if (this->info.change_mask & SPA_NODE_CHANGE_MASK_PARAMS) {
for (i = 0; i < this->info.n_params; i++) {
if (this->params[i].user > 0) {
this->params[i].flags ^= SPA_PARAM_INFO_SERIAL;
this->params[i].user = 0;
}
}
}
spa_node_emit_info(&this->hooks, &this->info);
this->info.change_mask = old;
@ -84,9 +92,20 @@ static void emit_node_info(struct state *this, bool full)
static void emit_port_info(struct state *this, bool full)
{
uint64_t old = full ? this->port_info.change_mask : 0;
if (full)
this->port_info.change_mask = this->port_info_all;
if (this->port_info.change_mask) {
uint32_t i;
if (this->port_info.change_mask & SPA_PORT_CHANGE_MASK_PARAMS) {
for (i = 0; i < this->port_info.n_params; i++) {
if (this->port_params[i].user > 0) {
this->port_params[i].flags ^= SPA_PARAM_INFO_SERIAL;
this->port_params[i].user = 0;
}
}
}
spa_node_emit_port_info(&this->hooks,
SPA_DIRECTION_INPUT, 0, &this->port_info);
this->port_info.change_mask = old;
@ -297,13 +316,11 @@ static void handle_process_latency(struct state *this,
this->info.change_mask |= SPA_NODE_CHANGE_MASK_PARAMS;
if (ns_changed)
this->params[NODE_Props].flags ^= SPA_PARAM_INFO_SERIAL;
this->params[NODE_ProcessLatency].flags ^= SPA_PARAM_INFO_SERIAL;
emit_node_info(this, false);
this->params[NODE_Props].user++;
this->params[NODE_ProcessLatency].user++;
this->port_info.change_mask |= SPA_PORT_CHANGE_MASK_PARAMS;
this->port_params[PORT_Latency].flags ^= SPA_PARAM_INFO_SERIAL;
emit_port_info(this, false);
this->port_params[PORT_Latency].user++;
}
static int impl_node_set_param(void *object, uint32_t id, uint32_t flags,
@ -344,8 +361,17 @@ static int impl_node_set_param(void *object, uint32_t id, uint32_t flags,
this->iec958_codecs = 1ULL << SPA_AUDIO_IEC958_CODEC_PCM;
for (i = 0; i < n_codecs; i++)
this->iec958_codecs |= 1ULL << codecs[i];
this->info.change_mask |= SPA_NODE_CHANGE_MASK_PARAMS;
this->params[NODE_Props].user++;
this->port_info.change_mask |= SPA_PORT_CHANGE_MASK_PARAMS;
this->port_params[PORT_EnumFormat].user++;
}
handle_process_latency(this, &info);
emit_node_info(this, false);
emit_port_info(this, false);
break;
}
case SPA_PARAM_ProcessLatency:
@ -355,6 +381,9 @@ static int impl_node_set_param(void *object, uint32_t id, uint32_t flags,
return res;
handle_process_latency(this, &info);
emit_node_info(this, false);
emit_port_info(this, false);
break;
}
default:
@ -655,7 +684,7 @@ static int port_set_format(void *object,
if (this->have_format) {
this->port_params[PORT_Format] = SPA_PARAM_INFO(SPA_PARAM_Format, SPA_PARAM_INFO_READWRITE);
this->port_params[PORT_Buffers] = SPA_PARAM_INFO(SPA_PARAM_Buffers, SPA_PARAM_INFO_READ);
this->port_params[PORT_Latency].flags ^= SPA_PARAM_INFO_SERIAL;
this->port_params[PORT_Latency].user++;
} else {
this->port_params[PORT_Format] = SPA_PARAM_INFO(SPA_PARAM_Format, SPA_PARAM_INFO_WRITE);
this->port_params[PORT_Buffers] = SPA_PARAM_INFO(SPA_PARAM_Buffers, 0);
@ -692,7 +721,7 @@ impl_node_port_set_param(void *object,
this->latency[info.direction] = info;
this->port_info.change_mask |= SPA_PORT_CHANGE_MASK_PARAMS;
this->port_params[PORT_Latency].flags ^= SPA_PARAM_INFO_SERIAL;
this->port_params[PORT_Latency].user++;
emit_port_info(this, false);
break;
}