1129 	unsigned int rcvd;  in complete_tx_l2fwd()  local
1149 	rcvd = xsk_ring_cons__peek(&umem->cq, ndescs, &idx_cq);  in complete_tx_l2fwd()
1150 	if (rcvd > 0) {  in complete_tx_l2fwd()
1154 		ret = xsk_ring_prod__reserve(&umem->fq, rcvd, &idx_fq);  in complete_tx_l2fwd()
1155 		while (ret != rcvd) {  in complete_tx_l2fwd()
1163 			ret = xsk_ring_prod__reserve(&umem->fq, rcvd, &idx_fq);  in complete_tx_l2fwd()
1166 		for (i = 0; i < rcvd; i++)  in complete_tx_l2fwd()
1170 		xsk_ring_prod__submit(&xsk->umem->fq, rcvd);  in complete_tx_l2fwd()
1171 		xsk_ring_cons__release(&xsk->umem->cq, rcvd);  in complete_tx_l2fwd()
1172 		xsk->outstanding_tx -= rcvd;  in complete_tx_l2fwd()
1179 	unsigned int rcvd;  in complete_tx_only()  local
1190 	rcvd = xsk_ring_cons__peek(&xsk->umem->cq, batch_size, &idx);  in complete_tx_only()
1191 	if (rcvd > 0) {  in complete_tx_only()
1192 		xsk_ring_cons__release(&xsk->umem->cq, rcvd);  in complete_tx_only()
1193 		xsk->outstanding_tx -= rcvd;  in complete_tx_only()
1199 	unsigned int rcvd, i;  in rx_drop()  local
1203 	rcvd = xsk_ring_cons__peek(&xsk->rx, opt_batch_size, &idx_rx);  in rx_drop()
1204 	if (!rcvd) {  in rx_drop()
1212 	ret = xsk_ring_prod__reserve(&xsk->umem->fq, rcvd, &idx_fq);  in rx_drop()
1213 	while (ret != rcvd) {  in rx_drop()
1220 		ret = xsk_ring_prod__reserve(&xsk->umem->fq, rcvd, &idx_fq);  in rx_drop()
1223 	for (i = 0; i < rcvd; i++) {  in rx_drop()
1235 	xsk_ring_prod__submit(&xsk->umem->fq, rcvd);  in rx_drop()
1236 	xsk_ring_cons__release(&xsk->rx, rcvd);  in rx_drop()
1237 	xsk->ring_stats.rx_npkts += rcvd;  in rx_drop()
1362 	unsigned int rcvd, i;  in l2fwd()  local
1368 	rcvd = xsk_ring_cons__peek(&xsk->rx, opt_batch_size, &idx_rx);  in l2fwd()
1369 	if (!rcvd) {  in l2fwd()
1376 	xsk->ring_stats.rx_npkts += rcvd;  in l2fwd()
1378 	ret = xsk_ring_prod__reserve(&xsk->tx, rcvd, &idx_tx);  in l2fwd()
1379 	while (ret != rcvd) {  in l2fwd()
1387 		ret = xsk_ring_prod__reserve(&xsk->tx, rcvd, &idx_tx);  in l2fwd()
1390 	for (i = 0; i < rcvd; i++) {  in l2fwd()
1405 	xsk_ring_prod__submit(&xsk->tx, rcvd);  in l2fwd()
1406 	xsk_ring_cons__release(&xsk->rx, rcvd);  in l2fwd()
1408 	xsk->ring_stats.tx_npkts += rcvd;  in l2fwd()
1409 	xsk->outstanding_tx += rcvd;  in l2fwd()