mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pw-top: remove nodes from driver when idle

Browse source 
When we detect that no new profiler info has arrived for a node, assume
it was removed from the driver.

This avoids having idle nodes seemingly attached to an idle driver
when there is no activity.
This commit is contained in:
Wim Taymans 2022-04-19 12:06:53 +02:00
parent 26db2f1ec9
commit ae8c6f827b
1 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/tools/pw-top.c
View file

@ -65,6 +65,7 @@ struct node {
struct node *driver; struct node *driver;
uint32_t errors; uint32_t errors;
int32_t last_error_status; int32_t last_error_status;
uint32_t generation;
}; };
struct data { struct data {
@ -85,6 +86,7 @@ struct data {
int n_nodes; int n_nodes;
struct spa_list node_list; struct spa_list node_list;
uint32_t generation;
WINDOW *win; WINDOW *win;
}; };
@ -182,6 +184,7 @@ static int process_driver_block(struct data *d, const struct spa_pod *pod, struc
n->measurement = m; n->measurement = m;
n->info = point->info; n->info = point->info;
point->driver = n; point->driver = n;
n->generation = d->generation;
if (m.status != 3) { if (m.status != 3) {
n->errors++; n->errors++;
@ -216,6 +219,7 @@ static int process_follower_block(struct data *d, const struct spa_pod *pod, str
n->measurement = m; n->measurement = m;
n->driver = point->driver; n->driver = point->driver;
n->generation = d->generation;
if (m.status != 3) { if (m.status != 3) {
n->errors++; n->errors++;
if (n->last_error_status == -1) if (n->last_error_status == -1)
@ -296,6 +300,9 @@ static void do_refresh(struct data *d)
break; break;
spa_list_for_each(f, &d->node_list, link) { spa_list_for_each(f, &d->node_list, link) {
if (d->generation > f->generation + 2)
f->driver = f;
if (f->driver != n || f == n) if (f->driver != n || f == n)
continue; continue;
@ -316,6 +323,7 @@ static void do_refresh(struct data *d)
static void do_timeout(void *data, uint64_t expirations) static void do_timeout(void *data, uint64_t expirations)
{ {
struct data *d = data; struct data *d = data;
d->generation++;
do_refresh(d); do_refresh(d);
} }