Lines Matching refs:client
197 flush_rx_queue(uint16_t client) in flush_rx_queue() argument
200 struct client *cl; in flush_rx_queue()
202 if (cl_rx_buf[client].count == 0) in flush_rx_queue()
205 cl = &clients[client]; 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()
222 enqueue_rx_packet(uint8_t client, struct rte_mbuf *buf) in enqueue_rx_packet() argument
224 cl_rx_buf[client].buffer[cl_rx_buf[client].count++] = buf; in enqueue_rx_packet()
237 static uint8_t client; in process_packets() local
240 enqueue_rx_packet(client, pkts[i]); in process_packets()
242 if (++client == num_clients) in process_packets()
243 client = 0; in process_packets()