cls_basic.c 7.3 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7 8 9 10 11 12
/*
 * net/sched/cls_basic.c	Basic Packet Classifier.
 *
 *		This program is free software; you can redistribute it and/or
 *		modify it under the terms of the GNU General Public License
 *		as published by the Free Software Foundation; either version
 *		2 of the License, or (at your option) any later version.
 *
 * Authors:	Thomas Graf <tgraf@suug.ch>
 */

#include <linux/module.h>
13
#include <linux/slab.h>
L
Linus Torvalds 已提交
14 15 16 17 18 19
#include <linux/types.h>
#include <linux/kernel.h>
#include <linux/string.h>
#include <linux/errno.h>
#include <linux/rtnetlink.h>
#include <linux/skbuff.h>
20
#include <linux/idr.h>
21
#include <net/netlink.h>
L
Linus Torvalds 已提交
22 23 24
#include <net/act_api.h>
#include <net/pkt_cls.h>

E
Eric Dumazet 已提交
25
struct basic_head {
L
Linus Torvalds 已提交
26
	struct list_head	flist;
27
	struct idr		handle_idr;
J
John Fastabend 已提交
28
	struct rcu_head		rcu;
L
Linus Torvalds 已提交
29 30
};

E
Eric Dumazet 已提交
31
struct basic_filter {
L
Linus Torvalds 已提交
32 33 34 35
	u32			handle;
	struct tcf_exts		exts;
	struct tcf_ematch_tree	ematches;
	struct tcf_result	res;
J
John Fastabend 已提交
36
	struct tcf_proto	*tp;
L
Linus Torvalds 已提交
37
	struct list_head	link;
C
Cong Wang 已提交
38
	struct rcu_work		rwork;
L
Linus Torvalds 已提交
39 40
};

41
static int basic_classify(struct sk_buff *skb, const struct tcf_proto *tp,
L
Linus Torvalds 已提交
42 43 44
			  struct tcf_result *res)
{
	int r;
J
John Fastabend 已提交
45
	struct basic_head *head = rcu_dereference_bh(tp->root);
L
Linus Torvalds 已提交
46 47
	struct basic_filter *f;

J
John Fastabend 已提交
48
	list_for_each_entry_rcu(f, &head->flist, link) {
L
Linus Torvalds 已提交
49 50 51 52 53 54 55 56 57 58 59
		if (!tcf_em_tree_match(skb, &f->ematches, NULL))
			continue;
		*res = f->res;
		r = tcf_exts_exec(skb, &f->exts, res);
		if (r < 0)
			continue;
		return r;
	}
	return -1;
}

60
static void *basic_get(struct tcf_proto *tp, u32 handle)
L
Linus Torvalds 已提交
61
{
J
John Fastabend 已提交
62
	struct basic_head *head = rtnl_dereference(tp->root);
L
Linus Torvalds 已提交
63 64
	struct basic_filter *f;

65 66
	list_for_each_entry(f, &head->flist, link) {
		if (f->handle == handle) {
67
			return f;
68 69
		}
	}
L
Linus Torvalds 已提交
70

71
	return NULL;
L
Linus Torvalds 已提交
72 73 74 75
}

static int basic_init(struct tcf_proto *tp)
{
76 77 78 79 80 81
	struct basic_head *head;

	head = kzalloc(sizeof(*head), GFP_KERNEL);
	if (head == NULL)
		return -ENOBUFS;
	INIT_LIST_HEAD(&head->flist);
82
	idr_init(&head->handle_idr);
J
John Fastabend 已提交
83
	rcu_assign_pointer(tp->root, head);
L
Linus Torvalds 已提交
84 85 86
	return 0;
}

87 88 89 90 91 92 93 94
static void __basic_delete_filter(struct basic_filter *f)
{
	tcf_exts_destroy(&f->exts);
	tcf_em_tree_destroy(&f->ematches);
	tcf_exts_put_net(&f->exts);
	kfree(f);
}

95
static void basic_delete_filter_work(struct work_struct *work)
L
Linus Torvalds 已提交
96
{
C
Cong Wang 已提交
97 98 99
	struct basic_filter *f = container_of(to_rcu_work(work),
					      struct basic_filter,
					      rwork);
100
	rtnl_lock();
101
	__basic_delete_filter(f);
102
	rtnl_unlock();
L
Linus Torvalds 已提交
103 104
}

105
static void basic_destroy(struct tcf_proto *tp, struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
106
{
J
John Fastabend 已提交
107
	struct basic_head *head = rtnl_dereference(tp->root);
L
Linus Torvalds 已提交
108
	struct basic_filter *f, *n;
109

L
Linus Torvalds 已提交
110
	list_for_each_entry_safe(f, n, &head->flist, link) {
J
John Fastabend 已提交
111
		list_del_rcu(&f->link);
112
		tcf_unbind_filter(tp, &f->res);
113
		idr_remove(&head->handle_idr, f->handle);
114
		if (tcf_exts_get_net(&f->exts))
C
Cong Wang 已提交
115
			tcf_queue_work(&f->rwork, basic_delete_filter_work);
116 117
		else
			__basic_delete_filter(f);
L
Linus Torvalds 已提交
118
	}
119
	idr_destroy(&head->handle_idr);
J
John Fastabend 已提交
120
	kfree_rcu(head, rcu);
L
Linus Torvalds 已提交
121 122
}

123 124
static int basic_delete(struct tcf_proto *tp, void *arg, bool *last,
			struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
125
{
126
	struct basic_head *head = rtnl_dereference(tp->root);
127
	struct basic_filter *f = arg;
L
Linus Torvalds 已提交
128

129 130
	list_del_rcu(&f->link);
	tcf_unbind_filter(tp, &f->res);
131
	idr_remove(&head->handle_idr, f->handle);
132
	tcf_exts_get_net(&f->exts);
C
Cong Wang 已提交
133
	tcf_queue_work(&f->rwork, basic_delete_filter_work);
134
	*last = list_empty(&head->flist);
135
	return 0;
L
Linus Torvalds 已提交
136 137
}

138 139 140 141 142
static const struct nla_policy basic_policy[TCA_BASIC_MAX + 1] = {
	[TCA_BASIC_CLASSID]	= { .type = NLA_U32 },
	[TCA_BASIC_EMATCHES]	= { .type = NLA_NESTED },
};

143 144 145
static int basic_set_parms(struct net *net, struct tcf_proto *tp,
			   struct basic_filter *f, unsigned long base,
			   struct nlattr **tb,
146 147
			   struct nlattr *est, bool ovr,
			   struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
148
{
149
	int err;
L
Linus Torvalds 已提交
150

151
	err = tcf_exts_validate(net, tp, tb, est, &f->exts, ovr, extack);
L
Linus Torvalds 已提交
152 153 154
	if (err < 0)
		return err;

155
	err = tcf_em_tree_validate(tp, tb[TCA_BASIC_EMATCHES], &f->ematches);
L
Linus Torvalds 已提交
156
	if (err < 0)
157
		return err;
L
Linus Torvalds 已提交
158

159
	if (tb[TCA_BASIC_CLASSID]) {
160
		f->res.classid = nla_get_u32(tb[TCA_BASIC_CLASSID]);
L
Linus Torvalds 已提交
161 162 163
		tcf_bind_filter(tp, &f->res, base);
	}

J
John Fastabend 已提交
164
	f->tp = tp;
L
Linus Torvalds 已提交
165 166 167
	return 0;
}

168
static int basic_change(struct net *net, struct sk_buff *in_skb,
169
			struct tcf_proto *tp, unsigned long base, u32 handle,
170 171
			struct nlattr **tca, void **arg, bool ovr,
			struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
172
{
173
	int err;
J
John Fastabend 已提交
174
	struct basic_head *head = rtnl_dereference(tp->root);
175
	struct nlattr *tb[TCA_BASIC_MAX + 1];
J
John Fastabend 已提交
176 177
	struct basic_filter *fold = (struct basic_filter *) *arg;
	struct basic_filter *fnew;
L
Linus Torvalds 已提交
178

179
	if (tca[TCA_OPTIONS] == NULL)
L
Linus Torvalds 已提交
180 181
		return -EINVAL;

182
	err = nla_parse_nested(tb, TCA_BASIC_MAX, tca[TCA_OPTIONS],
183
			       basic_policy, NULL);
184 185
	if (err < 0)
		return err;
L
Linus Torvalds 已提交
186

J
John Fastabend 已提交
187 188
	if (fold != NULL) {
		if (handle && fold->handle != handle)
L
Linus Torvalds 已提交
189 190 191
			return -EINVAL;
	}

J
John Fastabend 已提交
192
	fnew = kzalloc(sizeof(*fnew), GFP_KERNEL);
193 194
	if (!fnew)
		return -ENOBUFS;
L
Linus Torvalds 已提交
195

196 197 198 199
	err = tcf_exts_init(&fnew->exts, TCA_BASIC_ACT, TCA_BASIC_POLICE);
	if (err < 0)
		goto errout;

200 201 202 203 204 205 206
	if (!handle) {
		handle = 1;
		err = idr_alloc_u32(&head->handle_idr, fnew, &handle,
				    INT_MAX, GFP_KERNEL);
	} else if (!fold) {
		err = idr_alloc_u32(&head->handle_idr, fnew, &handle,
				    handle, GFP_KERNEL);
L
Linus Torvalds 已提交
207
	}
208 209 210
	if (err)
		goto errout;
	fnew->handle = handle;
L
Linus Torvalds 已提交
211

212 213
	err = basic_set_parms(net, tp, fnew, base, tb, tca[TCA_RATE], ovr,
			      extack);
214 215
	if (err < 0) {
		if (!fold)
216
			idr_remove(&head->handle_idr, fnew->handle);
L
Linus Torvalds 已提交
217
		goto errout;
218
	}
L
Linus Torvalds 已提交
219

220
	*arg = fnew;
J
John Fastabend 已提交
221 222

	if (fold) {
223
		idr_replace(&head->handle_idr, fnew, fnew->handle);
J
John Fastabend 已提交
224
		list_replace_rcu(&fold->link, &fnew->link);
225
		tcf_unbind_filter(tp, &fold->res);
226
		tcf_exts_get_net(&fold->exts);
C
Cong Wang 已提交
227
		tcf_queue_work(&fold->rwork, basic_delete_filter_work);
J
John Fastabend 已提交
228 229 230
	} else {
		list_add_rcu(&fnew->link, &head->flist);
	}
L
Linus Torvalds 已提交
231 232 233

	return 0;
errout:
234
	tcf_exts_destroy(&fnew->exts);
J
John Fastabend 已提交
235
	kfree(fnew);
L
Linus Torvalds 已提交
236 237 238 239 240
	return err;
}

static void basic_walk(struct tcf_proto *tp, struct tcf_walker *arg)
{
J
John Fastabend 已提交
241
	struct basic_head *head = rtnl_dereference(tp->root);
L
Linus Torvalds 已提交
242 243 244 245 246 247
	struct basic_filter *f;

	list_for_each_entry(f, &head->flist, link) {
		if (arg->count < arg->skip)
			goto skip;

248
		if (arg->fn(tp, f, arg) < 0) {
L
Linus Torvalds 已提交
249 250 251 252 253 254 255 256
			arg->stop = 1;
			break;
		}
skip:
		arg->count++;
	}
}

257 258 259 260 261 262 263 264
static void basic_bind_class(void *fh, u32 classid, unsigned long cl)
{
	struct basic_filter *f = fh;

	if (f && f->res.classid == classid)
		f->res.class = cl;
}

265
static int basic_dump(struct net *net, struct tcf_proto *tp, void *fh,
L
Linus Torvalds 已提交
266 267
		      struct sk_buff *skb, struct tcmsg *t)
{
268
	struct basic_filter *f = fh;
269
	struct nlattr *nest;
L
Linus Torvalds 已提交
270 271 272 273 274 275

	if (f == NULL)
		return skb->len;

	t->tcm_handle = f->handle;

276 277 278
	nest = nla_nest_start(skb, TCA_OPTIONS);
	if (nest == NULL)
		goto nla_put_failure;
L
Linus Torvalds 已提交
279

280 281 282
	if (f->res.classid &&
	    nla_put_u32(skb, TCA_BASIC_CLASSID, f->res.classid))
		goto nla_put_failure;
283

284
	if (tcf_exts_dump(skb, &f->exts) < 0 ||
L
Linus Torvalds 已提交
285
	    tcf_em_tree_dump(skb, &f->ematches, TCA_BASIC_EMATCHES) < 0)
286
		goto nla_put_failure;
L
Linus Torvalds 已提交
287

288
	nla_nest_end(skb, nest);
289

290
	if (tcf_exts_dump_stats(skb, &f->exts) < 0)
291 292
		goto nla_put_failure;

L
Linus Torvalds 已提交
293 294
	return skb->len;

295
nla_put_failure:
296
	nla_nest_cancel(skb, nest);
L
Linus Torvalds 已提交
297 298 299
	return -1;
}

300
static struct tcf_proto_ops cls_basic_ops __read_mostly = {
L
Linus Torvalds 已提交
301 302 303 304 305 306 307 308 309
	.kind		=	"basic",
	.classify	=	basic_classify,
	.init		=	basic_init,
	.destroy	=	basic_destroy,
	.get		=	basic_get,
	.change		=	basic_change,
	.delete		=	basic_delete,
	.walk		=	basic_walk,
	.dump		=	basic_dump,
310
	.bind_class	=	basic_bind_class,
L
Linus Torvalds 已提交
311 312 313 314 315 316 317 318
	.owner		=	THIS_MODULE,
};

static int __init init_basic(void)
{
	return register_tcf_proto_ops(&cls_basic_ops);
}

319
static void __exit exit_basic(void)
L
Linus Torvalds 已提交
320 321 322 323 324 325 326
{
	unregister_tcf_proto_ops(&cls_basic_ops);
}

module_init(init_basic)
module_exit(exit_basic)
MODULE_LICENSE("GPL");