ospf6d: Review comment fixes

This commit is ease reviewing the review comment fixes.

Signed:-off-by: Mobashshera Rasool <mrasool@vmware.com>
This commit is contained in:
Mobashshera Rasool 2021-07-14 17:55:43 +00:00
parent 8440558257
commit 789828186e
3 changed files with 213 additions and 201 deletions

View File

@ -1328,22 +1328,21 @@ ospf6_external_aggr_match(struct ospf6 *ospf6, struct prefix *p)
{ {
struct route_node *node; struct route_node *node;
node = route_node_match(ospf6->rt_aggr_tbl, (struct prefix *)p); node = route_node_match(ospf6->rt_aggr_tbl, p);
if (node) { if (node == NULL)
return NULL;
if (IS_OSPF6_DEBUG_AGGR) { if (IS_OSPF6_DEBUG_AGGR) {
if (node->info) { struct ospf6_external_aggr_rt *ag = node->info;
struct ospf6_external_aggr_rt *ag = node->info; zlog_debug("%s: Matching aggregator found.prefix: %pFX Aggregator %pFX",
zlog_debug("%s: Matching aggregator found.prefix: %pFX Aggregator %pFX", __func__,
__func__, p,
p, &ag->p);
&ag->p);
}
}
route_unlock_node(node);
return node->info;
} }
return NULL;
route_unlock_node(node);
return node->info;
} }
void ospf6_asbr_redistribute_add(int type, ifindex_t ifindex, void ospf6_asbr_redistribute_add(int type, ifindex_t ifindex,
@ -2809,8 +2808,8 @@ ospf6_aggr_handle_advertise_change(struct ospf6 *ospf6,
static void static void
ospf6_originate_summary_lsa(struct ospf6 *ospf6, ospf6_originate_summary_lsa(struct ospf6 *ospf6,
struct ospf6_external_aggr_rt *aggr, struct ospf6_external_aggr_rt *aggr,
struct ospf6_route *rt) struct ospf6_route *rt)
{ {
struct ospf6_lsa *lsa = NULL, *aggr_lsa = NULL; struct ospf6_lsa *lsa = NULL, *aggr_lsa = NULL;
struct ospf6_external_info *info = NULL; struct ospf6_external_info *info = NULL;
@ -2942,8 +2941,7 @@ ospf6_originate_summary_lsa(struct ospf6 *ospf6,
* then it need to be refreshed and originate bit should * then it need to be refreshed and originate bit should
* be set. * be set.
*/ */
if (lsa && prefix_same((struct prefix *)&aggr->p, if (lsa && prefix_same(&aggr->p, &rt->prefix)) {
(struct prefix *)&rt->prefix)) {
if (IS_OSPF6_DEBUG_AGGR) if (IS_OSPF6_DEBUG_AGGR)
zlog_debug("%s: External route prefix is same as aggr so refreshing LSA(%pFX)", zlog_debug("%s: External route prefix is same as aggr so refreshing LSA(%pFX)",
__PRETTY_FUNCTION__, __PRETTY_FUNCTION__,
@ -3034,21 +3032,77 @@ ospf6_asbr_summary_config_delete(struct ospf6 *ospf6, struct route_node *rn)
route_unlock_node(rn); route_unlock_node(rn);
} }
static int
ospf6_handle_external_aggr_modify(struct ospf6 *ospf6,
struct ospf6_external_aggr_rt *aggr)
{
struct ospf6_lsa *lsa = NULL;
struct ospf6_as_external_lsa *asel = NULL;
struct ospf6_route *rt_aggr;
unsigned int metric = 0;
route_tag_t tag = 0;
int mtype;
lsa = ospf6_lsdb_lookup(
htons(OSPF6_LSTYPE_AS_EXTERNAL),
htonl(aggr->id), ospf6->router_id,
ospf6->lsdb);
if (!lsa) {
zlog_warn(
"%s: Could not refresh/originate %pFX",
__func__,
&aggr->p);
return OSPF6_FAILURE;
}
asel = (struct ospf6_as_external_lsa *)
OSPF6_LSA_HEADER_END(lsa->header);
metric = (unsigned long)OSPF6_ASBR_METRIC(asel);
tag = ospf6_as_external_lsa_get_tag(lsa);
mtype = CHECK_FLAG(asel->bits_metric,
OSPF6_ASBR_BIT_E) ? 2 : 1;
/* Fill all the details for advertisement */
ospf6_fill_aggr_route_details(ospf6, aggr);
rt_aggr = aggr->route;
/* If tag/metric/metric-type modified , then
* re-originate the route with modified
* tag/metric/metric-type details.
*/
if ((tag != aggr->tag)
|| (metric
!= (unsigned int)rt_aggr->path.cost)
|| (mtype
!= aggr->mtype)) {
if (IS_OSPF6_DEBUG_AGGR)
zlog_debug(
"%s: Changed tag(old:%d new:%d)/metric(o:%u n:%d)/mtype(o:%d n:%d),So refresh the summary route.(%pFX)",
__func__, tag,
aggr->tag,
metric,
(unsigned int)rt_aggr->path.cost,
mtype, aggr->mtype,
&aggr->p);
(void)ospf6_originate_type5_type7_lsas(
aggr->route,
ospf6);
}
return OSPF6_SUCCESS;
}
static void ospf6_handle_external_aggr_update(struct ospf6 *ospf6) static void ospf6_handle_external_aggr_update(struct ospf6 *ospf6)
{ {
struct route_node *rn = NULL; struct route_node *rn = NULL;
unsigned int metric = 0; int ret;
int mtype;
if (IS_OSPF6_DEBUG_AGGR) if (IS_OSPF6_DEBUG_AGGR)
zlog_debug("%s: Process modified aggregators.", __func__); zlog_debug("%s: Process modified aggregators.", __func__);
for (rn = route_top(ospf6->rt_aggr_tbl); rn; rn = route_next(rn)) { for (rn = route_top(ospf6->rt_aggr_tbl); rn; rn = route_next(rn)) {
struct ospf6_external_aggr_rt *aggr; struct ospf6_external_aggr_rt *aggr;
struct ospf6_lsa *lsa = NULL;
struct ospf6_as_external_lsa *asel = NULL;
struct ospf6_route *rt_aggr;
route_tag_t tag = 0;
if (!rn->info) if (!rn->info)
continue; continue;
@ -3061,7 +3115,7 @@ static void ospf6_handle_external_aggr_update(struct ospf6 *ospf6)
if (OSPF6_EXTERNAL_RT_COUNT(aggr)) if (OSPF6_EXTERNAL_RT_COUNT(aggr))
hash_clean(aggr->match_extnl_hash, hash_clean(aggr->match_extnl_hash,
(void *)ospf6_aggr_handle_external_info); ospf6_aggr_handle_external_info);
hash_free(aggr->match_extnl_hash); hash_free(aggr->match_extnl_hash);
XFREE(MTYPE_OSPF6_EXTERNAL_RT_AGGR, aggr); XFREE(MTYPE_OSPF6_EXTERNAL_RT_AGGR, aggr);
@ -3076,52 +3130,10 @@ static void ospf6_handle_external_aggr_update(struct ospf6 *ospf6)
&& !CHECK_FLAG(aggr->aggrflags, && !CHECK_FLAG(aggr->aggrflags,
OSPF6_EXTERNAL_AGGRT_NO_ADVERTISE)) { OSPF6_EXTERNAL_AGGRT_NO_ADVERTISE)) {
lsa = ospf6_lsdb_lookup( ret = ospf6_handle_external_aggr_modify(ospf6,
htons(OSPF6_LSTYPE_AS_EXTERNAL), aggr);
htonl(aggr->id), ospf6->router_id, if (ret == OSPF6_FAILURE)
ospf6->lsdb);
if (!lsa) {
zlog_warn(
"%s: Could not refresh/originate %pFX",
__func__,
&aggr->p);
continue; continue;
}
asel = (struct ospf6_as_external_lsa *)
OSPF6_LSA_HEADER_END(lsa->header);
metric = (unsigned long)OSPF6_ASBR_METRIC(asel);
tag = ospf6_as_external_lsa_get_tag(lsa);
mtype = CHECK_FLAG(asel->bits_metric,
OSPF6_ASBR_BIT_E) ? 2 : 1;
/* Fill all the details for advertisement */
ospf6_fill_aggr_route_details(ospf6, aggr);
rt_aggr = aggr->route;
/* If tag/metric/metric-type modified , then
* re-originate the route with modified
* tag/metric/metric-type details.
*/
if ((tag != aggr->tag)
|| (metric
!= (unsigned int)rt_aggr->path.cost)
|| (mtype
!= aggr->mtype)) {
if (IS_OSPF6_DEBUG_AGGR)
zlog_debug(
"%s: Changed tag(old:%d new:%d)/metric(o:%u n:%d)/mtype(o:%d n:%d),So refresh the summary route.(%pFX)",
__func__, tag,
aggr->tag,
metric,
(unsigned int)rt_aggr->path.cost,
mtype, aggr->mtype,
&aggr->p);
(void)ospf6_originate_type5_type7_lsas(
aggr->route,
ospf6);
}
} }
/* Advertise option modified ? /* Advertise option modified ?
@ -3145,7 +3157,7 @@ void ospf6_external_aggregator_free(struct ospf6_external_aggr_rt *aggr)
{ {
if (OSPF6_EXTERNAL_RT_COUNT(aggr)) if (OSPF6_EXTERNAL_RT_COUNT(aggr))
hash_clean(aggr->match_extnl_hash, hash_clean(aggr->match_extnl_hash,
(void *)ospf6_aggr_unlink_external_info); ospf6_aggr_unlink_external_info);
if (IS_OSPF6_DEBUG_AGGR) if (IS_OSPF6_DEBUG_AGGR)
zlog_debug("%s: Release the aggregator Address(%pFX)", zlog_debug("%s: Release the aggregator Address(%pFX)",
@ -3168,17 +3180,19 @@ ospf6_delete_all_marked_aggregators(struct ospf6 *ospf6)
* which are marked as DELETE. Set action to NONE for remaining * which are marked as DELETE. Set action to NONE for remaining
* aggregators * aggregators
*/ */
for (rn = route_top(ospf6->rt_aggr_tbl); rn; rn = route_next(rn)) for (rn = route_top(ospf6->rt_aggr_tbl); rn; rn = route_next(rn)) {
if (rn->info) { if (!rn->info)
aggr = rn->info; continue;
if (aggr->action != OSPF6_ROUTE_AGGR_DEL) { aggr = rn->info;
aggr->action = OSPF6_ROUTE_AGGR_NONE;
continue; if (aggr->action != OSPF6_ROUTE_AGGR_DEL) {
} aggr->action = OSPF6_ROUTE_AGGR_NONE;
ospf6_asbr_summary_config_delete(ospf6, rn); continue;
ospf6_external_aggregator_free(aggr);
} }
ospf6_asbr_summary_config_delete(ospf6, rn);
ospf6_external_aggregator_free(aggr);
}
} }
static void ospf6_handle_exnl_rt_after_aggr_del(struct ospf6 *ospf6, static void ospf6_handle_exnl_rt_after_aggr_del(struct ospf6 *ospf6,
@ -3223,8 +3237,7 @@ static void ospf6_handle_aggregated_exnl_rt(struct ospf6 *ospf6,
* and aggegate prefix is same * and aggegate prefix is same
* If same dont flush the originated external LSA. * If same dont flush the originated external LSA.
*/ */
if (prefix_same((struct prefix *)&aggr->p, if (prefix_same(&aggr->p, &rt->prefix)) {
(struct prefix *)&rt->prefix)) {
if (IS_OSPF6_DEBUG_AGGR) if (IS_OSPF6_DEBUG_AGGR)
zlog_debug("%s: External Route prefix same as Aggregator(%pFX), so dont flush.", zlog_debug("%s: External Route prefix same as Aggregator(%pFX), so dont flush.",
__func__, __func__,
@ -3269,38 +3282,39 @@ ospf6_handle_external_aggr_add(struct ospf6 *ospf6)
for (rt = ospf6_route_head(ospf6->external_table); rt; for (rt = ospf6_route_head(ospf6->external_table); rt;
rt = ospf6_route_next(rt)) { rt = ospf6_route_next(rt)) {
ei = rt->route_option; ei = rt->route_option;
if (ei != NULL) { if (ei == NULL)
if (is_default_prefix(&rt->prefix)) continue;
continue;
aggr = ospf6_external_aggr_match(ospf6, if (is_default_prefix(&rt->prefix))
&rt->prefix); continue;
/* If matching aggregator found, Add aggr = ospf6_external_aggr_match(ospf6,
* the external route refrenace to the &rt->prefix);
* aggregator and originate the aggr
* route if it is advertisable. /* If matching aggregator found, Add
* flush the external LSA if it is * the external route refrenace to the
* already originated for this external * aggregator and originate the aggr
* prefix. * route if it is advertisable.
* flush the external LSA if it is
* already originated for this external
* prefix.
*/
if (aggr) {
ospf6_originate_summary_lsa(ospf6, aggr, rt);
/* All aggregated external rts
* are handled here.
*/ */
if (aggr) { ospf6_handle_aggregated_exnl_rt(
ospf6_originate_summary_lsa(ospf6, aggr, rt); ospf6, aggr, rt);
continue;
/* All aggregated external rts
* are handled here.
*/
ospf6_handle_aggregated_exnl_rt(
ospf6, aggr, rt);
continue;
}
/* External routes which are only out
* of aggregation will be handled here.
*/
ospf6_handle_exnl_rt_after_aggr_del(
ospf6, rt);
} }
/* External routes which are only out
* of aggregation will be handled here.
*/
ospf6_handle_exnl_rt_after_aggr_del(
ospf6, rt);
} }
} }
@ -3373,7 +3387,7 @@ int ospf6_asbr_external_rt_advertise(struct ospf6 *ospf6,
struct route_node *rn; struct route_node *rn;
struct ospf6_external_aggr_rt *aggr; struct ospf6_external_aggr_rt *aggr;
rn = route_node_lookup(ospf6->rt_aggr_tbl, (struct prefix *)p); rn = route_node_lookup(ospf6->rt_aggr_tbl, p);
if (!rn) if (!rn)
return OSPF6_INVALID; return OSPF6_INVALID;
@ -3417,8 +3431,7 @@ static bool ospf6_external_rt_hash_cmp(const void *d1, const void *d2)
const struct ospf6_route *rt1 = d1; const struct ospf6_route *rt1 = d1;
const struct ospf6_route *rt2 = d2; const struct ospf6_route *rt2 = d2;
return prefix_same((struct prefix *)&rt1->prefix, return prefix_same(&rt1->prefix, &rt2->prefix);
(struct prefix *)&rt2->prefix);
} }
static struct ospf6_external_aggr_rt * static struct ospf6_external_aggr_rt *
@ -3426,16 +3439,10 @@ ospf6_external_aggr_new(struct prefix *p)
{ {
struct ospf6_external_aggr_rt *aggr; struct ospf6_external_aggr_rt *aggr;
aggr = (struct ospf6_external_aggr_rt *)XCALLOC( aggr = XCALLOC(MTYPE_OSPF6_EXTERNAL_RT_AGGR,
MTYPE_OSPF6_EXTERNAL_RT_AGGR, sizeof(struct ospf6_external_aggr_rt));
sizeof(struct ospf6_external_aggr_rt));
if (!aggr)
return NULL;
aggr->p.family = p->family;
prefix_copy(&aggr->p, p); prefix_copy(&aggr->p, p);
aggr->p.prefixlen = p->prefixlen;
aggr->metric = -1; aggr->metric = -1;
aggr->mtype = DEFAULT_METRIC_TYPE; aggr->mtype = DEFAULT_METRIC_TYPE;
aggr->match_extnl_hash = hash_create(ospf6_external_rt_hash_key, aggr->match_extnl_hash = hash_create(ospf6_external_rt_hash_key,
@ -3454,7 +3461,7 @@ static void ospf6_external_aggr_add(struct ospf6 *ospf6,
__func__, __func__,
&aggr->p); &aggr->p);
rn = route_node_get(ospf6->rt_aggr_tbl, (struct prefix *)&aggr->p); rn = route_node_get(ospf6->rt_aggr_tbl, &aggr->p);
if (rn->info) if (rn->info)
route_unlock_node(rn); route_unlock_node(rn);
else else
@ -3503,7 +3510,7 @@ ospf6_external_aggr_config_lookup(struct ospf6 *ospf6, struct prefix *p)
{ {
struct route_node *rn; struct route_node *rn;
rn = route_node_lookup(ospf6->rt_aggr_tbl, (struct prefix *)p); rn = route_node_lookup(ospf6->rt_aggr_tbl, p);
if (rn) { if (rn) {
route_unlock_node(rn); route_unlock_node(rn);
return rn->info; return rn->info;
@ -3559,7 +3566,7 @@ int ospf6_external_aggr_config_unset(struct ospf6 *ospf6,
struct route_node *rn; struct route_node *rn;
struct ospf6_external_aggr_rt *aggr; struct ospf6_external_aggr_rt *aggr;
rn = route_node_lookup(ospf6->rt_aggr_tbl, (struct prefix *)p); rn = route_node_lookup(ospf6->rt_aggr_tbl, p);
if (!rn) if (!rn)
return OSPF6_INVALID; return OSPF6_INVALID;

View File

@ -209,7 +209,7 @@ struct ospf6_lsa *ospf6_find_external_lsa(struct ospf6 *ospf6, struct prefix *p)
return NULL; return NULL;
} }
info = (struct ospf6_external_info *)(match->route_option); info = match->route_option;
assert(info); assert(info);
lsa = ospf6_lsdb_lookup(htons(OSPF6_LSTYPE_AS_EXTERNAL), lsa = ospf6_lsdb_lookup(htons(OSPF6_LSTYPE_AS_EXTERNAL),

View File

@ -1929,7 +1929,7 @@ ospf6_print_json_external_routes_walkcb(struct hash_bucket *bucket, void *arg)
prefix2str(&rt->prefix, buf, sizeof(buf)); prefix2str(&rt->prefix, buf, sizeof(buf));
snprintf(exnalbuf, 20, "Exnl Addr-%d", count); snprintf(exnalbuf, sizeof(exnalbuf), "Exnl Addr-%d", count);
json_object_string_add(json, exnalbuf, buf); json_object_string_add(json, exnalbuf, buf);
@ -1958,81 +1958,83 @@ ospf6_show_summary_address(struct vty *vty, struct ospf6 *ospf6,
ospf6->aggr_delay_interval); ospf6->aggr_delay_interval);
} }
for (rn = route_top(ospf6->rt_aggr_tbl); rn; rn = route_next(rn)) for (rn = route_top(ospf6->rt_aggr_tbl); rn; rn = route_next(rn)) {
if (rn->info) { if (!rn->info)
struct ospf6_external_aggr_rt *aggr = rn->info; continue;
json_object *json_aggr = NULL;
char buf[PREFIX2STR_BUFFER];
prefix2str(&aggr->p, buf, sizeof(buf)); struct ospf6_external_aggr_rt *aggr = rn->info;
json_object *json_aggr = NULL;
char buf[PREFIX2STR_BUFFER];
if (uj) { prefix2str(&aggr->p, buf, sizeof(buf));
json_aggr = json_object_new_object(); if (uj) {
json_object_object_add(json, json_aggr = json_object_new_object();
buf,
json_aggr);
json_object_string_add(json_aggr, json_object_object_add(json,
"Summary address", buf,
buf); json_aggr);
json_object_string_add( json_object_string_add(json_aggr,
json_aggr, "Metric-type", "Summary address",
(aggr->mtype == DEFAULT_METRIC_TYPE) buf);
? "E2"
: "E1");
json_object_int_add(json_aggr, "Metric",
(aggr->metric != -1)
? aggr->metric
: DEFAULT_DEFAULT_METRIC);
json_object_int_add(json_aggr, "Tag",
aggr->tag);
json_object_int_add(json_aggr,
"External route count",
OSPF6_EXTERNAL_RT_COUNT(aggr));
if (OSPF6_EXTERNAL_RT_COUNT(aggr) && detail) {
json_object_int_add(json_aggr, "ID",
aggr->id);
json_object_int_add(json_aggr, "Flags",
aggr->aggrflags);
hash_walk(aggr->match_extnl_hash,
ospf6_print_json_external_routes_walkcb,
json_aggr);
}
} else {
vty_out(vty, "%-22s", buf);
json_object_string_add(
json_aggr, "Metric-type",
(aggr->mtype == DEFAULT_METRIC_TYPE) (aggr->mtype == DEFAULT_METRIC_TYPE)
? vty_out(vty, "%-16s", "E2") ? "E2"
: vty_out(vty, "%-16s", "E1"); : "E1");
vty_out(vty, "%-11d", (aggr->metric != -1)
? aggr->metric
: DEFAULT_DEFAULT_METRIC);
vty_out(vty, "%-12u", aggr->tag); json_object_int_add(json_aggr, "Metric",
(aggr->metric != -1)
? aggr->metric
: DEFAULT_DEFAULT_METRIC);
vty_out(vty, "%-5ld\n", json_object_int_add(json_aggr, "Tag",
aggr->tag);
json_object_int_add(json_aggr,
"External route count",
OSPF6_EXTERNAL_RT_COUNT(aggr)); OSPF6_EXTERNAL_RT_COUNT(aggr));
if (OSPF6_EXTERNAL_RT_COUNT(aggr) && detail) { if (OSPF6_EXTERNAL_RT_COUNT(aggr) && detail) {
vty_out(vty, json_object_int_add(json_aggr, "ID",
"Matched External routes:\n"); aggr->id);
hash_walk(aggr->match_extnl_hash, json_object_int_add(json_aggr, "Flags",
ospf6_print_vty_external_routes_walkcb, aggr->aggrflags);
vty); hash_walk(aggr->match_extnl_hash,
vty_out(vty, "\n"); ospf6_print_json_external_routes_walkcb,
} json_aggr);
}
} else {
vty_out(vty, "%-22s", buf);
(aggr->mtype == DEFAULT_METRIC_TYPE)
? vty_out(vty, "%-16s", "E2")
: vty_out(vty, "%-16s", "E1");
vty_out(vty, "%-11d", (aggr->metric != -1)
? aggr->metric
: DEFAULT_DEFAULT_METRIC);
vty_out(vty, "%-12u", aggr->tag);
vty_out(vty, "%-5ld\n",
OSPF6_EXTERNAL_RT_COUNT(aggr));
if (OSPF6_EXTERNAL_RT_COUNT(aggr) && detail) {
vty_out(vty,
"Matched External routes:\n");
hash_walk(aggr->match_extnl_hash,
ospf6_print_vty_external_routes_walkcb,
vty);
vty_out(vty, "\n"); vty_out(vty, "\n");
} }
vty_out(vty, "\n");
} }
}
return CMD_SUCCESS; return CMD_SUCCESS;
} }
@ -2129,26 +2131,29 @@ static int ospf6_asbr_summary_config_write(struct vty *vty, struct ospf6 *ospf6)
ospf6->aggr_delay_interval); ospf6->aggr_delay_interval);
/* print 'summary-address A:B::C:D/M' */ /* print 'summary-address A:B::C:D/M' */
for (rn = route_top(ospf6->rt_aggr_tbl); rn; rn = route_next(rn)) for (rn = route_top(ospf6->rt_aggr_tbl); rn; rn = route_next(rn)) {
if (rn->info) { if (!rn->info)
aggr = rn->info; continue;
prefix2str(&aggr->p, buf, sizeof(buf));
vty_out(vty, " summary-address %s ", buf);
if (aggr->tag)
vty_out(vty, " tag %u ", aggr->tag);
if (aggr->metric != -1) aggr = rn->info;
vty_out(vty, " metric %d ", aggr->metric);
if (aggr->mtype != DEFAULT_METRIC_TYPE) prefix2str(&aggr->p, buf, sizeof(buf));
vty_out(vty, " metric-type %d ", aggr->mtype); vty_out(vty, " summary-address %s", buf);
if (aggr->tag)
vty_out(vty, " tag %u", aggr->tag);
if (CHECK_FLAG(aggr->aggrflags, if (aggr->metric != -1)
OSPF6_EXTERNAL_AGGRT_NO_ADVERTISE)) vty_out(vty, " metric %d", aggr->metric);
vty_out(vty, " no-advertise");
vty_out(vty, "\n"); if (aggr->mtype != DEFAULT_METRIC_TYPE)
} vty_out(vty, " metric-type %d", aggr->mtype);
if (CHECK_FLAG(aggr->aggrflags,
OSPF6_EXTERNAL_AGGRT_NO_ADVERTISE))
vty_out(vty, " no-advertise");
vty_out(vty, "\n");
}
return 0; return 0;
} }