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

params: only emit callback for requested seq

Browse source
This commit is contained in:
Wim Taymans 2019-03-14 16:37:58 +01:00
parent efa74adfc3
commit 8b2b7c3053
2 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/pipewire/node.c
View file

@ -1160,13 +1160,15 @@ struct result_node_params_data {
int (*callback) (void *data, int seq, int (*callback) (void *data, int seq,
uint32_t id, uint32_t index, uint32_t next, uint32_t id, uint32_t index, uint32_t next,
struct spa_pod *param); struct spa_pod *param);
int seq;
}; };
static void result_node_params(void *data, int seq, int res, const void *result) static void result_node_params(void *data, int seq, int res, const void *result)
{ {
struct result_node_params_data *d = data; struct result_node_params_data *d = data;
const struct spa_result_node_params *r = result; const struct spa_result_node_params *r = result;
d->callback(d->data, seq, r->id, r->index, r->next, r->param); if (d->seq == seq)
d->callback(d->data, seq, r->id, r->index, r->next, r->param);
} }
SPA_EXPORT SPA_EXPORT
@ -1180,7 +1182,7 @@ int pw_node_for_each_param(struct pw_node *node,
void *data) void *data)
{ {
int res; int res;
struct result_node_params_data user_data = { data, callback }; struct result_node_params_data user_data = { data, callback, seq };
struct spa_hook listener; struct spa_hook listener;
static const struct spa_node_events node_events = { static const struct spa_node_events node_events = {
SPA_VERSION_NODE_EVENTS, SPA_VERSION_NODE_EVENTS,

6
src/pipewire/port.c
View file

@ -736,13 +736,15 @@ struct result_port_params_data {
int (*callback) (void *data, int seq, int (*callback) (void *data, int seq,
uint32_t id, uint32_t index, uint32_t next, uint32_t id, uint32_t index, uint32_t next,
struct spa_pod *param); struct spa_pod *param);
int seq;
}; };
static void result_port_params(void *data, int seq, int res, const void *result) static void result_port_params(void *data, int seq, int res, const void *result)
{ {
struct result_port_params_data *d = data; struct result_port_params_data *d = data;
const struct spa_result_node_params *r = result; const struct spa_result_node_params *r = result;
d->callback(d->data, seq, r->id, r->index, r->next, r->param); if (d->seq == seq)
d->callback(d->data, seq, r->id, r->index, r->next, r->param);
} }
int pw_port_for_each_param(struct pw_port *port, int pw_port_for_each_param(struct pw_port *port,
@ -757,7 +759,7 @@ int pw_port_for_each_param(struct pw_port *port,
{ {
int res; int res;
struct pw_node *node = port->node; struct pw_node *node = port->node;
struct result_port_params_data user_data = { data, callback }; struct result_port_params_data user_data = { data, callback, seq };
struct spa_hook listener; struct spa_hook listener;
static const struct spa_node_events node_events = { static const struct spa_node_events node_events = {
SPA_VERSION_NODE_EVENTS, SPA_VERSION_NODE_EVENTS,