Lines Matching refs:cl_rx_buf
66 static struct node_rx_buf *cl_rx_buf; variable
221 if (cl_rx_buf[node].count == 0) in flush_rx_queue()
225 if (rte_ring_enqueue_bulk(cl->rx_q, (void **)cl_rx_buf[node].buffer, in flush_rx_queue()
226 cl_rx_buf[node].count, NULL) != cl_rx_buf[node].count){ in flush_rx_queue()
227 for (j = 0; j < cl_rx_buf[node].count; j++) in flush_rx_queue()
228 rte_pktmbuf_free(cl_rx_buf[node].buffer[j]); in flush_rx_queue()
229 cl->stats.rx_drop += cl_rx_buf[node].count; in flush_rx_queue()
231 cl->stats.rx += cl_rx_buf[node].count; in flush_rx_queue()
233 cl_rx_buf[node].count = 0; in flush_rx_queue()
242 cl_rx_buf[node].buffer[cl_rx_buf[node].count++] = buf; in enqueue_rx_packet()
328 cl_rx_buf = calloc(num_nodes, sizeof(cl_rx_buf[0])); in main()