Lines Matching refs:nb_enq
692 uint16_t nb_rx, nb_enq, nb_deq, nb_sent; in run_encoding() local
778 nb_enq = rte_bbdev_enqueue_enc_ops(bbdev_id, enc_queue_id, in run_encoding()
780 if (unlikely(nb_enq < nb_rx)) { in run_encoding()
781 pktmbuf_input_free_bulk(&enc_out_pkts[nb_enq], in run_encoding()
782 nb_rx - nb_enq); in run_encoding()
783 rte_bbdev_enc_op_free_bulk(&bbdev_ops_burst[nb_enq], in run_encoding()
784 nb_rx - nb_enq); in run_encoding()
785 lcore_stats->rx_lost_packets += nb_rx - nb_enq; in run_encoding()
787 if (!nb_enq) in run_encoding()
791 lcore_stats->enqueued += nb_enq; in run_encoding()
797 &bbdev_ops_burst[nb_deq], nb_enq - nb_deq); in run_encoding()
798 } while (unlikely(nb_deq < nb_enq)); in run_encoding()
823 uint16_t nb_recv, nb_enq, nb_deq, nb_tx; in run_decoding() local
874 nb_enq = rte_bbdev_enqueue_dec_ops(bbdev_id, bbdev_queue_id, in run_decoding()
876 if (unlikely(nb_enq < nb_recv)) { in run_decoding()
877 pktmbuf_input_free_bulk(&recv_pkts_burst[nb_enq], in run_decoding()
878 nb_recv - nb_enq); in run_decoding()
879 rte_bbdev_dec_op_free_bulk(&bbdev_ops_burst[nb_enq], in run_decoding()
880 nb_recv - nb_enq); in run_decoding()
881 lcore_stats->rx_lost_packets += nb_recv - nb_enq; in run_decoding()
883 if (!nb_enq) in run_decoding()
887 lcore_stats->enqueued += nb_enq; in run_decoding()
893 &bbdev_ops_burst[nb_deq], nb_enq - nb_deq); in run_decoding()
894 } while (unlikely(nb_deq < nb_enq)); in run_decoding()