FEX-Emu/linux
1
0
Fork 0
mirror of https://github.com/FEX-Emu/linux.git synced 2024-12-22 09:22:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

bonding: rejoin multicast groups on VLANs

Browse Source 
During a failover, the IGMP membership is sent to update
the switch restoring the traffic, but it misses groups added
to VLAN devices running on top of bonding devices.

This patch changes it to iterate over all VLAN devices
on top of it sending IGMP memberships too.

Signed-off-by: Flavio Leitner <fleitner@redhat.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
Flavio Leitner 2010-10-05 14:23:57 +00:00 committed by David S. Miller
parent a8bb69f781
commit 5a37e8ca85
2 changed files with 51 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
drivers/net/bonding/bond_main.c
View File

@ -865,6 +865,21 @@ static void bond_mc_del(struct bonding *bond, void *addr)
} }
static void __bond_resend_igmp_join_requests(struct net_device *dev)
{
struct in_device *in_dev;
struct ip_mc_list *im;
rcu_read_lock();
in_dev = __in_dev_get_rcu(dev);
if (in_dev) {
for (im = in_dev->mc_list; im; im = im->next)
ip_mc_rejoin_group(im);
}
rcu_read_unlock();
}
/* /*
* Retrieve the list of registered multicast addresses for the bonding * Retrieve the list of registered multicast addresses for the bonding
* device and retransmit an IGMP JOIN request to the current active * device and retransmit an IGMP JOIN request to the current active
@ -872,17 +887,32 @@ static void bond_mc_del(struct bonding *bond, void *addr)
*/ */
static void bond_resend_igmp_join_requests(struct bonding *bond) static void bond_resend_igmp_join_requests(struct bonding *bond)
{ {
struct in_device *in_dev; struct net_device *vlan_dev;
struct ip_mc_list *im; struct vlan_entry *vlan;
rcu_read_lock(); read_lock(&bond->lock);
in_dev = __in_dev_get_rcu(bond->dev);
if (in_dev) { /* rejoin all groups on bond device */
for (im = in_dev->mc_list; im; im = im->next) __bond_resend_igmp_join_requests(bond->dev);
ip_mc_rejoin_group(im);
/* rejoin all groups on vlan devices */
if (bond->vlgrp) {
list_for_each_entry(vlan, &bond->vlan_list, vlan_list) {
vlan_dev = vlan_group_get_device(bond->vlgrp,
vlan->vlan_id);
if (vlan_dev)
__bond_resend_igmp_join_requests(vlan_dev);
}
} }
rcu_read_unlock(); read_unlock(&bond->lock);
}
void bond_resend_igmp_join_requests_delayed(struct work_struct *work)
{
struct bonding *bond = container_of(work, struct bonding,
mcast_work.work);
bond_resend_igmp_join_requests(bond);
} }
/* /*
@ -944,7 +974,6 @@ static void bond_mc_swap(struct bonding *bond, struct slave *new_active,
netdev_for_each_mc_addr(ha, bond->dev) netdev_for_each_mc_addr(ha, bond->dev)
dev_mc_add(new_active->dev, ha->addr); dev_mc_add(new_active->dev, ha->addr);
bond_resend_igmp_join_requests(bond);
} }
} }
@ -1180,9 +1209,11 @@ void bond_change_active_slave(struct bonding *bond, struct slave *new_active)
} }
} }
/* resend IGMP joins since all were sent on curr_active_slave */ /* resend IGMP joins since active slave has changed or
if (bond->params.mode == BOND_MODE_ROUNDROBIN) { * all were sent on curr_active_slave */
bond_resend_igmp_join_requests(bond); if ((USES_PRIMARY(bond->params.mode) && new_active) ||
bond->params.mode == BOND_MODE_ROUNDROBIN) {
queue_delayed_work(bond->wq, &bond->mcast_work, 0);
} }
} }
@ -3744,6 +3775,8 @@ static int bond_open(struct net_device *bond_dev)
bond->kill_timers = 0; bond->kill_timers = 0;
INIT_DELAYED_WORK(&bond->mcast_work, bond_resend_igmp_join_requests_delayed);
if (bond_is_lb(bond)) { if (bond_is_lb(bond)) {
/* bond_alb_initialize must be called before the timer /* bond_alb_initialize must be called before the timer
* is started. * is started.
@ -3828,6 +3861,8 @@ static int bond_close(struct net_device *bond_dev)
break; break;
} }
if (delayed_work_pending(&bond->mcast_work))
cancel_delayed_work(&bond->mcast_work);
if (bond_is_lb(bond)) { if (bond_is_lb(bond)) {
/* Must be called only after all /* Must be called only after all
@ -4703,6 +4738,9 @@ static void bond_work_cancel_all(struct bonding *bond)
if (bond->params.mode == BOND_MODE_8023AD && if (bond->params.mode == BOND_MODE_8023AD &&
delayed_work_pending(&bond->ad_work)) delayed_work_pending(&bond->ad_work))
cancel_delayed_work(&bond->ad_work); cancel_delayed_work(&bond->ad_work);
if (delayed_work_pending(&bond->mcast_work))
cancel_delayed_work(&bond->mcast_work);
} }
/* /*

1
drivers/net/bonding/bonding.h
View File

@ -223,6 +223,7 @@ struct bonding {
struct delayed_work arp_work; struct delayed_work arp_work;
struct delayed_work alb_work; struct delayed_work alb_work;
struct delayed_work ad_work; struct delayed_work ad_work;
struct delayed_work mcast_work;
#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE) #if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
struct in6_addr master_ipv6; struct in6_addr master_ipv6;
#endif #endif