d/numam-spdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

spdk_top: create local poller structure to fill with RPC data

Browse Source 
Create local structs to fill with RPC data, sort and then
copy into a global poller array inside get_pollers_data().

Signed-off-by: Krzysztof Karas <krzysztof.karas@intel.com>
Change-Id: I545392cbdc699e4d96f1d39611a6e694e209c25d
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/8234
Community-CI: Mellanox Build Bot
Community-CI: Broadcom CI <spdk-ci.pdl@broadcom.com>
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
This commit is contained in:
Krzysztof Karas 2021-06-02 10:12:29 +02:00 committed by Tomasz Zawadzki
parent d55eb1af28
commit c3e625ba2b
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
app/spdk_top/spdk_top.c
View File

@ -848,12 +848,24 @@ get_pollers_data(void)
struct spdk_jsonrpc_client_response *json_resp = NULL;
int rc = 0;
uint64_t i = 0;
uint32_t current_pollers_count;
struct rpc_poller_info pollers_info[RPC_MAX_POLLERS];
rc = rpc_send_req("thread_get_pollers", &json_resp);
if (rc) {
return rc;
}
/* Decode json */
memset(&pollers_info, 0, sizeof(pollers_info));
if (rpc_decode_pollers_threads_array(json_resp->result, pollers_info, &current_pollers_count)) {
rc = -EINVAL;
for (i = 0; i < current_pollers_count; i++) {
free_rpc_poller(&pollers_info[i]);
}
goto end;
}
pthread_mutex_lock(&g_thread_lock);
/* Save last run counter of each poller before updating g_pollers_stats. */
@ -867,13 +879,13 @@ get_pollers_data(void)
free_rpc_poller(&g_pollers_info[i]);
}
/* Decode json */
memset(&g_pollers_info, 0, sizeof(g_pollers_info));
if (rpc_decode_pollers_threads_array(json_resp->result, g_pollers_info, &g_last_pollers_count)) {
rc = -EINVAL;
}
g_last_pollers_count = current_pollers_count;
memcpy(&g_pollers_info, &pollers_info, sizeof(struct rpc_poller_info) * g_last_pollers_count);
pthread_mutex_unlock(&g_thread_lock);
end:
spdk_jsonrpc_client_free_response(json_resp);
return rc;
}