Lines Matching refs:nb_deq
692 uint16_t nb_rx, nb_enq, nb_deq, nb_sent; in run_encoding() local
794 nb_deq = 0; in run_encoding()
796 nb_deq += rte_bbdev_dequeue_enc_ops(bbdev_id, enc_queue_id, 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()
800 lcore_stats->dequeued += nb_deq; in run_encoding()
803 add_awgn(enc_out_pkts, nb_deq); in run_encoding()
805 rte_bbdev_enc_op_free_bulk(bbdev_ops_burst, nb_deq); in run_encoding()
809 nb_deq, NULL); in run_encoding()
810 if (unlikely(nb_sent < nb_deq)) { in run_encoding()
812 nb_deq - nb_sent); in run_encoding()
813 lcore_stats->enc_to_dec_lost_packets += nb_deq - nb_sent; in run_encoding()
823 uint16_t nb_recv, nb_enq, nb_deq, nb_tx; in run_decoding() local
890 nb_deq = 0; in run_decoding()
892 nb_deq += rte_bbdev_dequeue_dec_ops(bbdev_id, bbdev_queue_id, 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()
896 lcore_stats->dequeued += nb_deq; in run_decoding()
898 rte_bbdev_dec_op_free_bulk(bbdev_ops_burst, nb_deq); in run_decoding()
900 verify_data(recv_pkts_burst, nb_deq); in run_decoding()
903 for (i = 0; i < nb_deq; ++i) in run_decoding()
907 nb_tx = rte_eth_tx_burst(port_id, tx_queue_id, recv_pkts_burst, nb_deq); in run_decoding()
908 if (unlikely(nb_tx < nb_deq)) { in run_decoding()
910 nb_deq - nb_tx); in run_decoding()
911 lcore_stats->tx_lost_packets += nb_deq - nb_tx; in run_decoding()