struct mlx5e_modify_sq_param *p);
 int mlx5e_open_txqsq(struct mlx5e_channel *c, u32 tisn, int txq_ix,
                     struct mlx5e_params *params, struct mlx5e_sq_param *param,
-                    struct mlx5e_txqsq *sq, int tc, u16 qos_queue_group_id, u16 qos_qid);
+                    struct mlx5e_txqsq *sq, int tc, u16 qos_queue_group_id,
+                    struct mlx5e_sq_stats *sq_stats);
 void mlx5e_activate_txqsq(struct mlx5e_txqsq *sq);
 void mlx5e_deactivate_txqsq(struct mlx5e_txqsq *sq);
 void mlx5e_free_txqsq(struct mlx5e_txqsq *sq);
 
        if (err)
                goto err_free_sq;
        err = mlx5e_open_txqsq(c, priv->tisn[c->lag_port][0], txq_ix, params,
-                              ¶m_sq, sq, 0, node->hw_id, node->qid);
+                              ¶m_sq, sq, 0, node->hw_id,
+                              priv->htb.qos_sq_stats[node->qid]);
        if (err)
                goto err_close_cq;
 
 
 
 int mlx5e_open_txqsq(struct mlx5e_channel *c, u32 tisn, int txq_ix,
                     struct mlx5e_params *params, struct mlx5e_sq_param *param,
-                    struct mlx5e_txqsq *sq, int tc, u16 qos_queue_group_id, u16 qos_qid)
+                    struct mlx5e_txqsq *sq, int tc, u16 qos_queue_group_id,
+                    struct mlx5e_sq_stats *sq_stats)
 {
        struct mlx5e_create_sq_param csp = {};
        u32 tx_rate;
        if (err)
                return err;
 
-       if (qos_queue_group_id)
-               sq->stats = c->priv->htb.qos_sq_stats[qos_qid];
-       else
-               sq->stats = &c->priv->channel_stats[c->ix].sq[tc];
+       sq->stats = sq_stats;
 
        csp.tisn            = tisn;
        csp.tis_lst_sz      = 1;
                int txq_ix = c->ix + tc * params->num_channels;
 
                err = mlx5e_open_txqsq(c, c->priv->tisn[c->lag_port][tc], txq_ix,
-                                      params, &cparam->txq_sq, &c->sq[tc], tc, 0, 0);
+                                      params, &cparam->txq_sq, &c->sq[tc], tc, 0,
+                                      &c->priv->channel_stats[c->ix].sq[tc]);
                if (err)
                        goto err_close_sqs;
        }