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
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
|
/*
* 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 _LIBILB_IMPL_H
#define _LIBILB_IMPL_H
#ifdef __cplusplus
extern "C" {
#endif
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/note.h>
#include <netinet/in.h>
#include <netdb.h>
#include <net/if.h>
#include <inet/ilb.h>
#include <libilb.h>
#include <thread.h>
#include <synch.h>
#if !defined max
#define max(a, b) ((a) > (b) ? (a) : (b))
#endif
/* The UNIX domain socket path to talk to ilbd. */
#define SOCKET_PATH "/var/run/daemon/ilb_sock"
/* The max message size for communicating with ilbd */
#define ILBD_MSG_SIZE 102400
/*
* moral equivalent of ntohl for IPv6 addresses, MSB and LSB (64 bit each),
* assign to uint64_t variables
*/
#define INV6_N2H_MSB64(addr) \
(((uint64_t)ntohl((addr)->_S6_un._S6_u32[0]) << 32) + \
(ntohl((addr)->_S6_un._S6_u32[1])))
#define INV6_N2H_LSB64(addr) \
(((uint64_t)ntohl((addr)->_S6_un._S6_u32[2]) << 32) + \
(ntohl((addr)->_S6_un._S6_u32[3])))
/*
* moral equiv. of htonl of MSB and LSB 64-bit portions to an IPv6 address
*/
#define INV6_H2N_MSB64(addr, msb) \
(addr)->_S6_un._S6_u32[0] = htonl((msb) >> 32); \
(addr)->_S6_un._S6_u32[1] = htonl((msb) & 0xffffffff)
#define INV6_H2N_LSB64(addr, lsb) \
(addr)->_S6_un._S6_u32[2] = htonl((lsb) >> 32); \
(addr)->_S6_un._S6_u32[3] = htonl((lsb) & 0xffffffff)
#define IP_COPY_CLI_2_IMPL(_e, _i) \
bzero(_i, sizeof (*(_i))); \
if ((_e)->ia_af == AF_INET6) \
(void) memcpy((_i), &(_e)->ia_v6, sizeof (*(_i))); \
else \
IN6_INADDR_TO_V4MAPPED(&(_e)->ia_v4, (_i))
#define IP_COPY_IMPL_2_CLI(_i, _e) \
do { \
bzero(_e, sizeof (*(_e))); \
if (IN6_IS_ADDR_V4MAPPED(_i)) { \
(_e)->ia_af = AF_INET; \
IN6_V4MAPPED_TO_INADDR((_i), &(_e)->ia_v4); \
} else { \
(_e)->ia_af = AF_INET6; \
(void) memcpy(&(_e)->ia_v6, (_i), \
sizeof ((_e)->ia_v6)); \
} \
_NOTE(CONSTCOND) \
} while (0)
#define GET_AF(_a) IN6_IS_ADDR_V4MAPPED(_a)?AF_INET:AF_INET6
#define IS_AF_VALID(_af) (_af == AF_INET || _af == AF_INET6)
typedef enum {
ILBD_BAD_CMD = 0,
/* servergroup commands */
ILBD_CREATE_SERVERGROUP,
ILBD_ADD_SERVER_TO_GROUP,
ILBD_REM_SERVER_FROM_GROUP,
ILBD_ENABLE_SERVER,
ILBD_DISABLE_SERVER,
ILBD_DESTROY_SERVERGROUP,
ILBD_RETRIEVE_SG_NAMES, /* names of all SGs registered */
ILBD_RETRIEVE_SG_HOSTS, /* all hosts for a given SG (hndl) */
ILBD_SRV_ADDR2ID, /* fill in serverID for given address */
ILBD_SRV_ID2ADDR, /* fill in address from given serverID */
/* rule commands */
ILBD_CREATE_RULE,
ILBD_DESTROY_RULE,
ILBD_ENABLE_RULE,
ILBD_DISABLE_RULE,
ILBD_RETRIEVE_RULE_NAMES,
ILBD_RETRIEVE_RULE,
ILBD_CREATE_HC,
ILBD_DESTROY_HC,
ILBD_GET_HC_INFO,
ILBD_GET_HC_SRVS,
ILBD_GET_HC_RULES,
ILBD_RETRIEVE_HC_NAMES,
ILBD_SHOW_NAT, /* list the NAT table */
ILBD_SHOW_PERSIST, /* list the sticky table */
ILBD_CMD_OK, /* Requested operation succeeds. */
ILBD_CMD_ERROR /* Rquested operation fails. */
} ilbd_cmd_t;
typedef struct sg_srv {
int32_t sgs_flags; /* enabled, dis- */
struct in6_addr sgs_addr;
int32_t sgs_minport;
int32_t sgs_maxport;
int32_t sgs_id; /* numerical part of srvID */
char sgs_srvID[ILB_NAMESZ]; /* "name" given to server */
} ilb_sg_srv_t;
typedef struct sg_info {
int32_t sg_flags;
char sg_name[ILB_SGNAME_SZ];
int32_t sg_srvcount;
ilb_sg_srv_t sg_servers[];
} ilb_sg_info_t;
typedef char ilbd_name_t[ILB_NAMESZ];
typedef struct ilbd_namelist {
int32_t ilbl_flags;
int32_t ilbl_count;
ilbd_name_t ilbl_name[];
} ilbd_namelist_t;
#define ILBL_NAME_OFFSET (offsetof(ilbd_namelist_t, ilbl_name))
typedef struct rule_info {
int32_t rl_flags;
char rl_name[ILB_NAMESZ];
struct in6_addr rl_vip;
uint16_t rl_proto;
uint16_t rl_ipversion;
int32_t rl_minport;
int32_t rl_maxport;
ilb_algo_t rl_algo;
ilb_topo_t rl_topo;
struct in6_addr rl_nat_src_start;
struct in6_addr rl_nat_src_end;
struct in6_addr rl_stickymask;
uint32_t rl_conndrain;
uint32_t rl_nat_timeout;
uint32_t rl_sticky_timeout;
in_port_t rl_hcport;
ilb_hcp_flags_t rl_hcpflag;
char rl_sgname[ILB_SGNAME_SZ];
char rl_hcname[ILB_NAMESZ];
} ilb_rule_info_t;
/*
* Struct to represent show NAT request and reply.
*
* sn_num: (request) indicates the number of entries wanted;
* (reply) the number of entries returned;
* sn_data: NAT/persist able entries (is uint32_t aligned).
*/
typedef struct {
uint32_t sn_num;
uint32_t sn_data[];
} ilb_show_info_t;
/*
* Struct to represent the set of servers associated with a hc object.
*
* rs_num_srvs: number of servers in this struct.
* rs_srvs: array of servers.
*/
typedef struct {
uint32_t rs_num_srvs;
ilb_hc_srv_t rs_srvs[];
} ilb_hc_rule_srv_t;
typedef struct ilb_handle_impl {
mutex_t h_lock;
cond_t h_cv;
boolean_t h_busy;
boolean_t h_valid;
boolean_t h_closing;
uint32_t h_waiter;
int h_socket;
ilb_status_t h_error; /* ... that caused invalidation */
} ilb_handle_impl_t;
/*
* Communication flags used in ilb_comm_t.
*
* ILB_COMM_END: end of communication
*/
#define ILB_COMM_END 0x1
/*
* The message structure used to communicate with ilbd.
*
* ic_cmd: the message type.
* ic_flags: communication flags
* ic_data: message data (is uint32_t aligned).
*/
typedef struct {
ilbd_cmd_t ic_cmd;
int32_t ic_flags;
uint32_t ic_data[];
} ilb_comm_t;
ilb_status_t i_check_ip_range(ilb_ip_addr_t *, ilb_ip_addr_t *);
ilb_status_t i_ilb_do_comm(ilb_handle_t, ilb_comm_t *, size_t, ilb_comm_t *,
size_t *);
void i_ilb_close_comm(ilb_handle_t);
struct in6_addr i_next_ip_addr(struct in6_addr *, int);
ilb_status_t i_ilb_retrieve_rule_names(ilb_handle_t, ilb_comm_t **,
size_t *);
ilb_comm_t *i_ilb_alloc_req(ilbd_cmd_t, size_t *);
#ifdef __cplusplus
}
#endif
#endif /* _LIBILB_IMPL_H */
|
