Lines Matching refs:nb_enq
699 uint16_t nb_rx, nb_enq, nb_deq, nb_sent; in run_encoding() local
785 nb_enq = rte_bbdev_enqueue_enc_ops(bbdev_id, enc_queue_id, in run_encoding()
787 if (unlikely(nb_enq < nb_rx)) { in run_encoding()
788 pktmbuf_input_free_bulk(&enc_out_pkts[nb_enq], in run_encoding()
789 nb_rx - nb_enq); in run_encoding()
790 rte_bbdev_enc_op_free_bulk(&bbdev_ops_burst[nb_enq], in run_encoding()
791 nb_rx - nb_enq); in run_encoding()
792 lcore_stats->rx_lost_packets += nb_rx - nb_enq; in run_encoding()
794 if (!nb_enq) in run_encoding()
798 lcore_stats->enqueued += nb_enq; in run_encoding()
804 &bbdev_ops_burst[nb_deq], nb_enq - nb_deq); in run_encoding()
805 } while (unlikely(nb_deq < nb_enq)); in run_encoding()
830 uint16_t nb_recv, nb_enq, nb_deq, nb_tx; in run_decoding() local
881 nb_enq = rte_bbdev_enqueue_dec_ops(bbdev_id, bbdev_queue_id, in run_decoding()
883 if (unlikely(nb_enq < nb_recv)) { in run_decoding()
884 pktmbuf_input_free_bulk(&recv_pkts_burst[nb_enq], in run_decoding()
885 nb_recv - nb_enq); in run_decoding()
886 rte_bbdev_dec_op_free_bulk(&bbdev_ops_burst[nb_enq], in run_decoding()
887 nb_recv - nb_enq); in run_decoding()
888 lcore_stats->rx_lost_packets += nb_recv - nb_enq; in run_decoding()
890 if (!nb_enq) in run_decoding()
894 lcore_stats->enqueued += nb_enq; in run_decoding()
900 &bbdev_ops_burst[nb_deq], nb_enq - nb_deq); in run_decoding()
901 } while (unlikely(nb_deq < nb_enq)); in run_decoding()