dpdk - support HW timestamp only when metadata are available

Author: SiskaPavel

input/dpdk.cpp

@@ -352,6 +352,11 @@ int DpdkCore::getRxTimestampOffset()
     return m_rxTimestampOffset;
 }
 
+int DpdkCore::getRxTimestampDynflag()
+{
+    return RTE_BIT64(rte_mbuf_dynflag_lookup(RTE_MBUF_DYNFLAG_RX_TIMESTAMP_NAME, NULL));
+}
+
 DpdkReader::DpdkReader()
     : m_dpdkCore(DpdkCore::getInstance())
 {
@@ -370,6 +375,7 @@ void DpdkReader::init(const char* params)
     m_rxQueueId = m_dpdkCore.getRxQueueId();
     m_portId = m_dpdkCore.parser.port_num();
     m_rxTimestampOffset = m_dpdkCore.getRxTimestampOffset();
+    m_rxTimestampDynflag = m_dpdkCore.getRxTimestampDynflag();
     m_useHwRxTimestamp = m_dpdkCore.isNfbDpdkDriver();
 
     createRteMempool(m_dpdkCore.parser.pkt_mempool_size());
@@ -420,7 +426,7 @@ void DpdkReader::setupRxQueue()
 struct timeval DpdkReader::getTimestamp(rte_mbuf* mbuf)
 {
 	struct timeval tv;
-    if (m_useHwRxTimestamp) {
+    if (m_useHwRxTimestamp && (mbuf->ol_flags & m_rxTimestampDynflag)) {
         static constexpr time_t nanosecInSec = 1000000000;
         static constexpr time_t nsecInUsec = 1000;
 

input/dpdk.h

@@ -136,6 +136,13 @@ class DpdkCore {
 
     int getRxTimestampOffset();
 
+    /**
+     * @brief Get the Rx Timestamp mbuf Dynflag for RTE_MBUF_DYNFLAG_RX_TIMESTAMP_NAME
+     * 
+     * @return int RTE_BIT64 value
+     */
+    int getRxTimestampDynflag();
+
     bool isNfbDpdkDriver();
 
     /**
@@ -214,6 +221,7 @@ class DpdkReader : public InputPlugin {
     uint16_t m_rxQueueId;
     uint16_t m_portId;
     int m_rxTimestampOffset;
+    uint64_t m_rxTimestampDynflag;
 
     bool m_useHwRxTimestamp;