.hthresh = RX_HTHRESH,
.wthresh = RX_WTHRESH,
},
+ .rx_drop_en = 1,
};
/*
* Main thread that does the work, reading from INPUT_PORT
* and writing to OUTPUT_PORT
*/
-static __attribute__((noreturn)) int
+static int
lcore_main(__attribute__((__unused__)) void* dummy)
{
const uint16_t lcore_id = (uint16_t)rte_lcore_id();
printf("core %u(lcore %u) reading queues %i-%i\n", (unsigned)core_id,
(unsigned)lcore_id, startQueue, endQueue - 1);
+ if (startQueue == endQueue) {
+ printf("lcore %u has nothing to do\n", lcore_id);
+ return (0);
+ }
+
for (;;) {
struct rte_mbuf *buf[MAX_PKT_BURST];
const uint16_t buf_size = sizeof(buf) / sizeof(buf[0]);