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

mod_component: Add read timeout handler (same behaviour as c2s and s2s)

Browse source
This commit is contained in:
Kim Alvefur 2017-02-10 21:25:12 +01:00
parent 0e99534951
commit a586901308
1 changed files with 18 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

18
plugins/mod_component.lua
View file

@ -29,6 +29,13 @@ local opt_keepalives = module:get_option_boolean("component_tcp_keepalives", mod
local sessions = module:shared("sessions");
local function keepalive(event)
local session = event.session;
if not session.notopen then
return event.session.send(' ');
end
end
function module.add_host(module)
if module:get_host_type() ~= "component" then
error("Don't load mod_component manually, it should be for a component, please see http://prosody.im/doc/components", 0);
@ -135,8 +142,12 @@ function module.add_host(module)
module:hook("iq/host", handle_stanza, -1);
module:hook("message/host", handle_stanza, -1);
module:hook("presence/host", handle_stanza, -1);
module:hook("component-read-timeout", keepalive, -1);
end
module:hook("component-read-timeout", keepalive, -1);
--- Network and stream part ---
local xmlns_component = 'jabber:component:accept';
@ -332,6 +343,13 @@ function listener.ondetach(conn)
sessions[conn] = nil;
end
function listener.onreadtimeout(conn)
local session = sessions[conn];
if session then
return (hosts[session.host] or prosody).events.fire_event("component-read-timeout", { session = session });
end
end
module:provides("net", {
name = "component";
private = true;