220 flush_rx_queue(uint16_t node)  in flush_rx_queue()  argument
223 	struct node *cl;  in flush_rx_queue()
225 	if (cl_rx_buf[node].count == 0)  in flush_rx_queue()
228 	cl = &nodes[node];  in flush_rx_queue()
229 	if (rte_ring_enqueue_bulk(cl->rx_q, (void **)cl_rx_buf[node].buffer,  in flush_rx_queue()
230 			cl_rx_buf[node].count, NULL) != cl_rx_buf[node].count){  in flush_rx_queue()
231 		for (j = 0; j < cl_rx_buf[node].count; j++)  in flush_rx_queue()
232 			rte_pktmbuf_free(cl_rx_buf[node].buffer[j]);  in flush_rx_queue()
233 		cl->stats.rx_drop += cl_rx_buf[node].count;  in flush_rx_queue()
235 		cl->stats.rx += cl_rx_buf[node].count;  in flush_rx_queue()
237 	cl_rx_buf[node].count = 0;  in flush_rx_queue()
245 enqueue_rx_packet(uint8_t node, struct rte_mbuf *buf)  in enqueue_rx_packet()  argument
247 	cl_rx_buf[node].buffer[cl_rx_buf[node].count++] = buf;  in enqueue_rx_packet()
262 	uint8_t node;  in process_packets()  local
280 		node = (uint8_t) ((uintptr_t)data[i]);  in process_packets()
282 		if (node >= num_nodes) {  in process_packets()
291 			enqueue_rx_packet(node, pkts[i]);  in process_packets()