mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-04 13:47:41 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

net.server_epoll: Wrap calling of ondisconnect listener in additional indirection

Browse source
This commit is contained in:
Kim Alvefur 2016-08-14 01:09:55 +02:00
parent 421ef192ca
commit bf7da12bdf
1 changed files with 12 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

16
net/server_epoll.lua
View file

@ -155,7 +155,7 @@ function interface:setreadtimeout(t)
if self:onreadtimeout() then
return cfg.read_timeout;
else
self.listeners.ondisconnect(self, "read timeout");
self:ondisconnect("read timeout");
self:destroy();
end
end);
@ -330,7 +330,7 @@ function interface:starttls(ctx)
self:setflags(false, false);
local conn, err = luasec.wrap(self.conn, ctx or self.tls);
if not conn then
self.listeners.ondisconnect(self, err);
self:ondisconnect(err);
self:destroy();
end
conn:settimeout(0);
@ -365,7 +365,7 @@ function interface:tlshandskake()
self:setreadtimeout(false);
self:setwritetimeout(cfg.handshake_timeout);
else
self.listeners.ondisconnect(self, err);
self:ondisconnect(err);
self:destroy();
end
end
@ -430,9 +430,17 @@ function interface:pausefor(t)
end);
end
function interface:ondisconnect(err)
if self.listeners.ondisconnect then
self.listeners.ondisconnect(self, err);
end
end
function interface:onconnect()
self.onwriteable = nil;
self.listeners.onconnect(self);
if self.listeners.onconnect then
self.listeners.onconnect(self);
end
self:setflags(true);
return self:onwriteable();
end