609 	if (pkt_stream->current_pkt_nb >= pkt_stream->nb_pkts)  in pkt_stream_get_next_tx_pkt()
617 	while (pkt_stream->current_pkt_nb < pkt_stream->nb_pkts) {  in pkt_stream_get_next_rx_pkt()
648 static struct pkt_stream *__pkt_stream_alloc(u32 nb_pkts)  in __pkt_stream_alloc()  argument
656 	pkt_stream->pkts = calloc(nb_pkts, sizeof(*pkt_stream->pkts));  in __pkt_stream_alloc()
662 	pkt_stream->nb_pkts = nb_pkts;  in __pkt_stream_alloc()
695 	while (next_frag++ < pkt_stream->nb_pkts) {  in pkt_nb_frags()
729 static struct pkt_stream *__pkt_stream_generate(u32 nb_pkts, u32 pkt_len, u32 nb_start, u32 nb_off)  in __pkt_stream_generate()  argument
734 	pkt_stream = __pkt_stream_alloc(nb_pkts);  in __pkt_stream_generate()
738 	pkt_stream->nb_pkts = nb_pkts;  in __pkt_stream_generate()
740 	for (i = 0; i < nb_pkts; i++) {  in __pkt_stream_generate()
750 static struct pkt_stream *pkt_stream_generate(u32 nb_pkts, u32 pkt_len)  in pkt_stream_generate()  argument
752 	return __pkt_stream_generate(nb_pkts, pkt_len, 0, 1);  in pkt_stream_generate()
757 	return pkt_stream_generate(pkt_stream->nb_pkts, pkt_stream->pkts[0].len);  in pkt_stream_clone()
760 static void pkt_stream_replace(struct test_spec *test, u32 nb_pkts, u32 pkt_len)  in pkt_stream_replace()  argument
764 	pkt_stream = pkt_stream_generate(nb_pkts, pkt_len);  in pkt_stream_replace()
766 	pkt_stream = pkt_stream_generate(nb_pkts, pkt_len);  in pkt_stream_replace()
777 	for (i = 1; i < ifobj->xsk->pkt_stream->nb_pkts; i += 2)  in __pkt_stream_replace_half()
794 	test->ifobj_rx->xsk->pkt_stream = pkt_stream_generate(pkt_stream->nb_pkts,  in pkt_stream_receive_half()
797 	for (i = 1; i < pkt_stream->nb_pkts; i += 2)  in pkt_stream_receive_half()
810 		pkt_stream = __pkt_stream_generate(pkt_stream->nb_pkts / 2,  in pkt_stream_even_odd_sequence()
815 		pkt_stream = __pkt_stream_generate(pkt_stream->nb_pkts / 2,  in pkt_stream_even_odd_sequence()
899 	pkt_stream->nb_pkts = pkt_nb;  in __pkt_stream_generate_custom()
904 static void pkt_stream_generate_custom(struct test_spec *test, struct pkt *pkts, u32 nb_pkts)  in pkt_stream_generate_custom()  argument
908 	pkt_stream = __pkt_stream_generate_custom(test->ifobj_tx, pkts, nb_pkts, true);  in pkt_stream_generate_custom()
911 	pkt_stream = __pkt_stream_generate_custom(test->ifobj_rx, pkts, nb_pkts, false);  in pkt_stream_generate_custom()
1463 			if (!pkt_stream || pkt_stream->current_pkt_nb >= pkt_stream->nb_pkts) {  in send_pkts()
1529 	if (stats.rx_dropped == ifobject->xsk->pkt_stream->nb_pkts / 2 ||  in validate_rx_dropped()
1530 	    stats.rx_dropped == ifobject->xsk->pkt_stream->nb_pkts / 2 - 1)  in validate_rx_dropped()
1594 	if (stats.tx_invalid_descs != ifobject->xsk->pkt_stream->nb_pkts / 2) {  in validate_tx_invalid_descs()
1598 			       ifobject->xsk->pkt_stream->nb_pkts);  in validate_tx_invalid_descs()
1643 	u32 idx = 0, filled = 0, buffers_to_fill, nb_pkts;  in xsk_populate_fill_ring()  local
1656 		struct pkt *pkt = pkt_stream_get_next_rx_pkt(pkt_stream, &nb_pkts);  in xsk_populate_fill_ring()