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

mod_c2s: Run stream open and close events in async thread, fixes #1103

Browse source 
Enables async processing during stream opening and closing.
This commit is contained in:
Kim Alvefur 2020-05-08 23:58:24 +02:00
parent a7c0def27f
commit 0747cbea53
1 changed files with 18 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

20
plugins/mod_c2s.lua
View file

@ -55,6 +55,11 @@ end);
local stream_xmlns_attr = {xmlns='urn:ietf:params:xml:ns:xmpp-streams'}; local stream_xmlns_attr = {xmlns='urn:ietf:params:xml:ns:xmpp-streams'};
function stream_callbacks.streamopened(session, attr) function stream_callbacks.streamopened(session, attr)
-- run _streamopened in async context
session.thread:run({ stream = "opened", attr = attr });
end
function stream_callbacks._streamopened(session, attr)
local send = session.send; local send = session.send;
if not attr.to then if not attr.to then
session:close{ condition = "improper-addressing", session:close{ condition = "improper-addressing",
@ -121,7 +126,12 @@ function stream_callbacks.streamopened(session, attr)
end end
end end
function stream_callbacks.streamclosed(session) function stream_callbacks.streamclosed(session, attr)
-- run _streamclosed in async context
session.thread:run({ stream = "closed", attr = attr });
end
function stream_callbacks._streamclosed(session)
session.log("debug", "Received </stream:stream>"); session.log("debug", "Received </stream:stream>");
session:close(false); session:close(false);
end end
@ -280,7 +290,13 @@ function listener.onconnect(conn)
end end
session.thread = runner(function (stanza) session.thread = runner(function (stanza)
core_process_stanza(session, stanza); if st.is_stanza(stanza) then
core_process_stanza(session, stanza);
elseif stanza.stream == "opened" then
stream_callbacks._streamopened(session, stanza.attr);
elseif stanza.stream == "closed" then
stream_callbacks._streamclosed(session, stanza.attr);
end
end, runner_callbacks, session); end, runner_callbacks, session);
local filter = session.filter; local filter = session.filter;