Searched refs:cl_rx_buf (Results 1 – 3 of 3) sorted by relevance
57 static struct client_rx_buf *cl_rx_buf; variable201 if (cl_rx_buf[client].count == 0) in flush_rx_queue()205 if (rte_ring_enqueue_bulk(cl->rx_q, (void **)cl_rx_buf[client].buffer, in flush_rx_queue()206 cl_rx_buf[client].count, NULL) == 0){ in flush_rx_queue()207 for (j = 0; j < cl_rx_buf[client].count; j++) in flush_rx_queue()208 rte_pktmbuf_free(cl_rx_buf[client].buffer[j]); in flush_rx_queue()209 cl->stats.rx_drop += cl_rx_buf[client].count; in flush_rx_queue()212 cl->stats.rx += cl_rx_buf[client].count; in flush_rx_queue()214 cl_rx_buf[client].count = 0; in flush_rx_queue()223 cl_rx_buf[client].buffer[cl_rx_buf[client].count++] = buf; in enqueue_rx_packet()[all …]
66 static struct node_rx_buf *cl_rx_buf; variable221 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()[all …]
240 if (cl_rx_buf[node].count == 0)244 if (rte_ring_enqueue_bulk(cl->rx_q, (void **)cl_rx_buf[node].buffer,245 cl_rx_buf[node].count, NULL) != cl_rx_buf[node].count){246 for (j = 0; j < cl_rx_buf[node].count; j++)247 rte_pktmbuf_free(cl_rx_buf[node].buffer[j]);248 cl->stats.rx_drop += cl_rx_buf[node].count;250 cl->stats.rx += cl_rx_buf[node].count;252 cl_rx_buf[node].count = 0;