[linux-2.6-block.git] / net / sched / cls_bpf.c

/*
 * Berkeley Packet Filter based traffic classifier
 *
 * Might be used to classify traffic through flexible, user-defined and
 * possibly JIT-ed BPF filters for traffic control as an alternative to
 * ematches.
 *
 * (C) 2013 Daniel Borkmann <dborkman@redhat.com>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 as
 * published by the Free Software Foundation.
 */

#include <linux/module.h>
#include <linux/types.h>
#include <linux/skbuff.h>
#include <linux/filter.h>
#include <net/rtnetlink.h>
#include <net/pkt_cls.h>
#include <net/sock.h>

MODULE_LICENSE("GPL");
MODULE_AUTHOR("Daniel Borkmann <dborkman@redhat.com>");
MODULE_DESCRIPTION("TC BPF based classifier");

struct cls_bpf_head {
	struct list_head plist;
	u32 hgen;
	struct rcu_head rcu;
};

struct cls_bpf_prog {
	struct bpf_prog *filter;
	struct sock_filter *bpf_ops;
	struct tcf_exts exts;
	struct tcf_result res;
	struct list_head link;
	u32 handle;
	u16 bpf_len;
	struct tcf_proto *tp;
	struct rcu_head rcu;
};

static const struct nla_policy bpf_policy[TCA_BPF_MAX + 1] = {
	[TCA_BPF_CLASSID]	= { .type = NLA_U32 },
	[TCA_BPF_OPS_LEN]	= { .type = NLA_U16 },
	[TCA_BPF_OPS]		= { .type = NLA_BINARY,
				    .len = sizeof(struct sock_filter) * BPF_MAXINSNS },
};

static int cls_bpf_classify(struct sk_buff *skb, const struct tcf_proto *tp,
			    struct tcf_result *res)
{
	struct cls_bpf_head *head = rcu_dereference_bh(tp->root);
	struct cls_bpf_prog *prog;
	int ret;

	list_for_each_entry_rcu(prog, &head->plist, link) {
		int filter_res = BPF_PROG_RUN(prog->filter, skb);

		if (filter_res == 0)
			continue;

		*res = prog->res;
		if (filter_res != -1)
			res->classid = filter_res;

		ret = tcf_exts_exec(skb, &prog->exts, res);
		if (ret < 0)
			continue;

		return ret;
	}

	return -1;
}

static int cls_bpf_init(struct tcf_proto *tp)
{
	struct cls_bpf_head *head;

	head = kzalloc(sizeof(*head), GFP_KERNEL);
	if (head == NULL)
		return -ENOBUFS;

	INIT_LIST_HEAD_RCU(&head->plist);
	rcu_assign_pointer(tp->root, head);

	return 0;
}

static void cls_bpf_delete_prog(struct tcf_proto *tp, struct cls_bpf_prog *prog)
{
	tcf_exts_destroy(&prog->exts);

	bpf_prog_destroy(prog->filter);

	kfree(prog->bpf_ops);
	kfree(prog);
}

static void __cls_bpf_delete_prog(struct rcu_head *rcu)
{
	struct cls_bpf_prog *prog = container_of(rcu, struct cls_bpf_prog, rcu);

	cls_bpf_delete_prog(prog->tp, prog);
}

static int cls_bpf_delete(struct tcf_proto *tp, unsigned long arg)
{
	struct cls_bpf_prog *prog = (struct cls_bpf_prog *) arg;

	list_del_rcu(&prog->link);
	tcf_unbind_filter(tp, &prog->res);
	call_rcu(&prog->rcu, __cls_bpf_delete_prog);
	return 0;
}

static void cls_bpf_destroy(struct tcf_proto *tp)
{
	struct cls_bpf_head *head = rtnl_dereference(tp->root);
	struct cls_bpf_prog *prog, *tmp;

	list_for_each_entry_safe(prog, tmp, &head->plist, link) {
		list_del_rcu(&prog->link);
		tcf_unbind_filter(tp, &prog->res);
		call_rcu(&prog->rcu, __cls_bpf_delete_prog);
	}

	RCU_INIT_POINTER(tp->root, NULL);
	kfree_rcu(head, rcu);
}

static unsigned long cls_bpf_get(struct tcf_proto *tp, u32 handle)
{
	struct cls_bpf_head *head = rtnl_dereference(tp->root);
	struct cls_bpf_prog *prog;
	unsigned long ret = 0UL;

	if (head == NULL)
		return 0UL;

	list_for_each_entry(prog, &head->plist, link) {
		if (prog->handle == handle) {
			ret = (unsigned long) prog;
			break;
		}
	}

	return ret;
}

static int cls_bpf_modify_existing(struct net *net, struct tcf_proto *tp,
				   struct cls_bpf_prog *prog,
				   unsigned long base, struct nlattr **tb,
				   struct nlattr *est, bool ovr)
{
	struct sock_filter *bpf_ops;
	struct tcf_exts exts;
	struct sock_fprog_kern tmp;
	struct bpf_prog *fp;
	u16 bpf_size, bpf_len;
	u32 classid;
	int ret;

	if (!tb[TCA_BPF_OPS_LEN] || !tb[TCA_BPF_OPS] || !tb[TCA_BPF_CLASSID])
		return -EINVAL;

	tcf_exts_init(&exts, TCA_BPF_ACT, TCA_BPF_POLICE);
	ret = tcf_exts_validate(net, tp, tb, est, &exts, ovr);
	if (ret < 0)
		return ret;

	classid = nla_get_u32(tb[TCA_BPF_CLASSID]);
	bpf_len = nla_get_u16(tb[TCA_BPF_OPS_LEN]);
	if (bpf_len > BPF_MAXINSNS || bpf_len == 0) {
		ret = -EINVAL;
		goto errout;
	}

	bpf_size = bpf_len * sizeof(*bpf_ops);
	bpf_ops = kzalloc(bpf_size, GFP_KERNEL);
	if (bpf_ops == NULL) {
		ret = -ENOMEM;
		goto errout;
	}

	memcpy(bpf_ops, nla_data(tb[TCA_BPF_OPS]), bpf_size);

	tmp.len = bpf_len;
	tmp.filter = bpf_ops;

	ret = bpf_prog_create(&fp, &tmp);
	if (ret)
		goto errout_free;

	prog->bpf_len = bpf_len;
	prog->bpf_ops = bpf_ops;
	prog->filter = fp;
	prog->res.classid = classid;

	tcf_bind_filter(tp, &prog->res, base);
	tcf_exts_change(tp, &prog->exts, &exts);

	return 0;
errout_free:
	kfree(bpf_ops);
errout:
	tcf_exts_destroy(&exts);
	return ret;
}

static u32 cls_bpf_grab_new_handle(struct tcf_proto *tp,
				   struct cls_bpf_head *head)
{
	unsigned int i = 0x80000000;

	do {
		if (++head->hgen == 0x7FFFFFFF)
			head->hgen = 1;
	} while (--i > 0 && cls_bpf_get(tp, head->hgen));
	if (i == 0)
		pr_err("Insufficient number of handles\n");

	return i;
}

static int cls_bpf_change(struct net *net, struct sk_buff *in_skb,
			  struct tcf_proto *tp, unsigned long base,
			  u32 handle, struct nlattr **tca,
			  unsigned long *arg, bool ovr)
{
	struct cls_bpf_head *head = rtnl_dereference(tp->root);
	struct cls_bpf_prog *oldprog = (struct cls_bpf_prog *) *arg;
	struct nlattr *tb[TCA_BPF_MAX + 1];
	struct cls_bpf_prog *prog;
	int ret;

	if (tca[TCA_OPTIONS] == NULL)
		return -EINVAL;

	ret = nla_parse_nested(tb, TCA_BPF_MAX, tca[TCA_OPTIONS], bpf_policy);
	if (ret < 0)
		return ret;

	prog = kzalloc(sizeof(*prog), GFP_KERNEL);
	if (!prog)
		return -ENOBUFS;

	tcf_exts_init(&prog->exts, TCA_BPF_ACT, TCA_BPF_POLICE);

	if (oldprog) {
		if (handle && oldprog->handle != handle) {
			ret = -EINVAL;
			goto errout;
		}
	}

	if (handle == 0)
		prog->handle = cls_bpf_grab_new_handle(tp, head);
	else
		prog->handle = handle;
	if (prog->handle == 0) {
		ret = -EINVAL;
		goto errout;
	}

	ret = cls_bpf_modify_existing(net, tp, prog, base, tb, tca[TCA_RATE], ovr);
	if (ret < 0)
		goto errout;

	if (oldprog) {
		list_replace_rcu(&prog->link, &oldprog->link);
		tcf_unbind_filter(tp, &oldprog->res);
		call_rcu(&oldprog->rcu, __cls_bpf_delete_prog);
	} else {
		list_add_rcu(&prog->link, &head->plist);
	}

	*arg = (unsigned long) prog;
	return 0;
errout:
	kfree(prog);

	return ret;
}

static int cls_bpf_dump(struct net *net, struct tcf_proto *tp, unsigned long fh,
			struct sk_buff *skb, struct tcmsg *tm)
{
	struct cls_bpf_prog *prog = (struct cls_bpf_prog *) fh;
	struct nlattr *nest, *nla;

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

	tm->tcm_handle = prog->handle;

	nest = nla_nest_start(skb, TCA_OPTIONS);
	if (nest == NULL)
		goto nla_put_failure;

	if (nla_put_u32(skb, TCA_BPF_CLASSID, prog->res.classid))
		goto nla_put_failure;
	if (nla_put_u16(skb, TCA_BPF_OPS_LEN, prog->bpf_len))
		goto nla_put_failure;

	nla = nla_reserve(skb, TCA_BPF_OPS, prog->bpf_len *
			  sizeof(struct sock_filter));
	if (nla == NULL)
		goto nla_put_failure;

	memcpy(nla_data(nla), prog->bpf_ops, nla_len(nla));

	if (tcf_exts_dump(skb, &prog->exts) < 0)
		goto nla_put_failure;

	nla_nest_end(skb, nest);

	if (tcf_exts_dump_stats(skb, &prog->exts) < 0)
		goto nla_put_failure;

	return skb->len;

nla_put_failure:
	nla_nest_cancel(skb, nest);
	return -1;
}

static void cls_bpf_walk(struct tcf_proto *tp, struct tcf_walker *arg)
{
	struct cls_bpf_head *head = rtnl_dereference(tp->root);
	struct cls_bpf_prog *prog;

	list_for_each_entry(prog, &head->plist, link) {
		if (arg->count < arg->skip)
			goto skip;
		if (arg->fn(tp, (unsigned long) prog, arg) < 0) {
			arg->stop = 1;
			break;
		}
skip:
		arg->count++;
	}
}

static struct tcf_proto_ops cls_bpf_ops __read_mostly = {
	.kind		=	"bpf",
	.owner		=	THIS_MODULE,
	.classify	=	cls_bpf_classify,
	.init		=	cls_bpf_init,
	.destroy	=	cls_bpf_destroy,
	.get		=	cls_bpf_get,
	.change		=	cls_bpf_change,
	.delete		=	cls_bpf_delete,
	.walk		=	cls_bpf_walk,
	.dump		=	cls_bpf_dump,
};

static int __init cls_bpf_init_mod(void)
{
	return register_tcf_proto_ops(&cls_bpf_ops);
}

static void __exit cls_bpf_exit_mod(void)
{
	unregister_tcf_proto_ops(&cls_bpf_ops);
}

module_init(cls_bpf_init_mod);
module_exit(cls_bpf_exit_mod);
Commit	Line	Data
7d1d65cb DB	1	/*
	2	* Berkeley Packet Filter based traffic classifier
	3	*
	4	* Might be used to classify traffic through flexible, user-defined and
	5	* possibly JIT-ed BPF filters for traffic control as an alternative to
	6	* ematches.
	7	*
	8	* (C) 2013 Daniel Borkmann <dborkman@redhat.com>
	9	*
	10	* This program is free software; you can redistribute it and/or modify
	11	* it under the terms of the GNU General Public License version 2 as
	12	* published by the Free Software Foundation.
	13	*/
	14
	15	#include <linux/module.h>
	16	#include <linux/types.h>
	17	#include <linux/skbuff.h>
	18	#include <linux/filter.h>
	19	#include <net/rtnetlink.h>
	20	#include <net/pkt_cls.h>
	21	#include <net/sock.h>
	22
	23	MODULE_LICENSE("GPL");
	24	MODULE_AUTHOR("Daniel Borkmann <dborkman@redhat.com>");
	25	MODULE_DESCRIPTION("TC BPF based classifier");
	26
	27	struct cls_bpf_head {
	28	struct list_head plist;
	29	u32 hgen;
1f947bf1	30	struct rcu_head rcu;
7d1d65cb DB	31	};
	32
	33	struct cls_bpf_prog {
7ae457c1	34	struct bpf_prog *filter;
7d1d65cb DB	35	struct sock_filter *bpf_ops;
	36	struct tcf_exts exts;
	37	struct tcf_result res;
	38	struct list_head link;
	39	u32 handle;
	40	u16 bpf_len;
1f947bf1 JF	41	struct tcf_proto *tp;
1f947bf1 JF	42	struct rcu_head rcu;
7d1d65cb DB	43	};
	44
	45	static const struct nla_policy bpf_policy[TCA_BPF_MAX + 1] = {
	46	[TCA_BPF_CLASSID] = { .type = NLA_U32 },
	47	[TCA_BPF_OPS_LEN] = { .type = NLA_U16 },
	48	[TCA_BPF_OPS] = { .type = NLA_BINARY,
	49	.len = sizeof(struct sock_filter) * BPF_MAXINSNS },
	50	};
	51
7d1d65cb DB	52	static int cls_bpf_classify(struct sk_buff skb, const struct tcf_proto tp,
	53	struct tcf_result *res)
	54	{
80dcbd12	55	struct cls_bpf_head *head = rcu_dereference_bh(tp->root);
7d1d65cb DB	56	struct cls_bpf_prog *prog;
	57	int ret;
	58
1f947bf1	59	list_for_each_entry_rcu(prog, &head->plist, link) {
7ae457c1	60	int filter_res = BPF_PROG_RUN(prog->filter, skb);
7d1d65cb DB	61
	62	if (filter_res == 0)
	63	continue;
	64
	65	*res = prog->res;
	66	if (filter_res != -1)
	67	res->classid = filter_res;
	68
	69	ret = tcf_exts_exec(skb, &prog->exts, res);
	70	if (ret < 0)
	71	continue;
	72
	73	return ret;
	74	}
	75
	76	return -1;
	77	}
	78
	79	static int cls_bpf_init(struct tcf_proto *tp)
	80	{
	81	struct cls_bpf_head *head;
	82
	83	head = kzalloc(sizeof(*head), GFP_KERNEL);
	84	if (head == NULL)
	85	return -ENOBUFS;
	86
1f947bf1 JF	87	INIT_LIST_HEAD_RCU(&head->plist);
1f947bf1 JF	88	rcu_assign_pointer(tp->root, head);
7d1d65cb DB	89
	90	return 0;
	91	}
	92
	93	static void cls_bpf_delete_prog(struct tcf_proto tp, struct cls_bpf_prog prog)
	94	{
18d0264f	95	tcf_exts_destroy(&prog->exts);
7d1d65cb	96
7ae457c1	97	bpf_prog_destroy(prog->filter);
7d1d65cb DB	98
	99	kfree(prog->bpf_ops);
	100	kfree(prog);
	101	}
	102
1f947bf1 JF	103	static void __cls_bpf_delete_prog(struct rcu_head *rcu)
	104	{
	105	struct cls_bpf_prog *prog = container_of(rcu, struct cls_bpf_prog, rcu);
	106
	107	cls_bpf_delete_prog(prog->tp, prog);
	108	}
	109
7d1d65cb DB	110	static int cls_bpf_delete(struct tcf_proto *tp, unsigned long arg)
7d1d65cb DB	111	{
472f5837	112	struct cls_bpf_prog prog = (struct cls_bpf_prog ) arg;
7d1d65cb	113
472f5837 JP	114	list_del_rcu(&prog->link);
	115	tcf_unbind_filter(tp, &prog->res);
	116	call_rcu(&prog->rcu, __cls_bpf_delete_prog);
	117	return 0;
7d1d65cb DB	118	}
	119
	120	static void cls_bpf_destroy(struct tcf_proto *tp)
	121	{
1f947bf1	122	struct cls_bpf_head *head = rtnl_dereference(tp->root);
7d1d65cb DB	123	struct cls_bpf_prog prog, tmp;
	124
	125	list_for_each_entry_safe(prog, tmp, &head->plist, link) {
1f947bf1	126	list_del_rcu(&prog->link);
18cdb37e	127	tcf_unbind_filter(tp, &prog->res);
1f947bf1	128	call_rcu(&prog->rcu, __cls_bpf_delete_prog);
7d1d65cb DB	129	}
7d1d65cb DB	130
1f947bf1 JF	131	RCU_INIT_POINTER(tp->root, NULL);
1f947bf1 JF	132	kfree_rcu(head, rcu);
7d1d65cb DB	133	}
	134
	135	static unsigned long cls_bpf_get(struct tcf_proto *tp, u32 handle)
	136	{
1f947bf1	137	struct cls_bpf_head *head = rtnl_dereference(tp->root);
7d1d65cb DB	138	struct cls_bpf_prog *prog;
	139	unsigned long ret = 0UL;
	140
	141	if (head == NULL)
	142	return 0UL;
	143
3fe6b49e	144	list_for_each_entry(prog, &head->plist, link) {
7d1d65cb DB	145	if (prog->handle == handle) {
	146	ret = (unsigned long) prog;
	147	break;
	148	}
	149	}
	150
	151	return ret;
	152	}
	153
7d1d65cb DB	154	static int cls_bpf_modify_existing(struct net net, struct tcf_proto tp,
	155	struct cls_bpf_prog *prog,
	156	unsigned long base, struct nlattr **tb,
2f7ef2f8	157	struct nlattr *est, bool ovr)
7d1d65cb	158	{
1f947bf1	159	struct sock_filter *bpf_ops;
7d1d65cb	160	struct tcf_exts exts;
b1fcd35c	161	struct sock_fprog_kern tmp;
1f947bf1	162	struct bpf_prog *fp;
7d1d65cb DB	163	u16 bpf_size, bpf_len;
	164	u32 classid;
	165	int ret;
	166
	167	if (!tb[TCA_BPF_OPS_LEN] \|\| !tb[TCA_BPF_OPS] \|\| !tb[TCA_BPF_CLASSID])
	168	return -EINVAL;
	169
5da57f42	170	tcf_exts_init(&exts, TCA_BPF_ACT, TCA_BPF_POLICE);
2f7ef2f8	171	ret = tcf_exts_validate(net, tp, tb, est, &exts, ovr);
7d1d65cb DB	172	if (ret < 0)
	173	return ret;
	174
	175	classid = nla_get_u32(tb[TCA_BPF_CLASSID]);
	176	bpf_len = nla_get_u16(tb[TCA_BPF_OPS_LEN]);
	177	if (bpf_len > BPF_MAXINSNS \|\| bpf_len == 0) {
	178	ret = -EINVAL;
	179	goto errout;
	180	}
	181
	182	bpf_size = bpf_len * sizeof(*bpf_ops);
	183	bpf_ops = kzalloc(bpf_size, GFP_KERNEL);
	184	if (bpf_ops == NULL) {
	185	ret = -ENOMEM;
	186	goto errout;
	187	}
	188
	189	memcpy(bpf_ops, nla_data(tb[TCA_BPF_OPS]), bpf_size);
	190
	191	tmp.len = bpf_len;
b1fcd35c	192	tmp.filter = bpf_ops;
7d1d65cb	193
7ae457c1	194	ret = bpf_prog_create(&fp, &tmp);
7d1d65cb DB	195	if (ret)
	196	goto errout_free;
	197
7d1d65cb DB	198	prog->bpf_len = bpf_len;
	199	prog->bpf_ops = bpf_ops;
	200	prog->filter = fp;
	201	prog->res.classid = classid;
7d1d65cb DB	202
	203	tcf_bind_filter(tp, &prog->res, base);
	204	tcf_exts_change(tp, &prog->exts, &exts);
	205
7d1d65cb	206	return 0;
7d1d65cb DB	207	errout_free:
	208	kfree(bpf_ops);
	209	errout:
18d0264f	210	tcf_exts_destroy(&exts);
7d1d65cb DB	211	return ret;
	212	}
	213
	214	static u32 cls_bpf_grab_new_handle(struct tcf_proto *tp,
	215	struct cls_bpf_head *head)
	216	{
	217	unsigned int i = 0x80000000;
	218
	219	do {
	220	if (++head->hgen == 0x7FFFFFFF)
	221	head->hgen = 1;
	222	} while (--i > 0 && cls_bpf_get(tp, head->hgen));
	223	if (i == 0)
	224	pr_err("Insufficient number of handles\n");
	225
	226	return i;
	227	}
	228
	229	static int cls_bpf_change(struct net net, struct sk_buff in_skb,
	230	struct tcf_proto *tp, unsigned long base,
	231	u32 handle, struct nlattr **tca,
2f7ef2f8	232	unsigned long *arg, bool ovr)
7d1d65cb	233	{
1f947bf1 JF	234	struct cls_bpf_head *head = rtnl_dereference(tp->root);
1f947bf1 JF	235	struct cls_bpf_prog oldprog = (struct cls_bpf_prog ) *arg;
7d1d65cb	236	struct nlattr *tb[TCA_BPF_MAX + 1];
1f947bf1	237	struct cls_bpf_prog *prog;
7d1d65cb DB	238	int ret;
	239
	240	if (tca[TCA_OPTIONS] == NULL)
	241	return -EINVAL;
	242
	243	ret = nla_parse_nested(tb, TCA_BPF_MAX, tca[TCA_OPTIONS], bpf_policy);
	244	if (ret < 0)
	245	return ret;
	246
7d1d65cb	247	prog = kzalloc(sizeof(*prog), GFP_KERNEL);
1f947bf1	248	if (!prog)
7d1d65cb DB	249	return -ENOBUFS;
7d1d65cb DB	250
5da57f42	251	tcf_exts_init(&prog->exts, TCA_BPF_ACT, TCA_BPF_POLICE);
1f947bf1 JF	252
	253	if (oldprog) {
	254	if (handle && oldprog->handle != handle) {
	255	ret = -EINVAL;
	256	goto errout;
	257	}
	258	}
	259
7d1d65cb DB	260	if (handle == 0)
	261	prog->handle = cls_bpf_grab_new_handle(tp, head);
	262	else
	263	prog->handle = handle;
	264	if (prog->handle == 0) {
	265	ret = -EINVAL;
	266	goto errout;
	267	}
	268
2f7ef2f8	269	ret = cls_bpf_modify_existing(net, tp, prog, base, tb, tca[TCA_RATE], ovr);
7d1d65cb DB	270	if (ret < 0)
	271	goto errout;
	272
1f947bf1 JF	273	if (oldprog) {
1f947bf1 JF	274	list_replace_rcu(&prog->link, &oldprog->link);
18cdb37e	275	tcf_unbind_filter(tp, &oldprog->res);
1f947bf1 JF	276	call_rcu(&oldprog->rcu, __cls_bpf_delete_prog);
	277	} else {
	278	list_add_rcu(&prog->link, &head->plist);
	279	}
7d1d65cb DB	280
7d1d65cb DB	281	*arg = (unsigned long) prog;
7d1d65cb DB	282	return 0;
7d1d65cb DB	283	errout:
1f947bf1	284	kfree(prog);
7d1d65cb DB	285
	286	return ret;
	287	}
	288
832d1d5b	289	static int cls_bpf_dump(struct net net, struct tcf_proto tp, unsigned long fh,
7d1d65cb DB	290	struct sk_buff skb, struct tcmsg tm)
	291	{
	292	struct cls_bpf_prog prog = (struct cls_bpf_prog ) fh;
	293	struct nlattr nest, nla;
	294
	295	if (prog == NULL)
	296	return skb->len;
	297
	298	tm->tcm_handle = prog->handle;
	299
	300	nest = nla_nest_start(skb, TCA_OPTIONS);
	301	if (nest == NULL)
	302	goto nla_put_failure;
	303
	304	if (nla_put_u32(skb, TCA_BPF_CLASSID, prog->res.classid))
	305	goto nla_put_failure;
	306	if (nla_put_u16(skb, TCA_BPF_OPS_LEN, prog->bpf_len))
	307	goto nla_put_failure;
	308
	309	nla = nla_reserve(skb, TCA_BPF_OPS, prog->bpf_len *
	310	sizeof(struct sock_filter));
	311	if (nla == NULL)
	312	goto nla_put_failure;
	313
1fab9abc	314	memcpy(nla_data(nla), prog->bpf_ops, nla_len(nla));
7d1d65cb	315
5da57f42	316	if (tcf_exts_dump(skb, &prog->exts) < 0)
7d1d65cb DB	317	goto nla_put_failure;
	318
	319	nla_nest_end(skb, nest);
	320
5da57f42	321	if (tcf_exts_dump_stats(skb, &prog->exts) < 0)
7d1d65cb DB	322	goto nla_put_failure;
	323
	324	return skb->len;
	325
	326	nla_put_failure:
	327	nla_nest_cancel(skb, nest);
	328	return -1;
	329	}
	330
	331	static void cls_bpf_walk(struct tcf_proto tp, struct tcf_walker arg)
	332	{
1f947bf1	333	struct cls_bpf_head *head = rtnl_dereference(tp->root);
7d1d65cb DB	334	struct cls_bpf_prog *prog;
7d1d65cb DB	335
3fe6b49e	336	list_for_each_entry(prog, &head->plist, link) {
7d1d65cb DB	337	if (arg->count < arg->skip)
	338	goto skip;
	339	if (arg->fn(tp, (unsigned long) prog, arg) < 0) {
	340	arg->stop = 1;
	341	break;
	342	}
	343	skip:
	344	arg->count++;
	345	}
	346	}
	347
	348	static struct tcf_proto_ops cls_bpf_ops __read_mostly = {
	349	.kind = "bpf",
	350	.owner = THIS_MODULE,
	351	.classify = cls_bpf_classify,
	352	.init = cls_bpf_init,
	353	.destroy = cls_bpf_destroy,
	354	.get = cls_bpf_get,
7d1d65cb DB	355	.change = cls_bpf_change,
	356	.delete = cls_bpf_delete,
	357	.walk = cls_bpf_walk,
	358	.dump = cls_bpf_dump,
	359	};
	360
	361	static int __init cls_bpf_init_mod(void)
	362	{
	363	return register_tcf_proto_ops(&cls_bpf_ops);
	364	}
	365
	366	static void __exit cls_bpf_exit_mod(void)
	367	{
	368	unregister_tcf_proto_ops(&cls_bpf_ops);
	369	}
	370
	371	module_init(cls_bpf_init_mod);
	372	module_exit(cls_bpf_exit_mod);