| 613 | } |
| 614 | |
| 615 | static uint16_t |
| 616 | dpaa_eth_queue_portal_rx(struct qman_fq *fq, |
| 617 | struct rte_mbuf **bufs, |
| 618 | uint16_t nb_bufs) |
| 619 | { |
| 620 | int ret; |
| 621 | |
| 622 | if (unlikely(!fq->qp_initialized)) { |
| 623 | ret = rte_dpaa_portal_fq_init((void *)0, fq); |
| 624 | if (ret) { |
| 625 | DPAA_PMD_ERR("Failure in affining portal %d", ret); |
| 626 | return 0; |
| 627 | } |
| 628 | fq->qp_initialized = 1; |
| 629 | } |
| 630 | |
| 631 | return qman_portal_poll_rx(nb_bufs, (void **)bufs, fq->qp); |
| 632 | } |
| 633 | |
| 634 | enum qman_cb_dqrr_result |
| 635 | dpaa_rx_cb_parallel(void *event, |
no test coverage detected