fff6df7bf5
Different NIC ports can have different numbers of xstats on them, which
means that we can't just use the xstats list from the first port registered
in the telemetry library. Instead, we need to check the type of each port -
by checking its ops structure pointer - and register each port type once
with the metrics lib.
Fixes: fdbdb3f9ce ("telemetry: add initial connection socket")
Cc: stable@dpdk.org
Signed-off-by: Bruce Richardson <bruce.richardson@intel.com>
Acked-by: Kevin Laatz <kevin.laatz@intel.com>
82 lines
2.0 KiB
C
82 lines
2.0 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)
|
|
|
|
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
|
|
};
|
|
|
|
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(uint32_t *metric_ids, int num_metric_ids,
|
|
uint32_t *port_ids, int num_port_ids, struct telemetry_impl *telemetry);
|
|
|
|
int32_t
|
|
rte_telemetry_socket_messaging_testing(int index, int socket);
|
|
|
|
#endif
|