diff options
Diffstat (limited to 'src/udp.c')
-rw-r--r-- | src/udp.c | 99 |
1 files changed, 5 insertions, 94 deletions
@@ -14,6 +14,7 @@ | |||
14 | #include "auxiliar.h" | 14 | #include "auxiliar.h" |
15 | #include "socket.h" | 15 | #include "socket.h" |
16 | #include "inet.h" | 16 | #include "inet.h" |
17 | #include "options.h" | ||
17 | #include "udp.h" | 18 | #include "udp.h" |
18 | 19 | ||
19 | /*=========================================================================*\ | 20 | /*=========================================================================*\ |
@@ -34,13 +35,6 @@ static int meth_setoption(lua_State *L); | |||
34 | static int meth_settimeout(lua_State *L); | 35 | static int meth_settimeout(lua_State *L); |
35 | static int meth_fd(lua_State *L); | 36 | static int meth_fd(lua_State *L); |
36 | static int meth_dirty(lua_State *L); | 37 | static int meth_dirty(lua_State *L); |
37 | static int opt_dontroute(lua_State *L); | ||
38 | static int opt_broadcast(lua_State *L); | ||
39 | static int opt_reuseaddr(lua_State *L); | ||
40 | static int opt_ip_multicast_ttl(lua_State *L); | ||
41 | static int opt_ip_multicast_loop(lua_State *L); | ||
42 | static int opt_ip_add_membership(lua_State *L); | ||
43 | static int opt_ip_drop_membersip(lua_State *L); | ||
44 | 38 | ||
45 | /* udp object methods */ | 39 | /* udp object methods */ |
46 | static luaL_reg udp[] = { | 40 | static luaL_reg udp[] = { |
@@ -63,7 +57,7 @@ static luaL_reg udp[] = { | |||
63 | }; | 57 | }; |
64 | 58 | ||
65 | /* socket options */ | 59 | /* socket options */ |
66 | static luaL_reg opt[] = { | 60 | static t_opt opt[] = { |
67 | {"dontroute", opt_dontroute}, | 61 | {"dontroute", opt_dontroute}, |
68 | {"broadcast", opt_broadcast}, | 62 | {"broadcast", opt_broadcast}, |
69 | {"reuseaddr", opt_reuseaddr}, | 63 | {"reuseaddr", opt_reuseaddr}, |
@@ -231,95 +225,12 @@ static int meth_getsockname(lua_State *L) | |||
231 | } | 225 | } |
232 | 226 | ||
233 | /*-------------------------------------------------------------------------*\ | 227 | /*-------------------------------------------------------------------------*\ |
234 | * Option handlers | 228 | * Just call option handler |
235 | \*-------------------------------------------------------------------------*/ | 229 | \*-------------------------------------------------------------------------*/ |
236 | static int meth_setoption(lua_State *L) | 230 | static int meth_setoption(lua_State *L) |
237 | { | 231 | { |
238 | return aux_meth_setoption(L, opt); | ||
239 | } | ||
240 | |||
241 | static int opt_boolean(lua_State *L, int level, int name) | ||
242 | { | ||
243 | p_udp udp = (p_udp) aux_checkgroup(L, "udp{any}", 1); | ||
244 | int val = aux_checkboolean(L, 2); | ||
245 | if (setsockopt(udp->sock, level, name, (char *) &val, sizeof(val)) < 0) { | ||
246 | lua_pushnil(L); | ||
247 | lua_pushstring(L, "setsockopt failed"); | ||
248 | return 2; | ||
249 | } | ||
250 | lua_pushnumber(L, 1); | ||
251 | return 1; | ||
252 | } | ||
253 | |||
254 | static int opt_dontroute(lua_State *L) | ||
255 | { | ||
256 | return opt_boolean(L, SOL_SOCKET, SO_DONTROUTE); | ||
257 | } | ||
258 | |||
259 | static int opt_reuseaddr(lua_State *L) | ||
260 | { | ||
261 | return opt_boolean(L, SOL_SOCKET, SO_REUSEADDR); | ||
262 | } | ||
263 | |||
264 | static int opt_broadcast(lua_State *L) | ||
265 | { | ||
266 | return opt_boolean(L, SOL_SOCKET, SO_BROADCAST); | ||
267 | } | ||
268 | |||
269 | static int opt_ip_multicast_loop(lua_State *L) | ||
270 | { | ||
271 | return opt_boolean(L, IPPROTO_IP, IP_MULTICAST_LOOP); | ||
272 | } | ||
273 | |||
274 | static int opt_ip_multicast_ttl(lua_State *L) | ||
275 | { | ||
276 | p_udp udp = (p_udp) aux_checkgroup(L, "udp{any}", 1); | ||
277 | int val = (int) luaL_checknumber(L, 2); | ||
278 | if (setsockopt(udp->sock, IPPROTO_IP, IP_MULTICAST_TTL, | ||
279 | (char *) &val, sizeof(val)) < 0) { | ||
280 | lua_pushnil(L); | ||
281 | lua_pushstring(L, "setsockopt failed"); | ||
282 | return 2; | ||
283 | } | ||
284 | lua_pushnumber(L, 1); | ||
285 | return 1; | ||
286 | } | ||
287 | |||
288 | static int opt_membership(lua_State *L, int level, int name) | ||
289 | { | ||
290 | p_udp udp = (p_udp) aux_checkgroup(L, "udp{any}", 1); | 232 | p_udp udp = (p_udp) aux_checkgroup(L, "udp{any}", 1); |
291 | struct ip_mreq val; | 233 | return opt_meth_setoption(L, opt, &udp->sock); |
292 | if (!lua_istable(L, 2)) | ||
293 | luaL_typerror(L, 2, lua_typename(L, LUA_TTABLE)); | ||
294 | lua_pushstring(L, "multiaddr"); | ||
295 | lua_gettable(L, 2); | ||
296 | if (!lua_isstring(L, -1)) luaL_argerror(L, 2, "invalid 'group' field"); | ||
297 | if (!inet_aton(lua_tostring(L, -1), &val.imr_multiaddr)) | ||
298 | luaL_argerror(L, 3, "invalid 'multiaddr' ip address"); | ||
299 | lua_pushstring(L, "interface"); | ||
300 | lua_gettable(L, 2); | ||
301 | if (!lua_isstring(L, -1)) luaL_argerror(L, 2, "invalid 'interface' field"); | ||
302 | val.imr_interface.s_addr = htonl(INADDR_ANY); | ||
303 | if (strcmp(lua_tostring(L, -1), "*") && | ||
304 | !inet_aton(lua_tostring(L, -1), &val.imr_interface)) | ||
305 | luaL_argerror(L, 3, "invalid 'interface' ip address"); | ||
306 | if (setsockopt(udp->sock, level, name, (char *) &val, sizeof(val)) < 0) { | ||
307 | lua_pushnil(L); | ||
308 | lua_pushstring(L, "setsockopt failed"); | ||
309 | return 2; | ||
310 | } | ||
311 | lua_pushnumber(L, 1); | ||
312 | return 1; | ||
313 | } | ||
314 | |||
315 | static int opt_ip_add_membership(lua_State *L) | ||
316 | { | ||
317 | return opt_membership(L, IPPROTO_IP, IP_ADD_MEMBERSHIP); | ||
318 | } | ||
319 | |||
320 | static int opt_ip_drop_membersip(lua_State *L) | ||
321 | { | ||
322 | return opt_membership(L, IPPROTO_IP, IP_DROP_MEMBERSHIP); | ||
323 | } | 234 | } |
324 | 235 | ||
325 | /*-------------------------------------------------------------------------*\ | 236 | /*-------------------------------------------------------------------------*\ |
@@ -343,7 +254,7 @@ static int meth_setpeername(lua_State *L) | |||
343 | unsigned short port = connecting ? | 254 | unsigned short port = connecting ? |
344 | (unsigned short) luaL_checknumber(L, 3) : | 255 | (unsigned short) luaL_checknumber(L, 3) : |
345 | (unsigned short) luaL_optnumber(L, 3, 0); | 256 | (unsigned short) luaL_optnumber(L, 3, 0); |
346 | const char *err = inet_tryconnect(&udp->sock, tm, address, port); | 257 | const char *err = inet_tryconnect(&udp->sock, address, port, tm); |
347 | if (err) { | 258 | if (err) { |
348 | lua_pushnil(L); | 259 | lua_pushnil(L); |
349 | lua_pushstring(L, err); | 260 | lua_pushstring(L, err); |