#include "zebra/interface.h"
#include "zebra/zebra_memory.h"
-static void free_state(vrf_id_t vrf_id, struct route_entry *re, struct route_node *rn);
+static void free_state(vrf_id_t vrf_id, struct route_entry *re,
+ struct route_node *rn);
static void copy_state(struct rnh *rnh, struct route_entry *re,
struct route_node *rn);
-#define lookup_rnh_table(v, f) \
-({ \
- struct zebra_vrf *zvrf; \
- struct route_table *t = NULL; \
- zvrf = zebra_vrf_lookup_by_id(v); \
- if (zvrf) \
- t = zvrf->rnh_table[family2afi(f)]; \
- t; \
-})
+#define lookup_rnh_table(v, f) \
+ ({ \
+ struct zebra_vrf *zvrf; \
+ struct route_table *t = NULL; \
+ zvrf = zebra_vrf_lookup_by_id(v); \
+ if (zvrf) \
+ t = zvrf->rnh_table[family2afi(f)]; \
+ t; \
+ })
static int compare_state(struct route_entry *r1, struct route_entry *r2);
static int send_client(struct rnh *rnh, struct zserv *client, rnh_type_t type,
- vrf_id_t vrf_id);
+ vrf_id_t vrf_id);
static void print_rnh(struct route_node *rn, struct vty *vty);
int zebra_rnh_ip_default_route = 0;
static inline struct route_table *get_rnh_table(vrf_id_t vrfid, int family,
rnh_type_t type)
{
- struct zebra_vrf *zvrf;
- struct route_table *t = NULL;
-
- zvrf = zebra_vrf_lookup_by_id(vrfid);
- if (zvrf)
- switch (type)
- {
- case RNH_NEXTHOP_TYPE:
- t = zvrf->rnh_table[family2afi(family)];
- break;
- case RNH_IMPORT_CHECK_TYPE:
- t = zvrf->import_check_table[family2afi(family)];
- break;
- }
-
- return t;
+ struct zebra_vrf *zvrf;
+ struct route_table *t = NULL;
+
+ zvrf = zebra_vrf_lookup_by_id(vrfid);
+ if (zvrf)
+ switch (type) {
+ case RNH_NEXTHOP_TYPE:
+ t = zvrf->rnh_table[family2afi(family)];
+ break;
+ case RNH_IMPORT_CHECK_TYPE:
+ t = zvrf->import_check_table[family2afi(family)];
+ break;
+ }
+
+ return t;
}
-char *rnh_str (struct rnh *rnh, char *buf, int size)
+char *rnh_str(struct rnh *rnh, char *buf, int size)
{
- prefix2str(&(rnh->node->p), buf, size);
- return buf;
+ prefix2str(&(rnh->node->p), buf, size);
+ return buf;
}
-struct rnh *
-zebra_add_rnh (struct prefix *p, vrf_id_t vrfid, rnh_type_t type)
+struct rnh *zebra_add_rnh(struct prefix *p, vrf_id_t vrfid, rnh_type_t type)
{
- struct route_table *table;
- struct route_node *rn;
- struct rnh *rnh = NULL;
- char buf[PREFIX2STR_BUFFER];
-
- if (IS_ZEBRA_DEBUG_NHT)
- {
- prefix2str(p, buf, sizeof (buf));
- zlog_debug("%u: Add RNH %s type %d", vrfid, buf, type);
- }
- table = get_rnh_table(vrfid, PREFIX_FAMILY(p), type);
- if (!table)
- {
- prefix2str(p, buf, sizeof (buf));
- zlog_warn("%u: Add RNH %s type %d - table not found",
- vrfid, buf, type);
- return NULL;
- }
-
- /* Make it sure prefixlen is applied to the prefix. */
- apply_mask (p);
-
- /* Lookup (or add) route node.*/
- rn = route_node_get (table, p);
-
- if (!rn->info)
- {
- rnh = XCALLOC(MTYPE_RNH, sizeof(struct rnh));
- rnh->client_list = list_new();
- rnh->vrf_id = vrfid;
- rnh->zebra_static_route_list = list_new();
- route_lock_node (rn);
- rn->info = rnh;
- rnh->node = rn;
- }
-
- route_unlock_node (rn);
- return (rn->info);
+ struct route_table *table;
+ struct route_node *rn;
+ struct rnh *rnh = NULL;
+ char buf[PREFIX2STR_BUFFER];
+
+ if (IS_ZEBRA_DEBUG_NHT) {
+ prefix2str(p, buf, sizeof(buf));
+ zlog_debug("%u: Add RNH %s type %d", vrfid, buf, type);
+ }
+ table = get_rnh_table(vrfid, PREFIX_FAMILY(p), type);
+ if (!table) {
+ prefix2str(p, buf, sizeof(buf));
+ zlog_warn("%u: Add RNH %s type %d - table not found", vrfid,
+ buf, type);
+ return NULL;
+ }
+
+ /* Make it sure prefixlen is applied to the prefix. */
+ apply_mask(p);
+
+ /* Lookup (or add) route node.*/
+ rn = route_node_get(table, p);
+
+ if (!rn->info) {
+ rnh = XCALLOC(MTYPE_RNH, sizeof(struct rnh));
+ rnh->client_list = list_new();
+ rnh->vrf_id = vrfid;
+ rnh->zebra_static_route_list = list_new();
+ route_lock_node(rn);
+ rn->info = rnh;
+ rnh->node = rn;
+ }
+
+ route_unlock_node(rn);
+ return (rn->info);
}
-struct rnh *
-zebra_lookup_rnh (struct prefix *p, vrf_id_t vrfid, rnh_type_t type)
+struct rnh *zebra_lookup_rnh(struct prefix *p, vrf_id_t vrfid, rnh_type_t type)
{
- struct route_table *table;
- struct route_node *rn;
+ struct route_table *table;
+ struct route_node *rn;
- table = get_rnh_table(vrfid, PREFIX_FAMILY(p), type);
- if (!table)
- return NULL;
+ table = get_rnh_table(vrfid, PREFIX_FAMILY(p), type);
+ if (!table)
+ return NULL;
- /* Make it sure prefixlen is applied to the prefix. */
- apply_mask (p);
+ /* Make it sure prefixlen is applied to the prefix. */
+ apply_mask(p);
- /* Lookup route node.*/
- rn = route_node_lookup (table, p);
- if (!rn)
- return NULL;
+ /* Lookup route node.*/
+ rn = route_node_lookup(table, p);
+ if (!rn)
+ return NULL;
- route_unlock_node (rn);
- return (rn->info);
+ route_unlock_node(rn);
+ return (rn->info);
}
-void
-zebra_free_rnh (struct rnh *rnh)
+void zebra_free_rnh(struct rnh *rnh)
{
- rnh->flags |= ZEBRA_NHT_DELETED;
- list_free (rnh->client_list);
- list_free (rnh->zebra_static_route_list);
- free_state (rnh->vrf_id, rnh->state, rnh->node);
- XFREE (MTYPE_RNH, rnh);
+ rnh->flags |= ZEBRA_NHT_DELETED;
+ list_free(rnh->client_list);
+ list_free(rnh->zebra_static_route_list);
+ free_state(rnh->vrf_id, rnh->state, rnh->node);
+ XFREE(MTYPE_RNH, rnh);
}
-void
-zebra_delete_rnh (struct rnh *rnh, rnh_type_t type)
+void zebra_delete_rnh(struct rnh *rnh, rnh_type_t type)
{
- struct route_node *rn;
+ struct route_node *rn;
- if (!rnh || (rnh->flags & ZEBRA_NHT_DELETED) || !(rn = rnh->node))
- return;
+ if (!rnh || (rnh->flags & ZEBRA_NHT_DELETED) || !(rn = rnh->node))
+ return;
- if (IS_ZEBRA_DEBUG_NHT)
- {
- char buf[PREFIX2STR_BUFFER];
- zlog_debug("%u: Del RNH %s type %d",
- rnh->vrf_id, rnh_str(rnh, buf, sizeof (buf)), type);
- }
+ if (IS_ZEBRA_DEBUG_NHT) {
+ char buf[PREFIX2STR_BUFFER];
+ zlog_debug("%u: Del RNH %s type %d", rnh->vrf_id,
+ rnh_str(rnh, buf, sizeof(buf)), type);
+ }
- zebra_free_rnh (rnh);
- rn->info = NULL;
- route_unlock_node (rn);
+ zebra_free_rnh(rnh);
+ rn->info = NULL;
+ route_unlock_node(rn);
}
-void
-zebra_add_rnh_client (struct rnh *rnh, struct zserv *client, rnh_type_t type,
- vrf_id_t vrf_id)
+void zebra_add_rnh_client(struct rnh *rnh, struct zserv *client,
+ rnh_type_t type, vrf_id_t vrf_id)
{
- if (IS_ZEBRA_DEBUG_NHT)
- {
- char buf[PREFIX2STR_BUFFER];
- zlog_debug("%u: Client %s registers for RNH %s type %d",
- vrf_id, zebra_route_string(client->proto),
- rnh_str(rnh, buf, sizeof (buf)), type);
- }
- if (!listnode_lookup(rnh->client_list, client))
- {
- listnode_add(rnh->client_list, client);
- send_client(rnh, client, type, vrf_id); // Pending: check if its needed
- }
+ if (IS_ZEBRA_DEBUG_NHT) {
+ char buf[PREFIX2STR_BUFFER];
+ zlog_debug("%u: Client %s registers for RNH %s type %d", vrf_id,
+ zebra_route_string(client->proto),
+ rnh_str(rnh, buf, sizeof(buf)), type);
+ }
+ if (!listnode_lookup(rnh->client_list, client)) {
+ listnode_add(rnh->client_list, client);
+ send_client(rnh, client, type,
+ vrf_id); // Pending: check if its needed
+ }
}
-void
-zebra_remove_rnh_client (struct rnh *rnh, struct zserv *client, rnh_type_t type)
+void zebra_remove_rnh_client(struct rnh *rnh, struct zserv *client,
+ rnh_type_t type)
{
- if (IS_ZEBRA_DEBUG_NHT)
- {
- char buf[PREFIX2STR_BUFFER];
- zlog_debug("Client %s unregisters for RNH %s type %d",
- zebra_route_string(client->proto),
- rnh_str(rnh, buf, sizeof (buf)), type);
- }
- listnode_delete(rnh->client_list, client);
- if (list_isempty(rnh->client_list) &&
- list_isempty(rnh->zebra_static_route_list))
- zebra_delete_rnh(rnh, type);
+ if (IS_ZEBRA_DEBUG_NHT) {
+ char buf[PREFIX2STR_BUFFER];
+ zlog_debug("Client %s unregisters for RNH %s type %d",
+ zebra_route_string(client->proto),
+ rnh_str(rnh, buf, sizeof(buf)), type);
+ }
+ listnode_delete(rnh->client_list, client);
+ if (list_isempty(rnh->client_list)
+ && list_isempty(rnh->zebra_static_route_list))
+ zebra_delete_rnh(rnh, type);
}
-void
-zebra_register_rnh_static_nh(vrf_id_t vrf_id, struct prefix *nh,
- struct route_node *static_rn)
+void zebra_register_rnh_static_nh(vrf_id_t vrf_id, struct prefix *nh,
+ struct route_node *static_rn)
{
- struct rnh *rnh;
+ struct rnh *rnh;
- rnh = zebra_add_rnh(nh, vrf_id, RNH_NEXTHOP_TYPE);
- if (rnh && !listnode_lookup(rnh->zebra_static_route_list, static_rn))
- {
- listnode_add(rnh->zebra_static_route_list, static_rn);
- }
+ rnh = zebra_add_rnh(nh, vrf_id, RNH_NEXTHOP_TYPE);
+ if (rnh && !listnode_lookup(rnh->zebra_static_route_list, static_rn)) {
+ listnode_add(rnh->zebra_static_route_list, static_rn);
+ }
}
-void
-zebra_deregister_rnh_static_nh(vrf_id_t vrf_id, struct prefix *nh,
- struct route_node *static_rn)
+void zebra_deregister_rnh_static_nh(vrf_id_t vrf_id, struct prefix *nh,
+ struct route_node *static_rn)
{
- struct rnh *rnh;
+ struct rnh *rnh;
- rnh = zebra_lookup_rnh(nh, vrf_id, RNH_NEXTHOP_TYPE);
- if (!rnh || (rnh->flags & ZEBRA_NHT_DELETED))
- return;
+ rnh = zebra_lookup_rnh(nh, vrf_id, RNH_NEXTHOP_TYPE);
+ if (!rnh || (rnh->flags & ZEBRA_NHT_DELETED))
+ return;
- listnode_delete(rnh->zebra_static_route_list, static_rn);
+ listnode_delete(rnh->zebra_static_route_list, static_rn);
- if (list_isempty(rnh->client_list) &&
- list_isempty(rnh->zebra_static_route_list))
- zebra_delete_rnh(rnh, RNH_NEXTHOP_TYPE);
+ if (list_isempty(rnh->client_list)
+ && list_isempty(rnh->zebra_static_route_list))
+ zebra_delete_rnh(rnh, RNH_NEXTHOP_TYPE);
}
-void
-zebra_deregister_rnh_static_nexthops (vrf_id_t vrf_id, struct nexthop *nexthop,
- struct route_node *rn)
+void zebra_deregister_rnh_static_nexthops(vrf_id_t vrf_id,
+ struct nexthop *nexthop,
+ struct route_node *rn)
{
- struct nexthop *nh;
- struct prefix nh_p;
-
- for (nh = nexthop; nh ; nh = nh->next)
- {
- switch (nh->type)
- {
- case NEXTHOP_TYPE_IPV4:
- case NEXTHOP_TYPE_IPV4_IFINDEX:
- nh_p.family = AF_INET;
- nh_p.prefixlen = IPV4_MAX_BITLEN;
- nh_p.u.prefix4 = nh->gate.ipv4;
- break;
- case NEXTHOP_TYPE_IPV6:
- case NEXTHOP_TYPE_IPV6_IFINDEX:
- nh_p.family = AF_INET6;
- nh_p.prefixlen = IPV6_MAX_BITLEN;
- nh_p.u.prefix6 = nh->gate.ipv6;
- break;
- /*
- * Not sure what really to do here, we are not
- * supposed to have either of these for NHT
- * and the code has no way to know what prefix
- * to use. So I'm going to just continue
- * for the moment, which is preferable to
- * what is currently happening which is a
- * CRASH and BURN.
- * Some simple testing shows that we
- * are not leaving slag around for these
- * skipped static routes. Since
- * they don't appear to be installed
- */
- case NEXTHOP_TYPE_IFINDEX:
- case NEXTHOP_TYPE_BLACKHOLE:
- continue;
- break;
- }
- zebra_deregister_rnh_static_nh(vrf_id, &nh_p, rn);
- }
+ struct nexthop *nh;
+ struct prefix nh_p;
+
+ for (nh = nexthop; nh; nh = nh->next) {
+ switch (nh->type) {
+ case NEXTHOP_TYPE_IPV4:
+ case NEXTHOP_TYPE_IPV4_IFINDEX:
+ nh_p.family = AF_INET;
+ nh_p.prefixlen = IPV4_MAX_BITLEN;
+ nh_p.u.prefix4 = nh->gate.ipv4;
+ break;
+ case NEXTHOP_TYPE_IPV6:
+ case NEXTHOP_TYPE_IPV6_IFINDEX:
+ nh_p.family = AF_INET6;
+ nh_p.prefixlen = IPV6_MAX_BITLEN;
+ nh_p.u.prefix6 = nh->gate.ipv6;
+ break;
+ /*
+ * Not sure what really to do here, we are not
+ * supposed to have either of these for NHT
+ * and the code has no way to know what prefix
+ * to use. So I'm going to just continue
+ * for the moment, which is preferable to
+ * what is currently happening which is a
+ * CRASH and BURN.
+ * Some simple testing shows that we
+ * are not leaving slag around for these
+ * skipped static routes. Since
+ * they don't appear to be installed
+ */
+ case NEXTHOP_TYPE_IFINDEX:
+ case NEXTHOP_TYPE_BLACKHOLE:
+ continue;
+ break;
+ }
+ zebra_deregister_rnh_static_nh(vrf_id, &nh_p, rn);
+ }
}
/* Apply the NHT route-map for a client to the route (and nexthops)
* resolving a NH.
*/
-static int
-zebra_rnh_apply_nht_rmap(int family, struct route_node *prn,
- struct route_entry *re, int proto)
+static int zebra_rnh_apply_nht_rmap(int family, struct route_node *prn,
+ struct route_entry *re, int proto)
{
- int at_least_one = 0;
- int rmap_family; /* Route map has diff AF family enum */
- struct nexthop *nexthop;
- int ret;
-
- rmap_family = (family == AF_INET) ? AFI_IP : AFI_IP6;
-
- if (prn && re)
- {
- for (nexthop = re->nexthop; nexthop; nexthop = nexthop->next)
- {
- ret = zebra_nht_route_map_check(rmap_family, proto, &prn->p, re,
- nexthop);
- if (ret != RMAP_DENYMATCH)
- {
- SET_FLAG (nexthop->flags, NEXTHOP_FLAG_ACTIVE);
- at_least_one++; /* at least one valid NH */
- }
- else
- {
- UNSET_FLAG (nexthop->flags, NEXTHOP_FLAG_ACTIVE);
- }
+ int at_least_one = 0;
+ int rmap_family; /* Route map has diff AF family enum */
+ struct nexthop *nexthop;
+ int ret;
+
+ rmap_family = (family == AF_INET) ? AFI_IP : AFI_IP6;
+
+ if (prn && re) {
+ for (nexthop = re->nexthop; nexthop; nexthop = nexthop->next) {
+ ret = zebra_nht_route_map_check(rmap_family, proto,
+ &prn->p, re, nexthop);
+ if (ret != RMAP_DENYMATCH) {
+ SET_FLAG(nexthop->flags, NEXTHOP_FLAG_ACTIVE);
+ at_least_one++; /* at least one valid NH */
+ } else {
+ UNSET_FLAG(nexthop->flags, NEXTHOP_FLAG_ACTIVE);
+ }
+ }
}
- }
- return (at_least_one);
+ return (at_least_one);
}
/*
* Determine appropriate route (RE entry) resolving a tracked entry
* (nexthop or BGP route for import).
*/
-static struct route_entry *
-zebra_rnh_resolve_entry (vrf_id_t vrfid, int family, rnh_type_t type,
- struct route_node *nrn, struct rnh *rnh,
- struct route_node **prn)
+static struct route_entry *zebra_rnh_resolve_entry(vrf_id_t vrfid, int family,
+ rnh_type_t type,
+ struct route_node *nrn,
+ struct rnh *rnh,
+ struct route_node **prn)
{
- struct route_table *route_table;
- struct route_node *rn;
- struct route_entry *re;
-
- *prn = NULL;
-
- route_table = zebra_vrf_table(family2afi(family), SAFI_UNICAST, vrfid);
- if (!route_table) // unexpected
- return NULL;
-
- rn = route_node_match(route_table, &nrn->p);
- if (!rn)
- return NULL;
-
- /* When resolving nexthops, do not resolve via the default route unless
- * 'ip nht resolve-via-default' is configured.
- */
- if ((type == RNH_NEXTHOP_TYPE) &&
- (is_default_prefix (&rn->p) &&
- !nh_resolve_via_default(rn->p.family)))
- re = NULL;
- else if ((type == RNH_IMPORT_CHECK_TYPE) &&
- CHECK_FLAG(rnh->flags, ZEBRA_NHT_EXACT_MATCH) &&
- !prefix_same(&nrn->p, &rn->p))
- re = NULL;
- else
- {
- /* Identify appropriate route entry. */
- RNODE_FOREACH_RE(rn, re)
- {
- if (CHECK_FLAG (re->status, ROUTE_ENTRY_REMOVED))
- continue;
- if (! CHECK_FLAG (re->status, ROUTE_ENTRY_SELECTED_FIB))
- continue;
-
- if (CHECK_FLAG(rnh->flags, ZEBRA_NHT_CONNECTED))
- {
- if (re->type == ZEBRA_ROUTE_CONNECT)
- break;
- if (re->type == ZEBRA_ROUTE_NHRP)
- {
- struct nexthop *nexthop;
- for (nexthop = re->nexthop; nexthop; nexthop = nexthop->next)
- if (nexthop->type == NEXTHOP_TYPE_IFINDEX)
- break;
- if (nexthop)
- break;
- }
- }
- else if ((type == RNH_IMPORT_CHECK_TYPE) &&
- (re->type == ZEBRA_ROUTE_BGP))
- continue;
- else
- break;
- }
- }
-
- /* Need to unlock route node */
- route_unlock_node(rn);
- if (re)
- *prn = rn;
- return re;
+ struct route_table *route_table;
+ struct route_node *rn;
+ struct route_entry *re;
+
+ *prn = NULL;
+
+ route_table = zebra_vrf_table(family2afi(family), SAFI_UNICAST, vrfid);
+ if (!route_table) // unexpected
+ return NULL;
+
+ rn = route_node_match(route_table, &nrn->p);
+ if (!rn)
+ return NULL;
+
+ /* When resolving nexthops, do not resolve via the default route unless
+ * 'ip nht resolve-via-default' is configured.
+ */
+ if ((type == RNH_NEXTHOP_TYPE)
+ && (is_default_prefix(&rn->p)
+ && !nh_resolve_via_default(rn->p.family)))
+ re = NULL;
+ else if ((type == RNH_IMPORT_CHECK_TYPE)
+ && CHECK_FLAG(rnh->flags, ZEBRA_NHT_EXACT_MATCH)
+ && !prefix_same(&nrn->p, &rn->p))
+ re = NULL;
+ else {
+ /* Identify appropriate route entry. */
+ RNODE_FOREACH_RE(rn, re)
+ {
+ if (CHECK_FLAG(re->status, ROUTE_ENTRY_REMOVED))
+ continue;
+ if (!CHECK_FLAG(re->status, ROUTE_ENTRY_SELECTED_FIB))
+ continue;
+
+ if (CHECK_FLAG(rnh->flags, ZEBRA_NHT_CONNECTED)) {
+ if (re->type == ZEBRA_ROUTE_CONNECT)
+ break;
+ if (re->type == ZEBRA_ROUTE_NHRP) {
+ struct nexthop *nexthop;
+ for (nexthop = re->nexthop; nexthop;
+ nexthop = nexthop->next)
+ if (nexthop->type
+ == NEXTHOP_TYPE_IFINDEX)
+ break;
+ if (nexthop)
+ break;
+ }
+ } else if ((type == RNH_IMPORT_CHECK_TYPE)
+ && (re->type == ZEBRA_ROUTE_BGP))
+ continue;
+ else
+ break;
+ }
+ }
+
+ /* Need to unlock route node */
+ route_unlock_node(rn);
+ if (re)
+ *prn = rn;
+ return re;
}
/*
* See if a tracked route entry for import (by BGP) has undergone any
* change, and if so, notify the client.
*/
-static void
-zebra_rnh_eval_import_check_entry (vrf_id_t vrfid, int family, int force,
- struct route_node *nrn, struct rnh *rnh,
- struct route_entry *re)
+static void zebra_rnh_eval_import_check_entry(vrf_id_t vrfid, int family,
+ int force, struct route_node *nrn,
+ struct rnh *rnh,
+ struct route_entry *re)
{
- int state_changed = 0;
- struct zserv *client;
- char bufn[INET6_ADDRSTRLEN];
- struct listnode *node;
- struct nexthop *nexthop;
-
- if (re && (rnh->state == NULL))
- {
- for (ALL_NEXTHOPS(re->nexthop, nexthop))
- if (CHECK_FLAG (nexthop->flags, NEXTHOP_FLAG_FIB))
- {
- state_changed = 1;
- break;
- }
- }
- else if (!re && (rnh->state != NULL))
- state_changed = 1;
-
- if (compare_state(re, rnh->state))
- copy_state(rnh, re, nrn);
-
- if (state_changed || force)
- {
- if (IS_ZEBRA_DEBUG_NHT)
- {
- prefix2str(&nrn->p, bufn, INET6_ADDRSTRLEN);
- zlog_debug("%u:%s: Route import check %s %s\n",
- vrfid, bufn, rnh->state ? "passed" : "failed",
- state_changed ? "(state changed)" : "");
- }
- /* state changed, notify clients */
- for (ALL_LIST_ELEMENTS_RO(rnh->client_list, node, client))
- {
- send_client(rnh, client, RNH_IMPORT_CHECK_TYPE, vrfid);
- }
- }
+ int state_changed = 0;
+ struct zserv *client;
+ char bufn[INET6_ADDRSTRLEN];
+ struct listnode *node;
+ struct nexthop *nexthop;
+
+ if (re && (rnh->state == NULL)) {
+ for (ALL_NEXTHOPS(re->nexthop, nexthop))
+ if (CHECK_FLAG(nexthop->flags, NEXTHOP_FLAG_FIB)) {
+ state_changed = 1;
+ break;
+ }
+ } else if (!re && (rnh->state != NULL))
+ state_changed = 1;
+
+ if (compare_state(re, rnh->state))
+ copy_state(rnh, re, nrn);
+
+ if (state_changed || force) {
+ if (IS_ZEBRA_DEBUG_NHT) {
+ prefix2str(&nrn->p, bufn, INET6_ADDRSTRLEN);
+ zlog_debug("%u:%s: Route import check %s %s\n", vrfid,
+ bufn, rnh->state ? "passed" : "failed",
+ state_changed ? "(state changed)" : "");
+ }
+ /* state changed, notify clients */
+ for (ALL_LIST_ELEMENTS_RO(rnh->client_list, node, client)) {
+ send_client(rnh, client, RNH_IMPORT_CHECK_TYPE, vrfid);
+ }
+ }
}
/*
* Notify clients registered for this nexthop about a change.
*/
-static void
-zebra_rnh_notify_protocol_clients (vrf_id_t vrfid, int family,
- struct route_node *nrn, struct rnh *rnh,
- struct route_node *prn, struct route_entry *re)
+static void zebra_rnh_notify_protocol_clients(vrf_id_t vrfid, int family,
+ struct route_node *nrn,
+ struct rnh *rnh,
+ struct route_node *prn,
+ struct route_entry *re)
{
- struct listnode *node;
- struct zserv *client;
- char bufn[INET6_ADDRSTRLEN];
- char bufp[INET6_ADDRSTRLEN];
- int num_resolving_nh;
-
- if (IS_ZEBRA_DEBUG_NHT)
- {
- prefix2str(&nrn->p, bufn, INET6_ADDRSTRLEN);
- if (prn && re)
- {
- prefix2str(&prn->p, bufp, INET6_ADDRSTRLEN);
- zlog_debug("%u:%s: NH resolved over route %s", vrfid, bufn, bufp);
- }
- else
- zlog_debug("%u:%s: NH has become unresolved", vrfid, bufn);
- }
-
- for (ALL_LIST_ELEMENTS_RO(rnh->client_list, node, client))
- {
- if (prn && re)
- {
- /* Apply route-map for this client to route resolving this
- * nexthop to see if it is filtered or not.
- */
- num_resolving_nh = zebra_rnh_apply_nht_rmap(family, prn, re,
- client->proto);
- if (num_resolving_nh)
- rnh->filtered[client->proto] = 0;
- else
- rnh->filtered[client->proto] = 1;
-
- if (IS_ZEBRA_DEBUG_NHT)
- zlog_debug("%u:%s: Notifying client %s about NH %s",
- vrfid, bufn, zebra_route_string(client->proto),
- num_resolving_nh ? "" : "(filtered by route-map)");
- }
- else
- {
- rnh->filtered[client->proto] = 0;
- if (IS_ZEBRA_DEBUG_NHT)
- zlog_debug("%u:%s: Notifying client %s about NH (unreachable)",
- vrfid, bufn, zebra_route_string(client->proto));
- }
-
- send_client(rnh, client, RNH_NEXTHOP_TYPE, vrfid);
- }
+ struct listnode *node;
+ struct zserv *client;
+ char bufn[INET6_ADDRSTRLEN];
+ char bufp[INET6_ADDRSTRLEN];
+ int num_resolving_nh;
+
+ if (IS_ZEBRA_DEBUG_NHT) {
+ prefix2str(&nrn->p, bufn, INET6_ADDRSTRLEN);
+ if (prn && re) {
+ prefix2str(&prn->p, bufp, INET6_ADDRSTRLEN);
+ zlog_debug("%u:%s: NH resolved over route %s", vrfid,
+ bufn, bufp);
+ } else
+ zlog_debug("%u:%s: NH has become unresolved", vrfid,
+ bufn);
+ }
+
+ for (ALL_LIST_ELEMENTS_RO(rnh->client_list, node, client)) {
+ if (prn && re) {
+ /* Apply route-map for this client to route resolving
+ * this
+ * nexthop to see if it is filtered or not.
+ */
+ num_resolving_nh = zebra_rnh_apply_nht_rmap(
+ family, prn, re, client->proto);
+ if (num_resolving_nh)
+ rnh->filtered[client->proto] = 0;
+ else
+ rnh->filtered[client->proto] = 1;
+
+ if (IS_ZEBRA_DEBUG_NHT)
+ zlog_debug(
+ "%u:%s: Notifying client %s about NH %s",
+ vrfid, bufn,
+ zebra_route_string(client->proto),
+ num_resolving_nh
+ ? ""
+ : "(filtered by route-map)");
+ } else {
+ rnh->filtered[client->proto] = 0;
+ if (IS_ZEBRA_DEBUG_NHT)
+ zlog_debug(
+ "%u:%s: Notifying client %s about NH (unreachable)",
+ vrfid, bufn,
+ zebra_route_string(client->proto));
+ }
+
+ send_client(rnh, client, RNH_NEXTHOP_TYPE, vrfid);
+ }
}
-static void
-zebra_rnh_process_static_routes (vrf_id_t vrfid, int family,
- struct route_node *nrn, struct rnh *rnh,
- struct route_node *prn, struct route_entry *re)
+static void zebra_rnh_process_static_routes(vrf_id_t vrfid, int family,
+ struct route_node *nrn,
+ struct rnh *rnh,
+ struct route_node *prn,
+ struct route_entry *re)
{
- struct listnode *node;
- int num_resolving_nh = 0;
- struct route_node *static_rn;
- struct route_entry *sre;
- struct nexthop *nexthop;
- char bufn[INET6_ADDRSTRLEN];
- char bufp[INET6_ADDRSTRLEN];
- char bufs[INET6_ADDRSTRLEN];
-
- if (IS_ZEBRA_DEBUG_NHT)
- {
- prefix2str(&nrn->p, bufn, INET6_ADDRSTRLEN);
- if (prn)
- prefix2str(&prn->p, bufp, INET6_ADDRSTRLEN);
- }
-
- if (prn && re)
- {
- /* Apply route-map for "static" to route resolving this
- * nexthop to see if it is filtered or not.
- */
- num_resolving_nh = zebra_rnh_apply_nht_rmap(family, prn, re,
- ZEBRA_ROUTE_STATIC);
- if (num_resolving_nh)
- rnh->filtered[ZEBRA_ROUTE_STATIC] = 0;
- else
- rnh->filtered[ZEBRA_ROUTE_STATIC] = 1;
- }
- else
- rnh->filtered[ZEBRA_ROUTE_STATIC] = 0;
-
- /* Evaluate each static route associated with this nexthop. */
- for (ALL_LIST_ELEMENTS_RO(rnh->zebra_static_route_list, node,
- static_rn))
- {
- RNODE_FOREACH_RE(static_rn, sre)
- {
- if (sre->type != ZEBRA_ROUTE_STATIC)
- continue;
-
- /* Set the filter flag for the correct nexthop - static route may
- * be having multiple. We care here only about registered nexthops.
- */
- for (nexthop = sre->nexthop; nexthop; nexthop = nexthop->next)
- {
- switch (nexthop->type)
- {
- case NEXTHOP_TYPE_IPV4:
- case NEXTHOP_TYPE_IPV4_IFINDEX:
- if (nexthop->gate.ipv4.s_addr == nrn->p.u.prefix4.s_addr)
- {
- if (num_resolving_nh)
- UNSET_FLAG(nexthop->flags, NEXTHOP_FLAG_FILTERED);
- else
- SET_FLAG(nexthop->flags, NEXTHOP_FLAG_FILTERED);
- }
- break;
- case NEXTHOP_TYPE_IPV6:
- case NEXTHOP_TYPE_IPV6_IFINDEX:
+ struct listnode *node;
+ int num_resolving_nh = 0;
+ struct route_node *static_rn;
+ struct route_entry *sre;
+ struct nexthop *nexthop;
+ char bufn[INET6_ADDRSTRLEN];
+ char bufp[INET6_ADDRSTRLEN];
+ char bufs[INET6_ADDRSTRLEN];
+
+ if (IS_ZEBRA_DEBUG_NHT) {
+ prefix2str(&nrn->p, bufn, INET6_ADDRSTRLEN);
+ if (prn)
+ prefix2str(&prn->p, bufp, INET6_ADDRSTRLEN);
+ }
- if (memcmp(&nexthop->gate.ipv6,&nrn->p.u.prefix6, 16) == 0)
- {
- if (num_resolving_nh)
- UNSET_FLAG(nexthop->flags, NEXTHOP_FLAG_FILTERED);
- else
- SET_FLAG(nexthop->flags, NEXTHOP_FLAG_FILTERED);
- }
- break;
- default:
- break;
- }
- }
-
- if (IS_ZEBRA_DEBUG_NHT)
- {
- prefix2str(&static_rn->p, bufs, INET6_ADDRSTRLEN);
- if (prn && re)
- zlog_debug("%u:%s: NH change %s, scheduling static route %s",
- vrfid, bufn, num_resolving_nh ?
- "" : "(filtered by route-map)", bufs);
- else
- zlog_debug("%u:%s: NH unreachable, scheduling static route %s",
- vrfid, bufn, bufs);
- }
-
- SET_FLAG(sre->status, ROUTE_ENTRY_CHANGED);
- SET_FLAG(sre->status, ROUTE_ENTRY_NEXTHOPS_CHANGED);
- }
-
- rib_queue_add(static_rn);
- }
+ if (prn && re) {
+ /* Apply route-map for "static" to route resolving this
+ * nexthop to see if it is filtered or not.
+ */
+ num_resolving_nh = zebra_rnh_apply_nht_rmap(family, prn, re,
+ ZEBRA_ROUTE_STATIC);
+ if (num_resolving_nh)
+ rnh->filtered[ZEBRA_ROUTE_STATIC] = 0;
+ else
+ rnh->filtered[ZEBRA_ROUTE_STATIC] = 1;
+ } else
+ rnh->filtered[ZEBRA_ROUTE_STATIC] = 0;
+
+ /* Evaluate each static route associated with this nexthop. */
+ for (ALL_LIST_ELEMENTS_RO(rnh->zebra_static_route_list, node,
+ static_rn)) {
+ RNODE_FOREACH_RE(static_rn, sre)
+ {
+ if (sre->type != ZEBRA_ROUTE_STATIC)
+ continue;
+
+ /* Set the filter flag for the correct nexthop - static
+ * route may
+ * be having multiple. We care here only about
+ * registered nexthops.
+ */
+ for (nexthop = sre->nexthop; nexthop;
+ nexthop = nexthop->next) {
+ switch (nexthop->type) {
+ case NEXTHOP_TYPE_IPV4:
+ case NEXTHOP_TYPE_IPV4_IFINDEX:
+ if (nexthop->gate.ipv4.s_addr
+ == nrn->p.u.prefix4.s_addr) {
+ if (num_resolving_nh)
+ UNSET_FLAG(
+ nexthop->flags,
+ NEXTHOP_FLAG_FILTERED);
+ else
+ SET_FLAG(
+ nexthop->flags,
+ NEXTHOP_FLAG_FILTERED);
+ }
+ break;
+ case NEXTHOP_TYPE_IPV6:
+ case NEXTHOP_TYPE_IPV6_IFINDEX:
+
+ if (memcmp(&nexthop->gate.ipv6,
+ &nrn->p.u.prefix6, 16)
+ == 0) {
+ if (num_resolving_nh)
+ UNSET_FLAG(
+ nexthop->flags,
+ NEXTHOP_FLAG_FILTERED);
+ else
+ SET_FLAG(
+ nexthop->flags,
+ NEXTHOP_FLAG_FILTERED);
+ }
+ break;
+ default:
+ break;
+ }
+ }
+
+ if (IS_ZEBRA_DEBUG_NHT) {
+ prefix2str(&static_rn->p, bufs,
+ INET6_ADDRSTRLEN);
+ if (prn && re)
+ zlog_debug(
+ "%u:%s: NH change %s, scheduling static route %s",
+ vrfid, bufn,
+ num_resolving_nh
+ ? ""
+ : "(filtered by route-map)",
+ bufs);
+ else
+ zlog_debug(
+ "%u:%s: NH unreachable, scheduling static route %s",
+ vrfid, bufn, bufs);
+ }
+
+ SET_FLAG(sre->status, ROUTE_ENTRY_CHANGED);
+ SET_FLAG(sre->status, ROUTE_ENTRY_NEXTHOPS_CHANGED);
+ }
+
+ rib_queue_add(static_rn);
+ }
}
/*
* take appropriate action; this involves notifying any clients and/or
* scheduling dependent static routes for processing.
*/
-static void
-zebra_rnh_eval_nexthop_entry (vrf_id_t vrfid, int family, int force,
- struct route_node *nrn, struct rnh *rnh,
- struct route_node *prn, struct route_entry *re)
+static void zebra_rnh_eval_nexthop_entry(vrf_id_t vrfid, int family, int force,
+ struct route_node *nrn,
+ struct rnh *rnh,
+ struct route_node *prn,
+ struct route_entry *re)
{
- int state_changed = 0;
-
- /* If we're resolving over a different route, resolution has changed or
- * the resolving route has some change (e.g., metric), there is a state
- * change.
- */
- if (!prefix_same(&rnh->resolved_route, &prn->p))
- {
- if (prn)
- prefix_copy(&rnh->resolved_route, &prn->p);
- else
- memset(&rnh->resolved_route, 0, sizeof(struct prefix));
-
- copy_state(rnh, re, nrn);
- state_changed = 1;
- }
- else if (compare_state(re, rnh->state))
- {
- copy_state(rnh, re, nrn);
- state_changed = 1;
- }
-
- if (state_changed || force)
- {
- /* NOTE: Use the "copy" of resolving route stored in 'rnh' i.e.,
- * rnh->state.
- */
- /* Notify registered protocol clients. */
- zebra_rnh_notify_protocol_clients (vrfid, family, nrn, rnh,
- prn, rnh->state);
-
- /* Process static routes attached to this nexthop */
- zebra_rnh_process_static_routes (vrfid, family, nrn, rnh,
- prn, rnh->state);
- }
+ int state_changed = 0;
+
+ /* If we're resolving over a different route, resolution has changed or
+ * the resolving route has some change (e.g., metric), there is a state
+ * change.
+ */
+ if (!prefix_same(&rnh->resolved_route, &prn->p)) {
+ if (prn)
+ prefix_copy(&rnh->resolved_route, &prn->p);
+ else
+ memset(&rnh->resolved_route, 0, sizeof(struct prefix));
+
+ copy_state(rnh, re, nrn);
+ state_changed = 1;
+ } else if (compare_state(re, rnh->state)) {
+ copy_state(rnh, re, nrn);
+ state_changed = 1;
+ }
+
+ if (state_changed || force) {
+ /* NOTE: Use the "copy" of resolving route stored in 'rnh' i.e.,
+ * rnh->state.
+ */
+ /* Notify registered protocol clients. */
+ zebra_rnh_notify_protocol_clients(vrfid, family, nrn, rnh, prn,
+ rnh->state);
+
+ /* Process static routes attached to this nexthop */
+ zebra_rnh_process_static_routes(vrfid, family, nrn, rnh, prn,
+ rnh->state);
+ }
}
/* Evaluate one tracked entry */
-static void
-zebra_rnh_evaluate_entry (vrf_id_t vrfid, int family, int force, rnh_type_t type,
- struct route_node *nrn)
+static void zebra_rnh_evaluate_entry(vrf_id_t vrfid, int family, int force,
+ rnh_type_t type, struct route_node *nrn)
{
- struct rnh *rnh;
- struct route_entry *re;
- struct route_node *prn;
- char bufn[INET6_ADDRSTRLEN];
-
- if (IS_ZEBRA_DEBUG_NHT)
- {
- prefix2str(&nrn->p, bufn, INET6_ADDRSTRLEN);
- zlog_debug("%u:%s: Evaluate RNH, type %d %s",
- vrfid, bufn, type, force ? "(force)" : "");
- }
-
- rnh = nrn->info;
-
- /* Identify route entry (RE) resolving this tracked entry. */
- re = zebra_rnh_resolve_entry (vrfid, family, type, nrn, rnh, &prn);
-
- /* If the entry cannot be resolved and that is also the existing state,
- * there is nothing further to do.
- */
- if (!re && rnh->state == NULL && !force)
- return;
-
- /* Process based on type of entry. */
- if (type == RNH_IMPORT_CHECK_TYPE)
- zebra_rnh_eval_import_check_entry (vrfid, family, force,
- nrn, rnh, re);
- else
- zebra_rnh_eval_nexthop_entry (vrfid, family, force,
- nrn, rnh, prn, re);
+ struct rnh *rnh;
+ struct route_entry *re;
+ struct route_node *prn;
+ char bufn[INET6_ADDRSTRLEN];
+
+ if (IS_ZEBRA_DEBUG_NHT) {
+ prefix2str(&nrn->p, bufn, INET6_ADDRSTRLEN);
+ zlog_debug("%u:%s: Evaluate RNH, type %d %s", vrfid, bufn, type,
+ force ? "(force)" : "");
+ }
+
+ rnh = nrn->info;
+
+ /* Identify route entry (RE) resolving this tracked entry. */
+ re = zebra_rnh_resolve_entry(vrfid, family, type, nrn, rnh, &prn);
+
+ /* If the entry cannot be resolved and that is also the existing state,
+ * there is nothing further to do.
+ */
+ if (!re && rnh->state == NULL && !force)
+ return;
+
+ /* Process based on type of entry. */
+ if (type == RNH_IMPORT_CHECK_TYPE)
+ zebra_rnh_eval_import_check_entry(vrfid, family, force, nrn,
+ rnh, re);
+ else
+ zebra_rnh_eval_nexthop_entry(vrfid, family, force, nrn, rnh,
+ prn, re);
}
/*
* we can have a situation where one re entry
* covers multiple nexthops we are interested in.
*/
-static void
-zebra_rnh_clear_nhc_flag (vrf_id_t vrfid, int family, rnh_type_t type,
- struct route_node *nrn)
+static void zebra_rnh_clear_nhc_flag(vrf_id_t vrfid, int family,
+ rnh_type_t type, struct route_node *nrn)
{
- struct rnh *rnh;
- struct route_entry *re;
- struct route_node *prn;
+ struct rnh *rnh;
+ struct route_entry *re;
+ struct route_node *prn;
- rnh = nrn->info;
+ rnh = nrn->info;
- re = zebra_rnh_resolve_entry (vrfid, family, type, nrn, rnh, &prn);
+ re = zebra_rnh_resolve_entry(vrfid, family, type, nrn, rnh, &prn);
- if (re)
- UNSET_FLAG (re->status, ROUTE_ENTRY_NEXTHOPS_CHANGED);
+ if (re)
+ UNSET_FLAG(re->status, ROUTE_ENTRY_NEXTHOPS_CHANGED);
}
/* Evaluate all tracked entries (nexthops or routes for import into BGP)
* of a particular VRF and address-family or a specific prefix.
*/
-void
-zebra_evaluate_rnh (vrf_id_t vrfid, int family, int force, rnh_type_t type,
- struct prefix *p)
+void zebra_evaluate_rnh(vrf_id_t vrfid, int family, int force, rnh_type_t type,
+ struct prefix *p)
{
- struct route_table *rnh_table;
- struct route_node *nrn;
-
- rnh_table = get_rnh_table(vrfid, family, type);
- if (!rnh_table) // unexpected
- return;
-
- if (p)
- {
- /* Evaluating a specific entry, make sure it exists. */
- nrn = route_node_lookup (rnh_table, p);
- if (nrn && nrn->info)
- zebra_rnh_evaluate_entry (vrfid, family, force, type, nrn);
-
- if (nrn)
- route_unlock_node (nrn);
- }
- else
- {
- /* Evaluate entire table. */
- nrn = route_top (rnh_table);
- while (nrn)
- {
- if (nrn->info)
- zebra_rnh_evaluate_entry (vrfid, family, force, type, nrn);
- nrn = route_next(nrn); /* this will also unlock nrn */
- }
- nrn = route_top (rnh_table);
- while (nrn)
- {
- if (nrn->info)
- zebra_rnh_clear_nhc_flag (vrfid, family, type, nrn);
- nrn = route_next(nrn); /* this will also unlock nrn */
- }
- }
+ struct route_table *rnh_table;
+ struct route_node *nrn;
+
+ rnh_table = get_rnh_table(vrfid, family, type);
+ if (!rnh_table) // unexpected
+ return;
+
+ if (p) {
+ /* Evaluating a specific entry, make sure it exists. */
+ nrn = route_node_lookup(rnh_table, p);
+ if (nrn && nrn->info)
+ zebra_rnh_evaluate_entry(vrfid, family, force, type,
+ nrn);
+
+ if (nrn)
+ route_unlock_node(nrn);
+ } else {
+ /* Evaluate entire table. */
+ nrn = route_top(rnh_table);
+ while (nrn) {
+ if (nrn->info)
+ zebra_rnh_evaluate_entry(vrfid, family, force,
+ type, nrn);
+ nrn = route_next(nrn); /* this will also unlock nrn */
+ }
+ nrn = route_top(rnh_table);
+ while (nrn) {
+ if (nrn->info)
+ zebra_rnh_clear_nhc_flag(vrfid, family, type,
+ nrn);
+ nrn = route_next(nrn); /* this will also unlock nrn */
+ }
+ }
}
-void
-zebra_print_rnh_table (vrf_id_t vrfid, int af, struct vty *vty, rnh_type_t type)
+void zebra_print_rnh_table(vrf_id_t vrfid, int af, struct vty *vty,
+ rnh_type_t type)
{
- struct route_table *table;
- struct route_node *rn;
-
- table = get_rnh_table(vrfid, af, type);
- if (!table)
- {
- zlog_debug("print_rnhs: rnh table not found\n");
- return;
- }
-
- for (rn = route_top(table); rn; rn = route_next(rn))
- if (rn->info)
- print_rnh(rn, vty);
+ struct route_table *table;
+ struct route_node *rn;
+
+ table = get_rnh_table(vrfid, af, type);
+ if (!table) {
+ zlog_debug("print_rnhs: rnh table not found\n");
+ return;
+ }
+
+ for (rn = route_top(table); rn; rn = route_next(rn))
+ if (rn->info)
+ print_rnh(rn, vty);
}
-int
-zebra_cleanup_rnh_client (vrf_id_t vrf_id, int family, struct zserv *client,
- rnh_type_t type)
+int zebra_cleanup_rnh_client(vrf_id_t vrf_id, int family, struct zserv *client,
+ rnh_type_t type)
{
- struct route_table *ntable;
- struct route_node *nrn;
- struct rnh *rnh;
-
- if (IS_ZEBRA_DEBUG_NHT)
- zlog_debug("%u: Client %s RNH cleanup for family %d type %d",
- vrf_id, zebra_route_string(client->proto), family, type);
-
- ntable = get_rnh_table(vrf_id, family, type);
- if (!ntable)
- {
- zlog_debug("cleanup_rnh_client: rnh table not found\n");
- return -1;
- }
-
- for (nrn = route_top (ntable); nrn; nrn = route_next (nrn))
- {
- if (!nrn->info)
- continue;
-
- rnh = nrn->info;
- zebra_remove_rnh_client(rnh, client, type);
- }
- return 1;
+ struct route_table *ntable;
+ struct route_node *nrn;
+ struct rnh *rnh;
+
+ if (IS_ZEBRA_DEBUG_NHT)
+ zlog_debug("%u: Client %s RNH cleanup for family %d type %d",
+ vrf_id, zebra_route_string(client->proto), family,
+ type);
+
+ ntable = get_rnh_table(vrf_id, family, type);
+ if (!ntable) {
+ zlog_debug("cleanup_rnh_client: rnh table not found\n");
+ return -1;
+ }
+
+ for (nrn = route_top(ntable); nrn; nrn = route_next(nrn)) {
+ if (!nrn->info)
+ continue;
+
+ rnh = nrn->info;
+ zebra_remove_rnh_client(rnh, client, type);
+ }
+ return 1;
}
/**
* free_state - free up the re structure associated with the rnh.
*/
-static void
-free_state (vrf_id_t vrf_id, struct route_entry *re, struct route_node *rn)
+static void free_state(vrf_id_t vrf_id, struct route_entry *re,
+ struct route_node *rn)
{
- if (!re)
- return;
+ if (!re)
+ return;
- /* free RE and nexthops */
- zebra_deregister_rnh_static_nexthops (vrf_id, re->nexthop, rn);
- nexthops_free(re->nexthop);
- XFREE (MTYPE_RE, re);
+ /* free RE and nexthops */
+ zebra_deregister_rnh_static_nexthops(vrf_id, re->nexthop, rn);
+ nexthops_free(re->nexthop);
+ XFREE(MTYPE_RE, re);
}
-static void
-copy_state (struct rnh *rnh, struct route_entry *re, struct route_node *rn)
+static void copy_state(struct rnh *rnh, struct route_entry *re,
+ struct route_node *rn)
{
- struct route_entry *state;
+ struct route_entry *state;
- if (rnh->state)
- {
- free_state(rnh->vrf_id, rnh->state, rn);
- rnh->state = NULL;
- }
+ if (rnh->state) {
+ free_state(rnh->vrf_id, rnh->state, rn);
+ rnh->state = NULL;
+ }
- if (!re)
- return;
+ if (!re)
+ return;
- state = XCALLOC (MTYPE_RE, sizeof (struct route_entry));
- state->type = re->type;
- state->metric = re->metric;
+ state = XCALLOC(MTYPE_RE, sizeof(struct route_entry));
+ state->type = re->type;
+ state->metric = re->metric;
- route_entry_copy_nexthops(state, re->nexthop);
- rnh->state = state;
+ route_entry_copy_nexthops(state, re->nexthop);
+ rnh->state = state;
}
-static int
-compare_state (struct route_entry *r1, struct route_entry *r2)
+static int compare_state(struct route_entry *r1, struct route_entry *r2)
{
- if (!r1 && !r2)
- return 0;
+ if (!r1 && !r2)
+ return 0;
- if ((!r1 && r2) || (r1 && !r2))
- return 1;
+ if ((!r1 && r2) || (r1 && !r2))
+ return 1;
- if (r1->metric != r2->metric)
- return 1;
+ if (r1->metric != r2->metric)
+ return 1;
- if (r1->nexthop_num != r2->nexthop_num)
- return 1;
+ if (r1->nexthop_num != r2->nexthop_num)
+ return 1;
- if (CHECK_FLAG(r1->status, ROUTE_ENTRY_NEXTHOPS_CHANGED))
- return 1;
+ if (CHECK_FLAG(r1->status, ROUTE_ENTRY_NEXTHOPS_CHANGED))
+ return 1;
- return 0;
+ return 0;
}
-static int
-send_client (struct rnh *rnh, struct zserv *client, rnh_type_t type, vrf_id_t vrf_id)
+static int send_client(struct rnh *rnh, struct zserv *client, rnh_type_t type,
+ vrf_id_t vrf_id)
{
- struct stream *s;
- struct route_entry *re;
- unsigned long nump;
- u_char num;
- struct nexthop *nexthop;
- struct route_node *rn;
- int cmd = (type == RNH_IMPORT_CHECK_TYPE)
- ? ZEBRA_IMPORT_CHECK_UPDATE : ZEBRA_NEXTHOP_UPDATE;
-
- rn = rnh->node;
- re = rnh->state;
-
- /* Get output stream. */
- s = client->obuf;
- stream_reset (s);
-
- zserv_create_header (s, cmd, vrf_id);
-
- stream_putw(s, rn->p.family);
- switch (rn->p.family)
- {
- case AF_INET:
- stream_putc(s, rn->p.prefixlen);
- stream_put_in_addr(s, &rn->p.u.prefix4);
- break;
- case AF_INET6:
- stream_putc(s, rn->p.prefixlen);
- stream_put(s, &rn->p.u.prefix6, IPV6_MAX_BYTELEN);
- break;
- default:
- zlog_err("%s: Unknown family (%d) notification attempted\n",
- __FUNCTION__, rn->p.family);
- break;
- }
- if (re)
- {
- stream_putc (s, re->distance);
- stream_putl (s, re->metric);
- num = 0;
- nump = stream_get_endp(s);
- stream_putc (s, 0);
- for (nexthop = re->nexthop; nexthop; nexthop = nexthop->next)
- if ((CHECK_FLAG (nexthop->flags, NEXTHOP_FLAG_FIB) ||
- CHECK_FLAG (nexthop->flags, NEXTHOP_FLAG_RECURSIVE)) &&
- CHECK_FLAG (nexthop->flags, NEXTHOP_FLAG_ACTIVE))
- {
- stream_putc (s, nexthop->type);
- switch (nexthop->type)
- {
- case NEXTHOP_TYPE_IPV4:
- stream_put_in_addr (s, &nexthop->gate.ipv4);
- stream_putl (s, nexthop->ifindex);
+ struct stream *s;
+ struct route_entry *re;
+ unsigned long nump;
+ u_char num;
+ struct nexthop *nexthop;
+ struct route_node *rn;
+ int cmd = (type == RNH_IMPORT_CHECK_TYPE) ? ZEBRA_IMPORT_CHECK_UPDATE
+ : ZEBRA_NEXTHOP_UPDATE;
+
+ rn = rnh->node;
+ re = rnh->state;
+
+ /* Get output stream. */
+ s = client->obuf;
+ stream_reset(s);
+
+ zserv_create_header(s, cmd, vrf_id);
+
+ stream_putw(s, rn->p.family);
+ switch (rn->p.family) {
+ case AF_INET:
+ stream_putc(s, rn->p.prefixlen);
+ stream_put_in_addr(s, &rn->p.u.prefix4);
break;
- case NEXTHOP_TYPE_IFINDEX:
- stream_putl (s, nexthop->ifindex);
+ case AF_INET6:
+ stream_putc(s, rn->p.prefixlen);
+ stream_put(s, &rn->p.u.prefix6, IPV6_MAX_BYTELEN);
break;
- case NEXTHOP_TYPE_IPV4_IFINDEX:
- stream_put_in_addr (s, &nexthop->gate.ipv4);
- stream_putl (s, nexthop->ifindex);
+ default:
+ zlog_err("%s: Unknown family (%d) notification attempted\n",
+ __FUNCTION__, rn->p.family);
break;
- case NEXTHOP_TYPE_IPV6:
- stream_put (s, &nexthop->gate.ipv6, 16);
- stream_putl (s, nexthop->ifindex);
- break;
- case NEXTHOP_TYPE_IPV6_IFINDEX:
- stream_put (s, &nexthop->gate.ipv6, 16);
- stream_putl (s, nexthop->ifindex);
- break;
- default:
- /* do nothing */
- break;
- }
- num++;
- }
- stream_putc_at (s, nump, num);
- }
- else
- {
- stream_putc (s, 0); // distance
- stream_putl (s, 0); // metric
- stream_putc (s, 0); // nexthops
- }
- stream_putw_at (s, 0, stream_get_endp (s));
-
- client->nh_last_upd_time = monotime(NULL);
- client->last_write_cmd = cmd;
- return zebra_server_send_message(client);
+ }
+ if (re) {
+ stream_putc(s, re->distance);
+ stream_putl(s, re->metric);
+ num = 0;
+ nump = stream_get_endp(s);
+ stream_putc(s, 0);
+ for (nexthop = re->nexthop; nexthop; nexthop = nexthop->next)
+ if ((CHECK_FLAG(nexthop->flags, NEXTHOP_FLAG_FIB)
+ || CHECK_FLAG(nexthop->flags,
+ NEXTHOP_FLAG_RECURSIVE))
+ && CHECK_FLAG(nexthop->flags,
+ NEXTHOP_FLAG_ACTIVE)) {
+ stream_putc(s, nexthop->type);
+ switch (nexthop->type) {
+ case NEXTHOP_TYPE_IPV4:
+ stream_put_in_addr(s,
+ &nexthop->gate.ipv4);
+ stream_putl(s, nexthop->ifindex);
+ break;
+ case NEXTHOP_TYPE_IFINDEX:
+ stream_putl(s, nexthop->ifindex);
+ break;
+ case NEXTHOP_TYPE_IPV4_IFINDEX:
+ stream_put_in_addr(s,
+ &nexthop->gate.ipv4);
+ stream_putl(s, nexthop->ifindex);
+ break;
+ case NEXTHOP_TYPE_IPV6:
+ stream_put(s, &nexthop->gate.ipv6, 16);
+ stream_putl(s, nexthop->ifindex);
+ break;
+ case NEXTHOP_TYPE_IPV6_IFINDEX:
+ stream_put(s, &nexthop->gate.ipv6, 16);
+ stream_putl(s, nexthop->ifindex);
+ break;
+ default:
+ /* do nothing */
+ break;
+ }
+ num++;
+ }
+ stream_putc_at(s, nump, num);
+ } else {
+ stream_putc(s, 0); // distance
+ stream_putl(s, 0); // metric
+ stream_putc(s, 0); // nexthops
+ }
+ stream_putw_at(s, 0, stream_get_endp(s));
+
+ client->nh_last_upd_time = monotime(NULL);
+ client->last_write_cmd = cmd;
+ return zebra_server_send_message(client);
}
-static void
-print_nh (struct nexthop *nexthop, struct vty *vty)
+static void print_nh(struct nexthop *nexthop, struct vty *vty)
{
- char buf[BUFSIZ];
- struct zebra_ns *zns = zebra_ns_lookup (NS_DEFAULT);
-
- switch (nexthop->type)
- {
- case NEXTHOP_TYPE_IPV4:
- case NEXTHOP_TYPE_IPV4_IFINDEX:
- vty_out (vty, " via %s", inet_ntoa (nexthop->gate.ipv4));
- if (nexthop->ifindex)
- vty_out (vty, ", %s", ifindex2ifname_per_ns (zns, nexthop->ifindex));
- break;
- case NEXTHOP_TYPE_IPV6:
- case NEXTHOP_TYPE_IPV6_IFINDEX:
- vty_out (vty, " %s",
- inet_ntop (AF_INET6, &nexthop->gate.ipv6, buf, BUFSIZ));
- if (nexthop->ifindex)
- vty_out (vty, ", via %s", ifindex2ifname_per_ns (zns, nexthop->ifindex));
- break;
- case NEXTHOP_TYPE_IFINDEX:
- vty_out (vty, " is directly connected, %s",
- ifindex2ifname_per_ns (zns, nexthop->ifindex));
- break;
- case NEXTHOP_TYPE_BLACKHOLE:
- vty_out (vty, " is directly connected, Null0");
- break;
- default:
- break;
- }
- vty_out(vty, "\n");
+ char buf[BUFSIZ];
+ struct zebra_ns *zns = zebra_ns_lookup(NS_DEFAULT);
+
+ switch (nexthop->type) {
+ case NEXTHOP_TYPE_IPV4:
+ case NEXTHOP_TYPE_IPV4_IFINDEX:
+ vty_out(vty, " via %s", inet_ntoa(nexthop->gate.ipv4));
+ if (nexthop->ifindex)
+ vty_out(vty, ", %s",
+ ifindex2ifname_per_ns(zns, nexthop->ifindex));
+ break;
+ case NEXTHOP_TYPE_IPV6:
+ case NEXTHOP_TYPE_IPV6_IFINDEX:
+ vty_out(vty, " %s",
+ inet_ntop(AF_INET6, &nexthop->gate.ipv6, buf, BUFSIZ));
+ if (nexthop->ifindex)
+ vty_out(vty, ", via %s",
+ ifindex2ifname_per_ns(zns, nexthop->ifindex));
+ break;
+ case NEXTHOP_TYPE_IFINDEX:
+ vty_out(vty, " is directly connected, %s",
+ ifindex2ifname_per_ns(zns, nexthop->ifindex));
+ break;
+ case NEXTHOP_TYPE_BLACKHOLE:
+ vty_out(vty, " is directly connected, Null0");
+ break;
+ default:
+ break;
+ }
+ vty_out(vty, "\n");
}
-static void
-print_rnh (struct route_node *rn, struct vty *vty)
+static void print_rnh(struct route_node *rn, struct vty *vty)
{
- struct rnh *rnh;
- struct nexthop *nexthop;
- struct listnode *node;
- struct zserv *client;
- char buf[BUFSIZ];
-
- rnh = rn->info;
- vty_out(vty, "%s%s\n", inet_ntop(rn->p.family, &rn->p.u.prefix, buf, BUFSIZ),
- CHECK_FLAG(rnh->flags, ZEBRA_NHT_CONNECTED) ? "(Connected)" : "");
- if (rnh->state)
- {
- vty_out(vty, " resolved via %s\n",
- zebra_route_string(rnh->state->type));
- for (nexthop = rnh->state->nexthop; nexthop; nexthop = nexthop->next)
- print_nh(nexthop, vty);
- }
- else
- vty_out(vty, " unresolved%s\n",
- CHECK_FLAG(rnh->flags, ZEBRA_NHT_CONNECTED) ? "(Connected)" : "");
-
- vty_out(vty, " Client list:");
- for (ALL_LIST_ELEMENTS_RO(rnh->client_list, node, client))
- vty_out(vty, " %s(fd %d)%s", zebra_route_string(client->proto),
- client->sock, rnh->filtered[client->proto] ? "(filtered)" : "");
- if (!list_isempty(rnh->zebra_static_route_list))
- vty_out(vty, " zebra%s", rnh->filtered[ZEBRA_ROUTE_STATIC] ? "(filtered)" : "");
- vty_out(vty, "\n");
+ struct rnh *rnh;
+ struct nexthop *nexthop;
+ struct listnode *node;
+ struct zserv *client;
+ char buf[BUFSIZ];
+
+ rnh = rn->info;
+ vty_out(vty, "%s%s\n",
+ inet_ntop(rn->p.family, &rn->p.u.prefix, buf, BUFSIZ),
+ CHECK_FLAG(rnh->flags, ZEBRA_NHT_CONNECTED) ? "(Connected)"
+ : "");
+ if (rnh->state) {
+ vty_out(vty, " resolved via %s\n",
+ zebra_route_string(rnh->state->type));
+ for (nexthop = rnh->state->nexthop; nexthop;
+ nexthop = nexthop->next)
+ print_nh(nexthop, vty);
+ } else
+ vty_out(vty, " unresolved%s\n",
+ CHECK_FLAG(rnh->flags, ZEBRA_NHT_CONNECTED)
+ ? "(Connected)"
+ : "");
+
+ vty_out(vty, " Client list:");
+ for (ALL_LIST_ELEMENTS_RO(rnh->client_list, node, client))
+ vty_out(vty, " %s(fd %d)%s", zebra_route_string(client->proto),
+ client->sock,
+ rnh->filtered[client->proto] ? "(filtered)" : "");
+ if (!list_isempty(rnh->zebra_static_route_list))
+ vty_out(vty, " zebra%s",
+ rnh->filtered[ZEBRA_ROUTE_STATIC] ? "(filtered)" : "");
+ vty_out(vty, "\n");
}
projects / mirror_frr.git / blobdiff