Skip to content

Commit fc92cdd

Browse files
cjubrankuba-moo
authored andcommitted
net/mlx5e: Introduce mlx5e_rss_init_params
Introduce a dedicated structure to group RSS initialization parameters that are only used during RSS creation, and drop the "init" prefix from pkt_merge_param. No functional changes. Signed-off-by: Carolina Jubran <[email protected]> Signed-off-by: Tariq Toukan <[email protected]> Link: https://patch.msgid.link/[email protected] Signed-off-by: Jakub Kicinski <[email protected]>
1 parent a3f6964 commit fc92cdd

File tree

4 files changed

+63
-39
lines changed

4 files changed

+63
-39
lines changed

drivers/net/ethernet/mellanox/mlx5/core/en/rss.c

Lines changed: 26 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -193,10 +193,10 @@ mlx5e_rss_get_tt_config(struct mlx5e_rss *rss, enum mlx5_traffic_types tt)
193193
return rss_tt;
194194
}
195195

196-
static int mlx5e_rss_create_tir(struct mlx5e_rss *rss,
197-
enum mlx5_traffic_types tt,
198-
const struct mlx5e_packet_merge_param *init_pkt_merge_param,
199-
bool inner)
196+
static int
197+
mlx5e_rss_create_tir(struct mlx5e_rss *rss, enum mlx5_traffic_types tt,
198+
const struct mlx5e_packet_merge_param *pkt_merge_param,
199+
bool inner)
200200
{
201201
struct mlx5e_rss_params_traffic_type rss_tt;
202202
struct mlx5e_tir_builder *builder;
@@ -229,7 +229,7 @@ static int mlx5e_rss_create_tir(struct mlx5e_rss *rss,
229229
rqtn = mlx5e_rqt_get_rqtn(&rss->rqt);
230230
mlx5e_tir_builder_build_rqt(builder, rss->mdev->mlx5e_res.hw_objs.td.tdn,
231231
rqtn, rss->inner_ft_support);
232-
mlx5e_tir_builder_build_packet_merge(builder, init_pkt_merge_param);
232+
mlx5e_tir_builder_build_packet_merge(builder, pkt_merge_param);
233233
rss_tt = mlx5e_rss_get_tt_config(rss, tt);
234234
mlx5e_tir_builder_build_rss(builder, &rss->hash, &rss_tt, inner);
235235

@@ -265,15 +265,16 @@ static void mlx5e_rss_destroy_tir(struct mlx5e_rss *rss, enum mlx5_traffic_types
265265
*tir_p = NULL;
266266
}
267267

268-
static int mlx5e_rss_create_tirs(struct mlx5e_rss *rss,
269-
const struct mlx5e_packet_merge_param *init_pkt_merge_param,
270-
bool inner)
268+
static int
269+
mlx5e_rss_create_tirs(struct mlx5e_rss *rss,
270+
const struct mlx5e_packet_merge_param *pkt_merge_param,
271+
bool inner)
271272
{
272273
enum mlx5_traffic_types tt, max_tt;
273274
int err;
274275

275276
for (tt = 0; tt < MLX5E_NUM_INDIR_TIRS; tt++) {
276-
err = mlx5e_rss_create_tir(rss, tt, init_pkt_merge_param, inner);
277+
err = mlx5e_rss_create_tir(rss, tt, pkt_merge_param, inner);
277278
if (err)
278279
goto err_destroy_tirs;
279280
}
@@ -359,10 +360,9 @@ static int mlx5e_rss_init_no_tirs(struct mlx5e_rss *rss)
359360
rss->drop_rqn, rss->indir.max_table_size);
360361
}
361362

362-
struct mlx5e_rss *mlx5e_rss_init(struct mlx5_core_dev *mdev, bool inner_ft_support, u32 drop_rqn,
363-
const struct mlx5e_packet_merge_param *init_pkt_merge_param,
364-
enum mlx5e_rss_init_type type, unsigned int nch,
365-
unsigned int max_nch)
363+
struct mlx5e_rss *
364+
mlx5e_rss_init(struct mlx5_core_dev *mdev, bool inner_ft_support, u32 drop_rqn,
365+
const struct mlx5e_rss_init_params *init_params)
366366
{
367367
u32 rqt_max_size, rqt_size;
368368
struct mlx5e_rss *rss;
@@ -372,8 +372,8 @@ struct mlx5e_rss *mlx5e_rss_init(struct mlx5_core_dev *mdev, bool inner_ft_suppo
372372
if (!rss)
373373
return ERR_PTR(-ENOMEM);
374374

375-
rqt_size = mlx5e_rqt_size(mdev, nch);
376-
rqt_max_size = mlx5e_rqt_size(mdev, max_nch);
375+
rqt_size = mlx5e_rqt_size(mdev, init_params->nch);
376+
rqt_max_size = mlx5e_rqt_size(mdev, init_params->max_nch);
377377
err = mlx5e_rss_params_indir_init(&rss->indir, rqt_size, rqt_max_size);
378378
if (err)
379379
goto err_free_rss;
@@ -386,15 +386,18 @@ struct mlx5e_rss *mlx5e_rss_init(struct mlx5_core_dev *mdev, bool inner_ft_suppo
386386
if (err)
387387
goto err_free_indir;
388388

389-
if (type == MLX5E_RSS_INIT_NO_TIRS)
389+
if (init_params->type == MLX5E_RSS_INIT_NO_TIRS)
390390
goto out;
391391

392-
err = mlx5e_rss_create_tirs(rss, init_pkt_merge_param, false);
392+
err = mlx5e_rss_create_tirs(rss, init_params->pkt_merge_param,
393+
false);
393394
if (err)
394395
goto err_destroy_rqt;
395396

396397
if (inner_ft_support) {
397-
err = mlx5e_rss_create_tirs(rss, init_pkt_merge_param, true);
398+
err = mlx5e_rss_create_tirs(rss,
399+
init_params->pkt_merge_param,
400+
true);
398401
if (err)
399402
goto err_destroy_tirs;
400403
}
@@ -470,18 +473,18 @@ bool mlx5e_rss_valid_tir(struct mlx5e_rss *rss, enum mlx5_traffic_types tt, bool
470473
/* Fill the "tirn" output parameter.
471474
* Create the requested TIR if it's its first usage.
472475
*/
473-
int mlx5e_rss_obtain_tirn(struct mlx5e_rss *rss,
474-
enum mlx5_traffic_types tt,
475-
const struct mlx5e_packet_merge_param *init_pkt_merge_param,
476-
bool inner, u32 *tirn)
476+
int
477+
mlx5e_rss_obtain_tirn(struct mlx5e_rss *rss, enum mlx5_traffic_types tt,
478+
const struct mlx5e_packet_merge_param *pkt_merge_param,
479+
bool inner, u32 *tirn)
477480
{
478481
struct mlx5e_tir *tir;
479482

480483
tir = rss_get_tir(rss, tt, inner);
481484
if (!tir) { /* TIR doesn't exist, create one */
482485
int err;
483486

484-
err = mlx5e_rss_create_tir(rss, tt, init_pkt_merge_param, inner);
487+
err = mlx5e_rss_create_tir(rss, tt, pkt_merge_param, inner);
485488
if (err)
486489
return err;
487490
tir = rss_get_tir(rss, tt, inner);

drivers/net/ethernet/mellanox/mlx5/core/en/rss.h

Lines changed: 14 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,13 @@ enum mlx5e_rss_init_type {
1313
MLX5E_RSS_INIT_TIRS
1414
};
1515

16+
struct mlx5e_rss_init_params {
17+
enum mlx5e_rss_init_type type;
18+
const struct mlx5e_packet_merge_param *pkt_merge_param;
19+
unsigned int nch;
20+
unsigned int max_nch;
21+
};
22+
1623
struct mlx5e_rss_params_traffic_type
1724
mlx5e_rss_get_default_tt_config(enum mlx5_traffic_types tt);
1825

@@ -22,10 +29,9 @@ int mlx5e_rss_params_indir_init(struct mlx5e_rss_params_indir *indir,
2229
u32 actual_table_size, u32 max_table_size);
2330
void mlx5e_rss_params_indir_cleanup(struct mlx5e_rss_params_indir *indir);
2431
void mlx5e_rss_params_indir_modify_actual_size(struct mlx5e_rss *rss, u32 num_channels);
25-
struct mlx5e_rss *mlx5e_rss_init(struct mlx5_core_dev *mdev, bool inner_ft_support, u32 drop_rqn,
26-
const struct mlx5e_packet_merge_param *init_pkt_merge_param,
27-
enum mlx5e_rss_init_type type, unsigned int nch,
28-
unsigned int max_nch);
32+
struct mlx5e_rss *
33+
mlx5e_rss_init(struct mlx5_core_dev *mdev, bool inner_ft_support, u32 drop_rqn,
34+
const struct mlx5e_rss_init_params *init_params);
2935
int mlx5e_rss_cleanup(struct mlx5e_rss *rss);
3036

3137
void mlx5e_rss_refcnt_inc(struct mlx5e_rss *rss);
@@ -37,10 +43,10 @@ u32 mlx5e_rss_get_tirn(struct mlx5e_rss *rss, enum mlx5_traffic_types tt,
3743
bool inner);
3844
bool mlx5e_rss_valid_tir(struct mlx5e_rss *rss, enum mlx5_traffic_types tt, bool inner);
3945
u32 mlx5e_rss_get_rqtn(struct mlx5e_rss *rss);
40-
int mlx5e_rss_obtain_tirn(struct mlx5e_rss *rss,
41-
enum mlx5_traffic_types tt,
42-
const struct mlx5e_packet_merge_param *init_pkt_merge_param,
43-
bool inner, u32 *tirn);
46+
int
47+
mlx5e_rss_obtain_tirn(struct mlx5e_rss *rss, enum mlx5_traffic_types tt,
48+
const struct mlx5e_packet_merge_param *pkt_merge_param,
49+
bool inner, u32 *tirn);
4450

4551
void mlx5e_rss_enable(struct mlx5e_rss *rss, u32 *rqns, u32 *vhca_ids, unsigned int num_rqns);
4652
void mlx5e_rss_disable(struct mlx5e_rss *rss);

drivers/net/ethernet/mellanox/mlx5/core/en/rx_res.c

Lines changed: 22 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -54,17 +54,25 @@ static int mlx5e_rx_res_rss_init_def(struct mlx5e_rx_res *res,
5454
unsigned int init_nch)
5555
{
5656
bool inner_ft_support = res->features & MLX5E_RX_RES_FEATURE_INNER_FT;
57+
struct mlx5e_rss_init_params init_params;
5758
struct mlx5e_rss *rss;
5859

5960
if (WARN_ON(res->rss[0]))
6061
return -EINVAL;
6162

63+
init_params = (struct mlx5e_rss_init_params) {
64+
.type = MLX5E_RSS_INIT_TIRS,
65+
.pkt_merge_param = &res->pkt_merge_param,
66+
.nch = init_nch,
67+
.max_nch = res->max_nch,
68+
};
69+
6270
rss = mlx5e_rss_init(res->mdev, inner_ft_support, res->drop_rqn,
63-
&res->pkt_merge_param, MLX5E_RSS_INIT_TIRS, init_nch, res->max_nch);
71+
&init_params);
6472
if (IS_ERR(rss))
6573
return PTR_ERR(rss);
6674

67-
mlx5e_rss_set_indir_uniform(rss, init_nch);
75+
mlx5e_rss_set_indir_uniform(rss, init_params.nch);
6876

6977
res->rss[0] = rss;
7078

@@ -74,18 +82,25 @@ static int mlx5e_rx_res_rss_init_def(struct mlx5e_rx_res *res,
7482
int mlx5e_rx_res_rss_init(struct mlx5e_rx_res *res, u32 rss_idx, unsigned int init_nch)
7583
{
7684
bool inner_ft_support = res->features & MLX5E_RX_RES_FEATURE_INNER_FT;
85+
struct mlx5e_rss_init_params init_params;
7786
struct mlx5e_rss *rss;
7887

7988
if (WARN_ON_ONCE(res->rss[rss_idx]))
8089
return -ENOSPC;
8190

91+
init_params = (struct mlx5e_rss_init_params) {
92+
.type = MLX5E_RSS_INIT_NO_TIRS,
93+
.pkt_merge_param = &res->pkt_merge_param,
94+
.nch = init_nch,
95+
.max_nch = res->max_nch,
96+
};
97+
8298
rss = mlx5e_rss_init(res->mdev, inner_ft_support, res->drop_rqn,
83-
&res->pkt_merge_param, MLX5E_RSS_INIT_NO_TIRS, init_nch,
84-
res->max_nch);
99+
&init_params);
85100
if (IS_ERR(rss))
86101
return PTR_ERR(rss);
87102

88-
mlx5e_rss_set_indir_uniform(rss, init_nch);
103+
mlx5e_rss_set_indir_uniform(rss, init_params.nch);
89104
if (res->rss_active) {
90105
u32 *vhca_ids = get_vhca_ids(res, 0);
91106

@@ -438,7 +453,7 @@ static void mlx5e_rx_res_ptp_destroy(struct mlx5e_rx_res *res)
438453
struct mlx5e_rx_res *
439454
mlx5e_rx_res_create(struct mlx5_core_dev *mdev, enum mlx5e_rx_res_features features,
440455
unsigned int max_nch, u32 drop_rqn,
441-
const struct mlx5e_packet_merge_param *init_pkt_merge_param,
456+
const struct mlx5e_packet_merge_param *pkt_merge_param,
442457
unsigned int init_nch)
443458
{
444459
bool multi_vhca = features & MLX5E_RX_RES_FEATURE_MULTI_VHCA;
@@ -454,7 +469,7 @@ mlx5e_rx_res_create(struct mlx5_core_dev *mdev, enum mlx5e_rx_res_features featu
454469
res->max_nch = max_nch;
455470
res->drop_rqn = drop_rqn;
456471

457-
res->pkt_merge_param = *init_pkt_merge_param;
472+
res->pkt_merge_param = *pkt_merge_param;
458473
init_rwsem(&res->pkt_merge_param_sem);
459474

460475
err = mlx5e_rx_res_rss_init_def(res, init_nch);

drivers/net/ethernet/mellanox/mlx5/core/en/rx_res.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ enum mlx5e_rx_res_features {
2727
struct mlx5e_rx_res *
2828
mlx5e_rx_res_create(struct mlx5_core_dev *mdev, enum mlx5e_rx_res_features features,
2929
unsigned int max_nch, u32 drop_rqn,
30-
const struct mlx5e_packet_merge_param *init_pkt_merge_param,
30+
const struct mlx5e_packet_merge_param *pkt_merge_param,
3131
unsigned int init_nch);
3232
void mlx5e_rx_res_destroy(struct mlx5e_rx_res *res);
3333

0 commit comments

Comments
 (0)