#include <rte_string_fns.h>
#include <rte_mbuf.h>
+#include <rte_mbuf_dyn.h>
#include <rte_log.h>
#include <rte_cycles.h>
#include <rte_ethdev.h>
/* Macros for printing using RTE_LOG */
#define RTE_LOGTYPE_LATENCY_STATS RTE_LOGTYPE_USER1
+static uint64_t timestamp_dynflag;
+static int timestamp_dynfield_offset = -1;
+
+static inline rte_mbuf_timestamp_t *
+timestamp_dynfield(struct rte_mbuf *mbuf)
+{
+ return RTE_MBUF_DYNFIELD(mbuf,
+ timestamp_dynfield_offset, rte_mbuf_timestamp_t *);
+}
+
static const char *MZ_RTE_LATENCY_STATS = "rte_latencystats";
static int latency_stats_index;
static uint64_t samp_intvl;
diff_tsc = now - prev_tsc;
timer_tsc += diff_tsc;
- if ((pkts[i]->ol_flags & PKT_RX_TIMESTAMP) == 0
+ if ((pkts[i]->ol_flags & timestamp_dynflag) == 0
&& (timer_tsc >= samp_intvl)) {
- pkts[i]->timestamp = now;
- pkts[i]->ol_flags |= PKT_RX_TIMESTAMP;
+ *timestamp_dynfield(pkts[i]) = now;
+ pkts[i]->ol_flags |= timestamp_dynflag;
timer_tsc = 0;
}
prev_tsc = now;
now = rte_rdtsc();
for (i = 0; i < nb_pkts; i++) {
- if (pkts[i]->ol_flags & PKT_RX_TIMESTAMP)
- latency[cnt++] = now - pkts[i]->timestamp;
+ if (pkts[i]->ol_flags & timestamp_dynflag)
+ latency[cnt++] = now - *timestamp_dynfield(pkts[i]);
}
rte_spinlock_lock(&glob_stats->lock);
return -1;
}
+ /* Register mbuf field and flag for Rx timestamp */
+ ret = rte_mbuf_dyn_rx_timestamp_register(×tamp_dynfield_offset,
+ ×tamp_dynflag);
+ if (ret != 0) {
+ RTE_LOG(ERR, LATENCY_STATS,
+ "Cannot register mbuf field/flag for timestamp\n");
+ return -rte_errno;
+ }
+
/** Register Rx/Tx callbacks */
RTE_ETH_FOREACH_DEV(pid) {
struct rte_eth_dev_info dev_info;