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
|
/*
* %CopyrightBegin%
*
* Copyright Ericsson AB 2018-2021. All Rights Reserved.
*
* Licensed 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.
*
* %CopyrightEnd%
*
* ----------------------------------------------------------------------
* Purpose : Utility "stuff" for socket and prim_net (nifs).
* ----------------------------------------------------------------------
*
*/
#ifndef SOCKET_UTIL_H__
#define SOCKET_UTIL_H__
#include <erl_nif.h>
#include "socket_int.h"
#define CHAR(C) ((char) (C))
#define UCHAR(C) ((unsigned char) (C))
#define INT(I) ((int) (I))
#define UINT(U) ((unsigned int) (U))
#define LONG(L) ((long) (L))
#define ULONG(L) ((unsigned long) (L))
#define SZT(I) ((size_t) (I))
#define VOIDP(P) ((void*) (P))
#define CHARP(P) ((char*) (P))
#define UCHARP(P) ((unsigned char*) (P))
#define ESOCK_ABORT(E) esock_abort(E, __func__, __FILE__, __LINE__)
#define ESOCK_ASSERT(e) ((void) ((e) ? 1 : (ESOCK_ABORT(#e), 0)))
extern
BOOLEAN_T esock_get_bool_from_map(ErlNifEnv* env,
ERL_NIF_TERM map,
ERL_NIF_TERM key,
BOOLEAN_T def);
extern
BOOLEAN_T esock_decode_iov(ErlNifEnv* env,
ERL_NIF_TERM eIOV,
ErlNifBinary* bufs,
struct iovec* iov,
size_t len,
ssize_t* totSize);
extern
void esock_encode_iov(ErlNifEnv* env,
ssize_t read,
struct iovec* iov,
size_t len,
ErlNifBinary* data,
ERL_NIF_TERM* eIOV);
extern
BOOLEAN_T esock_decode_sockaddr(ErlNifEnv* env,
ERL_NIF_TERM eSockAddr,
ESockAddress* sockAddrP,
SOCKLEN_T* addrLen);
extern
void esock_encode_sockaddr(ErlNifEnv* env,
ESockAddress* sockAddrP,
SOCKLEN_T addrLen,
ERL_NIF_TERM* eSockAddr);
extern
BOOLEAN_T esock_decode_sockaddr_in(ErlNifEnv* env,
ERL_NIF_TERM eSockAddr,
struct sockaddr_in* sockAddrP,
SOCKLEN_T* addrLen);
extern
void esock_encode_sockaddr_in(ErlNifEnv* env,
struct sockaddr_in* sockAddrP,
SOCKLEN_T addrLen,
ERL_NIF_TERM* eSockAddr);
#if defined(HAVE_IN6) && defined(AF_INET6)
extern
BOOLEAN_T esock_decode_sockaddr_in6(ErlNifEnv* env,
ERL_NIF_TERM eSockAddr,
struct sockaddr_in6* sockAddrP,
SOCKLEN_T* addrLen);
extern
void esock_encode_sockaddr_in6(ErlNifEnv* env,
struct sockaddr_in6* sockAddrP,
SOCKLEN_T addrLen,
ERL_NIF_TERM* eSockAddr);
#endif
#ifdef HAS_AF_LOCAL
extern
BOOLEAN_T esock_decode_sockaddr_un(ErlNifEnv* env,
ERL_NIF_TERM eSockAddr,
struct sockaddr_un* sockAddrP,
SOCKLEN_T* addrLen);
extern
void esock_encode_sockaddr_un(ErlNifEnv* env,
struct sockaddr_un* sockAddrP,
SOCKLEN_T addrLen,
ERL_NIF_TERM* eSockAddr);
#endif
#ifdef HAVE_NETPACKET_PACKET_H
extern
void esock_encode_sockaddr_ll(ErlNifEnv* env,
struct sockaddr_ll* sockAddrP,
SOCKLEN_T addrLen,
ERL_NIF_TERM* eSockAddr);
#endif
extern
BOOLEAN_T esock_decode_in_addr(ErlNifEnv* env,
ERL_NIF_TERM eAddr,
struct in_addr* inAddrP);
extern
void esock_encode_in_addr(ErlNifEnv* env,
struct in_addr* addrP,
ERL_NIF_TERM* eAddr);
#if defined(HAVE_IN6) && defined(AF_INET6)
extern
BOOLEAN_T esock_decode_in6_addr(ErlNifEnv* env,
ERL_NIF_TERM eAddr,
struct in6_addr* inAddrP);
extern
void esock_encode_in6_addr(ErlNifEnv* env,
struct in6_addr* addrP,
ERL_NIF_TERM* eAddr);
#endif
extern void esock_encode_timeval(ErlNifEnv* env,
struct timeval* timeP,
ERL_NIF_TERM* eTime);
extern BOOLEAN_T esock_decode_timeval(ErlNifEnv* env,
ERL_NIF_TERM eTime,
struct timeval* timeP);
extern
void esock_encode_domain(ErlNifEnv* env,
int domain,
ERL_NIF_TERM* eDomain);
extern
int esock_decode_domain(ErlNifEnv* env,
ERL_NIF_TERM eDomain,
int* domain);
extern
BOOLEAN_T esock_decode_type(ErlNifEnv* env,
ERL_NIF_TERM eType,
int* type);
extern
void esock_encode_type(ErlNifEnv* env,
int type,
ERL_NIF_TERM* eType);
extern
void esock_encode_packet_protocol(ErlNifEnv* env,
unsigned short protocol,
ERL_NIF_TERM* eProtocol);
extern
void esock_encode_packet_hatype(ErlNifEnv* env,
unsigned short hatype,
ERL_NIF_TERM* eHaType);
extern
void esock_encode_packet_pkttype(ErlNifEnv* env,
unsigned short pkttype,
ERL_NIF_TERM* ePktType);
extern
void esock_encode_packet_addr(ErlNifEnv* env,
unsigned char len,
unsigned char* addr,
ERL_NIF_TERM* eAddr);
extern
BOOLEAN_T esock_decode_bufsz(ErlNifEnv* env,
ERL_NIF_TERM eVal,
size_t defSz,
size_t* sz);
extern
BOOLEAN_T esock_decode_string(ErlNifEnv* env,
const ERL_NIF_TERM eString,
char** stringP);
extern
BOOLEAN_T esock_extract_bool_from_map(ErlNifEnv* env,
ERL_NIF_TERM map,
ERL_NIF_TERM key,
BOOLEAN_T def);
extern
BOOLEAN_T esock_extract_pid_from_map(ErlNifEnv* env,
ERL_NIF_TERM map,
ERL_NIF_TERM key,
ErlNifPid* pid);
extern
BOOLEAN_T esock_extract_int_from_map(ErlNifEnv* env,
ERL_NIF_TERM map,
ERL_NIF_TERM key,
int* val);
extern
BOOLEAN_T esock_decode_bool(ERL_NIF_TERM eVal, BOOLEAN_T* val);
extern
ERL_NIF_TERM esock_encode_bool(BOOLEAN_T val);
extern
BOOLEAN_T esock_decode_level(ErlNifEnv* env, ERL_NIF_TERM eVal, int *val);
extern
ERL_NIF_TERM esock_encode_level(ErlNifEnv* env, int level);
extern
size_t esock_strnlen(const char *s, size_t maxlen);
extern
void __noreturn
esock_abort(const char* expr,
const char* func,
const char* file,
int line);
extern
ERL_NIF_TERM esock_self(ErlNifEnv* env);
extern
ERL_NIF_TERM esock_make_ok2(ErlNifEnv* env, ERL_NIF_TERM any);
extern
ERL_NIF_TERM esock_make_error(ErlNifEnv* env, ERL_NIF_TERM reason);
extern
ERL_NIF_TERM esock_make_error_str(ErlNifEnv* env, char* reason);
extern
ERL_NIF_TERM esock_make_error_errno(ErlNifEnv* env, int err);
extern
ERL_NIF_TERM esock_make_error_invalid(ErlNifEnv* env, ERL_NIF_TERM what);
extern
ERL_NIF_TERM esock_make_error_integer_range(ErlNifEnv* env, ERL_NIF_TERM i);
extern
ERL_NIF_TERM esock_make_invalid(ErlNifEnv* env, ERL_NIF_TERM reason);
extern
ERL_NIF_TERM esock_raise_invalid(ErlNifEnv* env, ERL_NIF_TERM what);
extern
ERL_NIF_TERM esock_make_new_binary(ErlNifEnv *env, void *buf, size_t size);
extern
ErlNifTime esock_timestamp(void);
extern
BOOLEAN_T esock_timestamp_str(char *buf, unsigned int len);
extern
BOOLEAN_T esock_format_timestamp(ErlNifTime timestamp, char *buf, unsigned int len);
extern
void esock_warning_msg(const char* format, ... );
extern
BOOLEAN_T esock_is_integer(ErlNifEnv *env, ERL_NIF_TERM term);
#endif // SOCKET_UTIL_H__
|
