Commit 12ed6015 authored by David S. Miller's avatar David S. Miller
Browse files

Merge git://git.kernel.org/pub/scm/linux/kernel/git/pablo/nf 



Pablo Neira Ayuso says:

====================
Netfilter fixes for net

This patchset contains Netfilter fixes for net:

1) Extend selftest to cover flowtable with ipsec, from Florian Westphal.

2) Fix interaction of ipsec with flowtable, also from Florian.

3) User-after-free with bound set to rule that fails to load.

4) Adjust state and timeout for flows that expire.

5) Timeout update race with flows in teardown state.

6) Ensure conntrack id hash calculation use invariants as input,
   from Dirk Morris.

7) Do not push flows into flowtable for TCP fin/rst packets.
====================

Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parents 32d3182c dfe42be1

include/net/netfilter/nf_tables.h

+7 −2
Original line number Diff line number Diff line
@@ -421,8 +421,7 @@ struct nft_set { 
	unsigned char			*udata;

	/* runtime data below here */

	const struct nft_set_ops	*ops ____cacheline_aligned;

	u16				flags:13,

					bound:1,

	u16				flags:14,

					genmask:2;

	u8				klen;

	u8				dlen;
@@ -1348,12 +1347,15 @@ struct nft_trans_rule { 
struct nft_trans_set {

	struct nft_set			*set;

	u32				set_id;

	bool				bound;

};



#define nft_trans_set(trans)	\

	(((struct nft_trans_set *)trans->data)->set)

#define nft_trans_set_id(trans)	\

	(((struct nft_trans_set *)trans->data)->set_id)

#define nft_trans_set_bound(trans)	\

	(((struct nft_trans_set *)trans->data)->bound)



struct nft_trans_chain {

	bool				update;
@@ -1384,12 +1386,15 @@ struct nft_trans_table { 
struct nft_trans_elem {

	struct nft_set			*set;

	struct nft_set_elem		elem;

	bool				bound;

};



#define nft_trans_elem_set(trans)	\

	(((struct nft_trans_elem *)trans->data)->set)

#define nft_trans_elem(trans)	\

	(((struct nft_trans_elem *)trans->data)->elem)

#define nft_trans_elem_set_bound(trans)	\

	(((struct nft_trans_elem *)trans->data)->bound)



struct nft_trans_obj {

	struct nft_object		*obj;

net/netfilter/nf_conntrack_core.c

+8 −8
Original line number Diff line number Diff line
@@ -453,13 +453,12 @@ EXPORT_SYMBOL_GPL(nf_ct_invert_tuple); 
 * table location, we assume id gets exposed to userspace.

 *

 * Following nf_conn items do not change throughout lifetime

 * of the nf_conn after it has been committed to main hash table:

 * of the nf_conn:

 *

 * 1. nf_conn address

 * 2. nf_conn->ext address

 * 3. nf_conn->master address (normally NULL)

 * 4. tuple

 * 5. the associated net namespace

 * 2. nf_conn->master address (normally NULL)

 * 3. the associated net namespace

 * 4. the original direction tuple

 */

u32 nf_ct_get_id(const struct nf_conn *ct)

{
@@ -469,9 +468,10 @@ u32 nf_ct_get_id(const struct nf_conn *ct) 
	net_get_random_once(&ct_id_seed, sizeof(ct_id_seed));



	a = (unsigned long)ct;

	b = (unsigned long)ct->master ^ net_hash_mix(nf_ct_net(ct));

	c = (unsigned long)ct->ext;

	d = (unsigned long)siphash(&ct->tuplehash, sizeof(ct->tuplehash),

	b = (unsigned long)ct->master;

	c = (unsigned long)nf_ct_net(ct);

	d = (unsigned long)siphash(&ct->tuplehash[IP_CT_DIR_ORIGINAL].tuple,

				   sizeof(ct->tuplehash[IP_CT_DIR_ORIGINAL].tuple),

				   &ct_id_seed);

#ifdef CONFIG_64BIT

	return siphash_4u64((u64)a, (u64)b, (u64)c, (u64)d, &ct_id_seed);

net/netfilter/nf_flow_table_core.c

+31 −12
Original line number Diff line number Diff line
@@ -111,15 +111,16 @@ static void flow_offload_fixup_tcp(struct ip_ct_tcp *tcp) 
#define NF_FLOWTABLE_TCP_PICKUP_TIMEOUT	(120 * HZ)

#define NF_FLOWTABLE_UDP_PICKUP_TIMEOUT	(30 * HZ)



static void flow_offload_fixup_ct_state(struct nf_conn *ct)

static inline __s32 nf_flow_timeout_delta(unsigned int timeout)

{

	return (__s32)(timeout - (u32)jiffies);

}



static void flow_offload_fixup_ct_timeout(struct nf_conn *ct)

{

	const struct nf_conntrack_l4proto *l4proto;

	int l4num = nf_ct_protonum(ct);

	unsigned int timeout;

	int l4num;



	l4num = nf_ct_protonum(ct);

	if (l4num == IPPROTO_TCP)

		flow_offload_fixup_tcp(&ct->proto.tcp);



	l4proto = nf_ct_l4proto_find(l4num);

	if (!l4proto)
@@ -132,9 +133,22 @@ static void flow_offload_fixup_ct_state(struct nf_conn *ct) 
	else

		return;



	if (nf_flow_timeout_delta(ct->timeout) > (__s32)timeout)

		ct->timeout = nfct_time_stamp + timeout;

}



static void flow_offload_fixup_ct_state(struct nf_conn *ct)

{

	if (nf_ct_protonum(ct) == IPPROTO_TCP)

		flow_offload_fixup_tcp(&ct->proto.tcp);

}



static void flow_offload_fixup_ct(struct nf_conn *ct)

{

	flow_offload_fixup_ct_state(ct);

	flow_offload_fixup_ct_timeout(ct);

}



void flow_offload_free(struct flow_offload *flow)

{

	struct flow_offload_entry *e;
@@ -208,6 +222,11 @@ int flow_offload_add(struct nf_flowtable *flow_table, struct flow_offload *flow) 
}

EXPORT_SYMBOL_GPL(flow_offload_add);



static inline bool nf_flow_has_expired(const struct flow_offload *flow)

{

	return nf_flow_timeout_delta(flow->timeout) <= 0;

}



static void flow_offload_del(struct nf_flowtable *flow_table,

			     struct flow_offload *flow)

{
@@ -223,6 +242,11 @@ static void flow_offload_del(struct nf_flowtable *flow_table, 
	e = container_of(flow, struct flow_offload_entry, flow);

	clear_bit(IPS_OFFLOAD_BIT, &e->ct->status);



	if (nf_flow_has_expired(flow))

		flow_offload_fixup_ct(e->ct);

	else if (flow->flags & FLOW_OFFLOAD_TEARDOWN)

		flow_offload_fixup_ct_timeout(e->ct);



	flow_offload_free(flow);

}
@@ -298,11 +322,6 @@ nf_flow_table_iterate(struct nf_flowtable *flow_table, 
	return err;

}



static inline bool nf_flow_has_expired(const struct flow_offload *flow)

{

	return (__s32)(flow->timeout - (u32)jiffies) <= 0;

}



static void nf_flow_offload_gc_step(struct flow_offload *flow, void *data)

{

	struct nf_flowtable *flow_table = data;

net/netfilter/nf_flow_table_ip.c

+43 −0
Original line number Diff line number Diff line
@@ -214,6 +214,25 @@ static bool nf_flow_exceeds_mtu(const struct sk_buff *skb, unsigned int mtu) 
	return true;

}



static int nf_flow_offload_dst_check(struct dst_entry *dst)

{

	if (unlikely(dst_xfrm(dst)))

		return dst_check(dst, 0) ? 0 : -1;



	return 0;

}



static unsigned int nf_flow_xmit_xfrm(struct sk_buff *skb,

				      const struct nf_hook_state *state,

				      struct dst_entry *dst)

{

	skb_orphan(skb);

	skb_dst_set_noref(skb, dst);

	skb->tstamp = 0;

	dst_output(state->net, state->sk, skb);

	return NF_STOLEN;

}



unsigned int

nf_flow_offload_ip_hook(void *priv, struct sk_buff *skb,

			const struct nf_hook_state *state)
@@ -254,6 +273,11 @@ nf_flow_offload_ip_hook(void *priv, struct sk_buff *skb, 
	if (nf_flow_state_check(flow, ip_hdr(skb)->protocol, skb, thoff))

		return NF_ACCEPT;



	if (nf_flow_offload_dst_check(&rt->dst)) {

		flow_offload_teardown(flow);

		return NF_ACCEPT;

	}



	if (nf_flow_nat_ip(flow, skb, thoff, dir) < 0)

		return NF_DROP;
@@ -261,6 +285,13 @@ nf_flow_offload_ip_hook(void *priv, struct sk_buff *skb, 
	iph = ip_hdr(skb);

	ip_decrease_ttl(iph);



	if (unlikely(dst_xfrm(&rt->dst))) {

		memset(skb->cb, 0, sizeof(struct inet_skb_parm));

		IPCB(skb)->iif = skb->dev->ifindex;

		IPCB(skb)->flags = IPSKB_FORWARDED;

		return nf_flow_xmit_xfrm(skb, state, &rt->dst);

	}



	skb->dev = outdev;

	nexthop = rt_nexthop(rt, flow->tuplehash[!dir].tuple.src_v4.s_addr);

	skb_dst_set_noref(skb, &rt->dst);
@@ -467,6 +498,11 @@ nf_flow_offload_ipv6_hook(void *priv, struct sk_buff *skb, 
				sizeof(*ip6h)))

		return NF_ACCEPT;



	if (nf_flow_offload_dst_check(&rt->dst)) {

		flow_offload_teardown(flow);

		return NF_ACCEPT;

	}



	if (skb_try_make_writable(skb, sizeof(*ip6h)))

		return NF_DROP;
@@ -477,6 +513,13 @@ nf_flow_offload_ipv6_hook(void *priv, struct sk_buff *skb, 
	ip6h = ipv6_hdr(skb);

	ip6h->hop_limit--;



	if (unlikely(dst_xfrm(&rt->dst))) {

		memset(skb->cb, 0, sizeof(struct inet6_skb_parm));

		IP6CB(skb)->iif = skb->dev->ifindex;

		IP6CB(skb)->flags = IP6SKB_FORWARDED;

		return nf_flow_xmit_xfrm(skb, state, &rt->dst);

	}



	skb->dev = outdev;

	nexthop = rt6_nexthop(rt, &flow->tuplehash[!dir].tuple.src_v6);

	skb_dst_set_noref(skb, &rt->dst);

net/netfilter/nf_tables_api.c

+10 −5
Original line number Diff line number Diff line
@@ -138,9 +138,14 @@ static void nft_set_trans_bind(const struct nft_ctx *ctx, struct nft_set *set) 
		return;



	list_for_each_entry_reverse(trans, &net->nft.commit_list, list) {

		if (trans->msg_type == NFT_MSG_NEWSET &&

		    nft_trans_set(trans) == set) {

			set->bound = true;

		switch (trans->msg_type) {

		case NFT_MSG_NEWSET:

			if (nft_trans_set(trans) == set)

				nft_trans_set_bound(trans) = true;

			break;

		case NFT_MSG_NEWSETELEM:

			if (nft_trans_elem_set(trans) == set)

				nft_trans_elem_set_bound(trans) = true;

			break;

		}

	}
@@ -6906,7 +6911,7 @@ static int __nf_tables_abort(struct net *net) 
			break;

		case NFT_MSG_NEWSET:

			trans->ctx.table->use--;

			if (nft_trans_set(trans)->bound) {

			if (nft_trans_set_bound(trans)) {

				nft_trans_destroy(trans);

				break;

			}
@@ -6918,7 +6923,7 @@ static int __nf_tables_abort(struct net *net) 
			nft_trans_destroy(trans);

			break;

		case NFT_MSG_NEWSETELEM:

			if (nft_trans_elem_set(trans)->bound) {

			if (nft_trans_elem_set_bound(trans)) {

				nft_trans_destroy(trans);

				break;

			}

CRA Git | Maintained and supported by SUSTech CRA and CCSE