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
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
|
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#if !defined(hysock_h)
#define hysock_h
/******************************************************\
Portable socket library implementation.
\******************************************************/
#include "xmlvm-hy.h"
#include <errno.h>
#include <signal.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#if !defined(ZOS)
#include <netinet/tcp.h>
#else /* !defined(ZOS) */
#include <netinet/tcp_var.h>
#endif /* !defined(ZOS) */
#include <netdb.h>
#include <sys/time.h>
#include <stdlib.h>
#if !defined(ZOS)
#if !defined(MACOSX) && !defined(__CYGWIN__)
#include <sys/socketvar.h>
#endif
#else /* !defined(ZOS) */
#include <arpa/inet.h>
#include <xti.h>
#endif /* !defined(ZOS) */
#include "hysocket.h"
#include "hycomp.h"
// #include "hyport.h"
#if defined(DEBUG)
#define HYSOCKDEBUG(x, err) printf(x, err)
#define HYSOCKDEBUGH(x, err) printf(x, err)
#define HYSOCKDEBUGPRINT(x) printf(x)
#else
#define HYSOCKDEBUG(x, err)
#define HYSOCKDEBUGH(x, err)
#define HYSOCKDEBUGPRINT(x)
#endif
/* the following defines are used to determine how gethostby*_r calls should be handled.*/
/* HOSTENT_DATA_R: if the HOSTENT_DATA structure is used */
#define HOSTENT_DATA_R (defined(AIX))
/* GLIBC_R: uses the GLIBC versions */
#define GLIBC_R (defined(LINUX))
/* ORIGINAL_R: the original gethostby* call is thread safe */
#define ORIGINAL_R defined(FREEBSD)
/* TOFIX: FreeBSD man page says:
* Though these functions are thread-safe, still it is recommended to use
* the getaddrinfo(3) family of functions, instead.
*/
/* NO_R: gethostby*_r calls do not exist and the normal gethostby* calls are not threadsafe */
#define NO_R (defined(MACOSX) || defined(__CYGWIN__))
/* OTHER_R: everything else */
#define OTHER_R ((!HOSTENT_DATA_R)&&(!GLIBC_R)&&(!ORIGINAL_R)&&(!NO_R))
/* Converts (seconds, microseconds) to milliseconds */
#define TO_MILLIS(sec, microsec) (sec * 1000 + (microsec + 999) / 1000)
/* os types */
typedef int OSSOCKET; /* as returned by socket() */
typedef struct sockaddr_in OSSOCKADDR; /* as used by bind() and friends */
typedef struct hostent OSHOSTENT;
typedef fd_set OSFDSET;
typedef struct timeval OSTIMEVAL;
typedef struct linger OSLINGER;
typedef struct sockaddr OSADDR;
typedef struct sockaddr_in6 OSSOCKADDR_IN6; /* IPv6 */
typedef struct ipv6_mreq OSIPMREQ6;
typedef struct addrinfo OSADDRINFO; /* IPv6 */
typedef struct sockaddr_storage OSSOCKADDR_STORAGE; /* IPv6 */
/*
* Socket Types
*/
#define OSSOCK_ANY 0 /* for getaddrinfo hints */
#define OSSOCK_STREAM SOCK_STREAM /* stream socket */
#define OSSOCK_DGRAM SOCK_DGRAM /* datagram socket */
#define OSSOCK_RAW SOCK_RAW /* raw-protocol interface */
#define OSSOCK_RDM SOCK_RDM /* reliably-delivered message */
#define OSSOCK_SEQPACKET SOCK_SEQPACKET /* sequenced packet stream */
#if defined(HOSTENT_DATA_R)
typedef struct hostent_data OSHOSTENT_DATA;
#endif
typedef struct ip_mreq OSIPMREQ;
#define OSSOMAXCONN SOMAXCONN
#define OS_BADSOCKET -1 /* Provide bad socket constant */
/* defines for socket levels */
#define OS_SOL_SOCKET SOL_SOCKET
#define OS_IPPROTO_TCP IPPROTO_TCP
#define OS_IPPROTO_IP IPPROTO_IP
#if defined(IPv6_FUNCTION_SUPPORT)
#define OS_IPPROTO_IPV6 IPPROTO_IPV6
#endif
/* defines for socket options */
#define OS_SO_LINGER SO_LINGER
#define OS_SO_KEEPALIVE SO_KEEPALIVE
#define OS_TCP_NODELAY TCP_NODELAY
#define OS_SO_REUSEADDR SO_REUSEADDR
#define OS_SO_SNDBUF SO_SNDBUF
#define OS_SO_RCVBUF SO_RCVBUF
#define OS_SO_BROADCAST SO_BROADCAST /* Support datagram broadcasts */
#define OS_SO_OOBINLINE SO_OOBINLINE
#define OS_IP_TOS IP_TOS
/* defines for socket options, multicast */
#define OS_MCAST_TTL IP_MULTICAST_TTL
#define OS_MCAST_ADD_MEMBERSHIP IP_ADD_MEMBERSHIP
#define OS_MCAST_DROP_MEMBERSHIP IP_DROP_MEMBERSHIP
#define OS_MCAST_INTERFACE IP_MULTICAST_IF
#define OS_MCAST_LOOP IP_MULTICAST_LOOP
#if defined(IPv6_FUNCTION_SUPPORT)
#define OS_MCAST_INTERFACE_2 IPV6_MULTICAST_IF
#if defined(FREEBSD) || defined(MACOSX) || defined(ZOS)
#define OS_IPV6_ADD_MEMBERSHIP IPV6_JOIN_GROUP
#define OS_IPV6_DROP_MEMBERSHIP IPV6_LEAVE_GROUP
#else
#define OS_IPV6_ADD_MEMBERSHIP IPV6_ADD_MEMBERSHIP
#define OS_IPV6_DROP_MEMBERSHIP IPV6_DROP_MEMBERSHIP
#endif
#endif
/* defines for the unix error constants. These may be overriden for specific platforms. */
#define HYPORT_ERROR_SOCKET_UNIX_CONNRESET ECONNRESET
#define HYPORT_ERROR_SOCKET_UNIX_EAGAIN EAGAIN
#define HYPORT_ERROR_SOCKET_UNIX_EAFNOSUPPORT EAFNOSUPPORT
#define HYPORT_ERROR_SOCKET_UNIX_EBADF EBADF
#define HYPORT_ERROR_SOCKET_UNIX_ECONNRESET ECONNRESET
#define HYPORT_ERROR_SOCKET_UNIX_EINVAL EINVAL
#define HYPORT_ERROR_SOCKET_UNIX_EINTR EINTR
#define HYPORT_ERROR_SOCKET_UNIX_EFAULT EFAULT
#define HYPORT_ERROR_SOCKET_UNIX_ENOPROTOOPT ENOPROTOOPT
#define HYPORT_ERROR_SOCKET_UNIX_ENOTCONN ENOTCONN
#define HYPORT_ERROR_SOCKET_UNIX_EPROTONOSUPPORT EPROTONOSUPPORT
#define HYPORT_ERROR_SOCKET_UNIX_HOSTNOTFOUND HOST_NOT_FOUND
#define HYPORT_ERROR_SOCKET_UNIX_ENOBUFS ENOBUFS
#define HYPORT_ERROR_SOCKET_UNIX_NODATA NO_DATA
#define HYPORT_ERROR_SOCKET_UNIX_NORECOVERY NO_RECOVERY
#define HYPORT_ERROR_SOCKET_UNIX_ENOTSOCK ENOTSOCK
#define HYPORT_ERROR_SOCKET_UNIX_TRYAGAIN TRY_AGAIN
#define HYPORT_ERROR_SOCKET_UNIX_EOPNOTSUP EOPNOTSUPP
#define HYPORT_ERROR_SOCKET_UNIX_ETIMEDOUT ETIMEDOUT
#define HYPORT_ERROR_SOCKET_UNIX_CONNREFUSED ECONNREFUSED
#define HYPORT_ERROR_SOCKET_UNIX_EINPROGRESS EINPROGRESS
#define HYPORT_ERROR_SOCKET_UNIX_ENETUNREACH ENETUNREACH
#define HYPORT_ERROR_SOCKET_UNIX_EACCES EACCES
/* platform constants */
#define HYSOCK_MAXCONN OSSOMAXCONN;
#define HYSOCK_BADSOCKET OS_BADSOCKET /* Provide bad socket constant */
/* defines added for IPv6 */
#define OS_AF_INET4 AF_INET
#define OS_AF_UNSPEC AF_UNSPEC
#define OS_PF_UNSPEC PF_UNSPEC
#define OS_PF_INET4 PF_INET
#define OS_INET4_ADDRESS_LENGTH INET_ADDRSTRLEN
#if defined(NI_MAXHOST)
#define OSNIMAXHOST NI_MAXHOST
#define OSNIMAXSERV NI_MAXSERV
#else
#define OSNIMAXHOST 1025
#define OSNIMAXSERV 32
#endif
#if defined(AF_INET6)
#define OS_AF_INET6 AF_INET6
#define OS_PF_INET6 PF_INET6
#define OS_INET6_ADDRESS_LENGTH INET6_ADDRSTRLEN
#else
#define OS_AF_INET6 -1
#define OS_PF_INET6 -1
#define OS_INET6_ADDRESS_LENGTH 46
#endif
/*platform structs */
typedef struct hysocket_struct
{
OSSOCKET sock;
U_16 family;
} hysocket_struct;
/* The sockets are now structs */
#if defined(NO_LVALUE_CASTING)
#define SOCKET_CAST(x) ((struct hysocket_struct*) x)->sock
#else
#define SOCKET_CAST(x) ((struct hysocket_struct*) x)->sock
#endif
typedef struct hysockaddr_struct
{
#if defined(IPv6_FUNCTION_SUPPORT)
OSSOCKADDR_STORAGE addr;
#else
OSSOCKADDR addr;
#endif
} hysockaddr_struct;
typedef struct hyhostent_struct
{
OSHOSTENT *entity;
} hyhostent_struct;
typedef struct hyfdset_struct
{
OSFDSET handle;
} hyfdset_struct;
typedef struct hytimeval_struct
{
OSTIMEVAL time;
} hytimeval_struct;
typedef struct hylinger_struct
{
OSLINGER linger;
} hylinger_struct;
typedef struct hyipmreq_struct
{
int addrpair;
} hyipmreq_struct;
#define GET_HOST_BUFFER_SIZE 512
/* The gethostBuffer is allocated bufferSize + EXTRA_SPACE, while gethostby*_r is only aware of bufferSize
* because there seems to be a bug on Linux 386 where gethostbyname_r writes past the end of the
* buffer. This bug has not been observed on other platforms, but EXTRA_SPACE is added anyway as a precaution.*/
#define EXTRA_SPACE 128
/*size is 16 because an IP string is "xxx.xxx.xxx.xxx" + 1 null character */
#define NTOA_SIZE 16
/** new structure for IPv6 mulitcast requests */
typedef struct hyipv6_mreq_struct
{
#if defined(IPv6_FUNCTION_SUPPORT)
OSIPMREQ6 mreq;
#else
int dummy;
#endif
} hyipv6_mreq_struct;
/* structure for returning either and IPV4 or IPV6 ip address */
typedef struct hyipAddress_struct
{
union
{
#if defined(IPv6_FUNCTION_SUPPORT)
U_8 bytes[sizeof (struct in6_addr)];
#else
U_8 bytes[sizeof (struct in_addr)];
#endif
struct in_addr inAddr;
#if defined(IPv6_FUNCTION_SUPPORT)
struct in6_addr in6Addr;
#endif
} addr;
U_32 length;
U_32 scope;
} hyipAddress_struct;
/* structure for returning network interface information */
typedef struct hyNetworkInterface_struct
{
char *name;
char *displayName;
U_32 numberAddresses;
U_32 index;
struct hyipAddress_struct *addresses;
} hyNetworkInterface_struct;
/* array of network interface structures */
typedef struct hyNetworkInterfaceArray_struct
{
U_32 length;
struct hyNetworkInterface_struct *elements;
} hyNetworkInterfaceArray_struct;
/** new structure for IPv6 addrinfo will either point to a hostent or
an addr info depending on the IPv6 support for this OS */
typedef struct hyaddrinfo_struct
{
void *addr_info;
int length;
} hyaddrinfo_struct;
#endif
|
