576 	if (pkt_nb >= pkt_stream->nb_pkts)  in pkt_stream_get_pkt()
584 	while (pkt_stream->rx_pkt_nb < pkt_stream->nb_pkts) {  in pkt_stream_get_next_rx_pkt()
615 static struct pkt_stream *__pkt_stream_alloc(u32 nb_pkts)  in __pkt_stream_alloc()  argument
623 	pkt_stream->pkts = calloc(nb_pkts, sizeof(*pkt_stream->pkts));  in __pkt_stream_alloc()
629 	pkt_stream->nb_pkts = nb_pkts;  in __pkt_stream_alloc()
643 static struct pkt_stream *pkt_stream_generate(struct xsk_umem_info *umem, u32 nb_pkts, u32 pkt_len)  in pkt_stream_generate()  argument
648 	pkt_stream = __pkt_stream_alloc(nb_pkts);  in pkt_stream_generate()
652 	pkt_stream->nb_pkts = nb_pkts;  in pkt_stream_generate()
653 	for (i = 0; i < nb_pkts; i++) {  in pkt_stream_generate()
665 	return pkt_stream_generate(umem, pkt_stream->nb_pkts, pkt_stream->pkts[0].len);  in pkt_stream_clone()
668 static void pkt_stream_replace(struct test_spec *test, u32 nb_pkts, u32 pkt_len)  in pkt_stream_replace()  argument
672 	pkt_stream = pkt_stream_generate(test->ifobj_tx->umem, nb_pkts, pkt_len);  in pkt_stream_replace()
674 	pkt_stream = pkt_stream_generate(test->ifobj_rx->umem, nb_pkts, pkt_len);  in pkt_stream_replace()
686 	for (i = 1; i < ifobj->pkt_stream->nb_pkts; i += 2)  in __pkt_stream_replace_half()
705 	test->ifobj_rx->pkt_stream = pkt_stream_generate(umem, pkt_stream->nb_pkts,  in pkt_stream_receive_half()
708 	for (i = 1; i < pkt_stream->nb_pkts; i += 2)  in pkt_stream_receive_half()
739 					 struct pkt *pkts, u32 nb_pkts)  in __pkt_stream_generate_custom()  argument
744 	pkt_stream = __pkt_stream_alloc(nb_pkts);  in __pkt_stream_generate_custom()
748 	for (i = 0; i < nb_pkts; i++) {  in __pkt_stream_generate_custom()
758 static void pkt_stream_generate_custom(struct test_spec *test, struct pkt *pkts, u32 nb_pkts)  in pkt_stream_generate_custom()  argument
760 	__pkt_stream_generate_custom(test->ifobj_tx, pkts, nb_pkts);  in pkt_stream_generate_custom()
761 	__pkt_stream_generate_custom(test->ifobj_rx, pkts, nb_pkts);  in pkt_stream_generate_custom()
1097 	while (pkt_cnt < ifobject->pkt_stream->nb_pkts) {  in send_pkts()
1144 	if (stats.rx_dropped == ifobject->pkt_stream->nb_pkts / 2)  in validate_rx_dropped()
1204 	if (stats.tx_invalid_descs != ifobject->pkt_stream->nb_pkts / 2) {  in validate_tx_invalid_descs()
1206 			       __func__, stats.tx_invalid_descs, ifobject->pkt_stream->nb_pkts);  in validate_tx_invalid_descs()
1352 	print_verbose("Sending %d packets on interface %s\n", ifobject->pkt_stream->nb_pkts,  in worker_testapp_validate_tx()