415 static struct pkt *pkt_stream_get_pkt(struct pkt_stream *pkt_stream, u32 pkt_nb)  in pkt_stream_get_pkt()  argument
417 	if (pkt_nb >= pkt_stream->nb_pkts)  in pkt_stream_get_pkt()
420 	return &pkt_stream->pkts[pkt_nb];  in pkt_stream_get_pkt()
423 static struct pkt_stream *pkt_stream_generate(u32 nb_pkts, u32 pkt_len)  in pkt_stream_generate()
425 	struct pkt_stream *pkt_stream;  in pkt_stream_generate()  local
428 	pkt_stream = malloc(sizeof(*pkt_stream));  in pkt_stream_generate()
429 	if (!pkt_stream)  in pkt_stream_generate()
432 	pkt_stream->pkts = calloc(nb_pkts, sizeof(*pkt_stream->pkts));  in pkt_stream_generate()
433 	if (!pkt_stream->pkts)  in pkt_stream_generate()
436 	pkt_stream->nb_pkts = nb_pkts;  in pkt_stream_generate()
438 		pkt_stream->pkts[i].addr = (i % num_frames) * XSK_UMEM__DEFAULT_FRAME_SIZE;  in pkt_stream_generate()
439 		pkt_stream->pkts[i].len = pkt_len;  in pkt_stream_generate()
440 		pkt_stream->pkts[i].payload = i;  in pkt_stream_generate()
443 	return pkt_stream;  in pkt_stream_generate()
448 	struct pkt *pkt = pkt_stream_get_pkt(ifobject->pkt_stream, pkt_nb);  in pkt_generate()
574 static void receive_pkts(struct pkt_stream *pkt_stream, struct xsk_socket_info *xsk,  in receive_pkts()  argument
581 	pkt = pkt_stream_get_pkt(pkt_stream, pkt_count++);  in receive_pkts()
615 			pkt = pkt_stream_get_pkt(pkt_stream, pkt_count++);  in receive_pkts()
667 	while (pkt_cnt < ifobject->pkt_stream->nb_pkts) {  in send_pkts()
691 	u32 xsk_stat = 0, expected_stat = ifobject->pkt_stream->nb_pkts;  in rx_stats_are_valid()
747 	if (stats.tx_invalid_descs == ifobject->pkt_stream->nb_pkts)  in tx_stats_validate()
751 			      __func__, stats.tx_invalid_descs, ifobject->pkt_stream->nb_pkts);  in tx_stats_validate()
820 	print_verbose("Sending %d packets on interface %s\n", ifobject->pkt_stream->nb_pkts,  in worker_testapp_validate_tx()
852 		receive_pkts(ifobject->pkt_stream, ifobject->xsk, fds);  in worker_testapp_validate_rx()
865 	struct pkt_stream *pkt_stream;  in testapp_validate()  local
871 		pkt_stream = pkt_stream_generate(DEFAULT_PKT_CNT, XSK_UMEM__INVALID_FRAME_SIZE);  in testapp_validate()
873 		pkt_stream = pkt_stream_generate(DEFAULT_PKT_CNT, PKT_SIZE);  in testapp_validate()
874 	ifdict_tx->pkt_stream = pkt_stream;  in testapp_validate()
875 	ifdict_rx->pkt_stream = pkt_stream;  in testapp_validate()