Function ntb_dequeue_bufs

dpdk/drivers/raw/ntb/ntb.c:714–820

}

static int
ntb_dequeue_bufs(struct rte_rawdev *dev,
		 struct rte_rawdev_buf **buffers,
		 unsigned int count,
		 rte_rawdev_obj_t context)
{
	struct ntb_hw *hw = dev->dev_private;
	struct ntb_rx_queue *rxq = hw->rx_queues[(size_t)context];
	struct ntb_rx_entry *sw_ring = rxq->sw_ring;
	struct ntb_desc rx_desc[NTB_MAX_DESC_SIZE];
	struct rte_mbuf *first, *rxm_t;
	struct rte_mbuf *prev = NULL;
	volatile struct ntb_used *rx_item;
	uint16_t nb_mbufs = 0;
	uint16_t nb_rx = 0;
	uint64_t bytes = 0;
	uint16_t off, last_avail, used_cnt, used_nb;
	int i;

	if (unlikely(dev->started == 0 || hw->peer_dev_up == 0)) {
		NTB_LOG(DEBUG, "Link is not up");
		return nb_rx;
	}

	used_cnt = *rxq->used_cnt;

	if (rxq->last_used == used_cnt)
		return nb_rx;

	last_avail = rxq->last_avail;
	used_nb = (used_cnt - rxq->last_used) & (rxq->nb_rx_desc - 1);
	count = RTE_MIN(count, used_nb);
	for (nb_rx = 0; nb_rx < count; nb_rx++) {
		i = 0;
		while (true) {
			rx_item = rxq->rx_used_ring + rxq->last_used;
			rxm_t = sw_ring[rxq->last_used].mbuf;
			rxm_t->data_len = rx_item->len;
			rxm_t->data_off = RTE_PKTMBUF_HEADROOM;
			rxm_t->port = rxq->port_id;

			if (!i) {
				rxm_t->nb_segs = 1;
				first = rxm_t;
				first->pkt_len = 0;
				buffers[nb_rx]->buf_addr = rxm_t;
			} else {
				prev->next = rxm_t;
				first->nb_segs++;
			}

			prev = rxm_t;
			first->pkt_len += prev->data_len;
			rxq->last_used = (rxq->last_used + 1) &
					 (rxq->nb_rx_desc - 1);

			/* alloc new mbuf */
			rxm_t = rte_mbuf_raw_alloc(rxq->mpool);