drivers/net/sxe2/sxe2_queue.c - main - phprus/github_dpdk

drivers/net/sxe2/sxe2_queue.c
81 строка2 KB
Jie Liu
net/sxe2: support VF representors
30 июн 2026, 17:11
30 июн 2026, 17:11635084d
/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright (C), 2025, Wuxi Stars Micro System Technologies Co., Ltd.
 */

#include "sxe2_ethdev.h"
#include "sxe2_queue.h"
#include "sxe2_common_log.h"
#include "sxe2_tx.h"
#include "sxe2_rx.h"

void sxe2_sw_queue_ctx_hw_cap_set(struct sxe2_adapter *adapter,
		struct sxe2_drv_queue_caps *q_caps)
{
	adapter->q_ctxt.qp_cnt_assign = q_caps->queues_cnt;
	adapter->q_ctxt.base_idx_in_pf = q_caps->base_idx_in_pf;
}

int32_t sxe2_queues_init(struct rte_eth_dev *dev)
{
	struct sxe2_adapter *adapter = SXE2_DEV_PRIVATE_TO_ADAPTER(dev);
	int32_t ret = 0;
	uint16_t buf_size;
	uint16_t frame_size;
	struct sxe2_rx_queue *rxq;
	uint16_t nb_rxq;

	if (adapter->is_dev_repr)
		frame_size = SXE2_FRAME_SIZE_MAX - SXE2_ETH_OVERHEAD;
	else
		frame_size = dev->data->mtu + SXE2_ETH_OVERHEAD;

	for (nb_rxq = 0; nb_rxq < dev->data->nb_rx_queues; nb_rxq++) {
		rxq = dev->data->rx_queues[nb_rxq];
		if (!rxq)
			continue;

		buf_size = rte_pktmbuf_data_room_size(rxq->mb_pool) - RTE_PKTMBUF_HEADROOM;
		rxq->rx_buf_len = RTE_ALIGN_FLOOR(buf_size, (1 << SXE2_RXQ_CTX_DBUFF_SHIFT));
		rxq->rx_buf_len = RTE_MIN(rxq->rx_buf_len, SXE2_RX_MAX_DATA_BUF_SIZE);
		if (frame_size > rxq->rx_buf_len)
			dev->data->scattered_rx = 1;
	}

	adapter->ptp_ctxt.mbuf_rx_ts_offset = -1;
	adapter->ptp_ctxt.mbuf_rx_ts_flag = 0;
	if (dev->data->dev_conf.rxmode.offloads & RTE_ETH_RX_OFFLOAD_TIMESTAMP) {
		ret = rte_mbuf_dyn_rx_timestamp_register
			(&adapter->ptp_ctxt.mbuf_rx_ts_offset,
			 (uint64_t *)&adapter->ptp_ctxt.mbuf_rx_ts_flag);
		if (ret)
			PMD_LOG_ERR(INIT, "Failed to enable timestamp offloads, ret=%d", ret);
	}

	return ret;
}

int32_t sxe2_queues_start(struct rte_eth_dev *dev)
{
	int32_t ret = 0;

	ret = sxe2_txqs_all_start(dev);
	if (ret) {
		PMD_LOG_ERR(INIT, "Failed to start tx queue.");
		goto l_end;
	}

	ret = sxe2_rxqs_all_start(dev);
	if (ret) {
		PMD_LOG_ERR(INIT, "Failed to start rx queue.");
		sxe2_txqs_all_stop(dev);
	}
l_end:
	return ret;
}

void sxe2_queues_release(struct rte_eth_dev *dev)
{
	sxe2_all_rxqs_release(dev);

	sxe2_all_txqs_release(dev);
}