[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 <ganapati.kundapura@intel.com>
---
v3:
* Updated release notes
* Addressed review comments

v2:
* Fixed checkpatch warning
---
  

Acked by: Jay Jayatheerthan <jay.jayatheerthan@intel.com>

+ @Ray Kinsella @Thomas Monjalon  @David Marchand

> -----Original Message-----
> From: Kundapura, Ganapati <ganapati.kundapura@intel.com>
> Sent: Tuesday, October 12, 2021 3:55 PM
> To: jerinjacobk@gmail.com; dev@dpdk.org
> Cc: Jayatheerthan, Jay <jay.jayatheerthan@intel.com>
> 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 <ganapati.kundapura@intel.com>
> ---
> 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 <rte_thash.h>
>  #include <rte_interrupts.h>
>  #include <rte_mbuf_dyn.h>
> +#include <rte_telemetry.h>
> 
>  #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 = { 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 = rx_adapter->stats;
> 
> +	buf = &rx_adapter->event_enqueue_buffer;
>  	stats->rx_packets += dev_stats_sum.rx_packets;
>  	stats->rx_enq_count += dev_stats_sum.rx_enq_count;
> +	stats->rx_event_buf_count = buf->count;
> +	stats->rx_event_buf_size = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> +		return -1;
> +
> +	/* Get Rx adapter ID from parameter string */
> +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || ~isdigit(*params))
> +		return -1;
> +
> +	/* Get Rx adapter ID from parameter string */
> +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> +		return -1;
> +
> +	/* Get Rx adapter ID from parameter string */
> +	l_params = strdup(params);
> +	token = strtok(l_params, ",");
> +	rx_adapter_id = strtoul(token, NULL, 10);
> +	RTE_EVENT_ETH_RX_ADAPTER_ID_VALID_OR_ERR_RET(rx_adapter_id, -EINVAL);
> +
> +	token = strtok(NULL, ",");
> +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> +		return -1;
> +
> +	/* Get device ID from parameter string */
> +	eth_dev_id = strtoul(token, NULL, 10);
> +	RTE_EVENTDEV_VALID_DEVID_OR_ERR_RET(eth_dev_id, -EINVAL);
> +
> +	token = strtok(NULL, ",");
> +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> +		return -1;
> +
> +	/* Get Rx queue ID from parameter string */
> +	rx_queue_id = strtoul(token, NULL, 10);
> +	if (rx_queue_id >= 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 = strtok(NULL, "\0");
> +	if (token != 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
  

> -----Original Message-----
> From: dev <dev-bounces@dpdk.org> On Behalf Of Jayatheerthan, Jay
> Sent: Tuesday, October 12, 2021 6:39 PM
> To: Kundapura, Ganapati <Ganapati.Kundapura@intel.com>;
> jerinjacobk@gmail.com; dev@dpdk.org
> Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> <thomas@monjalon.net>; David Marchand <david.marchand@redhat.com>
> Subject: Re: [dpdk-dev] [PATCH v3] eventdev/rx_adapter: add telemetry
> callbacks
> 
> Acked by: Jay Jayatheerthan <jay.jayatheerthan@intel.com>
> 
> + @Ray Kinsella @Thomas Monjalon  @David Marchand
> 
> > -----Original Message-----
> > From: Kundapura, Ganapati <ganapati.kundapura@intel.com>
> > Sent: Tuesday, October 12, 2021 3:55 PM
> > To: jerinjacobk@gmail.com; dev@dpdk.org
> > Cc: Jayatheerthan, Jay <jay.jayatheerthan@intel.com>
> > 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 <ganapati.kundapura@intel.com>
> > ---
> > 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 <rte_thash.h>
> >  #include <rte_interrupts.h>
> >  #include <rte_mbuf_dyn.h>
> > +#include <rte_telemetry.h>
> >
> >  #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 = { 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 = rx_adapter->stats;
> >
> > +	buf = &rx_adapter->event_enqueue_buffer;
> >  	stats->rx_packets += dev_stats_sum.rx_packets;
> >  	stats->rx_enq_count += dev_stats_sum.rx_enq_count;
> > +	stats->rx_event_buf_count = 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 = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> > +		return -1;
> > +
> > +	/* Get Rx adapter ID from parameter string */
> > +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || ~isdigit(*params))
> > +		return -1;
> > +
> > +	/* Get Rx adapter ID from parameter string */
> > +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> > +		return -1;
> > +
> > +	/* Get Rx adapter ID from parameter string */
> > +	l_params = strdup(params);
> > +	token = strtok(l_params, ",");
> > +	rx_adapter_id = strtoul(token, NULL, 10);
> > +
> 	RTE_EVENT_ETH_RX_ADAPTER_ID_VALID_OR_ERR_RET(rx_adapter
> _id,
> > +-EINVAL);
> > +
> > +	token = strtok(NULL, ",");
> > +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> > +		return -1;
> > +
> > +	/* Get device ID from parameter string */
> > +	eth_dev_id = strtoul(token, NULL, 10);
> > +	RTE_EVENTDEV_VALID_DEVID_OR_ERR_RET(eth_dev_id, -EINVAL);
> > +
> > +	token = strtok(NULL, ",");
> > +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> > +		return -1;
> > +
> > +	/* Get Rx queue ID from parameter string */
> > +	rx_queue_id = strtoul(token, NULL, 10);
> > +	if (rx_queue_id >= 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 = strtok(NULL, "\0");
> > +	if (token != 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
  

Hi Harish,

> -----Original Message-----
> From: Naga Harish K, S V <s.v.naga.harish.k@intel.com>
> Sent: 12 October 2021 19:36
> To: Jayatheerthan, Jay <jay.jayatheerthan@intel.com>; Kundapura, Ganapati
> <ganapati.kundapura@intel.com>; jerinjacobk@gmail.com; dev@dpdk.org
> Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> <thomas@monjalon.net>; David Marchand <david.marchand@redhat.com>
> Subject: RE: [PATCH v3] eventdev/rx_adapter: add telemetry callbacks
> 
> 
> 
> > -----Original Message-----
> > From: dev <dev-bounces@dpdk.org> On Behalf Of Jayatheerthan, Jay
> > Sent: Tuesday, October 12, 2021 6:39 PM
> > To: Kundapura, Ganapati <Ganapati.Kundapura@intel.com>;
> > jerinjacobk@gmail.com; dev@dpdk.org
> > Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> > <thomas@monjalon.net>; David Marchand <david.marchand@redhat.com>
> > Subject: Re: [dpdk-dev] [PATCH v3] eventdev/rx_adapter: add telemetry
> > callbacks
> >
> > Acked by: Jay Jayatheerthan <jay.jayatheerthan@intel.com>
> >
> > + @Ray Kinsella @Thomas Monjalon  @David Marchand
> >
> > > -----Original Message-----
> > > From: Kundapura, Ganapati <ganapati.kundapura@intel.com>
> > > Sent: Tuesday, October 12, 2021 3:55 PM
> > > To: jerinjacobk@gmail.com; dev@dpdk.org
> > > Cc: Jayatheerthan, Jay <jay.jayatheerthan@intel.com>
> > > 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 <ganapati.kundapura@intel.com>
> > > ---
> > > 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 <rte_thash.h>
> > >  #include <rte_interrupts.h>
> > >  #include <rte_mbuf_dyn.h>
> > > +#include <rte_telemetry.h>
> > >
> > >  #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 = { 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 = rx_adapter->stats;
> > >
> > > +	buf = &rx_adapter->event_enqueue_buffer;
> > >  	stats->rx_packets += dev_stats_sum.rx_packets;
> > >  	stats->rx_enq_count += dev_stats_sum.rx_enq_count;
> > > +	stats->rx_event_buf_count = buf->count;
> 
> When per Rx queue event buffer is used, there is a possibility of segfault here
> Because of null pointer deference.
> 
Queue_id is not passed to rte_event_eth_rx_adapter_stats_get() and there's no way to 
retrieve the queue id to return the queue's event buffer size and count. We may need to 
loop through all the queue's in the adapter which requires changes in rte_event_eth_rx_adapter_stats
structure to hold event buffer size and count for all the queues.

Alternatively stats_get() can return event buffer size and count only if use_queue_event_buf = false
i.e only for adapter wide event buffer.

Do we need event buffer size and count in Rx adapter stats?

> > > +	stats->rx_event_buf_size = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> > > +		return -1;
> > > +
> > > +	/* Get Rx adapter ID from parameter string */
> > > +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || ~isdigit(*params))
> > > +		return -1;
> > > +
> > > +	/* Get Rx adapter ID from parameter string */
> > > +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> > > +		return -1;
> > > +
> > > +	/* Get Rx adapter ID from parameter string */
> > > +	l_params = strdup(params);
> > > +	token = strtok(l_params, ",");
> > > +	rx_adapter_id = strtoul(token, NULL, 10);
> > > +
> > 	RTE_EVENT_ETH_RX_ADAPTER_ID_VALID_OR_ERR_RET(rx_adapter
> > _id,
> > > +-EINVAL);
> > > +
> > > +	token = strtok(NULL, ",");
> > > +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> > > +		return -1;
> > > +
> > > +	/* Get device ID from parameter string */
> > > +	eth_dev_id = strtoul(token, NULL, 10);
> > > +	RTE_EVENTDEV_VALID_DEVID_OR_ERR_RET(eth_dev_id, -EINVAL);
> > > +
> > > +	token = strtok(NULL, ",");
> > > +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> > > +		return -1;
> > > +
> > > +	/* Get Rx queue ID from parameter string */
> > > +	rx_queue_id = strtoul(token, NULL, 10);
> > > +	if (rx_queue_id >= 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 = strtok(NULL, "\0");
> > > +	if (token != 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
  

> -----Original Message-----
> From: Kundapura, Ganapati <ganapati.kundapura@intel.com>
> Sent: Tuesday, October 12, 2021 9:44 PM
> To: Naga Harish K, S V <s.v.naga.harish.k@intel.com>; Jayatheerthan, Jay
> <jay.jayatheerthan@intel.com>; jerinjacobk@gmail.com; dev@dpdk.org
> Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> <thomas@monjalon.net>; David Marchand <david.marchand@redhat.com>
> Subject: RE: [PATCH v3] eventdev/rx_adapter: add telemetry callbacks
> 
> Hi Harish,
> 
> > -----Original Message-----
> > From: Naga Harish K, S V <s.v.naga.harish.k@intel.com>
> > Sent: 12 October 2021 19:36
> > To: Jayatheerthan, Jay <jay.jayatheerthan@intel.com>; Kundapura,
> > Ganapati <ganapati.kundapura@intel.com>; jerinjacobk@gmail.com;
> > dev@dpdk.org
> > Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> > <thomas@monjalon.net>; David Marchand
> <david.marchand@redhat.com>
> > Subject: RE: [PATCH v3] eventdev/rx_adapter: add telemetry callbacks
> >
> >
> >
> > > -----Original Message-----
> > > From: dev <dev-bounces@dpdk.org> On Behalf Of Jayatheerthan, Jay
> > > Sent: Tuesday, October 12, 2021 6:39 PM
> > > To: Kundapura, Ganapati <Ganapati.Kundapura@intel.com>;
> > > jerinjacobk@gmail.com; dev@dpdk.org
> > > Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> > > <thomas@monjalon.net>; David Marchand
> <david.marchand@redhat.com>
> > > Subject: Re: [dpdk-dev] [PATCH v3] eventdev/rx_adapter: add
> > > telemetry callbacks
> > >
> > > Acked by: Jay Jayatheerthan <jay.jayatheerthan@intel.com>
> > >
> > > + @Ray Kinsella @Thomas Monjalon  @David Marchand
> > >
> > > > -----Original Message-----
> > > > From: Kundapura, Ganapati <ganapati.kundapura@intel.com>
> > > > Sent: Tuesday, October 12, 2021 3:55 PM
> > > > To: jerinjacobk@gmail.com; dev@dpdk.org
> > > > Cc: Jayatheerthan, Jay <jay.jayatheerthan@intel.com>
> > > > 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 <ganapati.kundapura@intel.com>
> > > > ---
> > > > 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 <rte_thash.h>
> > > >  #include <rte_interrupts.h>
> > > >  #include <rte_mbuf_dyn.h>
> > > > +#include <rte_telemetry.h>
> > > >
> > > >  #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 = { 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 = rx_adapter->stats;
> > > >
> > > > +	buf = &rx_adapter->event_enqueue_buffer;
> > > >  	stats->rx_packets += dev_stats_sum.rx_packets;
> > > >  	stats->rx_enq_count += dev_stats_sum.rx_enq_count;
> > > > +	stats->rx_event_buf_count = buf->count;
> >
> > When per Rx queue event buffer is used, there is a possibility of
> > segfault here Because of null pointer deference.
> >
> Queue_id is not passed to rte_event_eth_rx_adapter_stats_get() and
> there's no way to retrieve the queue id to return the queue's event buffer
> size and count. We may need to loop through all the queue's in the adapter
> which requires changes in rte_event_eth_rx_adapter_stats structure to hold
> event buffer size and count for all the queues.
> 
> Alternatively stats_get() can return event buffer size and count only if
> use_queue_event_buf = false i.e only for adapter wide event buffer.
> 

This approach looks ok. When use_queue_event_buf = true, buffer size and count
Can be returned as zero.

> Do we need event buffer size and count in Rx adapter stats?
> 
> > > > +	stats->rx_event_buf_size = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> > > > +		return -1;
> > > > +
> > > > +	/* Get Rx adapter ID from parameter string */
> > > > +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || ~isdigit(*params))
> > > > +		return -1;
> > > > +
> > > > +	/* Get Rx adapter ID from parameter string */
> > > > +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> > > > +		return -1;
> > > > +
> > > > +	/* Get Rx adapter ID from parameter string */
> > > > +	l_params = strdup(params);
> > > > +	token = strtok(l_params, ",");
> > > > +	rx_adapter_id = strtoul(token, NULL, 10);
> > > > +
> > > 	RTE_EVENT_ETH_RX_ADAPTER_ID_VALID_OR_ERR_RET(rx_adapter
> > > _id,
> > > > +-EINVAL);
> > > > +
> > > > +	token = strtok(NULL, ",");
> > > > +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> > > > +		return -1;
> > > > +
> > > > +	/* Get device ID from parameter string */
> > > > +	eth_dev_id = strtoul(token, NULL, 10);
> > > > +	RTE_EVENTDEV_VALID_DEVID_OR_ERR_RET(eth_dev_id, -EINVAL);
> > > > +
> > > > +	token = strtok(NULL, ",");
> > > > +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> > > > +		return -1;
> > > > +
> > > > +	/* Get Rx queue ID from parameter string */
> > > > +	rx_queue_id = strtoul(token, NULL, 10);
> > > > +	if (rx_queue_id >= 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 = strtok(NULL, "\0");
> > > > +	if (token != 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
  

Hi Harish,

> -----Original Message-----
> From: Naga Harish K, S V <s.v.naga.harish.k@intel.com>
> Sent: 13 October 2021 12:18
> To: Kundapura, Ganapati <ganapati.kundapura@intel.com>; Jayatheerthan, Jay
> <jay.jayatheerthan@intel.com>; jerinjacobk@gmail.com; dev@dpdk.org
> Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> <thomas@monjalon.net>; David Marchand <david.marchand@redhat.com>
> Subject: RE: [PATCH v3] eventdev/rx_adapter: add telemetry callbacks
> 
> 
> 
> > -----Original Message-----
> > From: Kundapura, Ganapati <ganapati.kundapura@intel.com>
> > Sent: Tuesday, October 12, 2021 9:44 PM
> > To: Naga Harish K, S V <s.v.naga.harish.k@intel.com>; Jayatheerthan,
> > Jay <jay.jayatheerthan@intel.com>; jerinjacobk@gmail.com; dev@dpdk.org
> > Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> > <thomas@monjalon.net>; David Marchand <david.marchand@redhat.com>
> > Subject: RE: [PATCH v3] eventdev/rx_adapter: add telemetry callbacks
> >
> > Hi Harish,
> >
> > > -----Original Message-----
> > > From: Naga Harish K, S V <s.v.naga.harish.k@intel.com>
> > > Sent: 12 October 2021 19:36
> > > To: Jayatheerthan, Jay <jay.jayatheerthan@intel.com>; Kundapura,
> > > Ganapati <ganapati.kundapura@intel.com>; jerinjacobk@gmail.com;
> > > dev@dpdk.org
> > > Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> > > <thomas@monjalon.net>; David Marchand
> > <david.marchand@redhat.com>
> > > Subject: RE: [PATCH v3] eventdev/rx_adapter: add telemetry callbacks
> > >
> > >
> > >
> > > > -----Original Message-----
> > > > From: dev <dev-bounces@dpdk.org> On Behalf Of Jayatheerthan, Jay
> > > > Sent: Tuesday, October 12, 2021 6:39 PM
> > > > To: Kundapura, Ganapati <Ganapati.Kundapura@intel.com>;
> > > > jerinjacobk@gmail.com; dev@dpdk.org
> > > > Cc: Kinsella, Ray <ray.kinsella@intel.com>; Thomas Monjalon
> > > > <thomas@monjalon.net>; David Marchand
> > <david.marchand@redhat.com>
> > > > Subject: Re: [dpdk-dev] [PATCH v3] eventdev/rx_adapter: add
> > > > telemetry callbacks
> > > >
> > > > Acked by: Jay Jayatheerthan <jay.jayatheerthan@intel.com>
> > > >
> > > > + @Ray Kinsella @Thomas Monjalon  @David Marchand
> > > >
> > > > > -----Original Message-----
> > > > > From: Kundapura, Ganapati <ganapati.kundapura@intel.com>
> > > > > Sent: Tuesday, October 12, 2021 3:55 PM
> > > > > To: jerinjacobk@gmail.com; dev@dpdk.org
> > > > > Cc: Jayatheerthan, Jay <jay.jayatheerthan@intel.com>
> > > > > 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 <ganapati.kundapura@intel.com>
> > > > > ---
> > > > > 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 <rte_thash.h>
> > > > >  #include <rte_interrupts.h>
> > > > >  #include <rte_mbuf_dyn.h>
> > > > > +#include <rte_telemetry.h>
> > > > >
> > > > >  #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 = { 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 = rx_adapter->stats;
> > > > >
> > > > > +	buf = &rx_adapter->event_enqueue_buffer;
> > > > >  	stats->rx_packets += dev_stats_sum.rx_packets;
> > > > >  	stats->rx_enq_count += dev_stats_sum.rx_enq_count;
> > > > > +	stats->rx_event_buf_count = buf->count;
> > >
> > > When per Rx queue event buffer is used, there is a possibility of
> > > segfault here Because of null pointer deference.
> > >
> > Queue_id is not passed to rte_event_eth_rx_adapter_stats_get() and
> > there's no way to retrieve the queue id to return the queue's event
> > buffer size and count. We may need to loop through all the queue's in
> > the adapter which requires changes in rte_event_eth_rx_adapter_stats
> > structure to hold event buffer size and count for all the queues.
> >
> > Alternatively stats_get() can return event buffer size and count only
> > if use_queue_event_buf = false i.e only for adapter wide event buffer.
> >
> 
> This approach looks ok. When use_queue_event_buf = true, buffer size and
> count Can be returned as zero.
> 
Posted new patch with the suggested changes.

> > Do we need event buffer size and count in Rx adapter stats?
> >
> > > > > +	stats->rx_event_buf_size = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> > > > > +		return -1;
> > > > > +
> > > > > +	/* Get Rx adapter ID from parameter string */
> > > > > +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || ~isdigit(*params))
> > > > > +		return -1;
> > > > > +
> > > > > +	/* Get Rx adapter ID from parameter string */
> > > > > +	rx_adapter_id = 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 == NULL || strlen(params) == 0 || !isdigit(*params))
> > > > > +		return -1;
> > > > > +
> > > > > +	/* Get Rx adapter ID from parameter string */
> > > > > +	l_params = strdup(params);
> > > > > +	token = strtok(l_params, ",");
> > > > > +	rx_adapter_id = strtoul(token, NULL, 10);
> > > > > +
> > > > 	RTE_EVENT_ETH_RX_ADAPTER_ID_VALID_OR_ERR_RET(rx_adapter
> > > > _id,
> > > > > +-EINVAL);
> > > > > +
> > > > > +	token = strtok(NULL, ",");
> > > > > +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> > > > > +		return -1;
> > > > > +
> > > > > +	/* Get device ID from parameter string */
> > > > > +	eth_dev_id = strtoul(token, NULL, 10);
> > > > > +	RTE_EVENTDEV_VALID_DEVID_OR_ERR_RET(eth_dev_id, -
> EINVAL);
> > > > > +
> > > > > +	token = strtok(NULL, ",");
> > > > > +	if (token == NULL || strlen(token) == 0 || !isdigit(*token))
> > > > > +		return -1;
> > > > > +
> > > > > +	/* Get Rx queue ID from parameter string */
> > > > > +	rx_queue_id = strtoul(token, NULL, 10);
> > > > > +	if (rx_queue_id >= 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 = strtok(NULL, "\0");
> > > > > +	if (token != 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