#include <string.h>
#include <inttypes.h>
#include <stdbool.h>
-#include <sys/queue.h>
#include <rte_memzone.h>
-#include <rte_memory.h>
-#include <rte_dev.h>
#include <rte_errno.h>
#include <rte_malloc.h>
-#include <rte_ring.h>
#include <rte_mempool.h>
#include <rte_common.h>
#include <rte_timer.h>
#include <rte_service_component.h>
-#include <rte_cycles.h>
+#include <rte_telemetry.h>
#include "event_timer_adapter_pmd.h"
#include "eventdev_pmd.h"
#include "rte_event_timer_adapter.h"
#include "rte_eventdev.h"
-#include "rte_eventdev_trace.h"
+#include "eventdev_trace.h"
#define DATA_MZ_NAME_MAX_LEN 64
#define DATA_MZ_NAME_FORMAT "rte_event_timer_adapter_data_%d"
RTE_LOG_REGISTER_SUFFIX(evtim_buffer_logtype, adapter.timer, NOTICE);
RTE_LOG_REGISTER_SUFFIX(evtim_svc_logtype, adapter.timer.svc, NOTICE);
-static struct rte_event_timer_adapter adapters[RTE_EVENT_TIMER_ADAPTER_NUM_MAX];
+static struct rte_event_timer_adapter *adapters;
static const struct event_timer_adapter_ops swtim_ops;
int n, ret;
struct rte_eventdev *dev;
+ if (adapters == NULL) {
+ adapters = rte_zmalloc("Eventdev",
+ sizeof(struct rte_event_timer_adapter) *
+ RTE_EVENT_TIMER_ADAPTER_NUM_MAX,
+ RTE_CACHE_LINE_SIZE);
+ if (adapters == NULL) {
+ rte_errno = ENOMEM;
+ return NULL;
+ }
+ }
+
if (conf == NULL) {
rte_errno = EINVAL;
return NULL;
int ret;
struct rte_eventdev *dev;
+ if (adapters == NULL) {
+ adapters = rte_zmalloc("Eventdev",
+ sizeof(struct rte_event_timer_adapter) *
+ RTE_EVENT_TIMER_ADAPTER_NUM_MAX,
+ RTE_CACHE_LINE_SIZE);
+ if (adapters == NULL) {
+ rte_errno = ENOMEM;
+ return NULL;
+ }
+ }
+
if (adapters[adapter_id].allocated)
return &adapters[adapter_id]; /* Adapter is already loaded */
int
rte_event_timer_adapter_free(struct rte_event_timer_adapter *adapter)
{
- int ret;
+ int i, ret;
ADAPTER_VALID_OR_ERR_RET(adapter, -EINVAL);
FUNC_PTR_OR_ERR_RET(adapter->ops->uninit, -EINVAL);
adapter->data = NULL;
adapter->allocated = 0;
+ ret = 0;
+ for (i = 0; i < RTE_EVENT_TIMER_ADAPTER_NUM_MAX; i++)
+ if (adapters[i].allocated)
+ ret = adapters[i].allocated;
+
+ if (!ret) {
+ rte_free(adapters);
+ adapters = NULL;
+ }
+
rte_eventdev_trace_timer_adapter_free(adapter);
return 0;
}
RTE_ASSERT(head_idx < EVENT_BUFFER_SZ && tail_idx < EVENT_BUFFER_SZ);
- /* Determine the largest contigous run we can attempt to enqueue to the
+ /* Determine the largest contiguous run we can attempt to enqueue to the
* event device.
*/
if (head_idx > tail_idx)
sw->stats.adapter_tick_count++;
}
+ rte_event_maintain(adapter->data->event_dev_id,
+ adapter->data->event_port_id, 0);
+
return 0;
}
.arm_tmo_tick_burst = swtim_arm_tmo_tick_burst,
.cancel_burst = swtim_cancel_burst,
};
+
+static int
+handle_ta_info(const char *cmd __rte_unused, const char *params,
+ struct rte_tel_data *d)
+{
+ struct rte_event_timer_adapter_info adapter_info;
+ struct rte_event_timer_adapter *adapter;
+ uint16_t adapter_id;
+ int ret;
+
+ if (params == NULL || strlen(params) == 0 || !isdigit(*params))
+ return -1;
+
+ adapter_id = atoi(params);
+
+ if (adapter_id >= RTE_EVENT_TIMER_ADAPTER_NUM_MAX) {
+ EVTIM_LOG_ERR("Invalid timer adapter id %u", adapter_id);
+ return -EINVAL;
+ }
+
+ adapter = &adapters[adapter_id];
+
+ ret = rte_event_timer_adapter_get_info(adapter, &adapter_info);
+ if (ret < 0) {
+ EVTIM_LOG_ERR("Failed to get info for timer adapter id %u", adapter_id);
+ return ret;
+ }
+
+ rte_tel_data_start_dict(d);
+ rte_tel_data_add_dict_u64(d, "timer_adapter_id", adapter_id);
+ rte_tel_data_add_dict_u64(d, "min_resolution_ns", adapter_info.min_resolution_ns);
+ rte_tel_data_add_dict_u64(d, "max_tmo_ns", adapter_info.max_tmo_ns);
+ rte_tel_data_add_dict_u64(d, "event_dev_id", adapter_info.conf.event_dev_id);
+ rte_tel_data_add_dict_u64(d, "socket_id", adapter_info.conf.socket_id);
+ rte_tel_data_add_dict_u64(d, "clk_src", adapter_info.conf.clk_src);
+ rte_tel_data_add_dict_u64(d, "timer_tick_ns", adapter_info.conf.timer_tick_ns);
+ rte_tel_data_add_dict_u64(d, "nb_timers", adapter_info.conf.nb_timers);
+ rte_tel_data_add_dict_u64(d, "flags", adapter_info.conf.flags);
+
+ return 0;
+}
+
+static int
+handle_ta_stats(const char *cmd __rte_unused, const char *params,
+ struct rte_tel_data *d)
+{
+ struct rte_event_timer_adapter_stats stats;
+ struct rte_event_timer_adapter *adapter;
+ uint16_t adapter_id;
+ int ret;
+
+ if (params == NULL || strlen(params) == 0 || !isdigit(*params))
+ return -1;
+
+ adapter_id = atoi(params);
+
+ if (adapter_id >= RTE_EVENT_TIMER_ADAPTER_NUM_MAX) {
+ EVTIM_LOG_ERR("Invalid timer adapter id %u", adapter_id);
+ return -EINVAL;
+ }
+
+ adapter = &adapters[adapter_id];
+
+ ret = rte_event_timer_adapter_stats_get(adapter, &stats);
+ if (ret < 0) {
+ EVTIM_LOG_ERR("Failed to get stats for timer adapter id %u", adapter_id);
+ return ret;
+ }
+
+ rte_tel_data_start_dict(d);
+ rte_tel_data_add_dict_u64(d, "timer_adapter_id", adapter_id);
+ rte_tel_data_add_dict_u64(d, "evtim_exp_count", stats.evtim_exp_count);
+ rte_tel_data_add_dict_u64(d, "ev_enq_count", stats.ev_enq_count);
+ rte_tel_data_add_dict_u64(d, "ev_inv_count", stats.ev_inv_count);
+ rte_tel_data_add_dict_u64(d, "evtim_retry_count", stats.evtim_retry_count);
+ rte_tel_data_add_dict_u64(d, "adapter_tick_count", stats.adapter_tick_count);
+
+ return 0;
+}
+
+RTE_INIT(ta_init_telemetry)
+{
+ rte_telemetry_register_cmd("/eventdev/ta_info",
+ handle_ta_info,
+ "Returns Timer adapter info. Parameter: Timer adapter id");
+
+ rte_telemetry_register_cmd("/eventdev/ta_stats",
+ handle_ta_stats,
+ "Returns Timer adapter stats. Parameter: Timer adapter id");
+}
git.droids-corp.org / dpdk.git / blobdiff