dpdkDevice: use mempool size as rx queue size instead of burst size

CESNET · Nov 12, 2024 · 70969e4 · 70969e4
1 parent 2af9567
commit 70969e4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/input/dpdk/dpdkDevice.cpp b/input/dpdk/dpdkDevice.cpp
@@ -54,7 +54,7 @@ DpdkDevice::DpdkDevice(
 	recognizeDriver();
 	configurePort();
 	initMemPools(memPoolSize);
-	setupRxQueues();
+	setupRxQueues(memPoolSize);
 	configureRSS();
 	enablePort();
 }
@@ -194,13 +194,13 @@ void DpdkDevice::initMemPools(uint16_t memPoolSize)
 	}
 }
 
-void DpdkDevice::setupRxQueues()
+void DpdkDevice::setupRxQueues(uint16_t memPoolSize)
 {
 	for (uint16_t rxQueueID = 0; rxQueueID < m_rxQueueCount; rxQueueID++) {
 		int ret = rte_eth_rx_queue_setup(
 			m_portID,
 			rxQueueID,
-			m_mBufsCount,
+			memPoolSize,
 			rte_eth_dev_socket_id(m_portID),
 			nullptr,
 			m_memPools[rxQueueID]);

diff --git a/input/dpdk/dpdkDevice.hpp b/input/dpdk/dpdkDevice.hpp
@@ -76,7 +76,7 @@ class DpdkDevice {
 	void configurePort();
 	rte_eth_conf createPortConfig();
 	void initMemPools(uint16_t memPoolSize);
-	void setupRxQueues();
+	void setupRxQueues(uint16_t memPoolSize);
 	void configureRSS();
 	void enablePort();
 	void createRteMempool(uint16_t mempoolSize);