Skip to content

Commit

Permalink
eigrpd, ospfd, pimd: Fix assumption that interface may not be up
Browse files Browse the repository at this point in the history
Commit: ddbf3e6

This commit modified the interface up handling code in
ZAPI such that the zclient handled the decoding for you.
Prior to this commit ospf assumed that it could use the
old ifp pointer to know state before reading the stream.
This lead to a situation where ospf would `smartly` track
and do the right thing in this situation.  This commit
changed this assumption and in certain scenarios, say
a interface was changed after it was already up would
lead to situations where ospf would not properly handle
the new interface up.

Modify ospf to track data that is important to it in
it's interface->info pointer.

This code pattern was followed in both eigrp and pim.
In eigrp's case it was just behaving weirdly in any event
so fixing this pattern is not a big deal.  In pim's
case it was not properly using this so it's a no-op
to fix.

Signed-off-by: Donald Sharp <sharpd@cumulusnetworks.com>
  • Loading branch information
donaldsharp committed Dec 4, 2019
1 parent c84355a commit 85d2558
Show file tree
Hide file tree
Showing 5 changed files with 67 additions and 66 deletions.
60 changes: 29 additions & 31 deletions eigrpd/eigrp_interface.c
Original file line number Diff line number Diff line change
Expand Up @@ -99,6 +99,9 @@ struct eigrp_interface *eigrp_if_new(struct eigrp *eigrp, struct interface *ifp,
ei->params.auth_type = EIGRP_AUTH_TYPE_NONE;
ei->params.auth_keychain = NULL;

ei->curr_bandwidth = ifp->bandwidth;
ei->curr_mtu = ifp->mtu;

return ei;
}

Expand Down Expand Up @@ -139,45 +142,40 @@ static int eigrp_ifp_create(struct interface *ifp)

static int eigrp_ifp_up(struct interface *ifp)
{
/* Interface is already up. */
if (if_is_operative(ifp)) {
/* Temporarily keep ifp values. */
struct interface if_tmp;
memcpy(&if_tmp, ifp, sizeof(struct interface));
struct eigrp_interface *ei = ifp->info;

if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
zlog_debug("Zebra: Interface[%s] state update.",
ifp->name);
if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
zlog_debug("Zebra: Interface[%s] state change to up.",
ifp->name);

if (if_tmp.bandwidth != ifp->bandwidth) {
if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
zlog_debug(
"Zebra: Interface[%s] bandwidth change %d -> %d.",
ifp->name, if_tmp.bandwidth,
ifp->bandwidth);
if (!ei)
return 0;

// eigrp_if_recalculate_output_cost (ifp);
}
if (ei->curr_bandwidth != ifp->bandwidth) {
if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
zlog_debug(
"Zebra: Interface[%s] bandwidth change %d -> %d.",
ifp->name, ei->curr_bandwidth,
ifp->bandwidth);

if (if_tmp.mtu != ifp->mtu) {
if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
zlog_debug(
"Zebra: Interface[%s] MTU change %u -> %u.",
ifp->name, if_tmp.mtu, ifp->mtu);
ei->curr_bandwidth = ifp->bandwidth;
// eigrp_if_recalculate_output_cost (ifp);
}

/* Must reset the interface (simulate down/up) when MTU
* changes. */
eigrp_if_reset(ifp);
}
if (ei->curr_mtu != ifp->mtu) {
if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
zlog_debug(
"Zebra: Interface[%s] MTU change %u -> %u.",
ifp->name, ei->curr_mtu, ifp->mtu);

ei->curr_mtu = ifp->mtu;
/* Must reset the interface (simulate down/up) when MTU
* changes. */
eigrp_if_reset(ifp);
return 0;
}

if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
zlog_debug("Zebra: Interface[%s] state change to up.",
ifp->name);

if (ifp->info)
eigrp_if_up(ifp->info);
eigrp_if_up(ifp->info);

return 0;
}
Expand Down
2 changes: 2 additions & 0 deletions eigrpd/eigrp_structs.h
Original file line number Diff line number Diff line change
Expand Up @@ -176,6 +176,8 @@ struct eigrp_interface {

/* To which multicast groups do we currently belong? */

uint32_t curr_bandwidth;
uint32_t curr_mtu;

uint8_t multicast_memberships;

Expand Down
32 changes: 13 additions & 19 deletions ospfd/ospf_interface.c
Original file line number Diff line number Diff line change
Expand Up @@ -636,9 +636,13 @@ void ospf_if_update_params(struct interface *ifp, struct in_addr addr)
int ospf_if_new_hook(struct interface *ifp)
{
int rc = 0;
struct ospf_if_info *oii;

ifp->info = XCALLOC(MTYPE_OSPF_IF_INFO, sizeof(struct ospf_if_info));

oii = ifp->info;
oii->curr_mtu = ifp->mtu;

IF_OIFS(ifp) = route_table_init();
IF_OIFS_PARAMS(ifp) = route_table_init();

Expand Down Expand Up @@ -1261,31 +1265,21 @@ static int ospf_ifp_up(struct interface *ifp)
{
struct ospf_interface *oi;
struct route_node *rn;
struct ospf_if_info *oii = ifp->info;

/* Interface is already up. */
if (if_is_operative(ifp)) {
/* Temporarily keep ifp values. */
struct interface if_tmp;
memcpy(&if_tmp, ifp, sizeof(struct interface));
ospf_if_recalculate_output_cost(ifp);

if (oii && oii->curr_mtu != ifp->mtu) {
if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE))
zlog_debug(
"Zebra: Interface[%s] state update speed %u -> %u, bw %d -> %d",
ifp->name, if_tmp.speed, ifp->speed,
if_tmp.bandwidth, ifp->bandwidth);
"Zebra: Interface[%s] MTU change %u -> %u.",
ifp->name, oii->curr_mtu, ifp->mtu);

ospf_if_recalculate_output_cost(ifp);
oii->curr_mtu = ifp->mtu;
/* Must reset the interface (simulate down/up) when MTU
* changes. */
ospf_if_reset(ifp);

if (if_tmp.mtu != ifp->mtu) {
if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE))
zlog_debug(
"Zebra: Interface[%s] MTU change %u -> %u.",
ifp->name, if_tmp.mtu, ifp->mtu);

/* Must reset the interface (simulate down/up) when MTU
* changes. */
ospf_if_reset(ifp);
}
return 0;
}

Expand Down
2 changes: 2 additions & 0 deletions ospfd/ospf_interface.h
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,8 @@ struct ospf_if_info {
struct route_table *oifs;
unsigned int
membership_counts[MEMBER_MAX]; /* multicast group refcnts */

uint32_t curr_mtu;
};

struct ospf_interface;
Expand Down
37 changes: 21 additions & 16 deletions pimd/pim_iface.c
Original file line number Diff line number Diff line change
Expand Up @@ -1481,6 +1481,13 @@ void pim_if_create_pimreg(struct pim_instance *pim)

pim_if_new(pim->regiface, false, false, true,
false /*vxlan_term*/);
/*
* On vrf moves we delete the interface if there
* is nothing going on with it. We cannot have
* the pimregiface deleted.
*/
pim->regiface->configured = true;

}
}

Expand Down Expand Up @@ -1581,6 +1588,7 @@ int pim_ifp_create(struct interface *ifp)

int pim_ifp_up(struct interface *ifp)
{
struct pim_interface *pim_ifp;
struct pim_instance *pim;
uint32_t table_id;

Expand All @@ -1593,24 +1601,21 @@ int pim_ifp_up(struct interface *ifp)
}

pim = pim_get_pim_instance(ifp->vrf_id);
if (if_is_operative(ifp)) {
struct pim_interface *pim_ifp;

pim_ifp = ifp->info;
/*
* If we have a pim_ifp already and this is an if_add
* that means that we probably have a vrf move event
* If that is the case, set the proper vrfness.
*/
if (pim_ifp)
pim_ifp->pim = pim;
pim_ifp = ifp->info;
/*
* If we have a pim_ifp already and this is an if_add
* that means that we probably have a vrf move event
* If that is the case, set the proper vrfness.
*/
if (pim_ifp)
pim_ifp->pim = pim;

/*
pim_if_addr_add_all() suffices for bringing up both IGMP and
PIM
*/
pim_if_addr_add_all(ifp);
}
/*
pim_if_addr_add_all() suffices for bringing up both IGMP and
PIM
*/
pim_if_addr_add_all(ifp);

/*
* If we have a pimreg device callback and it's for a specific
Expand Down

0 comments on commit 85d2558

Please sign in to comment.