socksctp.h revision 903a11ebdc8df157c4700150f41f1f262f4a8ae8
/*
* 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 2008 Sun Microsystems, Inc. All rights reserved.
* Use is subject to license terms.
*/
#ifndef _SOCKSCTP_H_
#define _SOCKSCTP_H_
#pragma ident "%Z%%M% %I% %E% SMI"
#ifdef __cplusplus
extern "C" {
#endif
/*
* SCTP socket structure.
*
* The opaque pointer passed in upcalls is either a pointer to sctp_sonode,
* or sctp_soassoc. The identification is done through the first element
* in data structure (if it cannot be identified by upcall which gets called).
*/
struct sctp_sonode {
int ss_type; /* sonode or soassoc */
struct sonode ss_so;
struct sockaddr_in6 ss_laddr; /* can fit both v4 & v6 */
struct sockaddr_in6 ss_faddr;
sctp_assoc_t ss_maxassoc; /* assoc array size for 1-N */
sctp_assoc_t ss_assoccnt; /* current # of assocs */
struct sctp_sa_id *ss_assocs; /* assoc array for 1-N */
kcondvar_t ss_txdata_cv; /* wait TX window to open */
int ss_wroff;
size_t ss_wrsize;
int ss_txqueued; /* queued tx bytes */
kcondvar_t ss_rxdata_cv; /* for waiting RX data */
mblk_t *ss_rxdata; /* queued rx data */
mblk_t **ss_rxtail; /* ptr to last message */
int ss_rxqueued; /* queued rx bytes/# of conn */
struct pollhead ss_poll_list;
};
/*
* Association for 1-N sockets.
*/
struct sctp_soassoc {
int ssa_type;
sctp_assoc_t ssa_id; /* association ID */
uint_t ssa_refcnt;
struct sctp_sonode *ssa_sonode;
struct sctp_s *ssa_conn; /* opaque ptr passed to SCTP */
uint_t ssa_state; /* same as so_state */
int ssa_error; /* same as so_error */
int ssa_txqueued; /* queued tx bytes */
int ssa_wroff;
size_t ssa_wrsize;
int ssa_rxqueued; /* queued rx bytes/# of conn */
};
/* 1-N socket association cache defined in socksctp.c */
extern kmem_cache_t *sosctp_assoccache;
/*
* Association array element.
*
* Association data structures for 1-N socket are stored in
* an array in similar manner to file descriptor array.
* Each association is identified by its association ID, which also
* is used as an index to this array (again, like file descriptor number).
*/
struct sctp_sa_id {
sctp_assoc_t ssi_alloc;
struct sctp_soassoc *ssi_assoc;
};
extern sctp_upcalls_t sosctp_sock_upcalls;
extern sctp_upcalls_t sosctp_assoc_upcalls;
extern struct vnodeops *socksctp_vnodeops;
extern const fs_operation_def_t socksctp_vnodeops_template[];
extern void sosctp_free(struct sonode *so);
extern int sosctp_chgpgrp(struct sctp_sonode *ss, pid_t pid);
extern void sosctp_sendsig(struct sctp_sonode *ss, int event);
extern int sosctp_bind(struct sonode *so, struct sockaddr *name,
socklen_t namelen, int flags);
extern int sosctp_recvmsg(struct sonode *, struct nmsghdr *, struct uio *);
extern int sosctp_aid_grow(struct sctp_sonode *ss, sctp_assoc_t maxid,
int kmflags);
extern sctp_assoc_t sosctp_aid_get(struct sctp_sonode *ss);
extern void sosctp_aid_reserve(struct sctp_sonode *ss, sctp_assoc_t id,
int incr);
extern struct cmsghdr *sosctp_find_cmsg(const uchar_t *control, socklen_t clen,
int type);
extern void sosctp_pack_cmsg(const uchar_t *, struct nmsghdr *, int);
extern int sosctp_assoc(struct sctp_sonode *ss, sctp_assoc_t id,
struct sctp_soassoc **ssa);
extern struct sctp_soassoc *sosctp_assoc_create(struct sctp_sonode *ss,
int kmflags);
extern void sosctp_assoc_free(struct sctp_sonode *ss, struct sctp_soassoc *ssa);
extern int sosctp_assoc_createconn(struct sctp_sonode *ss,
const struct sockaddr *name, socklen_t namelen,
const uchar_t *control, socklen_t controllen, int fflag,
struct sctp_soassoc **ssap);
extern void sosctp_assoc_move(struct sctp_sonode *ss, struct sctp_sonode *nss,
struct sctp_soassoc *ssa);
extern void sosctp_so_inherit(struct sctp_sonode *lss, struct sctp_sonode *nss);
extern void sosctp_assoc_isconnecting(struct sctp_soassoc *ssa);
extern void sosctp_assoc_isconnected(struct sctp_soassoc *ssa);
extern void sosctp_assoc_isdisconnecting(struct sctp_soassoc *ssa);
extern void sosctp_assoc_isdisconnected(struct sctp_soassoc *ssa, int error);
extern int sosctp_waitconnected(struct sonode *so, int fmode);
extern int sosctp_uiomove(mblk_t *hdr_mp, ssize_t count, ssize_t blk_size,
int wroff, struct uio *uiop, int flags, cred_t *cr);
/*
* Data structure types.
*/
#define SOSCTP_SOCKET 0x1
#define SOSCTP_ASSOC 0x2
#define SOTOSSO(so) ((struct sctp_sonode *)(((char *)so) - \
offsetof(struct sctp_sonode, ss_so)))
#define SSA_REFHOLD(ssa) \
{ \
ASSERT(MUTEX_HELD(&(ssa)->ssa_sonode->ss_so.so_lock)); \
ASSERT((ssa)->ssa_refcnt > 0); \
++(ssa)->ssa_refcnt; \
dprint(3, ("ssa_refhold on %p %d (%s,%d)\n", \
(void *)(ssa), (ssa)->ssa_refcnt, \
__FILE__, __LINE__)); \
}
#define SSA_REFRELE(ss, ssa) \
{ \
dprint(3, ("ssa_refrele on %p %d (%s, %d)\n", \
(void *)(ssa), \
(ssa)->ssa_refcnt-1, __FILE__, __LINE__)); \
ASSERT((ssa)->ssa_refcnt > 0); \
if (--(ssa)->ssa_refcnt == 0) { \
sosctp_assoc_free(ss, ssa); \
} \
}
/*
* Event flags to sosctp_sendsig().
*/
#define SCTPSIG_WRITE 0x1
#define SCTPSIG_READ 0x2
#ifdef __cplusplus
}
#endif
#endif /* _SOCKSCTP_H_ */