aboutsummaryrefslogtreecommitdiffstats
path: root/net/server_epoll.lua
diff options
context:
space:
mode:
Diffstat (limited to 'net/server_epoll.lua')
-rw-r--r--net/server_epoll.lua9
1 files changed, 5 insertions, 4 deletions
diff --git a/net/server_epoll.lua b/net/server_epoll.lua
index c3b9974c..21a6f785 100644
--- a/net/server_epoll.lua
+++ b/net/server_epoll.lua
@@ -263,6 +263,11 @@ function interface:setflags(r, w)
-- log("debug", "epoll_ctl(%q, %d, %q) -> %s" .. (err and ", %q" or ""),
-- op, fd, flags or "", tostring(ok), err);
if not ok then return ok, err end
+ if op == "add" then
+ fds[fd] = self;
+ elseif op == "del" then
+ fds[fd] = nil;
+ end
self._flags = flags;
return true;
end
@@ -367,7 +372,6 @@ function interface:destroy()
self.destroy = noop;
self.close = noop;
self.on = noop;
- fds[self:getfd()] = nil;
self.conn:close();
self.conn = nil;
end
@@ -455,8 +459,6 @@ local function wrapsocket(client, server, pattern, listeners, tls) -- luasocket
if client.getsockname then
conn.sockname, conn.sockport = client:getsockname();
end
-
- fds[conn:getfd()] = conn;
return conn;
end
@@ -528,7 +530,6 @@ local function addserver(addr, port, listeners, pattern, tls)
sockport = port;
}, interface_mt);
server:setflags(true, false);
- fds[server:getfd()] = server;
return server;
end