[1/2] net/cnxk: add telemetry for inline IPsec for cn9k

  Adds telemetry function to get information about inline
outbound and inline inbound sa's. The function takes port id
as input. Some fields in the structures roc_onf_ipsec_outb_sa
and roc_onf_ipsec_inb_sa are returned as output.

Signed-off-by: Ankur Dwivedi <adwivedi@marvell.com>
Reviewed-by: Jerin Jacob Kollanukkaran <jerinj@marvell.com>
---
 drivers/net/cnxk/cnxk_ethdev_sec_telemetry.c | 140 +++++++++++++++++++
 drivers/net/cnxk/meson.build                 |   1 +
 2 files changed, 141 insertions(+)
 create mode 100644 drivers/net/cnxk/cnxk_ethdev_sec_telemetry.c
  

On Thu, Feb 10, 2022 at 12:24 PM Ankur Dwivedi <adwivedi@marvell.com> wrote:
>
> Adds telemetry function to get information about inline
> outbound and inline inbound sa's. The function takes port id
> as input. Some fields in the structures roc_onf_ipsec_outb_sa
> and roc_onf_ipsec_inb_sa are returned as output.


Acked-by: Jerin Jacob <jerinj@marvell.com>
Applied to dpdk-next-net-mrvl/for-next-net. Thanks

>
> Signed-off-by: Ankur Dwivedi <adwivedi@marvell.com>
> Reviewed-by: Jerin Jacob Kollanukkaran <jerinj@marvell.com>
> ---
>  drivers/net/cnxk/cnxk_ethdev_sec_telemetry.c | 140 +++++++++++++++++++
>  drivers/net/cnxk/meson.build                 |   1 +
>  2 files changed, 141 insertions(+)
>  create mode 100644 drivers/net/cnxk/cnxk_ethdev_sec_telemetry.c
>
> diff --git a/drivers/net/cnxk/cnxk_ethdev_sec_telemetry.c b/drivers/net/cnxk/cnxk_ethdev_sec_telemetry.c
> new file mode 100644
> index 0000000000..83015e11e2
> --- /dev/null
> +++ b/drivers/net/cnxk/cnxk_ethdev_sec_telemetry.c
> @@ -0,0 +1,140 @@
> +/* SPDX-License-Identifier: BSD-3-Clause
> + * Copyright(C) 2022 Marvell.
> + */
> +
> +#include <rte_telemetry.h>
> +
> +#include <roc_api.h>
> +
> +#include "cnxk_ethdev.h"
> +
> +#define STR_MAXLEN 20
> +#define W0_MAXLEN  21
> +
> +static int
> +copy_outb_sa_9k(struct rte_tel_data *d, uint32_t i, void *sa)
> +{
> +       struct roc_onf_ipsec_outb_sa *out_sa;
> +       union {
> +               struct roc_ie_onf_sa_ctl ctl;
> +               uint64_t u64;
> +       } w0;
> +       char strw0[W0_MAXLEN];
> +       char str[STR_MAXLEN];
> +
> +       out_sa = (struct roc_onf_ipsec_outb_sa *)sa;
> +       w0.ctl = out_sa->ctl;
> +
> +       snprintf(str, sizeof(str), "outsa_w0_%u", i);
> +       snprintf(strw0, sizeof(strw0), "%" PRIu64, w0.u64);
> +       rte_tel_data_add_dict_string(d, str, strw0);
> +
> +       snprintf(str, sizeof(str), "outsa_src_%u", i);
> +       rte_tel_data_add_dict_u64(d, str, out_sa->udp_src);
> +
> +       snprintf(str, sizeof(str), "outsa_dst_%u", i);
> +       rte_tel_data_add_dict_u64(d, str, out_sa->udp_dst);
> +
> +       snprintf(str, sizeof(str), "outsa_isrc_%u", i);
> +       rte_tel_data_add_dict_u64(d, str, out_sa->ip_src);
> +
> +       snprintf(str, sizeof(str), "outsa_idst_%u", i);
> +       rte_tel_data_add_dict_u64(d, str, out_sa->ip_dst);
> +
> +       return 0;
> +}
> +
> +static int
> +copy_inb_sa_9k(struct rte_tel_data *d, uint32_t i, void *sa)
> +{
> +       struct roc_onf_ipsec_inb_sa *in_sa;
> +       union {
> +               struct roc_ie_onf_sa_ctl ctl;
> +               uint64_t u64;
> +       } w0;
> +       char strw0[W0_MAXLEN];
> +       char str[STR_MAXLEN];
> +
> +       in_sa = (struct roc_onf_ipsec_inb_sa *)sa;
> +       w0.ctl = in_sa->ctl;
> +
> +       snprintf(str, sizeof(str), "insa_w0_%u", i);
> +       snprintf(strw0, sizeof(strw0), "%" PRIu64, w0.u64);
> +       rte_tel_data_add_dict_string(d, str, strw0);
> +
> +       snprintf(str, sizeof(str), "insa_esnh_%u", i);
> +       rte_tel_data_add_dict_u64(d, str, in_sa->esn_hi);
> +
> +       snprintf(str, sizeof(str), "insa_esnl_%u", i);
> +       rte_tel_data_add_dict_u64(d, str, in_sa->esn_low);
> +
> +       return 0;
> +}
> +
> +static int
> +ethdev_sec_tel_handle_info(const char *cmd __rte_unused, const char *params,
> +                          struct rte_tel_data *d)
> +{
> +       struct cnxk_eth_sec_sess *eth_sec, *tvar;
> +       struct rte_eth_dev *eth_dev;
> +       struct cnxk_eth_dev *dev;
> +       uint16_t port_id;
> +       char *end_p;
> +       uint32_t i;
> +       int ret;
> +
> +       port_id = strtoul(params, &end_p, 0);
> +       if (errno != 0)
> +               return -EINVAL;
> +
> +       if (*end_p != '\0')
> +               plt_err("Extra parameters passed to telemetry, ignoring it");
> +
> +       if (!rte_eth_dev_is_valid_port(port_id)) {
> +               plt_err("Invalid port id %u", port_id);
> +               return -EINVAL;
> +       }
> +
> +       eth_dev = &rte_eth_devices[port_id];
> +       if (!eth_dev) {
> +               plt_err("Ethdev not available");
> +               return -EINVAL;
> +       }
> +
> +       dev = cnxk_eth_pmd_priv(eth_dev);
> +
> +       rte_tel_data_start_dict(d);
> +
> +       rte_tel_data_add_dict_int(d, "nb_outb_sa", dev->outb.nb_sess);
> +
> +       i = 0;
> +       if (dev->tx_offloads & RTE_ETH_TX_OFFLOAD_SECURITY) {
> +               tvar = NULL;
> +               RTE_TAILQ_FOREACH_SAFE(eth_sec, &dev->outb.list, entry, tvar) {
> +                       ret = copy_outb_sa_9k(d, i++, eth_sec->sa);
> +                       if (ret < 0)
> +                               return ret;
> +               }
> +       }
> +
> +       rte_tel_data_add_dict_int(d, "nb_inb_sa", dev->inb.nb_sess);
> +
> +       i = 0;
> +       if (dev->rx_offloads & RTE_ETH_RX_OFFLOAD_SECURITY) {
> +               tvar = NULL;
> +               RTE_TAILQ_FOREACH_SAFE(eth_sec, &dev->inb.list, entry, tvar) {
> +                       ret = copy_inb_sa_9k(d, i++, eth_sec->sa);
> +                       if (ret < 0)
> +                               return ret;
> +               }
> +       }
> +
> +       return 0;
> +}
> +
> +RTE_INIT(cnxk_ipsec_init_telemetry)
> +{
> +       rte_telemetry_register_cmd("/cnxk/ipsec/info",
> +                                  ethdev_sec_tel_handle_info,
> +                                  "Returns ipsec info. Parameters: port id");
> +}
> diff --git a/drivers/net/cnxk/meson.build b/drivers/net/cnxk/meson.build
> index cd8c13bd1c..83af1f4d0c 100644
> --- a/drivers/net/cnxk/meson.build
> +++ b/drivers/net/cnxk/meson.build
> @@ -15,6 +15,7 @@ sources = files(
>          'cnxk_ethdev_ops.c',
>          'cnxk_ethdev_sec.c',
>          'cnxk_ethdev_telemetry.c',
> +        'cnxk_ethdev_sec_telemetry.c',
>          'cnxk_link.c',
>          'cnxk_lookup.c',
>          'cnxk_ptp.c',
> --
> 2.28.0
>