Lines Matching refs:nb_pkts
558 if (pkt_nb >= pkt_stream->nb_pkts) in pkt_stream_get_pkt()
566 while (pkt_stream->rx_pkt_nb < pkt_stream->nb_pkts) { in pkt_stream_get_next_rx_pkt()
597 static struct pkt_stream *__pkt_stream_alloc(u32 nb_pkts) in __pkt_stream_alloc() argument
605 pkt_stream->pkts = calloc(nb_pkts, sizeof(*pkt_stream->pkts)); in __pkt_stream_alloc()
611 pkt_stream->nb_pkts = nb_pkts; in __pkt_stream_alloc()
625 static struct pkt_stream *pkt_stream_generate(struct xsk_umem_info *umem, u32 nb_pkts, u32 pkt_len) in pkt_stream_generate() argument
630 pkt_stream = __pkt_stream_alloc(nb_pkts); in pkt_stream_generate()
634 pkt_stream->nb_pkts = nb_pkts; in pkt_stream_generate()
635 for (i = 0; i < nb_pkts; i++) { in pkt_stream_generate()
647 return pkt_stream_generate(umem, pkt_stream->nb_pkts, pkt_stream->pkts[0].len); in pkt_stream_clone()
650 static void pkt_stream_replace(struct test_spec *test, u32 nb_pkts, u32 pkt_len) in pkt_stream_replace() argument
654 pkt_stream = pkt_stream_generate(test->ifobj_tx->umem, nb_pkts, pkt_len); in pkt_stream_replace()
656 pkt_stream = pkt_stream_generate(test->ifobj_rx->umem, nb_pkts, pkt_len); in pkt_stream_replace()
668 for (i = 1; i < ifobj->pkt_stream->nb_pkts; i += 2) in __pkt_stream_replace_half()
687 test->ifobj_rx->pkt_stream = pkt_stream_generate(umem, pkt_stream->nb_pkts, in pkt_stream_receive_half()
690 for (i = 1; i < pkt_stream->nb_pkts; i += 2) in pkt_stream_receive_half()
721 struct pkt *pkts, u32 nb_pkts) in __pkt_stream_generate_custom() argument
726 pkt_stream = __pkt_stream_alloc(nb_pkts); in __pkt_stream_generate_custom()
730 for (i = 0; i < nb_pkts; i++) { in __pkt_stream_generate_custom()
740 static void pkt_stream_generate_custom(struct test_spec *test, struct pkt *pkts, u32 nb_pkts) in pkt_stream_generate_custom() argument
742 __pkt_stream_generate_custom(test->ifobj_tx, pkts, nb_pkts); in pkt_stream_generate_custom()
743 __pkt_stream_generate_custom(test->ifobj_rx, pkts, nb_pkts); in pkt_stream_generate_custom()
1080 while (pkt_cnt < ifobject->pkt_stream->nb_pkts) { in send_pkts()
1127 if (stats.rx_dropped == ifobject->pkt_stream->nb_pkts / 2) in validate_rx_dropped()
1187 if (stats.tx_invalid_descs != ifobject->pkt_stream->nb_pkts / 2) { in validate_tx_invalid_descs()
1189 __func__, stats.tx_invalid_descs, ifobject->pkt_stream->nb_pkts); in validate_tx_invalid_descs()
1309 print_verbose("Sending %d packets on interface %s\n", ifobject->pkt_stream->nb_pkts, in worker_testapp_validate_tx()