Lines Matching refs:nb_deq
699 uint16_t nb_rx, nb_enq, nb_deq, nb_sent; in run_encoding() local
801 nb_deq = 0; in run_encoding()
803 nb_deq += rte_bbdev_dequeue_enc_ops(bbdev_id, enc_queue_id, 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()
807 lcore_stats->dequeued += nb_deq; in run_encoding()
810 add_awgn(enc_out_pkts, nb_deq); in run_encoding()
812 rte_bbdev_enc_op_free_bulk(bbdev_ops_burst, nb_deq); in run_encoding()
816 nb_deq, NULL); in run_encoding()
817 if (unlikely(nb_sent < nb_deq)) { in run_encoding()
819 nb_deq - nb_sent); in run_encoding()
820 lcore_stats->enc_to_dec_lost_packets += nb_deq - nb_sent; in run_encoding()
830 uint16_t nb_recv, nb_enq, nb_deq, nb_tx; in run_decoding() local
897 nb_deq = 0; in run_decoding()
899 nb_deq += rte_bbdev_dequeue_dec_ops(bbdev_id, bbdev_queue_id, 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()
903 lcore_stats->dequeued += nb_deq; in run_decoding()
905 rte_bbdev_dec_op_free_bulk(bbdev_ops_burst, nb_deq); in run_decoding()
907 verify_data(recv_pkts_burst, nb_deq); in run_decoding()
910 for (i = 0; i < nb_deq; ++i) in run_decoding()
914 nb_tx = rte_eth_tx_burst(port_id, tx_queue_id, recv_pkts_burst, nb_deq); in run_decoding()
915 if (unlikely(nb_tx < nb_deq)) { in run_decoding()
917 nb_deq - nb_tx); in run_decoding()
918 lcore_stats->tx_lost_packets += nb_deq - nb_tx; in run_decoding()