The Tor Browser: testing/xpcshell/node-spdy/lib/spdy/utils.js@b8a032363ba2

Incorporate requested changes from Mozilla in review:
https://bugzilla.mozilla.org/show_bug.cgi?id=1123480#c6

     1 var spdy = require('../spdy'),

     2     utils = exports;

     4 var zlib = require('zlib'),

     5     Buffer = require('buffer').Buffer;

     7 //

     8 // ### function createDeflate ()

     9 // Creates deflate stream with SPDY dictionary

    10 //

    11 utils.createDeflate = function createDeflate(version) {

    12   var deflate = zlib.createDeflate({

    13     dictionary: spdy.protocol[version].dictionary,

    14     windowBits: 11

    15   });

    17   // Define lock information early

    18   deflate.locked = false;

    19   deflate.lockBuffer = [];

    21   return deflate;

    22 };

    24 //

    25 // ### function createInflate ()

    26 // Creates inflate stream with SPDY dictionary

    27 //

    28 utils.createInflate = function createInflate(version) {

    29   var inflate = zlib.createInflate({

    30     dictionary: spdy.protocol[version].dictionary,

    31     windowBits: 15

    32   });

    34   // Define lock information early

    35   inflate.locked = false;

    36   inflate.lockBuffer = [];

    38   return inflate;

    39 };

    41 //

    42 // ### function resetZlibStream (stream)

    43 // #### @stream {zlib.Stream} stream

    44 // Resets zlib stream and associated locks

    45 //

    46 utils.resetZlibStream = function resetZlibStream(stream, callback) {

    47   if (stream.locked) {

    48     stream.lockBuffer.push(function() {

    49       resetZlibStream(stream, callback);

    50     });

    51     return;

    52   }

    54   stream.reset();

    55   stream.lockBuffer = [];

    57   callback(null);

    58 };

    60 var delta = 0;

    61 //

    62 // ### function zstream (stream, buffer, callback)

    63 // #### @stream {Deflate|Inflate} One of streams above

    64 // #### @buffer {Buffer} Input data (to compress or to decompress)

    65 // #### @callback {Function} Continuation to callback

    66 // Compress/decompress data and pass it to callback

    67 //

    68 utils.zstream = function zstream(stream, buffer, callback) {

    69   var flush = stream._flush,

    70       chunks = [],

    71       total = 0;

    73   if (stream.locked) {

    74     stream.lockBuffer.push(function() {

    75       zstream(stream, buffer, callback);

    76     });

    77     return;

    78   }

    79   stream.locked = true;

    81   function collect(chunk) {

    82     chunks.push(chunk);

    83     total += chunk.length;

    84   }

    85   stream.on('data', collect);

    86   stream.write(buffer);

    88   stream.once('error', function(err) {

    89     stream.removeAllListeners('data');

    90     callback(err);

    91   });

    93   stream.flush(function() {

    94     stream.removeAllListeners('data');

    95     stream.removeAllListeners('error');

    96     stream._flush = flush;

    98     callback(null, chunks, total);

   100     stream.locked = false;

   101     var deferred = stream.lockBuffer.shift();

   102     if (deferred) deferred();

   103   });

   104 };

   106 //

   107 // ### function zwrap (stream)

   108 // #### @stream {zlib.Stream} stream to wrap

   109 // Wraps stream within function to allow simple deflate/inflate

   110 //

   111 utils.zwrap = function zwrap(stream) {

   112   return function(data, callback) {

   113     utils.zstream(stream, data, callback);

   114   };

   115 };

The Tor Browser / file revision