ospfd/ospf_neighbor.c

   1 /*
   2  * OSPF Neighbor functions.
   3  * Copyright (C) 1999, 2000 Toshiaki Takada
   4  *
   5  * This file is part of GNU Zebra.
   6  *
   7  * GNU Zebra is free software; you can redistribute it and/or modify
   8  * it under the terms of the GNU General Public License as published
   9  * by the Free Software Foundation; either version 2, or (at your
  10  * option) any later version.
  11  *
  12  * GNU Zebra is distributed in the hope that it will be useful, but
  13  * WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15  * General Public License for more details.
  16  *
  17  * You should have received a copy of the GNU General Public License along
  18  * with this program; see the file COPYING; if not, write to the Free Software
  19  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  20  */
  21
  22 #include <zebra.h>
  23
  24 #include "linklist.h"
  25 #include "prefix.h"
  26 #include "memory.h"
  27 #include "command.h"
  28 #include "thread.h"
  29 #include "stream.h"
  30 #include "table.h"
  31 #include "log.h"
  32 #include "json.h"
  33
  34 #include "ospfd/ospfd.h"
  35 #include "ospfd/ospf_interface.h"
  36 #include "ospfd/ospf_asbr.h"
  37 #include "ospfd/ospf_lsa.h"
  38 #include "ospfd/ospf_lsdb.h"
  39 #include "ospfd/ospf_neighbor.h"
  40 #include "ospfd/ospf_nsm.h"
  41 #include "ospfd/ospf_packet.h"
  42 #include "ospfd/ospf_network.h"
  43 #include "ospfd/ospf_flood.h"
  44 #include "ospfd/ospf_dump.h"
  45 #include "ospfd/ospf_bfd.h"
  46 #include "ospfd/ospf_gr_helper.h"
  47
  48 /* Fill in the the 'key' as appropriate to retrieve the entry for nbr
  49  * from the ospf_interface's nbrs table. Indexed by interface address
  50  * for all cases except Virtual-link and PointToPoint interfaces, where
  51  * neighbours are indexed by router-ID instead.
  52  */
  53 static void ospf_nbr_key(struct ospf_interface *oi, struct ospf_neighbor *nbr,
  54                          struct prefix *key)
  55 {
  56         key->family = AF_INET;
  57         key->prefixlen = IPV4_MAX_BITLEN;
  58
  59         /* vlinks are indexed by router-id */
  60         if (oi->type == OSPF_IFTYPE_VIRTUALLINK
  61             || oi->type == OSPF_IFTYPE_POINTOPOINT)
  62                 key->u.prefix4 = nbr->router_id;
  63         else
  64                 key->u.prefix4 = nbr->src;
  65         return;
  66 }
  67
  68 struct ospf_neighbor *ospf_nbr_new(struct ospf_interface *oi)
  69 {
  70         struct ospf_neighbor *nbr;
  71
  72         /* Allcate new neighbor. */
  73         nbr = XCALLOC(MTYPE_OSPF_NEIGHBOR, sizeof(struct ospf_neighbor));
  74
  75         /* Relate neighbor to the interface. */
  76         nbr->oi = oi;
  77
  78         /* Set default values. */
  79         nbr->state = NSM_Down;
  80
  81         /* Set inheritance values. */
  82         nbr->v_inactivity = OSPF_IF_PARAM(oi, v_wait);
  83         nbr->v_db_desc = OSPF_IF_PARAM(oi, retransmit_interval);
  84         nbr->v_ls_req = OSPF_IF_PARAM(oi, retransmit_interval);
  85         nbr->v_ls_upd = OSPF_IF_PARAM(oi, retransmit_interval);
  86         nbr->priority = -1;
  87
  88         /* DD flags. */
  89         nbr->dd_flags = OSPF_DD_FLAG_MS | OSPF_DD_FLAG_M | OSPF_DD_FLAG_I;
  90
  91         /* Last received and sent DD. */
  92         nbr->last_send = NULL;
  93
  94         nbr->nbr_nbma = NULL;
  95
  96         ospf_lsdb_init(&nbr->db_sum);
  97         ospf_lsdb_init(&nbr->ls_rxmt);
  98         ospf_lsdb_init(&nbr->ls_req);
  99
 100         nbr->crypt_seqnum = 0;
 101
 102         ospf_bfd_info_nbr_create(oi, nbr);
 103
 104         /* Initialize GR Helper info*/
 105         nbr->gr_helper_info.recvd_grace_period = 0;
 106         nbr->gr_helper_info.actual_grace_period = 0;
 107         nbr->gr_helper_info.gr_helper_status = OSPF_GR_NOT_HELPER;
 108         nbr->gr_helper_info.helper_exit_reason = OSPF_GR_HELPER_EXIT_NONE;
 109         nbr->gr_helper_info.gr_restart_reason = OSPF_GR_UNKNOWN_RESTART;
 110
 111         return nbr;
 112 }
 113
 114 void ospf_nbr_free(struct ospf_neighbor *nbr)
 115 {
 116         /* Free DB summary list. */
 117         if (ospf_db_summary_count(nbr))
 118                 ospf_db_summary_clear(nbr);
 119         /* ospf_db_summary_delete_all (nbr); */
 120
 121         /* Free ls request list. */
 122         if (ospf_ls_request_count(nbr))
 123                 ospf_ls_request_delete_all(nbr);
 124
 125         /* Free retransmit list. */
 126         if (ospf_ls_retransmit_count(nbr))
 127                 ospf_ls_retransmit_clear(nbr);
 128
 129         /* Cleanup LSDBs. */
 130         ospf_lsdb_cleanup(&nbr->db_sum);
 131         ospf_lsdb_cleanup(&nbr->ls_req);
 132         ospf_lsdb_cleanup(&nbr->ls_rxmt);
 133
 134         /* Clear last send packet. */
 135         if (nbr->last_send)
 136                 ospf_packet_free(nbr->last_send);
 137
 138         if (nbr->nbr_nbma) {
 139                 nbr->nbr_nbma->nbr = NULL;
 140                 nbr->nbr_nbma = NULL;
 141         }
 142
 143         /* Cancel all timers. */
 144         OSPF_NSM_TIMER_OFF(nbr->t_inactivity);
 145         OSPF_NSM_TIMER_OFF(nbr->t_db_desc);
 146         OSPF_NSM_TIMER_OFF(nbr->t_ls_req);
 147         OSPF_NSM_TIMER_OFF(nbr->t_ls_upd);
 148
 149         /* Cancel all events. */ /* Thread lookup cost would be negligible. */
 150         thread_cancel_event(master, nbr);
 151
 152         ospf_bfd_info_free(&nbr->bfd_info);
 153
 154         OSPF_NSM_TIMER_OFF(nbr->gr_helper_info.t_grace_timer);
 155
 156         nbr->oi = NULL;
 157         XFREE(MTYPE_OSPF_NEIGHBOR, nbr);
 158 }
 159
 160 /* Delete specified OSPF neighbor from interface. */
 161 void ospf_nbr_delete(struct ospf_neighbor *nbr)
 162 {
 163         struct ospf_interface *oi;
 164         struct route_node *rn;
 165         struct prefix p;
 166
 167         oi = nbr->oi;
 168
 169         /* get appropriate prefix 'key' */
 170         ospf_nbr_key(oi, nbr, &p);
 171
 172         rn = route_node_lookup(oi->nbrs, &p);
 173         if (rn) {
 174                 /* If lookup for a NBR succeeds, the leaf route_node could
 175                  * only exist because there is (or was) a nbr there.
 176                  * If the nbr was deleted, the leaf route_node should have
 177                  * lost its last refcount too, and be deleted.
 178                  * Therefore a looked-up leaf route_node in nbrs table
 179                  * should never have NULL info.
 180                  */
 181                 assert(rn->info);
 182
 183                 if (rn->info) {
 184                         rn->info = NULL;
 185                         route_unlock_node(rn);
 186                 } else
 187                         zlog_info("Can't find neighbor %s in the interface %s",
 188                                   inet_ntoa(nbr->src), IF_NAME(oi));
 189
 190                 route_unlock_node(rn);
 191         } else {
 192                 /*
 193                  * This neighbor was not found, but before we move on and
 194                  * free the neighbor structre, make sure that it was not
 195                  * indexed incorrectly and ended up in the "worng" place
 196                  */
 197
 198                 /* Reverse the lookup rules */
 199                 if (oi->type == OSPF_IFTYPE_VIRTUALLINK
 200                     || oi->type == OSPF_IFTYPE_POINTOPOINT)
 201                         p.u.prefix4 = nbr->src;
 202                 else
 203                         p.u.prefix4 = nbr->router_id;
 204
 205                 rn = route_node_lookup(oi->nbrs, &p);
 206                 if (rn) {
 207                         /* We found the neighbor!
 208                          * Now make sure it is not the exact same neighbor
 209                          * structure that we are about to free
 210                          */
 211                         if (nbr == rn->info) {
 212                                 /* Same neighbor, drop the reference to it */
 213                                 rn->info = NULL;
 214                                 route_unlock_node(rn);
 215                         }
 216                         route_unlock_node(rn);
 217                 }
 218         }
 219
 220         /* Free ospf_neighbor structure. */
 221         ospf_nbr_free(nbr);
 222 }
 223
 224 /* Check myself is in the neighbor list. */
 225 int ospf_nbr_bidirectional(struct in_addr *router_id, struct in_addr *neighbors,
 226                            int size)
 227 {
 228         int i;
 229         int max;
 230
 231         max = size / sizeof(struct in_addr);
 232
 233         for (i = 0; i < max; i++)
 234                 if (IPV4_ADDR_SAME(router_id, &neighbors[i]))
 235                         return 1;
 236
 237         return 0;
 238 }
 239
 240 /* reset nbr_self */
 241 void ospf_nbr_self_reset(struct ospf_interface *oi, struct in_addr router_id)
 242 {
 243         if (oi->nbr_self)
 244                 ospf_nbr_delete(oi->nbr_self);
 245
 246         oi->nbr_self = ospf_nbr_new(oi);
 247         ospf_nbr_add_self(oi, router_id);
 248 }
 249
 250 /* Add self to nbr list. */
 251 void ospf_nbr_add_self(struct ospf_interface *oi, struct in_addr router_id)
 252 {
 253         struct prefix p;
 254         struct route_node *rn;
 255
 256         if (!oi->nbr_self)
 257                 oi->nbr_self = ospf_nbr_new(oi);
 258
 259         /* Initial state */
 260         oi->nbr_self->address = *oi->address;
 261         oi->nbr_self->priority = OSPF_IF_PARAM(oi, priority);
 262         oi->nbr_self->router_id = router_id;
 263         oi->nbr_self->src = oi->address->u.prefix4;
 264         oi->nbr_self->state = NSM_TwoWay;
 265
 266         switch (oi->area->external_routing) {
 267         case OSPF_AREA_DEFAULT:
 268                 SET_FLAG(oi->nbr_self->options, OSPF_OPTION_E);
 269                 break;
 270         case OSPF_AREA_STUB:
 271                 UNSET_FLAG(oi->nbr_self->options, OSPF_OPTION_E);
 272                 break;
 273         case OSPF_AREA_NSSA:
 274                 UNSET_FLAG(oi->nbr_self->options, OSPF_OPTION_E);
 275                 SET_FLAG(oi->nbr_self->options, OSPF_OPTION_NP);
 276                 break;
 277         }
 278
 279         /* Add nbr_self to nbrs table */
 280         ospf_nbr_key(oi, oi->nbr_self, &p);
 281
 282         rn = route_node_get(oi->nbrs, &p);
 283         if (rn->info) {
 284                 /* There is already pseudo neighbor. */
 285                 if (IS_DEBUG_OSPF_EVENT)
 286                         zlog_debug(
 287                                 "router_id %s already present in neighbor table. node refcount %u",
 288                                 inet_ntoa(router_id),
 289                                 route_node_get_lock_count(rn));
 290                 route_unlock_node(rn);
 291         } else
 292                 rn->info = oi->nbr_self;
 293 }
 294
 295 /* Get neighbor count by status.
 296    Specify status = 0, get all neighbor other than myself. */
 297 int ospf_nbr_count(struct ospf_interface *oi, int state)
 298 {
 299         struct ospf_neighbor *nbr;
 300         struct route_node *rn;
 301         int count = 0;
 302
 303         for (rn = route_top(oi->nbrs); rn; rn = route_next(rn))
 304                 if ((nbr = rn->info))
 305                         if (!IPV4_ADDR_SAME(&nbr->router_id,
 306                                             &oi->ospf->router_id))
 307                                 if (state == 0 || nbr->state == state)
 308                                         count++;
 309
 310         return count;
 311 }
 312
 313 int ospf_nbr_count_opaque_capable(struct ospf_interface *oi)
 314 {
 315         struct ospf_neighbor *nbr;
 316         struct route_node *rn;
 317         int count = 0;
 318
 319         for (rn = route_top(oi->nbrs); rn; rn = route_next(rn))
 320                 if ((nbr = rn->info))
 321                         if (!IPV4_ADDR_SAME(&nbr->router_id,
 322                                             &oi->ospf->router_id))
 323                                 if (nbr->state == NSM_Full)
 324                                         if (CHECK_FLAG(nbr->options,
 325                                                        OSPF_OPTION_O))
 326                                                 count++;
 327
 328         return count;
 329 }
 330
 331 /* lookup nbr by address - use this only if you know you must
 332  * otherwise use the ospf_nbr_lookup() wrapper, which deals
 333  * with virtual link and PointToPoint neighbours
 334  */
 335 struct ospf_neighbor *ospf_nbr_lookup_by_addr(struct route_table *nbrs,
 336                                               struct in_addr *addr)
 337 {
 338         struct prefix p;
 339         struct route_node *rn;
 340         struct ospf_neighbor *nbr;
 341
 342         p.family = AF_INET;
 343         p.prefixlen = IPV4_MAX_BITLEN;
 344         p.u.prefix4 = *addr;
 345
 346         rn = route_node_lookup(nbrs, &p);
 347         if (!rn)
 348                 return NULL;
 349
 350         /* See comment in ospf_nbr_delete */
 351         assert(rn->info);
 352
 353         if (rn->info == NULL) {
 354                 route_unlock_node(rn);
 355                 return NULL;
 356         }
 357
 358         nbr = (struct ospf_neighbor *)rn->info;
 359         route_unlock_node(rn);
 360
 361         return nbr;
 362 }
 363
 364 struct ospf_neighbor *ospf_nbr_lookup_by_routerid(struct route_table *nbrs,
 365                                                   struct in_addr *id)
 366 {
 367         struct route_node *rn;
 368         struct ospf_neighbor *nbr;
 369
 370         for (rn = route_top(nbrs); rn; rn = route_next(rn))
 371                 if ((nbr = rn->info) != NULL)
 372                         if (IPV4_ADDR_SAME(&nbr->router_id, id)) {
 373                                 route_unlock_node(rn);
 374                                 return nbr;
 375                         }
 376
 377         return NULL;
 378 }
 379
 380 void ospf_renegotiate_optional_capabilities(struct ospf *top)
 381 {
 382         struct listnode *node;
 383         struct ospf_interface *oi;
 384         struct route_table *nbrs;
 385         struct route_node *rn;
 386         struct ospf_neighbor *nbr;
 387
 388         /* At first, flush self-originated LSAs from routing domain. */
 389         ospf_flush_self_originated_lsas_now(top);
 390
 391         /* Revert all neighbor status to ExStart. */
 392         for (ALL_LIST_ELEMENTS_RO(top->oiflist, node, oi)) {
 393                 if ((nbrs = oi->nbrs) == NULL)
 394                         continue;
 395
 396                 for (rn = route_top(nbrs); rn; rn = route_next(rn)) {
 397                         if ((nbr = rn->info) == NULL || nbr == oi->nbr_self)
 398                                 continue;
 399
 400                         if (nbr->state < NSM_ExStart)
 401                                 continue;
 402
 403                         if (IS_DEBUG_OSPF_EVENT)
 404                                 zlog_debug(
 405                                         "Renegotiate optional capabilities with neighbor(%s)",
 406                                         inet_ntoa(nbr->router_id));
 407
 408                         OSPF_NSM_EVENT_SCHEDULE(nbr, NSM_SeqNumberMismatch);
 409                 }
 410         }
 411
 412         return;
 413 }
 414
 415
 416 struct ospf_neighbor *ospf_nbr_lookup(struct ospf_interface *oi, struct ip *iph,
 417                                       struct ospf_header *ospfh)
 418 {
 419         struct in_addr srcaddr = iph->ip_src;
 420
 421         if (oi->type == OSPF_IFTYPE_VIRTUALLINK
 422             || oi->type == OSPF_IFTYPE_POINTOPOINT)
 423                 return (ospf_nbr_lookup_by_routerid(oi->nbrs,
 424                                                     &ospfh->router_id));
 425         else
 426                 return (ospf_nbr_lookup_by_addr(oi->nbrs, &srcaddr));
 427 }
 428
 429 static struct ospf_neighbor *ospf_nbr_add(struct ospf_interface *oi,
 430                                           struct ospf_header *ospfh,
 431                                           struct prefix *p)
 432 {
 433         struct ospf_neighbor *nbr;
 434
 435         nbr = ospf_nbr_new(oi);
 436         nbr->state = NSM_Down;
 437         nbr->src = p->u.prefix4;
 438         memcpy(&nbr->address, p, sizeof(struct prefix));
 439
 440         nbr->nbr_nbma = NULL;
 441         if (oi->type == OSPF_IFTYPE_NBMA) {
 442                 struct ospf_nbr_nbma *nbr_nbma;
 443                 struct listnode *node;
 444
 445                 for (ALL_LIST_ELEMENTS_RO(oi->nbr_nbma, node, nbr_nbma)) {
 446                         if (IPV4_ADDR_SAME(&nbr_nbma->addr, &nbr->src)) {
 447                                 nbr_nbma->nbr = nbr;
 448                                 nbr->nbr_nbma = nbr_nbma;
 449
 450                                 if (nbr_nbma->t_poll)
 451                                         OSPF_POLL_TIMER_OFF(nbr_nbma->t_poll);
 452
 453                                 nbr->state_change = nbr_nbma->state_change + 1;
 454                         }
 455                 }
 456         }
 457
 458         /* New nbr, save the crypto sequence number if necessary */
 459         if (ntohs(ospfh->auth_type) == OSPF_AUTH_CRYPTOGRAPHIC)
 460                 nbr->crypt_seqnum = ospfh->u.crypt.crypt_seqnum;
 461
 462         if (IS_DEBUG_OSPF_EVENT)
 463                 zlog_debug("NSM[%s:%s]: start", IF_NAME(oi),
 464                            inet_ntoa(nbr->router_id));
 465
 466         return nbr;
 467 }
 468
 469 struct ospf_neighbor *ospf_nbr_get(struct ospf_interface *oi,
 470                                    struct ospf_header *ospfh, struct ip *iph,
 471                                    struct prefix *p)
 472 {
 473         struct route_node *rn;
 474         struct prefix key;
 475         struct ospf_neighbor *nbr;
 476
 477         key.family = AF_INET;
 478         key.prefixlen = IPV4_MAX_BITLEN;
 479
 480         if (oi->type == OSPF_IFTYPE_VIRTUALLINK
 481             || oi->type == OSPF_IFTYPE_POINTOPOINT)
 482                 key.u.prefix4 = ospfh->router_id; /* index vlink and ptp nbrs by
 483                                                      router-id */
 484         else
 485                 key.u.prefix4 = iph->ip_src;
 486
 487         rn = route_node_get(oi->nbrs, &key);
 488         if (rn->info) {
 489                 route_unlock_node(rn);
 490                 nbr = rn->info;
 491
 492                 if (oi->type == OSPF_IFTYPE_NBMA && nbr->state == NSM_Attempt) {
 493                         nbr->src = iph->ip_src;
 494                         memcpy(&nbr->address, p, sizeof(struct prefix));
 495                 }
 496         } else {
 497                 rn->info = nbr = ospf_nbr_add(oi, ospfh, p);
 498         }
 499
 500         nbr->router_id = ospfh->router_id;
 501
 502         return nbr;
 503 }