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