10Sstevel@tonic-gate /* 20Sstevel@tonic-gate * CDDL HEADER START 30Sstevel@tonic-gate * 40Sstevel@tonic-gate * The contents of this file are subject to the terms of the 51676Sjpk * Common Development and Distribution License (the "License"). 61676Sjpk * You may not use this file except in compliance with the License. 70Sstevel@tonic-gate * 80Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 90Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing. 100Sstevel@tonic-gate * See the License for the specific language governing permissions 110Sstevel@tonic-gate * and limitations under the License. 120Sstevel@tonic-gate * 130Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each 140Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 150Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the 160Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying 170Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner] 180Sstevel@tonic-gate * 190Sstevel@tonic-gate * CDDL HEADER END 200Sstevel@tonic-gate */ 210Sstevel@tonic-gate /* 223448Sdh155122 * Copyright 2007 Sun Microsystems, Inc. All rights reserved. 230Sstevel@tonic-gate * Use is subject to license terms. 240Sstevel@tonic-gate */ 250Sstevel@tonic-gate 260Sstevel@tonic-gate #pragma ident "%Z%%M% %I% %E% SMI" 270Sstevel@tonic-gate 280Sstevel@tonic-gate #include <sys/types.h> 290Sstevel@tonic-gate #include <sys/systm.h> 300Sstevel@tonic-gate #include <sys/stream.h> 31*4311Svi117747 #include <sys/cmn_err.h> 320Sstevel@tonic-gate #include <sys/ddi.h> 330Sstevel@tonic-gate #include <sys/sunddi.h> 340Sstevel@tonic-gate #include <sys/kmem.h> 350Sstevel@tonic-gate #include <sys/socket.h> 360Sstevel@tonic-gate #include <sys/sysmacros.h> 370Sstevel@tonic-gate #include <sys/list.h> 380Sstevel@tonic-gate 390Sstevel@tonic-gate #include <netinet/in.h> 400Sstevel@tonic-gate #include <netinet/ip6.h> 410Sstevel@tonic-gate #include <netinet/sctp.h> 420Sstevel@tonic-gate 430Sstevel@tonic-gate #include <inet/common.h> 440Sstevel@tonic-gate #include <inet/ip.h> 450Sstevel@tonic-gate #include <inet/ip6.h> 460Sstevel@tonic-gate #include <inet/ip_if.h> 470Sstevel@tonic-gate #include <inet/ipclassifier.h> 480Sstevel@tonic-gate #include <inet/sctp_ip.h> 490Sstevel@tonic-gate #include "sctp_impl.h" 500Sstevel@tonic-gate #include "sctp_addr.h" 510Sstevel@tonic-gate 520Sstevel@tonic-gate static void sctp_ipif_inactive(sctp_ipif_t *); 530Sstevel@tonic-gate static sctp_ipif_t *sctp_lookup_ipif_addr(in6_addr_t *, boolean_t, 543510Svi117747 zoneid_t, boolean_t, uint_t, uint_t, boolean_t, 553510Svi117747 sctp_stack_t *); 560Sstevel@tonic-gate static int sctp_get_all_ipifs(sctp_t *, int); 57432Svi117747 static int sctp_ipif_hash_insert(sctp_t *, sctp_ipif_t *, int, 583510Svi117747 boolean_t, boolean_t); 590Sstevel@tonic-gate static void sctp_ipif_hash_remove(sctp_t *, sctp_ipif_t *); 600Sstevel@tonic-gate static int sctp_compare_ipif_list(sctp_ipif_hash_t *, 610Sstevel@tonic-gate sctp_ipif_hash_t *); 620Sstevel@tonic-gate static int sctp_copy_ipifs(sctp_ipif_hash_t *, sctp_t *, int); 63432Svi117747 643510Svi117747 #define SCTP_ADDR4_HASH(addr) \ 653510Svi117747 (((addr) ^ ((addr) >> 8) ^ ((addr) >> 16) ^ ((addr) >> 24)) & \ 663510Svi117747 (SCTP_IPIF_HASH - 1)) 673510Svi117747 683510Svi117747 #define SCTP_ADDR6_HASH(addr) \ 693510Svi117747 (((addr).s6_addr32[3] ^ \ 703510Svi117747 (((addr).s6_addr32[3] ^ (addr).s6_addr32[2]) >> 12)) & \ 713510Svi117747 (SCTP_IPIF_HASH - 1)) 723510Svi117747 733510Svi117747 #define SCTP_IPIF_ADDR_HASH(addr, isv6) \ 743510Svi117747 ((isv6) ? SCTP_ADDR6_HASH((addr)) : \ 753510Svi117747 SCTP_ADDR4_HASH((addr)._S6_un._S6_u32[3])) 763510Svi117747 770Sstevel@tonic-gate #define SCTP_IPIF_USABLE(sctp_ipif_state) \ 780Sstevel@tonic-gate ((sctp_ipif_state) == SCTP_IPIFS_UP || \ 79432Svi117747 (sctp_ipif_state) == SCTP_IPIFS_DOWN) 80432Svi117747 81432Svi117747 #define SCTP_IPIF_DISCARD(sctp_ipif_flags) \ 82432Svi117747 ((sctp_ipif_flags) & (IPIF_PRIVATE | IPIF_DEPRECATED)) 83432Svi117747 84852Svi117747 #define SCTP_IS_IPIF_LOOPBACK(ipif) \ 85852Svi117747 ((ipif)->sctp_ipif_ill->sctp_ill_flags & PHYI_LOOPBACK) 86852Svi117747 87852Svi117747 #define SCTP_IS_IPIF_LINKLOCAL(ipif) \ 88852Svi117747 ((ipif)->sctp_ipif_isv6 && \ 89852Svi117747 IN6_IS_ADDR_LINKLOCAL(&(ipif)->sctp_ipif_saddr)) 90432Svi117747 91432Svi117747 #define SCTP_UNSUPP_AF(ipif, supp_af) \ 92432Svi117747 ((!(ipif)->sctp_ipif_isv6 && !((supp_af) & PARM_SUPP_V4)) || \ 93432Svi117747 ((ipif)->sctp_ipif_isv6 && !((supp_af) & PARM_SUPP_V6))) 940Sstevel@tonic-gate 952263Ssommerfe #define SCTP_IPIF_ZONE_MATCH(sctp, ipif) \ 962263Ssommerfe IPCL_ZONE_MATCH((sctp)->sctp_connp, (ipif)->sctp_ipif_zoneid) 972263Ssommerfe 980Sstevel@tonic-gate #define SCTP_ILL_HASH_FN(index) ((index) % SCTP_ILL_HASH) 990Sstevel@tonic-gate #define SCTP_ILL_TO_PHYINDEX(ill) ((ill)->ill_phyint->phyint_ifindex) 1000Sstevel@tonic-gate 1010Sstevel@tonic-gate /* 1020Sstevel@tonic-gate * SCTP Interface list manipulation functions, locking used. 1030Sstevel@tonic-gate */ 1040Sstevel@tonic-gate 1050Sstevel@tonic-gate /* 1060Sstevel@tonic-gate * Delete an SCTP IPIF from the list if the refcount goes to 0 and it is 1070Sstevel@tonic-gate * marked as condemned. Also, check if the ILL needs to go away. 1080Sstevel@tonic-gate */ 1090Sstevel@tonic-gate static void 1100Sstevel@tonic-gate sctp_ipif_inactive(sctp_ipif_t *sctp_ipif) 1110Sstevel@tonic-gate { 1120Sstevel@tonic-gate sctp_ill_t *sctp_ill; 1133510Svi117747 uint_t hindex; 1140Sstevel@tonic-gate uint_t ill_index; 1153448Sdh155122 sctp_stack_t *sctps = sctp_ipif->sctp_ipif_ill-> 1163448Sdh155122 sctp_ill_netstack->netstack_sctp; 1170Sstevel@tonic-gate 1183448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 1193448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_WRITER); 1200Sstevel@tonic-gate 1213510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(sctp_ipif->sctp_ipif_saddr, 1223510Svi117747 sctp_ipif->sctp_ipif_isv6); 1233510Svi117747 1240Sstevel@tonic-gate sctp_ill = sctp_ipif->sctp_ipif_ill; 1250Sstevel@tonic-gate ASSERT(sctp_ill != NULL); 1260Sstevel@tonic-gate ill_index = SCTP_ILL_HASH_FN(sctp_ill->sctp_ill_index); 1270Sstevel@tonic-gate if (sctp_ipif->sctp_ipif_state != SCTP_IPIFS_CONDEMNED || 1280Sstevel@tonic-gate sctp_ipif->sctp_ipif_refcnt != 0) { 1293448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 1303448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 1310Sstevel@tonic-gate return; 1320Sstevel@tonic-gate } 1333510Svi117747 list_remove(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 1343448Sdh155122 sctp_ipif); 1353510Svi117747 sctps->sctps_g_ipifs[hindex].ipif_count--; 1363448Sdh155122 sctps->sctps_g_ipifs_count--; 1370Sstevel@tonic-gate rw_destroy(&sctp_ipif->sctp_ipif_lock); 1380Sstevel@tonic-gate kmem_free(sctp_ipif, sizeof (sctp_ipif_t)); 1390Sstevel@tonic-gate 1400Sstevel@tonic-gate (void) atomic_add_32_nv(&sctp_ill->sctp_ill_ipifcnt, -1); 1413448Sdh155122 if (rw_tryupgrade(&sctps->sctps_g_ills_lock) != 0) { 1423448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 1430Sstevel@tonic-gate if (sctp_ill->sctp_ill_ipifcnt == 0 && 1440Sstevel@tonic-gate sctp_ill->sctp_ill_state == SCTP_ILLS_CONDEMNED) { 1453448Sdh155122 list_remove(&sctps->sctps_g_ills[ill_index]. 1463448Sdh155122 sctp_ill_list, (void *)sctp_ill); 1473448Sdh155122 sctps->sctps_g_ills[ill_index].ill_count--; 1483448Sdh155122 sctps->sctps_ills_count--; 1490Sstevel@tonic-gate kmem_free(sctp_ill->sctp_ill_name, 1500Sstevel@tonic-gate sctp_ill->sctp_ill_name_length); 1510Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 1520Sstevel@tonic-gate } 1530Sstevel@tonic-gate } 1543448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 1553448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 1560Sstevel@tonic-gate } 1570Sstevel@tonic-gate 1580Sstevel@tonic-gate /* 1590Sstevel@tonic-gate * Lookup an SCTP IPIF given an IP address. Increments sctp_ipif refcnt. 1603510Svi117747 * We are either looking for a IPIF with the given address before 1613510Svi117747 * inserting it into the global list or looking for an IPIF for an 1623510Svi117747 * address given an SCTP. In the former case we always check the zoneid, 1633510Svi117747 * but for the latter case, check_zid could be B_FALSE if the connp 1643510Svi117747 * for the sctp has conn_all_zones set. When looking for an address we 1653510Svi117747 * give preference to one that is up, so even though we may find one that 1663510Svi117747 * is not up we keep looking if there is one up, we hold the down addr 1673510Svi117747 * in backup_ipif in case we don't find one that is up - i.e. we return 1683510Svi117747 * the backup_ipif in that case. Note that if we are looking for. If we 1693510Svi117747 * are specifically looking for an up address, then usable will be set 1703510Svi117747 * to true. 1710Sstevel@tonic-gate */ 1720Sstevel@tonic-gate static sctp_ipif_t * 1733510Svi117747 sctp_lookup_ipif_addr(in6_addr_t *addr, boolean_t refhold, zoneid_t zoneid, 1743510Svi117747 boolean_t check_zid, uint_t ifindex, uint_t seqid, boolean_t usable, 1753510Svi117747 sctp_stack_t *sctps) 1760Sstevel@tonic-gate { 1770Sstevel@tonic-gate int j; 1780Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 1793510Svi117747 sctp_ipif_t *backup_ipif = NULL; 1803510Svi117747 int hindex; 1810Sstevel@tonic-gate 1823510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(*addr, !IN6_IS_ADDR_V4MAPPED(addr)); 1833510Svi117747 1843448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 1853510Svi117747 if (sctps->sctps_g_ipifs[hindex].ipif_count == 0) { 1863510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 1873510Svi117747 return (NULL); 1883510Svi117747 } 1893510Svi117747 sctp_ipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 1903510Svi117747 for (j = 0; j < sctps->sctps_g_ipifs[hindex].ipif_count; j++) { 1913510Svi117747 rw_enter(&sctp_ipif->sctp_ipif_lock, RW_READER); 1923510Svi117747 if ((!check_zid || 1933510Svi117747 (sctp_ipif->sctp_ipif_zoneid == ALL_ZONES || 1943510Svi117747 zoneid == sctp_ipif->sctp_ipif_zoneid)) && 1953510Svi117747 (ifindex == 0 || ifindex == 1963510Svi117747 sctp_ipif->sctp_ipif_ill->sctp_ill_index) && 1973510Svi117747 ((seqid != 0 && seqid == sctp_ipif->sctp_ipif_id) || 1983510Svi117747 (IN6_ARE_ADDR_EQUAL(&sctp_ipif->sctp_ipif_saddr, 1993510Svi117747 addr)))) { 2003510Svi117747 if (!usable || sctp_ipif->sctp_ipif_state == 2013510Svi117747 SCTP_IPIFS_UP) { 2020Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 2030Sstevel@tonic-gate if (refhold) 2040Sstevel@tonic-gate SCTP_IPIF_REFHOLD(sctp_ipif); 2053448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2060Sstevel@tonic-gate return (sctp_ipif); 2073510Svi117747 } else if (sctp_ipif->sctp_ipif_state == 2083510Svi117747 SCTP_IPIFS_DOWN && backup_ipif == NULL) { 2093510Svi117747 backup_ipif = sctp_ipif; 2100Sstevel@tonic-gate } 2110Sstevel@tonic-gate } 2123510Svi117747 rw_exit(&sctp_ipif->sctp_ipif_lock); 2133510Svi117747 sctp_ipif = list_next( 2143510Svi117747 &sctps->sctps_g_ipifs[hindex].sctp_ipif_list, sctp_ipif); 2153510Svi117747 } 2163510Svi117747 if (backup_ipif != NULL) { 2173510Svi117747 if (refhold) 2183510Svi117747 SCTP_IPIF_REFHOLD(backup_ipif); 2193510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 2203510Svi117747 return (backup_ipif); 2210Sstevel@tonic-gate } 2223448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2230Sstevel@tonic-gate return (NULL); 2240Sstevel@tonic-gate } 2250Sstevel@tonic-gate 2260Sstevel@tonic-gate /* 2270Sstevel@tonic-gate * Populate the list with all the SCTP ipifs for a given ipversion. 2280Sstevel@tonic-gate * Increments sctp_ipif refcnt. 2290Sstevel@tonic-gate * Called with no locks held. 2300Sstevel@tonic-gate */ 2310Sstevel@tonic-gate static int 2320Sstevel@tonic-gate sctp_get_all_ipifs(sctp_t *sctp, int sleep) 2330Sstevel@tonic-gate { 2340Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 2350Sstevel@tonic-gate int i; 2360Sstevel@tonic-gate int j; 2370Sstevel@tonic-gate int error = 0; 2383448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps; 2390Sstevel@tonic-gate 2403448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 2410Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 2423448Sdh155122 if (sctps->sctps_g_ipifs[i].ipif_count == 0) 2430Sstevel@tonic-gate continue; 2443448Sdh155122 sctp_ipif = list_head(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 2453448Sdh155122 for (j = 0; j < sctps->sctps_g_ipifs[i].ipif_count; j++) { 2460Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_READER); 247432Svi117747 if (SCTP_IPIF_DISCARD(sctp_ipif->sctp_ipif_flags) || 2480Sstevel@tonic-gate !SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state) || 2492263Ssommerfe !SCTP_IPIF_ZONE_MATCH(sctp, sctp_ipif) || 2500Sstevel@tonic-gate (sctp->sctp_ipversion == IPV4_VERSION && 251432Svi117747 sctp_ipif->sctp_ipif_isv6) || 2520Sstevel@tonic-gate (sctp->sctp_connp->conn_ipv6_v6only && 253432Svi117747 !sctp_ipif->sctp_ipif_isv6)) { 2540Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 2550Sstevel@tonic-gate sctp_ipif = list_next( 2563448Sdh155122 &sctps->sctps_g_ipifs[i].sctp_ipif_list, 2573448Sdh155122 sctp_ipif); 2580Sstevel@tonic-gate continue; 2590Sstevel@tonic-gate } 2600Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 2610Sstevel@tonic-gate SCTP_IPIF_REFHOLD(sctp_ipif); 262432Svi117747 error = sctp_ipif_hash_insert(sctp, sctp_ipif, sleep, 2633510Svi117747 B_FALSE, B_FALSE); 2643510Svi117747 if (error != 0 && error != EALREADY) 2650Sstevel@tonic-gate goto free_stuff; 2663448Sdh155122 sctp_ipif = list_next( 2673448Sdh155122 &sctps->sctps_g_ipifs[i].sctp_ipif_list, 2680Sstevel@tonic-gate sctp_ipif); 2690Sstevel@tonic-gate } 2700Sstevel@tonic-gate } 2713448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2720Sstevel@tonic-gate return (0); 2730Sstevel@tonic-gate free_stuff: 2743448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 2750Sstevel@tonic-gate sctp_free_saddrs(sctp); 2760Sstevel@tonic-gate return (ENOMEM); 2770Sstevel@tonic-gate } 2780Sstevel@tonic-gate 2790Sstevel@tonic-gate /* 2800Sstevel@tonic-gate * Given a list of address, fills in the list of SCTP ipifs if all the addresses 2810Sstevel@tonic-gate * are present in the SCTP interface list, return number of addresses filled 282852Svi117747 * or error. If the caller wants the list of addresses, it sends a pre-allocated 283852Svi117747 * buffer - list. Currently, this list is only used on a clustered node when 284852Svi117747 * the SCTP is in the listen state (from sctp_bind_add()). When called on a 285852Svi117747 * clustered node, the input is always a list of addresses (even if the 286852Svi117747 * original bind() was to INADDR_ANY). 2870Sstevel@tonic-gate * Called with no locks held. 2880Sstevel@tonic-gate */ 2890Sstevel@tonic-gate int 290852Svi117747 sctp_valid_addr_list(sctp_t *sctp, const void *addrs, uint32_t addrcnt, 291852Svi117747 uchar_t *list, size_t lsize) 2920Sstevel@tonic-gate { 2930Sstevel@tonic-gate struct sockaddr_in *sin4; 2940Sstevel@tonic-gate struct sockaddr_in6 *sin6; 2950Sstevel@tonic-gate struct in_addr *addr4; 2960Sstevel@tonic-gate in6_addr_t addr; 2970Sstevel@tonic-gate int cnt; 2980Sstevel@tonic-gate int err = 0; 2990Sstevel@tonic-gate int saddr_cnt = 0; 3000Sstevel@tonic-gate sctp_ipif_t *ipif; 3010Sstevel@tonic-gate boolean_t bind_to_all = B_FALSE; 3020Sstevel@tonic-gate boolean_t check_addrs = B_FALSE; 3030Sstevel@tonic-gate boolean_t check_lport = B_FALSE; 304852Svi117747 uchar_t *p = list; 3050Sstevel@tonic-gate 3060Sstevel@tonic-gate /* 3070Sstevel@tonic-gate * Need to check for port and address depending on the state. 3080Sstevel@tonic-gate * After a socket is bound, we need to make sure that subsequent 3090Sstevel@tonic-gate * bindx() has correct port. After an association is established, 3100Sstevel@tonic-gate * we need to check for changing the bound address to invalid 3110Sstevel@tonic-gate * addresses. 3120Sstevel@tonic-gate */ 3130Sstevel@tonic-gate if (sctp->sctp_state >= SCTPS_BOUND) { 3140Sstevel@tonic-gate check_lport = B_TRUE; 3150Sstevel@tonic-gate if (sctp->sctp_state > SCTPS_LISTEN) 3160Sstevel@tonic-gate check_addrs = B_TRUE; 3170Sstevel@tonic-gate } 318852Svi117747 3190Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 3200Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 3210Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 3220Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 3230Sstevel@tonic-gate for (cnt = 0; cnt < addrcnt; cnt++) { 3240Sstevel@tonic-gate boolean_t lookup_saddr = B_TRUE; 325852Svi117747 uint_t ifindex = 0; 3260Sstevel@tonic-gate 3270Sstevel@tonic-gate switch (sctp->sctp_family) { 3280Sstevel@tonic-gate case AF_INET: 3290Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + cnt; 3300Sstevel@tonic-gate if (sin4->sin_family != AF_INET || (check_lport && 3310Sstevel@tonic-gate sin4->sin_port != sctp->sctp_lport)) { 3320Sstevel@tonic-gate err = EINVAL; 3330Sstevel@tonic-gate goto free_ret; 3340Sstevel@tonic-gate } 3350Sstevel@tonic-gate addr4 = &sin4->sin_addr; 3360Sstevel@tonic-gate if (check_addrs && 3370Sstevel@tonic-gate (addr4->s_addr == INADDR_ANY || 3380Sstevel@tonic-gate addr4->s_addr == INADDR_BROADCAST || 3390Sstevel@tonic-gate IN_MULTICAST(addr4->s_addr))) { 3400Sstevel@tonic-gate err = EINVAL; 3410Sstevel@tonic-gate goto free_ret; 3420Sstevel@tonic-gate } 3430Sstevel@tonic-gate IN6_INADDR_TO_V4MAPPED(addr4, &addr); 3440Sstevel@tonic-gate if (!check_addrs && addr4->s_addr == INADDR_ANY) { 3450Sstevel@tonic-gate lookup_saddr = B_FALSE; 3460Sstevel@tonic-gate bind_to_all = B_TRUE; 3470Sstevel@tonic-gate } 3480Sstevel@tonic-gate 3490Sstevel@tonic-gate break; 3500Sstevel@tonic-gate case AF_INET6: 3510Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + cnt; 3520Sstevel@tonic-gate if (sin6->sin6_family != AF_INET6 || (check_lport && 3530Sstevel@tonic-gate sin6->sin6_port != sctp->sctp_lport)) { 3540Sstevel@tonic-gate err = EINVAL; 3550Sstevel@tonic-gate goto free_ret; 3560Sstevel@tonic-gate } 3570Sstevel@tonic-gate addr = sin6->sin6_addr; 358852Svi117747 /* Contains the interface index */ 359852Svi117747 ifindex = sin6->sin6_scope_id; 3600Sstevel@tonic-gate if (sctp->sctp_connp->conn_ipv6_v6only && 3610Sstevel@tonic-gate IN6_IS_ADDR_V4MAPPED(&addr)) { 3620Sstevel@tonic-gate err = EAFNOSUPPORT; 3630Sstevel@tonic-gate goto free_ret; 3640Sstevel@tonic-gate } 3650Sstevel@tonic-gate if (check_addrs && 3660Sstevel@tonic-gate (IN6_IS_ADDR_LINKLOCAL(&addr) || 3670Sstevel@tonic-gate IN6_IS_ADDR_MULTICAST(&addr) || 3680Sstevel@tonic-gate IN6_IS_ADDR_UNSPECIFIED(&addr))) { 3690Sstevel@tonic-gate err = EINVAL; 3700Sstevel@tonic-gate goto free_ret; 3710Sstevel@tonic-gate } 3720Sstevel@tonic-gate if (!check_addrs && IN6_IS_ADDR_UNSPECIFIED(&addr)) { 3730Sstevel@tonic-gate lookup_saddr = B_FALSE; 3740Sstevel@tonic-gate bind_to_all = B_TRUE; 3750Sstevel@tonic-gate } 3760Sstevel@tonic-gate 3770Sstevel@tonic-gate break; 3780Sstevel@tonic-gate default: 3790Sstevel@tonic-gate err = EAFNOSUPPORT; 3800Sstevel@tonic-gate goto free_ret; 3810Sstevel@tonic-gate } 3820Sstevel@tonic-gate if (lookup_saddr) { 3833510Svi117747 ipif = sctp_lookup_ipif_addr(&addr, B_TRUE, 3843510Svi117747 sctp->sctp_zoneid, !sctp->sctp_connp->conn_allzones, 3853510Svi117747 ifindex, 0, B_TRUE, sctp->sctp_sctps); 3860Sstevel@tonic-gate if (ipif == NULL) { 3870Sstevel@tonic-gate /* Address not in the list */ 3880Sstevel@tonic-gate err = EINVAL; 3890Sstevel@tonic-gate goto free_ret; 390852Svi117747 } else if (check_addrs && SCTP_IS_IPIF_LOOPBACK(ipif) && 391852Svi117747 cl_sctp_check_addrs == NULL) { 3920Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif); 3930Sstevel@tonic-gate err = EINVAL; 3940Sstevel@tonic-gate goto free_ret; 3950Sstevel@tonic-gate } 3960Sstevel@tonic-gate } 3970Sstevel@tonic-gate if (!bind_to_all) { 398432Svi117747 /* 399432Svi117747 * If an address is added after association setup, 400432Svi117747 * we need to wait for the peer to send us an ASCONF 401432Svi117747 * ACK before we can start using it. 402432Svi117747 * saddr_ipif_dontsrc will be reset (to 0) when we 403432Svi117747 * get the ASCONF ACK for this address. 404432Svi117747 */ 405432Svi117747 err = sctp_ipif_hash_insert(sctp, ipif, KM_SLEEP, 4063510Svi117747 check_addrs ? B_TRUE : B_FALSE, B_FALSE); 4070Sstevel@tonic-gate if (err != 0) { 4080Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif); 4090Sstevel@tonic-gate if (check_addrs && err == EALREADY) 4100Sstevel@tonic-gate err = EADDRINUSE; 4110Sstevel@tonic-gate goto free_ret; 4120Sstevel@tonic-gate } 4130Sstevel@tonic-gate saddr_cnt++; 414852Svi117747 if (lsize >= sizeof (addr)) { 415852Svi117747 bcopy(&addr, p, sizeof (addr)); 416852Svi117747 p += sizeof (addr); 417852Svi117747 lsize -= sizeof (addr); 418852Svi117747 } 4190Sstevel@tonic-gate } 4200Sstevel@tonic-gate } 4210Sstevel@tonic-gate if (bind_to_all) { 4220Sstevel@tonic-gate /* 4230Sstevel@tonic-gate * Free whatever we might have added before encountering 4240Sstevel@tonic-gate * inaddr_any. 4250Sstevel@tonic-gate */ 4260Sstevel@tonic-gate if (sctp->sctp_nsaddrs > 0) { 4270Sstevel@tonic-gate sctp_free_saddrs(sctp); 4280Sstevel@tonic-gate ASSERT(sctp->sctp_nsaddrs == 0); 4290Sstevel@tonic-gate } 4300Sstevel@tonic-gate err = sctp_get_all_ipifs(sctp, KM_SLEEP); 4310Sstevel@tonic-gate if (err != 0) 4320Sstevel@tonic-gate return (err); 4330Sstevel@tonic-gate sctp->sctp_bound_to_all = 1; 4340Sstevel@tonic-gate } 4350Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 4360Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 4370Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 4380Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 4390Sstevel@tonic-gate return (0); 4400Sstevel@tonic-gate free_ret: 4410Sstevel@tonic-gate if (saddr_cnt != 0) 4420Sstevel@tonic-gate sctp_del_saddr_list(sctp, addrs, saddr_cnt, B_TRUE); 4430Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 4440Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 4450Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 4460Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 4470Sstevel@tonic-gate return (err); 4480Sstevel@tonic-gate } 4490Sstevel@tonic-gate 4500Sstevel@tonic-gate static int 451432Svi117747 sctp_ipif_hash_insert(sctp_t *sctp, sctp_ipif_t *ipif, int sleep, 4523510Svi117747 boolean_t dontsrc, boolean_t allow_dup) 4530Sstevel@tonic-gate { 4540Sstevel@tonic-gate int cnt; 4550Sstevel@tonic-gate sctp_saddr_ipif_t *ipif_obj; 4563510Svi117747 int hindex; 4570Sstevel@tonic-gate 4583510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->sctp_ipif_saddr, 4593510Svi117747 ipif->sctp_ipif_isv6); 4603510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 4613510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 4623510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif_obj->saddr_ipifp->sctp_ipif_saddr, 4633510Svi117747 &ipif->sctp_ipif_saddr)) { 4643510Svi117747 if (ipif->sctp_ipif_id != 4653510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_id && 4663510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_state == 4673510Svi117747 SCTP_IPIFS_DOWN && ipif->sctp_ipif_state == 4683510Svi117747 SCTP_IPIFS_UP) { 4693510Svi117747 SCTP_IPIF_REFRELE(ipif_obj->saddr_ipifp); 4703510Svi117747 ipif_obj->saddr_ipifp = ipif; 4713510Svi117747 ipif_obj->saddr_ipif_dontsrc = dontsrc ? 1 : 0; 4723510Svi117747 return (0); 4733510Svi117747 } else if (!allow_dup || ipif->sctp_ipif_id == 4743510Svi117747 ipif_obj->saddr_ipifp->sctp_ipif_id) { 4753510Svi117747 return (EALREADY); 4763510Svi117747 } 4773510Svi117747 } 4783510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 4790Sstevel@tonic-gate ipif_obj); 4800Sstevel@tonic-gate } 4810Sstevel@tonic-gate ipif_obj = kmem_zalloc(sizeof (sctp_saddr_ipif_t), sleep); 4820Sstevel@tonic-gate if (ipif_obj == NULL) { 4830Sstevel@tonic-gate /* Need to do something */ 4840Sstevel@tonic-gate return (ENOMEM); 4850Sstevel@tonic-gate } 4860Sstevel@tonic-gate ipif_obj->saddr_ipifp = ipif; 487432Svi117747 ipif_obj->saddr_ipif_dontsrc = dontsrc ? 1 : 0; 4883510Svi117747 list_insert_tail(&sctp->sctp_saddrs[hindex].sctp_ipif_list, ipif_obj); 4893510Svi117747 sctp->sctp_saddrs[hindex].ipif_count++; 4900Sstevel@tonic-gate sctp->sctp_nsaddrs++; 4910Sstevel@tonic-gate return (0); 4920Sstevel@tonic-gate } 4930Sstevel@tonic-gate 4940Sstevel@tonic-gate static void 4950Sstevel@tonic-gate sctp_ipif_hash_remove(sctp_t *sctp, sctp_ipif_t *ipif) 4960Sstevel@tonic-gate { 4970Sstevel@tonic-gate int cnt; 4980Sstevel@tonic-gate sctp_saddr_ipif_t *ipif_obj; 4993510Svi117747 int hindex; 5000Sstevel@tonic-gate 5013510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->sctp_ipif_saddr, 5023510Svi117747 ipif->sctp_ipif_isv6); 5033510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 5043510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 5053510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif_obj->saddr_ipifp->sctp_ipif_saddr, 5063510Svi117747 &ipif->sctp_ipif_saddr)) { 5073510Svi117747 list_remove(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 5080Sstevel@tonic-gate ipif_obj); 5093510Svi117747 sctp->sctp_saddrs[hindex].ipif_count--; 5100Sstevel@tonic-gate sctp->sctp_nsaddrs--; 5110Sstevel@tonic-gate SCTP_IPIF_REFRELE(ipif_obj->saddr_ipifp); 5120Sstevel@tonic-gate kmem_free(ipif_obj, sizeof (sctp_saddr_ipif_t)); 5130Sstevel@tonic-gate break; 5140Sstevel@tonic-gate } 5153510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 5160Sstevel@tonic-gate ipif_obj); 5170Sstevel@tonic-gate } 5180Sstevel@tonic-gate } 5190Sstevel@tonic-gate 5200Sstevel@tonic-gate static int 5210Sstevel@tonic-gate sctp_compare_ipif_list(sctp_ipif_hash_t *list1, sctp_ipif_hash_t *list2) 5220Sstevel@tonic-gate { 5230Sstevel@tonic-gate int i; 5240Sstevel@tonic-gate int j; 5250Sstevel@tonic-gate sctp_saddr_ipif_t *obj1; 5260Sstevel@tonic-gate sctp_saddr_ipif_t *obj2; 5270Sstevel@tonic-gate int overlap = 0; 5280Sstevel@tonic-gate 5290Sstevel@tonic-gate obj1 = list_head(&list1->sctp_ipif_list); 5300Sstevel@tonic-gate for (i = 0; i < list1->ipif_count; i++) { 5310Sstevel@tonic-gate obj2 = list_head(&list2->sctp_ipif_list); 5320Sstevel@tonic-gate for (j = 0; j < list2->ipif_count; j++) { 5333510Svi117747 if (IN6_ARE_ADDR_EQUAL( 5343510Svi117747 &obj1->saddr_ipifp->sctp_ipif_saddr, 5353510Svi117747 &obj2->saddr_ipifp->sctp_ipif_saddr)) { 5360Sstevel@tonic-gate overlap++; 5370Sstevel@tonic-gate break; 5380Sstevel@tonic-gate } 5390Sstevel@tonic-gate obj2 = list_next(&list2->sctp_ipif_list, 5400Sstevel@tonic-gate obj2); 5410Sstevel@tonic-gate } 5420Sstevel@tonic-gate obj1 = list_next(&list1->sctp_ipif_list, obj1); 5430Sstevel@tonic-gate } 5440Sstevel@tonic-gate return (overlap); 5450Sstevel@tonic-gate } 5460Sstevel@tonic-gate 5470Sstevel@tonic-gate int 5480Sstevel@tonic-gate sctp_compare_saddrs(sctp_t *sctp1, sctp_t *sctp2) 5490Sstevel@tonic-gate { 5500Sstevel@tonic-gate int i; 5510Sstevel@tonic-gate int overlap = 0; 5520Sstevel@tonic-gate 5530Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 5540Sstevel@tonic-gate overlap += sctp_compare_ipif_list(&sctp1->sctp_saddrs[i], 5550Sstevel@tonic-gate &sctp2->sctp_saddrs[i]); 5560Sstevel@tonic-gate } 5570Sstevel@tonic-gate 5580Sstevel@tonic-gate if (sctp1->sctp_nsaddrs == sctp2->sctp_nsaddrs && 5590Sstevel@tonic-gate overlap == sctp1->sctp_nsaddrs) { 5600Sstevel@tonic-gate return (SCTP_ADDR_EQUAL); 5610Sstevel@tonic-gate } 5620Sstevel@tonic-gate 5630Sstevel@tonic-gate if (overlap == sctp1->sctp_nsaddrs) 5640Sstevel@tonic-gate return (SCTP_ADDR_SUBSET); 5650Sstevel@tonic-gate 5660Sstevel@tonic-gate if (overlap > 0) 5670Sstevel@tonic-gate return (SCTP_ADDR_OVERLAP); 5680Sstevel@tonic-gate 5690Sstevel@tonic-gate return (SCTP_ADDR_DISJOINT); 5700Sstevel@tonic-gate } 5710Sstevel@tonic-gate 5720Sstevel@tonic-gate static int 5730Sstevel@tonic-gate sctp_copy_ipifs(sctp_ipif_hash_t *list1, sctp_t *sctp2, int sleep) 5740Sstevel@tonic-gate { 5750Sstevel@tonic-gate int i; 5760Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 5770Sstevel@tonic-gate int error = 0; 5780Sstevel@tonic-gate 5790Sstevel@tonic-gate obj = list_head(&list1->sctp_ipif_list); 5800Sstevel@tonic-gate for (i = 0; i < list1->ipif_count; i++) { 5810Sstevel@tonic-gate SCTP_IPIF_REFHOLD(obj->saddr_ipifp); 582432Svi117747 error = sctp_ipif_hash_insert(sctp2, obj->saddr_ipifp, sleep, 5833510Svi117747 B_FALSE, B_FALSE); 5843510Svi117747 ASSERT(error != EALREADY); 5850Sstevel@tonic-gate if (error != 0) 5860Sstevel@tonic-gate return (error); 5870Sstevel@tonic-gate obj = list_next(&list1->sctp_ipif_list, obj); 5880Sstevel@tonic-gate } 5890Sstevel@tonic-gate return (error); 5900Sstevel@tonic-gate } 5910Sstevel@tonic-gate 5920Sstevel@tonic-gate int 5930Sstevel@tonic-gate sctp_dup_saddrs(sctp_t *sctp1, sctp_t *sctp2, int sleep) 5940Sstevel@tonic-gate { 5950Sstevel@tonic-gate int error = 0; 5960Sstevel@tonic-gate int i; 5970Sstevel@tonic-gate 598432Svi117747 if (sctp1 == NULL || sctp1->sctp_bound_to_all == 1) 5990Sstevel@tonic-gate return (sctp_get_all_ipifs(sctp2, sleep)); 6000Sstevel@tonic-gate 6010Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 6020Sstevel@tonic-gate if (sctp1->sctp_saddrs[i].ipif_count == 0) 6030Sstevel@tonic-gate continue; 6040Sstevel@tonic-gate error = sctp_copy_ipifs(&sctp1->sctp_saddrs[i], sctp2, sleep); 6050Sstevel@tonic-gate if (error != 0) { 6060Sstevel@tonic-gate sctp_free_saddrs(sctp2); 6070Sstevel@tonic-gate return (error); 6080Sstevel@tonic-gate } 6090Sstevel@tonic-gate } 6100Sstevel@tonic-gate return (0); 6110Sstevel@tonic-gate } 6120Sstevel@tonic-gate 6130Sstevel@tonic-gate void 6140Sstevel@tonic-gate sctp_free_saddrs(sctp_t *sctp) 6150Sstevel@tonic-gate { 6160Sstevel@tonic-gate int i; 6170Sstevel@tonic-gate int l; 6180Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 6190Sstevel@tonic-gate 6200Sstevel@tonic-gate if (sctp->sctp_nsaddrs == 0) 6210Sstevel@tonic-gate return; 6220Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 6230Sstevel@tonic-gate if (sctp->sctp_saddrs[i].ipif_count == 0) 6240Sstevel@tonic-gate continue; 6250Sstevel@tonic-gate obj = list_tail(&sctp->sctp_saddrs[i].sctp_ipif_list); 6260Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 6270Sstevel@tonic-gate list_remove(&sctp->sctp_saddrs[i].sctp_ipif_list, obj); 6280Sstevel@tonic-gate SCTP_IPIF_REFRELE(obj->saddr_ipifp); 6290Sstevel@tonic-gate sctp->sctp_nsaddrs--; 6300Sstevel@tonic-gate kmem_free(obj, sizeof (sctp_saddr_ipif_t)); 6310Sstevel@tonic-gate obj = list_tail(&sctp->sctp_saddrs[i].sctp_ipif_list); 6320Sstevel@tonic-gate } 6330Sstevel@tonic-gate sctp->sctp_saddrs[i].ipif_count = 0; 6340Sstevel@tonic-gate } 635432Svi117747 if (sctp->sctp_bound_to_all == 1) 636432Svi117747 sctp->sctp_bound_to_all = 0; 6370Sstevel@tonic-gate ASSERT(sctp->sctp_nsaddrs == 0); 6380Sstevel@tonic-gate } 6390Sstevel@tonic-gate 6400Sstevel@tonic-gate /* 6410Sstevel@tonic-gate * Add/Delete the given ILL from the SCTP ILL list. Called with no locks 6420Sstevel@tonic-gate * held. 6430Sstevel@tonic-gate */ 6440Sstevel@tonic-gate void 6450Sstevel@tonic-gate sctp_update_ill(ill_t *ill, int op) 6460Sstevel@tonic-gate { 6470Sstevel@tonic-gate int i; 6480Sstevel@tonic-gate sctp_ill_t *sctp_ill = NULL; 6490Sstevel@tonic-gate uint_t index; 6503448Sdh155122 netstack_t *ns = ill->ill_ipst->ips_netstack; 6513448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 6520Sstevel@tonic-gate 6533448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_WRITER); 6540Sstevel@tonic-gate 6550Sstevel@tonic-gate index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 6563448Sdh155122 sctp_ill = list_head(&sctps->sctps_g_ills[index].sctp_ill_list); 6573448Sdh155122 for (i = 0; i < sctps->sctps_g_ills[index].ill_count; i++) { 658*4311Svi117747 if ((sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill)) && 659*4311Svi117747 (sctp_ill->sctp_ill_isv6 == ill->ill_isv6)) { 6600Sstevel@tonic-gate break; 661*4311Svi117747 } 6623448Sdh155122 sctp_ill = list_next(&sctps->sctps_g_ills[index].sctp_ill_list, 6630Sstevel@tonic-gate sctp_ill); 6640Sstevel@tonic-gate } 6650Sstevel@tonic-gate 6660Sstevel@tonic-gate switch (op) { 6670Sstevel@tonic-gate case SCTP_ILL_INSERT: 6680Sstevel@tonic-gate if (sctp_ill != NULL) { 6690Sstevel@tonic-gate /* Unmark it if it is condemned */ 6700Sstevel@tonic-gate if (sctp_ill->sctp_ill_state == SCTP_ILLS_CONDEMNED) 6710Sstevel@tonic-gate sctp_ill->sctp_ill_state = 0; 6723448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 6730Sstevel@tonic-gate return; 6740Sstevel@tonic-gate } 6750Sstevel@tonic-gate sctp_ill = kmem_zalloc(sizeof (sctp_ill_t), KM_NOSLEEP); 6760Sstevel@tonic-gate /* Need to re-try? */ 6770Sstevel@tonic-gate if (sctp_ill == NULL) { 678*4311Svi117747 cmn_err(CE_WARN, "sctp_update_ill: error adding " 679*4311Svi117747 "ILL %p to SCTP's ILL list", (void *)ill); 6803448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 6810Sstevel@tonic-gate return; 6820Sstevel@tonic-gate } 6833510Svi117747 sctp_ill->sctp_ill_name = kmem_zalloc(ill->ill_name_length, 6843510Svi117747 KM_NOSLEEP); 6850Sstevel@tonic-gate if (sctp_ill->sctp_ill_name == NULL) { 686*4311Svi117747 cmn_err(CE_WARN, "sctp_update_ill: error adding " 687*4311Svi117747 "ILL %p to SCTP's ILL list", (void *)ill); 6880Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 6893448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 6900Sstevel@tonic-gate return; 6910Sstevel@tonic-gate } 6920Sstevel@tonic-gate bcopy(ill->ill_name, sctp_ill->sctp_ill_name, 6930Sstevel@tonic-gate ill->ill_name_length); 6940Sstevel@tonic-gate sctp_ill->sctp_ill_name_length = ill->ill_name_length; 6950Sstevel@tonic-gate sctp_ill->sctp_ill_index = SCTP_ILL_TO_PHYINDEX(ill); 6960Sstevel@tonic-gate sctp_ill->sctp_ill_flags = ill->ill_phyint->phyint_flags; 6973448Sdh155122 sctp_ill->sctp_ill_netstack = ns; /* No netstack_hold */ 698*4311Svi117747 sctp_ill->sctp_ill_isv6 = ill->ill_isv6; 6993448Sdh155122 list_insert_tail(&sctps->sctps_g_ills[index].sctp_ill_list, 7000Sstevel@tonic-gate (void *)sctp_ill); 7013448Sdh155122 sctps->sctps_g_ills[index].ill_count++; 7023448Sdh155122 sctps->sctps_ills_count++; 7030Sstevel@tonic-gate 7040Sstevel@tonic-gate break; 7050Sstevel@tonic-gate 7060Sstevel@tonic-gate case SCTP_ILL_REMOVE: 7070Sstevel@tonic-gate 7080Sstevel@tonic-gate if (sctp_ill == NULL) { 7093448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7100Sstevel@tonic-gate return; 7110Sstevel@tonic-gate } 7120Sstevel@tonic-gate if (sctp_ill->sctp_ill_ipifcnt == 0) { 7133448Sdh155122 list_remove(&sctps->sctps_g_ills[index].sctp_ill_list, 7140Sstevel@tonic-gate (void *)sctp_ill); 7153448Sdh155122 sctps->sctps_g_ills[index].ill_count--; 7163448Sdh155122 sctps->sctps_ills_count--; 7170Sstevel@tonic-gate kmem_free(sctp_ill->sctp_ill_name, 7180Sstevel@tonic-gate ill->ill_name_length); 7190Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 7200Sstevel@tonic-gate } else { 7210Sstevel@tonic-gate sctp_ill->sctp_ill_state = SCTP_ILLS_CONDEMNED; 7220Sstevel@tonic-gate } 7230Sstevel@tonic-gate 7240Sstevel@tonic-gate break; 7250Sstevel@tonic-gate } 7263448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 7270Sstevel@tonic-gate } 7280Sstevel@tonic-gate 729*4311Svi117747 /* 730*4311Svi117747 * The ILL's index is being changed, just remove it from the old list, 731*4311Svi117747 * change the SCTP ILL's index and re-insert using the new index. 732*4311Svi117747 */ 733*4311Svi117747 void 734*4311Svi117747 sctp_ill_reindex(ill_t *ill, uint_t orig_ill_index) 735*4311Svi117747 { 736*4311Svi117747 sctp_ill_t *sctp_ill = NULL; 737*4311Svi117747 sctp_ill_t *nxt_sill; 738*4311Svi117747 uint_t indx; 739*4311Svi117747 uint_t nindx; 740*4311Svi117747 boolean_t once = B_FALSE; 741*4311Svi117747 netstack_t *ns = ill->ill_ipst->ips_netstack; 742*4311Svi117747 sctp_stack_t *sctps = ns->netstack_sctp; 743*4311Svi117747 744*4311Svi117747 rw_enter(&sctps->sctps_g_ills_lock, RW_WRITER); 745*4311Svi117747 746*4311Svi117747 indx = SCTP_ILL_HASH_FN(orig_ill_index); 747*4311Svi117747 nindx = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 748*4311Svi117747 sctp_ill = list_head(&sctps->sctps_g_ills[indx].sctp_ill_list); 749*4311Svi117747 while (sctp_ill != NULL) { 750*4311Svi117747 nxt_sill = list_next(&sctps->sctps_g_ills[indx].sctp_ill_list, 751*4311Svi117747 sctp_ill); 752*4311Svi117747 if (sctp_ill->sctp_ill_index == orig_ill_index) { 753*4311Svi117747 sctp_ill->sctp_ill_index = SCTP_ILL_TO_PHYINDEX(ill); 754*4311Svi117747 /* 755*4311Svi117747 * if the new index hashes to the same value, all's 756*4311Svi117747 * done. 757*4311Svi117747 */ 758*4311Svi117747 if (nindx != indx) { 759*4311Svi117747 list_remove( 760*4311Svi117747 &sctps->sctps_g_ills[indx].sctp_ill_list, 761*4311Svi117747 (void *)sctp_ill); 762*4311Svi117747 sctps->sctps_g_ills[indx].ill_count--; 763*4311Svi117747 list_insert_tail( 764*4311Svi117747 &sctps->sctps_g_ills[nindx].sctp_ill_list, 765*4311Svi117747 (void *)sctp_ill); 766*4311Svi117747 sctps->sctps_g_ills[nindx].ill_count++; 767*4311Svi117747 } 768*4311Svi117747 if (once) 769*4311Svi117747 break; 770*4311Svi117747 /* We might have one for v4 and for v6 */ 771*4311Svi117747 once = B_TRUE; 772*4311Svi117747 } 773*4311Svi117747 sctp_ill = nxt_sill; 774*4311Svi117747 } 775*4311Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 776*4311Svi117747 } 777*4311Svi117747 7780Sstevel@tonic-gate /* move ipif from f_ill to t_ill */ 7790Sstevel@tonic-gate void 7800Sstevel@tonic-gate sctp_move_ipif(ipif_t *ipif, ill_t *f_ill, ill_t *t_ill) 7810Sstevel@tonic-gate { 7820Sstevel@tonic-gate sctp_ill_t *fsctp_ill = NULL; 7830Sstevel@tonic-gate sctp_ill_t *tsctp_ill = NULL; 7840Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 7853510Svi117747 uint_t hindex; 7860Sstevel@tonic-gate int i; 7873448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 7883448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 7890Sstevel@tonic-gate 7903448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 7913448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 7920Sstevel@tonic-gate 7933510Svi117747 hindex = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(f_ill)); 7943510Svi117747 fsctp_ill = list_head(&sctps->sctps_g_ills[hindex].sctp_ill_list); 7953510Svi117747 for (i = 0; i < sctps->sctps_g_ills[hindex].ill_count; i++) { 796*4311Svi117747 if (fsctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(f_ill) && 797*4311Svi117747 fsctp_ill->sctp_ill_isv6 == f_ill->ill_isv6) { 7980Sstevel@tonic-gate break; 799*4311Svi117747 } 8003510Svi117747 fsctp_ill = list_next( 8013510Svi117747 &sctps->sctps_g_ills[hindex].sctp_ill_list, fsctp_ill); 8020Sstevel@tonic-gate } 8030Sstevel@tonic-gate 8043510Svi117747 hindex = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(t_ill)); 8053510Svi117747 tsctp_ill = list_head(&sctps->sctps_g_ills[hindex].sctp_ill_list); 8063510Svi117747 for (i = 0; i < sctps->sctps_g_ills[hindex].ill_count; i++) { 807*4311Svi117747 if (tsctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(t_ill) && 808*4311Svi117747 tsctp_ill->sctp_ill_isv6 == t_ill->ill_isv6) { 8090Sstevel@tonic-gate break; 810*4311Svi117747 } 8113510Svi117747 tsctp_ill = list_next( 8123510Svi117747 &sctps->sctps_g_ills[hindex].sctp_ill_list, tsctp_ill); 8130Sstevel@tonic-gate } 8140Sstevel@tonic-gate 8153510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, 8163510Svi117747 ipif->ipif_ill->ill_isv6); 8173510Svi117747 sctp_ipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 8183510Svi117747 for (i = 0; i < sctps->sctps_g_ipifs[hindex].ipif_count; i++) { 8190Sstevel@tonic-gate if (sctp_ipif->sctp_ipif_id == ipif->ipif_seqid) 8200Sstevel@tonic-gate break; 8213448Sdh155122 sctp_ipif = list_next( 8223510Svi117747 &sctps->sctps_g_ipifs[hindex].sctp_ipif_list, sctp_ipif); 8230Sstevel@tonic-gate } 8240Sstevel@tonic-gate /* Should be an ASSERT? */ 8250Sstevel@tonic-gate if (fsctp_ill == NULL || tsctp_ill == NULL || sctp_ipif == NULL) { 8260Sstevel@tonic-gate ip1dbg(("sctp_move_ipif: error moving ipif %p from %p to %p\n", 8270Sstevel@tonic-gate (void *)ipif, (void *)f_ill, (void *)t_ill)); 8283448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 8293448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 8300Sstevel@tonic-gate return; 8310Sstevel@tonic-gate } 8320Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 8330Sstevel@tonic-gate ASSERT(sctp_ipif->sctp_ipif_ill == fsctp_ill); 8340Sstevel@tonic-gate sctp_ipif->sctp_ipif_ill = tsctp_ill; 8350Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 8360Sstevel@tonic-gate (void) atomic_add_32_nv(&fsctp_ill->sctp_ill_ipifcnt, -1); 8370Sstevel@tonic-gate atomic_add_32(&tsctp_ill->sctp_ill_ipifcnt, 1); 8383448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 8393448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 8400Sstevel@tonic-gate } 8410Sstevel@tonic-gate 8423510Svi117747 /* 8433510Svi117747 * Walk the list of SCTPs and find each that has oipif in it's saddr list, and 8443510Svi117747 * if so replace it with nipif. 8453510Svi117747 */ 8463510Svi117747 void 8473510Svi117747 sctp_update_saddrs(sctp_ipif_t *oipif, sctp_ipif_t *nipif, int idx, 8483510Svi117747 sctp_stack_t *sctps) 8493510Svi117747 { 8503510Svi117747 sctp_t *sctp; 8513510Svi117747 sctp_t *sctp_prev = NULL; 8523510Svi117747 sctp_saddr_ipif_t *sobj; 8533510Svi117747 int count; 8543510Svi117747 8553510Svi117747 sctp = sctps->sctps_gsctp; 8563510Svi117747 mutex_enter(&sctps->sctps_g_lock); 8573510Svi117747 while (sctp != NULL && oipif->sctp_ipif_refcnt > 0) { 8583510Svi117747 mutex_enter(&sctp->sctp_reflock); 8593510Svi117747 if (sctp->sctp_condemned || 8603510Svi117747 sctp->sctp_saddrs[idx].ipif_count <= 0) { 8613510Svi117747 mutex_exit(&sctp->sctp_reflock); 8623510Svi117747 sctp = list_next(&sctps->sctps_g_list, sctp); 8633510Svi117747 continue; 8643510Svi117747 } 8653510Svi117747 sctp->sctp_refcnt++; 8663510Svi117747 mutex_exit(&sctp->sctp_reflock); 8673510Svi117747 mutex_exit(&sctps->sctps_g_lock); 8683510Svi117747 if (sctp_prev != NULL) 8693510Svi117747 SCTP_REFRELE(sctp_prev); 8703510Svi117747 8713510Svi117747 RUN_SCTP(sctp); 8723510Svi117747 sobj = list_head(&sctp->sctp_saddrs[idx].sctp_ipif_list); 8733510Svi117747 for (count = 0; count < 8743510Svi117747 sctp->sctp_saddrs[idx].ipif_count; count++) { 8753510Svi117747 if (sobj->saddr_ipifp == oipif) { 8763510Svi117747 SCTP_IPIF_REFHOLD(nipif); 8773510Svi117747 sobj->saddr_ipifp = nipif; 8783510Svi117747 ASSERT(oipif->sctp_ipif_refcnt > 0); 8793510Svi117747 /* We have the writer lock */ 8803510Svi117747 oipif->sctp_ipif_refcnt--; 8813510Svi117747 /* 8823510Svi117747 * Can't have more than one referring 8833510Svi117747 * to the same sctp_ipif. 8843510Svi117747 */ 8853510Svi117747 break; 8863510Svi117747 } 8873510Svi117747 sobj = list_next(&sctp->sctp_saddrs[idx].sctp_ipif_list, 8883510Svi117747 sobj); 8893510Svi117747 } 8903510Svi117747 WAKE_SCTP(sctp); 8913510Svi117747 sctp_prev = sctp; 8923510Svi117747 mutex_enter(&sctps->sctps_g_lock); 8933510Svi117747 sctp = list_next(&sctps->sctps_g_list, sctp); 8943510Svi117747 } 8953510Svi117747 mutex_exit(&sctps->sctps_g_lock); 8963510Svi117747 if (sctp_prev != NULL) 8973510Svi117747 SCTP_REFRELE(sctp_prev); 8983510Svi117747 } 8993510Svi117747 9003510Svi117747 /* 9013510Svi117747 * Given an ipif, walk the hash list in the global ipif table and for 9023510Svi117747 * any other SCTP ipif with the same address and non-zero reference, walk 9033510Svi117747 * the SCTP list and update the saddr list, if required, to point to the 9043510Svi117747 * new SCTP ipif. 9053510Svi117747 */ 9063510Svi117747 void 9073510Svi117747 sctp_chk_and_updt_saddr(int hindex, sctp_ipif_t *ipif, sctp_stack_t *sctps) 9083510Svi117747 { 9093510Svi117747 int cnt; 9103510Svi117747 sctp_ipif_t *sipif; 9113510Svi117747 9123510Svi117747 ASSERT(sctps->sctps_g_ipifs[hindex].ipif_count > 0); 9133510Svi117747 ASSERT(ipif->sctp_ipif_state == SCTP_IPIFS_UP); 9143510Svi117747 9153510Svi117747 sipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 9163510Svi117747 for (cnt = 0; cnt < sctps->sctps_g_ipifs[hindex].ipif_count; cnt++) { 9173510Svi117747 rw_enter(&sipif->sctp_ipif_lock, RW_WRITER); 9183510Svi117747 if (sipif->sctp_ipif_id != ipif->sctp_ipif_id && 9193510Svi117747 IN6_ARE_ADDR_EQUAL(&sipif->sctp_ipif_saddr, 9203510Svi117747 &ipif->sctp_ipif_saddr) && sipif->sctp_ipif_refcnt > 0) { 9213510Svi117747 /* 9223510Svi117747 * There can only be one address up at any time 9233510Svi117747 * and we are here because ipif has been brought 9243510Svi117747 * up. 9253510Svi117747 */ 9263510Svi117747 ASSERT(sipif->sctp_ipif_state != SCTP_IPIFS_UP); 9273510Svi117747 /* 9283510Svi117747 * Someone has a reference to this we need to update to 9293510Svi117747 * point to the new sipif. 9303510Svi117747 */ 9313510Svi117747 sctp_update_saddrs(sipif, ipif, hindex, sctps); 9323510Svi117747 } 9333510Svi117747 rw_exit(&sipif->sctp_ipif_lock); 9343510Svi117747 sipif = list_next(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 9353510Svi117747 sipif); 9363510Svi117747 } 9373510Svi117747 } 9383510Svi117747 9393510Svi117747 /* 9403510Svi117747 * Insert a new SCTP ipif using 'ipif'. v6addr is the address that existed 9413510Svi117747 * prior to the current address in 'ipif'. Only when an existing address 9423510Svi117747 * is changed on an IPIF, will v6addr be specified. If the IPIF already 9433510Svi117747 * exists in the global SCTP ipif table, then we either removed it, if 9443510Svi117747 * it doesn't have any existing reference, or mark it condemned otherwise. 9453510Svi117747 * If an address is being brought up (IPIF_UP), then we need to scan 9463510Svi117747 * the SCTP list to check if there is any SCTP that points to the *same* 9473510Svi117747 * address on a different SCTP ipif and update in that case. 9483510Svi117747 */ 9493510Svi117747 void 9503510Svi117747 sctp_update_ipif_addr(ipif_t *ipif, in6_addr_t v6addr) 9513510Svi117747 { 9523510Svi117747 ill_t *ill = ipif->ipif_ill; 9533510Svi117747 int i; 9543510Svi117747 sctp_ill_t *sctp_ill; 9553510Svi117747 sctp_ill_t *osctp_ill; 9563510Svi117747 sctp_ipif_t *sctp_ipif = NULL; 9573510Svi117747 sctp_ipif_t *osctp_ipif = NULL; 9583510Svi117747 uint_t ill_index; 9593510Svi117747 int hindex; 9603510Svi117747 sctp_stack_t *sctps; 9613510Svi117747 9623510Svi117747 9633510Svi117747 sctps = ipif->ipif_ill->ill_ipst->ips_netstack->netstack_sctp; 9643510Svi117747 9653510Svi117747 /* Index for new address */ 9663510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, ill->ill_isv6); 9673510Svi117747 9683510Svi117747 /* 9693510Svi117747 * The address on this IPIF is changing, we need to look for 9703510Svi117747 * this old address and mark it condemned, before creating 9713510Svi117747 * one for the new address. 9723510Svi117747 */ 9733510Svi117747 osctp_ipif = sctp_lookup_ipif_addr(&v6addr, B_FALSE, 9743510Svi117747 ipif->ipif_zoneid, B_TRUE, SCTP_ILL_TO_PHYINDEX(ill), 9753510Svi117747 ipif->ipif_seqid, B_FALSE, sctps); 9763510Svi117747 9773510Svi117747 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 9783510Svi117747 rw_enter(&sctps->sctps_g_ipifs_lock, RW_WRITER); 9793510Svi117747 9803510Svi117747 ill_index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 9813510Svi117747 sctp_ill = list_head(&sctps->sctps_g_ills[ill_index].sctp_ill_list); 9823510Svi117747 for (i = 0; i < sctps->sctps_g_ills[ill_index].ill_count; i++) { 983*4311Svi117747 if (sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill) && 984*4311Svi117747 sctp_ill->sctp_ill_isv6 == ill->ill_isv6) { 9853510Svi117747 break; 986*4311Svi117747 } 9873510Svi117747 sctp_ill = list_next( 9883510Svi117747 &sctps->sctps_g_ills[ill_index].sctp_ill_list, sctp_ill); 9893510Svi117747 } 9903510Svi117747 9913510Svi117747 if (sctp_ill == NULL) { 992*4311Svi117747 ip1dbg(("sctp_update_ipif_addr: ill not found ..\n")); 9933510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 9943510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 995*4311Svi117747 return; 9963510Svi117747 } 9973510Svi117747 9983510Svi117747 if (osctp_ipif != NULL) { 9993510Svi117747 10003510Svi117747 /* The address is the same? */ 10013510Svi117747 if (IN6_ARE_ADDR_EQUAL(&ipif->ipif_v6lcl_addr, &v6addr)) { 10023510Svi117747 boolean_t chk_n_updt = B_FALSE; 10033510Svi117747 10043510Svi117747 rw_downgrade(&sctps->sctps_g_ipifs_lock); 10053510Svi117747 rw_enter(&osctp_ipif->sctp_ipif_lock, RW_WRITER); 10063510Svi117747 if (ipif->ipif_flags & IPIF_UP && 10073510Svi117747 osctp_ipif->sctp_ipif_state != SCTP_IPIFS_UP) { 10083510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 10093510Svi117747 chk_n_updt = B_TRUE; 10103510Svi117747 } else { 10113510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 10123510Svi117747 } 10133510Svi117747 osctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 10143510Svi117747 rw_exit(&osctp_ipif->sctp_ipif_lock); 10153510Svi117747 if (chk_n_updt) { 10163510Svi117747 sctp_chk_and_updt_saddr(hindex, osctp_ipif, 10173510Svi117747 sctps); 10183510Svi117747 } 10193510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 10203510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 10213510Svi117747 return; 10223510Svi117747 } 10233510Svi117747 /* 10243510Svi117747 * We are effectively removing this address from the ILL. 10253510Svi117747 */ 10263510Svi117747 if (osctp_ipif->sctp_ipif_refcnt != 0) { 10273510Svi117747 osctp_ipif->sctp_ipif_state = SCTP_IPIFS_CONDEMNED; 10283510Svi117747 } else { 10293510Svi117747 list_t *ipif_list; 10303510Svi117747 int ohindex; 10313510Svi117747 10323510Svi117747 osctp_ill = osctp_ipif->sctp_ipif_ill; 10333510Svi117747 /* hash index for the old one */ 10343510Svi117747 ohindex = SCTP_IPIF_ADDR_HASH( 10353510Svi117747 osctp_ipif->sctp_ipif_saddr, 10363510Svi117747 osctp_ipif->sctp_ipif_isv6); 10373510Svi117747 10383510Svi117747 ipif_list = 10393510Svi117747 &sctps->sctps_g_ipifs[ohindex].sctp_ipif_list; 10403510Svi117747 10413510Svi117747 list_remove(ipif_list, (void *)osctp_ipif); 10423510Svi117747 sctps->sctps_g_ipifs[ohindex].ipif_count--; 10433510Svi117747 sctps->sctps_g_ipifs_count--; 10443510Svi117747 rw_destroy(&osctp_ipif->sctp_ipif_lock); 10453510Svi117747 kmem_free(osctp_ipif, sizeof (sctp_ipif_t)); 10463510Svi117747 (void) atomic_add_32_nv(&osctp_ill->sctp_ill_ipifcnt, 10473510Svi117747 -1); 10483510Svi117747 } 10493510Svi117747 } 10503510Svi117747 10513510Svi117747 sctp_ipif = kmem_zalloc(sizeof (sctp_ipif_t), KM_NOSLEEP); 10523510Svi117747 /* Try again? */ 10533510Svi117747 if (sctp_ipif == NULL) { 1054*4311Svi117747 cmn_err(CE_WARN, "sctp_update_ipif_addr: error adding " 1055*4311Svi117747 "IPIF %p to SCTP's IPIF list", (void *)ipif); 10563510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 10573510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 10583510Svi117747 return; 10593510Svi117747 } 10603510Svi117747 sctps->sctps_g_ipifs_count++; 10613510Svi117747 rw_init(&sctp_ipif->sctp_ipif_lock, NULL, RW_DEFAULT, NULL); 10623510Svi117747 sctp_ipif->sctp_ipif_saddr = ipif->ipif_v6lcl_addr; 10633510Svi117747 sctp_ipif->sctp_ipif_ill = sctp_ill; 10643510Svi117747 sctp_ipif->sctp_ipif_isv6 = ill->ill_isv6; 10653510Svi117747 sctp_ipif->sctp_ipif_zoneid = ipif->ipif_zoneid; 10663510Svi117747 sctp_ipif->sctp_ipif_id = ipif->ipif_seqid; 10673510Svi117747 if (ipif->ipif_flags & IPIF_UP) 10683510Svi117747 sctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 10693510Svi117747 else 10703510Svi117747 sctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 10713510Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 10723510Svi117747 /* 10733510Svi117747 * We add it to the head so that it is quicker to find good/recent 10743510Svi117747 * additions. 10753510Svi117747 */ 10763510Svi117747 list_insert_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 10773510Svi117747 (void *)sctp_ipif); 10783510Svi117747 sctps->sctps_g_ipifs[hindex].ipif_count++; 10793510Svi117747 atomic_add_32(&sctp_ill->sctp_ill_ipifcnt, 1); 10803510Svi117747 if (sctp_ipif->sctp_ipif_state == SCTP_IPIFS_UP) 10813510Svi117747 sctp_chk_and_updt_saddr(hindex, sctp_ipif, sctps); 10823510Svi117747 rw_exit(&sctps->sctps_g_ipifs_lock); 10833510Svi117747 rw_exit(&sctps->sctps_g_ills_lock); 10843510Svi117747 } 10853510Svi117747 10860Sstevel@tonic-gate /* Insert, Remove, Mark up or Mark down the ipif */ 10870Sstevel@tonic-gate void 10880Sstevel@tonic-gate sctp_update_ipif(ipif_t *ipif, int op) 10890Sstevel@tonic-gate { 10900Sstevel@tonic-gate ill_t *ill = ipif->ipif_ill; 10910Sstevel@tonic-gate int i; 10920Sstevel@tonic-gate sctp_ill_t *sctp_ill; 10930Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 10940Sstevel@tonic-gate uint_t ill_index; 10953510Svi117747 uint_t hindex; 10963448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 10973448Sdh155122 sctp_stack_t *sctps = ns->netstack_sctp; 10980Sstevel@tonic-gate 10990Sstevel@tonic-gate ip2dbg(("sctp_update_ipif: %s %d\n", ill->ill_name, ipif->ipif_seqid)); 11000Sstevel@tonic-gate 11013448Sdh155122 rw_enter(&sctps->sctps_g_ills_lock, RW_READER); 11023448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_WRITER); 11030Sstevel@tonic-gate 11040Sstevel@tonic-gate ill_index = SCTP_ILL_HASH_FN(SCTP_ILL_TO_PHYINDEX(ill)); 11053448Sdh155122 sctp_ill = list_head(&sctps->sctps_g_ills[ill_index].sctp_ill_list); 11063448Sdh155122 for (i = 0; i < sctps->sctps_g_ills[ill_index].ill_count; i++) { 1107*4311Svi117747 if (sctp_ill->sctp_ill_index == SCTP_ILL_TO_PHYINDEX(ill) && 1108*4311Svi117747 sctp_ill->sctp_ill_isv6 == ill->ill_isv6) { 11090Sstevel@tonic-gate break; 1110*4311Svi117747 } 11113448Sdh155122 sctp_ill = list_next( 11123448Sdh155122 &sctps->sctps_g_ills[ill_index].sctp_ill_list, sctp_ill); 11130Sstevel@tonic-gate } 11140Sstevel@tonic-gate if (sctp_ill == NULL) { 11153448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 11163448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 11170Sstevel@tonic-gate return; 11180Sstevel@tonic-gate } 11190Sstevel@tonic-gate 11203510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(ipif->ipif_v6lcl_addr, 11213510Svi117747 ipif->ipif_ill->ill_isv6); 11223510Svi117747 sctp_ipif = list_head(&sctps->sctps_g_ipifs[hindex].sctp_ipif_list); 11233510Svi117747 for (i = 0; i < sctps->sctps_g_ipifs[hindex].ipif_count; i++) { 11243510Svi117747 if (sctp_ipif->sctp_ipif_id == ipif->ipif_seqid) { 11253510Svi117747 ASSERT(IN6_ARE_ADDR_EQUAL(&sctp_ipif->sctp_ipif_saddr, 11263510Svi117747 &ipif->ipif_v6lcl_addr)); 11270Sstevel@tonic-gate break; 11283510Svi117747 } 11293448Sdh155122 sctp_ipif = list_next( 11303510Svi117747 &sctps->sctps_g_ipifs[hindex].sctp_ipif_list, 11310Sstevel@tonic-gate sctp_ipif); 11320Sstevel@tonic-gate } 11333510Svi117747 if (sctp_ipif == NULL) { 11340Sstevel@tonic-gate ip1dbg(("sctp_update_ipif: null sctp_ipif for %d\n", op)); 11353448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 11363448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 11370Sstevel@tonic-gate return; 11380Sstevel@tonic-gate } 11393510Svi117747 ASSERT(sctp_ill == sctp_ipif->sctp_ipif_ill); 11400Sstevel@tonic-gate switch (op) { 11410Sstevel@tonic-gate case SCTP_IPIF_REMOVE: 11420Sstevel@tonic-gate { 11430Sstevel@tonic-gate list_t *ipif_list; 11440Sstevel@tonic-gate list_t *ill_list; 11450Sstevel@tonic-gate 11463448Sdh155122 ill_list = &sctps->sctps_g_ills[ill_index].sctp_ill_list; 11473510Svi117747 ipif_list = &sctps->sctps_g_ipifs[hindex].sctp_ipif_list; 11480Sstevel@tonic-gate if (sctp_ipif->sctp_ipif_refcnt != 0) { 11490Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_CONDEMNED; 11503448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 11513448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 11520Sstevel@tonic-gate return; 11530Sstevel@tonic-gate } 11540Sstevel@tonic-gate list_remove(ipif_list, (void *)sctp_ipif); 11553510Svi117747 sctps->sctps_g_ipifs[hindex].ipif_count--; 11563448Sdh155122 sctps->sctps_g_ipifs_count--; 11570Sstevel@tonic-gate rw_destroy(&sctp_ipif->sctp_ipif_lock); 11580Sstevel@tonic-gate kmem_free(sctp_ipif, sizeof (sctp_ipif_t)); 11590Sstevel@tonic-gate (void) atomic_add_32_nv(&sctp_ill->sctp_ill_ipifcnt, -1); 11603448Sdh155122 if (rw_tryupgrade(&sctps->sctps_g_ills_lock) != 0) { 11613448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 11620Sstevel@tonic-gate if (sctp_ill->sctp_ill_ipifcnt == 0 && 11630Sstevel@tonic-gate sctp_ill->sctp_ill_state == SCTP_ILLS_CONDEMNED) { 11640Sstevel@tonic-gate list_remove(ill_list, (void *)sctp_ill); 11653448Sdh155122 sctps->sctps_ills_count--; 11663448Sdh155122 sctps->sctps_g_ills[ill_index].ill_count--; 11670Sstevel@tonic-gate kmem_free(sctp_ill->sctp_ill_name, 11680Sstevel@tonic-gate sctp_ill->sctp_ill_name_length); 11690Sstevel@tonic-gate kmem_free(sctp_ill, sizeof (sctp_ill_t)); 11700Sstevel@tonic-gate } 11710Sstevel@tonic-gate } 11720Sstevel@tonic-gate break; 11730Sstevel@tonic-gate } 11740Sstevel@tonic-gate 11750Sstevel@tonic-gate case SCTP_IPIF_UP: 11760Sstevel@tonic-gate 11773448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 11780Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 11790Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_UP; 11803510Svi117747 sctp_ipif->sctp_ipif_mtu = ipif->ipif_mtu; 1181432Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 11820Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 11833510Svi117747 sctp_chk_and_updt_saddr(hindex, sctp_ipif, 11843510Svi117747 ipif->ipif_ill->ill_ipst->ips_netstack->netstack_sctp); 11850Sstevel@tonic-gate 11860Sstevel@tonic-gate break; 11870Sstevel@tonic-gate 11880Sstevel@tonic-gate case SCTP_IPIF_UPDATE: 11890Sstevel@tonic-gate 11903448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 11910Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 11920Sstevel@tonic-gate sctp_ipif->sctp_ipif_mtu = ipif->ipif_mtu; 11930Sstevel@tonic-gate sctp_ipif->sctp_ipif_zoneid = ipif->ipif_zoneid; 1194432Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 11950Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 11960Sstevel@tonic-gate 11970Sstevel@tonic-gate break; 11980Sstevel@tonic-gate 11990Sstevel@tonic-gate case SCTP_IPIF_DOWN: 12000Sstevel@tonic-gate 12013448Sdh155122 rw_downgrade(&sctps->sctps_g_ipifs_lock); 12020Sstevel@tonic-gate rw_enter(&sctp_ipif->sctp_ipif_lock, RW_WRITER); 12030Sstevel@tonic-gate sctp_ipif->sctp_ipif_state = SCTP_IPIFS_DOWN; 12043510Svi117747 sctp_ipif->sctp_ipif_mtu = ipif->ipif_mtu; 12053510Svi117747 sctp_ipif->sctp_ipif_flags = ipif->ipif_flags; 12060Sstevel@tonic-gate rw_exit(&sctp_ipif->sctp_ipif_lock); 12070Sstevel@tonic-gate 12080Sstevel@tonic-gate break; 12090Sstevel@tonic-gate } 12103448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 12113448Sdh155122 rw_exit(&sctps->sctps_g_ills_lock); 12120Sstevel@tonic-gate } 12130Sstevel@tonic-gate 12140Sstevel@tonic-gate /* 12150Sstevel@tonic-gate * SCTP source address list manipulaton, locking not used (except for 12160Sstevel@tonic-gate * sctp locking by the caller. 12170Sstevel@tonic-gate */ 12180Sstevel@tonic-gate 12190Sstevel@tonic-gate /* Remove a specific saddr from the list */ 12200Sstevel@tonic-gate void 12210Sstevel@tonic-gate sctp_del_saddr(sctp_t *sctp, sctp_saddr_ipif_t *sp) 12220Sstevel@tonic-gate { 12230Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12240Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 12250Sstevel@tonic-gate 12260Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12270Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 12280Sstevel@tonic-gate 12290Sstevel@tonic-gate sctp_ipif_hash_remove(sctp, sp->saddr_ipifp); 12300Sstevel@tonic-gate 1231432Svi117747 if (sctp->sctp_bound_to_all == 1) 12320Sstevel@tonic-gate sctp->sctp_bound_to_all = 0; 12330Sstevel@tonic-gate 12340Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12350Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 12360Sstevel@tonic-gate 12370Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12380Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 12390Sstevel@tonic-gate } 12400Sstevel@tonic-gate 12410Sstevel@tonic-gate /* 12420Sstevel@tonic-gate * Delete source address from the existing list. No error checking done here 12430Sstevel@tonic-gate * Called with no locks held. 12440Sstevel@tonic-gate */ 12450Sstevel@tonic-gate void 12460Sstevel@tonic-gate sctp_del_saddr_list(sctp_t *sctp, const void *addrs, int addcnt, 12470Sstevel@tonic-gate boolean_t fanout_locked) 12480Sstevel@tonic-gate { 12490Sstevel@tonic-gate struct sockaddr_in *sin4; 12500Sstevel@tonic-gate struct sockaddr_in6 *sin6; 12510Sstevel@tonic-gate int cnt; 12520Sstevel@tonic-gate in6_addr_t addr; 12530Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 1254852Svi117747 int ifindex = 0; 12550Sstevel@tonic-gate 1256852Svi117747 ASSERT(sctp->sctp_nsaddrs >= addcnt); 12570Sstevel@tonic-gate 12580Sstevel@tonic-gate if (!fanout_locked) { 12590Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12600Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock); 12610Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12620Sstevel@tonic-gate mutex_enter(&sctp->sctp_listen_tfp->tf_lock); 12630Sstevel@tonic-gate } 12640Sstevel@tonic-gate 12650Sstevel@tonic-gate for (cnt = 0; cnt < addcnt; cnt++) { 12660Sstevel@tonic-gate switch (sctp->sctp_family) { 12670Sstevel@tonic-gate case AF_INET: 12680Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + cnt; 12690Sstevel@tonic-gate IN6_INADDR_TO_V4MAPPED(&sin4->sin_addr, &addr); 12700Sstevel@tonic-gate break; 12710Sstevel@tonic-gate 12720Sstevel@tonic-gate case AF_INET6: 12730Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + cnt; 12740Sstevel@tonic-gate addr = sin6->sin6_addr; 1275852Svi117747 ifindex = sin6->sin6_scope_id; 12760Sstevel@tonic-gate break; 12770Sstevel@tonic-gate } 12783510Svi117747 sctp_ipif = sctp_lookup_ipif_addr(&addr, B_FALSE, 12793510Svi117747 sctp->sctp_zoneid, !sctp->sctp_connp->conn_allzones, 12803510Svi117747 ifindex, 0, B_TRUE, sctp->sctp_sctps); 12810Sstevel@tonic-gate ASSERT(sctp_ipif != NULL); 12820Sstevel@tonic-gate sctp_ipif_hash_remove(sctp, sctp_ipif); 12830Sstevel@tonic-gate } 1284432Svi117747 if (sctp->sctp_bound_to_all == 1) 12850Sstevel@tonic-gate sctp->sctp_bound_to_all = 0; 12860Sstevel@tonic-gate 12870Sstevel@tonic-gate if (!fanout_locked) { 12880Sstevel@tonic-gate if (sctp->sctp_conn_tfp != NULL) 12890Sstevel@tonic-gate mutex_exit(&sctp->sctp_conn_tfp->tf_lock); 12900Sstevel@tonic-gate if (sctp->sctp_listen_tfp != NULL) 12910Sstevel@tonic-gate mutex_exit(&sctp->sctp_listen_tfp->tf_lock); 12920Sstevel@tonic-gate } 12930Sstevel@tonic-gate } 12940Sstevel@tonic-gate 12950Sstevel@tonic-gate /* 12960Sstevel@tonic-gate * Given an address get the corresponding entry from the list 12970Sstevel@tonic-gate * Called with no locks held. 12980Sstevel@tonic-gate */ 12990Sstevel@tonic-gate sctp_saddr_ipif_t * 1300852Svi117747 sctp_saddr_lookup(sctp_t *sctp, in6_addr_t *addr, uint_t ifindex) 13010Sstevel@tonic-gate { 13023510Svi117747 int cnt; 13033510Svi117747 sctp_saddr_ipif_t *ipif_obj; 13043510Svi117747 int hindex; 13050Sstevel@tonic-gate sctp_ipif_t *sctp_ipif; 13060Sstevel@tonic-gate 13073510Svi117747 hindex = SCTP_IPIF_ADDR_HASH(*addr, !IN6_IS_ADDR_V4MAPPED(addr)); 13083510Svi117747 if (sctp->sctp_saddrs[hindex].ipif_count == 0) 13090Sstevel@tonic-gate return (NULL); 13100Sstevel@tonic-gate 13113510Svi117747 ipif_obj = list_head(&sctp->sctp_saddrs[hindex].sctp_ipif_list); 13123510Svi117747 for (cnt = 0; cnt < sctp->sctp_saddrs[hindex].ipif_count; cnt++) { 13133510Svi117747 sctp_ipif = ipif_obj->saddr_ipifp; 13143510Svi117747 /* 13153510Svi117747 * Zone check shouldn't be needed. 13163510Svi117747 */ 13173510Svi117747 if (IN6_ARE_ADDR_EQUAL(addr, &sctp_ipif->sctp_ipif_saddr) && 13183510Svi117747 (ifindex == 0 || 13193510Svi117747 ifindex == sctp_ipif->sctp_ipif_ill->sctp_ill_index) && 13203510Svi117747 SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state)) { 13213510Svi117747 return (ipif_obj); 13223510Svi117747 } 13233510Svi117747 ipif_obj = list_next(&sctp->sctp_saddrs[hindex].sctp_ipif_list, 13243510Svi117747 ipif_obj); 13253510Svi117747 } 13263510Svi117747 return (NULL); 13270Sstevel@tonic-gate } 13280Sstevel@tonic-gate 1329432Svi117747 /* Given an address, add it to the source address list */ 1330432Svi117747 int 1331852Svi117747 sctp_saddr_add_addr(sctp_t *sctp, in6_addr_t *addr, uint_t ifindex) 1332432Svi117747 { 1333432Svi117747 sctp_ipif_t *sctp_ipif; 1334432Svi117747 13353510Svi117747 sctp_ipif = sctp_lookup_ipif_addr(addr, B_TRUE, sctp->sctp_zoneid, 13363510Svi117747 !sctp->sctp_connp->conn_allzones, ifindex, 0, B_TRUE, 13373510Svi117747 sctp->sctp_sctps); 1338432Svi117747 if (sctp_ipif == NULL) 1339432Svi117747 return (EINVAL); 1340432Svi117747 13413510Svi117747 if (sctp_ipif_hash_insert(sctp, sctp_ipif, KM_NOSLEEP, B_FALSE, 13423510Svi117747 B_FALSE) != 0) { 1343432Svi117747 SCTP_IPIF_REFRELE(sctp_ipif); 1344432Svi117747 return (EINVAL); 1345432Svi117747 } 1346432Svi117747 return (0); 1347432Svi117747 } 1348432Svi117747 1349432Svi117747 /* 1350432Svi117747 * Remove or mark as dontsrc addresses that are currently not part of the 1351432Svi117747 * association. One would delete addresses when processing an INIT and 1352432Svi117747 * mark as dontsrc when processing an INIT-ACK. 1353432Svi117747 */ 1354432Svi117747 void 1355432Svi117747 sctp_check_saddr(sctp_t *sctp, int supp_af, boolean_t delete) 1356432Svi117747 { 1357432Svi117747 int i; 1358432Svi117747 int l; 1359432Svi117747 sctp_saddr_ipif_t *obj; 1360432Svi117747 int scanned = 0; 1361432Svi117747 int naddr; 1362432Svi117747 int nsaddr; 1363432Svi117747 1364432Svi117747 ASSERT(!sctp->sctp_loopback && !sctp->sctp_linklocal && supp_af != 0); 1365432Svi117747 1366432Svi117747 /* 1367432Svi117747 * Irregardless of the supported address in the INIT, v4 1368432Svi117747 * must be supported. 1369432Svi117747 */ 1370432Svi117747 if (sctp->sctp_family == AF_INET) 1371432Svi117747 supp_af = PARM_SUPP_V4; 1372432Svi117747 1373432Svi117747 nsaddr = sctp->sctp_nsaddrs; 1374432Svi117747 for (i = 0; i < SCTP_IPIF_HASH; i++) { 1375432Svi117747 if (sctp->sctp_saddrs[i].ipif_count == 0) 1376432Svi117747 continue; 1377432Svi117747 obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 1378432Svi117747 naddr = sctp->sctp_saddrs[i].ipif_count; 1379432Svi117747 for (l = 0; l < naddr; l++) { 1380432Svi117747 sctp_ipif_t *ipif; 1381432Svi117747 1382432Svi117747 ipif = obj->saddr_ipifp; 1383432Svi117747 scanned++; 1384432Svi117747 1385432Svi117747 /* 1386432Svi117747 * Delete/mark dontsrc loopback/linklocal addresses and 1387432Svi117747 * unsupported address. 1388852Svi117747 * On a clustered node, we trust the clustering module 1389852Svi117747 * to do the right thing w.r.t loopback addresses, so 1390852Svi117747 * we ignore loopback addresses in this check. 1391432Svi117747 */ 1392852Svi117747 if ((SCTP_IS_IPIF_LOOPBACK(ipif) && 1393852Svi117747 cl_sctp_check_addrs == NULL) || 1394852Svi117747 SCTP_IS_IPIF_LINKLOCAL(ipif) || 1395432Svi117747 SCTP_UNSUPP_AF(ipif, supp_af)) { 1396432Svi117747 if (!delete) { 1397432Svi117747 obj->saddr_ipif_unconfirmed = 1; 1398432Svi117747 goto next_obj; 1399432Svi117747 } 1400432Svi117747 if (sctp->sctp_bound_to_all == 1) 1401432Svi117747 sctp->sctp_bound_to_all = 0; 1402432Svi117747 if (scanned < nsaddr) { 1403432Svi117747 obj = list_next(&sctp->sctp_saddrs[i]. 1404432Svi117747 sctp_ipif_list, obj); 1405432Svi117747 sctp_ipif_hash_remove(sctp, ipif); 1406432Svi117747 continue; 1407432Svi117747 } 1408432Svi117747 sctp_ipif_hash_remove(sctp, ipif); 1409432Svi117747 } 1410432Svi117747 next_obj: 1411432Svi117747 if (scanned >= nsaddr) 1412432Svi117747 return; 1413432Svi117747 obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 1414432Svi117747 obj); 1415432Svi117747 } 1416432Svi117747 } 1417432Svi117747 } 1418432Svi117747 1419432Svi117747 14200Sstevel@tonic-gate /* Get the first valid address from the list. Called with no locks held */ 14210Sstevel@tonic-gate in6_addr_t 14220Sstevel@tonic-gate sctp_get_valid_addr(sctp_t *sctp, boolean_t isv6) 14230Sstevel@tonic-gate { 14240Sstevel@tonic-gate int i; 14250Sstevel@tonic-gate int l; 14260Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 14270Sstevel@tonic-gate int scanned = 0; 14280Sstevel@tonic-gate in6_addr_t addr; 14290Sstevel@tonic-gate 14300Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 14310Sstevel@tonic-gate if (sctp->sctp_saddrs[i].ipif_count == 0) 14320Sstevel@tonic-gate continue; 14330Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 14340Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 14350Sstevel@tonic-gate sctp_ipif_t *ipif; 14360Sstevel@tonic-gate 14370Sstevel@tonic-gate ipif = obj->saddr_ipifp; 1438432Svi117747 if (!SCTP_DONT_SRC(obj) && 14390Sstevel@tonic-gate ipif->sctp_ipif_isv6 == isv6 && 1440432Svi117747 ipif->sctp_ipif_state == SCTP_IPIFS_UP) { 14410Sstevel@tonic-gate return (ipif->sctp_ipif_saddr); 14420Sstevel@tonic-gate } 14430Sstevel@tonic-gate scanned++; 14440Sstevel@tonic-gate if (scanned >= sctp->sctp_nsaddrs) 14450Sstevel@tonic-gate goto got_none; 14460Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 14470Sstevel@tonic-gate obj); 14480Sstevel@tonic-gate } 14490Sstevel@tonic-gate } 14500Sstevel@tonic-gate got_none: 14510Sstevel@tonic-gate /* Need to double check this */ 14520Sstevel@tonic-gate if (isv6 == B_TRUE) 14530Sstevel@tonic-gate addr = ipv6_all_zeros; 14540Sstevel@tonic-gate else 14550Sstevel@tonic-gate IN6_IPADDR_TO_V4MAPPED(0, &addr); 14560Sstevel@tonic-gate 14570Sstevel@tonic-gate return (addr); 14580Sstevel@tonic-gate } 14590Sstevel@tonic-gate 14600Sstevel@tonic-gate /* 14610Sstevel@tonic-gate * Return the list of local addresses of an association. The parameter 14620Sstevel@tonic-gate * myaddrs is supposed to be either (struct sockaddr_in *) or (struct 14630Sstevel@tonic-gate * sockaddr_in6 *) depending on the address family. 14640Sstevel@tonic-gate */ 14650Sstevel@tonic-gate int 14660Sstevel@tonic-gate sctp_getmyaddrs(void *conn, void *myaddrs, int *addrcnt) 14670Sstevel@tonic-gate { 14680Sstevel@tonic-gate int i; 14690Sstevel@tonic-gate int l; 14700Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 14710Sstevel@tonic-gate sctp_t *sctp = (sctp_t *)conn; 14720Sstevel@tonic-gate int family = sctp->sctp_family; 14730Sstevel@tonic-gate int max = *addrcnt; 14740Sstevel@tonic-gate size_t added = 0; 14750Sstevel@tonic-gate struct sockaddr_in6 *sin6; 14760Sstevel@tonic-gate struct sockaddr_in *sin4; 14770Sstevel@tonic-gate int scanned = 0; 14780Sstevel@tonic-gate boolean_t skip_lback = B_FALSE; 14790Sstevel@tonic-gate 14800Sstevel@tonic-gate if (sctp->sctp_nsaddrs == 0) 14810Sstevel@tonic-gate return (EINVAL); 14820Sstevel@tonic-gate 1483852Svi117747 /* 1484852Svi117747 * Skip loopback addresses for non-loopback assoc., ignore 1485852Svi117747 * this on a clustered node. 1486852Svi117747 */ 1487852Svi117747 if (sctp->sctp_state >= SCTPS_ESTABLISHED && !sctp->sctp_loopback && 1488852Svi117747 (cl_sctp_check_addrs == NULL)) { 14890Sstevel@tonic-gate skip_lback = B_TRUE; 1490852Svi117747 } 1491852Svi117747 14920Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 14930Sstevel@tonic-gate if (sctp->sctp_saddrs[i].ipif_count == 0) 14940Sstevel@tonic-gate continue; 14950Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 14960Sstevel@tonic-gate for (l = 0; l < sctp->sctp_saddrs[i].ipif_count; l++) { 14970Sstevel@tonic-gate sctp_ipif_t *ipif = obj->saddr_ipifp; 14980Sstevel@tonic-gate in6_addr_t addr = ipif->sctp_ipif_saddr; 14990Sstevel@tonic-gate 15000Sstevel@tonic-gate scanned++; 15010Sstevel@tonic-gate if ((ipif->sctp_ipif_state == SCTP_IPIFS_CONDEMNED) || 1502432Svi117747 SCTP_DONT_SRC(obj) || 1503852Svi117747 (SCTP_IS_IPIF_LOOPBACK(ipif) && skip_lback)) { 15040Sstevel@tonic-gate if (scanned >= sctp->sctp_nsaddrs) 15050Sstevel@tonic-gate goto done; 15060Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i]. 15070Sstevel@tonic-gate sctp_ipif_list, obj); 15080Sstevel@tonic-gate continue; 15090Sstevel@tonic-gate } 15100Sstevel@tonic-gate switch (family) { 15110Sstevel@tonic-gate case AF_INET: 15120Sstevel@tonic-gate sin4 = (struct sockaddr_in *)myaddrs + added; 15130Sstevel@tonic-gate sin4->sin_family = AF_INET; 15140Sstevel@tonic-gate sin4->sin_port = sctp->sctp_lport; 15150Sstevel@tonic-gate IN6_V4MAPPED_TO_INADDR(&addr, &sin4->sin_addr); 15160Sstevel@tonic-gate break; 15170Sstevel@tonic-gate 15180Sstevel@tonic-gate case AF_INET6: 15190Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)myaddrs + added; 15200Sstevel@tonic-gate sin6->sin6_family = AF_INET6; 15210Sstevel@tonic-gate sin6->sin6_port = sctp->sctp_lport; 15220Sstevel@tonic-gate sin6->sin6_addr = addr; 15230Sstevel@tonic-gate break; 15240Sstevel@tonic-gate } 15250Sstevel@tonic-gate added++; 15260Sstevel@tonic-gate if (added >= max || scanned >= sctp->sctp_nsaddrs) 15270Sstevel@tonic-gate goto done; 15280Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 15290Sstevel@tonic-gate obj); 15300Sstevel@tonic-gate } 15310Sstevel@tonic-gate } 15320Sstevel@tonic-gate done: 15330Sstevel@tonic-gate *addrcnt = added; 15340Sstevel@tonic-gate return (0); 15350Sstevel@tonic-gate } 15360Sstevel@tonic-gate 15370Sstevel@tonic-gate /* 1538252Svi117747 * Given the supported address family, walk through the source address list 1539252Svi117747 * and return the total length of the available addresses. If 'p' is not 1540252Svi117747 * null, construct the parameter list for the addresses in 'p'. 1541432Svi117747 * 'modify' will only be set when we want the source address list to 1542432Svi117747 * be modified. The source address list will be modified only when 1543432Svi117747 * generating an INIT chunk. For generating an INIT-ACK 'modify' will 1544432Svi117747 * be false since the 'sctp' will be that of the listener. 15450Sstevel@tonic-gate */ 15460Sstevel@tonic-gate size_t 1547432Svi117747 sctp_saddr_info(sctp_t *sctp, int supp_af, uchar_t *p, boolean_t modify) 15480Sstevel@tonic-gate { 15490Sstevel@tonic-gate int i; 15500Sstevel@tonic-gate int l; 15510Sstevel@tonic-gate sctp_saddr_ipif_t *obj; 1552252Svi117747 size_t paramlen = 0; 15530Sstevel@tonic-gate sctp_parm_hdr_t *hdr; 15540Sstevel@tonic-gate int scanned = 0; 1555432Svi117747 int naddr; 1556432Svi117747 int nsaddr; 1557852Svi117747 boolean_t del_ll = B_FALSE; 1558852Svi117747 boolean_t del_lb = B_FALSE; 1559852Svi117747 15600Sstevel@tonic-gate 1561852Svi117747 /* 1562852Svi117747 * On a clustered node don't bother changing anything 1563852Svi117747 * on the loopback interface. 1564852Svi117747 */ 1565852Svi117747 if (modify && !sctp->sctp_loopback && (cl_sctp_check_addrs == NULL)) 1566852Svi117747 del_lb = B_TRUE; 1567852Svi117747 1568852Svi117747 if (modify && !sctp->sctp_linklocal) 1569852Svi117747 del_ll = B_TRUE; 1570432Svi117747 1571432Svi117747 nsaddr = sctp->sctp_nsaddrs; 15720Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 15730Sstevel@tonic-gate if (sctp->sctp_saddrs[i].ipif_count == 0) 15740Sstevel@tonic-gate continue; 15750Sstevel@tonic-gate obj = list_head(&sctp->sctp_saddrs[i].sctp_ipif_list); 1576432Svi117747 naddr = sctp->sctp_saddrs[i].ipif_count; 1577432Svi117747 for (l = 0; l < naddr; l++) { 15780Sstevel@tonic-gate in6_addr_t addr; 15790Sstevel@tonic-gate sctp_ipif_t *ipif; 1580852Svi117747 boolean_t ipif_lb; 1581852Svi117747 boolean_t ipif_ll; 1582432Svi117747 boolean_t unsupp_af; 15830Sstevel@tonic-gate 15840Sstevel@tonic-gate ipif = obj->saddr_ipifp; 15850Sstevel@tonic-gate scanned++; 1586432Svi117747 1587852Svi117747 ipif_lb = SCTP_IS_IPIF_LOOPBACK(ipif); 1588852Svi117747 ipif_ll = SCTP_IS_IPIF_LINKLOCAL(ipif); 1589432Svi117747 unsupp_af = SCTP_UNSUPP_AF(ipif, supp_af); 1590432Svi117747 /* 1591432Svi117747 * We need to either delete or skip loopback/linklocal 1592852Svi117747 * or unsupported addresses, if required. 1593432Svi117747 */ 1594852Svi117747 if ((ipif_ll && del_ll) || (ipif_lb && del_lb) || 1595852Svi117747 (unsupp_af && modify)) { 1596432Svi117747 if (sctp->sctp_bound_to_all == 1) 1597432Svi117747 sctp->sctp_bound_to_all = 0; 1598432Svi117747 if (scanned < nsaddr) { 1599432Svi117747 obj = list_next(&sctp->sctp_saddrs[i]. 1600432Svi117747 sctp_ipif_list, obj); 1601432Svi117747 sctp_ipif_hash_remove(sctp, ipif); 1602432Svi117747 continue; 1603432Svi117747 } 1604432Svi117747 sctp_ipif_hash_remove(sctp, ipif); 1605432Svi117747 goto next_addr; 1606852Svi117747 } else if (ipif_ll || unsupp_af || 1607852Svi117747 (ipif_lb && (cl_sctp_check_addrs == NULL))) { 1608252Svi117747 goto next_addr; 16090Sstevel@tonic-gate } 1610432Svi117747 1611432Svi117747 if (!SCTP_IPIF_USABLE(ipif->sctp_ipif_state)) 1612432Svi117747 goto next_addr; 1613252Svi117747 if (p != NULL) 1614252Svi117747 hdr = (sctp_parm_hdr_t *)(p + paramlen); 16150Sstevel@tonic-gate addr = ipif->sctp_ipif_saddr; 1616432Svi117747 if (!ipif->sctp_ipif_isv6) { 16170Sstevel@tonic-gate struct in_addr *v4; 16180Sstevel@tonic-gate 1619252Svi117747 if (p != NULL) { 1620252Svi117747 hdr->sph_type = htons(PARM_ADDR4); 1621252Svi117747 hdr->sph_len = htons(PARM_ADDR4_LEN); 1622252Svi117747 v4 = (struct in_addr *)(hdr + 1); 1623252Svi117747 IN6_V4MAPPED_TO_INADDR(&addr, v4); 1624252Svi117747 } 1625252Svi117747 paramlen += PARM_ADDR4_LEN; 1626432Svi117747 } else { 1627252Svi117747 if (p != NULL) { 1628252Svi117747 hdr->sph_type = htons(PARM_ADDR6); 1629252Svi117747 hdr->sph_len = htons(PARM_ADDR6_LEN); 1630252Svi117747 bcopy(&addr, hdr + 1, sizeof (addr)); 1631252Svi117747 } 1632252Svi117747 paramlen += PARM_ADDR6_LEN; 16330Sstevel@tonic-gate } 1634252Svi117747 next_addr: 1635432Svi117747 if (scanned >= nsaddr) 1636252Svi117747 return (paramlen); 16370Sstevel@tonic-gate obj = list_next(&sctp->sctp_saddrs[i].sctp_ipif_list, 16380Sstevel@tonic-gate obj); 16390Sstevel@tonic-gate } 16400Sstevel@tonic-gate } 1641252Svi117747 return (paramlen); 16420Sstevel@tonic-gate } 16430Sstevel@tonic-gate 1644852Svi117747 /* 1645852Svi117747 * This is used on a clustered node to obtain a list of addresses, the list 1646852Svi117747 * consists of sockaddr_in structs for v4 and sockaddr_in6 for v6. The list 1647852Svi117747 * is then passed onto the clustering module which sends back the correct 1648852Svi117747 * list based on the port info. Regardless of the input, i.e INADDR_ANY 1649852Svi117747 * or specific address(es), we create the list since it could be modified by 1650852Svi117747 * the clustering module. When given a list of addresses, we simply 1651852Svi117747 * create the list of sockaddr_in or sockaddr_in6 structs using those 1652852Svi117747 * addresses. If there is an INADDR_ANY in the input list, or if the 1653852Svi117747 * input is INADDR_ANY, we create a list of sockaddr_in or sockaddr_in6 1654852Svi117747 * structs consisting all the addresses in the global interface list 1655852Svi117747 * except those that are hosted on the loopback interface. We create 1656852Svi117747 * a list of sockaddr_in[6] structs just so that it can be directly input 1657852Svi117747 * to sctp_valid_addr_list() once the clustering module has processed it. 1658852Svi117747 */ 1659852Svi117747 int 1660852Svi117747 sctp_get_addrlist(sctp_t *sctp, const void *addrs, uint32_t *addrcnt, 1661852Svi117747 uchar_t **addrlist, int *uspec, size_t *size) 1662852Svi117747 { 1663852Svi117747 int cnt; 1664852Svi117747 int icnt; 1665852Svi117747 sctp_ipif_t *sctp_ipif; 1666852Svi117747 struct sockaddr_in *s4; 1667852Svi117747 struct sockaddr_in6 *s6; 1668852Svi117747 uchar_t *p; 1669852Svi117747 int err = 0; 16703448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps; 1671852Svi117747 1672852Svi117747 *addrlist = NULL; 1673852Svi117747 *size = 0; 1674852Svi117747 1675852Svi117747 /* 1676852Svi117747 * Create a list of sockaddr_in[6] structs using the input list. 1677852Svi117747 */ 1678852Svi117747 if (sctp->sctp_family == AF_INET) { 1679852Svi117747 *size = sizeof (struct sockaddr_in) * *addrcnt; 1680852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1681852Svi117747 p = *addrlist; 1682852Svi117747 for (cnt = 0; cnt < *addrcnt; cnt++) { 1683852Svi117747 s4 = (struct sockaddr_in *)addrs + cnt; 1684852Svi117747 /* 1685852Svi117747 * We need to create a list of all the available 1686852Svi117747 * addresses if there is an INADDR_ANY. However, 1687852Svi117747 * if we are beyond LISTEN, then this is invalid 1688852Svi117747 * (see sctp_valid_addr_list(). So, we just fail 1689852Svi117747 * it here rather than wait till it fails in 1690852Svi117747 * sctp_valid_addr_list(). 1691852Svi117747 */ 1692852Svi117747 if (s4->sin_addr.s_addr == INADDR_ANY) { 1693852Svi117747 kmem_free(*addrlist, *size); 1694852Svi117747 *addrlist = NULL; 1695852Svi117747 *size = 0; 1696852Svi117747 if (sctp->sctp_state > SCTPS_LISTEN) { 1697852Svi117747 *addrcnt = 0; 1698852Svi117747 return (EINVAL); 1699852Svi117747 } 1700852Svi117747 if (uspec != NULL) 1701852Svi117747 *uspec = 1; 1702852Svi117747 goto get_all_addrs; 1703852Svi117747 } else { 1704852Svi117747 bcopy(s4, p, sizeof (*s4)); 1705852Svi117747 p += sizeof (*s4); 1706852Svi117747 } 1707852Svi117747 } 1708852Svi117747 } else { 1709852Svi117747 *size = sizeof (struct sockaddr_in6) * *addrcnt; 1710852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1711852Svi117747 p = *addrlist; 1712852Svi117747 for (cnt = 0; cnt < *addrcnt; cnt++) { 1713852Svi117747 s6 = (struct sockaddr_in6 *)addrs + cnt; 1714852Svi117747 /* 1715852Svi117747 * Comments for INADDR_ANY, above, apply here too. 1716852Svi117747 */ 1717852Svi117747 if (IN6_IS_ADDR_UNSPECIFIED(&s6->sin6_addr)) { 1718852Svi117747 kmem_free(*addrlist, *size); 1719852Svi117747 *size = 0; 1720852Svi117747 *addrlist = NULL; 1721852Svi117747 if (sctp->sctp_state > SCTPS_LISTEN) { 1722852Svi117747 *addrcnt = 0; 1723852Svi117747 return (EINVAL); 1724852Svi117747 } 1725852Svi117747 if (uspec != NULL) 1726852Svi117747 *uspec = 1; 1727852Svi117747 goto get_all_addrs; 1728852Svi117747 } else { 1729852Svi117747 bcopy(addrs, p, sizeof (*s6)); 1730852Svi117747 p += sizeof (*s6); 1731852Svi117747 } 1732852Svi117747 } 1733852Svi117747 } 1734852Svi117747 return (err); 1735852Svi117747 get_all_addrs: 1736852Svi117747 1737852Svi117747 /* 1738852Svi117747 * Allocate max possible size. We allocate the max. size here because 1739852Svi117747 * the clustering module could end up adding addresses to the list. 1740852Svi117747 * We allocate upfront so that the clustering module need to bother 1741852Svi117747 * re-sizing the list. 1742852Svi117747 */ 17433448Sdh155122 if (sctp->sctp_family == AF_INET) { 17443448Sdh155122 *size = sizeof (struct sockaddr_in) * 17453448Sdh155122 sctps->sctps_g_ipifs_count; 17463448Sdh155122 } else { 17473448Sdh155122 *size = sizeof (struct sockaddr_in6) * 17483448Sdh155122 sctps->sctps_g_ipifs_count; 17493448Sdh155122 } 1750852Svi117747 *addrlist = kmem_zalloc(*size, KM_SLEEP); 1751852Svi117747 *addrcnt = 0; 1752852Svi117747 p = *addrlist; 17533448Sdh155122 rw_enter(&sctps->sctps_g_ipifs_lock, RW_READER); 1754852Svi117747 1755852Svi117747 /* 1756852Svi117747 * Walk through the global interface list and add all addresses, 1757852Svi117747 * except those that are hosted on loopback interfaces. 1758852Svi117747 */ 1759852Svi117747 for (cnt = 0; cnt < SCTP_IPIF_HASH; cnt++) { 17603448Sdh155122 if (sctps->sctps_g_ipifs[cnt].ipif_count == 0) 1761852Svi117747 continue; 17623448Sdh155122 sctp_ipif = list_head( 17633448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list); 17643448Sdh155122 for (icnt = 0; 17653448Sdh155122 icnt < sctps->sctps_g_ipifs[cnt].ipif_count; 17663448Sdh155122 icnt++) { 1767852Svi117747 in6_addr_t addr; 1768852Svi117747 1769852Svi117747 rw_enter(&sctp_ipif->sctp_ipif_lock, RW_READER); 1770852Svi117747 addr = sctp_ipif->sctp_ipif_saddr; 1771852Svi117747 if (SCTP_IPIF_DISCARD(sctp_ipif->sctp_ipif_flags) || 1772852Svi117747 !SCTP_IPIF_USABLE(sctp_ipif->sctp_ipif_state) || 1773852Svi117747 SCTP_IS_IPIF_LOOPBACK(sctp_ipif) || 1774852Svi117747 SCTP_IS_IPIF_LINKLOCAL(sctp_ipif) || 17752263Ssommerfe !SCTP_IPIF_ZONE_MATCH(sctp, sctp_ipif) || 1776852Svi117747 (sctp->sctp_ipversion == IPV4_VERSION && 1777852Svi117747 sctp_ipif->sctp_ipif_isv6) || 1778852Svi117747 (sctp->sctp_connp->conn_ipv6_v6only && 1779852Svi117747 !sctp_ipif->sctp_ipif_isv6)) { 1780852Svi117747 rw_exit(&sctp_ipif->sctp_ipif_lock); 1781852Svi117747 sctp_ipif = list_next( 17823448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list, 1783852Svi117747 sctp_ipif); 1784852Svi117747 continue; 1785852Svi117747 } 1786852Svi117747 rw_exit(&sctp_ipif->sctp_ipif_lock); 1787852Svi117747 if (sctp->sctp_family == AF_INET) { 1788852Svi117747 s4 = (struct sockaddr_in *)p; 1789852Svi117747 IN6_V4MAPPED_TO_INADDR(&addr, &s4->sin_addr); 1790852Svi117747 s4->sin_family = AF_INET; 1791852Svi117747 p += sizeof (*s4); 1792852Svi117747 } else { 1793852Svi117747 s6 = (struct sockaddr_in6 *)p; 1794852Svi117747 s6->sin6_addr = addr; 1795852Svi117747 s6->sin6_family = AF_INET6; 1796852Svi117747 s6->sin6_scope_id = 1797852Svi117747 sctp_ipif->sctp_ipif_ill->sctp_ill_index; 1798852Svi117747 p += sizeof (*s6); 1799852Svi117747 } 1800852Svi117747 (*addrcnt)++; 18013448Sdh155122 sctp_ipif = list_next( 18023448Sdh155122 &sctps->sctps_g_ipifs[cnt].sctp_ipif_list, 1803852Svi117747 sctp_ipif); 1804852Svi117747 } 1805852Svi117747 } 18063448Sdh155122 rw_exit(&sctps->sctps_g_ipifs_lock); 1807852Svi117747 return (err); 1808852Svi117747 } 1809852Svi117747 1810852Svi117747 /* 1811852Svi117747 * Get a list of addresses from the source address list. The caller is 1812852Svi117747 * responsible for allocating sufficient buffer for this. 1813852Svi117747 */ 1814852Svi117747 void 1815852Svi117747 sctp_get_saddr_list(sctp_t *sctp, uchar_t *p, size_t psize) 1816852Svi117747 { 1817852Svi117747 int cnt; 1818852Svi117747 int icnt; 1819852Svi117747 sctp_saddr_ipif_t *obj; 1820852Svi117747 int naddr; 1821852Svi117747 int scanned = 0; 1822852Svi117747 1823852Svi117747 for (cnt = 0; cnt < SCTP_IPIF_HASH; cnt++) { 1824852Svi117747 if (sctp->sctp_saddrs[cnt].ipif_count == 0) 1825852Svi117747 continue; 1826852Svi117747 obj = list_head(&sctp->sctp_saddrs[cnt].sctp_ipif_list); 1827852Svi117747 naddr = sctp->sctp_saddrs[cnt].ipif_count; 1828852Svi117747 for (icnt = 0; icnt < naddr; icnt++) { 1829852Svi117747 sctp_ipif_t *ipif; 1830852Svi117747 1831852Svi117747 if (psize < sizeof (ipif->sctp_ipif_saddr)) 1832852Svi117747 return; 1833852Svi117747 1834852Svi117747 scanned++; 1835852Svi117747 ipif = obj->saddr_ipifp; 1836852Svi117747 bcopy(&ipif->sctp_ipif_saddr, p, 1837852Svi117747 sizeof (ipif->sctp_ipif_saddr)); 1838852Svi117747 p += sizeof (ipif->sctp_ipif_saddr); 1839852Svi117747 psize -= sizeof (ipif->sctp_ipif_saddr); 1840852Svi117747 if (scanned >= sctp->sctp_nsaddrs) 1841852Svi117747 return; 18423448Sdh155122 obj = list_next( 18433448Sdh155122 &sctp->sctp_saddrs[icnt].sctp_ipif_list, 1844852Svi117747 obj); 1845852Svi117747 } 1846852Svi117747 } 1847852Svi117747 } 1848852Svi117747 1849852Svi117747 /* 1850852Svi117747 * Get a list of addresses from the remote address list. The caller is 1851852Svi117747 * responsible for allocating sufficient buffer for this. 1852852Svi117747 */ 1853852Svi117747 void 1854852Svi117747 sctp_get_faddr_list(sctp_t *sctp, uchar_t *p, size_t psize) 1855852Svi117747 { 1856852Svi117747 sctp_faddr_t *fp; 1857852Svi117747 1858852Svi117747 for (fp = sctp->sctp_faddrs; fp != NULL; fp = fp->next) { 1859852Svi117747 if (psize < sizeof (fp->faddr)) 1860852Svi117747 return; 1861852Svi117747 bcopy(&fp->faddr, p, sizeof (fp->faddr)); 1862852Svi117747 p += sizeof (fp->faddr); 1863852Svi117747 psize -= sizeof (fp->faddr); 1864852Svi117747 } 1865852Svi117747 } 18660Sstevel@tonic-gate 18673448Sdh155122 static void 18683448Sdh155122 sctp_free_ills(sctp_stack_t *sctps) 18693448Sdh155122 { 18703448Sdh155122 int i; 18713448Sdh155122 int l; 18723448Sdh155122 sctp_ill_t *sctp_ill; 18733448Sdh155122 18743448Sdh155122 if (sctps->sctps_ills_count == 0) 18753448Sdh155122 return; 18763448Sdh155122 18773448Sdh155122 for (i = 0; i < SCTP_ILL_HASH; i++) { 18783448Sdh155122 sctp_ill = list_tail(&sctps->sctps_g_ills[i].sctp_ill_list); 18793448Sdh155122 for (l = 0; l < sctps->sctps_g_ills[i].ill_count; l++) { 18803448Sdh155122 ASSERT(sctp_ill->sctp_ill_ipifcnt == 0); 18813448Sdh155122 list_remove(&sctps->sctps_g_ills[i].sctp_ill_list, 18823448Sdh155122 sctp_ill); 18833448Sdh155122 sctps->sctps_ills_count--; 18843448Sdh155122 kmem_free(sctp_ill->sctp_ill_name, 18853448Sdh155122 sctp_ill->sctp_ill_name_length); 18863448Sdh155122 kmem_free(sctp_ill, sizeof (sctp_ill_t)); 18873448Sdh155122 sctp_ill = 18883448Sdh155122 list_tail(&sctps->sctps_g_ills[i].sctp_ill_list); 18893448Sdh155122 } 18903448Sdh155122 sctps->sctps_g_ills[i].ill_count = 0; 18913448Sdh155122 } 18923448Sdh155122 ASSERT(sctps->sctps_ills_count == 0); 18933448Sdh155122 } 18943448Sdh155122 18953448Sdh155122 static void 18963448Sdh155122 sctp_free_ipifs(sctp_stack_t *sctps) 18973448Sdh155122 { 18983448Sdh155122 int i; 18993448Sdh155122 int l; 19003448Sdh155122 sctp_ipif_t *sctp_ipif; 19013448Sdh155122 sctp_ill_t *sctp_ill; 19023448Sdh155122 19033448Sdh155122 if (sctps->sctps_g_ipifs_count == 0) 19043448Sdh155122 return; 19053448Sdh155122 19063448Sdh155122 for (i = 0; i < SCTP_IPIF_HASH; i++) { 19073448Sdh155122 sctp_ipif = list_tail(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 19083448Sdh155122 for (l = 0; l < sctps->sctps_g_ipifs[i].ipif_count; l++) { 19093448Sdh155122 sctp_ill = sctp_ipif->sctp_ipif_ill; 19103448Sdh155122 19113448Sdh155122 list_remove(&sctps->sctps_g_ipifs[i].sctp_ipif_list, 19123448Sdh155122 sctp_ipif); 19133448Sdh155122 sctps->sctps_g_ipifs_count--; 19143448Sdh155122 (void) atomic_add_32_nv(&sctp_ill->sctp_ill_ipifcnt, 19153448Sdh155122 -1); 19163448Sdh155122 kmem_free(sctp_ipif, sizeof (sctp_ipif_t)); 19173448Sdh155122 sctp_ipif = 19183448Sdh155122 list_tail(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 19193448Sdh155122 } 19203448Sdh155122 sctps->sctps_g_ipifs[i].ipif_count = 0; 19213448Sdh155122 } 19223448Sdh155122 ASSERT(sctps->sctps_g_ipifs_count == 0); 19233448Sdh155122 } 19243448Sdh155122 19253448Sdh155122 19260Sstevel@tonic-gate /* Initialize the SCTP ILL list and lock */ 19270Sstevel@tonic-gate void 19283448Sdh155122 sctp_saddr_init(sctp_stack_t *sctps) 19290Sstevel@tonic-gate { 19300Sstevel@tonic-gate int i; 19310Sstevel@tonic-gate 19323448Sdh155122 sctps->sctps_g_ills = kmem_zalloc(sizeof (sctp_ill_hash_t) * 19333448Sdh155122 SCTP_ILL_HASH, KM_SLEEP); 19343448Sdh155122 sctps->sctps_g_ipifs = kmem_zalloc(sizeof (sctp_ipif_hash_t) * 19353448Sdh155122 SCTP_IPIF_HASH, KM_SLEEP); 19363448Sdh155122 19373448Sdh155122 rw_init(&sctps->sctps_g_ills_lock, NULL, RW_DEFAULT, NULL); 19383448Sdh155122 rw_init(&sctps->sctps_g_ipifs_lock, NULL, RW_DEFAULT, NULL); 19390Sstevel@tonic-gate 19400Sstevel@tonic-gate for (i = 0; i < SCTP_ILL_HASH; i++) { 19413448Sdh155122 sctps->sctps_g_ills[i].ill_count = 0; 19423448Sdh155122 list_create(&sctps->sctps_g_ills[i].sctp_ill_list, 19433448Sdh155122 sizeof (sctp_ill_t), 19440Sstevel@tonic-gate offsetof(sctp_ill_t, sctp_ills)); 19450Sstevel@tonic-gate } 19460Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) { 19473448Sdh155122 sctps->sctps_g_ipifs[i].ipif_count = 0; 19483448Sdh155122 list_create(&sctps->sctps_g_ipifs[i].sctp_ipif_list, 19490Sstevel@tonic-gate sizeof (sctp_ipif_t), offsetof(sctp_ipif_t, sctp_ipifs)); 19500Sstevel@tonic-gate } 19510Sstevel@tonic-gate } 19520Sstevel@tonic-gate 19530Sstevel@tonic-gate void 19543448Sdh155122 sctp_saddr_fini(sctp_stack_t *sctps) 19550Sstevel@tonic-gate { 19560Sstevel@tonic-gate int i; 19570Sstevel@tonic-gate 19583448Sdh155122 sctp_free_ipifs(sctps); 19593448Sdh155122 sctp_free_ills(sctps); 19603448Sdh155122 19610Sstevel@tonic-gate for (i = 0; i < SCTP_ILL_HASH; i++) 19623448Sdh155122 list_destroy(&sctps->sctps_g_ills[i].sctp_ill_list); 19630Sstevel@tonic-gate for (i = 0; i < SCTP_IPIF_HASH; i++) 19643448Sdh155122 list_destroy(&sctps->sctps_g_ipifs[i].sctp_ipif_list); 19653448Sdh155122 19663448Sdh155122 ASSERT(sctps->sctps_ills_count == 0 && sctps->sctps_g_ipifs_count == 0); 19673448Sdh155122 kmem_free(sctps->sctps_g_ills, sizeof (sctp_ill_hash_t) * 19683448Sdh155122 SCTP_ILL_HASH); 19693448Sdh155122 sctps->sctps_g_ills = NULL; 19703448Sdh155122 kmem_free(sctps->sctps_g_ipifs, sizeof (sctp_ipif_hash_t) * 19713448Sdh155122 SCTP_IPIF_HASH); 19723448Sdh155122 sctps->sctps_g_ipifs = NULL; 19733448Sdh155122 rw_destroy(&sctps->sctps_g_ills_lock); 19743448Sdh155122 rw_destroy(&sctps->sctps_g_ipifs_lock); 19750Sstevel@tonic-gate } 1976