[PATCH v14 06/18] net/idpf: add support for queue start

[Andrew Rybchenko]

On 10/27/22 10:47, Junfeng Guo wrote:
> Add support for these device ops:
>   - rx_queue_start
>   - tx_queue_start
> 
> Signed-off-by: Beilei Xing <beilei.xing at intel.com>
> Signed-off-by: Xiaoyun Li <xiaoyun.li at intel.com>
> Signed-off-by: Junfeng Guo <junfeng.guo at intel.com>

[snip]

> +#define IDPF_RX_BUF_STRIDE		64
> +int
> +idpf_vc_config_rxqs(struct idpf_vport *vport)
> +{
> +	struct idpf_adapter *adapter = vport->adapter;
> +	struct idpf_rx_queue **rxq =
> +		(struct idpf_rx_queue **)vport->dev_data->rx_queues;
> +	struct virtchnl2_config_rx_queues *vc_rxqs = NULL;
> +	struct virtchnl2_rxq_info *rxq_info;
> +	struct idpf_cmd_info args;
> +	uint16_t total_qs, num_qs;
> +	int size, i, j;
> +	int err = 0;
> +	int k = 0;
> +
> +	total_qs = vport->num_rx_q + vport->num_rx_bufq;
> +	while (total_qs) {
> +		if (total_qs > adapter->max_rxq_per_msg) {
> +			num_qs = adapter->max_rxq_per_msg;
> +			total_qs -= adapter->max_rxq_per_msg;
> +		} else {
> +			num_qs = total_qs;
> +			total_qs = 0;
> +		}
> +
> +		size = sizeof(*vc_rxqs) + (num_qs - 1) *
> +			sizeof(struct virtchnl2_rxq_info);
> +		vc_rxqs = rte_zmalloc("cfg_rxqs", size, 0);
> +		if (vc_rxqs == NULL) {
> +			PMD_DRV_LOG(ERR, "Failed to allocate virtchnl2_config_rx_queues");
> +			err = -ENOMEM;
> +			break;
> +		}
> +		vc_rxqs->vport_id = vport->vport_id;
> +		vc_rxqs->num_qinfo = num_qs;
> +		if (vport->rxq_model == VIRTCHNL2_QUEUE_MODEL_SINGLE) {
> +			for (i = 0; i < num_qs; i++, k++) {
> +				rxq_info = &vc_rxqs->qinfo[i];
> +				rxq_info->dma_ring_addr = rxq[k]->rx_ring_phys_addr;
> +				rxq_info->type = VIRTCHNL2_QUEUE_TYPE_RX;
> +				rxq_info->queue_id = rxq[k]->queue_id;
> +				rxq_info->model = VIRTCHNL2_QUEUE_MODEL_SINGLE;
> +				rxq_info->data_buffer_size = rxq[k]->rx_buf_len;
> +				rxq_info->max_pkt_size = vport->max_pkt_len;
> +
> +				rxq_info->desc_ids = VIRTCHNL2_RXDID_2_FLEX_SQ_NIC_M;
> +				rxq_info->qflags |= VIRTCHNL2_RX_DESC_SIZE_32BYTE;
> +
> +				rxq_info->ring_len = rxq[k]->nb_rx_desc;
> +			}
> +		} else {
> +			for (i = 0; i < num_qs / 3; i++, k++) {
> +				/* Rx queue */
> +				rxq_info = &vc_rxqs->qinfo[i * 3];
> +				rxq_info->dma_ring_addr =
> +					rxq[k]->rx_ring_phys_addr;
> +				rxq_info->type = VIRTCHNL2_QUEUE_TYPE_RX;
> +				rxq_info->queue_id = rxq[k]->queue_id;
> +				rxq_info->model = VIRTCHNL2_QUEUE_MODEL_SPLIT;
> +				rxq_info->data_buffer_size = rxq[k]->rx_buf_len;
> +				rxq_info->max_pkt_size = vport->max_pkt_len;
> +
> +				rxq_info->desc_ids = VIRTCHNL2_RXDID_2_FLEX_SPLITQ_M;
> +				rxq_info->qflags |= VIRTCHNL2_RX_DESC_SIZE_32BYTE;
> +
> +				rxq_info->ring_len = rxq[k]->nb_rx_desc;
> +				rxq_info->rx_bufq1_id = rxq[k]->bufq1->queue_id;
> +				rxq_info->rx_bufq2_id = rxq[k]->bufq2->queue_id;
> +				rxq_info->rx_buffer_low_watermark = 64;
> +
> +				/* Buffer queue */
> +				for (j = 1; j <= IDPF_RX_BUFQ_PER_GRP; j++) {
> +					struct idpf_rx_queue *bufq = j == 1 ?
> +						rxq[k]->bufq1 : rxq[k]->bufq2;
> +					rxq_info = &vc_rxqs->qinfo[i * 3 + j];
> +					rxq_info->dma_ring_addr =
> +						bufq->rx_ring_phys_addr;
> +					rxq_info->type =
> +						VIRTCHNL2_QUEUE_TYPE_RX_BUFFER;
> +					rxq_info->queue_id = bufq->queue_id;
> +					rxq_info->model = VIRTCHNL2_QUEUE_MODEL_SPLIT;
> +					rxq_info->data_buffer_size = bufq->rx_buf_len;
> +					rxq_info->desc_ids =
> +						VIRTCHNL2_RXDID_2_FLEX_SPLITQ_M;
> +					rxq_info->ring_len = bufq->nb_rx_desc;
> +
> +					rxq_info->buffer_notif_stride =
> +						IDPF_RX_BUF_STRIDE;
> +					rxq_info->rx_buffer_low_watermark = 64;
> +				}
> +			}
> +		}
> +		memset(&args, 0, sizeof(args));
> +		args.ops = VIRTCHNL2_OP_CONFIG_RX_QUEUES;
> +		args.in_args = (uint8_t *)vc_rxqs;
> +		args.in_args_size = size;
> +		args.out_buffer = adapter->mbx_resp;
> +		args.out_size = IDPF_DFLT_MBX_BUF_SIZE;
> +
> +		err = idpf_execute_vc_cmd(adapter, &args);

The function must return negative errno since its return
value is used as a return value of functions returning
negative errno.

> +		rte_free(vc_rxqs);
> +		if (err != 0) {
> +			PMD_DRV_LOG(ERR, "Failed to execute command of VIRTCHNL2_OP_CONFIG_RX_QUEUES");
> +			break;
> +		}
> +	}
> +
> +	return err;
> +}

[snip]