Mercurial > prosody-hg

comparison plugins/mod_compression.lua @ 2292:9c5941198719

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mod_compression: Declaring the de-/compression pipes as local.
author Tobias Markmann <tm@ayena.de>
date Tue, 01 Dec 2009 21:04:02 +0100
parents c6bed51c6733
children abd28ed5d8b0
comparison
equal deleted inserted replaced
2291:c6bed51c6733 2292:9c5941198719
137 137
138 module:add_handler({"s2sout_unauthed", "s2sout"}, "compressed", xmlns_compression_protocol, 138 module:add_handler({"s2sout_unauthed", "s2sout"}, "compressed", xmlns_compression_protocol,
139 function(session ,stanza) 139 function(session ,stanza)
140 session.log("debug", "Activating compression...") 140 session.log("debug", "Activating compression...")
141 -- create deflate and inflate streams 141 -- create deflate and inflate streams
142 deflate_stream = get_deflate_stream(session); 142 local deflate_stream = get_deflate_stream(session);
143 if not deflate_stream then return end 143 if not deflate_stream then return end
144 144
145 inflate_stream = get_inflate_stream(session); 145 local inflate_stream = get_inflate_stream(session);
146 if not inflate_stream then return end 146 if not inflate_stream then return end
147 147
148 -- setup compression for session.w 148 -- setup compression for session.w
149 setup_compression(session, deflate_stream); 149 setup_compression(session, deflate_stream);
150 150
178 local method = stanza:child_with_name("method")[1]; 178 local method = stanza:child_with_name("method")[1];
179 if method == "zlib" then 179 if method == "zlib" then
180 session.log("info", method.." compression selected."); 180 session.log("info", method.." compression selected.");
181 181
182 -- create deflate and inflate streams 182 -- create deflate and inflate streams
183 deflate_stream = get_deflate_stream(session); 183 local deflate_stream = get_deflate_stream(session);
184 if not deflate_stream then return end 184 if not deflate_stream then return end
185 185
186 inflate_stream = get_inflate_stream(session); 186 local inflate_stream = get_inflate_stream(session);
187 if not inflate_stream then return end 187 if not inflate_stream then return end
188 188
189 (session.sends2s or session.send)(st.stanza("compressed", {xmlns=xmlns_compression_protocol})); 189 (session.sends2s or session.send)(st.stanza("compressed", {xmlns=xmlns_compression_protocol}));
190 session:reset_stream(); 190 session:reset_stream();
191 191