eigrpd/eigrp_zebra.c

   1 /*
   2  * Zebra connect library for EIGRP.
   3  * Copyright (C) 2013-2014
   4  * Authors:
   5  *   Donnie Savage
   6  *   Jan Janovic
   7  *   Matej Perina
   8  *   Peter Orsag
   9  *   Peter Paluch
  10  *
  11  * This file is part of GNU Zebra.
  12  *
  13  * GNU Zebra is free software; you can redistribute it and/or modify it
  14  * under the terms of the GNU General Public License as published by the
  15  * Free Software Foundation; either version 2, or (at your option) any
  16  * later version.
  17  *
  18  * GNU Zebra is distributed in the hope that it will be useful, but
  19  * WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  21  * General Public License for more details.
  22  *
  23  * You should have received a copy of the GNU General Public License along
  24  * with this program; see the file COPYING; if not, write to the Free Software
  25  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  26  */
  27
  28 #include <zebra.h>
  29
  30 #include "thread.h"
  31 #include "command.h"
  32 #include "network.h"
  33 #include "prefix.h"
  34 #include "routemap.h"
  35 #include "table.h"
  36 #include "stream.h"
  37 #include "memory.h"
  38 #include "zclient.h"
  39 #include "filter.h"
  40 #include "plist.h"
  41 #include "log.h"
  42 #include "nexthop.h"
  43
  44 #include "eigrpd/eigrp_structs.h"
  45 #include "eigrpd/eigrpd.h"
  46 #include "eigrpd/eigrp_interface.h"
  47 #include "eigrpd/eigrp_neighbor.h"
  48 #include "eigrpd/eigrp_packet.h"
  49 #include "eigrpd/eigrp_zebra.h"
  50 #include "eigrpd/eigrp_vty.h"
  51 #include "eigrpd/eigrp_dump.h"
  52 #include "eigrpd/eigrp_network.h"
  53 #include "eigrpd/eigrp_topology.h"
  54 #include "eigrpd/eigrp_fsm.h"
  55
  56 static int eigrp_interface_add(int, struct zclient *, zebra_size_t, vrf_id_t);
  57 static int eigrp_interface_delete(int, struct zclient *, zebra_size_t,
  58                                   vrf_id_t);
  59 static int eigrp_interface_address_add(int, struct zclient *, zebra_size_t,
  60                                        vrf_id_t vrf_id);
  61 static int eigrp_interface_address_delete(int, struct zclient *, zebra_size_t,
  62                                           vrf_id_t vrf_id);
  63 static int eigrp_interface_state_up(int, struct zclient *, zebra_size_t,
  64                                     vrf_id_t vrf_id);
  65 static int eigrp_interface_state_down(int, struct zclient *, zebra_size_t,
  66                                       vrf_id_t vrf_id);
  67 static struct interface *zebra_interface_if_lookup(struct stream *);
  68
  69 static int eigrp_zebra_read_route(int, struct zclient *, zebra_size_t,
  70                                   vrf_id_t vrf_id);
  71
  72 /* Zebra structure to hold current status. */
  73 struct zclient *zclient = NULL;
  74
  75 /* For registering threads. */
  76 extern struct thread_master *master;
  77 struct in_addr router_id_zebra;
  78
  79 /* Router-id update message from zebra. */
  80 static int eigrp_router_id_update_zebra(int command, struct zclient *zclient,
  81                                         zebra_size_t length, vrf_id_t vrf_id)
  82 {
  83         struct eigrp *eigrp;
  84         struct prefix router_id;
  85         zebra_router_id_update_read(zclient->ibuf, &router_id);
  86
  87         router_id_zebra = router_id.u.prefix4;
  88
  89         eigrp = eigrp_lookup();
  90
  91         if (eigrp != NULL)
  92                 eigrp_router_id_update(eigrp);
  93
  94         return 0;
  95 }
  96
  97 static int eigrp_zebra_route_notify_owner(int command, struct zclient *zclient,
  98                                           zebra_size_t length, vrf_id_t vrf_id)
  99 {
 100         struct prefix p;
 101         enum zapi_route_notify_owner note;
 102         uint32_t table;
 103
 104         if (!zapi_route_notify_decode(zclient->ibuf, &p, &table, &note))
 105                 return -1;
 106
 107         return 0;
 108 }
 109
 110 static void eigrp_zebra_connected(struct zclient *zclient)
 111 {
 112         zclient_send_reg_requests(zclient, VRF_DEFAULT);
 113 }
 114
 115 void eigrp_zebra_init(void)
 116 {
 117         struct zclient_options opt = { .receive_notify = false };
 118
 119         zclient = zclient_new_notify(master, &opt);
 120
 121         zclient_init(zclient, ZEBRA_ROUTE_EIGRP, 0, &eigrpd_privs);
 122         zclient->zebra_connected = eigrp_zebra_connected;
 123         zclient->router_id_update = eigrp_router_id_update_zebra;
 124         zclient->interface_add = eigrp_interface_add;
 125         zclient->interface_delete = eigrp_interface_delete;
 126         zclient->interface_up = eigrp_interface_state_up;
 127         zclient->interface_down = eigrp_interface_state_down;
 128         zclient->interface_address_add = eigrp_interface_address_add;
 129         zclient->interface_address_delete = eigrp_interface_address_delete;
 130         zclient->redistribute_route_add = eigrp_zebra_read_route;
 131         zclient->redistribute_route_del = eigrp_zebra_read_route;
 132         zclient->route_notify_owner = eigrp_zebra_route_notify_owner;
 133 }
 134
 135
 136 /* Zebra route add and delete treatment. */
 137 static int eigrp_zebra_read_route(int command, struct zclient *zclient,
 138                                   zebra_size_t length, vrf_id_t vrf_id)
 139 {
 140         struct zapi_route api;
 141         struct eigrp *eigrp;
 142
 143         if (zapi_route_decode(zclient->ibuf, &api) < 0)
 144                 return -1;
 145
 146         if (IPV4_NET127(ntohl(api.prefix.u.prefix4.s_addr)))
 147                 return 0;
 148
 149         eigrp = eigrp_lookup();
 150         if (eigrp == NULL)
 151                 return 0;
 152
 153         if (command == ZEBRA_REDISTRIBUTE_ROUTE_ADD) {
 154
 155         } else /* if (command == ZEBRA_REDISTRIBUTE_ROUTE_DEL) */
 156         {
 157         }
 158
 159         return 0;
 160 }
 161
 162 /* Inteface addition message from zebra. */
 163 static int eigrp_interface_add(int command, struct zclient *zclient,
 164                                zebra_size_t length, vrf_id_t vrf_id)
 165 {
 166         struct interface *ifp;
 167         struct eigrp_interface *ei;
 168
 169         ifp = zebra_interface_add_read(zclient->ibuf, vrf_id);
 170
 171         if (!ifp->info)
 172                 return 0;
 173
 174         ei = ifp->info;
 175
 176         ei->params.type = eigrp_default_iftype(ifp);
 177
 178         eigrp_if_update(ifp);
 179
 180         return 0;
 181 }
 182
 183 static int eigrp_interface_delete(int command, struct zclient *zclient,
 184                                   zebra_size_t length, vrf_id_t vrf_id)
 185 {
 186         struct interface *ifp;
 187         struct stream *s;
 188
 189         s = zclient->ibuf;
 190         /* zebra_interface_state_read () updates interface structure in iflist
 191          */
 192         ifp = zebra_interface_state_read(s, vrf_id);
 193
 194         if (ifp == NULL)
 195                 return 0;
 196
 197         if (if_is_up(ifp))
 198                 zlog_warn("Zebra: got delete of %s, but interface is still up",
 199                           ifp->name);
 200
 201         if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
 202                 zlog_debug(
 203                         "Zebra: interface delete %s index %d flags %llx metric %d mtu %d",
 204                         ifp->name, ifp->ifindex, (unsigned long long)ifp->flags,
 205                         ifp->metric, ifp->mtu);
 206
 207         if (ifp->info)
 208                 eigrp_if_free(ifp->info,
 209                               INTERFACE_DOWN_BY_ZEBRA);
 210
 211         if_set_index(ifp, IFINDEX_INTERNAL);
 212         return 0;
 213 }
 214
 215 static int eigrp_interface_address_add(int command, struct zclient *zclient,
 216                                        zebra_size_t length, vrf_id_t vrf_id)
 217 {
 218         struct connected *c;
 219
 220         c = zebra_interface_address_read(command, zclient->ibuf, vrf_id);
 221
 222         if (c == NULL)
 223                 return 0;
 224
 225         if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE)) {
 226                 char buf[128];
 227                 prefix2str(c->address, buf, sizeof(buf));
 228                 zlog_debug("Zebra: interface %s address add %s", c->ifp->name,
 229                            buf);
 230         }
 231
 232         eigrp_if_update(c->ifp);
 233
 234         return 0;
 235 }
 236
 237 static int eigrp_interface_address_delete(int command, struct zclient *zclient,
 238                                           zebra_size_t length, vrf_id_t vrf_id)
 239 {
 240         struct connected *c;
 241         struct interface *ifp;
 242         struct eigrp_interface *ei;
 243
 244         c = zebra_interface_address_read(command, zclient->ibuf, vrf_id);
 245
 246         if (c == NULL)
 247                 return 0;
 248
 249         if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE)) {
 250                 char buf[128];
 251                 prefix2str(c->address, buf, sizeof(buf));
 252                 zlog_debug("Zebra: interface %s address delete %s",
 253                            c->ifp->name, buf);
 254         }
 255
 256         ifp = c->ifp;
 257         ei = ifp->info;
 258         if (!ei)
 259                 return 0;
 260
 261         /* Call interface hook functions to clean up */
 262         eigrp_if_free(ei, INTERFACE_DOWN_BY_ZEBRA);
 263
 264         connected_free(c);
 265
 266         return 0;
 267 }
 268
 269 static int eigrp_interface_state_up(int command, struct zclient *zclient,
 270                                     zebra_size_t length, vrf_id_t vrf_id)
 271 {
 272         struct interface *ifp;
 273
 274         ifp = zebra_interface_if_lookup(zclient->ibuf);
 275
 276         if (ifp == NULL)
 277                 return 0;
 278
 279         /* Interface is already up. */
 280         if (if_is_operative(ifp)) {
 281                 /* Temporarily keep ifp values. */
 282                 struct interface if_tmp;
 283                 memcpy(&if_tmp, ifp, sizeof(struct interface));
 284
 285                 zebra_interface_if_set_value(zclient->ibuf, ifp);
 286
 287                 if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
 288                         zlog_debug("Zebra: Interface[%s] state update.",
 289                                    ifp->name);
 290
 291                 if (if_tmp.bandwidth != ifp->bandwidth) {
 292                         if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
 293                                 zlog_debug(
 294                                         "Zebra: Interface[%s] bandwidth change %d -> %d.",
 295                                         ifp->name, if_tmp.bandwidth,
 296                                         ifp->bandwidth);
 297
 298                         //          eigrp_if_recalculate_output_cost (ifp);
 299                 }
 300
 301                 if (if_tmp.mtu != ifp->mtu) {
 302                         if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
 303                                 zlog_debug(
 304                                         "Zebra: Interface[%s] MTU change %u -> %u.",
 305                                         ifp->name, if_tmp.mtu, ifp->mtu);
 306
 307                         /* Must reset the interface (simulate down/up) when MTU
 308                          * changes. */
 309                         eigrp_if_reset(ifp);
 310                 }
 311                 return 0;
 312         }
 313
 314         zebra_interface_if_set_value(zclient->ibuf, ifp);
 315
 316         if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
 317                 zlog_debug("Zebra: Interface[%s] state change to up.",
 318                            ifp->name);
 319
 320         if (ifp->info)
 321                 eigrp_if_up(ifp->info);
 322
 323         return 0;
 324 }
 325
 326 static int eigrp_interface_state_down(int command, struct zclient *zclient,
 327                                       zebra_size_t length, vrf_id_t vrf_id)
 328 {
 329         struct interface *ifp;
 330
 331         ifp = zebra_interface_state_read(zclient->ibuf, vrf_id);
 332
 333         if (ifp == NULL)
 334                 return 0;
 335
 336         if (IS_DEBUG_EIGRP(zebra, ZEBRA_INTERFACE))
 337                 zlog_debug("Zebra: Interface[%s] state change to down.",
 338                            ifp->name);
 339
 340         if (ifp->info)
 341                 eigrp_if_down(ifp->info);
 342
 343         return 0;
 344 }
 345
 346 static struct interface *zebra_interface_if_lookup(struct stream *s)
 347 {
 348         char ifname_tmp[INTERFACE_NAMSIZ];
 349
 350         /* Read interface name. */
 351         stream_get(ifname_tmp, s, INTERFACE_NAMSIZ);
 352
 353         /* And look it up. */
 354         return if_lookup_by_name(ifname_tmp, VRF_DEFAULT);
 355 }
 356
 357 void eigrp_zebra_route_add(struct prefix *p, struct list *successors)
 358 {
 359         struct zapi_route api;
 360         struct zapi_nexthop *api_nh;
 361         struct eigrp_nexthop_entry *te;
 362         struct listnode *node;
 363         int count = 0;
 364
 365         if (!zclient->redist[AFI_IP][ZEBRA_ROUTE_EIGRP])
 366                 return;
 367
 368         memset(&api, 0, sizeof(api));
 369         api.vrf_id = VRF_DEFAULT;
 370         api.type = ZEBRA_ROUTE_EIGRP;
 371         api.safi = SAFI_UNICAST;
 372         memcpy(&api.prefix, p, sizeof(*p));
 373
 374         SET_FLAG(api.message, ZAPI_MESSAGE_NEXTHOP);
 375
 376         /* Nexthop, ifindex, distance and metric information. */
 377         for (ALL_LIST_ELEMENTS_RO(successors, node, te)) {
 378                 if (count >= MULTIPATH_NUM)
 379                         break;
 380                 api_nh = &api.nexthops[count];
 381                 api_nh->vrf_id = VRF_DEFAULT;
 382                 if (te->adv_router->src.s_addr) {
 383                         api_nh->gate.ipv4 = te->adv_router->src;
 384                         api_nh->type = NEXTHOP_TYPE_IPV4_IFINDEX;
 385                 } else
 386                         api_nh->type = NEXTHOP_TYPE_IFINDEX;
 387                 api_nh->ifindex = te->ei->ifp->ifindex;
 388
 389                 count++;
 390         }
 391         api.nexthop_num = count;
 392
 393         if (IS_DEBUG_EIGRP(zebra, ZEBRA_REDISTRIBUTE)) {
 394                 char buf[2][PREFIX_STRLEN];
 395                 zlog_debug("Zebra: Route add %s nexthop %s",
 396                            prefix2str(p, buf[0], PREFIX_STRLEN),
 397                            inet_ntop(AF_INET, 0, buf[1], PREFIX_STRLEN));
 398         }
 399
 400         zclient_route_send(ZEBRA_ROUTE_ADD, zclient, &api);
 401 }
 402
 403 void eigrp_zebra_route_delete(struct prefix *p)
 404 {
 405         struct zapi_route api;
 406
 407         if (!zclient->redist[AFI_IP][ZEBRA_ROUTE_EIGRP])
 408                 return;
 409
 410         memset(&api, 0, sizeof(api));
 411         api.vrf_id = VRF_DEFAULT;
 412         api.type = ZEBRA_ROUTE_EIGRP;
 413         api.safi = SAFI_UNICAST;
 414         memcpy(&api.prefix, p, sizeof(*p));
 415         zclient_route_send(ZEBRA_ROUTE_DELETE, zclient, &api);
 416
 417         if (IS_DEBUG_EIGRP(zebra, ZEBRA_REDISTRIBUTE)) {
 418                 char buf[PREFIX_STRLEN];
 419                 zlog_debug("Zebra: Route del %s",
 420                            prefix2str(p, buf, PREFIX_STRLEN));
 421         }
 422
 423         return;
 424 }
 425
 426 int eigrp_is_type_redistributed(int type)
 427 {
 428         return ((DEFAULT_ROUTE_TYPE(type))
 429                         ? vrf_bitmap_check(zclient->default_information,
 430                                            VRF_DEFAULT)
 431                         : vrf_bitmap_check(zclient->redist[AFI_IP][type],
 432                                            VRF_DEFAULT));
 433 }
 434
 435 int eigrp_redistribute_set(struct eigrp *eigrp, int type,
 436                            struct eigrp_metrics metric)
 437 {
 438
 439         if (eigrp_is_type_redistributed(type)) {
 440                 if (eigrp_metrics_is_same(metric, eigrp->dmetric[type])) {
 441                         eigrp->dmetric[type] = metric;
 442                 }
 443
 444                 eigrp_external_routes_refresh(eigrp, type);
 445
 446                 //      if (IS_DEBUG_EIGRP(zebra, ZEBRA_REDISTRIBUTE))
 447                 //        zlog_debug ("Redistribute[%s]: Refresh  Type[%d],
 448                 //        Metric[%d]",
 449                 //                   eigrp_redist_string(type),
 450                 //                   metric_type (eigrp, type), metric_value
 451                 //                   (eigrp, type));
 452                 return CMD_SUCCESS;
 453         }
 454
 455         eigrp->dmetric[type] = metric;
 456
 457         zclient_redistribute(ZEBRA_REDISTRIBUTE_ADD, zclient, AFI_IP, type, 0,
 458                              VRF_DEFAULT);
 459
 460         ++eigrp->redistribute;
 461
 462         return CMD_SUCCESS;
 463 }
 464
 465 int eigrp_redistribute_unset(struct eigrp *eigrp, int type)
 466 {
 467
 468         if (eigrp_is_type_redistributed(type)) {
 469                 memset(&eigrp->dmetric[type], 0, sizeof(struct eigrp_metrics));
 470                 zclient_redistribute(ZEBRA_REDISTRIBUTE_DELETE, zclient, AFI_IP,
 471                                      type, 0, VRF_DEFAULT);
 472                 --eigrp->redistribute;
 473         }
 474
 475         return CMD_SUCCESS;
 476 }