diff options
| author | Donald Sharp <sharpd@cumulusnetworks.com> | 2019-07-15 16:26:17 -0400 | 
|---|---|---|
| committer | Donald Sharp <sharpd@cumulusnetworks.com> | 2019-07-16 07:35:45 -0400 | 
| commit | 27da30442fbe5cd1358d231cbbf1265441f0e849 (patch) | |
| tree | 24372011e99a6978ff3429ed30f49467de3f3f98 /staticd/static_nht.c | |
| parent | 5f7faeb041c75c01641c6d8bb29617a014b6a8ac (diff) | |
staticd: Fix static_nht_update to actually know route we are installing
We are using static_nht_update in two different cases:
1) We have received a callback that a nexthop has changed and we need
to find any static route that is using it and we must refigure it.
2) We have received a new static route that depends on a pre-existing
nexthop, in which case we can go straight to the chase and just refigure
that particular node, since we already have all the information we need.
Signed-off-by: Donald Sharp <sharpd@cumulusnetworks.com>
Diffstat (limited to 'staticd/static_nht.c')
| -rw-r--r-- | staticd/static_nht.c | 76 | 
1 files changed, 48 insertions, 28 deletions
diff --git a/staticd/static_nht.c b/staticd/static_nht.c index 2aa0db59f1..8891ae3210 100644 --- a/staticd/static_nht.c +++ b/staticd/static_nht.c @@ -23,18 +23,47 @@  #include "table.h"  #include "vrf.h"  #include "nexthop.h" +#include "srcdest_table.h"  #include "static_vrf.h"  #include "static_routes.h"  #include "static_zebra.h"  #include "static_nht.h" -static void static_nht_update_safi(struct prefix *p, uint32_t nh_num, -				   afi_t afi, safi_t safi, struct vrf *vrf, -				   vrf_id_t nh_vrf_id) +static void static_nht_update_rn(struct route_node *rn, +				 struct prefix *nhp, uint32_t nh_num, +				 vrf_id_t nh_vrf_id, struct vrf *vrf, +				 safi_t safi)  { -	struct route_table *stable;  	struct static_route *si; + +	for (si = rn->info; si; si = si->next) { +		if (si->nh_vrf_id != nh_vrf_id) +			continue; + +		if (si->type != STATIC_IPV4_GATEWAY +		    && si->type != STATIC_IPV4_GATEWAY_IFNAME +		    && si->type != STATIC_IPV6_GATEWAY +		    && si->type != STATIC_IPV6_GATEWAY_IFNAME) +			continue; + +		if (nhp->family == AF_INET +		    && nhp->u.prefix4.s_addr == si->addr.ipv4.s_addr) +			si->nh_valid = !!nh_num; + +		if (nhp->family == AF_INET6 +		    && memcmp(&nhp->u.prefix6, &si->addr.ipv6, 16) == 0) +			si->nh_valid = !!nh_num; + +		static_zebra_route_add(rn, si, vrf->vrf_id, safi, true); +	} +} + +static void static_nht_update_safi(struct prefix *sp, struct prefix *nhp, +				   uint32_t nh_num, afi_t afi, safi_t safi, +				   struct vrf *vrf, vrf_id_t nh_vrf_id) +{ +	struct route_table *stable;  	struct static_vrf *svrf;  	struct route_node *rn; @@ -46,40 +75,31 @@ static void static_nht_update_safi(struct prefix *p, uint32_t nh_num,  	if (!stable)  		return; -	for (rn = route_top(stable); rn; rn = route_next(rn)) { -		for (si = rn->info; si; si = si->next) { -			if (si->nh_vrf_id != nh_vrf_id) -				continue; - -			if (si->type != STATIC_IPV4_GATEWAY -			    && si->type != STATIC_IPV4_GATEWAY_IFNAME -			    && si->type != STATIC_IPV6_GATEWAY -			    && si->type != STATIC_IPV6_GATEWAY_IFNAME) -				continue; - -			if (p->family == AF_INET -			    && p->u.prefix4.s_addr == si->addr.ipv4.s_addr) -				si->nh_valid = !!nh_num; - -			if (p->family == AF_INET6 -			    && memcmp(&p->u.prefix6, &si->addr.ipv6, 16) == 0) -				si->nh_valid = !!nh_num; - -			static_zebra_route_add(rn, si, vrf->vrf_id, safi, true); +	if (sp) { +		rn = srcdest_rnode_lookup(stable, sp, NULL); +		if (rn) { +			static_nht_update_rn(rn, nhp, nh_num, nh_vrf_id, +					     vrf, safi); +			route_unlock_node(rn);  		} +		return;  	} + +	for (rn = route_top(stable); rn; rn = route_next(rn)) +		static_nht_update_rn(rn, nhp, nh_num, nh_vrf_id, vrf, safi); +  } -void static_nht_update(struct prefix *p, uint32_t nh_num, afi_t afi, -		       vrf_id_t nh_vrf_id) +void static_nht_update(struct prefix *sp, struct prefix *nhp, +		       uint32_t nh_num, afi_t afi, vrf_id_t nh_vrf_id)  {  	struct vrf *vrf;  	RB_FOREACH (vrf, vrf_name_head, &vrfs_by_name) { -		static_nht_update_safi(p, nh_num, afi, SAFI_UNICAST, +		static_nht_update_safi(sp, nhp, nh_num, afi, SAFI_UNICAST,  				       vrf, nh_vrf_id); -		static_nht_update_safi(p, nh_num, afi, SAFI_MULTICAST, +		static_nht_update_safi(sp, nhp, nh_num, afi, SAFI_MULTICAST,  				       vrf, nh_vrf_id);  	}  }  | 
