1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9 * or http://www.opensolaris.org/os/licensing. 10 * See the License for the specific language governing permissions 11 * and limitations under the License. 12 * 13 * When distributing Covered Code, include this CDDL HEADER in each 14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15 * If applicable, add the following below this CDDL HEADER, with the 16 * fields enclosed by brackets "[]" replaced with your own identifying 17 * information: Portions Copyright [yyyy] [name of copyright owner] 18 * 19 * CDDL HEADER END 20 */ 21 /* 22 * Copyright 2007 Sun Microsystems, Inc. All rights reserved. 23 * Use is subject to license terms. 24 */ 25 26 #pragma ident "%Z%%M% %I% %E% SMI" 27 28 #include <sys/types.h> 29 #include <sys/stream.h> 30 #include <sys/stropts.h> 31 #include <sys/strsun.h> 32 #include <sys/sysmacros.h> 33 #include <sys/errno.h> 34 #include <sys/dlpi.h> 35 #include <sys/socket.h> 36 #include <sys/ddi.h> 37 #include <sys/sunddi.h> 38 #include <sys/cmn_err.h> 39 #include <sys/debug.h> 40 #include <sys/vtrace.h> 41 #include <sys/kmem.h> 42 #include <sys/zone.h> 43 #include <sys/ethernet.h> 44 #include <sys/sdt.h> 45 46 #include <net/if.h> 47 #include <net/if_types.h> 48 #include <net/if_dl.h> 49 #include <net/route.h> 50 #include <netinet/in.h> 51 #include <netinet/ip6.h> 52 #include <netinet/icmp6.h> 53 54 #include <inet/common.h> 55 #include <inet/mi.h> 56 #include <inet/mib2.h> 57 #include <inet/nd.h> 58 #include <inet/ip.h> 59 #include <inet/ip_impl.h> 60 #include <inet/ipclassifier.h> 61 #include <inet/ip_if.h> 62 #include <inet/ip_ire.h> 63 #include <inet/ip_rts.h> 64 #include <inet/ip6.h> 65 #include <inet/ip_ndp.h> 66 #include <inet/ipsec_impl.h> 67 #include <inet/ipsec_info.h> 68 #include <inet/sctp_ip.h> 69 70 /* 71 * Function names with nce_ prefix are static while function 72 * names with ndp_ prefix are used by rest of the IP. 73 * 74 * Lock ordering: 75 * 76 * ndp_g_lock -> ill_lock -> nce_lock 77 * 78 * The ndp_g_lock protects the NCE hash (nce_hash_tbl, NCE_HASH_PTR) and 79 * nce_next. Nce_lock protects the contents of the NCE (particularly 80 * nce_refcnt). 81 */ 82 83 static boolean_t nce_cmp_ll_addr(const nce_t *nce, const uchar_t *new_ll_addr, 84 uint32_t ll_addr_len); 85 static void nce_ire_delete(nce_t *nce); 86 static void nce_ire_delete1(ire_t *ire, char *nce_arg); 87 static void nce_set_ll(nce_t *nce, uchar_t *ll_addr); 88 static nce_t *nce_lookup_addr(ill_t *, const in6_addr_t *, nce_t *); 89 static nce_t *nce_lookup_mapping(ill_t *ill, const in6_addr_t *addr); 90 static void nce_make_mapping(nce_t *nce, uchar_t *addrpos, 91 uchar_t *addr); 92 static int nce_set_multicast(ill_t *ill, const in6_addr_t *addr); 93 static void nce_queue_mp(nce_t *nce, mblk_t *mp); 94 static void nce_report1(nce_t *nce, uchar_t *mp_arg); 95 static mblk_t *nce_udreq_alloc(ill_t *ill); 96 static void nce_update(nce_t *nce, uint16_t new_state, 97 uchar_t *new_ll_addr); 98 static uint32_t nce_solicit(nce_t *nce, mblk_t *mp); 99 static boolean_t nce_xmit(ill_t *ill, uint32_t operation, 100 ill_t *hwaddr_ill, boolean_t use_lla_addr, const in6_addr_t *sender, 101 const in6_addr_t *target, int flag); 102 extern void th_trace_rrecord(th_trace_t *); 103 static int ndp_lookup_then_add_v6(ill_t *, uchar_t *, 104 const in6_addr_t *, const in6_addr_t *, const in6_addr_t *, 105 uint32_t, uint16_t, uint16_t, nce_t **, mblk_t *, mblk_t *); 106 static int ndp_lookup_then_add_v4(ill_t *, uchar_t *, 107 const in_addr_t *, const in_addr_t *, const in_addr_t *, 108 uint32_t, uint16_t, uint16_t, nce_t **, mblk_t *, mblk_t *); 109 static int ndp_add_v6(ill_t *, uchar_t *, const in6_addr_t *, 110 const in6_addr_t *, const in6_addr_t *, uint32_t, uint16_t, uint16_t, 111 nce_t **); 112 static int ndp_add_v4(ill_t *, uchar_t *, const in_addr_t *, 113 const in_addr_t *, const in_addr_t *, uint32_t, uint16_t, uint16_t, 114 nce_t **, mblk_t *, mblk_t *); 115 116 117 #ifdef NCE_DEBUG 118 void nce_trace_inactive(nce_t *); 119 #endif 120 121 #define NCE_HASH_PTR_V4(ipst, addr) \ 122 (&((ipst)->ips_ndp4->nce_hash_tbl[IRE_ADDR_HASH(addr, NCE_TABLE_SIZE)])) 123 124 #define NCE_HASH_PTR_V6(ipst, addr) \ 125 (&((ipst)->ips_ndp6->nce_hash_tbl[NCE_ADDR_HASH_V6(addr, \ 126 NCE_TABLE_SIZE)])) 127 128 /* 129 * Compute default flags to use for an advertisement of this nce's address. 130 */ 131 static int 132 nce_advert_flags(const nce_t *nce) 133 { 134 int flag = 0; 135 136 if (nce->nce_flags & NCE_F_ISROUTER) 137 flag |= NDP_ISROUTER; 138 if (!(nce->nce_flags & NCE_F_PROXY)) 139 flag |= NDP_ORIDE; 140 return (flag); 141 } 142 143 int 144 ndp_add(ill_t *ill, uchar_t *hw_addr, const void *addr, 145 const void *mask, const void *extract_mask, 146 uint32_t hw_extract_start, uint16_t flags, uint16_t state, 147 nce_t **newnce, mblk_t *fp_mp, mblk_t *res_mp) 148 { 149 int status; 150 151 if (ill->ill_isv6) 152 status = ndp_add_v6(ill, hw_addr, (in6_addr_t *)addr, 153 (in6_addr_t *)mask, (in6_addr_t *)extract_mask, 154 hw_extract_start, flags, state, newnce); 155 else 156 status = ndp_add_v4(ill, hw_addr, (in_addr_t *)addr, 157 (in_addr_t *)mask, (in_addr_t *)extract_mask, 158 hw_extract_start, flags, state, newnce, fp_mp, res_mp); 159 return (status); 160 } 161 162 /* Non-tunable probe interval, based on link capabilities */ 163 #define ILL_PROBE_INTERVAL(ill) ((ill)->ill_note_link ? 150 : 1500) 164 165 /* 166 * NDP Cache Entry creation routine. 167 * Mapped entries will never do NUD . 168 * This routine must always be called with ndp6->ndp_g_lock held. 169 * Prior to return, nce_refcnt is incremented. 170 */ 171 static int 172 ndp_add_v6(ill_t *ill, uchar_t *hw_addr, const in6_addr_t *addr, 173 const in6_addr_t *mask, const in6_addr_t *extract_mask, 174 uint32_t hw_extract_start, uint16_t flags, uint16_t state, 175 nce_t **newnce) 176 { 177 static nce_t nce_nil; 178 nce_t *nce; 179 mblk_t *mp; 180 mblk_t *template; 181 nce_t **ncep; 182 int err; 183 boolean_t dropped = B_FALSE; 184 ip_stack_t *ipst = ill->ill_ipst; 185 186 ASSERT(MUTEX_HELD(&ipst->ips_ndp6->ndp_g_lock)); 187 ASSERT(ill != NULL && ill->ill_isv6); 188 if (IN6_IS_ADDR_UNSPECIFIED(addr)) { 189 ip0dbg(("ndp_add: no addr\n")); 190 return (EINVAL); 191 } 192 if ((flags & ~NCE_EXTERNAL_FLAGS_MASK)) { 193 ip0dbg(("ndp_add: flags = %x\n", (int)flags)); 194 return (EINVAL); 195 } 196 if (IN6_IS_ADDR_UNSPECIFIED(extract_mask) && 197 (flags & NCE_F_MAPPING)) { 198 ip0dbg(("ndp_add: extract mask zero for mapping")); 199 return (EINVAL); 200 } 201 /* 202 * Allocate the mblk to hold the nce. 203 * 204 * XXX This can come out of a separate cache - nce_cache. 205 * We don't need the mp anymore as there are no more 206 * "qwriter"s 207 */ 208 mp = allocb(sizeof (nce_t), BPRI_MED); 209 if (mp == NULL) 210 return (ENOMEM); 211 212 nce = (nce_t *)mp->b_rptr; 213 mp->b_wptr = (uchar_t *)&nce[1]; 214 *nce = nce_nil; 215 216 /* 217 * This one holds link layer address 218 */ 219 if (ill->ill_net_type == IRE_IF_RESOLVER) { 220 template = nce_udreq_alloc(ill); 221 } else { 222 if (ill->ill_resolver_mp == NULL) { 223 freeb(mp); 224 return (EINVAL); 225 } 226 ASSERT((ill->ill_net_type == IRE_IF_NORESOLVER)); 227 template = copyb(ill->ill_resolver_mp); 228 } 229 if (template == NULL) { 230 freeb(mp); 231 return (ENOMEM); 232 } 233 nce->nce_ill = ill; 234 nce->nce_ipversion = IPV6_VERSION; 235 nce->nce_flags = flags; 236 nce->nce_state = state; 237 nce->nce_pcnt = ND_MAX_UNICAST_SOLICIT; 238 nce->nce_rcnt = ill->ill_xmit_count; 239 nce->nce_addr = *addr; 240 nce->nce_mask = *mask; 241 nce->nce_extract_mask = *extract_mask; 242 nce->nce_ll_extract_start = hw_extract_start; 243 nce->nce_fp_mp = NULL; 244 nce->nce_res_mp = template; 245 if (state == ND_REACHABLE) 246 nce->nce_last = TICK_TO_MSEC(lbolt64); 247 else 248 nce->nce_last = 0; 249 nce->nce_qd_mp = NULL; 250 nce->nce_mp = mp; 251 if (hw_addr != NULL) 252 nce_set_ll(nce, hw_addr); 253 /* This one is for nce getting created */ 254 nce->nce_refcnt = 1; 255 mutex_init(&nce->nce_lock, NULL, MUTEX_DEFAULT, NULL); 256 if (nce->nce_flags & NCE_F_MAPPING) { 257 ASSERT(IN6_IS_ADDR_MULTICAST(addr)); 258 ASSERT(!IN6_IS_ADDR_UNSPECIFIED(&nce->nce_mask)); 259 ASSERT(!IN6_IS_ADDR_UNSPECIFIED(&nce->nce_extract_mask)); 260 ncep = &ipst->ips_ndp6->nce_mask_entries; 261 } else { 262 ncep = ((nce_t **)NCE_HASH_PTR_V6(ipst, *addr)); 263 } 264 265 #ifdef NCE_DEBUG 266 bzero(nce->nce_trace, sizeof (th_trace_t *) * IP_TR_HASH_MAX); 267 #endif 268 /* 269 * Atomically ensure that the ill is not CONDEMNED, before 270 * adding the NCE. 271 */ 272 mutex_enter(&ill->ill_lock); 273 if (ill->ill_state_flags & ILL_CONDEMNED) { 274 mutex_exit(&ill->ill_lock); 275 freeb(mp); 276 freeb(template); 277 return (EINVAL); 278 } 279 if ((nce->nce_next = *ncep) != NULL) 280 nce->nce_next->nce_ptpn = &nce->nce_next; 281 *ncep = nce; 282 nce->nce_ptpn = ncep; 283 *newnce = nce; 284 /* This one is for nce being used by an active thread */ 285 NCE_REFHOLD(*newnce); 286 287 /* Bump up the number of nce's referencing this ill */ 288 ill->ill_nce_cnt++; 289 mutex_exit(&ill->ill_lock); 290 291 err = 0; 292 if ((flags & NCE_F_PERMANENT) && state == ND_PROBE) { 293 mutex_enter(&nce->nce_lock); 294 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 295 nce->nce_pcnt = ND_MAX_UNICAST_SOLICIT; 296 mutex_exit(&nce->nce_lock); 297 dropped = nce_xmit(ill, ND_NEIGHBOR_SOLICIT, NULL, B_FALSE, 298 &ipv6_all_zeros, addr, NDP_PROBE); 299 if (dropped) { 300 mutex_enter(&nce->nce_lock); 301 nce->nce_pcnt++; 302 mutex_exit(&nce->nce_lock); 303 } 304 NDP_RESTART_TIMER(nce, ILL_PROBE_INTERVAL(ill)); 305 mutex_enter(&ipst->ips_ndp6->ndp_g_lock); 306 err = EINPROGRESS; 307 } else if (flags & NCE_F_UNSOL_ADV) { 308 /* 309 * We account for the transmit below by assigning one 310 * less than the ndd variable. Subsequent decrements 311 * are done in ndp_timer. 312 */ 313 mutex_enter(&nce->nce_lock); 314 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 315 nce->nce_unsolicit_count = ipst->ips_ip_ndp_unsolicit_count - 1; 316 mutex_exit(&nce->nce_lock); 317 dropped = nce_xmit(ill, 318 ND_NEIGHBOR_ADVERT, 319 ill, /* ill to be used for extracting ill_nd_lla */ 320 B_TRUE, /* use ill_nd_lla */ 321 addr, /* Source and target of the advertisement pkt */ 322 &ipv6_all_hosts_mcast, /* Destination of the packet */ 323 nce_advert_flags(nce)); 324 mutex_enter(&nce->nce_lock); 325 if (dropped) 326 nce->nce_unsolicit_count++; 327 if (nce->nce_unsolicit_count != 0) { 328 nce->nce_timeout_id = timeout(ndp_timer, nce, 329 MSEC_TO_TICK(ipst->ips_ip_ndp_unsolicit_interval)); 330 } 331 mutex_exit(&nce->nce_lock); 332 mutex_enter(&ipst->ips_ndp6->ndp_g_lock); 333 } 334 /* 335 * If the hw_addr is NULL, typically for ND_INCOMPLETE nces, then 336 * we call nce_fastpath as soon as the nce is resolved in ndp_process. 337 * We call nce_fastpath from nce_update if the link layer address of 338 * the peer changes from nce_update 339 */ 340 if (hw_addr != NULL || ill->ill_net_type == IRE_IF_NORESOLVER) 341 nce_fastpath(nce); 342 return (err); 343 } 344 345 int 346 ndp_lookup_then_add(ill_t *ill, uchar_t *hw_addr, const void *addr, 347 const void *mask, const void *extract_mask, 348 uint32_t hw_extract_start, uint16_t flags, uint16_t state, 349 nce_t **newnce, mblk_t *fp_mp, mblk_t *res_mp) 350 { 351 int status; 352 353 if (ill->ill_isv6) { 354 status = ndp_lookup_then_add_v6(ill, hw_addr, 355 (in6_addr_t *)addr, (in6_addr_t *)mask, 356 (in6_addr_t *)extract_mask, hw_extract_start, flags, 357 state, newnce, fp_mp, res_mp); 358 } else { 359 status = ndp_lookup_then_add_v4(ill, hw_addr, 360 (in_addr_t *)addr, (in_addr_t *)mask, 361 (in_addr_t *)extract_mask, hw_extract_start, flags, 362 state, newnce, fp_mp, res_mp); 363 } 364 365 return (status); 366 } 367 368 static int 369 ndp_lookup_then_add_v6(ill_t *ill, uchar_t *hw_addr, const in6_addr_t *addr, 370 const in6_addr_t *mask, const in6_addr_t *extract_mask, 371 uint32_t hw_extract_start, uint16_t flags, uint16_t state, 372 nce_t **newnce, mblk_t *fp_mp, mblk_t *res_mp) 373 { 374 int err = 0; 375 nce_t *nce; 376 ip_stack_t *ipst = ill->ill_ipst; 377 378 ASSERT(ill != NULL && ill->ill_isv6); 379 mutex_enter(&ipst->ips_ndp6->ndp_g_lock); 380 381 /* Get head of v6 hash table */ 382 nce = *((nce_t **)NCE_HASH_PTR_V6(ipst, *addr)); 383 nce = nce_lookup_addr(ill, addr, nce); 384 if (nce == NULL) { 385 err = ndp_add(ill, 386 hw_addr, 387 addr, 388 mask, 389 extract_mask, 390 hw_extract_start, 391 flags, 392 state, 393 newnce, 394 fp_mp, 395 res_mp); 396 } else { 397 *newnce = nce; 398 err = EEXIST; 399 } 400 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 401 return (err); 402 } 403 404 /* 405 * Remove all the CONDEMNED nces from the appropriate hash table. 406 * We create a private list of NCEs, these may have ires pointing 407 * to them, so the list will be passed through to clean up dependent 408 * ires and only then we can do NCE_REFRELE which can make NCE inactive. 409 */ 410 static void 411 nce_remove(ndp_g_t *ndp, nce_t *nce, nce_t **free_nce_list) 412 { 413 nce_t *nce1; 414 nce_t **ptpn; 415 416 ASSERT(MUTEX_HELD(&ndp->ndp_g_lock)); 417 ASSERT(ndp->ndp_g_walker == 0); 418 for (; nce; nce = nce1) { 419 nce1 = nce->nce_next; 420 mutex_enter(&nce->nce_lock); 421 if (nce->nce_flags & NCE_F_CONDEMNED) { 422 ptpn = nce->nce_ptpn; 423 nce1 = nce->nce_next; 424 if (nce1 != NULL) 425 nce1->nce_ptpn = ptpn; 426 *ptpn = nce1; 427 nce->nce_ptpn = NULL; 428 nce->nce_next = NULL; 429 nce->nce_next = *free_nce_list; 430 *free_nce_list = nce; 431 } 432 mutex_exit(&nce->nce_lock); 433 } 434 } 435 436 /* 437 * 1. Mark the nce CONDEMNED. This ensures that no new nce_lookup() 438 * will return this NCE. Also no new IREs will be created that 439 * point to this NCE (See ire_add_v6). Also no new timeouts will 440 * be started (See NDP_RESTART_TIMER). 441 * 2. Cancel any currently running timeouts. 442 * 3. If there is an ndp walker, return. The walker will do the cleanup. 443 * This ensures that walkers see a consistent list of NCEs while walking. 444 * 4. Otherwise remove the NCE from the list of NCEs 445 * 5. Delete all IREs pointing to this NCE. 446 */ 447 void 448 ndp_delete(nce_t *nce) 449 { 450 nce_t **ptpn; 451 nce_t *nce1; 452 int ipversion = nce->nce_ipversion; 453 ndp_g_t *ndp; 454 ip_stack_t *ipst = nce->nce_ill->ill_ipst; 455 456 if (ipversion == IPV4_VERSION) 457 ndp = ipst->ips_ndp4; 458 else 459 ndp = ipst->ips_ndp6; 460 461 /* Serialize deletes */ 462 mutex_enter(&nce->nce_lock); 463 if (nce->nce_flags & NCE_F_CONDEMNED) { 464 /* Some other thread is doing the delete */ 465 mutex_exit(&nce->nce_lock); 466 return; 467 } 468 /* 469 * Caller has a refhold. Also 1 ref for being in the list. Thus 470 * refcnt has to be >= 2 471 */ 472 ASSERT(nce->nce_refcnt >= 2); 473 nce->nce_flags |= NCE_F_CONDEMNED; 474 mutex_exit(&nce->nce_lock); 475 476 nce_fastpath_list_delete(nce); 477 478 /* 479 * Cancel any running timer. Timeout can't be restarted 480 * since CONDEMNED is set. Can't hold nce_lock across untimeout. 481 * Passing invalid timeout id is fine. 482 */ 483 if (nce->nce_timeout_id != 0) { 484 (void) untimeout(nce->nce_timeout_id); 485 nce->nce_timeout_id = 0; 486 } 487 488 mutex_enter(&ndp->ndp_g_lock); 489 if (nce->nce_ptpn == NULL) { 490 /* 491 * The last ndp walker has already removed this nce from 492 * the list after we marked the nce CONDEMNED and before 493 * we grabbed the global lock. 494 */ 495 mutex_exit(&ndp->ndp_g_lock); 496 return; 497 } 498 if (ndp->ndp_g_walker > 0) { 499 /* 500 * Can't unlink. The walker will clean up 501 */ 502 ndp->ndp_g_walker_cleanup = B_TRUE; 503 mutex_exit(&ndp->ndp_g_lock); 504 return; 505 } 506 507 /* 508 * Now remove the nce from the list. NDP_RESTART_TIMER won't restart 509 * the timer since it is marked CONDEMNED. 510 */ 511 ptpn = nce->nce_ptpn; 512 nce1 = nce->nce_next; 513 if (nce1 != NULL) 514 nce1->nce_ptpn = ptpn; 515 *ptpn = nce1; 516 nce->nce_ptpn = NULL; 517 nce->nce_next = NULL; 518 mutex_exit(&ndp->ndp_g_lock); 519 520 nce_ire_delete(nce); 521 } 522 523 void 524 ndp_inactive(nce_t *nce) 525 { 526 mblk_t **mpp; 527 ill_t *ill; 528 529 ASSERT(nce->nce_refcnt == 0); 530 ASSERT(MUTEX_HELD(&nce->nce_lock)); 531 ASSERT(nce->nce_fastpath == NULL); 532 533 /* Free all nce allocated messages */ 534 mpp = &nce->nce_first_mp_to_free; 535 do { 536 while (*mpp != NULL) { 537 mblk_t *mp; 538 539 mp = *mpp; 540 *mpp = mp->b_next; 541 542 inet_freemsg(mp); 543 } 544 } while (mpp++ != &nce->nce_last_mp_to_free); 545 546 #ifdef NCE_DEBUG 547 nce_trace_inactive(nce); 548 #endif 549 550 ill = nce->nce_ill; 551 mutex_enter(&ill->ill_lock); 552 ill->ill_nce_cnt--; 553 /* 554 * If the number of nce's associated with this ill have dropped 555 * to zero, check whether we need to restart any operation that 556 * is waiting for this to happen. 557 */ 558 if (ill->ill_nce_cnt == 0) { 559 /* ipif_ill_refrele_tail drops the ill_lock */ 560 ipif_ill_refrele_tail(ill); 561 } else { 562 mutex_exit(&ill->ill_lock); 563 } 564 mutex_destroy(&nce->nce_lock); 565 if (nce->nce_mp != NULL) 566 inet_freemsg(nce->nce_mp); 567 } 568 569 /* 570 * ndp_walk routine. Delete the nce if it is associated with the ill 571 * that is going away. Always called as a writer. 572 */ 573 void 574 ndp_delete_per_ill(nce_t *nce, uchar_t *arg) 575 { 576 if ((nce != NULL) && nce->nce_ill == (ill_t *)arg) { 577 ndp_delete(nce); 578 } 579 } 580 581 /* 582 * Walk a list of to be inactive NCEs and blow away all the ires. 583 */ 584 static void 585 nce_ire_delete_list(nce_t *nce) 586 { 587 nce_t *nce_next; 588 589 ASSERT(nce != NULL); 590 while (nce != NULL) { 591 nce_next = nce->nce_next; 592 nce->nce_next = NULL; 593 594 /* 595 * It is possible for the last ndp walker (this thread) 596 * to come here after ndp_delete has marked the nce CONDEMNED 597 * and before it has removed the nce from the fastpath list 598 * or called untimeout. So we need to do it here. It is safe 599 * for both ndp_delete and this thread to do it twice or 600 * even simultaneously since each of the threads has a 601 * reference on the nce. 602 */ 603 nce_fastpath_list_delete(nce); 604 /* 605 * Cancel any running timer. Timeout can't be restarted 606 * since CONDEMNED is set. Can't hold nce_lock across untimeout. 607 * Passing invalid timeout id is fine. 608 */ 609 if (nce->nce_timeout_id != 0) { 610 (void) untimeout(nce->nce_timeout_id); 611 nce->nce_timeout_id = 0; 612 } 613 /* 614 * We might hit this func thus in the v4 case: 615 * ipif_down->ipif_ndp_down->ndp_walk 616 */ 617 618 if (nce->nce_ipversion == IPV4_VERSION) { 619 ire_walk_ill_v4(MATCH_IRE_ILL | MATCH_IRE_TYPE, 620 IRE_CACHE, nce_ire_delete1, 621 (char *)nce, nce->nce_ill); 622 } else { 623 ASSERT(nce->nce_ipversion == IPV6_VERSION); 624 ire_walk_ill_v6(MATCH_IRE_ILL | MATCH_IRE_TYPE, 625 IRE_CACHE, nce_ire_delete1, 626 (char *)nce, nce->nce_ill); 627 } 628 NCE_REFRELE_NOTR(nce); 629 nce = nce_next; 630 } 631 } 632 633 /* 634 * Delete an ire when the nce goes away. 635 */ 636 /* ARGSUSED */ 637 static void 638 nce_ire_delete(nce_t *nce) 639 { 640 if (nce->nce_ipversion == IPV6_VERSION) { 641 ire_walk_ill_v6(MATCH_IRE_ILL | MATCH_IRE_TYPE, IRE_CACHE, 642 nce_ire_delete1, (char *)nce, nce->nce_ill); 643 NCE_REFRELE_NOTR(nce); 644 } else { 645 ire_walk_ill_v4(MATCH_IRE_ILL | MATCH_IRE_TYPE, IRE_CACHE, 646 nce_ire_delete1, (char *)nce, nce->nce_ill); 647 NCE_REFRELE_NOTR(nce); 648 } 649 } 650 651 /* 652 * ire_walk routine used to delete every IRE that shares this nce 653 */ 654 static void 655 nce_ire_delete1(ire_t *ire, char *nce_arg) 656 { 657 nce_t *nce = (nce_t *)nce_arg; 658 659 ASSERT(ire->ire_type == IRE_CACHE); 660 661 if (ire->ire_nce == nce) { 662 ASSERT(ire->ire_ipversion == nce->nce_ipversion); 663 ire_delete(ire); 664 } 665 } 666 667 /* 668 * Restart DAD on given NCE. Returns B_TRUE if DAD has been restarted. 669 */ 670 boolean_t 671 ndp_restart_dad(nce_t *nce) 672 { 673 boolean_t started; 674 boolean_t dropped; 675 676 if (nce == NULL) 677 return (B_FALSE); 678 mutex_enter(&nce->nce_lock); 679 if (nce->nce_state == ND_PROBE) { 680 mutex_exit(&nce->nce_lock); 681 started = B_TRUE; 682 } else if (nce->nce_state == ND_REACHABLE) { 683 nce->nce_state = ND_PROBE; 684 nce->nce_pcnt = ND_MAX_UNICAST_SOLICIT - 1; 685 mutex_exit(&nce->nce_lock); 686 dropped = nce_xmit(nce->nce_ill, ND_NEIGHBOR_SOLICIT, NULL, 687 B_FALSE, &ipv6_all_zeros, &nce->nce_addr, NDP_PROBE); 688 if (dropped) { 689 mutex_enter(&nce->nce_lock); 690 nce->nce_pcnt++; 691 mutex_exit(&nce->nce_lock); 692 } 693 NDP_RESTART_TIMER(nce, ILL_PROBE_INTERVAL(nce->nce_ill)); 694 started = B_TRUE; 695 } else { 696 mutex_exit(&nce->nce_lock); 697 started = B_FALSE; 698 } 699 return (started); 700 } 701 702 /* 703 * IPv6 Cache entry lookup. Try to find an nce matching the parameters passed. 704 * If one is found, the refcnt on the nce will be incremented. 705 */ 706 nce_t * 707 ndp_lookup_v6(ill_t *ill, const in6_addr_t *addr, boolean_t caller_holds_lock) 708 { 709 nce_t *nce; 710 ip_stack_t *ipst; 711 712 ASSERT(ill != NULL); 713 ipst = ill->ill_ipst; 714 715 ASSERT(ill != NULL && ill->ill_isv6); 716 if (!caller_holds_lock) { 717 mutex_enter(&ipst->ips_ndp6->ndp_g_lock); 718 } 719 720 /* Get head of v6 hash table */ 721 nce = *((nce_t **)NCE_HASH_PTR_V6(ipst, *addr)); 722 nce = nce_lookup_addr(ill, addr, nce); 723 if (nce == NULL) 724 nce = nce_lookup_mapping(ill, addr); 725 if (!caller_holds_lock) 726 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 727 return (nce); 728 } 729 /* 730 * IPv4 Cache entry lookup. Try to find an nce matching the parameters passed. 731 * If one is found, the refcnt on the nce will be incremented. 732 * Since multicast mappings are handled in arp, there are no nce_mcast_entries 733 * so we skip the nce_lookup_mapping call. 734 * XXX TODO: if the nce is found to be ND_STALE, ndp_delete it and return NULL 735 */ 736 nce_t * 737 ndp_lookup_v4(ill_t *ill, const in_addr_t *addr, boolean_t caller_holds_lock) 738 { 739 nce_t *nce; 740 in6_addr_t addr6; 741 ip_stack_t *ipst = ill->ill_ipst; 742 743 if (!caller_holds_lock) { 744 mutex_enter(&ipst->ips_ndp4->ndp_g_lock); 745 } 746 747 /* Get head of v4 hash table */ 748 nce = *((nce_t **)NCE_HASH_PTR_V4(ipst, *addr)); 749 IN6_IPADDR_TO_V4MAPPED(*addr, &addr6); 750 nce = nce_lookup_addr(ill, &addr6, nce); 751 if (!caller_holds_lock) 752 mutex_exit(&ipst->ips_ndp4->ndp_g_lock); 753 return (nce); 754 } 755 756 /* 757 * Cache entry lookup. Try to find an nce matching the parameters passed. 758 * Look only for exact entries (no mappings). If an nce is found, increment 759 * the hold count on that nce. The caller passes in the start of the 760 * appropriate hash table, and must be holding the appropriate global 761 * lock (ndp_g_lock). 762 */ 763 static nce_t * 764 nce_lookup_addr(ill_t *ill, const in6_addr_t *addr, nce_t *nce) 765 { 766 ndp_g_t *ndp; 767 ip_stack_t *ipst = ill->ill_ipst; 768 769 if (ill->ill_isv6) 770 ndp = ipst->ips_ndp6; 771 else 772 ndp = ipst->ips_ndp4; 773 774 ASSERT(ill != NULL); 775 ASSERT(MUTEX_HELD(&ndp->ndp_g_lock)); 776 if (IN6_IS_ADDR_UNSPECIFIED(addr)) 777 return (NULL); 778 for (; nce != NULL; nce = nce->nce_next) { 779 if (nce->nce_ill == ill) { 780 if (IN6_ARE_ADDR_EQUAL(&nce->nce_addr, addr) && 781 IN6_ARE_ADDR_EQUAL(&nce->nce_mask, 782 &ipv6_all_ones)) { 783 mutex_enter(&nce->nce_lock); 784 if (!(nce->nce_flags & NCE_F_CONDEMNED)) { 785 NCE_REFHOLD_LOCKED(nce); 786 mutex_exit(&nce->nce_lock); 787 break; 788 } 789 mutex_exit(&nce->nce_lock); 790 } 791 } 792 } 793 return (nce); 794 } 795 796 /* 797 * Cache entry lookup. Try to find an nce matching the parameters passed. 798 * Look only for mappings. 799 */ 800 static nce_t * 801 nce_lookup_mapping(ill_t *ill, const in6_addr_t *addr) 802 { 803 nce_t *nce; 804 ip_stack_t *ipst = ill->ill_ipst; 805 806 ASSERT(ill != NULL && ill->ill_isv6); 807 ASSERT(MUTEX_HELD(&ipst->ips_ndp6->ndp_g_lock)); 808 if (!IN6_IS_ADDR_MULTICAST(addr)) 809 return (NULL); 810 nce = ipst->ips_ndp6->nce_mask_entries; 811 for (; nce != NULL; nce = nce->nce_next) 812 if (nce->nce_ill == ill && 813 (V6_MASK_EQ(*addr, nce->nce_mask, nce->nce_addr))) { 814 mutex_enter(&nce->nce_lock); 815 if (!(nce->nce_flags & NCE_F_CONDEMNED)) { 816 NCE_REFHOLD_LOCKED(nce); 817 mutex_exit(&nce->nce_lock); 818 break; 819 } 820 mutex_exit(&nce->nce_lock); 821 } 822 return (nce); 823 } 824 825 /* 826 * Process passed in parameters either from an incoming packet or via 827 * user ioctl. 828 */ 829 void 830 ndp_process(nce_t *nce, uchar_t *hw_addr, uint32_t flag, boolean_t is_adv) 831 { 832 ill_t *ill = nce->nce_ill; 833 uint32_t hw_addr_len = ill->ill_nd_lla_len; 834 mblk_t *mp; 835 boolean_t ll_updated = B_FALSE; 836 boolean_t ll_changed; 837 ip_stack_t *ipst = ill->ill_ipst; 838 839 ASSERT(nce->nce_ipversion == IPV6_VERSION); 840 /* 841 * No updates of link layer address or the neighbor state is 842 * allowed, when the cache is in NONUD state. This still 843 * allows for responding to reachability solicitation. 844 */ 845 mutex_enter(&nce->nce_lock); 846 if (nce->nce_state == ND_INCOMPLETE) { 847 if (hw_addr == NULL) { 848 mutex_exit(&nce->nce_lock); 849 return; 850 } 851 nce_set_ll(nce, hw_addr); 852 /* 853 * Update nce state and send the queued packets 854 * back to ip this time ire will be added. 855 */ 856 if (flag & ND_NA_FLAG_SOLICITED) { 857 nce_update(nce, ND_REACHABLE, NULL); 858 } else { 859 nce_update(nce, ND_STALE, NULL); 860 } 861 mutex_exit(&nce->nce_lock); 862 nce_fastpath(nce); 863 mutex_enter(&nce->nce_lock); 864 mp = nce->nce_qd_mp; 865 nce->nce_qd_mp = NULL; 866 mutex_exit(&nce->nce_lock); 867 while (mp != NULL) { 868 mblk_t *nxt_mp, *data_mp; 869 870 nxt_mp = mp->b_next; 871 mp->b_next = NULL; 872 873 if (mp->b_datap->db_type == M_CTL) 874 data_mp = mp->b_cont; 875 else 876 data_mp = mp; 877 if (data_mp->b_prev != NULL) { 878 ill_t *inbound_ill; 879 queue_t *fwdq = NULL; 880 uint_t ifindex; 881 882 ifindex = (uint_t)(uintptr_t)data_mp->b_prev; 883 inbound_ill = ill_lookup_on_ifindex(ifindex, 884 B_TRUE, NULL, NULL, NULL, NULL, ipst); 885 if (inbound_ill == NULL) { 886 data_mp->b_prev = NULL; 887 freemsg(mp); 888 return; 889 } else { 890 fwdq = inbound_ill->ill_rq; 891 } 892 data_mp->b_prev = NULL; 893 /* 894 * Send a forwarded packet back into ip_rput_v6 895 * just as in ire_send_v6(). 896 * Extract the queue from b_prev (set in 897 * ip_rput_data_v6). 898 */ 899 if (fwdq != NULL) { 900 /* 901 * Forwarded packets hop count will 902 * get decremented in ip_rput_data_v6 903 */ 904 if (data_mp != mp) 905 freeb(mp); 906 put(fwdq, data_mp); 907 } else { 908 /* 909 * Send locally originated packets back 910 * into * ip_wput_v6. 911 */ 912 put(ill->ill_wq, mp); 913 } 914 ill_refrele(inbound_ill); 915 } else { 916 put(ill->ill_wq, mp); 917 } 918 mp = nxt_mp; 919 } 920 return; 921 } 922 ll_changed = nce_cmp_ll_addr(nce, hw_addr, hw_addr_len); 923 if (!is_adv) { 924 /* If this is a SOLICITATION request only */ 925 if (ll_changed) 926 nce_update(nce, ND_STALE, hw_addr); 927 mutex_exit(&nce->nce_lock); 928 return; 929 } 930 if (!(flag & ND_NA_FLAG_OVERRIDE) && ll_changed) { 931 /* If in any other state than REACHABLE, ignore */ 932 if (nce->nce_state == ND_REACHABLE) { 933 nce_update(nce, ND_STALE, NULL); 934 } 935 mutex_exit(&nce->nce_lock); 936 return; 937 } else { 938 if (ll_changed) { 939 nce_update(nce, ND_UNCHANGED, hw_addr); 940 ll_updated = B_TRUE; 941 } 942 if (flag & ND_NA_FLAG_SOLICITED) { 943 nce_update(nce, ND_REACHABLE, NULL); 944 } else { 945 if (ll_updated) { 946 nce_update(nce, ND_STALE, NULL); 947 } 948 } 949 mutex_exit(&nce->nce_lock); 950 if (!(flag & ND_NA_FLAG_ROUTER) && (nce->nce_flags & 951 NCE_F_ISROUTER)) { 952 ire_t *ire; 953 954 /* 955 * Router turned to host. We need to remove the 956 * entry as well as any default route that may be 957 * using this as a next hop. This is required by 958 * section 7.2.5 of RFC 2461. 959 */ 960 ire = ire_ftable_lookup_v6(&ipv6_all_zeros, 961 &ipv6_all_zeros, &nce->nce_addr, IRE_DEFAULT, 962 nce->nce_ill->ill_ipif, NULL, ALL_ZONES, 0, NULL, 963 MATCH_IRE_ILL | MATCH_IRE_TYPE | MATCH_IRE_GW | 964 MATCH_IRE_DEFAULT, ipst); 965 if (ire != NULL) { 966 ip_rts_rtmsg(RTM_DELETE, ire, 0, ipst); 967 ire_delete(ire); 968 ire_refrele(ire); 969 } 970 ndp_delete(nce); 971 } 972 } 973 } 974 975 /* 976 * Pass arg1 to the pfi supplied, along with each nce in existence. 977 * ndp_walk() places a REFHOLD on the nce and drops the lock when 978 * walking the hash list. 979 */ 980 void 981 ndp_walk_common(ndp_g_t *ndp, ill_t *ill, pfi_t pfi, void *arg1, 982 boolean_t trace) 983 { 984 985 nce_t *nce; 986 nce_t *nce1; 987 nce_t **ncep; 988 nce_t *free_nce_list = NULL; 989 990 mutex_enter(&ndp->ndp_g_lock); 991 /* Prevent ndp_delete from unlink and free of NCE */ 992 ndp->ndp_g_walker++; 993 mutex_exit(&ndp->ndp_g_lock); 994 for (ncep = ndp->nce_hash_tbl; 995 ncep < A_END(ndp->nce_hash_tbl); ncep++) { 996 for (nce = *ncep; nce != NULL; nce = nce1) { 997 nce1 = nce->nce_next; 998 if (ill == NULL || nce->nce_ill == ill) { 999 if (trace) { 1000 NCE_REFHOLD(nce); 1001 (*pfi)(nce, arg1); 1002 NCE_REFRELE(nce); 1003 } else { 1004 NCE_REFHOLD_NOTR(nce); 1005 (*pfi)(nce, arg1); 1006 NCE_REFRELE_NOTR(nce); 1007 } 1008 } 1009 } 1010 } 1011 for (nce = ndp->nce_mask_entries; nce != NULL; nce = nce1) { 1012 nce1 = nce->nce_next; 1013 if (ill == NULL || nce->nce_ill == ill) { 1014 if (trace) { 1015 NCE_REFHOLD(nce); 1016 (*pfi)(nce, arg1); 1017 NCE_REFRELE(nce); 1018 } else { 1019 NCE_REFHOLD_NOTR(nce); 1020 (*pfi)(nce, arg1); 1021 NCE_REFRELE_NOTR(nce); 1022 } 1023 } 1024 } 1025 mutex_enter(&ndp->ndp_g_lock); 1026 ndp->ndp_g_walker--; 1027 /* 1028 * While NCE's are removed from global list they are placed 1029 * in a private list, to be passed to nce_ire_delete_list(). 1030 * The reason is, there may be ires pointing to this nce 1031 * which needs to cleaned up. 1032 */ 1033 if (ndp->ndp_g_walker_cleanup && ndp->ndp_g_walker == 0) { 1034 /* Time to delete condemned entries */ 1035 for (ncep = ndp->nce_hash_tbl; 1036 ncep < A_END(ndp->nce_hash_tbl); ncep++) { 1037 nce = *ncep; 1038 if (nce != NULL) { 1039 nce_remove(ndp, nce, &free_nce_list); 1040 } 1041 } 1042 nce = ndp->nce_mask_entries; 1043 if (nce != NULL) { 1044 nce_remove(ndp, nce, &free_nce_list); 1045 } 1046 ndp->ndp_g_walker_cleanup = B_FALSE; 1047 } 1048 mutex_exit(&ndp->ndp_g_lock); 1049 1050 if (free_nce_list != NULL) { 1051 nce_ire_delete_list(free_nce_list); 1052 } 1053 } 1054 1055 /* 1056 * Walk everything. 1057 * Note that ill can be NULL hence can't derive the ipst from it. 1058 */ 1059 void 1060 ndp_walk(ill_t *ill, pfi_t pfi, void *arg1, ip_stack_t *ipst) 1061 { 1062 ndp_walk_common(ipst->ips_ndp4, ill, pfi, arg1, B_TRUE); 1063 ndp_walk_common(ipst->ips_ndp6, ill, pfi, arg1, B_TRUE); 1064 } 1065 1066 /* 1067 * Process resolve requests. Handles both mapped entries 1068 * as well as cases that needs to be send out on the wire. 1069 * Lookup a NCE for a given IRE. Regardless of whether one exists 1070 * or one is created, we defer making ire point to nce until the 1071 * ire is actually added at which point the nce_refcnt on the nce is 1072 * incremented. This is done primarily to have symmetry between ire_add() 1073 * and ire_delete() which decrements the nce_refcnt, when an ire is deleted. 1074 */ 1075 int 1076 ndp_resolver(ill_t *ill, const in6_addr_t *dst, mblk_t *mp, zoneid_t zoneid) 1077 { 1078 nce_t *nce; 1079 int err = 0; 1080 uint32_t ms; 1081 mblk_t *mp_nce = NULL; 1082 ip_stack_t *ipst = ill->ill_ipst; 1083 1084 ASSERT(ill != NULL); 1085 ASSERT(ill->ill_isv6); 1086 if (IN6_IS_ADDR_MULTICAST(dst)) { 1087 err = nce_set_multicast(ill, dst); 1088 return (err); 1089 } 1090 err = ndp_lookup_then_add(ill, 1091 NULL, /* No hardware address */ 1092 dst, 1093 &ipv6_all_ones, 1094 &ipv6_all_zeros, 1095 0, 1096 (ill->ill_flags & ILLF_NONUD) ? NCE_F_NONUD : 0, 1097 ND_INCOMPLETE, 1098 &nce, 1099 NULL, /* let ndp_add figure out fastpath mp and dlureq_mp for v6 */ 1100 NULL); 1101 1102 switch (err) { 1103 case 0: 1104 /* 1105 * New cache entry was created. Make sure that the state 1106 * is not ND_INCOMPLETE. It can be in some other state 1107 * even before we send out the solicitation as we could 1108 * get un-solicited advertisements. 1109 * 1110 * If this is an XRESOLV interface, simply return 0, 1111 * since we don't want to solicit just yet. 1112 */ 1113 if (ill->ill_flags & ILLF_XRESOLV) { 1114 NCE_REFRELE(nce); 1115 return (0); 1116 } 1117 rw_enter(&ipst->ips_ill_g_lock, RW_READER); 1118 mutex_enter(&nce->nce_lock); 1119 if (nce->nce_state != ND_INCOMPLETE) { 1120 mutex_exit(&nce->nce_lock); 1121 rw_exit(&ipst->ips_ill_g_lock); 1122 NCE_REFRELE(nce); 1123 return (0); 1124 } 1125 mp_nce = ip_prepend_zoneid(mp, zoneid, ipst); 1126 if (mp_nce == NULL) { 1127 /* The caller will free mp */ 1128 mutex_exit(&nce->nce_lock); 1129 rw_exit(&ipst->ips_ill_g_lock); 1130 ndp_delete(nce); 1131 NCE_REFRELE(nce); 1132 return (ENOMEM); 1133 } 1134 ms = nce_solicit(nce, mp_nce); 1135 rw_exit(&ipst->ips_ill_g_lock); 1136 if (ms == 0) { 1137 /* The caller will free mp */ 1138 if (mp_nce != mp) 1139 freeb(mp_nce); 1140 mutex_exit(&nce->nce_lock); 1141 ndp_delete(nce); 1142 NCE_REFRELE(nce); 1143 return (EBUSY); 1144 } 1145 mutex_exit(&nce->nce_lock); 1146 NDP_RESTART_TIMER(nce, (clock_t)ms); 1147 NCE_REFRELE(nce); 1148 return (EINPROGRESS); 1149 case EEXIST: 1150 /* Resolution in progress just queue the packet */ 1151 mutex_enter(&nce->nce_lock); 1152 if (nce->nce_state == ND_INCOMPLETE) { 1153 mp_nce = ip_prepend_zoneid(mp, zoneid, ipst); 1154 if (mp_nce == NULL) { 1155 err = ENOMEM; 1156 } else { 1157 nce_queue_mp(nce, mp_nce); 1158 err = EINPROGRESS; 1159 } 1160 } else { 1161 /* 1162 * Any other state implies we have 1163 * a nce but IRE needs to be added ... 1164 * ire_add_v6() will take care of the 1165 * the case when the nce becomes CONDEMNED 1166 * before the ire is added to the table. 1167 */ 1168 err = 0; 1169 } 1170 mutex_exit(&nce->nce_lock); 1171 NCE_REFRELE(nce); 1172 break; 1173 default: 1174 ip1dbg(("ndp_resolver: Can't create NCE %d\n", err)); 1175 break; 1176 } 1177 return (err); 1178 } 1179 1180 /* 1181 * When there is no resolver, the link layer template is passed in 1182 * the IRE. 1183 * Lookup a NCE for a given IRE. Regardless of whether one exists 1184 * or one is created, we defer making ire point to nce until the 1185 * ire is actually added at which point the nce_refcnt on the nce is 1186 * incremented. This is done primarily to have symmetry between ire_add() 1187 * and ire_delete() which decrements the nce_refcnt, when an ire is deleted. 1188 */ 1189 int 1190 ndp_noresolver(ill_t *ill, const in6_addr_t *dst) 1191 { 1192 nce_t *nce; 1193 int err = 0; 1194 1195 ASSERT(ill != NULL); 1196 ASSERT(ill->ill_isv6); 1197 if (IN6_IS_ADDR_MULTICAST(dst)) { 1198 err = nce_set_multicast(ill, dst); 1199 return (err); 1200 } 1201 1202 err = ndp_lookup_then_add(ill, 1203 NULL, /* hardware address */ 1204 dst, 1205 &ipv6_all_ones, 1206 &ipv6_all_zeros, 1207 0, 1208 (ill->ill_flags & ILLF_NONUD) ? NCE_F_NONUD : 0, 1209 ND_REACHABLE, 1210 &nce, 1211 NULL, /* let ndp_add figure out fp_mp/dlureq_mp for v6 */ 1212 NULL); 1213 1214 switch (err) { 1215 case 0: 1216 /* 1217 * Cache entry with a proper resolver cookie was 1218 * created. 1219 */ 1220 NCE_REFRELE(nce); 1221 break; 1222 case EEXIST: 1223 err = 0; 1224 NCE_REFRELE(nce); 1225 break; 1226 default: 1227 ip1dbg(("ndp_noresolver: Can't create NCE %d\n", err)); 1228 break; 1229 } 1230 return (err); 1231 } 1232 1233 /* 1234 * For each interface an entry is added for the unspecified multicast group. 1235 * Here that mapping is used to form the multicast cache entry for a particular 1236 * multicast destination. 1237 */ 1238 static int 1239 nce_set_multicast(ill_t *ill, const in6_addr_t *dst) 1240 { 1241 nce_t *mnce; /* Multicast mapping entry */ 1242 nce_t *nce; 1243 uchar_t *hw_addr = NULL; 1244 int err = 0; 1245 ip_stack_t *ipst = ill->ill_ipst; 1246 1247 ASSERT(ill != NULL); 1248 ASSERT(ill->ill_isv6); 1249 ASSERT(!(IN6_IS_ADDR_UNSPECIFIED(dst))); 1250 1251 mutex_enter(&ipst->ips_ndp6->ndp_g_lock); 1252 nce = *((nce_t **)NCE_HASH_PTR_V6(ipst, *dst)); 1253 nce = nce_lookup_addr(ill, dst, nce); 1254 if (nce != NULL) { 1255 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 1256 NCE_REFRELE(nce); 1257 return (0); 1258 } 1259 /* No entry, now lookup for a mapping this should never fail */ 1260 mnce = nce_lookup_mapping(ill, dst); 1261 if (mnce == NULL) { 1262 /* Something broken for the interface. */ 1263 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 1264 return (ESRCH); 1265 } 1266 ASSERT(mnce->nce_flags & NCE_F_MAPPING); 1267 if (ill->ill_net_type == IRE_IF_RESOLVER) { 1268 /* 1269 * For IRE_IF_RESOLVER a hardware mapping can be 1270 * generated, for IRE_IF_NORESOLVER, resolution cookie 1271 * in the ill is copied in ndp_add(). 1272 */ 1273 hw_addr = kmem_alloc(ill->ill_nd_lla_len, KM_NOSLEEP); 1274 if (hw_addr == NULL) { 1275 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 1276 NCE_REFRELE(mnce); 1277 return (ENOMEM); 1278 } 1279 nce_make_mapping(mnce, hw_addr, (uchar_t *)dst); 1280 } 1281 NCE_REFRELE(mnce); 1282 /* 1283 * IRE_IF_NORESOLVER type simply copies the resolution 1284 * cookie passed in. So no hw_addr is needed. 1285 */ 1286 err = ndp_add(ill, 1287 hw_addr, 1288 dst, 1289 &ipv6_all_ones, 1290 &ipv6_all_zeros, 1291 0, 1292 NCE_F_NONUD, 1293 ND_REACHABLE, 1294 &nce, 1295 NULL, 1296 NULL); 1297 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 1298 if (hw_addr != NULL) 1299 kmem_free(hw_addr, ill->ill_nd_lla_len); 1300 if (err != 0) { 1301 ip1dbg(("nce_set_multicast: create failed" "%d\n", err)); 1302 return (err); 1303 } 1304 NCE_REFRELE(nce); 1305 return (0); 1306 } 1307 1308 /* 1309 * Return the link layer address, and any flags of a nce. 1310 */ 1311 int 1312 ndp_query(ill_t *ill, struct lif_nd_req *lnr) 1313 { 1314 nce_t *nce; 1315 in6_addr_t *addr; 1316 sin6_t *sin6; 1317 dl_unitdata_req_t *dl; 1318 1319 ASSERT(ill != NULL && ill->ill_isv6); 1320 sin6 = (sin6_t *)&lnr->lnr_addr; 1321 addr = &sin6->sin6_addr; 1322 1323 nce = ndp_lookup_v6(ill, addr, B_FALSE); 1324 if (nce == NULL) 1325 return (ESRCH); 1326 /* If in INCOMPLETE state, no link layer address is available yet */ 1327 if (nce->nce_state == ND_INCOMPLETE) 1328 goto done; 1329 dl = (dl_unitdata_req_t *)nce->nce_res_mp->b_rptr; 1330 if (ill->ill_flags & ILLF_XRESOLV) 1331 lnr->lnr_hdw_len = dl->dl_dest_addr_length; 1332 else 1333 lnr->lnr_hdw_len = ill->ill_nd_lla_len; 1334 ASSERT(NCE_LL_ADDR_OFFSET(ill) + lnr->lnr_hdw_len <= 1335 sizeof (lnr->lnr_hdw_addr)); 1336 bcopy(nce->nce_res_mp->b_rptr + NCE_LL_ADDR_OFFSET(ill), 1337 (uchar_t *)&lnr->lnr_hdw_addr, lnr->lnr_hdw_len); 1338 if (nce->nce_flags & NCE_F_ISROUTER) 1339 lnr->lnr_flags = NDF_ISROUTER_ON; 1340 if (nce->nce_flags & NCE_F_PROXY) 1341 lnr->lnr_flags |= NDF_PROXY_ON; 1342 if (nce->nce_flags & NCE_F_ANYCAST) 1343 lnr->lnr_flags |= NDF_ANYCAST_ON; 1344 done: 1345 NCE_REFRELE(nce); 1346 return (0); 1347 } 1348 1349 /* 1350 * Send Enable/Disable multicast reqs to driver. 1351 */ 1352 int 1353 ndp_mcastreq(ill_t *ill, const in6_addr_t *addr, uint32_t hw_addr_len, 1354 uint32_t hw_addr_offset, mblk_t *mp) 1355 { 1356 nce_t *nce; 1357 uchar_t *hw_addr; 1358 ip_stack_t *ipst = ill->ill_ipst; 1359 1360 ASSERT(ill != NULL && ill->ill_isv6); 1361 ASSERT(ill->ill_net_type == IRE_IF_RESOLVER); 1362 hw_addr = mi_offset_paramc(mp, hw_addr_offset, hw_addr_len); 1363 if (hw_addr == NULL || !IN6_IS_ADDR_MULTICAST(addr)) { 1364 freemsg(mp); 1365 return (EINVAL); 1366 } 1367 mutex_enter(&ipst->ips_ndp6->ndp_g_lock); 1368 nce = nce_lookup_mapping(ill, addr); 1369 if (nce == NULL) { 1370 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 1371 freemsg(mp); 1372 return (ESRCH); 1373 } 1374 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 1375 /* 1376 * Update dl_addr_length and dl_addr_offset for primitives that 1377 * have physical addresses as opposed to full saps 1378 */ 1379 switch (((union DL_primitives *)mp->b_rptr)->dl_primitive) { 1380 case DL_ENABMULTI_REQ: 1381 /* Track the state if this is the first enabmulti */ 1382 if (ill->ill_dlpi_multicast_state == IDS_UNKNOWN) 1383 ill->ill_dlpi_multicast_state = IDS_INPROGRESS; 1384 ip1dbg(("ndp_mcastreq: ENABMULTI\n")); 1385 break; 1386 case DL_DISABMULTI_REQ: 1387 ip1dbg(("ndp_mcastreq: DISABMULTI\n")); 1388 break; 1389 default: 1390 NCE_REFRELE(nce); 1391 ip1dbg(("ndp_mcastreq: default\n")); 1392 return (EINVAL); 1393 } 1394 nce_make_mapping(nce, hw_addr, (uchar_t *)addr); 1395 NCE_REFRELE(nce); 1396 ill_dlpi_send(ill, mp); 1397 return (0); 1398 } 1399 1400 /* 1401 * Send a neighbor solicitation. 1402 * Returns number of milliseconds after which we should either rexmit or abort. 1403 * Return of zero means we should abort. 1404 * The caller holds the nce_lock to protect nce_qd_mp and nce_rcnt. 1405 * 1406 * NOTE: This routine drops nce_lock (and later reacquires it) when sending 1407 * the packet. 1408 * NOTE: This routine does not consume mp. 1409 */ 1410 uint32_t 1411 nce_solicit(nce_t *nce, mblk_t *mp) 1412 { 1413 ill_t *ill; 1414 ill_t *src_ill; 1415 ip6_t *ip6h; 1416 in6_addr_t src; 1417 in6_addr_t dst; 1418 ipif_t *ipif; 1419 ip6i_t *ip6i; 1420 boolean_t dropped = B_FALSE; 1421 ip_stack_t *ipst = nce->nce_ill->ill_ipst; 1422 1423 ASSERT(RW_READ_HELD(&ipst->ips_ill_g_lock)); 1424 ASSERT(MUTEX_HELD(&nce->nce_lock)); 1425 ill = nce->nce_ill; 1426 ASSERT(ill != NULL); 1427 1428 if (nce->nce_rcnt == 0) { 1429 return (0); 1430 } 1431 1432 if (mp == NULL) { 1433 ASSERT(nce->nce_qd_mp != NULL); 1434 mp = nce->nce_qd_mp; 1435 } else { 1436 nce_queue_mp(nce, mp); 1437 } 1438 1439 /* Handle ip_newroute_v6 giving us IPSEC packets */ 1440 if (mp->b_datap->db_type == M_CTL) 1441 mp = mp->b_cont; 1442 1443 ip6h = (ip6_t *)mp->b_rptr; 1444 if (ip6h->ip6_nxt == IPPROTO_RAW) { 1445 /* 1446 * This message should have been pulled up already in 1447 * ip_wput_v6. We can't do pullups here because the message 1448 * could be from the nce_qd_mp which could have b_next/b_prev 1449 * non-NULL. 1450 */ 1451 ip6i = (ip6i_t *)ip6h; 1452 ASSERT((mp->b_wptr - (uchar_t *)ip6i) >= 1453 sizeof (ip6i_t) + IPV6_HDR_LEN); 1454 ip6h = (ip6_t *)(mp->b_rptr + sizeof (ip6i_t)); 1455 } 1456 src = ip6h->ip6_src; 1457 /* 1458 * If the src of outgoing packet is one of the assigned interface 1459 * addresses use it, otherwise we will pick the source address below. 1460 */ 1461 src_ill = ill; 1462 if (!IN6_IS_ADDR_UNSPECIFIED(&src)) { 1463 if (ill->ill_group != NULL) 1464 src_ill = ill->ill_group->illgrp_ill; 1465 for (; src_ill != NULL; src_ill = src_ill->ill_group_next) { 1466 for (ipif = src_ill->ill_ipif; ipif != NULL; 1467 ipif = ipif->ipif_next) { 1468 if (IN6_ARE_ADDR_EQUAL(&src, 1469 &ipif->ipif_v6lcl_addr)) { 1470 break; 1471 } 1472 } 1473 if (ipif != NULL) 1474 break; 1475 } 1476 /* 1477 * If no relevant ipif can be found, then it's not one of our 1478 * addresses. Reset to :: and let nce_xmit. If an ipif can be 1479 * found, but it's not yet done with DAD verification, then 1480 * just postpone this transmission until later. 1481 */ 1482 if (src_ill == NULL) 1483 src = ipv6_all_zeros; 1484 else if (!ipif->ipif_addr_ready) 1485 return (ill->ill_reachable_retrans_time); 1486 } 1487 dst = nce->nce_addr; 1488 /* 1489 * If source address is unspecified, nce_xmit will choose 1490 * one for us and initialize the hardware address also 1491 * appropriately. 1492 */ 1493 if (IN6_IS_ADDR_UNSPECIFIED(&src)) 1494 src_ill = NULL; 1495 nce->nce_rcnt--; 1496 mutex_exit(&nce->nce_lock); 1497 rw_exit(&ipst->ips_ill_g_lock); 1498 dropped = nce_xmit(ill, ND_NEIGHBOR_SOLICIT, src_ill, B_TRUE, &src, 1499 &dst, 0); 1500 rw_enter(&ipst->ips_ill_g_lock, RW_READER); 1501 mutex_enter(&nce->nce_lock); 1502 if (dropped) 1503 nce->nce_rcnt++; 1504 return (ill->ill_reachable_retrans_time); 1505 } 1506 1507 /* 1508 * Attempt to recover an address on an interface that's been marked as a 1509 * duplicate. Because NCEs are destroyed when the interface goes down, there's 1510 * no easy way to just probe the address and have the right thing happen if 1511 * it's no longer in use. Instead, we just bring it up normally and allow the 1512 * regular interface start-up logic to probe for a remaining duplicate and take 1513 * us back down if necessary. 1514 * Neither DHCP nor temporary addresses arrive here; they're excluded by 1515 * ip_ndp_excl. 1516 */ 1517 /* ARGSUSED */ 1518 static void 1519 ip_ndp_recover(ipsq_t *ipsq, queue_t *rq, mblk_t *mp, void *dummy_arg) 1520 { 1521 ill_t *ill = rq->q_ptr; 1522 ipif_t *ipif; 1523 in6_addr_t *addr = (in6_addr_t *)mp->b_rptr; 1524 1525 for (ipif = ill->ill_ipif; ipif != NULL; ipif = ipif->ipif_next) { 1526 /* 1527 * We do not support recovery of proxy ARP'd interfaces, 1528 * because the system lacks a complete proxy ARP mechanism. 1529 */ 1530 if ((ipif->ipif_flags & IPIF_POINTOPOINT) || 1531 !IN6_ARE_ADDR_EQUAL(&ipif->ipif_v6lcl_addr, addr)) { 1532 continue; 1533 } 1534 1535 /* 1536 * If we have already recovered or if the interface is going 1537 * away, then ignore. 1538 */ 1539 mutex_enter(&ill->ill_lock); 1540 if (!(ipif->ipif_flags & IPIF_DUPLICATE) || 1541 (ipif->ipif_flags & (IPIF_MOVING | IPIF_CONDEMNED))) { 1542 mutex_exit(&ill->ill_lock); 1543 continue; 1544 } 1545 1546 ipif->ipif_flags &= ~IPIF_DUPLICATE; 1547 ill->ill_ipif_dup_count--; 1548 mutex_exit(&ill->ill_lock); 1549 ipif->ipif_was_dup = B_TRUE; 1550 1551 if (ipif_ndp_up(ipif, addr) != EINPROGRESS) 1552 (void) ipif_up_done_v6(ipif); 1553 } 1554 freeb(mp); 1555 } 1556 1557 /* 1558 * Attempt to recover an IPv6 interface that's been shut down as a duplicate. 1559 * As long as someone else holds the address, the interface will stay down. 1560 * When that conflict goes away, the interface is brought back up. This is 1561 * done so that accidental shutdowns of addresses aren't made permanent. Your 1562 * server will recover from a failure. 1563 * 1564 * For DHCP and temporary addresses, recovery is not done in the kernel. 1565 * Instead, it's handled by user space processes (dhcpagent and in.ndpd). 1566 * 1567 * This function is entered on a timer expiry; the ID is in ipif_recovery_id. 1568 */ 1569 static void 1570 ipif6_dup_recovery(void *arg) 1571 { 1572 ipif_t *ipif = arg; 1573 1574 ipif->ipif_recovery_id = 0; 1575 if (!(ipif->ipif_flags & IPIF_DUPLICATE)) 1576 return; 1577 1578 /* 1579 * No lock, because this is just an optimization. 1580 */ 1581 if (ipif->ipif_state_flags & (IPIF_MOVING | IPIF_CONDEMNED)) 1582 return; 1583 1584 /* If the link is down, we'll retry this later */ 1585 if (!(ipif->ipif_ill->ill_phyint->phyint_flags & PHYI_RUNNING)) 1586 return; 1587 1588 ndp_do_recovery(ipif); 1589 } 1590 1591 /* 1592 * Perform interface recovery by forcing the duplicate interfaces up and 1593 * allowing the system to determine which ones should stay up. 1594 * 1595 * Called both by recovery timer expiry and link-up notification. 1596 */ 1597 void 1598 ndp_do_recovery(ipif_t *ipif) 1599 { 1600 ill_t *ill = ipif->ipif_ill; 1601 mblk_t *mp; 1602 ip_stack_t *ipst = ill->ill_ipst; 1603 1604 mp = allocb(sizeof (ipif->ipif_v6lcl_addr), BPRI_MED); 1605 if (mp == NULL) { 1606 mutex_enter(&ill->ill_lock); 1607 if (ipif->ipif_recovery_id == 0 && 1608 !(ipif->ipif_state_flags & (IPIF_MOVING | 1609 IPIF_CONDEMNED))) { 1610 ipif->ipif_recovery_id = timeout(ipif6_dup_recovery, 1611 ipif, MSEC_TO_TICK(ipst->ips_ip_dup_recovery)); 1612 } 1613 mutex_exit(&ill->ill_lock); 1614 } else { 1615 bcopy(&ipif->ipif_v6lcl_addr, mp->b_rptr, 1616 sizeof (ipif->ipif_v6lcl_addr)); 1617 ill_refhold(ill); 1618 qwriter_ip(ill, ill->ill_rq, mp, ip_ndp_recover, NEW_OP, 1619 B_FALSE); 1620 } 1621 } 1622 1623 /* 1624 * Find the solicitation in the given message, and extract printable details 1625 * (MAC and IP addresses) from it. 1626 */ 1627 static nd_neighbor_solicit_t * 1628 ip_ndp_find_solicitation(mblk_t *mp, mblk_t *dl_mp, ill_t *ill, char *hbuf, 1629 size_t hlen, char *sbuf, size_t slen, uchar_t **haddr) 1630 { 1631 nd_neighbor_solicit_t *ns; 1632 ip6_t *ip6h; 1633 uchar_t *addr; 1634 int alen; 1635 1636 alen = 0; 1637 ip6h = (ip6_t *)mp->b_rptr; 1638 if (dl_mp == NULL) { 1639 nd_opt_hdr_t *opt; 1640 int nslen; 1641 1642 /* 1643 * If it's from the fast-path, then it can't be a probe 1644 * message, and thus must include the source linkaddr option. 1645 * Extract that here. 1646 */ 1647 ns = (nd_neighbor_solicit_t *)((char *)ip6h + IPV6_HDR_LEN); 1648 nslen = mp->b_wptr - (uchar_t *)ns; 1649 if ((nslen -= sizeof (*ns)) > 0) { 1650 opt = ndp_get_option((nd_opt_hdr_t *)(ns + 1), nslen, 1651 ND_OPT_SOURCE_LINKADDR); 1652 if (opt != NULL && 1653 opt->nd_opt_len * 8 - sizeof (*opt) >= 1654 ill->ill_nd_lla_len) { 1655 addr = (uchar_t *)(opt + 1); 1656 alen = ill->ill_nd_lla_len; 1657 } 1658 } 1659 /* 1660 * We cheat a bit here for the sake of printing usable log 1661 * messages in the rare case where the reply we got was unicast 1662 * without a source linkaddr option, and the interface is in 1663 * fastpath mode. (Sigh.) 1664 */ 1665 if (alen == 0 && ill->ill_type == IFT_ETHER && 1666 MBLKHEAD(mp) >= sizeof (struct ether_header)) { 1667 struct ether_header *pether; 1668 1669 pether = (struct ether_header *)((char *)ip6h - 1670 sizeof (*pether)); 1671 addr = pether->ether_shost.ether_addr_octet; 1672 alen = ETHERADDRL; 1673 } 1674 } else { 1675 dl_unitdata_ind_t *dlu; 1676 1677 dlu = (dl_unitdata_ind_t *)dl_mp->b_rptr; 1678 alen = dlu->dl_src_addr_length; 1679 if (alen > 0 && dlu->dl_src_addr_offset >= sizeof (*dlu) && 1680 dlu->dl_src_addr_offset + alen <= MBLKL(dl_mp)) { 1681 addr = dl_mp->b_rptr + dlu->dl_src_addr_offset; 1682 if (ill->ill_sap_length < 0) { 1683 alen += ill->ill_sap_length; 1684 } else { 1685 addr += ill->ill_sap_length; 1686 alen -= ill->ill_sap_length; 1687 } 1688 } 1689 } 1690 if (alen > 0) { 1691 *haddr = addr; 1692 (void) mac_colon_addr(addr, alen, hbuf, hlen); 1693 } else { 1694 *haddr = NULL; 1695 (void) strcpy(hbuf, "?"); 1696 } 1697 ns = (nd_neighbor_solicit_t *)((char *)ip6h + IPV6_HDR_LEN); 1698 (void) inet_ntop(AF_INET6, &ns->nd_ns_target, sbuf, slen); 1699 return (ns); 1700 } 1701 1702 /* 1703 * This is for exclusive changes due to NDP duplicate address detection 1704 * failure. 1705 */ 1706 /* ARGSUSED */ 1707 static void 1708 ip_ndp_excl(ipsq_t *ipsq, queue_t *rq, mblk_t *mp, void *dummy_arg) 1709 { 1710 ill_t *ill = rq->q_ptr; 1711 ipif_t *ipif; 1712 char ibuf[LIFNAMSIZ + 10]; /* 10 digits for logical i/f number */ 1713 char hbuf[MAC_STR_LEN]; 1714 char sbuf[INET6_ADDRSTRLEN]; 1715 nd_neighbor_solicit_t *ns; 1716 mblk_t *dl_mp = NULL; 1717 uchar_t *haddr; 1718 ip_stack_t *ipst = ill->ill_ipst; 1719 1720 if (DB_TYPE(mp) != M_DATA) { 1721 dl_mp = mp; 1722 mp = mp->b_cont; 1723 } 1724 ns = ip_ndp_find_solicitation(mp, dl_mp, ill, hbuf, sizeof (hbuf), sbuf, 1725 sizeof (sbuf), &haddr); 1726 if (haddr != NULL && 1727 bcmp(haddr, ill->ill_phys_addr, ill->ill_phys_addr_length) == 0) { 1728 /* 1729 * Ignore conflicts generated by misbehaving switches that just 1730 * reflect our own messages back to us. 1731 */ 1732 goto ignore_conflict; 1733 } 1734 (void) strlcpy(ibuf, ill->ill_name, sizeof (ibuf)); 1735 for (ipif = ill->ill_ipif; ipif != NULL; ipif = ipif->ipif_next) { 1736 1737 if ((ipif->ipif_flags & IPIF_POINTOPOINT) || 1738 !IN6_ARE_ADDR_EQUAL(&ipif->ipif_v6lcl_addr, 1739 &ns->nd_ns_target)) { 1740 continue; 1741 } 1742 1743 /* If it's already marked, then don't do anything. */ 1744 if (ipif->ipif_flags & IPIF_DUPLICATE) 1745 continue; 1746 1747 /* 1748 * If this is a failure during duplicate recovery, then don't 1749 * complain. It may take a long time to recover. 1750 */ 1751 if (!ipif->ipif_was_dup) { 1752 if (ipif->ipif_id != 0) { 1753 (void) snprintf(ibuf + ill->ill_name_length - 1, 1754 sizeof (ibuf) - ill->ill_name_length + 1, 1755 ":%d", ipif->ipif_id); 1756 } 1757 cmn_err(CE_WARN, "%s has duplicate address %s (in " 1758 "use by %s); disabled", ibuf, sbuf, hbuf); 1759 } 1760 mutex_enter(&ill->ill_lock); 1761 ASSERT(!(ipif->ipif_flags & IPIF_DUPLICATE)); 1762 ipif->ipif_flags |= IPIF_DUPLICATE; 1763 ill->ill_ipif_dup_count++; 1764 mutex_exit(&ill->ill_lock); 1765 (void) ipif_down(ipif, NULL, NULL); 1766 ipif_down_tail(ipif); 1767 mutex_enter(&ill->ill_lock); 1768 if (!(ipif->ipif_flags & (IPIF_DHCPRUNNING|IPIF_TEMPORARY)) && 1769 ill->ill_net_type == IRE_IF_RESOLVER && 1770 !(ipif->ipif_state_flags & (IPIF_MOVING | 1771 IPIF_CONDEMNED)) && 1772 ipst->ips_ip_dup_recovery > 0) { 1773 ipif->ipif_recovery_id = timeout(ipif6_dup_recovery, 1774 ipif, MSEC_TO_TICK(ipst->ips_ip_dup_recovery)); 1775 } 1776 mutex_exit(&ill->ill_lock); 1777 } 1778 ignore_conflict: 1779 if (dl_mp != NULL) 1780 freeb(dl_mp); 1781 freemsg(mp); 1782 } 1783 1784 /* 1785 * Handle failure by tearing down the ipifs with the specified address. Note 1786 * that tearing down the ipif also means deleting the nce through ipif_down, so 1787 * it's not possible to do recovery by just restarting the nce timer. Instead, 1788 * we start a timer on the ipif. 1789 */ 1790 static void 1791 ip_ndp_failure(ill_t *ill, mblk_t *mp, mblk_t *dl_mp, nce_t *nce) 1792 { 1793 if ((mp = copymsg(mp)) != NULL) { 1794 if (dl_mp == NULL) 1795 dl_mp = mp; 1796 else if ((dl_mp = copyb(dl_mp)) != NULL) 1797 dl_mp->b_cont = mp; 1798 if (dl_mp == NULL) { 1799 freemsg(mp); 1800 } else { 1801 ill_refhold(ill); 1802 qwriter_ip(ill, ill->ill_rq, dl_mp, ip_ndp_excl, NEW_OP, 1803 B_FALSE); 1804 } 1805 } 1806 ndp_delete(nce); 1807 } 1808 1809 /* 1810 * Handle a discovered conflict: some other system is advertising that it owns 1811 * one of our IP addresses. We need to defend ourselves, or just shut down the 1812 * interface. 1813 */ 1814 static void 1815 ip_ndp_conflict(ill_t *ill, mblk_t *mp, mblk_t *dl_mp, nce_t *nce) 1816 { 1817 ipif_t *ipif; 1818 uint32_t now; 1819 uint_t maxdefense; 1820 uint_t defs; 1821 ip_stack_t *ipst = ill->ill_ipst; 1822 1823 ipif = ipif_lookup_addr_v6(&nce->nce_addr, ill, ALL_ZONES, NULL, NULL, 1824 NULL, NULL, ipst); 1825 if (ipif == NULL) 1826 return; 1827 /* 1828 * First, figure out if this address is disposable. 1829 */ 1830 if (ipif->ipif_flags & (IPIF_DHCPRUNNING | IPIF_TEMPORARY)) 1831 maxdefense = ipst->ips_ip_max_temp_defend; 1832 else 1833 maxdefense = ipst->ips_ip_max_defend; 1834 1835 /* 1836 * Now figure out how many times we've defended ourselves. Ignore 1837 * defenses that happened long in the past. 1838 */ 1839 now = gethrestime_sec(); 1840 mutex_enter(&nce->nce_lock); 1841 if ((defs = nce->nce_defense_count) > 0 && 1842 now - nce->nce_defense_time > ipst->ips_ip_defend_interval) { 1843 nce->nce_defense_count = defs = 0; 1844 } 1845 nce->nce_defense_count++; 1846 nce->nce_defense_time = now; 1847 mutex_exit(&nce->nce_lock); 1848 ipif_refrele(ipif); 1849 1850 /* 1851 * If we've defended ourselves too many times already, then give up and 1852 * tear down the interface(s) using this address. Otherwise, defend by 1853 * sending out an unsolicited Neighbor Advertisement. 1854 */ 1855 if (defs >= maxdefense) { 1856 ip_ndp_failure(ill, mp, dl_mp, nce); 1857 } else { 1858 char hbuf[MAC_STR_LEN]; 1859 char sbuf[INET6_ADDRSTRLEN]; 1860 uchar_t *haddr; 1861 1862 (void) ip_ndp_find_solicitation(mp, dl_mp, ill, hbuf, 1863 sizeof (hbuf), sbuf, sizeof (sbuf), &haddr); 1864 cmn_err(CE_WARN, "node %s is using our IP address %s on %s", 1865 hbuf, sbuf, ill->ill_name); 1866 (void) nce_xmit(ill, ND_NEIGHBOR_ADVERT, ill, B_FALSE, 1867 &nce->nce_addr, &ipv6_all_hosts_mcast, 1868 nce_advert_flags(nce)); 1869 } 1870 } 1871 1872 static void 1873 ndp_input_solicit(ill_t *ill, mblk_t *mp, mblk_t *dl_mp) 1874 { 1875 nd_neighbor_solicit_t *ns; 1876 uint32_t hlen = ill->ill_nd_lla_len; 1877 uchar_t *haddr = NULL; 1878 icmp6_t *icmp_nd; 1879 ip6_t *ip6h; 1880 nce_t *our_nce = NULL; 1881 in6_addr_t target; 1882 in6_addr_t src; 1883 int len; 1884 int flag = 0; 1885 nd_opt_hdr_t *opt = NULL; 1886 boolean_t bad_solicit = B_FALSE; 1887 mib2_ipv6IfIcmpEntry_t *mib = ill->ill_icmp6_mib; 1888 1889 ip6h = (ip6_t *)mp->b_rptr; 1890 icmp_nd = (icmp6_t *)(mp->b_rptr + IPV6_HDR_LEN); 1891 len = mp->b_wptr - mp->b_rptr - IPV6_HDR_LEN; 1892 src = ip6h->ip6_src; 1893 ns = (nd_neighbor_solicit_t *)icmp_nd; 1894 target = ns->nd_ns_target; 1895 if (IN6_IS_ADDR_MULTICAST(&target)) { 1896 if (ip_debug > 2) { 1897 /* ip1dbg */ 1898 pr_addr_dbg("ndp_input_solicit: Target is" 1899 " multicast! %s\n", AF_INET6, &target); 1900 } 1901 bad_solicit = B_TRUE; 1902 goto done; 1903 } 1904 if (len > sizeof (nd_neighbor_solicit_t)) { 1905 /* Options present */ 1906 opt = (nd_opt_hdr_t *)&ns[1]; 1907 len -= sizeof (nd_neighbor_solicit_t); 1908 if (!ndp_verify_optlen(opt, len)) { 1909 ip1dbg(("ndp_input_solicit: Bad opt len\n")); 1910 bad_solicit = B_TRUE; 1911 goto done; 1912 } 1913 } 1914 if (IN6_IS_ADDR_UNSPECIFIED(&src)) { 1915 /* Check to see if this is a valid DAD solicitation */ 1916 if (!IN6_IS_ADDR_MC_SOLICITEDNODE(&ip6h->ip6_dst)) { 1917 if (ip_debug > 2) { 1918 /* ip1dbg */ 1919 pr_addr_dbg("ndp_input_solicit: IPv6 " 1920 "Destination is not solicited node " 1921 "multicast %s\n", AF_INET6, 1922 &ip6h->ip6_dst); 1923 } 1924 bad_solicit = B_TRUE; 1925 goto done; 1926 } 1927 } 1928 1929 our_nce = ndp_lookup_v6(ill, &target, B_FALSE); 1930 /* 1931 * If this is a valid Solicitation, a permanent 1932 * entry should exist in the cache 1933 */ 1934 if (our_nce == NULL || 1935 !(our_nce->nce_flags & NCE_F_PERMANENT)) { 1936 ip1dbg(("ndp_input_solicit: Wrong target in NS?!" 1937 "ifname=%s ", ill->ill_name)); 1938 if (ip_debug > 2) { 1939 /* ip1dbg */ 1940 pr_addr_dbg(" dst %s\n", AF_INET6, &target); 1941 } 1942 bad_solicit = B_TRUE; 1943 goto done; 1944 } 1945 1946 /* At this point we should have a verified NS per spec */ 1947 if (opt != NULL) { 1948 opt = ndp_get_option(opt, len, ND_OPT_SOURCE_LINKADDR); 1949 if (opt != NULL) { 1950 haddr = (uchar_t *)&opt[1]; 1951 if (hlen > opt->nd_opt_len * 8 - sizeof (*opt) || 1952 hlen == 0) { 1953 ip1dbg(("ndp_input_advert: bad SLLA\n")); 1954 bad_solicit = B_TRUE; 1955 goto done; 1956 } 1957 } 1958 } 1959 1960 /* If sending directly to peer, set the unicast flag */ 1961 if (!IN6_IS_ADDR_MULTICAST(&ip6h->ip6_dst)) 1962 flag |= NDP_UNICAST; 1963 1964 /* 1965 * Create/update the entry for the soliciting node. 1966 * or respond to outstanding queries, don't if 1967 * the source is unspecified address. 1968 */ 1969 if (!IN6_IS_ADDR_UNSPECIFIED(&src)) { 1970 int err; 1971 nce_t *nnce; 1972 1973 ASSERT(ill->ill_isv6); 1974 /* 1975 * Regular solicitations *must* include the Source Link-Layer 1976 * Address option. Ignore messages that do not. 1977 */ 1978 if (haddr == NULL && IN6_IS_ADDR_MULTICAST(&ip6h->ip6_dst)) { 1979 ip1dbg(("ndp_input_solicit: source link-layer address " 1980 "option missing with a specified source.\n")); 1981 bad_solicit = B_TRUE; 1982 goto done; 1983 } 1984 1985 /* 1986 * This is a regular solicitation. If we're still in the 1987 * process of verifying the address, then don't respond at all 1988 * and don't keep track of the sender. 1989 */ 1990 if (our_nce->nce_state == ND_PROBE) 1991 goto done; 1992 1993 /* 1994 * If the solicitation doesn't have sender hardware address 1995 * (legal for unicast solicitation), then process without 1996 * installing the return NCE. Either we already know it, or 1997 * we'll be forced to look it up when (and if) we reply to the 1998 * packet. 1999 */ 2000 if (haddr == NULL) 2001 goto no_source; 2002 2003 err = ndp_lookup_then_add(ill, 2004 haddr, 2005 &src, /* Soliciting nodes address */ 2006 &ipv6_all_ones, 2007 &ipv6_all_zeros, 2008 0, 2009 0, 2010 ND_STALE, 2011 &nnce, 2012 NULL, 2013 NULL); 2014 switch (err) { 2015 case 0: 2016 /* done with this entry */ 2017 NCE_REFRELE(nnce); 2018 break; 2019 case EEXIST: 2020 /* 2021 * B_FALSE indicates this is not an 2022 * an advertisement. 2023 */ 2024 ndp_process(nnce, haddr, 0, B_FALSE); 2025 NCE_REFRELE(nnce); 2026 break; 2027 default: 2028 ip1dbg(("ndp_input_solicit: Can't create NCE %d\n", 2029 err)); 2030 goto done; 2031 } 2032 no_source: 2033 flag |= NDP_SOLICITED; 2034 } else { 2035 /* 2036 * No source link layer address option should be present in a 2037 * valid DAD request. 2038 */ 2039 if (haddr != NULL) { 2040 ip1dbg(("ndp_input_solicit: source link-layer address " 2041 "option present with an unspecified source.\n")); 2042 bad_solicit = B_TRUE; 2043 goto done; 2044 } 2045 if (our_nce->nce_state == ND_PROBE) { 2046 /* 2047 * Internally looped-back probes won't have DLPI 2048 * attached to them. External ones (which are sent by 2049 * multicast) always will. Just ignore our own 2050 * transmissions. 2051 */ 2052 if (dl_mp != NULL) { 2053 /* 2054 * If someone else is probing our address, then 2055 * we've crossed wires. Declare failure. 2056 */ 2057 ip_ndp_failure(ill, mp, dl_mp, our_nce); 2058 } 2059 goto done; 2060 } 2061 /* 2062 * This is a DAD probe. Multicast the advertisement to the 2063 * all-nodes address. 2064 */ 2065 src = ipv6_all_hosts_mcast; 2066 } 2067 flag |= nce_advert_flags(our_nce); 2068 /* Response to a solicitation */ 2069 (void) nce_xmit(ill, 2070 ND_NEIGHBOR_ADVERT, 2071 ill, /* ill to be used for extracting ill_nd_lla */ 2072 B_TRUE, /* use ill_nd_lla */ 2073 &target, /* Source and target of the advertisement pkt */ 2074 &src, /* IP Destination (source of original pkt) */ 2075 flag); 2076 done: 2077 if (bad_solicit) 2078 BUMP_MIB(mib, ipv6IfIcmpInBadNeighborSolicitations); 2079 if (our_nce != NULL) 2080 NCE_REFRELE(our_nce); 2081 } 2082 2083 void 2084 ndp_input_advert(ill_t *ill, mblk_t *mp, mblk_t *dl_mp) 2085 { 2086 nd_neighbor_advert_t *na; 2087 uint32_t hlen = ill->ill_nd_lla_len; 2088 uchar_t *haddr = NULL; 2089 icmp6_t *icmp_nd; 2090 ip6_t *ip6h; 2091 nce_t *dst_nce = NULL; 2092 in6_addr_t target; 2093 nd_opt_hdr_t *opt = NULL; 2094 int len; 2095 mib2_ipv6IfIcmpEntry_t *mib = ill->ill_icmp6_mib; 2096 ip_stack_t *ipst = ill->ill_ipst; 2097 2098 ip6h = (ip6_t *)mp->b_rptr; 2099 icmp_nd = (icmp6_t *)(mp->b_rptr + IPV6_HDR_LEN); 2100 len = mp->b_wptr - mp->b_rptr - IPV6_HDR_LEN; 2101 na = (nd_neighbor_advert_t *)icmp_nd; 2102 if (IN6_IS_ADDR_MULTICAST(&ip6h->ip6_dst) && 2103 (na->nd_na_flags_reserved & ND_NA_FLAG_SOLICITED)) { 2104 ip1dbg(("ndp_input_advert: Target is multicast but the " 2105 "solicited flag is not zero\n")); 2106 BUMP_MIB(mib, ipv6IfIcmpInBadNeighborAdvertisements); 2107 return; 2108 } 2109 target = na->nd_na_target; 2110 if (IN6_IS_ADDR_MULTICAST(&target)) { 2111 ip1dbg(("ndp_input_advert: Target is multicast!\n")); 2112 BUMP_MIB(mib, ipv6IfIcmpInBadNeighborAdvertisements); 2113 return; 2114 } 2115 if (len > sizeof (nd_neighbor_advert_t)) { 2116 opt = (nd_opt_hdr_t *)&na[1]; 2117 if (!ndp_verify_optlen(opt, 2118 len - sizeof (nd_neighbor_advert_t))) { 2119 ip1dbg(("ndp_input_advert: cannot verify SLLA\n")); 2120 BUMP_MIB(mib, ipv6IfIcmpInBadNeighborAdvertisements); 2121 return; 2122 } 2123 /* At this point we have a verified NA per spec */ 2124 len -= sizeof (nd_neighbor_advert_t); 2125 opt = ndp_get_option(opt, len, ND_OPT_TARGET_LINKADDR); 2126 if (opt != NULL) { 2127 haddr = (uchar_t *)&opt[1]; 2128 if (hlen > opt->nd_opt_len * 8 - sizeof (*opt) || 2129 hlen == 0) { 2130 ip1dbg(("ndp_input_advert: bad SLLA\n")); 2131 BUMP_MIB(mib, 2132 ipv6IfIcmpInBadNeighborAdvertisements); 2133 return; 2134 } 2135 } 2136 } 2137 2138 /* 2139 * If this interface is part of the group look at all the 2140 * ills in the group. 2141 */ 2142 rw_enter(&ipst->ips_ill_g_lock, RW_READER); 2143 if (ill->ill_group != NULL) 2144 ill = ill->ill_group->illgrp_ill; 2145 2146 for (; ill != NULL; ill = ill->ill_group_next) { 2147 mutex_enter(&ill->ill_lock); 2148 if (!ILL_CAN_LOOKUP(ill)) { 2149 mutex_exit(&ill->ill_lock); 2150 continue; 2151 } 2152 ill_refhold_locked(ill); 2153 mutex_exit(&ill->ill_lock); 2154 dst_nce = ndp_lookup_v6(ill, &target, B_FALSE); 2155 /* We have to drop the lock since ndp_process calls put* */ 2156 rw_exit(&ipst->ips_ill_g_lock); 2157 if (dst_nce != NULL) { 2158 if ((dst_nce->nce_flags & NCE_F_PERMANENT) && 2159 dst_nce->nce_state == ND_PROBE) { 2160 /* 2161 * Someone else sent an advertisement for an 2162 * address that we're trying to configure. 2163 * Tear it down. Note that dl_mp might be NULL 2164 * if we're getting a unicast reply. This 2165 * isn't typically done (multicast is the norm 2166 * in response to a probe), but ip_ndp_failure 2167 * will handle the dl_mp == NULL case as well. 2168 */ 2169 ip_ndp_failure(ill, mp, dl_mp, dst_nce); 2170 } else if (dst_nce->nce_flags & NCE_F_PERMANENT) { 2171 /* 2172 * Someone just announced one of our local 2173 * addresses. If it wasn't us, then this is a 2174 * conflict. Defend the address or shut it 2175 * down. 2176 */ 2177 if (dl_mp != NULL && 2178 (haddr == NULL || 2179 nce_cmp_ll_addr(dst_nce, haddr, 2180 ill->ill_nd_lla_len))) { 2181 ip_ndp_conflict(ill, mp, dl_mp, 2182 dst_nce); 2183 } 2184 } else { 2185 if (na->nd_na_flags_reserved & 2186 ND_NA_FLAG_ROUTER) { 2187 dst_nce->nce_flags |= NCE_F_ISROUTER; 2188 } 2189 /* B_TRUE indicates this an advertisement */ 2190 ndp_process(dst_nce, haddr, 2191 na->nd_na_flags_reserved, B_TRUE); 2192 } 2193 NCE_REFRELE(dst_nce); 2194 } 2195 rw_enter(&ipst->ips_ill_g_lock, RW_READER); 2196 ill_refrele(ill); 2197 } 2198 rw_exit(&ipst->ips_ill_g_lock); 2199 } 2200 2201 /* 2202 * Process NDP neighbor solicitation/advertisement messages. 2203 * The checksum has already checked o.k before reaching here. 2204 */ 2205 void 2206 ndp_input(ill_t *ill, mblk_t *mp, mblk_t *dl_mp) 2207 { 2208 icmp6_t *icmp_nd; 2209 ip6_t *ip6h; 2210 int len; 2211 mib2_ipv6IfIcmpEntry_t *mib = ill->ill_icmp6_mib; 2212 2213 2214 if (!pullupmsg(mp, -1)) { 2215 ip1dbg(("ndp_input: pullupmsg failed\n")); 2216 BUMP_MIB(ill->ill_ip_mib, ipIfStatsInDiscards); 2217 goto done; 2218 } 2219 ip6h = (ip6_t *)mp->b_rptr; 2220 if (ip6h->ip6_hops != IPV6_MAX_HOPS) { 2221 ip1dbg(("ndp_input: hoplimit != IPV6_MAX_HOPS\n")); 2222 BUMP_MIB(mib, ipv6IfIcmpBadHoplimit); 2223 goto done; 2224 } 2225 /* 2226 * NDP does not accept any extension headers between the 2227 * IP header and the ICMP header since e.g. a routing 2228 * header could be dangerous. 2229 * This assumes that any AH or ESP headers are removed 2230 * by ip prior to passing the packet to ndp_input. 2231 */ 2232 if (ip6h->ip6_nxt != IPPROTO_ICMPV6) { 2233 ip1dbg(("ndp_input: Wrong next header 0x%x\n", 2234 ip6h->ip6_nxt)); 2235 BUMP_MIB(mib, ipv6IfIcmpInErrors); 2236 goto done; 2237 } 2238 icmp_nd = (icmp6_t *)(mp->b_rptr + IPV6_HDR_LEN); 2239 ASSERT(icmp_nd->icmp6_type == ND_NEIGHBOR_SOLICIT || 2240 icmp_nd->icmp6_type == ND_NEIGHBOR_ADVERT); 2241 if (icmp_nd->icmp6_code != 0) { 2242 ip1dbg(("ndp_input: icmp6 code != 0 \n")); 2243 BUMP_MIB(mib, ipv6IfIcmpInErrors); 2244 goto done; 2245 } 2246 len = mp->b_wptr - mp->b_rptr - IPV6_HDR_LEN; 2247 /* 2248 * Make sure packet length is large enough for either 2249 * a NS or a NA icmp packet. 2250 */ 2251 if (len < sizeof (struct icmp6_hdr) + sizeof (struct in6_addr)) { 2252 ip1dbg(("ndp_input: packet too short\n")); 2253 BUMP_MIB(mib, ipv6IfIcmpInErrors); 2254 goto done; 2255 } 2256 if (icmp_nd->icmp6_type == ND_NEIGHBOR_SOLICIT) { 2257 ndp_input_solicit(ill, mp, dl_mp); 2258 } else { 2259 ndp_input_advert(ill, mp, dl_mp); 2260 } 2261 done: 2262 freemsg(mp); 2263 } 2264 2265 /* 2266 * nce_xmit is called to form and transmit a ND solicitation or 2267 * advertisement ICMP packet. 2268 * 2269 * If the source address is unspecified and this isn't a probe (used for 2270 * duplicate address detection), an appropriate source address and link layer 2271 * address will be chosen here. The link layer address option is included if 2272 * the source is specified (i.e., all non-probe packets), and omitted (per the 2273 * specification) otherwise. 2274 * 2275 * It returns B_FALSE only if it does a successful put() to the 2276 * corresponding ill's ill_wq otherwise returns B_TRUE. 2277 */ 2278 static boolean_t 2279 nce_xmit(ill_t *ill, uint32_t operation, ill_t *hwaddr_ill, 2280 boolean_t use_nd_lla, const in6_addr_t *sender, const in6_addr_t *target, 2281 int flag) 2282 { 2283 uint32_t len; 2284 icmp6_t *icmp6; 2285 mblk_t *mp; 2286 ip6_t *ip6h; 2287 nd_opt_hdr_t *opt; 2288 uint_t plen; 2289 ip6i_t *ip6i; 2290 ipif_t *src_ipif = NULL; 2291 uint8_t *hw_addr; 2292 zoneid_t zoneid = GLOBAL_ZONEID; 2293 2294 /* 2295 * If we have a unspecified source(sender) address, select a 2296 * proper source address for the solicitation here itself so 2297 * that we can initialize the h/w address correctly. This is 2298 * needed for interface groups as source address can come from 2299 * the whole group and the h/w address initialized from ill will 2300 * be wrong if the source address comes from a different ill. 2301 * 2302 * If the sender is specified then we use this address in order 2303 * to lookup the zoneid before calling ip_output_v6(). This is to 2304 * enable unicast ND_NEIGHBOR_ADVERT packets to be routed correctly 2305 * by IP (we cannot guarantee that the global zone has an interface 2306 * route to the destination). 2307 * 2308 * Note that the NA never comes here with the unspecified source 2309 * address. The following asserts that whenever the source 2310 * address is specified, the haddr also should be specified. 2311 */ 2312 ASSERT(IN6_IS_ADDR_UNSPECIFIED(sender) || (hwaddr_ill != NULL)); 2313 2314 if (IN6_IS_ADDR_UNSPECIFIED(sender) && !(flag & NDP_PROBE)) { 2315 ASSERT(operation != ND_NEIGHBOR_ADVERT); 2316 /* 2317 * Pick a source address for this solicitation, but 2318 * restrict the selection to addresses assigned to the 2319 * output interface (or interface group). We do this 2320 * because the destination will create a neighbor cache 2321 * entry for the source address of this packet, so the 2322 * source address had better be a valid neighbor. 2323 */ 2324 src_ipif = ipif_select_source_v6(ill, target, RESTRICT_TO_ILL, 2325 IPV6_PREFER_SRC_DEFAULT, ALL_ZONES); 2326 if (src_ipif == NULL) { 2327 char buf[INET6_ADDRSTRLEN]; 2328 2329 ip1dbg(("nce_xmit: No source ipif for dst %s\n", 2330 inet_ntop(AF_INET6, (char *)target, buf, 2331 sizeof (buf)))); 2332 return (B_TRUE); 2333 } 2334 sender = &src_ipif->ipif_v6src_addr; 2335 hwaddr_ill = src_ipif->ipif_ill; 2336 } else if (!(IN6_IS_ADDR_UNSPECIFIED(sender))) { 2337 zoneid = ipif_lookup_addr_zoneid_v6(sender, ill, ill->ill_ipst); 2338 /* 2339 * It's possible for ipif_lookup_addr_zoneid_v6() to return 2340 * ALL_ZONES if it cannot find a matching ipif for the address 2341 * we are trying to use. In this case we err on the side of 2342 * trying to send the packet by defaulting to the GLOBAL_ZONEID. 2343 */ 2344 if (zoneid == ALL_ZONES) 2345 zoneid = GLOBAL_ZONEID; 2346 } 2347 2348 /* 2349 * Always make sure that the NS/NA packets don't get load 2350 * spread. This is needed so that the probe packets sent 2351 * by the in.mpathd daemon can really go out on the desired 2352 * interface. Probe packets are made to go out on a desired 2353 * interface by including a ip6i with ATTACH_IF flag. As these 2354 * packets indirectly end up sending/receiving NS/NA packets 2355 * (neighbor doing NUD), we have to make sure that NA 2356 * also go out on the same interface. 2357 */ 2358 plen = (sizeof (nd_opt_hdr_t) + ill->ill_nd_lla_len + 7) / 8; 2359 len = IPV6_HDR_LEN + sizeof (ip6i_t) + sizeof (nd_neighbor_advert_t) + 2360 plen * 8; 2361 mp = allocb(len, BPRI_LO); 2362 if (mp == NULL) { 2363 if (src_ipif != NULL) 2364 ipif_refrele(src_ipif); 2365 return (B_TRUE); 2366 } 2367 bzero((char *)mp->b_rptr, len); 2368 mp->b_wptr = mp->b_rptr + len; 2369 2370 ip6i = (ip6i_t *)mp->b_rptr; 2371 ip6i->ip6i_vcf = IPV6_DEFAULT_VERS_AND_FLOW; 2372 ip6i->ip6i_nxt = IPPROTO_RAW; 2373 ip6i->ip6i_flags = IP6I_ATTACH_IF | IP6I_HOPLIMIT; 2374 if (flag & NDP_PROBE) 2375 ip6i->ip6i_flags |= IP6I_UNSPEC_SRC; 2376 ip6i->ip6i_ifindex = ill->ill_phyint->phyint_ifindex; 2377 2378 ip6h = (ip6_t *)(mp->b_rptr + sizeof (ip6i_t)); 2379 ip6h->ip6_vcf = IPV6_DEFAULT_VERS_AND_FLOW; 2380 ip6h->ip6_plen = htons(len - IPV6_HDR_LEN - sizeof (ip6i_t)); 2381 ip6h->ip6_nxt = IPPROTO_ICMPV6; 2382 ip6h->ip6_hops = IPV6_MAX_HOPS; 2383 ip6h->ip6_dst = *target; 2384 icmp6 = (icmp6_t *)&ip6h[1]; 2385 2386 opt = (nd_opt_hdr_t *)((uint8_t *)ip6h + IPV6_HDR_LEN + 2387 sizeof (nd_neighbor_advert_t)); 2388 2389 if (operation == ND_NEIGHBOR_SOLICIT) { 2390 nd_neighbor_solicit_t *ns = (nd_neighbor_solicit_t *)icmp6; 2391 2392 if (!(flag & NDP_PROBE)) 2393 opt->nd_opt_type = ND_OPT_SOURCE_LINKADDR; 2394 ip6h->ip6_src = *sender; 2395 ns->nd_ns_target = *target; 2396 if (!(flag & NDP_UNICAST)) { 2397 /* Form multicast address of the target */ 2398 ip6h->ip6_dst = ipv6_solicited_node_mcast; 2399 ip6h->ip6_dst.s6_addr32[3] |= 2400 ns->nd_ns_target.s6_addr32[3]; 2401 } 2402 } else { 2403 nd_neighbor_advert_t *na = (nd_neighbor_advert_t *)icmp6; 2404 2405 ASSERT(!(flag & NDP_PROBE)); 2406 opt->nd_opt_type = ND_OPT_TARGET_LINKADDR; 2407 ip6h->ip6_src = *sender; 2408 na->nd_na_target = *sender; 2409 if (flag & NDP_ISROUTER) 2410 na->nd_na_flags_reserved |= ND_NA_FLAG_ROUTER; 2411 if (flag & NDP_SOLICITED) 2412 na->nd_na_flags_reserved |= ND_NA_FLAG_SOLICITED; 2413 if (flag & NDP_ORIDE) 2414 na->nd_na_flags_reserved |= ND_NA_FLAG_OVERRIDE; 2415 } 2416 2417 hw_addr = NULL; 2418 if (!(flag & NDP_PROBE)) { 2419 hw_addr = use_nd_lla ? hwaddr_ill->ill_nd_lla : 2420 hwaddr_ill->ill_phys_addr; 2421 if (hw_addr != NULL) { 2422 /* Fill in link layer address and option len */ 2423 opt->nd_opt_len = (uint8_t)plen; 2424 bcopy(hw_addr, &opt[1], hwaddr_ill->ill_nd_lla_len); 2425 } 2426 } 2427 if (hw_addr == NULL) { 2428 /* If there's no link layer address option, then strip it. */ 2429 len -= plen * 8; 2430 mp->b_wptr = mp->b_rptr + len; 2431 ip6h->ip6_plen = htons(len - IPV6_HDR_LEN - sizeof (ip6i_t)); 2432 } 2433 2434 icmp6->icmp6_type = (uint8_t)operation; 2435 icmp6->icmp6_code = 0; 2436 /* 2437 * Prepare for checksum by putting icmp length in the icmp 2438 * checksum field. The checksum is calculated in ip_wput_v6. 2439 */ 2440 icmp6->icmp6_cksum = ip6h->ip6_plen; 2441 2442 if (src_ipif != NULL) 2443 ipif_refrele(src_ipif); 2444 2445 ip_output_v6((void *)(uintptr_t)zoneid, mp, ill->ill_wq, IP_WPUT); 2446 return (B_FALSE); 2447 } 2448 2449 /* 2450 * Make a link layer address (does not include the SAP) from an nce. 2451 * To form the link layer address, use the last four bytes of ipv6 2452 * address passed in and the fixed offset stored in nce. 2453 */ 2454 static void 2455 nce_make_mapping(nce_t *nce, uchar_t *addrpos, uchar_t *addr) 2456 { 2457 uchar_t *mask, *to; 2458 ill_t *ill = nce->nce_ill; 2459 int len; 2460 2461 if (ill->ill_net_type == IRE_IF_NORESOLVER) 2462 return; 2463 ASSERT(nce->nce_res_mp != NULL); 2464 ASSERT(ill->ill_net_type == IRE_IF_RESOLVER); 2465 ASSERT(nce->nce_flags & NCE_F_MAPPING); 2466 ASSERT(!IN6_IS_ADDR_UNSPECIFIED(&nce->nce_extract_mask)); 2467 ASSERT(addr != NULL); 2468 bcopy(nce->nce_res_mp->b_rptr + NCE_LL_ADDR_OFFSET(ill), 2469 addrpos, ill->ill_nd_lla_len); 2470 len = MIN((int)ill->ill_nd_lla_len - nce->nce_ll_extract_start, 2471 IPV6_ADDR_LEN); 2472 mask = (uchar_t *)&nce->nce_extract_mask; 2473 mask += (IPV6_ADDR_LEN - len); 2474 addr += (IPV6_ADDR_LEN - len); 2475 to = addrpos + nce->nce_ll_extract_start; 2476 while (len-- > 0) 2477 *to++ |= *mask++ & *addr++; 2478 } 2479 2480 /* 2481 * Pass a cache report back out via NDD. 2482 */ 2483 /* ARGSUSED */ 2484 int 2485 ndp_report(queue_t *q, mblk_t *mp, caddr_t arg, cred_t *ioc_cr) 2486 { 2487 ip_stack_t *ipst; 2488 2489 if (CONN_Q(q)) 2490 ipst = CONNQ_TO_IPST(q); 2491 else 2492 ipst = ILLQ_TO_IPST(q); 2493 2494 (void) mi_mpprintf(mp, "ifname hardware addr flags" 2495 " proto addr/mask"); 2496 ndp_walk(NULL, (pfi_t)nce_report1, (uchar_t *)mp, ipst); 2497 return (0); 2498 } 2499 2500 /* 2501 * Add a single line to the NDP Cache Entry Report. 2502 */ 2503 static void 2504 nce_report1(nce_t *nce, uchar_t *mp_arg) 2505 { 2506 ill_t *ill = nce->nce_ill; 2507 char local_buf[INET6_ADDRSTRLEN]; 2508 uchar_t flags_buf[10]; 2509 uint32_t flags = nce->nce_flags; 2510 mblk_t *mp = (mblk_t *)mp_arg; 2511 uchar_t *h; 2512 uchar_t *m = flags_buf; 2513 in6_addr_t v6addr; 2514 uint64_t now; 2515 2516 /* 2517 * Lock the nce to protect nce_res_mp from being changed 2518 * if an external resolver address resolution completes 2519 * while nce_res_mp is being accessed here. 2520 * 2521 * Deal with all address formats, not just Ethernet-specific 2522 * In addition, make sure that the mblk has enough space 2523 * before writing to it. If is doesn't, allocate a new one. 2524 */ 2525 if (nce->nce_ipversion == IPV4_VERSION) { 2526 /* 2527 * Don't include v4 NCEs in NDP cache entry report. 2528 * But sanity check for lingering ND_INITIAL entries 2529 * when we do 'ndd -get /dev/ip ip_ndp_cache_report' 2530 */ 2531 if (nce->nce_state == ND_INITIAL) { 2532 2533 now = TICK_TO_MSEC(lbolt64); 2534 if (now - nce->nce_init_time > 120000) { 2535 DTRACE_PROBE1(nce__stuck, nce_t *, nce); 2536 } 2537 } 2538 return; 2539 } 2540 2541 ASSERT(ill != NULL); 2542 v6addr = nce->nce_mask; 2543 if (flags & NCE_F_PERMANENT) 2544 *m++ = 'P'; 2545 if (flags & NCE_F_ISROUTER) 2546 *m++ = 'R'; 2547 if (flags & NCE_F_MAPPING) 2548 *m++ = 'M'; 2549 *m = '\0'; 2550 2551 if (ill->ill_net_type == IRE_IF_RESOLVER) { 2552 size_t addrlen; 2553 char *addr_buf; 2554 dl_unitdata_req_t *dl; 2555 2556 mutex_enter(&nce->nce_lock); 2557 h = nce->nce_res_mp->b_rptr + NCE_LL_ADDR_OFFSET(ill); 2558 dl = (dl_unitdata_req_t *)nce->nce_res_mp->b_rptr; 2559 if (ill->ill_flags & ILLF_XRESOLV) 2560 addrlen = (3 * (dl->dl_dest_addr_length)); 2561 else 2562 addrlen = (3 * (ill->ill_nd_lla_len)); 2563 if (addrlen <= 0) { 2564 mutex_exit(&nce->nce_lock); 2565 (void) mi_mpprintf(mp, 2566 "%8s %9s %5s %s/%d", 2567 ill->ill_name, 2568 "None", 2569 (uchar_t *)&flags_buf, 2570 inet_ntop(AF_INET6, (char *)&nce->nce_addr, 2571 (char *)local_buf, sizeof (local_buf)), 2572 ip_mask_to_plen_v6(&v6addr)); 2573 } else { 2574 /* 2575 * Convert the hardware/lla address to ascii 2576 */ 2577 addr_buf = kmem_zalloc(addrlen, KM_NOSLEEP); 2578 if (addr_buf == NULL) { 2579 mutex_exit(&nce->nce_lock); 2580 return; 2581 } 2582 (void) mac_colon_addr((uint8_t *)h, 2583 (ill->ill_flags & ILLF_XRESOLV) ? 2584 dl->dl_dest_addr_length : ill->ill_nd_lla_len, 2585 addr_buf, addrlen); 2586 mutex_exit(&nce->nce_lock); 2587 (void) mi_mpprintf(mp, "%8s %17s %5s %s/%d", 2588 ill->ill_name, addr_buf, (uchar_t *)&flags_buf, 2589 inet_ntop(AF_INET6, (char *)&nce->nce_addr, 2590 (char *)local_buf, sizeof (local_buf)), 2591 ip_mask_to_plen_v6(&v6addr)); 2592 kmem_free(addr_buf, addrlen); 2593 } 2594 } else { 2595 (void) mi_mpprintf(mp, 2596 "%8s %9s %5s %s/%d", 2597 ill->ill_name, 2598 "None", 2599 (uchar_t *)&flags_buf, 2600 inet_ntop(AF_INET6, (char *)&nce->nce_addr, 2601 (char *)local_buf, sizeof (local_buf)), 2602 ip_mask_to_plen_v6(&v6addr)); 2603 } 2604 } 2605 2606 mblk_t * 2607 nce_udreq_alloc(ill_t *ill) 2608 { 2609 mblk_t *template_mp = NULL; 2610 dl_unitdata_req_t *dlur; 2611 int sap_length; 2612 2613 ASSERT(ill->ill_isv6); 2614 2615 sap_length = ill->ill_sap_length; 2616 template_mp = ip_dlpi_alloc(sizeof (dl_unitdata_req_t) + 2617 ill->ill_nd_lla_len + ABS(sap_length), DL_UNITDATA_REQ); 2618 if (template_mp == NULL) 2619 return (NULL); 2620 2621 dlur = (dl_unitdata_req_t *)template_mp->b_rptr; 2622 dlur->dl_priority.dl_min = 0; 2623 dlur->dl_priority.dl_max = 0; 2624 dlur->dl_dest_addr_length = ABS(sap_length) + ill->ill_nd_lla_len; 2625 dlur->dl_dest_addr_offset = sizeof (dl_unitdata_req_t); 2626 2627 /* Copy in the SAP value. */ 2628 NCE_LL_SAP_COPY(ill, template_mp); 2629 2630 return (template_mp); 2631 } 2632 2633 /* 2634 * NDP retransmit timer. 2635 * This timer goes off when: 2636 * a. It is time to retransmit NS for resolver. 2637 * b. It is time to send reachability probes. 2638 */ 2639 void 2640 ndp_timer(void *arg) 2641 { 2642 nce_t *nce = arg; 2643 ill_t *ill = nce->nce_ill; 2644 uint32_t ms; 2645 char addrbuf[INET6_ADDRSTRLEN]; 2646 mblk_t *mp; 2647 boolean_t dropped = B_FALSE; 2648 ip_stack_t *ipst = ill->ill_ipst; 2649 2650 /* 2651 * The timer has to be cancelled by ndp_delete before doing the final 2652 * refrele. So the NCE is guaranteed to exist when the timer runs 2653 * until it clears the timeout_id. Before clearing the timeout_id 2654 * bump up the refcnt so that we can continue to use the nce 2655 */ 2656 ASSERT(nce != NULL); 2657 2658 /* 2659 * Grab the ill_g_lock now itself to avoid lock order problems. 2660 * nce_solicit needs ill_g_lock to be able to traverse ills 2661 */ 2662 rw_enter(&ipst->ips_ill_g_lock, RW_READER); 2663 mutex_enter(&nce->nce_lock); 2664 NCE_REFHOLD_LOCKED(nce); 2665 nce->nce_timeout_id = 0; 2666 2667 /* 2668 * Check the reachability state first. 2669 */ 2670 switch (nce->nce_state) { 2671 case ND_DELAY: 2672 rw_exit(&ipst->ips_ill_g_lock); 2673 nce->nce_state = ND_PROBE; 2674 mutex_exit(&nce->nce_lock); 2675 (void) nce_xmit(ill, ND_NEIGHBOR_SOLICIT, NULL, B_FALSE, 2676 &ipv6_all_zeros, &nce->nce_addr, NDP_UNICAST); 2677 if (ip_debug > 3) { 2678 /* ip2dbg */ 2679 pr_addr_dbg("ndp_timer: state for %s changed " 2680 "to PROBE\n", AF_INET6, &nce->nce_addr); 2681 } 2682 NDP_RESTART_TIMER(nce, ill->ill_reachable_retrans_time); 2683 NCE_REFRELE(nce); 2684 return; 2685 case ND_PROBE: 2686 /* must be retransmit timer */ 2687 rw_exit(&ipst->ips_ill_g_lock); 2688 nce->nce_pcnt--; 2689 ASSERT(nce->nce_pcnt < ND_MAX_UNICAST_SOLICIT && 2690 nce->nce_pcnt >= -1); 2691 if (nce->nce_pcnt > 0) { 2692 /* 2693 * As per RFC2461, the nce gets deleted after 2694 * MAX_UNICAST_SOLICIT unsuccessful re-transmissions. 2695 * Note that the first unicast solicitation is sent 2696 * during the DELAY state. 2697 */ 2698 ip2dbg(("ndp_timer: pcount=%x dst %s\n", 2699 nce->nce_pcnt, inet_ntop(AF_INET6, &nce->nce_addr, 2700 addrbuf, sizeof (addrbuf)))); 2701 mutex_exit(&nce->nce_lock); 2702 dropped = nce_xmit(ill, ND_NEIGHBOR_SOLICIT, NULL, 2703 B_FALSE, &ipv6_all_zeros, &nce->nce_addr, 2704 (nce->nce_flags & NCE_F_PERMANENT) ? NDP_PROBE : 2705 NDP_UNICAST); 2706 if (dropped) { 2707 mutex_enter(&nce->nce_lock); 2708 nce->nce_pcnt++; 2709 mutex_exit(&nce->nce_lock); 2710 } 2711 NDP_RESTART_TIMER(nce, ILL_PROBE_INTERVAL(ill)); 2712 } else if (nce->nce_pcnt < 0) { 2713 /* No hope, delete the nce */ 2714 nce->nce_state = ND_UNREACHABLE; 2715 mutex_exit(&nce->nce_lock); 2716 if (ip_debug > 2) { 2717 /* ip1dbg */ 2718 pr_addr_dbg("ndp_timer: Delete IRE for" 2719 " dst %s\n", AF_INET6, &nce->nce_addr); 2720 } 2721 ndp_delete(nce); 2722 } else if (!(nce->nce_flags & NCE_F_PERMANENT)) { 2723 /* Wait RetransTimer, before deleting the entry */ 2724 ip2dbg(("ndp_timer: pcount=%x dst %s\n", 2725 nce->nce_pcnt, inet_ntop(AF_INET6, 2726 &nce->nce_addr, addrbuf, sizeof (addrbuf)))); 2727 mutex_exit(&nce->nce_lock); 2728 /* Wait one interval before killing */ 2729 NDP_RESTART_TIMER(nce, ill->ill_reachable_retrans_time); 2730 } else if (ill->ill_phyint->phyint_flags & PHYI_RUNNING) { 2731 ipif_t *ipif; 2732 2733 /* 2734 * We're done probing, and we can now declare this 2735 * address to be usable. Let IP know that it's ok to 2736 * use. 2737 */ 2738 nce->nce_state = ND_REACHABLE; 2739 mutex_exit(&nce->nce_lock); 2740 ipif = ipif_lookup_addr_v6(&nce->nce_addr, ill, 2741 ALL_ZONES, NULL, NULL, NULL, NULL, ipst); 2742 if (ipif != NULL) { 2743 if (ipif->ipif_was_dup) { 2744 char ibuf[LIFNAMSIZ + 10]; 2745 char sbuf[INET6_ADDRSTRLEN]; 2746 2747 ipif->ipif_was_dup = B_FALSE; 2748 (void) strlcpy(ibuf, ill->ill_name, 2749 sizeof (ibuf)); 2750 (void) inet_ntop(AF_INET6, 2751 &ipif->ipif_v6lcl_addr, 2752 sbuf, sizeof (sbuf)); 2753 if (ipif->ipif_id != 0) { 2754 (void) snprintf(ibuf + 2755 ill->ill_name_length - 1, 2756 sizeof (ibuf) - 2757 ill->ill_name_length + 1, 2758 ":%d", ipif->ipif_id); 2759 } 2760 cmn_err(CE_NOTE, "recovered address " 2761 "%s on %s", sbuf, ibuf); 2762 } 2763 if ((ipif->ipif_flags & IPIF_UP) && 2764 !ipif->ipif_addr_ready) { 2765 ip_rts_ifmsg(ipif); 2766 ip_rts_newaddrmsg(RTM_ADD, 0, ipif); 2767 sctp_update_ipif(ipif, SCTP_IPIF_UP); 2768 } 2769 ipif->ipif_addr_ready = 1; 2770 ipif_refrele(ipif); 2771 } 2772 /* Begin defending our new address */ 2773 nce->nce_unsolicit_count = 0; 2774 dropped = nce_xmit(ill, ND_NEIGHBOR_ADVERT, ill, 2775 B_FALSE, &nce->nce_addr, &ipv6_all_hosts_mcast, 2776 nce_advert_flags(nce)); 2777 if (dropped) { 2778 nce->nce_unsolicit_count = 1; 2779 NDP_RESTART_TIMER(nce, 2780 ipst->ips_ip_ndp_unsolicit_interval); 2781 } else if (ipst->ips_ip_ndp_defense_interval != 0) { 2782 NDP_RESTART_TIMER(nce, 2783 ipst->ips_ip_ndp_defense_interval); 2784 } 2785 } else { 2786 /* 2787 * This is an address we're probing to be our own, but 2788 * the ill is down. Wait until it comes back before 2789 * doing anything, but switch to reachable state so 2790 * that the restart will work. 2791 */ 2792 nce->nce_state = ND_REACHABLE; 2793 mutex_exit(&nce->nce_lock); 2794 } 2795 NCE_REFRELE(nce); 2796 return; 2797 case ND_INCOMPLETE: 2798 /* 2799 * Must be resolvers retransmit timer. 2800 */ 2801 for (mp = nce->nce_qd_mp; mp != NULL; mp = mp->b_next) { 2802 ip6i_t *ip6i; 2803 ip6_t *ip6h; 2804 mblk_t *data_mp; 2805 2806 /* 2807 * Walk the list of packets queued, and see if there 2808 * are any multipathing probe packets. Such packets 2809 * are always queued at the head. Since this is a 2810 * retransmit timer firing, mark such packets as 2811 * delayed in ND resolution. This info will be used 2812 * in ip_wput_v6(). Multipathing probe packets will 2813 * always have an ip6i_t. Once we hit a packet without 2814 * it, we can break out of this loop. 2815 */ 2816 if (mp->b_datap->db_type == M_CTL) 2817 data_mp = mp->b_cont; 2818 else 2819 data_mp = mp; 2820 2821 ip6h = (ip6_t *)data_mp->b_rptr; 2822 if (ip6h->ip6_nxt != IPPROTO_RAW) 2823 break; 2824 2825 /* 2826 * This message should have been pulled up already in 2827 * ip_wput_v6. We can't do pullups here because the 2828 * b_next/b_prev is non-NULL. 2829 */ 2830 ip6i = (ip6i_t *)ip6h; 2831 ASSERT((data_mp->b_wptr - (uchar_t *)ip6i) >= 2832 sizeof (ip6i_t) + IPV6_HDR_LEN); 2833 2834 /* Mark this packet as delayed due to ND resolution */ 2835 if (ip6i->ip6i_flags & IP6I_DROP_IFDELAYED) 2836 ip6i->ip6i_flags |= IP6I_ND_DELAYED; 2837 } 2838 if (nce->nce_qd_mp != NULL) { 2839 ms = nce_solicit(nce, NULL); 2840 rw_exit(&ipst->ips_ill_g_lock); 2841 if (ms == 0) { 2842 if (nce->nce_state != ND_REACHABLE) { 2843 mutex_exit(&nce->nce_lock); 2844 nce_resolv_failed(nce); 2845 ndp_delete(nce); 2846 } else { 2847 mutex_exit(&nce->nce_lock); 2848 } 2849 } else { 2850 mutex_exit(&nce->nce_lock); 2851 NDP_RESTART_TIMER(nce, (clock_t)ms); 2852 } 2853 NCE_REFRELE(nce); 2854 return; 2855 } 2856 mutex_exit(&nce->nce_lock); 2857 rw_exit(&ipst->ips_ill_g_lock); 2858 NCE_REFRELE(nce); 2859 break; 2860 case ND_REACHABLE : 2861 rw_exit(&ipst->ips_ill_g_lock); 2862 if (((nce->nce_flags & NCE_F_UNSOL_ADV) && 2863 nce->nce_unsolicit_count != 0) || 2864 ((nce->nce_flags & NCE_F_PERMANENT) && 2865 ipst->ips_ip_ndp_defense_interval != 0)) { 2866 if (nce->nce_unsolicit_count > 0) 2867 nce->nce_unsolicit_count--; 2868 mutex_exit(&nce->nce_lock); 2869 dropped = nce_xmit(ill, 2870 ND_NEIGHBOR_ADVERT, 2871 ill, /* ill to be used for hw addr */ 2872 B_FALSE, /* use ill_phys_addr */ 2873 &nce->nce_addr, 2874 &ipv6_all_hosts_mcast, 2875 nce_advert_flags(nce)); 2876 if (dropped) { 2877 mutex_enter(&nce->nce_lock); 2878 nce->nce_unsolicit_count++; 2879 mutex_exit(&nce->nce_lock); 2880 } 2881 if (nce->nce_unsolicit_count != 0) { 2882 NDP_RESTART_TIMER(nce, 2883 ipst->ips_ip_ndp_unsolicit_interval); 2884 } else { 2885 NDP_RESTART_TIMER(nce, 2886 ipst->ips_ip_ndp_defense_interval); 2887 } 2888 } else { 2889 mutex_exit(&nce->nce_lock); 2890 } 2891 NCE_REFRELE(nce); 2892 break; 2893 default: 2894 rw_exit(&ipst->ips_ill_g_lock); 2895 mutex_exit(&nce->nce_lock); 2896 NCE_REFRELE(nce); 2897 break; 2898 } 2899 } 2900 2901 /* 2902 * Set a link layer address from the ll_addr passed in. 2903 * Copy SAP from ill. 2904 */ 2905 static void 2906 nce_set_ll(nce_t *nce, uchar_t *ll_addr) 2907 { 2908 ill_t *ill = nce->nce_ill; 2909 uchar_t *woffset; 2910 2911 ASSERT(ll_addr != NULL); 2912 /* Always called before fast_path_probe */ 2913 ASSERT(nce->nce_fp_mp == NULL); 2914 if (ill->ill_sap_length != 0) { 2915 /* 2916 * Copy the SAP type specified in the 2917 * request into the xmit template. 2918 */ 2919 NCE_LL_SAP_COPY(ill, nce->nce_res_mp); 2920 } 2921 if (ill->ill_phys_addr_length > 0) { 2922 /* 2923 * The bcopy() below used to be called for the physical address 2924 * length rather than the link layer address length. For 2925 * ethernet and many other media, the phys_addr and lla are 2926 * identical. 2927 * However, with xresolv interfaces being introduced, the 2928 * phys_addr and lla are no longer the same, and the physical 2929 * address may not have any useful meaning, so we use the lla 2930 * for IPv6 address resolution and destination addressing. 2931 * 2932 * For PPP or other interfaces with a zero length 2933 * physical address, don't do anything here. 2934 * The bcopy() with a zero phys_addr length was previously 2935 * a no-op for interfaces with a zero-length physical address. 2936 * Using the lla for them would change the way they operate. 2937 * Doing nothing in such cases preserves expected behavior. 2938 */ 2939 woffset = nce->nce_res_mp->b_rptr + NCE_LL_ADDR_OFFSET(ill); 2940 bcopy(ll_addr, woffset, ill->ill_nd_lla_len); 2941 } 2942 } 2943 2944 static boolean_t 2945 nce_cmp_ll_addr(const nce_t *nce, const uchar_t *ll_addr, uint32_t ll_addr_len) 2946 { 2947 ill_t *ill = nce->nce_ill; 2948 uchar_t *ll_offset; 2949 2950 ASSERT(nce->nce_res_mp != NULL); 2951 if (ll_addr == NULL) 2952 return (B_FALSE); 2953 ll_offset = nce->nce_res_mp->b_rptr + NCE_LL_ADDR_OFFSET(ill); 2954 if (bcmp(ll_addr, ll_offset, ll_addr_len) != 0) 2955 return (B_TRUE); 2956 return (B_FALSE); 2957 } 2958 2959 /* 2960 * Updates the link layer address or the reachability state of 2961 * a cache entry. Reset probe counter if needed. 2962 */ 2963 static void 2964 nce_update(nce_t *nce, uint16_t new_state, uchar_t *new_ll_addr) 2965 { 2966 ill_t *ill = nce->nce_ill; 2967 boolean_t need_stop_timer = B_FALSE; 2968 boolean_t need_fastpath_update = B_FALSE; 2969 2970 ASSERT(MUTEX_HELD(&nce->nce_lock)); 2971 ASSERT(nce->nce_ipversion == IPV6_VERSION); 2972 /* 2973 * If this interface does not do NUD, there is no point 2974 * in allowing an update to the cache entry. Although 2975 * we will respond to NS. 2976 * The only time we accept an update for a resolver when 2977 * NUD is turned off is when it has just been created. 2978 * Non-Resolvers will always be created as REACHABLE. 2979 */ 2980 if (new_state != ND_UNCHANGED) { 2981 if ((nce->nce_flags & NCE_F_NONUD) && 2982 (nce->nce_state != ND_INCOMPLETE)) 2983 return; 2984 ASSERT((int16_t)new_state >= ND_STATE_VALID_MIN); 2985 ASSERT((int16_t)new_state <= ND_STATE_VALID_MAX); 2986 need_stop_timer = B_TRUE; 2987 if (new_state == ND_REACHABLE) 2988 nce->nce_last = TICK_TO_MSEC(lbolt64); 2989 else { 2990 /* We force NUD in this case */ 2991 nce->nce_last = 0; 2992 } 2993 nce->nce_state = new_state; 2994 nce->nce_pcnt = ND_MAX_UNICAST_SOLICIT; 2995 } 2996 /* 2997 * In case of fast path we need to free the the fastpath 2998 * M_DATA and do another probe. Otherwise we can just 2999 * overwrite the DL_UNITDATA_REQ data, noting we'll lose 3000 * whatever packets that happens to be transmitting at the time. 3001 */ 3002 if (new_ll_addr != NULL) { 3003 ASSERT(nce->nce_res_mp->b_rptr + NCE_LL_ADDR_OFFSET(ill) + 3004 ill->ill_nd_lla_len <= nce->nce_res_mp->b_wptr); 3005 bcopy(new_ll_addr, nce->nce_res_mp->b_rptr + 3006 NCE_LL_ADDR_OFFSET(ill), ill->ill_nd_lla_len); 3007 if (nce->nce_fp_mp != NULL) { 3008 freemsg(nce->nce_fp_mp); 3009 nce->nce_fp_mp = NULL; 3010 } 3011 need_fastpath_update = B_TRUE; 3012 } 3013 mutex_exit(&nce->nce_lock); 3014 if (need_stop_timer) { 3015 (void) untimeout(nce->nce_timeout_id); 3016 nce->nce_timeout_id = 0; 3017 } 3018 if (need_fastpath_update) 3019 nce_fastpath(nce); 3020 mutex_enter(&nce->nce_lock); 3021 } 3022 3023 void 3024 nce_queue_mp_common(nce_t *nce, mblk_t *mp, boolean_t head_insert) 3025 { 3026 uint_t count = 0; 3027 mblk_t **mpp; 3028 3029 ASSERT(MUTEX_HELD(&nce->nce_lock)); 3030 3031 for (mpp = &nce->nce_qd_mp; *mpp != NULL; 3032 mpp = &(*mpp)->b_next) { 3033 if (++count > 3034 nce->nce_ill->ill_max_buf) { 3035 mblk_t *tmp = nce->nce_qd_mp->b_next; 3036 3037 nce->nce_qd_mp->b_next = NULL; 3038 nce->nce_qd_mp->b_prev = NULL; 3039 freemsg(nce->nce_qd_mp); 3040 nce->nce_qd_mp = tmp; 3041 } 3042 } 3043 /* put this on the list */ 3044 if (head_insert) { 3045 mp->b_next = nce->nce_qd_mp; 3046 nce->nce_qd_mp = mp; 3047 } else { 3048 *mpp = mp; 3049 } 3050 } 3051 3052 static void 3053 nce_queue_mp(nce_t *nce, mblk_t *mp) 3054 { 3055 boolean_t head_insert = B_FALSE; 3056 ip6_t *ip6h; 3057 ip6i_t *ip6i; 3058 mblk_t *data_mp; 3059 3060 ASSERT(MUTEX_HELD(&nce->nce_lock)); 3061 3062 if (mp->b_datap->db_type == M_CTL) 3063 data_mp = mp->b_cont; 3064 else 3065 data_mp = mp; 3066 ip6h = (ip6_t *)data_mp->b_rptr; 3067 if (ip6h->ip6_nxt == IPPROTO_RAW) { 3068 /* 3069 * This message should have been pulled up already in 3070 * ip_wput_v6. We can't do pullups here because the message 3071 * could be from the nce_qd_mp which could have b_next/b_prev 3072 * non-NULL. 3073 */ 3074 ip6i = (ip6i_t *)ip6h; 3075 ASSERT((data_mp->b_wptr - (uchar_t *)ip6i) >= 3076 sizeof (ip6i_t) + IPV6_HDR_LEN); 3077 /* 3078 * Multipathing probe packets have IP6I_DROP_IFDELAYED set. 3079 * This has 2 aspects mentioned below. 3080 * 1. Perform head insertion in the nce_qd_mp for these packets. 3081 * This ensures that next retransmit of ND solicitation 3082 * will use the interface specified by the probe packet, 3083 * for both NS and NA. This corresponds to the src address 3084 * in the IPv6 packet. If we insert at tail, we will be 3085 * depending on the packet at the head for successful 3086 * ND resolution. This is not reliable, because the interface 3087 * on which the NA arrives could be different from the interface 3088 * on which the NS was sent, and if the receiving interface is 3089 * failed, it will appear that the sending interface is also 3090 * failed, causing in.mpathd to misdiagnose this as link 3091 * failure. 3092 * 2. Drop the original packet, if the ND resolution did not 3093 * succeed in the first attempt. However we will create the 3094 * nce and the ire, as soon as the ND resolution succeeds. 3095 * We don't gain anything by queueing multiple probe packets 3096 * and sending them back-to-back once resolution succeeds. 3097 * It is sufficient to send just 1 packet after ND resolution 3098 * succeeds. Since mpathd is sending down probe packets at a 3099 * constant rate, we don't need to send the queued packet. We 3100 * need to queue it only for NDP resolution. The benefit of 3101 * dropping the probe packets that were delayed in ND 3102 * resolution, is that in.mpathd will not see inflated 3103 * RTT. If the ND resolution does not succeed within 3104 * in.mpathd's failure detection time, mpathd may detect 3105 * a failure, and it does not matter whether the packet 3106 * was queued or dropped. 3107 */ 3108 if (ip6i->ip6i_flags & IP6I_DROP_IFDELAYED) 3109 head_insert = B_TRUE; 3110 } 3111 3112 nce_queue_mp_common(nce, mp, head_insert); 3113 } 3114 3115 /* 3116 * Called when address resolution failed due to a timeout. 3117 * Send an ICMP unreachable in response to all queued packets. 3118 */ 3119 void 3120 nce_resolv_failed(nce_t *nce) 3121 { 3122 mblk_t *mp, *nxt_mp, *first_mp; 3123 char buf[INET6_ADDRSTRLEN]; 3124 ip6_t *ip6h; 3125 zoneid_t zoneid = GLOBAL_ZONEID; 3126 ip_stack_t *ipst = nce->nce_ill->ill_ipst; 3127 3128 ip1dbg(("nce_resolv_failed: dst %s\n", 3129 inet_ntop(AF_INET6, (char *)&nce->nce_addr, buf, sizeof (buf)))); 3130 mutex_enter(&nce->nce_lock); 3131 mp = nce->nce_qd_mp; 3132 nce->nce_qd_mp = NULL; 3133 mutex_exit(&nce->nce_lock); 3134 while (mp != NULL) { 3135 nxt_mp = mp->b_next; 3136 mp->b_next = NULL; 3137 mp->b_prev = NULL; 3138 3139 first_mp = mp; 3140 if (mp->b_datap->db_type == M_CTL) { 3141 ipsec_out_t *io = (ipsec_out_t *)mp->b_rptr; 3142 ASSERT(io->ipsec_out_type == IPSEC_OUT); 3143 zoneid = io->ipsec_out_zoneid; 3144 ASSERT(zoneid != ALL_ZONES); 3145 mp = mp->b_cont; 3146 } 3147 3148 ip6h = (ip6_t *)mp->b_rptr; 3149 if (ip6h->ip6_nxt == IPPROTO_RAW) { 3150 ip6i_t *ip6i; 3151 /* 3152 * This message should have been pulled up already 3153 * in ip_wput_v6. ip_hdr_complete_v6 assumes that 3154 * the header is pulled up. 3155 */ 3156 ip6i = (ip6i_t *)ip6h; 3157 ASSERT((mp->b_wptr - (uchar_t *)ip6i) >= 3158 sizeof (ip6i_t) + IPV6_HDR_LEN); 3159 mp->b_rptr += sizeof (ip6i_t); 3160 } 3161 /* 3162 * Ignore failure since icmp_unreachable_v6 will silently 3163 * drop packets with an unspecified source address. 3164 */ 3165 (void) ip_hdr_complete_v6((ip6_t *)mp->b_rptr, zoneid, ipst); 3166 icmp_unreachable_v6(nce->nce_ill->ill_wq, first_mp, 3167 ICMP6_DST_UNREACH_ADDR, B_FALSE, B_FALSE, zoneid, ipst); 3168 mp = nxt_mp; 3169 } 3170 } 3171 3172 /* 3173 * Called by SIOCSNDP* ioctl to add/change an nce entry 3174 * and the corresponding attributes. 3175 * Disallow states other than ND_REACHABLE or ND_STALE. 3176 */ 3177 int 3178 ndp_sioc_update(ill_t *ill, lif_nd_req_t *lnr) 3179 { 3180 sin6_t *sin6; 3181 in6_addr_t *addr; 3182 nce_t *nce; 3183 int err; 3184 uint16_t new_flags = 0; 3185 uint16_t old_flags = 0; 3186 int inflags = lnr->lnr_flags; 3187 ip_stack_t *ipst = ill->ill_ipst; 3188 3189 ASSERT(ill->ill_isv6); 3190 if ((lnr->lnr_state_create != ND_REACHABLE) && 3191 (lnr->lnr_state_create != ND_STALE)) 3192 return (EINVAL); 3193 3194 sin6 = (sin6_t *)&lnr->lnr_addr; 3195 addr = &sin6->sin6_addr; 3196 3197 mutex_enter(&ipst->ips_ndp6->ndp_g_lock); 3198 /* We know it can not be mapping so just look in the hash table */ 3199 nce = *((nce_t **)NCE_HASH_PTR_V6(ipst, *addr)); 3200 nce = nce_lookup_addr(ill, addr, nce); 3201 if (nce != NULL) 3202 new_flags = nce->nce_flags; 3203 3204 switch (inflags & (NDF_ISROUTER_ON|NDF_ISROUTER_OFF)) { 3205 case NDF_ISROUTER_ON: 3206 new_flags |= NCE_F_ISROUTER; 3207 break; 3208 case NDF_ISROUTER_OFF: 3209 new_flags &= ~NCE_F_ISROUTER; 3210 break; 3211 case (NDF_ISROUTER_OFF|NDF_ISROUTER_ON): 3212 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 3213 if (nce != NULL) 3214 NCE_REFRELE(nce); 3215 return (EINVAL); 3216 } 3217 3218 switch (inflags & (NDF_ANYCAST_ON|NDF_ANYCAST_OFF)) { 3219 case NDF_ANYCAST_ON: 3220 new_flags |= NCE_F_ANYCAST; 3221 break; 3222 case NDF_ANYCAST_OFF: 3223 new_flags &= ~NCE_F_ANYCAST; 3224 break; 3225 case (NDF_ANYCAST_OFF|NDF_ANYCAST_ON): 3226 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 3227 if (nce != NULL) 3228 NCE_REFRELE(nce); 3229 return (EINVAL); 3230 } 3231 3232 switch (inflags & (NDF_PROXY_ON|NDF_PROXY_OFF)) { 3233 case NDF_PROXY_ON: 3234 new_flags |= NCE_F_PROXY; 3235 break; 3236 case NDF_PROXY_OFF: 3237 new_flags &= ~NCE_F_PROXY; 3238 break; 3239 case (NDF_PROXY_OFF|NDF_PROXY_ON): 3240 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 3241 if (nce != NULL) 3242 NCE_REFRELE(nce); 3243 return (EINVAL); 3244 } 3245 3246 if (nce == NULL) { 3247 err = ndp_add(ill, 3248 (uchar_t *)lnr->lnr_hdw_addr, 3249 addr, 3250 &ipv6_all_ones, 3251 &ipv6_all_zeros, 3252 0, 3253 new_flags, 3254 lnr->lnr_state_create, 3255 &nce, 3256 NULL, 3257 NULL); 3258 if (err != 0) { 3259 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 3260 ip1dbg(("ndp_sioc_update: Can't create NCE %d\n", err)); 3261 return (err); 3262 } 3263 } 3264 old_flags = nce->nce_flags; 3265 if (old_flags & NCE_F_ISROUTER && !(new_flags & NCE_F_ISROUTER)) { 3266 /* 3267 * Router turned to host, delete all ires. 3268 * XXX Just delete the entry, but we need to add too. 3269 */ 3270 nce->nce_flags &= ~NCE_F_ISROUTER; 3271 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 3272 ndp_delete(nce); 3273 NCE_REFRELE(nce); 3274 return (0); 3275 } 3276 mutex_exit(&ipst->ips_ndp6->ndp_g_lock); 3277 3278 mutex_enter(&nce->nce_lock); 3279 nce->nce_flags = new_flags; 3280 mutex_exit(&nce->nce_lock); 3281 /* 3282 * Note that we ignore the state at this point, which 3283 * should be either STALE or REACHABLE. Instead we let 3284 * the link layer address passed in to determine the state 3285 * much like incoming packets. 3286 */ 3287 ndp_process(nce, (uchar_t *)lnr->lnr_hdw_addr, 0, B_FALSE); 3288 NCE_REFRELE(nce); 3289 return (0); 3290 } 3291 3292 /* 3293 * If the device driver supports it, we make nce_fp_mp to have 3294 * an M_DATA prepend. Otherwise nce_fp_mp will be null. 3295 * The caller insures there is hold on nce for this function. 3296 * Note that since ill_fastpath_probe() copies the mblk there is 3297 * no need for the hold beyond this function. 3298 */ 3299 void 3300 nce_fastpath(nce_t *nce) 3301 { 3302 ill_t *ill = nce->nce_ill; 3303 int res; 3304 3305 ASSERT(ill != NULL); 3306 if ((nce->nce_fp_mp != NULL) || 3307 !(ire_nce_valid_dlureq_mp(nce->nce_res_mp))) { 3308 /* 3309 * Already contains fastpath info or nce is not 3310 * resolved, so cant process fastpath yet. 3311 */ 3312 return; 3313 } 3314 if (nce->nce_res_mp != NULL) { 3315 nce_fastpath_list_add(nce); 3316 res = ill_fastpath_probe(ill, nce->nce_res_mp); 3317 /* 3318 * EAGAIN is an indication of a transient error 3319 * i.e. allocation failure etc. leave the nce in the list it 3320 * will be updated when another probe happens for another ire 3321 * if not it will be taken out of the list when the ire is 3322 * deleted. 3323 */ 3324 3325 if (res != 0 && res != EAGAIN) 3326 nce_fastpath_list_delete(nce); 3327 } 3328 } 3329 3330 /* 3331 * Drain the list of nce's waiting for fastpath response. 3332 */ 3333 void 3334 nce_fastpath_list_dispatch(ill_t *ill, boolean_t (*func)(nce_t *, void *), 3335 void *arg) 3336 { 3337 3338 nce_t *next_nce; 3339 nce_t *current_nce; 3340 nce_t *first_nce; 3341 nce_t *prev_nce = NULL; 3342 3343 mutex_enter(&ill->ill_lock); 3344 first_nce = current_nce = (nce_t *)ill->ill_fastpath_list; 3345 while (current_nce != (nce_t *)&ill->ill_fastpath_list) { 3346 next_nce = current_nce->nce_fastpath; 3347 /* 3348 * Take it off the list if we're flushing, or if the callback 3349 * routine tells us to do so. Otherwise, leave the nce in the 3350 * fastpath list to handle any pending response from the lower 3351 * layer. We can't drain the list when the callback routine 3352 * comparison failed, because the response is asynchronous in 3353 * nature, and may not arrive in the same order as the list 3354 * insertion. 3355 */ 3356 if (func == NULL || func(current_nce, arg)) { 3357 current_nce->nce_fastpath = NULL; 3358 if (current_nce == first_nce) 3359 ill->ill_fastpath_list = first_nce = next_nce; 3360 else 3361 prev_nce->nce_fastpath = next_nce; 3362 } else { 3363 /* previous element that is still in the list */ 3364 prev_nce = current_nce; 3365 } 3366 current_nce = next_nce; 3367 } 3368 mutex_exit(&ill->ill_lock); 3369 } 3370 3371 /* 3372 * Add nce to the nce fastpath list. 3373 */ 3374 void 3375 nce_fastpath_list_add(nce_t *nce) 3376 { 3377 ill_t *ill; 3378 3379 ill = nce->nce_ill; 3380 3381 mutex_enter(&ill->ill_lock); 3382 mutex_enter(&nce->nce_lock); 3383 3384 /* 3385 * if nce has not been deleted and 3386 * is not already in the list add it. 3387 */ 3388 if (!(nce->nce_flags & NCE_F_CONDEMNED) && 3389 (nce->nce_fastpath == NULL)) { 3390 nce->nce_fastpath = (nce_t *)ill->ill_fastpath_list; 3391 ill->ill_fastpath_list = nce; 3392 } 3393 3394 mutex_exit(&nce->nce_lock); 3395 mutex_exit(&ill->ill_lock); 3396 } 3397 3398 /* 3399 * remove nce from the nce fastpath list. 3400 */ 3401 void 3402 nce_fastpath_list_delete(nce_t *nce) 3403 { 3404 nce_t *nce_ptr; 3405 3406 ill_t *ill; 3407 3408 ill = nce->nce_ill; 3409 ASSERT(ill != NULL); 3410 3411 mutex_enter(&ill->ill_lock); 3412 if (nce->nce_fastpath == NULL) 3413 goto done; 3414 3415 ASSERT(ill->ill_fastpath_list != &ill->ill_fastpath_list); 3416 3417 if (ill->ill_fastpath_list == nce) { 3418 ill->ill_fastpath_list = nce->nce_fastpath; 3419 } else { 3420 nce_ptr = ill->ill_fastpath_list; 3421 while (nce_ptr != (nce_t *)&ill->ill_fastpath_list) { 3422 if (nce_ptr->nce_fastpath == nce) { 3423 nce_ptr->nce_fastpath = nce->nce_fastpath; 3424 break; 3425 } 3426 nce_ptr = nce_ptr->nce_fastpath; 3427 } 3428 } 3429 3430 nce->nce_fastpath = NULL; 3431 done: 3432 mutex_exit(&ill->ill_lock); 3433 } 3434 3435 /* 3436 * Update all NCE's that are not in fastpath mode and 3437 * have an nce_fp_mp that matches mp. mp->b_cont contains 3438 * the fastpath header. 3439 * 3440 * Returns TRUE if entry should be dequeued, or FALSE otherwise. 3441 */ 3442 boolean_t 3443 ndp_fastpath_update(nce_t *nce, void *arg) 3444 { 3445 mblk_t *mp, *fp_mp; 3446 uchar_t *mp_rptr, *ud_mp_rptr; 3447 mblk_t *ud_mp = nce->nce_res_mp; 3448 ptrdiff_t cmplen; 3449 3450 if (nce->nce_flags & NCE_F_MAPPING) 3451 return (B_TRUE); 3452 if ((nce->nce_fp_mp != NULL) || (ud_mp == NULL)) 3453 return (B_TRUE); 3454 3455 ip2dbg(("ndp_fastpath_update: trying\n")); 3456 mp = (mblk_t *)arg; 3457 mp_rptr = mp->b_rptr; 3458 cmplen = mp->b_wptr - mp_rptr; 3459 ASSERT(cmplen >= 0); 3460 ud_mp_rptr = ud_mp->b_rptr; 3461 /* 3462 * The nce is locked here to prevent any other threads 3463 * from accessing and changing nce_res_mp when the IPv6 address 3464 * becomes resolved to an lla while we're in the middle 3465 * of looking at and comparing the hardware address (lla). 3466 * It is also locked to prevent multiple threads in nce_fastpath_update 3467 * from examining nce_res_mp atthe same time. 3468 */ 3469 mutex_enter(&nce->nce_lock); 3470 if (ud_mp->b_wptr - ud_mp_rptr != cmplen || 3471 bcmp((char *)mp_rptr, (char *)ud_mp_rptr, cmplen) != 0) { 3472 mutex_exit(&nce->nce_lock); 3473 /* 3474 * Don't take the ire off the fastpath list yet, 3475 * since the response may come later. 3476 */ 3477 return (B_FALSE); 3478 } 3479 /* Matched - install mp as the fastpath mp */ 3480 ip1dbg(("ndp_fastpath_update: match\n")); 3481 fp_mp = dupb(mp->b_cont); 3482 if (fp_mp != NULL) { 3483 nce->nce_fp_mp = fp_mp; 3484 } 3485 mutex_exit(&nce->nce_lock); 3486 return (B_TRUE); 3487 } 3488 3489 /* 3490 * This function handles the DL_NOTE_FASTPATH_FLUSH notification from 3491 * driver. Note that it assumes IP is exclusive... 3492 */ 3493 /* ARGSUSED */ 3494 void 3495 ndp_fastpath_flush(nce_t *nce, char *arg) 3496 { 3497 if (nce->nce_flags & NCE_F_MAPPING) 3498 return; 3499 /* No fastpath info? */ 3500 if (nce->nce_fp_mp == NULL || nce->nce_res_mp == NULL) 3501 return; 3502 3503 if (nce->nce_ipversion == IPV4_VERSION && 3504 nce->nce_flags & NCE_F_BCAST) { 3505 /* 3506 * IPv4 BROADCAST entries: 3507 * We can't delete the nce since it is difficult to 3508 * recreate these without going through the 3509 * ipif down/up dance. 3510 * 3511 * All access to nce->nce_fp_mp in the case of these 3512 * is protected by nce_lock. 3513 */ 3514 mutex_enter(&nce->nce_lock); 3515 if (nce->nce_fp_mp != NULL) { 3516 freeb(nce->nce_fp_mp); 3517 nce->nce_fp_mp = NULL; 3518 mutex_exit(&nce->nce_lock); 3519 nce_fastpath(nce); 3520 } else { 3521 mutex_exit(&nce->nce_lock); 3522 } 3523 } else { 3524 /* Just delete the NCE... */ 3525 ndp_delete(nce); 3526 } 3527 } 3528 3529 /* 3530 * Return a pointer to a given option in the packet. 3531 * Assumes that option part of the packet have already been validated. 3532 */ 3533 nd_opt_hdr_t * 3534 ndp_get_option(nd_opt_hdr_t *opt, int optlen, int opt_type) 3535 { 3536 while (optlen > 0) { 3537 if (opt->nd_opt_type == opt_type) 3538 return (opt); 3539 optlen -= 8 * opt->nd_opt_len; 3540 opt = (struct nd_opt_hdr *)((char *)opt + 8 * opt->nd_opt_len); 3541 } 3542 return (NULL); 3543 } 3544 3545 /* 3546 * Verify all option lengths present are > 0, also check to see 3547 * if the option lengths and packet length are consistent. 3548 */ 3549 boolean_t 3550 ndp_verify_optlen(nd_opt_hdr_t *opt, int optlen) 3551 { 3552 ASSERT(opt != NULL); 3553 while (optlen > 0) { 3554 if (opt->nd_opt_len == 0) 3555 return (B_FALSE); 3556 optlen -= 8 * opt->nd_opt_len; 3557 if (optlen < 0) 3558 return (B_FALSE); 3559 opt = (struct nd_opt_hdr *)((char *)opt + 8 * opt->nd_opt_len); 3560 } 3561 return (B_TRUE); 3562 } 3563 3564 /* 3565 * ndp_walk function. 3566 * Free a fraction of the NCE cache entries. 3567 * A fraction of zero means to not free any in that category. 3568 */ 3569 void 3570 ndp_cache_reclaim(nce_t *nce, char *arg) 3571 { 3572 nce_cache_reclaim_t *ncr = (nce_cache_reclaim_t *)arg; 3573 uint_t rand; 3574 3575 if (nce->nce_flags & NCE_F_PERMANENT) 3576 return; 3577 3578 rand = (uint_t)lbolt + 3579 NCE_ADDR_HASH_V6(nce->nce_addr, NCE_TABLE_SIZE); 3580 if (ncr->ncr_host != 0 && 3581 (rand/ncr->ncr_host)*ncr->ncr_host == rand) { 3582 ndp_delete(nce); 3583 return; 3584 } 3585 } 3586 3587 /* 3588 * ndp_walk function. 3589 * Count the number of NCEs that can be deleted. 3590 * These would be hosts but not routers. 3591 */ 3592 void 3593 ndp_cache_count(nce_t *nce, char *arg) 3594 { 3595 ncc_cache_count_t *ncc = (ncc_cache_count_t *)arg; 3596 3597 if (nce->nce_flags & NCE_F_PERMANENT) 3598 return; 3599 3600 ncc->ncc_total++; 3601 if (!(nce->nce_flags & NCE_F_ISROUTER)) 3602 ncc->ncc_host++; 3603 } 3604 3605 #ifdef NCE_DEBUG 3606 th_trace_t * 3607 th_trace_nce_lookup(nce_t *nce) 3608 { 3609 int bucket_id; 3610 th_trace_t *th_trace; 3611 3612 ASSERT(MUTEX_HELD(&nce->nce_lock)); 3613 3614 bucket_id = IP_TR_HASH(curthread); 3615 ASSERT(bucket_id < IP_TR_HASH_MAX); 3616 3617 for (th_trace = nce->nce_trace[bucket_id]; th_trace != NULL; 3618 th_trace = th_trace->th_next) { 3619 if (th_trace->th_id == curthread) 3620 return (th_trace); 3621 } 3622 return (NULL); 3623 } 3624 3625 void 3626 nce_trace_ref(nce_t *nce) 3627 { 3628 int bucket_id; 3629 th_trace_t *th_trace; 3630 3631 /* 3632 * Attempt to locate the trace buffer for the curthread. 3633 * If it does not exist, then allocate a new trace buffer 3634 * and link it in list of trace bufs for this ipif, at the head 3635 */ 3636 ASSERT(MUTEX_HELD(&nce->nce_lock)); 3637 3638 if (nce->nce_trace_disable == B_TRUE) 3639 return; 3640 3641 th_trace = th_trace_nce_lookup(nce); 3642 if (th_trace == NULL) { 3643 bucket_id = IP_TR_HASH(curthread); 3644 th_trace = (th_trace_t *)kmem_zalloc(sizeof (th_trace_t), 3645 KM_NOSLEEP); 3646 if (th_trace == NULL) { 3647 nce->nce_trace_disable = B_TRUE; 3648 nce_trace_inactive(nce); 3649 return; 3650 } 3651 th_trace->th_id = curthread; 3652 th_trace->th_next = nce->nce_trace[bucket_id]; 3653 th_trace->th_prev = &nce->nce_trace[bucket_id]; 3654 if (th_trace->th_next != NULL) 3655 th_trace->th_next->th_prev = &th_trace->th_next; 3656 nce->nce_trace[bucket_id] = th_trace; 3657 } 3658 ASSERT(th_trace->th_refcnt < TR_BUF_MAX - 1); 3659 th_trace->th_refcnt++; 3660 th_trace_rrecord(th_trace); 3661 } 3662 3663 void 3664 nce_untrace_ref(nce_t *nce) 3665 { 3666 th_trace_t *th_trace; 3667 3668 ASSERT(MUTEX_HELD(&nce->nce_lock)); 3669 3670 if (nce->nce_trace_disable == B_TRUE) 3671 return; 3672 3673 th_trace = th_trace_nce_lookup(nce); 3674 ASSERT(th_trace != NULL && th_trace->th_refcnt > 0); 3675 3676 th_trace_rrecord(th_trace); 3677 th_trace->th_refcnt--; 3678 } 3679 3680 void 3681 nce_trace_inactive(nce_t *nce) 3682 { 3683 th_trace_t *th_trace; 3684 int i; 3685 3686 ASSERT(MUTEX_HELD(&nce->nce_lock)); 3687 3688 for (i = 0; i < IP_TR_HASH_MAX; i++) { 3689 while (nce->nce_trace[i] != NULL) { 3690 th_trace = nce->nce_trace[i]; 3691 3692 /* unlink th_trace and free it */ 3693 nce->nce_trace[i] = th_trace->th_next; 3694 if (th_trace->th_next != NULL) 3695 th_trace->th_next->th_prev = 3696 &nce->nce_trace[i]; 3697 3698 th_trace->th_next = NULL; 3699 th_trace->th_prev = NULL; 3700 kmem_free(th_trace, sizeof (th_trace_t)); 3701 } 3702 } 3703 3704 } 3705 3706 /* ARGSUSED */ 3707 int 3708 nce_thread_exit(nce_t *nce, caddr_t arg) 3709 { 3710 th_trace_t *th_trace; 3711 uint64_t now; 3712 3713 mutex_enter(&nce->nce_lock); 3714 if (nce->nce_state == ND_INITIAL) { 3715 3716 now = TICK_TO_MSEC(lbolt64); 3717 if (now - nce->nce_init_time > 120000) { 3718 DTRACE_PROBE1(nce__stuck, nce_t *, nce); 3719 } 3720 } 3721 th_trace = th_trace_nce_lookup(nce); 3722 3723 if (th_trace == NULL) { 3724 mutex_exit(&nce->nce_lock); 3725 return (0); 3726 } 3727 3728 ASSERT(th_trace->th_refcnt == 0); 3729 3730 /* unlink th_trace and free it */ 3731 *th_trace->th_prev = th_trace->th_next; 3732 if (th_trace->th_next != NULL) 3733 th_trace->th_next->th_prev = th_trace->th_prev; 3734 th_trace->th_next = NULL; 3735 th_trace->th_prev = NULL; 3736 kmem_free(th_trace, sizeof (th_trace_t)); 3737 mutex_exit(&nce->nce_lock); 3738 return (0); 3739 } 3740 #endif 3741 3742 /* 3743 * Called when address resolution fails due to a timeout. 3744 * Send an ICMP unreachable in response to all queued packets. 3745 */ 3746 void 3747 arp_resolv_failed(nce_t *nce) 3748 { 3749 mblk_t *mp, *nxt_mp, *first_mp; 3750 char buf[INET6_ADDRSTRLEN]; 3751 zoneid_t zoneid = GLOBAL_ZONEID; 3752 struct in_addr ipv4addr; 3753 ip_stack_t *ipst = nce->nce_ill->ill_ipst; 3754 3755 IN6_V4MAPPED_TO_INADDR(&nce->nce_addr, &ipv4addr); 3756 ip3dbg(("arp_resolv_failed: dst %s\n", 3757 inet_ntop(AF_INET, &ipv4addr, buf, sizeof (buf)))); 3758 mutex_enter(&nce->nce_lock); 3759 mp = nce->nce_qd_mp; 3760 nce->nce_qd_mp = NULL; 3761 mutex_exit(&nce->nce_lock); 3762 3763 while (mp != NULL) { 3764 nxt_mp = mp->b_next; 3765 mp->b_next = NULL; 3766 mp->b_prev = NULL; 3767 3768 first_mp = mp; 3769 /* 3770 * Send icmp unreachable messages 3771 * to the hosts. 3772 */ 3773 (void) ip_hdr_complete((ipha_t *)mp->b_rptr, zoneid, ipst); 3774 ip3dbg(("arp_resolv_failed: Calling icmp_unreachable\n")); 3775 icmp_unreachable(nce->nce_ill->ill_wq, first_mp, 3776 ICMP_HOST_UNREACHABLE, zoneid, ipst); 3777 mp = nxt_mp; 3778 } 3779 } 3780 3781 static int 3782 ndp_lookup_then_add_v4(ill_t *ill, uchar_t *hw_addr, const in_addr_t *addr, 3783 const in_addr_t *mask, const in_addr_t *extract_mask, 3784 uint32_t hw_extract_start, uint16_t flags, uint16_t state, 3785 nce_t **newnce, mblk_t *fp_mp, mblk_t *res_mp) 3786 { 3787 int err = 0; 3788 nce_t *nce; 3789 in6_addr_t addr6; 3790 ip_stack_t *ipst = ill->ill_ipst; 3791 3792 mutex_enter(&ipst->ips_ndp4->ndp_g_lock); 3793 nce = *((nce_t **)NCE_HASH_PTR_V4(ipst, *addr)); 3794 IN6_IPADDR_TO_V4MAPPED(*addr, &addr6); 3795 nce = nce_lookup_addr(ill, &addr6, nce); 3796 if (nce == NULL) { 3797 err = ndp_add_v4(ill, 3798 hw_addr, 3799 addr, 3800 mask, 3801 extract_mask, 3802 hw_extract_start, 3803 flags, 3804 state, 3805 newnce, 3806 fp_mp, 3807 res_mp); 3808 } else { 3809 *newnce = nce; 3810 err = EEXIST; 3811 } 3812 mutex_exit(&ipst->ips_ndp4->ndp_g_lock); 3813 return (err); 3814 } 3815 3816 /* 3817 * NDP Cache Entry creation routine for IPv4. 3818 * Mapped entries are handled in arp. 3819 * This routine must always be called with ndp4->ndp_g_lock held. 3820 * Prior to return, nce_refcnt is incremented. 3821 */ 3822 static int 3823 ndp_add_v4(ill_t *ill, uchar_t *hw_addr, const in_addr_t *addr, 3824 const in_addr_t *mask, const in_addr_t *extract_mask, 3825 uint32_t hw_extract_start, uint16_t flags, uint16_t state, 3826 nce_t **newnce, mblk_t *fp_mp, mblk_t *res_mp) 3827 { 3828 static nce_t nce_nil; 3829 nce_t *nce; 3830 mblk_t *mp; 3831 mblk_t *template; 3832 nce_t **ncep; 3833 ip_stack_t *ipst = ill->ill_ipst; 3834 3835 ASSERT(MUTEX_HELD(&ipst->ips_ndp4->ndp_g_lock)); 3836 ASSERT(ill != NULL); 3837 if ((flags & ~NCE_EXTERNAL_FLAGS_MASK)) { 3838 return (EINVAL); 3839 } 3840 ASSERT((flags & NCE_F_MAPPING) == 0); 3841 ASSERT(extract_mask == NULL); 3842 /* 3843 * Allocate the mblk to hold the nce. 3844 */ 3845 mp = allocb(sizeof (nce_t), BPRI_MED); 3846 if (mp == NULL) 3847 return (ENOMEM); 3848 3849 nce = (nce_t *)mp->b_rptr; 3850 mp->b_wptr = (uchar_t *)&nce[1]; 3851 *nce = nce_nil; 3852 3853 /* 3854 * This one holds link layer address; if res_mp has been provided 3855 * by the caller, accept it without any further checks. Otherwise, 3856 * for V4, we fill it up with ill_resolver_mp here, then in 3857 * in ire_arpresolve(), we fill it up with the ARP query 3858 * once its formulated. 3859 */ 3860 if (res_mp != NULL) { 3861 template = res_mp; 3862 } else { 3863 if (ill->ill_resolver_mp == NULL) { 3864 freeb(mp); 3865 return (EINVAL); 3866 } 3867 template = copyb(ill->ill_resolver_mp); 3868 } 3869 if (template == NULL) { 3870 freeb(mp); 3871 return (ENOMEM); 3872 } 3873 nce->nce_ill = ill; 3874 nce->nce_ipversion = IPV4_VERSION; 3875 nce->nce_flags = flags; 3876 nce->nce_state = state; 3877 nce->nce_pcnt = ND_MAX_UNICAST_SOLICIT; 3878 nce->nce_rcnt = ill->ill_xmit_count; 3879 IN6_IPADDR_TO_V4MAPPED(*addr, &nce->nce_addr); 3880 if (*mask == IP_HOST_MASK) { 3881 nce->nce_mask = ipv6_all_ones; 3882 } else { 3883 IN6_IPADDR_TO_V4MAPPED(*mask, &nce->nce_mask); 3884 } 3885 nce->nce_extract_mask = ipv6_all_zeros; 3886 nce->nce_ll_extract_start = hw_extract_start; 3887 nce->nce_fp_mp = (fp_mp? fp_mp : NULL); 3888 nce->nce_res_mp = template; 3889 if (state == ND_REACHABLE) { 3890 nce->nce_last = TICK_TO_MSEC(lbolt64); 3891 } else { 3892 nce->nce_last = 0; 3893 if (state == ND_INITIAL) 3894 nce->nce_init_time = TICK_TO_MSEC(lbolt64); 3895 } 3896 nce->nce_qd_mp = NULL; 3897 nce->nce_mp = mp; 3898 if (hw_addr != NULL) 3899 nce_set_ll(nce, hw_addr); 3900 /* This one is for nce getting created */ 3901 nce->nce_refcnt = 1; 3902 mutex_init(&nce->nce_lock, NULL, MUTEX_DEFAULT, NULL); 3903 ncep = ((nce_t **)NCE_HASH_PTR_V4(ipst, *addr)); 3904 3905 #ifdef NCE_DEBUG 3906 bzero(nce->nce_trace, sizeof (th_trace_t *) * IP_TR_HASH_MAX); 3907 #endif 3908 /* 3909 * Atomically ensure that the ill is not CONDEMNED, before 3910 * adding the NCE. 3911 */ 3912 mutex_enter(&ill->ill_lock); 3913 if (ill->ill_state_flags & ILL_CONDEMNED) { 3914 mutex_exit(&ill->ill_lock); 3915 freeb(mp); 3916 if (res_mp == NULL) { 3917 /* 3918 * template was locally allocated. need to free it. 3919 */ 3920 freeb(template); 3921 } 3922 return (EINVAL); 3923 } 3924 if ((nce->nce_next = *ncep) != NULL) 3925 nce->nce_next->nce_ptpn = &nce->nce_next; 3926 *ncep = nce; 3927 nce->nce_ptpn = ncep; 3928 *newnce = nce; 3929 /* This one is for nce being used by an active thread */ 3930 NCE_REFHOLD(*newnce); 3931 3932 /* Bump up the number of nce's referencing this ill */ 3933 ill->ill_nce_cnt++; 3934 mutex_exit(&ill->ill_lock); 3935 return (0); 3936 } 3937 3938 void 3939 ndp_flush_qd_mp(nce_t *nce) 3940 { 3941 mblk_t *qd_mp, *qd_next; 3942 3943 ASSERT(MUTEX_HELD(&nce->nce_lock)); 3944 qd_mp = nce->nce_qd_mp; 3945 nce->nce_qd_mp = NULL; 3946 while (qd_mp != NULL) { 3947 qd_next = qd_mp->b_next; 3948 qd_mp->b_next = NULL; 3949 qd_mp->b_prev = NULL; 3950 freemsg(qd_mp); 3951 qd_mp = qd_next; 3952 } 3953 } 3954 3955 3956 /* 3957 * ndp_walk routine to delete all entries that have a given destination or 3958 * gateway address and cached link layer (MAC) address. This is used when ARP 3959 * informs us that a network-to-link-layer mapping may have changed. 3960 */ 3961 void 3962 nce_delete_hw_changed(nce_t *nce, void *arg) 3963 { 3964 nce_hw_map_t *hwm = arg; 3965 mblk_t *mp; 3966 dl_unitdata_req_t *dlu; 3967 uchar_t *macaddr; 3968 ill_t *ill; 3969 int saplen; 3970 ipaddr_t nce_addr; 3971 3972 if (nce->nce_state != ND_REACHABLE) 3973 return; 3974 3975 IN6_V4MAPPED_TO_IPADDR(&nce->nce_addr, nce_addr); 3976 if (nce_addr != hwm->hwm_addr) 3977 return; 3978 3979 mutex_enter(&nce->nce_lock); 3980 if ((mp = nce->nce_res_mp) == NULL) { 3981 mutex_exit(&nce->nce_lock); 3982 return; 3983 } 3984 dlu = (dl_unitdata_req_t *)mp->b_rptr; 3985 macaddr = (uchar_t *)(dlu + 1); 3986 ill = nce->nce_ill; 3987 if ((saplen = ill->ill_sap_length) > 0) 3988 macaddr += saplen; 3989 else 3990 saplen = -saplen; 3991 3992 /* 3993 * If the hardware address is unchanged, then leave this one alone. 3994 * Note that saplen == abs(saplen) now. 3995 */ 3996 if (hwm->hwm_hwlen == dlu->dl_dest_addr_length - saplen && 3997 bcmp(hwm->hwm_hwaddr, macaddr, hwm->hwm_hwlen) == 0) { 3998 mutex_exit(&nce->nce_lock); 3999 return; 4000 } 4001 mutex_exit(&nce->nce_lock); 4002 4003 DTRACE_PROBE1(nce__hw__deleted, nce_t *, nce); 4004 ndp_delete(nce); 4005 } 4006 4007 /* 4008 * This function verifies whether a given IPv4 address is potentially known to 4009 * the NCE subsystem. If so, then ARP must not delete the corresponding ace_t, 4010 * so that it can continue to look for hardware changes on that address. 4011 */ 4012 boolean_t 4013 ndp_lookup_ipaddr(in_addr_t addr, netstack_t *ns) 4014 { 4015 nce_t *nce; 4016 struct in_addr nceaddr; 4017 ip_stack_t *ipst = ns->netstack_ip; 4018 4019 if (addr == INADDR_ANY) 4020 return (B_FALSE); 4021 4022 mutex_enter(&ipst->ips_ndp4->ndp_g_lock); 4023 nce = *(nce_t **)NCE_HASH_PTR_V4(ipst, addr); 4024 for (; nce != NULL; nce = nce->nce_next) { 4025 /* Note that only v4 mapped entries are in the table. */ 4026 IN6_V4MAPPED_TO_INADDR(&nce->nce_addr, &nceaddr); 4027 if (addr == nceaddr.s_addr && 4028 IN6_ARE_ADDR_EQUAL(&nce->nce_mask, &ipv6_all_ones)) { 4029 /* Single flag check; no lock needed */ 4030 if (!(nce->nce_flags & NCE_F_CONDEMNED)) 4031 break; 4032 } 4033 } 4034 mutex_exit(&ipst->ips_ndp4->ndp_g_lock); 4035 return (nce != NULL); 4036 } 4037