[mirror_ubuntu-bionic-kernel.git] / net / netfilter / nft_objref.c

/*
 * Copyright (c) 2012-2016 Pablo Neira Ayuso <pablo@netfilter.org>
 *
 * This program is free software; you can redistribute it and/or modify it
 * under the terms and conditions of the GNU General Public License,
 * version 2, as published by the Free Software Foundation.
 */

#include <linux/init.h>
#include <linux/module.h>
#include <linux/skbuff.h>
#include <linux/netlink.h>
#include <linux/netfilter.h>
#include <linux/netfilter/nf_tables.h>
#include <net/netfilter/nf_tables.h>

#define nft_objref_priv(expr)	*((struct nft_object **)nft_expr_priv(expr))

static void nft_objref_eval(const struct nft_expr *expr,
			    struct nft_regs *regs,
			    const struct nft_pktinfo *pkt)
{
	struct nft_object *obj = nft_objref_priv(expr);

	obj->ops->eval(obj, regs, pkt);
}

static int nft_objref_init(const struct nft_ctx *ctx,
			   const struct nft_expr *expr,
			   const struct nlattr * const tb[])
{
	struct nft_object *obj = nft_objref_priv(expr);
	u8 genmask = nft_genmask_next(ctx->net);
	u32 objtype;

	if (!tb[NFTA_OBJREF_IMM_NAME] ||
	    !tb[NFTA_OBJREF_IMM_TYPE])
		return -EINVAL;

	objtype = ntohl(nla_get_be32(tb[NFTA_OBJREF_IMM_TYPE]));
	obj = nf_tables_obj_lookup(ctx->table, tb[NFTA_OBJREF_IMM_NAME], objtype,
				   genmask);
	if (IS_ERR(obj))
		return -ENOENT;

	nft_objref_priv(expr) = obj;
	obj->use++;

	return 0;
}

static int nft_objref_dump(struct sk_buff *skb, const struct nft_expr *expr)
{
	const struct nft_object *obj = nft_objref_priv(expr);

	if (nla_put_string(skb, NFTA_OBJREF_IMM_NAME, obj->name) ||
	    nla_put_be32(skb, NFTA_OBJREF_IMM_TYPE,
			 htonl(obj->ops->type->type)))
		goto nla_put_failure;

	return 0;

nla_put_failure:
	return -1;
}

static void nft_objref_destroy(const struct nft_ctx *ctx,
			       const struct nft_expr *expr)
{
	struct nft_object *obj = nft_objref_priv(expr);

	obj->use--;
}

static struct nft_expr_type nft_objref_type;
static const struct nft_expr_ops nft_objref_ops = {
	.type		= &nft_objref_type,
	.size		= NFT_EXPR_SIZE(sizeof(struct nft_object *)),
	.eval		= nft_objref_eval,
	.init		= nft_objref_init,
	.destroy	= nft_objref_destroy,
	.dump		= nft_objref_dump,
};

struct nft_objref_map {
	struct nft_set		*set;
	enum nft_registers	sreg:8;
	struct nft_set_binding	binding;
};

static void nft_objref_map_eval(const struct nft_expr *expr,
				struct nft_regs *regs,
				const struct nft_pktinfo *pkt)
{
	struct nft_objref_map *priv = nft_expr_priv(expr);
	const struct nft_set *set = priv->set;
	const struct nft_set_ext *ext;
	struct nft_object *obj;
	bool found;

	found = set->ops->lookup(nft_net(pkt), set, &regs->data[priv->sreg],
				 &ext);
	if (!found) {
		regs->verdict.code = NFT_BREAK;
		return;
	}
	obj = *nft_set_ext_obj(ext);
	obj->ops->eval(obj, regs, pkt);
}

static int nft_objref_map_init(const struct nft_ctx *ctx,
			       const struct nft_expr *expr,
			       const struct nlattr * const tb[])
{
	struct nft_objref_map *priv = nft_expr_priv(expr);
	u8 genmask = nft_genmask_next(ctx->net);
	struct nft_set *set;
	int err;

	set = nft_set_lookup(ctx->net, ctx->table, tb[NFTA_OBJREF_SET_NAME],
			     tb[NFTA_OBJREF_SET_ID], genmask);
	if (IS_ERR(set))
		return PTR_ERR(set);

	if (!(set->flags & NFT_SET_OBJECT))
		return -EINVAL;

	priv->sreg = nft_parse_register(tb[NFTA_OBJREF_SET_SREG]);
	err = nft_validate_register_load(priv->sreg, set->klen);
	if (err < 0)
		return err;

	priv->binding.flags = set->flags & NFT_SET_OBJECT;

	err = nf_tables_bind_set(ctx, set, &priv->binding);
	if (err < 0)
		return err;

	priv->set = set;
	return 0;
}

static int nft_objref_map_dump(struct sk_buff *skb, const struct nft_expr *expr)
{
	const struct nft_objref_map *priv = nft_expr_priv(expr);

	if (nft_dump_register(skb, NFTA_OBJREF_SET_SREG, priv->sreg) ||
	    nla_put_string(skb, NFTA_OBJREF_SET_NAME, priv->set->name))
		goto nla_put_failure;

	return 0;

nla_put_failure:
	return -1;
}

static void nft_objref_map_destroy(const struct nft_ctx *ctx,
				   const struct nft_expr *expr)
{
	struct nft_objref_map *priv = nft_expr_priv(expr);

	nf_tables_unbind_set(ctx, priv->set, &priv->binding);
}

static struct nft_expr_type nft_objref_type;
static const struct nft_expr_ops nft_objref_map_ops = {
	.type		= &nft_objref_type,
	.size		= NFT_EXPR_SIZE(sizeof(struct nft_objref_map)),
	.eval		= nft_objref_map_eval,
	.init		= nft_objref_map_init,
	.destroy	= nft_objref_map_destroy,
	.dump		= nft_objref_map_dump,
};

static const struct nft_expr_ops *
nft_objref_select_ops(const struct nft_ctx *ctx,
                      const struct nlattr * const tb[])
{
	if (tb[NFTA_OBJREF_SET_SREG] &&
	    (tb[NFTA_OBJREF_SET_NAME] ||
	     tb[NFTA_OBJREF_SET_ID]))
		return &nft_objref_map_ops;
	else if (tb[NFTA_OBJREF_IMM_NAME] &&
		 tb[NFTA_OBJREF_IMM_TYPE])
		return &nft_objref_ops;

	return ERR_PTR(-EOPNOTSUPP);
}

static const struct nla_policy nft_objref_policy[NFTA_OBJREF_MAX + 1] = {
	[NFTA_OBJREF_IMM_NAME]	= { .type = NLA_STRING,
				    .len = NFT_OBJ_MAXNAMELEN - 1 },
	[NFTA_OBJREF_IMM_TYPE]	= { .type = NLA_U32 },
	[NFTA_OBJREF_SET_SREG]	= { .type = NLA_U32 },
	[NFTA_OBJREF_SET_NAME]	= { .type = NLA_STRING,
				    .len = NFT_SET_MAXNAMELEN - 1 },
	[NFTA_OBJREF_SET_ID]	= { .type = NLA_U32 },
};

static struct nft_expr_type nft_objref_type __read_mostly = {
	.name		= "objref",
	.select_ops	= nft_objref_select_ops,
	.policy		= nft_objref_policy,
	.maxattr	= NFTA_OBJREF_MAX,
	.owner		= THIS_MODULE,
};

static int __init nft_objref_module_init(void)
{
	return nft_register_expr(&nft_objref_type);
}

static void __exit nft_objref_module_exit(void)
{
	nft_unregister_expr(&nft_objref_type);
}

module_init(nft_objref_module_init);
module_exit(nft_objref_module_exit);

MODULE_LICENSE("GPL");
MODULE_AUTHOR("Pablo Neira Ayuso <pablo@netfilter.org>");
MODULE_ALIAS_NFT_EXPR("objref");
Commit	Line	Data
c97d22e6 PNA	1	/*
	2	* Copyright (c) 2012-2016 Pablo Neira Ayuso <pablo@netfilter.org>
	3	*
	4	* This program is free software; you can redistribute it and/or modify it
	5	* under the terms and conditions of the GNU General Public License,
	6	* version 2, as published by the Free Software Foundation.
	7	*/
	8
	9	#include <linux/init.h>
	10	#include <linux/module.h>
	11	#include <linux/skbuff.h>
	12	#include <linux/netlink.h>
	13	#include <linux/netfilter.h>
	14	#include <linux/netfilter/nf_tables.h>
	15	#include <net/netfilter/nf_tables.h>
	16
	17	#define nft_objref_priv(expr) ((struct nft_object *)nft_expr_priv(expr))
	18
	19	static void nft_objref_eval(const struct nft_expr *expr,
	20	struct nft_regs *regs,
	21	const struct nft_pktinfo *pkt)
	22	{
	23	struct nft_object *obj = nft_objref_priv(expr);
	24
dfc46034	25	obj->ops->eval(obj, regs, pkt);
c97d22e6 PNA	26	}
	27
	28	static int nft_objref_init(const struct nft_ctx *ctx,
	29	const struct nft_expr *expr,
	30	const struct nlattr * const tb[])
	31	{
	32	struct nft_object *obj = nft_objref_priv(expr);
	33	u8 genmask = nft_genmask_next(ctx->net);
	34	u32 objtype;
	35
	36	if (!tb[NFTA_OBJREF_IMM_NAME] \|\|
	37	!tb[NFTA_OBJREF_IMM_TYPE])
	38	return -EINVAL;
	39
	40	objtype = ntohl(nla_get_be32(tb[NFTA_OBJREF_IMM_TYPE]));
	41	obj = nf_tables_obj_lookup(ctx->table, tb[NFTA_OBJREF_IMM_NAME], objtype,
	42	genmask);
	43	if (IS_ERR(obj))
	44	return -ENOENT;
	45
	46	nft_objref_priv(expr) = obj;
	47	obj->use++;
	48
	49	return 0;
	50	}
	51
	52	static int nft_objref_dump(struct sk_buff skb, const struct nft_expr expr)
	53	{
	54	const struct nft_object *obj = nft_objref_priv(expr);
	55
	56	if (nla_put_string(skb, NFTA_OBJREF_IMM_NAME, obj->name) \|\|
dfc46034 PBG	57	nla_put_be32(skb, NFTA_OBJREF_IMM_TYPE,
dfc46034 PBG	58	htonl(obj->ops->type->type)))
c97d22e6 PNA	59	goto nla_put_failure;
	60
	61	return 0;
	62
	63	nla_put_failure:
	64	return -1;
	65	}
	66
	67	static void nft_objref_destroy(const struct nft_ctx *ctx,
	68	const struct nft_expr *expr)
	69	{
	70	struct nft_object *obj = nft_objref_priv(expr);
	71
	72	obj->use--;
	73	}
	74
	75	static struct nft_expr_type nft_objref_type;
	76	static const struct nft_expr_ops nft_objref_ops = {
	77	.type = &nft_objref_type,
	78	.size = NFT_EXPR_SIZE(sizeof(struct nft_object *)),
	79	.eval = nft_objref_eval,
	80	.init = nft_objref_init,
	81	.destroy = nft_objref_destroy,
	82	.dump = nft_objref_dump,
	83	};
	84
63aea290 PNA	85	struct nft_objref_map {
	86	struct nft_set *set;
	87	enum nft_registers sreg:8;
	88	struct nft_set_binding binding;
	89	};
	90
	91	static void nft_objref_map_eval(const struct nft_expr *expr,
	92	struct nft_regs *regs,
	93	const struct nft_pktinfo *pkt)
	94	{
	95	struct nft_objref_map *priv = nft_expr_priv(expr);
	96	const struct nft_set *set = priv->set;
	97	const struct nft_set_ext *ext;
	98	struct nft_object *obj;
	99	bool found;
	100
	101	found = set->ops->lookup(nft_net(pkt), set, &regs->data[priv->sreg],
	102	&ext);
	103	if (!found) {
	104	regs->verdict.code = NFT_BREAK;
	105	return;
	106	}
	107	obj = *nft_set_ext_obj(ext);
dfc46034	108	obj->ops->eval(obj, regs, pkt);
63aea290 PNA	109	}
	110
	111	static int nft_objref_map_init(const struct nft_ctx *ctx,
	112	const struct nft_expr *expr,
	113	const struct nlattr * const tb[])
	114	{
	115	struct nft_objref_map *priv = nft_expr_priv(expr);
	116	u8 genmask = nft_genmask_next(ctx->net);
	117	struct nft_set *set;
	118	int err;
	119
c7a72e3f PNA	120	set = nft_set_lookup(ctx->net, ctx->table, tb[NFTA_OBJREF_SET_NAME],
	121	tb[NFTA_OBJREF_SET_ID], genmask);
	122	if (IS_ERR(set))
	123	return PTR_ERR(set);
63aea290 PNA	124
	125	if (!(set->flags & NFT_SET_OBJECT))
	126	return -EINVAL;
	127
	128	priv->sreg = nft_parse_register(tb[NFTA_OBJREF_SET_SREG]);
	129	err = nft_validate_register_load(priv->sreg, set->klen);
	130	if (err < 0)
	131	return err;
	132
	133	priv->binding.flags = set->flags & NFT_SET_OBJECT;
	134
	135	err = nf_tables_bind_set(ctx, set, &priv->binding);
	136	if (err < 0)
	137	return err;
	138
	139	priv->set = set;
	140	return 0;
	141	}
	142
	143	static int nft_objref_map_dump(struct sk_buff skb, const struct nft_expr expr)
	144	{
	145	const struct nft_objref_map *priv = nft_expr_priv(expr);
	146
	147	if (nft_dump_register(skb, NFTA_OBJREF_SET_SREG, priv->sreg) \|\|
	148	nla_put_string(skb, NFTA_OBJREF_SET_NAME, priv->set->name))
	149	goto nla_put_failure;
	150
	151	return 0;
	152
	153	nla_put_failure:
	154	return -1;
	155	}
	156
	157	static void nft_objref_map_destroy(const struct nft_ctx *ctx,
	158	const struct nft_expr *expr)
	159	{
	160	struct nft_objref_map *priv = nft_expr_priv(expr);
	161
	162	nf_tables_unbind_set(ctx, priv->set, &priv->binding);
	163	}
	164
	165	static struct nft_expr_type nft_objref_type;
	166	static const struct nft_expr_ops nft_objref_map_ops = {
	167	.type = &nft_objref_type,
	168	.size = NFT_EXPR_SIZE(sizeof(struct nft_objref_map)),
	169	.eval = nft_objref_map_eval,
	170	.init = nft_objref_map_init,
	171	.destroy = nft_objref_map_destroy,
	172	.dump = nft_objref_map_dump,
	173	};
	174
	175	static const struct nft_expr_ops *
	176	nft_objref_select_ops(const struct nft_ctx *ctx,
	177	const struct nlattr * const tb[])
	178	{
	179	if (tb[NFTA_OBJREF_SET_SREG] &&
	180	(tb[NFTA_OBJREF_SET_NAME] \|\|
	181	tb[NFTA_OBJREF_SET_ID]))
	182	return &nft_objref_map_ops;
	183	else if (tb[NFTA_OBJREF_IMM_NAME] &&
	184	tb[NFTA_OBJREF_IMM_TYPE])
	185	return &nft_objref_ops;
	186
	187	return ERR_PTR(-EOPNOTSUPP);
188	}
189
c97d22e6	190	static const struct nla_policy nft_objref_policy[NFTA_OBJREF_MAX + 1] = {
b2fbd044 LZ	191	[NFTA_OBJREF_IMM_NAME] = { .type = NLA_STRING,
b2fbd044 LZ	192	.len = NFT_OBJ_MAXNAMELEN - 1 },
c97d22e6	193	[NFTA_OBJREF_IMM_TYPE] = { .type = NLA_U32 },
63aea290	194	[NFTA_OBJREF_SET_SREG] = { .type = NLA_U32 },
b2fbd044 LZ	195	[NFTA_OBJREF_SET_NAME] = { .type = NLA_STRING,
b2fbd044 LZ	196	.len = NFT_SET_MAXNAMELEN - 1 },
63aea290	197	[NFTA_OBJREF_SET_ID] = { .type = NLA_U32 },
c97d22e6 PNA	198	};
	199
	200	static struct nft_expr_type nft_objref_type __read_mostly = {
	201	.name = "objref",
63aea290	202	.select_ops = nft_objref_select_ops,
c97d22e6 PNA	203	.policy = nft_objref_policy,
	204	.maxattr = NFTA_OBJREF_MAX,
	205	.owner = THIS_MODULE,
	206	};
	207
	208	static int __init nft_objref_module_init(void)
	209	{
	210	return nft_register_expr(&nft_objref_type);
	211	}
	212
	213	static void __exit nft_objref_module_exit(void)
	214	{
	215	nft_unregister_expr(&nft_objref_type);
	216	}
	217
	218	module_init(nft_objref_module_init);
	219	module_exit(nft_objref_module_exit);
	220
	221	MODULE_LICENSE("GPL");
	222	MODULE_AUTHOR("Pablo Neira Ayuso <pablo@netfilter.org>");
	223	MODULE_ALIAS_NFT_EXPR("objref");