Lines Matching refs:cl_rx_buf
65 static struct node_rx_buf *cl_rx_buf; variable
225 if (cl_rx_buf[node].count == 0) 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()
247 cl_rx_buf[node].buffer[cl_rx_buf[node].count++] = buf; in enqueue_rx_packet()
336 cl_rx_buf = calloc(num_nodes, sizeof(cl_rx_buf[0])); in main()