10Sstevel@tonic-gate /* 20Sstevel@tonic-gate * CDDL HEADER START 30Sstevel@tonic-gate * 40Sstevel@tonic-gate * The contents of this file are subject to the terms of the 51676Sjpk * Common Development and Distribution License (the "License"). 61676Sjpk * You may not use this file except in compliance with the License. 70Sstevel@tonic-gate * 80Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 90Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing. 100Sstevel@tonic-gate * See the License for the specific language governing permissions 110Sstevel@tonic-gate * and limitations under the License. 120Sstevel@tonic-gate * 130Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each 140Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 150Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the 160Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying 170Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner] 180Sstevel@tonic-gate * 190Sstevel@tonic-gate * CDDL HEADER END 200Sstevel@tonic-gate */ 210Sstevel@tonic-gate /* 223448Sdh155122 * Copyright 2007 Sun Microsystems, Inc. All rights reserved. 230Sstevel@tonic-gate * Use is subject to license terms. 240Sstevel@tonic-gate */ 250Sstevel@tonic-gate 260Sstevel@tonic-gate #pragma ident "%Z%%M% %I% %E% SMI" 270Sstevel@tonic-gate 280Sstevel@tonic-gate #include <sys/types.h> 290Sstevel@tonic-gate #include <sys/systm.h> 300Sstevel@tonic-gate #include <sys/stream.h> 314311Svi117747 #include <sys/cmn_err.h> 320Sstevel@tonic-gate #include <sys/ddi.h> 330Sstevel@tonic-gate #include <sys/sunddi.h> 340Sstevel@tonic-gate #include <sys/kmem.h> 350Sstevel@tonic-gate #include <sys/socket.h> 360Sstevel@tonic-gate #include <sys/sysmacros.h> 370Sstevel@tonic-gate #include <sys/list.h> 380Sstevel@tonic-gate 390Sstevel@tonic-gate #include <netinet/in.h> 400Sstevel@tonic-gate #include <netinet/ip6.h> 410Sstevel@tonic-gate #include <netinet/sctp.h> 420Sstevel@tonic-gate 430Sstevel@tonic-gate #include <inet/common.h> 440Sstevel@tonic-gate #include <inet/ip.h> 450Sstevel@tonic-gate #include <inet/ip6.h> 460Sstevel@tonic-gate #include <inet/ip_if.h> 470Sstevel@tonic-gate #include <inet/ipclassifier.h> 480Sstevel@tonic-gate #include <inet/sctp_ip.h> 490Sstevel@tonic-gate #include "sctp_impl.h" 500Sstevel@tonic-gate #include "sctp_addr.h" 510Sstevel@tonic-gate 520Sstevel@tonic-gate static void sctp_ipif_inactive(sctp_ipif_t *); 530Sstevel@tonic-gate static sctp_ipif_t *sctp_lookup_ipif_addr(in6_addr_t *, boolean_t, 543510Svi117747 zoneid_t, boolean_t, uint_t, uint_t, boolean_t, 553510Svi117747 sctp_stack_t *); 560Sstevel@tonic-gate static int sctp_get_all_ipifs(sctp_t *, int); 57432Svi117747 static int sctp_ipif_hash_insert(sctp_t *, sctp_ipif_t *, int, 583510Svi117747 boolean_t, boolean_t); 590Sstevel@tonic-gate static void sctp_ipif_hash_remove(sctp_t *, sctp_ipif_t *); 604818Skcpoon static void sctp_fix_saddr(sctp_t *, in6_addr_t *); 610Sstevel@tonic-gate static int sctp_compare_ipif_list(sctp_ipif_hash_t *, 620Sstevel@tonic-gate sctp_ipif_hash_t *); 630Sstevel@tonic-gate static int sctp_copy_ipifs(sctp_ipif_hash_t *, sctp_t *, int); 64432Svi117747 653510Svi117747 #define SCTP_ADDR4_HASH(addr) \ 663510Svi117747 (((addr) ^ ((addr) >> 8) ^ ((addr) >> 16) ^ ((addr) >> 24)) & \ 673510Svi117747 (SCTP_IPIF_HASH - 1)) 683510Svi117747 693510Svi117747 #define SCTP_ADDR6_HASH(addr) \ 703510Svi117747 (((addr).s6_addr32[3] ^ \ 713510Svi117747 (((addr).s6_addr32[3] ^ (addr).s6_addr32[2]) >> 12)) & \ 723510Svi117747 (SCTP_IPIF_HASH - 1)) 733510Svi117747 743510Svi117747 #define SCTP_IPIF_ADDR_HASH(addr, isv6) \ 753510Svi117747 ((isv6) ? SCTP_ADDR6_HASH((addr)) : \ 763510Svi117747 SCTP_ADDR4_HASH((addr)._S6_un._S6_u32[3])) 773510Svi117747 780Sstevel@tonic-gate #define SCTP_IPIF_USABLE(sctp_ipif_state) \ 790Sstevel@tonic-gate ((sctp_ipif_state) == SCTP_IPIFS_UP || \ 80432Svi117747 (sctp_ipif_state) == SCTP_IPIFS_DOWN) 81432Svi117747 82432Svi117747 #define SCTP_IPIF_DISCARD(sctp_ipif_flags) \ 83432Svi117747 ((sctp_ipif_flags) & (IPIF_PRIVATE | IPIF_DEPRECATED)) 84432Svi117747 85852Svi117747 #define SCTP_IS_IPIF_LOOPBACK(ipif) \ 86852Svi117747 ((ipif)->sctp_ipif_ill->sctp_ill_flags & PHYI_LOOPBACK) 87852Svi117747 88852Svi117747 #define SCTP_IS_IPIF_LINKLOCAL(ipif) \ 89852Svi117747 ((ipif)->sctp_ipif_isv6 && \ 90852Svi117747 IN6_IS_ADDR_LINKLOCAL(&(ipif)->sctp_ipif_saddr)) 91432Svi117747 92432Svi117747 #define SCTP_UNSUPP_AF(ipif, supp_af) \ 93432Svi117747 ((!(ipif)->sctp_ipif_isv6 && !((supp_af) & PARM_SUPP_V4)) || \ 94432Svi117747 ((ipif)->sctp_ipif_isv6 && !((supp_af) & PARM_SUPP_V6))) 950Sstevel@tonic-gate 962263Ssommerfe #define SCTP_IPIF_ZONE_MATCH(sctp, ipif) \ 972263Ssommerfe IPCL_ZONE_MATCH((sctp)->sctp_connp, (ipif)->sctp_ipif_zoneid) 982263Ssommerfe 990Sstevel@tonic-gate #define SCTP_ILL_HASH_FN(index) ((index) % SCTP_ILL_HASH) 1000Sstevel@tonic-gate #define SCTP_ILL_TO_PHYINDEX(ill) ((ill)->ill_phyint->phyint_ifindex) 1010Sstevel@tonic-gate 1020Sstevel@tonic-gate /* 1030Sstevel@tonic-gate * SCTP Interface list manipulation functions, locking used. 1040Sstevel@tonic-gate */ 1050Sstevel@tonic-gate 1060Sstevel@tonic-gate /* 1070Sstevel@tonic-gate * Delete an SCTP IPIF from the list if the refcount goes to 0 and it is 1080Sstevel@tonic-gate * marked as condemned. Also, check if the ILL needs to go away. 1090Sstevel@tonic-gate */ 1100Sstevel@tonic-gate static void 1110Sstevel@tonic-gate sctp_ipif_inactive(sctp_ipif_t *sctp_ipif) 1120Sstevel@tonic-gate { 1130Sstevel@tonic-gate sctp_ill_t *sctp_ill; 1143510Svi117747 uint_t hindex; 1150Sstevel@tonic-gate uint_t ill_index; 1163448Sdh155122 sctp_stack_t *sctps = sctp_ipif->sctp_ipif_ill-> 1173448Sdh155122 sctp_ill_netstack->netstack_sctp; 1180Sstevel@tonic-gate 1193448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 1203448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_WRITER); 1210Sstevel@tonic-gate 1223510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(sctp_ipif->sctp_ipif_saddr, 1233510Svi117747 sctp_ipif->sctp_ipif_isv6); 1243510Svi117747 1250Sstevel@tonic-gate sctp_ill = sctp_ipif->sctp_ipif_ill; 1260Sstevel@tonic-gate ASSERT(sctp_ill != NULL); 1270Sstevel@tonic-gate ill_index = SCTP_ILL_HASH_FN(sctp_ill->sctp_ill_index); 1280Sstevel@tonic-gate if (sctp_ipif->sctp_ipif_state != SCTP_IPIFS_CONDEMNED || 1290Sstevel@tonic-gate sctp_ipif->sctp_ipif_refcnt != 0) { 1303448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 1313448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 1320Sstevel@tonic-gate return; 1330Sstevel@tonic-gate } 1343510Svi117747 list_remove(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 1353448Sdh155122 sctp_ipif); 1363510Svi117747 sctps->sctps_g_ipifs[hindex].ipif_count--; 1373448Sdh155122 sctps->sctps_g_ipifs_count--; 1380Sstevel@tonic-gate rw_destroy(&sctp_ipif->sctp_ipif_lock); 1390Sstevel@tonic-gate kmem_free(sctp_ipif, sizeof (sctp_ipif_t)); 1400Sstevel@tonic-gate 1410Sstevel@tonic-gate (void) atomic_add_32_nv(&sctp_ill->sctp_ill_ipifcnt, -1); 1423448Sdh155122 if (rw_tryupgrade(&sctps->sctps_g_ills_lock) != 0) { 1433448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 1440Sstevel@tonic-gate if (sctp_ill->sctp_ill_ipifcnt == 0 && 1450Sstevel@tonic-gate sctp_ill->sctp_ill_state == SCTP_ILLS_CONDEMNED) { 1463448Sdh155122 list_remove(&sctps->sctps_g_ills[ill_index]. 1473448Sdh155122 sctp_ill_list, (void *)sctp_ill); 1483448Sdh155122 sctps->sctps_g_ills[ill_index].ill_count--; 1493448Sdh155122 sctps->sctps_ills_count--; 1500Sstevel@tonic-gate kmem_free(sctp_ill->sctp_ill_name, 1510Sstevel@tonic-gate sctp_ill->sctp_ill_name_length); 1520Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 1530Sstevel@tonic-gate } 1540Sstevel@tonic-gate } 1553448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 1563448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 1570Sstevel@tonic-gate } 1580Sstevel@tonic-gate 1590Sstevel@tonic-gate /* 1600Sstevel@tonic-gate * Lookup an SCTP IPIF given an IP address. Increments sctp_ipif refcnt. 1613510Svi117747 * We are either looking for a IPIF with the given address before 1623510Svi117747 * inserting it into the global list or looking for an IPIF for an 1633510Svi117747 * address given an SCTP. In the former case we always check the zoneid, 1643510Svi117747 * but for the latter case, check_zid could be B_FALSE if the connp 1653510Svi117747 * for the sctp has conn_all_zones set. When looking for an address we 1663510Svi117747 * give preference to one that is up, so even though we may find one that 1673510Svi117747 * is not up we keep looking if there is one up, we hold the down addr 1683510Svi117747 * in backup_ipif in case we don't find one that is up - i.e. we return 1693510Svi117747 * the backup_ipif in that case. Note that if we are looking for. If we 1703510Svi117747 * are specifically looking for an up address, then usable will be set 1713510Svi117747 * to true. 1720Sstevel@tonic-gate */ 1730Sstevel@tonic-gate static sctp_ipif_t * 1743510Svi117747 sctp_lookup_ipif_addr(in6_addr_t *addr, boolean_t refhold, zoneid_t zoneid, 1753510Svi117747 boolean_t check_zid, uint_t ifindex, uint_t seqid, boolean_t usable, 1763510Svi117747 sctp_stack_t *sctps) 1770Sstevel@tonic-gate { 1780Sstevel@tonic-gate int j; 1790Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 1803510Svi117747 sctp_ipif_t *backup_ipif = NULL; 1813510Svi117747 int hindex; 1820Sstevel@tonic-gate 1833510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(*addr, !IN6_IS_ADDR_V4MAPPED(addr)); 1843510Svi117747 1853448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 1863510Svi117747 if (sctps->sctps_g_ipifs[hindex].ipif_count == 0) { 1873510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 1883510Svi117747 return (NULL); 1893510Svi117747 } 1903510Svi117747 sctp_ipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 1913510Svi117747 for (j = 0; j < sctps->sctps_g_ipifs[hindex].ipif_count; j++) { 1923510Svi117747 rw_enter(&sctp_ipif->sctp_ipif_lock, RW_READER); 1933510Svi117747 if ((!check_zid || 1943510Svi117747 (sctp_ipif->sctp_ipif_zoneid == ALL_ZONES || 1953510Svi117747 zoneid == sctp_ipif->sctp_ipif_zoneid)) && 1963510Svi117747 (ifindex == 0 || ifindex == 1973510Svi117747 sctp_ipif->sctp_ipif_ill->sctp_ill_index) && 1983510Svi117747 ((seqid != 0 && seqid == sctp_ipif->sctp_ipif_id) || 1993510Svi117747 (IN6_ARE_ADDR_EQUAL(&sctp_ipif->sctp_ipif_saddr, 2003510Svi117747 addr)))) { 2013510Svi117747 if (!usable || sctp_ipif->sctp_ipif_state == 2023510Svi117747 SCTP_IPIFS_UP) { 2030Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 2040Sstevel@tonic-gate if (refhold) 2050Sstevel@tonic-gate SCTP_IPIF_REFHOLD(sctp_ipif); 2063448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2070Sstevel@tonic-gate return (sctp_ipif); 2083510Svi117747 } else if (sctp_ipif->sctp_ipif_state == 2093510Svi117747 SCTP_IPIFS_DOWN && backup_ipif == NULL) { 2103510Svi117747 backup_ipif = sctp_ipif; 2110Sstevel@tonic-gate } 2120Sstevel@tonic-gate } 2133510Svi117747 rw_exit(&sctp_ipif->sctp_ipif_lock); 2143510Svi117747 sctp_ipif = list_next( 2153510Svi117747 &sctps->sctps_g_ipifs[hindex].sctp_ipif_list, sctp_ipif); 2163510Svi117747 } 2173510Svi117747 if (backup_ipif != NULL) { 2183510Svi117747 if (refhold) 2193510Svi117747 SCTP_IPIF_REFHOLD(backup_ipif); 2203510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 2213510Svi117747 return (backup_ipif); 2220Sstevel@tonic-gate } 2233448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2240Sstevel@tonic-gate return (NULL); 2250Sstevel@tonic-gate } 2260Sstevel@tonic-gate 2270Sstevel@tonic-gate /* 2280Sstevel@tonic-gate * Populate the list with all the SCTP ipifs for a given ipversion. 2290Sstevel@tonic-gate * Increments sctp_ipif refcnt. 2300Sstevel@tonic-gate * Called with no locks held. 2310Sstevel@tonic-gate */ 2320Sstevel@tonic-gate static int 2330Sstevel@tonic-gate sctp_get_all_ipifs(sctp_t *sctp, int sleep) 2340Sstevel@tonic-gate { 2350Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 2360Sstevel@tonic-gate int i; 2370Sstevel@tonic-gate int j; 2380Sstevel@tonic-gate int error = 0; 2393448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps; 2400Sstevel@tonic-gate 2413448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 2420Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 2433448Sdh155122 if (sctps->sctps_g_ipifs[i].ipif_count == 0) 2440Sstevel@tonic-gate continue; 2453448Sdh155122 sctp_ipif = list_head(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 2463448Sdh155122 for (j = 0; j < sctps->sctps_g_ipifs[i].ipif_count; j++) { 2470Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_READER); 248432Svi117747 if (SCTP_IPIF_DISCARD(sctp_ipif->sctp_ipif_flags) || 2490Sstevel@tonic-gate !SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state) || 2502263Ssommerfe !SCTP_IPIF_ZONE_MATCH(sctp, sctp_ipif) || 2510Sstevel@tonic-gate (sctp->sctp_ipversion == IPV4_VERSION && 252432Svi117747 sctp_ipif->sctp_ipif_isv6) || 2530Sstevel@tonic-gate (sctp->sctp_connp->conn_ipv6_v6only && 254432Svi117747 !sctp_ipif->sctp_ipif_isv6)) { 2550Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 2560Sstevel@tonic-gate sctp_ipif = list_next( 2573448Sdh155122 &sctps->sctps_g_ipifs[i].sctp_ipif_list, 2583448Sdh155122 sctp_ipif); 2590Sstevel@tonic-gate continue; 2600Sstevel@tonic-gate } 2610Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 2620Sstevel@tonic-gate SCTP_IPIF_REFHOLD(sctp_ipif); 263432Svi117747 error = sctp_ipif_hash_insert(sctp, sctp_ipif, sleep, 2643510Svi117747 B_FALSE, B_FALSE); 2653510Svi117747 if (error != 0 && error != EALREADY) 2660Sstevel@tonic-gate goto free_stuff; 2673448Sdh155122 sctp_ipif = list_next( 2683448Sdh155122 &sctps->sctps_g_ipifs[i].sctp_ipif_list, 2690Sstevel@tonic-gate sctp_ipif); 2700Sstevel@tonic-gate } 2710Sstevel@tonic-gate } 2723448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2730Sstevel@tonic-gate return (0); 2740Sstevel@tonic-gate free_stuff: 2753448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2760Sstevel@tonic-gate sctp_free_saddrs(sctp); 2770Sstevel@tonic-gate return (ENOMEM); 2780Sstevel@tonic-gate } 2790Sstevel@tonic-gate 2800Sstevel@tonic-gate /* 2810Sstevel@tonic-gate * Given a list of address, fills in the list of SCTP ipifs if all the addresses 2820Sstevel@tonic-gate * are present in the SCTP interface list, return number of addresses filled 283852Svi117747 * or error. If the caller wants the list of addresses, it sends a pre-allocated 284852Svi117747 * buffer - list. Currently, this list is only used on a clustered node when 285852Svi117747 * the SCTP is in the listen state (from sctp_bind_add()). When called on a 286852Svi117747 * clustered node, the input is always a list of addresses (even if the 287852Svi117747 * original bind() was to INADDR_ANY). 2880Sstevel@tonic-gate * Called with no locks held. 2890Sstevel@tonic-gate */ 2900Sstevel@tonic-gate int 291852Svi117747 sctp_valid_addr_list(sctp_t *sctp, const void *addrs, uint32_t addrcnt, 292852Svi117747 uchar_t *list, size_t lsize) 2930Sstevel@tonic-gate { 2940Sstevel@tonic-gate struct sockaddr_in *sin4; 2950Sstevel@tonic-gate struct sockaddr_in6 *sin6; 2960Sstevel@tonic-gate struct in_addr *addr4; 2970Sstevel@tonic-gate in6_addr_t addr; 2980Sstevel@tonic-gate int cnt; 2990Sstevel@tonic-gate int err = 0; 3000Sstevel@tonic-gate int saddr_cnt = 0; 3010Sstevel@tonic-gate sctp_ipif_t *ipif; 3020Sstevel@tonic-gate boolean_t bind_to_all = B_FALSE; 3030Sstevel@tonic-gate boolean_t check_addrs = B_FALSE; 3040Sstevel@tonic-gate boolean_t check_lport = B_FALSE; 305852Svi117747 uchar_t *p = list; 3060Sstevel@tonic-gate 3070Sstevel@tonic-gate /* 3080Sstevel@tonic-gate * Need to check for port and address depending on the state. 3090Sstevel@tonic-gate * After a socket is bound, we need to make sure that subsequent 3100Sstevel@tonic-gate * bindx() has correct port. After an association is established, 3110Sstevel@tonic-gate * we need to check for changing the bound address to invalid 3120Sstevel@tonic-gate * addresses. 3130Sstevel@tonic-gate */ 3140Sstevel@tonic-gate if (sctp->sctp_state >= SCTPS_BOUND) { 3150Sstevel@tonic-gate check_lport = B_TRUE; 3160Sstevel@tonic-gate if (sctp->sctp_state > SCTPS_LISTEN) 3170Sstevel@tonic-gate check_addrs = B_TRUE; 3180Sstevel@tonic-gate } 319852Svi117747 3200Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 3210Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 3220Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 3230Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 3240Sstevel@tonic-gate for (cnt = 0; cnt < addrcnt; cnt++) { 3250Sstevel@tonic-gate boolean_t lookup_saddr = B_TRUE; 326852Svi117747 uint_t ifindex = 0; 3270Sstevel@tonic-gate 3280Sstevel@tonic-gate switch (sctp->sctp_family) { 3290Sstevel@tonic-gate case AF_INET: 3300Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + cnt; 3310Sstevel@tonic-gate if (sin4->sin_family != AF_INET || (check_lport && 3320Sstevel@tonic-gate sin4->sin_port != sctp->sctp_lport)) { 3330Sstevel@tonic-gate err = EINVAL; 3340Sstevel@tonic-gate goto free_ret; 3350Sstevel@tonic-gate } 3360Sstevel@tonic-gate addr4 = &sin4->sin_addr; 3370Sstevel@tonic-gate if (check_addrs && 3380Sstevel@tonic-gate (addr4->s_addr == INADDR_ANY || 3390Sstevel@tonic-gate addr4->s_addr == INADDR_BROADCAST || 340*5215Skcpoon CLASSD(addr4->s_addr))) { 3410Sstevel@tonic-gate err = EINVAL; 3420Sstevel@tonic-gate goto free_ret; 3430Sstevel@tonic-gate } 3440Sstevel@tonic-gate IN6_INADDR_TO_V4MAPPED(addr4, &addr); 3450Sstevel@tonic-gate if (!check_addrs && addr4->s_addr == INADDR_ANY) { 3460Sstevel@tonic-gate lookup_saddr = B_FALSE; 3470Sstevel@tonic-gate bind_to_all = B_TRUE; 3480Sstevel@tonic-gate } 3490Sstevel@tonic-gate 3500Sstevel@tonic-gate break; 3510Sstevel@tonic-gate case AF_INET6: 3520Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + cnt; 3530Sstevel@tonic-gate if (sin6->sin6_family != AF_INET6 || (check_lport && 3540Sstevel@tonic-gate sin6->sin6_port != sctp->sctp_lport)) { 3550Sstevel@tonic-gate err = EINVAL; 3560Sstevel@tonic-gate goto free_ret; 3570Sstevel@tonic-gate } 3580Sstevel@tonic-gate addr = sin6->sin6_addr; 359852Svi117747 /* Contains the interface index */ 360852Svi117747 ifindex = sin6->sin6_scope_id; 3610Sstevel@tonic-gate if (sctp->sctp_connp->conn_ipv6_v6only && 3620Sstevel@tonic-gate IN6_IS_ADDR_V4MAPPED(&addr)) { 3630Sstevel@tonic-gate err = EAFNOSUPPORT; 3640Sstevel@tonic-gate goto free_ret; 3650Sstevel@tonic-gate } 3660Sstevel@tonic-gate if (check_addrs && 3670Sstevel@tonic-gate (IN6_IS_ADDR_LINKLOCAL(&addr) || 3680Sstevel@tonic-gate IN6_IS_ADDR_MULTICAST(&addr) || 3690Sstevel@tonic-gate IN6_IS_ADDR_UNSPECIFIED(&addr))) { 3700Sstevel@tonic-gate err = EINVAL; 3710Sstevel@tonic-gate goto free_ret; 3720Sstevel@tonic-gate } 3730Sstevel@tonic-gate if (!check_addrs && IN6_IS_ADDR_UNSPECIFIED(&addr)) { 3740Sstevel@tonic-gate lookup_saddr = B_FALSE; 3750Sstevel@tonic-gate bind_to_all = B_TRUE; 3760Sstevel@tonic-gate } 3770Sstevel@tonic-gate 3780Sstevel@tonic-gate break; 3790Sstevel@tonic-gate default: 3800Sstevel@tonic-gate err = EAFNOSUPPORT; 3810Sstevel@tonic-gate goto free_ret; 3820Sstevel@tonic-gate } 3830Sstevel@tonic-gate if (lookup_saddr) { 3843510Svi117747 ipif = sctp_lookup_ipif_addr(&addr, B_TRUE, 3853510Svi117747 sctp->sctp_zoneid, !sctp->sctp_connp->conn_allzones, 3863510Svi117747 ifindex, 0, B_TRUE, sctp->sctp_sctps); 3870Sstevel@tonic-gate if (ipif == NULL) { 3880Sstevel@tonic-gate /* Address not in the list */ 3890Sstevel@tonic-gate err = EINVAL; 3900Sstevel@tonic-gate goto free_ret; 391852Svi117747 } else if (check_addrs && SCTP_IS_IPIF_LOOPBACK(ipif) && 392852Svi117747 cl_sctp_check_addrs == NULL) { 3930Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif); 3940Sstevel@tonic-gate err = EINVAL; 3950Sstevel@tonic-gate goto free_ret; 3960Sstevel@tonic-gate } 3970Sstevel@tonic-gate } 3980Sstevel@tonic-gate if (!bind_to_all) { 399432Svi117747 /* 400432Svi117747 * If an address is added after association setup, 401432Svi117747 * we need to wait for the peer to send us an ASCONF 402432Svi117747 * ACK before we can start using it. 403432Svi117747 * saddr_ipif_dontsrc will be reset (to 0) when we 404432Svi117747 * get the ASCONF ACK for this address. 405432Svi117747 */ 406432Svi117747 err = sctp_ipif_hash_insert(sctp, ipif, KM_SLEEP, 4073510Svi117747 check_addrs ? B_TRUE : B_FALSE, B_FALSE); 4080Sstevel@tonic-gate if (err != 0) { 4090Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif); 4100Sstevel@tonic-gate if (check_addrs && err == EALREADY) 4110Sstevel@tonic-gate err = EADDRINUSE; 4120Sstevel@tonic-gate goto free_ret; 4130Sstevel@tonic-gate } 4140Sstevel@tonic-gate saddr_cnt++; 415852Svi117747 if (lsize >= sizeof (addr)) { 416852Svi117747 bcopy(&addr, p, sizeof (addr)); 417852Svi117747 p += sizeof (addr); 418852Svi117747 lsize -= sizeof (addr); 419852Svi117747 } 4200Sstevel@tonic-gate } 4210Sstevel@tonic-gate } 4220Sstevel@tonic-gate if (bind_to_all) { 4230Sstevel@tonic-gate /* 4240Sstevel@tonic-gate * Free whatever we might have added before encountering 4250Sstevel@tonic-gate * inaddr_any. 4260Sstevel@tonic-gate */ 4270Sstevel@tonic-gate if (sctp->sctp_nsaddrs > 0) { 4280Sstevel@tonic-gate sctp_free_saddrs(sctp); 4290Sstevel@tonic-gate ASSERT(sctp->sctp_nsaddrs == 0); 4300Sstevel@tonic-gate } 4310Sstevel@tonic-gate err = sctp_get_all_ipifs(sctp, KM_SLEEP); 4320Sstevel@tonic-gate if (err != 0) 4330Sstevel@tonic-gate return (err); 4340Sstevel@tonic-gate sctp->sctp_bound_to_all = 1; 4350Sstevel@tonic-gate } 4360Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 4370Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 4380Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 4390Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 4400Sstevel@tonic-gate return (0); 4410Sstevel@tonic-gate free_ret: 4420Sstevel@tonic-gate if (saddr_cnt != 0) 4430Sstevel@tonic-gate sctp_del_saddr_list(sctp, addrs, saddr_cnt, B_TRUE); 4440Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 4450Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 4460Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 4470Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 4480Sstevel@tonic-gate return (err); 4490Sstevel@tonic-gate } 4500Sstevel@tonic-gate 4510Sstevel@tonic-gate static int 452432Svi117747 sctp_ipif_hash_insert(sctp_t *sctp, sctp_ipif_t *ipif, int sleep, 4533510Svi117747 boolean_t dontsrc, boolean_t allow_dup) 4540Sstevel@tonic-gate { 4550Sstevel@tonic-gate int cnt; 4560Sstevel@tonic-gate sctp_saddr_ipif_t *ipif_obj; 4573510Svi117747 int hindex; 4580Sstevel@tonic-gate 4593510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->sctp_ipif_saddr, 4603510Svi117747 ipif->sctp_ipif_isv6); 4613510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 4623510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 4633510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif_obj->saddr_ipifp->sctp_ipif_saddr, 4643510Svi117747 &ipif->sctp_ipif_saddr)) { 4653510Svi117747 if (ipif->sctp_ipif_id != 4663510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_id && 4673510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_state == 4683510Svi117747 SCTP_IPIFS_DOWN && ipif->sctp_ipif_state == 4693510Svi117747 SCTP_IPIFS_UP) { 4703510Svi117747 SCTP_IPIF_REFRELE(ipif_obj->saddr_ipifp); 4713510Svi117747 ipif_obj->saddr_ipifp = ipif; 4723510Svi117747 ipif_obj->saddr_ipif_dontsrc = dontsrc ? 1 : 0; 4733510Svi117747 return (0); 4743510Svi117747 } else if (!allow_dup || ipif->sctp_ipif_id == 4753510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_id) { 4763510Svi117747 return (EALREADY); 4773510Svi117747 } 4783510Svi117747 } 4793510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 4800Sstevel@tonic-gate ipif_obj); 4810Sstevel@tonic-gate } 4820Sstevel@tonic-gate ipif_obj = kmem_zalloc(sizeof (sctp_saddr_ipif_t), sleep); 4830Sstevel@tonic-gate if (ipif_obj == NULL) { 4840Sstevel@tonic-gate /* Need to do something */ 4850Sstevel@tonic-gate return (ENOMEM); 4860Sstevel@tonic-gate } 4870Sstevel@tonic-gate ipif_obj->saddr_ipifp = ipif; 488432Svi117747 ipif_obj->saddr_ipif_dontsrc = dontsrc ? 1 : 0; 4893510Svi117747 list_insert_tail(&sctp->sctp_saddrs[hindex].sctp_ipif_list, ipif_obj); 4903510Svi117747 sctp->sctp_saddrs[hindex].ipif_count++; 4910Sstevel@tonic-gate sctp->sctp_nsaddrs++; 4920Sstevel@tonic-gate return (0); 4930Sstevel@tonic-gate } 4940Sstevel@tonic-gate 4954818Skcpoon /* 4964818Skcpoon * Given a source address, walk through the peer address list to see 4974818Skcpoon * if the source address is being used. If it is, reset that. 4984818Skcpoon */ 4994818Skcpoon static void 5004818Skcpoon sctp_fix_saddr(sctp_t *sctp, in6_addr_t *saddr) 5014818Skcpoon { 5024818Skcpoon sctp_faddr_t *fp; 5034818Skcpoon 5044818Skcpoon for (fp = sctp->sctp_faddrs; fp != NULL; fp = fp->next) { 5054818Skcpoon if (!IN6_ARE_ADDR_EQUAL(&fp->saddr, saddr)) 5064818Skcpoon continue; 5074818Skcpoon if (fp->ire != NULL) { 5084818Skcpoon IRE_REFRELE_NOTR(fp->ire); 5094818Skcpoon fp->ire = NULL; 5104818Skcpoon } 5114818Skcpoon V6_SET_ZERO(fp->saddr); 5124818Skcpoon } 5134818Skcpoon } 5144818Skcpoon 5150Sstevel@tonic-gate static void 5160Sstevel@tonic-gate sctp_ipif_hash_remove(sctp_t *sctp, sctp_ipif_t *ipif) 5170Sstevel@tonic-gate { 5180Sstevel@tonic-gate int cnt; 5190Sstevel@tonic-gate sctp_saddr_ipif_t *ipif_obj; 5203510Svi117747 int hindex; 5210Sstevel@tonic-gate 5223510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->sctp_ipif_saddr, 5233510Svi117747 ipif->sctp_ipif_isv6); 5243510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 5253510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 5263510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif_obj->saddr_ipifp->sctp_ipif_saddr, 5273510Svi117747 &ipif->sctp_ipif_saddr)) { 5283510Svi117747 list_remove(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 5290Sstevel@tonic-gate ipif_obj); 5303510Svi117747 sctp->sctp_saddrs[hindex].ipif_count--; 5310Sstevel@tonic-gate sctp->sctp_nsaddrs--; 5324818Skcpoon sctp_fix_saddr(sctp, &ipif->sctp_ipif_saddr); 5330Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif_obj->saddr_ipifp); 5340Sstevel@tonic-gate kmem_free(ipif_obj, sizeof (sctp_saddr_ipif_t)); 5350Sstevel@tonic-gate break; 5360Sstevel@tonic-gate } 5373510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 5380Sstevel@tonic-gate ipif_obj); 5390Sstevel@tonic-gate } 5400Sstevel@tonic-gate } 5410Sstevel@tonic-gate 5420Sstevel@tonic-gate static int 5430Sstevel@tonic-gate sctp_compare_ipif_list(sctp_ipif_hash_t *list1, sctp_ipif_hash_t *list2) 5440Sstevel@tonic-gate { 5450Sstevel@tonic-gate int i; 5460Sstevel@tonic-gate int j; 5470Sstevel@tonic-gate sctp_saddr_ipif_t *obj1; 5480Sstevel@tonic-gate sctp_saddr_ipif_t *obj2; 5490Sstevel@tonic-gate int overlap = 0; 5500Sstevel@tonic-gate 5510Sstevel@tonic-gate obj1 = list_head(&list1->sctp_ipif_list); 5520Sstevel@tonic-gate for (i = 0; i < list1->ipif_count; i++) { 5530Sstevel@tonic-gate obj2 = list_head(&list2->sctp_ipif_list); 5540Sstevel@tonic-gate for (j = 0; j < list2->ipif_count; j++) { 5553510Svi117747 if (IN6_ARE_ADDR_EQUAL( 5563510Svi117747 &obj1->saddr_ipifp->sctp_ipif_saddr, 5573510Svi117747 &obj2->saddr_ipifp->sctp_ipif_saddr)) { 5580Sstevel@tonic-gate overlap++; 5590Sstevel@tonic-gate break; 5600Sstevel@tonic-gate } 5610Sstevel@tonic-gate obj2 = list_next(&list2->sctp_ipif_list, 5620Sstevel@tonic-gate obj2); 5630Sstevel@tonic-gate } 5640Sstevel@tonic-gate obj1 = list_next(&list1->sctp_ipif_list, obj1); 5650Sstevel@tonic-gate } 5660Sstevel@tonic-gate return (overlap); 5670Sstevel@tonic-gate } 5680Sstevel@tonic-gate 5690Sstevel@tonic-gate int 5700Sstevel@tonic-gate sctp_compare_saddrs(sctp_t *sctp1, sctp_t *sctp2) 5710Sstevel@tonic-gate { 5720Sstevel@tonic-gate int i; 5730Sstevel@tonic-gate int overlap = 0; 5740Sstevel@tonic-gate 5750Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 5760Sstevel@tonic-gate overlap += sctp_compare_ipif_list(&sctp1->sctp_saddrs[i], 5770Sstevel@tonic-gate &sctp2->sctp_saddrs[i]); 5780Sstevel@tonic-gate } 5790Sstevel@tonic-gate 5800Sstevel@tonic-gate if (sctp1->sctp_nsaddrs == sctp2->sctp_nsaddrs && 5810Sstevel@tonic-gate overlap == sctp1->sctp_nsaddrs) { 5820Sstevel@tonic-gate return (SCTP_ADDR_EQUAL); 5830Sstevel@tonic-gate } 5840Sstevel@tonic-gate 5850Sstevel@tonic-gate if (overlap == sctp1->sctp_nsaddrs) 5860Sstevel@tonic-gate return (SCTP_ADDR_SUBSET); 5870Sstevel@tonic-gate 5880Sstevel@tonic-gate if (overlap > 0) 5890Sstevel@tonic-gate return (SCTP_ADDR_OVERLAP); 5900Sstevel@tonic-gate 5910Sstevel@tonic-gate return (SCTP_ADDR_DISJOINT); 5920Sstevel@tonic-gate } 5930Sstevel@tonic-gate 5940Sstevel@tonic-gate static int 5950Sstevel@tonic-gate sctp_copy_ipifs(sctp_ipif_hash_t *list1, sctp_t *sctp2, int sleep) 5960Sstevel@tonic-gate { 5970Sstevel@tonic-gate int i; 5980Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 5990Sstevel@tonic-gate int error = 0; 6000Sstevel@tonic-gate 6010Sstevel@tonic-gate obj = list_head(&list1->sctp_ipif_list); 6020Sstevel@tonic-gate for (i = 0; i < list1->ipif_count; i++) { 6030Sstevel@tonic-gate SCTP_IPIF_REFHOLD(obj->saddr_ipifp); 604432Svi117747 error = sctp_ipif_hash_insert(sctp2, obj->saddr_ipifp, sleep, 6053510Svi117747 B_FALSE, B_FALSE); 6063510Svi117747 ASSERT(error != EALREADY); 6070Sstevel@tonic-gate if (error != 0) 6080Sstevel@tonic-gate return (error); 6090Sstevel@tonic-gate obj = list_next(&list1->sctp_ipif_list, obj); 6100Sstevel@tonic-gate } 6110Sstevel@tonic-gate return (error); 6120Sstevel@tonic-gate } 6130Sstevel@tonic-gate 6140Sstevel@tonic-gate int 6150Sstevel@tonic-gate sctp_dup_saddrs(sctp_t *sctp1, sctp_t *sctp2, int sleep) 6160Sstevel@tonic-gate { 6170Sstevel@tonic-gate int error = 0; 6180Sstevel@tonic-gate int i; 6190Sstevel@tonic-gate 620432Svi117747 if (sctp1 == NULL || sctp1->sctp_bound_to_all == 1) 6210Sstevel@tonic-gate return (sctp_get_all_ipifs(sctp2, sleep)); 6220Sstevel@tonic-gate 6230Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 6240Sstevel@tonic-gate if (sctp1->sctp_saddrs[i].ipif_count == 0) 6250Sstevel@tonic-gate continue; 6260Sstevel@tonic-gate error = sctp_copy_ipifs(&sctp1->sctp_saddrs[i], sctp2, sleep); 6270Sstevel@tonic-gate if (error != 0) { 6280Sstevel@tonic-gate sctp_free_saddrs(sctp2); 6290Sstevel@tonic-gate return (error); 6300Sstevel@tonic-gate } 6310Sstevel@tonic-gate } 6320Sstevel@tonic-gate return (0); 6330Sstevel@tonic-gate } 6340Sstevel@tonic-gate 6350Sstevel@tonic-gate void 6360Sstevel@tonic-gate sctp_free_saddrs(sctp_t *sctp) 6370Sstevel@tonic-gate { 6380Sstevel@tonic-gate int i; 6390Sstevel@tonic-gate int l; 6400Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 6410Sstevel@tonic-gate 6420Sstevel@tonic-gate if (sctp->sctp_nsaddrs == 0) 6430Sstevel@tonic-gate return; 6440Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 6450Sstevel@tonic-gate if (sctp->sctp_saddrs[i].ipif_count == 0) 6460Sstevel@tonic-gate continue; 6470Sstevel@tonic-gate obj = list_tail(&sctp->sctp_saddrs[i].sctp_ipif_list); 6480Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 6490Sstevel@tonic-gate list_remove(&sctp->sctp_saddrs[i].sctp_ipif_list, obj); 6500Sstevel@tonic-gate SCTP_IPIF_REFRELE(obj->saddr_ipifp); 6510Sstevel@tonic-gate sctp->sctp_nsaddrs--; 6520Sstevel@tonic-gate kmem_free(obj, sizeof (sctp_saddr_ipif_t)); 6530Sstevel@tonic-gate obj = list_tail(&sctp->sctp_saddrs[i].sctp_ipif_list); 6540Sstevel@tonic-gate } 6550Sstevel@tonic-gate sctp->sctp_saddrs[i].ipif_count = 0; 6560Sstevel@tonic-gate } 657432Svi117747 if (sctp->sctp_bound_to_all == 1) 658432Svi117747 sctp->sctp_bound_to_all = 0; 6590Sstevel@tonic-gate ASSERT(sctp->sctp_nsaddrs == 0); 6600Sstevel@tonic-gate } 6610Sstevel@tonic-gate 6620Sstevel@tonic-gate /* 6630Sstevel@tonic-gate * Add/Delete the given ILL from the SCTP ILL list. Called with no locks 6640Sstevel@tonic-gate * held. 6650Sstevel@tonic-gate */ 6660Sstevel@tonic-gate void 6670Sstevel@tonic-gate sctp_update_ill(ill_t *ill, int op) 6680Sstevel@tonic-gate { 6690Sstevel@tonic-gate int i; 6700Sstevel@tonic-gate sctp_ill_t *sctp_ill = NULL; 6710Sstevel@tonic-gate uint_t index; 6723448Sdh155122 netstack_t *ns = ill->ill_ipst->ips_netstack; 6733448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 6740Sstevel@tonic-gate 6753448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_WRITER); 6760Sstevel@tonic-gate 6770Sstevel@tonic-gate index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 6783448Sdh155122 sctp_ill = list_head(&sctps->sctps_g_ills[index].sctp_ill_list); 6793448Sdh155122 for (i = 0; i < sctps->sctps_g_ills[index].ill_count; i++) { 6804311Svi117747 if ((sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill)) && 6814311Svi117747 (sctp_ill->sctp_ill_isv6 == ill->ill_isv6)) { 6820Sstevel@tonic-gate break; 6834311Svi117747 } 6843448Sdh155122 sctp_ill = list_next(&sctps->sctps_g_ills[index].sctp_ill_list, 6850Sstevel@tonic-gate sctp_ill); 6860Sstevel@tonic-gate } 6870Sstevel@tonic-gate 6880Sstevel@tonic-gate switch (op) { 6890Sstevel@tonic-gate case SCTP_ILL_INSERT: 6900Sstevel@tonic-gate if (sctp_ill != NULL) { 6910Sstevel@tonic-gate /* Unmark it if it is condemned */ 6920Sstevel@tonic-gate if (sctp_ill->sctp_ill_state == SCTP_ILLS_CONDEMNED) 6930Sstevel@tonic-gate sctp_ill->sctp_ill_state = 0; 6943448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 6950Sstevel@tonic-gate return; 6960Sstevel@tonic-gate } 6970Sstevel@tonic-gate sctp_ill = kmem_zalloc(sizeof (sctp_ill_t), KM_NOSLEEP); 6980Sstevel@tonic-gate /* Need to re-try? */ 6990Sstevel@tonic-gate if (sctp_ill == NULL) { 7004311Svi117747 cmn_err(CE_WARN, "sctp_update_ill: error adding " 7014311Svi117747 "ILL %p to SCTP's ILL list", (void *)ill); 7023448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7030Sstevel@tonic-gate return; 7040Sstevel@tonic-gate } 7053510Svi117747 sctp_ill->sctp_ill_name = kmem_zalloc(ill->ill_name_length, 7063510Svi117747 KM_NOSLEEP); 7070Sstevel@tonic-gate if (sctp_ill->sctp_ill_name == NULL) { 7084311Svi117747 cmn_err(CE_WARN, "sctp_update_ill: error adding " 7094311Svi117747 "ILL %p to SCTP's ILL list", (void *)ill); 7100Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 7113448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7120Sstevel@tonic-gate return; 7130Sstevel@tonic-gate } 7140Sstevel@tonic-gate bcopy(ill->ill_name, sctp_ill->sctp_ill_name, 7150Sstevel@tonic-gate ill->ill_name_length); 7160Sstevel@tonic-gate sctp_ill->sctp_ill_name_length = ill->ill_name_length; 7170Sstevel@tonic-gate sctp_ill->sctp_ill_index = SCTP_ILL_TO_PHYINDEX(ill); 7180Sstevel@tonic-gate sctp_ill->sctp_ill_flags = ill->ill_phyint->phyint_flags; 7193448Sdh155122 sctp_ill->sctp_ill_netstack = ns; /* No netstack_hold */ 7204311Svi117747 sctp_ill->sctp_ill_isv6 = ill->ill_isv6; 7213448Sdh155122 list_insert_tail(&sctps->sctps_g_ills[index].sctp_ill_list, 7220Sstevel@tonic-gate (void *)sctp_ill); 7233448Sdh155122 sctps->sctps_g_ills[index].ill_count++; 7243448Sdh155122 sctps->sctps_ills_count++; 7250Sstevel@tonic-gate 7260Sstevel@tonic-gate break; 7270Sstevel@tonic-gate 7280Sstevel@tonic-gate case SCTP_ILL_REMOVE: 7290Sstevel@tonic-gate 7300Sstevel@tonic-gate if (sctp_ill == NULL) { 7313448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7320Sstevel@tonic-gate return; 7330Sstevel@tonic-gate } 7340Sstevel@tonic-gate if (sctp_ill->sctp_ill_ipifcnt == 0) { 7353448Sdh155122 list_remove(&sctps->sctps_g_ills[index].sctp_ill_list, 7360Sstevel@tonic-gate (void *)sctp_ill); 7373448Sdh155122 sctps->sctps_g_ills[index].ill_count--; 7383448Sdh155122 sctps->sctps_ills_count--; 7390Sstevel@tonic-gate kmem_free(sctp_ill->sctp_ill_name, 7400Sstevel@tonic-gate ill->ill_name_length); 7410Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 7420Sstevel@tonic-gate } else { 7430Sstevel@tonic-gate sctp_ill->sctp_ill_state = SCTP_ILLS_CONDEMNED; 7440Sstevel@tonic-gate } 7450Sstevel@tonic-gate 7460Sstevel@tonic-gate break; 7470Sstevel@tonic-gate } 7483448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7490Sstevel@tonic-gate } 7500Sstevel@tonic-gate 7514311Svi117747 /* 7524311Svi117747 * The ILL's index is being changed, just remove it from the old list, 7534311Svi117747 * change the SCTP ILL's index and re-insert using the new index. 7544311Svi117747 */ 7554311Svi117747 void 7564311Svi117747 sctp_ill_reindex(ill_t *ill, uint_t orig_ill_index) 7574311Svi117747 { 7584311Svi117747 sctp_ill_t *sctp_ill = NULL; 7594311Svi117747 sctp_ill_t *nxt_sill; 7604311Svi117747 uint_t indx; 7614311Svi117747 uint_t nindx; 7624311Svi117747 boolean_t once = B_FALSE; 7634311Svi117747 netstack_t *ns = ill->ill_ipst->ips_netstack; 7644311Svi117747 sctp_stack_t *sctps = ns->netstack_sctp; 7654311Svi117747 7664311Svi117747 rw_enter(&sctps->sctps_g_ills_lock, RW_WRITER); 7674311Svi117747 7684311Svi117747 indx = SCTP_ILL_HASH_FN(orig_ill_index); 7694311Svi117747 nindx = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 7704311Svi117747 sctp_ill = list_head(&sctps->sctps_g_ills[indx].sctp_ill_list); 7714311Svi117747 while (sctp_ill != NULL) { 7724311Svi117747 nxt_sill = list_next(&sctps->sctps_g_ills[indx].sctp_ill_list, 7734311Svi117747 sctp_ill); 7744311Svi117747 if (sctp_ill->sctp_ill_index == orig_ill_index) { 7754311Svi117747 sctp_ill->sctp_ill_index = SCTP_ILL_TO_PHYINDEX(ill); 7764311Svi117747 /* 7774311Svi117747 * if the new index hashes to the same value, all's 7784311Svi117747 * done. 7794311Svi117747 */ 7804311Svi117747 if (nindx != indx) { 7814311Svi117747 list_remove( 7824311Svi117747 &sctps->sctps_g_ills[indx].sctp_ill_list, 7834311Svi117747 (void *)sctp_ill); 7844311Svi117747 sctps->sctps_g_ills[indx].ill_count--; 7854311Svi117747 list_insert_tail( 7864311Svi117747 &sctps->sctps_g_ills[nindx].sctp_ill_list, 7874311Svi117747 (void *)sctp_ill); 7884311Svi117747 sctps->sctps_g_ills[nindx].ill_count++; 7894311Svi117747 } 7904311Svi117747 if (once) 7914311Svi117747 break; 7924311Svi117747 /* We might have one for v4 and for v6 */ 7934311Svi117747 once = B_TRUE; 7944311Svi117747 } 7954311Svi117747 sctp_ill = nxt_sill; 7964311Svi117747 } 7974311Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 7984311Svi117747 } 7994311Svi117747 8000Sstevel@tonic-gate /* move ipif from f_ill to t_ill */ 8010Sstevel@tonic-gate void 8020Sstevel@tonic-gate sctp_move_ipif(ipif_t *ipif, ill_t *f_ill, ill_t *t_ill) 8030Sstevel@tonic-gate { 8040Sstevel@tonic-gate sctp_ill_t *fsctp_ill = NULL; 8050Sstevel@tonic-gate sctp_ill_t *tsctp_ill = NULL; 8060Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 8073510Svi117747 uint_t hindex; 8080Sstevel@tonic-gate int i; 8093448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 8103448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 8110Sstevel@tonic-gate 8123448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 8133448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 8140Sstevel@tonic-gate 8153510Svi117747 hindex = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(f_ill)); 8163510Svi117747 fsctp_ill = list_head(&sctps->sctps_g_ills[hindex].sctp_ill_list); 8173510Svi117747 for (i = 0; i < sctps->sctps_g_ills[hindex].ill_count; i++) { 8184311Svi117747 if (fsctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(f_ill) && 8194311Svi117747 fsctp_ill->sctp_ill_isv6 == f_ill->ill_isv6) { 8200Sstevel@tonic-gate break; 8214311Svi117747 } 8223510Svi117747 fsctp_ill = list_next( 8233510Svi117747 &sctps->sctps_g_ills[hindex].sctp_ill_list, fsctp_ill); 8240Sstevel@tonic-gate } 8250Sstevel@tonic-gate 8263510Svi117747 hindex = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(t_ill)); 8273510Svi117747 tsctp_ill = list_head(&sctps->sctps_g_ills[hindex].sctp_ill_list); 8283510Svi117747 for (i = 0; i < sctps->sctps_g_ills[hindex].ill_count; i++) { 8294311Svi117747 if (tsctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(t_ill) && 8304311Svi117747 tsctp_ill->sctp_ill_isv6 == t_ill->ill_isv6) { 8310Sstevel@tonic-gate break; 8324311Svi117747 } 8333510Svi117747 tsctp_ill = list_next( 8343510Svi117747 &sctps->sctps_g_ills[hindex].sctp_ill_list, tsctp_ill); 8350Sstevel@tonic-gate } 8360Sstevel@tonic-gate 8373510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, 8383510Svi117747 ipif->ipif_ill->ill_isv6); 8393510Svi117747 sctp_ipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 8403510Svi117747 for (i = 0; i < sctps->sctps_g_ipifs[hindex].ipif_count; i++) { 8410Sstevel@tonic-gate if (sctp_ipif->sctp_ipif_id == ipif->ipif_seqid) 8420Sstevel@tonic-gate break; 8433448Sdh155122 sctp_ipif = list_next( 8443510Svi117747 &sctps->sctps_g_ipifs[hindex].sctp_ipif_list, sctp_ipif); 8450Sstevel@tonic-gate } 8460Sstevel@tonic-gate /* Should be an ASSERT? */ 8470Sstevel@tonic-gate if (fsctp_ill == NULL || tsctp_ill == NULL || sctp_ipif == NULL) { 8480Sstevel@tonic-gate ip1dbg(("sctp_move_ipif: error moving ipif %p from %p to %p\n", 8490Sstevel@tonic-gate (void *)ipif, (void *)f_ill, (void *)t_ill)); 8503448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 8513448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 8520Sstevel@tonic-gate return; 8530Sstevel@tonic-gate } 8540Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 8550Sstevel@tonic-gate ASSERT(sctp_ipif->sctp_ipif_ill == fsctp_ill); 8560Sstevel@tonic-gate sctp_ipif->sctp_ipif_ill = tsctp_ill; 8570Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 8580Sstevel@tonic-gate (void) atomic_add_32_nv(&fsctp_ill->sctp_ill_ipifcnt, -1); 8590Sstevel@tonic-gate atomic_add_32(&tsctp_ill->sctp_ill_ipifcnt, 1); 8603448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 8613448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 8620Sstevel@tonic-gate } 8630Sstevel@tonic-gate 8643510Svi117747 /* 8653510Svi117747 * Walk the list of SCTPs and find each that has oipif in it's saddr list, and 8663510Svi117747 * if so replace it with nipif. 8673510Svi117747 */ 8683510Svi117747 void 8693510Svi117747 sctp_update_saddrs(sctp_ipif_t *oipif, sctp_ipif_t *nipif, int idx, 8703510Svi117747 sctp_stack_t *sctps) 8713510Svi117747 { 8723510Svi117747 sctp_t *sctp; 8733510Svi117747 sctp_t *sctp_prev = NULL; 8743510Svi117747 sctp_saddr_ipif_t *sobj; 8753510Svi117747 int count; 8763510Svi117747 8773510Svi117747 sctp = sctps->sctps_gsctp; 8783510Svi117747 mutex_enter(&sctps->sctps_g_lock); 8793510Svi117747 while (sctp != NULL && oipif->sctp_ipif_refcnt > 0) { 8803510Svi117747 mutex_enter(&sctp->sctp_reflock); 8813510Svi117747 if (sctp->sctp_condemned || 8823510Svi117747 sctp->sctp_saddrs[idx].ipif_count <= 0) { 8833510Svi117747 mutex_exit(&sctp->sctp_reflock); 8843510Svi117747 sctp = list_next(&sctps->sctps_g_list, sctp); 8853510Svi117747 continue; 8863510Svi117747 } 8873510Svi117747 sctp->sctp_refcnt++; 8883510Svi117747 mutex_exit(&sctp->sctp_reflock); 8893510Svi117747 mutex_exit(&sctps->sctps_g_lock); 8903510Svi117747 if (sctp_prev != NULL) 8913510Svi117747 SCTP_REFRELE(sctp_prev); 8923510Svi117747 8933510Svi117747 RUN_SCTP(sctp); 8943510Svi117747 sobj = list_head(&sctp->sctp_saddrs[idx].sctp_ipif_list); 8953510Svi117747 for (count = 0; count < 8963510Svi117747 sctp->sctp_saddrs[idx].ipif_count; count++) { 8973510Svi117747 if (sobj->saddr_ipifp == oipif) { 8983510Svi117747 SCTP_IPIF_REFHOLD(nipif); 8993510Svi117747 sobj->saddr_ipifp = nipif; 9003510Svi117747 ASSERT(oipif->sctp_ipif_refcnt > 0); 9013510Svi117747 /* We have the writer lock */ 9023510Svi117747 oipif->sctp_ipif_refcnt--; 9033510Svi117747 /* 9043510Svi117747 * Can't have more than one referring 9053510Svi117747 * to the same sctp_ipif. 9063510Svi117747 */ 9073510Svi117747 break; 9083510Svi117747 } 9093510Svi117747 sobj = list_next(&sctp->sctp_saddrs[idx].sctp_ipif_list, 9103510Svi117747 sobj); 9113510Svi117747 } 9123510Svi117747 WAKE_SCTP(sctp); 9133510Svi117747 sctp_prev = sctp; 9143510Svi117747 mutex_enter(&sctps->sctps_g_lock); 9153510Svi117747 sctp = list_next(&sctps->sctps_g_list, sctp); 9163510Svi117747 } 9173510Svi117747 mutex_exit(&sctps->sctps_g_lock); 9183510Svi117747 if (sctp_prev != NULL) 9193510Svi117747 SCTP_REFRELE(sctp_prev); 9203510Svi117747 } 9213510Svi117747 9223510Svi117747 /* 9233510Svi117747 * Given an ipif, walk the hash list in the global ipif table and for 9243510Svi117747 * any other SCTP ipif with the same address and non-zero reference, walk 9253510Svi117747 * the SCTP list and update the saddr list, if required, to point to the 9263510Svi117747 * new SCTP ipif. 9273510Svi117747 */ 9283510Svi117747 void 9293510Svi117747 sctp_chk_and_updt_saddr(int hindex, sctp_ipif_t *ipif, sctp_stack_t *sctps) 9303510Svi117747 { 9313510Svi117747 int cnt; 9323510Svi117747 sctp_ipif_t *sipif; 9333510Svi117747 9343510Svi117747 ASSERT(sctps->sctps_g_ipifs[hindex].ipif_count > 0); 9353510Svi117747 ASSERT(ipif->sctp_ipif_state == SCTP_IPIFS_UP); 9363510Svi117747 9373510Svi117747 sipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 9383510Svi117747 for (cnt = 0; cnt < sctps->sctps_g_ipifs[hindex].ipif_count; cnt++) { 9393510Svi117747 rw_enter(&sipif->sctp_ipif_lock, RW_WRITER); 9403510Svi117747 if (sipif->sctp_ipif_id != ipif->sctp_ipif_id && 9413510Svi117747 IN6_ARE_ADDR_EQUAL(&sipif->sctp_ipif_saddr, 9423510Svi117747 &ipif->sctp_ipif_saddr) && sipif->sctp_ipif_refcnt > 0) { 9433510Svi117747 /* 9443510Svi117747 * There can only be one address up at any time 9453510Svi117747 * and we are here because ipif has been brought 9463510Svi117747 * up. 9473510Svi117747 */ 9483510Svi117747 ASSERT(sipif->sctp_ipif_state != SCTP_IPIFS_UP); 9493510Svi117747 /* 9503510Svi117747 * Someone has a reference to this we need to update to 9513510Svi117747 * point to the new sipif. 9523510Svi117747 */ 9533510Svi117747 sctp_update_saddrs(sipif, ipif, hindex, sctps); 9543510Svi117747 } 9553510Svi117747 rw_exit(&sipif->sctp_ipif_lock); 9563510Svi117747 sipif = list_next(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 9573510Svi117747 sipif); 9583510Svi117747 } 9593510Svi117747 } 9603510Svi117747 9613510Svi117747 /* 9623510Svi117747 * Insert a new SCTP ipif using 'ipif'. v6addr is the address that existed 9633510Svi117747 * prior to the current address in 'ipif'. Only when an existing address 9643510Svi117747 * is changed on an IPIF, will v6addr be specified. If the IPIF already 9653510Svi117747 * exists in the global SCTP ipif table, then we either removed it, if 9663510Svi117747 * it doesn't have any existing reference, or mark it condemned otherwise. 9673510Svi117747 * If an address is being brought up (IPIF_UP), then we need to scan 9683510Svi117747 * the SCTP list to check if there is any SCTP that points to the *same* 9693510Svi117747 * address on a different SCTP ipif and update in that case. 9703510Svi117747 */ 9713510Svi117747 void 9723510Svi117747 sctp_update_ipif_addr(ipif_t *ipif, in6_addr_t v6addr) 9733510Svi117747 { 9743510Svi117747 ill_t *ill = ipif->ipif_ill; 9753510Svi117747 int i; 9763510Svi117747 sctp_ill_t *sctp_ill; 9773510Svi117747 sctp_ill_t *osctp_ill; 9783510Svi117747 sctp_ipif_t *sctp_ipif = NULL; 9793510Svi117747 sctp_ipif_t *osctp_ipif = NULL; 9803510Svi117747 uint_t ill_index; 9813510Svi117747 int hindex; 9823510Svi117747 sctp_stack_t *sctps; 9833510Svi117747 9843510Svi117747 9853510Svi117747 sctps = ipif->ipif_ill->ill_ipst->ips_netstack->netstack_sctp; 9863510Svi117747 9873510Svi117747 /* Index for new address */ 9883510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, ill->ill_isv6); 9893510Svi117747 9903510Svi117747 /* 9913510Svi117747 * The address on this IPIF is changing, we need to look for 9923510Svi117747 * this old address and mark it condemned, before creating 9933510Svi117747 * one for the new address. 9943510Svi117747 */ 9953510Svi117747 osctp_ipif = sctp_lookup_ipif_addr(&v6addr, B_FALSE, 9963510Svi117747 ipif->ipif_zoneid, B_TRUE, SCTP_ILL_TO_PHYINDEX(ill), 9973510Svi117747 ipif->ipif_seqid, B_FALSE, sctps); 9983510Svi117747 9993510Svi117747 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 10003510Svi117747 rw_enter(&sctps->sctps_g_ipifs_lock, RW_WRITER); 10013510Svi117747 10023510Svi117747 ill_index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 10033510Svi117747 sctp_ill = list_head(&sctps->sctps_g_ills[ill_index].sctp_ill_list); 10043510Svi117747 for (i = 0; i < sctps->sctps_g_ills[ill_index].ill_count; i++) { 10054311Svi117747 if (sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill) && 10064311Svi117747 sctp_ill->sctp_ill_isv6 == ill->ill_isv6) { 10073510Svi117747 break; 10084311Svi117747 } 10093510Svi117747 sctp_ill = list_next( 10103510Svi117747 &sctps->sctps_g_ills[ill_index].sctp_ill_list, sctp_ill); 10113510Svi117747 } 10123510Svi117747 10133510Svi117747 if (sctp_ill == NULL) { 10144311Svi117747 ip1dbg(("sctp_update_ipif_addr: ill not found ..\n")); 10153510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 10163510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 10174311Svi117747 return; 10183510Svi117747 } 10193510Svi117747 10203510Svi117747 if (osctp_ipif != NULL) { 10213510Svi117747 10223510Svi117747 /* The address is the same? */ 10233510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif->ipif_v6lcl_addr, &v6addr)) { 10243510Svi117747 boolean_t chk_n_updt = B_FALSE; 10253510Svi117747 10263510Svi117747 rw_downgrade(&sctps->sctps_g_ipifs_lock); 10273510Svi117747 rw_enter(&osctp_ipif->sctp_ipif_lock, RW_WRITER); 10283510Svi117747 if (ipif->ipif_flags & IPIF_UP && 10293510Svi117747 osctp_ipif->sctp_ipif_state != SCTP_IPIFS_UP) { 10303510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 10313510Svi117747 chk_n_updt = B_TRUE; 10323510Svi117747 } else { 10333510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 10343510Svi117747 } 10353510Svi117747 osctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 10363510Svi117747 rw_exit(&osctp_ipif->sctp_ipif_lock); 10373510Svi117747 if (chk_n_updt) { 10383510Svi117747 sctp_chk_and_updt_saddr(hindex, osctp_ipif, 10393510Svi117747 sctps); 10403510Svi117747 } 10413510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 10423510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 10433510Svi117747 return; 10443510Svi117747 } 10453510Svi117747 /* 10463510Svi117747 * We are effectively removing this address from the ILL. 10473510Svi117747 */ 10483510Svi117747 if (osctp_ipif->sctp_ipif_refcnt != 0) { 10493510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_CONDEMNED; 10503510Svi117747 } else { 10513510Svi117747 list_t *ipif_list; 10523510Svi117747 int ohindex; 10533510Svi117747 10543510Svi117747 osctp_ill = osctp_ipif->sctp_ipif_ill; 10553510Svi117747 /* hash index for the old one */ 10563510Svi117747 ohindex = SCTP_IPIF_ADDR_HASH( 10573510Svi117747 osctp_ipif->sctp_ipif_saddr, 10583510Svi117747 osctp_ipif->sctp_ipif_isv6); 10593510Svi117747 10603510Svi117747 ipif_list = 10613510Svi117747 &sctps->sctps_g_ipifs[ohindex].sctp_ipif_list; 10623510Svi117747 10633510Svi117747 list_remove(ipif_list, (void *)osctp_ipif); 10643510Svi117747 sctps->sctps_g_ipifs[ohindex].ipif_count--; 10653510Svi117747 sctps->sctps_g_ipifs_count--; 10663510Svi117747 rw_destroy(&osctp_ipif->sctp_ipif_lock); 10673510Svi117747 kmem_free(osctp_ipif, sizeof (sctp_ipif_t)); 10683510Svi117747 (void) atomic_add_32_nv(&osctp_ill->sctp_ill_ipifcnt, 10693510Svi117747 -1); 10703510Svi117747 } 10713510Svi117747 } 10723510Svi117747 10733510Svi117747 sctp_ipif = kmem_zalloc(sizeof (sctp_ipif_t), KM_NOSLEEP); 10743510Svi117747 /* Try again? */ 10753510Svi117747 if (sctp_ipif == NULL) { 10764311Svi117747 cmn_err(CE_WARN, "sctp_update_ipif_addr: error adding " 10774311Svi117747 "IPIF %p to SCTP's IPIF list", (void *)ipif); 10783510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 10793510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 10803510Svi117747 return; 10813510Svi117747 } 10823510Svi117747 sctps->sctps_g_ipifs_count++; 10833510Svi117747 rw_init(&sctp_ipif->sctp_ipif_lock, NULL, RW_DEFAULT, NULL); 10843510Svi117747 sctp_ipif->sctp_ipif_saddr = ipif->ipif_v6lcl_addr; 10853510Svi117747 sctp_ipif->sctp_ipif_ill = sctp_ill; 10863510Svi117747 sctp_ipif->sctp_ipif_isv6 = ill->ill_isv6; 10873510Svi117747 sctp_ipif->sctp_ipif_zoneid = ipif->ipif_zoneid; 10883510Svi117747 sctp_ipif->sctp_ipif_id = ipif->ipif_seqid; 10893510Svi117747 if (ipif->ipif_flags & IPIF_UP) 10903510Svi117747 sctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 10913510Svi117747 else 10923510Svi117747 sctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 10933510Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 10943510Svi117747 /* 10953510Svi117747 * We add it to the head so that it is quicker to find good/recent 10963510Svi117747 * additions. 10973510Svi117747 */ 10983510Svi117747 list_insert_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 10993510Svi117747 (void *)sctp_ipif); 11003510Svi117747 sctps->sctps_g_ipifs[hindex].ipif_count++; 11013510Svi117747 atomic_add_32(&sctp_ill->sctp_ill_ipifcnt, 1); 11023510Svi117747 if (sctp_ipif->sctp_ipif_state == SCTP_IPIFS_UP) 11033510Svi117747 sctp_chk_and_updt_saddr(hindex, sctp_ipif, sctps); 11043510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 11053510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 11063510Svi117747 } 11073510Svi117747 11080Sstevel@tonic-gate /* Insert, Remove, Mark up or Mark down the ipif */ 11090Sstevel@tonic-gate void 11100Sstevel@tonic-gate sctp_update_ipif(ipif_t *ipif, int op) 11110Sstevel@tonic-gate { 11120Sstevel@tonic-gate ill_t *ill = ipif->ipif_ill; 11130Sstevel@tonic-gate int i; 11140Sstevel@tonic-gate sctp_ill_t *sctp_ill; 11150Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 11160Sstevel@tonic-gate uint_t ill_index; 11173510Svi117747 uint_t hindex; 11183448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 11193448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 11200Sstevel@tonic-gate 11210Sstevel@tonic-gate ip2dbg(("sctp_update_ipif: %s %d\n", ill->ill_name, ipif->ipif_seqid)); 11220Sstevel@tonic-gate 11233448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 11243448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_WRITER); 11250Sstevel@tonic-gate 11260Sstevel@tonic-gate ill_index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 11273448Sdh155122 sctp_ill = list_head(&sctps->sctps_g_ills[ill_index].sctp_ill_list); 11283448Sdh155122 for (i = 0; i < sctps->sctps_g_ills[ill_index].ill_count; i++) { 11294311Svi117747 if (sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill) && 11304311Svi117747 sctp_ill->sctp_ill_isv6 == ill->ill_isv6) { 11310Sstevel@tonic-gate break; 11324311Svi117747 } 11333448Sdh155122 sctp_ill = list_next( 11343448Sdh155122 &sctps->sctps_g_ills[ill_index].sctp_ill_list, sctp_ill); 11350Sstevel@tonic-gate } 11360Sstevel@tonic-gate if (sctp_ill == NULL) { 11373448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 11383448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 11390Sstevel@tonic-gate return; 11400Sstevel@tonic-gate } 11410Sstevel@tonic-gate 11423510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, 11433510Svi117747 ipif->ipif_ill->ill_isv6); 11443510Svi117747 sctp_ipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 11453510Svi117747 for (i = 0; i < sctps->sctps_g_ipifs[hindex].ipif_count; i++) { 11463510Svi117747 if (sctp_ipif->sctp_ipif_id == ipif->ipif_seqid) { 11473510Svi117747 ASSERT(IN6_ARE_ADDR_EQUAL(&sctp_ipif->sctp_ipif_saddr, 11483510Svi117747 &ipif->ipif_v6lcl_addr)); 11490Sstevel@tonic-gate break; 11503510Svi117747 } 11513448Sdh155122 sctp_ipif = list_next( 11523510Svi117747 &sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 11530Sstevel@tonic-gate sctp_ipif); 11540Sstevel@tonic-gate } 11553510Svi117747 if (sctp_ipif == NULL) { 11560Sstevel@tonic-gate ip1dbg(("sctp_update_ipif: null sctp_ipif for %d\n", op)); 11573448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 11583448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 11590Sstevel@tonic-gate return; 11600Sstevel@tonic-gate } 11613510Svi117747 ASSERT(sctp_ill == sctp_ipif->sctp_ipif_ill); 11620Sstevel@tonic-gate switch (op) { 11630Sstevel@tonic-gate case SCTP_IPIF_REMOVE: 11640Sstevel@tonic-gate { 11650Sstevel@tonic-gate list_t *ipif_list; 11660Sstevel@tonic-gate list_t *ill_list; 11670Sstevel@tonic-gate 11683448Sdh155122 ill_list = &sctps->sctps_g_ills[ill_index].sctp_ill_list; 11693510Svi117747 ipif_list = &sctps->sctps_g_ipifs[hindex].sctp_ipif_list; 11700Sstevel@tonic-gate if (sctp_ipif->sctp_ipif_refcnt != 0) { 11710Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_CONDEMNED; 11723448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 11733448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 11740Sstevel@tonic-gate return; 11750Sstevel@tonic-gate } 11760Sstevel@tonic-gate list_remove(ipif_list, (void *)sctp_ipif); 11773510Svi117747 sctps->sctps_g_ipifs[hindex].ipif_count--; 11783448Sdh155122 sctps->sctps_g_ipifs_count--; 11790Sstevel@tonic-gate rw_destroy(&sctp_ipif->sctp_ipif_lock); 11800Sstevel@tonic-gate kmem_free(sctp_ipif, sizeof (sctp_ipif_t)); 11810Sstevel@tonic-gate (void) atomic_add_32_nv(&sctp_ill->sctp_ill_ipifcnt, -1); 11823448Sdh155122 if (rw_tryupgrade(&sctps->sctps_g_ills_lock) != 0) { 11833448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 11840Sstevel@tonic-gate if (sctp_ill->sctp_ill_ipifcnt == 0 && 11850Sstevel@tonic-gate sctp_ill->sctp_ill_state == SCTP_ILLS_CONDEMNED) { 11860Sstevel@tonic-gate list_remove(ill_list, (void *)sctp_ill); 11873448Sdh155122 sctps->sctps_ills_count--; 11883448Sdh155122 sctps->sctps_g_ills[ill_index].ill_count--; 11890Sstevel@tonic-gate kmem_free(sctp_ill->sctp_ill_name, 11900Sstevel@tonic-gate sctp_ill->sctp_ill_name_length); 11910Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 11920Sstevel@tonic-gate } 11930Sstevel@tonic-gate } 11940Sstevel@tonic-gate break; 11950Sstevel@tonic-gate } 11960Sstevel@tonic-gate 11970Sstevel@tonic-gate case SCTP_IPIF_UP: 11980Sstevel@tonic-gate 11993448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 12000Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 12010Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 12023510Svi117747 sctp_ipif->sctp_ipif_mtu = ipif->ipif_mtu; 1203432Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 12040Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 12053510Svi117747 sctp_chk_and_updt_saddr(hindex, sctp_ipif, 12063510Svi117747 ipif->ipif_ill->ill_ipst->ips_netstack->netstack_sctp); 12070Sstevel@tonic-gate 12080Sstevel@tonic-gate break; 12090Sstevel@tonic-gate 12100Sstevel@tonic-gate case SCTP_IPIF_UPDATE: 12110Sstevel@tonic-gate 12123448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 12130Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 12140Sstevel@tonic-gate sctp_ipif->sctp_ipif_mtu = ipif->ipif_mtu; 12150Sstevel@tonic-gate sctp_ipif->sctp_ipif_zoneid = ipif->ipif_zoneid; 1216432Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 12170Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 12180Sstevel@tonic-gate 12190Sstevel@tonic-gate break; 12200Sstevel@tonic-gate 12210Sstevel@tonic-gate case SCTP_IPIF_DOWN: 12220Sstevel@tonic-gate 12233448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 12240Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 12250Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 12263510Svi117747 sctp_ipif->sctp_ipif_mtu = ipif->ipif_mtu; 12273510Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 12280Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 12290Sstevel@tonic-gate 12300Sstevel@tonic-gate break; 12310Sstevel@tonic-gate } 12323448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 12333448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 12340Sstevel@tonic-gate } 12350Sstevel@tonic-gate 12360Sstevel@tonic-gate /* 12370Sstevel@tonic-gate * SCTP source address list manipulaton, locking not used (except for 12380Sstevel@tonic-gate * sctp locking by the caller. 12390Sstevel@tonic-gate */ 12400Sstevel@tonic-gate 12410Sstevel@tonic-gate /* Remove a specific saddr from the list */ 12420Sstevel@tonic-gate void 12430Sstevel@tonic-gate sctp_del_saddr(sctp_t *sctp, sctp_saddr_ipif_t *sp) 12440Sstevel@tonic-gate { 12450Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12460Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 12470Sstevel@tonic-gate 12480Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12490Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 12500Sstevel@tonic-gate 12510Sstevel@tonic-gate sctp_ipif_hash_remove(sctp, sp->saddr_ipifp); 12520Sstevel@tonic-gate 1253432Svi117747 if (sctp->sctp_bound_to_all == 1) 12540Sstevel@tonic-gate sctp->sctp_bound_to_all = 0; 12550Sstevel@tonic-gate 12560Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12570Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 12580Sstevel@tonic-gate 12590Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12600Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 12610Sstevel@tonic-gate } 12620Sstevel@tonic-gate 12630Sstevel@tonic-gate /* 12640Sstevel@tonic-gate * Delete source address from the existing list. No error checking done here 12650Sstevel@tonic-gate * Called with no locks held. 12660Sstevel@tonic-gate */ 12670Sstevel@tonic-gate void 12680Sstevel@tonic-gate sctp_del_saddr_list(sctp_t *sctp, const void *addrs, int addcnt, 12690Sstevel@tonic-gate boolean_t fanout_locked) 12700Sstevel@tonic-gate { 12710Sstevel@tonic-gate struct sockaddr_in *sin4; 12720Sstevel@tonic-gate struct sockaddr_in6 *sin6; 12730Sstevel@tonic-gate int cnt; 12740Sstevel@tonic-gate in6_addr_t addr; 12750Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 1276852Svi117747 int ifindex = 0; 12770Sstevel@tonic-gate 1278852Svi117747 ASSERT(sctp->sctp_nsaddrs >= addcnt); 12790Sstevel@tonic-gate 12800Sstevel@tonic-gate if (!fanout_locked) { 12810Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12820Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 12830Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12840Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 12850Sstevel@tonic-gate } 12860Sstevel@tonic-gate 12870Sstevel@tonic-gate for (cnt = 0; cnt < addcnt; cnt++) { 12880Sstevel@tonic-gate switch (sctp->sctp_family) { 12890Sstevel@tonic-gate case AF_INET: 12900Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + cnt; 12910Sstevel@tonic-gate IN6_INADDR_TO_V4MAPPED(&sin4->sin_addr, &addr); 12920Sstevel@tonic-gate break; 12930Sstevel@tonic-gate 12940Sstevel@tonic-gate case AF_INET6: 12950Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + cnt; 12960Sstevel@tonic-gate addr = sin6->sin6_addr; 1297852Svi117747 ifindex = sin6->sin6_scope_id; 12980Sstevel@tonic-gate break; 12990Sstevel@tonic-gate } 13003510Svi117747 sctp_ipif = sctp_lookup_ipif_addr(&addr, B_FALSE, 13013510Svi117747 sctp->sctp_zoneid, !sctp->sctp_connp->conn_allzones, 13023510Svi117747 ifindex, 0, B_TRUE, sctp->sctp_sctps); 13030Sstevel@tonic-gate ASSERT(sctp_ipif != NULL); 13040Sstevel@tonic-gate sctp_ipif_hash_remove(sctp, sctp_ipif); 13050Sstevel@tonic-gate } 1306432Svi117747 if (sctp->sctp_bound_to_all == 1) 13070Sstevel@tonic-gate sctp->sctp_bound_to_all = 0; 13080Sstevel@tonic-gate 13090Sstevel@tonic-gate if (!fanout_locked) { 13100Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 13110Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 13120Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 13130Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 13140Sstevel@tonic-gate } 13150Sstevel@tonic-gate } 13160Sstevel@tonic-gate 13170Sstevel@tonic-gate /* 13180Sstevel@tonic-gate * Given an address get the corresponding entry from the list 13190Sstevel@tonic-gate * Called with no locks held. 13200Sstevel@tonic-gate */ 13210Sstevel@tonic-gate sctp_saddr_ipif_t * 1322852Svi117747 sctp_saddr_lookup(sctp_t *sctp, in6_addr_t *addr, uint_t ifindex) 13230Sstevel@tonic-gate { 13243510Svi117747 int cnt; 13253510Svi117747 sctp_saddr_ipif_t *ipif_obj; 13263510Svi117747 int hindex; 13270Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 13280Sstevel@tonic-gate 13293510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(*addr, !IN6_IS_ADDR_V4MAPPED(addr)); 13303510Svi117747 if (sctp->sctp_saddrs[hindex].ipif_count == 0) 13310Sstevel@tonic-gate return (NULL); 13320Sstevel@tonic-gate 13333510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 13343510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 13353510Svi117747 sctp_ipif = ipif_obj->saddr_ipifp; 13363510Svi117747 /* 13373510Svi117747 * Zone check shouldn't be needed. 13383510Svi117747 */ 13393510Svi117747 if (IN6_ARE_ADDR_EQUAL(addr, &sctp_ipif->sctp_ipif_saddr) && 13403510Svi117747 (ifindex == 0 || 13413510Svi117747 ifindex == sctp_ipif->sctp_ipif_ill->sctp_ill_index) && 13423510Svi117747 SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state)) { 13433510Svi117747 return (ipif_obj); 13443510Svi117747 } 13453510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 13463510Svi117747 ipif_obj); 13473510Svi117747 } 13483510Svi117747 return (NULL); 13490Sstevel@tonic-gate } 13500Sstevel@tonic-gate 1351432Svi117747 /* Given an address, add it to the source address list */ 1352432Svi117747 int 1353852Svi117747 sctp_saddr_add_addr(sctp_t *sctp, in6_addr_t *addr, uint_t ifindex) 1354432Svi117747 { 1355432Svi117747 sctp_ipif_t *sctp_ipif; 1356432Svi117747 13573510Svi117747 sctp_ipif = sctp_lookup_ipif_addr(addr, B_TRUE, sctp->sctp_zoneid, 13583510Svi117747 !sctp->sctp_connp->conn_allzones, ifindex, 0, B_TRUE, 13593510Svi117747 sctp->sctp_sctps); 1360432Svi117747 if (sctp_ipif == NULL) 1361432Svi117747 return (EINVAL); 1362432Svi117747 13633510Svi117747 if (sctp_ipif_hash_insert(sctp, sctp_ipif, KM_NOSLEEP, B_FALSE, 13643510Svi117747 B_FALSE) != 0) { 1365432Svi117747 SCTP_IPIF_REFRELE(sctp_ipif); 1366432Svi117747 return (EINVAL); 1367432Svi117747 } 1368432Svi117747 return (0); 1369432Svi117747 } 1370432Svi117747 1371432Svi117747 /* 1372432Svi117747 * Remove or mark as dontsrc addresses that are currently not part of the 1373432Svi117747 * association. One would delete addresses when processing an INIT and 1374432Svi117747 * mark as dontsrc when processing an INIT-ACK. 1375432Svi117747 */ 1376432Svi117747 void 13774818Skcpoon sctp_check_saddr(sctp_t *sctp, int supp_af, boolean_t delete, 13784818Skcpoon in6_addr_t *no_del_addr) 1379432Svi117747 { 1380432Svi117747 int i; 1381432Svi117747 int l; 1382432Svi117747 sctp_saddr_ipif_t *obj; 1383432Svi117747 int scanned = 0; 1384432Svi117747 int naddr; 1385432Svi117747 int nsaddr; 1386432Svi117747 1387432Svi117747 ASSERT(!sctp->sctp_loopback && !sctp->sctp_linklocal && supp_af != 0); 1388432Svi117747 1389432Svi117747 /* 1390432Svi117747 * Irregardless of the supported address in the INIT, v4 1391432Svi117747 * must be supported. 1392432Svi117747 */ 1393432Svi117747 if (sctp->sctp_family == AF_INET) 1394432Svi117747 supp_af = PARM_SUPP_V4; 1395432Svi117747 1396432Svi117747 nsaddr = sctp->sctp_nsaddrs; 1397432Svi117747 for (i = 0; i < SCTP_IPIF_HASH; i++) { 1398432Svi117747 if (sctp->sctp_saddrs[i].ipif_count == 0) 1399432Svi117747 continue; 1400432Svi117747 obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 1401432Svi117747 naddr = sctp->sctp_saddrs[i].ipif_count; 1402432Svi117747 for (l = 0; l < naddr; l++) { 1403432Svi117747 sctp_ipif_t *ipif; 1404432Svi117747 1405432Svi117747 ipif = obj->saddr_ipifp; 1406432Svi117747 scanned++; 1407432Svi117747 14084818Skcpoon if (IN6_ARE_ADDR_EQUAL(&ipif->sctp_ipif_saddr, 14094818Skcpoon no_del_addr)) { 14104818Skcpoon goto next_obj; 14114818Skcpoon } 14124818Skcpoon 1413432Svi117747 /* 1414432Svi117747 * Delete/mark dontsrc loopback/linklocal addresses and 1415432Svi117747 * unsupported address. 1416852Svi117747 * On a clustered node, we trust the clustering module 1417852Svi117747 * to do the right thing w.r.t loopback addresses, so 1418852Svi117747 * we ignore loopback addresses in this check. 1419432Svi117747 */ 1420852Svi117747 if ((SCTP_IS_IPIF_LOOPBACK(ipif) && 1421852Svi117747 cl_sctp_check_addrs == NULL) || 1422852Svi117747 SCTP_IS_IPIF_LINKLOCAL(ipif) || 1423432Svi117747 SCTP_UNSUPP_AF(ipif, supp_af)) { 1424432Svi117747 if (!delete) { 1425432Svi117747 obj->saddr_ipif_unconfirmed = 1; 1426432Svi117747 goto next_obj; 1427432Svi117747 } 1428432Svi117747 if (sctp->sctp_bound_to_all == 1) 1429432Svi117747 sctp->sctp_bound_to_all = 0; 1430432Svi117747 if (scanned < nsaddr) { 1431432Svi117747 obj = list_next(&sctp->sctp_saddrs[i]. 1432432Svi117747 sctp_ipif_list, obj); 1433432Svi117747 sctp_ipif_hash_remove(sctp, ipif); 1434432Svi117747 continue; 1435432Svi117747 } 1436432Svi117747 sctp_ipif_hash_remove(sctp, ipif); 1437432Svi117747 } 1438432Svi117747 next_obj: 1439432Svi117747 if (scanned >= nsaddr) 1440432Svi117747 return; 1441432Svi117747 obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 1442432Svi117747 obj); 1443432Svi117747 } 1444432Svi117747 } 1445432Svi117747 } 1446432Svi117747 1447432Svi117747 14480Sstevel@tonic-gate /* Get the first valid address from the list. Called with no locks held */ 14490Sstevel@tonic-gate in6_addr_t 14504818Skcpoon sctp_get_valid_addr(sctp_t *sctp, boolean_t isv6, boolean_t *addr_set) 14510Sstevel@tonic-gate { 14520Sstevel@tonic-gate int i; 14530Sstevel@tonic-gate int l; 14540Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 14550Sstevel@tonic-gate int scanned = 0; 14560Sstevel@tonic-gate in6_addr_t addr; 14570Sstevel@tonic-gate 14580Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 14590Sstevel@tonic-gate if (sctp->sctp_saddrs[i].ipif_count == 0) 14600Sstevel@tonic-gate continue; 14610Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 14620Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 14630Sstevel@tonic-gate sctp_ipif_t *ipif; 14640Sstevel@tonic-gate 14650Sstevel@tonic-gate ipif = obj->saddr_ipifp; 1466432Svi117747 if (!SCTP_DONT_SRC(obj) && 14670Sstevel@tonic-gate ipif->sctp_ipif_isv6 == isv6 && 1468432Svi117747 ipif->sctp_ipif_state == SCTP_IPIFS_UP) { 14694818Skcpoon *addr_set = B_TRUE; 14700Sstevel@tonic-gate return (ipif->sctp_ipif_saddr); 14710Sstevel@tonic-gate } 14720Sstevel@tonic-gate scanned++; 14730Sstevel@tonic-gate if (scanned >= sctp->sctp_nsaddrs) 14740Sstevel@tonic-gate goto got_none; 14750Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 14760Sstevel@tonic-gate obj); 14770Sstevel@tonic-gate } 14780Sstevel@tonic-gate } 14790Sstevel@tonic-gate got_none: 14800Sstevel@tonic-gate /* Need to double check this */ 14810Sstevel@tonic-gate if (isv6 == B_TRUE) 14820Sstevel@tonic-gate addr = ipv6_all_zeros; 14830Sstevel@tonic-gate else 14840Sstevel@tonic-gate IN6_IPADDR_TO_V4MAPPED(0, &addr); 14854818Skcpoon *addr_set = B_FALSE; 14860Sstevel@tonic-gate return (addr); 14870Sstevel@tonic-gate } 14880Sstevel@tonic-gate 14890Sstevel@tonic-gate /* 14900Sstevel@tonic-gate * Return the list of local addresses of an association. The parameter 14910Sstevel@tonic-gate * myaddrs is supposed to be either (struct sockaddr_in *) or (struct 14920Sstevel@tonic-gate * sockaddr_in6 *) depending on the address family. 14930Sstevel@tonic-gate */ 14940Sstevel@tonic-gate int 14950Sstevel@tonic-gate sctp_getmyaddrs(void *conn, void *myaddrs, int *addrcnt) 14960Sstevel@tonic-gate { 14970Sstevel@tonic-gate int i; 14980Sstevel@tonic-gate int l; 14990Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 15000Sstevel@tonic-gate sctp_t *sctp = (sctp_t *)conn; 15010Sstevel@tonic-gate int family = sctp->sctp_family; 15020Sstevel@tonic-gate int max = *addrcnt; 15030Sstevel@tonic-gate size_t added = 0; 15040Sstevel@tonic-gate struct sockaddr_in6 *sin6; 15050Sstevel@tonic-gate struct sockaddr_in *sin4; 15060Sstevel@tonic-gate int scanned = 0; 15070Sstevel@tonic-gate boolean_t skip_lback = B_FALSE; 15080Sstevel@tonic-gate 15090Sstevel@tonic-gate if (sctp->sctp_nsaddrs == 0) 15100Sstevel@tonic-gate return (EINVAL); 15110Sstevel@tonic-gate 1512852Svi117747 /* 1513852Svi117747 * Skip loopback addresses for non-loopback assoc., ignore 1514852Svi117747 * this on a clustered node. 1515852Svi117747 */ 1516852Svi117747 if (sctp->sctp_state >= SCTPS_ESTABLISHED && !sctp->sctp_loopback && 1517852Svi117747 (cl_sctp_check_addrs == NULL)) { 15180Sstevel@tonic-gate skip_lback = B_TRUE; 1519852Svi117747 } 1520852Svi117747 15210Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 15220Sstevel@tonic-gate if (sctp->sctp_saddrs[i].ipif_count == 0) 15230Sstevel@tonic-gate continue; 15240Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 15250Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 15260Sstevel@tonic-gate sctp_ipif_t *ipif = obj->saddr_ipifp; 15270Sstevel@tonic-gate in6_addr_t addr = ipif->sctp_ipif_saddr; 15280Sstevel@tonic-gate 15290Sstevel@tonic-gate scanned++; 15300Sstevel@tonic-gate if ((ipif->sctp_ipif_state == SCTP_IPIFS_CONDEMNED) || 1531432Svi117747 SCTP_DONT_SRC(obj) || 1532852Svi117747 (SCTP_IS_IPIF_LOOPBACK(ipif) && skip_lback)) { 15330Sstevel@tonic-gate if (scanned >= sctp->sctp_nsaddrs) 15340Sstevel@tonic-gate goto done; 15350Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i]. 15360Sstevel@tonic-gate sctp_ipif_list, obj); 15370Sstevel@tonic-gate continue; 15380Sstevel@tonic-gate } 15390Sstevel@tonic-gate switch (family) { 15400Sstevel@tonic-gate case AF_INET: 15410Sstevel@tonic-gate sin4 = (struct sockaddr_in *)myaddrs + added; 15420Sstevel@tonic-gate sin4->sin_family = AF_INET; 15430Sstevel@tonic-gate sin4->sin_port = sctp->sctp_lport; 15440Sstevel@tonic-gate IN6_V4MAPPED_TO_INADDR(&addr, &sin4->sin_addr); 15450Sstevel@tonic-gate break; 15460Sstevel@tonic-gate 15470Sstevel@tonic-gate case AF_INET6: 15480Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)myaddrs + added; 15490Sstevel@tonic-gate sin6->sin6_family = AF_INET6; 15500Sstevel@tonic-gate sin6->sin6_port = sctp->sctp_lport; 15510Sstevel@tonic-gate sin6->sin6_addr = addr; 15520Sstevel@tonic-gate break; 15530Sstevel@tonic-gate } 15540Sstevel@tonic-gate added++; 15550Sstevel@tonic-gate if (added >= max || scanned >= sctp->sctp_nsaddrs) 15560Sstevel@tonic-gate goto done; 15570Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 15580Sstevel@tonic-gate obj); 15590Sstevel@tonic-gate } 15600Sstevel@tonic-gate } 15610Sstevel@tonic-gate done: 15620Sstevel@tonic-gate *addrcnt = added; 15630Sstevel@tonic-gate return (0); 15640Sstevel@tonic-gate } 15650Sstevel@tonic-gate 15660Sstevel@tonic-gate /* 1567252Svi117747 * Given the supported address family, walk through the source address list 1568252Svi117747 * and return the total length of the available addresses. If 'p' is not 1569252Svi117747 * null, construct the parameter list for the addresses in 'p'. 1570432Svi117747 * 'modify' will only be set when we want the source address list to 1571432Svi117747 * be modified. The source address list will be modified only when 1572432Svi117747 * generating an INIT chunk. For generating an INIT-ACK 'modify' will 1573432Svi117747 * be false since the 'sctp' will be that of the listener. 15740Sstevel@tonic-gate */ 15750Sstevel@tonic-gate size_t 1576432Svi117747 sctp_saddr_info(sctp_t *sctp, int supp_af, uchar_t *p, boolean_t modify) 15770Sstevel@tonic-gate { 15780Sstevel@tonic-gate int i; 15790Sstevel@tonic-gate int l; 15800Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 1581252Svi117747 size_t paramlen = 0; 15820Sstevel@tonic-gate sctp_parm_hdr_t *hdr; 15830Sstevel@tonic-gate int scanned = 0; 1584432Svi117747 int naddr; 1585432Svi117747 int nsaddr; 1586852Svi117747 boolean_t del_ll = B_FALSE; 1587852Svi117747 boolean_t del_lb = B_FALSE; 1588852Svi117747 15890Sstevel@tonic-gate 1590852Svi117747 /* 1591852Svi117747 * On a clustered node don't bother changing anything 1592852Svi117747 * on the loopback interface. 1593852Svi117747 */ 1594852Svi117747 if (modify && !sctp->sctp_loopback && (cl_sctp_check_addrs == NULL)) 1595852Svi117747 del_lb = B_TRUE; 1596852Svi117747 1597852Svi117747 if (modify && !sctp->sctp_linklocal) 1598852Svi117747 del_ll = B_TRUE; 1599432Svi117747 1600432Svi117747 nsaddr = sctp->sctp_nsaddrs; 16010Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 16020Sstevel@tonic-gate if (sctp->sctp_saddrs[i].ipif_count == 0) 16030Sstevel@tonic-gate continue; 16040Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 1605432Svi117747 naddr = sctp->sctp_saddrs[i].ipif_count; 1606432Svi117747 for (l = 0; l < naddr; l++) { 16070Sstevel@tonic-gate in6_addr_t addr; 16080Sstevel@tonic-gate sctp_ipif_t *ipif; 1609852Svi117747 boolean_t ipif_lb; 1610852Svi117747 boolean_t ipif_ll; 1611432Svi117747 boolean_t unsupp_af; 16120Sstevel@tonic-gate 16130Sstevel@tonic-gate ipif = obj->saddr_ipifp; 16140Sstevel@tonic-gate scanned++; 1615432Svi117747 1616852Svi117747 ipif_lb = SCTP_IS_IPIF_LOOPBACK(ipif); 1617852Svi117747 ipif_ll = SCTP_IS_IPIF_LINKLOCAL(ipif); 1618432Svi117747 unsupp_af = SCTP_UNSUPP_AF(ipif, supp_af); 1619432Svi117747 /* 1620432Svi117747 * We need to either delete or skip loopback/linklocal 1621852Svi117747 * or unsupported addresses, if required. 1622432Svi117747 */ 1623852Svi117747 if ((ipif_ll && del_ll) || (ipif_lb && del_lb) || 1624852Svi117747 (unsupp_af && modify)) { 1625432Svi117747 if (sctp->sctp_bound_to_all == 1) 1626432Svi117747 sctp->sctp_bound_to_all = 0; 1627432Svi117747 if (scanned < nsaddr) { 1628432Svi117747 obj = list_next(&sctp->sctp_saddrs[i]. 1629432Svi117747 sctp_ipif_list, obj); 1630432Svi117747 sctp_ipif_hash_remove(sctp, ipif); 1631432Svi117747 continue; 1632432Svi117747 } 1633432Svi117747 sctp_ipif_hash_remove(sctp, ipif); 1634432Svi117747 goto next_addr; 1635852Svi117747 } else if (ipif_ll || unsupp_af || 1636852Svi117747 (ipif_lb && (cl_sctp_check_addrs == NULL))) { 1637252Svi117747 goto next_addr; 16380Sstevel@tonic-gate } 1639432Svi117747 1640432Svi117747 if (!SCTP_IPIF_USABLE(ipif->sctp_ipif_state)) 1641432Svi117747 goto next_addr; 1642252Svi117747 if (p != NULL) 1643252Svi117747 hdr = (sctp_parm_hdr_t *)(p + paramlen); 16440Sstevel@tonic-gate addr = ipif->sctp_ipif_saddr; 1645432Svi117747 if (!ipif->sctp_ipif_isv6) { 16460Sstevel@tonic-gate struct in_addr *v4; 16470Sstevel@tonic-gate 1648252Svi117747 if (p != NULL) { 1649252Svi117747 hdr->sph_type = htons(PARM_ADDR4); 1650252Svi117747 hdr->sph_len = htons(PARM_ADDR4_LEN); 1651252Svi117747 v4 = (struct in_addr *)(hdr + 1); 1652252Svi117747 IN6_V4MAPPED_TO_INADDR(&addr, v4); 1653252Svi117747 } 1654252Svi117747 paramlen += PARM_ADDR4_LEN; 1655432Svi117747 } else { 1656252Svi117747 if (p != NULL) { 1657252Svi117747 hdr->sph_type = htons(PARM_ADDR6); 1658252Svi117747 hdr->sph_len = htons(PARM_ADDR6_LEN); 1659252Svi117747 bcopy(&addr, hdr + 1, sizeof (addr)); 1660252Svi117747 } 1661252Svi117747 paramlen += PARM_ADDR6_LEN; 16620Sstevel@tonic-gate } 1663252Svi117747 next_addr: 1664432Svi117747 if (scanned >= nsaddr) 1665252Svi117747 return (paramlen); 16660Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 16670Sstevel@tonic-gate obj); 16680Sstevel@tonic-gate } 16690Sstevel@tonic-gate } 1670252Svi117747 return (paramlen); 16710Sstevel@tonic-gate } 16720Sstevel@tonic-gate 1673852Svi117747 /* 1674852Svi117747 * This is used on a clustered node to obtain a list of addresses, the list 1675852Svi117747 * consists of sockaddr_in structs for v4 and sockaddr_in6 for v6. The list 1676852Svi117747 * is then passed onto the clustering module which sends back the correct 1677852Svi117747 * list based on the port info. Regardless of the input, i.e INADDR_ANY 1678852Svi117747 * or specific address(es), we create the list since it could be modified by 1679852Svi117747 * the clustering module. When given a list of addresses, we simply 1680852Svi117747 * create the list of sockaddr_in or sockaddr_in6 structs using those 1681852Svi117747 * addresses. If there is an INADDR_ANY in the input list, or if the 1682852Svi117747 * input is INADDR_ANY, we create a list of sockaddr_in or sockaddr_in6 1683852Svi117747 * structs consisting all the addresses in the global interface list 1684852Svi117747 * except those that are hosted on the loopback interface. We create 1685852Svi117747 * a list of sockaddr_in[6] structs just so that it can be directly input 1686852Svi117747 * to sctp_valid_addr_list() once the clustering module has processed it. 1687852Svi117747 */ 1688852Svi117747 int 1689852Svi117747 sctp_get_addrlist(sctp_t *sctp, const void *addrs, uint32_t *addrcnt, 1690852Svi117747 uchar_t **addrlist, int *uspec, size_t *size) 1691852Svi117747 { 1692852Svi117747 int cnt; 1693852Svi117747 int icnt; 1694852Svi117747 sctp_ipif_t *sctp_ipif; 1695852Svi117747 struct sockaddr_in *s4; 1696852Svi117747 struct sockaddr_in6 *s6; 1697852Svi117747 uchar_t *p; 1698852Svi117747 int err = 0; 16993448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps; 1700852Svi117747 1701852Svi117747 *addrlist = NULL; 1702852Svi117747 *size = 0; 1703852Svi117747 1704852Svi117747 /* 1705852Svi117747 * Create a list of sockaddr_in[6] structs using the input list. 1706852Svi117747 */ 1707852Svi117747 if (sctp->sctp_family == AF_INET) { 1708852Svi117747 *size = sizeof (struct sockaddr_in) * *addrcnt; 1709852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1710852Svi117747 p = *addrlist; 1711852Svi117747 for (cnt = 0; cnt < *addrcnt; cnt++) { 1712852Svi117747 s4 = (struct sockaddr_in *)addrs + cnt; 1713852Svi117747 /* 1714852Svi117747 * We need to create a list of all the available 1715852Svi117747 * addresses if there is an INADDR_ANY. However, 1716852Svi117747 * if we are beyond LISTEN, then this is invalid 1717852Svi117747 * (see sctp_valid_addr_list(). So, we just fail 1718852Svi117747 * it here rather than wait till it fails in 1719852Svi117747 * sctp_valid_addr_list(). 1720852Svi117747 */ 1721852Svi117747 if (s4->sin_addr.s_addr == INADDR_ANY) { 1722852Svi117747 kmem_free(*addrlist, *size); 1723852Svi117747 *addrlist = NULL; 1724852Svi117747 *size = 0; 1725852Svi117747 if (sctp->sctp_state > SCTPS_LISTEN) { 1726852Svi117747 *addrcnt = 0; 1727852Svi117747 return (EINVAL); 1728852Svi117747 } 1729852Svi117747 if (uspec != NULL) 1730852Svi117747 *uspec = 1; 1731852Svi117747 goto get_all_addrs; 1732852Svi117747 } else { 1733852Svi117747 bcopy(s4, p, sizeof (*s4)); 1734852Svi117747 p += sizeof (*s4); 1735852Svi117747 } 1736852Svi117747 } 1737852Svi117747 } else { 1738852Svi117747 *size = sizeof (struct sockaddr_in6) * *addrcnt; 1739852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1740852Svi117747 p = *addrlist; 1741852Svi117747 for (cnt = 0; cnt < *addrcnt; cnt++) { 1742852Svi117747 s6 = (struct sockaddr_in6 *)addrs + cnt; 1743852Svi117747 /* 1744852Svi117747 * Comments for INADDR_ANY, above, apply here too. 1745852Svi117747 */ 1746852Svi117747 if (IN6_IS_ADDR_UNSPECIFIED(&s6->sin6_addr)) { 1747852Svi117747 kmem_free(*addrlist, *size); 1748852Svi117747 *size = 0; 1749852Svi117747 *addrlist = NULL; 1750852Svi117747 if (sctp->sctp_state > SCTPS_LISTEN) { 1751852Svi117747 *addrcnt = 0; 1752852Svi117747 return (EINVAL); 1753852Svi117747 } 1754852Svi117747 if (uspec != NULL) 1755852Svi117747 *uspec = 1; 1756852Svi117747 goto get_all_addrs; 1757852Svi117747 } else { 1758852Svi117747 bcopy(addrs, p, sizeof (*s6)); 1759852Svi117747 p += sizeof (*s6); 1760852Svi117747 } 1761852Svi117747 } 1762852Svi117747 } 1763852Svi117747 return (err); 1764852Svi117747 get_all_addrs: 1765852Svi117747 1766852Svi117747 /* 1767852Svi117747 * Allocate max possible size. We allocate the max. size here because 1768852Svi117747 * the clustering module could end up adding addresses to the list. 1769852Svi117747 * We allocate upfront so that the clustering module need to bother 1770852Svi117747 * re-sizing the list. 1771852Svi117747 */ 17723448Sdh155122 if (sctp->sctp_family == AF_INET) { 17733448Sdh155122 *size = sizeof (struct sockaddr_in) * 17743448Sdh155122 sctps->sctps_g_ipifs_count; 17753448Sdh155122 } else { 17763448Sdh155122 *size = sizeof (struct sockaddr_in6) * 17773448Sdh155122 sctps->sctps_g_ipifs_count; 17783448Sdh155122 } 1779852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1780852Svi117747 *addrcnt = 0; 1781852Svi117747 p = *addrlist; 17823448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 1783852Svi117747 1784852Svi117747 /* 1785852Svi117747 * Walk through the global interface list and add all addresses, 1786852Svi117747 * except those that are hosted on loopback interfaces. 1787852Svi117747 */ 1788852Svi117747 for (cnt = 0; cnt < SCTP_IPIF_HASH; cnt++) { 17893448Sdh155122 if (sctps->sctps_g_ipifs[cnt].ipif_count == 0) 1790852Svi117747 continue; 17913448Sdh155122 sctp_ipif = list_head( 17923448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list); 17933448Sdh155122 for (icnt = 0; 17943448Sdh155122 icnt < sctps->sctps_g_ipifs[cnt].ipif_count; 17953448Sdh155122 icnt++) { 1796852Svi117747 in6_addr_t addr; 1797852Svi117747 1798852Svi117747 rw_enter(&sctp_ipif->sctp_ipif_lock, RW_READER); 1799852Svi117747 addr = sctp_ipif->sctp_ipif_saddr; 1800852Svi117747 if (SCTP_IPIF_DISCARD(sctp_ipif->sctp_ipif_flags) || 1801852Svi117747 !SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state) || 1802852Svi117747 SCTP_IS_IPIF_LOOPBACK(sctp_ipif) || 1803852Svi117747 SCTP_IS_IPIF_LINKLOCAL(sctp_ipif) || 18042263Ssommerfe !SCTP_IPIF_ZONE_MATCH(sctp, sctp_ipif) || 1805852Svi117747 (sctp->sctp_ipversion == IPV4_VERSION && 1806852Svi117747 sctp_ipif->sctp_ipif_isv6) || 1807852Svi117747 (sctp->sctp_connp->conn_ipv6_v6only && 1808852Svi117747 !sctp_ipif->sctp_ipif_isv6)) { 1809852Svi117747 rw_exit(&sctp_ipif->sctp_ipif_lock); 1810852Svi117747 sctp_ipif = list_next( 18113448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list, 1812852Svi117747 sctp_ipif); 1813852Svi117747 continue; 1814852Svi117747 } 1815852Svi117747 rw_exit(&sctp_ipif->sctp_ipif_lock); 1816852Svi117747 if (sctp->sctp_family == AF_INET) { 1817852Svi117747 s4 = (struct sockaddr_in *)p; 1818852Svi117747 IN6_V4MAPPED_TO_INADDR(&addr, &s4->sin_addr); 1819852Svi117747 s4->sin_family = AF_INET; 1820852Svi117747 p += sizeof (*s4); 1821852Svi117747 } else { 1822852Svi117747 s6 = (struct sockaddr_in6 *)p; 1823852Svi117747 s6->sin6_addr = addr; 1824852Svi117747 s6->sin6_family = AF_INET6; 1825852Svi117747 s6->sin6_scope_id = 1826852Svi117747 sctp_ipif->sctp_ipif_ill->sctp_ill_index; 1827852Svi117747 p += sizeof (*s6); 1828852Svi117747 } 1829852Svi117747 (*addrcnt)++; 18303448Sdh155122 sctp_ipif = list_next( 18313448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list, 1832852Svi117747 sctp_ipif); 1833852Svi117747 } 1834852Svi117747 } 18353448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 1836852Svi117747 return (err); 1837852Svi117747 } 1838852Svi117747 1839852Svi117747 /* 1840852Svi117747 * Get a list of addresses from the source address list. The caller is 1841852Svi117747 * responsible for allocating sufficient buffer for this. 1842852Svi117747 */ 1843852Svi117747 void 1844852Svi117747 sctp_get_saddr_list(sctp_t *sctp, uchar_t *p, size_t psize) 1845852Svi117747 { 1846852Svi117747 int cnt; 1847852Svi117747 int icnt; 1848852Svi117747 sctp_saddr_ipif_t *obj; 1849852Svi117747 int naddr; 1850852Svi117747 int scanned = 0; 1851852Svi117747 1852852Svi117747 for (cnt = 0; cnt < SCTP_IPIF_HASH; cnt++) { 1853852Svi117747 if (sctp->sctp_saddrs[cnt].ipif_count == 0) 1854852Svi117747 continue; 1855852Svi117747 obj = list_head(&sctp->sctp_saddrs[cnt].sctp_ipif_list); 1856852Svi117747 naddr = sctp->sctp_saddrs[cnt].ipif_count; 1857852Svi117747 for (icnt = 0; icnt < naddr; icnt++) { 1858852Svi117747 sctp_ipif_t *ipif; 1859852Svi117747 1860852Svi117747 if (psize < sizeof (ipif->sctp_ipif_saddr)) 1861852Svi117747 return; 1862852Svi117747 1863852Svi117747 scanned++; 1864852Svi117747 ipif = obj->saddr_ipifp; 1865852Svi117747 bcopy(&ipif->sctp_ipif_saddr, p, 1866852Svi117747 sizeof (ipif->sctp_ipif_saddr)); 1867852Svi117747 p += sizeof (ipif->sctp_ipif_saddr); 1868852Svi117747 psize -= sizeof (ipif->sctp_ipif_saddr); 1869852Svi117747 if (scanned >= sctp->sctp_nsaddrs) 1870852Svi117747 return; 18713448Sdh155122 obj = list_next( 18723448Sdh155122 &sctp->sctp_saddrs[icnt].sctp_ipif_list, 1873852Svi117747 obj); 1874852Svi117747 } 1875852Svi117747 } 1876852Svi117747 } 1877852Svi117747 1878852Svi117747 /* 1879852Svi117747 * Get a list of addresses from the remote address list. The caller is 1880852Svi117747 * responsible for allocating sufficient buffer for this. 1881852Svi117747 */ 1882852Svi117747 void 1883852Svi117747 sctp_get_faddr_list(sctp_t *sctp, uchar_t *p, size_t psize) 1884852Svi117747 { 1885852Svi117747 sctp_faddr_t *fp; 1886852Svi117747 1887852Svi117747 for (fp = sctp->sctp_faddrs; fp != NULL; fp = fp->next) { 1888852Svi117747 if (psize < sizeof (fp->faddr)) 1889852Svi117747 return; 1890852Svi117747 bcopy(&fp->faddr, p, sizeof (fp->faddr)); 1891852Svi117747 p += sizeof (fp->faddr); 1892852Svi117747 psize -= sizeof (fp->faddr); 1893852Svi117747 } 1894852Svi117747 } 18950Sstevel@tonic-gate 18963448Sdh155122 static void 18973448Sdh155122 sctp_free_ills(sctp_stack_t *sctps) 18983448Sdh155122 { 18993448Sdh155122 int i; 19003448Sdh155122 int l; 19013448Sdh155122 sctp_ill_t *sctp_ill; 19023448Sdh155122 19033448Sdh155122 if (sctps->sctps_ills_count == 0) 19043448Sdh155122 return; 19053448Sdh155122 19063448Sdh155122 for (i = 0; i < SCTP_ILL_HASH; i++) { 19073448Sdh155122 sctp_ill = list_tail(&sctps->sctps_g_ills[i].sctp_ill_list); 19083448Sdh155122 for (l = 0; l < sctps->sctps_g_ills[i].ill_count; l++) { 19093448Sdh155122 ASSERT(sctp_ill->sctp_ill_ipifcnt == 0); 19103448Sdh155122 list_remove(&sctps->sctps_g_ills[i].sctp_ill_list, 19113448Sdh155122 sctp_ill); 19123448Sdh155122 sctps->sctps_ills_count--; 19133448Sdh155122 kmem_free(sctp_ill->sctp_ill_name, 19143448Sdh155122 sctp_ill->sctp_ill_name_length); 19153448Sdh155122 kmem_free(sctp_ill, sizeof (sctp_ill_t)); 19163448Sdh155122 sctp_ill = 19173448Sdh155122 list_tail(&sctps->sctps_g_ills[i].sctp_ill_list); 19183448Sdh155122 } 19193448Sdh155122 sctps->sctps_g_ills[i].ill_count = 0; 19203448Sdh155122 } 19213448Sdh155122 ASSERT(sctps->sctps_ills_count == 0); 19223448Sdh155122 } 19233448Sdh155122 19243448Sdh155122 static void 19253448Sdh155122 sctp_free_ipifs(sctp_stack_t *sctps) 19263448Sdh155122 { 19273448Sdh155122 int i; 19283448Sdh155122 int l; 19293448Sdh155122 sctp_ipif_t *sctp_ipif; 19303448Sdh155122 sctp_ill_t *sctp_ill; 19313448Sdh155122 19323448Sdh155122 if (sctps->sctps_g_ipifs_count == 0) 19333448Sdh155122 return; 19343448Sdh155122 19353448Sdh155122 for (i = 0; i < SCTP_IPIF_HASH; i++) { 19363448Sdh155122 sctp_ipif = list_tail(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 19373448Sdh155122 for (l = 0; l < sctps->sctps_g_ipifs[i].ipif_count; l++) { 19383448Sdh155122 sctp_ill = sctp_ipif->sctp_ipif_ill; 19393448Sdh155122 19403448Sdh155122 list_remove(&sctps->sctps_g_ipifs[i].sctp_ipif_list, 19413448Sdh155122 sctp_ipif); 19423448Sdh155122 sctps->sctps_g_ipifs_count--; 19433448Sdh155122 (void) atomic_add_32_nv(&sctp_ill->sctp_ill_ipifcnt, 19443448Sdh155122 -1); 19453448Sdh155122 kmem_free(sctp_ipif, sizeof (sctp_ipif_t)); 19463448Sdh155122 sctp_ipif = 19473448Sdh155122 list_tail(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 19483448Sdh155122 } 19493448Sdh155122 sctps->sctps_g_ipifs[i].ipif_count = 0; 19503448Sdh155122 } 19513448Sdh155122 ASSERT(sctps->sctps_g_ipifs_count == 0); 19523448Sdh155122 } 19533448Sdh155122 19543448Sdh155122 19550Sstevel@tonic-gate /* Initialize the SCTP ILL list and lock */ 19560Sstevel@tonic-gate void 19573448Sdh155122 sctp_saddr_init(sctp_stack_t *sctps) 19580Sstevel@tonic-gate { 19590Sstevel@tonic-gate int i; 19600Sstevel@tonic-gate 19613448Sdh155122 sctps->sctps_g_ills = kmem_zalloc(sizeof (sctp_ill_hash_t) * 19623448Sdh155122 SCTP_ILL_HASH, KM_SLEEP); 19633448Sdh155122 sctps->sctps_g_ipifs = kmem_zalloc(sizeof (sctp_ipif_hash_t) * 19643448Sdh155122 SCTP_IPIF_HASH, KM_SLEEP); 19653448Sdh155122 19663448Sdh155122 rw_init(&sctps->sctps_g_ills_lock, NULL, RW_DEFAULT, NULL); 19673448Sdh155122 rw_init(&sctps->sctps_g_ipifs_lock, NULL, RW_DEFAULT, NULL); 19680Sstevel@tonic-gate 19690Sstevel@tonic-gate for (i = 0; i < SCTP_ILL_HASH; i++) { 19703448Sdh155122 sctps->sctps_g_ills[i].ill_count = 0; 19713448Sdh155122 list_create(&sctps->sctps_g_ills[i].sctp_ill_list, 19723448Sdh155122 sizeof (sctp_ill_t), 19730Sstevel@tonic-gate offsetof(sctp_ill_t, sctp_ills)); 19740Sstevel@tonic-gate } 19750Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 19763448Sdh155122 sctps->sctps_g_ipifs[i].ipif_count = 0; 19773448Sdh155122 list_create(&sctps->sctps_g_ipifs[i].sctp_ipif_list, 19780Sstevel@tonic-gate sizeof (sctp_ipif_t), offsetof(sctp_ipif_t, sctp_ipifs)); 19790Sstevel@tonic-gate } 19800Sstevel@tonic-gate } 19810Sstevel@tonic-gate 19820Sstevel@tonic-gate void 19833448Sdh155122 sctp_saddr_fini(sctp_stack_t *sctps) 19840Sstevel@tonic-gate { 19850Sstevel@tonic-gate int i; 19860Sstevel@tonic-gate 19873448Sdh155122 sctp_free_ipifs(sctps); 19883448Sdh155122 sctp_free_ills(sctps); 19893448Sdh155122 19900Sstevel@tonic-gate for (i = 0; i < SCTP_ILL_HASH; i++) 19913448Sdh155122 list_destroy(&sctps->sctps_g_ills[i].sctp_ill_list); 19920Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) 19933448Sdh155122 list_destroy(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 19943448Sdh155122 19953448Sdh155122 ASSERT(sctps->sctps_ills_count == 0 && sctps->sctps_g_ipifs_count == 0); 19963448Sdh155122 kmem_free(sctps->sctps_g_ills, sizeof (sctp_ill_hash_t) * 19973448Sdh155122 SCTP_ILL_HASH); 19983448Sdh155122 sctps->sctps_g_ills = NULL; 19993448Sdh155122 kmem_free(sctps->sctps_g_ipifs, sizeof (sctp_ipif_hash_t) * 20003448Sdh155122 SCTP_IPIF_HASH); 20013448Sdh155122 sctps->sctps_g_ipifs = NULL; 20023448Sdh155122 rw_destroy(&sctps->sctps_g_ills_lock); 20033448Sdh155122 rw_destroy(&sctps->sctps_g_ipifs_lock); 20040Sstevel@tonic-gate } 2005