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 /* 228485SPeter.Memishian@Sun.COM * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 230Sstevel@tonic-gate * Use is subject to license terms. 240Sstevel@tonic-gate */ 250Sstevel@tonic-gate 260Sstevel@tonic-gate #include <sys/types.h> 270Sstevel@tonic-gate #include <sys/systm.h> 280Sstevel@tonic-gate #include <sys/stream.h> 294311Svi117747 #include <sys/cmn_err.h> 300Sstevel@tonic-gate #include <sys/ddi.h> 310Sstevel@tonic-gate #include <sys/sunddi.h> 320Sstevel@tonic-gate #include <sys/kmem.h> 330Sstevel@tonic-gate #include <sys/socket.h> 340Sstevel@tonic-gate #include <sys/sysmacros.h> 350Sstevel@tonic-gate #include <sys/list.h> 360Sstevel@tonic-gate 370Sstevel@tonic-gate #include <netinet/in.h> 380Sstevel@tonic-gate #include <netinet/ip6.h> 390Sstevel@tonic-gate #include <netinet/sctp.h> 400Sstevel@tonic-gate 410Sstevel@tonic-gate #include <inet/common.h> 420Sstevel@tonic-gate #include <inet/ip.h> 430Sstevel@tonic-gate #include <inet/ip6.h> 4411042SErik.Nordmark@Sun.COM #include <inet/ip_ire.h> 450Sstevel@tonic-gate #include <inet/ip_if.h> 460Sstevel@tonic-gate #include <inet/ipclassifier.h> 470Sstevel@tonic-gate #include <inet/sctp_ip.h> 480Sstevel@tonic-gate #include "sctp_impl.h" 490Sstevel@tonic-gate #include "sctp_addr.h" 500Sstevel@tonic-gate 510Sstevel@tonic-gate static void sctp_ipif_inactive(sctp_ipif_t *); 520Sstevel@tonic-gate static sctp_ipif_t *sctp_lookup_ipif_addr(in6_addr_t *, boolean_t, 533510Svi117747 zoneid_t, boolean_t, uint_t, uint_t, boolean_t, 543510Svi117747 sctp_stack_t *); 550Sstevel@tonic-gate static int sctp_get_all_ipifs(sctp_t *, int); 56432Svi117747 static int sctp_ipif_hash_insert(sctp_t *, sctp_ipif_t *, int, 573510Svi117747 boolean_t, boolean_t); 58*11373SGeorge.Shepherd@Sun.COM static void sctp_ipif_hash_remove(sctp_t *, sctp_ipif_t *, 59*11373SGeorge.Shepherd@Sun.COM boolean_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; 2398903SVenu.Iyer@Sun.COM sctp_stack_t *sctps = sctp->sctp_sctps; 2408903SVenu.Iyer@Sun.COM boolean_t isv6; 24111042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp; 2420Sstevel@tonic-gate 2433448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 2440Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 2453448Sdh155122 if (sctps->sctps_g_ipifs[i].ipif_count == 0) 2460Sstevel@tonic-gate continue; 2473448Sdh155122 sctp_ipif = list_head(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 2483448Sdh155122 for (j = 0; j < sctps->sctps_g_ipifs[i].ipif_count; j++) { 2490Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_READER); 2508903SVenu.Iyer@Sun.COM isv6 = sctp_ipif->sctp_ipif_isv6; 251432Svi117747 if (SCTP_IPIF_DISCARD(sctp_ipif->sctp_ipif_flags) || 2520Sstevel@tonic-gate !SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state) || 2532263Ssommerfe !SCTP_IPIF_ZONE_MATCH(sctp, sctp_ipif) || 2548903SVenu.Iyer@Sun.COM SCTP_IS_ADDR_UNSPEC(!isv6, 2558903SVenu.Iyer@Sun.COM sctp_ipif->sctp_ipif_saddr) || 25611042SErik.Nordmark@Sun.COM (connp->conn_family == AF_INET && isv6) || 25711042SErik.Nordmark@Sun.COM (connp->conn_ipv6_v6only && !isv6)) { 2580Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 2590Sstevel@tonic-gate sctp_ipif = list_next( 2603448Sdh155122 &sctps->sctps_g_ipifs[i].sctp_ipif_list, 2613448Sdh155122 sctp_ipif); 2620Sstevel@tonic-gate continue; 2630Sstevel@tonic-gate } 2640Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 2650Sstevel@tonic-gate SCTP_IPIF_REFHOLD(sctp_ipif); 266432Svi117747 error = sctp_ipif_hash_insert(sctp, sctp_ipif, sleep, 2673510Svi117747 B_FALSE, B_FALSE); 2683510Svi117747 if (error != 0 && error != EALREADY) 2690Sstevel@tonic-gate goto free_stuff; 2703448Sdh155122 sctp_ipif = list_next( 2713448Sdh155122 &sctps->sctps_g_ipifs[i].sctp_ipif_list, 2720Sstevel@tonic-gate sctp_ipif); 2730Sstevel@tonic-gate } 2740Sstevel@tonic-gate } 2753448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2760Sstevel@tonic-gate return (0); 2770Sstevel@tonic-gate free_stuff: 2783448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2790Sstevel@tonic-gate sctp_free_saddrs(sctp); 2800Sstevel@tonic-gate return (ENOMEM); 2810Sstevel@tonic-gate } 2820Sstevel@tonic-gate 2830Sstevel@tonic-gate /* 2840Sstevel@tonic-gate * Given a list of address, fills in the list of SCTP ipifs if all the addresses 2850Sstevel@tonic-gate * are present in the SCTP interface list, return number of addresses filled 286852Svi117747 * or error. If the caller wants the list of addresses, it sends a pre-allocated 287852Svi117747 * buffer - list. Currently, this list is only used on a clustered node when 288852Svi117747 * the SCTP is in the listen state (from sctp_bind_add()). When called on a 289852Svi117747 * clustered node, the input is always a list of addresses (even if the 290852Svi117747 * original bind() was to INADDR_ANY). 2910Sstevel@tonic-gate * Called with no locks held. 2920Sstevel@tonic-gate */ 2930Sstevel@tonic-gate int 294852Svi117747 sctp_valid_addr_list(sctp_t *sctp, const void *addrs, uint32_t addrcnt, 295852Svi117747 uchar_t *list, size_t lsize) 2960Sstevel@tonic-gate { 2970Sstevel@tonic-gate struct sockaddr_in *sin4; 2980Sstevel@tonic-gate struct sockaddr_in6 *sin6; 2990Sstevel@tonic-gate struct in_addr *addr4; 3000Sstevel@tonic-gate in6_addr_t addr; 3010Sstevel@tonic-gate int cnt; 3020Sstevel@tonic-gate int err = 0; 3030Sstevel@tonic-gate int saddr_cnt = 0; 3040Sstevel@tonic-gate sctp_ipif_t *ipif; 3050Sstevel@tonic-gate boolean_t bind_to_all = B_FALSE; 3060Sstevel@tonic-gate boolean_t check_addrs = B_FALSE; 3070Sstevel@tonic-gate boolean_t check_lport = B_FALSE; 308852Svi117747 uchar_t *p = list; 30911042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp; 3100Sstevel@tonic-gate 3110Sstevel@tonic-gate /* 3120Sstevel@tonic-gate * Need to check for port and address depending on the state. 3130Sstevel@tonic-gate * After a socket is bound, we need to make sure that subsequent 3140Sstevel@tonic-gate * bindx() has correct port. After an association is established, 3150Sstevel@tonic-gate * we need to check for changing the bound address to invalid 3160Sstevel@tonic-gate * addresses. 3170Sstevel@tonic-gate */ 3180Sstevel@tonic-gate if (sctp->sctp_state >= SCTPS_BOUND) { 3190Sstevel@tonic-gate check_lport = B_TRUE; 3200Sstevel@tonic-gate if (sctp->sctp_state > SCTPS_LISTEN) 3210Sstevel@tonic-gate check_addrs = B_TRUE; 3220Sstevel@tonic-gate } 323852Svi117747 3240Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 3250Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 3260Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 3270Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 3280Sstevel@tonic-gate for (cnt = 0; cnt < addrcnt; cnt++) { 3290Sstevel@tonic-gate boolean_t lookup_saddr = B_TRUE; 330852Svi117747 uint_t ifindex = 0; 3310Sstevel@tonic-gate 33211042SErik.Nordmark@Sun.COM switch (connp->conn_family) { 3330Sstevel@tonic-gate case AF_INET: 3340Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + cnt; 3350Sstevel@tonic-gate if (sin4->sin_family != AF_INET || (check_lport && 33611042SErik.Nordmark@Sun.COM sin4->sin_port != connp->conn_lport)) { 3370Sstevel@tonic-gate err = EINVAL; 3380Sstevel@tonic-gate goto free_ret; 3390Sstevel@tonic-gate } 3400Sstevel@tonic-gate addr4 = &sin4->sin_addr; 3410Sstevel@tonic-gate if (check_addrs && 3420Sstevel@tonic-gate (addr4->s_addr == INADDR_ANY || 3430Sstevel@tonic-gate addr4->s_addr == INADDR_BROADCAST || 3445215Skcpoon CLASSD(addr4->s_addr))) { 3450Sstevel@tonic-gate err = EINVAL; 3460Sstevel@tonic-gate goto free_ret; 3470Sstevel@tonic-gate } 3480Sstevel@tonic-gate IN6_INADDR_TO_V4MAPPED(addr4, &addr); 3490Sstevel@tonic-gate if (!check_addrs && addr4->s_addr == INADDR_ANY) { 3500Sstevel@tonic-gate lookup_saddr = B_FALSE; 3510Sstevel@tonic-gate bind_to_all = B_TRUE; 3520Sstevel@tonic-gate } 3530Sstevel@tonic-gate 3540Sstevel@tonic-gate break; 3550Sstevel@tonic-gate case AF_INET6: 3560Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + cnt; 3570Sstevel@tonic-gate if (sin6->sin6_family != AF_INET6 || (check_lport && 35811042SErik.Nordmark@Sun.COM sin6->sin6_port != connp->conn_lport)) { 3590Sstevel@tonic-gate err = EINVAL; 3600Sstevel@tonic-gate goto free_ret; 3610Sstevel@tonic-gate } 3620Sstevel@tonic-gate addr = sin6->sin6_addr; 363852Svi117747 /* Contains the interface index */ 364852Svi117747 ifindex = sin6->sin6_scope_id; 36511042SErik.Nordmark@Sun.COM if (connp->conn_ipv6_v6only && 3660Sstevel@tonic-gate IN6_IS_ADDR_V4MAPPED(&addr)) { 3670Sstevel@tonic-gate err = EAFNOSUPPORT; 3680Sstevel@tonic-gate goto free_ret; 3690Sstevel@tonic-gate } 3700Sstevel@tonic-gate if (check_addrs && 3710Sstevel@tonic-gate (IN6_IS_ADDR_LINKLOCAL(&addr) || 3720Sstevel@tonic-gate IN6_IS_ADDR_MULTICAST(&addr) || 3730Sstevel@tonic-gate IN6_IS_ADDR_UNSPECIFIED(&addr))) { 3740Sstevel@tonic-gate err = EINVAL; 3750Sstevel@tonic-gate goto free_ret; 3760Sstevel@tonic-gate } 3770Sstevel@tonic-gate if (!check_addrs && IN6_IS_ADDR_UNSPECIFIED(&addr)) { 3780Sstevel@tonic-gate lookup_saddr = B_FALSE; 3790Sstevel@tonic-gate bind_to_all = B_TRUE; 3800Sstevel@tonic-gate } 3810Sstevel@tonic-gate 3820Sstevel@tonic-gate break; 3830Sstevel@tonic-gate default: 3840Sstevel@tonic-gate err = EAFNOSUPPORT; 3850Sstevel@tonic-gate goto free_ret; 3860Sstevel@tonic-gate } 3870Sstevel@tonic-gate if (lookup_saddr) { 3883510Svi117747 ipif = sctp_lookup_ipif_addr(&addr, B_TRUE, 38911042SErik.Nordmark@Sun.COM IPCL_ZONEID(connp), !connp->conn_allzones, 3903510Svi117747 ifindex, 0, B_TRUE, sctp->sctp_sctps); 3910Sstevel@tonic-gate if (ipif == NULL) { 3920Sstevel@tonic-gate /* Address not in the list */ 3930Sstevel@tonic-gate err = EINVAL; 3940Sstevel@tonic-gate goto free_ret; 395852Svi117747 } else if (check_addrs && SCTP_IS_IPIF_LOOPBACK(ipif) && 396852Svi117747 cl_sctp_check_addrs == NULL) { 3970Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif); 3980Sstevel@tonic-gate err = EINVAL; 3990Sstevel@tonic-gate goto free_ret; 4000Sstevel@tonic-gate } 4010Sstevel@tonic-gate } 4020Sstevel@tonic-gate if (!bind_to_all) { 403432Svi117747 /* 404432Svi117747 * If an address is added after association setup, 405432Svi117747 * we need to wait for the peer to send us an ASCONF 406432Svi117747 * ACK before we can start using it. 407432Svi117747 * saddr_ipif_dontsrc will be reset (to 0) when we 408432Svi117747 * get the ASCONF ACK for this address. 409432Svi117747 */ 410432Svi117747 err = sctp_ipif_hash_insert(sctp, ipif, KM_SLEEP, 4113510Svi117747 check_addrs ? B_TRUE : B_FALSE, B_FALSE); 4120Sstevel@tonic-gate if (err != 0) { 4130Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif); 4140Sstevel@tonic-gate if (check_addrs && err == EALREADY) 4150Sstevel@tonic-gate err = EADDRINUSE; 4160Sstevel@tonic-gate goto free_ret; 4170Sstevel@tonic-gate } 4180Sstevel@tonic-gate saddr_cnt++; 419852Svi117747 if (lsize >= sizeof (addr)) { 420852Svi117747 bcopy(&addr, p, sizeof (addr)); 421852Svi117747 p += sizeof (addr); 422852Svi117747 lsize -= sizeof (addr); 423852Svi117747 } 4240Sstevel@tonic-gate } 4250Sstevel@tonic-gate } 4260Sstevel@tonic-gate if (bind_to_all) { 4270Sstevel@tonic-gate /* 4280Sstevel@tonic-gate * Free whatever we might have added before encountering 4290Sstevel@tonic-gate * inaddr_any. 4300Sstevel@tonic-gate */ 4310Sstevel@tonic-gate if (sctp->sctp_nsaddrs > 0) { 4320Sstevel@tonic-gate sctp_free_saddrs(sctp); 4330Sstevel@tonic-gate ASSERT(sctp->sctp_nsaddrs == 0); 4340Sstevel@tonic-gate } 4350Sstevel@tonic-gate err = sctp_get_all_ipifs(sctp, KM_SLEEP); 4360Sstevel@tonic-gate if (err != 0) 4370Sstevel@tonic-gate return (err); 4380Sstevel@tonic-gate sctp->sctp_bound_to_all = 1; 4390Sstevel@tonic-gate } 4400Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 4410Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 4420Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 4430Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 4440Sstevel@tonic-gate return (0); 4450Sstevel@tonic-gate free_ret: 4460Sstevel@tonic-gate if (saddr_cnt != 0) 4470Sstevel@tonic-gate sctp_del_saddr_list(sctp, addrs, saddr_cnt, B_TRUE); 4480Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 4490Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 4500Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 4510Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 4520Sstevel@tonic-gate return (err); 4530Sstevel@tonic-gate } 4540Sstevel@tonic-gate 4550Sstevel@tonic-gate static int 456432Svi117747 sctp_ipif_hash_insert(sctp_t *sctp, sctp_ipif_t *ipif, int sleep, 4573510Svi117747 boolean_t dontsrc, boolean_t allow_dup) 4580Sstevel@tonic-gate { 4590Sstevel@tonic-gate int cnt; 4600Sstevel@tonic-gate sctp_saddr_ipif_t *ipif_obj; 4613510Svi117747 int hindex; 4620Sstevel@tonic-gate 4633510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->sctp_ipif_saddr, 4643510Svi117747 ipif->sctp_ipif_isv6); 465*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[hindex].ipif_hash_lock, RW_WRITER); 4663510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 4673510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 4683510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif_obj->saddr_ipifp->sctp_ipif_saddr, 4693510Svi117747 &ipif->sctp_ipif_saddr)) { 4703510Svi117747 if (ipif->sctp_ipif_id != 4713510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_id && 4723510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_state == 4733510Svi117747 SCTP_IPIFS_DOWN && ipif->sctp_ipif_state == 4743510Svi117747 SCTP_IPIFS_UP) { 4753510Svi117747 SCTP_IPIF_REFRELE(ipif_obj->saddr_ipifp); 4763510Svi117747 ipif_obj->saddr_ipifp = ipif; 4773510Svi117747 ipif_obj->saddr_ipif_dontsrc = dontsrc ? 1 : 0; 478*11373SGeorge.Shepherd@Sun.COM rw_exit( 479*11373SGeorge.Shepherd@Sun.COM &sctp->sctp_saddrs[hindex].ipif_hash_lock); 4803510Svi117747 return (0); 4813510Svi117747 } else if (!allow_dup || ipif->sctp_ipif_id == 4823510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_id) { 483*11373SGeorge.Shepherd@Sun.COM rw_exit( 484*11373SGeorge.Shepherd@Sun.COM &sctp->sctp_saddrs[hindex].ipif_hash_lock); 4853510Svi117747 return (EALREADY); 4863510Svi117747 } 4873510Svi117747 } 4883510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 4890Sstevel@tonic-gate ipif_obj); 4900Sstevel@tonic-gate } 4910Sstevel@tonic-gate ipif_obj = kmem_zalloc(sizeof (sctp_saddr_ipif_t), sleep); 4920Sstevel@tonic-gate if (ipif_obj == NULL) { 493*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[hindex].ipif_hash_lock); 4940Sstevel@tonic-gate /* Need to do something */ 4950Sstevel@tonic-gate return (ENOMEM); 4960Sstevel@tonic-gate } 4970Sstevel@tonic-gate ipif_obj->saddr_ipifp = ipif; 498432Svi117747 ipif_obj->saddr_ipif_dontsrc = dontsrc ? 1 : 0; 4993510Svi117747 list_insert_tail(&sctp->sctp_saddrs[hindex].sctp_ipif_list, ipif_obj); 5003510Svi117747 sctp->sctp_saddrs[hindex].ipif_count++; 5010Sstevel@tonic-gate sctp->sctp_nsaddrs++; 502*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[hindex].ipif_hash_lock); 5030Sstevel@tonic-gate return (0); 5040Sstevel@tonic-gate } 5050Sstevel@tonic-gate 5064818Skcpoon /* 5074818Skcpoon * Given a source address, walk through the peer address list to see 5084818Skcpoon * if the source address is being used. If it is, reset that. 50911042SErik.Nordmark@Sun.COM * A cleared saddr will then make sctp_make_mp lookup the destination again 51011042SErik.Nordmark@Sun.COM * and as part of that look for a new source. 5114818Skcpoon */ 5124818Skcpoon static void 5134818Skcpoon sctp_fix_saddr(sctp_t *sctp, in6_addr_t *saddr) 5144818Skcpoon { 5154818Skcpoon sctp_faddr_t *fp; 5164818Skcpoon 5174818Skcpoon for (fp = sctp->sctp_faddrs; fp != NULL; fp = fp->next) { 5184818Skcpoon if (!IN6_ARE_ADDR_EQUAL(&fp->saddr, saddr)) 5194818Skcpoon continue; 5204818Skcpoon V6_SET_ZERO(fp->saddr); 5214818Skcpoon } 5224818Skcpoon } 5234818Skcpoon 5240Sstevel@tonic-gate static void 525*11373SGeorge.Shepherd@Sun.COM sctp_ipif_hash_remove(sctp_t *sctp, sctp_ipif_t *ipif, boolean_t locked) 5260Sstevel@tonic-gate { 5270Sstevel@tonic-gate int cnt; 5280Sstevel@tonic-gate sctp_saddr_ipif_t *ipif_obj; 5293510Svi117747 int hindex; 5300Sstevel@tonic-gate 5313510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->sctp_ipif_saddr, 5323510Svi117747 ipif->sctp_ipif_isv6); 533*11373SGeorge.Shepherd@Sun.COM if (!locked) 534*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[hindex].ipif_hash_lock, RW_WRITER); 5353510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 5363510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 5373510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif_obj->saddr_ipifp->sctp_ipif_saddr, 5383510Svi117747 &ipif->sctp_ipif_saddr)) { 5393510Svi117747 list_remove(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 5400Sstevel@tonic-gate ipif_obj); 5413510Svi117747 sctp->sctp_saddrs[hindex].ipif_count--; 5420Sstevel@tonic-gate sctp->sctp_nsaddrs--; 5434818Skcpoon sctp_fix_saddr(sctp, &ipif->sctp_ipif_saddr); 5440Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif_obj->saddr_ipifp); 5450Sstevel@tonic-gate kmem_free(ipif_obj, sizeof (sctp_saddr_ipif_t)); 5460Sstevel@tonic-gate break; 5470Sstevel@tonic-gate } 5483510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 5490Sstevel@tonic-gate ipif_obj); 5500Sstevel@tonic-gate } 551*11373SGeorge.Shepherd@Sun.COM if (!locked) 552*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[hindex].ipif_hash_lock); 5530Sstevel@tonic-gate } 5540Sstevel@tonic-gate 5550Sstevel@tonic-gate static int 5560Sstevel@tonic-gate sctp_compare_ipif_list(sctp_ipif_hash_t *list1, sctp_ipif_hash_t *list2) 5570Sstevel@tonic-gate { 5580Sstevel@tonic-gate int i; 5590Sstevel@tonic-gate int j; 5600Sstevel@tonic-gate sctp_saddr_ipif_t *obj1; 5610Sstevel@tonic-gate sctp_saddr_ipif_t *obj2; 5620Sstevel@tonic-gate int overlap = 0; 5630Sstevel@tonic-gate 564*11373SGeorge.Shepherd@Sun.COM rw_enter(&list1->ipif_hash_lock, RW_READER); 565*11373SGeorge.Shepherd@Sun.COM rw_enter(&list2->ipif_hash_lock, RW_READER); 5660Sstevel@tonic-gate obj1 = list_head(&list1->sctp_ipif_list); 5670Sstevel@tonic-gate for (i = 0; i < list1->ipif_count; i++) { 5680Sstevel@tonic-gate obj2 = list_head(&list2->sctp_ipif_list); 5690Sstevel@tonic-gate for (j = 0; j < list2->ipif_count; j++) { 5703510Svi117747 if (IN6_ARE_ADDR_EQUAL( 5713510Svi117747 &obj1->saddr_ipifp->sctp_ipif_saddr, 5723510Svi117747 &obj2->saddr_ipifp->sctp_ipif_saddr)) { 5730Sstevel@tonic-gate overlap++; 5740Sstevel@tonic-gate break; 5750Sstevel@tonic-gate } 5760Sstevel@tonic-gate obj2 = list_next(&list2->sctp_ipif_list, 5770Sstevel@tonic-gate obj2); 5780Sstevel@tonic-gate } 5790Sstevel@tonic-gate obj1 = list_next(&list1->sctp_ipif_list, obj1); 5800Sstevel@tonic-gate } 581*11373SGeorge.Shepherd@Sun.COM rw_exit(&list1->ipif_hash_lock); 582*11373SGeorge.Shepherd@Sun.COM rw_exit(&list2->ipif_hash_lock); 5830Sstevel@tonic-gate return (overlap); 5840Sstevel@tonic-gate } 5850Sstevel@tonic-gate 5860Sstevel@tonic-gate int 5870Sstevel@tonic-gate sctp_compare_saddrs(sctp_t *sctp1, sctp_t *sctp2) 5880Sstevel@tonic-gate { 5890Sstevel@tonic-gate int i; 5900Sstevel@tonic-gate int overlap = 0; 5910Sstevel@tonic-gate 5920Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 5930Sstevel@tonic-gate overlap += sctp_compare_ipif_list(&sctp1->sctp_saddrs[i], 5940Sstevel@tonic-gate &sctp2->sctp_saddrs[i]); 5950Sstevel@tonic-gate } 5960Sstevel@tonic-gate 5970Sstevel@tonic-gate if (sctp1->sctp_nsaddrs == sctp2->sctp_nsaddrs && 5980Sstevel@tonic-gate overlap == sctp1->sctp_nsaddrs) { 5990Sstevel@tonic-gate return (SCTP_ADDR_EQUAL); 6000Sstevel@tonic-gate } 6010Sstevel@tonic-gate 6020Sstevel@tonic-gate if (overlap == sctp1->sctp_nsaddrs) 6030Sstevel@tonic-gate return (SCTP_ADDR_SUBSET); 6040Sstevel@tonic-gate 6050Sstevel@tonic-gate if (overlap > 0) 6060Sstevel@tonic-gate return (SCTP_ADDR_OVERLAP); 6070Sstevel@tonic-gate 6080Sstevel@tonic-gate return (SCTP_ADDR_DISJOINT); 6090Sstevel@tonic-gate } 6100Sstevel@tonic-gate 6110Sstevel@tonic-gate static int 6120Sstevel@tonic-gate sctp_copy_ipifs(sctp_ipif_hash_t *list1, sctp_t *sctp2, int sleep) 6130Sstevel@tonic-gate { 6140Sstevel@tonic-gate int i; 6150Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 6160Sstevel@tonic-gate int error = 0; 6170Sstevel@tonic-gate 618*11373SGeorge.Shepherd@Sun.COM rw_enter(&list1->ipif_hash_lock, RW_READER); 6190Sstevel@tonic-gate obj = list_head(&list1->sctp_ipif_list); 6200Sstevel@tonic-gate for (i = 0; i < list1->ipif_count; i++) { 6210Sstevel@tonic-gate SCTP_IPIF_REFHOLD(obj->saddr_ipifp); 622432Svi117747 error = sctp_ipif_hash_insert(sctp2, obj->saddr_ipifp, sleep, 6233510Svi117747 B_FALSE, B_FALSE); 6243510Svi117747 ASSERT(error != EALREADY); 625*11373SGeorge.Shepherd@Sun.COM if (error != 0) { 626*11373SGeorge.Shepherd@Sun.COM rw_exit(&list1->ipif_hash_lock); 6270Sstevel@tonic-gate return (error); 628*11373SGeorge.Shepherd@Sun.COM } 6290Sstevel@tonic-gate obj = list_next(&list1->sctp_ipif_list, obj); 6300Sstevel@tonic-gate } 631*11373SGeorge.Shepherd@Sun.COM rw_exit(&list1->ipif_hash_lock); 6320Sstevel@tonic-gate return (error); 6330Sstevel@tonic-gate } 6340Sstevel@tonic-gate 6350Sstevel@tonic-gate int 6360Sstevel@tonic-gate sctp_dup_saddrs(sctp_t *sctp1, sctp_t *sctp2, int sleep) 6370Sstevel@tonic-gate { 6380Sstevel@tonic-gate int error = 0; 6390Sstevel@tonic-gate int i; 6400Sstevel@tonic-gate 641432Svi117747 if (sctp1 == NULL || sctp1->sctp_bound_to_all == 1) 6420Sstevel@tonic-gate return (sctp_get_all_ipifs(sctp2, sleep)); 6430Sstevel@tonic-gate 6440Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 645*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp1->sctp_saddrs[i].ipif_hash_lock, RW_READER); 646*11373SGeorge.Shepherd@Sun.COM if (sctp1->sctp_saddrs[i].ipif_count == 0) { 647*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp1->sctp_saddrs[i].ipif_hash_lock); 6480Sstevel@tonic-gate continue; 649*11373SGeorge.Shepherd@Sun.COM } 6500Sstevel@tonic-gate error = sctp_copy_ipifs(&sctp1->sctp_saddrs[i], sctp2, sleep); 6510Sstevel@tonic-gate if (error != 0) { 652*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp1->sctp_saddrs[i].ipif_hash_lock); 6530Sstevel@tonic-gate sctp_free_saddrs(sctp2); 6540Sstevel@tonic-gate return (error); 6550Sstevel@tonic-gate } 656*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp1->sctp_saddrs[i].ipif_hash_lock); 6570Sstevel@tonic-gate } 6580Sstevel@tonic-gate return (0); 6590Sstevel@tonic-gate } 6600Sstevel@tonic-gate 6610Sstevel@tonic-gate void 6620Sstevel@tonic-gate sctp_free_saddrs(sctp_t *sctp) 6630Sstevel@tonic-gate { 6640Sstevel@tonic-gate int i; 6650Sstevel@tonic-gate int l; 6660Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 6670Sstevel@tonic-gate 6680Sstevel@tonic-gate if (sctp->sctp_nsaddrs == 0) 6690Sstevel@tonic-gate return; 6700Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 671*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[i].ipif_hash_lock, RW_WRITER); 672*11373SGeorge.Shepherd@Sun.COM if (sctp->sctp_saddrs[i].ipif_count == 0) { 673*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 6740Sstevel@tonic-gate continue; 675*11373SGeorge.Shepherd@Sun.COM } 6760Sstevel@tonic-gate obj = list_tail(&sctp->sctp_saddrs[i].sctp_ipif_list); 6770Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 6780Sstevel@tonic-gate list_remove(&sctp->sctp_saddrs[i].sctp_ipif_list, obj); 6790Sstevel@tonic-gate SCTP_IPIF_REFRELE(obj->saddr_ipifp); 6800Sstevel@tonic-gate sctp->sctp_nsaddrs--; 6810Sstevel@tonic-gate kmem_free(obj, sizeof (sctp_saddr_ipif_t)); 6820Sstevel@tonic-gate obj = list_tail(&sctp->sctp_saddrs[i].sctp_ipif_list); 6830Sstevel@tonic-gate } 6840Sstevel@tonic-gate sctp->sctp_saddrs[i].ipif_count = 0; 685*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 6860Sstevel@tonic-gate } 687432Svi117747 if (sctp->sctp_bound_to_all == 1) 688432Svi117747 sctp->sctp_bound_to_all = 0; 6890Sstevel@tonic-gate ASSERT(sctp->sctp_nsaddrs == 0); 6900Sstevel@tonic-gate } 6910Sstevel@tonic-gate 6920Sstevel@tonic-gate /* 6930Sstevel@tonic-gate * Add/Delete the given ILL from the SCTP ILL list. Called with no locks 6940Sstevel@tonic-gate * held. 6950Sstevel@tonic-gate */ 6960Sstevel@tonic-gate void 6970Sstevel@tonic-gate sctp_update_ill(ill_t *ill, int op) 6980Sstevel@tonic-gate { 6990Sstevel@tonic-gate int i; 7000Sstevel@tonic-gate sctp_ill_t *sctp_ill = NULL; 7010Sstevel@tonic-gate uint_t index; 7023448Sdh155122 netstack_t *ns = ill->ill_ipst->ips_netstack; 7033448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 7040Sstevel@tonic-gate 7053448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_WRITER); 7060Sstevel@tonic-gate 7070Sstevel@tonic-gate index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 7083448Sdh155122 sctp_ill = list_head(&sctps->sctps_g_ills[index].sctp_ill_list); 7093448Sdh155122 for (i = 0; i < sctps->sctps_g_ills[index].ill_count; i++) { 7104311Svi117747 if ((sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill)) && 7114311Svi117747 (sctp_ill->sctp_ill_isv6 == ill->ill_isv6)) { 7120Sstevel@tonic-gate break; 7134311Svi117747 } 7143448Sdh155122 sctp_ill = list_next(&sctps->sctps_g_ills[index].sctp_ill_list, 7150Sstevel@tonic-gate sctp_ill); 7160Sstevel@tonic-gate } 7170Sstevel@tonic-gate 7180Sstevel@tonic-gate switch (op) { 7190Sstevel@tonic-gate case SCTP_ILL_INSERT: 7200Sstevel@tonic-gate if (sctp_ill != NULL) { 7210Sstevel@tonic-gate /* Unmark it if it is condemned */ 7220Sstevel@tonic-gate if (sctp_ill->sctp_ill_state == SCTP_ILLS_CONDEMNED) 7230Sstevel@tonic-gate sctp_ill->sctp_ill_state = 0; 7243448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7250Sstevel@tonic-gate return; 7260Sstevel@tonic-gate } 7270Sstevel@tonic-gate sctp_ill = kmem_zalloc(sizeof (sctp_ill_t), KM_NOSLEEP); 7280Sstevel@tonic-gate /* Need to re-try? */ 7290Sstevel@tonic-gate if (sctp_ill == NULL) { 7304311Svi117747 cmn_err(CE_WARN, "sctp_update_ill: error adding " 7314311Svi117747 "ILL %p to SCTP's ILL list", (void *)ill); 7323448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7330Sstevel@tonic-gate return; 7340Sstevel@tonic-gate } 7353510Svi117747 sctp_ill->sctp_ill_name = kmem_zalloc(ill->ill_name_length, 7363510Svi117747 KM_NOSLEEP); 7370Sstevel@tonic-gate if (sctp_ill->sctp_ill_name == NULL) { 7384311Svi117747 cmn_err(CE_WARN, "sctp_update_ill: error adding " 7394311Svi117747 "ILL %p to SCTP's ILL list", (void *)ill); 7400Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 7413448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7420Sstevel@tonic-gate return; 7430Sstevel@tonic-gate } 7440Sstevel@tonic-gate bcopy(ill->ill_name, sctp_ill->sctp_ill_name, 7450Sstevel@tonic-gate ill->ill_name_length); 7460Sstevel@tonic-gate sctp_ill->sctp_ill_name_length = ill->ill_name_length; 7470Sstevel@tonic-gate sctp_ill->sctp_ill_index = SCTP_ILL_TO_PHYINDEX(ill); 7480Sstevel@tonic-gate sctp_ill->sctp_ill_flags = ill->ill_phyint->phyint_flags; 7493448Sdh155122 sctp_ill->sctp_ill_netstack = ns; /* No netstack_hold */ 7504311Svi117747 sctp_ill->sctp_ill_isv6 = ill->ill_isv6; 7513448Sdh155122 list_insert_tail(&sctps->sctps_g_ills[index].sctp_ill_list, 7520Sstevel@tonic-gate (void *)sctp_ill); 7533448Sdh155122 sctps->sctps_g_ills[index].ill_count++; 7543448Sdh155122 sctps->sctps_ills_count++; 7550Sstevel@tonic-gate 7560Sstevel@tonic-gate break; 7570Sstevel@tonic-gate 7580Sstevel@tonic-gate case SCTP_ILL_REMOVE: 7590Sstevel@tonic-gate 7600Sstevel@tonic-gate if (sctp_ill == NULL) { 7613448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7620Sstevel@tonic-gate return; 7630Sstevel@tonic-gate } 7640Sstevel@tonic-gate if (sctp_ill->sctp_ill_ipifcnt == 0) { 7653448Sdh155122 list_remove(&sctps->sctps_g_ills[index].sctp_ill_list, 7660Sstevel@tonic-gate (void *)sctp_ill); 7673448Sdh155122 sctps->sctps_g_ills[index].ill_count--; 7683448Sdh155122 sctps->sctps_ills_count--; 7690Sstevel@tonic-gate kmem_free(sctp_ill->sctp_ill_name, 7700Sstevel@tonic-gate ill->ill_name_length); 7710Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 7720Sstevel@tonic-gate } else { 7730Sstevel@tonic-gate sctp_ill->sctp_ill_state = SCTP_ILLS_CONDEMNED; 7740Sstevel@tonic-gate } 7750Sstevel@tonic-gate 7760Sstevel@tonic-gate break; 7770Sstevel@tonic-gate } 7783448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7790Sstevel@tonic-gate } 7800Sstevel@tonic-gate 7814311Svi117747 /* 7824311Svi117747 * The ILL's index is being changed, just remove it from the old list, 7834311Svi117747 * change the SCTP ILL's index and re-insert using the new index. 7844311Svi117747 */ 7854311Svi117747 void 7864311Svi117747 sctp_ill_reindex(ill_t *ill, uint_t orig_ill_index) 7874311Svi117747 { 7884311Svi117747 sctp_ill_t *sctp_ill = NULL; 7894311Svi117747 sctp_ill_t *nxt_sill; 7904311Svi117747 uint_t indx; 7914311Svi117747 uint_t nindx; 7924311Svi117747 boolean_t once = B_FALSE; 7934311Svi117747 netstack_t *ns = ill->ill_ipst->ips_netstack; 7944311Svi117747 sctp_stack_t *sctps = ns->netstack_sctp; 7954311Svi117747 7964311Svi117747 rw_enter(&sctps->sctps_g_ills_lock, RW_WRITER); 7974311Svi117747 7984311Svi117747 indx = SCTP_ILL_HASH_FN(orig_ill_index); 7994311Svi117747 nindx = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 8004311Svi117747 sctp_ill = list_head(&sctps->sctps_g_ills[indx].sctp_ill_list); 8014311Svi117747 while (sctp_ill != NULL) { 8024311Svi117747 nxt_sill = list_next(&sctps->sctps_g_ills[indx].sctp_ill_list, 8034311Svi117747 sctp_ill); 8044311Svi117747 if (sctp_ill->sctp_ill_index == orig_ill_index) { 8054311Svi117747 sctp_ill->sctp_ill_index = SCTP_ILL_TO_PHYINDEX(ill); 8064311Svi117747 /* 8074311Svi117747 * if the new index hashes to the same value, all's 8084311Svi117747 * done. 8094311Svi117747 */ 8104311Svi117747 if (nindx != indx) { 8114311Svi117747 list_remove( 8124311Svi117747 &sctps->sctps_g_ills[indx].sctp_ill_list, 8134311Svi117747 (void *)sctp_ill); 8144311Svi117747 sctps->sctps_g_ills[indx].ill_count--; 8154311Svi117747 list_insert_tail( 8164311Svi117747 &sctps->sctps_g_ills[nindx].sctp_ill_list, 8174311Svi117747 (void *)sctp_ill); 8184311Svi117747 sctps->sctps_g_ills[nindx].ill_count++; 8194311Svi117747 } 8204311Svi117747 if (once) 8214311Svi117747 break; 8224311Svi117747 /* We might have one for v4 and for v6 */ 8234311Svi117747 once = B_TRUE; 8244311Svi117747 } 8254311Svi117747 sctp_ill = nxt_sill; 8264311Svi117747 } 8274311Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 8284311Svi117747 } 8294311Svi117747 8300Sstevel@tonic-gate /* move ipif from f_ill to t_ill */ 8310Sstevel@tonic-gate void 8320Sstevel@tonic-gate sctp_move_ipif(ipif_t *ipif, ill_t *f_ill, ill_t *t_ill) 8330Sstevel@tonic-gate { 8340Sstevel@tonic-gate sctp_ill_t *fsctp_ill = NULL; 8350Sstevel@tonic-gate sctp_ill_t *tsctp_ill = NULL; 8360Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 8373510Svi117747 uint_t hindex; 8380Sstevel@tonic-gate int i; 8393448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 8403448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 8410Sstevel@tonic-gate 8423448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 8433448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 8440Sstevel@tonic-gate 8453510Svi117747 hindex = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(f_ill)); 8463510Svi117747 fsctp_ill = list_head(&sctps->sctps_g_ills[hindex].sctp_ill_list); 8473510Svi117747 for (i = 0; i < sctps->sctps_g_ills[hindex].ill_count; i++) { 8484311Svi117747 if (fsctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(f_ill) && 8494311Svi117747 fsctp_ill->sctp_ill_isv6 == f_ill->ill_isv6) { 8500Sstevel@tonic-gate break; 8514311Svi117747 } 8523510Svi117747 fsctp_ill = list_next( 8533510Svi117747 &sctps->sctps_g_ills[hindex].sctp_ill_list, fsctp_ill); 8540Sstevel@tonic-gate } 8550Sstevel@tonic-gate 8563510Svi117747 hindex = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(t_ill)); 8573510Svi117747 tsctp_ill = list_head(&sctps->sctps_g_ills[hindex].sctp_ill_list); 8583510Svi117747 for (i = 0; i < sctps->sctps_g_ills[hindex].ill_count; i++) { 8594311Svi117747 if (tsctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(t_ill) && 8604311Svi117747 tsctp_ill->sctp_ill_isv6 == t_ill->ill_isv6) { 8610Sstevel@tonic-gate break; 8624311Svi117747 } 8633510Svi117747 tsctp_ill = list_next( 8643510Svi117747 &sctps->sctps_g_ills[hindex].sctp_ill_list, tsctp_ill); 8650Sstevel@tonic-gate } 8660Sstevel@tonic-gate 8673510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, 8683510Svi117747 ipif->ipif_ill->ill_isv6); 8693510Svi117747 sctp_ipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 8703510Svi117747 for (i = 0; i < sctps->sctps_g_ipifs[hindex].ipif_count; i++) { 8710Sstevel@tonic-gate if (sctp_ipif->sctp_ipif_id == ipif->ipif_seqid) 8720Sstevel@tonic-gate break; 8733448Sdh155122 sctp_ipif = list_next( 8743510Svi117747 &sctps->sctps_g_ipifs[hindex].sctp_ipif_list, sctp_ipif); 8750Sstevel@tonic-gate } 8760Sstevel@tonic-gate /* Should be an ASSERT? */ 8770Sstevel@tonic-gate if (fsctp_ill == NULL || tsctp_ill == NULL || sctp_ipif == NULL) { 8780Sstevel@tonic-gate ip1dbg(("sctp_move_ipif: error moving ipif %p from %p to %p\n", 8790Sstevel@tonic-gate (void *)ipif, (void *)f_ill, (void *)t_ill)); 8803448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 8813448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 8820Sstevel@tonic-gate return; 8830Sstevel@tonic-gate } 8840Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 8850Sstevel@tonic-gate ASSERT(sctp_ipif->sctp_ipif_ill == fsctp_ill); 8860Sstevel@tonic-gate sctp_ipif->sctp_ipif_ill = tsctp_ill; 8870Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 8880Sstevel@tonic-gate (void) atomic_add_32_nv(&fsctp_ill->sctp_ill_ipifcnt, -1); 8890Sstevel@tonic-gate atomic_add_32(&tsctp_ill->sctp_ill_ipifcnt, 1); 8903448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 8913448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 8920Sstevel@tonic-gate } 8930Sstevel@tonic-gate 8943510Svi117747 /* 8953510Svi117747 * Walk the list of SCTPs and find each that has oipif in it's saddr list, and 8963510Svi117747 * if so replace it with nipif. 8973510Svi117747 */ 8983510Svi117747 void 8993510Svi117747 sctp_update_saddrs(sctp_ipif_t *oipif, sctp_ipif_t *nipif, int idx, 9003510Svi117747 sctp_stack_t *sctps) 9013510Svi117747 { 9023510Svi117747 sctp_t *sctp; 9033510Svi117747 sctp_t *sctp_prev = NULL; 9043510Svi117747 sctp_saddr_ipif_t *sobj; 9053510Svi117747 int count; 9063510Svi117747 9073510Svi117747 mutex_enter(&sctps->sctps_g_lock); 90811042SErik.Nordmark@Sun.COM sctp = list_head(&sctps->sctps_g_list); 9093510Svi117747 while (sctp != NULL && oipif->sctp_ipif_refcnt > 0) { 9103510Svi117747 mutex_enter(&sctp->sctp_reflock); 9113510Svi117747 if (sctp->sctp_condemned || 9123510Svi117747 sctp->sctp_saddrs[idx].ipif_count <= 0) { 9133510Svi117747 mutex_exit(&sctp->sctp_reflock); 9143510Svi117747 sctp = list_next(&sctps->sctps_g_list, sctp); 9153510Svi117747 continue; 9163510Svi117747 } 9173510Svi117747 sctp->sctp_refcnt++; 9183510Svi117747 mutex_exit(&sctp->sctp_reflock); 9193510Svi117747 mutex_exit(&sctps->sctps_g_lock); 9203510Svi117747 if (sctp_prev != NULL) 9213510Svi117747 SCTP_REFRELE(sctp_prev); 9223510Svi117747 9233510Svi117747 RUN_SCTP(sctp); 9243510Svi117747 sobj = list_head(&sctp->sctp_saddrs[idx].sctp_ipif_list); 9253510Svi117747 for (count = 0; count < 9263510Svi117747 sctp->sctp_saddrs[idx].ipif_count; count++) { 9273510Svi117747 if (sobj->saddr_ipifp == oipif) { 9283510Svi117747 SCTP_IPIF_REFHOLD(nipif); 9293510Svi117747 sobj->saddr_ipifp = nipif; 9303510Svi117747 ASSERT(oipif->sctp_ipif_refcnt > 0); 9313510Svi117747 /* We have the writer lock */ 9323510Svi117747 oipif->sctp_ipif_refcnt--; 9333510Svi117747 /* 9343510Svi117747 * Can't have more than one referring 9353510Svi117747 * to the same sctp_ipif. 9363510Svi117747 */ 9373510Svi117747 break; 9383510Svi117747 } 9393510Svi117747 sobj = list_next(&sctp->sctp_saddrs[idx].sctp_ipif_list, 9403510Svi117747 sobj); 9413510Svi117747 } 9423510Svi117747 WAKE_SCTP(sctp); 9433510Svi117747 sctp_prev = sctp; 9443510Svi117747 mutex_enter(&sctps->sctps_g_lock); 9453510Svi117747 sctp = list_next(&sctps->sctps_g_list, sctp); 9463510Svi117747 } 9473510Svi117747 mutex_exit(&sctps->sctps_g_lock); 9483510Svi117747 if (sctp_prev != NULL) 9493510Svi117747 SCTP_REFRELE(sctp_prev); 9503510Svi117747 } 9513510Svi117747 9523510Svi117747 /* 9533510Svi117747 * Given an ipif, walk the hash list in the global ipif table and for 9543510Svi117747 * any other SCTP ipif with the same address and non-zero reference, walk 9553510Svi117747 * the SCTP list and update the saddr list, if required, to point to the 9569705SVenu.Iyer@Sun.COM * new SCTP ipif. If it is a loopback interface, then there could be 9579705SVenu.Iyer@Sun.COM * multiple interfaces with 127.0.0.1 if there are zones configured, so 9589705SVenu.Iyer@Sun.COM * check the zoneid in addition to the address. 9593510Svi117747 */ 9603510Svi117747 void 9613510Svi117747 sctp_chk_and_updt_saddr(int hindex, sctp_ipif_t *ipif, sctp_stack_t *sctps) 9623510Svi117747 { 9633510Svi117747 int cnt; 9643510Svi117747 sctp_ipif_t *sipif; 9653510Svi117747 9663510Svi117747 ASSERT(sctps->sctps_g_ipifs[hindex].ipif_count > 0); 9673510Svi117747 ASSERT(ipif->sctp_ipif_state == SCTP_IPIFS_UP); 9683510Svi117747 9693510Svi117747 sipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 9703510Svi117747 for (cnt = 0; cnt < sctps->sctps_g_ipifs[hindex].ipif_count; cnt++) { 9713510Svi117747 rw_enter(&sipif->sctp_ipif_lock, RW_WRITER); 9723510Svi117747 if (sipif->sctp_ipif_id != ipif->sctp_ipif_id && 9733510Svi117747 IN6_ARE_ADDR_EQUAL(&sipif->sctp_ipif_saddr, 9749705SVenu.Iyer@Sun.COM &ipif->sctp_ipif_saddr) && sipif->sctp_ipif_refcnt > 0 && 9759705SVenu.Iyer@Sun.COM (!SCTP_IS_IPIF_LOOPBACK(ipif) || ipif->sctp_ipif_zoneid == 9769705SVenu.Iyer@Sun.COM sipif->sctp_ipif_zoneid)) { 9773510Svi117747 /* 9783510Svi117747 * There can only be one address up at any time 9793510Svi117747 * and we are here because ipif has been brought 9803510Svi117747 * up. 9813510Svi117747 */ 9823510Svi117747 ASSERT(sipif->sctp_ipif_state != SCTP_IPIFS_UP); 9833510Svi117747 /* 9843510Svi117747 * Someone has a reference to this we need to update to 9853510Svi117747 * point to the new sipif. 9863510Svi117747 */ 9873510Svi117747 sctp_update_saddrs(sipif, ipif, hindex, sctps); 9883510Svi117747 } 9893510Svi117747 rw_exit(&sipif->sctp_ipif_lock); 9903510Svi117747 sipif = list_next(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 9913510Svi117747 sipif); 9923510Svi117747 } 9933510Svi117747 } 9943510Svi117747 9953510Svi117747 /* 9963510Svi117747 * Insert a new SCTP ipif using 'ipif'. v6addr is the address that existed 9973510Svi117747 * prior to the current address in 'ipif'. Only when an existing address 9983510Svi117747 * is changed on an IPIF, will v6addr be specified. If the IPIF already 9993510Svi117747 * exists in the global SCTP ipif table, then we either removed it, if 10003510Svi117747 * it doesn't have any existing reference, or mark it condemned otherwise. 10013510Svi117747 * If an address is being brought up (IPIF_UP), then we need to scan 10023510Svi117747 * the SCTP list to check if there is any SCTP that points to the *same* 10033510Svi117747 * address on a different SCTP ipif and update in that case. 10043510Svi117747 */ 10053510Svi117747 void 10063510Svi117747 sctp_update_ipif_addr(ipif_t *ipif, in6_addr_t v6addr) 10073510Svi117747 { 10083510Svi117747 ill_t *ill = ipif->ipif_ill; 10093510Svi117747 int i; 10103510Svi117747 sctp_ill_t *sctp_ill; 10113510Svi117747 sctp_ill_t *osctp_ill; 10123510Svi117747 sctp_ipif_t *sctp_ipif = NULL; 10133510Svi117747 sctp_ipif_t *osctp_ipif = NULL; 10143510Svi117747 uint_t ill_index; 10153510Svi117747 int hindex; 10163510Svi117747 sctp_stack_t *sctps; 10173510Svi117747 10183510Svi117747 sctps = ipif->ipif_ill->ill_ipst->ips_netstack->netstack_sctp; 10193510Svi117747 10203510Svi117747 /* Index for new address */ 10213510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, ill->ill_isv6); 10223510Svi117747 10233510Svi117747 /* 10243510Svi117747 * The address on this IPIF is changing, we need to look for 10253510Svi117747 * this old address and mark it condemned, before creating 10263510Svi117747 * one for the new address. 10273510Svi117747 */ 10283510Svi117747 osctp_ipif = sctp_lookup_ipif_addr(&v6addr, B_FALSE, 10293510Svi117747 ipif->ipif_zoneid, B_TRUE, SCTP_ILL_TO_PHYINDEX(ill), 10303510Svi117747 ipif->ipif_seqid, B_FALSE, sctps); 10313510Svi117747 10323510Svi117747 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 10333510Svi117747 rw_enter(&sctps->sctps_g_ipifs_lock, RW_WRITER); 10343510Svi117747 10353510Svi117747 ill_index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 10363510Svi117747 sctp_ill = list_head(&sctps->sctps_g_ills[ill_index].sctp_ill_list); 10373510Svi117747 for (i = 0; i < sctps->sctps_g_ills[ill_index].ill_count; i++) { 10384311Svi117747 if (sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill) && 10394311Svi117747 sctp_ill->sctp_ill_isv6 == ill->ill_isv6) { 10403510Svi117747 break; 10414311Svi117747 } 10423510Svi117747 sctp_ill = list_next( 10433510Svi117747 &sctps->sctps_g_ills[ill_index].sctp_ill_list, sctp_ill); 10443510Svi117747 } 10453510Svi117747 10463510Svi117747 if (sctp_ill == NULL) { 10474311Svi117747 ip1dbg(("sctp_update_ipif_addr: ill not found ..\n")); 10483510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 10493510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 10504311Svi117747 return; 10513510Svi117747 } 10523510Svi117747 10533510Svi117747 if (osctp_ipif != NULL) { 10543510Svi117747 10553510Svi117747 /* The address is the same? */ 10563510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif->ipif_v6lcl_addr, &v6addr)) { 10573510Svi117747 boolean_t chk_n_updt = B_FALSE; 10583510Svi117747 10593510Svi117747 rw_downgrade(&sctps->sctps_g_ipifs_lock); 10603510Svi117747 rw_enter(&osctp_ipif->sctp_ipif_lock, RW_WRITER); 10613510Svi117747 if (ipif->ipif_flags & IPIF_UP && 10623510Svi117747 osctp_ipif->sctp_ipif_state != SCTP_IPIFS_UP) { 10633510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 10643510Svi117747 chk_n_updt = B_TRUE; 10653510Svi117747 } else { 10663510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 10673510Svi117747 } 10683510Svi117747 osctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 10693510Svi117747 rw_exit(&osctp_ipif->sctp_ipif_lock); 10703510Svi117747 if (chk_n_updt) { 10713510Svi117747 sctp_chk_and_updt_saddr(hindex, osctp_ipif, 10723510Svi117747 sctps); 10733510Svi117747 } 10743510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 10753510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 10763510Svi117747 return; 10773510Svi117747 } 10783510Svi117747 /* 10793510Svi117747 * We are effectively removing this address from the ILL. 10803510Svi117747 */ 10813510Svi117747 if (osctp_ipif->sctp_ipif_refcnt != 0) { 10823510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_CONDEMNED; 10833510Svi117747 } else { 10843510Svi117747 list_t *ipif_list; 10853510Svi117747 int ohindex; 10863510Svi117747 10873510Svi117747 osctp_ill = osctp_ipif->sctp_ipif_ill; 10883510Svi117747 /* hash index for the old one */ 10893510Svi117747 ohindex = SCTP_IPIF_ADDR_HASH( 10903510Svi117747 osctp_ipif->sctp_ipif_saddr, 10913510Svi117747 osctp_ipif->sctp_ipif_isv6); 10923510Svi117747 10933510Svi117747 ipif_list = 10943510Svi117747 &sctps->sctps_g_ipifs[ohindex].sctp_ipif_list; 10953510Svi117747 10963510Svi117747 list_remove(ipif_list, (void *)osctp_ipif); 10973510Svi117747 sctps->sctps_g_ipifs[ohindex].ipif_count--; 10983510Svi117747 sctps->sctps_g_ipifs_count--; 10993510Svi117747 rw_destroy(&osctp_ipif->sctp_ipif_lock); 11003510Svi117747 kmem_free(osctp_ipif, sizeof (sctp_ipif_t)); 11013510Svi117747 (void) atomic_add_32_nv(&osctp_ill->sctp_ill_ipifcnt, 11023510Svi117747 -1); 11033510Svi117747 } 11043510Svi117747 } 11053510Svi117747 11063510Svi117747 sctp_ipif = kmem_zalloc(sizeof (sctp_ipif_t), KM_NOSLEEP); 11073510Svi117747 /* Try again? */ 11083510Svi117747 if (sctp_ipif == NULL) { 11094311Svi117747 cmn_err(CE_WARN, "sctp_update_ipif_addr: error adding " 11104311Svi117747 "IPIF %p to SCTP's IPIF list", (void *)ipif); 11113510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 11123510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 11133510Svi117747 return; 11143510Svi117747 } 11153510Svi117747 sctps->sctps_g_ipifs_count++; 11163510Svi117747 rw_init(&sctp_ipif->sctp_ipif_lock, NULL, RW_DEFAULT, NULL); 11173510Svi117747 sctp_ipif->sctp_ipif_saddr = ipif->ipif_v6lcl_addr; 11183510Svi117747 sctp_ipif->sctp_ipif_ill = sctp_ill; 11193510Svi117747 sctp_ipif->sctp_ipif_isv6 = ill->ill_isv6; 11203510Svi117747 sctp_ipif->sctp_ipif_zoneid = ipif->ipif_zoneid; 11213510Svi117747 sctp_ipif->sctp_ipif_id = ipif->ipif_seqid; 11223510Svi117747 if (ipif->ipif_flags & IPIF_UP) 11233510Svi117747 sctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 11243510Svi117747 else 11253510Svi117747 sctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 11263510Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 11273510Svi117747 /* 11283510Svi117747 * We add it to the head so that it is quicker to find good/recent 11293510Svi117747 * additions. 11303510Svi117747 */ 11313510Svi117747 list_insert_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 11323510Svi117747 (void *)sctp_ipif); 11333510Svi117747 sctps->sctps_g_ipifs[hindex].ipif_count++; 11343510Svi117747 atomic_add_32(&sctp_ill->sctp_ill_ipifcnt, 1); 11353510Svi117747 if (sctp_ipif->sctp_ipif_state == SCTP_IPIFS_UP) 11363510Svi117747 sctp_chk_and_updt_saddr(hindex, sctp_ipif, sctps); 11373510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 11383510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 11393510Svi117747 } 11403510Svi117747 11410Sstevel@tonic-gate /* Insert, Remove, Mark up or Mark down the ipif */ 11420Sstevel@tonic-gate void 11430Sstevel@tonic-gate sctp_update_ipif(ipif_t *ipif, int op) 11440Sstevel@tonic-gate { 11450Sstevel@tonic-gate ill_t *ill = ipif->ipif_ill; 11460Sstevel@tonic-gate int i; 11470Sstevel@tonic-gate sctp_ill_t *sctp_ill; 11480Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 11490Sstevel@tonic-gate uint_t ill_index; 11503510Svi117747 uint_t hindex; 11513448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 11523448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 11530Sstevel@tonic-gate 11540Sstevel@tonic-gate ip2dbg(("sctp_update_ipif: %s %d\n", ill->ill_name, ipif->ipif_seqid)); 11550Sstevel@tonic-gate 11563448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 11573448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_WRITER); 11580Sstevel@tonic-gate 11590Sstevel@tonic-gate ill_index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 11603448Sdh155122 sctp_ill = list_head(&sctps->sctps_g_ills[ill_index].sctp_ill_list); 11613448Sdh155122 for (i = 0; i < sctps->sctps_g_ills[ill_index].ill_count; i++) { 11624311Svi117747 if (sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill) && 11634311Svi117747 sctp_ill->sctp_ill_isv6 == ill->ill_isv6) { 11640Sstevel@tonic-gate break; 11654311Svi117747 } 11663448Sdh155122 sctp_ill = list_next( 11673448Sdh155122 &sctps->sctps_g_ills[ill_index].sctp_ill_list, sctp_ill); 11680Sstevel@tonic-gate } 11690Sstevel@tonic-gate if (sctp_ill == NULL) { 11703448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 11713448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 11720Sstevel@tonic-gate return; 11730Sstevel@tonic-gate } 11740Sstevel@tonic-gate 11753510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, 11763510Svi117747 ipif->ipif_ill->ill_isv6); 11773510Svi117747 sctp_ipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 11783510Svi117747 for (i = 0; i < sctps->sctps_g_ipifs[hindex].ipif_count; i++) { 11793510Svi117747 if (sctp_ipif->sctp_ipif_id == ipif->ipif_seqid) { 11803510Svi117747 ASSERT(IN6_ARE_ADDR_EQUAL(&sctp_ipif->sctp_ipif_saddr, 11813510Svi117747 &ipif->ipif_v6lcl_addr)); 11820Sstevel@tonic-gate break; 11833510Svi117747 } 11843448Sdh155122 sctp_ipif = list_next( 11853510Svi117747 &sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 11860Sstevel@tonic-gate sctp_ipif); 11870Sstevel@tonic-gate } 11883510Svi117747 if (sctp_ipif == NULL) { 11890Sstevel@tonic-gate ip1dbg(("sctp_update_ipif: null sctp_ipif for %d\n", op)); 11903448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 11913448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 11920Sstevel@tonic-gate return; 11930Sstevel@tonic-gate } 11943510Svi117747 ASSERT(sctp_ill == sctp_ipif->sctp_ipif_ill); 11950Sstevel@tonic-gate switch (op) { 11960Sstevel@tonic-gate case SCTP_IPIF_REMOVE: 11970Sstevel@tonic-gate { 11980Sstevel@tonic-gate list_t *ipif_list; 11990Sstevel@tonic-gate list_t *ill_list; 12000Sstevel@tonic-gate 12013448Sdh155122 ill_list = &sctps->sctps_g_ills[ill_index].sctp_ill_list; 12023510Svi117747 ipif_list = &sctps->sctps_g_ipifs[hindex].sctp_ipif_list; 12030Sstevel@tonic-gate if (sctp_ipif->sctp_ipif_refcnt != 0) { 12040Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_CONDEMNED; 12053448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 12063448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 12070Sstevel@tonic-gate return; 12080Sstevel@tonic-gate } 12090Sstevel@tonic-gate list_remove(ipif_list, (void *)sctp_ipif); 12103510Svi117747 sctps->sctps_g_ipifs[hindex].ipif_count--; 12113448Sdh155122 sctps->sctps_g_ipifs_count--; 12120Sstevel@tonic-gate rw_destroy(&sctp_ipif->sctp_ipif_lock); 12130Sstevel@tonic-gate kmem_free(sctp_ipif, sizeof (sctp_ipif_t)); 12140Sstevel@tonic-gate (void) atomic_add_32_nv(&sctp_ill->sctp_ill_ipifcnt, -1); 12153448Sdh155122 if (rw_tryupgrade(&sctps->sctps_g_ills_lock) != 0) { 12163448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 12170Sstevel@tonic-gate if (sctp_ill->sctp_ill_ipifcnt == 0 && 12180Sstevel@tonic-gate sctp_ill->sctp_ill_state == SCTP_ILLS_CONDEMNED) { 12190Sstevel@tonic-gate list_remove(ill_list, (void *)sctp_ill); 12203448Sdh155122 sctps->sctps_ills_count--; 12213448Sdh155122 sctps->sctps_g_ills[ill_index].ill_count--; 12220Sstevel@tonic-gate kmem_free(sctp_ill->sctp_ill_name, 12230Sstevel@tonic-gate sctp_ill->sctp_ill_name_length); 12240Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 12250Sstevel@tonic-gate } 12260Sstevel@tonic-gate } 12270Sstevel@tonic-gate break; 12280Sstevel@tonic-gate } 12290Sstevel@tonic-gate 12300Sstevel@tonic-gate case SCTP_IPIF_UP: 12310Sstevel@tonic-gate 12323448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 12330Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 12340Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 1235432Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 12360Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 12373510Svi117747 sctp_chk_and_updt_saddr(hindex, sctp_ipif, 12383510Svi117747 ipif->ipif_ill->ill_ipst->ips_netstack->netstack_sctp); 12390Sstevel@tonic-gate 12400Sstevel@tonic-gate break; 12410Sstevel@tonic-gate 12420Sstevel@tonic-gate case SCTP_IPIF_UPDATE: 12430Sstevel@tonic-gate 12443448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 12450Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 12460Sstevel@tonic-gate sctp_ipif->sctp_ipif_zoneid = ipif->ipif_zoneid; 1247432Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 12480Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 12490Sstevel@tonic-gate 12500Sstevel@tonic-gate break; 12510Sstevel@tonic-gate 12520Sstevel@tonic-gate case SCTP_IPIF_DOWN: 12530Sstevel@tonic-gate 12543448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 12550Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 12560Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 12573510Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 12580Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 12590Sstevel@tonic-gate 12600Sstevel@tonic-gate break; 12610Sstevel@tonic-gate } 12623448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 12633448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 12640Sstevel@tonic-gate } 12650Sstevel@tonic-gate 12660Sstevel@tonic-gate /* 12670Sstevel@tonic-gate * SCTP source address list manipulaton, locking not used (except for 12680Sstevel@tonic-gate * sctp locking by the caller. 12690Sstevel@tonic-gate */ 12700Sstevel@tonic-gate 12710Sstevel@tonic-gate /* Remove a specific saddr from the list */ 12720Sstevel@tonic-gate void 12730Sstevel@tonic-gate sctp_del_saddr(sctp_t *sctp, sctp_saddr_ipif_t *sp) 12740Sstevel@tonic-gate { 12750Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12760Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 12770Sstevel@tonic-gate 12780Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12790Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 12800Sstevel@tonic-gate 1281*11373SGeorge.Shepherd@Sun.COM sctp_ipif_hash_remove(sctp, sp->saddr_ipifp, B_FALSE); 12820Sstevel@tonic-gate 1283432Svi117747 if (sctp->sctp_bound_to_all == 1) 12840Sstevel@tonic-gate sctp->sctp_bound_to_all = 0; 12850Sstevel@tonic-gate 12860Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12870Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 12880Sstevel@tonic-gate 12890Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12900Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 12910Sstevel@tonic-gate } 12920Sstevel@tonic-gate 12930Sstevel@tonic-gate /* 12940Sstevel@tonic-gate * Delete source address from the existing list. No error checking done here 12950Sstevel@tonic-gate * Called with no locks held. 12960Sstevel@tonic-gate */ 12970Sstevel@tonic-gate void 12980Sstevel@tonic-gate sctp_del_saddr_list(sctp_t *sctp, const void *addrs, int addcnt, 12990Sstevel@tonic-gate boolean_t fanout_locked) 13000Sstevel@tonic-gate { 13010Sstevel@tonic-gate struct sockaddr_in *sin4; 13020Sstevel@tonic-gate struct sockaddr_in6 *sin6; 13030Sstevel@tonic-gate int cnt; 13040Sstevel@tonic-gate in6_addr_t addr; 13050Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 1306852Svi117747 int ifindex = 0; 130711042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp; 13080Sstevel@tonic-gate 1309852Svi117747 ASSERT(sctp->sctp_nsaddrs >= addcnt); 13100Sstevel@tonic-gate 13110Sstevel@tonic-gate if (!fanout_locked) { 13120Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 13130Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 13140Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 13150Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 13160Sstevel@tonic-gate } 13170Sstevel@tonic-gate 13180Sstevel@tonic-gate for (cnt = 0; cnt < addcnt; cnt++) { 131911042SErik.Nordmark@Sun.COM switch (connp->conn_family) { 13200Sstevel@tonic-gate case AF_INET: 13210Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + cnt; 13220Sstevel@tonic-gate IN6_INADDR_TO_V4MAPPED(&sin4->sin_addr, &addr); 13230Sstevel@tonic-gate break; 13240Sstevel@tonic-gate 13250Sstevel@tonic-gate case AF_INET6: 13260Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + cnt; 13270Sstevel@tonic-gate addr = sin6->sin6_addr; 1328852Svi117747 ifindex = sin6->sin6_scope_id; 13290Sstevel@tonic-gate break; 13300Sstevel@tonic-gate } 13313510Svi117747 sctp_ipif = sctp_lookup_ipif_addr(&addr, B_FALSE, 133211042SErik.Nordmark@Sun.COM IPCL_ZONEID(connp), !connp->conn_allzones, 13333510Svi117747 ifindex, 0, B_TRUE, sctp->sctp_sctps); 13340Sstevel@tonic-gate ASSERT(sctp_ipif != NULL); 1335*11373SGeorge.Shepherd@Sun.COM sctp_ipif_hash_remove(sctp, sctp_ipif, B_FALSE); 13360Sstevel@tonic-gate } 1337432Svi117747 if (sctp->sctp_bound_to_all == 1) 13380Sstevel@tonic-gate sctp->sctp_bound_to_all = 0; 13390Sstevel@tonic-gate 13400Sstevel@tonic-gate if (!fanout_locked) { 13410Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 13420Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 13430Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 13440Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 13450Sstevel@tonic-gate } 13460Sstevel@tonic-gate } 13470Sstevel@tonic-gate 13480Sstevel@tonic-gate /* 13490Sstevel@tonic-gate * Given an address get the corresponding entry from the list 13500Sstevel@tonic-gate * Called with no locks held. 13510Sstevel@tonic-gate */ 13520Sstevel@tonic-gate sctp_saddr_ipif_t * 1353852Svi117747 sctp_saddr_lookup(sctp_t *sctp, in6_addr_t *addr, uint_t ifindex) 13540Sstevel@tonic-gate { 13553510Svi117747 int cnt; 13563510Svi117747 sctp_saddr_ipif_t *ipif_obj; 13573510Svi117747 int hindex; 13580Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 13590Sstevel@tonic-gate 13603510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(*addr, !IN6_IS_ADDR_V4MAPPED(addr)); 1361*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[hindex].ipif_hash_lock, RW_READER); 1362*11373SGeorge.Shepherd@Sun.COM if (sctp->sctp_saddrs[hindex].ipif_count == 0) { 1363*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[hindex].ipif_hash_lock); 13640Sstevel@tonic-gate return (NULL); 1365*11373SGeorge.Shepherd@Sun.COM } 13660Sstevel@tonic-gate 13673510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 13683510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 13693510Svi117747 sctp_ipif = ipif_obj->saddr_ipifp; 13703510Svi117747 /* 13713510Svi117747 * Zone check shouldn't be needed. 13723510Svi117747 */ 13733510Svi117747 if (IN6_ARE_ADDR_EQUAL(addr, &sctp_ipif->sctp_ipif_saddr) && 13743510Svi117747 (ifindex == 0 || 13753510Svi117747 ifindex == sctp_ipif->sctp_ipif_ill->sctp_ill_index) && 13763510Svi117747 SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state)) { 1377*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[hindex].ipif_hash_lock); 13783510Svi117747 return (ipif_obj); 13793510Svi117747 } 13803510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 13813510Svi117747 ipif_obj); 13823510Svi117747 } 1383*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[hindex].ipif_hash_lock); 13843510Svi117747 return (NULL); 13850Sstevel@tonic-gate } 13860Sstevel@tonic-gate 1387432Svi117747 /* Given an address, add it to the source address list */ 1388432Svi117747 int 1389852Svi117747 sctp_saddr_add_addr(sctp_t *sctp, in6_addr_t *addr, uint_t ifindex) 1390432Svi117747 { 1391432Svi117747 sctp_ipif_t *sctp_ipif; 139211042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp; 1393432Svi117747 139411042SErik.Nordmark@Sun.COM sctp_ipif = sctp_lookup_ipif_addr(addr, B_TRUE, IPCL_ZONEID(connp), 139511042SErik.Nordmark@Sun.COM !connp->conn_allzones, ifindex, 0, B_TRUE, sctp->sctp_sctps); 1396432Svi117747 if (sctp_ipif == NULL) 1397432Svi117747 return (EINVAL); 1398432Svi117747 13993510Svi117747 if (sctp_ipif_hash_insert(sctp, sctp_ipif, KM_NOSLEEP, B_FALSE, 14003510Svi117747 B_FALSE) != 0) { 1401432Svi117747 SCTP_IPIF_REFRELE(sctp_ipif); 1402432Svi117747 return (EINVAL); 1403432Svi117747 } 1404432Svi117747 return (0); 1405432Svi117747 } 1406432Svi117747 1407432Svi117747 /* 1408432Svi117747 * Remove or mark as dontsrc addresses that are currently not part of the 1409432Svi117747 * association. One would delete addresses when processing an INIT and 1410432Svi117747 * mark as dontsrc when processing an INIT-ACK. 1411432Svi117747 */ 1412432Svi117747 void 14134818Skcpoon sctp_check_saddr(sctp_t *sctp, int supp_af, boolean_t delete, 14144818Skcpoon in6_addr_t *no_del_addr) 1415432Svi117747 { 1416432Svi117747 int i; 1417432Svi117747 int l; 1418432Svi117747 sctp_saddr_ipif_t *obj; 1419432Svi117747 int scanned = 0; 1420432Svi117747 int naddr; 1421432Svi117747 int nsaddr; 142211042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp; 1423432Svi117747 1424432Svi117747 ASSERT(!sctp->sctp_loopback && !sctp->sctp_linklocal && supp_af != 0); 1425432Svi117747 1426432Svi117747 /* 1427432Svi117747 * Irregardless of the supported address in the INIT, v4 1428432Svi117747 * must be supported. 1429432Svi117747 */ 143011042SErik.Nordmark@Sun.COM if (connp->conn_family == AF_INET) 1431432Svi117747 supp_af = PARM_SUPP_V4; 1432432Svi117747 1433432Svi117747 nsaddr = sctp->sctp_nsaddrs; 1434432Svi117747 for (i = 0; i < SCTP_IPIF_HASH; i++) { 1435*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[i].ipif_hash_lock, RW_WRITER); 1436*11373SGeorge.Shepherd@Sun.COM if (sctp->sctp_saddrs[i].ipif_count == 0) { 1437*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 1438432Svi117747 continue; 1439*11373SGeorge.Shepherd@Sun.COM } 1440432Svi117747 obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 1441432Svi117747 naddr = sctp->sctp_saddrs[i].ipif_count; 1442432Svi117747 for (l = 0; l < naddr; l++) { 1443432Svi117747 sctp_ipif_t *ipif; 1444432Svi117747 1445432Svi117747 ipif = obj->saddr_ipifp; 1446432Svi117747 scanned++; 1447432Svi117747 14484818Skcpoon if (IN6_ARE_ADDR_EQUAL(&ipif->sctp_ipif_saddr, 14494818Skcpoon no_del_addr)) { 14504818Skcpoon goto next_obj; 14514818Skcpoon } 14524818Skcpoon 1453432Svi117747 /* 1454432Svi117747 * Delete/mark dontsrc loopback/linklocal addresses and 1455432Svi117747 * unsupported address. 1456852Svi117747 * On a clustered node, we trust the clustering module 1457852Svi117747 * to do the right thing w.r.t loopback addresses, so 1458852Svi117747 * we ignore loopback addresses in this check. 1459432Svi117747 */ 1460852Svi117747 if ((SCTP_IS_IPIF_LOOPBACK(ipif) && 1461852Svi117747 cl_sctp_check_addrs == NULL) || 1462852Svi117747 SCTP_IS_IPIF_LINKLOCAL(ipif) || 1463432Svi117747 SCTP_UNSUPP_AF(ipif, supp_af)) { 1464432Svi117747 if (!delete) { 1465432Svi117747 obj->saddr_ipif_unconfirmed = 1; 1466432Svi117747 goto next_obj; 1467432Svi117747 } 1468432Svi117747 if (sctp->sctp_bound_to_all == 1) 1469432Svi117747 sctp->sctp_bound_to_all = 0; 1470432Svi117747 if (scanned < nsaddr) { 1471432Svi117747 obj = list_next(&sctp->sctp_saddrs[i]. 1472432Svi117747 sctp_ipif_list, obj); 1473*11373SGeorge.Shepherd@Sun.COM sctp_ipif_hash_remove(sctp, ipif, 1474*11373SGeorge.Shepherd@Sun.COM B_TRUE); 1475432Svi117747 continue; 1476432Svi117747 } 1477*11373SGeorge.Shepherd@Sun.COM sctp_ipif_hash_remove(sctp, ipif, B_TRUE); 1478432Svi117747 } 1479432Svi117747 next_obj: 1480*11373SGeorge.Shepherd@Sun.COM if (scanned >= nsaddr) { 1481*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 1482432Svi117747 return; 1483*11373SGeorge.Shepherd@Sun.COM } 1484432Svi117747 obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 1485432Svi117747 obj); 1486432Svi117747 } 1487*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 1488432Svi117747 } 1489432Svi117747 } 1490432Svi117747 1491432Svi117747 14920Sstevel@tonic-gate /* Get the first valid address from the list. Called with no locks held */ 14930Sstevel@tonic-gate in6_addr_t 14944818Skcpoon sctp_get_valid_addr(sctp_t *sctp, boolean_t isv6, boolean_t *addr_set) 14950Sstevel@tonic-gate { 14960Sstevel@tonic-gate int i; 14970Sstevel@tonic-gate int l; 14980Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 14990Sstevel@tonic-gate int scanned = 0; 15000Sstevel@tonic-gate in6_addr_t addr; 15010Sstevel@tonic-gate 15020Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 1503*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[i].ipif_hash_lock, RW_READER); 1504*11373SGeorge.Shepherd@Sun.COM if (sctp->sctp_saddrs[i].ipif_count == 0) { 1505*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 15060Sstevel@tonic-gate continue; 1507*11373SGeorge.Shepherd@Sun.COM } 15080Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 15090Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 15100Sstevel@tonic-gate sctp_ipif_t *ipif; 15110Sstevel@tonic-gate 15120Sstevel@tonic-gate ipif = obj->saddr_ipifp; 1513432Svi117747 if (!SCTP_DONT_SRC(obj) && 15140Sstevel@tonic-gate ipif->sctp_ipif_isv6 == isv6 && 1515432Svi117747 ipif->sctp_ipif_state == SCTP_IPIFS_UP) { 15164818Skcpoon *addr_set = B_TRUE; 1517*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 15180Sstevel@tonic-gate return (ipif->sctp_ipif_saddr); 15190Sstevel@tonic-gate } 15200Sstevel@tonic-gate scanned++; 1521*11373SGeorge.Shepherd@Sun.COM if (scanned >= sctp->sctp_nsaddrs) { 1522*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 15230Sstevel@tonic-gate goto got_none; 1524*11373SGeorge.Shepherd@Sun.COM } 15250Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 15260Sstevel@tonic-gate obj); 15270Sstevel@tonic-gate } 1528*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 15290Sstevel@tonic-gate } 15300Sstevel@tonic-gate got_none: 15310Sstevel@tonic-gate /* Need to double check this */ 15320Sstevel@tonic-gate if (isv6 == B_TRUE) 15330Sstevel@tonic-gate addr = ipv6_all_zeros; 15340Sstevel@tonic-gate else 15350Sstevel@tonic-gate IN6_IPADDR_TO_V4MAPPED(0, &addr); 15364818Skcpoon *addr_set = B_FALSE; 15370Sstevel@tonic-gate return (addr); 15380Sstevel@tonic-gate } 15390Sstevel@tonic-gate 15400Sstevel@tonic-gate /* 15410Sstevel@tonic-gate * Return the list of local addresses of an association. The parameter 15420Sstevel@tonic-gate * myaddrs is supposed to be either (struct sockaddr_in *) or (struct 15430Sstevel@tonic-gate * sockaddr_in6 *) depending on the address family. 15440Sstevel@tonic-gate */ 15450Sstevel@tonic-gate int 15460Sstevel@tonic-gate sctp_getmyaddrs(void *conn, void *myaddrs, int *addrcnt) 15470Sstevel@tonic-gate { 15480Sstevel@tonic-gate int i; 15490Sstevel@tonic-gate int l; 15500Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 15510Sstevel@tonic-gate sctp_t *sctp = (sctp_t *)conn; 155211042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp; 155311042SErik.Nordmark@Sun.COM int family = connp->conn_family; 15540Sstevel@tonic-gate int max = *addrcnt; 15550Sstevel@tonic-gate size_t added = 0; 15560Sstevel@tonic-gate struct sockaddr_in6 *sin6; 15570Sstevel@tonic-gate struct sockaddr_in *sin4; 15580Sstevel@tonic-gate int scanned = 0; 15590Sstevel@tonic-gate boolean_t skip_lback = B_FALSE; 156011042SErik.Nordmark@Sun.COM ip_xmit_attr_t *ixa = connp->conn_ixa; 15610Sstevel@tonic-gate 15620Sstevel@tonic-gate if (sctp->sctp_nsaddrs == 0) 15630Sstevel@tonic-gate return (EINVAL); 15640Sstevel@tonic-gate 1565852Svi117747 /* 1566852Svi117747 * Skip loopback addresses for non-loopback assoc., ignore 1567852Svi117747 * this on a clustered node. 1568852Svi117747 */ 1569852Svi117747 if (sctp->sctp_state >= SCTPS_ESTABLISHED && !sctp->sctp_loopback && 1570852Svi117747 (cl_sctp_check_addrs == NULL)) { 15710Sstevel@tonic-gate skip_lback = B_TRUE; 1572852Svi117747 } 1573852Svi117747 15740Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 1575*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[i].ipif_hash_lock, RW_READER); 1576*11373SGeorge.Shepherd@Sun.COM if (sctp->sctp_saddrs[i].ipif_count == 0) { 1577*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 15780Sstevel@tonic-gate continue; 1579*11373SGeorge.Shepherd@Sun.COM } 15800Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 15810Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 15820Sstevel@tonic-gate sctp_ipif_t *ipif = obj->saddr_ipifp; 15830Sstevel@tonic-gate in6_addr_t addr = ipif->sctp_ipif_saddr; 15840Sstevel@tonic-gate 15850Sstevel@tonic-gate scanned++; 15860Sstevel@tonic-gate if ((ipif->sctp_ipif_state == SCTP_IPIFS_CONDEMNED) || 1587432Svi117747 SCTP_DONT_SRC(obj) || 1588852Svi117747 (SCTP_IS_IPIF_LOOPBACK(ipif) && skip_lback)) { 1589*11373SGeorge.Shepherd@Sun.COM if (scanned >= sctp->sctp_nsaddrs) { 1590*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp-> 1591*11373SGeorge.Shepherd@Sun.COM sctp_saddrs[i].ipif_hash_lock); 15920Sstevel@tonic-gate goto done; 1593*11373SGeorge.Shepherd@Sun.COM } 15940Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i]. 15950Sstevel@tonic-gate sctp_ipif_list, obj); 15960Sstevel@tonic-gate continue; 15970Sstevel@tonic-gate } 15980Sstevel@tonic-gate switch (family) { 15990Sstevel@tonic-gate case AF_INET: 16000Sstevel@tonic-gate sin4 = (struct sockaddr_in *)myaddrs + added; 16010Sstevel@tonic-gate sin4->sin_family = AF_INET; 160211042SErik.Nordmark@Sun.COM sin4->sin_port = connp->conn_lport; 16030Sstevel@tonic-gate IN6_V4MAPPED_TO_INADDR(&addr, &sin4->sin_addr); 16040Sstevel@tonic-gate break; 16050Sstevel@tonic-gate 16060Sstevel@tonic-gate case AF_INET6: 16070Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)myaddrs + added; 16080Sstevel@tonic-gate sin6->sin6_family = AF_INET6; 160911042SErik.Nordmark@Sun.COM sin6->sin6_port = connp->conn_lport; 16100Sstevel@tonic-gate sin6->sin6_addr = addr; 161111042SErik.Nordmark@Sun.COM /* 161211042SErik.Nordmark@Sun.COM * Note that flowinfo is only returned for 161311042SErik.Nordmark@Sun.COM * getpeername just like for TCP and UDP. 161411042SErik.Nordmark@Sun.COM */ 161511042SErik.Nordmark@Sun.COM sin6->sin6_flowinfo = 0; 161611042SErik.Nordmark@Sun.COM 161711042SErik.Nordmark@Sun.COM if (IN6_IS_ADDR_LINKSCOPE(&sin6->sin6_addr) && 161811042SErik.Nordmark@Sun.COM (ixa->ixa_flags & IXAF_SCOPEID_SET)) 161911042SErik.Nordmark@Sun.COM sin6->sin6_scope_id = ixa->ixa_scopeid; 162011042SErik.Nordmark@Sun.COM else 162111042SErik.Nordmark@Sun.COM sin6->sin6_scope_id = 0; 162211042SErik.Nordmark@Sun.COM sin6->__sin6_src_id = 0; 16230Sstevel@tonic-gate break; 16240Sstevel@tonic-gate } 16250Sstevel@tonic-gate added++; 1626*11373SGeorge.Shepherd@Sun.COM if (added >= max || scanned >= sctp->sctp_nsaddrs) { 1627*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 16280Sstevel@tonic-gate goto done; 1629*11373SGeorge.Shepherd@Sun.COM } 16300Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 16310Sstevel@tonic-gate obj); 16320Sstevel@tonic-gate } 1633*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 16340Sstevel@tonic-gate } 16350Sstevel@tonic-gate done: 16360Sstevel@tonic-gate *addrcnt = added; 16370Sstevel@tonic-gate return (0); 16380Sstevel@tonic-gate } 16390Sstevel@tonic-gate 16400Sstevel@tonic-gate /* 1641252Svi117747 * Given the supported address family, walk through the source address list 1642252Svi117747 * and return the total length of the available addresses. If 'p' is not 1643252Svi117747 * null, construct the parameter list for the addresses in 'p'. 1644432Svi117747 * 'modify' will only be set when we want the source address list to 1645432Svi117747 * be modified. The source address list will be modified only when 1646432Svi117747 * generating an INIT chunk. For generating an INIT-ACK 'modify' will 1647432Svi117747 * be false since the 'sctp' will be that of the listener. 16480Sstevel@tonic-gate */ 16490Sstevel@tonic-gate size_t 1650432Svi117747 sctp_saddr_info(sctp_t *sctp, int supp_af, uchar_t *p, boolean_t modify) 16510Sstevel@tonic-gate { 16520Sstevel@tonic-gate int i; 16530Sstevel@tonic-gate int l; 16540Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 1655252Svi117747 size_t paramlen = 0; 16560Sstevel@tonic-gate sctp_parm_hdr_t *hdr; 16570Sstevel@tonic-gate int scanned = 0; 1658432Svi117747 int naddr; 1659432Svi117747 int nsaddr; 1660852Svi117747 boolean_t del_ll = B_FALSE; 1661852Svi117747 boolean_t del_lb = B_FALSE; 1662852Svi117747 16630Sstevel@tonic-gate 1664852Svi117747 /* 1665852Svi117747 * On a clustered node don't bother changing anything 1666852Svi117747 * on the loopback interface. 1667852Svi117747 */ 1668852Svi117747 if (modify && !sctp->sctp_loopback && (cl_sctp_check_addrs == NULL)) 1669852Svi117747 del_lb = B_TRUE; 1670852Svi117747 1671852Svi117747 if (modify && !sctp->sctp_linklocal) 1672852Svi117747 del_ll = B_TRUE; 1673432Svi117747 1674432Svi117747 nsaddr = sctp->sctp_nsaddrs; 16750Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 1676*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[i].ipif_hash_lock, RW_WRITER); 1677*11373SGeorge.Shepherd@Sun.COM if (sctp->sctp_saddrs[i].ipif_count == 0) { 1678*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 16790Sstevel@tonic-gate continue; 1680*11373SGeorge.Shepherd@Sun.COM } 16810Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 1682432Svi117747 naddr = sctp->sctp_saddrs[i].ipif_count; 1683432Svi117747 for (l = 0; l < naddr; l++) { 16840Sstevel@tonic-gate in6_addr_t addr; 16850Sstevel@tonic-gate sctp_ipif_t *ipif; 1686852Svi117747 boolean_t ipif_lb; 1687852Svi117747 boolean_t ipif_ll; 1688432Svi117747 boolean_t unsupp_af; 16890Sstevel@tonic-gate 16900Sstevel@tonic-gate ipif = obj->saddr_ipifp; 16910Sstevel@tonic-gate scanned++; 1692432Svi117747 1693852Svi117747 ipif_lb = SCTP_IS_IPIF_LOOPBACK(ipif); 1694852Svi117747 ipif_ll = SCTP_IS_IPIF_LINKLOCAL(ipif); 1695432Svi117747 unsupp_af = SCTP_UNSUPP_AF(ipif, supp_af); 1696432Svi117747 /* 1697432Svi117747 * We need to either delete or skip loopback/linklocal 1698852Svi117747 * or unsupported addresses, if required. 1699432Svi117747 */ 1700852Svi117747 if ((ipif_ll && del_ll) || (ipif_lb && del_lb) || 1701852Svi117747 (unsupp_af && modify)) { 1702432Svi117747 if (sctp->sctp_bound_to_all == 1) 1703432Svi117747 sctp->sctp_bound_to_all = 0; 1704432Svi117747 if (scanned < nsaddr) { 1705432Svi117747 obj = list_next(&sctp->sctp_saddrs[i]. 1706432Svi117747 sctp_ipif_list, obj); 1707*11373SGeorge.Shepherd@Sun.COM sctp_ipif_hash_remove(sctp, ipif, 1708*11373SGeorge.Shepherd@Sun.COM B_TRUE); 1709432Svi117747 continue; 1710432Svi117747 } 1711*11373SGeorge.Shepherd@Sun.COM sctp_ipif_hash_remove(sctp, ipif, B_TRUE); 1712*11373SGeorge.Shepherd@Sun.COM 1713432Svi117747 goto next_addr; 1714852Svi117747 } else if (ipif_ll || unsupp_af || 1715852Svi117747 (ipif_lb && (cl_sctp_check_addrs == NULL))) { 1716252Svi117747 goto next_addr; 17170Sstevel@tonic-gate } 1718432Svi117747 1719432Svi117747 if (!SCTP_IPIF_USABLE(ipif->sctp_ipif_state)) 1720432Svi117747 goto next_addr; 1721252Svi117747 if (p != NULL) 1722252Svi117747 hdr = (sctp_parm_hdr_t *)(p + paramlen); 17230Sstevel@tonic-gate addr = ipif->sctp_ipif_saddr; 1724432Svi117747 if (!ipif->sctp_ipif_isv6) { 17250Sstevel@tonic-gate struct in_addr *v4; 17260Sstevel@tonic-gate 1727252Svi117747 if (p != NULL) { 1728252Svi117747 hdr->sph_type = htons(PARM_ADDR4); 1729252Svi117747 hdr->sph_len = htons(PARM_ADDR4_LEN); 1730252Svi117747 v4 = (struct in_addr *)(hdr + 1); 1731252Svi117747 IN6_V4MAPPED_TO_INADDR(&addr, v4); 1732252Svi117747 } 1733252Svi117747 paramlen += PARM_ADDR4_LEN; 1734432Svi117747 } else { 1735252Svi117747 if (p != NULL) { 1736252Svi117747 hdr->sph_type = htons(PARM_ADDR6); 1737252Svi117747 hdr->sph_len = htons(PARM_ADDR6_LEN); 1738252Svi117747 bcopy(&addr, hdr + 1, sizeof (addr)); 1739252Svi117747 } 1740252Svi117747 paramlen += PARM_ADDR6_LEN; 17410Sstevel@tonic-gate } 1742252Svi117747 next_addr: 1743*11373SGeorge.Shepherd@Sun.COM if (scanned >= nsaddr) { 1744*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 1745252Svi117747 return (paramlen); 1746*11373SGeorge.Shepherd@Sun.COM } 17470Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 17480Sstevel@tonic-gate obj); 17490Sstevel@tonic-gate } 1750*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[i].ipif_hash_lock); 17510Sstevel@tonic-gate } 1752252Svi117747 return (paramlen); 17530Sstevel@tonic-gate } 17540Sstevel@tonic-gate 1755852Svi117747 /* 1756852Svi117747 * This is used on a clustered node to obtain a list of addresses, the list 1757852Svi117747 * consists of sockaddr_in structs for v4 and sockaddr_in6 for v6. The list 1758852Svi117747 * is then passed onto the clustering module which sends back the correct 1759852Svi117747 * list based on the port info. Regardless of the input, i.e INADDR_ANY 1760852Svi117747 * or specific address(es), we create the list since it could be modified by 1761852Svi117747 * the clustering module. When given a list of addresses, we simply 1762852Svi117747 * create the list of sockaddr_in or sockaddr_in6 structs using those 1763852Svi117747 * addresses. If there is an INADDR_ANY in the input list, or if the 1764852Svi117747 * input is INADDR_ANY, we create a list of sockaddr_in or sockaddr_in6 1765852Svi117747 * structs consisting all the addresses in the global interface list 1766852Svi117747 * except those that are hosted on the loopback interface. We create 1767852Svi117747 * a list of sockaddr_in[6] structs just so that it can be directly input 1768852Svi117747 * to sctp_valid_addr_list() once the clustering module has processed it. 1769852Svi117747 */ 1770852Svi117747 int 1771852Svi117747 sctp_get_addrlist(sctp_t *sctp, const void *addrs, uint32_t *addrcnt, 1772852Svi117747 uchar_t **addrlist, int *uspec, size_t *size) 1773852Svi117747 { 1774852Svi117747 int cnt; 1775852Svi117747 int icnt; 1776852Svi117747 sctp_ipif_t *sctp_ipif; 1777852Svi117747 struct sockaddr_in *s4; 1778852Svi117747 struct sockaddr_in6 *s6; 1779852Svi117747 uchar_t *p; 1780852Svi117747 int err = 0; 17813448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps; 178211042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp; 1783852Svi117747 1784852Svi117747 *addrlist = NULL; 1785852Svi117747 *size = 0; 1786852Svi117747 1787852Svi117747 /* 1788852Svi117747 * Create a list of sockaddr_in[6] structs using the input list. 1789852Svi117747 */ 179011042SErik.Nordmark@Sun.COM if (connp->conn_family == AF_INET) { 1791852Svi117747 *size = sizeof (struct sockaddr_in) * *addrcnt; 1792852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1793852Svi117747 p = *addrlist; 1794852Svi117747 for (cnt = 0; cnt < *addrcnt; cnt++) { 1795852Svi117747 s4 = (struct sockaddr_in *)addrs + cnt; 1796852Svi117747 /* 1797852Svi117747 * We need to create a list of all the available 1798852Svi117747 * addresses if there is an INADDR_ANY. However, 1799852Svi117747 * if we are beyond LISTEN, then this is invalid 1800852Svi117747 * (see sctp_valid_addr_list(). So, we just fail 1801852Svi117747 * it here rather than wait till it fails in 1802852Svi117747 * sctp_valid_addr_list(). 1803852Svi117747 */ 1804852Svi117747 if (s4->sin_addr.s_addr == INADDR_ANY) { 1805852Svi117747 kmem_free(*addrlist, *size); 1806852Svi117747 *addrlist = NULL; 1807852Svi117747 *size = 0; 1808852Svi117747 if (sctp->sctp_state > SCTPS_LISTEN) { 1809852Svi117747 *addrcnt = 0; 1810852Svi117747 return (EINVAL); 1811852Svi117747 } 1812852Svi117747 if (uspec != NULL) 1813852Svi117747 *uspec = 1; 1814852Svi117747 goto get_all_addrs; 1815852Svi117747 } else { 1816852Svi117747 bcopy(s4, p, sizeof (*s4)); 1817852Svi117747 p += sizeof (*s4); 1818852Svi117747 } 1819852Svi117747 } 1820852Svi117747 } else { 1821852Svi117747 *size = sizeof (struct sockaddr_in6) * *addrcnt; 1822852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1823852Svi117747 p = *addrlist; 1824852Svi117747 for (cnt = 0; cnt < *addrcnt; cnt++) { 1825852Svi117747 s6 = (struct sockaddr_in6 *)addrs + cnt; 1826852Svi117747 /* 1827852Svi117747 * Comments for INADDR_ANY, above, apply here too. 1828852Svi117747 */ 1829852Svi117747 if (IN6_IS_ADDR_UNSPECIFIED(&s6->sin6_addr)) { 1830852Svi117747 kmem_free(*addrlist, *size); 1831852Svi117747 *size = 0; 1832852Svi117747 *addrlist = NULL; 1833852Svi117747 if (sctp->sctp_state > SCTPS_LISTEN) { 1834852Svi117747 *addrcnt = 0; 1835852Svi117747 return (EINVAL); 1836852Svi117747 } 1837852Svi117747 if (uspec != NULL) 1838852Svi117747 *uspec = 1; 1839852Svi117747 goto get_all_addrs; 1840852Svi117747 } else { 1841852Svi117747 bcopy(addrs, p, sizeof (*s6)); 1842852Svi117747 p += sizeof (*s6); 1843852Svi117747 } 1844852Svi117747 } 1845852Svi117747 } 1846852Svi117747 return (err); 1847852Svi117747 get_all_addrs: 1848852Svi117747 1849852Svi117747 /* 1850852Svi117747 * Allocate max possible size. We allocate the max. size here because 1851852Svi117747 * the clustering module could end up adding addresses to the list. 1852852Svi117747 * We allocate upfront so that the clustering module need to bother 1853852Svi117747 * re-sizing the list. 1854852Svi117747 */ 185511042SErik.Nordmark@Sun.COM if (connp->conn_family == AF_INET) { 18563448Sdh155122 *size = sizeof (struct sockaddr_in) * 18573448Sdh155122 sctps->sctps_g_ipifs_count; 18583448Sdh155122 } else { 18593448Sdh155122 *size = sizeof (struct sockaddr_in6) * 18603448Sdh155122 sctps->sctps_g_ipifs_count; 18613448Sdh155122 } 1862852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1863852Svi117747 *addrcnt = 0; 1864852Svi117747 p = *addrlist; 18653448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 1866852Svi117747 1867852Svi117747 /* 1868852Svi117747 * Walk through the global interface list and add all addresses, 1869852Svi117747 * except those that are hosted on loopback interfaces. 1870852Svi117747 */ 1871852Svi117747 for (cnt = 0; cnt < SCTP_IPIF_HASH; cnt++) { 18723448Sdh155122 if (sctps->sctps_g_ipifs[cnt].ipif_count == 0) 1873852Svi117747 continue; 18743448Sdh155122 sctp_ipif = list_head( 18753448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list); 18763448Sdh155122 for (icnt = 0; 18773448Sdh155122 icnt < sctps->sctps_g_ipifs[cnt].ipif_count; 18783448Sdh155122 icnt++) { 1879852Svi117747 in6_addr_t addr; 1880852Svi117747 1881852Svi117747 rw_enter(&sctp_ipif->sctp_ipif_lock, RW_READER); 1882852Svi117747 addr = sctp_ipif->sctp_ipif_saddr; 1883852Svi117747 if (SCTP_IPIF_DISCARD(sctp_ipif->sctp_ipif_flags) || 1884852Svi117747 !SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state) || 1885852Svi117747 SCTP_IS_IPIF_LOOPBACK(sctp_ipif) || 1886852Svi117747 SCTP_IS_IPIF_LINKLOCAL(sctp_ipif) || 18872263Ssommerfe !SCTP_IPIF_ZONE_MATCH(sctp, sctp_ipif) || 188811042SErik.Nordmark@Sun.COM (connp->conn_family == AF_INET && 1889852Svi117747 sctp_ipif->sctp_ipif_isv6) || 1890852Svi117747 (sctp->sctp_connp->conn_ipv6_v6only && 1891852Svi117747 !sctp_ipif->sctp_ipif_isv6)) { 1892852Svi117747 rw_exit(&sctp_ipif->sctp_ipif_lock); 1893852Svi117747 sctp_ipif = list_next( 18943448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list, 1895852Svi117747 sctp_ipif); 1896852Svi117747 continue; 1897852Svi117747 } 1898852Svi117747 rw_exit(&sctp_ipif->sctp_ipif_lock); 189911042SErik.Nordmark@Sun.COM if (connp->conn_family == AF_INET) { 1900852Svi117747 s4 = (struct sockaddr_in *)p; 1901852Svi117747 IN6_V4MAPPED_TO_INADDR(&addr, &s4->sin_addr); 1902852Svi117747 s4->sin_family = AF_INET; 1903852Svi117747 p += sizeof (*s4); 1904852Svi117747 } else { 1905852Svi117747 s6 = (struct sockaddr_in6 *)p; 1906852Svi117747 s6->sin6_addr = addr; 1907852Svi117747 s6->sin6_family = AF_INET6; 1908852Svi117747 s6->sin6_scope_id = 1909852Svi117747 sctp_ipif->sctp_ipif_ill->sctp_ill_index; 1910852Svi117747 p += sizeof (*s6); 1911852Svi117747 } 1912852Svi117747 (*addrcnt)++; 19133448Sdh155122 sctp_ipif = list_next( 19143448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list, 1915852Svi117747 sctp_ipif); 1916852Svi117747 } 1917852Svi117747 } 19183448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 1919852Svi117747 return (err); 1920852Svi117747 } 1921852Svi117747 1922852Svi117747 /* 1923852Svi117747 * Get a list of addresses from the source address list. The caller is 1924852Svi117747 * responsible for allocating sufficient buffer for this. 1925852Svi117747 */ 1926852Svi117747 void 1927852Svi117747 sctp_get_saddr_list(sctp_t *sctp, uchar_t *p, size_t psize) 1928852Svi117747 { 1929852Svi117747 int cnt; 1930852Svi117747 int icnt; 1931852Svi117747 sctp_saddr_ipif_t *obj; 1932852Svi117747 int naddr; 1933852Svi117747 int scanned = 0; 1934852Svi117747 1935852Svi117747 for (cnt = 0; cnt < SCTP_IPIF_HASH; cnt++) { 1936*11373SGeorge.Shepherd@Sun.COM rw_enter(&sctp->sctp_saddrs[cnt].ipif_hash_lock, RW_READER); 1937*11373SGeorge.Shepherd@Sun.COM if (sctp->sctp_saddrs[cnt].ipif_count == 0) { 1938*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[cnt].ipif_hash_lock); 1939852Svi117747 continue; 1940*11373SGeorge.Shepherd@Sun.COM } 1941852Svi117747 obj = list_head(&sctp->sctp_saddrs[cnt].sctp_ipif_list); 1942852Svi117747 naddr = sctp->sctp_saddrs[cnt].ipif_count; 1943852Svi117747 for (icnt = 0; icnt < naddr; icnt++) { 1944852Svi117747 sctp_ipif_t *ipif; 1945852Svi117747 1946*11373SGeorge.Shepherd@Sun.COM if (psize < sizeof (ipif->sctp_ipif_saddr)) { 1947*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[cnt].ipif_hash_lock); 1948852Svi117747 return; 1949*11373SGeorge.Shepherd@Sun.COM } 1950852Svi117747 1951852Svi117747 scanned++; 1952852Svi117747 ipif = obj->saddr_ipifp; 1953852Svi117747 bcopy(&ipif->sctp_ipif_saddr, p, 1954852Svi117747 sizeof (ipif->sctp_ipif_saddr)); 1955852Svi117747 p += sizeof (ipif->sctp_ipif_saddr); 1956852Svi117747 psize -= sizeof (ipif->sctp_ipif_saddr); 1957*11373SGeorge.Shepherd@Sun.COM if (scanned >= sctp->sctp_nsaddrs) { 1958*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[cnt].ipif_hash_lock); 1959852Svi117747 return; 1960*11373SGeorge.Shepherd@Sun.COM } 19613448Sdh155122 obj = list_next( 19623448Sdh155122 &sctp->sctp_saddrs[icnt].sctp_ipif_list, 1963852Svi117747 obj); 1964852Svi117747 } 1965*11373SGeorge.Shepherd@Sun.COM rw_exit(&sctp->sctp_saddrs[cnt].ipif_hash_lock); 1966852Svi117747 } 1967852Svi117747 } 1968852Svi117747 1969852Svi117747 /* 1970852Svi117747 * Get a list of addresses from the remote address list. The caller is 1971852Svi117747 * responsible for allocating sufficient buffer for this. 1972852Svi117747 */ 1973852Svi117747 void 1974852Svi117747 sctp_get_faddr_list(sctp_t *sctp, uchar_t *p, size_t psize) 1975852Svi117747 { 1976852Svi117747 sctp_faddr_t *fp; 1977852Svi117747 1978852Svi117747 for (fp = sctp->sctp_faddrs; fp != NULL; fp = fp->next) { 1979852Svi117747 if (psize < sizeof (fp->faddr)) 1980852Svi117747 return; 1981852Svi117747 bcopy(&fp->faddr, p, sizeof (fp->faddr)); 1982852Svi117747 p += sizeof (fp->faddr); 1983852Svi117747 psize -= sizeof (fp->faddr); 1984852Svi117747 } 1985852Svi117747 } 19860Sstevel@tonic-gate 19873448Sdh155122 static void 19883448Sdh155122 sctp_free_ills(sctp_stack_t *sctps) 19893448Sdh155122 { 19903448Sdh155122 int i; 19913448Sdh155122 int l; 19923448Sdh155122 sctp_ill_t *sctp_ill; 19933448Sdh155122 19943448Sdh155122 if (sctps->sctps_ills_count == 0) 19953448Sdh155122 return; 19963448Sdh155122 19973448Sdh155122 for (i = 0; i < SCTP_ILL_HASH; i++) { 19983448Sdh155122 sctp_ill = list_tail(&sctps->sctps_g_ills[i].sctp_ill_list); 19993448Sdh155122 for (l = 0; l < sctps->sctps_g_ills[i].ill_count; l++) { 20003448Sdh155122 ASSERT(sctp_ill->sctp_ill_ipifcnt == 0); 20013448Sdh155122 list_remove(&sctps->sctps_g_ills[i].sctp_ill_list, 20023448Sdh155122 sctp_ill); 20033448Sdh155122 sctps->sctps_ills_count--; 20043448Sdh155122 kmem_free(sctp_ill->sctp_ill_name, 20053448Sdh155122 sctp_ill->sctp_ill_name_length); 20063448Sdh155122 kmem_free(sctp_ill, sizeof (sctp_ill_t)); 20073448Sdh155122 sctp_ill = 20083448Sdh155122 list_tail(&sctps->sctps_g_ills[i].sctp_ill_list); 20093448Sdh155122 } 20103448Sdh155122 sctps->sctps_g_ills[i].ill_count = 0; 20113448Sdh155122 } 20123448Sdh155122 ASSERT(sctps->sctps_ills_count == 0); 20133448Sdh155122 } 20143448Sdh155122 20153448Sdh155122 static void 20163448Sdh155122 sctp_free_ipifs(sctp_stack_t *sctps) 20173448Sdh155122 { 20183448Sdh155122 int i; 20193448Sdh155122 int l; 20203448Sdh155122 sctp_ipif_t *sctp_ipif; 20213448Sdh155122 sctp_ill_t *sctp_ill; 20223448Sdh155122 20233448Sdh155122 if (sctps->sctps_g_ipifs_count == 0) 20243448Sdh155122 return; 20253448Sdh155122 20263448Sdh155122 for (i = 0; i < SCTP_IPIF_HASH; i++) { 20273448Sdh155122 sctp_ipif = list_tail(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 20283448Sdh155122 for (l = 0; l < sctps->sctps_g_ipifs[i].ipif_count; l++) { 20293448Sdh155122 sctp_ill = sctp_ipif->sctp_ipif_ill; 20303448Sdh155122 20313448Sdh155122 list_remove(&sctps->sctps_g_ipifs[i].sctp_ipif_list, 20323448Sdh155122 sctp_ipif); 20333448Sdh155122 sctps->sctps_g_ipifs_count--; 20343448Sdh155122 (void) atomic_add_32_nv(&sctp_ill->sctp_ill_ipifcnt, 20353448Sdh155122 -1); 20363448Sdh155122 kmem_free(sctp_ipif, sizeof (sctp_ipif_t)); 20373448Sdh155122 sctp_ipif = 20383448Sdh155122 list_tail(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 20393448Sdh155122 } 20403448Sdh155122 sctps->sctps_g_ipifs[i].ipif_count = 0; 20413448Sdh155122 } 20423448Sdh155122 ASSERT(sctps->sctps_g_ipifs_count == 0); 20433448Sdh155122 } 20443448Sdh155122 20453448Sdh155122 20460Sstevel@tonic-gate /* Initialize the SCTP ILL list and lock */ 20470Sstevel@tonic-gate void 20483448Sdh155122 sctp_saddr_init(sctp_stack_t *sctps) 20490Sstevel@tonic-gate { 20500Sstevel@tonic-gate int i; 20510Sstevel@tonic-gate 20523448Sdh155122 sctps->sctps_g_ills = kmem_zalloc(sizeof (sctp_ill_hash_t) * 20533448Sdh155122 SCTP_ILL_HASH, KM_SLEEP); 20543448Sdh155122 sctps->sctps_g_ipifs = kmem_zalloc(sizeof (sctp_ipif_hash_t) * 20553448Sdh155122 SCTP_IPIF_HASH, KM_SLEEP); 20563448Sdh155122 20573448Sdh155122 rw_init(&sctps->sctps_g_ills_lock, NULL, RW_DEFAULT, NULL); 20583448Sdh155122 rw_init(&sctps->sctps_g_ipifs_lock, NULL, RW_DEFAULT, NULL); 20590Sstevel@tonic-gate 20600Sstevel@tonic-gate for (i = 0; i < SCTP_ILL_HASH; i++) { 20613448Sdh155122 sctps->sctps_g_ills[i].ill_count = 0; 20623448Sdh155122 list_create(&sctps->sctps_g_ills[i].sctp_ill_list, 20633448Sdh155122 sizeof (sctp_ill_t), 20640Sstevel@tonic-gate offsetof(sctp_ill_t, sctp_ills)); 20650Sstevel@tonic-gate } 20660Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 20673448Sdh155122 sctps->sctps_g_ipifs[i].ipif_count = 0; 20683448Sdh155122 list_create(&sctps->sctps_g_ipifs[i].sctp_ipif_list, 20690Sstevel@tonic-gate sizeof (sctp_ipif_t), offsetof(sctp_ipif_t, sctp_ipifs)); 20700Sstevel@tonic-gate } 20710Sstevel@tonic-gate } 20720Sstevel@tonic-gate 20730Sstevel@tonic-gate void 20743448Sdh155122 sctp_saddr_fini(sctp_stack_t *sctps) 20750Sstevel@tonic-gate { 20760Sstevel@tonic-gate int i; 20770Sstevel@tonic-gate 20783448Sdh155122 sctp_free_ipifs(sctps); 20793448Sdh155122 sctp_free_ills(sctps); 20803448Sdh155122 20810Sstevel@tonic-gate for (i = 0; i < SCTP_ILL_HASH; i++) 20823448Sdh155122 list_destroy(&sctps->sctps_g_ills[i].sctp_ill_list); 20830Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) 20843448Sdh155122 list_destroy(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 20853448Sdh155122 20863448Sdh155122 ASSERT(sctps->sctps_ills_count == 0 && sctps->sctps_g_ipifs_count == 0); 20873448Sdh155122 kmem_free(sctps->sctps_g_ills, sizeof (sctp_ill_hash_t) * 20883448Sdh155122 SCTP_ILL_HASH); 20893448Sdh155122 sctps->sctps_g_ills = NULL; 20903448Sdh155122 kmem_free(sctps->sctps_g_ipifs, sizeof (sctp_ipif_hash_t) * 20913448Sdh155122 SCTP_IPIF_HASH); 20923448Sdh155122 sctps->sctps_g_ipifs = NULL; 20933448Sdh155122 rw_destroy(&sctps->sctps_g_ills_lock); 20943448Sdh155122 rw_destroy(&sctps->sctps_g_ipifs_lock); 20950Sstevel@tonic-gate } 2096