diff options
Diffstat (limited to 'net/sched/cls_api.c')
| -rw-r--r-- | net/sched/cls_api.c | 144 | 
1 files changed, 67 insertions, 77 deletions
diff --git a/net/sched/cls_api.c b/net/sched/cls_api.c index 8e118af9097..45527e6b52d 100644 --- a/net/sched/cls_api.c +++ b/net/sched/cls_api.c @@ -31,8 +31,7 @@  #include <net/pkt_cls.h>  /* The list of all installed classifier types */ - -static struct tcf_proto_ops *tcf_proto_base __read_mostly; +static LIST_HEAD(tcf_proto_base);  /* Protects list of registered TC modules. It is pure SMP lock. */  static DEFINE_RWLOCK(cls_mod_lock); @@ -41,36 +40,35 @@ static DEFINE_RWLOCK(cls_mod_lock);  static const struct tcf_proto_ops *tcf_proto_lookup_ops(struct nlattr *kind)  { -	const struct tcf_proto_ops *t = NULL; +	const struct tcf_proto_ops *t, *res = NULL;  	if (kind) {  		read_lock(&cls_mod_lock); -		for (t = tcf_proto_base; t; t = t->next) { +		list_for_each_entry(t, &tcf_proto_base, head) {  			if (nla_strcmp(kind, t->kind) == 0) { -				if (!try_module_get(t->owner)) -					t = NULL; +				if (try_module_get(t->owner)) +					res = t;  				break;  			}  		}  		read_unlock(&cls_mod_lock);  	} -	return t; +	return res;  }  /* Register(unregister) new classifier type */  int register_tcf_proto_ops(struct tcf_proto_ops *ops)  { -	struct tcf_proto_ops *t, **tp; +	struct tcf_proto_ops *t;  	int rc = -EEXIST;  	write_lock(&cls_mod_lock); -	for (tp = &tcf_proto_base; (t = *tp) != NULL; tp = &t->next) +	list_for_each_entry(t, &tcf_proto_base, head)  		if (!strcmp(ops->kind, t->kind))  			goto out; -	ops->next = NULL; -	*tp = ops; +	list_add_tail(&ops->head, &tcf_proto_base);  	rc = 0;  out:  	write_unlock(&cls_mod_lock); @@ -80,19 +78,17 @@ EXPORT_SYMBOL(register_tcf_proto_ops);  int unregister_tcf_proto_ops(struct tcf_proto_ops *ops)  { -	struct tcf_proto_ops *t, **tp; +	struct tcf_proto_ops *t;  	int rc = -ENOENT;  	write_lock(&cls_mod_lock); -	for (tp = &tcf_proto_base; (t = *tp) != NULL; tp = &t->next) -		if (t == ops) +	list_for_each_entry(t, &tcf_proto_base, head) { +		if (t == ops) { +			list_del(&t->head); +			rc = 0;  			break; - -	if (!t) -		goto out; -	*tp = t->next; -	rc = 0; -out: +		} +	}  	write_unlock(&cls_mod_lock);  	return rc;  } @@ -138,7 +134,8 @@ static int tc_ctl_tfilter(struct sk_buff *skb, struct nlmsghdr *n)  	int err;  	int tp_created = 0; -	if ((n->nlmsg_type != RTM_GETTFILTER) && !capable(CAP_NET_ADMIN)) +	if ((n->nlmsg_type != RTM_GETTFILTER) && +	    !netlink_ns_capable(skb, net->user_ns, CAP_NET_ADMIN))  		return -EPERM;  replay: @@ -321,7 +318,8 @@ replay:  		}  	} -	err = tp->ops->change(net, skb, tp, cl, t->tcm_handle, tca, &fh); +	err = tp->ops->change(net, skb, tp, cl, t->tcm_handle, tca, &fh, +			      n->nlmsg_flags & NLM_F_CREATE ? TCA_ACT_NOREPLACE : TCA_ACT_REPLACE);  	if (err == 0) {  		if (tp_created) {  			spin_lock_bh(root_lock); @@ -344,7 +342,7 @@ errout:  	return err;  } -static int tcf_fill_node(struct sk_buff *skb, struct tcf_proto *tp, +static int tcf_fill_node(struct net *net, struct sk_buff *skb, struct tcf_proto *tp,  			 unsigned long fh, u32 portid, u32 seq, u16 flags, int event)  {  	struct tcmsg *tcm; @@ -366,7 +364,7 @@ static int tcf_fill_node(struct sk_buff *skb, struct tcf_proto *tp,  	tcm->tcm_handle = fh;  	if (RTM_DELTFILTER != event) {  		tcm->tcm_handle = 0; -		if (tp->ops->dump && tp->ops->dump(tp, fh, skb, tcm) < 0) +		if (tp->ops->dump && tp->ops->dump(net, tp, fh, skb, tcm) < 0)  			goto nla_put_failure;  	}  	nlh->nlmsg_len = skb_tail_pointer(skb) - b; @@ -389,7 +387,7 @@ static int tfilter_notify(struct net *net, struct sk_buff *oskb,  	if (!skb)  		return -ENOBUFS; -	if (tcf_fill_node(skb, tp, fh, portid, n->nlmsg_seq, 0, event) <= 0) { +	if (tcf_fill_node(net, skb, tp, fh, portid, n->nlmsg_seq, 0, event) <= 0) {  		kfree_skb(skb);  		return -EINVAL;  	} @@ -408,8 +406,9 @@ static int tcf_node_dump(struct tcf_proto *tp, unsigned long n,  			 struct tcf_walker *arg)  {  	struct tcf_dump_args *a = (void *)arg; +	struct net *net = sock_net(a->skb->sk); -	return tcf_fill_node(a->skb, tp, n, NETLINK_CB(a->cb->skb).portid, +	return tcf_fill_node(net, a->skb, tp, n, NETLINK_CB(a->cb->skb).portid,  			     a->cb->nlh->nlmsg_seq, NLM_F_MULTI, RTM_NEWTFILTER);  } @@ -467,7 +466,7 @@ static int tc_dump_tfilter(struct sk_buff *skb, struct netlink_callback *cb)  		if (t > s_t)  			memset(&cb->args[1], 0, sizeof(cb->args)-sizeof(cb->args[0]));  		if (cb->args[1] == 0) { -			if (tcf_fill_node(skb, tp, 0, NETLINK_CB(cb->skb).portid, +			if (tcf_fill_node(net, skb, tp, 0, NETLINK_CB(cb->skb).portid,  					  cb->nlh->nlmsg_seq, NLM_F_MULTI,  					  RTM_NEWTFILTER) <= 0)  				break; @@ -500,46 +499,41 @@ out:  void tcf_exts_destroy(struct tcf_proto *tp, struct tcf_exts *exts)  {  #ifdef CONFIG_NET_CLS_ACT -	if (exts->action) { -		tcf_action_destroy(exts->action, TCA_ACT_UNBIND); -		exts->action = NULL; -	} +	tcf_action_destroy(&exts->actions, TCA_ACT_UNBIND); +	INIT_LIST_HEAD(&exts->actions);  #endif  }  EXPORT_SYMBOL(tcf_exts_destroy);  int tcf_exts_validate(struct net *net, struct tcf_proto *tp, struct nlattr **tb, -		  struct nlattr *rate_tlv, struct tcf_exts *exts, -		  const struct tcf_ext_map *map) +		  struct nlattr *rate_tlv, struct tcf_exts *exts, bool ovr)  { -	memset(exts, 0, sizeof(*exts)); -  #ifdef CONFIG_NET_CLS_ACT  	{  		struct tc_action *act; -		if (map->police && tb[map->police]) { -			act = tcf_action_init_1(net, tb[map->police], rate_tlv, -						"police", TCA_ACT_NOREPLACE, +		INIT_LIST_HEAD(&exts->actions); +		if (exts->police && tb[exts->police]) { +			act = tcf_action_init_1(net, tb[exts->police], rate_tlv, +						"police", ovr,  						TCA_ACT_BIND);  			if (IS_ERR(act))  				return PTR_ERR(act); -			act->type = TCA_OLD_COMPAT; -			exts->action = act; -		} else if (map->action && tb[map->action]) { -			act = tcf_action_init(net, tb[map->action], rate_tlv, -					      NULL, TCA_ACT_NOREPLACE, -					      TCA_ACT_BIND); -			if (IS_ERR(act)) -				return PTR_ERR(act); - -			exts->action = act; +			act->type = exts->type = TCA_OLD_COMPAT; +			list_add(&act->list, &exts->actions); +		} else if (exts->action && tb[exts->action]) { +			int err; +			err = tcf_action_init(net, tb[exts->action], rate_tlv, +					      NULL, ovr, +					      TCA_ACT_BIND, &exts->actions); +			if (err) +				return err;  		}  	}  #else -	if ((map->action && tb[map->action]) || -	    (map->police && tb[map->police])) +	if ((exts->action && tb[exts->action]) || +	    (exts->police && tb[exts->police]))  		return -EOPNOTSUPP;  #endif @@ -551,43 +545,42 @@ void tcf_exts_change(struct tcf_proto *tp, struct tcf_exts *dst,  		     struct tcf_exts *src)  {  #ifdef CONFIG_NET_CLS_ACT -	if (src->action) { -		struct tc_action *act; -		tcf_tree_lock(tp); -		act = dst->action; -		dst->action = src->action; -		tcf_tree_unlock(tp); -		if (act) -			tcf_action_destroy(act, TCA_ACT_UNBIND); -	} +	LIST_HEAD(tmp); +	tcf_tree_lock(tp); +	list_splice_init(&dst->actions, &tmp); +	list_splice(&src->actions, &dst->actions); +	tcf_tree_unlock(tp); +	tcf_action_destroy(&tmp, TCA_ACT_UNBIND);  #endif  }  EXPORT_SYMBOL(tcf_exts_change); -int tcf_exts_dump(struct sk_buff *skb, struct tcf_exts *exts, -		  const struct tcf_ext_map *map) +#define tcf_exts_first_act(ext) \ +		list_first_entry(&(exts)->actions, struct tc_action, list) + +int tcf_exts_dump(struct sk_buff *skb, struct tcf_exts *exts)  {  #ifdef CONFIG_NET_CLS_ACT -	if (map->action && exts->action) { +	if (exts->action && !list_empty(&exts->actions)) {  		/*  		 * again for backward compatible mode - we want  		 * to work with both old and new modes of entering  		 * tc data even if iproute2  was newer - jhs  		 */  		struct nlattr *nest; - -		if (exts->action->type != TCA_OLD_COMPAT) { -			nest = nla_nest_start(skb, map->action); +		if (exts->type != TCA_OLD_COMPAT) { +			nest = nla_nest_start(skb, exts->action);  			if (nest == NULL)  				goto nla_put_failure; -			if (tcf_action_dump(skb, exts->action, 0, 0) < 0) +			if (tcf_action_dump(skb, &exts->actions, 0, 0) < 0)  				goto nla_put_failure;  			nla_nest_end(skb, nest); -		} else if (map->police) { -			nest = nla_nest_start(skb, map->police); -			if (nest == NULL) +		} else if (exts->police) { +			struct tc_action *act = tcf_exts_first_act(exts); +			nest = nla_nest_start(skb, exts->police); +			if (nest == NULL || !act)  				goto nla_put_failure; -			if (tcf_action_dump_old(skb, exts->action, 0, 0) < 0) +			if (tcf_action_dump_old(skb, act, 0, 0) < 0)  				goto nla_put_failure;  			nla_nest_end(skb, nest);  		} @@ -600,17 +593,14 @@ nla_put_failure: __attribute__ ((unused))  EXPORT_SYMBOL(tcf_exts_dump); -int tcf_exts_dump_stats(struct sk_buff *skb, struct tcf_exts *exts, -			const struct tcf_ext_map *map) +int tcf_exts_dump_stats(struct sk_buff *skb, struct tcf_exts *exts)  {  #ifdef CONFIG_NET_CLS_ACT -	if (exts->action) -		if (tcf_action_copy_stats(skb, exts->action, 1) < 0) -			goto nla_put_failure; +	struct tc_action *a = tcf_exts_first_act(exts); +	if (tcf_action_copy_stats(skb, a, 1) < 0) +		return -1;  #endif  	return 0; -nla_put_failure: __attribute__ ((unused)) -	return -1;  }  EXPORT_SYMBOL(tcf_exts_dump_stats);  | 
