From: Tvrtko Ursulin <tvrtko.ursulin@linux.intel.com> To: igt-dev@lists.freedesktop.org Cc: Intel-gfx@lists.freedesktop.org Subject: [Intel-gfx] [PATCH i-g-t 2/3] intel_gpu_top: Aggregate clients by PID by default Date: Wed, 10 Feb 2021 11:12:56 +0000 [thread overview] Message-ID: <20210210111256.63625-1-tvrtko.ursulin@linux.intel.com> (raw) In-Reply-To: <20210210093756.61424-2-tvrtko.ursulin@linux.intel.com> From: Tvrtko Ursulin <tvrtko.ursulin@intel.com> Implement a default view where clients are aggregated by their PID. Toggled by pressing 'H' similar to top(1). v2: * Fix memory leak. v3: * Do not allow sort by client id in aggregated mode. * Tweak sort criteria and sorting decisions. (Chris) v4: * More tweaks to code flow. (Chris) Signed-off-by: Tvrtko Ursulin <tvrtko.ursulin@intel.com> --- man/intel_gpu_top.rst | 1 + tools/intel_gpu_top.c | 133 +++++++++++++++++++++++++++++++++++++----- 2 files changed, 121 insertions(+), 13 deletions(-) diff --git a/man/intel_gpu_top.rst b/man/intel_gpu_top.rst index b145d85c0440..20658e291db0 100644 --- a/man/intel_gpu_top.rst +++ b/man/intel_gpu_top.rst @@ -58,6 +58,7 @@ Supported keys: 'n' Toggle display of numeric client busyness overlay. 's' Toggle between sort modes (runtime, total runtime, pid, client id). 'i' Toggle display of clients which used no GPU time. + 'H' Toggle between per PID aggregation and individual clients. DEVICE SELECTION ================ diff --git a/tools/intel_gpu_top.c b/tools/intel_gpu_top.c index 63ef77056341..e7f696110be8 100644 --- a/tools/intel_gpu_top.c +++ b/tools/intel_gpu_top.c @@ -979,17 +979,18 @@ static int client_pid_cmp(const void *_a, const void *_b) static int (*client_cmp)(const void *, const void *) = client_last_cmp; -static void sort_clients(struct clients *clients) +static struct clients *sort_clients(struct clients *clients, + int (*cmp)(const void *, const void *)) { unsigned int active, free; struct client *c; int tmp; if (!clients) - return; + return clients; qsort(clients->client, clients->num_clients, sizeof(*clients->client), - client_cmp); + cmp); /* Trim excessive array space. */ active = 0; @@ -1011,9 +1012,98 @@ static void sort_clients(struct clients *clients) sizeof(*c)); } } + + return clients; +} + +static bool aggregate_pids = true; + +static struct clients *display_clients(struct clients *clients) +{ + struct client *ac, *c, *cp = NULL; + struct clients *aggregated; + int tmp, num = 0; + + if (!aggregate_pids) + goto out; + + /* Sort by pid first to make it easy to aggregate while walking. */ + sort_clients(clients, client_pid_cmp); + + aggregated = calloc(1, sizeof(*clients)); + assert(aggregated); + + ac = calloc(clients->num_clients, sizeof(*c)); + assert(ac); + + aggregated->num_classes = clients->num_classes; + aggregated->class = clients->class; + aggregated->client = ac; + + for_each_client(clients, c, tmp) { + unsigned int i; + + if (c->status == FREE) + break; + + assert(c->status == ALIVE); + + if ((cp && c->pid != cp->pid) || !cp) { + ac = &aggregated->client[num++]; + + /* New pid. */ + ac->clients = aggregated; + ac->status = ALIVE; + ac->id = -c->pid; + ac->pid = c->pid; + ac->busy_root = -1; + ac->sysfs_root = -1; + strcpy(ac->name, c->name); + strcpy(ac->print_name, c->print_name); + ac->engines = c->engines; + ac->val = calloc(clients->num_classes, + sizeof(ac->val[0])); + assert(ac->val); + ac->samples = 1; + } + + cp = c; + + if (c->samples < 2) + continue; + + ac->samples = 2; /* All what matters for display. */ + ac->total_runtime += c->total_runtime; + ac->last_runtime += c->last_runtime; + + for (i = 0; i < clients->num_classes; i++) + ac->val[i] += c->val[i]; + } + + aggregated->num_clients = num; + aggregated->active_clients = num; + + clients = aggregated; + +out: + return sort_clients(clients, client_cmp); } -static void scan_clients(struct clients *clients) +static void free_clients(struct clients *clients) +{ + struct client *c; + unsigned int tmp; + + for_each_client(clients, c, tmp) { + free(c->val); + free(c->last); + } + + free(clients->client); + free(clients); +} + +static struct clients *scan_clients(struct clients *clients) { struct dirent *dent; struct client *c; @@ -1022,7 +1112,7 @@ static void scan_clients(struct clients *clients) DIR *d; if (!clients) - return; + return clients; for_each_client(clients, c, tmp) { assert(c->status != PROBE); @@ -1034,7 +1124,7 @@ static void scan_clients(struct clients *clients) d = opendir(clients->sysfs_root); if (!d) - return; + return clients; while ((dent = readdir(d)) != NULL) { char name[24], pid[24]; @@ -1077,7 +1167,7 @@ static void scan_clients(struct clients *clients) break; } - sort_clients(clients); + return display_clients(clients); } static const char *bars[] = { " ", "▏", "▎", "▍", "▌", "▋", "▊", "▉", "█" }; @@ -2177,11 +2267,16 @@ static void select_client_sort(void) }; static unsigned int client_sort; +bump: if (++client_sort >= ARRAY_SIZE(cmp)) client_sort = 0; client_cmp = cmp[client_sort].cmp; header_msg = cmp[client_sort].msg; + + /* Sort by client id makes no sense with pid aggregation. */ + if (aggregate_pids && client_cmp == client_id_cmp) + goto bump; } static void process_stdin(unsigned int timeout_us) @@ -2227,6 +2322,13 @@ static void process_stdin(unsigned int timeout_us) case 's': select_client_sort(); break; + case 'H': + aggregate_pids ^= true; + if (aggregate_pids) + header_msg = "Aggregating clients."; + else + header_msg = "Showing individual clients."; + break; }; } } @@ -2378,6 +2480,7 @@ int main(int argc, char **argv) codename = igt_device_get_pretty_name(&card, false); while (!stop_top) { + struct clients *disp_clients; bool consumed = false; int j, lines = 0; struct winsize ws; @@ -2400,7 +2503,7 @@ int main(int argc, char **argv) pmu_sample(engines); t = (double)(engines->ts.cur - engines->ts.prev) / 1e9; - scan_clients(clients); + disp_clients = scan_clients(clients); if (stop_top) break; @@ -2416,14 +2519,14 @@ int main(int argc, char **argv) lines = print_engines(engines, t, lines, con_w, con_h); - if (clients) { + if (disp_clients) { int class_w; - lines = print_clients_header(clients, lines, + lines = print_clients_header(disp_clients, lines, con_w, con_h, &class_w); - for_each_client(clients, c, j) { + for_each_client(disp_clients, c, j) { assert(c->status != PROBE); if (c->status != ALIVE) break; /* Active clients are first in the array. */ @@ -2437,8 +2540,9 @@ int main(int argc, char **argv) &class_w); } - lines = print_clients_footer(clients, t, lines, - con_w, con_h); + lines = print_clients_footer(disp_clients, t, + lines, con_w, + con_h); } pops->close_struct(); @@ -2447,6 +2551,9 @@ int main(int argc, char **argv) if (stop_top) break; + if (disp_clients != clients) + free_clients(disp_clients); + if (output_mode == INTERACTIVE) process_stdin(period_us); else -- 2.27.0 _______________________________________________ Intel-gfx mailing list Intel-gfx@lists.freedesktop.org https://lists.freedesktop.org/mailman/listinfo/intel-gfx
WARNING: multiple messages have this Message-ID (diff)
From: Tvrtko Ursulin <tvrtko.ursulin@linux.intel.com> To: igt-dev@lists.freedesktop.org Cc: Intel-gfx@lists.freedesktop.org, Tvrtko Ursulin <tvrtko.ursulin@intel.com> Subject: [igt-dev] [PATCH i-g-t 2/3] intel_gpu_top: Aggregate clients by PID by default Date: Wed, 10 Feb 2021 11:12:56 +0000 [thread overview] Message-ID: <20210210111256.63625-1-tvrtko.ursulin@linux.intel.com> (raw) In-Reply-To: <20210210093756.61424-2-tvrtko.ursulin@linux.intel.com> From: Tvrtko Ursulin <tvrtko.ursulin@intel.com> Implement a default view where clients are aggregated by their PID. Toggled by pressing 'H' similar to top(1). v2: * Fix memory leak. v3: * Do not allow sort by client id in aggregated mode. * Tweak sort criteria and sorting decisions. (Chris) v4: * More tweaks to code flow. (Chris) Signed-off-by: Tvrtko Ursulin <tvrtko.ursulin@intel.com> --- man/intel_gpu_top.rst | 1 + tools/intel_gpu_top.c | 133 +++++++++++++++++++++++++++++++++++++----- 2 files changed, 121 insertions(+), 13 deletions(-) diff --git a/man/intel_gpu_top.rst b/man/intel_gpu_top.rst index b145d85c0440..20658e291db0 100644 --- a/man/intel_gpu_top.rst +++ b/man/intel_gpu_top.rst @@ -58,6 +58,7 @@ Supported keys: 'n' Toggle display of numeric client busyness overlay. 's' Toggle between sort modes (runtime, total runtime, pid, client id). 'i' Toggle display of clients which used no GPU time. + 'H' Toggle between per PID aggregation and individual clients. DEVICE SELECTION ================ diff --git a/tools/intel_gpu_top.c b/tools/intel_gpu_top.c index 63ef77056341..e7f696110be8 100644 --- a/tools/intel_gpu_top.c +++ b/tools/intel_gpu_top.c @@ -979,17 +979,18 @@ static int client_pid_cmp(const void *_a, const void *_b) static int (*client_cmp)(const void *, const void *) = client_last_cmp; -static void sort_clients(struct clients *clients) +static struct clients *sort_clients(struct clients *clients, + int (*cmp)(const void *, const void *)) { unsigned int active, free; struct client *c; int tmp; if (!clients) - return; + return clients; qsort(clients->client, clients->num_clients, sizeof(*clients->client), - client_cmp); + cmp); /* Trim excessive array space. */ active = 0; @@ -1011,9 +1012,98 @@ static void sort_clients(struct clients *clients) sizeof(*c)); } } + + return clients; +} + +static bool aggregate_pids = true; + +static struct clients *display_clients(struct clients *clients) +{ + struct client *ac, *c, *cp = NULL; + struct clients *aggregated; + int tmp, num = 0; + + if (!aggregate_pids) + goto out; + + /* Sort by pid first to make it easy to aggregate while walking. */ + sort_clients(clients, client_pid_cmp); + + aggregated = calloc(1, sizeof(*clients)); + assert(aggregated); + + ac = calloc(clients->num_clients, sizeof(*c)); + assert(ac); + + aggregated->num_classes = clients->num_classes; + aggregated->class = clients->class; + aggregated->client = ac; + + for_each_client(clients, c, tmp) { + unsigned int i; + + if (c->status == FREE) + break; + + assert(c->status == ALIVE); + + if ((cp && c->pid != cp->pid) || !cp) { + ac = &aggregated->client[num++]; + + /* New pid. */ + ac->clients = aggregated; + ac->status = ALIVE; + ac->id = -c->pid; + ac->pid = c->pid; + ac->busy_root = -1; + ac->sysfs_root = -1; + strcpy(ac->name, c->name); + strcpy(ac->print_name, c->print_name); + ac->engines = c->engines; + ac->val = calloc(clients->num_classes, + sizeof(ac->val[0])); + assert(ac->val); + ac->samples = 1; + } + + cp = c; + + if (c->samples < 2) + continue; + + ac->samples = 2; /* All what matters for display. */ + ac->total_runtime += c->total_runtime; + ac->last_runtime += c->last_runtime; + + for (i = 0; i < clients->num_classes; i++) + ac->val[i] += c->val[i]; + } + + aggregated->num_clients = num; + aggregated->active_clients = num; + + clients = aggregated; + +out: + return sort_clients(clients, client_cmp); } -static void scan_clients(struct clients *clients) +static void free_clients(struct clients *clients) +{ + struct client *c; + unsigned int tmp; + + for_each_client(clients, c, tmp) { + free(c->val); + free(c->last); + } + + free(clients->client); + free(clients); +} + +static struct clients *scan_clients(struct clients *clients) { struct dirent *dent; struct client *c; @@ -1022,7 +1112,7 @@ static void scan_clients(struct clients *clients) DIR *d; if (!clients) - return; + return clients; for_each_client(clients, c, tmp) { assert(c->status != PROBE); @@ -1034,7 +1124,7 @@ static void scan_clients(struct clients *clients) d = opendir(clients->sysfs_root); if (!d) - return; + return clients; while ((dent = readdir(d)) != NULL) { char name[24], pid[24]; @@ -1077,7 +1167,7 @@ static void scan_clients(struct clients *clients) break; } - sort_clients(clients); + return display_clients(clients); } static const char *bars[] = { " ", "▏", "▎", "▍", "▌", "▋", "▊", "▉", "█" }; @@ -2177,11 +2267,16 @@ static void select_client_sort(void) }; static unsigned int client_sort; +bump: if (++client_sort >= ARRAY_SIZE(cmp)) client_sort = 0; client_cmp = cmp[client_sort].cmp; header_msg = cmp[client_sort].msg; + + /* Sort by client id makes no sense with pid aggregation. */ + if (aggregate_pids && client_cmp == client_id_cmp) + goto bump; } static void process_stdin(unsigned int timeout_us) @@ -2227,6 +2322,13 @@ static void process_stdin(unsigned int timeout_us) case 's': select_client_sort(); break; + case 'H': + aggregate_pids ^= true; + if (aggregate_pids) + header_msg = "Aggregating clients."; + else + header_msg = "Showing individual clients."; + break; }; } } @@ -2378,6 +2480,7 @@ int main(int argc, char **argv) codename = igt_device_get_pretty_name(&card, false); while (!stop_top) { + struct clients *disp_clients; bool consumed = false; int j, lines = 0; struct winsize ws; @@ -2400,7 +2503,7 @@ int main(int argc, char **argv) pmu_sample(engines); t = (double)(engines->ts.cur - engines->ts.prev) / 1e9; - scan_clients(clients); + disp_clients = scan_clients(clients); if (stop_top) break; @@ -2416,14 +2519,14 @@ int main(int argc, char **argv) lines = print_engines(engines, t, lines, con_w, con_h); - if (clients) { + if (disp_clients) { int class_w; - lines = print_clients_header(clients, lines, + lines = print_clients_header(disp_clients, lines, con_w, con_h, &class_w); - for_each_client(clients, c, j) { + for_each_client(disp_clients, c, j) { assert(c->status != PROBE); if (c->status != ALIVE) break; /* Active clients are first in the array. */ @@ -2437,8 +2540,9 @@ int main(int argc, char **argv) &class_w); } - lines = print_clients_footer(clients, t, lines, - con_w, con_h); + lines = print_clients_footer(disp_clients, t, + lines, con_w, + con_h); } pops->close_struct(); @@ -2447,6 +2551,9 @@ int main(int argc, char **argv) if (stop_top) break; + if (disp_clients != clients) + free_clients(disp_clients); + if (output_mode == INTERACTIVE) process_stdin(period_us); else -- 2.27.0 _______________________________________________ igt-dev mailing list igt-dev@lists.freedesktop.org https://lists.freedesktop.org/mailman/listinfo/igt-dev
next prev parent reply other threads:[~2021-02-10 11:13 UTC|newest] Thread overview: 20+ messages / expand[flat|nested] mbox.gz Atom feed top 2021-02-10 9:37 [Intel-gfx] [PATCH i-g-t 1/3] intel_gpu_top: Wrap interactive header Tvrtko Ursulin 2021-02-10 9:37 ` [igt-dev] " Tvrtko Ursulin 2021-02-10 9:37 ` [Intel-gfx] [PATCH i-g-t 2/3] intel_gpu_top: Aggregate clients by PID by default Tvrtko Ursulin 2021-02-10 9:44 ` Tvrtko Ursulin 2021-02-10 10:35 ` [Intel-gfx] [igt-dev] " Chris Wilson 2021-02-10 10:35 ` Chris Wilson 2021-02-10 10:55 ` [Intel-gfx] " Tvrtko Ursulin 2021-02-10 10:55 ` Tvrtko Ursulin 2021-02-10 11:03 ` [Intel-gfx] " Chris Wilson 2021-02-10 10:53 ` [Intel-gfx] " Tvrtko Ursulin 2021-02-10 11:06 ` Chris Wilson 2021-02-10 11:06 ` [igt-dev] " Chris Wilson 2021-02-10 11:12 ` Tvrtko Ursulin [this message] 2021-02-10 11:12 ` [igt-dev] " Tvrtko Ursulin 2021-02-10 9:37 ` [Intel-gfx] [PATCH i-g-t 3/3] intel_gpu_top: Interactive help screen Tvrtko Ursulin 2021-02-10 9:37 ` [igt-dev] " Tvrtko Ursulin 2021-02-10 10:36 ` [Intel-gfx] " Chris Wilson 2021-02-10 10:36 ` Chris Wilson 2021-02-10 10:37 ` [Intel-gfx] [PATCH i-g-t 1/3] intel_gpu_top: Wrap interactive header Chris Wilson 2021-02-10 11:35 ` [igt-dev] ✗ Fi.CI.BUILD: failure for series starting with [i-g-t,1/3] intel_gpu_top: Wrap interactive header (rev4) Patchwork
Reply instructions: You may reply publicly to this message via plain-text email using any one of the following methods: * Save the following mbox file, import it into your mail client, and reply-to-all from there: mbox Avoid top-posting and favor interleaved quoting: https://en.wikipedia.org/wiki/Posting_style#Interleaved_style * Reply using the --to, --cc, and --in-reply-to switches of git-send-email(1): git send-email \ --in-reply-to=20210210111256.63625-1-tvrtko.ursulin@linux.intel.com \ --to=tvrtko.ursulin@linux.intel.com \ --cc=Intel-gfx@lists.freedesktop.org \ --cc=igt-dev@lists.freedesktop.org \ /path/to/YOUR_REPLY https://kernel.org/pub/software/scm/git/docs/git-send-email.html * If your mail client supports setting the In-Reply-To header via mailto: links, try the mailto: linkBe sure your reply has a Subject: header at the top and a blank line before the message body.
This is an external index of several public inboxes, see mirroring instructions on how to clone and mirror all data and code used by this external index.