X-Git-Url: https://git.enpas.org/?a=blobdiff_plain;ds=sidebyside;f=plugins%2Fmod_compression.lua;fp=plugins%2Fmod_compression.lua;h=9edee44a770f7ff4358253c4332f8e2f1d9b00f8;hb=0b768cce43772f38dd06bbd0e96c9d1e7d5e3973;hp=0bee5b127634d09bfd2c40bd7c02a3be154ffca3;hpb=640e5279fc77a5d3edc678c79691c79a9380d5d2;p=prosody.git diff --git a/plugins/mod_compression.lua b/plugins/mod_compression.lua index 0bee5b12..9edee44a 100644 --- a/plugins/mod_compression.lua +++ b/plugins/mod_compression.lua @@ -98,12 +98,12 @@ local function setup_compression(session, deflate_stream) add_filter(session, "bytes/out", function(t) local status, compressed, eof = pcall(deflate_stream, tostring(t), 'sync'); if status == false then + module:log("warn", "%s", tostring(compressed)); session:close({ condition = "undefined-condition"; text = compressed; extra = st.stanza("failure", {xmlns="http://jabber.org/protocol/compress"}):tag("processing-failed"); }); - module:log("warn", "%s", tostring(compressed)); return; end return compressed; @@ -115,12 +115,12 @@ local function setup_decompression(session, inflate_stream) add_filter(session, "bytes/in", function(data) local status, decompressed, eof = pcall(inflate_stream, data); if status == false then + module:log("warn", "%s", tostring(decompressed)); session:close({ condition = "undefined-condition"; text = decompressed; extra = st.stanza("failure", {xmlns="http://jabber.org/protocol/compress"}):tag("processing-failed"); }); - module:log("warn", "%s", tostring(decompressed)); return; end return decompressed;