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