From mboxrd@z Thu Jan  1 00:00:00 1970
From: Ferruh Yigit <ferruh.yigit@intel.com>
Subject: Re: [PATCH 20/32] net/dpaa2: add queue configuration
 support
Date: Tue, 6 Dec 2016 19:49:49 +0000
Message-ID: <4a688759-269f-3556-e32c-df14ccfa3b9a@intel.com>
References: <1480875447-23680-1-git-send-email-hemant.agrawal@nxp.com>
 <1480875447-23680-21-git-send-email-hemant.agrawal@nxp.com>
Mime-Version: 1.0
Content-Type: text/plain; charset=windows-1252
Content-Transfer-Encoding: 8bit
Cc: thomas.monjalon@6wind.com, bruce.richardson@intel.com,
 shreyansh.jain@nxp.com
To: Hemant Agrawal <hemant.agrawal@nxp.com>, dev@dpdk.org
Return-path: <dev-bounces@dpdk.org>
Received: from mga06.intel.com (mga06.intel.com [134.134.136.31])
 by dpdk.org (Postfix) with ESMTP id 6FEFFFA3C
 for <dev@dpdk.org>; Tue,  6 Dec 2016 20:49:53 +0100 (CET)
In-Reply-To: <1480875447-23680-21-git-send-email-hemant.agrawal@nxp.com>
List-Id: DPDK patches and discussions <dev.dpdk.org>
List-Unsubscribe: <http://dpdk.org/ml/options/dev>,
 <mailto:dev-request@dpdk.org?subject=unsubscribe>
List-Archive: <http://dpdk.org/ml/archives/dev/>
List-Post: <mailto:dev@dpdk.org>
List-Help: <mailto:dev-request@dpdk.org?subject=help>
List-Subscribe: <http://dpdk.org/ml/listinfo/dev>,
 <mailto:dev-request@dpdk.org?subject=subscribe>
Errors-To: dev-bounces@dpdk.org
Sender: "dev" <dev-bounces@dpdk.org>

On 12/4/2016 6:17 PM, Hemant Agrawal wrote:
> Signed-off-by: Hemant Agrawal <hemant.agrawal@nxp.com>
> ---
>  doc/guides/nics/features/dpaa2.ini     |   1 +
>  drivers/net/dpaa2/base/dpaa2_hw_dpni.h |  14 +-
>  drivers/net/dpaa2/base/dpaa2_hw_pvt.h  |  21 +++
>  drivers/net/dpaa2/dpaa2_ethdev.c       | 254 ++++++++++++++++++++++++++++++++-
>  4 files changed, 288 insertions(+), 2 deletions(-)
> 
> diff --git a/doc/guides/nics/features/dpaa2.ini b/doc/guides/nics/features/dpaa2.ini
> index b176208..0b59725 100644
> --- a/doc/guides/nics/features/dpaa2.ini
> +++ b/doc/guides/nics/features/dpaa2.ini
> @@ -4,6 +4,7 @@
>  ; Refer to default.ini for the full list of available PMD features.
>  ;
>  [Features]
> +Queue start/stop     = Y
>  Linux VFIO           = Y
>  ARMv8                = Y
>  Usage doc            = Y
> diff --git a/drivers/net/dpaa2/base/dpaa2_hw_dpni.h b/drivers/net/dpaa2/base/dpaa2_hw_dpni.h
> index 1b655e4..197fd28 100644
> --- a/drivers/net/dpaa2/base/dpaa2_hw_dpni.h
> +++ b/drivers/net/dpaa2/base/dpaa2_hw_dpni.h
> @@ -36,15 +36,27 @@
>  
>  #include <fsl_dpni.h>
>  #include <fsl_mc_sys.h>
> +
> +#define MAX_RX_QUEUES		16
> +#define MAX_TX_QUEUES		16
> +
> +/*default tc to be used for ,congestion, distribution etc configuration. */
> +#define DPAA2_DEF_TC		0
> +
>  /*! Global MCP list */
>  extern void *(*mcp_ptr_list);
>  
> -
>  struct dpaa2_dev_priv {
>  	void *hw;
>  	int32_t hw_id;
> +	int32_t qdid;
>  	uint16_t token;
> +	uint8_t nb_tx_queues;
> +	uint8_t nb_rx_queues;
> +	void *rx_vq[MAX_RX_QUEUES];
> +	void *tx_vq[MAX_TX_QUEUES];
>  
> +	uint8_t num_tc;
>  	uint8_t flags; /*dpaa2 config flags */
>  };
>  #endif /* _DPAA2_DPNI_H_ */
> diff --git a/drivers/net/dpaa2/base/dpaa2_hw_pvt.h b/drivers/net/dpaa2/base/dpaa2_hw_pvt.h
> index 5038209..867611f 100644
> --- a/drivers/net/dpaa2/base/dpaa2_hw_pvt.h
> +++ b/drivers/net/dpaa2/base/dpaa2_hw_pvt.h
> @@ -37,9 +37,12 @@
>  #include <fsl_mc_sys.h>
>  #include <fsl_qbman_portal.h>
>  
> +#define DPAA2_DQRR_RING_SIZE	16
> +	/** <Maximum number of slots available in RX ring*/
>  
>  #define MC_PORTAL_INDEX		0
>  #define NUM_DPIO_REGIONS	2
> +#define NUM_DQS_PER_QUEUE       2
>  
>  #define MEMPOOL_F_HW_PKT_POOL 0x8000 /**< mpool flag to check offloaded pool */
>  
> @@ -70,6 +73,24 @@ struct dpaa2_dpio_dev {
>  	int32_t hw_id; /**< An unique ID of this DPIO device instance */
>  };
>  
> +struct queue_storage_info_t {
> +	struct qbman_result *dq_storage[NUM_DQS_PER_QUEUE];
> +};
> +
> +struct dpaa2_queue {
> +	struct rte_mempool *mb_pool; /**< mbuf pool to populate RX ring. */
> +	void *dev;
> +	int32_t eventfd;	/*!< Event Fd of this queue */
> +	uint32_t fqid;		/*!< Unique ID of this queue */
> +	uint8_t tc_index;	/*!< traffic class identifier */
> +	uint16_t flow_id;	/*!< To be used by DPAA2 frmework */
> +	uint64_t rx_pkts;
> +	uint64_t tx_pkts;
> +	uint64_t err_pkts;
> +	struct queue_storage_info_t *q_storage;
> +};
> +
>  /*! Global MCP list */
>  extern void *(*mcp_ptr_list);
> +
>  #endif
> diff --git a/drivers/net/dpaa2/dpaa2_ethdev.c b/drivers/net/dpaa2/dpaa2_ethdev.c
> index daf59c1..45c3f8f 100644
> --- a/drivers/net/dpaa2/dpaa2_ethdev.c
> +++ b/drivers/net/dpaa2/dpaa2_ethdev.c
> @@ -46,10 +46,94 @@
>  #include <rte_dpaa2.h>
>  
>  #include <dpaa2_logs.h>
> +#include <base/dpaa2_hw_pvt.h>
>  #include <base/dpaa2_hw_dpni.h>
>  /* DPDK Interfaces */
>  #include <dpaa2_ethdev.h>
>  
> +/* Name of the DPAA2 Net PMD */
> +static const char *drivername = "DPNI PMD";
> +
> +static void
> +dpaa2_dev_info_get(struct rte_eth_dev *dev, struct rte_eth_dev_info *dev_info)
> +{
> +	struct dpaa2_dev_priv *priv = dev->data->dev_private;
> +
> +	PMD_INIT_FUNC_TRACE();
> +
> +	dev_info->driver_name = drivername;

Please check patches
http://dpdk.org/dev/patchwork/patch/17170/
http://dpdk.org/dev/patchwork/patch/17171/

> +	dev_info->if_index = priv->hw_id;
> +
> +	dev_info->max_rx_queues = (uint16_t)priv->nb_rx_queues;
> +	dev_info->max_tx_queues = (uint16_t)priv->nb_tx_queues;
> +}
> +
> +static int
> +dpaa2_alloc_rx_tx_queues(struct rte_eth_dev *dev)
> +{
> +	struct dpaa2_dev_priv *priv = dev->data->dev_private;
> +	uint16_t dist_idx;
> +	uint32_t vq_id;
> +	struct dpaa2_queue *mc_q, *mcq;
> +	uint32_t tot_queues;
> +	int i;
> +	struct dpaa2_queue *dpaa2_q;
> +
> +	PMD_INIT_FUNC_TRACE();
> +
> +	tot_queues = priv->nb_rx_queues + priv->nb_tx_queues;
> +	mc_q = rte_malloc(NULL, sizeof(struct dpaa2_queue) * tot_queues,
> +			  RTE_CACHE_LINE_SIZE);
> +	if (!mc_q) {
> +		PMD_INIT_LOG(ERR, "malloc failed for rx/tx queues\n");
> +		return -1;
> +	}
> +
> +	for (i = 0; i < priv->nb_rx_queues; i++) {
> +		mc_q->dev = dev;
> +		priv->rx_vq[i] = mc_q++;
> +		dpaa2_q = (struct dpaa2_queue *)priv->rx_vq[i];
> +		dpaa2_q->q_storage = rte_malloc("dq_storage",
> +					sizeof(struct queue_storage_info_t),
> +					RTE_CACHE_LINE_SIZE);
> +		if (!dpaa2_q->q_storage)
> +			goto fail;
> +
> +		memset(dpaa2_q->q_storage, 0,
> +		       sizeof(struct queue_storage_info_t));
> +		dpaa2_q->q_storage->dq_storage[0] = rte_malloc(NULL,
> +			DPAA2_DQRR_RING_SIZE * sizeof(struct qbman_result),
> +			RTE_CACHE_LINE_SIZE);
> +	}
> +
> +	for (i = 0; i < priv->nb_tx_queues; i++) {
> +		mc_q->dev = dev;
> +		mc_q->flow_id = DPNI_NEW_FLOW_ID;
> +		priv->tx_vq[i] = mc_q++;
> +	}
> +
> +	vq_id = 0;
> +	for (dist_idx = 0; dist_idx < priv->nb_rx_queues; dist_idx++) {
> +		mcq = (struct dpaa2_queue *)priv->rx_vq[vq_id];
> +		mcq->tc_index = DPAA2_DEF_TC;
> +		mcq->flow_id = dist_idx;
> +		vq_id++;
> +	}
> +
> +	return 0;
> +fail:
> +	i -= 1;
> +	mc_q = priv->rx_vq[0];
> +	while (i >= 0) {
> +		dpaa2_q = (struct dpaa2_queue *)priv->rx_vq[i];
> +		rte_free(dpaa2_q->q_storage->dq_storage[0]);
> +		rte_free(dpaa2_q->q_storage);
> +		priv->rx_vq[i--] = NULL;
> +	}
> +	rte_free(mc_q);
> +	return -1;
> +}
> +
>  static int
>  dpaa2_eth_dev_configure(struct rte_eth_dev *dev)
>  {
> @@ -69,15 +153,134 @@
>  	return 0;
>  }
>  
> +/* Function to setup RX flow information. It contains traffic class ID,
> + * flow ID, destination configuration etc.
> + */
>  static int
> -dpaa2_dev_start(struct rte_eth_dev *dev)
> +dpaa2_dev_rx_queue_setup(struct rte_eth_dev *dev,
> +			 uint16_t rx_queue_id,
> +			 uint16_t nb_rx_desc __rte_unused,
> +			 unsigned int socket_id __rte_unused,
> +			 const struct rte_eth_rxconf *rx_conf __rte_unused,
> +			 struct rte_mempool *mb_pool)
>  {
>  	struct dpaa2_dev_priv *priv = dev->data->dev_private;
>  	struct fsl_mc_io *dpni = (struct fsl_mc_io *)priv->hw;
> +	struct dpaa2_queue *dpaa2_q;
> +	struct dpni_queue cfg;
> +	uint8_t options = 0;
> +	uint8_t flow_id;
> +	int ret;
> +
> +	PMD_INIT_FUNC_TRACE();
> +
> +	PMD_INIT_LOG(DEBUG, "dev =%p, queue =%d, pool = %p, conf =%p",
> +		     dev, rx_queue_id, mb_pool, rx_conf);
> +
> +	dpaa2_q = (struct dpaa2_queue *)priv->rx_vq[rx_queue_id];
> +	dpaa2_q->mb_pool = mb_pool; /**< mbuf pool to populate RX ring. */
> +
> +	/*Get the tc id and flow id from given VQ id*/
> +	flow_id = rx_queue_id;
> +	memset(&cfg, 0, sizeof(struct dpni_queue));
> +
> +	options = options | DPNI_QUEUE_OPT_USER_CTX;
> +	cfg.user_context = (uint64_t)(dpaa2_q);
> +
> +	ret = dpni_set_queue(dpni, CMD_PRI_LOW, priv->token, DPNI_QUEUE_RX,
> +			     dpaa2_q->tc_index, flow_id, options, &cfg);
> +	if (ret) {
> +		PMD_INIT_LOG(ERR, "Error in setting the rx flow: = %d\n", ret);
> +		return -1;
> +	}
> +
> +	dev->data->rx_queues[rx_queue_id] = dpaa2_q;
> +	return 0;
> +}
> +
> +static int
> +dpaa2_dev_tx_queue_setup(struct rte_eth_dev *dev,
> +			 uint16_t tx_queue_id,
> +			 uint16_t nb_tx_desc __rte_unused,
> +			 unsigned int socket_id __rte_unused,
> +			 const struct rte_eth_txconf *tx_conf __rte_unused)
> +{
> +	struct dpaa2_dev_priv *priv = dev->data->dev_private;
> +	struct dpaa2_queue *dpaa2_q = (struct dpaa2_queue *)
> +		priv->tx_vq[tx_queue_id];
> +	struct fsl_mc_io *dpni = priv->hw;
> +	struct dpni_queue tx_conf_cfg;
> +	struct dpni_queue tx_flow_cfg;
> +	uint8_t options = 0, flow_id;
> +	uint32_t tc_id;
>  	int ret;
>  
>  	PMD_INIT_FUNC_TRACE();
>  
> +	/* Return if queue already configured */
> +	if (dpaa2_q->flow_id != DPNI_NEW_FLOW_ID)
> +		return 0;
> +
> +	memset(&tx_conf_cfg, 0, sizeof(struct dpni_queue));
> +	memset(&tx_flow_cfg, 0, sizeof(struct dpni_queue));
> +
> +	tc_id = 0;
> +	flow_id = tx_queue_id;
> +
> +	ret = dpni_set_queue(dpni, CMD_PRI_LOW, priv->token, DPNI_QUEUE_TX,
> +			     tc_id, flow_id, options, &tx_flow_cfg);
> +	if (ret) {
> +		PMD_INIT_LOG(ERR, "Error in setting the tx flow: "
> +			     "tc_id=%d, flow =%d ErrorCode = %x\n",
> +			     tc_id, flow_id, -ret);
> +			return -1;
> +	}
> +
> +	dpaa2_q->flow_id = flow_id;
> +
> +	if (tx_queue_id == 0) {
> +		/*Set tx-conf and error configuration*/
> +		ret = dpni_set_tx_confirmation_mode(dpni, CMD_PRI_LOW,
> +						    priv->token,
> +						    DPNI_CONF_DISABLE);
> +		if (ret) {
> +			PMD_INIT_LOG(ERR, "Error in set tx conf mode settings"
> +				     " ErrorCode = %x", ret);
> +			return -1;
> +		}
> +	}
> +	dpaa2_q->tc_index = tc_id;
> +
> +	dev->data->tx_queues[tx_queue_id] = dpaa2_q;
> +	return 0;
> +}
> +
> +static void
> +dpaa2_dev_rx_queue_release(void *q __rte_unused)
> +{
> +	PMD_INIT_FUNC_TRACE();
> +}
> +
> +static void
> +dpaa2_dev_tx_queue_release(void *q __rte_unused)
> +{
> +	PMD_INIT_FUNC_TRACE();
> +}
> +
> +static int
> +dpaa2_dev_start(struct rte_eth_dev *dev)
> +{
> +	struct rte_eth_dev_data *data = dev->data;
> +	struct dpaa2_dev_priv *priv = data->dev_private;
> +	struct fsl_mc_io *dpni = (struct fsl_mc_io *)priv->hw;
> +	struct dpni_queue cfg;
> +	uint16_t qdid;
> +	struct dpni_queue_id qid;
> +	struct dpaa2_queue *dpaa2_q;
> +	int ret, i;
> +
> +	PMD_INIT_FUNC_TRACE();
> +
>  	ret = dpni_enable(dpni, CMD_PRI_LOW, priv->token);
>  	if (ret) {
>  		PMD_INIT_LOG(ERR, "Failure %d in enabling dpni %d device\n",
> @@ -85,6 +288,27 @@
>  		return ret;
>  	}
>  
> +	ret = dpni_get_qdid(dpni, CMD_PRI_LOW, priv->token,
> +			    DPNI_QUEUE_TX, &qdid);
> +	if (ret) {
> +		PMD_INIT_LOG(ERR, "Error to get qdid:ErrorCode = %d\n", ret);
> +		return ret;
> +	}
> +	priv->qdid = qdid;
> +
> +	for (i = 0; i < data->nb_rx_queues; i++) {
> +		dpaa2_q = (struct dpaa2_queue *)data->rx_queues[i];
> +		ret = dpni_get_queue(dpni, CMD_PRI_LOW, priv->token,
> +				     DPNI_QUEUE_RX, dpaa2_q->tc_index,
> +				       dpaa2_q->flow_id, &cfg, &qid);
> +		if (ret) {
> +			PMD_INIT_LOG(ERR, "Error to get flow "
> +				     "information Error code = %d\n", ret);
> +			return ret;
> +		}
> +		dpaa2_q->fqid = qid.fqid;
> +	}
> +
>  	return 0;
>  }
>  
> @@ -132,6 +356,11 @@
>  	.dev_start	      = dpaa2_dev_start,
>  	.dev_stop	      = dpaa2_dev_stop,
>  	.dev_close	      = dpaa2_dev_close,
> +	.dev_infos_get	   = dpaa2_dev_info_get,
> +	.rx_queue_setup    = dpaa2_dev_rx_queue_setup,
> +	.rx_queue_release  = dpaa2_dev_rx_queue_release,
> +	.tx_queue_setup    = dpaa2_dev_tx_queue_setup,
> +	.tx_queue_release  = dpaa2_dev_tx_queue_release,
>  };
>  
>  int
> @@ -140,6 +369,7 @@
>  	struct rte_device *dev = eth_dev->device;
>  	struct rte_dpaa2_device *dpaa2_dev;
>  	struct fsl_mc_io *dpni_dev;
> +	struct dpni_attr attr;
>  	struct dpaa2_dev_priv *priv = eth_dev->data->dev_private;
>  	int ret, hw_id;
>  
> @@ -175,8 +405,30 @@
>  		return -1;
>  	}
>  
> +	ret = dpni_get_attributes(dpni_dev, CMD_PRI_LOW, priv->token, &attr);
> +	if (ret) {
> +		PMD_INIT_LOG(ERR, "Failure in getting dpni@%d attribute, "
> +			" error code %d\n", hw_id, ret);
> +		return -1;
> +	}
> +
> +	priv->num_tc = attr.num_tcs;
> +	priv->nb_rx_queues = attr.num_queues;
> +	priv->nb_tx_queues = attr.num_queues;
> +
> +	eth_dev->data->nb_rx_queues = priv->nb_rx_queues;
> +	eth_dev->data->nb_tx_queues = priv->nb_tx_queues;
> +
>  	priv->hw = dpni_dev;
>  	priv->hw_id = hw_id;
> +	priv->flags = 0;
> +
> +	ret = dpaa2_alloc_rx_tx_queues(eth_dev);
> +	if (ret) {
> +		PMD_INIT_LOG(ERR, "dpaa2_alloc_rx_tx_queuesFailed\n");
> +		return -ret;
> +	}
> +
>  	eth_dev->dev_ops = &dpaa2_ethdev_ops;
>  	return 0;
>  }
>