Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 59001
b: refs/heads/master
c: b560580
h: refs/heads/master
i:
  58999: 2429784
v: v3
  • Loading branch information
Patrick McHardy authored and David S. Miller committed Jul 11, 2007
1 parent fccb41e commit 983b465
Show file tree
Hide file tree
Showing 8 changed files with 46 additions and 40 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 31f15875c5ad98a13b528aaf19c839e22b43dc9a
refs/heads/master: b560580a13b180bc1e3cad7ffbc93388cc39be5d
2 changes: 2 additions & 0 deletions trunk/include/net/netfilter/nf_conntrack.h
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,8 @@ struct nf_conn_help {

union nf_conntrack_help help;

struct hlist_head expectations;

/* Current number of expected connections */
unsigned int expecting;
};
Expand Down
5 changes: 2 additions & 3 deletions trunk/include/net/netfilter/nf_conntrack_expect.h
Original file line number Diff line number Diff line change
Expand Up @@ -6,14 +6,13 @@
#define _NF_CONNTRACK_EXPECT_H
#include <net/netfilter/nf_conntrack.h>

extern struct list_head nf_ct_expect_list;
extern struct hlist_head *nf_ct_expect_hash;
extern unsigned int nf_ct_expect_hsize;

struct nf_conntrack_expect
{
/* Internal linked list (global expectation list) */
struct list_head list;
/* Conntrack expectation list member */
struct hlist_node lnode;

/* Hash member */
struct hlist_node hnode;
Expand Down
2 changes: 2 additions & 0 deletions trunk/include/net/netfilter/nf_conntrack_helper.h
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,8 @@ extern void nf_ct_helper_put(struct nf_conntrack_helper *helper);
extern int nf_conntrack_helper_register(struct nf_conntrack_helper *);
extern void nf_conntrack_helper_unregister(struct nf_conntrack_helper *);

extern struct nf_conn_help *nf_ct_helper_ext_add(struct nf_conn *ct, gfp_t gfp);

static inline struct nf_conn_help *nfct_help(const struct nf_conn *ct)
{
return nf_ct_ext_find(ct, NF_CT_EXT_HELPER);
Expand Down
18 changes: 4 additions & 14 deletions trunk/net/netfilter/nf_conntrack_core.c
Original file line number Diff line number Diff line change
Expand Up @@ -502,12 +502,9 @@ init_conntrack(const struct nf_conntrack_tuple *tuple,
__set_bit(IPS_EXPECTED_BIT, &conntrack->status);
conntrack->master = exp->master;
if (exp->helper) {
help = nf_ct_ext_add(conntrack, NF_CT_EXT_HELPER,
GFP_ATOMIC);
help = nf_ct_helper_ext_add(conntrack, GFP_ATOMIC);
if (help)
rcu_assign_pointer(help->helper, exp->helper);
else
DEBUGP("failed to add helper extension area");
}

#ifdef CONFIG_NF_CONNTRACK_MARK
Expand All @@ -523,14 +520,9 @@ init_conntrack(const struct nf_conntrack_tuple *tuple,

helper = __nf_ct_helper_find(&repl_tuple);
if (helper) {
help = nf_ct_ext_add(conntrack, NF_CT_EXT_HELPER,
GFP_ATOMIC);
help = nf_ct_helper_ext_add(conntrack, GFP_ATOMIC);
if (help)
/* not in hash table yet, so not strictly
necessary */
rcu_assign_pointer(help->helper, helper);
else
DEBUGP("failed to add helper extension area");
}
NF_CT_STAT_INC(new);
}
Expand Down Expand Up @@ -721,11 +713,9 @@ void nf_conntrack_alter_reply(struct nf_conn *ct,
}

if (help == NULL) {
help = nf_ct_ext_add(ct, NF_CT_EXT_HELPER, GFP_ATOMIC);
if (help == NULL) {
DEBUGP("failed to add helper extension area");
help = nf_ct_helper_ext_add(ct, GFP_ATOMIC);
if (help == NULL)
goto out;
}
} else {
memset(&help->help, 0, sizeof(help->help));
}
Expand Down
40 changes: 20 additions & 20 deletions trunk/net/netfilter/nf_conntrack_expect.c
Original file line number Diff line number Diff line change
Expand Up @@ -27,9 +27,6 @@
#include <net/netfilter/nf_conntrack_helper.h>
#include <net/netfilter/nf_conntrack_tuple.h>

LIST_HEAD(nf_ct_expect_list);
EXPORT_SYMBOL_GPL(nf_ct_expect_list);

struct hlist_head *nf_ct_expect_hash __read_mostly;
EXPORT_SYMBOL_GPL(nf_ct_expect_hash);

Expand All @@ -52,13 +49,14 @@ void nf_ct_unlink_expect(struct nf_conntrack_expect *exp)
NF_CT_ASSERT(master_help);
NF_CT_ASSERT(!timer_pending(&exp->timeout));

list_del(&exp->list);
hlist_del(&exp->hnode);
nf_ct_expect_count--;

NF_CT_STAT_INC(expect_delete);
hlist_del(&exp->lnode);
master_help->expecting--;
nf_ct_expect_put(exp);

NF_CT_STAT_INC(expect_delete);
}
EXPORT_SYMBOL_GPL(nf_ct_unlink_expect);

Expand Down Expand Up @@ -153,17 +151,18 @@ nf_ct_find_expectation(const struct nf_conntrack_tuple *tuple)
/* delete all expectations for this conntrack */
void nf_ct_remove_expectations(struct nf_conn *ct)
{
struct nf_conntrack_expect *i, *tmp;
struct nf_conn_help *help = nfct_help(ct);
struct nf_conntrack_expect *exp;
struct hlist_node *n, *next;

/* Optimization: most connection never expect any others. */
if (!help || help->expecting == 0)
return;

list_for_each_entry_safe(i, tmp, &nf_ct_expect_list, list) {
if (i->master == ct && del_timer(&i->timeout)) {
nf_ct_unlink_expect(i);
nf_ct_expect_put(i);
hlist_for_each_entry_safe(exp, n, next, &help->expectations, lnode) {
if (del_timer(&exp->timeout)) {
nf_ct_unlink_expect(exp);
nf_ct_expect_put(exp);
}
}
}
Expand Down Expand Up @@ -289,9 +288,10 @@ static void nf_ct_expect_insert(struct nf_conntrack_expect *exp)
unsigned int h = nf_ct_expect_dst_hash(&exp->tuple);

atomic_inc(&exp->use);

hlist_add_head(&exp->lnode, &master_help->expectations);
master_help->expecting++;

list_add(&exp->list, &nf_ct_expect_list);
hlist_add_head(&exp->hnode, &nf_ct_expect_hash[h]);
nf_ct_expect_count++;

Expand All @@ -308,16 +308,16 @@ static void nf_ct_expect_insert(struct nf_conntrack_expect *exp)
/* Race with expectations being used means we could have none to find; OK. */
static void evict_oldest_expect(struct nf_conn *master)
{
struct nf_conntrack_expect *i;
struct nf_conn_help *master_help = nfct_help(master);
struct nf_conntrack_expect *exp = NULL;
struct hlist_node *n;

list_for_each_entry_reverse(i, &nf_ct_expect_list, list) {
if (i->master == master) {
if (del_timer(&i->timeout)) {
nf_ct_unlink_expect(i);
nf_ct_expect_put(i);
}
break;
}
hlist_for_each_entry(exp, n, &master_help->expectations, lnode)
; /* nothing */

if (exp && del_timer(&exp->timeout)) {
nf_ct_unlink_expect(exp);
nf_ct_expect_put(exp);
}
}

Expand Down
13 changes: 13 additions & 0 deletions trunk/net/netfilter/nf_conntrack_helper.c
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,19 @@ __nf_conntrack_helper_find_byname(const char *name)
}
EXPORT_SYMBOL_GPL(__nf_conntrack_helper_find_byname);

struct nf_conn_help *nf_ct_helper_ext_add(struct nf_conn *ct, gfp_t gfp)
{
struct nf_conn_help *help;

help = nf_ct_ext_add(ct, NF_CT_EXT_HELPER, gfp);
if (help)
INIT_HLIST_HEAD(&help->expectations);
else
pr_debug("failed to add helper extension area");
return help;
}
EXPORT_SYMBOL_GPL(nf_ct_helper_ext_add);

static inline int unhelp(struct nf_conntrack_tuple_hash *i,
const struct nf_conntrack_helper *me)
{
Expand Down
4 changes: 2 additions & 2 deletions trunk/net/netfilter/nf_conntrack_netlink.c
Original file line number Diff line number Diff line change
Expand Up @@ -868,7 +868,7 @@ ctnetlink_change_helper(struct nf_conn *ct, struct nfattr *cda[])
/* need to zero data of old helper */
memset(&help->help, 0, sizeof(help->help));
} else {
help = nf_ct_ext_add(ct, NF_CT_EXT_HELPER, GFP_KERNEL);
help = nf_ct_helper_ext_add(ct, GFP_KERNEL);
if (help == NULL)
return -ENOMEM;
}
Expand Down Expand Up @@ -989,7 +989,7 @@ ctnetlink_create_conntrack(struct nfattr *cda[],

helper = nf_ct_helper_find_get(rtuple);
if (helper) {
help = nf_ct_ext_add(ct, NF_CT_EXT_HELPER, GFP_KERNEL);
help = nf_ct_helper_ext_add(ct, GFP_KERNEL);
if (help == NULL) {
nf_ct_helper_put(helper);
err = -ENOMEM;
Expand Down

0 comments on commit 983b465

Please sign in to comment.