/
phprus
/
github_dpdk
Обзор
Документация
Войти
/
phprus
/
github_dpdk
Код
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
lib/telemetry/telemetry_data.c
280 строк
7 KB
Robin Jarry
telemetry: fix adding dict in container array
17 фев 2026, 19:58
17 фев 2026, 19:58
dd5789e
Код
Авторство
О чём код?
/* SPDX-License-Identifier: BSD-3-Clause * Copyright(c) 2020 Intel Corporation */ #include <ctype.h> #include <errno.h> #include <stdlib.h> #include <inttypes.h> #undef RTE_USE_LIBBSD #include <stdbool.h> #include <eal_export.h> #include <rte_string_fns.h> #include "telemetry_data.h" #define RTE_TEL_UINT_HEX_STR_BUF_LEN 64 RTE_EXPORT_SYMBOL(rte_tel_data_start_array) int rte_tel_data_start_array(struct rte_tel_data *d, enum rte_tel_value_type type) { enum tel_container_types array_types[] = { [RTE_TEL_STRING_VAL] = TEL_ARRAY_STRING, [RTE_TEL_INT_VAL] = TEL_ARRAY_INT, [RTE_TEL_UINT_VAL] = TEL_ARRAY_UINT, [RTE_TEL_CONTAINER] = TEL_ARRAY_CONTAINER, }; d->type = array_types[type]; d->data_len = 0; return 0; } RTE_EXPORT_SYMBOL(rte_tel_data_start_dict) int rte_tel_data_start_dict(struct rte_tel_data *d) { d->type = TEL_DICT; d->data_len = 0; return 0; } RTE_EXPORT_SYMBOL(rte_tel_data_string) int rte_tel_data_string(struct rte_tel_data *d, const char *str) { d->type = TEL_STRING; d->data_len = strlcpy(d->data.str, str, sizeof(d->data.str)); if (d->data_len >= RTE_TEL_MAX_SINGLE_STRING_LEN) { d->data_len = RTE_TEL_MAX_SINGLE_STRING_LEN - 1; return E2BIG; /* not necessarily and error, just truncation */ } return 0; } RTE_EXPORT_SYMBOL(rte_tel_data_add_array_string) int rte_tel_data_add_array_string(struct rte_tel_data *d, const char *str) { if (d->type != TEL_ARRAY_STRING) return -EINVAL; if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES) return -ENOSPC; const size_t bytes = strlcpy(d->data.array[d->data_len++].sval, str, RTE_TEL_MAX_STRING_LEN); return bytes < RTE_TEL_MAX_STRING_LEN ? 0 : E2BIG; } RTE_EXPORT_SYMBOL(rte_tel_data_add_array_int) int rte_tel_data_add_array_int(struct rte_tel_data *d, int64_t x) { if (d->type != TEL_ARRAY_INT) return -EINVAL; if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES) return -ENOSPC; d->data.array[d->data_len++].ival = x; return 0; } RTE_EXPORT_SYMBOL(rte_tel_data_add_array_uint) int rte_tel_data_add_array_uint(struct rte_tel_data *d, uint64_t x) { if (d->type != TEL_ARRAY_UINT) return -EINVAL; if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES) return -ENOSPC; d->data.array[d->data_len++].uval = x; return 0; } RTE_EXPORT_SYMBOL(rte_tel_data_add_array_container) int rte_tel_data_add_array_container(struct rte_tel_data *d, struct rte_tel_data *val, int keep) { if (d->type != TEL_ARRAY_CONTAINER || (val->type != TEL_ARRAY_UINT && val->type != TEL_ARRAY_INT && val->type != TEL_ARRAY_STRING && val->type != TEL_DICT)) return -EINVAL; if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES) return -ENOSPC; d->data.array[d->data_len].container.data = val; d->data.array[d->data_len++].container.keep = !!keep; return 0; } static int rte_tel_uint_to_hex_encoded_str(char *buf, size_t buf_len, uint64_t val, uint8_t display_bitwidth) { int spec_hex_width = (display_bitwidth + 3) / 4; int len; if (display_bitwidth != 0) len = snprintf(buf, buf_len, "0x%0*" PRIx64, spec_hex_width, val); else len = snprintf(buf, buf_len, "0x%" PRIx64, val); return len < (int)buf_len ? 0 : -EINVAL; } RTE_EXPORT_EXPERIMENTAL_SYMBOL(rte_tel_data_add_array_uint_hex, 23.03) int rte_tel_data_add_array_uint_hex(struct rte_tel_data *d, uint64_t val, uint8_t display_bitwidth) { char hex_str[RTE_TEL_UINT_HEX_STR_BUF_LEN]; int ret; ret = rte_tel_uint_to_hex_encoded_str(hex_str, RTE_TEL_UINT_HEX_STR_BUF_LEN, val, display_bitwidth); if (ret != 0) return ret; return rte_tel_data_add_array_string(d, hex_str); } static bool valid_name(const char *name) { /* non-alphanumeric characters allowed in names */ static const char allowed[128] = { ['_'] = 1, ['/'] = 1 }; for (; *name != '\0'; name++) { if (isalnum(*name)) continue; if ((size_t)*name >= RTE_DIM(allowed) || allowed[(int)*name] == 0) return false; } return true; } RTE_EXPORT_SYMBOL(rte_tel_data_add_dict_string) int rte_tel_data_add_dict_string(struct rte_tel_data *d, const char *name, const char *val) { struct tel_dict_entry *e = &d->data.dict[d->data_len]; size_t nbytes, vbytes; if (d->type != TEL_DICT) return -EINVAL; if (d->data_len >= RTE_TEL_MAX_DICT_ENTRIES) return -ENOSPC; if (!valid_name(name)) return -EINVAL; d->data_len++; e->type = RTE_TEL_STRING_VAL; vbytes = strlcpy(e->value.sval, val, RTE_TEL_MAX_STRING_LEN); nbytes = strlcpy(e->name, name, RTE_TEL_MAX_STRING_LEN); if (vbytes >= RTE_TEL_MAX_STRING_LEN || nbytes >= RTE_TEL_MAX_STRING_LEN) return E2BIG; return 0; } RTE_EXPORT_SYMBOL(rte_tel_data_add_dict_int) int rte_tel_data_add_dict_int(struct rte_tel_data *d, const char *name, int64_t val) { struct tel_dict_entry *e = &d->data.dict[d->data_len]; if (d->type != TEL_DICT) return -EINVAL; if (d->data_len >= RTE_TEL_MAX_DICT_ENTRIES) return -ENOSPC; if (!valid_name(name)) return -EINVAL; d->data_len++; e->type = RTE_TEL_INT_VAL; e->value.ival = val; const size_t bytes = strlcpy(e->name, name, RTE_TEL_MAX_STRING_LEN); return bytes < RTE_TEL_MAX_STRING_LEN ? 0 : E2BIG; } RTE_EXPORT_SYMBOL(rte_tel_data_add_dict_uint) int 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]; if (d->type != TEL_DICT) return -EINVAL; if (d->data_len >= RTE_TEL_MAX_DICT_ENTRIES) return -ENOSPC; if (!valid_name(name)) return -EINVAL; d->data_len++; e->type = RTE_TEL_UINT_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; } RTE_EXPORT_SYMBOL(rte_tel_data_add_dict_container) 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 != TEL_DICT || (val->type != TEL_ARRAY_UINT && val->type != TEL_ARRAY_INT && val->type != TEL_ARRAY_STRING && val->type != TEL_DICT)) return -EINVAL; if (d->data_len >= RTE_TEL_MAX_DICT_ENTRIES) return -ENOSPC; if (!valid_name(name)) return -EINVAL; d->data_len++; e->type = RTE_TEL_CONTAINER; e->value.container.data = val; e->value.container.keep = !!keep; const size_t bytes = strlcpy(e->name, name, RTE_TEL_MAX_STRING_LEN); return bytes < RTE_TEL_MAX_STRING_LEN ? 0 : E2BIG; } RTE_EXPORT_EXPERIMENTAL_SYMBOL(rte_tel_data_add_dict_uint_hex, 23.03) int rte_tel_data_add_dict_uint_hex(struct rte_tel_data *d, const char *name, uint64_t val, uint8_t display_bitwidth) { char hex_str[RTE_TEL_UINT_HEX_STR_BUF_LEN]; int ret; ret = rte_tel_uint_to_hex_encoded_str(hex_str, RTE_TEL_UINT_HEX_STR_BUF_LEN, val, display_bitwidth); if (ret != 0) return ret; return rte_tel_data_add_dict_string(d, name, hex_str); } RTE_EXPORT_SYMBOL(rte_tel_data_alloc) struct rte_tel_data * rte_tel_data_alloc(void) { return malloc(sizeof(struct rte_tel_data)); } RTE_EXPORT_SYMBOL(rte_tel_data_free) void rte_tel_data_free(struct rte_tel_data *data) { free(data); }