Function ena_tx_cleanup

dpdk/drivers/net/ena/ena_ethdev.c:3103–3175

}

static int ena_tx_cleanup(void *txp, uint32_t free_pkt_cnt)
{
	struct rte_mbuf *pkts_to_clean[ENA_CLEANUP_BUF_THRESH];
	struct ena_ring *tx_ring = (struct ena_ring *)txp;
	size_t mbuf_cnt = 0;
	size_t pkt_cnt = 0;
	unsigned int total_tx_descs = 0;
	unsigned int total_tx_pkts = 0;
	uint16_t cleanup_budget;
	uint16_t next_to_clean = tx_ring->next_to_clean;
	bool fast_free = tx_ring->offloads & RTE_ETH_TX_OFFLOAD_MBUF_FAST_FREE;

	/*
	 * If free_pkt_cnt is equal to 0, it means that the user requested
	 * full cleanup, so attempt to release all Tx descriptors
	 * (ring_size - 1 -> size_mask)
	 */
	cleanup_budget = (free_pkt_cnt == 0) ? tx_ring->size_mask : free_pkt_cnt;

	while (likely(total_tx_pkts < cleanup_budget)) {
		struct rte_mbuf *mbuf;
		struct ena_tx_buffer *tx_info;
		uint16_t req_id;

		if (ena_com_tx_comp_req_id_get(tx_ring->ena_com_io_cq, &req_id) != 0)
			break;

		if (unlikely(validate_tx_req_id(tx_ring, req_id) != 0))
			break;

		/* Get Tx info & store how many descs were processed  */
		tx_info = &tx_ring->tx_buffer_info[req_id];
		tx_info->timestamp = 0;

		mbuf = tx_info->mbuf;
		if (fast_free) {
			pkts_to_clean[pkt_cnt++] = mbuf;
			mbuf_cnt += mbuf->nb_segs;
			if (mbuf_cnt >= ENA_CLEANUP_BUF_THRESH) {
				rte_pktmbuf_free_bulk(pkts_to_clean, pkt_cnt);
				mbuf_cnt = 0;
				pkt_cnt = 0;
			}
		} else {
			rte_pktmbuf_free(mbuf);
		}

		tx_info->mbuf = NULL;
		tx_ring->empty_tx_reqs[next_to_clean] = req_id;

		total_tx_descs += tx_info->tx_descs;
		total_tx_pkts++;

		/* Put back descriptor to the ring for reuse */
		next_to_clean = ENA_IDX_NEXT_MASKED(next_to_clean,
			tx_ring->size_mask);
	}