Function flush_rx_queue

dpdk/examples/server_node_efd/efd_server/main.c:219–238

Flush rx queue. 8< */

/* Flush rx queue. 8< */
static void
flush_rx_queue(uint16_t node)
{
	uint16_t j;
	struct node *cl;

	if (cl_rx_buf[node].count == 0)
		return;

	cl = &nodes[node];
	if (rte_ring_enqueue_bulk(cl->rx_q, (void **)cl_rx_buf[node].buffer,
			cl_rx_buf[node].count, NULL) != cl_rx_buf[node].count){
		for (j = 0; j < cl_rx_buf[node].count; j++)
			rte_pktmbuf_free(cl_rx_buf[node].buffer[j]);
		cl->stats.rx_drop += cl_rx_buf[node].count;
	} else
		cl->stats.rx += cl_rx_buf[node].count;

	cl_rx_buf[node].count = 0;
}
/* >8 End of sending a burst of traffic to a node. */

/*