1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright 2020 Intel Corporation
6 #include <sys/socket.h>
12 #include <rte_common.h>
13 #include <rte_telemetry.h>
14 #include <rte_string_fns.h>
17 #include "telemetry_data.h"
19 #define TELEMETRY_VERSION "v2"
20 #define REQUEST_CMD "/test"
22 #define TEST_OUTPUT(exp) test_output(__func__, exp)
24 static struct rte_tel_data response_data;
28 * This function is the callback registered with Telemetry to be used when
29 * the /test command is requested. This callback returns the global data built
30 * up by the individual test cases.
33 test_cb(const char *cmd __rte_unused, const char *params __rte_unused,
34 struct rte_tel_data *d)
41 * This function is called by each test case function. It communicates with
42 * the telemetry socket by requesting the /test command, and reading the
43 * response. The expected response is passed in by the test case function,
44 * and is compared to the actual response received from Telemetry.
47 test_output(const char *func_name, const char *expected)
50 char buf[BUF_SIZE * 16];
51 if (write(sock, REQUEST_CMD, strlen(REQUEST_CMD)) < 0) {
52 printf("%s: Error with socket write - %s\n", __func__,
56 bytes = read(sock, buf, sizeof(buf) - 1);
58 printf("%s: Error with socket read - %s\n", __func__,
63 printf("%s: buf = '%s', expected = '%s'\n", func_name, buf, expected);
64 return strncmp(expected, buf, sizeof(buf));
68 test_dict_with_array_int_values(void)
72 struct rte_tel_data *child_data = rte_tel_data_alloc();
73 rte_tel_data_start_array(child_data, RTE_TEL_INT_VAL);
75 struct rte_tel_data *child_data2 = rte_tel_data_alloc();
76 rte_tel_data_start_array(child_data2, RTE_TEL_INT_VAL);
78 memset(&response_data, 0, sizeof(response_data));
79 rte_tel_data_start_dict(&response_data);
81 for (i = 0; i < 5; i++) {
82 rte_tel_data_add_array_int(child_data, i);
83 rte_tel_data_add_array_int(child_data2, i);
86 rte_tel_data_add_dict_container(&response_data, "dict_0",
88 rte_tel_data_add_dict_container(&response_data, "dict_1",
91 return TEST_OUTPUT("{\"/test\":{\"dict_0\":[0,1,2,3,4],"
92 "\"dict_1\":[0,1,2,3,4]}}");
96 test_array_with_array_int_values(void)
100 struct rte_tel_data *child_data = rte_tel_data_alloc();
101 rte_tel_data_start_array(child_data, RTE_TEL_INT_VAL);
103 struct rte_tel_data *child_data2 = rte_tel_data_alloc();
104 rte_tel_data_start_array(child_data2, RTE_TEL_INT_VAL);
106 memset(&response_data, 0, sizeof(response_data));
107 rte_tel_data_start_array(&response_data, RTE_TEL_CONTAINER);
109 for (i = 0; i < 5; i++) {
110 rte_tel_data_add_array_int(child_data, i);
111 rte_tel_data_add_array_int(child_data2, i);
113 rte_tel_data_add_array_container(&response_data, child_data, 0);
114 rte_tel_data_add_array_container(&response_data, child_data2, 0);
116 return TEST_OUTPUT("{\"/test\":[[0,1,2,3,4],[0,1,2,3,4]]}");
120 test_case_array_int(void)
123 memset(&response_data, 0, sizeof(response_data));
124 rte_tel_data_start_array(&response_data, RTE_TEL_INT_VAL);
125 for (i = 0; i < 5; i++)
126 rte_tel_data_add_array_int(&response_data, i);
127 return TEST_OUTPUT("{\"/test\":[0,1,2,3,4]}");
131 test_case_add_dict_int(void)
134 char name_of_value[8];
136 memset(&response_data, 0, sizeof(response_data));
137 rte_tel_data_start_dict(&response_data);
139 for (i = 0; i < 5; i++) {
140 sprintf(name_of_value, "dict_%d", i);
141 rte_tel_data_add_dict_int(&response_data, name_of_value, i);
144 return TEST_OUTPUT("{\"/test\":{\"dict_0\":0,\"dict_1\":1,\"dict_2\":2,"
145 "\"dict_3\":3,\"dict_4\":4}}");
149 test_case_array_string(void)
151 memset(&response_data, 0, sizeof(response_data));
152 rte_tel_data_start_array(&response_data, RTE_TEL_STRING_VAL);
153 rte_tel_data_add_array_string(&response_data, "aaaa");
154 rte_tel_data_add_array_string(&response_data, "bbbb");
155 rte_tel_data_add_array_string(&response_data, "cccc");
156 rte_tel_data_add_array_string(&response_data, "dddd");
157 rte_tel_data_add_array_string(&response_data, "eeee");
159 return TEST_OUTPUT("{\"/test\":[\"aaaa\",\"bbbb\",\"cccc\",\"dddd\","
164 test_case_add_dict_string(void)
166 memset(&response_data, 0, sizeof(response_data));
167 rte_tel_data_start_dict(&response_data);
169 rte_tel_data_add_dict_string(&response_data, "dict_0", "aaaa");
170 rte_tel_data_add_dict_string(&response_data, "dict_1", "bbbb");
171 rte_tel_data_add_dict_string(&response_data, "dict_2", "cccc");
172 rte_tel_data_add_dict_string(&response_data, "dict_3", "dddd");
174 return TEST_OUTPUT("{\"/test\":{\"dict_0\":\"aaaa\",\"dict_1\":"
175 "\"bbbb\",\"dict_2\":\"cccc\",\"dict_3\":\"dddd\"}}");
180 test_dict_with_array_string_values(void)
182 struct rte_tel_data *child_data = rte_tel_data_alloc();
183 rte_tel_data_start_array(child_data, RTE_TEL_STRING_VAL);
185 struct rte_tel_data *child_data2 = rte_tel_data_alloc();
186 rte_tel_data_start_array(child_data2, RTE_TEL_STRING_VAL);
188 memset(&response_data, 0, sizeof(response_data));
189 rte_tel_data_start_dict(&response_data);
191 rte_tel_data_add_array_string(child_data, "aaaa");
192 rte_tel_data_add_array_string(child_data2, "bbbb");
194 rte_tel_data_add_dict_container(&response_data, "dict_0",
196 rte_tel_data_add_dict_container(&response_data, "dict_1",
199 return TEST_OUTPUT("{\"/test\":{\"dict_0\":[\"aaaa\"],\"dict_1\":"
204 test_array_with_array_string_values(void)
206 struct rte_tel_data *child_data = rte_tel_data_alloc();
207 rte_tel_data_start_array(child_data, RTE_TEL_STRING_VAL);
209 struct rte_tel_data *child_data2 = rte_tel_data_alloc();
210 rte_tel_data_start_array(child_data2, RTE_TEL_STRING_VAL);
212 memset(&response_data, 0, sizeof(response_data));
213 rte_tel_data_start_array(&response_data, RTE_TEL_CONTAINER);
215 rte_tel_data_add_array_string(child_data, "aaaa");
216 rte_tel_data_add_array_string(child_data2, "bbbb");
218 rte_tel_data_add_array_container(&response_data, child_data, 0);
219 rte_tel_data_add_array_container(&response_data, child_data2, 0);
221 return TEST_OUTPUT("{\"/test\":[[\"aaaa\"],[\"bbbb\"]]}");
225 test_case_array_u64(void)
228 memset(&response_data, 0, sizeof(response_data));
229 rte_tel_data_start_array(&response_data, RTE_TEL_U64_VAL);
230 for (i = 0; i < 5; i++)
231 rte_tel_data_add_array_u64(&response_data, i);
232 return TEST_OUTPUT("{\"/test\":[0,1,2,3,4]}");
236 test_case_add_dict_u64(void)
239 char name_of_value[8];
241 memset(&response_data, 0, sizeof(response_data));
242 rte_tel_data_start_dict(&response_data);
244 for (i = 0; i < 5; i++) {
245 sprintf(name_of_value, "dict_%d", i);
246 rte_tel_data_add_dict_u64(&response_data, name_of_value, i);
248 return TEST_OUTPUT("{\"/test\":{\"dict_0\":0,\"dict_1\":1,\"dict_2\":2,"
249 "\"dict_3\":3,\"dict_4\":4}}");
253 test_dict_with_array_u64_values(void)
257 struct rte_tel_data *child_data = rte_tel_data_alloc();
258 rte_tel_data_start_array(child_data, RTE_TEL_U64_VAL);
260 struct rte_tel_data *child_data2 = rte_tel_data_alloc();
261 rte_tel_data_start_array(child_data2, RTE_TEL_U64_VAL);
263 memset(&response_data, 0, sizeof(response_data));
264 rte_tel_data_start_dict(&response_data);
266 for (i = 0; i < 10; i++) {
267 rte_tel_data_add_array_u64(child_data, i);
268 rte_tel_data_add_array_u64(child_data2, i);
271 rte_tel_data_add_dict_container(&response_data, "dict_0",
273 rte_tel_data_add_dict_container(&response_data, "dict_1",
276 return TEST_OUTPUT("{\"/test\":{\"dict_0\":[0,1,2,3,4,5,6,7,8,9],"
277 "\"dict_1\":[0,1,2,3,4,5,6,7,8,9]}}");
281 test_array_with_array_u64_values(void)
285 struct rte_tel_data *child_data = rte_tel_data_alloc();
286 rte_tel_data_start_array(child_data, RTE_TEL_U64_VAL);
288 struct rte_tel_data *child_data2 = rte_tel_data_alloc();
289 rte_tel_data_start_array(child_data2, RTE_TEL_U64_VAL);
291 memset(&response_data, 0, sizeof(response_data));
292 rte_tel_data_start_array(&response_data, RTE_TEL_CONTAINER);
294 for (i = 0; i < 5; i++) {
295 rte_tel_data_add_array_u64(child_data, i);
296 rte_tel_data_add_array_u64(child_data2, i);
298 rte_tel_data_add_array_container(&response_data, child_data, 0);
299 rte_tel_data_add_array_container(&response_data, child_data2, 0);
301 return TEST_OUTPUT("{\"/test\":[[0,1,2,3,4],[0,1,2,3,4]]}");
305 connect_to_socket(void)
309 struct sockaddr_un telem_addr;
311 sock = socket(AF_UNIX, SOCK_SEQPACKET, 0);
313 printf("\n%s: Error creating socket: %s\n", __func__,
317 telem_addr.sun_family = AF_UNIX;
318 snprintf(telem_addr.sun_path, sizeof(telem_addr.sun_path),
319 "%s/dpdk_telemetry.%s", rte_eal_get_runtime_dir(),
321 if (connect(sock, (struct sockaddr *) &telem_addr,
322 sizeof(telem_addr)) < 0)
323 printf("\n%s: Error connecting to socket: %s\n", __func__,
326 bytes = read(sock, buf, sizeof(buf) - 1);
328 printf("%s: Error with socket read - %s\n", __func__,
333 printf("\n%s: %s\n", __func__, buf);
338 test_telemetry_data(void)
340 typedef int (*test_case)(void);
343 sock = connect_to_socket();
347 test_case test_cases[] = {test_case_array_string,
348 test_case_array_int, test_case_array_u64,
349 test_case_add_dict_int, test_case_add_dict_u64,
350 test_case_add_dict_string,
351 test_dict_with_array_int_values,
352 test_dict_with_array_u64_values,
353 test_dict_with_array_string_values,
354 test_array_with_array_int_values,
355 test_array_with_array_u64_values,
356 test_array_with_array_string_values };
358 rte_telemetry_register_cmd(REQUEST_CMD, test_cb, "Test");
359 for (i = 0; i < RTE_DIM(test_cases); i++) {
360 if (test_cases[i]() != 0) {
369 REGISTER_TEST_COMMAND(telemetry_data_autotest, test_telemetry_data);