Commit 2e84f6b3 authored by Maciej Fijalkowski's avatar Maciej Fijalkowski Committed by Tony Nguyen

ice: parameterize functions responsible for Tx ring management

Commit ae15e0ba ("ice: Change number of XDP Tx queues to match
number of Rx queues") tried to address the incorrect setting of XDP
queue count that was based on the Tx queue count, whereas in theory we
should provide the XDP queue per Rx queue. However, the routines that
setup and destroy the set of Tx resources are still based on the
vsi->num_txq.

Ice supports the asynchronous Tx/Rx queue count, so for a setup where
vsi->num_txq > vsi->num_rxq, ice_vsi_stop_tx_rings and ice_vsi_cfg_txqs
will be accessing the vsi->xdp_rings out of the bounds.

Parameterize two mentioned functions so they get the size of Tx resources
array as the input.

Fixes: ae15e0ba ("ice: Change number of XDP Tx queues to match number of Rx queues")
Signed-off-by: default avatarMaciej Fijalkowski <maciej.fijalkowski@intel.com>
Tested-by: default avatarKiran Bhandare <kiranx.bhandare@intel.com>
Signed-off-by: default avatarTony Nguyen <anthony.l.nguyen@intel.com>
parent ebc5399e
...@@ -1717,12 +1717,13 @@ int ice_vsi_cfg_rxqs(struct ice_vsi *vsi) ...@@ -1717,12 +1717,13 @@ int ice_vsi_cfg_rxqs(struct ice_vsi *vsi)
* ice_vsi_cfg_txqs - Configure the VSI for Tx * ice_vsi_cfg_txqs - Configure the VSI for Tx
* @vsi: the VSI being configured * @vsi: the VSI being configured
* @rings: Tx ring array to be configured * @rings: Tx ring array to be configured
* @count: number of Tx ring array elements
* *
* Return 0 on success and a negative value on error * Return 0 on success and a negative value on error
* Configure the Tx VSI for operation. * Configure the Tx VSI for operation.
*/ */
static int static int
ice_vsi_cfg_txqs(struct ice_vsi *vsi, struct ice_ring **rings) ice_vsi_cfg_txqs(struct ice_vsi *vsi, struct ice_ring **rings, u16 count)
{ {
struct ice_aqc_add_tx_qgrp *qg_buf; struct ice_aqc_add_tx_qgrp *qg_buf;
u16 q_idx = 0; u16 q_idx = 0;
...@@ -1734,7 +1735,7 @@ ice_vsi_cfg_txqs(struct ice_vsi *vsi, struct ice_ring **rings) ...@@ -1734,7 +1735,7 @@ ice_vsi_cfg_txqs(struct ice_vsi *vsi, struct ice_ring **rings)
qg_buf->num_txqs = 1; qg_buf->num_txqs = 1;
for (q_idx = 0; q_idx < vsi->num_txq; q_idx++) { for (q_idx = 0; q_idx < count; q_idx++) {
err = ice_vsi_cfg_txq(vsi, rings[q_idx], qg_buf); err = ice_vsi_cfg_txq(vsi, rings[q_idx], qg_buf);
if (err) if (err)
goto err_cfg_txqs; goto err_cfg_txqs;
...@@ -1754,7 +1755,7 @@ ice_vsi_cfg_txqs(struct ice_vsi *vsi, struct ice_ring **rings) ...@@ -1754,7 +1755,7 @@ ice_vsi_cfg_txqs(struct ice_vsi *vsi, struct ice_ring **rings)
*/ */
int ice_vsi_cfg_lan_txqs(struct ice_vsi *vsi) int ice_vsi_cfg_lan_txqs(struct ice_vsi *vsi)
{ {
return ice_vsi_cfg_txqs(vsi, vsi->tx_rings); return ice_vsi_cfg_txqs(vsi, vsi->tx_rings, vsi->num_txq);
} }
/** /**
...@@ -1769,7 +1770,7 @@ int ice_vsi_cfg_xdp_txqs(struct ice_vsi *vsi) ...@@ -1769,7 +1770,7 @@ int ice_vsi_cfg_xdp_txqs(struct ice_vsi *vsi)
int ret; int ret;
int i; int i;
ret = ice_vsi_cfg_txqs(vsi, vsi->xdp_rings); ret = ice_vsi_cfg_txqs(vsi, vsi->xdp_rings, vsi->num_xdp_txq);
if (ret) if (ret)
return ret; return ret;
...@@ -2009,17 +2010,18 @@ int ice_vsi_stop_all_rx_rings(struct ice_vsi *vsi) ...@@ -2009,17 +2010,18 @@ int ice_vsi_stop_all_rx_rings(struct ice_vsi *vsi)
* @rst_src: reset source * @rst_src: reset source
* @rel_vmvf_num: Relative ID of VF/VM * @rel_vmvf_num: Relative ID of VF/VM
* @rings: Tx ring array to be stopped * @rings: Tx ring array to be stopped
* @count: number of Tx ring array elements
*/ */
static int static int
ice_vsi_stop_tx_rings(struct ice_vsi *vsi, enum ice_disq_rst_src rst_src, ice_vsi_stop_tx_rings(struct ice_vsi *vsi, enum ice_disq_rst_src rst_src,
u16 rel_vmvf_num, struct ice_ring **rings) u16 rel_vmvf_num, struct ice_ring **rings, u16 count)
{ {
u16 q_idx; u16 q_idx;
if (vsi->num_txq > ICE_LAN_TXQ_MAX_QDIS) if (vsi->num_txq > ICE_LAN_TXQ_MAX_QDIS)
return -EINVAL; return -EINVAL;
for (q_idx = 0; q_idx < vsi->num_txq; q_idx++) { for (q_idx = 0; q_idx < count; q_idx++) {
struct ice_txq_meta txq_meta = { }; struct ice_txq_meta txq_meta = { };
int status; int status;
...@@ -2047,7 +2049,7 @@ int ...@@ -2047,7 +2049,7 @@ int
ice_vsi_stop_lan_tx_rings(struct ice_vsi *vsi, enum ice_disq_rst_src rst_src, ice_vsi_stop_lan_tx_rings(struct ice_vsi *vsi, enum ice_disq_rst_src rst_src,
u16 rel_vmvf_num) u16 rel_vmvf_num)
{ {
return ice_vsi_stop_tx_rings(vsi, rst_src, rel_vmvf_num, vsi->tx_rings); return ice_vsi_stop_tx_rings(vsi, rst_src, rel_vmvf_num, vsi->tx_rings, vsi->num_txq);
} }
/** /**
...@@ -2056,7 +2058,7 @@ ice_vsi_stop_lan_tx_rings(struct ice_vsi *vsi, enum ice_disq_rst_src rst_src, ...@@ -2056,7 +2058,7 @@ ice_vsi_stop_lan_tx_rings(struct ice_vsi *vsi, enum ice_disq_rst_src rst_src,
*/ */
int ice_vsi_stop_xdp_tx_rings(struct ice_vsi *vsi) int ice_vsi_stop_xdp_tx_rings(struct ice_vsi *vsi)
{ {
return ice_vsi_stop_tx_rings(vsi, ICE_NO_RESET, 0, vsi->xdp_rings); return ice_vsi_stop_tx_rings(vsi, ICE_NO_RESET, 0, vsi->xdp_rings, vsi->num_xdp_txq);
} }
/** /**
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment