Searched refs:cl_rx_buf (Results 1 – 2 of 2) sorted by relevance
56 static struct client_rx_buf *cl_rx_buf; variable202 if (cl_rx_buf[client].count == 0) in flush_rx_queue()206 if (rte_ring_enqueue_bulk(cl->rx_q, (void **)cl_rx_buf[client].buffer, in flush_rx_queue()207 cl_rx_buf[client].count, NULL) == 0){ in flush_rx_queue()208 for (j = 0; j < cl_rx_buf[client].count; j++) in flush_rx_queue()209 rte_pktmbuf_free(cl_rx_buf[client].buffer[j]); in flush_rx_queue()210 cl->stats.rx_drop += cl_rx_buf[client].count; in flush_rx_queue()213 cl->stats.rx += cl_rx_buf[client].count; in flush_rx_queue()215 cl_rx_buf[client].count = 0; in flush_rx_queue()224 cl_rx_buf[client].buffer[cl_rx_buf[client].count++] = buf; in enqueue_rx_packet()[all …]
65 static struct node_rx_buf *cl_rx_buf; variable225 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()[all …]