Software `/` code `/` prosody

Annotate

util-src/poll.c @ 11763:e273ef869794

net.server: Pikc server_epoll as unconditional default Previously it would have gone for server_select if util.poll was for some reason not available, which should be never these days. And even if it was, best to flush it out by throwing loud errors so users notice. Then they can work around it by using select until we delete that one.

author	Kim Alvefur <zash@zash.se>
date	Fri, 03 Sep 2021 17:39:00 +0200
parent	10921:6eb5d2bb11af
child	12314:898554323338

rev	line source
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	1
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	2 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	3 * Lua polling library
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	4 * Copyright (C) 2017-2018 Kim Alvefur
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	5 *
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	6 * This project is MIT licensed. Please see the
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	7 * COPYING file in the source package for more information.
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	8 *
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	9 */
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	10
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	11 #include <unistd.h>
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	12 #include <string.h>
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	13 #include <errno.h>
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	14
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	15 #ifdef __linux__
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	16 #define USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	17 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	18
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	19 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	20 #include <sys/epoll.h>
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	21 #ifndef MAX_EVENTS
9450 b890ceb1c24f util.poll: Increase max epoll events per call Kim Alvefur <zash@zash.se> parents: 9448 diff changeset	22 #define MAX_EVENTS 64
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	23 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	24 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	25 #include <sys/select.h>
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	26 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	27
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	28 #include <lualib.h>
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	29 #include <lauxlib.h>
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	30
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	31 #ifdef USE_EPOLL
9440 1ddecde4ce98 util.poll: Tweak metatable name field Kim Alvefur <zash@zash.se> parents: 9437 diff changeset	32 #define STATE_MT "util.poll<epoll>"
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	33 #else
9440 1ddecde4ce98 util.poll: Tweak metatable name field Kim Alvefur <zash@zash.se> parents: 9437 diff changeset	34 #define STATE_MT "util.poll<select>"
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	35 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	36
9318 3429006518bf util.poll: Lua 5.1 compat Kim Alvefur <zash@zash.se> parents: 9317 diff changeset	37 #if (LUA_VERSION_NUM == 501)
3429006518bf util.poll: Lua 5.1 compat Kim Alvefur <zash@zash.se> parents: 9317 diff changeset	38 #define luaL_setmetatable(L, tname) luaL_getmetatable(L, tname); lua_setmetatable(L, -2)
3429006518bf util.poll: Lua 5.1 compat Kim Alvefur <zash@zash.se> parents: 9317 diff changeset	39 #endif
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	40 #if (LUA_VERSION_NUM < 504)
6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	41 #define luaL_pushfail lua_pushnil
6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	42 #endif
9318 3429006518bf util.poll: Lua 5.1 compat Kim Alvefur <zash@zash.se> parents: 9317 diff changeset	43
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	44 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	45 * Structure to keep state for each type of API
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	46 */
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	47 typedef struct Lpoll_state {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	48 int processed;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	49 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	50 int epoll_fd;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	51 struct epoll_event events[MAX_EVENTS];
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	52 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	53 fd_set wantread;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	54 fd_set wantwrite;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	55 fd_set readable;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	56 fd_set writable;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	57 fd_set all;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	58 fd_set err;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	59 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	60 } Lpoll_state;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	61
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	62 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	63 * Add an FD to be watched
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	64 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	65 static int Ladd(lua_State *L) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	66 struct Lpoll_state *state = luaL_checkudata(L, 1, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	67 int fd = luaL_checkinteger(L, 2);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	68
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	69 int wantread = lua_toboolean(L, 3);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	70 int wantwrite = lua_toboolean(L, 4);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	71
9447 6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	72 if(fd < 0) {
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	73 luaL_pushfail(L);
9447 6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	74 lua_pushstring(L, strerror(EBADF));
6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	75 lua_pushinteger(L, EBADF);
6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	76 return 3;
6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	77 }
6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	78
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	79 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	80 struct epoll_event event;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	81 event.data.fd = fd;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	82 event.events = (wantread ? EPOLLIN : 0) \| (wantwrite ? EPOLLOUT : 0);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	83
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	84 event.events \|= EPOLLERR \| EPOLLHUP \| EPOLLRDHUP;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	85
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	86 int ret = epoll_ctl(state->epoll_fd, EPOLL_CTL_ADD, fd, &event);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	87
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	88 if(ret < 0) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	89 ret = errno;
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	90 luaL_pushfail(L);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	91 lua_pushstring(L, strerror(ret));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	92 lua_pushinteger(L, ret);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	93 return 3;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	94 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	95
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	96 lua_pushboolean(L, 1);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	97 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	98
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	99 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	100
9447 6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	101 if(fd > FD_SETSIZE) {
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	102 luaL_pushfail(L);
9447 6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	103 lua_pushstring(L, strerror(EBADF));
6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	104 lua_pushinteger(L, EBADF);
6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	105 return 3;
6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	106 }
6397e965a22d net.poll: Guard against negative or too large FDs Kim Alvefur <zash@zash.se> parents: 9446 diff changeset	107
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	108 if(FD_ISSET(fd, &state->all)) {
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	109 luaL_pushfail(L);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	110 lua_pushstring(L, strerror(EEXIST));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	111 lua_pushinteger(L, EEXIST);
9446 6b4d28eb19cf util.poll: Fix missing return for adding duplicate FD Kim Alvefur <zash@zash.se> parents: 9440 diff changeset	112 return 3;
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	113 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	114
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	115 FD_CLR(fd, &state->readable);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	116 FD_CLR(fd, &state->writable);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	117 FD_CLR(fd, &state->err);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	118
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	119 FD_SET(fd, &state->all);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	120
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	121 if(wantread) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	122 FD_SET(fd, &state->wantread);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	123 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	124 else {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	125 FD_CLR(fd, &state->wantread);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	126 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	127
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	128 if(wantwrite) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	129 FD_SET(fd, &state->wantwrite);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	130 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	131 else {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	132 FD_CLR(fd, &state->wantwrite);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	133 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	134
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	135 lua_pushboolean(L, 1);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	136 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	137 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	138 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	139
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	140 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	141 * Set events to watch for, readable and/or writable
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	142 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	143 static int Lset(lua_State *L) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	144 struct Lpoll_state *state = luaL_checkudata(L, 1, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	145 int fd = luaL_checkinteger(L, 2);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	146
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	147 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	148
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	149 int wantread = lua_toboolean(L, 3);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	150 int wantwrite = lua_toboolean(L, 4);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	151
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	152 struct epoll_event event;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	153 event.data.fd = fd;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	154 event.events = (wantread ? EPOLLIN : 0) \| (wantwrite ? EPOLLOUT : 0);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	155
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	156 event.events \|= EPOLLERR \| EPOLLHUP \| EPOLLRDHUP;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	157
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	158 int ret = epoll_ctl(state->epoll_fd, EPOLL_CTL_MOD, fd, &event);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	159
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	160 if(ret == 0) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	161 lua_pushboolean(L, 1);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	162 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	163 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	164 else {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	165 ret = errno;
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	166 luaL_pushfail(L);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	167 lua_pushstring(L, strerror(ret));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	168 lua_pushinteger(L, ret);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	169 return 3;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	170 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	171
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	172 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	173
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	174 if(!FD_ISSET(fd, &state->all)) {
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	175 luaL_pushfail(L);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	176 lua_pushstring(L, strerror(ENOENT));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	177 lua_pushinteger(L, ENOENT);
10096 46a7792fdac5 util.poll: Add missing return statements in fallback mode Kim Alvefur <zash@zash.se> parents: 9954 diff changeset	178 return 3;
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	179 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	180
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	181 if(!lua_isnoneornil(L, 3)) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	182 if(lua_toboolean(L, 3)) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	183 FD_SET(fd, &state->wantread);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	184 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	185 else {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	186 FD_CLR(fd, &state->wantread);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	187 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	188 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	189
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	190 if(!lua_isnoneornil(L, 4)) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	191 if(lua_toboolean(L, 4)) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	192 FD_SET(fd, &state->wantwrite);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	193 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	194 else {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	195 FD_CLR(fd, &state->wantwrite);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	196 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	197 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	198
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	199 lua_pushboolean(L, 1);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	200 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	201 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	202 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	203
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	204 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	205 * Remove FDs
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	206 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	207 static int Ldel(lua_State *L) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	208 struct Lpoll_state *state = luaL_checkudata(L, 1, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	209 int fd = luaL_checkinteger(L, 2);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	210
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	211 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	212
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	213 struct epoll_event event;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	214 event.data.fd = fd;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	215
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	216 int ret = epoll_ctl(state->epoll_fd, EPOLL_CTL_DEL, fd, &event);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	217
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	218 if(ret == 0) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	219 lua_pushboolean(L, 1);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	220 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	221 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	222 else {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	223 ret = errno;
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	224 luaL_pushfail(L);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	225 lua_pushstring(L, strerror(ret));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	226 lua_pushinteger(L, ret);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	227 return 3;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	228 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	229
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	230 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	231
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	232 if(!FD_ISSET(fd, &state->all)) {
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	233 luaL_pushfail(L);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	234 lua_pushstring(L, strerror(ENOENT));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	235 lua_pushinteger(L, ENOENT);
10096 46a7792fdac5 util.poll: Add missing return statements in fallback mode Kim Alvefur <zash@zash.se> parents: 9954 diff changeset	236 return 3;
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	237 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	238
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	239 FD_CLR(fd, &state->wantread);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	240 FD_CLR(fd, &state->wantwrite);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	241 FD_CLR(fd, &state->readable);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	242 FD_CLR(fd, &state->writable);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	243 FD_CLR(fd, &state->all);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	244 FD_CLR(fd, &state->err);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	245
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	246 lua_pushboolean(L, 1);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	247 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	248 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	249 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	250
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	251
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	252 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	253 * Check previously manipulated event state for FDs ready for reading or writing
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	254 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	255 static int Lpushevent(lua_State L, struct Lpoll_state state) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	256 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	257
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	258 if(state->processed > 0) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	259 state->processed--;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	260 struct epoll_event event = state->events[state->processed];
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	261 lua_pushinteger(L, event.data.fd);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	262 lua_pushboolean(L, event.events & (EPOLLIN \| EPOLLHUP \| EPOLLRDHUP \| EPOLLERR));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	263 lua_pushboolean(L, event.events & EPOLLOUT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	264 return 3;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	265 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	266
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	267 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	268
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	269 for(int fd = state->processed + 1; fd < FD_SETSIZE; fd++) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	270 if(FD_ISSET(fd, &state->readable) \|\| FD_ISSET(fd, &state->writable) \|\| FD_ISSET(fd, &state->err)) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	271 lua_pushinteger(L, fd);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	272 lua_pushboolean(L, FD_ISSET(fd, &state->readable) \| FD_ISSET(fd, &state->err));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	273 lua_pushboolean(L, FD_ISSET(fd, &state->writable));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	274 FD_CLR(fd, &state->readable);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	275 FD_CLR(fd, &state->writable);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	276 FD_CLR(fd, &state->err);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	277 state->processed = fd;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	278 return 3;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	279 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	280 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	281
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	282 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	283 return 0;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	284 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	285
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	286 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	287 * Wait for event
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	288 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	289 static int Lwait(lua_State *L) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	290 struct Lpoll_state *state = luaL_checkudata(L, 1, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	291
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	292 int ret = Lpushevent(L, state);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	293
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	294 if(ret != 0) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	295 return ret;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	296 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	297
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	298 lua_Number timeout = luaL_checknumber(L, 2);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	299 luaL_argcheck(L, timeout >= 0, 1, "positive number expected");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	300
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	301 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	302 ret = epoll_wait(state->epoll_fd, state->events, MAX_EVENTS, timeout * 1000);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	303 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	304 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	305 * select(2) mutates the fd_sets passed to it so in order to not
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	306 * have to recreate it manually every time a copy is made.
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	307 */
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	308 memcpy(&state->readable, &state->wantread, sizeof(fd_set));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	309 memcpy(&state->writable, &state->wantwrite, sizeof(fd_set));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	310 memcpy(&state->err, &state->all, sizeof(fd_set));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	311
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	312 struct timeval tv;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	313 tv.tv_sec = (time_t)timeout;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	314 tv.tv_usec = ((suseconds_t)(timeout * 1000000)) % 1000000;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	315
9437 b202aa1e2d7b util.poll: Fix monitoring of socket exceptions in select mode Kim Alvefur <zash@zash.se> parents: 9318 diff changeset	316 ret = select(FD_SETSIZE, &state->readable, &state->writable, &state->err, &tv);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	317 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	318
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	319 if(ret == 0) {
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	320 /* Is this an error? */
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	321 lua_pushnil(L);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	322 lua_pushstring(L, "timeout");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	323 return 2;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	324 }
9508 2055b497b515 net.server_epoll: Special handling of signal interrupts Kim Alvefur <zash@zash.se> parents: 9507 diff changeset	325 else if(ret < 0 && errno == EINTR) {
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	326 /* Is this an error? */
9508 2055b497b515 net.server_epoll: Special handling of signal interrupts Kim Alvefur <zash@zash.se> parents: 9507 diff changeset	327 lua_pushnil(L);
2055b497b515 net.server_epoll: Special handling of signal interrupts Kim Alvefur <zash@zash.se> parents: 9507 diff changeset	328 lua_pushstring(L, "signal");
2055b497b515 net.server_epoll: Special handling of signal interrupts Kim Alvefur <zash@zash.se> parents: 9507 diff changeset	329 return 2;
2055b497b515 net.server_epoll: Special handling of signal interrupts Kim Alvefur <zash@zash.se> parents: 9507 diff changeset	330 }
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	331 else if(ret < 0) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	332 ret = errno;
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	333 luaL_pushfail(L);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	334 lua_pushstring(L, strerror(ret));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	335 lua_pushinteger(L, ret);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	336 return 3;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	337 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	338
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	339 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	340 * Search for the first ready FD and return it
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	341 */
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	342 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	343 state->processed = ret;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	344 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	345 state->processed = -1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	346 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	347 return Lpushevent(L, state);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	348 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	349
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	350 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	351 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	352 * Return Epoll FD
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	353 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	354 static int Lgetfd(lua_State *L) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	355 struct Lpoll_state *state = luaL_checkudata(L, 1, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	356 lua_pushinteger(L, state->epoll_fd);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	357 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	358 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	359
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	360 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	361 * Close epoll FD
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	362 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	363 static int Lgc(lua_State *L) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	364 struct Lpoll_state *state = luaL_checkudata(L, 1, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	365
9478 bd178ed0459b util.poll: Fix inverted logic Kim Alvefur <zash@zash.se> parents: 9476 diff changeset	366 if(state->epoll_fd == -1) {
9475 9b26a50cdfe3 util.poll: Early return from __gc in case of no valid epoll FD Kim Alvefur <zash@zash.se> parents: 9450 diff changeset	367 return 0;
9b26a50cdfe3 util.poll: Early return from __gc in case of no valid epoll FD Kim Alvefur <zash@zash.se> parents: 9450 diff changeset	368 }
9b26a50cdfe3 util.poll: Early return from __gc in case of no valid epoll FD Kim Alvefur <zash@zash.se> parents: 9450 diff changeset	369
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	370 if(close(state->epoll_fd) == 0) {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	371 state->epoll_fd = -1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	372 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	373 else {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	374 lua_pushstring(L, strerror(errno));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	375 lua_error(L);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	376 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	377
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	378 return 0;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	379 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	380 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	381
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	382 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	383 * String representation
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	384 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	385 static int Ltos(lua_State *L) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	386 struct Lpoll_state *state = luaL_checkudata(L, 1, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	387 lua_pushfstring(L, "%s: %p", STATE_MT, state);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	388 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	389 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	390
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	391 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	392 * Create a new context
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	393 */
9954 36280801ddf1 util.poll: Minimize scope of methods Kim Alvefur <zash@zash.se> parents: 9508 diff changeset	394 static int Lnew(lua_State *L) {
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	395 /* Allocate state */
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	396 Lpoll_state *state = lua_newuserdata(L, sizeof(Lpoll_state));
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	397 luaL_setmetatable(L, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	398
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	399 /* Initialize state */
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	400 #ifdef USE_EPOLL
9476 f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	401 state->epoll_fd = -1;
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	402 state->processed = 0;
9476 f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	403
f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	404 int epoll_fd = epoll_create1(EPOLL_CLOEXEC);
f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	405
f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	406 if(epoll_fd <= 0) {
10921 6eb5d2bb11af util-src: Use the luaL_pushfail API added in Lua 5.4 to highlight all failure conditions Kim Alvefur <zash@zash.se> parents: 10096 diff changeset	407 luaL_pushfail(L);
9476 f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	408 lua_pushstring(L, strerror(errno));
f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	409 lua_pushinteger(L, errno);
f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	410 return 3;
f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	411 }
f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	412
f3935aa4cc7e util.poll: Handle failed epoll FD creation Kim Alvefur <zash@zash.se> parents: 9475 diff changeset	413 state->epoll_fd = epoll_fd;
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	414 #else
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	415 FD_ZERO(&state->wantread);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	416 FD_ZERO(&state->wantwrite);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	417 FD_ZERO(&state->readable);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	418 FD_ZERO(&state->writable);
9448 352e8b75c1ae util.poll: Zero FD sets watched for errors on creation Kim Alvefur <zash@zash.se> parents: 9447 diff changeset	419 FD_ZERO(&state->all);
352e8b75c1ae util.poll: Zero FD sets watched for errors on creation Kim Alvefur <zash@zash.se> parents: 9447 diff changeset	420 FD_ZERO(&state->err);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	421 state->processed = FD_SETSIZE;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	422 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	423
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	424 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	425 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	426
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	427 /*
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	428 * Open library
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	429 */
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	430 int luaopen_util_poll(lua_State *L) {
9318 3429006518bf util.poll: Lua 5.1 compat Kim Alvefur <zash@zash.se> parents: 9317 diff changeset	431 #if (LUA_VERSION_NUM > 501)
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	432 luaL_checkversion(L);
9318 3429006518bf util.poll: Lua 5.1 compat Kim Alvefur <zash@zash.se> parents: 9317 diff changeset	433 #endif
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	434
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	435 luaL_newmetatable(L, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	436 {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	437
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	438 lua_pushliteral(L, STATE_MT);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	439 lua_setfield(L, -2, "__name");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	440
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	441 lua_pushcfunction(L, Ltos);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	442 lua_setfield(L, -2, "__tostring");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	443
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	444 lua_createtable(L, 0, 2);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	445 {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	446 lua_pushcfunction(L, Ladd);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	447 lua_setfield(L, -2, "add");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	448 lua_pushcfunction(L, Lset);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	449 lua_setfield(L, -2, "set");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	450 lua_pushcfunction(L, Ldel);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	451 lua_setfield(L, -2, "del");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	452 lua_pushcfunction(L, Lwait);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	453 lua_setfield(L, -2, "wait");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	454 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	455 lua_pushcfunction(L, Lgetfd);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	456 lua_setfield(L, -2, "getfd");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	457 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	458 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	459 lua_setfield(L, -2, "__index");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	460
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	461 #ifdef USE_EPOLL
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	462 lua_pushcfunction(L, Lgc);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	463 lua_setfield(L, -2, "__gc");
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	464 #endif
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	465 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	466
9507 33d21f020b66 net.server_epoll: Ignore ENOENT when deregitering socket Kim Alvefur <zash@zash.se> parents: 9506 diff changeset	467 lua_createtable(L, 0, 3);
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	468 {
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	469 lua_pushcfunction(L, Lnew);
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	470 lua_setfield(L, -2, "new");
9506 ae6636052be9 net.server_epoll: Graceful handling of registering already added socket Kim Alvefur <zash@zash.se> parents: 9478 diff changeset	471
ae6636052be9 net.server_epoll: Graceful handling of registering already added socket Kim Alvefur <zash@zash.se> parents: 9478 diff changeset	472 #define push_errno(named_error) lua_pushinteger(L, named_error);\
ae6636052be9 net.server_epoll: Graceful handling of registering already added socket Kim Alvefur <zash@zash.se> parents: 9478 diff changeset	473 lua_setfield(L, -2, #named_error);
ae6636052be9 net.server_epoll: Graceful handling of registering already added socket Kim Alvefur <zash@zash.se> parents: 9478 diff changeset	474
ae6636052be9 net.server_epoll: Graceful handling of registering already added socket Kim Alvefur <zash@zash.se> parents: 9478 diff changeset	475 push_errno(EEXIST);
9507 33d21f020b66 net.server_epoll: Ignore ENOENT when deregitering socket Kim Alvefur <zash@zash.se> parents: 9506 diff changeset	476 push_errno(ENOENT);
9506 ae6636052be9 net.server_epoll: Graceful handling of registering already added socket Kim Alvefur <zash@zash.se> parents: 9478 diff changeset	477
9313 b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	478 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	479 return 1;
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	480 }
b95ef295c66d util.poll: Import poll library with epoll and select support Kim Alvefur <zash@zash.se> parents: diff changeset	481

prosody

e273ef869794

util-src/poll.c

Software / code / prosody

Annotate

util-src/poll.c @ 11763:e273ef869794

Software `/` code `/` prosody