verse
82ad158714e5
plugins/compression.lua

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

Software / code / verse

Comparison

plugins/compression.lua @ 399:82ad158714e5

Merge with Zash
author Matthew Wild <mwild1@gmail.com>
date Tue, 12 Jan 2016 13:14:36 +0000
parent 380:0891b4e27766
comparison
equal deleted inserted replaced
378:6042c938e369 399:82ad158714e5
1 -- Copyright (C) 2009-2010 Matthew Wild 1 -- Copyright (C) 2009-2010 Matthew Wild
2 -- Copyright (C) 2009-2010 Tobias Markmann 2 -- Copyright (C) 2009-2010 Tobias Markmann
3 -- 3 --
4 -- This project is MIT/X11 licensed. Please see the 4 -- This project is MIT/X11 licensed. Please see the
5 -- COPYING file in the source package for more information. 5 -- COPYING file in the source package for more information.
6 -- 6 --
7 7
8 local verse = require "verse"; 8 local verse = require "verse";
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);
56 end; 56 end;
57 end 57 end
58 58
59 -- setup decompression for a stream 59 -- setup decompression for a stream
60 local function setup_decompression(session, inflate_stream) 60 local function setup_decompression(session, inflate_stream)
61 local old_data = session.data 61 local old_data = session.data
99 stream:debug("Activating compression...") 99 stream:debug("Activating compression...")
100 100
101 -- create deflate and inflate streams 101 -- create deflate and inflate streams
102 local deflate_stream = get_deflate_stream(stream); 102 local deflate_stream = get_deflate_stream(stream);
103 if not deflate_stream then return end 103 if not deflate_stream then return end
104 104
105 local inflate_stream = get_inflate_stream(stream); 105 local inflate_stream = get_inflate_stream(stream);
106 if not inflate_stream then return end 106 if not inflate_stream then return end
107 107
108 -- setup compression for stream.w 108 -- setup compression for stream.w
109 setup_compression(stream, deflate_stream); 109 setup_compression(stream, deflate_stream);
110 110
111 -- setup decompression for stream.data 111 -- setup decompression for stream.data
112 setup_decompression(stream, inflate_stream); 112 setup_decompression(stream, inflate_stream);
113 113
114 stream.compressed = true; 114 stream.compressed = true;
115 stream:reopen(); 115 stream:reopen();
116 elseif stanza.name == "failure" then 116 elseif stanza.name == "failure" then
117 stream:warn("Failed to establish compression"); 117 stream:warn("Failed to establish compression");
118 end 118 end