/* Redistribution Handler * Copyright (C) 1998 Kunihiro Ishiguro * * This file is part of GNU Zebra. * * GNU Zebra is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License as published by the * Free Software Foundation; either version 2, or (at your option) any * later version. * * GNU Zebra is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public License along * with this program; see the file COPYING; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ #include #include "vector.h" #include "vty.h" #include "command.h" #include "prefix.h" #include "table.h" #include "stream.h" #include "zclient.h" #include "linklist.h" #include "log.h" #include "vrf.h" #include "srcdest_table.h" #include "zebra/rib.h" #include "zebra/zserv.h" #include "zebra/zebra_ns.h" #include "zebra/zebra_vrf.h" #include "zebra/zebra_routemap.h" #include "zebra/redistribute.h" #include "zebra/debug.h" #include "zebra/router-id.h" #include "zebra/zapi_msg.h" #include "zebra/zebra_memory.h" #include "zebra/zebra_vxlan.h" #define ZEBRA_PTM_SUPPORT /* array holding redistribute info about table redistribution */ /* bit AFI is set if that AFI is redistributing routes from this table */ static int zebra_import_table_used[AFI_MAX][ZEBRA_KERNEL_TABLE_MAX]; static uint32_t zebra_import_table_distance[AFI_MAX][ZEBRA_KERNEL_TABLE_MAX]; int is_zebra_import_table_enabled(afi_t afi, uint32_t table_id) { /* * Make sure that what we are called with actualy makes sense */ if (afi == AFI_MAX) return 0; if (is_zebra_valid_kernel_table(table_id) && table_id < ZEBRA_KERNEL_TABLE_MAX) return zebra_import_table_used[afi][table_id]; return 0; } static void zebra_redistribute_default(struct zserv *client, vrf_id_t vrf_id) { int afi; struct prefix p; struct route_table *table; struct route_node *rn; struct route_entry *newre; for (afi = AFI_IP; afi <= AFI_IP6; afi++) { /* Lookup table. */ table = zebra_vrf_table(afi, SAFI_UNICAST, vrf_id); if (!table) continue; /* Lookup default route. */ memset(&p, 0, sizeof(p)); p.family = afi2family(afi); rn = route_node_lookup(table, &p); if (!rn) continue; RNODE_FOREACH_RE (rn, newre) { if (CHECK_FLAG(newre->flags, ZEBRA_FLAG_SELECTED) && newre->distance != DISTANCE_INFINITY) zsend_redistribute_route( ZEBRA_REDISTRIBUTE_ROUTE_ADD, client, &rn->p, NULL, newre); } route_unlock_node(rn); } } /* Redistribute routes. */ static void zebra_redistribute(struct zserv *client, int type, unsigned short instance, vrf_id_t vrf_id, int afi) { struct route_entry *newre; struct route_table *table; struct route_node *rn; table = zebra_vrf_table(afi, SAFI_UNICAST, vrf_id); if (!table) return; for (rn = route_top(table); rn; rn = srcdest_route_next(rn)) RNODE_FOREACH_RE (rn, newre) { const struct prefix *dst_p, *src_p; char buf[PREFIX_STRLEN]; srcdest_rnode_prefixes(rn, &dst_p, &src_p); if (IS_ZEBRA_DEBUG_EVENT) zlog_debug( "%s: client %s %s(%u) checking: selected=%d, type=%d, distance=%d, metric=%d zebra_check_addr=%d", __func__, zebra_route_string(client->proto), prefix2str(dst_p, buf, sizeof(buf)), vrf_id, CHECK_FLAG(newre->flags, ZEBRA_FLAG_SELECTED), newre->type, newre->distance, newre->metric, zebra_check_addr(dst_p)); if (!CHECK_FLAG(newre->flags, ZEBRA_FLAG_SELECTED)) continue; if ((type != ZEBRA_ROUTE_ALL && (newre->type != type || newre->instance != instance))) continue; if (newre->distance == DISTANCE_INFINITY) continue; if (!zebra_check_addr(dst_p)) continue; zsend_redistribute_route(ZEBRA_REDISTRIBUTE_ROUTE_ADD, client, dst_p, src_p, newre); } } /* Either advertise a route for redistribution to registered clients or */ /* withdraw redistribution if add cannot be done for client */ void redistribute_update(const struct prefix *p, const struct prefix *src_p, struct route_entry *re, struct route_entry *prev_re) { struct listnode *node, *nnode; struct zserv *client; int send_redistribute; int afi; char buf[PREFIX_STRLEN]; if (IS_ZEBRA_DEBUG_RIB) { zlog_debug( "%u:%s: Redist update re %p (type %d), old %p (type %d)", re->vrf_id, prefix2str(p, buf, sizeof(buf)), re, re->type, prev_re, prev_re ? prev_re->type : -1); } afi = family2afi(p->family); if (!afi) { zlog_warn("%s: Unknown AFI/SAFI prefix received\n", __FUNCTION__); return; } for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) { send_redistribute = 0; if (is_default_prefix(p) && vrf_bitmap_check(client->redist_default, re->vrf_id)) send_redistribute = 1; else if (vrf_bitmap_check(client->redist[afi][ZEBRA_ROUTE_ALL], re->vrf_id)) send_redistribute = 1; else if (re->instance && redist_check_instance( &client->mi_redist[afi][re->type], re->instance)) send_redistribute = 1; else if (vrf_bitmap_check(client->redist[afi][re->type], re->vrf_id)) send_redistribute = 1; if (send_redistribute) { if (IS_ZEBRA_DEBUG_EVENT) { zlog_debug( "%s: client %s %s(%u), type=%d, distance=%d, metric=%d", __func__, zebra_route_string(client->proto), prefix2str(p, buf, sizeof(buf)), re->vrf_id, re->type, re->distance, re->metric); } zsend_redistribute_route(ZEBRA_REDISTRIBUTE_ROUTE_ADD, client, p, src_p, re); } else if (prev_re && ((re->instance && redist_check_instance( &client->mi_redist[afi] [prev_re->type], re->instance)) || vrf_bitmap_check( client->redist[afi][prev_re->type], re->vrf_id))) { zsend_redistribute_route(ZEBRA_REDISTRIBUTE_ROUTE_DEL, client, p, src_p, prev_re); } } } void redistribute_delete(const struct prefix *p, const struct prefix *src_p, struct route_entry *re) { struct listnode *node, *nnode; struct zserv *client; char buf[INET6_ADDRSTRLEN]; int afi; if (IS_ZEBRA_DEBUG_RIB) { inet_ntop(p->family, &p->u.prefix, buf, INET6_ADDRSTRLEN); zlog_debug("%u:%s/%d: Redist delete re %p (type %d)", re->vrf_id, buf, p->prefixlen, re, re->type); } /* Add DISTANCE_INFINITY check. */ if (re->distance == DISTANCE_INFINITY) return; afi = family2afi(p->family); if (!afi) { zlog_warn("%s: Unknown AFI/SAFI prefix received\n", __FUNCTION__); return; } for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) { if ((is_default_prefix(p) && vrf_bitmap_check(client->redist_default, re->vrf_id)) || vrf_bitmap_check(client->redist[afi][ZEBRA_ROUTE_ALL], re->vrf_id) || (re->instance && redist_check_instance( &client->mi_redist[afi][re->type], re->instance)) || vrf_bitmap_check(client->redist[afi][re->type], re->vrf_id)) { zsend_redistribute_route(ZEBRA_REDISTRIBUTE_ROUTE_DEL, client, p, src_p, re); } } } void zebra_redistribute_add(ZAPI_HANDLER_ARGS) { afi_t afi = 0; int type = 0; unsigned short instance; STREAM_GETC(msg, afi); STREAM_GETC(msg, type); STREAM_GETW(msg, instance); if (IS_ZEBRA_DEBUG_EVENT) zlog_debug( "%s: client proto %s afi=%d, wants %s, vrf %u, instance=%d", __func__, zebra_route_string(client->proto), afi, zebra_route_string(type), zvrf_id(zvrf), instance); if (afi == 0 || afi >= AFI_MAX) { zlog_warn("%s: Specified afi %d does not exist", __PRETTY_FUNCTION__, afi); return; } if (type == 0 || type >= ZEBRA_ROUTE_MAX) { zlog_warn("%s: Specified Route Type %d does not exist", __PRETTY_FUNCTION__, type); return; } if (instance) { if (!redist_check_instance(&client->mi_redist[afi][type], instance)) { redist_add_instance(&client->mi_redist[afi][type], instance); zebra_redistribute(client, type, instance, zvrf_id(zvrf), afi); } } else { if (!vrf_bitmap_check(client->redist[afi][type], zvrf_id(zvrf))) { if (IS_ZEBRA_DEBUG_EVENT) zlog_debug("%s: setting vrf %u redist bitmap", __func__, zvrf_id(zvrf)); vrf_bitmap_set(client->redist[afi][type], zvrf_id(zvrf)); zebra_redistribute(client, type, 0, zvrf_id(zvrf), afi); } } stream_failure: return; } void zebra_redistribute_delete(ZAPI_HANDLER_ARGS) { afi_t afi = 0; int type = 0; unsigned short instance; STREAM_GETC(msg, afi); STREAM_GETC(msg, type); STREAM_GETW(msg, instance); if (afi == 0 || afi >= AFI_MAX) { zlog_warn("%s: Specified afi %d does not exist", __PRETTY_FUNCTION__, afi); return; } if (type == 0 || type >= ZEBRA_ROUTE_MAX) { zlog_warn("%s: Specified Route Type %d does not exist", __PRETTY_FUNCTION__, type); return; } /* * NOTE: no need to withdraw the previously advertised routes. The * clients * themselves should keep track of the received routes from zebra and * withdraw them when necessary. */ if (instance) redist_del_instance(&client->mi_redist[afi][type], instance); else vrf_bitmap_unset(client->redist[afi][type], zvrf_id(zvrf)); stream_failure: return; } void zebra_redistribute_default_add(ZAPI_HANDLER_ARGS) { vrf_bitmap_set(client->redist_default, zvrf_id(zvrf)); zebra_redistribute_default(client, zvrf_id(zvrf)); } void zebra_redistribute_default_delete(ZAPI_HANDLER_ARGS) { vrf_bitmap_unset(client->redist_default, zvrf_id(zvrf)); } /* Interface up information. */ void zebra_interface_up_update(struct interface *ifp) { struct listnode *node, *nnode; struct zserv *client; if (IS_ZEBRA_DEBUG_EVENT) zlog_debug("MESSAGE: ZEBRA_INTERFACE_UP %s(%u)", ifp->name, ifp->vrf_id); if (ifp->ptm_status || !ifp->ptm_enable) { for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) if (client->ifinfo) { zsend_interface_update(ZEBRA_INTERFACE_UP, client, ifp); zsend_interface_link_params(client, ifp); } } } /* Interface down information. */ void zebra_interface_down_update(struct interface *ifp) { struct listnode *node, *nnode; struct zserv *client; if (IS_ZEBRA_DEBUG_EVENT) zlog_debug("MESSAGE: ZEBRA_INTERFACE_DOWN %s(%u)", ifp->name, ifp->vrf_id); for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) { zsend_interface_update(ZEBRA_INTERFACE_DOWN, client, ifp); } } /* Interface information update. */ void zebra_interface_add_update(struct interface *ifp) { struct listnode *node, *nnode; struct zserv *client; if (IS_ZEBRA_DEBUG_EVENT) zlog_debug("MESSAGE: ZEBRA_INTERFACE_ADD %s(%u)", ifp->name, ifp->vrf_id); for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) if (client->ifinfo) { client->ifadd_cnt++; zsend_interface_add(client, ifp); zsend_interface_link_params(client, ifp); } } void zebra_interface_delete_update(struct interface *ifp) { struct listnode *node, *nnode; struct zserv *client; if (IS_ZEBRA_DEBUG_EVENT) zlog_debug("MESSAGE: ZEBRA_INTERFACE_DELETE %s(%u)", ifp->name, ifp->vrf_id); for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) { client->ifdel_cnt++; zsend_interface_delete(client, ifp); } } /* Interface address addition. */ void zebra_interface_address_add_update(struct interface *ifp, struct connected *ifc) { struct listnode *node, *nnode; struct zserv *client; struct prefix *p; if (IS_ZEBRA_DEBUG_EVENT) { char buf[PREFIX_STRLEN]; p = ifc->address; zlog_debug("MESSAGE: ZEBRA_INTERFACE_ADDRESS_ADD %s on %s(%u)", prefix2str(p, buf, sizeof(buf)), ifp->name, ifp->vrf_id); } if (!CHECK_FLAG(ifc->conf, ZEBRA_IFC_REAL)) zlog_warn( "WARNING: advertising address to clients that is not yet usable."); zebra_vxlan_add_del_gw_macip(ifp, ifc->address, 1); router_id_add_address(ifc); for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) if (CHECK_FLAG(ifc->conf, ZEBRA_IFC_REAL)) { client->connected_rt_add_cnt++; zsend_interface_address(ZEBRA_INTERFACE_ADDRESS_ADD, client, ifp, ifc); } } /* Interface address deletion. */ void zebra_interface_address_delete_update(struct interface *ifp, struct connected *ifc) { struct listnode *node, *nnode; struct zserv *client; struct prefix *p; if (IS_ZEBRA_DEBUG_EVENT) { char buf[PREFIX_STRLEN]; p = ifc->address; zlog_debug("MESSAGE: ZEBRA_INTERFACE_ADDRESS_DELETE %s on %s(%u)", prefix2str(p, buf, sizeof(buf)), ifp->name, ifp->vrf_id); } zebra_vxlan_add_del_gw_macip(ifp, ifc->address, 0); router_id_del_address(ifc); for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) if (CHECK_FLAG(ifc->conf, ZEBRA_IFC_REAL)) { client->connected_rt_del_cnt++; zsend_interface_address(ZEBRA_INTERFACE_ADDRESS_DELETE, client, ifp, ifc); } } /* Interface VRF change. May need to delete from clients not interested in * the new VRF. Note that this function is invoked *prior* to the VRF change. */ void zebra_interface_vrf_update_del(struct interface *ifp, vrf_id_t new_vrf_id) { struct listnode *node, *nnode; struct zserv *client; if (IS_ZEBRA_DEBUG_EVENT) zlog_debug( "MESSAGE: ZEBRA_INTERFACE_VRF_UPDATE/DEL %s VRF Id %u -> %u", ifp->name, ifp->vrf_id, new_vrf_id); for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) { /* Need to delete if the client is not interested in the new * VRF. */ zsend_interface_update(ZEBRA_INTERFACE_DOWN, client, ifp); client->ifdel_cnt++; zsend_interface_delete(client, ifp); zsend_interface_vrf_update(client, ifp, new_vrf_id); } } /* Interface VRF change. This function is invoked *post* VRF change and sends an * add to clients who are interested in the new VRF but not in the old VRF. */ void zebra_interface_vrf_update_add(struct interface *ifp, vrf_id_t old_vrf_id) { struct listnode *node, *nnode; struct zserv *client; if (IS_ZEBRA_DEBUG_EVENT) zlog_debug( "MESSAGE: ZEBRA_INTERFACE_VRF_UPDATE/ADD %s VRF Id %u -> %u", ifp->name, old_vrf_id, ifp->vrf_id); for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) { /* Need to add if the client is interested in the new VRF. */ client->ifadd_cnt++; zsend_interface_add(client, ifp); zsend_interface_addresses(client, ifp); } } int zebra_add_import_table_entry(struct route_node *rn, struct route_entry *re, const char *rmap_name) { struct route_entry *newre; struct route_entry *same; struct prefix p; route_map_result_t ret = RMAP_MATCH; afi_t afi; afi = family2afi(rn->p.family); if (rmap_name) ret = zebra_import_table_route_map_check( afi, re->type, re->instance, &rn->p, re->ng.nexthop, re->vrf_id, re->tag, rmap_name); if (ret != RMAP_MATCH) { UNSET_FLAG(re->flags, ZEBRA_FLAG_SELECTED); zebra_del_import_table_entry(rn, re); return 0; } prefix_copy(&p, &rn->p); RNODE_FOREACH_RE (rn, same) { if (CHECK_FLAG(same->status, ROUTE_ENTRY_REMOVED)) continue; if (same->type == re->type && same->instance == re->instance && same->table == re->table && same->type != ZEBRA_ROUTE_CONNECT) break; } if (same) { UNSET_FLAG(same->flags, ZEBRA_FLAG_SELECTED); zebra_del_import_table_entry(rn, same); } newre = XCALLOC(MTYPE_RE, sizeof(struct route_entry)); newre->type = ZEBRA_ROUTE_TABLE; newre->distance = zebra_import_table_distance[afi][re->table]; newre->flags = re->flags; newre->metric = re->metric; newre->mtu = re->mtu; newre->table = zebrad.rtm_table_default; newre->nexthop_num = 0; newre->uptime = time(NULL); newre->instance = re->table; route_entry_copy_nexthops(newre, re->ng.nexthop); rib_add_multipath(afi, SAFI_UNICAST, &p, NULL, newre); return 0; } int zebra_del_import_table_entry(struct route_node *rn, struct route_entry *re) { struct prefix p; afi_t afi; afi = family2afi(rn->p.family); prefix_copy(&p, &rn->p); rib_delete(afi, SAFI_UNICAST, re->vrf_id, ZEBRA_ROUTE_TABLE, re->table, re->flags, &p, NULL, re->ng.nexthop, zebrad.rtm_table_default, re->metric, re->distance, false); return 0; } /* Assuming no one calls this with the main routing table */ int zebra_import_table(afi_t afi, uint32_t table_id, uint32_t distance, const char *rmap_name, int add) { struct route_table *table; struct route_entry *re; struct route_node *rn; if (!is_zebra_valid_kernel_table(table_id) || ((table_id == RT_TABLE_MAIN) || (table_id == zebrad.rtm_table_default))) return (-1); if (afi >= AFI_MAX) return (-1); table = zebra_vrf_other_route_table(afi, table_id, VRF_DEFAULT); if (table == NULL) { return 0; } else if (IS_ZEBRA_DEBUG_RIB) { zlog_debug("%s routes from table %d", add ? "Importing" : "Unimporting", table_id); } if (add) { if (rmap_name) zebra_add_import_table_route_map(afi, rmap_name, table_id); else { rmap_name = zebra_get_import_table_route_map(afi, table_id); if (rmap_name) { zebra_del_import_table_route_map(afi, table_id); rmap_name = NULL; } } zebra_import_table_used[afi][table_id] = 1; zebra_import_table_distance[afi][table_id] = distance; } else { zebra_import_table_used[afi][table_id] = 0; zebra_import_table_distance[afi][table_id] = ZEBRA_TABLE_DISTANCE_DEFAULT; rmap_name = zebra_get_import_table_route_map(afi, table_id); if (rmap_name) { zebra_del_import_table_route_map(afi, table_id); rmap_name = NULL; } } for (rn = route_top(table); rn; rn = route_next(rn)) { /* For each entry in the non-default routing table, * add the entry in the main table */ if (!rn->info) continue; RNODE_FOREACH_RE (rn, re) { if (CHECK_FLAG(re->status, ROUTE_ENTRY_REMOVED)) continue; break; } if (!re) continue; if (((afi == AFI_IP) && (rn->p.family == AF_INET)) || ((afi == AFI_IP6) && (rn->p.family == AF_INET6))) { if (add) zebra_add_import_table_entry(rn, re, rmap_name); else zebra_del_import_table_entry(rn, re); } } return 0; } int zebra_import_table_config(struct vty *vty) { int i; afi_t afi; int write = 0; char afi_str[AFI_MAX][10] = {"", "ip", "ipv6", "ethernet"}; const char *rmap_name; for (afi = AFI_IP; afi < AFI_MAX; afi++) { for (i = 1; i < ZEBRA_KERNEL_TABLE_MAX; i++) { if (!is_zebra_import_table_enabled(afi, i)) continue; if (zebra_import_table_distance[afi][i] != ZEBRA_TABLE_DISTANCE_DEFAULT) { vty_out(vty, "%s import-table %d distance %d", afi_str[afi], i, zebra_import_table_distance[afi][i]); } else { vty_out(vty, "%s import-table %d", afi_str[afi], i); } rmap_name = zebra_get_import_table_route_map(afi, i); if (rmap_name) vty_out(vty, " route-map %s", rmap_name); vty_out(vty, "\n"); write = 1; } } return write; } void zebra_import_table_rm_update() { afi_t afi; int i; struct route_table *table; struct route_entry *re; struct route_node *rn; const char *rmap_name; for (afi = AFI_IP; afi < AFI_MAX; afi++) { for (i = 1; i < ZEBRA_KERNEL_TABLE_MAX; i++) { if (!is_zebra_import_table_enabled(afi, i)) continue; rmap_name = zebra_get_import_table_route_map(afi, i); if (!rmap_name) return; table = zebra_vrf_other_route_table(afi, i, VRF_DEFAULT); for (rn = route_top(table); rn; rn = route_next(rn)) { /* For each entry in the non-default * routing table, * add the entry in the main table */ if (!rn->info) continue; RNODE_FOREACH_RE (rn, re) { if (CHECK_FLAG(re->status, ROUTE_ENTRY_REMOVED)) continue; break; } if (!re) continue; if (((afi == AFI_IP) && (rn->p.family == AF_INET)) || ((afi == AFI_IP6) && (rn->p.family == AF_INET6))) zebra_add_import_table_entry(rn, re, rmap_name); } } } return; } /* Interface parameters update */ void zebra_interface_parameters_update(struct interface *ifp) { struct listnode *node, *nnode; struct zserv *client; if (IS_ZEBRA_DEBUG_EVENT) zlog_debug("MESSAGE: ZEBRA_INTERFACE_LINK_PARAMS %s(%u)", ifp->name, ifp->vrf_id); for (ALL_LIST_ELEMENTS(zebrad.client_list, node, nnode, client)) if (client->ifinfo) zsend_interface_link_params(client, ifp); }