/* * CDDL HEADER START * * The contents of this file are subject to the terms of the * Common Development and Distribution License (the "License"). * You may not use this file except in compliance with the License. * * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE * or http://www.opensolaris.org/os/licensing. * See the License for the specific language governing permissions * and limitations under the License. * * When distributing Covered Code, include this CDDL HEADER in each * file and include the License file at usr/src/OPENSOLARIS.LICENSE. * If applicable, add the following below this CDDL HEADER, with the * fields enclosed by brackets "[]" replaced with your own identifying * information: Portions Copyright [yyyy] [name of copyright owner] * * CDDL HEADER END */ /* * Copyright 2006 Sun Microsystems, Inc. All rights reserved. * Use is subject to license terms. */ #ifndef _INET_SCTP_SCTP_IMPL_H #define _INET_SCTP_SCTP_IMPL_H #pragma ident "%Z%%M% %I% %E% SMI" #ifdef __cplusplus extern "C" { #endif #include #include #include #include #include #include #include #include #include /* Streams device identifying info and version */ #define SCTP_DEV_IDINFO "SCTP Streams device 1.0" #define SSN_GT(a, b) ((int16_t)((a)-(b)) > 0) #define SSN_GE(a, b) ((int16_t)((a)-(b)) >= 0) /* Default buffer size and flow control wake up threshold. */ #define SCTP_XMIT_LOWATER 8192 #define SCTP_XMIT_HIWATER 102400 #define SCTP_RECV_LOWATER 8192 #define SCTP_RECV_HIWATER 102400 /* SCTP Timer control structure */ typedef struct sctpt_s { pfv_t sctpt_pfv; /* The routine we are to call */ struct sctp_s *sctpt_sctp; /* The parameter we are to pass in */ struct sctp_faddr_s *sctpt_faddr; } sctpt_t; /* * faddr timer mblks are not allocated until first use. This macro * will allocate the timer mblk if necessary, set the faddr, and then * start the timer. */ #define SCTP_FADDR_TIMER_RESTART(sctp, fp, intvl) \ if ((fp)->timer_mp == NULL) { \ (fp)->timer_mp = sctp_timer_alloc((sctp), sctp_rexmit_timer); \ } \ if ((fp)->timer_mp != NULL) { \ ((sctpt_t *)((fp)->timer_mp->b_rptr))->sctpt_faddr = fp; \ dprint(3, ("faddr_timer_restart: fp=%p %x:%x:%x:%x %d\n", \ (void *)(fp), SCTP_PRINTADDR((fp)->faddr), \ (int)(intvl))); \ sctp_timer((sctp), (fp)->timer_mp, (intvl)); \ (fp)->timer_running = 1; \ } #define SCTP_FADDR_TIMER_STOP(fp) \ if ((fp)->timer_running && (fp)->timer_mp != NULL) { \ sctp_timer_stop((fp)->timer_mp); \ (fp)->timer_running = 0; \ } #define SCTP_CALC_RXT(fp, max) \ { \ if (((fp)->rto <<= 1) > (max)) \ (fp)->rto = (max); \ } /* * Maximum number of duplicate TSNs we can report. This is currently * static, and governs the size of the mblk used to hold the duplicate * reports. The use of duplcate TSN reports is currently experimental, * so for now a static limit should suffice. */ #define SCTP_DUP_MBLK_SZ 64 #define SCTP_IS_ADDR_UNSPEC(isv4, addr) \ ((isv4) ? IN6_IS_ADDR_V4MAPPED_ANY(&(addr)) : \ IN6_IS_ADDR_UNSPECIFIED(&(addr))) extern int sctp_g_num_epriv_ports; extern uint16_t sctp_g_epriv_ports[]; extern kmutex_t sctp_epriv_port_lock; extern uint_t sctp_next_port_to_try; /* * SCTP parameters */ /* Named Dispatch Parameter Management Structure */ typedef struct sctpparam_s { uint32_t sctp_param_min; uint32_t sctp_param_max; uint32_t sctp_param_val; char *sctp_param_name; } sctpparam_t; extern sctpparam_t sctp_param_arr[]; #define sctp_max_init_retr sctp_param_arr[0].sctp_param_val #define sctp_max_init_retr_high sctp_param_arr[0].sctp_param_max #define sctp_max_init_retr_low sctp_param_arr[0].sctp_param_min #define sctp_pa_max_retr sctp_param_arr[1].sctp_param_val #define sctp_pa_max_retr_high sctp_param_arr[1].sctp_param_max #define sctp_pa_max_retr_low sctp_param_arr[1].sctp_param_min #define sctp_pp_max_retr sctp_param_arr[2].sctp_param_val #define sctp_pp_max_retr_high sctp_param_arr[2].sctp_param_max #define sctp_pp_max_retr_low sctp_param_arr[2].sctp_param_min #define sctp_cwnd_max_ sctp_param_arr[3].sctp_param_val #define sctp_dbg sctp_param_arr[4].sctp_param_val #define sctp_smallest_nonpriv_port sctp_param_arr[5].sctp_param_val #define sctp_ipv4_ttl sctp_param_arr[6].sctp_param_val #define sctp_heartbeat_interval sctp_param_arr[7].sctp_param_val #define sctp_heartbeat_interval_high sctp_param_arr[7].sctp_param_max #define sctp_heartbeat_interval_low sctp_param_arr[7].sctp_param_min #define sctp_initial_mtu sctp_param_arr[8].sctp_param_val #define sctp_mtu_probe_interval sctp_param_arr[9].sctp_param_val #define sctp_new_secret_interval sctp_param_arr[10].sctp_param_val #define sctp_deferred_ack_interval sctp_param_arr[11].sctp_param_val #define sctp_snd_lowat_fraction sctp_param_arr[12].sctp_param_val #define sctp_ignore_path_mtu sctp_param_arr[13].sctp_param_val #define sctp_initial_ssthresh sctp_param_arr[14].sctp_param_val #define sctp_smallest_anon_port sctp_param_arr[15].sctp_param_val #define sctp_largest_anon_port sctp_param_arr[16].sctp_param_val #define sctp_xmit_hiwat sctp_param_arr[17].sctp_param_val #define sctp_xmit_lowat sctp_param_arr[18].sctp_param_val #define sctp_recv_hiwat sctp_param_arr[19].sctp_param_val #define sctp_max_buf sctp_param_arr[20].sctp_param_val #define sctp_rtt_updates sctp_param_arr[21].sctp_param_val #define sctp_ipv6_hoplimit sctp_param_arr[22].sctp_param_val #define sctp_rto_ming sctp_param_arr[23].sctp_param_val #define sctp_rto_ming_high sctp_param_arr[23].sctp_param_max #define sctp_rto_ming_low sctp_param_arr[23].sctp_param_min #define sctp_rto_maxg sctp_param_arr[24].sctp_param_val #define sctp_rto_maxg_high sctp_param_arr[24].sctp_param_max #define sctp_rto_maxg_low sctp_param_arr[24].sctp_param_min #define sctp_rto_initialg sctp_param_arr[25].sctp_param_val #define sctp_rto_initialg_high sctp_param_arr[25].sctp_param_max #define sctp_rto_initialg_low sctp_param_arr[25].sctp_param_min #define sctp_cookie_life sctp_param_arr[26].sctp_param_val #define sctp_cookie_life_high sctp_param_arr[26].sctp_param_max #define sctp_cookie_life_low sctp_param_arr[26].sctp_param_min #define sctp_max_in_streams sctp_param_arr[27].sctp_param_val #define sctp_max_in_streams_high sctp_param_arr[27].sctp_param_max #define sctp_max_in_streams_low sctp_param_arr[27].sctp_param_min #define sctp_initial_out_streams sctp_param_arr[28].sctp_param_val #define sctp_initial_out_streams_high sctp_param_arr[28].sctp_param_max #define sctp_initial_out_streams_low sctp_param_arr[28].sctp_param_min #define sctp_shutack_wait_bound sctp_param_arr[29].sctp_param_val #define sctp_maxburst sctp_param_arr[30].sctp_param_val #define sctp_addip_enabled sctp_param_arr[31].sctp_param_val #define sctp_recv_hiwat_minmss sctp_param_arr[32].sctp_param_val #define sctp_slow_start_initial sctp_param_arr[33].sctp_param_val #define sctp_slow_start_after_idle sctp_param_arr[34].sctp_param_val #define sctp_prsctp_enabled sctp_param_arr[35].sctp_param_val #define sctp_fast_rxt_thresh sctp_param_arr[36].sctp_param_val /* * sctp_wroff_xtra is the extra space in front of SCTP/IP header for link * layer header. It has to be a multiple of 4. */ extern sctpparam_t sctp_wroff_xtra_param; #define sctp_wroff_xtra sctp_wroff_xtra_param.sctp_param_val #define SCTP_MAX_COMBINED_HEADER_LENGTH (60 + 12) /* Maxed out ip + sctp */ #define SCTP_MAX_IP_OPTIONS_LENGTH (60 - IP_SIMPLE_HDR_LENGTH) #define SCTP_MAX_HDR_LENGTH 60 #define SCTP_SECRET_LEN 16 #define SCTP_REFHOLD(sctp) { \ mutex_enter(&(sctp)->sctp_reflock); \ (sctp)->sctp_refcnt++; \ ASSERT((sctp)->sctp_refcnt != 0); \ mutex_exit(&(sctp)->sctp_reflock); \ } #define SCTP_REFRELE(sctp) { \ mutex_enter(&(sctp)->sctp_reflock); \ ASSERT((sctp)->sctp_refcnt != 0); \ if (--(sctp)->sctp_refcnt == 0) { \ mutex_exit(&(sctp)->sctp_reflock); \ CONN_DEC_REF((sctp)->sctp_connp); \ } else { \ mutex_exit(&(sctp)->sctp_reflock); \ } \ } #define SCTP_PRINTADDR(a) (a).s6_addr32[0], (a).s6_addr32[1],\ (a).s6_addr32[2], (a).s6_addr32[3] #define CONN2SCTP(conn) ((sctp_t *)(&((conn_t *)conn)[1])) /* * Outbound data, flags and macros for per-message, per-chunk info */ typedef struct { int64_t smh_ttl; /* Time to Live */ int64_t smh_tob; /* Time of Birth */ uint32_t smh_context; uint16_t smh_sid; uint16_t smh_ssn; uint32_t smh_ppid; uint16_t smh_flags; uint32_t smh_msglen; } sctp_msg_hdr_t; #define SCTP_CHUNK_FLAG_SENT 0x01 #define SCTP_CHUNK_FLAG_REXMIT 0x02 #define SCTP_CHUNK_FLAG_ACKED 0x04 #define SCTP_MSG_FLAG_CHUNKED 0x08 #define SCTP_MSG_FLAG_ABANDONED 0x10 #define SCTP_CHUNK_FLAG_ABANDONED 0x20 #define SCTP_CHUNK_CLEAR_FLAGS(mp) ((mp)->b_flag = 0) /* * If we are transmitting the chunk for the first time we assign the TSN and * SSN here. The reason we assign the SSN here (as opposed to doing it in * sctp_chunkify()) is that the chunk may expire, if PRSCTP is enabled, before * we get a chance to send it out. If we assign the SSN in sctp_chunkify() * and this happens, then we need to send a Forward TSN to the peer, which * will be expecting this SSN, assuming ordered. If we assign it here we * can just take out the chunk from the transmit list without having to * send a Forward TSN chunk. While assigning the SSN we use (meta)->b_cont * to determine if it needs a new SSN (i.e. the next SSN for the stream), * since (meta)->b_cont signifies the first chunk of a message (if the message * is unordered, then the SSN is 0). * */ #define SCTP_CHUNK_SENT(sctp, mp, sdc, fp, chunkdata, meta) { \ if (!SCTP_CHUNK_ISSENT(mp)) { \ sctp_msg_hdr_t *mhdr = (sctp_msg_hdr_t *)(meta)->b_rptr; \ ASSERT(!SCTP_CHUNK_ABANDONED(mp)); \ (mp)->b_flag = SCTP_CHUNK_FLAG_SENT; \ (sdc)->sdh_tsn = htonl((sctp)->sctp_ltsn++); \ if ((mhdr)->smh_flags & MSG_UNORDERED) { \ (sdc)->sdh_ssn = 0; \ SCTP_DATA_SET_UBIT(sdc); \ BUMP_LOCAL((sctp)->sctp_oudchunks); \ } else { \ BUMP_LOCAL((sctp)->sctp_odchunks); \ if ((mp) == (meta)->b_cont) { \ mhdr->smh_ssn = htons( \ (sctp)->sctp_ostrcntrs[mhdr->smh_sid]++); \ } \ (sdc)->sdh_ssn = mhdr->smh_ssn; \ } \ (sctp)->sctp_unacked += (chunkdata); \ (sctp)->sctp_unsent -= (chunkdata); \ (sctp)->sctp_frwnd -= (chunkdata); \ } else { \ if (SCTP_CHUNK_ISACKED(mp)) { \ (sctp)->sctp_unacked += (chunkdata); \ } else { \ ASSERT(SCTP_CHUNK_DEST(mp)->suna >= ((chunkdata) + \ sizeof (*sdc))); \ SCTP_CHUNK_DEST(mp)->suna -= ((chunkdata) + \ sizeof (*sdc)); \ } \ (mp)->b_flag &= ~(SCTP_CHUNK_FLAG_REXMIT | \ SCTP_CHUNK_FLAG_ACKED); \ SCTP_CHUNK_SET_SACKCNT(mp, 0); \ BUMP_LOCAL(sctp->sctp_rxtchunks); \ BUMP_LOCAL((sctp)->sctp_T3expire); \ BUMP_LOCAL((fp)->T3expire); \ } \ SCTP_SET_CHUNK_DEST(mp, fp); \ (fp)->suna += ((chunkdata) + sizeof (*sdc)); \ } #define SCTP_CHUNK_ISSENT(mp) ((mp)->b_flag & SCTP_CHUNK_FLAG_SENT) #define SCTP_CHUNK_CANSEND(mp) \ (!(SCTP_CHUNK_ABANDONED(mp)) && \ (((mp)->b_flag & (SCTP_CHUNK_FLAG_REXMIT|SCTP_CHUNK_FLAG_SENT)) != \ SCTP_CHUNK_FLAG_SENT)) #define SCTP_CHUNK_DEST(mp) ((sctp_faddr_t *)(mp)->b_queue) #define SCTP_SET_CHUNK_DEST(mp, fp) ((mp)->b_queue = (queue_t *)fp) #define SCTP_CHUNK_REXMIT(mp) ((mp)->b_flag |= SCTP_CHUNK_FLAG_REXMIT) #define SCTP_CHUNK_CLEAR_REXMIT(mp) ((mp)->b_flag &= ~SCTP_CHUNK_FLAG_REXMIT) #define SCTP_CHUNK_WANT_REXMIT(mp) ((mp)->b_flag & SCTP_CHUNK_FLAG_REXMIT) #define SCTP_CHUNK_ACKED(mp) \ ((mp)->b_flag = (SCTP_CHUNK_FLAG_SENT|SCTP_CHUNK_FLAG_ACKED)) #define SCTP_CHUNK_ISACKED(mp) ((mp)->b_flag & SCTP_CHUNK_FLAG_ACKED) #define SCTP_CHUNK_CLEAR_ACKED(mp) ((mp)->b_flag &= ~SCTP_CHUNK_FLAG_ACKED) #define SCTP_CHUNK_SACKCNT(mp) ((intptr_t)((mp)->b_prev)) #define SCTP_CHUNK_SET_SACKCNT(mp, val) ((mp)->b_prev = \ (mblk_t *)(uintptr_t)(val)) #define SCTP_MSG_SET_CHUNKED(mp) ((mp)->b_flag |= SCTP_MSG_FLAG_CHUNKED) #define SCTP_MSG_CLEAR_CHUNKED(mp)((mp)->b_flag &= ~SCTP_MSG_FLAG_CHUNKED) #define SCTP_IS_MSG_CHUNKED(mp) ((mp)->b_flag & SCTP_MSG_FLAG_CHUNKED) /* For PR-SCTP */ #define SCTP_ABANDON_CHUNK(mp) ((mp)->b_flag |= SCTP_CHUNK_FLAG_ABANDONED) #define SCTP_CHUNK_ABANDONED(mp) \ ((mp)->b_flag & SCTP_CHUNK_FLAG_ABANDONED) #define SCTP_MSG_SET_ABANDONED(mp) \ ((mp)->b_flag |= SCTP_MSG_FLAG_ABANDONED) #define SCTP_MSG_CLEAR_ABANDONED(mp)((mp)->b_flag &= ~SCTP_MSG_FLAG_ABANDONED) #define SCTP_IS_MSG_ABANDONED(mp) ((mp)->b_flag & SCTP_MSG_FLAG_ABANDONED) /* * Check if a message has expired. A message is expired if * 1. It has a non-zero time to live value and has not been sent before * that time expires. * 2. It is sent using PRSCTP and it has not been SACK'ed before * its lifetime expires. */ #define SCTP_MSG_TO_BE_ABANDONED(meta, mhdr, sctp) \ (((!SCTP_CHUNK_ISSENT((meta)->b_cont) && (mhdr)->smh_ttl > 0) || \ ((sctp)->sctp_prsctp_aware && ((mhdr)->smh_flags & MSG_PR_SCTP))) && \ ((lbolt64 - (mhdr)->smh_tob) > (mhdr)->smh_ttl)) /* SCTP association hash function. */ #define SCTP_CONN_HASH(ports) \ ((((ports) ^ ((ports) >> 16)) * 31) & (sctp_conn_hash_size - 1)) /* * Bind hash array size and hash function. The size must be a power * of 2 and lport must be in host byte order. */ #define SCTP_BIND_FANOUT_SIZE 2048 #define SCTP_BIND_HASH(lport) (((lport) * 31) & (SCTP_BIND_FANOUT_SIZE - 1)) /* options that SCTP negotiates during association establishment */ #define SCTP_PRSCTP_OPTION 0x01 /* * Listener hash array size and hash function. The size must be a power * of 2 and lport must be in host byte order. */ #define SCTP_LISTEN_FANOUT_SIZE 512 #define SCTP_LISTEN_HASH(lport) (((lport) * 31) & (SCTP_LISTEN_FANOUT_SIZE - 1)) typedef struct sctp_tf_s { struct sctp_s *tf_sctp; kmutex_t tf_lock; } sctp_tf_t; /* SCTP association hash list */ extern sctp_tf_t *sctp_conn_fanout; /* Size of sctp_conn_fanout */ extern uint_t sctp_conn_hash_size; /* SCTP bind hash list - all sctp_t with state >= BOUND. */ extern sctp_tf_t sctp_bind_fanout[]; /* SCTP listener hash list - all sctp_t with state == LISTEN. */ extern sctp_tf_t sctp_listen_fanout[]; /* Round up the value to the nearest mss. */ #define MSS_ROUNDUP(value, mss) ((((value) - 1) / (mss) + 1) * (mss)) extern sin_t sctp_sin_null; /* Zero address for quick clears */ extern sin6_t sctp_sin6_null; /* Zero address for quick clears */ #define SCTP_IS_DETACHED(sctp) ((sctp)->sctp_detached) extern mib2_sctp_t sctp_mib; /* SNMP fixed size info */ /* * Object to represent database of options to search passed to * {sock,tpi}optcom_req() interface routine to take care of option * management and associated methods. * XXX These and other externs should ideally move to a SCTP header */ extern optdb_obj_t sctp_opt_obj; extern uint_t sctp_max_optbuf_len; /* Data structure used to track received TSNs */ typedef struct sctp_set_s { struct sctp_set_s *next; struct sctp_set_s *prev; uint32_t begin; uint32_t end; } sctp_set_t; /* Data structure used to track TSNs for PR-SCTP */ typedef struct sctp_ftsn_set_s { struct sctp_ftsn_set_s *next; ftsn_entry_t ftsn_entries; } sctp_ftsn_set_t; /* Data structure used to track incoming SCTP streams */ typedef struct sctp_instr_s { mblk_t *istr_msgs; int istr_nmsgs; uint16_t nextseq; struct sctp_s *sctp; mblk_t *istr_reass; } sctp_instr_t; /* Reassembly data structure (per-stream) */ typedef struct sctp_reass_s { uint16_t ssn; uint16_t needed; uint16_t got; mblk_t *tail; boolean_t partial_delivered; } sctp_reass_t; /* debugging */ #undef dprint #ifdef DEBUG extern int sctpdebug; #define dprint(level, args) { if (sctpdebug > (level)) printf args; } #else #define dprint(level, args) {} #endif /* Peer address tracking */ /* * States for peer addresses * * SCTP_FADDRS_UNCONFIRMED: we have not communicated with this peer address * before, mark it as unconfirmed so that we will not send data to it. * All addresses initially are in unconfirmed state and required * validation. SCTP sends a heartbeat to each of them and when it gets * back a heartbeat ACK, the address will be marked as alive. This * validation fixes a security issue with multihoming. If an attacker * establishes an association with us and tells us that it has addresses * belonging to another host A, this will prevent A from communicating * with us. This is fixed by peer address validation. In the above case, * A will respond with an abort. * * SCTP_FADDRS_ALIVE: this peer address is alive and we can communicate with * it with no problem. * * SCTP_FADDRS_DOWN: we have exceeded the retransmission limit to this * peer address. Once an address is marked down, we will only send * a heartbeat to it every hb_interval in case it becomes alive now. * * SCTP_FADDRS_UNREACH: there is no suitable source address to send to * this peer address. For example, the peer address is v6 but we only * have v4 addresses. It is marked unreachable until there is an * address configuration change. At that time, mark these addresses * as unconfirmed and try again to see if those unreachable addresses * are OK as we may have more source addresses. */ typedef enum { SCTP_FADDRS_UNREACH, SCTP_FADDRS_DOWN, SCTP_FADDRS_ALIVE, SCTP_FADDRS_UNCONFIRMED } faddr_state_t; typedef struct sctp_faddr_s { struct sctp_faddr_s *next; faddr_state_t state; in6_addr_t faddr; in6_addr_t saddr; int64_t hb_expiry; /* time to retransmit heartbeat */ uint32_t hb_interval; /* the heartbeat interval */ int rto; /* RTO in tick */ int srtt; /* Smoothed RTT in tick */ int rttvar; /* RTT variance in tick */ uint32_t rtt_updates; int strikes; int max_retr; uint32_t sfa_pmss; uint32_t cwnd; uint32_t ssthresh; uint32_t suna; /* sent - unack'ed */ uint32_t pba; /* partial bytes acked */ uint32_t acked; int64_t lastactive; mblk_t *timer_mp; /* retransmission timer control */ uint32_t hb_pending : 1, timer_running : 1, df : 1, pmtu_discovered : 1, rc_timer_running : 1, isv4 : 1; mblk_t *rc_timer_mp; /* reliable control chunk timer */ ire_t *ire; /* cached IRE */ uint32_t T3expire; /* # of times T3 timer expired */ uint64_t hb_secret; /* per addr "secret" in heartbeat */ } sctp_faddr_t; /* Flags to indicate supported address type in the PARM_SUP_ADDRS. */ #define PARM_SUPP_V6 0x1 #define PARM_SUPP_V4 0x2 /* * Set heartbeat interval plus jitter. The jitter is supposed to be random, * up to +/- 50% of the RTO. We use gethrtime() here for performance reason * as the jitter does not really need to be "very" random. */ #define SET_HB_INTVL(fp) \ ((fp)->hb_interval + (fp)->rto + ((fp)->rto >> 1) - \ (uint_t)gethrtime() % (fp)->rto); #define SCTP_IPIF_HASH 16 typedef struct sctp_ipif_hash_s { list_t sctp_ipif_list; int ipif_count; } sctp_ipif_hash_t; struct sctp_s; /* * Control structure for each open SCTP stream, * defined only within the kernel or for a kmem user. * NOTE: sctp_reinit_values MUST have a line for each field in this structure! */ #if (defined(_KERNEL) || defined(_KMEMUSER)) typedef struct sctp_s { /* * The following is shared with (and duplicated) in IP, so if you * make changes, make sure you also change things in ip_sctp.c. */ struct sctp_s *sctp_conn_hash_next; struct sctp_s *sctp_conn_hash_prev; struct sctp_s *sctp_listen_hash_next; struct sctp_s *sctp_listen_hash_prev; sctp_tf_t *sctp_listen_tfp; /* Ptr to tf */ sctp_tf_t *sctp_conn_tfp; /* Ptr to tf */ /* Global list of sctp */ list_node_t sctp_list; sctp_faddr_t *sctp_faddrs; int sctp_nfaddrs; sctp_ipif_hash_t sctp_saddrs[SCTP_IPIF_HASH]; int sctp_nsaddrs; /* * These fields contain the same information as sctp_sctph->th_*port. * However, the lookup functions can not use the header fields * since during IP option manipulation the sctp_sctph pointer * changes. */ union { struct { in_port_t sctpu_fport; /* Remote port */ in_port_t sctpu_lport; /* Local port */ } sctpu_ports1; uint32_t sctpu_ports2; /* Rem port, */ /* local port */ /* Used for SCTP_MATCH performance */ } sctp_sctpu; #define sctp_fport sctp_sctpu.sctpu_ports1.sctpu_fport #define sctp_lport sctp_sctpu.sctpu_ports1.sctpu_lport #define sctp_ports sctp_sctpu.sctpu_ports2 kmutex_t sctp_lock; kcondvar_t sctp_cv; boolean_t sctp_running; void *sctp_ulpd; /* SCTP upper layer desc. */ struct sctp_upcalls_s sctp_upcalls; /* upcalls for sctp_ulpd */ #define sctp_ulp_newconn sctp_upcalls.su_newconn #define sctp_ulp_connected sctp_upcalls.su_connected #define sctp_ulp_disconnected sctp_upcalls.su_disconnected #define sctp_ulp_disconnecting sctp_upcalls.su_disconnecting #define sctp_ulp_recv sctp_upcalls.su_recv #define sctp_ulp_xmitted sctp_upcalls.su_xmitted #define sctp_ulp_prop sctp_upcalls.su_properties int32_t sctp_state; conn_t *sctp_connp; /* conn_t stuff */ #define sctp_zoneid sctp_connp->conn_zoneid #define sctp_credp sctp_connp->conn_cred /* Peer address tracking */ sctp_faddr_t *sctp_lastfaddr; /* last faddr in list */ sctp_faddr_t *sctp_primary; /* primary faddr */ sctp_faddr_t *sctp_current; /* current faddr */ sctp_faddr_t *sctp_lastdata; /* last data seen from this */ /* Outbound data tracking */ mblk_t *sctp_xmit_head; mblk_t *sctp_xmit_tail; mblk_t *sctp_xmit_unsent; mblk_t *sctp_xmit_unsent_tail; mblk_t *sctp_xmit_unacked; int32_t sctp_unacked; /* # of unacked bytes */ int32_t sctp_unsent; /* # of unsent bytes in hand */ uint32_t sctp_ltsn; /* Local instance TSN */ uint32_t sctp_lastack_rxd; /* Last rx'd cumtsn */ uint32_t sctp_recovery_tsn; /* Exit from fast recovery */ uint32_t sctp_adv_pap; /* Adv. Peer Ack Point */ uint16_t sctp_num_ostr; uint16_t *sctp_ostrcntrs; /* sendmsg() default parameters */ uint16_t sctp_def_stream; /* default stream id */ uint16_t sctp_def_flags; /* default xmit flags */ uint32_t sctp_def_ppid; /* default payload id */ uint32_t sctp_def_context; /* default context */ uint32_t sctp_def_timetolive; /* default msg TTL */ /* Inbound data tracking */ sctp_set_t *sctp_sack_info; /* Sack tracking */ mblk_t *sctp_ack_mp; /* Delayed ACK timer block */ sctp_instr_t *sctp_instr; /* Instream trackers */ mblk_t *sctp_uo_frags; /* Un-ordered msg. fragments */ uint32_t sctp_ftsn; /* Peer's TSN */ uint32_t sctp_lastacked; /* last cumtsn SACKd */ uint16_t sctp_num_istr; /* No. of instreams */ int32_t sctp_istr_nmsgs; /* No. of chunks in instreams */ int32_t sctp_sack_gaps; /* No. of received gaps */ int32_t sctp_sack_toggle; /* SACK every other pkt */ /* RTT calculation */ uint32_t sctp_rtt_tsn; int64_t sctp_out_time; /* Stats */ uint64_t sctp_opkts; /* sent pkts */ uint64_t sctp_obchunks; /* sent control chunks */ uint64_t sctp_odchunks; /* sent ordered data chunks */ uint64_t sctp_oudchunks; /* sent unord data chunks */ uint64_t sctp_rxtchunks; /* retransmitted chunks */ uint64_t sctp_ipkts; /* recv pkts */ uint64_t sctp_ibchunks; /* recv control chunks */ uint64_t sctp_idchunks; /* recv ordered data chunks */ uint64_t sctp_iudchunks; /* recv unord data chunks */ uint64_t sctp_fragdmsgs; uint64_t sctp_reassmsgs; uint32_t sctp_T1expire; /* # of times T1timer expired */ uint32_t sctp_T2expire; /* # of times T2timer expired */ uint32_t sctp_T3expire; /* # of times T3timer expired */ uint32_t sctp_assoc_start_time; /* time when assoc was est. */ /* Outbound flow control */ int32_t sctp_xmit_hiwater; /* Send high water mark */ int32_t sctp_xmit_lowater; /* Send low water mark */ uint32_t sctp_frwnd; /* Peer RWND */ uint32_t sctp_cwnd_max; /* Inbound flow control */ int32_t sctp_rwnd; /* Current receive window */ int32_t sctp_irwnd; /* Initial receive window */ int32_t sctp_rxqueued; /* No. of bytes in RX q's */ /* Pre-initialized composite headers */ char *sctp_iphc; /* v4 sctp/ip hdr template buffer */ char *sctp_iphc6; /* v6 sctp/ip hdr template buffer */ int32_t sctp_iphc_len; /* actual allocated v4 buffer size */ int32_t sctp_iphc6_len; /* actual allocated v6 buffer size */ int32_t sctp_hdr_len; /* len of combined SCTP/IP v4 hdr */ int32_t sctp_hdr6_len; /* len of combined SCTP/IP v6 hdr */ ipha_t *sctp_ipha; /* IPv4 header in the buffer */ ip6_t *sctp_ip6h; /* IPv6 header in the buffer */ int32_t sctp_ip_hdr_len; /* Byte len of our current v4 hdr */ int32_t sctp_ip_hdr6_len; /* Byte len of our current v6 hdr */ sctp_hdr_t *sctp_sctph; /* sctp header in combined v4 hdr */ sctp_hdr_t *sctp_sctph6; /* sctp header in combined v6 hdr */ uint32_t sctp_lvtag; /* local SCTP instance verf tag */ uint32_t sctp_fvtag; /* Peer's SCTP verf tag */ /* Path MTU Discovery */ int64_t sctp_last_mtu_probe; clock_t sctp_mtu_probe_intvl; uint32_t sctp_mss; /* Max send size (not TCP MSS!) */ /* structs sctp_bits, sctp_events are for clearing all bits at once */ struct { uint32_t sctp_understands_asconf : 1, /* Peer handles ASCONF chunks */ sctp_debug : 1, /* SO_DEBUG "socket" option. */ sctp_dontroute : 1, /* SO_DONTROUTE "socket" option. */ sctp_broadcast : 1, /* SO_BROADCAST "socket" option. */ sctp_useloopback : 1, /* SO_USELOOPBACK "socket" option. */ sctp_cchunk_pend : 1, /* Control chunk in flight. */ sctp_dgram_errind : 1, /* SO_DGRAM_ERRIND option */ sctp_reuseaddr : 1, /* SO_REUSEADDR "socket" option. */ sctp_linger : 1, /* SO_LINGER turned on */ sctp_lingering : 1, /* Lingering in close */ sctp_loopback: 1, /* src and dst are the same machine */ sctp_force_sack : 1, sctp_ack_timer_running: 1, /* Delayed ACK timer running */ sctp_recvdstaddr : 1, /* return T_EXTCONN_IND with dstaddr */ sctp_hwcksum : 1, /* The NIC is capable of hwcksum */ sctp_understands_addip : 1, sctp_bound_to_all : 1, sctp_cansleep : 1, /* itf routines can sleep */ sctp_detached : 1, /* If we're detached from a stream */ sctp_send_adaption : 1, /* send adaption layer ind */ sctp_recv_adaption : 1, /* received adaption layer ind */ sctp_ndelay : 1, /* turn off Nagle */ sctp_condemned : 1, /* this sctp is about to disappear */ sctp_chk_fast_rexmit : 1, /* check for fast rexmit message */ sctp_prsctp_aware : 1, /* is peer PR-SCTP aware? */ sctp_linklocal : 1, /* is linklocal assoc. */ sctp_mac_exempt : 1, /* SO_MAC_EXEMPT */ sctp_dummy : 5; } sctp_bits; struct { uint32_t sctp_recvsndrcvinfo : 1, sctp_recvassocevnt : 1, sctp_recvpathevnt : 1, sctp_recvsendfailevnt : 1, sctp_recvpeererr : 1, sctp_recvshutdownevnt : 1, sctp_recvpdevnt : 1, sctp_recvalevnt : 1; } sctp_events; #define sctp_priv_stream sctp_bits.sctp_priv_stream #define sctp_understands_asconf sctp_bits.sctp_understands_asconf #define sctp_debug sctp_bits.sctp_debug #define sctp_dontroute sctp_bits.sctp_dontroute #define sctp_broadcast sctp_bits.sctp_broadcast #define sctp_useloopback sctp_bits.sctp_useloopback #define sctp_cchunk_pend sctp_bits.sctp_cchunk_pend #define sctp_dgram_errind sctp_bits.sctp_dgram_errind #define sctp_reuseaddr sctp_bits.sctp_reuseaddr #define sctp_linger sctp_bits.sctp_linger #define sctp_lingering sctp_bits.sctp_lingering #define sctp_loopback sctp_bits.sctp_loopback #define sctp_force_sack sctp_bits.sctp_force_sack #define sctp_ack_timer_running sctp_bits.sctp_ack_timer_running #define sctp_recvdstaddr sctp_bits.sctp_recvdstaddr #define sctp_hwcksum sctp_bits.sctp_hwcksum #define sctp_understands_addip sctp_bits.sctp_understands_addip #define sctp_bound_to_all sctp_bits.sctp_bound_to_all #define sctp_cansleep sctp_bits.sctp_cansleep #define sctp_detached sctp_bits.sctp_detached #define sctp_send_adaption sctp_bits.sctp_send_adaption #define sctp_recv_adaption sctp_bits.sctp_recv_adaption #define sctp_ndelay sctp_bits.sctp_ndelay #define sctp_condemned sctp_bits.sctp_condemned #define sctp_chk_fast_rexmit sctp_bits.sctp_chk_fast_rexmit #define sctp_prsctp_aware sctp_bits.sctp_prsctp_aware #define sctp_linklocal sctp_bits.sctp_linklocal #define sctp_mac_exempt sctp_bits.sctp_mac_exempt #define sctp_recvsndrcvinfo sctp_events.sctp_recvsndrcvinfo #define sctp_recvassocevnt sctp_events.sctp_recvassocevnt #define sctp_recvpathevnt sctp_events.sctp_recvpathevnt #define sctp_recvsendfailevnt sctp_events.sctp_recvsendfailevnt #define sctp_recvpeererr sctp_events.sctp_recvpeererr #define sctp_recvshutdownevnt sctp_events.sctp_recvshutdownevnt #define sctp_recvpdevnt sctp_events.sctp_recvpdevnt #define sctp_recvalevnt sctp_events.sctp_recvalevnt /* Retransmit info */ mblk_t *sctp_cookie_mp; /* cookie chunk, if rxt needed */ int32_t sctp_strikes; /* Total number of assoc strikes */ int32_t sctp_max_init_rxt; int32_t sctp_pa_max_rxt; /* Max per-assoc retransmit cnt */ int32_t sctp_pp_max_rxt; /* Max per-path retransmit cnt */ uint32_t sctp_rto_max; uint32_t sctp_init_rto_max; uint32_t sctp_rto_min; uint32_t sctp_rto_initial; int64_t sctp_last_secret_update; uint8_t sctp_secret[SCTP_SECRET_LEN]; /* for cookie auth */ uint8_t sctp_old_secret[SCTP_SECRET_LEN]; uint32_t sctp_cookie_lifetime; /* cookie lifetime in ms */ /* * Address family that app wishes returned addrsses to be in. * Currently taken from address family used in T_BIND_REQ, but * should really come from family used in original socket() call. * Value can be AF_INET or AF_INET6. */ uint_t sctp_family; ushort_t sctp_ipversion; /* Bind hash tables */ kmutex_t *sctp_bind_lockp; /* Ptr to tf_lock */ struct sctp_s *sctp_bind_hash; struct sctp_s **sctp_ptpbhn; /* Shutdown / cleanup */ sctp_faddr_t *sctp_shutdown_faddr; /* rotate faddr during shutd */ int32_t sctp_client_errno; /* How the client screwed up */ int sctp_lingertime; /* Close linger time (in seconds) */ kmutex_t sctp_reflock; /* Protects sctp_refcnt & timer mp */ ushort_t sctp_refcnt; /* No. of pending upstream msg */ mblk_t *sctp_timer_mp; /* List of fired timers. */ /* Misc */ uint_t sctp_bound_if; /* IPV6_BOUND_IF */ mblk_t *sctp_heartbeat_mp; /* Timer block for heartbeats */ uint32_t sctp_hb_interval; /* Default hb_interval */ int32_t sctp_autoclose; /* Auto disconnect in ticks */ int64_t sctp_active; /* Last time data/sack on this conn */ uint32_t sctp_tx_adaption_code; /* TX adaptation code */ uint32_t sctp_rx_adaption_code; /* RX adaptation code */ /* Reliable control chunks */ mblk_t *sctp_cxmit_list; /* Xmit list for control chunks */ uint32_t sctp_lcsn; /* Our serial number */ uint32_t sctp_fcsn; /* Peer serial number */ /* Per association receive queue */ kmutex_t sctp_recvq_lock; mblk_t *sctp_recvq; mblk_t *sctp_recvq_tail; taskq_t *sctp_recvq_tq; /* Send queue to IP */ kmutex_t sctp_sendq_lock; mblk_t *sctp_sendq; mblk_t *sctp_sendq_tail; boolean_t sctp_sendq_sending; /* IPv6 ancillary data */ uint_t sctp_ipv6_recvancillary; /* flags */ #define SCTP_IPV6_RECVPKTINFO 0x01 /* IPV6_RECVPKTINFO opt */ #define SCTP_IPV6_RECVHOPLIMIT 0x02 /* IPV6_RECVHOPLIMIT opt */ #define SCTP_IPV6_RECVHOPOPTS 0x04 /* IPV6_RECVHOPOPTS opt */ #define SCTP_IPV6_RECVDSTOPTS 0x08 /* IPV6_RECVDSTOPTS opt */ #define SCTP_IPV6_RECVRTHDR 0x10 /* IPV6_RECVRTHDR opt */ #define SCTP_IPV6_RECVRTDSTOPTS 0x20 /* IPV6_RECVRTHDRDSTOPTS opt */ uint_t sctp_recvifindex; /* last rcvd IPV6_RCVPKTINFO */ uint_t sctp_recvhops; /* " IPV6_RECVHOPLIMIT */ ip6_hbh_t *sctp_hopopts; /* " IPV6_RECVHOPOPTS */ ip6_dest_t *sctp_dstopts; /* " IPV6_RECVDSTOPTS */ ip6_dest_t *sctp_rtdstopts; /* " IPV6_RECVRTHDRDSTOPTS */ ip6_rthdr_t *sctp_rthdr; /* " IPV6_RECVRTHDR */ uint_t sctp_hopoptslen; uint_t sctp_dstoptslen; uint_t sctp_rtdstoptslen; uint_t sctp_rthdrlen; ip6_pkt_t sctp_sticky_ipp; /* Sticky options */ #define sctp_ipp_fields sctp_sticky_ipp.ipp_fields #define sctp_ipp_ifindex sctp_sticky_ipp.ipp_ifindex #define sctp_ipp_addr sctp_sticky_ipp.ipp_addr #define sctp_ipp_hoplimit sctp_sticky_ipp.ipp_hoplimit #define sctp_ipp_hopoptslen sctp_sticky_ipp.ipp_hopoptslen #define sctp_ipp_rtdstoptslen sctp_sticky_ipp.ipp_rtdstoptslen #define sctp_ipp_rthdrlen sctp_sticky_ipp.ipp_rthdrlen #define sctp_ipp_dstoptslen sctp_sticky_ipp.ipp_dstoptslen #define sctp_ipp_hopopts sctp_sticky_ipp.ipp_hopopts #define sctp_ipp_rtdstopts sctp_sticky_ipp.ipp_rtdstopts #define sctp_ipp_rthdr sctp_sticky_ipp.ipp_rthdr #define sctp_ipp_dstopts sctp_sticky_ipp.ipp_dstopts #define sctp_ipp_nexthop sctp_sticky_ipp.ipp_nexthop /* Stats */ uint64_t sctp_msgcount; uint64_t sctp_prsctpdrop; uint_t sctp_v4label_len; /* length of cached v4 label */ uint_t sctp_v6label_len; /* length of cached v6 label */ } sctp_t; extern list_t sctp_g_list; /* Head of SCTP instance data chain */ extern kmutex_t sctp_g_lock; #endif /* (defined(_KERNEL) || defined(_KMEMUSER)) */ extern queue_t *sctp_g_q; /* Default queue used during detached closes */ extern sctp_t *gsctp; /* Padding mblk for SCTP chunks. */ extern mblk_t *sctp_pad_mp; extern void sctp_ack_timer(sctp_t *); extern size_t sctp_adaption_code_param(sctp_t *, uchar_t *); extern void sctp_adaption_event(sctp_t *); extern int sctp_add_faddr(sctp_t *, in6_addr_t *, int); extern int sctp_add_faddr_first(sctp_t *, in6_addr_t *, int); extern boolean_t sctp_add_ftsn_set(sctp_ftsn_set_t **, sctp_faddr_t *, mblk_t *, uint_t *, uint32_t *); extern boolean_t sctp_add_recvq(sctp_t *, mblk_t *, boolean_t); extern void sctp_add_sendq(sctp_t *, mblk_t *); extern void sctp_add_unrec_parm(sctp_parm_hdr_t *, mblk_t **); extern size_t sctp_addr_params(sctp_t *, int, uchar_t *); extern size_t sctp_addr_params_len(sctp_t *, int, boolean_t); extern mblk_t *sctp_add_proto_hdr(sctp_t *, sctp_faddr_t *, mblk_t *, int, int *); extern void sctp_addr_req(sctp_t *, mblk_t *); extern sctp_t *sctp_addrlist2sctp(mblk_t *, sctp_hdr_t *, sctp_chunk_hdr_t *, uint_t, zoneid_t); extern void sctp_add_hdr(sctp_t *, uchar_t *, size_t); extern void sctp_check_adv_ack_pt(sctp_t *, mblk_t *, mblk_t *); extern void sctp_assoc_event(sctp_t *, uint16_t, uint16_t, sctp_chunk_hdr_t *); extern void sctp_bind_hash_insert(sctp_tf_t *, sctp_t *, int); extern void sctp_bind_hash_remove(sctp_t *); extern int sctp_bindi(sctp_t *, in_port_t, boolean_t, int, in_port_t *); extern int sctp_bind_add(sctp_t *, const void *, uint32_t, boolean_t, in_port_t); extern int sctp_bind_del(sctp_t *, const void *, uint32_t, boolean_t); extern int sctp_build_hdrs(sctp_t *); extern int sctp_check_abandoned_msg(sctp_t *, mblk_t *); extern void sctp_chunkify(sctp_t *, int, int); extern void sctp_clean_death(sctp_t *, int); extern void sctp_close_eager(sctp_t *); extern int sctp_compare_faddrsets(sctp_faddr_t *, sctp_faddr_t *); extern void sctp_congest_reset(sctp_t *); extern void sctp_conn_hash_insert(sctp_tf_t *, sctp_t *, int); extern void sctp_conn_hash_remove(sctp_t *); extern sctp_t *sctp_conn_match(in6_addr_t *, in6_addr_t *, uint32_t, uint_t, zoneid_t); extern sctp_t *sctp_conn_request(sctp_t *, mblk_t *, uint_t, uint_t, sctp_init_chunk_t *, mblk_t *); extern int sctp_conprim_opt_process(queue_t *, mblk_t *, int *, int *, int *); extern uint32_t sctp_cumack(sctp_t *, uint32_t, mblk_t **); extern sctp_t *sctp_create_eager(sctp_t *); extern void sctp_dispatch_rput(queue_t *, sctp_t *, sctp_hdr_t *, mblk_t *, uint_t, uint_t, in6_addr_t); extern char *sctp_display(sctp_t *, char *); extern void sctp_display_all(void); extern void sctp_error_event(sctp_t *, sctp_chunk_hdr_t *); extern void sctp_faddr_alive(sctp_t *, sctp_faddr_t *); extern int sctp_faddr_dead(sctp_t *, sctp_faddr_t *, int); extern void sctp_faddr_fini(void); extern void sctp_faddr_init(void); extern void sctp_faddr2hdraddr(sctp_faddr_t *, sctp_t *); extern void sctp_faddr2ire(sctp_t *, sctp_faddr_t *); extern void sctp_fast_rexmit(sctp_t *); extern void sctp_fill_sack(sctp_t *, unsigned char *, int); extern void sctp_free_faddr_timers(sctp_t *); extern void sctp_free_ftsn_set(sctp_ftsn_set_t *); extern void sctp_free_msg(mblk_t *); extern void sctp_free_reass(sctp_instr_t *); extern void sctp_free_set(sctp_set_t *); extern void sctp_ftsn_sets_fini(void); extern void sctp_ftsn_sets_init(void); extern int sctp_get_addrlist(sctp_t *, const void *, uint32_t *, uchar_t **, int *, size_t *); extern int sctp_get_addrparams(sctp_t *, sctp_t *, mblk_t *, sctp_chunk_hdr_t *, uint_t *); extern void sctp_get_faddr_list(sctp_t *, uchar_t *, size_t); extern mblk_t *sctp_get_first_sent(sctp_t *); extern mblk_t *sctp_get_msg_to_send(sctp_t *, mblk_t **, mblk_t *, int *, int32_t, uint32_t, sctp_faddr_t *); extern void sctp_get_saddr_list(sctp_t *, uchar_t *, size_t); extern int sctp_handle_error(sctp_t *, sctp_hdr_t *, sctp_chunk_hdr_t *, mblk_t *); extern void sctp_hash_destroy(void); extern void sctp_hash_init(void); extern int sctp_header_init_ipv4(sctp_t *, int); extern int sctp_header_init_ipv6(sctp_t *, int); extern void sctp_heartbeat_timer(sctp_t *); extern void sctp_icmp_error(sctp_t *, mblk_t *); extern void sctp_inc_taskq(void); extern void sctp_info_req(sctp_t *, mblk_t *); extern mblk_t *sctp_init_mp(sctp_t *); extern boolean_t sctp_initialize_params(sctp_t *, sctp_init_chunk_t *, sctp_init_chunk_t *); extern uint32_t sctp_init2vtag(sctp_chunk_hdr_t *); extern void sctp_intf_event(sctp_t *, in6_addr_t, int, int); extern void sctp_input_data(sctp_t *, mblk_t *, mblk_t *); extern void sctp_instream_cleanup(sctp_t *, boolean_t); extern void sctp_ire2faddr(sctp_t *, sctp_faddr_t *); extern int sctp_is_a_faddr_clean(sctp_t *); extern void sctp_kstat_init(void); extern void sctp_kstat_fini(void); extern ssize_t sctp_link_abort(mblk_t *, uint16_t, char *, size_t, int, boolean_t); extern void sctp_listen_hash_insert(sctp_tf_t *, sctp_t *); extern void sctp_listen_hash_remove(sctp_t *); extern sctp_t *sctp_lookup(sctp_t *, in6_addr_t *, sctp_tf_t *, uint32_t *, int); extern sctp_faddr_t *sctp_lookup_faddr(sctp_t *, in6_addr_t *); extern mblk_t *sctp_make_err(sctp_t *, uint16_t, void *, size_t); extern mblk_t *sctp_make_ftsn_chunk(sctp_t *, sctp_faddr_t *, sctp_ftsn_set_t *, uint_t, uint32_t); extern void sctp_make_ftsns(sctp_t *, mblk_t *, mblk_t *, mblk_t **, sctp_faddr_t *, uint32_t *); extern mblk_t *sctp_make_mp(sctp_t *, sctp_faddr_t *, int); extern mblk_t *sctp_make_sack(sctp_t *, sctp_faddr_t *, mblk_t *); extern void sctp_maxpsz_set(sctp_t *); extern void sctp_move_faddr_timers(queue_t *, sctp_t *); extern void sctp_nd_free(void); extern int sctp_nd_getset(queue_t *, MBLKP); extern boolean_t sctp_nd_init(void); extern sctp_parm_hdr_t *sctp_next_parm(sctp_parm_hdr_t *, ssize_t *); extern void sctp_ootb_shutdown_ack(sctp_t *, mblk_t *, uint_t); extern size_t sctp_options_param(const sctp_t *, void *, int); extern size_t sctp_options_param_len(const sctp_t *, int); extern void sctp_output(sctp_t *sctp); extern boolean_t sctp_param_register(sctpparam_t *, int); extern void sctp_partial_delivery_event(sctp_t *); extern int sctp_process_cookie(sctp_t *, sctp_chunk_hdr_t *, mblk_t *, sctp_init_chunk_t **, sctp_hdr_t *, int *, in6_addr_t *); extern void sctp_process_heartbeat(sctp_t *, sctp_chunk_hdr_t *); extern void sctp_process_sendq(sctp_t *); extern void sctp_process_timer(sctp_t *); extern void sctp_redo_faddr_srcs(sctp_t *); extern void sctp_regift_xmitlist(sctp_t *); extern void sctp_return_heartbeat(sctp_t *, sctp_chunk_hdr_t *, mblk_t *); extern void sctp_rexmit(sctp_t *, sctp_faddr_t *); extern void sctp_rexmit_timer(sctp_t *, sctp_faddr_t *); extern sctp_faddr_t *sctp_rotate_faddr(sctp_t *, sctp_faddr_t *); extern void sctp_sack(sctp_t *, mblk_t *); extern int sctp_secure_restart_check(mblk_t *, sctp_chunk_hdr_t *, uint32_t, int); extern void sctp_send_abort(sctp_t *, uint32_t, uint16_t, char *, size_t, mblk_t *, int, boolean_t); extern void sctp_send_cookie_ack(sctp_t *); extern void sctp_send_cookie_echo(sctp_t *, sctp_chunk_hdr_t *, mblk_t *); extern void sctp_send_err(sctp_t *, mblk_t *, sctp_faddr_t *); extern void sctp_send_initack(sctp_t *, sctp_chunk_hdr_t *, mblk_t *); extern void sctp_send_shutdown(sctp_t *, int); extern void sctp_send_heartbeat(sctp_t *, sctp_faddr_t *); extern void sctp_sendfail_event(sctp_t *, mblk_t *, int, boolean_t); extern int sctp_set_hdraddrs(sctp_t *, cred_t *); extern void sctp_sets_init(void); extern void sctp_sets_fini(void); extern void sctp_shutdown_event(sctp_t *); extern void sctp_stop_faddr_timers(sctp_t *); extern int sctp_shutdown_received(sctp_t *, sctp_chunk_hdr_t *, int, int); extern void sctp_shutdown_complete(sctp_t *); extern void sctp_set_if_mtu(sctp_t *); extern void sctp_set_iplen(sctp_t *, mblk_t *); extern void sctp_set_ulp_prop(sctp_t *); extern size_t sctp_supaddr_param_len(sctp_t *); extern size_t sctp_supaddr_param(sctp_t *, uchar_t *); extern void sctp_timer(sctp_t *, mblk_t *, clock_t); extern mblk_t *sctp_timer_alloc(sctp_t *, pfv_t); extern void sctp_timer_call(sctp_t *sctp, mblk_t *); extern void sctp_timer_free(mblk_t *); extern void sctp_timer_stop(mblk_t *); extern void sctp_unlink_faddr(sctp_t *, sctp_faddr_t *); extern in_port_t sctp_update_next_port(in_port_t, zone_t *zone); extern void sctp_update_rtt(sctp_t *, sctp_faddr_t *, clock_t); extern void sctp_user_abort(sctp_t *, mblk_t *, boolean_t); extern void sctp_validate_peer(sctp_t *); extern void sctp_wput_ioctl(queue_t *, mblk_t *); extern int sctp_xmit_list_clean(sctp_t *, ssize_t); extern void sctp_zap_addrs(sctp_t *); extern void sctp_zap_faddrs(sctp_t *, int); /* Contract private interface between SCTP and Clustering - PSARC/2005/602 */ extern void (*cl_sctp_listen)(sa_family_t, uchar_t *, uint_t, in_port_t); extern void (*cl_sctp_unlisten)(sa_family_t, uchar_t *, uint_t, in_port_t); extern void (*cl_sctp_connect)(sa_family_t, uchar_t *, uint_t, in_port_t, uchar_t *, uint_t, in_port_t, boolean_t, cl_sctp_handle_t); extern void (*cl_sctp_disconnect)(sa_family_t, cl_sctp_handle_t); extern void (*cl_sctp_assoc_change)(sa_family_t, uchar_t *, size_t, uint_t, uchar_t *, size_t, uint_t, int, cl_sctp_handle_t); extern void (*cl_sctp_check_addrs)(sa_family_t, in_port_t, uchar_t **, size_t, uint_t *, boolean_t); /* Send a mp to IP. */ #define IP_PUT(mp, conn, isv4) \ { \ if ((isv4)) \ ip_output((conn), (mp), WR(sctp_g_q), IP_WPUT); \ else \ ip_output_v6((conn), (mp), WR(sctp_g_q), IP_WPUT); \ } #define RUN_SCTP(sctp) \ { \ mutex_enter(&(sctp)->sctp_lock); \ while ((sctp)->sctp_running) \ cv_wait(&(sctp)->sctp_cv, &(sctp)->sctp_lock); \ (sctp)->sctp_running = B_TRUE; \ mutex_exit(&(sctp)->sctp_lock); \ } /* Wake up recvq taskq */ #define WAKE_SCTP(sctp) \ { \ mutex_enter(&(sctp)->sctp_lock); \ if ((sctp)->sctp_timer_mp != NULL) \ sctp_process_timer(sctp); \ (sctp)->sctp_running = B_FALSE; \ cv_broadcast(&(sctp)->sctp_cv); \ mutex_exit(&(sctp)->sctp_lock); \ } #ifdef __cplusplus } #endif #endif /* _INET_SCTP_SCTP_IMPL_H */