From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from dpdk.org (dpdk.org [92.243.14.124]) by inbox.dpdk.org (Postfix) with ESMTP id 48ED6A057B; Thu, 2 Apr 2020 13:27:23 +0200 (CEST) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 56E0E1BEE6; Thu, 2 Apr 2020 13:27:06 +0200 (CEST) Received: from mellanox.co.il (mail-il-dmz.mellanox.com [193.47.165.129]) by dpdk.org (Postfix) with ESMTP id C0C3D1BEE0 for ; Thu, 2 Apr 2020 13:27:04 +0200 (CEST) Received: from Internal Mail-Server by MTLPINE1 (envelope-from matan@mellanox.com) with ESMTPS (AES256-SHA encrypted); 2 Apr 2020 14:27:04 +0300 Received: from pegasus07.mtr.labs.mlnx (pegasus07.mtr.labs.mlnx [10.210.16.112]) by labmailer.mlnx (8.13.8/8.13.8) with ESMTP id 032BQf1J026689; Thu, 2 Apr 2020 14:27:04 +0300 From: Matan Azrad To: dev@dpdk.org Cc: Viacheslav Ovsiienko , Shahaf Shuler , Maxime Coquelin Date: Thu, 2 Apr 2020 11:26:33 +0000 Message-Id: <1585826793-28709-5-git-send-email-matan@mellanox.com> X-Mailer: git-send-email 1.8.3.1 In-Reply-To: <1585826793-28709-1-git-send-email-matan@mellanox.com> References: <1585826793-28709-1-git-send-email-matan@mellanox.com> Subject: [dpdk-dev] [PATCH 4/4] examples/vdpa: add statistics show command X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Sender: "dev" A new vDPA driver feature was added to query the virtq statistics from the HW. Use this feature to show the HW queues statistics for the virtqs. Command description: stats X Y. X is the device ID. Y is the queue ID, Y=0xffff to show all the virtio queues statistics of the device X. Signed-off-by: Matan Azrad Acked-by: Viacheslav Ovsiienko --- doc/guides/sample_app_ug/vdpa.rst | 3 +- examples/vdpa/main.c | 78 +++++++++++++++++++++++++++++++++++++++ 2 files changed, 80 insertions(+), 1 deletion(-) diff --git a/doc/guides/sample_app_ug/vdpa.rst b/doc/guides/sample_app_ug/vdpa.rst index 745f196..d66a724 100644 --- a/doc/guides/sample_app_ug/vdpa.rst +++ b/doc/guides/sample_app_ug/vdpa.rst @@ -44,7 +44,8 @@ where 1. help: show help message 2. list: list all available vdpa devices 3. create: create a new vdpa port with socket file and vdpa device address - 4. quit: unregister vhost driver and exit the application + 4. stats: show statistics of virtio queues + 5. quit: unregister vhost driver and exit the application Take IFCVF driver for example: diff --git a/examples/vdpa/main.c b/examples/vdpa/main.c index d2e2cb7..1b8a9fd 100644 --- a/examples/vdpa/main.c +++ b/examples/vdpa/main.c @@ -18,6 +18,7 @@ #include #include #include +#include #include #define MAX_PATH_LEN 128 @@ -240,6 +241,7 @@ static void cmd_help_parsed(__attribute__((unused)) void *parsed_result, " help : Show interactive instructions.\n" " list : list all available vdpa devices.\n" " create : create a new vdpa port.\n" + " stats : show statistics of virtio queue, 0xffff for all.\n" " quit : exit vdpa sample app.\n" ); } @@ -363,6 +365,81 @@ static void cmd_create_vdpa_port_parsed(void *parsed_result, }, }; +/* *** STATS *** */ +struct cmd_stats_result { + cmdline_fixed_string_t stats; + uint16_t did; + uint16_t qid; +}; + +static void cmd_device_stats_parsed(void *parsed_result, struct cmdline *cl, + __attribute__((unused)) void *data) +{ + struct cmd_stats_result *res = parsed_result; + struct rte_vdpa_device *vdev = rte_vdpa_get_device(res->did); + struct rte_vdpa_queue_stats stats; + uint32_t first, last; + + if (!vdev) { + RTE_LOG(ERR, VDPA, "Invalid device id %" PRIu16 ".\n", + res->did); + return; + } + if (res->qid == 0xFFFF) { + first = 0; + last = rte_vhost_get_vring_num(vports[res->did].vid); + if (last == 0) { + RTE_LOG(ERR, VDPA, "Failed to get num of actual virtqs" + " for device id %d.\n", (int)res->did); + return; + } + last--; + } else { + first = res->qid; + last = res->qid; + } + cmdline_printf(cl, "\nDevice %d:\n", (int)res->did); + for (; first <= last; first++) { + memset(&stats, 0, sizeof(stats)); + if (rte_vdpa_get_stats((int)res->did, (int)first, &stats)) { + RTE_LOG(ERR, VDPA, "Failed to get vdpa queue statistics" + " for device id %d qid %d.\n", (int)res->did, + (int)first); + return; + } + cmdline_printf(cl, "\tVirtq %" PRIu32 + ":\n\t\tReceived descriptors: %16" PRIu64 + "\t\tCompleted desccriptors: %16" PRIu64 + "\n\t\tBad descriptors: %16" PRIu32 + "\t\tExceed max chain: %16" PRIu32 + "\n\t\tInvalid_buffers: %16" PRIu32 + "\t\tErrors: %16" PRIu32 + "\n", first, stats.received_desc, + stats.completed_desc, stats.bad_desc, + stats.exceed_max_chain, stats.invalid_buffer, + stats.errors); + } +} + +cmdline_parse_token_string_t cmd_device_stats_ = + TOKEN_STRING_INITIALIZER(struct cmd_stats_result, stats, "stats"); +cmdline_parse_token_num_t cmd_device_id = + TOKEN_NUM_INITIALIZER(struct cmd_stats_result, did, UINT32); +cmdline_parse_token_num_t cmd_queue_id = + TOKEN_NUM_INITIALIZER(struct cmd_stats_result, qid, UINT32); + +cmdline_parse_inst_t cmd_device_stats = { + .f = cmd_device_stats_parsed, + .data = NULL, + .help_str = "stats: show device statistics", + .tokens = { + (void *)&cmd_device_stats_, + (void *)&cmd_device_id, + (void *)&cmd_queue_id, + NULL, + }, +}; + /* *** QUIT *** */ struct cmd_quit_result { cmdline_fixed_string_t quit; @@ -392,6 +469,7 @@ static void cmd_quit_parsed(__attribute__((unused)) void *parsed_result, (cmdline_parse_inst_t *)&cmd_help, (cmdline_parse_inst_t *)&cmd_list_vdpa_devices, (cmdline_parse_inst_t *)&cmd_create_vdpa_port, + (cmdline_parse_inst_t *)&cmd_device_stats, (cmdline_parse_inst_t *)&cmd_quit, NULL, }; -- 1.8.3.1