Linux Audio

Check our new training course

Loading...
v4.17
  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#include <net/sch_generic.h>
 32
 33#define HTSIZE 256
 34
 35struct fw_head {
 36	u32			mask;
 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	union {
 51		struct work_struct	work;
 52		struct rcu_head		rcu;
 53	};
 54};
 55
 56static u32 fw_hash(u32 handle)
 
 
 
 
 
 57{
 58	handle ^= (handle >> 16);
 59	handle ^= (handle >> 8);
 60	return handle % HTSIZE;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 61}
 62
 63static int fw_classify(struct sk_buff *skb, const struct tcf_proto *tp,
 64		       struct tcf_result *res)
 65{
 66	struct fw_head *head = rcu_dereference_bh(tp->root);
 67	struct fw_filter *f;
 68	int r;
 69	u32 id = skb->mark;
 70
 71	if (head != NULL) {
 72		id &= head->mask;
 73
 74		for (f = rcu_dereference_bh(head->ht[fw_hash(id)]); f;
 75		     f = rcu_dereference_bh(f->next)) {
 76			if (f->id == id) {
 77				*res = f->res;
 78#ifdef CONFIG_NET_CLS_IND
 79				if (!tcf_match_indev(skb, f->ifindex))
 80					continue;
 81#endif /* CONFIG_NET_CLS_IND */
 82				r = tcf_exts_exec(skb, &f->exts, res);
 83				if (r < 0)
 84					continue;
 85
 86				return r;
 87			}
 88		}
 89	} else {
 90		struct Qdisc *q = tcf_block_q(tp->chain->block);
 91
 92		/* Old method: classify the packet using its skb mark. */
 93		if (id && (TC_H_MAJ(id) == 0 ||
 94			   !(TC_H_MAJ(id ^ q->handle)))) {
 95			res->classid = id;
 96			res->class = 0;
 97			return 0;
 98		}
 99	}
100
101	return -1;
102}
103
104static void *fw_get(struct tcf_proto *tp, u32 handle)
105{
106	struct fw_head *head = rtnl_dereference(tp->root);
107	struct fw_filter *f;
108
109	if (head == NULL)
110		return NULL;
111
112	f = rtnl_dereference(head->ht[fw_hash(handle)]);
113	for (; f; f = rtnl_dereference(f->next)) {
114		if (f->id == handle)
115			return f;
116	}
117	return NULL;
118}
119
120static int fw_init(struct tcf_proto *tp)
121{
122	/* We don't allocate fw_head here, because in the old method
123	 * we don't need it at all.
124	 */
125	return 0;
126}
127
128static void __fw_delete_filter(struct fw_filter *f)
129{
130	tcf_exts_destroy(&f->exts);
131	tcf_exts_put_net(&f->exts);
132	kfree(f);
133}
134
135static void fw_delete_filter_work(struct work_struct *work)
136{
137	struct fw_filter *f = container_of(work, struct fw_filter, work);
138
139	rtnl_lock();
140	__fw_delete_filter(f);
141	rtnl_unlock();
142}
143
144static void fw_delete_filter(struct rcu_head *head)
145{
146	struct fw_filter *f = container_of(head, struct fw_filter, rcu);
147
148	INIT_WORK(&f->work, fw_delete_filter_work);
149	tcf_queue_work(&f->work);
150}
151
152static void fw_destroy(struct tcf_proto *tp, struct netlink_ext_ack *extack)
153{
154	struct fw_head *head = rtnl_dereference(tp->root);
155	struct fw_filter *f;
156	int h;
157
158	if (head == NULL)
159		return;
160
161	for (h = 0; h < HTSIZE; h++) {
162		while ((f = rtnl_dereference(head->ht[h])) != NULL) {
163			RCU_INIT_POINTER(head->ht[h],
164					 rtnl_dereference(f->next));
165			tcf_unbind_filter(tp, &f->res);
166			if (tcf_exts_get_net(&f->exts))
167				call_rcu(&f->rcu, fw_delete_filter);
168			else
169				__fw_delete_filter(f);
170		}
171	}
172	kfree_rcu(head, rcu);
173}
174
175static int fw_delete(struct tcf_proto *tp, void *arg, bool *last,
176		     struct netlink_ext_ack *extack)
177{
178	struct fw_head *head = rtnl_dereference(tp->root);
179	struct fw_filter *f = arg;
180	struct fw_filter __rcu **fp;
181	struct fw_filter *pfp;
182	int ret = -EINVAL;
183	int h;
184
185	if (head == NULL || f == NULL)
186		goto out;
187
188	fp = &head->ht[fw_hash(f->id)];
189
190	for (pfp = rtnl_dereference(*fp); pfp;
191	     fp = &pfp->next, pfp = rtnl_dereference(*fp)) {
192		if (pfp == f) {
193			RCU_INIT_POINTER(*fp, rtnl_dereference(f->next));
194			tcf_unbind_filter(tp, &f->res);
195			tcf_exts_get_net(&f->exts);
196			call_rcu(&f->rcu, fw_delete_filter);
197			ret = 0;
198			break;
199		}
200	}
201
202	*last = true;
203	for (h = 0; h < HTSIZE; h++) {
204		if (rcu_access_pointer(head->ht[h])) {
205			*last = false;
206			break;
207		}
208	}
209
210out:
211	return ret;
212}
213
214static const struct nla_policy fw_policy[TCA_FW_MAX + 1] = {
215	[TCA_FW_CLASSID]	= { .type = NLA_U32 },
216	[TCA_FW_INDEV]		= { .type = NLA_STRING, .len = IFNAMSIZ },
217	[TCA_FW_MASK]		= { .type = NLA_U32 },
218};
219
220static int fw_set_parms(struct net *net, struct tcf_proto *tp,
221			struct fw_filter *f, struct nlattr **tb,
222			struct nlattr **tca, unsigned long base, bool ovr,
223			struct netlink_ext_ack *extack)
224{
225	struct fw_head *head = rtnl_dereference(tp->root);
 
226	u32 mask;
227	int err;
228
229	err = tcf_exts_validate(net, tp, tb, tca[TCA_RATE], &f->exts, ovr,
230				extack);
231	if (err < 0)
232		return err;
233
 
234	if (tb[TCA_FW_CLASSID]) {
235		f->res.classid = nla_get_u32(tb[TCA_FW_CLASSID]);
236		tcf_bind_filter(tp, &f->res, base);
237	}
238
239#ifdef CONFIG_NET_CLS_IND
240	if (tb[TCA_FW_INDEV]) {
241		int ret;
242		ret = tcf_change_indev(net, tb[TCA_FW_INDEV], extack);
243		if (ret < 0)
244			return ret;
245		f->ifindex = ret;
246	}
247#endif /* CONFIG_NET_CLS_IND */
248
249	err = -EINVAL;
250	if (tb[TCA_FW_MASK]) {
251		mask = nla_get_u32(tb[TCA_FW_MASK]);
252		if (mask != head->mask)
253			return err;
254	} else if (head->mask != 0xFFFFFFFF)
255		return err;
 
 
256
257	return 0;
 
 
 
258}
259
260static int fw_change(struct net *net, struct sk_buff *in_skb,
261		     struct tcf_proto *tp, unsigned long base,
262		     u32 handle, struct nlattr **tca, void **arg,
263		     bool ovr, struct netlink_ext_ack *extack)
264{
265	struct fw_head *head = rtnl_dereference(tp->root);
266	struct fw_filter *f = *arg;
267	struct nlattr *opt = tca[TCA_OPTIONS];
268	struct nlattr *tb[TCA_FW_MAX + 1];
269	int err;
270
271	if (!opt)
272		return handle ? -EINVAL : 0; /* Succeed if it is old method. */
273
274	err = nla_parse_nested(tb, TCA_FW_MAX, opt, fw_policy, NULL);
275	if (err < 0)
276		return err;
277
278	if (f) {
279		struct fw_filter *pfp, *fnew;
280		struct fw_filter __rcu **fp;
281
282		if (f->id != handle && handle)
283			return -EINVAL;
284
285		fnew = kzalloc(sizeof(struct fw_filter), GFP_KERNEL);
286		if (!fnew)
287			return -ENOBUFS;
288
289		fnew->id = f->id;
290		fnew->res = f->res;
291#ifdef CONFIG_NET_CLS_IND
292		fnew->ifindex = f->ifindex;
293#endif /* CONFIG_NET_CLS_IND */
294		fnew->tp = f->tp;
295
296		err = tcf_exts_init(&fnew->exts, TCA_FW_ACT, TCA_FW_POLICE);
297		if (err < 0) {
298			kfree(fnew);
299			return err;
300		}
301
302		err = fw_set_parms(net, tp, fnew, tb, tca, base, ovr, extack);
303		if (err < 0) {
304			tcf_exts_destroy(&fnew->exts);
305			kfree(fnew);
306			return err;
307		}
308
309		fp = &head->ht[fw_hash(fnew->id)];
310		for (pfp = rtnl_dereference(*fp); pfp;
311		     fp = &pfp->next, pfp = rtnl_dereference(*fp))
312			if (pfp == f)
313				break;
314
315		RCU_INIT_POINTER(fnew->next, rtnl_dereference(pfp->next));
316		rcu_assign_pointer(*fp, fnew);
317		tcf_unbind_filter(tp, &f->res);
318		tcf_exts_get_net(&f->exts);
319		call_rcu(&f->rcu, fw_delete_filter);
320
321		*arg = fnew;
322		return err;
323	}
324
325	if (!handle)
326		return -EINVAL;
327
328	if (!head) {
329		u32 mask = 0xFFFFFFFF;
330		if (tb[TCA_FW_MASK])
331			mask = nla_get_u32(tb[TCA_FW_MASK]);
332
333		head = kzalloc(sizeof(*head), GFP_KERNEL);
334		if (!head)
335			return -ENOBUFS;
336		head->mask = mask;
337
338		rcu_assign_pointer(tp->root, head);
 
 
339	}
340
341	f = kzalloc(sizeof(struct fw_filter), GFP_KERNEL);
342	if (f == NULL)
343		return -ENOBUFS;
344
345	err = tcf_exts_init(&f->exts, TCA_FW_ACT, TCA_FW_POLICE);
346	if (err < 0)
347		goto errout;
348	f->id = handle;
349	f->tp = tp;
350
351	err = fw_set_parms(net, tp, f, tb, tca, base, ovr, extack);
352	if (err < 0)
353		goto errout;
354
355	RCU_INIT_POINTER(f->next, head->ht[fw_hash(handle)]);
356	rcu_assign_pointer(head->ht[fw_hash(handle)], f);
 
 
357
358	*arg = f;
359	return 0;
360
361errout:
362	tcf_exts_destroy(&f->exts);
363	kfree(f);
364	return err;
365}
366
367static void fw_walk(struct tcf_proto *tp, struct tcf_walker *arg)
368{
369	struct fw_head *head = rtnl_dereference(tp->root);
370	int h;
371
372	if (head == NULL)
373		arg->stop = 1;
374
375	if (arg->stop)
376		return;
377
378	for (h = 0; h < HTSIZE; h++) {
379		struct fw_filter *f;
380
381		for (f = rtnl_dereference(head->ht[h]); f;
382		     f = rtnl_dereference(f->next)) {
383			if (arg->count < arg->skip) {
384				arg->count++;
385				continue;
386			}
387			if (arg->fn(tp, f, arg) < 0) {
388				arg->stop = 1;
389				return;
390			}
391			arg->count++;
392		}
393	}
394}
395
396static int fw_dump(struct net *net, struct tcf_proto *tp, void *fh,
397		   struct sk_buff *skb, struct tcmsg *t)
398{
399	struct fw_head *head = rtnl_dereference(tp->root);
400	struct fw_filter *f = fh;
 
401	struct nlattr *nest;
402
403	if (f == NULL)
404		return skb->len;
405
406	t->tcm_handle = f->id;
407
408	if (!f->res.classid && !tcf_exts_has_actions(&f->exts))
409		return skb->len;
410
411	nest = nla_nest_start(skb, TCA_OPTIONS);
412	if (nest == NULL)
413		goto nla_put_failure;
414
415	if (f->res.classid &&
416	    nla_put_u32(skb, TCA_FW_CLASSID, f->res.classid))
417		goto nla_put_failure;
418#ifdef CONFIG_NET_CLS_IND
419	if (f->ifindex) {
420		struct net_device *dev;
421		dev = __dev_get_by_index(net, f->ifindex);
422		if (dev && nla_put_string(skb, TCA_FW_INDEV, dev->name))
423			goto nla_put_failure;
424	}
425#endif /* CONFIG_NET_CLS_IND */
426	if (head->mask != 0xFFFFFFFF &&
427	    nla_put_u32(skb, TCA_FW_MASK, head->mask))
428		goto nla_put_failure;
429
430	if (tcf_exts_dump(skb, &f->exts) < 0)
431		goto nla_put_failure;
432
433	nla_nest_end(skb, nest);
434
435	if (tcf_exts_dump_stats(skb, &f->exts) < 0)
436		goto nla_put_failure;
437
438	return skb->len;
439
440nla_put_failure:
441	nla_nest_cancel(skb, nest);
442	return -1;
443}
444
445static void fw_bind_class(void *fh, u32 classid, unsigned long cl)
446{
447	struct fw_filter *f = fh;
448
449	if (f && f->res.classid == classid)
450		f->res.class = cl;
451}
452
453static struct tcf_proto_ops cls_fw_ops __read_mostly = {
454	.kind		=	"fw",
455	.classify	=	fw_classify,
456	.init		=	fw_init,
457	.destroy	=	fw_destroy,
458	.get		=	fw_get,
 
459	.change		=	fw_change,
460	.delete		=	fw_delete,
461	.walk		=	fw_walk,
462	.dump		=	fw_dump,
463	.bind_class	=	fw_bind_class,
464	.owner		=	THIS_MODULE,
465};
466
467static int __init init_fw(void)
468{
469	return register_tcf_proto_ops(&cls_fw_ops);
470}
471
472static void __exit exit_fw(void)
473{
474	unregister_tcf_proto_ops(&cls_fw_ops);
475}
476
477module_init(init_fw)
478module_exit(exit_fw)
479MODULE_LICENSE("GPL");
v3.1
  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 (PAGE_SIZE/sizeof(struct fw_filter *))
 33
 34struct fw_head {
 35	struct fw_filter *ht[HTSIZE];
 36	u32 mask;
 
 37};
 38
 39struct fw_filter {
 40	struct fw_filter	*next;
 41	u32			id;
 42	struct tcf_result	res;
 43#ifdef CONFIG_NET_CLS_IND
 44	char			indev[IFNAMSIZ];
 45#endif /* CONFIG_NET_CLS_IND */
 46	struct tcf_exts		exts;
 
 
 
 
 
 47};
 48
 49static const struct tcf_ext_map fw_ext_map = {
 50	.action = TCA_FW_ACT,
 51	.police = TCA_FW_POLICE
 52};
 53
 54static inline int fw_hash(u32 handle)
 55{
 56	if (HTSIZE == 4096)
 57		return ((handle >> 24) & 0xFFF) ^
 58		       ((handle >> 12) & 0xFFF) ^
 59		       (handle & 0xFFF);
 60	else if (HTSIZE == 2048)
 61		return ((handle >> 22) & 0x7FF) ^
 62		       ((handle >> 11) & 0x7FF) ^
 63		       (handle & 0x7FF);
 64	else if (HTSIZE == 1024)
 65		return ((handle >> 20) & 0x3FF) ^
 66		       ((handle >> 10) & 0x3FF) ^
 67		       (handle & 0x3FF);
 68	else if (HTSIZE == 512)
 69		return (handle >> 27) ^
 70		       ((handle >> 18) & 0x1FF) ^
 71		       ((handle >> 9) & 0x1FF) ^
 72		       (handle & 0x1FF);
 73	else if (HTSIZE == 256) {
 74		u8 *t = (u8 *) &handle;
 75		return t[0] ^ t[1] ^ t[2] ^ t[3];
 76	} else
 77		return handle & (HTSIZE - 1);
 78}
 79
 80static int fw_classify(struct sk_buff *skb, const struct tcf_proto *tp,
 81			  struct tcf_result *res)
 82{
 83	struct fw_head *head = (struct fw_head *)tp->root;
 84	struct fw_filter *f;
 85	int r;
 86	u32 id = skb->mark;
 87
 88	if (head != NULL) {
 89		id &= head->mask;
 90		for (f = head->ht[fw_hash(id)]; f; f = f->next) {
 
 
 91			if (f->id == id) {
 92				*res = f->res;
 93#ifdef CONFIG_NET_CLS_IND
 94				if (!tcf_match_indev(skb, f->indev))
 95					continue;
 96#endif /* CONFIG_NET_CLS_IND */
 97				r = tcf_exts_exec(skb, &f->exts, res);
 98				if (r < 0)
 99					continue;
100
101				return r;
102			}
103		}
104	} else {
105		/* old method */
 
 
106		if (id && (TC_H_MAJ(id) == 0 ||
107			   !(TC_H_MAJ(id ^ tp->q->handle)))) {
108			res->classid = id;
109			res->class = 0;
110			return 0;
111		}
112	}
113
114	return -1;
115}
116
117static unsigned long fw_get(struct tcf_proto *tp, u32 handle)
118{
119	struct fw_head *head = (struct fw_head *)tp->root;
120	struct fw_filter *f;
121
122	if (head == NULL)
123		return 0;
124
125	for (f = head->ht[fw_hash(handle)]; f; f = f->next) {
 
126		if (f->id == handle)
127			return (unsigned long)f;
128	}
 
 
 
 
 
 
 
 
129	return 0;
130}
131
132static void fw_put(struct tcf_proto *tp, unsigned long f)
133{
 
 
 
134}
135
136static int fw_init(struct tcf_proto *tp)
137{
138	return 0;
 
 
 
 
139}
140
141static void fw_delete_filter(struct tcf_proto *tp, struct fw_filter *f)
142{
143	tcf_unbind_filter(tp, &f->res);
144	tcf_exts_destroy(tp, &f->exts);
145	kfree(f);
 
146}
147
148static void fw_destroy(struct tcf_proto *tp)
149{
150	struct fw_head *head = tp->root;
151	struct fw_filter *f;
152	int h;
153
154	if (head == NULL)
155		return;
156
157	for (h = 0; h < HTSIZE; h++) {
158		while ((f = head->ht[h]) != NULL) {
159			head->ht[h] = f->next;
160			fw_delete_filter(tp, f);
 
 
 
 
 
161		}
162	}
163	kfree(head);
164}
165
166static int fw_delete(struct tcf_proto *tp, unsigned long arg)
 
167{
168	struct fw_head *head = (struct fw_head *)tp->root;
169	struct fw_filter *f = (struct fw_filter *)arg;
170	struct fw_filter **fp;
 
 
 
171
172	if (head == NULL || f == NULL)
173		goto out;
174
175	for (fp = &head->ht[fw_hash(f->id)]; *fp; fp = &(*fp)->next) {
176		if (*fp == f) {
177			tcf_tree_lock(tp);
178			*fp = f->next;
179			tcf_tree_unlock(tp);
180			fw_delete_filter(tp, f);
181			return 0;
 
 
 
 
 
 
 
 
 
 
 
 
182		}
183	}
 
184out:
185	return -EINVAL;
186}
187
188static const struct nla_policy fw_policy[TCA_FW_MAX + 1] = {
189	[TCA_FW_CLASSID]	= { .type = NLA_U32 },
190	[TCA_FW_INDEV]		= { .type = NLA_STRING, .len = IFNAMSIZ },
191	[TCA_FW_MASK]		= { .type = NLA_U32 },
192};
193
194static int
195fw_change_attrs(struct tcf_proto *tp, struct fw_filter *f,
196	struct nlattr **tb, struct nlattr **tca, unsigned long base)
 
197{
198	struct fw_head *head = (struct fw_head *)tp->root;
199	struct tcf_exts e;
200	u32 mask;
201	int err;
202
203	err = tcf_exts_validate(tp, tb, tca[TCA_RATE], &e, &fw_ext_map);
 
204	if (err < 0)
205		return err;
206
207	err = -EINVAL;
208	if (tb[TCA_FW_CLASSID]) {
209		f->res.classid = nla_get_u32(tb[TCA_FW_CLASSID]);
210		tcf_bind_filter(tp, &f->res, base);
211	}
212
213#ifdef CONFIG_NET_CLS_IND
214	if (tb[TCA_FW_INDEV]) {
215		err = tcf_change_indev(tp, f->indev, tb[TCA_FW_INDEV]);
216		if (err < 0)
217			goto errout;
 
 
218	}
219#endif /* CONFIG_NET_CLS_IND */
220
 
221	if (tb[TCA_FW_MASK]) {
222		mask = nla_get_u32(tb[TCA_FW_MASK]);
223		if (mask != head->mask)
224			goto errout;
225	} else if (head->mask != 0xFFFFFFFF)
226		goto errout;
227
228	tcf_exts_change(tp, &f->exts, &e);
229
230	return 0;
231errout:
232	tcf_exts_destroy(tp, &e);
233	return err;
234}
235
236static int fw_change(struct tcf_proto *tp, unsigned long base,
237		     u32 handle,
238		     struct nlattr **tca,
239		     unsigned long *arg)
240{
241	struct fw_head *head = (struct fw_head *)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 != NULL) {
 
 
 
255		if (f->id != handle && handle)
256			return -EINVAL;
257		return fw_change_attrs(tp, f, tb, tca, base);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
258	}
259
260	if (!handle)
261		return -EINVAL;
262
263	if (head == NULL) {
264		u32 mask = 0xFFFFFFFF;
265		if (tb[TCA_FW_MASK])
266			mask = nla_get_u32(tb[TCA_FW_MASK]);
267
268		head = kzalloc(sizeof(struct fw_head), GFP_KERNEL);
269		if (head == NULL)
270			return -ENOBUFS;
271		head->mask = mask;
272
273		tcf_tree_lock(tp);
274		tp->root = head;
275		tcf_tree_unlock(tp);
276	}
277
278	f = kzalloc(sizeof(struct fw_filter), GFP_KERNEL);
279	if (f == NULL)
280		return -ENOBUFS;
281
 
 
 
282	f->id = handle;
 
283
284	err = fw_change_attrs(tp, f, tb, tca, base);
285	if (err < 0)
286		goto errout;
287
288	f->next = head->ht[fw_hash(handle)];
289	tcf_tree_lock(tp);
290	head->ht[fw_hash(handle)] = f;
291	tcf_tree_unlock(tp);
292
293	*arg = (unsigned long)f;
294	return 0;
295
296errout:
 
297	kfree(f);
298	return err;
299}
300
301static void fw_walk(struct tcf_proto *tp, struct tcf_walker *arg)
302{
303	struct fw_head *head = (struct fw_head *)tp->root;
304	int h;
305
306	if (head == NULL)
307		arg->stop = 1;
308
309	if (arg->stop)
310		return;
311
312	for (h = 0; h < HTSIZE; h++) {
313		struct fw_filter *f;
314
315		for (f = head->ht[h]; f; f = f->next) {
 
316			if (arg->count < arg->skip) {
317				arg->count++;
318				continue;
319			}
320			if (arg->fn(tp, (unsigned long)f, arg) < 0) {
321				arg->stop = 1;
322				return;
323			}
324			arg->count++;
325		}
326	}
327}
328
329static int fw_dump(struct tcf_proto *tp, unsigned long fh,
330		   struct sk_buff *skb, struct tcmsg *t)
331{
332	struct fw_head *head = (struct fw_head *)tp->root;
333	struct fw_filter *f = (struct fw_filter *)fh;
334	unsigned char *b = skb_tail_pointer(skb);
335	struct nlattr *nest;
336
337	if (f == NULL)
338		return skb->len;
339
340	t->tcm_handle = f->id;
341
342	if (!f->res.classid && !tcf_exts_is_available(&f->exts))
343		return skb->len;
344
345	nest = nla_nest_start(skb, TCA_OPTIONS);
346	if (nest == NULL)
347		goto nla_put_failure;
348
349	if (f->res.classid)
350		NLA_PUT_U32(skb, TCA_FW_CLASSID, f->res.classid);
 
351#ifdef CONFIG_NET_CLS_IND
352	if (strlen(f->indev))
353		NLA_PUT_STRING(skb, TCA_FW_INDEV, f->indev);
 
 
 
 
354#endif /* CONFIG_NET_CLS_IND */
355	if (head->mask != 0xFFFFFFFF)
356		NLA_PUT_U32(skb, TCA_FW_MASK, head->mask);
 
357
358	if (tcf_exts_dump(skb, &f->exts, &fw_ext_map) < 0)
359		goto nla_put_failure;
360
361	nla_nest_end(skb, nest);
362
363	if (tcf_exts_dump_stats(skb, &f->exts, &fw_ext_map) < 0)
364		goto nla_put_failure;
365
366	return skb->len;
367
368nla_put_failure:
369	nlmsg_trim(skb, b);
370	return -1;
371}
372
 
 
 
 
 
 
 
 
373static struct tcf_proto_ops cls_fw_ops __read_mostly = {
374	.kind		=	"fw",
375	.classify	=	fw_classify,
376	.init		=	fw_init,
377	.destroy	=	fw_destroy,
378	.get		=	fw_get,
379	.put		=	fw_put,
380	.change		=	fw_change,
381	.delete		=	fw_delete,
382	.walk		=	fw_walk,
383	.dump		=	fw_dump,
 
384	.owner		=	THIS_MODULE,
385};
386
387static int __init init_fw(void)
388{
389	return register_tcf_proto_ops(&cls_fw_ops);
390}
391
392static void __exit exit_fw(void)
393{
394	unregister_tcf_proto_ops(&cls_fw_ops);
395}
396
397module_init(init_fw)
398module_exit(exit_fw)
399MODULE_LICENSE("GPL");