429 	u32 n_pkts;  member
529 	u32 n_pkts, pos, i;  in port_rx_burst()  local
532 	n_pkts = ARRAY_SIZE(b->addr);  in port_rx_burst()
534 	n_pkts = bcache_cons_check(p->bc, n_pkts);  in port_rx_burst()
535 	if (!n_pkts)  in port_rx_burst()
539 	n_pkts = xsk_ring_cons__peek(&p->rxq, n_pkts, &pos);  in port_rx_burst()
540 	if (!n_pkts) {  in port_rx_burst()
552 	for (i = 0; i < n_pkts; i++) {  in port_rx_burst()
557 	xsk_ring_cons__release(&p->rxq, n_pkts);  in port_rx_burst()
558 	p->n_pkts_rx += n_pkts;  in port_rx_burst()
564 		status = xsk_ring_prod__reserve(&p->umem_fq, n_pkts, &pos);  in port_rx_burst()
565 		if (status == n_pkts)  in port_rx_burst()
578 	for (i = 0; i < n_pkts; i++)  in port_rx_burst()
582 	xsk_ring_prod__submit(&p->umem_fq, n_pkts);  in port_rx_burst()
584 	return n_pkts;  in port_rx_burst()
590 	u32 n_pkts, pos, i;  in port_tx_burst()  local
594 	n_pkts = p->params.bp->umem_cfg.comp_size;  in port_tx_burst()
596 	n_pkts = xsk_ring_cons__peek(&p->umem_cq, n_pkts, &pos);  in port_tx_burst()
598 	for (i = 0; i < n_pkts; i++) {  in port_tx_burst()
604 	xsk_ring_cons__release(&p->umem_cq, n_pkts);  in port_tx_burst()
607 	n_pkts = b->n_pkts;  in port_tx_burst()
610 		status = xsk_ring_prod__reserve(&p->txq, n_pkts, &pos);  in port_tx_burst()
611 		if (status == n_pkts)  in port_tx_burst()
619 	for (i = 0; i < n_pkts; i++) {  in port_tx_burst()
624 	xsk_ring_prod__submit(&p->txq, n_pkts);  in port_tx_burst()
627 	p->n_pkts_tx += n_pkts;  in port_tx_burst()
677 		u32 n_pkts, j;  in thread_func()  local
680 		n_pkts = port_rx_burst(port_rx, brx);  in thread_func()
681 		if (!n_pkts)  in thread_func()
685 		for (j = 0; j < n_pkts; j++) {  in thread_func()
692 			btx->addr[btx->n_pkts] = brx->addr[j];  in thread_func()
693 			btx->len[btx->n_pkts] = brx->len[j];  in thread_func()
694 			btx->n_pkts++;  in thread_func()
696 			if (btx->n_pkts == MAX_BURST_TX) {  in thread_func()
698 				btx->n_pkts = 0;  in thread_func()