mlx5/core/en_arfs.c

88 	struct mlx5_flow_handle *rule;
242 		fs_err(fs, "%s: add rule failed, arfs type=%d\n", __func__, type);
447 		if (arfs_rule->rule) {
448 			mlx5_del_flow_rules(arfs_rule->rule);
460 	struct arfs_rule *rule;
468 	mlx5e_for_each_arfs_rule(rule, htmp, arfs->arfs_tables, i, j) {
469 		hlist_del_init(&rule->hlist);
470 		hlist_add_head(&rule->hlist, &del_list);
474 	hlist_for_each_entry_safe(rule, htmp, &del_list, hlist) {
475 		cancel_work_sync(&rule->arfs_work);
476 		if (rule->rule)
477 			mlx5_del_flow_rules(rule->rule);
478 		hlist_del(&rule->hlist);
479 		kfree(rule);
518 	struct mlx5_flow_handle *rule = NULL;
598 	rule = mlx5_add_flow_rules(ft, spec, &flow_act, &dest, 1);
599 	if (IS_ERR(rule)) {
600 		err = PTR_ERR(rule);
603 			   "%s: add rule(filter id=%d, rq idx=%d, ip proto=0x%x) failed,err=%d\n",
610 	return err ? ERR_PTR(err) : rule;
614 				struct mlx5_flow_handle *rule, u16 rxq)
621 	err =  mlx5_modify_rule_destination(rule, &dst, NULL);
625 			    "Failed to modify aRFS rule destination to rq=%d\n", rxq);
636 	struct mlx5_flow_handle *rule;
642 	if (!arfs_rule->rule) {
643 		rule = arfs_add_rule(priv, arfs_rule);
644 		if (IS_ERR(rule))
646 		arfs_rule->rule = rule;
649 		arfs_modify_rule_rq(priv, arfs_rule->rule,
662 	struct arfs_rule *rule;
665 	rule = kzalloc(sizeof(*rule), GFP_ATOMIC);
666 	if (!rule) {
671 	rule->priv = priv;
672 	rule->rxq = rxq;
673 	INIT_WORK(&rule->arfs_work, arfs_handle_work);
675 	tuple = &rule->tuple;
690 	rule->flow_id = flow_id;
691 	rule->filter_id = arfs->last_filter_id++ % RPS_NO_FILTER;
693 	hlist_add_head(&rule->hlist,
696 	return rule;