test/telemetry: fix typo at beginning of line

[dpdk.git] / lib / librte_eventdev / rte_event_eth_rx_adapter.c

diff --git a/lib/librte_eventdev/rte_event_eth_rx_adapter.c b/lib/librte_eventdev/rte_event_eth_rx_adapter.c
index 95dd478..3c73046 100644 (file)
--- a/lib/librte_eventdev/rte_event_eth_rx_adapter.c
+++ b/lib/librte_eventdev/rte_event_eth_rx_adapter.c
@@ -20,6 +20,7 @@
 
 #include "rte_eventdev.h"
 #include "rte_eventdev_pmd.h"
+#include "rte_eventdev_trace.h"
 #include "rte_event_eth_rx_adapter.h"
 
 #define BATCH_SIZE             32
@@ -762,7 +763,6 @@ rxa_buffer_mbufs(struct rte_event_eth_rx_adapter *rx_adapter,
        uint32_t rss_mask;
        uint32_t rss;
        int do_rss;
-       uint64_t ts;
        uint16_t nb_cb;
        uint16_t dropped;
 
@@ -770,16 +770,6 @@ rxa_buffer_mbufs(struct rte_event_eth_rx_adapter *rx_adapter,
        rss_mask = ~(((m->ol_flags & PKT_RX_RSS_HASH) != 0) - 1);
        do_rss = !rss_mask && !eth_rx_queue_info->flow_id_mask;
 
-       if ((m->ol_flags & PKT_RX_TIMESTAMP) == 0) {
-               ts = rte_get_tsc_cycles();
-               for (i = 0; i < num; i++) {
-                       m = mbufs[i];
-
-                       m->timestamp = ts;
-                       m->ol_flags |= PKT_RX_TIMESTAMP;
-               }
-       }
-
        for (i = 0; i < num; i++) {
                m = mbufs[i];
 
@@ -1998,6 +1988,8 @@ rte_event_eth_rx_adapter_create_ext(uint8_t id, uint8_t dev_id,
        event_eth_rx_adapter[id] = rx_adapter;
        if (conf_cb == rxa_default_conf_cb)
                rx_adapter->default_cb_arg = 1;
+       rte_eventdev_trace_eth_rx_adapter_create(id, dev_id, conf_cb,
+               conf_arg);
        return 0;
 }
 
@@ -2047,6 +2039,7 @@ rte_event_eth_rx_adapter_free(uint8_t id)
        rte_free(rx_adapter);
        event_eth_rx_adapter[id] = NULL;
 
+       rte_eventdev_trace_eth_rx_adapter_free(id);
        return 0;
 }
 
@@ -2142,6 +2135,8 @@ rte_event_eth_rx_adapter_queue_add(uint8_t id,
                rte_spinlock_unlock(&rx_adapter->rx_lock);
        }
 
+       rte_eventdev_trace_eth_rx_adapter_queue_add(id, eth_dev_id,
+               rx_queue_id, queue_conf, ret);
        if (ret)
                return ret;
 
@@ -2263,18 +2258,22 @@ unlock_ret:
                                rxa_sw_adapter_queue_count(rx_adapter));
        }
 
+       rte_eventdev_trace_eth_rx_adapter_queue_del(id, eth_dev_id,
+               rx_queue_id, ret);
        return ret;
 }
 
 int
 rte_event_eth_rx_adapter_start(uint8_t id)
 {
+       rte_eventdev_trace_eth_rx_adapter_start(id);
        return rxa_ctrl(id, 1);
 }
 
 int
 rte_event_eth_rx_adapter_stop(uint8_t id)
 {
+       rte_eventdev_trace_eth_rx_adapter_stop(id);
        return rxa_ctrl(id, 0);
 }