[RFC PATCH 2/7] telemetry: add uint type as alias for u64
lihuisong (C)
lihuisong at huawei.com
Thu Dec 15 02:49:06 CET 2022
在 2022/12/14 2:27, Bruce Richardson 写道:
> For future standardization on the "uint" name for unsigned values rather
> than the existing "u64" one, we can for now:
> * rename all internal values to use uint rather than u64
> * add new function names to alias the existing u64 ones
>
> Suggested-by: Morten Brørup <mb at smartsharesystems.com>
> Signed-off-by: Bruce Richardson <bruce.richardson at intel.com>
> ---
> lib/telemetry/rte_telemetry.h | 36 ++++++++++++++++++++++++++++++++++
> lib/telemetry/telemetry.c | 16 +++++++--------
> lib/telemetry/telemetry_data.c | 28 ++++++++++++++++++--------
> lib/telemetry/telemetry_data.h | 4 ++--
> lib/telemetry/version.map | 7 +++++++
> 5 files changed, 73 insertions(+), 18 deletions(-)
>
> diff --git a/lib/telemetry/rte_telemetry.h b/lib/telemetry/rte_telemetry.h
> index c2ad65effe..60877dae0a 100644
> --- a/lib/telemetry/rte_telemetry.h
> +++ b/lib/telemetry/rte_telemetry.h
> @@ -8,6 +8,8 @@
> #ifndef _RTE_TELEMETRY_H_
> #define _RTE_TELEMETRY_H_
>
> +#include <rte_compat.h>
> +
> #ifdef __cplusplus
> extern "C" {
> #endif
> @@ -121,6 +123,22 @@ int
> rte_tel_data_add_array_int(struct rte_tel_data *d, int x);
>
> /**
> + * Add an unsigned value to an array.
> + * The array must have been started by rte_tel_data_start_array() with
> + * RTE_TEL_UINT_VAL as the type parameter.
> + *
> + * @param d
> + * The data structure passed to the callback
> + * @param x
> + * The number to be returned in the array
> + * @return
> + * 0 on success, negative errno on error
> + */
> +__rte_experimental
> +int
> +rte_tel_data_add_array_uint(struct rte_tel_data *d, uint64_t x);
> +
> + /**
> * Add a uint64_t to an array.
> * The array must have been started by rte_tel_data_start_array() with
> * RTE_TEL_UINT_VAL as the type parameter.
> @@ -193,6 +211,24 @@ int
> rte_tel_data_add_dict_int(struct rte_tel_data *d, const char *name, int val);
>
> /**
> + * Add an unsigned value to a dictionary.
> + * The dict must have been started by rte_tel_data_start_dict().
> + *
> + * @param d
> + * The data structure passed to the callback
> + * @param name
> + * The name the value is to be stored under in the dict
> + * Must contain only alphanumeric characters or the symbols: '_' or '/'
> + * @param val
> + * The number to be stored in the dict
> + * @return
> + * 0 on success, negative errno on error, E2BIG on string truncation of name.
> + */
> +int __rte_experimental
__rte_experimental
int
Right?
> +rte_tel_data_add_dict_uint(struct rte_tel_data *d,
> + const char *name, uint64_t val);
> +
> + /**
> * Add a uint64_t value to a dictionary.
> * The dict must have been started by rte_tel_data_start_dict().
> *
> diff --git a/lib/telemetry/telemetry.c b/lib/telemetry/telemetry.c
> index 75957fe0b1..fd8186383f 100644
> --- a/lib/telemetry/telemetry.c
> +++ b/lib/telemetry/telemetry.c
> @@ -167,16 +167,16 @@ container_to_json(const struct rte_tel_data *d, char *out_buf, size_t buf_len)
> size_t used = 0;
> unsigned int i;
>
> - if (d->type != RTE_TEL_DICT && d->type != RTE_TEL_ARRAY_U64 &&
> + if (d->type != RTE_TEL_DICT && d->type != RTE_TEL_ARRAY_UINT &&
> d->type != RTE_TEL_ARRAY_INT && d->type != RTE_TEL_ARRAY_STRING)
> return snprintf(out_buf, buf_len, "null");
>
> used = rte_tel_json_empty_array(out_buf, buf_len, 0);
> - if (d->type == RTE_TEL_ARRAY_U64)
> + if (d->type == RTE_TEL_ARRAY_UINT)
> for (i = 0; i < d->data_len; i++)
> used = rte_tel_json_add_array_u64(out_buf,
> buf_len, used,
> - d->data.array[i].u64val);
> + d->data.array[i].uval);
> if (d->type == RTE_TEL_ARRAY_INT)
> for (i = 0; i < d->data_len; i++)
> used = rte_tel_json_add_array_int(out_buf,
> @@ -204,7 +204,7 @@ container_to_json(const struct rte_tel_data *d, char *out_buf, size_t buf_len)
> case RTE_TEL_UINT_VAL:
> used = rte_tel_json_add_obj_u64(out_buf,
> buf_len, used,
> - v->name, v->value.u64val);
> + v->name, v->value.uval);
> break;
> case RTE_TEL_CONTAINER:
> {
> @@ -271,7 +271,7 @@ output_json(const char *cmd, const struct rte_tel_data *d, int s)
> case RTE_TEL_UINT_VAL:
> used = rte_tel_json_add_obj_u64(cb_data_buf,
> buf_len, used,
> - v->name, v->value.u64val);
> + v->name, v->value.uval);
> break;
> case RTE_TEL_CONTAINER:
> {
> @@ -293,7 +293,7 @@ output_json(const char *cmd, const struct rte_tel_data *d, int s)
>
> case RTE_TEL_ARRAY_STRING:
> case RTE_TEL_ARRAY_INT:
> - case RTE_TEL_ARRAY_U64:
> + case RTE_TEL_ARRAY_UINT:
> case RTE_TEL_ARRAY_CONTAINER:
> used = rte_tel_json_empty_array(cb_data_buf, buf_len, 0);
> for (i = 0; i < d->data_len; i++)
> @@ -306,10 +306,10 @@ output_json(const char *cmd, const struct rte_tel_data *d, int s)
> used = rte_tel_json_add_array_int(cb_data_buf,
> buf_len, used,
> d->data.array[i].ival);
> - else if (d->type == RTE_TEL_ARRAY_U64)
> + else if (d->type == RTE_TEL_ARRAY_UINT)
> used = rte_tel_json_add_array_u64(cb_data_buf,
> buf_len, used,
> - d->data.array[i].u64val);
> + d->data.array[i].uval);
> else if (d->type == RTE_TEL_ARRAY_CONTAINER) {
> char temp[buf_len];
> const struct container *rec_data =
> diff --git a/lib/telemetry/telemetry_data.c b/lib/telemetry/telemetry_data.c
> index 3c996484ec..077b0c4a6f 100644
> --- a/lib/telemetry/telemetry_data.c
> +++ b/lib/telemetry/telemetry_data.c
> @@ -18,7 +18,7 @@ rte_tel_data_start_array(struct rte_tel_data *d, enum rte_tel_value_type type)
> enum tel_container_types array_types[] = {
> RTE_TEL_ARRAY_STRING, /* RTE_TEL_STRING_VAL = 0 */
> RTE_TEL_ARRAY_INT, /* RTE_TEL_INT_VAL = 1 */
> - RTE_TEL_ARRAY_U64, /* RTE_TEL_UINT_VAL = 2 */
> + RTE_TEL_ARRAY_UINT, /* RTE_TEL_UINT_VAL = 2 */
> RTE_TEL_ARRAY_CONTAINER, /* RTE_TEL_CONTAINER = 3 */
> };
> d->type = array_types[type];
> @@ -70,22 +70,28 @@ rte_tel_data_add_array_int(struct rte_tel_data *d, int x)
> }
>
> int
> -rte_tel_data_add_array_u64(struct rte_tel_data *d, uint64_t x)
> +rte_tel_data_add_array_uint(struct rte_tel_data *d, uint64_t x)
> {
> - if (d->type != RTE_TEL_ARRAY_U64)
> + if (d->type != RTE_TEL_ARRAY_UINT)
> return -EINVAL;
> if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES)
> return -ENOSPC;
> - d->data.array[d->data_len++].u64val = x;
> + d->data.array[d->data_len++].uval = x;
> return 0;
> }
>
> +int
> +rte_tel_data_add_array_u64(struct rte_tel_data *d, uint64_t x)
> +{
> + return rte_tel_data_add_array_uint(d, x);
> +}
> +
> int
> rte_tel_data_add_array_container(struct rte_tel_data *d,
> struct rte_tel_data *val, int keep)
> {
> if (d->type != RTE_TEL_ARRAY_CONTAINER ||
> - (val->type != RTE_TEL_ARRAY_U64
> + (val->type != RTE_TEL_ARRAY_UINT
> && val->type != RTE_TEL_ARRAY_INT
> && val->type != RTE_TEL_ARRAY_STRING))
> return -EINVAL;
> @@ -160,7 +166,7 @@ rte_tel_data_add_dict_int(struct rte_tel_data *d, const char *name, int val)
> }
>
> int
> -rte_tel_data_add_dict_u64(struct rte_tel_data *d,
> +rte_tel_data_add_dict_uint(struct rte_tel_data *d,
> const char *name, uint64_t val)
> {
> struct tel_dict_entry *e = &d->data.dict[d->data_len];
> @@ -174,18 +180,24 @@ rte_tel_data_add_dict_u64(struct rte_tel_data *d,
>
> d->data_len++;
> e->type = RTE_TEL_UINT_VAL;
> - e->value.u64val = val;
> + e->value.uval = val;
> const size_t bytes = strlcpy(e->name, name, RTE_TEL_MAX_STRING_LEN);
> return bytes < RTE_TEL_MAX_STRING_LEN ? 0 : E2BIG;
> }
>
> +int
> +rte_tel_data_add_dict_u64(struct rte_tel_data *d, const char *name, uint64_t val)
> +{
> + return rte_tel_data_add_dict_uint(d, name, val);
> +}
> +
> int
> rte_tel_data_add_dict_container(struct rte_tel_data *d, const char *name,
> struct rte_tel_data *val, int keep)
> {
> struct tel_dict_entry *e = &d->data.dict[d->data_len];
>
> - if (d->type != RTE_TEL_DICT || (val->type != RTE_TEL_ARRAY_U64
> + if (d->type != RTE_TEL_DICT || (val->type != RTE_TEL_ARRAY_UINT
> && val->type != RTE_TEL_ARRAY_INT
> && val->type != RTE_TEL_ARRAY_STRING
> && val->type != RTE_TEL_DICT))
> diff --git a/lib/telemetry/telemetry_data.h b/lib/telemetry/telemetry_data.h
> index 26aa28e72c..939deaa618 100644
> --- a/lib/telemetry/telemetry_data.h
> +++ b/lib/telemetry/telemetry_data.h
> @@ -13,7 +13,7 @@ enum tel_container_types {
> RTE_TEL_DICT, /** name-value pairs, of individual value type */
> RTE_TEL_ARRAY_STRING, /** array of string values only */
> RTE_TEL_ARRAY_INT, /** array of signed, 32-bit int values */
> - RTE_TEL_ARRAY_U64, /** array of unsigned 64-bit int values */
> + RTE_TEL_ARRAY_UINT, /** array of unsigned 64-bit int values */
> RTE_TEL_ARRAY_CONTAINER, /** array of container structs */
> };
>
> @@ -29,7 +29,7 @@ struct container {
> union tel_value {
> char sval[RTE_TEL_MAX_STRING_LEN];
> int ival;
> - uint64_t u64val;
> + uint64_t uval;
> struct container container;
> };
>
> diff --git a/lib/telemetry/version.map b/lib/telemetry/version.map
> index 9794f9ea20..0f70d82dfc 100644
> --- a/lib/telemetry/version.map
> +++ b/lib/telemetry/version.map
> @@ -19,6 +19,13 @@ DPDK_23 {
> local: *;
> };
>
> +EXPERIMENTAL {
> + global:
> +
> + rte_tel_data_add_array_uint;
> + rte_tel_data_add_dict_uint;
> +};
> +
> INTERNAL {
> rte_telemetry_legacy_register;
> rte_telemetry_init;
More information about the dev
mailing list