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 */
211735Skcpoon
220Sstevel@tonic-gate /*
2312474SGeorge.Shepherd@Sun.COM * Copyright (c) 2004, 2010, Oracle and/or its affiliates. All rights reserved.
240Sstevel@tonic-gate */
250Sstevel@tonic-gate
260Sstevel@tonic-gate #include <sys/types.h>
270Sstevel@tonic-gate #include <sys/systm.h>
280Sstevel@tonic-gate #include <sys/stream.h>
290Sstevel@tonic-gate #include <sys/cmn_err.h>
300Sstevel@tonic-gate #include <sys/socket.h>
310Sstevel@tonic-gate #include <sys/kmem.h>
320Sstevel@tonic-gate #include <sys/strsubr.h>
330Sstevel@tonic-gate #include <sys/strsun.h>
340Sstevel@tonic-gate
350Sstevel@tonic-gate #include <netinet/in.h>
360Sstevel@tonic-gate #include <netinet/ip6.h>
370Sstevel@tonic-gate #include <netinet/sctp.h>
380Sstevel@tonic-gate
390Sstevel@tonic-gate #include <inet/common.h>
400Sstevel@tonic-gate #include <inet/ip.h>
410Sstevel@tonic-gate #include <inet/ip6.h>
420Sstevel@tonic-gate #include <inet/mib2.h>
433448Sdh155122 #include <inet/ipclassifier.h>
440Sstevel@tonic-gate #include "sctp_impl.h"
450Sstevel@tonic-gate #include "sctp_asconf.h"
460Sstevel@tonic-gate #include "sctp_addr.h"
470Sstevel@tonic-gate
480Sstevel@tonic-gate typedef struct sctp_asconf_s {
49852Svi117747 mblk_t *head;
50852Svi117747 uint32_t cid;
510Sstevel@tonic-gate } sctp_asconf_t;
520Sstevel@tonic-gate
530Sstevel@tonic-gate /*
54852Svi117747 * This is only used on a clustered node to maintain pre-allocated buffer info.
55852Svi117747 * before sending an ASCONF chunk. The reason for pre-allocation is we don't
56852Svi117747 * want to fail allocating memory when we get then ASCONF-ACK in order to
57852Svi117747 * update the clustering subsystem's state for this assoc.
58852Svi117747 */
59852Svi117747 typedef struct sctp_cl_ainfo_s {
60852Svi117747 uchar_t *sctp_cl_alist;
61852Svi117747 size_t sctp_cl_asize;
62852Svi117747 uchar_t *sctp_cl_dlist;
63852Svi117747 size_t sctp_cl_dsize;
64852Svi117747 } sctp_cl_ainfo_t;
65852Svi117747
66852Svi117747 /*
670Sstevel@tonic-gate * The ASCONF chunk per-parameter request interface. ph is the
680Sstevel@tonic-gate * parameter header for the parameter in the request, and cid
690Sstevel@tonic-gate * is the parameters correlation ID. cont should be set to 1
700Sstevel@tonic-gate * if the ASCONF framework should continue processing request
710Sstevel@tonic-gate * parameters following this one, or 0 if it should stop. If
720Sstevel@tonic-gate * cont is -1, this indicates complete memory depletion, which
730Sstevel@tonic-gate * will cause the ASCONF framework to abort building a reply. If
740Sstevel@tonic-gate * act is 1, the callback should take whatever action it needs
750Sstevel@tonic-gate * to fulfil this request. If act is 0, this request has already
760Sstevel@tonic-gate * been processed, so the callback should only verify and pass
770Sstevel@tonic-gate * back error parameters, and not take any action.
780Sstevel@tonic-gate *
790Sstevel@tonic-gate * The callback should return an mblk with any reply enclosed,
800Sstevel@tonic-gate * with the correlation ID in the first four bytes of the
810Sstevel@tonic-gate * message. A NULL return implies implicit success to the
820Sstevel@tonic-gate * requestor.
830Sstevel@tonic-gate */
840Sstevel@tonic-gate typedef mblk_t *sctp_asconf_func_t(sctp_t *, sctp_parm_hdr_t *ph, uint32_t cid,
85852Svi117747 sctp_faddr_t *, int *cont, int act, in6_addr_t *addr);
860Sstevel@tonic-gate
870Sstevel@tonic-gate /*
880Sstevel@tonic-gate * The ASCONF chunk per-parameter ACK interface. ph is the parameter
890Sstevel@tonic-gate * header for the parameter returned in the ACK, and oph is the
900Sstevel@tonic-gate * original parameter sent out in the ASCONF request.
910Sstevel@tonic-gate * If the peer implicitly responded OK (by not including an
920Sstevel@tonic-gate * explicit OK for the request), ph will be NULL.
930Sstevel@tonic-gate * ph can also point to an Unrecognized Parameter parameter,
940Sstevel@tonic-gate * in which case the peer did not understand the request
950Sstevel@tonic-gate * parameter.
960Sstevel@tonic-gate *
970Sstevel@tonic-gate * ph and oph parameter headers are in host byte order. Encapsulated
980Sstevel@tonic-gate * parameters will still be in network byte order.
990Sstevel@tonic-gate */
1000Sstevel@tonic-gate typedef void sctp_asconf_ack_func_t(sctp_t *, sctp_parm_hdr_t *ph,
101852Svi117747 sctp_parm_hdr_t *oph, sctp_faddr_t *, in6_addr_t *addr);
1020Sstevel@tonic-gate
1030Sstevel@tonic-gate typedef struct {
1040Sstevel@tonic-gate uint16_t id;
1050Sstevel@tonic-gate sctp_asconf_func_t *asconf;
1060Sstevel@tonic-gate sctp_asconf_ack_func_t *asconf_ack;
1070Sstevel@tonic-gate } dispatch_t;
1080Sstevel@tonic-gate
1090Sstevel@tonic-gate static sctp_asconf_func_t sctp_addip_req, sctp_setprim_req,
1100Sstevel@tonic-gate sctp_asconf_unrec_parm;
1110Sstevel@tonic-gate
1120Sstevel@tonic-gate static sctp_asconf_ack_func_t sctp_addip_ack, sctp_setprim_ack,
1130Sstevel@tonic-gate sctp_asconf_ack_unrec_parm;
1140Sstevel@tonic-gate
1150Sstevel@tonic-gate static const dispatch_t sctp_asconf_dispatch_tbl[] = {
1160Sstevel@tonic-gate /* ID ASCONF ASCONF_ACK */
1170Sstevel@tonic-gate { PARM_ADD_IP, sctp_addip_req, sctp_addip_ack },
1180Sstevel@tonic-gate { PARM_DEL_IP, sctp_addip_req, sctp_addip_ack },
1190Sstevel@tonic-gate { PARM_SET_PRIMARY, sctp_setprim_req, sctp_setprim_ack }
1200Sstevel@tonic-gate };
1210Sstevel@tonic-gate
1220Sstevel@tonic-gate static const dispatch_t sctp_asconf_default_dispatch = {
1230Sstevel@tonic-gate 0, sctp_asconf_unrec_parm, sctp_asconf_ack_unrec_parm
1240Sstevel@tonic-gate };
1250Sstevel@tonic-gate
1260Sstevel@tonic-gate /*
1270Sstevel@tonic-gate * ASCONF framework
1280Sstevel@tonic-gate */
1290Sstevel@tonic-gate
1300Sstevel@tonic-gate static const dispatch_t *
sctp_lookup_asconf_dispatch(int id)1310Sstevel@tonic-gate sctp_lookup_asconf_dispatch(int id)
1320Sstevel@tonic-gate {
1330Sstevel@tonic-gate int i;
1340Sstevel@tonic-gate
1350Sstevel@tonic-gate for (i = 0; i < A_CNT(sctp_asconf_dispatch_tbl); i++) {
1360Sstevel@tonic-gate if (sctp_asconf_dispatch_tbl[i].id == id) {
1370Sstevel@tonic-gate return (sctp_asconf_dispatch_tbl + i);
1380Sstevel@tonic-gate }
1390Sstevel@tonic-gate }
1400Sstevel@tonic-gate
1410Sstevel@tonic-gate return (&sctp_asconf_default_dispatch);
1420Sstevel@tonic-gate }
1430Sstevel@tonic-gate
1440Sstevel@tonic-gate /*
1450Sstevel@tonic-gate * Frees mp on failure
1460Sstevel@tonic-gate */
1470Sstevel@tonic-gate static mblk_t *
sctp_asconf_prepend_errwrap(mblk_t * mp,uint32_t cid)1480Sstevel@tonic-gate sctp_asconf_prepend_errwrap(mblk_t *mp, uint32_t cid)
1490Sstevel@tonic-gate {
1500Sstevel@tonic-gate mblk_t *wmp;
1510Sstevel@tonic-gate sctp_parm_hdr_t *wph;
1520Sstevel@tonic-gate
1530Sstevel@tonic-gate /* Prepend a wrapper err cause ind param */
1540Sstevel@tonic-gate wmp = allocb(sizeof (*wph) + sizeof (cid), BPRI_MED);
1550Sstevel@tonic-gate if (wmp == NULL) {
1560Sstevel@tonic-gate freemsg(mp);
1570Sstevel@tonic-gate return (NULL);
1580Sstevel@tonic-gate }
1590Sstevel@tonic-gate wmp->b_wptr += sizeof (*wph) + sizeof (cid);
1600Sstevel@tonic-gate wph = (sctp_parm_hdr_t *)wmp->b_rptr;
1610Sstevel@tonic-gate wph->sph_type = htons(PARM_ERROR_IND);
1620Sstevel@tonic-gate wph->sph_len = htons(msgdsize(mp) + sizeof (*wph) + sizeof (cid));
1630Sstevel@tonic-gate bcopy(&cid, wph + 1, sizeof (uint32_t));
1640Sstevel@tonic-gate
1650Sstevel@tonic-gate wmp->b_cont = mp;
1660Sstevel@tonic-gate return (wmp);
1670Sstevel@tonic-gate }
1680Sstevel@tonic-gate
1690Sstevel@tonic-gate /*ARGSUSED*/
1700Sstevel@tonic-gate static mblk_t *
sctp_asconf_unrec_parm(sctp_t * sctp,sctp_parm_hdr_t * ph,uint32_t cid,sctp_faddr_t * fp,int * cont,int act,in6_addr_t * addr)1710Sstevel@tonic-gate sctp_asconf_unrec_parm(sctp_t *sctp, sctp_parm_hdr_t *ph, uint32_t cid,
172852Svi117747 sctp_faddr_t *fp, int *cont, int act, in6_addr_t *addr)
1730Sstevel@tonic-gate {
1740Sstevel@tonic-gate mblk_t *mp = NULL;
1750Sstevel@tonic-gate
1760Sstevel@tonic-gate /* Unrecognized param; check the high order bits */
1778153SGeorge.Shepherd@Sun.COM if ((ph->sph_type & SCTP_UNREC_PARAM_MASK) ==
1788153SGeorge.Shepherd@Sun.COM (SCTP_CONT_PROC_PARAMS | SCTP_REPORT_THIS_PARAM)) {
1790Sstevel@tonic-gate /* report unrecognized param, and keep processing */
1808549SGeorge.Shepherd@Sun.COM sctp_add_unrec_parm(ph, &mp, B_FALSE);
1810Sstevel@tonic-gate if (mp == NULL) {
1820Sstevel@tonic-gate *cont = -1;
1830Sstevel@tonic-gate return (NULL);
1840Sstevel@tonic-gate }
1850Sstevel@tonic-gate /* Prepend a the CID and a wrapper err cause ind param */
1860Sstevel@tonic-gate mp = sctp_asconf_prepend_errwrap(mp, cid);
1870Sstevel@tonic-gate if (mp == NULL) {
1880Sstevel@tonic-gate *cont = -1;
1890Sstevel@tonic-gate return (NULL);
1900Sstevel@tonic-gate }
1910Sstevel@tonic-gate
1920Sstevel@tonic-gate *cont = 1;
1930Sstevel@tonic-gate return (mp);
1940Sstevel@tonic-gate }
1958153SGeorge.Shepherd@Sun.COM if (ph->sph_type & SCTP_REPORT_THIS_PARAM) {
1960Sstevel@tonic-gate /* Stop processing and drop; report unrecognized param */
1978549SGeorge.Shepherd@Sun.COM sctp_add_unrec_parm(ph, &mp, B_FALSE);
1980Sstevel@tonic-gate if (mp == NULL) {
1990Sstevel@tonic-gate *cont = -1;
2000Sstevel@tonic-gate return (NULL);
2010Sstevel@tonic-gate }
2020Sstevel@tonic-gate /* Prepend a the CID and a wrapper err cause ind param */
2030Sstevel@tonic-gate mp = sctp_asconf_prepend_errwrap(mp, cid);
2040Sstevel@tonic-gate if (mp == NULL) {
2050Sstevel@tonic-gate *cont = -1;
2060Sstevel@tonic-gate return (NULL);
2070Sstevel@tonic-gate }
2080Sstevel@tonic-gate
2090Sstevel@tonic-gate *cont = 0;
2100Sstevel@tonic-gate return (mp);
2110Sstevel@tonic-gate }
2128153SGeorge.Shepherd@Sun.COM if (ph->sph_type & SCTP_CONT_PROC_PARAMS) {
2130Sstevel@tonic-gate /* skip and continue processing */
2140Sstevel@tonic-gate *cont = 1;
2150Sstevel@tonic-gate return (NULL);
2160Sstevel@tonic-gate }
2170Sstevel@tonic-gate
2180Sstevel@tonic-gate /* 2 high bits are clear; stop processing and drop packet */
2190Sstevel@tonic-gate *cont = 0;
2200Sstevel@tonic-gate return (NULL);
2210Sstevel@tonic-gate }
2220Sstevel@tonic-gate
2230Sstevel@tonic-gate /*ARGSUSED*/
2240Sstevel@tonic-gate static void
sctp_asconf_ack_unrec_parm(sctp_t * sctp,sctp_parm_hdr_t * ph,sctp_parm_hdr_t * oph,sctp_faddr_t * fp,in6_addr_t * laddr)2250Sstevel@tonic-gate sctp_asconf_ack_unrec_parm(sctp_t *sctp, sctp_parm_hdr_t *ph,
226852Svi117747 sctp_parm_hdr_t *oph, sctp_faddr_t *fp, in6_addr_t *laddr)
2270Sstevel@tonic-gate {
2280Sstevel@tonic-gate ASSERT(ph);
22911953Sanil.udupa@sun.com sctp_error_event(sctp, (sctp_chunk_hdr_t *)ph, B_TRUE);
2300Sstevel@tonic-gate }
2310Sstevel@tonic-gate
2320Sstevel@tonic-gate static void
sctp_asconf_init(sctp_asconf_t * asc)2330Sstevel@tonic-gate sctp_asconf_init(sctp_asconf_t *asc)
2340Sstevel@tonic-gate {
2350Sstevel@tonic-gate ASSERT(asc != NULL);
2360Sstevel@tonic-gate
2370Sstevel@tonic-gate asc->head = NULL;
2380Sstevel@tonic-gate asc->cid = 0;
2390Sstevel@tonic-gate }
2400Sstevel@tonic-gate
2410Sstevel@tonic-gate static int
sctp_asconf_add(sctp_asconf_t * asc,mblk_t * mp)2420Sstevel@tonic-gate sctp_asconf_add(sctp_asconf_t *asc, mblk_t *mp)
2430Sstevel@tonic-gate {
2440Sstevel@tonic-gate uint32_t *cp;
2450Sstevel@tonic-gate
2460Sstevel@tonic-gate /* XXX can't exceed MTU */
2470Sstevel@tonic-gate
2480Sstevel@tonic-gate cp = (uint32_t *)(mp->b_rptr + sizeof (sctp_parm_hdr_t));
2490Sstevel@tonic-gate *cp = asc->cid++;
2500Sstevel@tonic-gate
2510Sstevel@tonic-gate if (asc->head == NULL)
2520Sstevel@tonic-gate asc->head = mp;
2530Sstevel@tonic-gate else
2540Sstevel@tonic-gate linkb(asc->head, mp);
2550Sstevel@tonic-gate
2560Sstevel@tonic-gate return (0);
2570Sstevel@tonic-gate }
2580Sstevel@tonic-gate
2590Sstevel@tonic-gate static void
sctp_asconf_destroy(sctp_asconf_t * asc)2600Sstevel@tonic-gate sctp_asconf_destroy(sctp_asconf_t *asc)
2610Sstevel@tonic-gate {
2620Sstevel@tonic-gate if (asc->head != NULL) {
2630Sstevel@tonic-gate freemsg(asc->head);
2640Sstevel@tonic-gate asc->head = NULL;
2650Sstevel@tonic-gate }
2660Sstevel@tonic-gate asc->cid = 0;
2670Sstevel@tonic-gate }
2680Sstevel@tonic-gate
2690Sstevel@tonic-gate static int
sctp_asconf_send(sctp_t * sctp,sctp_asconf_t * asc,sctp_faddr_t * fp,sctp_cl_ainfo_t * ainfo)270852Svi117747 sctp_asconf_send(sctp_t *sctp, sctp_asconf_t *asc, sctp_faddr_t *fp,
271852Svi117747 sctp_cl_ainfo_t *ainfo)
2720Sstevel@tonic-gate {
2730Sstevel@tonic-gate mblk_t *mp, *nmp;
2740Sstevel@tonic-gate sctp_chunk_hdr_t *ch;
2750Sstevel@tonic-gate boolean_t isv4;
2760Sstevel@tonic-gate size_t msgsize;
2770Sstevel@tonic-gate
2780Sstevel@tonic-gate ASSERT(asc != NULL && asc->head != NULL);
2790Sstevel@tonic-gate
280*13009SChandrasekar.Marimuthu@Sun.COM isv4 = (fp != NULL) ? fp->sf_isv4 : sctp->sctp_current->sf_isv4;
2810Sstevel@tonic-gate
2820Sstevel@tonic-gate /* SCTP chunk header + Serial Number + Address Param TLV */
2830Sstevel@tonic-gate msgsize = sizeof (*ch) + sizeof (uint32_t) +
2840Sstevel@tonic-gate (isv4 ? PARM_ADDR4_LEN : PARM_ADDR6_LEN);
2850Sstevel@tonic-gate
2860Sstevel@tonic-gate mp = allocb(msgsize, BPRI_MED);
2870Sstevel@tonic-gate if (mp == NULL)
2880Sstevel@tonic-gate return (ENOMEM);
2890Sstevel@tonic-gate
2900Sstevel@tonic-gate mp->b_wptr += msgsize;
2910Sstevel@tonic-gate mp->b_cont = asc->head;
2920Sstevel@tonic-gate
2930Sstevel@tonic-gate ch = (sctp_chunk_hdr_t *)mp->b_rptr;
2940Sstevel@tonic-gate ch->sch_id = CHUNK_ASCONF;
2950Sstevel@tonic-gate ch->sch_flags = 0;
2960Sstevel@tonic-gate ch->sch_len = htons(msgdsize(mp));
2970Sstevel@tonic-gate
2980Sstevel@tonic-gate nmp = msgpullup(mp, -1);
2990Sstevel@tonic-gate if (nmp == NULL) {
3000Sstevel@tonic-gate freeb(mp);
3010Sstevel@tonic-gate return (ENOMEM);
3020Sstevel@tonic-gate }
3030Sstevel@tonic-gate
304852Svi117747 /*
305852Svi117747 * Stash the address list and the count so that when the operation
306852Svi117747 * completes, i.e. when as get an ACK, we can update the clustering's
307852Svi117747 * state for this association.
308852Svi117747 */
309852Svi117747 if (ainfo != NULL) {
310852Svi117747 ASSERT(cl_sctp_assoc_change != NULL);
311852Svi117747 ASSERT(nmp->b_prev == NULL);
312852Svi117747 nmp->b_prev = (mblk_t *)ainfo;
313852Svi117747 }
3140Sstevel@tonic-gate /* Clean up the temporary mblk chain */
3150Sstevel@tonic-gate freemsg(mp);
3160Sstevel@tonic-gate asc->head = NULL;
3170Sstevel@tonic-gate asc->cid = 0;
3180Sstevel@tonic-gate
3190Sstevel@tonic-gate /* Queue it ... */
3200Sstevel@tonic-gate if (sctp->sctp_cxmit_list == NULL) {
3210Sstevel@tonic-gate sctp->sctp_cxmit_list = nmp;
3220Sstevel@tonic-gate } else {
3230Sstevel@tonic-gate linkb(sctp->sctp_cxmit_list, nmp);
3240Sstevel@tonic-gate }
3250Sstevel@tonic-gate
3260Sstevel@tonic-gate BUMP_LOCAL(sctp->sctp_obchunks);
3270Sstevel@tonic-gate
3280Sstevel@tonic-gate /* And try to send it. */
3290Sstevel@tonic-gate sctp_wput_asconf(sctp, fp);
3300Sstevel@tonic-gate
3310Sstevel@tonic-gate return (0);
3320Sstevel@tonic-gate }
3330Sstevel@tonic-gate
3340Sstevel@tonic-gate /*
3350Sstevel@tonic-gate * If the peer does not understand an ASCONF chunk, we simply
3360Sstevel@tonic-gate * clear out the cxmit_list, since we can send nothing further
3370Sstevel@tonic-gate * that the peer will understand.
3380Sstevel@tonic-gate *
3390Sstevel@tonic-gate * Assumes chunk length has already been checked.
3400Sstevel@tonic-gate */
3410Sstevel@tonic-gate /*ARGSUSED*/
3420Sstevel@tonic-gate void
sctp_asconf_free_cxmit(sctp_t * sctp,sctp_chunk_hdr_t * ch)343852Svi117747 sctp_asconf_free_cxmit(sctp_t *sctp, sctp_chunk_hdr_t *ch)
3440Sstevel@tonic-gate {
345852Svi117747 mblk_t *mp;
346852Svi117747 mblk_t *mp1;
347852Svi117747 sctp_cl_ainfo_t *ainfo;
348852Svi117747
3490Sstevel@tonic-gate if (sctp->sctp_cxmit_list == NULL) {
3500Sstevel@tonic-gate /* Nothing pending */
3510Sstevel@tonic-gate return;
3520Sstevel@tonic-gate }
3530Sstevel@tonic-gate
354852Svi117747 mp = sctp->sctp_cxmit_list;
355852Svi117747 while (mp != NULL) {
356852Svi117747 mp1 = mp->b_cont;
357852Svi117747 mp->b_cont = NULL;
358852Svi117747 if (mp->b_prev != NULL) {
359852Svi117747 ainfo = (sctp_cl_ainfo_t *)mp->b_prev;
360852Svi117747 mp->b_prev = NULL;
361852Svi117747 kmem_free(ainfo->sctp_cl_alist, ainfo->sctp_cl_asize);
362852Svi117747 kmem_free(ainfo->sctp_cl_dlist, ainfo->sctp_cl_dsize);
363852Svi117747 kmem_free(ainfo, sizeof (*ainfo));
364852Svi117747 }
365852Svi117747 freeb(mp);
366852Svi117747 mp = mp1;
367852Svi117747 }
3680Sstevel@tonic-gate sctp->sctp_cxmit_list = NULL;
3690Sstevel@tonic-gate }
3700Sstevel@tonic-gate
3710Sstevel@tonic-gate void
sctp_input_asconf(sctp_t * sctp,sctp_chunk_hdr_t * ch,sctp_faddr_t * fp)3720Sstevel@tonic-gate sctp_input_asconf(sctp_t *sctp, sctp_chunk_hdr_t *ch, sctp_faddr_t *fp)
3730Sstevel@tonic-gate {
3740Sstevel@tonic-gate const dispatch_t *dp;
3750Sstevel@tonic-gate mblk_t *hmp;
3760Sstevel@tonic-gate mblk_t *mp;
3770Sstevel@tonic-gate uint32_t *idp;
3780Sstevel@tonic-gate uint32_t *hidp;
3790Sstevel@tonic-gate ssize_t rlen;
3800Sstevel@tonic-gate sctp_parm_hdr_t *ph;
3810Sstevel@tonic-gate sctp_chunk_hdr_t *ach;
3820Sstevel@tonic-gate int cont;
3830Sstevel@tonic-gate int act;
3840Sstevel@tonic-gate uint16_t plen;
385852Svi117747 uchar_t *alist = NULL;
386852Svi117747 size_t asize = 0;
387852Svi117747 uchar_t *dlist = NULL;
388852Svi117747 size_t dsize = 0;
389852Svi117747 uchar_t *aptr = NULL;
390852Svi117747 uchar_t *dptr = NULL;
391852Svi117747 int acount = 0;
392852Svi117747 int dcount = 0;
3933448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps;
3940Sstevel@tonic-gate
3950Sstevel@tonic-gate ASSERT(ch->sch_id == CHUNK_ASCONF);
3960Sstevel@tonic-gate
3970Sstevel@tonic-gate idp = (uint32_t *)(ch + 1);
3980Sstevel@tonic-gate rlen = ntohs(ch->sch_len) - sizeof (*ch) - sizeof (*idp);
3990Sstevel@tonic-gate
4000Sstevel@tonic-gate if (rlen < 0 || rlen < sizeof (*idp)) {
4010Sstevel@tonic-gate /* nothing there; bail out */
4020Sstevel@tonic-gate return;
4030Sstevel@tonic-gate }
4040Sstevel@tonic-gate
4050Sstevel@tonic-gate /* Check for duplicates */
4060Sstevel@tonic-gate *idp = ntohl(*idp);
4070Sstevel@tonic-gate if (*idp == (sctp->sctp_fcsn + 1)) {
4080Sstevel@tonic-gate act = 1;
4090Sstevel@tonic-gate } else if (*idp == sctp->sctp_fcsn) {
4100Sstevel@tonic-gate act = 0;
4110Sstevel@tonic-gate } else {
4120Sstevel@tonic-gate /* stale or malicious packet; drop */
4130Sstevel@tonic-gate return;
4140Sstevel@tonic-gate }
4150Sstevel@tonic-gate
4160Sstevel@tonic-gate /* Create the ASCONF_ACK header */
4170Sstevel@tonic-gate hmp = sctp_make_mp(sctp, fp, sizeof (*ach) + sizeof (*idp));
4180Sstevel@tonic-gate if (hmp == NULL) {
4190Sstevel@tonic-gate /* Let the peer retransmit */
4203448Sdh155122 SCTP_KSTAT(sctps, sctp_send_asconf_ack_failed);
4210Sstevel@tonic-gate return;
4220Sstevel@tonic-gate }
4230Sstevel@tonic-gate ach = (sctp_chunk_hdr_t *)hmp->b_wptr;
4240Sstevel@tonic-gate ach->sch_id = CHUNK_ASCONF_ACK;
4250Sstevel@tonic-gate ach->sch_flags = 0;
4260Sstevel@tonic-gate /* Set the length later */
4270Sstevel@tonic-gate hidp = (uint32_t *)(ach + 1);
4280Sstevel@tonic-gate *hidp = htonl(*idp);
4290Sstevel@tonic-gate hmp->b_wptr = (uchar_t *)(hidp + 1);
4300Sstevel@tonic-gate
4310Sstevel@tonic-gate /* Move to the Address Parameter */
4320Sstevel@tonic-gate ph = (sctp_parm_hdr_t *)(idp + 1);
4330Sstevel@tonic-gate if (rlen <= ntohs(ph->sph_len)) {
4340Sstevel@tonic-gate freeb(hmp);
4350Sstevel@tonic-gate return;
4360Sstevel@tonic-gate }
4370Sstevel@tonic-gate
4380Sstevel@tonic-gate /*
4390Sstevel@tonic-gate * We already have the association here, so this address parameter
4400Sstevel@tonic-gate * doesn't seem to be very useful, should we make sure this is part
4410Sstevel@tonic-gate * of the association and send an error, if not?
4420Sstevel@tonic-gate * Ignore it for now.
4430Sstevel@tonic-gate */
4440Sstevel@tonic-gate rlen -= ntohs(ph->sph_len);
4450Sstevel@tonic-gate ph = (sctp_parm_hdr_t *)((char *)ph + ntohs(ph->sph_len));
446852Svi117747
447852Svi117747 /*
448852Svi117747 * We need to pre-allocate buffer before processing the ASCONF
449852Svi117747 * chunk. We don't want to fail allocating buffers after processing
450852Svi117747 * the ASCONF chunk. So, we walk the list and get the number of
451852Svi117747 * addresses added and/or deleted.
452852Svi117747 */
453852Svi117747 if (cl_sctp_assoc_change != NULL) {
454852Svi117747 sctp_parm_hdr_t *oph = ph;
455852Svi117747 ssize_t orlen = rlen;
456852Svi117747
457852Svi117747 /*
458852Svi117747 * This not very efficient, but there is no better way of
459852Svi117747 * doing it. It should be fine since normally the param list
460852Svi117747 * will not be very long.
461852Svi117747 */
462852Svi117747 while (orlen > 0) {
463852Svi117747 /* Sanity checks */
464852Svi117747 if (orlen < sizeof (*oph))
465852Svi117747 break;
466852Svi117747 plen = ntohs(oph->sph_len);
467852Svi117747 if (plen < sizeof (*oph) || plen > orlen)
468852Svi117747 break;
469852Svi117747 if (oph->sph_type == htons(PARM_ADD_IP))
470852Svi117747 acount++;
471852Svi117747 if (oph->sph_type == htons(PARM_DEL_IP))
472852Svi117747 dcount++;
473852Svi117747 oph = sctp_next_parm(oph, &orlen);
474852Svi117747 if (oph == NULL)
475852Svi117747 break;
476852Svi117747 }
477852Svi117747 if (acount > 0 || dcount > 0) {
478852Svi117747 if (acount > 0) {
479852Svi117747 asize = sizeof (in6_addr_t) * acount;
480852Svi117747 alist = kmem_alloc(asize, KM_NOSLEEP);
481852Svi117747 if (alist == NULL) {
482852Svi117747 freeb(hmp);
4833448Sdh155122 SCTP_KSTAT(sctps, sctp_cl_assoc_change);
484852Svi117747 return;
485852Svi117747 }
486852Svi117747 }
487852Svi117747 if (dcount > 0) {
488852Svi117747 dsize = sizeof (in6_addr_t) * dcount;
489852Svi117747 dlist = kmem_alloc(dsize, KM_NOSLEEP);
490852Svi117747 if (dlist == NULL) {
491852Svi117747 if (acount > 0)
492852Svi117747 kmem_free(alist, asize);
493852Svi117747 freeb(hmp);
4943448Sdh155122 SCTP_KSTAT(sctps, sctp_cl_assoc_change);
495852Svi117747 return;
496852Svi117747 }
497852Svi117747 }
498852Svi117747 aptr = alist;
499852Svi117747 dptr = dlist;
500852Svi117747 /*
501852Svi117747 * We will get the actual count when we process
502852Svi117747 * the chunk.
503852Svi117747 */
504852Svi117747 acount = 0;
505852Svi117747 dcount = 0;
506852Svi117747 }
507852Svi117747 }
5080Sstevel@tonic-gate cont = 1;
5090Sstevel@tonic-gate while (rlen > 0 && cont) {
510852Svi117747 in6_addr_t addr;
511852Svi117747
5120Sstevel@tonic-gate /* Sanity checks */
5130Sstevel@tonic-gate if (rlen < sizeof (*ph))
5140Sstevel@tonic-gate break;
5150Sstevel@tonic-gate plen = ntohs(ph->sph_len);
5160Sstevel@tonic-gate if (plen < sizeof (*ph) || plen > rlen) {
5170Sstevel@tonic-gate break;
5180Sstevel@tonic-gate }
5190Sstevel@tonic-gate idp = (uint32_t *)(ph + 1);
5200Sstevel@tonic-gate dp = sctp_lookup_asconf_dispatch(ntohs(ph->sph_type));
5210Sstevel@tonic-gate ASSERT(dp);
5220Sstevel@tonic-gate if (dp->asconf) {
523852Svi117747 mp = dp->asconf(sctp, ph, *idp, fp, &cont, act, &addr);
5240Sstevel@tonic-gate if (cont == -1) {
5250Sstevel@tonic-gate /*
5260Sstevel@tonic-gate * Not even enough memory to create
5270Sstevel@tonic-gate * an out-of-resources error. Free
5280Sstevel@tonic-gate * everything and return; the peer
5290Sstevel@tonic-gate * should retransmit.
5300Sstevel@tonic-gate */
5310Sstevel@tonic-gate freemsg(hmp);
532852Svi117747 if (alist != NULL)
533852Svi117747 kmem_free(alist, asize);
534852Svi117747 if (dlist != NULL)
535852Svi117747 kmem_free(dlist, dsize);
5360Sstevel@tonic-gate return;
5370Sstevel@tonic-gate }
5380Sstevel@tonic-gate if (mp != NULL) {
5390Sstevel@tonic-gate linkb(hmp, mp);
540852Svi117747 } else if (act != 0) {
541852Svi117747 /* update the add/delete list */
542852Svi117747 if (cl_sctp_assoc_change != NULL) {
543852Svi117747 if (ph->sph_type ==
544852Svi117747 htons(PARM_ADD_IP)) {
545852Svi117747 ASSERT(alist != NULL);
546852Svi117747 bcopy(&addr, aptr,
547852Svi117747 sizeof (addr));
548852Svi117747 aptr += sizeof (addr);
549852Svi117747 acount++;
550852Svi117747 } else if (ph->sph_type ==
551852Svi117747 htons(PARM_DEL_IP)) {
552852Svi117747 ASSERT(dlist != NULL);
553852Svi117747 bcopy(&addr, dptr,
554852Svi117747 sizeof (addr));
555852Svi117747 dptr += sizeof (addr);
556852Svi117747 dcount++;
557852Svi117747 }
558852Svi117747 }
5590Sstevel@tonic-gate }
5600Sstevel@tonic-gate }
5610Sstevel@tonic-gate ph = sctp_next_parm(ph, &rlen);
5620Sstevel@tonic-gate if (ph == NULL)
5630Sstevel@tonic-gate break;
5640Sstevel@tonic-gate }
5650Sstevel@tonic-gate
566852Svi117747 /*
567852Svi117747 * Update clustering's state for this assoc. Note acount/dcount
568852Svi117747 * could be zero (i.e. if the add/delete address(es) were not
569852Svi117747 * processed successfully). Regardless, if the ?size is > 0,
570852Svi117747 * it is the clustering module's responsibility to free the lists.
571852Svi117747 */
572852Svi117747 if (cl_sctp_assoc_change != NULL) {
57311042SErik.Nordmark@Sun.COM (*cl_sctp_assoc_change)(sctp->sctp_connp->conn_family,
57411042SErik.Nordmark@Sun.COM alist, asize,
575852Svi117747 acount, dlist, dsize, dcount, SCTP_CL_PADDR,
576852Svi117747 (cl_sctp_handle_t)sctp);
577852Svi117747 /* alist and dlist will be freed by the clustering module */
578852Svi117747 }
5790Sstevel@tonic-gate /* Now that the params have been processed, increment the fcsn */
5800Sstevel@tonic-gate if (act) {
5810Sstevel@tonic-gate sctp->sctp_fcsn++;
5820Sstevel@tonic-gate }
5830Sstevel@tonic-gate BUMP_LOCAL(sctp->sctp_obchunks);
5840Sstevel@tonic-gate
585*13009SChandrasekar.Marimuthu@Sun.COM if (fp->sf_isv4)
5860Sstevel@tonic-gate ach->sch_len = htons(msgdsize(hmp) - sctp->sctp_hdr_len);
5870Sstevel@tonic-gate else
5880Sstevel@tonic-gate ach->sch_len = htons(msgdsize(hmp) - sctp->sctp_hdr6_len);
5890Sstevel@tonic-gate
590*13009SChandrasekar.Marimuthu@Sun.COM sctp_set_iplen(sctp, hmp, fp->sf_ixa);
591*13009SChandrasekar.Marimuthu@Sun.COM (void) conn_ip_output(hmp, fp->sf_ixa);
59211042SErik.Nordmark@Sun.COM BUMP_LOCAL(sctp->sctp_opkts);
5930Sstevel@tonic-gate sctp_validate_peer(sctp);
5940Sstevel@tonic-gate }
5950Sstevel@tonic-gate
5960Sstevel@tonic-gate static sctp_parm_hdr_t *
sctp_lookup_asconf_param(sctp_parm_hdr_t * ph,uint32_t cid,ssize_t rlen)5970Sstevel@tonic-gate sctp_lookup_asconf_param(sctp_parm_hdr_t *ph, uint32_t cid, ssize_t rlen)
5980Sstevel@tonic-gate {
5990Sstevel@tonic-gate uint32_t *idp;
6000Sstevel@tonic-gate
6010Sstevel@tonic-gate while (rlen > 0) {
6020Sstevel@tonic-gate idp = (uint32_t *)(ph + 1);
6030Sstevel@tonic-gate if (*idp == cid) {
6040Sstevel@tonic-gate return (ph);
6050Sstevel@tonic-gate }
6060Sstevel@tonic-gate ph = sctp_next_parm(ph, &rlen);
6070Sstevel@tonic-gate if (ph == NULL)
6080Sstevel@tonic-gate break;
6090Sstevel@tonic-gate }
6100Sstevel@tonic-gate return (NULL);
6110Sstevel@tonic-gate }
6120Sstevel@tonic-gate
6130Sstevel@tonic-gate void
sctp_input_asconf_ack(sctp_t * sctp,sctp_chunk_hdr_t * ch,sctp_faddr_t * fp)6140Sstevel@tonic-gate sctp_input_asconf_ack(sctp_t *sctp, sctp_chunk_hdr_t *ch, sctp_faddr_t *fp)
6150Sstevel@tonic-gate {
6160Sstevel@tonic-gate const dispatch_t *dp;
6170Sstevel@tonic-gate uint32_t *idp;
6180Sstevel@tonic-gate uint32_t *snp;
6190Sstevel@tonic-gate ssize_t rlen;
6200Sstevel@tonic-gate ssize_t plen;
6210Sstevel@tonic-gate sctp_parm_hdr_t *ph;
6220Sstevel@tonic-gate sctp_parm_hdr_t *oph;
6230Sstevel@tonic-gate sctp_parm_hdr_t *fph;
6240Sstevel@tonic-gate mblk_t *mp;
6250Sstevel@tonic-gate sctp_chunk_hdr_t *och;
6260Sstevel@tonic-gate int redosrcs = 0;
6270Sstevel@tonic-gate uint16_t param_len;
628852Svi117747 uchar_t *alist;
629852Svi117747 uchar_t *dlist;
630852Svi117747 uint_t acount = 0;
631852Svi117747 uint_t dcount = 0;
632852Svi117747 uchar_t *aptr;
633852Svi117747 uchar_t *dptr;
634852Svi117747 sctp_cl_ainfo_t *ainfo;
635852Svi117747 in6_addr_t addr;
6360Sstevel@tonic-gate
6370Sstevel@tonic-gate ASSERT(ch->sch_id == CHUNK_ASCONF_ACK);
6380Sstevel@tonic-gate
6390Sstevel@tonic-gate snp = (uint32_t *)(ch + 1);
6400Sstevel@tonic-gate rlen = ntohs(ch->sch_len) - sizeof (*ch) - sizeof (*snp);
6410Sstevel@tonic-gate if (rlen < 0) {
6420Sstevel@tonic-gate return;
6430Sstevel@tonic-gate }
6440Sstevel@tonic-gate
6450Sstevel@tonic-gate /* Accept only an ACK for the current serial number */
6460Sstevel@tonic-gate *snp = ntohl(*snp);
6470Sstevel@tonic-gate if (sctp->sctp_cxmit_list == NULL || *snp != (sctp->sctp_lcsn - 1)) {
6480Sstevel@tonic-gate /* Need to send an abort */
6490Sstevel@tonic-gate return;
6500Sstevel@tonic-gate }
6510Sstevel@tonic-gate sctp->sctp_cchunk_pend = 0;
6520Sstevel@tonic-gate SCTP_FADDR_RC_TIMER_STOP(fp);
6530Sstevel@tonic-gate
654852Svi117747 mp = sctp->sctp_cxmit_list;
655852Svi117747 /*
656852Svi117747 * We fill in the addresses here to update the clustering's state for
657852Svi117747 * this assoc.
658852Svi117747 */
659852Svi117747 if (mp != NULL && cl_sctp_assoc_change != NULL) {
660852Svi117747 ASSERT(mp->b_prev != NULL);
661852Svi117747 ainfo = (sctp_cl_ainfo_t *)mp->b_prev;
662852Svi117747 alist = ainfo->sctp_cl_alist;
663852Svi117747 dlist = ainfo->sctp_cl_dlist;
664852Svi117747 aptr = alist;
665852Svi117747 dptr = dlist;
666852Svi117747 }
667852Svi117747
6680Sstevel@tonic-gate /*
6690Sstevel@tonic-gate * Pass explicit replies to callbacks:
6700Sstevel@tonic-gate * For each reply in the ACK, look up the corresponding
6710Sstevel@tonic-gate * original parameter in the request using the correlation
6720Sstevel@tonic-gate * ID, and pass it to the right callback.
6730Sstevel@tonic-gate */
6740Sstevel@tonic-gate och = (sctp_chunk_hdr_t *)sctp->sctp_cxmit_list->b_rptr;
6750Sstevel@tonic-gate
6760Sstevel@tonic-gate plen = ntohs(och->sch_len) - sizeof (*och) - sizeof (*idp);
6770Sstevel@tonic-gate idp = (uint32_t *)(och + 1);
6780Sstevel@tonic-gate
6790Sstevel@tonic-gate /* Get to the 1st ASCONF param, need to skip Address TLV parm */
6800Sstevel@tonic-gate fph = (sctp_parm_hdr_t *)(idp + 1);
6810Sstevel@tonic-gate plen -= ntohs(fph->sph_len);
6820Sstevel@tonic-gate fph = (sctp_parm_hdr_t *)((char *)fph + ntohs(fph->sph_len));
6830Sstevel@tonic-gate ph = (sctp_parm_hdr_t *)(snp + 1);
6840Sstevel@tonic-gate while (rlen > 0) {
6850Sstevel@tonic-gate /* Sanity checks */
6860Sstevel@tonic-gate if (rlen < sizeof (*ph)) {
6870Sstevel@tonic-gate break;
6880Sstevel@tonic-gate }
6890Sstevel@tonic-gate param_len = ntohs(ph->sph_len);
6900Sstevel@tonic-gate if (param_len < sizeof (*ph) || param_len > rlen) {
6910Sstevel@tonic-gate break;
6920Sstevel@tonic-gate }
6930Sstevel@tonic-gate idp = (uint32_t *)(ph + 1);
6940Sstevel@tonic-gate oph = sctp_lookup_asconf_param(fph, *idp, plen);
6950Sstevel@tonic-gate if (oph != NULL) {
6960Sstevel@tonic-gate dp = sctp_lookup_asconf_dispatch(ntohs(oph->sph_type));
6970Sstevel@tonic-gate ASSERT(dp);
6980Sstevel@tonic-gate if (dp->asconf_ack) {
699852Svi117747 dp->asconf_ack(sctp, ph, oph, fp, &addr);
7000Sstevel@tonic-gate
7010Sstevel@tonic-gate /* hack. see below */
7020Sstevel@tonic-gate if (oph->sph_type == htons(PARM_ADD_IP) ||
7030Sstevel@tonic-gate oph->sph_type == htons(PARM_DEL_IP)) {
7040Sstevel@tonic-gate redosrcs = 1;
705852Svi117747 /*
706852Svi117747 * If the address was sucessfully
707852Svi117747 * processed, add it to the add/delete
708852Svi117747 * list to send to the clustering
709852Svi117747 * module.
710852Svi117747 */
711852Svi117747 if (cl_sctp_assoc_change != NULL &&
7128903SVenu.Iyer@Sun.COM !SCTP_IS_ADDR_UNSPEC(
7138903SVenu.Iyer@Sun.COM IN6_IS_ADDR_V4MAPPED(&addr),
7148903SVenu.Iyer@Sun.COM addr)) {
715852Svi117747 if (oph->sph_type ==
716852Svi117747 htons(PARM_ADD_IP)) {
717852Svi117747 bcopy(&addr, aptr,
718852Svi117747 sizeof (addr));
719852Svi117747 aptr += sizeof (addr);
720852Svi117747 acount++;
721852Svi117747 } else {
722852Svi117747 bcopy(&addr, dptr,
723852Svi117747 sizeof (addr));
724852Svi117747 dptr += sizeof (addr);
725852Svi117747 dcount++;
726852Svi117747 }
727852Svi117747 }
7280Sstevel@tonic-gate }
7290Sstevel@tonic-gate }
7300Sstevel@tonic-gate }
7310Sstevel@tonic-gate
7320Sstevel@tonic-gate ph = sctp_next_parm(ph, &rlen);
7330Sstevel@tonic-gate if (ph == NULL)
7340Sstevel@tonic-gate break;
7350Sstevel@tonic-gate }
7360Sstevel@tonic-gate
7370Sstevel@tonic-gate /*
7380Sstevel@tonic-gate * Pass implicit replies to callbacks:
7390Sstevel@tonic-gate * For each original request, look up its parameter
7400Sstevel@tonic-gate * in the ACK. If there is no corresponding reply,
7410Sstevel@tonic-gate * call the callback with a NULL parameter, indicating
7420Sstevel@tonic-gate * success.
7430Sstevel@tonic-gate */
7440Sstevel@tonic-gate rlen = plen;
7450Sstevel@tonic-gate plen = ntohs(ch->sch_len) - sizeof (*ch) - sizeof (*idp);
7460Sstevel@tonic-gate oph = fph;
7470Sstevel@tonic-gate fph = (sctp_parm_hdr_t *)((char *)ch + sizeof (sctp_chunk_hdr_t) +
7480Sstevel@tonic-gate sizeof (uint32_t));
7490Sstevel@tonic-gate while (rlen > 0) {
7500Sstevel@tonic-gate idp = (uint32_t *)(oph + 1);
7510Sstevel@tonic-gate ph = sctp_lookup_asconf_param(fph, *idp, plen);
7520Sstevel@tonic-gate if (ph == NULL) {
7530Sstevel@tonic-gate dp = sctp_lookup_asconf_dispatch(ntohs(oph->sph_type));
7540Sstevel@tonic-gate ASSERT(dp);
7550Sstevel@tonic-gate if (dp->asconf_ack) {
756852Svi117747 dp->asconf_ack(sctp, NULL, oph, fp, &addr);
7570Sstevel@tonic-gate
7580Sstevel@tonic-gate /* hack. see below */
7590Sstevel@tonic-gate if (oph->sph_type == htons(PARM_ADD_IP) ||
7600Sstevel@tonic-gate oph->sph_type == htons(PARM_DEL_IP)) {
7610Sstevel@tonic-gate redosrcs = 1;
762852Svi117747 /*
763852Svi117747 * If the address was sucessfully
764852Svi117747 * processed, add it to the add/delete
765852Svi117747 * list to send to the clustering
766852Svi117747 * module.
767852Svi117747 */
768852Svi117747 if (cl_sctp_assoc_change != NULL &&
7698903SVenu.Iyer@Sun.COM !SCTP_IS_ADDR_UNSPEC(
7708903SVenu.Iyer@Sun.COM IN6_IS_ADDR_V4MAPPED(&addr),
7718903SVenu.Iyer@Sun.COM addr)) {
772852Svi117747 if (oph->sph_type ==
773852Svi117747 htons(PARM_ADD_IP)) {
774852Svi117747 bcopy(&addr, aptr,
775852Svi117747 sizeof (addr));
776852Svi117747 aptr += sizeof (addr);
777852Svi117747 acount++;
778852Svi117747 } else {
779852Svi117747 bcopy(&addr, dptr,
780852Svi117747 sizeof (addr));
781852Svi117747 dptr += sizeof (addr);
782852Svi117747 dcount++;
783852Svi117747 }
784852Svi117747 }
7850Sstevel@tonic-gate }
7860Sstevel@tonic-gate }
7870Sstevel@tonic-gate }
7880Sstevel@tonic-gate oph = sctp_next_parm(oph, &rlen);
7890Sstevel@tonic-gate if (oph == NULL) {
7900Sstevel@tonic-gate break;
7910Sstevel@tonic-gate }
7920Sstevel@tonic-gate }
7930Sstevel@tonic-gate
7940Sstevel@tonic-gate /* We can now free up the first chunk in the cxmit list */
7950Sstevel@tonic-gate sctp->sctp_cxmit_list = mp->b_cont;
7960Sstevel@tonic-gate mp->b_cont = NULL;
7970Sstevel@tonic-gate
7980Sstevel@tonic-gate fp = SCTP_CHUNK_DEST(mp);
799*13009SChandrasekar.Marimuthu@Sun.COM ASSERT(fp != NULL && fp->sf_suna >= MBLKL(mp));
800*13009SChandrasekar.Marimuthu@Sun.COM fp->sf_suna -= MBLKL(mp);
801852Svi117747
802852Svi117747 /*
803852Svi117747 * Update clustering's state for this assoc. Note acount/dcount
804852Svi117747 * could be zero (i.e. if the add/delete address(es) did not
805852Svi117747 * succeed). Regardless, if the ?size is > 0, it is the clustering
806852Svi117747 * module's responsibility to free the lists.
807852Svi117747 */
808852Svi117747 if (cl_sctp_assoc_change != NULL) {
809852Svi117747 ASSERT(mp->b_prev != NULL);
810852Svi117747 mp->b_prev = NULL;
811852Svi117747 ainfo->sctp_cl_alist = NULL;
812852Svi117747 ainfo->sctp_cl_dlist = NULL;
81311042SErik.Nordmark@Sun.COM (*cl_sctp_assoc_change)(sctp->sctp_connp->conn_family, alist,
814852Svi117747 ainfo->sctp_cl_asize, acount, dlist, ainfo->sctp_cl_dsize,
815852Svi117747 dcount, SCTP_CL_LADDR, (cl_sctp_handle_t)sctp);
816852Svi117747 /* alist and dlist will be freed by the clustering module */
817852Svi117747 ainfo->sctp_cl_asize = 0;
818852Svi117747 ainfo->sctp_cl_dsize = 0;
819852Svi117747 kmem_free(ainfo, sizeof (*ainfo));
820852Svi117747 }
8210Sstevel@tonic-gate freeb(mp);
8220Sstevel@tonic-gate
8230Sstevel@tonic-gate /* can now send the next control chunk */
8240Sstevel@tonic-gate if (sctp->sctp_cxmit_list != NULL)
8250Sstevel@tonic-gate sctp_wput_asconf(sctp, NULL);
8260Sstevel@tonic-gate
8270Sstevel@tonic-gate /*
8280Sstevel@tonic-gate * If an add-ip or del-ip has completed (successfully or
8290Sstevel@tonic-gate * unsuccessfully), the pool of available source addresses
8300Sstevel@tonic-gate * may have changed, so we need to redo faddr source
8310Sstevel@tonic-gate * address selections. This is a bit of a hack since
8320Sstevel@tonic-gate * this really belongs in the add/del-ip code. However,
8330Sstevel@tonic-gate * that code consists of callbacks called for *each*
8340Sstevel@tonic-gate * add/del-ip parameter, and sctp_redo_faddr_srcs() is
8350Sstevel@tonic-gate * expensive enough that we really don't want to be
8360Sstevel@tonic-gate * doing it for each one. So we do it once here.
8370Sstevel@tonic-gate */
8380Sstevel@tonic-gate if (redosrcs)
8390Sstevel@tonic-gate sctp_redo_faddr_srcs(sctp);
8400Sstevel@tonic-gate }
8410Sstevel@tonic-gate
8420Sstevel@tonic-gate static void
sctp_rc_timer(sctp_t * sctp,sctp_faddr_t * fp)8430Sstevel@tonic-gate sctp_rc_timer(sctp_t *sctp, sctp_faddr_t *fp)
8440Sstevel@tonic-gate {
8450Sstevel@tonic-gate #define SCTP_CLR_SENT_FLAG(mp) ((mp)->b_flag &= ~SCTP_CHUNK_FLAG_SENT)
8460Sstevel@tonic-gate sctp_faddr_t *nfp;
8470Sstevel@tonic-gate sctp_faddr_t *ofp;
8483448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps;
8490Sstevel@tonic-gate
8500Sstevel@tonic-gate ASSERT(fp != NULL);
8510Sstevel@tonic-gate
852*13009SChandrasekar.Marimuthu@Sun.COM fp->sf_rc_timer_running = 0;
8530Sstevel@tonic-gate
8540Sstevel@tonic-gate if (sctp->sctp_state != SCTPS_ESTABLISHED ||
8550Sstevel@tonic-gate sctp->sctp_cxmit_list == NULL) {
8560Sstevel@tonic-gate return;
8570Sstevel@tonic-gate }
8580Sstevel@tonic-gate /*
8590Sstevel@tonic-gate * Not a retransmission, this was deferred due to some error
8600Sstevel@tonic-gate * condition
8610Sstevel@tonic-gate */
8620Sstevel@tonic-gate if (!SCTP_CHUNK_ISSENT(sctp->sctp_cxmit_list)) {
8630Sstevel@tonic-gate sctp_wput_asconf(sctp, fp);
8640Sstevel@tonic-gate return;
8650Sstevel@tonic-gate }
8660Sstevel@tonic-gate /*
8670Sstevel@tonic-gate * The sent flag indicates if the msg has been sent on this fp.
8680Sstevel@tonic-gate */
8690Sstevel@tonic-gate SCTP_CLR_SENT_FLAG(sctp->sctp_cxmit_list);
8700Sstevel@tonic-gate /* Retransmission */
8710Sstevel@tonic-gate if (sctp->sctp_strikes >= sctp->sctp_pa_max_rxt) {
8720Sstevel@tonic-gate /* time to give up */
87312869SKacheong.Poon@Sun.COM SCTPS_BUMP_MIB(sctps, sctpAborted);
8740Sstevel@tonic-gate sctp_assoc_event(sctp, SCTP_COMM_LOST, 0, NULL);
8750Sstevel@tonic-gate sctp_clean_death(sctp, ETIMEDOUT);
8760Sstevel@tonic-gate return;
8770Sstevel@tonic-gate }
878*13009SChandrasekar.Marimuthu@Sun.COM if (fp->sf_strikes >= fp->sf_max_retr) {
8790Sstevel@tonic-gate if (sctp_faddr_dead(sctp, fp, SCTP_FADDRS_DOWN) == -1)
8800Sstevel@tonic-gate return;
8810Sstevel@tonic-gate }
8820Sstevel@tonic-gate
883*13009SChandrasekar.Marimuthu@Sun.COM fp->sf_strikes++;
8840Sstevel@tonic-gate sctp->sctp_strikes++;
88512474SGeorge.Shepherd@Sun.COM SCTP_CALC_RXT(sctp, fp, sctp->sctp_rto_max);
8860Sstevel@tonic-gate
8870Sstevel@tonic-gate nfp = sctp_rotate_faddr(sctp, fp);
8880Sstevel@tonic-gate sctp->sctp_cchunk_pend = 0;
8890Sstevel@tonic-gate ofp = SCTP_CHUNK_DEST(sctp->sctp_cxmit_list);
8900Sstevel@tonic-gate SCTP_SET_CHUNK_DEST(sctp->sctp_cxmit_list, NULL);
8910Sstevel@tonic-gate ASSERT(ofp != NULL && ofp == fp);
892*13009SChandrasekar.Marimuthu@Sun.COM ASSERT(ofp->sf_suna >= MBLKL(sctp->sctp_cxmit_list));
8930Sstevel@tonic-gate /*
8940Sstevel@tonic-gate * Enter slow start for this destination.
8950Sstevel@tonic-gate * XXX anything in the data path that needs to be considered?
8960Sstevel@tonic-gate */
897*13009SChandrasekar.Marimuthu@Sun.COM ofp->sf_ssthresh = ofp->sf_cwnd / 2;
898*13009SChandrasekar.Marimuthu@Sun.COM if (ofp->sf_ssthresh < 2 * ofp->sf_pmss)
899*13009SChandrasekar.Marimuthu@Sun.COM ofp->sf_ssthresh = 2 * ofp->sf_pmss;
900*13009SChandrasekar.Marimuthu@Sun.COM ofp->sf_cwnd = ofp->sf_pmss;
901*13009SChandrasekar.Marimuthu@Sun.COM ofp->sf_pba = 0;
902*13009SChandrasekar.Marimuthu@Sun.COM ofp->sf_suna -= MBLKL(sctp->sctp_cxmit_list);
9030Sstevel@tonic-gate /*
9040Sstevel@tonic-gate * The rexmit flags is used to determine if a serial number needs to
9050Sstevel@tonic-gate * be assigned or not, so once set we leave it there.
9060Sstevel@tonic-gate */
9070Sstevel@tonic-gate if (!SCTP_CHUNK_WANT_REXMIT(sctp->sctp_cxmit_list))
90812604SGeorge.Shepherd@Sun.COM SCTP_CHUNK_REXMIT(sctp, sctp->sctp_cxmit_list);
9090Sstevel@tonic-gate sctp_wput_asconf(sctp, nfp);
9100Sstevel@tonic-gate #undef SCTP_CLR_SENT_FLAG
9110Sstevel@tonic-gate }
9120Sstevel@tonic-gate
9130Sstevel@tonic-gate void
sctp_wput_asconf(sctp_t * sctp,sctp_faddr_t * fp)9140Sstevel@tonic-gate sctp_wput_asconf(sctp_t *sctp, sctp_faddr_t *fp)
9150Sstevel@tonic-gate {
9160Sstevel@tonic-gate #define SCTP_SET_SENT_FLAG(mp) ((mp)->b_flag = SCTP_CHUNK_FLAG_SENT)
9170Sstevel@tonic-gate
9180Sstevel@tonic-gate mblk_t *mp;
9190Sstevel@tonic-gate mblk_t *ipmp;
9200Sstevel@tonic-gate uint32_t *snp;
9210Sstevel@tonic-gate sctp_parm_hdr_t *ph;
9220Sstevel@tonic-gate boolean_t isv4;
9233448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps;
9244818Skcpoon boolean_t saddr_set;
9250Sstevel@tonic-gate
9260Sstevel@tonic-gate if (sctp->sctp_cchunk_pend || sctp->sctp_cxmit_list == NULL ||
9270Sstevel@tonic-gate /* Queue it for later transmission if not yet established */
9280Sstevel@tonic-gate sctp->sctp_state < SCTPS_ESTABLISHED) {
9290Sstevel@tonic-gate ip2dbg(("sctp_wput_asconf: cchunk pending? (%d) or null "\
9300Sstevel@tonic-gate "sctp_cxmit_list? (%s) or incorrect state? (%x)\n",
9310Sstevel@tonic-gate sctp->sctp_cchunk_pend, sctp->sctp_cxmit_list == NULL ?
9320Sstevel@tonic-gate "yes" : "no", sctp->sctp_state));
9330Sstevel@tonic-gate return;
9340Sstevel@tonic-gate }
9350Sstevel@tonic-gate
9360Sstevel@tonic-gate if (fp == NULL)
9370Sstevel@tonic-gate fp = sctp->sctp_current;
9380Sstevel@tonic-gate
9390Sstevel@tonic-gate /* OK to send */
9400Sstevel@tonic-gate ipmp = sctp_make_mp(sctp, fp, 0);
9410Sstevel@tonic-gate if (ipmp == NULL) {
942*13009SChandrasekar.Marimuthu@Sun.COM SCTP_FADDR_RC_TIMER_RESTART(sctp, fp, fp->sf_rto);
9433448Sdh155122 SCTP_KSTAT(sctps, sctp_send_asconf_failed);
9440Sstevel@tonic-gate return;
9450Sstevel@tonic-gate }
9460Sstevel@tonic-gate mp = sctp->sctp_cxmit_list;
9470Sstevel@tonic-gate /* Fill in the mandatory Address Parameter TLV */
948*13009SChandrasekar.Marimuthu@Sun.COM isv4 = (fp != NULL) ? fp->sf_isv4 : sctp->sctp_current->sf_isv4;
9490Sstevel@tonic-gate ph = (sctp_parm_hdr_t *)(mp->b_rptr + sizeof (sctp_chunk_hdr_t) +
9500Sstevel@tonic-gate sizeof (uint32_t));
9510Sstevel@tonic-gate if (isv4) {
9520Sstevel@tonic-gate ipha_t *ipha = (ipha_t *)ipmp->b_rptr;
9530Sstevel@tonic-gate in6_addr_t ipaddr;
9540Sstevel@tonic-gate ipaddr_t addr4;
9550Sstevel@tonic-gate
9560Sstevel@tonic-gate ph->sph_type = htons(PARM_ADDR4);
9570Sstevel@tonic-gate ph->sph_len = htons(PARM_ADDR4_LEN);
9580Sstevel@tonic-gate if (ipha->ipha_src != INADDR_ANY) {
9590Sstevel@tonic-gate bcopy(&ipha->ipha_src, ph + 1, IP_ADDR_LEN);
9600Sstevel@tonic-gate } else {
9614818Skcpoon ipaddr = sctp_get_valid_addr(sctp, B_FALSE, &saddr_set);
962252Svi117747 /*
963252Svi117747 * All the addresses are down.
964252Svi117747 * Maybe we might have better luck next time.
965252Svi117747 */
9664818Skcpoon if (!saddr_set) {
967*13009SChandrasekar.Marimuthu@Sun.COM SCTP_FADDR_RC_TIMER_RESTART(sctp, fp,
968*13009SChandrasekar.Marimuthu@Sun.COM fp->sf_rto);
969252Svi117747 freeb(ipmp);
970252Svi117747 return;
971252Svi117747 }
9720Sstevel@tonic-gate IN6_V4MAPPED_TO_IPADDR(&ipaddr, addr4);
9730Sstevel@tonic-gate bcopy(&addr4, ph + 1, IP_ADDR_LEN);
9740Sstevel@tonic-gate }
9750Sstevel@tonic-gate } else {
9760Sstevel@tonic-gate ip6_t *ip6 = (ip6_t *)ipmp->b_rptr;
9770Sstevel@tonic-gate in6_addr_t ipaddr;
9780Sstevel@tonic-gate
9790Sstevel@tonic-gate ph->sph_type = htons(PARM_ADDR6);
9800Sstevel@tonic-gate ph->sph_len = htons(PARM_ADDR6_LEN);
9810Sstevel@tonic-gate if (!IN6_IS_ADDR_UNSPECIFIED(&ip6->ip6_src)) {
9820Sstevel@tonic-gate bcopy(&ip6->ip6_src, ph + 1, IPV6_ADDR_LEN);
9830Sstevel@tonic-gate } else {
9844818Skcpoon ipaddr = sctp_get_valid_addr(sctp, B_TRUE, &saddr_set);
985252Svi117747 /*
986252Svi117747 * All the addresses are down.
987252Svi117747 * Maybe we might have better luck next time.
988252Svi117747 */
9894818Skcpoon if (!saddr_set) {
990*13009SChandrasekar.Marimuthu@Sun.COM SCTP_FADDR_RC_TIMER_RESTART(sctp, fp,
991*13009SChandrasekar.Marimuthu@Sun.COM fp->sf_rto);
992252Svi117747 freeb(ipmp);
993252Svi117747 return;
994252Svi117747 }
9950Sstevel@tonic-gate bcopy(&ipaddr, ph + 1, IPV6_ADDR_LEN);
9960Sstevel@tonic-gate }
9970Sstevel@tonic-gate }
9980Sstevel@tonic-gate
9990Sstevel@tonic-gate /* Don't exceed CWND */
1000*13009SChandrasekar.Marimuthu@Sun.COM if ((MBLKL(mp) > (fp->sf_cwnd - fp->sf_suna)) ||
10010Sstevel@tonic-gate ((mp = dupb(sctp->sctp_cxmit_list)) == NULL)) {
1002*13009SChandrasekar.Marimuthu@Sun.COM SCTP_FADDR_RC_TIMER_RESTART(sctp, fp, fp->sf_rto);
10030Sstevel@tonic-gate freeb(ipmp);
10040Sstevel@tonic-gate return;
10050Sstevel@tonic-gate }
10060Sstevel@tonic-gate
10070Sstevel@tonic-gate /* Set the serial number now, if sending for the first time */
10080Sstevel@tonic-gate if (!SCTP_CHUNK_WANT_REXMIT(mp)) {
10090Sstevel@tonic-gate snp = (uint32_t *)(mp->b_rptr + sizeof (sctp_chunk_hdr_t));
10100Sstevel@tonic-gate *snp = htonl(sctp->sctp_lcsn++);
10110Sstevel@tonic-gate }
10120Sstevel@tonic-gate SCTP_CHUNK_CLEAR_FLAGS(mp);
1013*13009SChandrasekar.Marimuthu@Sun.COM fp->sf_suna += MBLKL(mp);
10140Sstevel@tonic-gate /* Attach the header and send the chunk */
10150Sstevel@tonic-gate ipmp->b_cont = mp;
10160Sstevel@tonic-gate sctp->sctp_cchunk_pend = 1;
10170Sstevel@tonic-gate
10180Sstevel@tonic-gate SCTP_SET_SENT_FLAG(sctp->sctp_cxmit_list);
10190Sstevel@tonic-gate SCTP_SET_CHUNK_DEST(sctp->sctp_cxmit_list, fp);
1020*13009SChandrasekar.Marimuthu@Sun.COM sctp_set_iplen(sctp, ipmp, fp->sf_ixa);
1021*13009SChandrasekar.Marimuthu@Sun.COM (void) conn_ip_output(ipmp, fp->sf_ixa);
102211042SErik.Nordmark@Sun.COM BUMP_LOCAL(sctp->sctp_opkts);
1023*13009SChandrasekar.Marimuthu@Sun.COM SCTP_FADDR_RC_TIMER_RESTART(sctp, fp, fp->sf_rto);
10240Sstevel@tonic-gate #undef SCTP_SET_SENT_FLAG
10250Sstevel@tonic-gate }
10260Sstevel@tonic-gate
10270Sstevel@tonic-gate /*
10280Sstevel@tonic-gate * Generate ASCONF error param, include errph, if present.
10290Sstevel@tonic-gate */
10300Sstevel@tonic-gate static mblk_t *
sctp_asconf_adderr(int err,sctp_parm_hdr_t * errph,uint32_t cid)10310Sstevel@tonic-gate sctp_asconf_adderr(int err, sctp_parm_hdr_t *errph, uint32_t cid)
10320Sstevel@tonic-gate {
10330Sstevel@tonic-gate mblk_t *mp;
10340Sstevel@tonic-gate sctp_parm_hdr_t *eph;
10350Sstevel@tonic-gate sctp_parm_hdr_t *wph;
10360Sstevel@tonic-gate size_t len;
10370Sstevel@tonic-gate size_t elen = 0;
10380Sstevel@tonic-gate
10390Sstevel@tonic-gate len = sizeof (*wph) + sizeof (*eph) + sizeof (cid);
10400Sstevel@tonic-gate if (errph != NULL) {
10410Sstevel@tonic-gate elen = ntohs(errph->sph_len);
10420Sstevel@tonic-gate len += elen;
10430Sstevel@tonic-gate }
10440Sstevel@tonic-gate mp = allocb(len, BPRI_MED);
10450Sstevel@tonic-gate if (mp == NULL) {
10460Sstevel@tonic-gate return (NULL);
10470Sstevel@tonic-gate }
10480Sstevel@tonic-gate wph = (sctp_parm_hdr_t *)mp->b_rptr;
10490Sstevel@tonic-gate /* error cause wrapper */
10500Sstevel@tonic-gate wph->sph_type = htons(PARM_ERROR_IND);
10510Sstevel@tonic-gate wph->sph_len = htons(len);
10520Sstevel@tonic-gate bcopy(&cid, wph + 1, sizeof (uint32_t));
10530Sstevel@tonic-gate
10540Sstevel@tonic-gate /* error cause */
10550Sstevel@tonic-gate eph = (sctp_parm_hdr_t *)((char *)wph + sizeof (sctp_parm_hdr_t) +
10560Sstevel@tonic-gate sizeof (cid));
10570Sstevel@tonic-gate eph->sph_type = htons(err);
10580Sstevel@tonic-gate eph->sph_len = htons(len - sizeof (*wph) - sizeof (cid));
10590Sstevel@tonic-gate mp->b_wptr = (uchar_t *)(eph + 1);
10600Sstevel@tonic-gate
10610Sstevel@tonic-gate /* details */
10620Sstevel@tonic-gate if (elen > 0) {
10630Sstevel@tonic-gate bcopy(errph, mp->b_wptr, elen);
10640Sstevel@tonic-gate mp->b_wptr += elen;
10650Sstevel@tonic-gate }
10660Sstevel@tonic-gate return (mp);
10670Sstevel@tonic-gate }
10680Sstevel@tonic-gate
10690Sstevel@tonic-gate static mblk_t *
sctp_check_addip_addr(sctp_parm_hdr_t * ph,sctp_parm_hdr_t * oph,int * cont,uint32_t cid,in6_addr_t * raddr)10700Sstevel@tonic-gate sctp_check_addip_addr(sctp_parm_hdr_t *ph, sctp_parm_hdr_t *oph, int *cont,
10710Sstevel@tonic-gate uint32_t cid, in6_addr_t *raddr)
10720Sstevel@tonic-gate {
10730Sstevel@tonic-gate uint16_t atype;
10740Sstevel@tonic-gate uint16_t alen;
10750Sstevel@tonic-gate mblk_t *mp;
10760Sstevel@tonic-gate in6_addr_t addr;
10770Sstevel@tonic-gate ipaddr_t *addr4;
10780Sstevel@tonic-gate
10790Sstevel@tonic-gate atype = ntohs(ph->sph_type);
10800Sstevel@tonic-gate alen = ntohs(ph->sph_len);
10810Sstevel@tonic-gate
10820Sstevel@tonic-gate if (atype != PARM_ADDR4 && atype != PARM_ADDR6) {
10830Sstevel@tonic-gate mp = sctp_asconf_adderr(SCTP_ERR_BAD_MANDPARM, oph, cid);
10840Sstevel@tonic-gate if (mp == NULL) {
10850Sstevel@tonic-gate *cont = -1;
10860Sstevel@tonic-gate }
10870Sstevel@tonic-gate return (mp);
10880Sstevel@tonic-gate }
10890Sstevel@tonic-gate if ((atype == PARM_ADDR4 && alen < PARM_ADDR4_LEN) ||
10900Sstevel@tonic-gate (atype == PARM_ADDR6 && alen < PARM_ADDR6_LEN)) {
10910Sstevel@tonic-gate mp = sctp_asconf_adderr(SCTP_ERR_BAD_MANDPARM, oph, cid);
10920Sstevel@tonic-gate if (mp == NULL) {
10930Sstevel@tonic-gate *cont = -1;
10940Sstevel@tonic-gate }
10950Sstevel@tonic-gate return (mp);
10960Sstevel@tonic-gate }
10970Sstevel@tonic-gate
10980Sstevel@tonic-gate /* Address parameter is present; extract and screen it */
10990Sstevel@tonic-gate if (atype == PARM_ADDR4) {
11000Sstevel@tonic-gate addr4 = (ipaddr_t *)(ph + 1);
11010Sstevel@tonic-gate IN6_IPADDR_TO_V4MAPPED(*addr4, &addr);
11020Sstevel@tonic-gate
11030Sstevel@tonic-gate /* screen XXX loopback to scoping */
11040Sstevel@tonic-gate if (*addr4 == 0 || *addr4 == INADDR_BROADCAST ||
11055215Skcpoon *addr4 == htonl(INADDR_LOOPBACK) || CLASSD(*addr4)) {
11060Sstevel@tonic-gate dprint(1, ("addip: addr not unicast: %x:%x:%x:%x\n",
11070Sstevel@tonic-gate SCTP_PRINTADDR(addr)));
11080Sstevel@tonic-gate mp = sctp_asconf_adderr(SCTP_ERR_BAD_MANDPARM, oph,
11090Sstevel@tonic-gate cid);
11100Sstevel@tonic-gate if (mp == NULL) {
11110Sstevel@tonic-gate *cont = -1;
11120Sstevel@tonic-gate }
11130Sstevel@tonic-gate return (mp);
11140Sstevel@tonic-gate }
11150Sstevel@tonic-gate /*
11160Sstevel@tonic-gate * XXX also need to check for subnet
11170Sstevel@tonic-gate * broadcasts. This should probably
11180Sstevel@tonic-gate * wait until we have full access
11190Sstevel@tonic-gate * to the ILL tables.
11200Sstevel@tonic-gate */
11210Sstevel@tonic-gate
11220Sstevel@tonic-gate } else {
11230Sstevel@tonic-gate bcopy(ph + 1, &addr, sizeof (addr));
11240Sstevel@tonic-gate
11250Sstevel@tonic-gate /* screen XXX loopback to scoping */
11260Sstevel@tonic-gate if (IN6_IS_ADDR_LINKLOCAL(&addr) ||
11270Sstevel@tonic-gate IN6_IS_ADDR_MULTICAST(&addr) ||
11280Sstevel@tonic-gate IN6_IS_ADDR_LOOPBACK(&addr)) {
11290Sstevel@tonic-gate dprint(1, ("addip: addr not unicast: %x:%x:%x:%x\n",
11300Sstevel@tonic-gate SCTP_PRINTADDR(addr)));
11310Sstevel@tonic-gate mp = sctp_asconf_adderr(SCTP_ERR_BAD_MANDPARM, oph,
11320Sstevel@tonic-gate cid);
11330Sstevel@tonic-gate if (mp == NULL) {
11340Sstevel@tonic-gate *cont = -1;
11350Sstevel@tonic-gate }
11360Sstevel@tonic-gate return (mp);
11370Sstevel@tonic-gate }
11380Sstevel@tonic-gate
11390Sstevel@tonic-gate }
11400Sstevel@tonic-gate
11410Sstevel@tonic-gate /* OK */
11420Sstevel@tonic-gate *raddr = addr;
11430Sstevel@tonic-gate return (NULL);
11440Sstevel@tonic-gate }
11450Sstevel@tonic-gate
11460Sstevel@tonic-gate /*
11470Sstevel@tonic-gate * Handles both add and delete address requests.
11480Sstevel@tonic-gate */
11490Sstevel@tonic-gate static mblk_t *
sctp_addip_req(sctp_t * sctp,sctp_parm_hdr_t * ph,uint32_t cid,sctp_faddr_t * fp,int * cont,int act,in6_addr_t * raddr)11500Sstevel@tonic-gate sctp_addip_req(sctp_t *sctp, sctp_parm_hdr_t *ph, uint32_t cid,
1151852Svi117747 sctp_faddr_t *fp, int *cont, int act, in6_addr_t *raddr)
11520Sstevel@tonic-gate {
11530Sstevel@tonic-gate in6_addr_t addr;
11540Sstevel@tonic-gate uint16_t type;
11550Sstevel@tonic-gate mblk_t *mp;
11560Sstevel@tonic-gate sctp_faddr_t *nfp;
11571676Sjpk sctp_parm_hdr_t *oph = ph;
11581676Sjpk int err;
11593448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps;
11600Sstevel@tonic-gate
11610Sstevel@tonic-gate *cont = 1;
11620Sstevel@tonic-gate
11630Sstevel@tonic-gate /* Send back an authorization error if addip is disabled */
11643448Sdh155122 if (!sctps->sctps_addip_enabled) {
11651676Sjpk err = SCTP_ERR_UNAUTHORIZED;
11661676Sjpk goto error_handler;
11670Sstevel@tonic-gate }
11680Sstevel@tonic-gate /* Check input */
11690Sstevel@tonic-gate if (ntohs(ph->sph_len) < (sizeof (*ph) * 2)) {
11701676Sjpk err = SCTP_ERR_BAD_MANDPARM;
11711676Sjpk goto error_handler;
11720Sstevel@tonic-gate }
11730Sstevel@tonic-gate
11740Sstevel@tonic-gate type = ntohs(ph->sph_type);
11750Sstevel@tonic-gate ph = (sctp_parm_hdr_t *)((char *)ph + sizeof (sctp_parm_hdr_t) +
11760Sstevel@tonic-gate sizeof (cid));
11770Sstevel@tonic-gate mp = sctp_check_addip_addr(ph, oph, cont, cid, &addr);
11780Sstevel@tonic-gate if (mp != NULL)
11790Sstevel@tonic-gate return (mp);
1180852Svi117747 if (raddr != NULL)
1181852Svi117747 *raddr = addr;
11820Sstevel@tonic-gate if (type == PARM_ADD_IP) {
11830Sstevel@tonic-gate if (sctp_lookup_faddr(sctp, &addr) != NULL) {
11840Sstevel@tonic-gate /* Address is already part of association */
11850Sstevel@tonic-gate dprint(1, ("addip: addr already here: %x:%x:%x:%x\n",
11860Sstevel@tonic-gate SCTP_PRINTADDR(addr)));
11871676Sjpk err = SCTP_ERR_BAD_MANDPARM;
11881676Sjpk goto error_handler;
11890Sstevel@tonic-gate }
11900Sstevel@tonic-gate
11910Sstevel@tonic-gate if (!act) {
11920Sstevel@tonic-gate return (NULL);
11930Sstevel@tonic-gate }
11940Sstevel@tonic-gate /* Add the new address */
11950Sstevel@tonic-gate mutex_enter(&sctp->sctp_conn_tfp->tf_lock);
11961735Skcpoon err = sctp_add_faddr(sctp, &addr, KM_NOSLEEP, B_FALSE);
11971676Sjpk mutex_exit(&sctp->sctp_conn_tfp->tf_lock);
11981676Sjpk if (err == ENOMEM) {
11990Sstevel@tonic-gate /* no memory */
12000Sstevel@tonic-gate *cont = -1;
12010Sstevel@tonic-gate return (NULL);
12020Sstevel@tonic-gate }
12031676Sjpk if (err != 0) {
12041676Sjpk err = SCTP_ERR_BAD_MANDPARM;
12051676Sjpk goto error_handler;
12061676Sjpk }
12070Sstevel@tonic-gate sctp_intf_event(sctp, addr, SCTP_ADDR_ADDED, 0);
12080Sstevel@tonic-gate } else if (type == PARM_DEL_IP) {
12090Sstevel@tonic-gate nfp = sctp_lookup_faddr(sctp, &addr);
12100Sstevel@tonic-gate if (nfp == NULL) {
12110Sstevel@tonic-gate /*
12120Sstevel@tonic-gate * Peer is trying to delete an address that is not
12130Sstevel@tonic-gate * part of the association.
12140Sstevel@tonic-gate */
12150Sstevel@tonic-gate dprint(1, ("delip: addr not here: %x:%x:%x:%x\n",
12160Sstevel@tonic-gate SCTP_PRINTADDR(addr)));
12171676Sjpk err = SCTP_ERR_BAD_MANDPARM;
12181676Sjpk goto error_handler;
12190Sstevel@tonic-gate }
1220*13009SChandrasekar.Marimuthu@Sun.COM if (sctp->sctp_faddrs == nfp && nfp->sf_next == NULL) {
12210Sstevel@tonic-gate /* Peer is trying to delete last address */
12220Sstevel@tonic-gate dprint(1, ("delip: del last addr: %x:%x:%x:%x\n",
12230Sstevel@tonic-gate SCTP_PRINTADDR(addr)));
12241676Sjpk err = SCTP_ERR_DEL_LAST_ADDR;
12251676Sjpk goto error_handler;
12260Sstevel@tonic-gate }
12270Sstevel@tonic-gate if (nfp == fp) {
12280Sstevel@tonic-gate /* Peer is trying to delete source address */
12290Sstevel@tonic-gate dprint(1, ("delip: del src addr: %x:%x:%x:%x\n",
12300Sstevel@tonic-gate SCTP_PRINTADDR(addr)));
12311676Sjpk err = SCTP_ERR_DEL_SRC_ADDR;
12321676Sjpk goto error_handler;
12330Sstevel@tonic-gate }
12340Sstevel@tonic-gate if (!act) {
12350Sstevel@tonic-gate return (NULL);
12360Sstevel@tonic-gate }
12370Sstevel@tonic-gate
12380Sstevel@tonic-gate sctp_unlink_faddr(sctp, nfp);
12390Sstevel@tonic-gate /* Update all references to the deleted faddr */
12400Sstevel@tonic-gate if (sctp->sctp_primary == nfp) {
12410Sstevel@tonic-gate sctp->sctp_primary = fp;
12420Sstevel@tonic-gate }
12430Sstevel@tonic-gate if (sctp->sctp_current == nfp) {
12441735Skcpoon sctp_set_faddr_current(sctp, fp);
12450Sstevel@tonic-gate }
12460Sstevel@tonic-gate if (sctp->sctp_lastdata == nfp) {
12470Sstevel@tonic-gate sctp->sctp_lastdata = fp;
12480Sstevel@tonic-gate }
12490Sstevel@tonic-gate if (sctp->sctp_shutdown_faddr == nfp) {
12500Sstevel@tonic-gate sctp->sctp_shutdown_faddr = nfp;
12510Sstevel@tonic-gate }
12520Sstevel@tonic-gate if (sctp->sctp_lastfaddr == nfp) {
1253*13009SChandrasekar.Marimuthu@Sun.COM for (fp = sctp->sctp_faddrs; fp->sf_next;
1254*13009SChandrasekar.Marimuthu@Sun.COM fp = fp->sf_next)
12550Sstevel@tonic-gate ;
12560Sstevel@tonic-gate sctp->sctp_lastfaddr = fp;
12570Sstevel@tonic-gate }
12580Sstevel@tonic-gate sctp_intf_event(sctp, addr, SCTP_ADDR_REMOVED, 0);
12590Sstevel@tonic-gate } else {
12600Sstevel@tonic-gate ASSERT(0);
12610Sstevel@tonic-gate }
12620Sstevel@tonic-gate
12630Sstevel@tonic-gate /* Successful, don't need to return anything. */
12640Sstevel@tonic-gate return (NULL);
12651676Sjpk
12661676Sjpk error_handler:
12671676Sjpk mp = sctp_asconf_adderr(err, oph, cid);
12681676Sjpk if (mp == NULL)
12691676Sjpk *cont = -1;
12701676Sjpk return (mp);
12710Sstevel@tonic-gate }
12720Sstevel@tonic-gate
12730Sstevel@tonic-gate /*
12740Sstevel@tonic-gate * Handles both add and delete IP ACKs.
12750Sstevel@tonic-gate */
12760Sstevel@tonic-gate /*ARGSUSED*/
12770Sstevel@tonic-gate static void
sctp_addip_ack(sctp_t * sctp,sctp_parm_hdr_t * ph,sctp_parm_hdr_t * oph,sctp_faddr_t * fp,in6_addr_t * laddr)12780Sstevel@tonic-gate sctp_addip_ack(sctp_t *sctp, sctp_parm_hdr_t *ph, sctp_parm_hdr_t *oph,
1279852Svi117747 sctp_faddr_t *fp, in6_addr_t *laddr)
12800Sstevel@tonic-gate {
12810Sstevel@tonic-gate in6_addr_t addr;
12820Sstevel@tonic-gate sctp_saddr_ipif_t *sp;
12830Sstevel@tonic-gate ipaddr_t *addr4;
12840Sstevel@tonic-gate boolean_t backout = B_FALSE;
12850Sstevel@tonic-gate uint16_t type;
12860Sstevel@tonic-gate uint32_t *cid;
12870Sstevel@tonic-gate
1288852Svi117747 /* could be an ASSERT */
1289852Svi117747 if (laddr != NULL)
1290852Svi117747 IN6_IPADDR_TO_V4MAPPED(0, laddr);
1291852Svi117747
12920Sstevel@tonic-gate /* If the peer doesn't understand Add-IP, remember it */
12930Sstevel@tonic-gate if (ph != NULL && ph->sph_type == htons(PARM_UNRECOGNIZED)) {
12940Sstevel@tonic-gate sctp->sctp_understands_addip = B_FALSE;
12950Sstevel@tonic-gate backout = B_TRUE;
12960Sstevel@tonic-gate }
12970Sstevel@tonic-gate
12980Sstevel@tonic-gate /*
12990Sstevel@tonic-gate * If OK, continue with the add / delete action, otherwise
13000Sstevel@tonic-gate * back out the action.
13010Sstevel@tonic-gate */
13020Sstevel@tonic-gate if (ph != NULL && ph->sph_type != htons(PARM_SUCCESS)) {
13030Sstevel@tonic-gate backout = B_TRUE;
130411953Sanil.udupa@sun.com sctp_error_event(sctp, (sctp_chunk_hdr_t *)ph, B_TRUE);
13050Sstevel@tonic-gate }
13060Sstevel@tonic-gate
13070Sstevel@tonic-gate type = ntohs(oph->sph_type);
13080Sstevel@tonic-gate cid = (uint32_t *)(oph + 1);
13090Sstevel@tonic-gate oph = (sctp_parm_hdr_t *)(cid + 1);
13100Sstevel@tonic-gate if (oph->sph_type == htons(PARM_ADDR4)) {
13110Sstevel@tonic-gate addr4 = (ipaddr_t *)(oph + 1);
13120Sstevel@tonic-gate IN6_IPADDR_TO_V4MAPPED(*addr4, &addr);
13130Sstevel@tonic-gate } else {
13140Sstevel@tonic-gate bcopy(oph + 1, &addr, sizeof (addr));
13150Sstevel@tonic-gate }
13160Sstevel@tonic-gate
1317852Svi117747 /* Signifies that the address was sucessfully processed */
1318852Svi117747 if (!backout && laddr != NULL)
1319852Svi117747 *laddr = addr;
1320852Svi117747
1321852Svi117747 sp = sctp_saddr_lookup(sctp, &addr, 0);
13220Sstevel@tonic-gate ASSERT(sp != NULL);
13230Sstevel@tonic-gate
13240Sstevel@tonic-gate if (type == PARM_ADD_IP) {
13250Sstevel@tonic-gate if (backout) {
13260Sstevel@tonic-gate sctp_del_saddr(sctp, sp);
13270Sstevel@tonic-gate } else {
13280Sstevel@tonic-gate sp->saddr_ipif_dontsrc = 0;
13290Sstevel@tonic-gate }
13300Sstevel@tonic-gate } else if (type == PARM_DEL_IP) {
13310Sstevel@tonic-gate if (backout) {
13320Sstevel@tonic-gate sp->saddr_ipif_delete_pending = 0;
13330Sstevel@tonic-gate sp->saddr_ipif_dontsrc = 0;
13340Sstevel@tonic-gate } else {
13350Sstevel@tonic-gate sctp_del_saddr(sctp, sp);
13360Sstevel@tonic-gate }
13370Sstevel@tonic-gate } else {
13380Sstevel@tonic-gate /* Must be either PARM_ADD_IP or PARM_DEL_IP */
13390Sstevel@tonic-gate ASSERT(0);
13400Sstevel@tonic-gate }
13410Sstevel@tonic-gate }
13420Sstevel@tonic-gate
13430Sstevel@tonic-gate /*ARGSUSED*/
13440Sstevel@tonic-gate static mblk_t *
sctp_setprim_req(sctp_t * sctp,sctp_parm_hdr_t * ph,uint32_t cid,sctp_faddr_t * fp,int * cont,int act,in6_addr_t * raddr)13450Sstevel@tonic-gate sctp_setprim_req(sctp_t *sctp, sctp_parm_hdr_t *ph, uint32_t cid,
1346852Svi117747 sctp_faddr_t *fp, int *cont, int act, in6_addr_t *raddr)
13470Sstevel@tonic-gate {
13480Sstevel@tonic-gate mblk_t *mp;
13490Sstevel@tonic-gate sctp_parm_hdr_t *oph;
13500Sstevel@tonic-gate sctp_faddr_t *nfp;
13510Sstevel@tonic-gate in6_addr_t addr;
13520Sstevel@tonic-gate
13530Sstevel@tonic-gate *cont = 1;
13540Sstevel@tonic-gate
135511953Sanil.udupa@sun.com /* Does the peer understand ASCONF and Add-IP? */
135611953Sanil.udupa@sun.com if (!sctp->sctp_understands_asconf || !sctp->sctp_understands_addip) {
135711953Sanil.udupa@sun.com mp = sctp_asconf_adderr(SCTP_ERR_UNAUTHORIZED, ph, cid);
135811953Sanil.udupa@sun.com if (mp == NULL) {
135911953Sanil.udupa@sun.com *cont = -1;
136011953Sanil.udupa@sun.com }
136111953Sanil.udupa@sun.com return (mp);
136211953Sanil.udupa@sun.com }
136311953Sanil.udupa@sun.com
13640Sstevel@tonic-gate /* Check input */
13650Sstevel@tonic-gate if (ntohs(ph->sph_len) < (sizeof (*ph) * 2)) {
13660Sstevel@tonic-gate mp = sctp_asconf_adderr(SCTP_ERR_BAD_MANDPARM, ph, cid);
13670Sstevel@tonic-gate if (mp == NULL) {
13680Sstevel@tonic-gate *cont = -1;
13690Sstevel@tonic-gate }
13700Sstevel@tonic-gate return (mp);
13710Sstevel@tonic-gate }
13720Sstevel@tonic-gate
13730Sstevel@tonic-gate oph = ph;
13740Sstevel@tonic-gate ph = (sctp_parm_hdr_t *)((char *)ph + sizeof (sctp_parm_hdr_t) +
13750Sstevel@tonic-gate sizeof (cid));
13760Sstevel@tonic-gate mp = sctp_check_addip_addr(ph, oph, cont, cid, &addr);
13770Sstevel@tonic-gate if (mp != NULL) {
13780Sstevel@tonic-gate return (mp);
13790Sstevel@tonic-gate }
13800Sstevel@tonic-gate
13810Sstevel@tonic-gate nfp = sctp_lookup_faddr(sctp, &addr);
13820Sstevel@tonic-gate if (nfp == NULL) {
13830Sstevel@tonic-gate /*
13840Sstevel@tonic-gate * Peer is trying to set an address that is not
13850Sstevel@tonic-gate * part of the association.
13860Sstevel@tonic-gate */
13870Sstevel@tonic-gate dprint(1, ("setprim: addr not here: %x:%x:%x:%x\n",
13880Sstevel@tonic-gate SCTP_PRINTADDR(addr)));
13890Sstevel@tonic-gate mp = sctp_asconf_adderr(SCTP_ERR_BAD_MANDPARM, oph, cid);
13900Sstevel@tonic-gate if (mp == NULL) {
13910Sstevel@tonic-gate *cont = -1;
13920Sstevel@tonic-gate }
13930Sstevel@tonic-gate return (mp);
13940Sstevel@tonic-gate }
13950Sstevel@tonic-gate
13960Sstevel@tonic-gate sctp_intf_event(sctp, addr, SCTP_ADDR_MADE_PRIM, 0);
13970Sstevel@tonic-gate sctp->sctp_primary = nfp;
1398*13009SChandrasekar.Marimuthu@Sun.COM if (nfp->sf_state != SCTP_FADDRS_ALIVE || nfp == sctp->sctp_current) {
13990Sstevel@tonic-gate return (NULL);
14000Sstevel@tonic-gate }
14011735Skcpoon sctp_set_faddr_current(sctp, nfp);
14020Sstevel@tonic-gate return (NULL);
14030Sstevel@tonic-gate }
14040Sstevel@tonic-gate
14050Sstevel@tonic-gate /*ARGSUSED*/
14060Sstevel@tonic-gate static void
sctp_setprim_ack(sctp_t * sctp,sctp_parm_hdr_t * ph,sctp_parm_hdr_t * oph,sctp_faddr_t * fp,in6_addr_t * laddr)14070Sstevel@tonic-gate sctp_setprim_ack(sctp_t *sctp, sctp_parm_hdr_t *ph, sctp_parm_hdr_t *oph,
1408852Svi117747 sctp_faddr_t *fp, in6_addr_t *laddr)
14090Sstevel@tonic-gate {
14100Sstevel@tonic-gate if (ph != NULL && ph->sph_type != htons(PARM_SUCCESS)) {
14110Sstevel@tonic-gate /* If the peer doesn't understand Add-IP, remember it */
14120Sstevel@tonic-gate if (ph->sph_type == htons(PARM_UNRECOGNIZED)) {
14130Sstevel@tonic-gate sctp->sctp_understands_addip = B_FALSE;
14140Sstevel@tonic-gate }
141511953Sanil.udupa@sun.com sctp_error_event(sctp, (sctp_chunk_hdr_t *)ph, B_TRUE);
14160Sstevel@tonic-gate }
14170Sstevel@tonic-gate
14180Sstevel@tonic-gate /* On success we do nothing */
14190Sstevel@tonic-gate }
14200Sstevel@tonic-gate
14210Sstevel@tonic-gate int
sctp_add_ip(sctp_t * sctp,const void * addrs,uint32_t cnt)14220Sstevel@tonic-gate sctp_add_ip(sctp_t *sctp, const void *addrs, uint32_t cnt)
14230Sstevel@tonic-gate {
14240Sstevel@tonic-gate struct sockaddr_in *sin4;
14250Sstevel@tonic-gate struct sockaddr_in6 *sin6;
14260Sstevel@tonic-gate mblk_t *mp;
14270Sstevel@tonic-gate int error = 0;
14280Sstevel@tonic-gate int i;
14290Sstevel@tonic-gate sctp_addip4_t *ad4;
14300Sstevel@tonic-gate sctp_addip6_t *ad6;
14310Sstevel@tonic-gate sctp_asconf_t asc[1];
14320Sstevel@tonic-gate uint16_t type = htons(PARM_ADD_IP);
14330Sstevel@tonic-gate boolean_t v4mapped = B_FALSE;
1434852Svi117747 sctp_cl_ainfo_t *ainfo = NULL;
143511042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp;
14360Sstevel@tonic-gate
14370Sstevel@tonic-gate /* Does the peer understand ASCONF and Add-IP? */
14380Sstevel@tonic-gate if (!sctp->sctp_understands_asconf || !sctp->sctp_understands_addip)
14390Sstevel@tonic-gate return (EOPNOTSUPP);
14400Sstevel@tonic-gate
1441852Svi117747 /*
1442852Svi117747 * On a clustered node, we need to pass this list when
1443852Svi117747 * we get an ASCONF-ACK. We only pre-allocate memory for the
1444852Svi117747 * list, but fill in the addresses when it is processed
1445852Svi117747 * successfully after we get an ASCONF-ACK.
1446852Svi117747 */
1447852Svi117747 if (cl_sctp_assoc_change != NULL) {
1448852Svi117747 ainfo = kmem_zalloc(sizeof (*ainfo), KM_SLEEP);
1449852Svi117747 /*
1450852Svi117747 * Reserve space for the list of new addresses
1451852Svi117747 */
1452852Svi117747 ainfo->sctp_cl_asize = sizeof (in6_addr_t) * cnt;
1453852Svi117747 ainfo->sctp_cl_alist = kmem_alloc(ainfo->sctp_cl_asize,
1454852Svi117747 KM_SLEEP);
1455852Svi117747 }
1456852Svi117747
14570Sstevel@tonic-gate sctp_asconf_init(asc);
14580Sstevel@tonic-gate
14590Sstevel@tonic-gate /*
14600Sstevel@tonic-gate * Screen addresses:
14610Sstevel@tonic-gate * If adding:
14620Sstevel@tonic-gate * o Must not already be a part of the association
14630Sstevel@tonic-gate * o Must be AF_INET or AF_INET6
14640Sstevel@tonic-gate * o XXX Must be valid source address for this node
14650Sstevel@tonic-gate * o Must be unicast
14660Sstevel@tonic-gate * o XXX Must fit scoping rules
14670Sstevel@tonic-gate * If deleting:
14680Sstevel@tonic-gate * o Must be part of the association
14690Sstevel@tonic-gate */
14700Sstevel@tonic-gate for (i = 0; i < cnt; i++) {
147111042SErik.Nordmark@Sun.COM switch (connp->conn_family) {
14720Sstevel@tonic-gate case AF_INET:
14730Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + i;
14740Sstevel@tonic-gate v4mapped = B_TRUE;
14750Sstevel@tonic-gate break;
14760Sstevel@tonic-gate
14770Sstevel@tonic-gate case AF_INET6:
14780Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + i;
14790Sstevel@tonic-gate break;
14800Sstevel@tonic-gate }
14810Sstevel@tonic-gate
14820Sstevel@tonic-gate if (v4mapped) {
14830Sstevel@tonic-gate mp = allocb(sizeof (*ad4), BPRI_MED);
14840Sstevel@tonic-gate if (mp == NULL) {
14850Sstevel@tonic-gate error = ENOMEM;
14860Sstevel@tonic-gate goto fail;
14870Sstevel@tonic-gate }
14880Sstevel@tonic-gate mp->b_wptr += sizeof (*ad4);
14890Sstevel@tonic-gate ad4 = (sctp_addip4_t *)mp->b_rptr;
14900Sstevel@tonic-gate ad4->sad4_addip_ph.sph_type = type;
14910Sstevel@tonic-gate ad4->sad4_addip_ph.sph_len =
14920Sstevel@tonic-gate htons(sizeof (sctp_parm_hdr_t) +
14930Sstevel@tonic-gate PARM_ADDR4_LEN + sizeof (ad4->asconf_req_cid));
14940Sstevel@tonic-gate ad4->sad4_addr4_ph.sph_type = htons(PARM_ADDR4);
14950Sstevel@tonic-gate ad4->sad4_addr4_ph.sph_len = htons(PARM_ADDR4_LEN);
14960Sstevel@tonic-gate ad4->sad4_addr = sin4->sin_addr.s_addr;
14970Sstevel@tonic-gate } else {
14980Sstevel@tonic-gate mp = allocb(sizeof (*ad6), BPRI_MED);
14990Sstevel@tonic-gate if (mp == NULL) {
15000Sstevel@tonic-gate error = ENOMEM;
15010Sstevel@tonic-gate goto fail;
15020Sstevel@tonic-gate }
15030Sstevel@tonic-gate mp->b_wptr += sizeof (*ad6);
15040Sstevel@tonic-gate ad6 = (sctp_addip6_t *)mp->b_rptr;
15050Sstevel@tonic-gate ad6->sad6_addip_ph.sph_type = type;
15060Sstevel@tonic-gate ad6->sad6_addip_ph.sph_len =
15070Sstevel@tonic-gate htons(sizeof (sctp_parm_hdr_t) +
15080Sstevel@tonic-gate PARM_ADDR6_LEN + sizeof (ad6->asconf_req_cid));
15090Sstevel@tonic-gate ad6->sad6_addr6_ph.sph_type = htons(PARM_ADDR6);
15100Sstevel@tonic-gate ad6->sad6_addr6_ph.sph_len = htons(PARM_ADDR6_LEN);
15110Sstevel@tonic-gate ad6->sad6_addr = sin6->sin6_addr;
15120Sstevel@tonic-gate }
15130Sstevel@tonic-gate error = sctp_asconf_add(asc, mp);
15140Sstevel@tonic-gate if (error != 0)
15150Sstevel@tonic-gate goto fail;
15160Sstevel@tonic-gate }
1517852Svi117747 error = sctp_asconf_send(sctp, asc, sctp->sctp_current, ainfo);
15180Sstevel@tonic-gate if (error != 0)
15190Sstevel@tonic-gate goto fail;
15200Sstevel@tonic-gate
15210Sstevel@tonic-gate return (0);
15220Sstevel@tonic-gate
15230Sstevel@tonic-gate fail:
1524852Svi117747 if (ainfo != NULL) {
1525852Svi117747 kmem_free(ainfo->sctp_cl_alist, ainfo->sctp_cl_asize);
1526852Svi117747 ainfo->sctp_cl_asize = 0;
1527852Svi117747 kmem_free(ainfo, sizeof (*ainfo));
1528852Svi117747 }
15290Sstevel@tonic-gate sctp_asconf_destroy(asc);
15300Sstevel@tonic-gate return (error);
15310Sstevel@tonic-gate }
15320Sstevel@tonic-gate
15330Sstevel@tonic-gate int
sctp_del_ip(sctp_t * sctp,const void * addrs,uint32_t cnt,uchar_t * ulist,size_t usize)1534852Svi117747 sctp_del_ip(sctp_t *sctp, const void *addrs, uint32_t cnt, uchar_t *ulist,
1535852Svi117747 size_t usize)
15360Sstevel@tonic-gate {
15370Sstevel@tonic-gate struct sockaddr_in *sin4;
15380Sstevel@tonic-gate struct sockaddr_in6 *sin6;
15390Sstevel@tonic-gate mblk_t *mp;
15400Sstevel@tonic-gate int error = 0;
15410Sstevel@tonic-gate int i;
15420Sstevel@tonic-gate int addrcnt = 0;
15430Sstevel@tonic-gate sctp_addip4_t *ad4;
15440Sstevel@tonic-gate sctp_addip6_t *ad6;
15450Sstevel@tonic-gate sctp_asconf_t asc[1];
15460Sstevel@tonic-gate sctp_saddr_ipif_t *nsp;
15470Sstevel@tonic-gate uint16_t type = htons(PARM_DEL_IP);
15480Sstevel@tonic-gate boolean_t v4mapped = B_FALSE;
15490Sstevel@tonic-gate in6_addr_t addr;
15500Sstevel@tonic-gate boolean_t asconf = B_TRUE;
1551852Svi117747 uint_t ifindex;
1552852Svi117747 sctp_cl_ainfo_t *ainfo = NULL;
1553852Svi117747 uchar_t *p = ulist;
1554852Svi117747 boolean_t check_lport = B_FALSE;
15553448Sdh155122 sctp_stack_t *sctps = sctp->sctp_sctps;
155611042SErik.Nordmark@Sun.COM conn_t *connp = sctp->sctp_connp;
15570Sstevel@tonic-gate
15580Sstevel@tonic-gate /* Does the peer understand ASCONF and Add-IP? */
15593448Sdh155122 if (sctp->sctp_state <= SCTPS_LISTEN || !sctps->sctps_addip_enabled ||
15600Sstevel@tonic-gate !sctp->sctp_understands_asconf || !sctp->sctp_understands_addip) {
15610Sstevel@tonic-gate asconf = B_FALSE;
15620Sstevel@tonic-gate }
15630Sstevel@tonic-gate
1564852Svi117747 if (sctp->sctp_state > SCTPS_BOUND)
1565852Svi117747 check_lport = B_TRUE;
1566852Svi117747
1567852Svi117747 if (asconf) {
1568852Svi117747 /*
1569852Svi117747 * On a clustered node, we need to pass this list when
1570852Svi117747 * we get an ASCONF-ACK. We only pre-allocate memory for the
1571852Svi117747 * list, but fill in the addresses when it is processed
1572852Svi117747 * successfully after we get an ASCONF-ACK.
1573852Svi117747 */
1574852Svi117747 if (cl_sctp_assoc_change != NULL) {
1575852Svi117747 ainfo = kmem_alloc(sizeof (*ainfo), KM_SLEEP);
1576852Svi117747 ainfo->sctp_cl_dsize = sizeof (in6_addr_t) * cnt;
1577852Svi117747 ainfo->sctp_cl_dlist = kmem_alloc(ainfo->sctp_cl_dsize,
1578852Svi117747 KM_SLEEP);
1579852Svi117747 }
15800Sstevel@tonic-gate sctp_asconf_init(asc);
1581852Svi117747 }
15820Sstevel@tonic-gate /*
15830Sstevel@tonic-gate * Screen addresses:
15840Sstevel@tonic-gate * If adding:
15850Sstevel@tonic-gate * o Must not already be a part of the association
15860Sstevel@tonic-gate * o Must be AF_INET or AF_INET6
15870Sstevel@tonic-gate * o XXX Must be valid source address for this node
15880Sstevel@tonic-gate * o Must be unicast
15890Sstevel@tonic-gate * o XXX Must fit scoping rules
15900Sstevel@tonic-gate * If deleting:
15910Sstevel@tonic-gate * o Must be part of the association
15920Sstevel@tonic-gate */
15930Sstevel@tonic-gate for (i = 0; i < cnt; i++) {
1594852Svi117747 ifindex = 0;
1595852Svi117747
159611042SErik.Nordmark@Sun.COM switch (connp->conn_family) {
15970Sstevel@tonic-gate case AF_INET:
15980Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + i;
159911042SErik.Nordmark@Sun.COM if (check_lport &&
160011042SErik.Nordmark@Sun.COM sin4->sin_port != connp->conn_lport) {
1601852Svi117747 error = EINVAL;
1602852Svi117747 goto fail;
1603852Svi117747 }
16040Sstevel@tonic-gate v4mapped = B_TRUE;
16050Sstevel@tonic-gate IN6_IPADDR_TO_V4MAPPED(sin4->sin_addr.s_addr, &addr);
16060Sstevel@tonic-gate break;
16070Sstevel@tonic-gate
16080Sstevel@tonic-gate case AF_INET6:
16090Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + i;
1610852Svi117747 if (check_lport &&
161111042SErik.Nordmark@Sun.COM sin6->sin6_port != connp->conn_lport) {
1612852Svi117747 error = EINVAL;
1613852Svi117747 goto fail;
1614852Svi117747 }
16150Sstevel@tonic-gate addr = sin6->sin6_addr;
1616852Svi117747 ifindex = sin6->sin6_scope_id;
16170Sstevel@tonic-gate break;
16180Sstevel@tonic-gate }
1619852Svi117747 nsp = sctp_saddr_lookup(sctp, &addr, ifindex);
16200Sstevel@tonic-gate if (nsp == NULL) {
16210Sstevel@tonic-gate error = EADDRNOTAVAIL;
16220Sstevel@tonic-gate goto fail;
16230Sstevel@tonic-gate }
16240Sstevel@tonic-gate
1625852Svi117747 /* Collect the list of addresses, if required */
1626852Svi117747 if (usize >= sizeof (addr)) {
1627852Svi117747 bcopy(&addr, p, sizeof (addr));
1628852Svi117747 p += sizeof (addr);
1629852Svi117747 usize -= sizeof (addr);
1630852Svi117747 }
16310Sstevel@tonic-gate if (!asconf)
16320Sstevel@tonic-gate continue;
16330Sstevel@tonic-gate
16340Sstevel@tonic-gate nsp->saddr_ipif_delete_pending = 1;
16350Sstevel@tonic-gate nsp->saddr_ipif_dontsrc = 1;
16360Sstevel@tonic-gate addrcnt++;
16370Sstevel@tonic-gate if (v4mapped) {
16380Sstevel@tonic-gate mp = allocb(sizeof (*ad4), BPRI_MED);
16390Sstevel@tonic-gate if (mp == NULL) {
16400Sstevel@tonic-gate error = ENOMEM;
16410Sstevel@tonic-gate goto fail;
16420Sstevel@tonic-gate }
16430Sstevel@tonic-gate mp->b_wptr += sizeof (*ad4);
16440Sstevel@tonic-gate ad4 = (sctp_addip4_t *)mp->b_rptr;
16450Sstevel@tonic-gate ad4->sad4_addip_ph.sph_type = type;
16460Sstevel@tonic-gate ad4->sad4_addip_ph.sph_len =
16470Sstevel@tonic-gate htons(sizeof (sctp_parm_hdr_t) +
16480Sstevel@tonic-gate PARM_ADDR4_LEN + sizeof (ad4->asconf_req_cid));
16490Sstevel@tonic-gate ad4->sad4_addr4_ph.sph_type = htons(PARM_ADDR4);
16500Sstevel@tonic-gate ad4->sad4_addr4_ph.sph_len = htons(PARM_ADDR4_LEN);
16510Sstevel@tonic-gate ad4->sad4_addr = sin4->sin_addr.s_addr;
16520Sstevel@tonic-gate } else {
16530Sstevel@tonic-gate mp = allocb(sizeof (*ad6), BPRI_MED);
16540Sstevel@tonic-gate if (mp == NULL) {
16550Sstevel@tonic-gate error = ENOMEM;
16560Sstevel@tonic-gate goto fail;
16570Sstevel@tonic-gate }
16580Sstevel@tonic-gate mp->b_wptr += sizeof (*ad6);
16590Sstevel@tonic-gate ad6 = (sctp_addip6_t *)mp->b_rptr;
16600Sstevel@tonic-gate ad6->sad6_addip_ph.sph_type = type;
16610Sstevel@tonic-gate ad6->sad6_addip_ph.sph_len =
16620Sstevel@tonic-gate htons(sizeof (sctp_parm_hdr_t) + PARM_ADDR6_LEN +
16630Sstevel@tonic-gate sizeof (ad6->asconf_req_cid));
16640Sstevel@tonic-gate ad6->sad6_addr6_ph.sph_type = htons(PARM_ADDR6);
16650Sstevel@tonic-gate ad6->sad6_addr6_ph.sph_len = htons(PARM_ADDR6_LEN);
16660Sstevel@tonic-gate ad6->sad6_addr = addr;
16670Sstevel@tonic-gate }
16680Sstevel@tonic-gate
16690Sstevel@tonic-gate error = sctp_asconf_add(asc, mp);
16700Sstevel@tonic-gate if (error != 0)
16710Sstevel@tonic-gate goto fail;
16720Sstevel@tonic-gate }
16730Sstevel@tonic-gate
16740Sstevel@tonic-gate if (!asconf) {
16750Sstevel@tonic-gate sctp_del_saddr_list(sctp, addrs, cnt, B_FALSE);
16760Sstevel@tonic-gate return (0);
16770Sstevel@tonic-gate }
1678852Svi117747 error = sctp_asconf_send(sctp, asc, sctp->sctp_current, ainfo);
16790Sstevel@tonic-gate if (error != 0)
16800Sstevel@tonic-gate goto fail;
16810Sstevel@tonic-gate sctp_redo_faddr_srcs(sctp);
16820Sstevel@tonic-gate return (0);
16830Sstevel@tonic-gate
16840Sstevel@tonic-gate fail:
1685852Svi117747 if (ainfo != NULL) {
1686852Svi117747 kmem_free(ainfo->sctp_cl_dlist, ainfo->sctp_cl_dsize);
1687852Svi117747 ainfo->sctp_cl_dsize = 0;
1688852Svi117747 kmem_free(ainfo, sizeof (*ainfo));
1689852Svi117747 }
16900Sstevel@tonic-gate if (!asconf)
16910Sstevel@tonic-gate return (error);
16920Sstevel@tonic-gate for (i = 0; i < addrcnt; i++) {
1693852Svi117747 ifindex = 0;
1694852Svi117747
169511042SErik.Nordmark@Sun.COM switch (connp->conn_family) {
16960Sstevel@tonic-gate case AF_INET:
16970Sstevel@tonic-gate sin4 = (struct sockaddr_in *)addrs + i;
16980Sstevel@tonic-gate IN6_INADDR_TO_V4MAPPED(&(sin4->sin_addr), &addr);
16990Sstevel@tonic-gate break;
17000Sstevel@tonic-gate case AF_INET6:
17010Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)addrs + i;
17020Sstevel@tonic-gate addr = sin6->sin6_addr;
1703852Svi117747 ifindex = sin6->sin6_scope_id;
17040Sstevel@tonic-gate break;
17050Sstevel@tonic-gate }
1706852Svi117747 nsp = sctp_saddr_lookup(sctp, &addr, ifindex);
17070Sstevel@tonic-gate ASSERT(nsp != NULL);
17080Sstevel@tonic-gate nsp->saddr_ipif_delete_pending = 0;
17090Sstevel@tonic-gate nsp->saddr_ipif_dontsrc = 0;
17100Sstevel@tonic-gate }
17110Sstevel@tonic-gate sctp_asconf_destroy(asc);
17120Sstevel@tonic-gate
17130Sstevel@tonic-gate return (error);
17140Sstevel@tonic-gate }
17150Sstevel@tonic-gate
17160Sstevel@tonic-gate int
sctp_set_peerprim(sctp_t * sctp,const void * inp)171711042SErik.Nordmark@Sun.COM sctp_set_peerprim(sctp_t *sctp, const void *inp)
17180Sstevel@tonic-gate {
17190Sstevel@tonic-gate const struct sctp_setprim *prim = inp;
17200Sstevel@tonic-gate const struct sockaddr_storage *ss;
17210Sstevel@tonic-gate struct sockaddr_in *sin;
17220Sstevel@tonic-gate struct sockaddr_in6 *sin6;
17230Sstevel@tonic-gate in6_addr_t addr;
17240Sstevel@tonic-gate mblk_t *mp;
17250Sstevel@tonic-gate sctp_saddr_ipif_t *sp;
17260Sstevel@tonic-gate sctp_addip4_t *ad4;
17270Sstevel@tonic-gate sctp_addip6_t *ad6;
17280Sstevel@tonic-gate sctp_asconf_t asc[1];
17290Sstevel@tonic-gate int error = 0;
1730852Svi117747 uint_t ifindex = 0;
17310Sstevel@tonic-gate
17320Sstevel@tonic-gate /* Does the peer understand ASCONF and Add-IP? */
17330Sstevel@tonic-gate if (!sctp->sctp_understands_asconf || !sctp->sctp_understands_addip) {
17340Sstevel@tonic-gate return (EOPNOTSUPP);
17350Sstevel@tonic-gate }
17360Sstevel@tonic-gate
17370Sstevel@tonic-gate /* Don't do anything if we are not connected */
17380Sstevel@tonic-gate if (sctp->sctp_state != SCTPS_ESTABLISHED)
17390Sstevel@tonic-gate return (EINVAL);
17400Sstevel@tonic-gate
17410Sstevel@tonic-gate ss = &prim->ssp_addr;
17420Sstevel@tonic-gate sin = NULL;
17430Sstevel@tonic-gate sin6 = NULL;
17440Sstevel@tonic-gate if (ss->ss_family == AF_INET) {
17450Sstevel@tonic-gate sin = (struct sockaddr_in *)ss;
17460Sstevel@tonic-gate IN6_IPADDR_TO_V4MAPPED(sin->sin_addr.s_addr, &addr);
17470Sstevel@tonic-gate } else if (ss->ss_family == AF_INET6) {
17480Sstevel@tonic-gate sin6 = (struct sockaddr_in6 *)ss;
17490Sstevel@tonic-gate addr = sin6->sin6_addr;
1750852Svi117747 ifindex = sin6->sin6_scope_id;
17510Sstevel@tonic-gate } else {
17520Sstevel@tonic-gate return (EAFNOSUPPORT);
17530Sstevel@tonic-gate }
1754852Svi117747 sp = sctp_saddr_lookup(sctp, &addr, ifindex);
17550Sstevel@tonic-gate if (sp == NULL)
17560Sstevel@tonic-gate return (EADDRNOTAVAIL);
17570Sstevel@tonic-gate sctp_asconf_init(asc);
17580Sstevel@tonic-gate if (sin) {
17590Sstevel@tonic-gate mp = allocb(sizeof (*ad4), BPRI_MED);
17600Sstevel@tonic-gate if (mp == NULL) {
17610Sstevel@tonic-gate error = ENOMEM;
17620Sstevel@tonic-gate goto fail;
17630Sstevel@tonic-gate }
17640Sstevel@tonic-gate mp->b_wptr += sizeof (*ad4);
17650Sstevel@tonic-gate ad4 = (sctp_addip4_t *)mp->b_rptr;
17660Sstevel@tonic-gate ad4->sad4_addip_ph.sph_type = htons(PARM_SET_PRIMARY);
17670Sstevel@tonic-gate ad4->sad4_addip_ph.sph_len = htons(sizeof (sctp_parm_hdr_t) +
17680Sstevel@tonic-gate PARM_ADDR4_LEN + sizeof (ad4->asconf_req_cid));
17690Sstevel@tonic-gate ad4->sad4_addr4_ph.sph_type = htons(PARM_ADDR4);
17700Sstevel@tonic-gate ad4->sad4_addr4_ph.sph_len = htons(PARM_ADDR4_LEN);
17710Sstevel@tonic-gate ad4->sad4_addr = sin->sin_addr.s_addr;
17720Sstevel@tonic-gate } else {
17730Sstevel@tonic-gate mp = allocb(sizeof (*ad6), BPRI_MED);
17740Sstevel@tonic-gate if (mp == NULL) {
17750Sstevel@tonic-gate error = ENOMEM;
17760Sstevel@tonic-gate goto fail;
17770Sstevel@tonic-gate }
17780Sstevel@tonic-gate mp->b_wptr += sizeof (*ad6);
17790Sstevel@tonic-gate ad6 = (sctp_addip6_t *)mp->b_rptr;
17800Sstevel@tonic-gate ad6->sad6_addip_ph.sph_type = htons(PARM_SET_PRIMARY);
17810Sstevel@tonic-gate ad6->sad6_addip_ph.sph_len = htons(sizeof (sctp_parm_hdr_t) +
17820Sstevel@tonic-gate PARM_ADDR6_LEN + sizeof (ad6->asconf_req_cid));
17830Sstevel@tonic-gate ad6->sad6_addr6_ph.sph_type = htons(PARM_ADDR6);
17840Sstevel@tonic-gate ad6->sad6_addr6_ph.sph_len = htons(PARM_ADDR6_LEN);
17850Sstevel@tonic-gate ad6->sad6_addr = sin6->sin6_addr;
17860Sstevel@tonic-gate }
17870Sstevel@tonic-gate
17880Sstevel@tonic-gate error = sctp_asconf_add(asc, mp);
17890Sstevel@tonic-gate if (error != 0) {
17900Sstevel@tonic-gate goto fail;
17910Sstevel@tonic-gate }
17920Sstevel@tonic-gate
1793852Svi117747 error = sctp_asconf_send(sctp, asc, sctp->sctp_current, NULL);
17940Sstevel@tonic-gate if (error == 0) {
17950Sstevel@tonic-gate return (0);
17960Sstevel@tonic-gate }
17970Sstevel@tonic-gate
17980Sstevel@tonic-gate fail:
17990Sstevel@tonic-gate sctp_asconf_destroy(asc);
18000Sstevel@tonic-gate return (error);
18010Sstevel@tonic-gate }
1802