1106 	unsigned int rcvd;  in complete_tx_l2fwd()  local
1126 	rcvd = xsk_ring_cons__peek(&umem->cq, ndescs, &idx_cq);  in complete_tx_l2fwd()
1127 	if (rcvd > 0) {  in complete_tx_l2fwd()
1131 		ret = xsk_ring_prod__reserve(&umem->fq, rcvd, &idx_fq);  in complete_tx_l2fwd()
1132 		while (ret != rcvd) {  in complete_tx_l2fwd()
1139 			ret = xsk_ring_prod__reserve(&umem->fq, rcvd, &idx_fq);  in complete_tx_l2fwd()
1142 		for (i = 0; i < rcvd; i++)  in complete_tx_l2fwd()
1146 		xsk_ring_prod__submit(&xsk->umem->fq, rcvd);  in complete_tx_l2fwd()
1147 		xsk_ring_cons__release(&xsk->umem->cq, rcvd);  in complete_tx_l2fwd()
1148 		xsk->outstanding_tx -= rcvd;  in complete_tx_l2fwd()
1149 		xsk->ring_stats.tx_npkts += rcvd;  in complete_tx_l2fwd()
1156 	unsigned int rcvd;  in complete_tx_only()  local
1167 	rcvd = xsk_ring_cons__peek(&xsk->umem->cq, batch_size, &idx);  in complete_tx_only()
1168 	if (rcvd > 0) {  in complete_tx_only()
1169 		xsk_ring_cons__release(&xsk->umem->cq, rcvd);  in complete_tx_only()
1170 		xsk->outstanding_tx -= rcvd;  in complete_tx_only()
1171 		xsk->ring_stats.tx_npkts += rcvd;  in complete_tx_only()
1177 	unsigned int rcvd, i;  in rx_drop()  local
1181 	rcvd = xsk_ring_cons__peek(&xsk->rx, opt_batch_size, &idx_rx);  in rx_drop()
1182 	if (!rcvd) {  in rx_drop()
1190 	ret = xsk_ring_prod__reserve(&xsk->umem->fq, rcvd, &idx_fq);  in rx_drop()
1191 	while (ret != rcvd) {  in rx_drop()
1198 		ret = xsk_ring_prod__reserve(&xsk->umem->fq, rcvd, &idx_fq);  in rx_drop()
1201 	for (i = 0; i < rcvd; i++) {  in rx_drop()
1213 	xsk_ring_prod__submit(&xsk->umem->fq, rcvd);  in rx_drop()
1214 	xsk_ring_cons__release(&xsk->rx, rcvd);  in rx_drop()
1215 	xsk->ring_stats.rx_npkts += rcvd;  in rx_drop()
1339 	unsigned int rcvd, i;  in l2fwd()  local
1345 	rcvd = xsk_ring_cons__peek(&xsk->rx, opt_batch_size, &idx_rx);  in l2fwd()
1346 	if (!rcvd) {  in l2fwd()
1354 	ret = xsk_ring_prod__reserve(&xsk->tx, rcvd, &idx_tx);  in l2fwd()
1355 	while (ret != rcvd) {  in l2fwd()
1363 		ret = xsk_ring_prod__reserve(&xsk->tx, rcvd, &idx_tx);  in l2fwd()
1366 	for (i = 0; i < rcvd; i++) {  in l2fwd()
1381 	xsk_ring_prod__submit(&xsk->tx, rcvd);  in l2fwd()
1382 	xsk_ring_cons__release(&xsk->rx, rcvd);  in l2fwd()
1384 	xsk->ring_stats.rx_npkts += rcvd;  in l2fwd()
1385 	xsk->outstanding_tx += rcvd;  in l2fwd()