File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change 2525
2626#include " dpdkDevice.hpp"
2727
28+ #include < algorithm>
2829#include < chrono>
2930#include < cstring>
3031#include < iostream>
@@ -192,11 +193,13 @@ void DpdkDevice::initMemPools(uint16_t memPoolSize)
192193
193194void DpdkDevice::setupRxQueues (uint16_t memPoolSize)
194195{
196+ const uint16_t rxQueueSize = std::max (memPoolSize / 2 , 1 );
197+
195198 for (uint16_t rxQueueID = 0 ; rxQueueID < m_rxQueueCount; rxQueueID++) {
196199 int ret = rte_eth_rx_queue_setup (
197200 m_portID,
198201 rxQueueID,
199- memPoolSize ,
202+ rxQueueSize ,
200203 rte_eth_dev_socket_id (m_portID),
201204 nullptr ,
202205 m_memPools[rxQueueID]);
@@ -206,6 +209,9 @@ void DpdkDevice::setupRxQueues(uint16_t memPoolSize)
206209 + std::to_string (m_portID));
207210 }
208211 }
212+
213+ std::cerr << " DPDK RX queues for port " << m_portID << " set up. Size of each queue: "
214+ << rxQueueSize << std::endl;
209215}
210216
211217void DpdkDevice::configureRSS ()
You can’t perform that action at this time.
0 commit comments