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 9C463A0C47; Tue, 12 Oct 2021 16:09:14 +0200 (CEST) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 7FD3C40E0F; Tue, 12 Oct 2021 16:09:14 +0200 (CEST) Received: from mga18.intel.com (mga18.intel.com [134.134.136.126]) by mails.dpdk.org (Postfix) with ESMTP id 32CD240151 for ; Tue, 12 Oct 2021 16:09:13 +0200 (CEST) X-IronPort-AV: E=McAfee;i="6200,9189,10134"; a="214102244" X-IronPort-AV: E=Sophos;i="5.85,367,1624345200"; d="scan'208";a="214102244" Received: from fmsmga001.fm.intel.com ([10.253.24.23]) by orsmga106.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 12 Oct 2021 07:05:54 -0700 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.85,367,1624345200"; d="scan'208";a="625962407" Received: from orsmsx606.amr.corp.intel.com ([10.22.229.19]) by fmsmga001.fm.intel.com with ESMTP; 12 Oct 2021 07:05:53 -0700 Received: from orsmsx608.amr.corp.intel.com (10.22.229.21) by ORSMSX606.amr.corp.intel.com (10.22.229.19) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256) id 15.1.2242.12; Tue, 12 Oct 2021 07:05:53 -0700 Received: from orsmsx609.amr.corp.intel.com (10.22.229.22) by ORSMSX608.amr.corp.intel.com (10.22.229.21) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256) id 15.1.2242.12; Tue, 12 Oct 2021 07:05:52 -0700 Received: from ORSEDG601.ED.cps.intel.com (10.7.248.6) by orsmsx609.amr.corp.intel.com (10.22.229.22) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256) id 15.1.2242.12 via Frontend Transport; Tue, 12 Oct 2021 07:05:52 -0700 Received: from NAM10-DM6-obe.outbound.protection.outlook.com (104.47.58.105) by edgegateway.intel.com (134.134.137.102) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.1.2242.12; Tue, 12 Oct 2021 07:05:52 -0700 ARC-Seal: i=1; a=rsa-sha256; s=arcselector9901; d=microsoft.com; cv=none; b=NlL7V8K/XH+t+wwiCbUdVCroY4aKLl56Sf9X9IvBU3OKhUdWvnxh0okJQdN/awdDZETRknq4KqAKNuPdjUeI6kW9+l4t2shC20cXwknuUpb2r4cEGF24rxoOLlDM2f8RTL7I9Vu3yDZT2sqvl2g6Qq4ropJ3/tGsAhn5zs2tc2X2wGjpFXYXpg3E00yG6xRMprMSg9/K6jYdjBcpTOQPRHd5/d32I8b2QevhyqAe6hXxkcACHv5aW0rJn6Ajwn84qqjzLEP2t6B3tpKNuKc98idExbKzj3V5xrSSAldRE6oCVrZ7w5/0tI802WRjGKVDiY+ioTFQrOiS/yAeW/cXpQ== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com; s=arcselector9901; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-AntiSpam-MessageData-ChunkCount:X-MS-Exchange-AntiSpam-MessageData-0:X-MS-Exchange-AntiSpam-MessageData-1; bh=5ZZewthXLpxkVk11adPq2Y0Syu7q5l0Ip+az9qsRKqA=; b=hgWCyKVrGe62eJ0D7B7vpEPVdflrnKpaPiX6BRqZejHBjs1V4SVubMg1Db3NKU9okEI/GWJ+YDBIaBJxbeOQHcAAU5GZGRJvu836R50vlD6j/yLvPb+qPWHcbajoP5BjdMi1NAQM5nkDZAtXh99snDR2wCmy/YmXhTblFqsblSoB/P1EOSs46HXAPpankiF+e++34rg88n/4tK9aWeKeXnCWSYQ5wXdTElNyx+yPCARmyVDAybE+RxqMY7UnvAeKbDOKva04IryKS3xV9QEfIk6bA9xgHvOhg+2bmkoq6Q3WKT163rqXbGs7PrZO1xjk6LuBHKw7rsrNLIkDu4BqWQ== ARC-Authentication-Results: i=1; mx.microsoft.com 1; spf=pass smtp.mailfrom=intel.com; dmarc=pass action=none header.from=intel.com; dkim=pass header.d=intel.com; arc=none DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=intel.onmicrosoft.com; s=selector2-intel-onmicrosoft-com; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck; bh=5ZZewthXLpxkVk11adPq2Y0Syu7q5l0Ip+az9qsRKqA=; b=V0UdGf97QOcJlKUqVtdde3jkSJD7MCY6fp8q2Cusz3oGkpafxQWGQtrfCqPjD+XBJBClJMB+3R9Sk5HnSvSY+UJIMGjGRqAvT2P5PbUoWke3eIkP5s+QBHsrrLQQmhXuQ0gLar+vPSOnRGlkmLYtc+4f1lyXtDlh+sW2qO5mjSI= Received: from DM6PR11MB3868.namprd11.prod.outlook.com (2603:10b6:5:19f::13) by DM5PR11MB1691.namprd11.prod.outlook.com (2603:10b6:3:b::20) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.4587.25; Tue, 12 Oct 2021 14:05:51 +0000 Received: from DM6PR11MB3868.namprd11.prod.outlook.com ([fe80::89fd:9564:349a:c59e]) by DM6PR11MB3868.namprd11.prod.outlook.com ([fe80::89fd:9564:349a:c59e%4]) with mapi id 15.20.4587.026; Tue, 12 Oct 2021 14:05:51 +0000 From: "Naga Harish K, S V" To: "Jayatheerthan, Jay" , "Kundapura, Ganapati" , "jerinjacobk@gmail.com" , "dev@dpdk.org" CC: "Kinsella, Ray" , Thomas Monjalon , David Marchand Thread-Topic: [PATCH v3] eventdev/rx_adapter: add telemetry callbacks Thread-Index: AQHXv1N9LiQWIJcmVk2wXDxJ0ft+vqvPVXnwgAAP2RA= Date: Tue, 12 Oct 2021 14:05:51 +0000 Message-ID: References: <20211007134607.2351243-1-ganapati.kundapura@intel.com> <20211012102526.361419-1-ganapati.kundapura@intel.com> In-Reply-To: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: dlp-product: dlpe-windows dlp-reaction: no-action dlp-version: 11.6.200.16 authentication-results: intel.com; dkim=none (message not signed) header.d=none;intel.com; dmarc=none action=none header.from=intel.com; x-ms-publictraffictype: Email x-ms-office365-filtering-correlation-id: 62a7692b-ff52-4463-aa69-08d98d896626 x-ms-traffictypediagnostic: DM5PR11MB1691: x-ms-exchange-transport-forked: True x-microsoft-antispam-prvs: x-ms-oob-tlc-oobclassifiers: OLM:34; x-ms-exchange-senderadcheck: 1 x-ms-exchange-antispam-relay: 0 x-microsoft-antispam: BCL:0; x-microsoft-antispam-message-info: 8qDMr7lMUmIW84ti0LXcdPAeFtmrRwwT6EZ4khv/LmhyZUZTVHwZeQ0Ds1BColOGaHxpu/x/XBAyfmYLfFgLjZ04WzOpi6ZQ4SVNHB4khnAiaTMGOzbFifusLEQ9hok05gXAfea+ovqtcavjw7Cnz7M6BG/KGE4CSzHedEGBAtdDOHp2DgQbVJuf8Lqj2xvnm5OtvbIOdmhzB2myOL3FK0eIVwfDLuTvuA74PQapqQZETAh8YS0PHx+t4LFT7o2c1MKDe6M5QOQqZiBLLADNTNwQIs8r6y70xOym08iEHSNBAiBkU0ofajGx/pU4TEP2y9+jNCz3J3Z9b9uDw7+YJoc0Xl4MxPzI01NbUlTj84rIhICY2oV9EVoWuD4K22XkInwN5hBDeXH4pGsYNsHCkJg1wE8yriowVTOHuYEcIPRvL2eOYttJ58TceoMdWLlTasQZ55e4Q9MFxtG6a4vuwd2aMh+uSd1tYxv3voJwA6U0uRkgBCiMCG0DUedhbe4Uh/i1+/xTDol3Qak1KcrPow+diMCjp4045h5VtrT/Nhddp7jjmlhjJ8IXQOKkHp7/M8VpX0vui8GSPDF5QjOkCKzdAhfK7THh5+3DBFAsImku5AwJ/W9+dRs/4sIxXNBTooEfZEU4i0lB4482jRaOsKm2C5qdjy/8FpoKnPE7MkoT4DCiU4zJGJIUR6vP7+4D9n3ghm9UrlSAtOx5CEFzPg== x-forefront-antispam-report: CIP:255.255.255.255; CTRY:; LANG:en; SCL:1; SRV:; IPV:NLI; SFV:NSPM; H:DM6PR11MB3868.namprd11.prod.outlook.com; PTR:; CAT:NONE; SFS:(4636009)(366004)(4326008)(38100700002)(7696005)(6506007)(54906003)(2906002)(71200400001)(508600001)(55016002)(55236004)(26005)(52536014)(9686003)(122000001)(5660300002)(110136005)(53546011)(66946007)(76116006)(66476007)(186003)(8936002)(83380400001)(64756008)(8676002)(66556008)(86362001)(66446008)(316002)(38070700005)(33656002); DIR:OUT; SFP:1102; x-ms-exchange-antispam-messagedata-chunkcount: 1 x-ms-exchange-antispam-messagedata-0: =?us-ascii?Q?gRI/0/DOglEIDDmolN6ieaC+626tywa4RfTtB+P++WXXZ8Q9cEyrVSpTKgtZ?= =?us-ascii?Q?3ZVFS9BqVCbBGsllXzxdqWdyNKONLwrdHYK4LumnFtrPN1FzDSg3XTE90Y9Y?= =?us-ascii?Q?1m7qZTNJFPeJeZuv1G0kQwhRDGlrSJee1Z3edwlcl1XFkSpbQiJWyWZQO0K2?= =?us-ascii?Q?yyIJpfqilcHCyNglMUrad97tRf6YxcHDNiM7kbNV+3tklwaHLaiJ/sADXs9v?= =?us-ascii?Q?tltDuk/msqSLIa28N71cvsvM4njF8pji+yNAcu+urEdV9UcFug1OvJRS4HzS?= =?us-ascii?Q?VXAuXrGSM0/IligeCnBVubxF8XPPffxaD7mP3vTDDiDMzIhyPxBdft8NPDYX?= =?us-ascii?Q?G8lTDBWZmP1MoQvFPhek42qgsgKkbEX7YB3NFzqIksrr115gDyBH589LfyIQ?= =?us-ascii?Q?vypPGxh4DZi2iiEOB+APSCgkH1tFpvrbTj84o7GYErSFX7kFY2NwYcaygFHW?= =?us-ascii?Q?C0I5a01fwU4lFsZRdJZgWrLW10E/lIHxFImJ2LiJOcyzHgnPLLcvy3tOtbgg?= =?us-ascii?Q?MQfSKU9UWBN4eKWcQ05rzp70keSVhAxW+H3PxPgEMDxqtbaM1as1aK6v8qOE?= =?us-ascii?Q?3IbfDoIsbWMqcpcNBR3ao6GbyadV/4Y+pU9b8Pl503qyT/JC3HrszklsPaoP?= =?us-ascii?Q?RdJ2HCq/FBYpf03O3M/KEPFNYWkm2xrEt1kwA9nwqYrcbWkXrwzGeMktjoLU?= =?us-ascii?Q?SG2D/TeozU1EwgenBDAZy7ymSCEsEuICx/C2Jwf160Mi35h3VaNqwfmPwIpP?= =?us-ascii?Q?sW+4ol5Mb7qnXRo1Zh8EHncWGQTMSIKkS3LJXSG4NG587maenFx7U5Pkj+sT?= =?us-ascii?Q?2BBdx59WS9VF68lUmJQP4AyThhdlBWZfqOTu3pFVrB5/MfrzjuHr3K9ThyK9?= =?us-ascii?Q?0PTkYSkqiyvQk07Z9Aa79mTPd1LRWKUy663L1sk+S8M0KXV/HrSSv/kCbewM?= =?us-ascii?Q?GZL4jX4KMhWTB07UswNAatagkmqI05ot/5AkTxmcEFutUWFe4HoMRKMPNhtJ?= =?us-ascii?Q?tphpuGaUzPAn+Z2ofl8o9Ets0xx/ZM5fVEqudP3bA79q7ds3V5r3op2t9ate?= =?us-ascii?Q?8VdAv+7xgsws+XA/+NeJ2M+Obkjob0W/j/fscpze3VCxMZ2RXQTbkF/seQEi?= =?us-ascii?Q?LwJTUyuJKxbqPeN61upXrbUSXVyRwvCNWEp7M2ZJRWEu8mmFsb25VYfJw0vi?= =?us-ascii?Q?XsKE5U5s+KVFdfatcMT/V8P8gTCH+rzycSYh6ah6W2+/beWNuwc+cUwKJeJB?= =?us-ascii?Q?lWOeDeAd4hUeah75NKJXM5ViXiPSg1unzh64ZYRXQYcGHP5NFFGYJAhPQkyt?= =?us-ascii?Q?tLhCmd9JHtjoMUGJ2A5PGu7K?= Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-MS-Exchange-CrossTenant-AuthAs: Internal X-MS-Exchange-CrossTenant-AuthSource: DM6PR11MB3868.namprd11.prod.outlook.com X-MS-Exchange-CrossTenant-Network-Message-Id: 62a7692b-ff52-4463-aa69-08d98d896626 X-MS-Exchange-CrossTenant-originalarrivaltime: 12 Oct 2021 14:05:51.2152 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Hosted X-MS-Exchange-CrossTenant-id: 46c98d88-e344-4ed4-8496-4ed7712e255d X-MS-Exchange-CrossTenant-mailboxtype: HOSTED X-MS-Exchange-CrossTenant-userprincipalname: rk7/JBu6MfxAKh+EC10BKi5KXtzsSxmxNhY2Q3qd/C04W4+BBKFBD4J5PpR1HuemNClIzQne04+bEsGZiMtRYiqxVP8xpjHIZJPE0XL057o= X-MS-Exchange-Transport-CrossTenantHeadersStamped: DM5PR11MB1691 X-OriginatorOrg: intel.com Subject: Re: [dpdk-dev] [PATCH v3] eventdev/rx_adapter: add telemetry callbacks 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 Sender: "dev" > -----Original Message----- > From: dev On Behalf Of Jayatheerthan, Jay > Sent: Tuesday, October 12, 2021 6:39 PM > To: Kundapura, Ganapati ; > jerinjacobk@gmail.com; dev@dpdk.org > Cc: Kinsella, Ray ; Thomas Monjalon > ; David Marchand > Subject: Re: [dpdk-dev] [PATCH v3] eventdev/rx_adapter: add telemetry > callbacks >=20 > Acked by: Jay Jayatheerthan >=20 > + @Ray Kinsella @Thomas Monjalon @David Marchand >=20 > > -----Original Message----- > > From: Kundapura, Ganapati > > Sent: Tuesday, October 12, 2021 3:55 PM > > To: jerinjacobk@gmail.com; dev@dpdk.org > > Cc: Jayatheerthan, Jay > > Subject: [PATCH v3] eventdev/rx_adapter: add telemetry callbacks > > > > Added telemetry callbacks to get Rx adapter stats, reset stats and to > > get Rx queue config information. > > > > Signed-off-by: Ganapati Kundapura > > --- > > v3: > > * Updated release notes > > * Addressed review comments > > > > v2: > > * Fixed checkpatch warning > > --- > > > > diff --git a/doc/guides/rel_notes/release_21_11.rst > > b/doc/guides/rel_notes/release_21_11.rst > > index dfc2cbd..9955e52 100644 > > --- a/doc/guides/rel_notes/release_21_11.rst > > +++ b/doc/guides/rel_notes/release_21_11.rst > > @@ -130,6 +130,10 @@ New Features > > * Added tests to validate packets hard expiry. > > * Added tests to verify tunnel header verification in IPsec inbound. > > > > +* **Updated rte_event_eth_rx_adapter_stats structure > > + * Added 'uint64_t rx_event_buf_count' > > + * Added 'uint64_t rx_event_buf_size' > > + > > > > Removed Items > > ------------- > > diff --git a/lib/eventdev/rte_event_eth_rx_adapter.c > > b/lib/eventdev/rte_event_eth_rx_adapter.c > > index 9ac976c..7e3bf62 100644 > > --- a/lib/eventdev/rte_event_eth_rx_adapter.c > > +++ b/lib/eventdev/rte_event_eth_rx_adapter.c > > @@ -18,6 +18,7 @@ > > #include > > #include > > #include > > +#include > > > > #include "rte_eventdev.h" > > #include "eventdev_pmd.h" > > @@ -2852,6 +2853,7 @@ rte_event_eth_rx_adapter_stats_get(uint8_t id, > > struct rte_event_eth_rx_adapter_stats *stats) { > > struct rte_event_eth_rx_adapter *rx_adapter; > > + struct rte_eth_event_enqueue_buffer *buf; > > struct rte_event_eth_rx_adapter_stats dev_stats_sum =3D { 0 }; > > struct rte_event_eth_rx_adapter_stats dev_stats; > > struct rte_eventdev *dev; > > @@ -2887,8 +2889,11 @@ rte_event_eth_rx_adapter_stats_get(uint8_t > id, > > if (rx_adapter->service_inited) > > *stats =3D rx_adapter->stats; > > > > + buf =3D &rx_adapter->event_enqueue_buffer; > > stats->rx_packets +=3D dev_stats_sum.rx_packets; > > stats->rx_enq_count +=3D dev_stats_sum.rx_enq_count; > > + stats->rx_event_buf_count =3D buf->count; When per Rx queue event buffer is used, there is a possibility of segfault = here Because of null pointer deference. > > + stats->rx_event_buf_size =3D buf->events_size; > > > > return 0; > > } > > @@ -3052,3 +3057,146 @@ > > rte_event_eth_rx_adapter_queue_conf_get(uint8_t id, > > > > return 0; > > } > > + > > +#define RXA_ADD_DICT(stats, s) rte_tel_data_add_dict_u64(d, #s, > > +stats.s) > > + > > +static int > > +handle_rxa_stats(const char *cmd __rte_unused, > > + const char *params, > > + struct rte_tel_data *d) > > +{ > > + uint8_t rx_adapter_id; > > + struct rte_event_eth_rx_adapter_stats rx_adptr_stats; > > + > > + if (params =3D=3D NULL || strlen(params) =3D=3D 0 || !isdigit(*params= )) > > + return -1; > > + > > + /* Get Rx adapter ID from parameter string */ > > + rx_adapter_id =3D atoi(params); > > + > RTE_EVENT_ETH_RX_ADAPTER_ID_VALID_OR_ERR_RET(rx_adapter > _id, > > +-EINVAL); > > + > > + /* Get Rx adapter stats */ > > + if (rte_event_eth_rx_adapter_stats_get(rx_adapter_id, > > + &rx_adptr_stats)) { > > + RTE_EDEV_LOG_ERR("Failed to get Rx adapter stats\n"); > > + return -1; > > + } > > + > > + rte_tel_data_start_dict(d); > > + rte_tel_data_add_dict_u64(d, "rx_adapter_id", rx_adapter_id); > > + RXA_ADD_DICT(rx_adptr_stats, rx_packets); > > + RXA_ADD_DICT(rx_adptr_stats, rx_poll_count); > > + RXA_ADD_DICT(rx_adptr_stats, rx_dropped); > > + RXA_ADD_DICT(rx_adptr_stats, rx_enq_retry); > > + RXA_ADD_DICT(rx_adptr_stats, rx_event_buf_count); > > + RXA_ADD_DICT(rx_adptr_stats, rx_event_buf_size); > > + RXA_ADD_DICT(rx_adptr_stats, rx_enq_count); > > + RXA_ADD_DICT(rx_adptr_stats, rx_enq_start_ts); > > + RXA_ADD_DICT(rx_adptr_stats, rx_enq_block_cycles); > > + RXA_ADD_DICT(rx_adptr_stats, rx_enq_end_ts); > > + RXA_ADD_DICT(rx_adptr_stats, rx_intr_packets); > > + > > + return 0; > > +} > > + > > +static int > > +handle_rxa_stats_reset(const char *cmd __rte_unused, > > + const char *params, > > + struct rte_tel_data *d __rte_unused) { > > + uint8_t rx_adapter_id; > > + > > + if (params =3D=3D NULL || strlen(params) =3D=3D 0 || ~isdigit(*params= )) > > + return -1; > > + > > + /* Get Rx adapter ID from parameter string */ > > + rx_adapter_id =3D atoi(params); > > + > RTE_EVENT_ETH_RX_ADAPTER_ID_VALID_OR_ERR_RET(rx_adapter > _id, > > +-EINVAL); > > + > > + /* Reset Rx adapter stats */ > > + if (rte_event_eth_rx_adapter_stats_reset(rx_adapter_id)) { > > + RTE_EDEV_LOG_ERR("Failed to reset Rx adapter stats\n"); > > + return -1; > > + } > > + > > + return 0; > > +} > > + > > +static int > > +handle_rxa_get_queue_conf(const char *cmd __rte_unused, > > + const char *params, > > + struct rte_tel_data *d) > > +{ > > + uint8_t rx_adapter_id; > > + uint16_t rx_queue_id; > > + int eth_dev_id; > > + char *token, *l_params; > > + struct rte_event_eth_rx_adapter_queue_conf queue_conf; > > + > > + if (params =3D=3D NULL || strlen(params) =3D=3D 0 || !isdigit(*params= )) > > + return -1; > > + > > + /* Get Rx adapter ID from parameter string */ > > + l_params =3D strdup(params); > > + token =3D strtok(l_params, ","); > > + rx_adapter_id =3D strtoul(token, NULL, 10); > > + > RTE_EVENT_ETH_RX_ADAPTER_ID_VALID_OR_ERR_RET(rx_adapter > _id, > > +-EINVAL); > > + > > + token =3D strtok(NULL, ","); > > + if (token =3D=3D NULL || strlen(token) =3D=3D 0 || !isdigit(*token)) > > + return -1; > > + > > + /* Get device ID from parameter string */ > > + eth_dev_id =3D strtoul(token, NULL, 10); > > + RTE_EVENTDEV_VALID_DEVID_OR_ERR_RET(eth_dev_id, -EINVAL); > > + > > + token =3D strtok(NULL, ","); > > + if (token =3D=3D NULL || strlen(token) =3D=3D 0 || !isdigit(*token)) > > + return -1; > > + > > + /* Get Rx queue ID from parameter string */ > > + rx_queue_id =3D strtoul(token, NULL, 10); > > + if (rx_queue_id >=3D rte_eth_devices[eth_dev_id].data- > >nb_rx_queues) { > > + RTE_EDEV_LOG_ERR("Invalid rx queue_id %u", > rx_queue_id); > > + return -EINVAL; > > + } > > + > > + token =3D strtok(NULL, "\0"); > > + if (token !=3D NULL) > > + RTE_EDEV_LOG_ERR("Extra parameters passed to eventdev" > > + " telemetry command, igrnoring"); > > + > > + if (rte_event_eth_rx_adapter_queue_conf_get(rx_adapter_id, > eth_dev_id, > > + rx_queue_id, > &queue_conf)) { > > + RTE_EDEV_LOG_ERR("Failed to get Rx adapter queue > config"); > > + return -1; > > + } > > + > > + rte_tel_data_start_dict(d); > > + rte_tel_data_add_dict_u64(d, "rx_adapter_id", rx_adapter_id); > > + rte_tel_data_add_dict_u64(d, "eth_dev_id", eth_dev_id); > > + rte_tel_data_add_dict_u64(d, "rx_queue_id", rx_queue_id); > > + RXA_ADD_DICT(queue_conf, rx_queue_flags); > > + RXA_ADD_DICT(queue_conf, servicing_weight); > > + RXA_ADD_DICT(queue_conf.ev, queue_id); > > + RXA_ADD_DICT(queue_conf.ev, sched_type); > > + RXA_ADD_DICT(queue_conf.ev, priority); > > + RXA_ADD_DICT(queue_conf.ev, flow_id); > > + > > + return 0; > > +} > > + > > +RTE_INIT(rxa_init_telemetry) > > +{ > > + rte_telemetry_register_cmd("/eventdev/rxa_stats", > > + handle_rxa_stats, > > + "Returns Rx adapter stats. Parameter: rxa_id"); > > + > > + rte_telemetry_register_cmd("/eventdev/rxa_stats_reset", > > + handle_rxa_stats_reset, > > + "Reset Rx adapter stats. Parameter: rxa_id"); > > + > > + rte_telemetry_register_cmd("/eventdev/rxa_queue_conf", > > + handle_rxa_get_queue_conf, > > + "Returns Rx queue config. Parameter: rxa_id, dev_id, > queue_id"); } > > diff --git a/lib/eventdev/rte_event_eth_rx_adapter.h > > b/lib/eventdev/rte_event_eth_rx_adapter.h > > index 70ca427..c4257e7 100644 > > --- a/lib/eventdev/rte_event_eth_rx_adapter.h > > +++ b/lib/eventdev/rte_event_eth_rx_adapter.h > > @@ -232,6 +232,10 @@ struct rte_event_eth_rx_adapter_stats { > > */ > > uint64_t rx_intr_packets; > > /**< Received packet count for interrupt mode Rx queues */ > > + uint64_t rx_event_buf_count; > > + /**< Rx event buffered count */ > > + uint64_t rx_event_buf_size; > > + /**< Rx event buffer size */ > > }; > > > > /** > > -- > > 2.6.4