Function dpaa_eth_queue_rx

dpdk/drivers/net/dpaa/dpaa_rxtx.c:739–795

#endif

uint16_t dpaa_eth_queue_rx(void *q,
			   struct rte_mbuf **bufs,
			   uint16_t nb_bufs)
{
	struct qman_fq *fq = q;
	struct qm_dqrr_entry *dq;
	uint32_t num_rx = 0, ifid = ((struct dpaa_if *)fq->dpaa_intf)->ifid;
	int num_rx_bufs, ret;
	uint32_t vdqcr_flags = 0;

	if (unlikely(rte_dpaa_bpid_info == NULL &&
				rte_eal_process_type() == RTE_PROC_SECONDARY))
		rte_dpaa_bpid_info = fq->bp_array;

#ifdef RTE_LIBRTE_DPAA_DEBUG_DRIVER
	if (fq->fqid == ((struct dpaa_if *)fq->dpaa_intf)->rx_queues[0].fqid)
		dpaa_eth_err_queue((struct dpaa_if *)fq->dpaa_intf);
#endif

	if (likely(fq->is_static))
		return dpaa_eth_queue_portal_rx(fq, bufs, nb_bufs);

	if (unlikely(!DPAA_PER_LCORE_PORTAL)) {
		ret = rte_dpaa_portal_init((void *)0);
		if (ret) {
			DPAA_PMD_ERR("Failure in affining portal");
			return 0;
		}
	}

	/* Until request for four buffers, we provide exact number of buffers.
	 * Otherwise we do not set the QM_VDQCR_EXACT flag.
	 * Not setting QM_VDQCR_EXACT flag can provide two more buffers than
	 * requested, so we request two less in this case.
	 */
	if (nb_bufs < 4) {
		vdqcr_flags = QM_VDQCR_EXACT;
		num_rx_bufs = nb_bufs;
	} else {
		num_rx_bufs = nb_bufs > DPAA_MAX_DEQUEUE_NUM_FRAMES ?
			(DPAA_MAX_DEQUEUE_NUM_FRAMES - 2) : (nb_bufs - 2);
	}
	ret = qman_set_vdq(fq, num_rx_bufs, vdqcr_flags);
	if (ret)
		return 0;

	do {
		dq = qman_dequeue(fq);
		if (!dq)
			continue;
		bufs[num_rx++] = dpaa_eth_fd_to_mbuf(&dq->fd, ifid);
		dpaa_display_frame_info(&dq->fd, fq->fqid, true);
		qman_dqrr_consume(fq, dq);
	} while (fq->flags & QMAN_FQ_STATE_VDQCR);

	return num_rx;
}