Skip to content

Commit

Permalink
netfilter: nf_flowtable: remove flow_offload_entry structure
Browse files Browse the repository at this point in the history
Move rcu_head to struct flow_offload, then remove the flow_offload_entry
structure definition.

Signed-off-by: Pablo Neira Ayuso <pablo@netfilter.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
  • Loading branch information
Pablo Neira Ayuso authored and David S. Miller committed Nov 13, 2019
1 parent 9f48e9b commit 62248df
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 15 deletions.
1 change: 1 addition & 0 deletions include/net/netfilter/nf_flow_table.h
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ struct flow_offload {
struct nf_conn *ct;
u32 flags;
u32 timeout;
struct rcu_head rcu_head;
};

#define NF_FLOW_TIMEOUT (30 * HZ)
Expand Down
19 changes: 4 additions & 15 deletions net/netfilter/nf_flow_table_core.c
Original file line number Diff line number Diff line change
Expand Up @@ -14,11 +14,6 @@
#include <net/netfilter/nf_conntrack_l4proto.h>
#include <net/netfilter/nf_conntrack_tuple.h>

struct flow_offload_entry {
struct flow_offload flow;
struct rcu_head rcu_head;
};

static DEFINE_MUTEX(flowtable_lock);
static LIST_HEAD(flowtables);

Expand Down Expand Up @@ -59,19 +54,16 @@ flow_offload_fill_dir(struct flow_offload *flow, struct nf_conn *ct,
struct flow_offload *
flow_offload_alloc(struct nf_conn *ct, struct nf_flow_route *route)
{
struct flow_offload_entry *entry;
struct flow_offload *flow;

if (unlikely(nf_ct_is_dying(ct) ||
!atomic_inc_not_zero(&ct->ct_general.use)))
return NULL;

entry = kzalloc(sizeof(*entry), GFP_ATOMIC);
if (!entry)
flow = kzalloc(sizeof(*flow), GFP_ATOMIC);
if (!flow)
goto err_ct_refcnt;

flow = &entry->flow;

if (!dst_hold_safe(route->tuple[FLOW_OFFLOAD_DIR_ORIGINAL].dst))
goto err_dst_cache_original;

Expand All @@ -93,7 +85,7 @@ flow_offload_alloc(struct nf_conn *ct, struct nf_flow_route *route)
err_dst_cache_reply:
dst_release(route->tuple[FLOW_OFFLOAD_DIR_ORIGINAL].dst);
err_dst_cache_original:
kfree(entry);
kfree(flow);
err_ct_refcnt:
nf_ct_put(ct);

Expand Down Expand Up @@ -151,15 +143,12 @@ static void flow_offload_fixup_ct(struct nf_conn *ct)

void flow_offload_free(struct flow_offload *flow)
{
struct flow_offload_entry *e;

dst_release(flow->tuplehash[FLOW_OFFLOAD_DIR_ORIGINAL].tuple.dst_cache);
dst_release(flow->tuplehash[FLOW_OFFLOAD_DIR_REPLY].tuple.dst_cache);
e = container_of(flow, struct flow_offload_entry, flow);
if (flow->flags & FLOW_OFFLOAD_DYING)
nf_ct_delete(flow->ct, 0, 0);
nf_ct_put(flow->ct);
kfree_rcu(e, rcu_head);
kfree_rcu(flow, rcu_head);
}
EXPORT_SYMBOL_GPL(flow_offload_free);

Expand Down

0 comments on commit 62248df

Please sign in to comment.