|
@@ -1445,6 +1445,7 @@ static int mlx5e_open_channel(struct mlx5e_priv *priv, int ix,
|
|
|
c->netdev = priv->netdev;
|
|
|
c->mkey_be = cpu_to_be32(priv->mdev->mlx5e_res.mkey.key);
|
|
|
c->num_tc = priv->params.num_tc;
|
|
|
+ c->xdp = !!priv->xdp_prog;
|
|
|
|
|
|
if (priv->params.rx_am_enabled)
|
|
|
rx_cq_profile = mlx5e_am_get_def_profile(priv->params.rx_cq_period_mode);
|
|
@@ -1468,6 +1469,12 @@ static int mlx5e_open_channel(struct mlx5e_priv *priv, int ix,
|
|
|
if (err)
|
|
|
goto err_close_tx_cqs;
|
|
|
|
|
|
+ /* XDP SQ CQ params are same as normal TXQ sq CQ params */
|
|
|
+ err = c->xdp ? mlx5e_open_cq(c, &cparam->tx_cq, &c->xdp_sq.cq,
|
|
|
+ priv->params.tx_cq_moderation) : 0;
|
|
|
+ if (err)
|
|
|
+ goto err_close_rx_cq;
|
|
|
+
|
|
|
napi_enable(&c->napi);
|
|
|
|
|
|
err = mlx5e_open_sq(c, 0, &cparam->icosq, &c->icosq);
|
|
@@ -1488,21 +1495,10 @@ static int mlx5e_open_channel(struct mlx5e_priv *priv, int ix,
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- if (priv->xdp_prog) {
|
|
|
- /* XDP SQ CQ params are same as normal TXQ sq CQ params */
|
|
|
- err = mlx5e_open_cq(c, &cparam->tx_cq, &c->xdp_sq.cq,
|
|
|
- priv->params.tx_cq_moderation);
|
|
|
- if (err)
|
|
|
- goto err_close_sqs;
|
|
|
-
|
|
|
- err = mlx5e_open_sq(c, 0, &cparam->xdp_sq, &c->xdp_sq);
|
|
|
- if (err) {
|
|
|
- mlx5e_close_cq(&c->xdp_sq.cq);
|
|
|
- goto err_close_sqs;
|
|
|
- }
|
|
|
- }
|
|
|
+ err = c->xdp ? mlx5e_open_sq(c, 0, &cparam->xdp_sq, &c->xdp_sq) : 0;
|
|
|
+ if (err)
|
|
|
+ goto err_close_sqs;
|
|
|
|
|
|
- c->xdp = !!priv->xdp_prog;
|
|
|
err = mlx5e_open_rq(c, &cparam->rq, &c->rq);
|
|
|
if (err)
|
|
|
goto err_close_xdp_sq;
|
|
@@ -1512,7 +1508,8 @@ static int mlx5e_open_channel(struct mlx5e_priv *priv, int ix,
|
|
|
|
|
|
return 0;
|
|
|
err_close_xdp_sq:
|
|
|
- mlx5e_close_sq(&c->xdp_sq);
|
|
|
+ if (c->xdp)
|
|
|
+ mlx5e_close_sq(&c->xdp_sq);
|
|
|
|
|
|
err_close_sqs:
|
|
|
mlx5e_close_sqs(c);
|
|
@@ -1522,6 +1519,10 @@ err_close_icosq:
|
|
|
|
|
|
err_disable_napi:
|
|
|
napi_disable(&c->napi);
|
|
|
+ if (c->xdp)
|
|
|
+ mlx5e_close_cq(&c->xdp_sq.cq);
|
|
|
+
|
|
|
+err_close_rx_cq:
|
|
|
mlx5e_close_cq(&c->rq.cq);
|
|
|
|
|
|
err_close_tx_cqs:
|