Commit f6ca5d5e authored by Jeremy Sowden's avatar Jeremy Sowden Committed by Florian Westphal

netfilter: nft_masq: deduplicate eval call-backs

nft_masq has separate ipv4 and ipv6 call-backs which share much of their
code, and an inet one switch containing a switch that calls one of the
others based on the family of the packet.  Merge the ipv4 and ipv6 ones
into the inet one in order to get rid of the duplicate code.

Const-qualify the `priv` pointer since we don't need to write through it.
Signed-off-by: default avatarJeremy Sowden <jeremy@azazel.net>
Signed-off-by: default avatarFlorian Westphal <fw@strlen.de>
parent 6f56ad1b
...@@ -96,23 +96,39 @@ static int nft_masq_dump(struct sk_buff *skb, ...@@ -96,23 +96,39 @@ static int nft_masq_dump(struct sk_buff *skb,
return -1; return -1;
} }
static void nft_masq_ipv4_eval(const struct nft_expr *expr, static void nft_masq_eval(const struct nft_expr *expr,
struct nft_regs *regs, struct nft_regs *regs,
const struct nft_pktinfo *pkt) const struct nft_pktinfo *pkt)
{ {
struct nft_masq *priv = nft_expr_priv(expr); const struct nft_masq *priv = nft_expr_priv(expr);
struct nf_nat_range2 range; struct nf_nat_range2 range;
memset(&range, 0, sizeof(range)); memset(&range, 0, sizeof(range));
range.flags = priv->flags; range.flags = priv->flags;
if (priv->sreg_proto_min) { if (priv->sreg_proto_min) {
range.min_proto.all = (__force __be16)nft_reg_load16( range.min_proto.all = (__force __be16)
&regs->data[priv->sreg_proto_min]); nft_reg_load16(&regs->data[priv->sreg_proto_min]);
range.max_proto.all = (__force __be16)nft_reg_load16( range.max_proto.all = (__force __be16)
&regs->data[priv->sreg_proto_max]); nft_reg_load16(&regs->data[priv->sreg_proto_max]);
}
switch (nft_pf(pkt)) {
case NFPROTO_IPV4:
regs->verdict.code = nf_nat_masquerade_ipv4(pkt->skb,
nft_hook(pkt),
&range,
nft_out(pkt));
break;
#ifdef CONFIG_NF_TABLES_IPV6
case NFPROTO_IPV6:
regs->verdict.code = nf_nat_masquerade_ipv6(pkt->skb, &range,
nft_out(pkt));
break;
#endif
default:
WARN_ON_ONCE(1);
break;
} }
regs->verdict.code = nf_nat_masquerade_ipv4(pkt->skb, nft_hook(pkt),
&range, nft_out(pkt));
} }
static void static void
...@@ -125,7 +141,7 @@ static struct nft_expr_type nft_masq_ipv4_type; ...@@ -125,7 +141,7 @@ static struct nft_expr_type nft_masq_ipv4_type;
static const struct nft_expr_ops nft_masq_ipv4_ops = { static const struct nft_expr_ops nft_masq_ipv4_ops = {
.type = &nft_masq_ipv4_type, .type = &nft_masq_ipv4_type,
.size = NFT_EXPR_SIZE(sizeof(struct nft_masq)), .size = NFT_EXPR_SIZE(sizeof(struct nft_masq)),
.eval = nft_masq_ipv4_eval, .eval = nft_masq_eval,
.init = nft_masq_init, .init = nft_masq_init,
.destroy = nft_masq_ipv4_destroy, .destroy = nft_masq_ipv4_destroy,
.dump = nft_masq_dump, .dump = nft_masq_dump,
...@@ -143,25 +159,6 @@ static struct nft_expr_type nft_masq_ipv4_type __read_mostly = { ...@@ -143,25 +159,6 @@ static struct nft_expr_type nft_masq_ipv4_type __read_mostly = {
}; };
#ifdef CONFIG_NF_TABLES_IPV6 #ifdef CONFIG_NF_TABLES_IPV6
static void nft_masq_ipv6_eval(const struct nft_expr *expr,
struct nft_regs *regs,
const struct nft_pktinfo *pkt)
{
struct nft_masq *priv = nft_expr_priv(expr);
struct nf_nat_range2 range;
memset(&range, 0, sizeof(range));
range.flags = priv->flags;
if (priv->sreg_proto_min) {
range.min_proto.all = (__force __be16)nft_reg_load16(
&regs->data[priv->sreg_proto_min]);
range.max_proto.all = (__force __be16)nft_reg_load16(
&regs->data[priv->sreg_proto_max]);
}
regs->verdict.code = nf_nat_masquerade_ipv6(pkt->skb, &range,
nft_out(pkt));
}
static void static void
nft_masq_ipv6_destroy(const struct nft_ctx *ctx, const struct nft_expr *expr) nft_masq_ipv6_destroy(const struct nft_ctx *ctx, const struct nft_expr *expr)
{ {
...@@ -172,7 +169,7 @@ static struct nft_expr_type nft_masq_ipv6_type; ...@@ -172,7 +169,7 @@ static struct nft_expr_type nft_masq_ipv6_type;
static const struct nft_expr_ops nft_masq_ipv6_ops = { static const struct nft_expr_ops nft_masq_ipv6_ops = {
.type = &nft_masq_ipv6_type, .type = &nft_masq_ipv6_type,
.size = NFT_EXPR_SIZE(sizeof(struct nft_masq)), .size = NFT_EXPR_SIZE(sizeof(struct nft_masq)),
.eval = nft_masq_ipv6_eval, .eval = nft_masq_eval,
.init = nft_masq_init, .init = nft_masq_init,
.destroy = nft_masq_ipv6_destroy, .destroy = nft_masq_ipv6_destroy,
.dump = nft_masq_dump, .dump = nft_masq_dump,
...@@ -204,20 +201,6 @@ static inline void nft_masq_module_exit_ipv6(void) {} ...@@ -204,20 +201,6 @@ static inline void nft_masq_module_exit_ipv6(void) {}
#endif #endif
#ifdef CONFIG_NF_TABLES_INET #ifdef CONFIG_NF_TABLES_INET
static void nft_masq_inet_eval(const struct nft_expr *expr,
struct nft_regs *regs,
const struct nft_pktinfo *pkt)
{
switch (nft_pf(pkt)) {
case NFPROTO_IPV4:
return nft_masq_ipv4_eval(expr, regs, pkt);
case NFPROTO_IPV6:
return nft_masq_ipv6_eval(expr, regs, pkt);
}
WARN_ON_ONCE(1);
}
static void static void
nft_masq_inet_destroy(const struct nft_ctx *ctx, const struct nft_expr *expr) nft_masq_inet_destroy(const struct nft_ctx *ctx, const struct nft_expr *expr)
{ {
...@@ -228,7 +211,7 @@ static struct nft_expr_type nft_masq_inet_type; ...@@ -228,7 +211,7 @@ static struct nft_expr_type nft_masq_inet_type;
static const struct nft_expr_ops nft_masq_inet_ops = { static const struct nft_expr_ops nft_masq_inet_ops = {
.type = &nft_masq_inet_type, .type = &nft_masq_inet_type,
.size = NFT_EXPR_SIZE(sizeof(struct nft_masq)), .size = NFT_EXPR_SIZE(sizeof(struct nft_masq)),
.eval = nft_masq_inet_eval, .eval = nft_masq_eval,
.init = nft_masq_init, .init = nft_masq_init,
.destroy = nft_masq_inet_destroy, .destroy = nft_masq_inet_destroy,
.dump = nft_masq_dump, .dump = nft_masq_dump,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment