inflate.c (48977B)
1 /* inflate.c -- zlib decompression 2 * Copyright (C) 1995-2005 Mark Adler 3 * For conditions of distribution and use, see copyright notice in zlib.h 4 */ 5 6 /* 7 * Change history: 8 * 9 * 1.2.beta0 24 Nov 2002 10 * - First version -- complete rewrite of inflate to simplify code, avoid 11 * creation of window when not needed, minimize use of window when it is 12 * needed, make inffast.c even faster, implement gzip decoding, and to 13 * improve code readability and style over the previous zlib inflate code 14 * 15 * 1.2.beta1 25 Nov 2002 16 * - Use pointers for available input and output checking in inffast.c 17 * - Remove input and output counters in inffast.c 18 * - Change inffast.c entry and loop from avail_in >= 7 to >= 6 19 * - Remove unnecessary second byte pull from length extra in inffast.c 20 * - Unroll direct copy to three copies per loop in inffast.c 21 * 22 * 1.2.beta2 4 Dec 2002 23 * - Change external routine names to reduce potential conflicts 24 * - Correct filename to inffixed.h for fixed tables in inflate.c 25 * - Make hbuf[] unsigned char to match parameter type in inflate.c 26 * - Change strm->next_out[-state->offset] to *(strm->next_out - state->offset) 27 * to avoid negation problem on Alphas (64 bit) in inflate.c 28 * 29 * 1.2.beta3 22 Dec 2002 30 * - Add comments on state->bits assertion in inffast.c 31 * - Add comments on op field in inftrees.h 32 * - Fix bug in reuse of allocated window after inflateReset() 33 * - Remove bit fields--back to byte structure for speed 34 * - Remove distance extra == 0 check in inflate_fast()--only helps for lengths 35 * - Change post-increments to pre-increments in inflate_fast(), PPC biased? 36 * - Add compile time option, POSTINC, to use post-increments instead (Intel?) 37 * - Make MATCH copy in inflate() much faster for when inflate_fast() not used 38 * - Use local copies of stream next and avail values, as well as local bit 39 * buffer and bit count in inflate()--for speed when inflate_fast() not used 40 * 41 * 1.2.beta4 1 Jan 2003 42 * - Split ptr - 257 statements in inflate_table() to avoid compiler warnings 43 * - Move a comment on output buffer sizes from inffast.c to inflate.c 44 * - Add comments in inffast.c to introduce the inflate_fast() routine 45 * - Rearrange window copies in inflate_fast() for speed and simplification 46 * - Unroll last copy for window match in inflate_fast() 47 * - Use local copies of window variables in inflate_fast() for speed 48 * - Pull out common write == 0 case for speed in inflate_fast() 49 * - Make op and len in inflate_fast() unsigned for consistency 50 * - Add FAR to lcode and dcode declarations in inflate_fast() 51 * - Simplified bad distance check in inflate_fast() 52 * - Added inflateBackInit(), inflateBack(), and inflateBackEnd() in new 53 * source file infback.c to provide a call-back interface to inflate for 54 * programs like gzip and unzip -- uses window as output buffer to avoid 55 * window copying 56 * 57 * 1.2.beta5 1 Jan 2003 58 * - Improved inflateBack() interface to allow the caller to provide initial 59 * input in strm. 60 * - Fixed stored blocks bug in inflateBack() 61 * 62 * 1.2.beta6 4 Jan 2003 63 * - Added comments in inffast.c on effectiveness of POSTINC 64 * - Typecasting all around to reduce compiler warnings 65 * - Changed loops from while (1) or do {} while (1) to for (;;), again to 66 * make compilers happy 67 * - Changed type of window in inflateBackInit() to unsigned char * 68 * 69 * 1.2.beta7 27 Jan 2003 70 * - Changed many types to unsigned or unsigned short to avoid warnings 71 * - Added inflateCopy() function 72 * 73 * 1.2.0 9 Mar 2003 74 * - Changed inflateBack() interface to provide separate opaque descriptors 75 * for the in() and out() functions 76 * - Changed inflateBack() argument and in_func typedef to swap the length 77 * and buffer address return values for the input function 78 * - Check next_in and next_out for Z_NULL on entry to inflate() 79 * 80 * The history for versions after 1.2.0 are in ChangeLog in zlib distribution. 81 */ 82 83 #include "zutil.h" 84 #include "inftrees.h" 85 #include "inflate.h" 86 #include "inffast.h" 87 88 #ifdef MAKEFIXED 89 # ifndef BUILDFIXED 90 # define BUILDFIXED 91 # endif 92 #endif 93 94 /* function prototypes */ 95 local void fixedtables OF((struct inflate_state FAR *state)); 96 local int updatewindow OF((z_streamp strm, unsigned out)); 97 #ifdef BUILDFIXED 98 void makefixed OF((void)); 99 #endif 100 local unsigned syncsearch OF((unsigned FAR *have, unsigned char FAR *buf, 101 unsigned len)); 102 103 int ZEXPORT inflateReset(strm) 104 z_streamp strm; 105 { 106 struct inflate_state FAR *state; 107 108 if (strm == Z_NULL || strm->state == Z_NULL) return Z_STREAM_ERROR; 109 state = (struct inflate_state FAR *)strm->state; 110 strm->total_in = strm->total_out = state->total = 0; 111 strm->msg = Z_NULL; 112 strm->adler = 1; /* to support ill-conceived Java test suite */ 113 state->mode = HEAD; 114 state->last = 0; 115 state->havedict = 0; 116 state->dmax = 32768U; 117 state->head = Z_NULL; 118 state->wsize = 0; 119 state->whave = 0; 120 state->write = 0; 121 state->hold = 0; 122 state->bits = 0; 123 state->lencode = state->distcode = state->next = state->codes; 124 Tracev((stderr, "inflate: reset\n")); 125 return Z_OK; 126 } 127 128 int ZEXPORT inflatePrime(strm, bits, value) 129 z_streamp strm; 130 int bits; 131 int value; 132 { 133 struct inflate_state FAR *state; 134 135 if (strm == Z_NULL || strm->state == Z_NULL) return Z_STREAM_ERROR; 136 state = (struct inflate_state FAR *)strm->state; 137 if (bits > 16 || state->bits + bits > 32) return Z_STREAM_ERROR; 138 value &= (1L << bits) - 1; 139 state->hold += value << state->bits; 140 state->bits += bits; 141 return Z_OK; 142 } 143 144 int ZEXPORT inflateInit2_(strm, windowBits, version, stream_size) 145 z_streamp strm; 146 int windowBits; 147 const char *version; 148 int stream_size; 149 { 150 struct inflate_state FAR *state; 151 152 if (version == Z_NULL || version[0] != ZLIB_VERSION[0] || 153 stream_size != (int)(sizeof(z_stream))) 154 return Z_VERSION_ERROR; 155 if (strm == Z_NULL) return Z_STREAM_ERROR; 156 strm->msg = Z_NULL; /* in case we return an error */ 157 if (strm->zalloc == (alloc_func)0) { 158 strm->zalloc = zcalloc; 159 strm->opaque = (voidpf)0; 160 } 161 if (strm->zfree == (free_func)0) strm->zfree = zcfree; 162 state = (struct inflate_state FAR *) 163 ZALLOC(strm, 1, sizeof(struct inflate_state)); 164 if (state == Z_NULL) return Z_MEM_ERROR; 165 Tracev((stderr, "inflate: allocated\n")); 166 strm->state = (struct internal_state FAR *)state; 167 if (windowBits < 0) { 168 state->wrap = 0; 169 windowBits = -windowBits; 170 } 171 else { 172 state->wrap = (windowBits >> 4) + 1; 173 #ifdef GUNZIP 174 if (windowBits < 48) windowBits &= 15; 175 #endif 176 } 177 if (windowBits < 8 || windowBits > 15) { 178 ZFREE(strm, state); 179 strm->state = Z_NULL; 180 return Z_STREAM_ERROR; 181 } 182 state->wbits = (unsigned)windowBits; 183 state->window = Z_NULL; 184 return inflateReset(strm); 185 } 186 187 int ZEXPORT inflateInit_(strm, version, stream_size) 188 z_streamp strm; 189 const char *version; 190 int stream_size; 191 { 192 return inflateInit2_(strm, DEF_WBITS, version, stream_size); 193 } 194 195 /* 196 Return state with length and distance decoding tables and index sizes set to 197 fixed code decoding. Normally this returns fixed tables from inffixed.h. 198 If BUILDFIXED is defined, then instead this routine builds the tables the 199 first time it's called, and returns those tables the first time and 200 thereafter. This reduces the size of the code by about 2K bytes, in 201 exchange for a little execution time. However, BUILDFIXED should not be 202 used for threaded applications, since the rewriting of the tables and virgin 203 may not be thread-safe. 204 */ 205 local void fixedtables(state) 206 struct inflate_state FAR *state; 207 { 208 #ifdef BUILDFIXED 209 static int virgin = 1; 210 static code *lenfix, *distfix; 211 static code fixed[544]; 212 213 /* build fixed huffman tables if first call (may not be thread safe) */ 214 if (virgin) { 215 unsigned sym, bits; 216 static code *next; 217 218 /* literal/length table */ 219 sym = 0; 220 while (sym < 144) state->lens[sym++] = 8; 221 while (sym < 256) state->lens[sym++] = 9; 222 while (sym < 280) state->lens[sym++] = 7; 223 while (sym < 288) state->lens[sym++] = 8; 224 next = fixed; 225 lenfix = next; 226 bits = 9; 227 inflate_table(LENS, state->lens, 288, &(next), &(bits), state->work); 228 229 /* distance table */ 230 sym = 0; 231 while (sym < 32) state->lens[sym++] = 5; 232 distfix = next; 233 bits = 5; 234 inflate_table(DISTS, state->lens, 32, &(next), &(bits), state->work); 235 236 /* do this just once */ 237 virgin = 0; 238 } 239 #else /* !BUILDFIXED */ 240 # include "inffixed.h" 241 #endif /* BUILDFIXED */ 242 state->lencode = lenfix; 243 state->lenbits = 9; 244 state->distcode = distfix; 245 state->distbits = 5; 246 } 247 248 #ifdef MAKEFIXED 249 #include <stdio.h> 250 251 /* 252 Write out the inffixed.h that is #include'd above. Defining MAKEFIXED also 253 defines BUILDFIXED, so the tables are built on the fly. makefixed() writes 254 those tables to stdout, which would be piped to inffixed.h. A small program 255 can simply call makefixed to do this: 256 257 void makefixed(void); 258 259 int main(void) 260 { 261 makefixed(); 262 return 0; 263 } 264 265 Then that can be linked with zlib built with MAKEFIXED defined and run: 266 267 a.out > inffixed.h 268 */ 269 void makefixed() 270 { 271 unsigned low, size; 272 struct inflate_state state; 273 274 fixedtables(&state); 275 puts(" /* inffixed.h -- table for decoding fixed codes"); 276 puts(" * Generated automatically by makefixed()."); 277 puts(" */"); 278 puts(""); 279 puts(" /* WARNING: this file should *not* be used by applications."); 280 puts(" It is part of the implementation of this library and is"); 281 puts(" subject to change. Applications should only use zlib.h."); 282 puts(" */"); 283 puts(""); 284 size = 1U << 9; 285 printf(" static const code lenfix[%u] = {", size); 286 low = 0; 287 for (;;) { 288 if ((low % 7) == 0) printf("\n "); 289 printf("{%u,%u,%d}", state.lencode[low].op, state.lencode[low].bits, 290 state.lencode[low].val); 291 if (++low == size) break; 292 putchar(','); 293 } 294 puts("\n };"); 295 size = 1U << 5; 296 printf("\n static const code distfix[%u] = {", size); 297 low = 0; 298 for (;;) { 299 if ((low % 6) == 0) printf("\n "); 300 printf("{%u,%u,%d}", state.distcode[low].op, state.distcode[low].bits, 301 state.distcode[low].val); 302 if (++low == size) break; 303 putchar(','); 304 } 305 puts("\n };"); 306 } 307 #endif /* MAKEFIXED */ 308 309 /* 310 Update the window with the last wsize (normally 32K) bytes written before 311 returning. If window does not exist yet, create it. This is only called 312 when a window is already in use, or when output has been written during this 313 inflate call, but the end of the deflate stream has not been reached yet. 314 It is also called to create a window for dictionary data when a dictionary 315 is loaded. 316 317 Providing output buffers larger than 32K to inflate() should provide a speed 318 advantage, since only the last 32K of output is copied to the sliding window 319 upon return from inflate(), and since all distances after the first 32K of 320 output will fall in the output data, making match copies simpler and faster. 321 The advantage may be dependent on the size of the processor's data caches. 322 */ 323 local int updatewindow(strm, out) 324 z_streamp strm; 325 unsigned out; 326 { 327 struct inflate_state FAR *state; 328 unsigned copy, dist; 329 330 state = (struct inflate_state FAR *)strm->state; 331 332 /* if it hasn't been done already, allocate space for the window */ 333 if (state->window == Z_NULL) { 334 state->window = (unsigned char FAR *) 335 ZALLOC(strm, 1U << state->wbits, 336 sizeof(unsigned char)); 337 if (state->window == Z_NULL) return 1; 338 } 339 340 /* if window not in use yet, initialize */ 341 if (state->wsize == 0) { 342 state->wsize = 1U << state->wbits; 343 state->write = 0; 344 state->whave = 0; 345 } 346 347 /* copy state->wsize or less output bytes into the circular window */ 348 copy = out - strm->avail_out; 349 if (copy >= state->wsize) { 350 zmemcpy(state->window, strm->next_out - state->wsize, state->wsize); 351 state->write = 0; 352 state->whave = state->wsize; 353 } 354 else { 355 dist = state->wsize - state->write; 356 if (dist > copy) dist = copy; 357 zmemcpy(state->window + state->write, strm->next_out - copy, dist); 358 copy -= dist; 359 if (copy) { 360 zmemcpy(state->window, strm->next_out - copy, copy); 361 state->write = copy; 362 state->whave = state->wsize; 363 } 364 else { 365 state->write += dist; 366 if (state->write == state->wsize) state->write = 0; 367 if (state->whave < state->wsize) state->whave += dist; 368 } 369 } 370 return 0; 371 } 372 373 /* Macros for inflate(): */ 374 375 /* check function to use adler32() for zlib or crc32() for gzip */ 376 #ifdef GUNZIP 377 # define UPDATE(check, buf, len) \ 378 (state->flags ? crc32(check, buf, len) : adler32(check, buf, len)) 379 #else 380 # define UPDATE(check, buf, len) adler32(check, buf, len) 381 #endif 382 383 /* check macros for header crc */ 384 #ifdef GUNZIP 385 # define CRC2(check, word) \ 386 do { \ 387 hbuf[0] = (unsigned char)(word); \ 388 hbuf[1] = (unsigned char)((word) >> 8); \ 389 check = crc32(check, hbuf, 2); \ 390 } while (0) 391 392 # define CRC4(check, word) \ 393 do { \ 394 hbuf[0] = (unsigned char)(word); \ 395 hbuf[1] = (unsigned char)((word) >> 8); \ 396 hbuf[2] = (unsigned char)((word) >> 16); \ 397 hbuf[3] = (unsigned char)((word) >> 24); \ 398 check = crc32(check, hbuf, 4); \ 399 } while (0) 400 #endif 401 402 /* Load registers with state in inflate() for speed */ 403 #define LOAD() \ 404 do { \ 405 put = strm->next_out; \ 406 left = strm->avail_out; \ 407 next = strm->next_in; \ 408 have = strm->avail_in; \ 409 hold = state->hold; \ 410 bits = state->bits; \ 411 } while (0) 412 413 /* Restore state from registers in inflate() */ 414 #define RESTORE() \ 415 do { \ 416 strm->next_out = put; \ 417 strm->avail_out = left; \ 418 strm->next_in = next; \ 419 strm->avail_in = have; \ 420 state->hold = hold; \ 421 state->bits = bits; \ 422 } while (0) 423 424 /* Clear the input bit accumulator */ 425 #define INITBITS() \ 426 do { \ 427 hold = 0; \ 428 bits = 0; \ 429 } while (0) 430 431 /* Get a byte of input into the bit accumulator, or return from inflate() 432 if there is no input available. */ 433 #define PULLBYTE() \ 434 do { \ 435 if (have == 0) goto inf_leave; \ 436 have--; \ 437 hold += (unsigned long)(*next++) << bits; \ 438 bits += 8; \ 439 } while (0) 440 441 /* Assure that there are at least n bits in the bit accumulator. If there is 442 not enough available input to do that, then return from inflate(). */ 443 #define NEEDBITS(n) \ 444 do { \ 445 while (bits < (unsigned)(n)) \ 446 PULLBYTE(); \ 447 } while (0) 448 449 /* Return the low n bits of the bit accumulator (n < 16) */ 450 #define BITS(n) \ 451 ((unsigned)hold & ((1U << (n)) - 1)) 452 453 /* Remove n bits from the bit accumulator */ 454 #define DROPBITS(n) \ 455 do { \ 456 hold >>= (n); \ 457 bits -= (unsigned)(n); \ 458 } while (0) 459 460 /* Remove zero to seven bits as needed to go to a byte boundary */ 461 #define BYTEBITS() \ 462 do { \ 463 hold >>= bits & 7; \ 464 bits -= bits & 7; \ 465 } while (0) 466 467 /* Reverse the bytes in a 32-bit value */ 468 #define REVERSE(q) \ 469 ((((q) >> 24) & 0xff) + (((q) >> 8) & 0xff00) + \ 470 (((q) & 0xff00) << 8) + (((q) & 0xff) << 24)) 471 472 /* 473 inflate() uses a state machine to process as much input data and generate as 474 much output data as possible before returning. The state machine is 475 structured roughly as follows: 476 477 for (;;) switch (state) { 478 ... 479 case STATEn: 480 if (not enough input data or output space to make progress) 481 return; 482 ... make progress ... 483 state = STATEm; 484 break; 485 ... 486 } 487 488 so when inflate() is called again, the same case is attempted again, and 489 if the appropriate resources are provided, the machine proceeds to the 490 next state. The NEEDBITS() macro is usually the way the state evaluates 491 whether it can proceed or should return. NEEDBITS() does the return if 492 the requested bits are not available. The typical use of the BITS macros 493 is: 494 495 NEEDBITS(n); 496 ... do something with BITS(n) ... 497 DROPBITS(n); 498 499 where NEEDBITS(n) either returns from inflate() if there isn't enough 500 input left to load n bits into the accumulator, or it continues. BITS(n) 501 gives the low n bits in the accumulator. When done, DROPBITS(n) drops 502 the low n bits off the accumulator. INITBITS() clears the accumulator 503 and sets the number of available bits to zero. BYTEBITS() discards just 504 enough bits to put the accumulator on a byte boundary. After BYTEBITS() 505 and a NEEDBITS(8), then BITS(8) would return the next byte in the stream. 506 507 NEEDBITS(n) uses PULLBYTE() to get an available byte of input, or to return 508 if there is no input available. The decoding of variable length codes uses 509 PULLBYTE() directly in order to pull just enough bytes to decode the next 510 code, and no more. 511 512 Some states loop until they get enough input, making sure that enough 513 state information is maintained to continue the loop where it left off 514 if NEEDBITS() returns in the loop. For example, want, need, and keep 515 would all have to actually be part of the saved state in case NEEDBITS() 516 returns: 517 518 case STATEw: 519 while (want < need) { 520 NEEDBITS(n); 521 keep[want++] = BITS(n); 522 DROPBITS(n); 523 } 524 state = STATEx; 525 case STATEx: 526 527 As shown above, if the next state is also the next case, then the break 528 is omitted. 529 530 A state may also return if there is not enough output space available to 531 complete that state. Those states are copying stored data, writing a 532 literal byte, and copying a matching string. 533 534 When returning, a "goto inf_leave" is used to update the total counters, 535 update the check value, and determine whether any progress has been made 536 during that inflate() call in order to return the proper return code. 537 Progress is defined as a change in either strm->avail_in or strm->avail_out. 538 When there is a window, goto inf_leave will update the window with the last 539 output written. If a goto inf_leave occurs in the middle of decompression 540 and there is no window currently, goto inf_leave will create one and copy 541 output to the window for the next call of inflate(). 542 543 In this implementation, the flush parameter of inflate() only affects the 544 return code (per zlib.h). inflate() always writes as much as possible to 545 strm->next_out, given the space available and the provided input--the effect 546 documented in zlib.h of Z_SYNC_FLUSH. Furthermore, inflate() always defers 547 the allocation of and copying into a sliding window until necessary, which 548 provides the effect documented in zlib.h for Z_FINISH when the entire input 549 stream available. So the only thing the flush parameter actually does is: 550 when flush is set to Z_FINISH, inflate() cannot return Z_OK. Instead it 551 will return Z_BUF_ERROR if it has not reached the end of the stream. 552 */ 553 554 int ZEXPORT inflate(strm, flush) 555 z_streamp strm; 556 int flush; 557 { 558 struct inflate_state FAR *state; 559 unsigned char FAR *next; /* next input */ 560 unsigned char FAR *put; /* next output */ 561 unsigned have, left; /* available input and output */ 562 unsigned long hold; /* bit buffer */ 563 unsigned bits; /* bits in bit buffer */ 564 unsigned in, out; /* save starting available input and output */ 565 unsigned copy; /* number of stored or match bytes to copy */ 566 unsigned char FAR *from; /* where to copy match bytes from */ 567 code this; /* current decoding table entry */ 568 code last; /* parent table entry */ 569 unsigned len; /* length to copy for repeats, bits to drop */ 570 int ret; /* return code */ 571 #ifdef GUNZIP 572 unsigned char hbuf[4]; /* buffer for gzip header crc calculation */ 573 #endif 574 static const unsigned short order[19] = /* permutation of code lengths */ 575 {16, 17, 18, 0, 8, 7, 9, 6, 10, 5, 11, 4, 12, 3, 13, 2, 14, 1, 15}; 576 577 if (strm == Z_NULL || strm->state == Z_NULL || strm->next_out == Z_NULL || 578 (strm->next_in == Z_NULL && strm->avail_in != 0)) 579 return Z_STREAM_ERROR; 580 581 state = (struct inflate_state FAR *)strm->state; 582 if (state->mode == TYPE) state->mode = TYPEDO; /* skip check */ 583 LOAD(); 584 in = have; 585 out = left; 586 ret = Z_OK; 587 for (;;) 588 switch (state->mode) { 589 case HEAD: 590 if (state->wrap == 0) { 591 state->mode = TYPEDO; 592 break; 593 } 594 NEEDBITS(16); 595 #ifdef GUNZIP 596 if ((state->wrap & 2) && hold == 0x8b1f) { /* gzip header */ 597 state->check = crc32(0L, Z_NULL, 0); 598 CRC2(state->check, hold); 599 INITBITS(); 600 state->mode = FLAGS; 601 break; 602 } 603 state->flags = 0; /* expect zlib header */ 604 if (state->head != Z_NULL) 605 state->head->done = -1; 606 if (!(state->wrap & 1) || /* check if zlib header allowed */ 607 #else 608 if ( 609 #endif 610 ((BITS(8) << 8) + (hold >> 8)) % 31) { 611 strm->msg = (char *)"incorrect header check"; 612 state->mode = BAD; 613 break; 614 } 615 if (BITS(4) != Z_DEFLATED) { 616 strm->msg = (char *)"unknown compression method"; 617 state->mode = BAD; 618 break; 619 } 620 DROPBITS(4); 621 len = BITS(4) + 8; 622 if (len > state->wbits) { 623 strm->msg = (char *)"invalid window size"; 624 state->mode = BAD; 625 break; 626 } 627 state->dmax = 1U << len; 628 Tracev((stderr, "inflate: zlib header ok\n")); 629 strm->adler = state->check = adler32(0L, Z_NULL, 0); 630 state->mode = hold & 0x200 ? DICTID : TYPE; 631 INITBITS(); 632 break; 633 #ifdef GUNZIP 634 case FLAGS: 635 NEEDBITS(16); 636 state->flags = (int)(hold); 637 if ((state->flags & 0xff) != Z_DEFLATED) { 638 strm->msg = (char *)"unknown compression method"; 639 state->mode = BAD; 640 break; 641 } 642 if (state->flags & 0xe000) { 643 strm->msg = (char *)"unknown header flags set"; 644 state->mode = BAD; 645 break; 646 } 647 if (state->head != Z_NULL) 648 state->head->text = (int)((hold >> 8) & 1); 649 if (state->flags & 0x0200) CRC2(state->check, hold); 650 INITBITS(); 651 state->mode = TIME; 652 case TIME: 653 NEEDBITS(32); 654 if (state->head != Z_NULL) 655 state->head->time = hold; 656 if (state->flags & 0x0200) CRC4(state->check, hold); 657 INITBITS(); 658 state->mode = OS; 659 case OS: 660 NEEDBITS(16); 661 if (state->head != Z_NULL) { 662 state->head->xflags = (int)(hold & 0xff); 663 state->head->os = (int)(hold >> 8); 664 } 665 if (state->flags & 0x0200) CRC2(state->check, hold); 666 INITBITS(); 667 state->mode = EXLEN; 668 case EXLEN: 669 if (state->flags & 0x0400) { 670 NEEDBITS(16); 671 state->length = (unsigned)(hold); 672 if (state->head != Z_NULL) 673 state->head->extra_len = (unsigned)hold; 674 if (state->flags & 0x0200) CRC2(state->check, hold); 675 INITBITS(); 676 } 677 else if (state->head != Z_NULL) 678 state->head->extra = Z_NULL; 679 state->mode = EXTRA; 680 case EXTRA: 681 if (state->flags & 0x0400) { 682 copy = state->length; 683 if (copy > have) copy = have; 684 if (copy) { 685 if (state->head != Z_NULL && 686 state->head->extra != Z_NULL) { 687 len = state->head->extra_len - state->length; 688 zmemcpy(state->head->extra + len, next, 689 len + copy > state->head->extra_max ? 690 state->head->extra_max - len : copy); 691 } 692 if (state->flags & 0x0200) 693 state->check = crc32(state->check, next, copy); 694 have -= copy; 695 next += copy; 696 state->length -= copy; 697 } 698 if (state->length) goto inf_leave; 699 } 700 state->length = 0; 701 state->mode = NAME; 702 case NAME: 703 if (state->flags & 0x0800) { 704 if (have == 0) goto inf_leave; 705 copy = 0; 706 do { 707 len = (unsigned)(next[copy++]); 708 if (state->head != Z_NULL && 709 state->head->name != Z_NULL && 710 state->length < state->head->name_max) 711 state->head->name[state->length++] = len; 712 } while (len && copy < have); 713 if (state->flags & 0x0200) 714 state->check = crc32(state->check, next, copy); 715 have -= copy; 716 next += copy; 717 if (len) goto inf_leave; 718 } 719 else if (state->head != Z_NULL) 720 state->head->name = Z_NULL; 721 state->length = 0; 722 state->mode = COMMENT; 723 case COMMENT: 724 if (state->flags & 0x1000) { 725 if (have == 0) goto inf_leave; 726 copy = 0; 727 do { 728 len = (unsigned)(next[copy++]); 729 if (state->head != Z_NULL && 730 state->head->comment != Z_NULL && 731 state->length < state->head->comm_max) 732 state->head->comment[state->length++] = len; 733 } while (len && copy < have); 734 if (state->flags & 0x0200) 735 state->check = crc32(state->check, next, copy); 736 have -= copy; 737 next += copy; 738 if (len) goto inf_leave; 739 } 740 else if (state->head != Z_NULL) 741 state->head->comment = Z_NULL; 742 state->mode = HCRC; 743 case HCRC: 744 if (state->flags & 0x0200) { 745 NEEDBITS(16); 746 if (hold != (state->check & 0xffff)) { 747 strm->msg = (char *)"header crc mismatch"; 748 state->mode = BAD; 749 break; 750 } 751 INITBITS(); 752 } 753 if (state->head != Z_NULL) { 754 state->head->hcrc = (int)((state->flags >> 9) & 1); 755 state->head->done = 1; 756 } 757 strm->adler = state->check = crc32(0L, Z_NULL, 0); 758 state->mode = TYPE; 759 break; 760 #endif 761 case DICTID: 762 NEEDBITS(32); 763 strm->adler = state->check = REVERSE(hold); 764 INITBITS(); 765 state->mode = DICT; 766 case DICT: 767 if (state->havedict == 0) { 768 RESTORE(); 769 return Z_NEED_DICT; 770 } 771 strm->adler = state->check = adler32(0L, Z_NULL, 0); 772 state->mode = TYPE; 773 case TYPE: 774 if (flush == Z_BLOCK) goto inf_leave; 775 case TYPEDO: 776 if (state->last) { 777 BYTEBITS(); 778 state->mode = CHECK; 779 break; 780 } 781 NEEDBITS(3); 782 state->last = BITS(1); 783 DROPBITS(1); 784 switch (BITS(2)) { 785 case 0: /* stored block */ 786 Tracev((stderr, "inflate: stored block%s\n", 787 state->last ? " (last)" : "")); 788 state->mode = STORED; 789 break; 790 case 1: /* fixed block */ 791 fixedtables(state); 792 Tracev((stderr, "inflate: fixed codes block%s\n", 793 state->last ? " (last)" : "")); 794 state->mode = LEN; /* decode codes */ 795 break; 796 case 2: /* dynamic block */ 797 Tracev((stderr, "inflate: dynamic codes block%s\n", 798 state->last ? " (last)" : "")); 799 state->mode = TABLE; 800 break; 801 case 3: 802 strm->msg = (char *)"invalid block type"; 803 state->mode = BAD; 804 } 805 DROPBITS(2); 806 break; 807 case STORED: 808 BYTEBITS(); /* go to byte boundary */ 809 NEEDBITS(32); 810 if ((hold & 0xffff) != ((hold >> 16) ^ 0xffff)) { 811 strm->msg = (char *)"invalid stored block lengths"; 812 state->mode = BAD; 813 break; 814 } 815 state->length = (unsigned)hold & 0xffff; 816 Tracev((stderr, "inflate: stored length %u\n", 817 state->length)); 818 INITBITS(); 819 state->mode = COPY; 820 case COPY: 821 copy = state->length; 822 if (copy) { 823 if (copy > have) copy = have; 824 if (copy > left) copy = left; 825 if (copy == 0) goto inf_leave; 826 zmemcpy(put, next, copy); 827 have -= copy; 828 next += copy; 829 left -= copy; 830 put += copy; 831 state->length -= copy; 832 break; 833 } 834 Tracev((stderr, "inflate: stored end\n")); 835 state->mode = TYPE; 836 break; 837 case TABLE: 838 NEEDBITS(14); 839 state->nlen = BITS(5) + 257; 840 DROPBITS(5); 841 state->ndist = BITS(5) + 1; 842 DROPBITS(5); 843 state->ncode = BITS(4) + 4; 844 DROPBITS(4); 845 #ifndef PKZIP_BUG_WORKAROUND 846 if (state->nlen > 286 || state->ndist > 30) { 847 strm->msg = (char *)"too many length or distance symbols"; 848 state->mode = BAD; 849 break; 850 } 851 #endif 852 Tracev((stderr, "inflate: table sizes ok\n")); 853 state->have = 0; 854 state->mode = LENLENS; 855 case LENLENS: 856 while (state->have < state->ncode) { 857 NEEDBITS(3); 858 state->lens[order[state->have++]] = (unsigned short)BITS(3); 859 DROPBITS(3); 860 } 861 while (state->have < 19) 862 state->lens[order[state->have++]] = 0; 863 state->next = state->codes; 864 state->lencode = (code const FAR *)(state->next); 865 state->lenbits = 7; 866 ret = inflate_table(CODES, state->lens, 19, &(state->next), 867 &(state->lenbits), state->work); 868 if (ret) { 869 strm->msg = (char *)"invalid code lengths set"; 870 state->mode = BAD; 871 break; 872 } 873 Tracev((stderr, "inflate: code lengths ok\n")); 874 state->have = 0; 875 state->mode = CODELENS; 876 case CODELENS: 877 while (state->have < state->nlen + state->ndist) { 878 for (;;) { 879 this = state->lencode[BITS(state->lenbits)]; 880 if ((unsigned)(this.bits) <= bits) break; 881 PULLBYTE(); 882 } 883 if (this.val < 16) { 884 NEEDBITS(this.bits); 885 DROPBITS(this.bits); 886 state->lens[state->have++] = this.val; 887 } 888 else { 889 if (this.val == 16) { 890 NEEDBITS(this.bits + 2); 891 DROPBITS(this.bits); 892 if (state->have == 0) { 893 strm->msg = (char *)"invalid bit length repeat"; 894 state->mode = BAD; 895 break; 896 } 897 len = state->lens[state->have - 1]; 898 copy = 3 + BITS(2); 899 DROPBITS(2); 900 } 901 else if (this.val == 17) { 902 NEEDBITS(this.bits + 3); 903 DROPBITS(this.bits); 904 len = 0; 905 copy = 3 + BITS(3); 906 DROPBITS(3); 907 } 908 else { 909 NEEDBITS(this.bits + 7); 910 DROPBITS(this.bits); 911 len = 0; 912 copy = 11 + BITS(7); 913 DROPBITS(7); 914 } 915 if (state->have + copy > state->nlen + state->ndist) { 916 strm->msg = (char *)"invalid bit length repeat"; 917 state->mode = BAD; 918 break; 919 } 920 while (copy--) 921 state->lens[state->have++] = (unsigned short)len; 922 } 923 } 924 925 /* handle error breaks in while */ 926 if (state->mode == BAD) break; 927 928 /* build code tables */ 929 state->next = state->codes; 930 state->lencode = (code const FAR *)(state->next); 931 state->lenbits = 9; 932 ret = inflate_table(LENS, state->lens, state->nlen, &(state->next), 933 &(state->lenbits), state->work); 934 if (ret) { 935 strm->msg = (char *)"invalid literal/lengths set"; 936 state->mode = BAD; 937 break; 938 } 939 state->distcode = (code const FAR *)(state->next); 940 state->distbits = 6; 941 ret = inflate_table(DISTS, state->lens + state->nlen, state->ndist, 942 &(state->next), &(state->distbits), state->work); 943 if (ret) { 944 strm->msg = (char *)"invalid distances set"; 945 state->mode = BAD; 946 break; 947 } 948 Tracev((stderr, "inflate: codes ok\n")); 949 state->mode = LEN; 950 case LEN: 951 if (have >= 6 && left >= 258) { 952 RESTORE(); 953 inflate_fast(strm, out); 954 LOAD(); 955 break; 956 } 957 for (;;) { 958 this = state->lencode[BITS(state->lenbits)]; 959 if ((unsigned)(this.bits) <= bits) break; 960 PULLBYTE(); 961 } 962 if (this.op && (this.op & 0xf0) == 0) { 963 last = this; 964 for (;;) { 965 this = state->lencode[last.val + 966 (BITS(last.bits + last.op) >> last.bits)]; 967 if ((unsigned)(last.bits + this.bits) <= bits) break; 968 PULLBYTE(); 969 } 970 DROPBITS(last.bits); 971 } 972 DROPBITS(this.bits); 973 state->length = (unsigned)this.val; 974 if ((int)(this.op) == 0) { 975 Tracevv((stderr, this.val >= 0x20 && this.val < 0x7f ? 976 "inflate: literal '%c'\n" : 977 "inflate: literal 0x%02x\n", this.val)); 978 state->mode = LIT; 979 break; 980 } 981 if (this.op & 32) { 982 Tracevv((stderr, "inflate: end of block\n")); 983 state->mode = TYPE; 984 break; 985 } 986 if (this.op & 64) { 987 strm->msg = (char *)"invalid literal/length code"; 988 state->mode = BAD; 989 break; 990 } 991 state->extra = (unsigned)(this.op) & 15; 992 state->mode = LENEXT; 993 case LENEXT: 994 if (state->extra) { 995 NEEDBITS(state->extra); 996 state->length += BITS(state->extra); 997 DROPBITS(state->extra); 998 } 999 Tracevv((stderr, "inflate: length %u\n", state->length)); 1000 state->mode = DIST; 1001 case DIST: 1002 for (;;) { 1003 this = state->distcode[BITS(state->distbits)]; 1004 if ((unsigned)(this.bits) <= bits) break; 1005 PULLBYTE(); 1006 } 1007 if ((this.op & 0xf0) == 0) { 1008 last = this; 1009 for (;;) { 1010 this = state->distcode[last.val + 1011 (BITS(last.bits + last.op) >> last.bits)]; 1012 if ((unsigned)(last.bits + this.bits) <= bits) break; 1013 PULLBYTE(); 1014 } 1015 DROPBITS(last.bits); 1016 } 1017 DROPBITS(this.bits); 1018 if (this.op & 64) { 1019 strm->msg = (char *)"invalid distance code"; 1020 state->mode = BAD; 1021 break; 1022 } 1023 state->offset = (unsigned)this.val; 1024 state->extra = (unsigned)(this.op) & 15; 1025 state->mode = DISTEXT; 1026 case DISTEXT: 1027 if (state->extra) { 1028 NEEDBITS(state->extra); 1029 state->offset += BITS(state->extra); 1030 DROPBITS(state->extra); 1031 } 1032 #ifdef INFLATE_STRICT 1033 if (state->offset > state->dmax) { 1034 strm->msg = (char *)"invalid distance too far back"; 1035 state->mode = BAD; 1036 break; 1037 } 1038 #endif 1039 if (state->offset > state->whave + out - left) { 1040 strm->msg = (char *)"invalid distance too far back"; 1041 state->mode = BAD; 1042 break; 1043 } 1044 Tracevv((stderr, "inflate: distance %u\n", state->offset)); 1045 state->mode = MATCH; 1046 case MATCH: 1047 if (left == 0) goto inf_leave; 1048 copy = out - left; 1049 if (state->offset > copy) { /* copy from window */ 1050 copy = state->offset - copy; 1051 if (copy > state->write) { 1052 copy -= state->write; 1053 from = state->window + (state->wsize - copy); 1054 } 1055 else 1056 from = state->window + (state->write - copy); 1057 if (copy > state->length) copy = state->length; 1058 } 1059 else { /* copy from output */ 1060 from = put - state->offset; 1061 copy = state->length; 1062 } 1063 if (copy > left) copy = left; 1064 left -= copy; 1065 state->length -= copy; 1066 do { 1067 *put++ = *from++; 1068 } while (--copy); 1069 if (state->length == 0) state->mode = LEN; 1070 break; 1071 case LIT: 1072 if (left == 0) goto inf_leave; 1073 *put++ = (unsigned char)(state->length); 1074 left--; 1075 state->mode = LEN; 1076 break; 1077 case CHECK: 1078 if (state->wrap) { 1079 NEEDBITS(32); 1080 out -= left; 1081 strm->total_out += out; 1082 state->total += out; 1083 if (out) 1084 strm->adler = state->check = 1085 UPDATE(state->check, put - out, out); 1086 out = left; 1087 if (( 1088 #ifdef GUNZIP 1089 state->flags ? hold : 1090 #endif 1091 REVERSE(hold)) != state->check) { 1092 strm->msg = (char *)"incorrect data check"; 1093 state->mode = BAD; 1094 break; 1095 } 1096 INITBITS(); 1097 Tracev((stderr, "inflate: check matches trailer\n")); 1098 } 1099 #ifdef GUNZIP 1100 state->mode = LENGTH; 1101 case LENGTH: 1102 if (state->wrap && state->flags) { 1103 NEEDBITS(32); 1104 if (hold != (state->total & 0xffffffffUL)) { 1105 strm->msg = (char *)"incorrect length check"; 1106 state->mode = BAD; 1107 break; 1108 } 1109 INITBITS(); 1110 Tracev((stderr, "inflate: length matches trailer\n")); 1111 } 1112 #endif 1113 state->mode = DONE; 1114 case DONE: 1115 ret = Z_STREAM_END; 1116 goto inf_leave; 1117 case BAD: 1118 ret = Z_DATA_ERROR; 1119 goto inf_leave; 1120 case MEM: 1121 return Z_MEM_ERROR; 1122 case SYNC: 1123 default: 1124 return Z_STREAM_ERROR; 1125 } 1126 1127 /* 1128 Return from inflate(), updating the total counts and the check value. 1129 If there was no progress during the inflate() call, return a buffer 1130 error. Call updatewindow() to create and/or update the window state. 1131 Note: a memory error from inflate() is non-recoverable. 1132 */ 1133 inf_leave: 1134 RESTORE(); 1135 if (state->wsize || (state->mode < CHECK && out != strm->avail_out)) 1136 if (updatewindow(strm, out)) { 1137 state->mode = MEM; 1138 return Z_MEM_ERROR; 1139 } 1140 in -= strm->avail_in; 1141 out -= strm->avail_out; 1142 strm->total_in += in; 1143 strm->total_out += out; 1144 state->total += out; 1145 if (state->wrap && out) 1146 strm->adler = state->check = 1147 UPDATE(state->check, strm->next_out - out, out); 1148 strm->data_type = state->bits + (state->last ? 64 : 0) + 1149 (state->mode == TYPE ? 128 : 0); 1150 if (((in == 0 && out == 0) || flush == Z_FINISH) && ret == Z_OK) 1151 ret = Z_BUF_ERROR; 1152 return ret; 1153 } 1154 1155 int ZEXPORT inflateEnd(strm) 1156 z_streamp strm; 1157 { 1158 struct inflate_state FAR *state; 1159 if (strm == Z_NULL || strm->state == Z_NULL || strm->zfree == (free_func)0) 1160 return Z_STREAM_ERROR; 1161 state = (struct inflate_state FAR *)strm->state; 1162 if (state->window != Z_NULL) ZFREE(strm, state->window); 1163 ZFREE(strm, strm->state); 1164 strm->state = Z_NULL; 1165 Tracev((stderr, "inflate: end\n")); 1166 return Z_OK; 1167 } 1168 1169 int ZEXPORT inflateSetDictionary(strm, dictionary, dictLength) 1170 z_streamp strm; 1171 const Bytef *dictionary; 1172 uInt dictLength; 1173 { 1174 struct inflate_state FAR *state; 1175 unsigned long id; 1176 1177 /* check state */ 1178 if (strm == Z_NULL || strm->state == Z_NULL) return Z_STREAM_ERROR; 1179 state = (struct inflate_state FAR *)strm->state; 1180 if (state->wrap != 0 && state->mode != DICT) 1181 return Z_STREAM_ERROR; 1182 1183 /* check for correct dictionary id */ 1184 if (state->mode == DICT) { 1185 id = adler32(0L, Z_NULL, 0); 1186 id = adler32(id, dictionary, dictLength); 1187 if (id != state->check) 1188 return Z_DATA_ERROR; 1189 } 1190 1191 /* copy dictionary to window */ 1192 if (updatewindow(strm, strm->avail_out)) { 1193 state->mode = MEM; 1194 return Z_MEM_ERROR; 1195 } 1196 if (dictLength > state->wsize) { 1197 zmemcpy(state->window, dictionary + dictLength - state->wsize, 1198 state->wsize); 1199 state->whave = state->wsize; 1200 } 1201 else { 1202 zmemcpy(state->window + state->wsize - dictLength, dictionary, 1203 dictLength); 1204 state->whave = dictLength; 1205 } 1206 state->havedict = 1; 1207 Tracev((stderr, "inflate: dictionary set\n")); 1208 return Z_OK; 1209 } 1210 1211 int ZEXPORT inflateGetHeader(strm, head) 1212 z_streamp strm; 1213 gz_headerp head; 1214 { 1215 struct inflate_state FAR *state; 1216 1217 /* check state */ 1218 if (strm == Z_NULL || strm->state == Z_NULL) return Z_STREAM_ERROR; 1219 state = (struct inflate_state FAR *)strm->state; 1220 if ((state->wrap & 2) == 0) return Z_STREAM_ERROR; 1221 1222 /* save header structure */ 1223 state->head = head; 1224 head->done = 0; 1225 return Z_OK; 1226 } 1227 1228 /* 1229 Search buf[0..len-1] for the pattern: 0, 0, 0xff, 0xff. Return when found 1230 or when out of input. When called, *have is the number of pattern bytes 1231 found in order so far, in 0..3. On return *have is updated to the new 1232 state. If on return *have equals four, then the pattern was found and the 1233 return value is how many bytes were read including the last byte of the 1234 pattern. If *have is less than four, then the pattern has not been found 1235 yet and the return value is len. In the latter case, syncsearch() can be 1236 called again with more data and the *have state. *have is initialized to 1237 zero for the first call. 1238 */ 1239 local unsigned syncsearch(have, buf, len) 1240 unsigned FAR *have; 1241 unsigned char FAR *buf; 1242 unsigned len; 1243 { 1244 unsigned got; 1245 unsigned next; 1246 1247 got = *have; 1248 next = 0; 1249 while (next < len && got < 4) { 1250 if ((int)(buf[next]) == (got < 2 ? 0 : 0xff)) 1251 got++; 1252 else if (buf[next]) 1253 got = 0; 1254 else 1255 got = 4 - got; 1256 next++; 1257 } 1258 *have = got; 1259 return next; 1260 } 1261 1262 int ZEXPORT inflateSync(strm) 1263 z_streamp strm; 1264 { 1265 unsigned len; /* number of bytes to look at or looked at */ 1266 unsigned long in, out; /* temporary to save total_in and total_out */ 1267 unsigned char buf[4]; /* to restore bit buffer to byte string */ 1268 struct inflate_state FAR *state; 1269 1270 /* check parameters */ 1271 if (strm == Z_NULL || strm->state == Z_NULL) return Z_STREAM_ERROR; 1272 state = (struct inflate_state FAR *)strm->state; 1273 if (strm->avail_in == 0 && state->bits < 8) return Z_BUF_ERROR; 1274 1275 /* if first time, start search in bit buffer */ 1276 if (state->mode != SYNC) { 1277 state->mode = SYNC; 1278 state->hold <<= state->bits & 7; 1279 state->bits -= state->bits & 7; 1280 len = 0; 1281 while (state->bits >= 8) { 1282 buf[len++] = (unsigned char)(state->hold); 1283 state->hold >>= 8; 1284 state->bits -= 8; 1285 } 1286 state->have = 0; 1287 syncsearch(&(state->have), buf, len); 1288 } 1289 1290 /* search available input */ 1291 len = syncsearch(&(state->have), strm->next_in, strm->avail_in); 1292 strm->avail_in -= len; 1293 strm->next_in += len; 1294 strm->total_in += len; 1295 1296 /* return no joy or set up to restart inflate() on a new block */ 1297 if (state->have != 4) return Z_DATA_ERROR; 1298 in = strm->total_in; out = strm->total_out; 1299 inflateReset(strm); 1300 strm->total_in = in; strm->total_out = out; 1301 state->mode = TYPE; 1302 return Z_OK; 1303 } 1304 1305 /* 1306 Returns true if inflate is currently at the end of a block generated by 1307 Z_SYNC_FLUSH or Z_FULL_FLUSH. This function is used by one PPP 1308 implementation to provide an additional safety check. PPP uses 1309 Z_SYNC_FLUSH but removes the length bytes of the resulting empty stored 1310 block. When decompressing, PPP checks that at the end of input packet, 1311 inflate is waiting for these length bytes. 1312 */ 1313 int ZEXPORT inflateSyncPoint(strm) 1314 z_streamp strm; 1315 { 1316 struct inflate_state FAR *state; 1317 1318 if (strm == Z_NULL || strm->state == Z_NULL) return Z_STREAM_ERROR; 1319 state = (struct inflate_state FAR *)strm->state; 1320 return state->mode == STORED && state->bits == 0; 1321 } 1322 1323 int ZEXPORT inflateCopy(dest, source) 1324 z_streamp dest; 1325 z_streamp source; 1326 { 1327 struct inflate_state FAR *state; 1328 struct inflate_state FAR *copy; 1329 unsigned char FAR *window; 1330 unsigned wsize; 1331 1332 /* check input */ 1333 if (dest == Z_NULL || source == Z_NULL || source->state == Z_NULL || 1334 source->zalloc == (alloc_func)0 || source->zfree == (free_func)0) 1335 return Z_STREAM_ERROR; 1336 state = (struct inflate_state FAR *)source->state; 1337 1338 /* allocate space */ 1339 copy = (struct inflate_state FAR *) 1340 ZALLOC(source, 1, sizeof(struct inflate_state)); 1341 if (copy == Z_NULL) return Z_MEM_ERROR; 1342 window = Z_NULL; 1343 if (state->window != Z_NULL) { 1344 window = (unsigned char FAR *) 1345 ZALLOC(source, 1U << state->wbits, sizeof(unsigned char)); 1346 if (window == Z_NULL) { 1347 ZFREE(source, copy); 1348 return Z_MEM_ERROR; 1349 } 1350 } 1351 1352 /* copy state */ 1353 zmemcpy(dest, source, sizeof(z_stream)); 1354 zmemcpy(copy, state, sizeof(struct inflate_state)); 1355 if (state->lencode >= state->codes && 1356 state->lencode <= state->codes + ENOUGH - 1) { 1357 copy->lencode = copy->codes + (state->lencode - state->codes); 1358 copy->distcode = copy->codes + (state->distcode - state->codes); 1359 } 1360 copy->next = copy->codes + (state->next - state->codes); 1361 if (window != Z_NULL) { 1362 wsize = 1U << state->wbits; 1363 zmemcpy(window, state->window, wsize); 1364 } 1365 copy->window = window; 1366 dest->state = (struct internal_state FAR *)copy; 1367 return Z_OK; 1368 }