prosody-modules
c472a454be61
mod_smacks/mod_smacks.lua

Find changesets by keywords by author, files, the commit message, revision number or hash, or revset expression.

Software / code / prosody-modules

Comparison

mod_smacks/mod_smacks.lua @ 2148:c472a454be61

mod_smacks: Fix sending <r> after stanzas while not creating multiple timers (thanks Thilo)
author Kim Alvefur <zash@zash.se>
date Sat, 02 Apr 2016 20:03:30 +0200
parent 2140:3a94b3cd31e2
child 2251:48c3d64a3fc1
comparison
equal deleted inserted replaced
2147:ed2bb50d4f91 2148:c472a454be61
85 session.log("debug", "#queue = %d", #queue); 85 session.log("debug", "#queue = %d", #queue);
86 if session.hibernating then 86 if session.hibernating then
87 session.log("debug", "hibernating, stanza queued"); 87 session.log("debug", "hibernating, stanza queued");
88 return nil; 88 return nil;
89 end 89 end
90 if #queue > max_unacked_stanzas and not session.awaiting_ack then 90 if #queue > max_unacked_stanzas and session.awaiting_ack == nil then
91 session.log("debug", "Queuing <r> (in a moment)"); 91 session.log("debug", "Queuing <r> (in a moment)");
92 session.awaiting_ack = true; 92 session.awaiting_ack = false;
93 session.awaiting_ack_timer = module:add_timer(1e-06, function () 93 session.awaiting_ack_timer = module:add_timer(1e-06, function ()
94 if not session.awaiting_ack then 94 if not session.awaiting_ack then
95 session.log("debug", "Sending <r> (after send)"); 95 session.log("debug", "Sending <r> (after send)");
96 (session.sends2s or session.send)(st.stanza("r", { xmlns = session.smacks })) 96 (session.sends2s or session.send)(st.stanza("r", { xmlns = session.smacks }))
97 session.awaiting_ack = true;
97 end 98 end
98 end); 99 end);
99 end 100 end
100 end 101 end
101 return stanza; 102 return stanza;