Software / code / prosody-modules
Changeset
1438:feca77ad88ac
mod_smacks: Backout ed2a9c00b5c4, need a better solution
| author | Kim Alvefur <zash@zash.se> |
|---|---|
| date | Tue, 17 Jun 2014 08:01:52 +0200 |
| parents | 1437:161bbe0b9dd3 |
| children | 1439:86ceb94e3db4 |
| files | mod_smacks/mod_smacks.lua |
| diffstat | 1 files changed, 0 insertions(+), 5 deletions(-) [+] |
line wrap: on
line diff
--- a/mod_smacks/mod_smacks.lua Sun Jun 15 02:40:18 2014 +0200 +++ b/mod_smacks/mod_smacks.lua Tue Jun 17 08:01:52 2014 +0200 @@ -19,7 +19,6 @@ local resume_timeout = module:get_option_number("smacks_hibernation_time", 300); local s2s_smacks = module:get_option_boolean("smacks_enabled_s2s", false); -local max_queue_size = module:get_option_number("smacks_max_queue_size", 500); local max_unacked_stanzas = module:get_option_number("smacks_max_unacked_stanzas", 0); local core_process_stanza = prosody.core_process_stanza; local sessionmanager = require"core.sessionmanager"; @@ -91,10 +90,6 @@ cached_stanza = cached_stanza:tag("delay", { xmlns = xmlns_delay, from = session.host, stamp = datetime.datetime()}); end - if max_queue_size > 0 and #queue > max_queue_size then - session.log("warn", "Too many unacked stanzas"); - session:close{ condition = "policy-violation"; text = "Too many unacked stanzas"; }; - end queue[#queue+1] = cached_stanza; session.log("debug", "#queue = %d", #queue); end
