1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
/*
* 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 2009 Sun Microsystems, Inc. All rights reserved.
* Use is subject to license terms.
*/
#ifndef _IDM_SO_H
#define _IDM_SO_H
#ifdef __cplusplus
extern "C" {
#endif
#include <sys/idm/idm_transport.h>
#include <sys/ksocket.h>
/*
* Define TCP window size (send and receive buffer sizes)
*/
#define IDM_RCVBUF_SIZE (256 * 1024)
#define IDM_SNDBUF_SIZE (256 * 1024)
/*
* Lower and upper bounds to use the 128k buffer cache. Below the lower bound
* allocations will use the built-in Solaris buffer caches. We don't expect
* to see allocations above the upper bound because SBD currently allocates
* 128k buffers.
*/
#define IDM_SO_BUF_CACHE_LB (32 * 1024)
#define IDM_SO_BUF_CACHE_UB (128 * 1024)
/* sockets-specific portion of idm_svc_t */
typedef struct idm_so_svc_s {
ksocket_t is_so;
kthread_t *is_thread;
kt_did_t is_thread_did;
boolean_t is_thread_running;
} idm_so_svc_t;
/* sockets-specific portion of idm_conn_t */
typedef struct idm_so_conn_s {
ksocket_t ic_so;
kthread_t *ic_tx_thread;
kt_did_t ic_tx_thread_did;
boolean_t ic_tx_thread_running;
kmutex_t ic_tx_mutex;
kcondvar_t ic_tx_cv;
list_t ic_tx_list; /* List of PDUs for transmit */
kthread_t *ic_rx_thread;
kt_did_t ic_rx_thread_did;
boolean_t ic_rx_thread_running;
} idm_so_conn_t;
void idm_so_init(idm_transport_t *it);
void idm_so_fini();
/* used by idm_so_timed_socket_connect */
typedef struct idm_so_timed_socket_s {
kcondvar_t it_cv;
boolean_t it_callback_called;
int it_socket_error_code;
} idm_so_timed_socket_t;
/* Socket functions */
ksocket_t
idm_socreate(int domain, int type, int protocol);
void idm_soshutdown(ksocket_t so);
void idm_sodestroy(ksocket_t so);
int idm_ss_compare(const struct sockaddr_storage *cmp_ss1,
const struct sockaddr_storage *cmp_ss2,
boolean_t v4_mapped_as_v4,
boolean_t compare_ports);
int idm_get_ipaddr(idm_addr_list_t **);
void idm_addr_to_sa(idm_addr_t *dportal,
struct sockaddr_storage *sa);
#define IDM_SA_NTOP_BUFSIZ (INET6_ADDRSTRLEN + sizeof ("[].65535") + 1)
const char *idm_sa_ntop(const struct sockaddr_storage *sa,
char *buf, size_t size);
int idm_sorecv(ksocket_t so, void *msg, size_t len);
int idm_sosendto(ksocket_t so, void *buff, size_t len,
struct sockaddr *name, socklen_t namelen);
int idm_iov_sosend(ksocket_t so, iovec_t *iop, int iovlen,
size_t total_len);
int idm_iov_sorecv(ksocket_t so, iovec_t *iop, int iovlen,
size_t total_len);
void idm_sotx_thread(void *arg);
void idm_sorx_thread(void *arg);
int idm_sotx_pdu_constructor(void *hdl, void *arg, int flags);
void idm_sotx_pdu_destructor(void *pdu_void, void *arg);
int idm_sorx_pdu_constructor(void *hdl, void *arg, int flags);
void idm_sorx_pdu_destructor(void *pdu_void, void *arg);
void idm_so_svc_port_watcher(void *arg);
int idm_so_timed_socket_connect(ksocket_t ks,
struct sockaddr_storage *sa, int sa_sz, int login_max_usec);
#ifdef __cplusplus
}
#endif
#endif /* _IDM_SO_H */
|
