45 local status, compressed, eof = pcall(deflate_stream, tostring(t), 'sync'); |
45 local status, compressed, eof = pcall(deflate_stream, tostring(t), 'sync'); |
46 if status == false then |
46 if status == false then |
47 session:close({ |
47 session:close({ |
48 condition = "undefined-condition"; |
48 condition = "undefined-condition"; |
49 text = compressed; |
49 text = compressed; |
50 extra = st.stanza("failure", {xmlns="http://jabber.org/protocol/compress"}):tag("processing-failed"); |
50 extra = st.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("processing-failed"); |
51 }); |
51 }); |
52 session:warn("Compressed send failed: %s", tostring(compressed)); |
52 session:warn("Compressed send failed: %s", tostring(compressed)); |
53 return; |
53 return; |
54 end |
54 end |
55 session.conn:write(compressed); |
55 session.conn:write(compressed); |
64 local status, decompressed, eof = pcall(inflate_stream, data); |
64 local status, decompressed, eof = pcall(inflate_stream, data); |
65 if status == false then |
65 if status == false then |
66 session:close({ |
66 session:close({ |
67 condition = "undefined-condition"; |
67 condition = "undefined-condition"; |
68 text = decompressed; |
68 text = decompressed; |
69 extra = st.stanza("failure", {xmlns="http://jabber.org/protocol/compress"}):tag("processing-failed"); |
69 extra = st.stanza("failure", {xmlns=xmlns_compression_protocol}):tag("processing-failed"); |
70 }); |
70 }); |
71 stream:warn("%s", tostring(decompressed)); |
71 stream:warn("%s", tostring(decompressed)); |
72 return; |
72 return; |
73 end |
73 end |
74 return old_data(conn, decompressed); |
74 return old_data(conn, decompressed); |