Merge pull request #9416 from pguibert6WIND/vxlan_evpn_updates

Vxlan evpn updates
This commit is contained in:
Sri Mohana Singamsetty 2021-09-21 09:26:34 -07:00 committed by GitHub
commit e81192ad7c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 133 additions and 59 deletions

View File

@ -1021,7 +1021,8 @@ static int netlink_interface(struct nlmsghdr *h, ns_id_t ns_id, int startup)
if (IS_ZEBRA_IF_BOND(ifp)) if (IS_ZEBRA_IF_BOND(ifp))
zebra_l2if_update_bond(ifp, true); zebra_l2if_update_bond(ifp, true);
if (IS_ZEBRA_IF_BRIDGE_SLAVE(ifp)) if (IS_ZEBRA_IF_BRIDGE_SLAVE(ifp))
zebra_l2if_update_bridge_slave(ifp, bridge_ifindex, ns_id); zebra_l2if_update_bridge_slave(ifp, bridge_ifindex, ns_id,
ZEBRA_BRIDGE_NO_ACTION);
else if (IS_ZEBRA_IF_BOND_SLAVE(ifp)) else if (IS_ZEBRA_IF_BOND_SLAVE(ifp))
zebra_l2if_update_bond_slave(ifp, bond_ifindex, !!bypass); zebra_l2if_update_bond_slave(ifp, bond_ifindex, !!bypass);
@ -1852,9 +1853,9 @@ int netlink_link_change(struct nlmsghdr *h, ns_id_t ns_id, int startup)
ifp, linkinfo[IFLA_INFO_DATA], ifp, linkinfo[IFLA_INFO_DATA],
1, link_nsid); 1, link_nsid);
if (IS_ZEBRA_IF_BRIDGE_SLAVE(ifp)) if (IS_ZEBRA_IF_BRIDGE_SLAVE(ifp))
zebra_l2if_update_bridge_slave(ifp, zebra_l2if_update_bridge_slave(
bridge_ifindex, ifp, bridge_ifindex, ns_id,
ns_id); ZEBRA_BRIDGE_NO_ACTION);
else if (IS_ZEBRA_IF_BOND_SLAVE(ifp)) else if (IS_ZEBRA_IF_BOND_SLAVE(ifp))
zebra_l2if_update_bond_slave(ifp, bond_ifindex, zebra_l2if_update_bond_slave(ifp, bond_ifindex,
!!bypass); !!bypass);
@ -1878,6 +1879,7 @@ int netlink_link_change(struct nlmsghdr *h, ns_id_t ns_id, int startup)
if_handle_vrf_change(ifp, vrf_id); if_handle_vrf_change(ifp, vrf_id);
} else { } else {
bool was_bridge_slave, was_bond_slave; bool was_bridge_slave, was_bond_slave;
uint8_t chgflags = ZEBRA_BRIDGE_NO_ACTION;
/* Interface update. */ /* Interface update. */
if (IS_ZEBRA_DEBUG_KERNEL) if (IS_ZEBRA_DEBUG_KERNEL)
@ -1919,6 +1921,8 @@ int netlink_link_change(struct nlmsghdr *h, ns_id_t ns_id, int startup)
if_down(ifp); if_down(ifp);
rib_update(RIB_UPDATE_KERNEL); rib_update(RIB_UPDATE_KERNEL);
} else if (if_is_operative(ifp)) { } else if (if_is_operative(ifp)) {
bool mac_updated = false;
/* Must notify client daemons of new /* Must notify client daemons of new
* interface status. */ * interface status. */
if (IS_ZEBRA_DEBUG_KERNEL) if (IS_ZEBRA_DEBUG_KERNEL)
@ -1929,9 +1933,11 @@ int netlink_link_change(struct nlmsghdr *h, ns_id_t ns_id, int startup)
/* Update EVPN VNI when SVI MAC change /* Update EVPN VNI when SVI MAC change
*/ */
if (IS_ZEBRA_IF_VLAN(ifp) && if (memcmp(old_hw_addr, ifp->hw_addr,
memcmp(old_hw_addr, ifp->hw_addr, INTERFACE_HWADDR_MAX))
INTERFACE_HWADDR_MAX)) { mac_updated = true;
if (IS_ZEBRA_IF_VLAN(ifp)
&& mac_updated) {
struct interface *link_if; struct interface *link_if;
link_if = link_if =
@ -1941,6 +1947,13 @@ int netlink_link_change(struct nlmsghdr *h, ns_id_t ns_id, int startup)
if (link_if) if (link_if)
zebra_vxlan_svi_up(ifp, zebra_vxlan_svi_up(ifp,
link_if); link_if);
} else if (mac_updated
&& IS_ZEBRA_IF_BRIDGE(ifp)) {
zlog_debug(
"Intf %s(%u) bridge changed MAC address",
name, ifp->ifindex);
chgflags =
ZEBRA_BRIDGE_MASTER_MAC_CHANGE;
} }
} }
} else { } else {
@ -1951,6 +1964,9 @@ int netlink_link_change(struct nlmsghdr *h, ns_id_t ns_id, int startup)
"Intf %s(%u) has come UP", "Intf %s(%u) has come UP",
name, ifp->ifindex); name, ifp->ifindex);
if_up(ifp); if_up(ifp);
if (IS_ZEBRA_IF_BRIDGE(ifp))
chgflags =
ZEBRA_BRIDGE_MASTER_UP;
} else { } else {
if (IS_ZEBRA_DEBUG_KERNEL) if (IS_ZEBRA_DEBUG_KERNEL)
zlog_debug( zlog_debug(
@ -1966,12 +1982,13 @@ int netlink_link_change(struct nlmsghdr *h, ns_id_t ns_id, int startup)
netlink_interface_update_l2info( netlink_interface_update_l2info(
ifp, linkinfo[IFLA_INFO_DATA], ifp, linkinfo[IFLA_INFO_DATA],
0, link_nsid); 0, link_nsid);
if (IS_ZEBRA_IF_BRIDGE(ifp))
zebra_l2if_update_bridge(ifp, chgflags);
if (IS_ZEBRA_IF_BOND(ifp)) if (IS_ZEBRA_IF_BOND(ifp))
zebra_l2if_update_bond(ifp, true); zebra_l2if_update_bond(ifp, true);
if (IS_ZEBRA_IF_BRIDGE_SLAVE(ifp) || was_bridge_slave) if (IS_ZEBRA_IF_BRIDGE_SLAVE(ifp) || was_bridge_slave)
zebra_l2if_update_bridge_slave(ifp, zebra_l2if_update_bridge_slave(
bridge_ifindex, ifp, bridge_ifindex, ns_id, chgflags);
ns_id);
else if (IS_ZEBRA_IF_BOND_SLAVE(ifp) || was_bond_slave) else if (IS_ZEBRA_IF_BOND_SLAVE(ifp) || was_bond_slave)
zebra_l2if_update_bond_slave(ifp, bond_ifindex, zebra_l2if_update_bond_slave(ifp, bond_ifindex,
!!bypass); !!bypass);

View File

@ -50,7 +50,8 @@
/* static function declarations */ /* static function declarations */
/* Private functions */ /* Private functions */
static void map_slaves_to_bridge(struct interface *br_if, int link) static void map_slaves_to_bridge(struct interface *br_if, int link,
bool update_slave, uint8_t chgflags)
{ {
struct vrf *vrf; struct vrf *vrf;
struct interface *ifp; struct interface *ifp;
@ -79,9 +80,17 @@ static void map_slaves_to_bridge(struct interface *br_if, int link)
br_slave = &zif->brslave_info; br_slave = &zif->brslave_info;
if (link) { if (link) {
if (br_slave->bridge_ifindex == br_if->ifindex && if (br_slave->bridge_ifindex == br_if->ifindex
br_slave->ns_id == zns->ns_id) && br_slave->ns_id == zns->ns_id) {
br_slave->br_if = br_if; br_slave->br_if = br_if;
if (update_slave) {
zebra_l2if_update_bridge_slave(
ifp,
br_slave->bridge_ifindex,
br_slave->ns_id,
chgflags);
}
}
} else { } else {
if (br_slave->br_if == br_if) if (br_slave->br_if == br_if)
br_slave->br_if = NULL; br_slave->br_if = NULL;
@ -261,7 +270,7 @@ void zebra_l2_bridge_add_update(struct interface *ifp,
memcpy(&zif->l2info.br, bridge_info, sizeof(*bridge_info)); memcpy(&zif->l2info.br, bridge_info, sizeof(*bridge_info));
/* Link all slaves to this bridge */ /* Link all slaves to this bridge */
map_slaves_to_bridge(ifp, 1); map_slaves_to_bridge(ifp, 1, false, ZEBRA_BRIDGE_NO_ACTION);
} }
/* /*
@ -270,7 +279,14 @@ void zebra_l2_bridge_add_update(struct interface *ifp,
void zebra_l2_bridge_del(struct interface *ifp) void zebra_l2_bridge_del(struct interface *ifp)
{ {
/* Unlink all slaves to this bridge */ /* Unlink all slaves to this bridge */
map_slaves_to_bridge(ifp, 0); map_slaves_to_bridge(ifp, 0, false, ZEBRA_BRIDGE_NO_ACTION);
}
void zebra_l2if_update_bridge(struct interface *ifp, uint8_t chgflags)
{
if (!chgflags)
return;
map_slaves_to_bridge(ifp, 1, true, chgflags);
} }
/* /*
@ -398,8 +414,8 @@ void zebra_l2_vxlanif_del(struct interface *ifp)
* from a bridge before it can be mapped to another bridge. * from a bridge before it can be mapped to another bridge.
*/ */
void zebra_l2if_update_bridge_slave(struct interface *ifp, void zebra_l2if_update_bridge_slave(struct interface *ifp,
ifindex_t bridge_ifindex, ifindex_t bridge_ifindex, ns_id_t ns_id,
ns_id_t ns_id) uint8_t chgflags)
{ {
struct zebra_if *zif; struct zebra_if *zif;
ifindex_t old_bridge_ifindex; ifindex_t old_bridge_ifindex;
@ -413,6 +429,14 @@ void zebra_l2if_update_bridge_slave(struct interface *ifp,
if (!zvrf) if (!zvrf)
return; return;
if (zif->zif_type == ZEBRA_IF_VXLAN
&& chgflags != ZEBRA_BRIDGE_NO_ACTION) {
if (ZEBRA_BRIDGE_MASTER_MAC_CHANGE)
zebra_vxlan_if_update(ifp,
ZEBRA_VXLIF_MASTER_MAC_CHANGE);
if (ZEBRA_BRIDGE_MASTER_UP)
zebra_vxlan_if_update(ifp, ZEBRA_VXLIF_MASTER_CHANGE);
}
old_bridge_ifindex = zif->brslave_info.bridge_ifindex; old_bridge_ifindex = zif->brslave_info.bridge_ifindex;
old_ns_id = zif->brslave_info.ns_id; old_ns_id = zif->brslave_info.ns_id;
if (old_bridge_ifindex == bridge_ifindex && if (old_bridge_ifindex == bridge_ifindex &&

View File

@ -33,6 +33,10 @@
extern "C" { extern "C" {
#endif #endif
#define ZEBRA_BRIDGE_NO_ACTION (0)
#define ZEBRA_BRIDGE_MASTER_MAC_CHANGE (1 << 1)
#define ZEBRA_BRIDGE_MASTER_UP (1 << 2)
/* zebra L2 interface information - bridge slave (linkage to bridge) */ /* zebra L2 interface information - bridge slave (linkage to bridge) */
struct zebra_l2info_brslave { struct zebra_l2info_brslave {
ifindex_t bridge_ifindex; /* Bridge Master */ ifindex_t bridge_ifindex; /* Bridge Master */
@ -121,7 +125,7 @@ extern void zebra_l2_greif_del(struct interface *ifp);
extern void zebra_l2_vxlanif_del(struct interface *ifp); extern void zebra_l2_vxlanif_del(struct interface *ifp);
extern void zebra_l2if_update_bridge_slave(struct interface *ifp, extern void zebra_l2if_update_bridge_slave(struct interface *ifp,
ifindex_t bridge_ifindex, ifindex_t bridge_ifindex,
ns_id_t ns_id); ns_id_t ns_id, uint8_t chgflags);
extern void zebra_l2if_update_bond_slave(struct interface *ifp, extern void zebra_l2if_update_bond_slave(struct interface *ifp,
ifindex_t bond_ifindex, bool bypass); ifindex_t bond_ifindex, bool bypass);
@ -130,6 +134,7 @@ extern void zebra_vlan_bitmap_compute(struct interface *ifp,
extern void zebra_vlan_mbr_re_eval(struct interface *ifp, extern void zebra_vlan_mbr_re_eval(struct interface *ifp,
bitfield_t vlan_bitmap); bitfield_t vlan_bitmap);
extern void zebra_l2if_update_bond(struct interface *ifp, bool add); extern void zebra_l2if_update_bond(struct interface *ifp, bool add);
extern void zebra_l2if_update_bridge(struct interface *ifp, uint8_t chgflags);
#ifdef __cplusplus #ifdef __cplusplus
} }

View File

@ -1798,51 +1798,22 @@ struct zebra_l3vni *zl3vni_from_vrf(vrf_id_t vrf_id)
return zl3vni_lookup(zvrf->l3vni); return zl3vni_lookup(zvrf->l3vni);
} }
/* static int zl3vni_from_svi_ns(struct ns *ns, void *_in_param, void **_p_zl3vni)
* Map SVI and associated bridge to a VNI. This is invoked upon getting
* neighbor notifications, to see if they are of interest.
*/
static struct zebra_l3vni *zl3vni_from_svi(struct interface *ifp,
struct interface *br_if)
{ {
int found = 0; int found = 0;
vlanid_t vid = 0; struct zebra_ns *zns = ns->info;
uint8_t bridge_vlan_aware = 0; struct zebra_l3vni **p_zl3vni = (struct zebra_l3vni **)_p_zl3vni;
struct zebra_l3vni *zl3vni = NULL; struct zebra_from_svi_param *in_param =
struct zebra_ns *zns = NULL; (struct zebra_from_svi_param *)_in_param;
struct route_node *rn = NULL; struct route_node *rn = NULL;
struct zebra_if *zif = NULL;
struct interface *tmp_if = NULL; struct interface *tmp_if = NULL;
struct zebra_l2info_bridge *br = NULL; struct zebra_if *zif = NULL;
struct zebra_l2info_vxlan *vxl = NULL; struct zebra_l2info_vxlan *vxl = NULL;
if (!br_if) if (!in_param)
return NULL; return NS_WALK_STOP;
/* Make sure the linked interface is a bridge. */ /* loop through all vxlan-interface */
if (!IS_ZEBRA_IF_BRIDGE(br_if))
return NULL;
/* Determine if bridge is VLAN-aware or not */
zif = br_if->info;
assert(zif);
br = &zif->l2info.br;
bridge_vlan_aware = br->vlan_aware;
if (bridge_vlan_aware) {
struct zebra_l2info_vlan *vl;
if (!IS_ZEBRA_IF_VLAN(ifp))
return NULL;
zif = ifp->info;
assert(zif);
vl = &zif->l2info.vl;
vid = vl->vid;
}
/* See if this interface (or interface plus VLAN Id) maps to a VxLAN */
/* TODO: Optimize with a hash. */
zns = zebra_ns_lookup(NS_DEFAULT);
for (rn = route_top(zns->if_table); rn; rn = route_next(rn)) { for (rn = route_top(zns->if_table); rn; rn = route_next(rn)) {
tmp_if = (struct interface *)rn->info; tmp_if = (struct interface *)rn->info;
if (!tmp_if) if (!tmp_if)
@ -1854,19 +1825,68 @@ static struct zebra_l3vni *zl3vni_from_svi(struct interface *ifp,
continue; continue;
vxl = &zif->l2info.vxl; vxl = &zif->l2info.vxl;
if (zif->brslave_info.br_if != br_if) if (zif->brslave_info.br_if != in_param->br_if)
continue; continue;
if (!bridge_vlan_aware || vxl->access_vlan == vid) { if (!in_param->bridge_vlan_aware
|| vxl->access_vlan == in_param->vid) {
found = 1; found = 1;
break; break;
} }
} }
if (!found) if (!found)
return NS_WALK_CONTINUE;
if (p_zl3vni)
*p_zl3vni = zl3vni_lookup(vxl->vni);
return NS_WALK_STOP;
}
/*
* Map SVI and associated bridge to a VNI. This is invoked upon getting
* neighbor notifications, to see if they are of interest.
*/
static struct zebra_l3vni *zl3vni_from_svi(struct interface *ifp,
struct interface *br_if)
{
struct zebra_l3vni *zl3vni = NULL;
struct zebra_if *zif = NULL;
struct zebra_l2info_bridge *br = NULL;
struct zebra_from_svi_param in_param = {};
struct zebra_l3vni **p_zl3vni;
if (!br_if)
return NULL; return NULL;
zl3vni = zl3vni_lookup(vxl->vni); /* Make sure the linked interface is a bridge. */
if (!IS_ZEBRA_IF_BRIDGE(br_if))
return NULL;
in_param.br_if = br_if;
/* Determine if bridge is VLAN-aware or not */
zif = br_if->info;
assert(zif);
br = &zif->l2info.br;
in_param.bridge_vlan_aware = br->vlan_aware;
if (in_param.bridge_vlan_aware) {
struct zebra_l2info_vlan *vl;
if (!IS_ZEBRA_IF_VLAN(ifp))
return NULL;
zif = ifp->info;
assert(zif);
vl = &zif->l2info.vl;
in_param.vid = vl->vid;
}
/* See if this interface (or interface plus VLAN Id) maps to a VxLAN */
/* TODO: Optimize with a hash. */
p_zl3vni = &zl3vni;
ns_walk_func(zl3vni_from_svi_ns, (void *)&in_param, (void **)p_zl3vni);
return zl3vni; return zl3vni;
} }
@ -5023,6 +5043,13 @@ int zebra_vxlan_if_update(struct interface *ifp, uint16_t chgflags)
return 0; return 0;
} }
if ((chgflags & ZEBRA_VXLIF_MASTER_MAC_CHANGE)
&& if_is_operative(ifp) && is_l3vni_oper_up(zl3vni)) {
zebra_vxlan_process_l3vni_oper_down(zl3vni);
zebra_vxlan_process_l3vni_oper_up(zl3vni);
return 0;
}
/* access-vlan change - process oper down, associate with new /* access-vlan change - process oper down, associate with new
* svi_if and then process oper up again * svi_if and then process oper up again
*/ */

View File

@ -65,6 +65,7 @@ is_vxlan_flooding_head_end(void)
#define ZEBRA_VXLIF_MASTER_CHANGE (1 << 1) #define ZEBRA_VXLIF_MASTER_CHANGE (1 << 1)
#define ZEBRA_VXLIF_VLAN_CHANGE (1 << 2) #define ZEBRA_VXLIF_VLAN_CHANGE (1 << 2)
#define ZEBRA_VXLIF_MCAST_GRP_CHANGE (1 << 3) #define ZEBRA_VXLIF_MCAST_GRP_CHANGE (1 << 3)
#define ZEBRA_VXLIF_MASTER_MAC_CHANGE (1 << 4)
#define VNI_STR_LEN 32 #define VNI_STR_LEN 32