1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9 * or http://www.opensolaris.org/os/licensing. 10 * See the License for the specific language governing permissions 11 * and limitations under the License. 12 * 13 * When distributing Covered Code, include this CDDL HEADER in each 14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15 * If applicable, add the following below this CDDL HEADER, with the 16 * fields enclosed by brackets "[]" replaced with your own identifying 17 * information: Portions Copyright [yyyy] [name of copyright owner] 18 * 19 * CDDL HEADER END 20 */ 21 /* 22 * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 23 * Use is subject to license terms. 24 */ 25 26 #ifndef _IDM_SO_H 27 #define _IDM_SO_H 28 29 #ifdef __cplusplus 30 extern "C" { 31 #endif 32 33 #include <sys/idm/idm_transport.h> 34 #include <sys/ksocket.h> 35 36 /* 37 * Define TCP window size (send and receive buffer sizes) 38 */ 39 40 #define IDM_RCVBUF_SIZE (256 * 1024) 41 #define IDM_SNDBUF_SIZE (256 * 1024) 42 43 /* 44 * Lower and upper bounds to use the 128k buffer cache. Below the lower bound 45 * allocations will use the built-in Solaris buffer caches. We don't expect 46 * to see allocations above the upper bound because SBD currently allocates 47 * 128k buffers. 48 */ 49 50 #define IDM_SO_BUF_CACHE_LB (32 * 1024) 51 #define IDM_SO_BUF_CACHE_UB (128 * 1024) 52 53 /* sockets-specific portion of idm_svc_t */ 54 typedef struct idm_so_svc_s { 55 ksocket_t is_so; 56 kthread_t *is_thread; 57 kt_did_t is_thread_did; 58 boolean_t is_thread_running; 59 } idm_so_svc_t; 60 61 /* sockets-specific portion of idm_conn_t */ 62 typedef struct idm_so_conn_s { 63 ksocket_t ic_so; 64 65 kthread_t *ic_tx_thread; 66 kt_did_t ic_tx_thread_did; 67 boolean_t ic_tx_thread_running; 68 kmutex_t ic_tx_mutex; 69 kcondvar_t ic_tx_cv; 70 list_t ic_tx_list; /* List of PDUs for transmit */ 71 72 kthread_t *ic_rx_thread; 73 kt_did_t ic_rx_thread_did; 74 boolean_t ic_rx_thread_running; 75 } idm_so_conn_t; 76 77 void idm_so_init(idm_transport_t *it); 78 void idm_so_fini(); 79 80 /* Socket functions */ 81 82 ksocket_t 83 idm_socreate(int domain, int type, int protocol); 84 85 void idm_soshutdown(ksocket_t so); 86 87 void idm_sodestroy(ksocket_t so); 88 89 int idm_get_ipaddr(idm_addr_list_t **); 90 91 int idm_sorecv(ksocket_t so, void *msg, size_t len); 92 93 int idm_sosendto(ksocket_t so, void *buff, size_t len, 94 struct sockaddr *name, socklen_t namelen); 95 96 int idm_iov_sosend(ksocket_t so, iovec_t *iop, int iovlen, 97 size_t total_len); 98 99 int idm_iov_sorecv(ksocket_t so, iovec_t *iop, int iovlen, 100 size_t total_len); 101 102 void idm_sotx_thread(void *arg); 103 void idm_sorx_thread(void *arg); 104 105 106 int idm_sotx_pdu_constructor(void *hdl, void *arg, int flags); 107 108 void idm_sotx_pdu_destructor(void *pdu_void, void *arg); 109 110 int idm_sorx_pdu_constructor(void *hdl, void *arg, int flags); 111 112 void idm_sorx_pdu_destructor(void *pdu_void, void *arg); 113 114 void idm_so_svc_port_watcher(void *arg); 115 116 117 #ifdef __cplusplus 118 } 119 #endif 120 121 #endif /* _IDM_SO_H */ 122