Lines Matching refs:nb_pkts
504 if (pkt_stream->current_pkt_nb >= pkt_stream->nb_pkts)
512 while (pkt_stream->current_pkt_nb < pkt_stream->nb_pkts) {
543 static struct pkt_stream *__pkt_stream_alloc(u32 nb_pkts)
551 pkt_stream->pkts = calloc(nb_pkts, sizeof(*pkt_stream->pkts));
557 pkt_stream->nb_pkts = nb_pkts;
590 while (next_frag++ < pkt_stream->nb_pkts) {
614 static struct pkt_stream *pkt_stream_generate(struct xsk_umem_info *umem, u32 nb_pkts, u32 pkt_len)
619 pkt_stream = __pkt_stream_alloc(nb_pkts);
623 pkt_stream->nb_pkts = nb_pkts;
625 for (i = 0; i < nb_pkts; i++) {
638 return pkt_stream_generate(umem, pkt_stream->nb_pkts, pkt_stream->pkts[0].len);
641 static void pkt_stream_replace(struct test_spec *test, u32 nb_pkts, u32 pkt_len)
645 pkt_stream = pkt_stream_generate(test->ifobj_tx->umem, nb_pkts, pkt_len);
647 pkt_stream = pkt_stream_generate(test->ifobj_rx->umem, nb_pkts, pkt_len);
659 for (i = 1; i < ifobj->pkt_stream->nb_pkts; i += 2)
677 test->ifobj_rx->pkt_stream = pkt_stream_generate(umem, pkt_stream->nb_pkts,
680 for (i = 1; i < pkt_stream->nb_pkts; i += 2)
755 pkt_stream->nb_pkts = pkt_nb;
760 static void pkt_stream_generate_custom(struct test_spec *test, struct pkt *pkts, u32 nb_pkts)
764 pkt_stream = __pkt_stream_generate_custom(test->ifobj_tx, pkts, nb_pkts, true);
767 pkt_stream = __pkt_stream_generate_custom(test->ifobj_rx, pkts, nb_pkts, false);
1226 while (pkt_stream->current_pkt_nb < pkt_stream->nb_pkts) {
1281 if (stats.rx_dropped == ifobject->pkt_stream->nb_pkts / 2 ||
1282 stats.rx_dropped == ifobject->pkt_stream->nb_pkts / 2 - 1)
1342 if (stats.tx_invalid_descs != ifobject->pkt_stream->nb_pkts / 2) {
1344 __func__, stats.tx_invalid_descs, ifobject->pkt_stream->nb_pkts);
1389 u32 idx = 0, filled = 0, buffers_to_fill, nb_pkts;
1402 struct pkt *pkt = pkt_stream_get_next_rx_pkt(pkt_stream, &nb_pkts);
1478 print_verbose("Sending %d packets on interface %s\n", ifobject->pkt_stream->nb_pkts,