Commit 46d5439d authored by Stephen Hemminger's avatar Stephen Hemminger Committed by David S. Miller

[BRIDGE]: Get rid of threaded link for forwarding timeout

For 2.6, I changed the bridge forwarding table timeout code to keep
a threaded list of in order entries. Well, it turns out that this is
a performance hit because we end up constantly moving entries around
in the list.  Later patch changes this to be in place update with RCU.

This version just uses a 100ms garbage collection timer.
Signed-off-by: default avatarStephen Hemminger <shemminger@osdl.org>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent f5b3da09
...@@ -64,9 +64,6 @@ static __inline__ int br_mac_hash(const unsigned char *mac) ...@@ -64,9 +64,6 @@ static __inline__ int br_mac_hash(const unsigned char *mac)
static __inline__ void fdb_delete(struct net_bridge_fdb_entry *f) static __inline__ void fdb_delete(struct net_bridge_fdb_entry *f)
{ {
hlist_del_rcu(&f->hlist); hlist_del_rcu(&f->hlist);
if (!f->is_static)
list_del(&f->u.age_list);
br_fdb_put(f); br_fdb_put(f);
} }
...@@ -113,30 +110,23 @@ void br_fdb_changeaddr(struct net_bridge_port *p, const unsigned char *newaddr) ...@@ -113,30 +110,23 @@ void br_fdb_changeaddr(struct net_bridge_port *p, const unsigned char *newaddr)
void br_fdb_cleanup(unsigned long _data) void br_fdb_cleanup(unsigned long _data)
{ {
struct net_bridge *br = (struct net_bridge *)_data; struct net_bridge *br = (struct net_bridge *)_data;
struct list_head *l, *n; unsigned long delay = hold_time(br);
unsigned long delay; int i;
spin_lock_bh(&br->hash_lock); spin_lock_bh(&br->hash_lock);
delay = hold_time(br); for (i = 0; i < BR_HASH_SIZE; i++) {
list_for_each_safe(l, n, &br->age_list) {
struct net_bridge_fdb_entry *f; struct net_bridge_fdb_entry *f;
unsigned long expires; struct hlist_node *h, *n;
f = list_entry(l, struct net_bridge_fdb_entry, u.age_list); hlist_for_each_entry_safe(f, h, n, &br->hash[i], hlist) {
expires = f->ageing_timer + delay; if (!f->is_static &&
time_before_eq(f->ageing_timer + delay, jiffies))
if (time_before_eq(expires, jiffies)) {
WARN_ON(f->is_static);
pr_debug("expire age %lu jiffies %lu\n",
f->ageing_timer, jiffies);
fdb_delete(f); fdb_delete(f);
} else {
mod_timer(&br->gc_timer, expires);
break;
} }
} }
spin_unlock_bh(&br->hash_lock); spin_unlock_bh(&br->hash_lock);
mod_timer(&br->gc_timer, jiffies + HZ/10);
} }
void br_fdb_delete_by_port(struct net_bridge *br, struct net_bridge_port *p) void br_fdb_delete_by_port(struct net_bridge *br, struct net_bridge_port *p)
...@@ -212,7 +202,7 @@ struct net_bridge_fdb_entry *br_fdb_get(struct net_bridge *br, ...@@ -212,7 +202,7 @@ struct net_bridge_fdb_entry *br_fdb_get(struct net_bridge *br,
static void fdb_rcu_free(struct rcu_head *head) static void fdb_rcu_free(struct rcu_head *head)
{ {
struct net_bridge_fdb_entry *ent struct net_bridge_fdb_entry *ent
= container_of(head, struct net_bridge_fdb_entry, u.rcu); = container_of(head, struct net_bridge_fdb_entry, rcu);
kmem_cache_free(br_fdb_cache, ent); kmem_cache_free(br_fdb_cache, ent);
} }
...@@ -220,7 +210,7 @@ static void fdb_rcu_free(struct rcu_head *head) ...@@ -220,7 +210,7 @@ static void fdb_rcu_free(struct rcu_head *head)
void br_fdb_put(struct net_bridge_fdb_entry *ent) void br_fdb_put(struct net_bridge_fdb_entry *ent)
{ {
if (atomic_dec_and_test(&ent->use_count)) if (atomic_dec_and_test(&ent->use_count))
call_rcu(&ent->u.rcu, fdb_rcu_free); call_rcu(&ent->rcu, fdb_rcu_free);
} }
/* /*
...@@ -305,8 +295,6 @@ static int fdb_insert(struct net_bridge *br, struct net_bridge_port *source, ...@@ -305,8 +295,6 @@ static int fdb_insert(struct net_bridge *br, struct net_bridge_port *source,
if (fdb->is_static) if (fdb->is_static)
return 0; return 0;
/* move to end of age list */
list_del(&fdb->u.age_list);
goto update; goto update;
} }
} }
...@@ -319,18 +307,11 @@ static int fdb_insert(struct net_bridge *br, struct net_bridge_port *source, ...@@ -319,18 +307,11 @@ static int fdb_insert(struct net_bridge *br, struct net_bridge_port *source,
atomic_set(&fdb->use_count, 1); atomic_set(&fdb->use_count, 1);
hlist_add_head_rcu(&fdb->hlist, &br->hash[hash]); hlist_add_head_rcu(&fdb->hlist, &br->hash[hash]);
if (!timer_pending(&br->gc_timer)) {
br->gc_timer.expires = jiffies + hold_time(br);
add_timer(&br->gc_timer);
}
update: update:
fdb->dst = source; fdb->dst = source;
fdb->is_local = is_local; fdb->is_local = is_local;
fdb->is_static = is_local; fdb->is_static = is_local;
fdb->ageing_timer = jiffies; fdb->ageing_timer = jiffies;
if (!is_local)
list_add_tail(&fdb->u.age_list, &br->age_list);
return 0; return 0;
} }
......
...@@ -46,10 +46,8 @@ struct net_bridge_fdb_entry ...@@ -46,10 +46,8 @@ struct net_bridge_fdb_entry
{ {
struct hlist_node hlist; struct hlist_node hlist;
struct net_bridge_port *dst; struct net_bridge_port *dst;
union {
struct list_head age_list;
struct rcu_head rcu; struct rcu_head rcu;
} u;
atomic_t use_count; atomic_t use_count;
unsigned long ageing_timer; unsigned long ageing_timer;
mac_addr addr; mac_addr addr;
......
...@@ -49,6 +49,8 @@ void br_stp_enable_bridge(struct net_bridge *br) ...@@ -49,6 +49,8 @@ void br_stp_enable_bridge(struct net_bridge *br)
spin_lock_bh(&br->lock); spin_lock_bh(&br->lock);
mod_timer(&br->hello_timer, jiffies + br->hello_time); mod_timer(&br->hello_timer, jiffies + br->hello_time);
mod_timer(&br->gc_timer, jiffies + HZ/10);
br_config_bpdu_generation(br); br_config_bpdu_generation(br);
list_for_each_entry(p, &br->port_list, list) { list_for_each_entry(p, &br->port_list, list) {
...@@ -78,6 +80,7 @@ void br_stp_disable_bridge(struct net_bridge *br) ...@@ -78,6 +80,7 @@ void br_stp_disable_bridge(struct net_bridge *br)
del_timer_sync(&br->hello_timer); del_timer_sync(&br->hello_timer);
del_timer_sync(&br->topology_change_timer); del_timer_sync(&br->topology_change_timer);
del_timer_sync(&br->tcn_timer); del_timer_sync(&br->tcn_timer);
del_timer_sync(&br->gc_timer);
} }
/* called under bridge lock */ /* called under bridge lock */
......
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