1 /* $OpenBSD: interface.c,v 1.21 2013/11/01 17:18:29 deraadt Exp $ */ 2 3 /* 4 * Copyright (c) 2005 Claudio Jeker <claudio@openbsd.org> 5 * Copyright (c) 2004, 2005, 2007 Esben Norby <norby@openbsd.org> 6 * 7 * Permission to use, copy, modify, and distribute this software for any 8 * purpose with or without fee is hereby granted, provided that the above 9 * copyright notice and this permission notice appear in all copies. 10 * 11 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES 12 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF 13 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR 14 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES 15 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN 16 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF 17 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. 18 */ 19 20 #include <sys/types.h> 21 #include <sys/ioctl.h> 22 #include <sys/time.h> 23 #include <sys/socket.h> 24 #include <netinet/in.h> 25 #include <arpa/inet.h> 26 #include <net/if.h> 27 #include <net/if_types.h> 28 #include <ctype.h> 29 #include <err.h> 30 #include <stddef.h> 31 #include <stdio.h> 32 #include <stdlib.h> 33 #include <unistd.h> 34 #include <string.h> 35 #include <event.h> 36 37 #include "ospf6d.h" 38 #include "ospf6.h" 39 #include "log.h" 40 #include "ospfe.h" 41 42 void if_hello_timer(int, short, void *); 43 void if_start_hello_timer(struct iface *); 44 void if_stop_hello_timer(struct iface *); 45 void if_stop_wait_timer(struct iface *); 46 void if_wait_timer(int, short, void *); 47 void if_start_wait_timer(struct iface *); 48 void if_stop_wait_timer(struct iface *); 49 struct nbr *if_elect(struct nbr *, struct nbr *); 50 51 struct { 52 int state; 53 enum iface_event event; 54 enum iface_action action; 55 int new_state; 56 } iface_fsm[] = { 57 /* current state event that happened action to take resulting state */ 58 {IF_STA_DOWN, IF_EVT_UP, IF_ACT_STRT, 0}, 59 {IF_STA_WAITING, IF_EVT_BACKUP_SEEN, IF_ACT_ELECT, 0}, 60 {IF_STA_WAITING, IF_EVT_WTIMER, IF_ACT_ELECT, 0}, 61 {IF_STA_ANY, IF_EVT_WTIMER, IF_ACT_NOTHING, 0}, 62 {IF_STA_WAITING, IF_EVT_NBR_CHNG, IF_ACT_NOTHING, 0}, 63 {IF_STA_MULTI, IF_EVT_NBR_CHNG, IF_ACT_ELECT, 0}, 64 {IF_STA_ANY, IF_EVT_NBR_CHNG, IF_ACT_NOTHING, 0}, 65 {IF_STA_ANY, IF_EVT_DOWN, IF_ACT_RST, IF_STA_DOWN}, 66 {IF_STA_ANY, IF_EVT_LOOP, IF_ACT_RST, IF_STA_LOOPBACK}, 67 {IF_STA_LOOPBACK, IF_EVT_UNLOOP, IF_ACT_NOTHING, IF_STA_DOWN}, 68 {-1, IF_EVT_NOTHING, IF_ACT_NOTHING, 0}, 69 }; 70 71 #if 0 72 /* TODO virtual links */ 73 static int vlink_cnt = 0; 74 #endif 75 76 TAILQ_HEAD(, iface) iflist; 77 78 const char * const if_event_names[] = { 79 "NOTHING", 80 "UP", 81 "WAITTIMER", 82 "BACKUPSEEN", 83 "NEIGHBORCHANGE", 84 "LOOP", 85 "UNLOOP", 86 "DOWN" 87 }; 88 89 const char * const if_action_names[] = { 90 "NOTHING", 91 "START", 92 "ELECT", 93 "RESET" 94 }; 95 96 int 97 if_fsm(struct iface *iface, enum iface_event event) 98 { 99 int old_state; 100 int new_state = 0; 101 int i, ret = 0; 102 103 old_state = iface->state; 104 105 for (i = 0; iface_fsm[i].state != -1; i++) 106 if ((iface_fsm[i].state & old_state) && 107 (iface_fsm[i].event == event)) { 108 new_state = iface_fsm[i].new_state; 109 break; 110 } 111 112 if (iface_fsm[i].state == -1) { 113 /* event outside of the defined fsm, ignore it. */ 114 log_debug("if_fsm: interface %s, " 115 "event %s not expected in state %s", iface->name, 116 if_event_names[event], if_state_name(old_state)); 117 return (0); 118 } 119 120 switch (iface_fsm[i].action) { 121 case IF_ACT_STRT: 122 ret = if_act_start(iface); 123 break; 124 case IF_ACT_ELECT: 125 ret = if_act_elect(iface); 126 break; 127 case IF_ACT_RST: 128 ret = if_act_reset(iface); 129 break; 130 case IF_ACT_NOTHING: 131 /* do nothing */ 132 break; 133 } 134 135 if (ret) { 136 log_debug("if_fsm: error changing state for interface %s, " 137 "event %s, state %s", iface->name, if_event_names[event], 138 if_state_name(old_state)); 139 return (-1); 140 } 141 142 if (new_state != 0) 143 iface->state = new_state; 144 145 if (iface->state != old_state) { 146 orig_rtr_lsa(iface); 147 orig_link_lsa(iface); 148 149 /* state change inform RDE */ 150 ospfe_imsg_compose_rde(IMSG_IFINFO, iface->self->peerid, 0, 151 &iface->state, sizeof(iface->state)); 152 } 153 154 if (old_state & (IF_STA_MULTI | IF_STA_POINTTOPOINT) && 155 (iface->state & (IF_STA_MULTI | IF_STA_POINTTOPOINT)) == 0) 156 ospfe_demote_iface(iface, 0); 157 if ((old_state & (IF_STA_MULTI | IF_STA_POINTTOPOINT)) == 0 && 158 iface->state & (IF_STA_MULTI | IF_STA_POINTTOPOINT)) 159 ospfe_demote_iface(iface, 1); 160 161 log_debug("if_fsm: event %s resulted in action %s and changing " 162 "state for interface %s from %s to %s", 163 if_event_names[event], if_action_names[iface_fsm[i].action], 164 iface->name, if_state_name(old_state), if_state_name(iface->state)); 165 166 return (ret); 167 } 168 169 int 170 if_init(void) 171 { 172 TAILQ_INIT(&iflist); 173 174 return (fetchifs(0)); 175 } 176 177 /* XXX using a linked list should be OK for now */ 178 struct iface * 179 if_find(unsigned int ifindex) 180 { 181 struct iface *iface; 182 183 TAILQ_FOREACH(iface, &iflist, list) { 184 if (ifindex == iface->ifindex) 185 return (iface); 186 } 187 return (NULL); 188 } 189 190 struct iface * 191 if_findname(char *name) 192 { 193 struct iface *iface; 194 195 TAILQ_FOREACH(iface, &iflist, list) { 196 if (!strcmp(name, iface->name)) 197 return (iface); 198 } 199 return (NULL); 200 } 201 202 struct iface * 203 if_new(u_short ifindex, char *ifname) 204 { 205 struct iface *iface; 206 207 if ((iface = calloc(1, sizeof(*iface))) == NULL) 208 err(1, "if_new: calloc"); 209 210 iface->state = IF_STA_DOWN; 211 212 LIST_INIT(&iface->nbr_list); 213 TAILQ_INIT(&iface->ifa_list); 214 TAILQ_INIT(&iface->ls_ack_list); 215 RB_INIT(&iface->lsa_tree); 216 217 #if 0 218 /* TODO */ 219 if (virtual) { 220 iface->type = IF_TYPE_VIRTUALLINK; 221 snprintf(iface->name, sizeof(iface->name), "vlink%d", 222 vlink_cnt++); 223 iface->flags |= IFF_UP; 224 iface->mtu = IP_MSS; 225 return (iface); 226 } 227 #endif 228 strlcpy(iface->name, ifname, sizeof(iface->name)); 229 iface->ifindex = ifindex; 230 231 TAILQ_INSERT_TAIL(&iflist, iface, list); 232 233 return (iface); 234 } 235 236 void 237 if_update(struct iface *iface, int mtu, int flags, u_int8_t type, 238 u_int8_t state, u_int64_t rate) 239 { 240 iface->mtu = mtu; 241 iface->flags = flags; 242 iface->media_type = type; 243 iface->linkstate = state; 244 iface->baudrate = rate; 245 246 /* set type */ 247 if (flags & IFF_POINTOPOINT) 248 iface->type = IF_TYPE_POINTOPOINT; 249 if (flags & IFF_BROADCAST && flags & IFF_MULTICAST) 250 iface->type = IF_TYPE_BROADCAST; 251 if (flags & IFF_LOOPBACK) { 252 iface->type = IF_TYPE_POINTOPOINT; 253 iface->cflags |= F_IFACE_PASSIVE; 254 } 255 } 256 257 void 258 if_del(struct iface *iface) 259 { 260 struct nbr *nbr = NULL; 261 262 log_debug("if_del: interface %s", iface->name); 263 264 /* revert the demotion when the interface is deleted */ 265 if ((iface->state & (IF_STA_MULTI | IF_STA_POINTTOPOINT)) == 0) 266 ospfe_demote_iface(iface, 1); 267 268 /* clear lists etc */ 269 while ((nbr = LIST_FIRST(&iface->nbr_list)) != NULL) 270 nbr_del(nbr); 271 272 if (evtimer_pending(&iface->hello_timer, NULL)) 273 evtimer_del(&iface->hello_timer); 274 if (evtimer_pending(&iface->wait_timer, NULL)) 275 evtimer_del(&iface->wait_timer); 276 if (evtimer_pending(&iface->lsack_tx_timer, NULL)) 277 evtimer_del(&iface->lsack_tx_timer); 278 279 ls_ack_list_clr(iface); 280 TAILQ_REMOVE(&iflist, iface, list); 281 free(iface); 282 } 283 284 void 285 if_start(struct ospfd_conf *xconf, struct iface *iface) 286 { 287 /* init the dummy local neighbor */ 288 iface->self = nbr_new(ospfe_router_id(), iface, iface->ifindex, 1, 289 NULL); 290 291 /* set event handlers for interface */ 292 evtimer_set(&iface->lsack_tx_timer, ls_ack_tx_timer, iface); 293 evtimer_set(&iface->hello_timer, if_hello_timer, iface); 294 evtimer_set(&iface->wait_timer, if_wait_timer, iface); 295 296 iface->fd = xconf->ospf_socket; 297 298 ospfe_demote_iface(iface, 0); 299 300 if (if_fsm(iface, IF_EVT_UP)) 301 log_debug("error starting interface %s", iface->name); 302 } 303 304 /* timers */ 305 /* ARGSUSED */ 306 void 307 if_hello_timer(int fd, short event, void *arg) 308 { 309 struct iface *iface = arg; 310 struct timeval tv; 311 312 send_hello(iface); 313 314 /* reschedule hello_timer */ 315 timerclear(&tv); 316 tv.tv_sec = iface->hello_interval; 317 if (evtimer_add(&iface->hello_timer, &tv) == -1) 318 fatal("if_hello_timer"); 319 } 320 321 void 322 if_start_hello_timer(struct iface *iface) 323 { 324 struct timeval tv; 325 326 timerclear(&tv); 327 if (evtimer_add(&iface->hello_timer, &tv) == -1) 328 fatal("if_start_hello_timer"); 329 } 330 331 void 332 if_stop_hello_timer(struct iface *iface) 333 { 334 if (evtimer_del(&iface->hello_timer) == -1) 335 fatal("if_stop_hello_timer"); 336 } 337 338 /* ARGSUSED */ 339 void 340 if_wait_timer(int fd, short event, void *arg) 341 { 342 struct iface *iface = arg; 343 344 if_fsm(iface, IF_EVT_WTIMER); 345 } 346 347 void 348 if_start_wait_timer(struct iface *iface) 349 { 350 struct timeval tv; 351 352 timerclear(&tv); 353 tv.tv_sec = iface->dead_interval; 354 if (evtimer_add(&iface->wait_timer, &tv) == -1) 355 fatal("if_start_wait_timer"); 356 } 357 358 void 359 if_stop_wait_timer(struct iface *iface) 360 { 361 if (evtimer_del(&iface->wait_timer) == -1) 362 fatal("if_stop_wait_timer"); 363 } 364 365 /* actions */ 366 int 367 if_act_start(struct iface *iface) 368 { 369 struct in6_addr addr; 370 struct timeval now; 371 372 if (!((iface->flags & IFF_UP) && 373 LINK_STATE_IS_UP(iface->linkstate))) { 374 log_debug("if_act_start: interface %s link down", 375 iface->name); 376 return (0); 377 } 378 379 if (iface->media_type == IFT_CARP && 380 !(iface->cflags & F_IFACE_PASSIVE)) { 381 /* force passive mode on carp interfaces */ 382 log_warnx("if_act_start: forcing interface %s to passive", 383 iface->name); 384 iface->cflags |= F_IFACE_PASSIVE; 385 } 386 387 gettimeofday(&now, NULL); 388 iface->uptime = now.tv_sec; 389 390 /* loopback interfaces have a special state */ 391 if (iface->flags & IFF_LOOPBACK) 392 iface->state = IF_STA_LOOPBACK; 393 394 if (iface->cflags & F_IFACE_PASSIVE) { 395 /* for an update of stub network entries */ 396 orig_rtr_lsa(iface); 397 return (0); 398 } 399 400 switch (iface->type) { 401 case IF_TYPE_POINTOPOINT: 402 inet_pton(AF_INET6, AllSPFRouters, &addr); 403 404 if (if_join_group(iface, &addr)) 405 return (-1); 406 iface->state = IF_STA_POINTTOPOINT; 407 break; 408 case IF_TYPE_VIRTUALLINK: 409 iface->state = IF_STA_POINTTOPOINT; 410 break; 411 case IF_TYPE_POINTOMULTIPOINT: 412 case IF_TYPE_NBMA: 413 log_debug("if_act_start: type %s not supported, interface %s", 414 if_type_name(iface->type), iface->name); 415 return (-1); 416 case IF_TYPE_BROADCAST: 417 inet_pton(AF_INET6, AllSPFRouters, &addr); 418 419 if (if_join_group(iface, &addr)) 420 return (-1); 421 if (iface->priority == 0) { 422 iface->state = IF_STA_DROTHER; 423 } else { 424 iface->state = IF_STA_WAITING; 425 if_start_wait_timer(iface); 426 } 427 break; 428 default: 429 fatalx("if_act_start: unknown interface type"); 430 } 431 432 /* hello timer needs to be started in any case */ 433 if_start_hello_timer(iface); 434 return (0); 435 } 436 437 struct nbr * 438 if_elect(struct nbr *a, struct nbr *b) 439 { 440 if (a->priority > b->priority) 441 return (a); 442 if (a->priority < b->priority) 443 return (b); 444 if (ntohl(a->id.s_addr) > ntohl(b->id.s_addr)) 445 return (a); 446 return (b); 447 } 448 449 int 450 if_act_elect(struct iface *iface) 451 { 452 struct in6_addr addr; 453 struct nbr *nbr, *bdr = NULL, *dr = NULL; 454 int round = 0; 455 int changed = 0; 456 int old_state; 457 char b1[16], b2[16], b3[16], b4[16]; 458 459 start: 460 /* elect backup designated router */ 461 LIST_FOREACH(nbr, &iface->nbr_list, entry) { 462 if (nbr->priority == 0 || nbr == dr || /* not electable */ 463 nbr->state & NBR_STA_PRELIM || /* not available */ 464 nbr->dr.s_addr == nbr->id.s_addr) /* don't elect DR */ 465 continue; 466 if (bdr != NULL) { 467 /* 468 * routers announcing themselves as BDR have higher 469 * precedence over those routers announcing a 470 * different BDR. 471 */ 472 if (nbr->bdr.s_addr == nbr->id.s_addr) { 473 if (bdr->bdr.s_addr == bdr->id.s_addr) 474 bdr = if_elect(bdr, nbr); 475 else 476 bdr = nbr; 477 } else if (bdr->bdr.s_addr != bdr->id.s_addr) 478 bdr = if_elect(bdr, nbr); 479 } else 480 bdr = nbr; 481 } 482 483 /* elect designated router */ 484 LIST_FOREACH(nbr, &iface->nbr_list, entry) { 485 if (nbr->priority == 0 || nbr->state & NBR_STA_PRELIM || 486 (nbr != dr && nbr->dr.s_addr != nbr->id.s_addr)) 487 /* only DR may be elected check priority too */ 488 continue; 489 if (dr == NULL) 490 dr = nbr; 491 else 492 dr = if_elect(dr, nbr); 493 } 494 495 if (dr == NULL) { 496 /* no designate router found use backup DR */ 497 dr = bdr; 498 bdr = NULL; 499 } 500 501 /* 502 * if we are involved in the election (e.g. new DR or no 503 * longer BDR) redo the election 504 */ 505 if (round == 0 && 506 ((iface->self == dr && iface->self != iface->dr) || 507 (iface->self != dr && iface->self == iface->dr) || 508 (iface->self == bdr && iface->self != iface->bdr) || 509 (iface->self != bdr && iface->self == iface->bdr))) { 510 /* 511 * Reset announced DR/BDR to calculated one, so 512 * that we may get elected in the second round. 513 * This is needed to drop from a DR to a BDR. 514 */ 515 iface->self->dr.s_addr = dr->id.s_addr; 516 if (bdr) 517 iface->self->bdr.s_addr = bdr->id.s_addr; 518 round = 1; 519 goto start; 520 } 521 522 log_debug("if_act_elect: interface %s old dr %s new dr %s, " 523 "old bdr %s new bdr %s", iface->name, 524 iface->dr ? inet_ntop(AF_INET, &iface->dr->id, b1, sizeof(b1)) : 525 "none", dr ? inet_ntop(AF_INET, &dr->id, b2, sizeof(b2)) : "none", 526 iface->bdr ? inet_ntop(AF_INET, &iface->bdr->id, b3, sizeof(b3)) : 527 "none", bdr ? inet_ntop(AF_INET, &bdr->id, b4, sizeof(b4)) : 528 "none"); 529 530 /* 531 * After the second round still DR or BDR change state to DR or BDR, 532 * etc. 533 */ 534 old_state = iface->state; 535 if (dr == iface->self) 536 iface->state = IF_STA_DR; 537 else if (bdr == iface->self) 538 iface->state = IF_STA_BACKUP; 539 else 540 iface->state = IF_STA_DROTHER; 541 542 /* TODO if iface is NBMA send all non eligible neighbors event Start */ 543 544 /* 545 * if DR or BDR changed issue a AdjOK? event for all neighbors > 2-Way 546 */ 547 if (iface->dr != dr || iface->bdr != bdr) 548 changed = 1; 549 550 iface->dr = dr; 551 iface->bdr = bdr; 552 553 if (changed) { 554 inet_pton(AF_INET6, AllDRouters, &addr); 555 if (old_state & IF_STA_DRORBDR && 556 (iface->state & IF_STA_DRORBDR) == 0) { 557 if (if_leave_group(iface, &addr)) 558 return (-1); 559 } else if ((old_state & IF_STA_DRORBDR) == 0 && 560 iface->state & IF_STA_DRORBDR) { 561 if (if_join_group(iface, &addr)) 562 return (-1); 563 } 564 565 LIST_FOREACH(nbr, &iface->nbr_list, entry) { 566 if (nbr->state & NBR_STA_BIDIR) 567 nbr_fsm(nbr, NBR_EVT_ADJ_OK); 568 } 569 570 orig_rtr_lsa(iface); 571 if (iface->state & IF_STA_DR || old_state & IF_STA_DR) 572 orig_net_lsa(iface); 573 } 574 575 if_start_hello_timer(iface); 576 return (0); 577 } 578 579 int 580 if_act_reset(struct iface *iface) 581 { 582 struct nbr *nbr = NULL; 583 struct in6_addr addr; 584 585 if (iface->cflags & F_IFACE_PASSIVE) { 586 /* for an update of stub network entries */ 587 orig_rtr_lsa(iface); 588 return (0); 589 } 590 591 switch (iface->type) { 592 case IF_TYPE_POINTOPOINT: 593 case IF_TYPE_BROADCAST: 594 inet_pton(AF_INET6, AllSPFRouters, &addr); 595 if (if_leave_group(iface, &addr)) { 596 log_warnx("if_act_reset: error leaving group %s, " 597 "interface %s", log_in6addr(&addr), iface->name); 598 } 599 if (iface->state & IF_STA_DRORBDR) { 600 inet_pton(AF_INET6, AllDRouters, &addr); 601 if (if_leave_group(iface, &addr)) { 602 log_warnx("if_act_reset: " 603 "error leaving group %s, interface %s", 604 log_in6addr(&addr), iface->name); 605 } 606 } 607 break; 608 case IF_TYPE_VIRTUALLINK: 609 /* nothing */ 610 break; 611 case IF_TYPE_NBMA: 612 case IF_TYPE_POINTOMULTIPOINT: 613 log_debug("if_act_reset: type %s not supported, interface %s", 614 if_type_name(iface->type), iface->name); 615 return (-1); 616 default: 617 fatalx("if_act_reset: unknown interface type"); 618 } 619 620 LIST_FOREACH(nbr, &iface->nbr_list, entry) { 621 if (nbr_fsm(nbr, NBR_EVT_KILL_NBR)) { 622 log_debug("if_act_reset: error killing neighbor %s", 623 inet_ntoa(nbr->id)); 624 } 625 } 626 627 iface->dr = NULL; 628 iface->bdr = NULL; 629 630 ls_ack_list_clr(iface); 631 stop_ls_ack_tx_timer(iface); 632 if_stop_hello_timer(iface); 633 if_stop_wait_timer(iface); 634 635 /* send empty hello to tell everybody that we are going down */ 636 send_hello(iface); 637 638 return (0); 639 } 640 641 struct ctl_iface * 642 if_to_ctl(struct iface *iface) 643 { 644 static struct ctl_iface ictl; 645 struct timeval tv, now, res; 646 struct nbr *nbr; 647 648 memcpy(ictl.name, iface->name, sizeof(ictl.name)); 649 memcpy(&ictl.addr, &iface->addr, sizeof(ictl.addr)); 650 ictl.rtr_id.s_addr = ospfe_router_id(); 651 memcpy(&ictl.area, &iface->area_id, sizeof(ictl.area)); 652 if (iface->dr) { 653 memcpy(&ictl.dr_id, &iface->dr->id, sizeof(ictl.dr_id)); 654 memcpy(&ictl.dr_addr, &iface->dr->addr, sizeof(ictl.dr_addr)); 655 } else { 656 bzero(&ictl.dr_id, sizeof(ictl.dr_id)); 657 bzero(&ictl.dr_addr, sizeof(ictl.dr_addr)); 658 } 659 if (iface->bdr) { 660 memcpy(&ictl.bdr_id, &iface->bdr->id, sizeof(ictl.bdr_id)); 661 memcpy(&ictl.bdr_addr, &iface->bdr->addr, 662 sizeof(ictl.bdr_addr)); 663 } else { 664 bzero(&ictl.bdr_id, sizeof(ictl.bdr_id)); 665 bzero(&ictl.bdr_addr, sizeof(ictl.bdr_addr)); 666 } 667 ictl.ifindex = iface->ifindex; 668 ictl.state = iface->state; 669 ictl.mtu = iface->mtu; 670 ictl.nbr_cnt = 0; 671 ictl.adj_cnt = 0; 672 ictl.baudrate = iface->baudrate; 673 ictl.dead_interval = iface->dead_interval; 674 ictl.transmit_delay = iface->transmit_delay; 675 ictl.hello_interval = iface->hello_interval; 676 ictl.flags = iface->flags; 677 ictl.metric = iface->metric; 678 ictl.rxmt_interval = iface->rxmt_interval; 679 ictl.type = iface->type; 680 ictl.linkstate = iface->linkstate; 681 ictl.mediatype = iface->media_type; 682 ictl.priority = iface->priority; 683 ictl.passive = (iface->cflags & F_IFACE_PASSIVE) == F_IFACE_PASSIVE; 684 685 gettimeofday(&now, NULL); 686 if (evtimer_pending(&iface->hello_timer, &tv)) { 687 timersub(&tv, &now, &res); 688 ictl.hello_timer = res.tv_sec; 689 } else 690 ictl.hello_timer = -1; 691 692 if (iface->state != IF_STA_DOWN) { 693 ictl.uptime = now.tv_sec - iface->uptime; 694 } else 695 ictl.uptime = 0; 696 697 LIST_FOREACH(nbr, &iface->nbr_list, entry) { 698 if (nbr == iface->self) 699 continue; 700 ictl.nbr_cnt++; 701 if (nbr->state & NBR_STA_ADJFORM) 702 ictl.adj_cnt++; 703 } 704 705 return (&ictl); 706 } 707 708 /* misc */ 709 void 710 if_set_recvbuf(int fd) 711 { 712 int bsize; 713 714 bsize = 65535; 715 while (setsockopt(fd, SOL_SOCKET, SO_RCVBUF, &bsize, 716 sizeof(bsize)) == -1) 717 bsize /= 2; 718 } 719 720 int 721 if_join_group(struct iface *iface, struct in6_addr *addr) 722 { 723 struct ipv6_mreq mreq; 724 725 switch (iface->type) { 726 case IF_TYPE_POINTOPOINT: 727 case IF_TYPE_BROADCAST: 728 log_debug("if_join_group: interface %s addr %s", 729 iface->name, log_in6addr(addr)); 730 mreq.ipv6mr_multiaddr = *addr; 731 mreq.ipv6mr_interface = iface->ifindex; 732 733 if (setsockopt(iface->fd, IPPROTO_IPV6, IPV6_JOIN_GROUP, 734 &mreq, sizeof(mreq)) < 0) { 735 log_warn("if_join_group: error IPV6_JOIN_GROUP, " 736 "interface %s address %s", iface->name, 737 log_in6addr(addr)); 738 return (-1); 739 } 740 break; 741 case IF_TYPE_POINTOMULTIPOINT: 742 case IF_TYPE_VIRTUALLINK: 743 case IF_TYPE_NBMA: 744 log_debug("if_join_group: type %s not supported, interface %s", 745 if_type_name(iface->type), iface->name); 746 return (-1); 747 default: 748 fatalx("if_join_group: unknown interface type"); 749 } 750 751 return (0); 752 } 753 754 int 755 if_leave_group(struct iface *iface, struct in6_addr *addr) 756 { 757 struct ipv6_mreq mreq; 758 759 switch (iface->type) { 760 case IF_TYPE_POINTOPOINT: 761 case IF_TYPE_BROADCAST: 762 log_debug("if_leave_group: interface %s addr %s", 763 iface->name, log_in6addr(addr)); 764 mreq.ipv6mr_multiaddr = *addr; 765 mreq.ipv6mr_interface = iface->ifindex; 766 767 if (setsockopt(iface->fd, IPPROTO_IPV6, IPV6_LEAVE_GROUP, 768 (void *)&mreq, sizeof(mreq)) < 0) { 769 log_warn("if_leave_group: error IPV6_LEAVE_GROUP, " 770 "interface %s address %s", iface->name, 771 log_in6addr(addr)); 772 return (-1); 773 } 774 break; 775 case IF_TYPE_POINTOMULTIPOINT: 776 case IF_TYPE_VIRTUALLINK: 777 case IF_TYPE_NBMA: 778 log_debug("if_leave_group: type %s not supported, interface %s", 779 if_type_name(iface->type), iface->name); 780 return (-1); 781 default: 782 fatalx("if_leave_group: unknown interface type"); 783 } 784 return (0); 785 } 786 787 int 788 if_set_mcast(struct iface *iface) 789 { 790 switch (iface->type) { 791 case IF_TYPE_POINTOPOINT: 792 case IF_TYPE_BROADCAST: 793 if (setsockopt(iface->fd, IPPROTO_IPV6, IPV6_MULTICAST_IF, 794 &iface->ifindex, sizeof(iface->ifindex)) < 0) { 795 log_debug("if_set_mcast: error setting " 796 "IP_MULTICAST_IF, interface %s", iface->name); 797 return (-1); 798 } 799 break; 800 case IF_TYPE_POINTOMULTIPOINT: 801 case IF_TYPE_VIRTUALLINK: 802 case IF_TYPE_NBMA: 803 log_debug("if_set_mcast: type %s not supported, interface %s", 804 if_type_name(iface->type), iface->name); 805 return (-1); 806 default: 807 fatalx("if_set_mcast: unknown interface type"); 808 } 809 810 return (0); 811 } 812 813 int 814 if_set_mcast_loop(int fd) 815 { 816 u_int loop = 0; 817 818 if (setsockopt(fd, IPPROTO_IPV6, IPV6_MULTICAST_LOOP, 819 (u_int *)&loop, sizeof(loop)) < 0) { 820 log_warn("if_set_mcast_loop: error setting " 821 "IPV6_MULTICAST_LOOP"); 822 return (-1); 823 } 824 825 return (0); 826 } 827 828 int 829 if_set_ipv6_pktinfo(int fd, int enable) 830 { 831 if (setsockopt(fd, IPPROTO_IPV6, IPV6_RECVPKTINFO, &enable, 832 sizeof(enable)) < 0) { 833 log_warn("if_set_ipv6_pktinfo: error setting IPV6_PKTINFO"); 834 return (-1); 835 } 836 837 return (0); 838 } 839 840 int 841 if_set_ipv6_checksum(int fd) 842 { 843 int offset = offsetof(struct ospf_hdr, chksum); 844 845 log_debug("if_set_ipv6_checksum setting cksum offset to %d", offset); 846 if (setsockopt(fd, IPPROTO_IPV6, IPV6_CHECKSUM, &offset, 847 sizeof(offset)) < 0) { 848 log_warn("if_set_ipv6_checksum: error setting IPV6_CHECKSUM"); 849 return (-1); 850 } 851 return (0); 852 } 853