5c0bdc3203
Suppress the unaligned packed member address warnings by extending the telemetry library build flags with -Wno-address-of-packed-member option, through the WERROR_FLAGS makefile variable. With this change additional warnings are turned on to be treated as errors, which causes the following build issues to be seen: - no previous prototype [-Werror=missing-prototypes] - initialization discards ‘const’ qualifier from pointer target type [-Werror=discarded-qualifiers] - old-style function definition [-Werror=old-style-definition] - variable may be used before its value is set (when using icc compiler). Fixes:0fe3a37924("telemetry: format json response when sending stats") Fixes:ee5ff0d329("telemetry: add client feature and sockets") Fixes:8877ac688b("telemetry: introduce infrastructure") Fixes:1b756087db("telemetry: add parser for client socket messages") Fixes:fff6df7bf5("telemetry: fix using ports of different types") Fixes:4080e46c80("telemetry: support global metrics") Cc: stable@dpdk.org Signed-off-by: Reshma Pattan <reshma.pattan@intel.com> Signed-off-by: Flavia Musatescu <flavia.musatescu@intel.com> Acked-by: Kevin Laatz <kevin.laatz@intel.com>
113 lines
2.5 KiB
C
113 lines
2.5 KiB
C
/* SPDX-License-Identifier: BSD-3-Clause
|
|
* Copyright(c) 2018 Intel Corporation
|
|
*/
|
|
|
|
#include <rte_log.h>
|
|
#include <rte_tailq.h>
|
|
|
|
#ifndef _RTE_TELEMETRY_INTERNAL_H_
|
|
#define _RTE_TELEMETRY_INTERNAL_H_
|
|
|
|
/* Logging Macros */
|
|
extern int telemetry_log_level;
|
|
|
|
#define TELEMETRY_LOG(level, fmt, args...) \
|
|
rte_log(RTE_LOG_ ##level, telemetry_log_level, "%s(): "fmt "\n", \
|
|
__func__, ##args)
|
|
|
|
#define TELEMETRY_LOG_ERR(fmt, args...) \
|
|
TELEMETRY_LOG(ERR, fmt, ## args)
|
|
|
|
#define TELEMETRY_LOG_WARN(fmt, args...) \
|
|
TELEMETRY_LOG(WARNING, fmt, ## args)
|
|
|
|
#define TELEMETRY_LOG_INFO(fmt, args...) \
|
|
TELEMETRY_LOG(INFO, fmt, ## args)
|
|
|
|
#define MAX_METRICS 256
|
|
|
|
typedef struct telemetry_client {
|
|
char *file_path;
|
|
int fd;
|
|
TAILQ_ENTRY(telemetry_client) client_list;
|
|
} telemetry_client;
|
|
|
|
typedef struct telemetry_impl {
|
|
int accept_fd;
|
|
int server_fd;
|
|
pthread_t thread_id;
|
|
int thread_status;
|
|
uint32_t socket_id;
|
|
int reg_index[RTE_MAX_ETHPORTS];
|
|
int metrics_register_done;
|
|
TAILQ_HEAD(, telemetry_client) client_list_head;
|
|
struct telemetry_client *request_client;
|
|
int register_fail_count;
|
|
} telemetry_impl;
|
|
|
|
enum rte_telemetry_parser_actions {
|
|
ACTION_GET = 0,
|
|
ACTION_DELETE = 2
|
|
};
|
|
|
|
enum rte_telemetry_stats_type {
|
|
PORT_STATS = 0,
|
|
GLOBAL_STATS = 1
|
|
};
|
|
|
|
/* @internal */
|
|
struct telemetry_encode_param {
|
|
enum rte_telemetry_stats_type type;
|
|
union {
|
|
struct port_param {
|
|
int num_metric_ids;
|
|
uint32_t metric_ids[MAX_METRICS];
|
|
int num_port_ids;
|
|
uint32_t port_ids[RTE_MAX_ETHPORTS];
|
|
} pp;
|
|
struct global_param {
|
|
int num_metric_ids;
|
|
uint32_t metric_ids[MAX_METRICS];
|
|
} gp;
|
|
};
|
|
};
|
|
|
|
int32_t
|
|
rte_telemetry_parse_client_message(struct telemetry_impl *telemetry, char *buf);
|
|
|
|
int32_t
|
|
rte_telemetry_send_error_response(struct telemetry_impl *telemetry,
|
|
int error_type);
|
|
|
|
int32_t
|
|
rte_telemetry_register_client(struct telemetry_impl *telemetry,
|
|
const char *client_path);
|
|
|
|
int32_t
|
|
rte_telemetry_unregister_client(struct telemetry_impl *telemetry,
|
|
const char *client_path);
|
|
|
|
/**
|
|
* This is a wrapper for the ethdev api rte_eth_find_next().
|
|
* If rte_eth_find_next() returns the same port id that we passed it,
|
|
* then we know that that port is active.
|
|
*/
|
|
int32_t
|
|
rte_telemetry_is_port_active(int port_id);
|
|
|
|
int32_t
|
|
rte_telemetry_send_ports_stats_values(struct telemetry_encode_param *ep,
|
|
struct telemetry_impl *telemetry);
|
|
|
|
int32_t
|
|
rte_telemetry_socket_messaging_testing(int index, int socket);
|
|
|
|
int32_t
|
|
rte_telemetry_send_global_stats_values(struct telemetry_encode_param *ep,
|
|
struct telemetry_impl *telemetry);
|
|
|
|
int32_t
|
|
rte_telemetry_parser_test(struct telemetry_impl *telemetry);
|
|
|
|
#endif
|