From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id 893D142B2F; Thu, 18 May 2023 00:37:30 +0200 (CEST) Received: from mails.dpdk.org (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 2C79540E25; Thu, 18 May 2023 00:37:30 +0200 (CEST) Received: from mga01.intel.com (mga01.intel.com [192.55.52.88]) by mails.dpdk.org (Postfix) with ESMTP id 0F28140698 for ; Thu, 18 May 2023 00:37:27 +0200 (CEST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=intel.com; i=@intel.com; q=dns/txt; s=Intel; t=1684363048; x=1715899048; h=from:to:cc:subject:date:message-id:in-reply-to: references:mime-version:content-transfer-encoding; bh=lLZl3UBsV7ems3+1eq1qyHra1QlnJ0HRn4pp6QIEhKE=; b=UBvFy0MMm/ayW83kZjrjGes6PPG0J2rtgPPMJV3ABAvvRUaWCfr89W9d 5sRWY7bWyVe9q3afxKZxn/0R/MiuAcOUpa5PRXXwNJ+cpVi1btP9ES3qN jyR4PZUgO7cZyzpbXpY2LxkS7gEa2m7If99UHuBA7gqO77JaxqdiiF1Bx R7gfxi1eTvXgmv2HiQclbX5lpDiOV0aSVoguvDoV2i2U3Fq9Rr4rf1k2n 3cY8wzJ5Hpcw1fcP93nOrSkqaO7ibxAgTExKskpY3cIXQcJ5QQzsn+FjX 25SGS6ozGO98ptDRnUvYClpGWuPPI60Of6OCh8LaUVzlvnBCc3JVbTSwr A==; X-IronPort-AV: E=McAfee;i="6600,9927,10713"; a="380096750" X-IronPort-AV: E=Sophos;i="5.99,283,1677571200"; d="scan'208";a="380096750" Received: from orsmga007.jf.intel.com ([10.7.209.58]) by fmsmga101.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 17 May 2023 15:37:27 -0700 X-ExtLoop1: 1 X-IronPort-AV: E=McAfee;i="6600,9927,10713"; a="696058694" X-IronPort-AV: E=Sophos;i="5.99,283,1677571200"; d="scan'208";a="696058694" Received: from txanpdk02.an.intel.com ([10.123.117.76]) by orsmga007.jf.intel.com with ESMTP; 17 May 2023 15:37:26 -0700 From: Abdullah Sevincer To: dev@dpdk.org Cc: jerinj@marvell.com, reshma.pattan@intel.com, Abdullah Sevincer Subject: [PATCH v14] app/procinfo: display eventdev xstats Date: Wed, 17 May 2023 17:37:24 -0500 Message-Id: <20230517223724.2417630-1-abdullah.sevincer@intel.com> X-Mailer: git-send-email 2.25.1 In-Reply-To: <20230320022316.2298874-1-abdullah.sevincer@intel.com> References: <20230320022316.2298874-1-abdullah.sevincer@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org This commit extends proc-info application to display xstats for the eventdev devices. New command line arguments are introduced to display xstats for eventdev devices. The command example is like: For displaying a specific port stats (e.g. port 1): ./dpdk-proc-info -- --show-edev-port-xstats=1:0 If any xstats parameters for eventdev passed through proc-info command line, proc-info will only display requested eventdev data and exit. Users should not pass any eventdev xstats parameters if they desire to dump other proc-info data such as Rx/Tx descriptor dump. More information can be found in proc-info app doc. Signed-off-by: Abdullah Sevincer --- app/proc-info/main.c | 386 ++++++++++++++++++++++++++++++++- app/proc-info/meson.build | 2 +- doc/guides/tools/proc_info.rst | 32 ++- 3 files changed, 417 insertions(+), 3 deletions(-) diff --git a/app/proc-info/main.c b/app/proc-info/main.c index 53e852a07c..9975d6a646 100644 --- a/app/proc-info/main.c +++ b/app/proc-info/main.c @@ -40,6 +40,7 @@ #include #include #include +#include /* Maximum long option length for option parsing. */ #define MAX_LONG_OPT_SZ 64 @@ -121,6 +122,26 @@ static uint32_t enable_shw_module_eeprom; static uint32_t enable_shw_rx_desc_dump; static uint32_t enable_shw_tx_desc_dump; +/* Note: Port_queue_id in xstats APIs is 8 bits, so we have a maximum of + * 256 ports and queues for event_Dev + */ +#define MAX_PORTS_QUEUES 256 + +struct eventdev_params { + uint32_t show_eventdev; + uint8_t ports[MAX_PORTS_QUEUES]; + uint8_t queues[MAX_PORTS_QUEUES]; + uint8_t num_queues; + uint8_t num_ports; + uint32_t shw_all_queues; + uint32_t shw_all_ports; + uint32_t dump_xstats; + uint32_t reset_xstats; + uint32_t shw_device_xstats; +}; + +static struct eventdev_params eventdev_var[RTE_EVENT_MAX_DEVS]; + #define DESC_PARAM_NUM 3 struct desc_param { @@ -172,7 +193,12 @@ proc_info_usage(const char *prgname) "offset: The offset of the descriptor starting from tail. " "num: The number of the descriptors to dump.\n" " --iter-mempool=name: iterate mempool elements to display content\n" - " --dump-regs=file-prefix: dump registers to file with the file-prefix\n", + " --dump-regs=file-prefix: dump registers to file with the file-prefix\n" + " --show-edev-queue-xstats=queue_num:evdev_id or *:evdev_id to get queue xstats for specified queue or all queues;\n" + " --show-edev-port-xstats=port_num:evdev_id or *:evdev_id to get queue xstats for specified port or all ports;\n" + " --edev-dump-xstats=evdev_id to dump all event_dev xstats for specified eventdev device;\n" + " --edev-reset-xstats=evdev_id to reset event_dev xstats after reading;\n" + " --show-edev-device-xstats=evdev_id to get event_dev device xstats for specified eventdev device;\n", prgname); } @@ -236,6 +262,123 @@ parse_descriptor_param(char *list, struct desc_param *desc) return 0; } +static int +parse_eventdev_dump_xstats_params(char *list) +{ + uint8_t evdev_id; + evdev_id = (uint8_t)atoi(list); + + if (evdev_id >= RTE_EVENT_MAX_DEVS) { + printf("Invalid eventdev id, id should be between 0 - %d\n", RTE_EVENT_MAX_DEVS-1); + return -EINVAL; + } + + eventdev_var[evdev_id].dump_xstats = 1; + + if (!eventdev_var[evdev_id].show_eventdev) + eventdev_var[evdev_id].show_eventdev = 1; + + return 0; +} + +static int +parse_eventdev_reset_xstats_params(char *list) +{ + uint8_t evdev_id; + evdev_id = (uint8_t)atoi(list); + + if (evdev_id >= RTE_EVENT_MAX_DEVS) { + printf("Invalid eventdev id, id should be between 0 - %d\n", RTE_EVENT_MAX_DEVS-1); + return -EINVAL; + } + + eventdev_var[evdev_id].reset_xstats = 1; + + if (!eventdev_var[evdev_id].show_eventdev) + eventdev_var[evdev_id].show_eventdev = 1; + + return 0; +} + +static int +parse_eventdev_device_xstats_params(char *list) +{ + uint8_t evdev_id; + evdev_id = (uint8_t)atoi(list); + + if (evdev_id >= RTE_EVENT_MAX_DEVS) { + printf("Invalid eventdev id, id should be between 0 - %d\n", RTE_EVENT_MAX_DEVS-1); + return -EINVAL; + } + + eventdev_var[evdev_id].shw_device_xstats = 1; + + if (!eventdev_var[evdev_id].show_eventdev) + eventdev_var[evdev_id].show_eventdev = 1; + + return 0; +} + +static int +parse_eventdev_queue_xstats_params(char *list) +{ + uint8_t queue_id; + uint8_t evdev_id; + if (sscanf(list, "*:%hhu", &evdev_id) == 1) { + if (evdev_id >= RTE_EVENT_MAX_DEVS) { + printf("Invalid eventdev id, id should be between 0 - %d\n", + RTE_EVENT_MAX_DEVS-1); + return -EINVAL; + } + eventdev_var[evdev_id].shw_all_queues = 1; + } else if (sscanf(list, "%hhu:%hhu", &queue_id, &evdev_id) == 2) { + if (evdev_id >= RTE_EVENT_MAX_DEVS) { + printf("Invalid eventdev id, id should be between 0 - %d\n", + RTE_EVENT_MAX_DEVS-1); + return -EINVAL; + } + eventdev_var[evdev_id].queues[eventdev_var[evdev_id].num_queues] = queue_id; + eventdev_var[evdev_id].num_queues++; + } else { + return -EINVAL; + } + + if (!eventdev_var[evdev_id].show_eventdev) + eventdev_var[evdev_id].show_eventdev = 1; + + return 0; +} + +static int +parse_eventdev_port_xstats_params(char *list) +{ + uint8_t port_id; + uint8_t evdev_id; + if (sscanf(list, "*:%hhu", &evdev_id) == 1) { + if (evdev_id >= RTE_EVENT_MAX_DEVS) { + printf("Invalid eventdev id, id should be between 0 - %d\n", + RTE_EVENT_MAX_DEVS-1); + return -EINVAL; + } + eventdev_var[evdev_id].shw_all_ports = 1; + } else if (sscanf(list, "%hhu:%hhu", &port_id, &evdev_id) == 2) { + if (evdev_id >= RTE_EVENT_MAX_DEVS) { + printf("Invalid eventdev id, id should be between 0 - %d\n", + RTE_EVENT_MAX_DEVS-1); + return -EINVAL; + } + eventdev_var[evdev_id].ports[eventdev_var[evdev_id].num_ports] = port_id; + eventdev_var[evdev_id].num_ports++; + } else { + return -EINVAL; + } + + if (!eventdev_var[evdev_id].show_eventdev) + eventdev_var[evdev_id].show_eventdev = 1; + + return 0; +} + static int proc_info_preparse_args(int argc, char **argv) { @@ -302,6 +445,11 @@ proc_info_parse_args(int argc, char **argv) {"show-module-eeprom", 0, NULL, 0}, {"show-rx-descriptor", required_argument, NULL, 1}, {"show-tx-descriptor", required_argument, NULL, 1}, + {"show-edev-queue-xstats", required_argument, NULL, 0}, + {"show-edev-port-xstats", required_argument, NULL, 0}, + {"edev-dump-xstats", required_argument, NULL, 0}, + {"edev-reset-xstats", required_argument, NULL, 0}, + {"show-edev-device-xstats", required_argument, NULL, 0}, {NULL, 0, 0, 0} }; @@ -385,6 +533,47 @@ proc_info_parse_args(int argc, char **argv) else if (!strncmp(long_option[option_index].name, "show-module-eeprom", MAX_LONG_OPT_SZ)) enable_shw_module_eeprom = 1; + else if (!strncmp(long_option[option_index].name, + "edev-dump-xstats", MAX_LONG_OPT_SZ)) { + int ret = parse_eventdev_dump_xstats_params(optarg); + if (ret < 0) { + fprintf(stderr, "Error parsing eventdev dump xstats params: %s\n", + strerror(-ret)); + return -1; + } + } else if (!strncmp(long_option[option_index].name, + "edev-reset-xstats", MAX_LONG_OPT_SZ)) { + int ret = parse_eventdev_reset_xstats_params(optarg); + if (ret < 0) { + fprintf(stderr, "Error parsing eventdev reset xstats params: %s\n", + strerror(-ret)); + return -1; + } + } else if (!strncmp(long_option[option_index].name, + "show-edev-device-xstats", MAX_LONG_OPT_SZ)) { + int ret = parse_eventdev_device_xstats_params(optarg); + if (ret < 0) { + fprintf(stderr, "Error parsing eventdev reset xstats params: %s\n", + strerror(-ret)); + return -1; + } + } else if (!strncmp(long_option[option_index].name, + "show-edev-queue-xstats", MAX_LONG_OPT_SZ)) { + int ret = parse_eventdev_queue_xstats_params(optarg); + if (ret < 0) { + fprintf(stderr, "Error parsing eventdev queue xstats params: %s\n", + strerror(-ret)); + return -1; + } + } else if (!strncmp(long_option[option_index].name, + "show-edev-port-xstats", MAX_LONG_OPT_SZ)) { + int ret = parse_eventdev_port_xstats_params(optarg); + if (ret < 0) { + fprintf(stderr, "Error parsing eventdev port xstats params: %s\n", + strerror(-ret)); + return -1; + } + } break; case 1: /* Print xstat single value given by name*/ @@ -1744,6 +1933,198 @@ nic_tx_descriptor_display(uint16_t port_id, struct desc_param *desc) strerror(-ret)); } +static unsigned int +xstats_get_names_and_ids_size(uint8_t dev_id, + enum rte_event_dev_xstats_mode mode, + uint8_t queue_port_id) +{ + + int ret; + + /* Get amount of storage required */ + ret = rte_event_dev_xstats_names_get(dev_id, + mode, + queue_port_id, + NULL, /* names */ + NULL, /* ids */ + 0); /* num */ + + if (ret < 0) + rte_panic("rte_event_dev_xstats_names_get err %d\n", ret); + + return (unsigned int)ret; + +} + +static void +xstats_display(uint8_t dev_id, + enum rte_event_dev_xstats_mode mode, + uint8_t queue_port_id) +{ + int ret; + struct rte_event_dev_xstats_name *xstats_names; + uint64_t *ids; + uint64_t *values; + unsigned int size; + int i; + + size = xstats_get_names_and_ids_size(dev_id, mode, queue_port_id); + + if (size == 0) { + printf( + "No stats available for this item, mode=%d, queue_port_id=%d\n", + mode, queue_port_id); + return; + } + + /* Get memory to hold stat names, IDs, and values */ + xstats_names = malloc(sizeof(struct rte_event_dev_xstats_name) * size); + ids = malloc(sizeof(unsigned int) * size); + + if (!xstats_names || !ids) + rte_panic("unable to alloc memory for stats retrieval\n"); + + ret = rte_event_dev_xstats_names_get(dev_id, mode, queue_port_id, + xstats_names, ids, + size); + if (ret != (int)size) + rte_panic("rte_event_dev_xstats_names_get err %d\n", ret); + + values = malloc(sizeof(uint64_t) * size); + if (!values) + rte_panic("unable to alloc memory for stats retrieval\n"); + + ret = rte_event_dev_xstats_get(dev_id, mode, queue_port_id, + ids, values, size); + + if (ret != (int)size) + rte_panic("rte_event_dev_xstats_get err %d\n", ret); + + for (i = 0; i < (int)size; i++) { + printf("id %"PRIu64" %s = %"PRIu64"\n", + ids[i], &xstats_names[i].name[0], values[i]); + } + + free(values); + free(xstats_names); + free(ids); + +} + +static void +xstats_reset(uint8_t dev_id, + enum rte_event_dev_xstats_mode mode, + uint8_t queue_port_id) +{ + int ret; + struct rte_event_dev_xstats_name *xstats_names; + uint64_t *ids; + unsigned int size; + + size = xstats_get_names_and_ids_size(dev_id, mode, queue_port_id); + + if (size == 0) { + printf( + "No stats available for this item, mode=%d, queue_port_id=%d\n", + mode, queue_port_id); + return; + } + + /* Get memory to hold stat names, IDs, and values */ + xstats_names = malloc(sizeof(struct rte_event_dev_xstats_name) * size); + ids = malloc(sizeof(unsigned int) * size); + + if (!xstats_names || !ids) + rte_panic("unable to alloc memory for stats retrieval\n"); + + ret = rte_event_dev_xstats_names_get(dev_id, mode, queue_port_id, + xstats_names, ids, + size); + if (ret != (int)size) + rte_panic("rte_event_dev_xstats_names_get err %d\n", ret); + + rte_event_dev_xstats_reset(dev_id, mode, queue_port_id, + ids, size); + + free(xstats_names); + free(ids); + +} + +static int +process_eventdev_xstats(void) +{ + int i; + int j; + int processing_eventdev_xstats = 0; + + for (i = 0; i < RTE_EVENT_MAX_DEVS; i++) { + if (eventdev_var[i].show_eventdev == 1) { + + if (!processing_eventdev_xstats) + processing_eventdev_xstats = 1; + + if (i >= rte_event_dev_count()) + rte_panic("invalid event device %d\n", i); + + if (eventdev_var[i].dump_xstats) { + int ret = rte_event_dev_dump(i, stdout); + if (ret) + rte_panic("dump failed with err=%d\n", ret); + } + + if (eventdev_var[i].shw_device_xstats == 1) { + xstats_display(i, RTE_EVENT_DEV_XSTATS_DEVICE, 0); + + if (eventdev_var[i].reset_xstats == 1) + xstats_reset(i, RTE_EVENT_DEV_XSTATS_DEVICE, 0); + } + + if (eventdev_var[i].shw_all_ports == 1) { + for (j = 0; j < MAX_PORTS_QUEUES; j++) { + xstats_display(i, RTE_EVENT_DEV_XSTATS_PORT, j); + + if (eventdev_var[i].reset_xstats == 1) + xstats_reset(i, RTE_EVENT_DEV_XSTATS_PORT, j); + } + } else { + for (j = 0; j < eventdev_var[i].num_ports; j++) { + xstats_display(i, RTE_EVENT_DEV_XSTATS_PORT, + eventdev_var[i].ports[j]); + + if (eventdev_var[i].reset_xstats == 1) + xstats_reset(i, RTE_EVENT_DEV_XSTATS_PORT, + eventdev_var[i].ports[j]); + } + } + + if (eventdev_var[i].shw_all_queues == 1) { + for (j = 0; j < MAX_PORTS_QUEUES; j++) { + xstats_display(i, RTE_EVENT_DEV_XSTATS_QUEUE, j); + + if (eventdev_var[i].reset_xstats == 1) + xstats_reset(i, RTE_EVENT_DEV_XSTATS_QUEUE, j); + } + } else { + for (j = 0; j < eventdev_var[i].num_queues; j++) { + xstats_display(i, RTE_EVENT_DEV_XSTATS_QUEUE, + eventdev_var[i].queues[j]); + + if (eventdev_var[i].reset_xstats == 1) + xstats_reset(i, RTE_EVENT_DEV_XSTATS_QUEUE, + eventdev_var[i].queues[j]); + } + } + + } + } + + if (processing_eventdev_xstats) + return 1; + + return 0; +} + int main(int argc, char **argv) { @@ -1794,6 +2175,9 @@ main(int argc, char **argv) return 0; } + if (process_eventdev_xstats()) + return 0; + nb_ports = rte_eth_dev_count_avail(); if (nb_ports == 0) rte_exit(EXIT_FAILURE, "No Ethernet ports - bye\n"); diff --git a/app/proc-info/meson.build b/app/proc-info/meson.build index 1563ce656a..4f83f29a64 100644 --- a/app/proc-info/meson.build +++ b/app/proc-info/meson.build @@ -8,7 +8,7 @@ if is_windows endif sources = files('main.c') -deps += ['ethdev', 'security'] +deps += ['ethdev', 'security', 'eventdev'] if dpdk_conf.has('RTE_LIB_METRICS') deps += 'metrics' endif diff --git a/doc/guides/tools/proc_info.rst b/doc/guides/tools/proc_info.rst index cf3502a8cb..a79e504d67 100644 --- a/doc/guides/tools/proc_info.rst +++ b/doc/guides/tools/proc_info.rst @@ -22,7 +22,9 @@ The application has a number of command line options: --show-ring[=name] | --show-mempool[=name] | --iter-mempool=name | --show-port-private | --version | --firmware-version | --show-rss-reta | --show-module-eeprom | --show-rx-descriptor queue_id:offset:num | - --show-tx-descriptor queue_id:offset:num ] + --show-tx-descriptor queue_id:offset:num | --show-edev-queue-xstats=queue_num:evdev_id | + --show-edev-port-xstats=port_num :evdev_id | --edev-dump-xstats=evdev_id | + --edev-reset-xstats=evdev_id | --show-edev-device-xstats=evdev_id] Parameters ~~~~~~~~~~ @@ -101,6 +103,34 @@ queue_id: A Tx queue identifier on this port. offset: The offset of the descriptor starting from tail. num: The number of the descriptors to dump. +**--show-edev-queue-xstats queue_num:evdev_id** +The show-edev-queue-xstats parameter enables stats for specified queue or all queues. +queue_num: The queue number to get queue xstats for this specified queue or * for all queues. +evdev_id: Id of the eventdev device to display xstats. + +**--show-edev-port-xstats port_num:evdev_id** +The show-edev-port-xstats parameter enables stats for specified port or all ports. +port_num: The port number to get port xstats for this specified port or * for all ports. +evdev_id: Id of the eventdev device to display xstats. + +**--edev-dump-xstats evdev_id** +The edev-dump-xstats parameter dumps all eventdev stats. +evdev_id: Id of the eventdev device to display xstats. + +**--edev-reset-xstats evdev_id** +The edev-reset-xstats parameter resets eventdev xstats after reading. +evdev_id: Id of the eventdev device to display xstats. + +**--show-edev-device-xstats evdev_id** +The show-edev-device-xstats parameter displays eventdev device xstats. +evdev_id: Id of the eventdev device to display xstats. + +A typical command line usage for eventdev stats: + + .. code-block:: console + + ./dpdk-proc-info -- --show-edev-port-xstats=1:0 + Limitations ----------- -- 2.25.1