Function dequeue_event_callback

dpdk/app/test-bbdev/test_bbdev_perf.c:3181–3337

}

static void
dequeue_event_callback(uint16_t dev_id,
		enum rte_bbdev_event_type event, void *cb_arg,
		void *ret_param)
{
	int ret;
	uint16_t i;
	uint64_t total_time;
	uint16_t deq, burst_sz, num_ops;
	uint16_t queue_id = *(uint16_t *) ret_param;
	struct rte_bbdev_info info;
	double tb_len_bits;
	struct thread_params *tp = cb_arg;

	/* Find matching thread params using queue_id */
	for (i = 0; i < MAX_QUEUES; ++i, ++tp)
		if (tp->queue_id == queue_id)
			break;

	if (i == MAX_QUEUES) {
		printf("%s: Queue_id from interrupt details was not found!\n",
				__func__);
		return;
	}

	if (unlikely(event != RTE_BBDEV_EVENT_DEQUEUE)) {
		__atomic_store_n(&tp->processing_status, TEST_FAILED, __ATOMIC_RELAXED);
		printf(
			"Dequeue interrupt handler called for incorrect event!\n");
		return;
	}

	burst_sz = __atomic_load_n(&tp->burst_sz, __ATOMIC_RELAXED);
	num_ops = tp->op_params->num_to_process;

	if (test_vector.op_type == RTE_BBDEV_OP_TURBO_DEC)
		deq = rte_bbdev_dequeue_dec_ops(dev_id, queue_id,
				&tp->dec_ops[
					__atomic_load_n(&tp->nb_dequeued, __ATOMIC_RELAXED)],
				burst_sz);
	else if (test_vector.op_type == RTE_BBDEV_OP_LDPC_DEC)
		deq = rte_bbdev_dequeue_ldpc_dec_ops(dev_id, queue_id,
				&tp->dec_ops[
					__atomic_load_n(&tp->nb_dequeued, __ATOMIC_RELAXED)],
				burst_sz);
	else if (test_vector.op_type == RTE_BBDEV_OP_LDPC_ENC)
		deq = rte_bbdev_dequeue_ldpc_enc_ops(dev_id, queue_id,
				&tp->enc_ops[
					__atomic_load_n(&tp->nb_dequeued, __ATOMIC_RELAXED)],
				burst_sz);
	else if (test_vector.op_type == RTE_BBDEV_OP_FFT)
		deq = rte_bbdev_dequeue_fft_ops(dev_id, queue_id,
				&tp->fft_ops[
					__atomic_load_n(&tp->nb_dequeued, __ATOMIC_RELAXED)],
				burst_sz);
	else if (test_vector.op_type == RTE_BBDEV_OP_MLDTS)
		deq = rte_bbdev_dequeue_mldts_ops(dev_id, queue_id,
				&tp->mldts_ops[