ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

spdk_top: Add poller run counter

Browse Source 
Signed-off-by: Maciej Szwed <maciej.szwed@intel.com>
Change-Id: I88c6621fc062020b9fbc1ca2357ce7d7db7adcfa
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/1175
Community-CI: Mellanox Build Bot
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
This commit is contained in:
Maciej Szwed 2020-03-06 10:39:06 +01:00 committed by Tomasz Zawadzki
parent c922ce09ae
commit cc627e6364
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
app/spdk_top/spdk_top.c
View File

@ -110,6 +110,7 @@ static struct col_desc g_col_desc[NUMBER_OF_TABS][TABS_COL_COUNT] = {
{ {.name = "Poller name", .max_data_string = MAX_POLLER_NAME_LEN}, { {.name = "Poller name", .max_data_string = MAX_POLLER_NAME_LEN},
{.name = "Type", .max_data_string = MAX_POLLER_TYPE_STR_LEN}, {.name = "Type", .max_data_string = MAX_POLLER_TYPE_STR_LEN},
{.name = "On thread", .max_data_string = MAX_THREAD_NAME_LEN}, {.name = "On thread", .max_data_string = MAX_THREAD_NAME_LEN},
{.name = "Run count", .max_data_string = MAX_TIME_STR_LEN},
{.name = (char *)NULL} {.name = (char *)NULL}
}, },
{ {.name = "Core", .max_data_string = MAX_CORE_STR_LEN}, { {.name = "Core", .max_data_string = MAX_CORE_STR_LEN},
@ -718,6 +719,15 @@ sort_pollers(const void *p1, const void *p2, void *arg)
case 2: /* Sort by thread */ case 2: /* Sort by thread */
rc = strcmp(poller1->thread_name, poller2->thread_name); rc = strcmp(poller1->thread_name, poller2->thread_name);
break; break;
case 3: /* Sort by run counter */
if (poller2->run_count > poller1->run_count) {
rc = 1;
} else if (poller2->run_count < poller1->run_count) {
rc = -1;
} else {
rc = 0;
}
break;
default: default:
rc = 0; rc = 0;
break; break;
@ -749,6 +759,7 @@ refresh_pollers_tab(void)
uint64_t i, count = 0; uint64_t i, count = 0;
uint16_t col, j; uint16_t col, j;
enum sort_type sorting; enum sort_type sorting;
char run_count[MAX_TIME_STR_LEN];
struct rpc_poller_info *pollers[RPC_MAX_POLLERS]; struct rpc_poller_info *pollers[RPC_MAX_POLLERS];
for (i = 0; i < g_pollers_stats.pollers_threads.threads_count; i++) { for (i = 0; i < g_pollers_stats.pollers_threads.threads_count; i++) {
@ -799,6 +810,13 @@ refresh_pollers_tab(void)
if (!col_desc[2].disabled) { if (!col_desc[2].disabled) {
print_max_len(g_tabs[POLLERS_TAB], TABS_DATA_START_ROW + i, col, col_desc[2].max_data_string, print_max_len(g_tabs[POLLERS_TAB], TABS_DATA_START_ROW + i, col, col_desc[2].max_data_string,
pollers[i]->thread_name); pollers[i]->thread_name);
col += col_desc[2].max_data_string + 1;
}
if (!col_desc[3].disabled) {
snprintf(run_count, MAX_TIME_STR_LEN, "%" PRIu64, pollers[i]->run_count);
print_max_len(g_tabs[POLLERS_TAB], TABS_DATA_START_ROW + i, col, col_desc[3].max_data_string,
run_count);
} }
} }
} }