1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2020 Intel Corporation
3 */
4
5 #undef RTE_USE_LIBBSD
6 #include <rte_string_fns.h>
7
8 #include "telemetry_data.h"
9
10 int
rte_tel_data_start_array(struct rte_tel_data * d,enum rte_tel_value_type type)11 rte_tel_data_start_array(struct rte_tel_data *d, enum rte_tel_value_type type)
12 {
13 enum tel_container_types array_types[] = {
14 RTE_TEL_ARRAY_STRING, /* RTE_TEL_STRING_VAL = 0 */
15 RTE_TEL_ARRAY_INT, /* RTE_TEL_INT_VAL = 1 */
16 RTE_TEL_ARRAY_U64, /* RTE_TEL_u64_VAL = 2 */
17 RTE_TEL_ARRAY_CONTAINER, /* RTE_TEL_CONTAINER = 3 */
18 };
19 d->type = array_types[type];
20 d->data_len = 0;
21 return 0;
22 }
23
24 int
rte_tel_data_start_dict(struct rte_tel_data * d)25 rte_tel_data_start_dict(struct rte_tel_data *d)
26 {
27 d->type = RTE_TEL_DICT;
28 d->data_len = 0;
29 return 0;
30 }
31
32 int
rte_tel_data_string(struct rte_tel_data * d,const char * str)33 rte_tel_data_string(struct rte_tel_data *d, const char *str)
34 {
35 d->type = RTE_TEL_STRING;
36 d->data_len = strlcpy(d->data.str, str, sizeof(d->data.str));
37 if (d->data_len >= RTE_TEL_MAX_SINGLE_STRING_LEN) {
38 d->data_len = RTE_TEL_MAX_SINGLE_STRING_LEN - 1;
39 return E2BIG; /* not necessarily and error, just truncation */
40 }
41 return 0;
42 }
43
44 int
rte_tel_data_add_array_string(struct rte_tel_data * d,const char * str)45 rte_tel_data_add_array_string(struct rte_tel_data *d, const char *str)
46 {
47 if (d->type != RTE_TEL_ARRAY_STRING)
48 return -EINVAL;
49 if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES)
50 return -ENOSPC;
51 const size_t bytes = strlcpy(d->data.array[d->data_len++].sval,
52 str, RTE_TEL_MAX_STRING_LEN);
53 return bytes < RTE_TEL_MAX_STRING_LEN ? 0 : E2BIG;
54 }
55
56 int
rte_tel_data_add_array_int(struct rte_tel_data * d,int x)57 rte_tel_data_add_array_int(struct rte_tel_data *d, int x)
58 {
59 if (d->type != RTE_TEL_ARRAY_INT)
60 return -EINVAL;
61 if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES)
62 return -ENOSPC;
63 d->data.array[d->data_len++].ival = x;
64 return 0;
65 }
66
67 int
rte_tel_data_add_array_u64(struct rte_tel_data * d,uint64_t x)68 rte_tel_data_add_array_u64(struct rte_tel_data *d, uint64_t x)
69 {
70 if (d->type != RTE_TEL_ARRAY_U64)
71 return -EINVAL;
72 if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES)
73 return -ENOSPC;
74 d->data.array[d->data_len++].u64val = x;
75 return 0;
76 }
77
78 int
rte_tel_data_add_array_container(struct rte_tel_data * d,struct rte_tel_data * val,int keep)79 rte_tel_data_add_array_container(struct rte_tel_data *d,
80 struct rte_tel_data *val, int keep)
81 {
82 if (d->type != RTE_TEL_ARRAY_CONTAINER ||
83 (val->type != RTE_TEL_ARRAY_U64
84 && val->type != RTE_TEL_ARRAY_INT
85 && val->type != RTE_TEL_ARRAY_STRING))
86 return -EINVAL;
87 if (d->data_len >= RTE_TEL_MAX_ARRAY_ENTRIES)
88 return -ENOSPC;
89
90 d->data.array[d->data_len].container.data = val;
91 d->data.array[d->data_len++].container.keep = !!keep;
92 return 0;
93 }
94
95 int
rte_tel_data_add_dict_string(struct rte_tel_data * d,const char * name,const char * val)96 rte_tel_data_add_dict_string(struct rte_tel_data *d, const char *name,
97 const char *val)
98 {
99 struct tel_dict_entry *e = &d->data.dict[d->data_len];
100 size_t nbytes, vbytes;
101
102 if (d->type != RTE_TEL_DICT)
103 return -EINVAL;
104 if (d->data_len >= RTE_TEL_MAX_DICT_ENTRIES)
105 return -ENOSPC;
106
107 d->data_len++;
108 e->type = RTE_TEL_STRING_VAL;
109 vbytes = strlcpy(e->value.sval, val, RTE_TEL_MAX_STRING_LEN);
110 nbytes = strlcpy(e->name, name, RTE_TEL_MAX_STRING_LEN);
111 if (vbytes >= RTE_TEL_MAX_STRING_LEN ||
112 nbytes >= RTE_TEL_MAX_STRING_LEN)
113 return E2BIG;
114 return 0;
115 }
116
117 int
rte_tel_data_add_dict_int(struct rte_tel_data * d,const char * name,int val)118 rte_tel_data_add_dict_int(struct rte_tel_data *d, const char *name, int val)
119 {
120 struct tel_dict_entry *e = &d->data.dict[d->data_len];
121 if (d->type != RTE_TEL_DICT)
122 return -EINVAL;
123 if (d->data_len >= RTE_TEL_MAX_DICT_ENTRIES)
124 return -ENOSPC;
125
126 d->data_len++;
127 e->type = RTE_TEL_INT_VAL;
128 e->value.ival = val;
129 const size_t bytes = strlcpy(e->name, name, RTE_TEL_MAX_STRING_LEN);
130 return bytes < RTE_TEL_MAX_STRING_LEN ? 0 : E2BIG;
131 }
132
133 int
rte_tel_data_add_dict_u64(struct rte_tel_data * d,const char * name,uint64_t val)134 rte_tel_data_add_dict_u64(struct rte_tel_data *d,
135 const char *name, uint64_t val)
136 {
137 struct tel_dict_entry *e = &d->data.dict[d->data_len];
138 if (d->type != RTE_TEL_DICT)
139 return -EINVAL;
140 if (d->data_len >= RTE_TEL_MAX_DICT_ENTRIES)
141 return -ENOSPC;
142
143 d->data_len++;
144 e->type = RTE_TEL_U64_VAL;
145 e->value.u64val = val;
146 const size_t bytes = strlcpy(e->name, name, RTE_TEL_MAX_STRING_LEN);
147 return bytes < RTE_TEL_MAX_STRING_LEN ? 0 : E2BIG;
148 }
149
150 int
rte_tel_data_add_dict_container(struct rte_tel_data * d,const char * name,struct rte_tel_data * val,int keep)151 rte_tel_data_add_dict_container(struct rte_tel_data *d, const char *name,
152 struct rte_tel_data *val, int keep)
153 {
154 struct tel_dict_entry *e = &d->data.dict[d->data_len];
155
156 if (d->type != RTE_TEL_DICT || (val->type != RTE_TEL_ARRAY_U64
157 && val->type != RTE_TEL_ARRAY_INT
158 && val->type != RTE_TEL_ARRAY_STRING))
159 return -EINVAL;
160 if (d->data_len >= RTE_TEL_MAX_DICT_ENTRIES)
161 return -ENOSPC;
162
163 d->data_len++;
164 e->type = RTE_TEL_CONTAINER;
165 e->value.container.data = val;
166 e->value.container.keep = !!keep;
167 const size_t bytes = strlcpy(e->name, name, RTE_TEL_MAX_STRING_LEN);
168 return bytes < RTE_TEL_MAX_STRING_LEN ? 0 : E2BIG;
169 }
170
171 struct rte_tel_data *
rte_tel_data_alloc(void)172 rte_tel_data_alloc(void)
173 {
174 return malloc(sizeof(struct rte_tel_data));
175 }
176
177 void
rte_tel_data_free(struct rte_tel_data * data)178 rte_tel_data_free(struct rte_tel_data *data)
179 {
180 free(data);
181 }
182