net/macb: Update DT bindings documentation
[deliverable/linux.git] / net / sched / cls_fw.c
... / ...
CommitLineData
1/*
2 * net/sched/cls_fw.c Classifier mapping ipchains' fwmark to traffic class.
3 *
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public License
6 * as published by the Free Software Foundation; either version
7 * 2 of the License, or (at your option) any later version.
8 *
9 * Authors: Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
10 *
11 * Changes:
12 * Karlis Peisenieks <karlis@mt.lv> : 990415 : fw_walk off by one
13 * Karlis Peisenieks <karlis@mt.lv> : 990415 : fw_delete killed all the filter (and kernel).
14 * Alex <alex@pilotsoft.com> : 2004xxyy: Added Action extension
15 *
16 * JHS: We should remove the CONFIG_NET_CLS_IND from here
17 * eventually when the meta match extension is made available
18 *
19 */
20
21#include <linux/module.h>
22#include <linux/slab.h>
23#include <linux/types.h>
24#include <linux/kernel.h>
25#include <linux/string.h>
26#include <linux/errno.h>
27#include <linux/skbuff.h>
28#include <net/netlink.h>
29#include <net/act_api.h>
30#include <net/pkt_cls.h>
31
32#define HTSIZE 256
33
34struct fw_head {
35 u32 mask;
36 bool mask_set;
37 struct fw_filter __rcu *ht[HTSIZE];
38 struct rcu_head rcu;
39};
40
41struct fw_filter {
42 struct fw_filter __rcu *next;
43 u32 id;
44 struct tcf_result res;
45#ifdef CONFIG_NET_CLS_IND
46 int ifindex;
47#endif /* CONFIG_NET_CLS_IND */
48 struct tcf_exts exts;
49 struct tcf_proto *tp;
50 struct rcu_head rcu;
51};
52
53static u32 fw_hash(u32 handle)
54{
55 handle ^= (handle >> 16);
56 handle ^= (handle >> 8);
57 return handle % HTSIZE;
58}
59
60static int fw_classify(struct sk_buff *skb, const struct tcf_proto *tp,
61 struct tcf_result *res)
62{
63 struct fw_head *head = rcu_dereference_bh(tp->root);
64 struct fw_filter *f;
65 int r;
66 u32 id = skb->mark;
67
68 if (head != NULL) {
69 id &= head->mask;
70
71 for (f = rcu_dereference_bh(head->ht[fw_hash(id)]); f;
72 f = rcu_dereference_bh(f->next)) {
73 if (f->id == id) {
74 *res = f->res;
75#ifdef CONFIG_NET_CLS_IND
76 if (!tcf_match_indev(skb, f->ifindex))
77 continue;
78#endif /* CONFIG_NET_CLS_IND */
79 r = tcf_exts_exec(skb, &f->exts, res);
80 if (r < 0)
81 continue;
82
83 return r;
84 }
85 }
86 } else {
87 /* old method */
88 if (id && (TC_H_MAJ(id) == 0 ||
89 !(TC_H_MAJ(id ^ tp->q->handle)))) {
90 res->classid = id;
91 res->class = 0;
92 return 0;
93 }
94 }
95
96 return -1;
97}
98
99static unsigned long fw_get(struct tcf_proto *tp, u32 handle)
100{
101 struct fw_head *head = rtnl_dereference(tp->root);
102 struct fw_filter *f;
103
104 if (head == NULL)
105 return 0;
106
107 f = rtnl_dereference(head->ht[fw_hash(handle)]);
108 for (; f; f = rtnl_dereference(f->next)) {
109 if (f->id == handle)
110 return (unsigned long)f;
111 }
112 return 0;
113}
114
115static int fw_init(struct tcf_proto *tp)
116{
117 struct fw_head *head;
118
119 head = kzalloc(sizeof(struct fw_head), GFP_KERNEL);
120 if (head == NULL)
121 return -ENOBUFS;
122
123 head->mask_set = false;
124 rcu_assign_pointer(tp->root, head);
125 return 0;
126}
127
128static void fw_delete_filter(struct rcu_head *head)
129{
130 struct fw_filter *f = container_of(head, struct fw_filter, rcu);
131
132 tcf_exts_destroy(&f->exts);
133 kfree(f);
134}
135
136static void fw_destroy(struct tcf_proto *tp)
137{
138 struct fw_head *head = rtnl_dereference(tp->root);
139 struct fw_filter *f;
140 int h;
141
142 if (head == NULL)
143 return;
144
145 for (h = 0; h < HTSIZE; h++) {
146 while ((f = rtnl_dereference(head->ht[h])) != NULL) {
147 RCU_INIT_POINTER(head->ht[h],
148 rtnl_dereference(f->next));
149 tcf_unbind_filter(tp, &f->res);
150 call_rcu(&f->rcu, fw_delete_filter);
151 }
152 }
153 RCU_INIT_POINTER(tp->root, NULL);
154 kfree_rcu(head, rcu);
155}
156
157static int fw_delete(struct tcf_proto *tp, unsigned long arg)
158{
159 struct fw_head *head = rtnl_dereference(tp->root);
160 struct fw_filter *f = (struct fw_filter *)arg;
161 struct fw_filter __rcu **fp;
162 struct fw_filter *pfp;
163
164 if (head == NULL || f == NULL)
165 goto out;
166
167 fp = &head->ht[fw_hash(f->id)];
168
169 for (pfp = rtnl_dereference(*fp); pfp;
170 fp = &pfp->next, pfp = rtnl_dereference(*fp)) {
171 if (pfp == f) {
172 RCU_INIT_POINTER(*fp, rtnl_dereference(f->next));
173 tcf_unbind_filter(tp, &f->res);
174 call_rcu(&f->rcu, fw_delete_filter);
175 return 0;
176 }
177 }
178out:
179 return -EINVAL;
180}
181
182static const struct nla_policy fw_policy[TCA_FW_MAX + 1] = {
183 [TCA_FW_CLASSID] = { .type = NLA_U32 },
184 [TCA_FW_INDEV] = { .type = NLA_STRING, .len = IFNAMSIZ },
185 [TCA_FW_MASK] = { .type = NLA_U32 },
186};
187
188static int
189fw_change_attrs(struct net *net, struct tcf_proto *tp, struct fw_filter *f,
190 struct nlattr **tb, struct nlattr **tca, unsigned long base, bool ovr)
191{
192 struct fw_head *head = rtnl_dereference(tp->root);
193 struct tcf_exts e;
194 u32 mask;
195 int err;
196
197 tcf_exts_init(&e, TCA_FW_ACT, TCA_FW_POLICE);
198 err = tcf_exts_validate(net, tp, tb, tca[TCA_RATE], &e, ovr);
199 if (err < 0)
200 return err;
201
202 if (tb[TCA_FW_CLASSID]) {
203 f->res.classid = nla_get_u32(tb[TCA_FW_CLASSID]);
204 tcf_bind_filter(tp, &f->res, base);
205 }
206
207#ifdef CONFIG_NET_CLS_IND
208 if (tb[TCA_FW_INDEV]) {
209 int ret;
210 ret = tcf_change_indev(net, tb[TCA_FW_INDEV]);
211 if (ret < 0) {
212 err = ret;
213 goto errout;
214 }
215 f->ifindex = ret;
216 }
217#endif /* CONFIG_NET_CLS_IND */
218
219 err = -EINVAL;
220 if (tb[TCA_FW_MASK]) {
221 mask = nla_get_u32(tb[TCA_FW_MASK]);
222 if (mask != head->mask)
223 goto errout;
224 } else if (head->mask != 0xFFFFFFFF)
225 goto errout;
226
227 tcf_exts_change(tp, &f->exts, &e);
228
229 return 0;
230errout:
231 tcf_exts_destroy(&e);
232 return err;
233}
234
235static int fw_change(struct net *net, struct sk_buff *in_skb,
236 struct tcf_proto *tp, unsigned long base,
237 u32 handle,
238 struct nlattr **tca,
239 unsigned long *arg, bool ovr)
240{
241 struct fw_head *head = rtnl_dereference(tp->root);
242 struct fw_filter *f = (struct fw_filter *) *arg;
243 struct nlattr *opt = tca[TCA_OPTIONS];
244 struct nlattr *tb[TCA_FW_MAX + 1];
245 int err;
246
247 if (!opt)
248 return handle ? -EINVAL : 0;
249
250 err = nla_parse_nested(tb, TCA_FW_MAX, opt, fw_policy);
251 if (err < 0)
252 return err;
253
254 if (f) {
255 struct fw_filter *pfp, *fnew;
256 struct fw_filter __rcu **fp;
257
258 if (f->id != handle && handle)
259 return -EINVAL;
260
261 fnew = kzalloc(sizeof(struct fw_filter), GFP_KERNEL);
262 if (!fnew)
263 return -ENOBUFS;
264
265 fnew->id = f->id;
266 fnew->res = f->res;
267#ifdef CONFIG_NET_CLS_IND
268 fnew->ifindex = f->ifindex;
269#endif /* CONFIG_NET_CLS_IND */
270 fnew->tp = f->tp;
271
272 tcf_exts_init(&fnew->exts, TCA_FW_ACT, TCA_FW_POLICE);
273
274 err = fw_change_attrs(net, tp, fnew, tb, tca, base, ovr);
275 if (err < 0) {
276 kfree(fnew);
277 return err;
278 }
279
280 fp = &head->ht[fw_hash(fnew->id)];
281 for (pfp = rtnl_dereference(*fp); pfp;
282 fp = &pfp->next, pfp = rtnl_dereference(*fp))
283 if (pfp == f)
284 break;
285
286 RCU_INIT_POINTER(fnew->next, rtnl_dereference(pfp->next));
287 rcu_assign_pointer(*fp, fnew);
288 tcf_unbind_filter(tp, &f->res);
289 call_rcu(&f->rcu, fw_delete_filter);
290
291 *arg = (unsigned long)fnew;
292 return err;
293 }
294
295 if (!handle)
296 return -EINVAL;
297
298 if (!head->mask_set) {
299 head->mask = 0xFFFFFFFF;
300 if (tb[TCA_FW_MASK])
301 head->mask = nla_get_u32(tb[TCA_FW_MASK]);
302 head->mask_set = true;
303 }
304
305 f = kzalloc(sizeof(struct fw_filter), GFP_KERNEL);
306 if (f == NULL)
307 return -ENOBUFS;
308
309 tcf_exts_init(&f->exts, TCA_FW_ACT, TCA_FW_POLICE);
310 f->id = handle;
311 f->tp = tp;
312
313 err = fw_change_attrs(net, tp, f, tb, tca, base, ovr);
314 if (err < 0)
315 goto errout;
316
317 RCU_INIT_POINTER(f->next, head->ht[fw_hash(handle)]);
318 rcu_assign_pointer(head->ht[fw_hash(handle)], f);
319
320 *arg = (unsigned long)f;
321 return 0;
322
323errout:
324 kfree(f);
325 return err;
326}
327
328static void fw_walk(struct tcf_proto *tp, struct tcf_walker *arg)
329{
330 struct fw_head *head = rtnl_dereference(tp->root);
331 int h;
332
333 if (head == NULL)
334 arg->stop = 1;
335
336 if (arg->stop)
337 return;
338
339 for (h = 0; h < HTSIZE; h++) {
340 struct fw_filter *f;
341
342 for (f = rtnl_dereference(head->ht[h]); f;
343 f = rtnl_dereference(f->next)) {
344 if (arg->count < arg->skip) {
345 arg->count++;
346 continue;
347 }
348 if (arg->fn(tp, (unsigned long)f, arg) < 0) {
349 arg->stop = 1;
350 return;
351 }
352 arg->count++;
353 }
354 }
355}
356
357static int fw_dump(struct net *net, struct tcf_proto *tp, unsigned long fh,
358 struct sk_buff *skb, struct tcmsg *t)
359{
360 struct fw_head *head = rtnl_dereference(tp->root);
361 struct fw_filter *f = (struct fw_filter *)fh;
362 struct nlattr *nest;
363
364 if (f == NULL)
365 return skb->len;
366
367 t->tcm_handle = f->id;
368
369 if (!f->res.classid && !tcf_exts_is_available(&f->exts))
370 return skb->len;
371
372 nest = nla_nest_start(skb, TCA_OPTIONS);
373 if (nest == NULL)
374 goto nla_put_failure;
375
376 if (f->res.classid &&
377 nla_put_u32(skb, TCA_FW_CLASSID, f->res.classid))
378 goto nla_put_failure;
379#ifdef CONFIG_NET_CLS_IND
380 if (f->ifindex) {
381 struct net_device *dev;
382 dev = __dev_get_by_index(net, f->ifindex);
383 if (dev && nla_put_string(skb, TCA_FW_INDEV, dev->name))
384 goto nla_put_failure;
385 }
386#endif /* CONFIG_NET_CLS_IND */
387 if (head->mask != 0xFFFFFFFF &&
388 nla_put_u32(skb, TCA_FW_MASK, head->mask))
389 goto nla_put_failure;
390
391 if (tcf_exts_dump(skb, &f->exts) < 0)
392 goto nla_put_failure;
393
394 nla_nest_end(skb, nest);
395
396 if (tcf_exts_dump_stats(skb, &f->exts) < 0)
397 goto nla_put_failure;
398
399 return skb->len;
400
401nla_put_failure:
402 nla_nest_cancel(skb, nest);
403 return -1;
404}
405
406static struct tcf_proto_ops cls_fw_ops __read_mostly = {
407 .kind = "fw",
408 .classify = fw_classify,
409 .init = fw_init,
410 .destroy = fw_destroy,
411 .get = fw_get,
412 .change = fw_change,
413 .delete = fw_delete,
414 .walk = fw_walk,
415 .dump = fw_dump,
416 .owner = THIS_MODULE,
417};
418
419static int __init init_fw(void)
420{
421 return register_tcf_proto_ops(&cls_fw_ops);
422}
423
424static void __exit exit_fw(void)
425{
426 unregister_tcf_proto_ops(&cls_fw_ops);
427}
428
429module_init(init_fw)
430module_exit(exit_fw)
431MODULE_LICENSE("GPL");
This page took 0.032049 seconds and 5 git commands to generate.