Show More
Commit Description:
merge
Commit Description:
merge
References:
File last commit:
Show/Diff file:
Action:
node_modules/pako/lib/zlib/inflate.js
| 1538 lines
| 46.3 KiB
| application/javascript
| JavascriptLexer
|
r789 | 'use strict'; | |||
var utils = require('../utils/common'); | ||||
var adler32 = require('./adler32'); | ||||
var crc32 = require('./crc32'); | ||||
var inflate_fast = require('./inffast'); | ||||
var inflate_table = require('./inftrees'); | ||||
var CODES = 0; | ||||
var LENS = 1; | ||||
var DISTS = 2; | ||||
/* Public constants ==========================================================*/ | ||||
/* ===========================================================================*/ | ||||
/* Allowed flush values; see deflate() and inflate() below for details */ | ||||
//var Z_NO_FLUSH = 0; | ||||
//var Z_PARTIAL_FLUSH = 1; | ||||
//var Z_SYNC_FLUSH = 2; | ||||
//var Z_FULL_FLUSH = 3; | ||||
var Z_FINISH = 4; | ||||
var Z_BLOCK = 5; | ||||
var Z_TREES = 6; | ||||
/* Return codes for the compression/decompression functions. Negative values | ||||
* are errors, positive values are used for special but normal events. | ||||
*/ | ||||
var Z_OK = 0; | ||||
var Z_STREAM_END = 1; | ||||
var Z_NEED_DICT = 2; | ||||
//var Z_ERRNO = -1; | ||||
var Z_STREAM_ERROR = -2; | ||||
var Z_DATA_ERROR = -3; | ||||
var Z_MEM_ERROR = -4; | ||||
var Z_BUF_ERROR = -5; | ||||
//var Z_VERSION_ERROR = -6; | ||||
/* The deflate compression method */ | ||||
var Z_DEFLATED = 8; | ||||
/* STATES ====================================================================*/ | ||||
/* ===========================================================================*/ | ||||
var HEAD = 1; /* i: waiting for magic header */ | ||||
var FLAGS = 2; /* i: waiting for method and flags (gzip) */ | ||||
var TIME = 3; /* i: waiting for modification time (gzip) */ | ||||
var OS = 4; /* i: waiting for extra flags and operating system (gzip) */ | ||||
var EXLEN = 5; /* i: waiting for extra length (gzip) */ | ||||
var EXTRA = 6; /* i: waiting for extra bytes (gzip) */ | ||||
var NAME = 7; /* i: waiting for end of file name (gzip) */ | ||||
var COMMENT = 8; /* i: waiting for end of comment (gzip) */ | ||||
var HCRC = 9; /* i: waiting for header crc (gzip) */ | ||||
var DICTID = 10; /* i: waiting for dictionary check value */ | ||||
var DICT = 11; /* waiting for inflateSetDictionary() call */ | ||||
var TYPE = 12; /* i: waiting for type bits, including last-flag bit */ | ||||
var TYPEDO = 13; /* i: same, but skip check to exit inflate on new block */ | ||||
var STORED = 14; /* i: waiting for stored size (length and complement) */ | ||||
var COPY_ = 15; /* i/o: same as COPY below, but only first time in */ | ||||
var COPY = 16; /* i/o: waiting for input or output to copy stored block */ | ||||
var TABLE = 17; /* i: waiting for dynamic block table lengths */ | ||||
var LENLENS = 18; /* i: waiting for code length code lengths */ | ||||
var CODELENS = 19; /* i: waiting for length/lit and distance code lengths */ | ||||
var LEN_ = 20; /* i: same as LEN below, but only first time in */ | ||||
var LEN = 21; /* i: waiting for length/lit/eob code */ | ||||
var LENEXT = 22; /* i: waiting for length extra bits */ | ||||
var DIST = 23; /* i: waiting for distance code */ | ||||
var DISTEXT = 24; /* i: waiting for distance extra bits */ | ||||
var MATCH = 25; /* o: waiting for output space to copy string */ | ||||
var LIT = 26; /* o: waiting for output space to write literal */ | ||||
var CHECK = 27; /* i: waiting for 32-bit check value */ | ||||
var LENGTH = 28; /* i: waiting for 32-bit length (gzip) */ | ||||
var DONE = 29; /* finished check, done -- remain here until reset */ | ||||
var BAD = 30; /* got a data error -- remain here until reset */ | ||||
var MEM = 31; /* got an inflate() memory error -- remain here until reset */ | ||||
var SYNC = 32; /* looking for synchronization bytes to restart inflate() */ | ||||
/* ===========================================================================*/ | ||||
var ENOUGH_LENS = 852; | ||||
var ENOUGH_DISTS = 592; | ||||
//var ENOUGH = (ENOUGH_LENS+ENOUGH_DISTS); | ||||
var MAX_WBITS = 15; | ||||
/* 32K LZ77 window */ | ||||
var DEF_WBITS = MAX_WBITS; | ||||
function zswap32(q) { | ||||
return (((q >>> 24) & 0xff) + | ||||
((q >>> 8) & 0xff00) + | ||||
((q & 0xff00) << 8) + | ||||
((q & 0xff) << 24)); | ||||
} | ||||
function InflateState() { | ||||
this.mode = 0; /* current inflate mode */ | ||||
this.last = false; /* true if processing last block */ | ||||
this.wrap = 0; /* bit 0 true for zlib, bit 1 true for gzip */ | ||||
this.havedict = false; /* true if dictionary provided */ | ||||
this.flags = 0; /* gzip header method and flags (0 if zlib) */ | ||||
this.dmax = 0; /* zlib header max distance (INFLATE_STRICT) */ | ||||
this.check = 0; /* protected copy of check value */ | ||||
this.total = 0; /* protected copy of output count */ | ||||
// TODO: may be {} | ||||
this.head = null; /* where to save gzip header information */ | ||||
/* sliding window */ | ||||
this.wbits = 0; /* log base 2 of requested window size */ | ||||
this.wsize = 0; /* window size or zero if not using window */ | ||||
this.whave = 0; /* valid bytes in the window */ | ||||
this.wnext = 0; /* window write index */ | ||||
this.window = null; /* allocated sliding window, if needed */ | ||||
/* bit accumulator */ | ||||
this.hold = 0; /* input bit accumulator */ | ||||
this.bits = 0; /* number of bits in "in" */ | ||||
/* for string and stored block copying */ | ||||
this.length = 0; /* literal or length of data to copy */ | ||||
this.offset = 0; /* distance back to copy string from */ | ||||
/* for table and code decoding */ | ||||
this.extra = 0; /* extra bits needed */ | ||||
/* fixed and dynamic code tables */ | ||||
this.lencode = null; /* starting table for length/literal codes */ | ||||
this.distcode = null; /* starting table for distance codes */ | ||||
this.lenbits = 0; /* index bits for lencode */ | ||||
this.distbits = 0; /* index bits for distcode */ | ||||
/* dynamic table building */ | ||||
this.ncode = 0; /* number of code length code lengths */ | ||||
this.nlen = 0; /* number of length code lengths */ | ||||
this.ndist = 0; /* number of distance code lengths */ | ||||
this.have = 0; /* number of code lengths in lens[] */ | ||||
this.next = null; /* next available space in codes[] */ | ||||
this.lens = new utils.Buf16(320); /* temporary storage for code lengths */ | ||||
this.work = new utils.Buf16(288); /* work area for code table building */ | ||||
/* | ||||
because we don't have pointers in js, we use lencode and distcode directly | ||||
as buffers so we don't need codes | ||||
*/ | ||||
//this.codes = new utils.Buf32(ENOUGH); /* space for code tables */ | ||||
this.lendyn = null; /* dynamic table for length/literal codes (JS specific) */ | ||||
this.distdyn = null; /* dynamic table for distance codes (JS specific) */ | ||||
this.sane = 0; /* if false, allow invalid distance too far */ | ||||
this.back = 0; /* bits back of last unprocessed length/lit */ | ||||
this.was = 0; /* initial length of match */ | ||||
} | ||||
function inflateResetKeep(strm) { | ||||
var state; | ||||
if (!strm || !strm.state) { return Z_STREAM_ERROR; } | ||||
state = strm.state; | ||||
strm.total_in = strm.total_out = state.total = 0; | ||||
strm.msg = ''; /*Z_NULL*/ | ||||
if (state.wrap) { /* to support ill-conceived Java test suite */ | ||||
strm.adler = state.wrap & 1; | ||||
} | ||||
state.mode = HEAD; | ||||
state.last = 0; | ||||
state.havedict = 0; | ||||
state.dmax = 32768; | ||||
state.head = null/*Z_NULL*/; | ||||
state.hold = 0; | ||||
state.bits = 0; | ||||
//state.lencode = state.distcode = state.next = state.codes; | ||||
state.lencode = state.lendyn = new utils.Buf32(ENOUGH_LENS); | ||||
state.distcode = state.distdyn = new utils.Buf32(ENOUGH_DISTS); | ||||
state.sane = 1; | ||||
state.back = -1; | ||||
//Tracev((stderr, "inflate: reset\n")); | ||||
return Z_OK; | ||||
} | ||||
function inflateReset(strm) { | ||||
var state; | ||||
if (!strm || !strm.state) { return Z_STREAM_ERROR; } | ||||
state = strm.state; | ||||
state.wsize = 0; | ||||
state.whave = 0; | ||||
state.wnext = 0; | ||||
return inflateResetKeep(strm); | ||||
} | ||||
function inflateReset2(strm, windowBits) { | ||||
var wrap; | ||||
var state; | ||||
/* get the state */ | ||||
if (!strm || !strm.state) { return Z_STREAM_ERROR; } | ||||
state = strm.state; | ||||
/* extract wrap request from windowBits parameter */ | ||||
if (windowBits < 0) { | ||||
wrap = 0; | ||||
windowBits = -windowBits; | ||||
} | ||||
else { | ||||
wrap = (windowBits >> 4) + 1; | ||||
if (windowBits < 48) { | ||||
windowBits &= 15; | ||||
} | ||||
} | ||||
/* set number of window bits, free window if different */ | ||||
if (windowBits && (windowBits < 8 || windowBits > 15)) { | ||||
return Z_STREAM_ERROR; | ||||
} | ||||
if (state.window !== null && state.wbits !== windowBits) { | ||||
state.window = null; | ||||
} | ||||
/* update state and reset the rest of it */ | ||||
state.wrap = wrap; | ||||
state.wbits = windowBits; | ||||
return inflateReset(strm); | ||||
} | ||||
function inflateInit2(strm, windowBits) { | ||||
var ret; | ||||
var state; | ||||
if (!strm) { return Z_STREAM_ERROR; } | ||||
//strm.msg = Z_NULL; /* in case we return an error */ | ||||
state = new InflateState(); | ||||
//if (state === Z_NULL) return Z_MEM_ERROR; | ||||
//Tracev((stderr, "inflate: allocated\n")); | ||||
strm.state = state; | ||||
state.window = null/*Z_NULL*/; | ||||
ret = inflateReset2(strm, windowBits); | ||||
if (ret !== Z_OK) { | ||||
strm.state = null/*Z_NULL*/; | ||||
} | ||||
return ret; | ||||
} | ||||
function inflateInit(strm) { | ||||
return inflateInit2(strm, DEF_WBITS); | ||||
} | ||||
/* | ||||
Return state with length and distance decoding tables and index sizes set to | ||||
fixed code decoding. Normally this returns fixed tables from inffixed.h. | ||||
If BUILDFIXED is defined, then instead this routine builds the tables the | ||||
first time it's called, and returns those tables the first time and | ||||
thereafter. This reduces the size of the code by about 2K bytes, in | ||||
exchange for a little execution time. However, BUILDFIXED should not be | ||||
used for threaded applications, since the rewriting of the tables and virgin | ||||
may not be thread-safe. | ||||
*/ | ||||
var virgin = true; | ||||
var lenfix, distfix; // We have no pointers in JS, so keep tables separate | ||||
function fixedtables(state) { | ||||
/* build fixed huffman tables if first call (may not be thread safe) */ | ||||
if (virgin) { | ||||
var sym; | ||||
lenfix = new utils.Buf32(512); | ||||
distfix = new utils.Buf32(32); | ||||
/* literal/length table */ | ||||
sym = 0; | ||||
while (sym < 144) { state.lens[sym++] = 8; } | ||||
while (sym < 256) { state.lens[sym++] = 9; } | ||||
while (sym < 280) { state.lens[sym++] = 7; } | ||||
while (sym < 288) { state.lens[sym++] = 8; } | ||||
inflate_table(LENS, state.lens, 0, 288, lenfix, 0, state.work, { bits: 9 }); | ||||
/* distance table */ | ||||
sym = 0; | ||||
while (sym < 32) { state.lens[sym++] = 5; } | ||||
inflate_table(DISTS, state.lens, 0, 32, distfix, 0, state.work, { bits: 5 }); | ||||
/* do this just once */ | ||||
virgin = false; | ||||
} | ||||
state.lencode = lenfix; | ||||
state.lenbits = 9; | ||||
state.distcode = distfix; | ||||
state.distbits = 5; | ||||
} | ||||
/* | ||||
Update the window with the last wsize (normally 32K) bytes written before | ||||
returning. If window does not exist yet, create it. This is only called | ||||
when a window is already in use, or when output has been written during this | ||||
inflate call, but the end of the deflate stream has not been reached yet. | ||||
It is also called to create a window for dictionary data when a dictionary | ||||
is loaded. | ||||
Providing output buffers larger than 32K to inflate() should provide a speed | ||||
advantage, since only the last 32K of output is copied to the sliding window | ||||
upon return from inflate(), and since all distances after the first 32K of | ||||
output will fall in the output data, making match copies simpler and faster. | ||||
The advantage may be dependent on the size of the processor's data caches. | ||||
*/ | ||||
function updatewindow(strm, src, end, copy) { | ||||
var dist; | ||||
var state = strm.state; | ||||
/* if it hasn't been done already, allocate space for the window */ | ||||
if (state.window === null) { | ||||
state.wsize = 1 << state.wbits; | ||||
state.wnext = 0; | ||||
state.whave = 0; | ||||
state.window = new utils.Buf8(state.wsize); | ||||
} | ||||
/* copy state->wsize or less output bytes into the circular window */ | ||||
if (copy >= state.wsize) { | ||||
utils.arraySet(state.window, src, end - state.wsize, state.wsize, 0); | ||||
state.wnext = 0; | ||||
state.whave = state.wsize; | ||||
} | ||||
else { | ||||
dist = state.wsize - state.wnext; | ||||
if (dist > copy) { | ||||
dist = copy; | ||||
} | ||||
//zmemcpy(state->window + state->wnext, end - copy, dist); | ||||
utils.arraySet(state.window, src, end - copy, dist, state.wnext); | ||||
copy -= dist; | ||||
if (copy) { | ||||
//zmemcpy(state->window, end - copy, copy); | ||||
utils.arraySet(state.window, src, end - copy, copy, 0); | ||||
state.wnext = copy; | ||||
state.whave = state.wsize; | ||||
} | ||||
else { | ||||
state.wnext += dist; | ||||
if (state.wnext === state.wsize) { state.wnext = 0; } | ||||
if (state.whave < state.wsize) { state.whave += dist; } | ||||
} | ||||
} | ||||
return 0; | ||||
} | ||||
function inflate(strm, flush) { | ||||
var state; | ||||
var input, output; // input/output buffers | ||||
var next; /* next input INDEX */ | ||||
var put; /* next output INDEX */ | ||||
var have, left; /* available input and output */ | ||||
var hold; /* bit buffer */ | ||||
var bits; /* bits in bit buffer */ | ||||
var _in, _out; /* save starting available input and output */ | ||||
var copy; /* number of stored or match bytes to copy */ | ||||
var from; /* where to copy match bytes from */ | ||||
var from_source; | ||||
var here = 0; /* current decoding table entry */ | ||||
var here_bits, here_op, here_val; // paked "here" denormalized (JS specific) | ||||
//var last; /* parent table entry */ | ||||
var last_bits, last_op, last_val; // paked "last" denormalized (JS specific) | ||||
var len; /* length to copy for repeats, bits to drop */ | ||||
var ret; /* return code */ | ||||
var hbuf = new utils.Buf8(4); /* buffer for gzip header crc calculation */ | ||||
var opts; | ||||
var n; // temporary var for NEED_BITS | ||||
var order = /* permutation of code lengths */ | ||||
[ 16, 17, 18, 0, 8, 7, 9, 6, 10, 5, 11, 4, 12, 3, 13, 2, 14, 1, 15 ]; | ||||
if (!strm || !strm.state || !strm.output || | ||||
(!strm.input && strm.avail_in !== 0)) { | ||||
return Z_STREAM_ERROR; | ||||
} | ||||
state = strm.state; | ||||
if (state.mode === TYPE) { state.mode = TYPEDO; } /* skip check */ | ||||
//--- LOAD() --- | ||||
put = strm.next_out; | ||||
output = strm.output; | ||||
left = strm.avail_out; | ||||
next = strm.next_in; | ||||
input = strm.input; | ||||
have = strm.avail_in; | ||||
hold = state.hold; | ||||
bits = state.bits; | ||||
//--- | ||||
_in = have; | ||||
_out = left; | ||||
ret = Z_OK; | ||||
inf_leave: // goto emulation | ||||
for (;;) { | ||||
switch (state.mode) { | ||||
case HEAD: | ||||
if (state.wrap === 0) { | ||||
state.mode = TYPEDO; | ||||
break; | ||||
} | ||||
//=== NEEDBITS(16); | ||||
while (bits < 16) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
if ((state.wrap & 2) && hold === 0x8b1f) { /* gzip header */ | ||||
state.check = 0/*crc32(0L, Z_NULL, 0)*/; | ||||
//=== CRC2(state.check, hold); | ||||
hbuf[0] = hold & 0xff; | ||||
hbuf[1] = (hold >>> 8) & 0xff; | ||||
state.check = crc32(state.check, hbuf, 2, 0); | ||||
//===// | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
state.mode = FLAGS; | ||||
break; | ||||
} | ||||
state.flags = 0; /* expect zlib header */ | ||||
if (state.head) { | ||||
state.head.done = false; | ||||
} | ||||
if (!(state.wrap & 1) || /* check if zlib header allowed */ | ||||
(((hold & 0xff)/*BITS(8)*/ << 8) + (hold >> 8)) % 31) { | ||||
strm.msg = 'incorrect header check'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
if ((hold & 0x0f)/*BITS(4)*/ !== Z_DEFLATED) { | ||||
strm.msg = 'unknown compression method'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
//--- DROPBITS(4) ---// | ||||
hold >>>= 4; | ||||
bits -= 4; | ||||
//---// | ||||
len = (hold & 0x0f)/*BITS(4)*/ + 8; | ||||
if (state.wbits === 0) { | ||||
state.wbits = len; | ||||
} | ||||
else if (len > state.wbits) { | ||||
strm.msg = 'invalid window size'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
state.dmax = 1 << len; | ||||
//Tracev((stderr, "inflate: zlib header ok\n")); | ||||
strm.adler = state.check = 1/*adler32(0L, Z_NULL, 0)*/; | ||||
state.mode = hold & 0x200 ? DICTID : TYPE; | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
break; | ||||
case FLAGS: | ||||
//=== NEEDBITS(16); */ | ||||
while (bits < 16) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
state.flags = hold; | ||||
if ((state.flags & 0xff) !== Z_DEFLATED) { | ||||
strm.msg = 'unknown compression method'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
if (state.flags & 0xe000) { | ||||
strm.msg = 'unknown header flags set'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
if (state.head) { | ||||
state.head.text = ((hold >> 8) & 1); | ||||
} | ||||
if (state.flags & 0x0200) { | ||||
//=== CRC2(state.check, hold); | ||||
hbuf[0] = hold & 0xff; | ||||
hbuf[1] = (hold >>> 8) & 0xff; | ||||
state.check = crc32(state.check, hbuf, 2, 0); | ||||
//===// | ||||
} | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
state.mode = TIME; | ||||
/* falls through */ | ||||
case TIME: | ||||
//=== NEEDBITS(32); */ | ||||
while (bits < 32) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
if (state.head) { | ||||
state.head.time = hold; | ||||
} | ||||
if (state.flags & 0x0200) { | ||||
//=== CRC4(state.check, hold) | ||||
hbuf[0] = hold & 0xff; | ||||
hbuf[1] = (hold >>> 8) & 0xff; | ||||
hbuf[2] = (hold >>> 16) & 0xff; | ||||
hbuf[3] = (hold >>> 24) & 0xff; | ||||
state.check = crc32(state.check, hbuf, 4, 0); | ||||
//=== | ||||
} | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
state.mode = OS; | ||||
/* falls through */ | ||||
case OS: | ||||
//=== NEEDBITS(16); */ | ||||
while (bits < 16) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
if (state.head) { | ||||
state.head.xflags = (hold & 0xff); | ||||
state.head.os = (hold >> 8); | ||||
} | ||||
if (state.flags & 0x0200) { | ||||
//=== CRC2(state.check, hold); | ||||
hbuf[0] = hold & 0xff; | ||||
hbuf[1] = (hold >>> 8) & 0xff; | ||||
state.check = crc32(state.check, hbuf, 2, 0); | ||||
//===// | ||||
} | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
state.mode = EXLEN; | ||||
/* falls through */ | ||||
case EXLEN: | ||||
if (state.flags & 0x0400) { | ||||
//=== NEEDBITS(16); */ | ||||
while (bits < 16) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
state.length = hold; | ||||
if (state.head) { | ||||
state.head.extra_len = hold; | ||||
} | ||||
if (state.flags & 0x0200) { | ||||
//=== CRC2(state.check, hold); | ||||
hbuf[0] = hold & 0xff; | ||||
hbuf[1] = (hold >>> 8) & 0xff; | ||||
state.check = crc32(state.check, hbuf, 2, 0); | ||||
//===// | ||||
} | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
} | ||||
else if (state.head) { | ||||
state.head.extra = null/*Z_NULL*/; | ||||
} | ||||
state.mode = EXTRA; | ||||
/* falls through */ | ||||
case EXTRA: | ||||
if (state.flags & 0x0400) { | ||||
copy = state.length; | ||||
if (copy > have) { copy = have; } | ||||
if (copy) { | ||||
if (state.head) { | ||||
len = state.head.extra_len - state.length; | ||||
if (!state.head.extra) { | ||||
// Use untyped array for more conveniend processing later | ||||
state.head.extra = new Array(state.head.extra_len); | ||||
} | ||||
utils.arraySet( | ||||
state.head.extra, | ||||
input, | ||||
next, | ||||
// extra field is limited to 65536 bytes | ||||
// - no need for additional size check | ||||
copy, | ||||
/*len + copy > state.head.extra_max - len ? state.head.extra_max : copy,*/ | ||||
len | ||||
); | ||||
//zmemcpy(state.head.extra + len, next, | ||||
// len + copy > state.head.extra_max ? | ||||
// state.head.extra_max - len : copy); | ||||
} | ||||
if (state.flags & 0x0200) { | ||||
state.check = crc32(state.check, input, copy, next); | ||||
} | ||||
have -= copy; | ||||
next += copy; | ||||
state.length -= copy; | ||||
} | ||||
if (state.length) { break inf_leave; } | ||||
} | ||||
state.length = 0; | ||||
state.mode = NAME; | ||||
/* falls through */ | ||||
case NAME: | ||||
if (state.flags & 0x0800) { | ||||
if (have === 0) { break inf_leave; } | ||||
copy = 0; | ||||
do { | ||||
// TODO: 2 or 1 bytes? | ||||
len = input[next + copy++]; | ||||
/* use constant limit because in js we should not preallocate memory */ | ||||
if (state.head && len && | ||||
(state.length < 65536 /*state.head.name_max*/)) { | ||||
state.head.name += String.fromCharCode(len); | ||||
} | ||||
} while (len && copy < have); | ||||
if (state.flags & 0x0200) { | ||||
state.check = crc32(state.check, input, copy, next); | ||||
} | ||||
have -= copy; | ||||
next += copy; | ||||
if (len) { break inf_leave; } | ||||
} | ||||
else if (state.head) { | ||||
state.head.name = null; | ||||
} | ||||
state.length = 0; | ||||
state.mode = COMMENT; | ||||
/* falls through */ | ||||
case COMMENT: | ||||
if (state.flags & 0x1000) { | ||||
if (have === 0) { break inf_leave; } | ||||
copy = 0; | ||||
do { | ||||
len = input[next + copy++]; | ||||
/* use constant limit because in js we should not preallocate memory */ | ||||
if (state.head && len && | ||||
(state.length < 65536 /*state.head.comm_max*/)) { | ||||
state.head.comment += String.fromCharCode(len); | ||||
} | ||||
} while (len && copy < have); | ||||
if (state.flags & 0x0200) { | ||||
state.check = crc32(state.check, input, copy, next); | ||||
} | ||||
have -= copy; | ||||
next += copy; | ||||
if (len) { break inf_leave; } | ||||
} | ||||
else if (state.head) { | ||||
state.head.comment = null; | ||||
} | ||||
state.mode = HCRC; | ||||
/* falls through */ | ||||
case HCRC: | ||||
if (state.flags & 0x0200) { | ||||
//=== NEEDBITS(16); */ | ||||
while (bits < 16) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
if (hold !== (state.check & 0xffff)) { | ||||
strm.msg = 'header crc mismatch'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
} | ||||
if (state.head) { | ||||
state.head.hcrc = ((state.flags >> 9) & 1); | ||||
state.head.done = true; | ||||
} | ||||
strm.adler = state.check = 0; | ||||
state.mode = TYPE; | ||||
break; | ||||
case DICTID: | ||||
//=== NEEDBITS(32); */ | ||||
while (bits < 32) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
strm.adler = state.check = zswap32(hold); | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
state.mode = DICT; | ||||
/* falls through */ | ||||
case DICT: | ||||
if (state.havedict === 0) { | ||||
//--- RESTORE() --- | ||||
strm.next_out = put; | ||||
strm.avail_out = left; | ||||
strm.next_in = next; | ||||
strm.avail_in = have; | ||||
state.hold = hold; | ||||
state.bits = bits; | ||||
//--- | ||||
return Z_NEED_DICT; | ||||
} | ||||
strm.adler = state.check = 1/*adler32(0L, Z_NULL, 0)*/; | ||||
state.mode = TYPE; | ||||
/* falls through */ | ||||
case TYPE: | ||||
if (flush === Z_BLOCK || flush === Z_TREES) { break inf_leave; } | ||||
/* falls through */ | ||||
case TYPEDO: | ||||
if (state.last) { | ||||
//--- BYTEBITS() ---// | ||||
hold >>>= bits & 7; | ||||
bits -= bits & 7; | ||||
//---// | ||||
state.mode = CHECK; | ||||
break; | ||||
} | ||||
//=== NEEDBITS(3); */ | ||||
while (bits < 3) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
state.last = (hold & 0x01)/*BITS(1)*/; | ||||
//--- DROPBITS(1) ---// | ||||
hold >>>= 1; | ||||
bits -= 1; | ||||
//---// | ||||
switch ((hold & 0x03)/*BITS(2)*/) { | ||||
case 0: /* stored block */ | ||||
//Tracev((stderr, "inflate: stored block%s\n", | ||||
// state.last ? " (last)" : "")); | ||||
state.mode = STORED; | ||||
break; | ||||
case 1: /* fixed block */ | ||||
fixedtables(state); | ||||
//Tracev((stderr, "inflate: fixed codes block%s\n", | ||||
// state.last ? " (last)" : "")); | ||||
state.mode = LEN_; /* decode codes */ | ||||
if (flush === Z_TREES) { | ||||
//--- DROPBITS(2) ---// | ||||
hold >>>= 2; | ||||
bits -= 2; | ||||
//---// | ||||
break inf_leave; | ||||
} | ||||
break; | ||||
case 2: /* dynamic block */ | ||||
//Tracev((stderr, "inflate: dynamic codes block%s\n", | ||||
// state.last ? " (last)" : "")); | ||||
state.mode = TABLE; | ||||
break; | ||||
case 3: | ||||
strm.msg = 'invalid block type'; | ||||
state.mode = BAD; | ||||
} | ||||
//--- DROPBITS(2) ---// | ||||
hold >>>= 2; | ||||
bits -= 2; | ||||
//---// | ||||
break; | ||||
case STORED: | ||||
//--- BYTEBITS() ---// /* go to byte boundary */ | ||||
hold >>>= bits & 7; | ||||
bits -= bits & 7; | ||||
//---// | ||||
//=== NEEDBITS(32); */ | ||||
while (bits < 32) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
if ((hold & 0xffff) !== ((hold >>> 16) ^ 0xffff)) { | ||||
strm.msg = 'invalid stored block lengths'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
state.length = hold & 0xffff; | ||||
//Tracev((stderr, "inflate: stored length %u\n", | ||||
// state.length)); | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
state.mode = COPY_; | ||||
if (flush === Z_TREES) { break inf_leave; } | ||||
/* falls through */ | ||||
case COPY_: | ||||
state.mode = COPY; | ||||
/* falls through */ | ||||
case COPY: | ||||
copy = state.length; | ||||
if (copy) { | ||||
if (copy > have) { copy = have; } | ||||
if (copy > left) { copy = left; } | ||||
if (copy === 0) { break inf_leave; } | ||||
//--- zmemcpy(put, next, copy); --- | ||||
utils.arraySet(output, input, next, copy, put); | ||||
//---// | ||||
have -= copy; | ||||
next += copy; | ||||
left -= copy; | ||||
put += copy; | ||||
state.length -= copy; | ||||
break; | ||||
} | ||||
//Tracev((stderr, "inflate: stored end\n")); | ||||
state.mode = TYPE; | ||||
break; | ||||
case TABLE: | ||||
//=== NEEDBITS(14); */ | ||||
while (bits < 14) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
state.nlen = (hold & 0x1f)/*BITS(5)*/ + 257; | ||||
//--- DROPBITS(5) ---// | ||||
hold >>>= 5; | ||||
bits -= 5; | ||||
//---// | ||||
state.ndist = (hold & 0x1f)/*BITS(5)*/ + 1; | ||||
//--- DROPBITS(5) ---// | ||||
hold >>>= 5; | ||||
bits -= 5; | ||||
//---// | ||||
state.ncode = (hold & 0x0f)/*BITS(4)*/ + 4; | ||||
//--- DROPBITS(4) ---// | ||||
hold >>>= 4; | ||||
bits -= 4; | ||||
//---// | ||||
//#ifndef PKZIP_BUG_WORKAROUND | ||||
if (state.nlen > 286 || state.ndist > 30) { | ||||
strm.msg = 'too many length or distance symbols'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
//#endif | ||||
//Tracev((stderr, "inflate: table sizes ok\n")); | ||||
state.have = 0; | ||||
state.mode = LENLENS; | ||||
/* falls through */ | ||||
case LENLENS: | ||||
while (state.have < state.ncode) { | ||||
//=== NEEDBITS(3); | ||||
while (bits < 3) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
state.lens[order[state.have++]] = (hold & 0x07);//BITS(3); | ||||
//--- DROPBITS(3) ---// | ||||
hold >>>= 3; | ||||
bits -= 3; | ||||
//---// | ||||
} | ||||
while (state.have < 19) { | ||||
state.lens[order[state.have++]] = 0; | ||||
} | ||||
// We have separate tables & no pointers. 2 commented lines below not needed. | ||||
//state.next = state.codes; | ||||
//state.lencode = state.next; | ||||
// Switch to use dynamic table | ||||
state.lencode = state.lendyn; | ||||
state.lenbits = 7; | ||||
opts = { bits: state.lenbits }; | ||||
ret = inflate_table(CODES, state.lens, 0, 19, state.lencode, 0, state.work, opts); | ||||
state.lenbits = opts.bits; | ||||
if (ret) { | ||||
strm.msg = 'invalid code lengths set'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
//Tracev((stderr, "inflate: code lengths ok\n")); | ||||
state.have = 0; | ||||
state.mode = CODELENS; | ||||
/* falls through */ | ||||
case CODELENS: | ||||
while (state.have < state.nlen + state.ndist) { | ||||
for (;;) { | ||||
here = state.lencode[hold & ((1 << state.lenbits) - 1)];/*BITS(state.lenbits)*/ | ||||
here_bits = here >>> 24; | ||||
here_op = (here >>> 16) & 0xff; | ||||
here_val = here & 0xffff; | ||||
if ((here_bits) <= bits) { break; } | ||||
//--- PULLBYTE() ---// | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
//---// | ||||
} | ||||
if (here_val < 16) { | ||||
//--- DROPBITS(here.bits) ---// | ||||
hold >>>= here_bits; | ||||
bits -= here_bits; | ||||
//---// | ||||
state.lens[state.have++] = here_val; | ||||
} | ||||
else { | ||||
if (here_val === 16) { | ||||
//=== NEEDBITS(here.bits + 2); | ||||
n = here_bits + 2; | ||||
while (bits < n) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
//--- DROPBITS(here.bits) ---// | ||||
hold >>>= here_bits; | ||||
bits -= here_bits; | ||||
//---// | ||||
if (state.have === 0) { | ||||
strm.msg = 'invalid bit length repeat'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
len = state.lens[state.have - 1]; | ||||
copy = 3 + (hold & 0x03);//BITS(2); | ||||
//--- DROPBITS(2) ---// | ||||
hold >>>= 2; | ||||
bits -= 2; | ||||
//---// | ||||
} | ||||
else if (here_val === 17) { | ||||
//=== NEEDBITS(here.bits + 3); | ||||
n = here_bits + 3; | ||||
while (bits < n) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
//--- DROPBITS(here.bits) ---// | ||||
hold >>>= here_bits; | ||||
bits -= here_bits; | ||||
//---// | ||||
len = 0; | ||||
copy = 3 + (hold & 0x07);//BITS(3); | ||||
//--- DROPBITS(3) ---// | ||||
hold >>>= 3; | ||||
bits -= 3; | ||||
//---// | ||||
} | ||||
else { | ||||
//=== NEEDBITS(here.bits + 7); | ||||
n = here_bits + 7; | ||||
while (bits < n) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
//--- DROPBITS(here.bits) ---// | ||||
hold >>>= here_bits; | ||||
bits -= here_bits; | ||||
//---// | ||||
len = 0; | ||||
copy = 11 + (hold & 0x7f);//BITS(7); | ||||
//--- DROPBITS(7) ---// | ||||
hold >>>= 7; | ||||
bits -= 7; | ||||
//---// | ||||
} | ||||
if (state.have + copy > state.nlen + state.ndist) { | ||||
strm.msg = 'invalid bit length repeat'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
while (copy--) { | ||||
state.lens[state.have++] = len; | ||||
} | ||||
} | ||||
} | ||||
/* handle error breaks in while */ | ||||
if (state.mode === BAD) { break; } | ||||
/* check for end-of-block code (better have one) */ | ||||
if (state.lens[256] === 0) { | ||||
strm.msg = 'invalid code -- missing end-of-block'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
/* build code tables -- note: do not change the lenbits or distbits | ||||
values here (9 and 6) without reading the comments in inftrees.h | ||||
concerning the ENOUGH constants, which depend on those values */ | ||||
state.lenbits = 9; | ||||
opts = { bits: state.lenbits }; | ||||
ret = inflate_table(LENS, state.lens, 0, state.nlen, state.lencode, 0, state.work, opts); | ||||
// We have separate tables & no pointers. 2 commented lines below not needed. | ||||
// state.next_index = opts.table_index; | ||||
state.lenbits = opts.bits; | ||||
// state.lencode = state.next; | ||||
if (ret) { | ||||
strm.msg = 'invalid literal/lengths set'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
state.distbits = 6; | ||||
//state.distcode.copy(state.codes); | ||||
// Switch to use dynamic table | ||||
state.distcode = state.distdyn; | ||||
opts = { bits: state.distbits }; | ||||
ret = inflate_table(DISTS, state.lens, state.nlen, state.ndist, state.distcode, 0, state.work, opts); | ||||
// We have separate tables & no pointers. 2 commented lines below not needed. | ||||
// state.next_index = opts.table_index; | ||||
state.distbits = opts.bits; | ||||
// state.distcode = state.next; | ||||
if (ret) { | ||||
strm.msg = 'invalid distances set'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
//Tracev((stderr, 'inflate: codes ok\n')); | ||||
state.mode = LEN_; | ||||
if (flush === Z_TREES) { break inf_leave; } | ||||
/* falls through */ | ||||
case LEN_: | ||||
state.mode = LEN; | ||||
/* falls through */ | ||||
case LEN: | ||||
if (have >= 6 && left >= 258) { | ||||
//--- RESTORE() --- | ||||
strm.next_out = put; | ||||
strm.avail_out = left; | ||||
strm.next_in = next; | ||||
strm.avail_in = have; | ||||
state.hold = hold; | ||||
state.bits = bits; | ||||
//--- | ||||
inflate_fast(strm, _out); | ||||
//--- LOAD() --- | ||||
put = strm.next_out; | ||||
output = strm.output; | ||||
left = strm.avail_out; | ||||
next = strm.next_in; | ||||
input = strm.input; | ||||
have = strm.avail_in; | ||||
hold = state.hold; | ||||
bits = state.bits; | ||||
//--- | ||||
if (state.mode === TYPE) { | ||||
state.back = -1; | ||||
} | ||||
break; | ||||
} | ||||
state.back = 0; | ||||
for (;;) { | ||||
here = state.lencode[hold & ((1 << state.lenbits) - 1)]; /*BITS(state.lenbits)*/ | ||||
here_bits = here >>> 24; | ||||
here_op = (here >>> 16) & 0xff; | ||||
here_val = here & 0xffff; | ||||
if (here_bits <= bits) { break; } | ||||
//--- PULLBYTE() ---// | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
//---// | ||||
} | ||||
if (here_op && (here_op & 0xf0) === 0) { | ||||
last_bits = here_bits; | ||||
last_op = here_op; | ||||
last_val = here_val; | ||||
for (;;) { | ||||
here = state.lencode[last_val + | ||||
((hold & ((1 << (last_bits + last_op)) - 1))/*BITS(last.bits + last.op)*/ >> last_bits)]; | ||||
here_bits = here >>> 24; | ||||
here_op = (here >>> 16) & 0xff; | ||||
here_val = here & 0xffff; | ||||
if ((last_bits + here_bits) <= bits) { break; } | ||||
//--- PULLBYTE() ---// | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
//---// | ||||
} | ||||
//--- DROPBITS(last.bits) ---// | ||||
hold >>>= last_bits; | ||||
bits -= last_bits; | ||||
//---// | ||||
state.back += last_bits; | ||||
} | ||||
//--- DROPBITS(here.bits) ---// | ||||
hold >>>= here_bits; | ||||
bits -= here_bits; | ||||
//---// | ||||
state.back += here_bits; | ||||
state.length = here_val; | ||||
if (here_op === 0) { | ||||
//Tracevv((stderr, here.val >= 0x20 && here.val < 0x7f ? | ||||
// "inflate: literal '%c'\n" : | ||||
// "inflate: literal 0x%02x\n", here.val)); | ||||
state.mode = LIT; | ||||
break; | ||||
} | ||||
if (here_op & 32) { | ||||
//Tracevv((stderr, "inflate: end of block\n")); | ||||
state.back = -1; | ||||
state.mode = TYPE; | ||||
break; | ||||
} | ||||
if (here_op & 64) { | ||||
strm.msg = 'invalid literal/length code'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
state.extra = here_op & 15; | ||||
state.mode = LENEXT; | ||||
/* falls through */ | ||||
case LENEXT: | ||||
if (state.extra) { | ||||
//=== NEEDBITS(state.extra); | ||||
n = state.extra; | ||||
while (bits < n) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
state.length += hold & ((1 << state.extra) - 1)/*BITS(state.extra)*/; | ||||
//--- DROPBITS(state.extra) ---// | ||||
hold >>>= state.extra; | ||||
bits -= state.extra; | ||||
//---// | ||||
state.back += state.extra; | ||||
} | ||||
//Tracevv((stderr, "inflate: length %u\n", state.length)); | ||||
state.was = state.length; | ||||
state.mode = DIST; | ||||
/* falls through */ | ||||
case DIST: | ||||
for (;;) { | ||||
here = state.distcode[hold & ((1 << state.distbits) - 1)];/*BITS(state.distbits)*/ | ||||
here_bits = here >>> 24; | ||||
here_op = (here >>> 16) & 0xff; | ||||
here_val = here & 0xffff; | ||||
if ((here_bits) <= bits) { break; } | ||||
//--- PULLBYTE() ---// | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
//---// | ||||
} | ||||
if ((here_op & 0xf0) === 0) { | ||||
last_bits = here_bits; | ||||
last_op = here_op; | ||||
last_val = here_val; | ||||
for (;;) { | ||||
here = state.distcode[last_val + | ||||
((hold & ((1 << (last_bits + last_op)) - 1))/*BITS(last.bits + last.op)*/ >> last_bits)]; | ||||
here_bits = here >>> 24; | ||||
here_op = (here >>> 16) & 0xff; | ||||
here_val = here & 0xffff; | ||||
if ((last_bits + here_bits) <= bits) { break; } | ||||
//--- PULLBYTE() ---// | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
//---// | ||||
} | ||||
//--- DROPBITS(last.bits) ---// | ||||
hold >>>= last_bits; | ||||
bits -= last_bits; | ||||
//---// | ||||
state.back += last_bits; | ||||
} | ||||
//--- DROPBITS(here.bits) ---// | ||||
hold >>>= here_bits; | ||||
bits -= here_bits; | ||||
//---// | ||||
state.back += here_bits; | ||||
if (here_op & 64) { | ||||
strm.msg = 'invalid distance code'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
state.offset = here_val; | ||||
state.extra = (here_op) & 15; | ||||
state.mode = DISTEXT; | ||||
/* falls through */ | ||||
case DISTEXT: | ||||
if (state.extra) { | ||||
//=== NEEDBITS(state.extra); | ||||
n = state.extra; | ||||
while (bits < n) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
state.offset += hold & ((1 << state.extra) - 1)/*BITS(state.extra)*/; | ||||
//--- DROPBITS(state.extra) ---// | ||||
hold >>>= state.extra; | ||||
bits -= state.extra; | ||||
//---// | ||||
state.back += state.extra; | ||||
} | ||||
//#ifdef INFLATE_STRICT | ||||
if (state.offset > state.dmax) { | ||||
strm.msg = 'invalid distance too far back'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
//#endif | ||||
//Tracevv((stderr, "inflate: distance %u\n", state.offset)); | ||||
state.mode = MATCH; | ||||
/* falls through */ | ||||
case MATCH: | ||||
if (left === 0) { break inf_leave; } | ||||
copy = _out - left; | ||||
if (state.offset > copy) { /* copy from window */ | ||||
copy = state.offset - copy; | ||||
if (copy > state.whave) { | ||||
if (state.sane) { | ||||
strm.msg = 'invalid distance too far back'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
// (!) This block is disabled in zlib defailts, | ||||
// don't enable it for binary compatibility | ||||
//#ifdef INFLATE_ALLOW_INVALID_DISTANCE_TOOFAR_ARRR | ||||
// Trace((stderr, "inflate.c too far\n")); | ||||
// copy -= state.whave; | ||||
// if (copy > state.length) { copy = state.length; } | ||||
// if (copy > left) { copy = left; } | ||||
// left -= copy; | ||||
// state.length -= copy; | ||||
// do { | ||||
// output[put++] = 0; | ||||
// } while (--copy); | ||||
// if (state.length === 0) { state.mode = LEN; } | ||||
// break; | ||||
//#endif | ||||
} | ||||
if (copy > state.wnext) { | ||||
copy -= state.wnext; | ||||
from = state.wsize - copy; | ||||
} | ||||
else { | ||||
from = state.wnext - copy; | ||||
} | ||||
if (copy > state.length) { copy = state.length; } | ||||
from_source = state.window; | ||||
} | ||||
else { /* copy from output */ | ||||
from_source = output; | ||||
from = put - state.offset; | ||||
copy = state.length; | ||||
} | ||||
if (copy > left) { copy = left; } | ||||
left -= copy; | ||||
state.length -= copy; | ||||
do { | ||||
output[put++] = from_source[from++]; | ||||
} while (--copy); | ||||
if (state.length === 0) { state.mode = LEN; } | ||||
break; | ||||
case LIT: | ||||
if (left === 0) { break inf_leave; } | ||||
output[put++] = state.length; | ||||
left--; | ||||
state.mode = LEN; | ||||
break; | ||||
case CHECK: | ||||
if (state.wrap) { | ||||
//=== NEEDBITS(32); | ||||
while (bits < 32) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
// Use '|' insdead of '+' to make sure that result is signed | ||||
hold |= input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
_out -= left; | ||||
strm.total_out += _out; | ||||
state.total += _out; | ||||
if (_out) { | ||||
strm.adler = state.check = | ||||
/*UPDATE(state.check, put - _out, _out);*/ | ||||
(state.flags ? crc32(state.check, output, _out, put - _out) : adler32(state.check, output, _out, put - _out)); | ||||
} | ||||
_out = left; | ||||
// NB: crc32 stored as signed 32-bit int, zswap32 returns signed too | ||||
if ((state.flags ? hold : zswap32(hold)) !== state.check) { | ||||
strm.msg = 'incorrect data check'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
//Tracev((stderr, "inflate: check matches trailer\n")); | ||||
} | ||||
state.mode = LENGTH; | ||||
/* falls through */ | ||||
case LENGTH: | ||||
if (state.wrap && state.flags) { | ||||
//=== NEEDBITS(32); | ||||
while (bits < 32) { | ||||
if (have === 0) { break inf_leave; } | ||||
have--; | ||||
hold += input[next++] << bits; | ||||
bits += 8; | ||||
} | ||||
//===// | ||||
if (hold !== (state.total & 0xffffffff)) { | ||||
strm.msg = 'incorrect length check'; | ||||
state.mode = BAD; | ||||
break; | ||||
} | ||||
//=== INITBITS(); | ||||
hold = 0; | ||||
bits = 0; | ||||
//===// | ||||
//Tracev((stderr, "inflate: length matches trailer\n")); | ||||
} | ||||
state.mode = DONE; | ||||
/* falls through */ | ||||
case DONE: | ||||
ret = Z_STREAM_END; | ||||
break inf_leave; | ||||
case BAD: | ||||
ret = Z_DATA_ERROR; | ||||
break inf_leave; | ||||
case MEM: | ||||
return Z_MEM_ERROR; | ||||
case SYNC: | ||||
/* falls through */ | ||||
default: | ||||
return Z_STREAM_ERROR; | ||||
} | ||||
} | ||||
// inf_leave <- here is real place for "goto inf_leave", emulated via "break inf_leave" | ||||
/* | ||||
Return from inflate(), updating the total counts and the check value. | ||||
If there was no progress during the inflate() call, return a buffer | ||||
error. Call updatewindow() to create and/or update the window state. | ||||
Note: a memory error from inflate() is non-recoverable. | ||||
*/ | ||||
//--- RESTORE() --- | ||||
strm.next_out = put; | ||||
strm.avail_out = left; | ||||
strm.next_in = next; | ||||
strm.avail_in = have; | ||||
state.hold = hold; | ||||
state.bits = bits; | ||||
//--- | ||||
if (state.wsize || (_out !== strm.avail_out && state.mode < BAD && | ||||
(state.mode < CHECK || flush !== Z_FINISH))) { | ||||
if (updatewindow(strm, strm.output, strm.next_out, _out - strm.avail_out)) { | ||||
state.mode = MEM; | ||||
return Z_MEM_ERROR; | ||||
} | ||||
} | ||||
_in -= strm.avail_in; | ||||
_out -= strm.avail_out; | ||||
strm.total_in += _in; | ||||
strm.total_out += _out; | ||||
state.total += _out; | ||||
if (state.wrap && _out) { | ||||
strm.adler = state.check = /*UPDATE(state.check, strm.next_out - _out, _out);*/ | ||||
(state.flags ? crc32(state.check, output, _out, strm.next_out - _out) : adler32(state.check, output, _out, strm.next_out - _out)); | ||||
} | ||||
strm.data_type = state.bits + (state.last ? 64 : 0) + | ||||
(state.mode === TYPE ? 128 : 0) + | ||||
(state.mode === LEN_ || state.mode === COPY_ ? 256 : 0); | ||||
if (((_in === 0 && _out === 0) || flush === Z_FINISH) && ret === Z_OK) { | ||||
ret = Z_BUF_ERROR; | ||||
} | ||||
return ret; | ||||
} | ||||
function inflateEnd(strm) { | ||||
if (!strm || !strm.state /*|| strm->zfree == (free_func)0*/) { | ||||
return Z_STREAM_ERROR; | ||||
} | ||||
var state = strm.state; | ||||
if (state.window) { | ||||
state.window = null; | ||||
} | ||||
strm.state = null; | ||||
return Z_OK; | ||||
} | ||||
function inflateGetHeader(strm, head) { | ||||
var state; | ||||
/* check state */ | ||||
if (!strm || !strm.state) { return Z_STREAM_ERROR; } | ||||
state = strm.state; | ||||
if ((state.wrap & 2) === 0) { return Z_STREAM_ERROR; } | ||||
/* save header structure */ | ||||
state.head = head; | ||||
head.done = false; | ||||
return Z_OK; | ||||
} | ||||
function inflateSetDictionary(strm, dictionary) { | ||||
var dictLength = dictionary.length; | ||||
var state; | ||||
var dictid; | ||||
var ret; | ||||
/* check state */ | ||||
if (!strm /* == Z_NULL */ || !strm.state /* == Z_NULL */) { return Z_STREAM_ERROR; } | ||||
state = strm.state; | ||||
if (state.wrap !== 0 && state.mode !== DICT) { | ||||
return Z_STREAM_ERROR; | ||||
} | ||||
/* check for correct dictionary identifier */ | ||||
if (state.mode === DICT) { | ||||
dictid = 1; /* adler32(0, null, 0)*/ | ||||
/* dictid = adler32(dictid, dictionary, dictLength); */ | ||||
dictid = adler32(dictid, dictionary, dictLength, 0); | ||||
if (dictid !== state.check) { | ||||
return Z_DATA_ERROR; | ||||
} | ||||
} | ||||
/* copy dictionary to window using updatewindow(), which will amend the | ||||
existing dictionary if appropriate */ | ||||
ret = updatewindow(strm, dictionary, dictLength, dictLength); | ||||
if (ret) { | ||||
state.mode = MEM; | ||||
return Z_MEM_ERROR; | ||||
} | ||||
state.havedict = 1; | ||||
// Tracev((stderr, "inflate: dictionary set\n")); | ||||
return Z_OK; | ||||
} | ||||
exports.inflateReset = inflateReset; | ||||
exports.inflateReset2 = inflateReset2; | ||||
exports.inflateResetKeep = inflateResetKeep; | ||||
exports.inflateInit = inflateInit; | ||||
exports.inflateInit2 = inflateInit2; | ||||
exports.inflate = inflate; | ||||
exports.inflateEnd = inflateEnd; | ||||
exports.inflateGetHeader = inflateGetHeader; | ||||
exports.inflateSetDictionary = inflateSetDictionary; | ||||
exports.inflateInfo = 'pako inflate (from Nodeca project)'; | ||||
/* Not implemented | ||||
exports.inflateCopy = inflateCopy; | ||||
exports.inflateGetDictionary = inflateGetDictionary; | ||||
exports.inflateMark = inflateMark; | ||||
exports.inflatePrime = inflatePrime; | ||||
exports.inflateSync = inflateSync; | ||||
exports.inflateSyncPoint = inflateSyncPoint; | ||||
exports.inflateUndermine = inflateUndermine; | ||||
*/ | ||||