Skip to content

Commit 70969e4

Browse files
committed
dpdkDevice: use mempool size as rx queue size instead of burst size
1 parent 2af9567 commit 70969e4

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

input/dpdk/dpdkDevice.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ DpdkDevice::DpdkDevice(
5454
recognizeDriver();
5555
configurePort();
5656
initMemPools(memPoolSize);
57-
setupRxQueues();
57+
setupRxQueues(memPoolSize);
5858
configureRSS();
5959
enablePort();
6060
}
@@ -194,13 +194,13 @@ void DpdkDevice::initMemPools(uint16_t memPoolSize)
194194
}
195195
}
196196

197-
void DpdkDevice::setupRxQueues()
197+
void DpdkDevice::setupRxQueues(uint16_t memPoolSize)
198198
{
199199
for (uint16_t rxQueueID = 0; rxQueueID < m_rxQueueCount; rxQueueID++) {
200200
int ret = rte_eth_rx_queue_setup(
201201
m_portID,
202202
rxQueueID,
203-
m_mBufsCount,
203+
memPoolSize,
204204
rte_eth_dev_socket_id(m_portID),
205205
nullptr,
206206
m_memPools[rxQueueID]);

input/dpdk/dpdkDevice.hpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ class DpdkDevice {
7676
void configurePort();
7777
rte_eth_conf createPortConfig();
7878
void initMemPools(uint16_t memPoolSize);
79-
void setupRxQueues();
79+
void setupRxQueues(uint16_t memPoolSize);
8080
void configureRSS();
8181
void enablePort();
8282
void createRteMempool(uint16_t mempoolSize);

0 commit comments

Comments
 (0)