diff options
author | Amerigo Wang <amwang@redhat.com> | 2012-12-03 18:56:40 -0500 |
---|---|---|
committer | David S. Miller <davem@davemloft.net> | 2012-12-05 16:01:27 -0500 |
commit | 50426b5925ff0d7f47c20e6886047f1bb6245901 (patch) | |
tree | 9a30b4f743be503bcd192784c0e52178d29f3734 | |
parent | a573ea56a9b014e3ab09c44ccb659ba6d538b81e (diff) |
bridge: implement multicast fast leave
V2: make the toggle per-port
Fast leave allows bridge to immediately stops the multicast
traffic on the port receives IGMP Leave when IGMP snooping is enabled,
no timeouts are observed.
Cc: Herbert Xu <herbert@gondor.apana.org.au>
Cc: Stephen Hemminger <shemminger@vyatta.com>
Cc: "David S. Miller" <davem@davemloft.net>
Signed-off-by: Cong Wang <amwang@redhat.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
-rw-r--r-- | net/bridge/br_multicast.c | 21 | ||||
-rw-r--r-- | net/bridge/br_private.h | 1 | ||||
-rw-r--r-- | net/bridge/br_sysfs_if.c | 20 |
3 files changed, 42 insertions, 0 deletions
diff --git a/net/bridge/br_multicast.c b/net/bridge/br_multicast.c index 241743417f49..2391bae4f733 100644 --- a/net/bridge/br_multicast.c +++ b/net/bridge/br_multicast.c | |||
@@ -1225,6 +1225,27 @@ static void br_multicast_leave_group(struct net_bridge *br, | |||
1225 | if (!mp) | 1225 | if (!mp) |
1226 | goto out; | 1226 | goto out; |
1227 | 1227 | ||
1228 | if (port && port->multicast_fast_leave) { | ||
1229 | struct net_bridge_port_group __rcu **pp; | ||
1230 | |||
1231 | for (pp = &mp->ports; | ||
1232 | (p = mlock_dereference(*pp, br)) != NULL; | ||
1233 | pp = &p->next) { | ||
1234 | if (p->port != port) | ||
1235 | continue; | ||
1236 | |||
1237 | rcu_assign_pointer(*pp, p->next); | ||
1238 | hlist_del_init(&p->mglist); | ||
1239 | del_timer(&p->timer); | ||
1240 | call_rcu_bh(&p->rcu, br_multicast_free_pg); | ||
1241 | |||
1242 | if (!mp->ports && !mp->mglist && | ||
1243 | netif_running(br->dev)) | ||
1244 | mod_timer(&mp->timer, jiffies); | ||
1245 | } | ||
1246 | goto out; | ||
1247 | } | ||
1248 | |||
1228 | now = jiffies; | 1249 | now = jiffies; |
1229 | time = now + br->multicast_last_member_count * | 1250 | time = now + br->multicast_last_member_count * |
1230 | br->multicast_last_member_interval; | 1251 | br->multicast_last_member_interval; |
diff --git a/net/bridge/br_private.h b/net/bridge/br_private.h index eb9cd42146a5..cdbf9047a659 100644 --- a/net/bridge/br_private.h +++ b/net/bridge/br_private.h | |||
@@ -141,6 +141,7 @@ struct net_bridge_port | |||
141 | #ifdef CONFIG_BRIDGE_IGMP_SNOOPING | 141 | #ifdef CONFIG_BRIDGE_IGMP_SNOOPING |
142 | u32 multicast_startup_queries_sent; | 142 | u32 multicast_startup_queries_sent; |
143 | unsigned char multicast_router; | 143 | unsigned char multicast_router; |
144 | unsigned char multicast_fast_leave; | ||
144 | struct timer_list multicast_router_timer; | 145 | struct timer_list multicast_router_timer; |
145 | struct timer_list multicast_query_timer; | 146 | struct timer_list multicast_query_timer; |
146 | struct hlist_head mglist; | 147 | struct hlist_head mglist; |
diff --git a/net/bridge/br_sysfs_if.c b/net/bridge/br_sysfs_if.c index 7ff95ba21982..dc484ace0be3 100644 --- a/net/bridge/br_sysfs_if.c +++ b/net/bridge/br_sysfs_if.c | |||
@@ -172,6 +172,25 @@ static int store_multicast_router(struct net_bridge_port *p, | |||
172 | } | 172 | } |
173 | static BRPORT_ATTR(multicast_router, S_IRUGO | S_IWUSR, show_multicast_router, | 173 | static BRPORT_ATTR(multicast_router, S_IRUGO | S_IWUSR, show_multicast_router, |
174 | store_multicast_router); | 174 | store_multicast_router); |
175 | |||
176 | static ssize_t show_multicast_fast_leave(struct net_bridge_port *p, | ||
177 | char *buf) | ||
178 | { | ||
179 | return sprintf(buf, "%d\n", p->multicast_fast_leave); | ||
180 | } | ||
181 | |||
182 | static int store_multicast_fast_leave(struct net_bridge_port *p, | ||
183 | unsigned long v) | ||
184 | { | ||
185 | if (p->br->multicast_disabled) | ||
186 | return -EINVAL; | ||
187 | |||
188 | p->multicast_fast_leave = !!v; | ||
189 | return 0; | ||
190 | } | ||
191 | |||
192 | static BRPORT_ATTR(multicast_fast_leave, S_IRUGO | S_IWUSR, | ||
193 | show_multicast_fast_leave, store_multicast_fast_leave); | ||
175 | #endif | 194 | #endif |
176 | 195 | ||
177 | static const struct brport_attribute *brport_attrs[] = { | 196 | static const struct brport_attribute *brport_attrs[] = { |
@@ -195,6 +214,7 @@ static const struct brport_attribute *brport_attrs[] = { | |||
195 | &brport_attr_root_block, | 214 | &brport_attr_root_block, |
196 | #ifdef CONFIG_BRIDGE_IGMP_SNOOPING | 215 | #ifdef CONFIG_BRIDGE_IGMP_SNOOPING |
197 | &brport_attr_multicast_router, | 216 | &brport_attr_multicast_router, |
217 | &brport_attr_multicast_fast_leave, | ||
198 | #endif | 218 | #endif |
199 | NULL | 219 | NULL |
200 | }; | 220 | }; |