OSDN Git Service

PR libgcj/14856:
[pf3gnuchains/gcc-fork.git] / zlib / gzio.c
1 /* gzio.c -- IO on .gz files
2  * Copyright (C) 1995-2003 Jean-loup Gailly.
3  * For conditions of distribution and use, see copyright notice in zlib.h
4  *
5  * Compile this file with -DNO_GZCOMPRESS to avoid the compression code.
6  */
7
8 /* @(#) $Id: gzio.c,v 1.1.1.2 2002/03/11 21:53:24 tromey Exp $ */
9
10 #include <stdio.h>
11
12 #include "zutil.h"
13
14 #ifdef NO_DEFLATE       /* for compatiblity with old definition */
15 #  define NO_GZCOMPRESS
16 #endif
17
18 #ifndef NO_DUMMY_DECL
19 struct internal_state {int dummy;}; /* for buggy compilers */
20 #endif
21
22 #ifndef Z_BUFSIZE
23 #  ifdef MAXSEG_64K
24 #    define Z_BUFSIZE 4096 /* minimize memory usage for 16-bit DOS */
25 #  else
26 #    define Z_BUFSIZE 16384
27 #  endif
28 #endif
29 #ifndef Z_PRINTF_BUFSIZE
30 #  define Z_PRINTF_BUFSIZE 4096
31 #endif
32
33 #ifdef __MVS__
34 #  pragma map (fdopen , "\174\174FDOPEN")
35    FILE *fdopen(int, const char *);
36 #endif
37
38 #ifndef STDC
39 extern voidp  malloc OF((uInt size));
40 extern void   free   OF((voidpf ptr));
41 #endif
42
43 #define ALLOC(size) malloc(size)
44 #define TRYFREE(p) {if (p) free(p);}
45
46 static int const gz_magic[2] = {0x1f, 0x8b}; /* gzip magic header */
47
48 /* gzip flag byte */
49 #define ASCII_FLAG   0x01 /* bit 0 set: file probably ascii text */
50 #define HEAD_CRC     0x02 /* bit 1 set: header CRC present */
51 #define EXTRA_FIELD  0x04 /* bit 2 set: extra field present */
52 #define ORIG_NAME    0x08 /* bit 3 set: original file name present */
53 #define COMMENT      0x10 /* bit 4 set: file comment present */
54 #define RESERVED     0xE0 /* bits 5..7: reserved */
55
56 typedef struct gz_stream {
57     z_stream stream;
58     int      z_err;   /* error code for last stream operation */
59     int      z_eof;   /* set if end of input file */
60     FILE     *file;   /* .gz file */
61     Byte     *inbuf;  /* input buffer */
62     Byte     *outbuf; /* output buffer */
63     uLong    crc;     /* crc32 of uncompressed data */
64     char     *msg;    /* error message */
65     char     *path;   /* path name for debugging only */
66     int      transparent; /* 1 if input file is not a .gz file */
67     char     mode;    /* 'w' or 'r' */
68     z_off_t  start;   /* start of compressed data in file (header skipped) */
69     z_off_t  in;      /* bytes into deflate or inflate */
70     z_off_t  out;     /* bytes out of deflate or inflate */
71     int      back;    /* one character push-back */
72     int      last;    /* true if push-back is last character */
73 } gz_stream;
74
75
76 local gzFile gz_open      OF((const char *path, const char *mode, int  fd));
77 local int do_flush        OF((gzFile file, int flush));
78 local int    get_byte     OF((gz_stream *s));
79 local void   check_header OF((gz_stream *s));
80 local int    destroy      OF((gz_stream *s));
81 local void   putLong      OF((FILE *file, uLong x));
82 local uLong  getLong      OF((gz_stream *s));
83
84 /* ===========================================================================
85      Opens a gzip (.gz) file for reading or writing. The mode parameter
86    is as in fopen ("rb" or "wb"). The file is given either by file descriptor
87    or path name (if fd == -1).
88      gz_open returns NULL if the file could not be opened or if there was
89    insufficient memory to allocate the (de)compression state; errno
90    can be checked to distinguish the two cases (if errno is zero, the
91    zlib error is Z_MEM_ERROR).
92 */
93 local gzFile gz_open (path, mode, fd)
94     const char *path;
95     const char *mode;
96     int  fd;
97 {
98     int err;
99     int level = Z_DEFAULT_COMPRESSION; /* compression level */
100     int strategy = Z_DEFAULT_STRATEGY; /* compression strategy */
101     char *p = (char*)mode;
102     gz_stream *s;
103     char fmode[80]; /* copy of mode, without the compression level */
104     char *m = fmode;
105
106     if (!path || !mode) return Z_NULL;
107
108     s = (gz_stream *)ALLOC(sizeof(gz_stream));
109     if (!s) return Z_NULL;
110
111     s->stream.zalloc = (alloc_func)0;
112     s->stream.zfree = (free_func)0;
113     s->stream.opaque = (voidpf)0;
114     s->stream.next_in = s->inbuf = Z_NULL;
115     s->stream.next_out = s->outbuf = Z_NULL;
116     s->stream.avail_in = s->stream.avail_out = 0;
117     s->file = NULL;
118     s->z_err = Z_OK;
119     s->z_eof = 0;
120     s->in = 0;
121     s->out = 0;
122     s->back = EOF;
123     s->crc = crc32(0L, Z_NULL, 0);
124     s->msg = NULL;
125     s->transparent = 0;
126
127     s->path = (char*)ALLOC(strlen(path)+1);
128     if (s->path == NULL) {
129         return destroy(s), (gzFile)Z_NULL;
130     }
131     strcpy(s->path, path); /* do this early for debugging */
132
133     s->mode = '\0';
134     do {
135         if (*p == 'r') s->mode = 'r';
136         if (*p == 'w' || *p == 'a') s->mode = 'w';
137         if (*p >= '0' && *p <= '9') {
138             level = *p - '0';
139         } else if (*p == 'f') {
140           strategy = Z_FILTERED;
141         } else if (*p == 'h') {
142           strategy = Z_HUFFMAN_ONLY;
143         } else if (*p == 'R') {
144           strategy = Z_RLE;
145         } else {
146             *m++ = *p; /* copy the mode */
147         }
148     } while (*p++ && m != fmode + sizeof(fmode));
149     if (s->mode == '\0') return destroy(s), (gzFile)Z_NULL;
150
151     if (s->mode == 'w') {
152 #ifdef NO_GZCOMPRESS
153         err = Z_STREAM_ERROR;
154 #else
155         err = deflateInit2(&(s->stream), level,
156                            Z_DEFLATED, -MAX_WBITS, DEF_MEM_LEVEL, strategy);
157         /* windowBits is passed < 0 to suppress zlib header */
158
159         s->stream.next_out = s->outbuf = (Byte*)ALLOC(Z_BUFSIZE);
160 #endif
161         if (err != Z_OK || s->outbuf == Z_NULL) {
162             return destroy(s), (gzFile)Z_NULL;
163         }
164     } else {
165         s->stream.next_in  = s->inbuf = (Byte*)ALLOC(Z_BUFSIZE);
166
167         err = inflateInit2(&(s->stream), -MAX_WBITS);
168         /* windowBits is passed < 0 to tell that there is no zlib header.
169          * Note that in this case inflate *requires* an extra "dummy" byte
170          * after the compressed stream in order to complete decompression and
171          * return Z_STREAM_END. Here the gzip CRC32 ensures that 4 bytes are
172          * present after the compressed stream.
173          */
174         if (err != Z_OK || s->inbuf == Z_NULL) {
175             return destroy(s), (gzFile)Z_NULL;
176         }
177     }
178     s->stream.avail_out = Z_BUFSIZE;
179
180     errno = 0;
181     s->file = fd < 0 ? F_OPEN(path, fmode) : (FILE*)fdopen(fd, fmode);
182
183     if (s->file == NULL) {
184         return destroy(s), (gzFile)Z_NULL;
185     }
186     if (s->mode == 'w') {
187         /* Write a very simple .gz header:
188          */
189         fprintf(s->file, "%c%c%c%c%c%c%c%c%c%c", gz_magic[0], gz_magic[1],
190              Z_DEFLATED, 0 /*flags*/, 0,0,0,0 /*time*/, 0 /*xflags*/, OS_CODE);
191         s->start = 10L;
192         /* We use 10L instead of ftell(s->file) to because ftell causes an
193          * fflush on some systems. This version of the library doesn't use
194          * start anyway in write mode, so this initialization is not
195          * necessary.
196          */
197     } else {
198         check_header(s); /* skip the .gz header */
199         s->start = ftell(s->file) - s->stream.avail_in;
200     }
201
202     return (gzFile)s;
203 }
204
205 /* ===========================================================================
206      Opens a gzip (.gz) file for reading or writing.
207 */
208 gzFile ZEXPORT gzopen (path, mode)
209     const char *path;
210     const char *mode;
211 {
212     return gz_open (path, mode, -1);
213 }
214
215 /* ===========================================================================
216      Associate a gzFile with the file descriptor fd. fd is not dup'ed here
217    to mimic the behavio(u)r of fdopen.
218 */
219 gzFile ZEXPORT gzdopen (fd, mode)
220     int fd;
221     const char *mode;
222 {
223     char name[20];
224
225     if (fd < 0) return (gzFile)Z_NULL;
226     sprintf(name, "<fd:%d>", fd); /* for debugging */
227
228     return gz_open (name, mode, fd);
229 }
230
231 /* ===========================================================================
232  * Update the compression level and strategy
233  */
234 int ZEXPORT gzsetparams (file, level, strategy)
235     gzFile file;
236     int level;
237     int strategy;
238 {
239     gz_stream *s = (gz_stream*)file;
240
241     if (s == NULL || s->mode != 'w') return Z_STREAM_ERROR;
242
243     /* Make room to allow flushing */
244     if (s->stream.avail_out == 0) {
245
246         s->stream.next_out = s->outbuf;
247         if (fwrite(s->outbuf, 1, Z_BUFSIZE, s->file) != Z_BUFSIZE) {
248             s->z_err = Z_ERRNO;
249         }
250         s->stream.avail_out = Z_BUFSIZE;
251     }
252
253     return deflateParams (&(s->stream), level, strategy);
254 }
255
256 /* ===========================================================================
257      Read a byte from a gz_stream; update next_in and avail_in. Return EOF
258    for end of file.
259    IN assertion: the stream s has been sucessfully opened for reading.
260 */
261 local int get_byte(s)
262     gz_stream *s;
263 {
264     if (s->z_eof) return EOF;
265     if (s->stream.avail_in == 0) {
266         errno = 0;
267         s->stream.avail_in = fread(s->inbuf, 1, Z_BUFSIZE, s->file);
268         if (s->stream.avail_in == 0) {
269             s->z_eof = 1;
270             if (ferror(s->file)) s->z_err = Z_ERRNO;
271             return EOF;
272         }
273         s->stream.next_in = s->inbuf;
274     }
275     s->stream.avail_in--;
276     return *(s->stream.next_in)++;
277 }
278
279 /* ===========================================================================
280       Check the gzip header of a gz_stream opened for reading. Set the stream
281     mode to transparent if the gzip magic header is not present; set s->err
282     to Z_DATA_ERROR if the magic header is present but the rest of the header
283     is incorrect.
284     IN assertion: the stream s has already been created sucessfully;
285        s->stream.avail_in is zero for the first time, but may be non-zero
286        for concatenated .gz files.
287 */
288 local void check_header(s)
289     gz_stream *s;
290 {
291     int method; /* method byte */
292     int flags;  /* flags byte */
293     uInt len;
294     int c;
295
296     /* Assure two bytes in the buffer so we can peek ahead -- handle case
297        where first byte of header is at the end of the buffer after the last
298        gzip segment */
299     len = s->stream.avail_in;
300     if (len < 2) {
301         if (len) s->inbuf[0] = s->stream.next_in[0];
302         errno = 0;
303         len = fread(s->inbuf + len, 1, Z_BUFSIZE >> len, s->file);
304         if (len == 0 && ferror(s->file)) s->z_err = Z_ERRNO;
305         s->stream.avail_in += len;
306         s->stream.next_in = s->inbuf;
307         if (s->stream.avail_in < 2) {
308             s->transparent = s->stream.avail_in;
309             return;
310         }
311     }
312
313     /* Peek ahead to check the gzip magic header */
314     if (s->stream.next_in[0] != gz_magic[0] ||
315         s->stream.next_in[1] != gz_magic[1]) {
316         s->transparent = 1;
317         return;
318     }
319     s->stream.avail_in -= 2;
320     s->stream.next_in += 2;
321
322     /* Check the rest of the gzip header */
323     method = get_byte(s);
324     flags = get_byte(s);
325     if (method != Z_DEFLATED || (flags & RESERVED) != 0) {
326         s->z_err = Z_DATA_ERROR;
327         return;
328     }
329
330     /* Discard time, xflags and OS code: */
331     for (len = 0; len < 6; len++) (void)get_byte(s);
332
333     if ((flags & EXTRA_FIELD) != 0) { /* skip the extra field */
334         len  =  (uInt)get_byte(s);
335         len += ((uInt)get_byte(s))<<8;
336         /* len is garbage if EOF but the loop below will quit anyway */
337         while (len-- != 0 && get_byte(s) != EOF) ;
338     }
339     if ((flags & ORIG_NAME) != 0) { /* skip the original file name */
340         while ((c = get_byte(s)) != 0 && c != EOF) ;
341     }
342     if ((flags & COMMENT) != 0) {   /* skip the .gz file comment */
343         while ((c = get_byte(s)) != 0 && c != EOF) ;
344     }
345     if ((flags & HEAD_CRC) != 0) {  /* skip the header crc */
346         for (len = 0; len < 2; len++) (void)get_byte(s);
347     }
348     s->z_err = s->z_eof ? Z_DATA_ERROR : Z_OK;
349 }
350
351  /* ===========================================================================
352  * Cleanup then free the given gz_stream. Return a zlib error code.
353    Try freeing in the reverse order of allocations.
354  */
355 local int destroy (s)
356     gz_stream *s;
357 {
358     int err = Z_OK;
359
360     if (!s) return Z_STREAM_ERROR;
361
362     TRYFREE(s->msg);
363
364     if (s->stream.state != NULL) {
365         if (s->mode == 'w') {
366 #ifdef NO_GZCOMPRESS
367             err = Z_STREAM_ERROR;
368 #else
369             err = deflateEnd(&(s->stream));
370 #endif
371         } else if (s->mode == 'r') {
372             err = inflateEnd(&(s->stream));
373         }
374     }
375     if (s->file != NULL && fclose(s->file)) {
376 #ifdef ESPIPE
377         if (errno != ESPIPE) /* fclose is broken for pipes in HP/UX */
378 #endif
379             err = Z_ERRNO;
380     }
381     if (s->z_err < 0) err = s->z_err;
382
383     TRYFREE(s->inbuf);
384     TRYFREE(s->outbuf);
385     TRYFREE(s->path);
386     TRYFREE(s);
387     return err;
388 }
389
390 /* ===========================================================================
391      Reads the given number of uncompressed bytes from the compressed file.
392    gzread returns the number of bytes actually read (0 for end of file).
393 */
394 int ZEXPORT gzread (file, buf, len)
395     gzFile file;
396     voidp buf;
397     unsigned len;
398 {
399     gz_stream *s = (gz_stream*)file;
400     Bytef *start = (Bytef*)buf; /* starting point for crc computation */
401     Byte  *next_out; /* == stream.next_out but not forced far (for MSDOS) */
402
403     if (s == NULL || s->mode != 'r') return Z_STREAM_ERROR;
404
405     if (s->z_err == Z_DATA_ERROR || s->z_err == Z_ERRNO) return -1;
406     if (s->z_err == Z_STREAM_END) return 0;  /* EOF */
407
408     next_out = (Byte*)buf;
409     s->stream.next_out = (Bytef*)buf;
410     s->stream.avail_out = len;
411
412     if (s->stream.avail_out && s->back != EOF) {
413         *next_out++ = s->back;
414         s->stream.next_out++;
415         s->stream.avail_out--;
416         s->back = EOF;
417         s->out++;
418         if (s->last) {
419             s->z_err = Z_STREAM_END;
420             return 1;
421         }
422     }
423
424     while (s->stream.avail_out != 0) {
425
426         if (s->transparent) {
427             /* Copy first the lookahead bytes: */
428             uInt n = s->stream.avail_in;
429             if (n > s->stream.avail_out) n = s->stream.avail_out;
430             if (n > 0) {
431                 zmemcpy(s->stream.next_out, s->stream.next_in, n);
432                 next_out += n;
433                 s->stream.next_out = next_out;
434                 s->stream.next_in   += n;
435                 s->stream.avail_out -= n;
436                 s->stream.avail_in  -= n;
437             }
438             if (s->stream.avail_out > 0) {
439                 s->stream.avail_out -= fread(next_out, 1, s->stream.avail_out,
440                                              s->file);
441             }
442             len -= s->stream.avail_out;
443             s->in  += len;
444             s->out += len;
445             if (len == 0) s->z_eof = 1;
446             return (int)len;
447         }
448         if (s->stream.avail_in == 0 && !s->z_eof) {
449
450             errno = 0;
451             s->stream.avail_in = fread(s->inbuf, 1, Z_BUFSIZE, s->file);
452             if (s->stream.avail_in == 0) {
453                 s->z_eof = 1;
454                 if (ferror(s->file)) {
455                     s->z_err = Z_ERRNO;
456                     break;
457                 }
458             }
459             s->stream.next_in = s->inbuf;
460         }
461         s->in += s->stream.avail_in;
462         s->out += s->stream.avail_out;
463         s->z_err = inflate(&(s->stream), Z_NO_FLUSH);
464         s->in -= s->stream.avail_in;
465         s->out -= s->stream.avail_out;
466
467         if (s->z_err == Z_STREAM_END) {
468             /* Check CRC and original size */
469             s->crc = crc32(s->crc, start, (uInt)(s->stream.next_out - start));
470             start = s->stream.next_out;
471
472             if (getLong(s) != s->crc) {
473                 s->z_err = Z_DATA_ERROR;
474             } else {
475                 (void)getLong(s);
476                 /* The uncompressed length returned by above getlong() may be
477                  * different from s->out in case of concatenated .gz files.
478                  * Check for such files:
479                  */
480                 check_header(s);
481                 if (s->z_err == Z_OK) {
482                     inflateReset(&(s->stream));
483                     s->crc = crc32(0L, Z_NULL, 0);
484                 }
485             }
486         }
487         if (s->z_err != Z_OK || s->z_eof) break;
488     }
489     s->crc = crc32(s->crc, start, (uInt)(s->stream.next_out - start));
490
491     return (int)(len - s->stream.avail_out);
492 }
493
494
495 /* ===========================================================================
496       Reads one byte from the compressed file. gzgetc returns this byte
497    or -1 in case of end of file or error.
498 */
499 int ZEXPORT gzgetc(file)
500     gzFile file;
501 {
502     unsigned char c;
503
504     return gzread(file, &c, 1) == 1 ? c : -1;
505 }
506
507
508 /* ===========================================================================
509       Push one byte back onto the stream.
510 */
511 int ZEXPORT gzungetc(c, file)
512     int c;
513     gzFile file;
514 {
515     gz_stream *s = (gz_stream*)file;
516
517     if (s == NULL || s->mode != 'r' || c == EOF || s->back != EOF) return EOF;
518     s->back = c;
519     s->out--;
520     s->last = (s->z_err == Z_STREAM_END);
521     if (s->last) s->z_err = Z_OK;
522     s->z_eof = 0;
523     return c;
524 }
525
526
527 /* ===========================================================================
528       Reads bytes from the compressed file until len-1 characters are
529    read, or a newline character is read and transferred to buf, or an
530    end-of-file condition is encountered.  The string is then terminated
531    with a null character.
532       gzgets returns buf, or Z_NULL in case of error.
533
534       The current implementation is not optimized at all.
535 */
536 char * ZEXPORT gzgets(file, buf, len)
537     gzFile file;
538     char *buf;
539     int len;
540 {
541     char *b = buf;
542     if (buf == Z_NULL || len <= 0) return Z_NULL;
543
544     while (--len > 0 && gzread(file, buf, 1) == 1 && *buf++ != '\n') ;
545     *buf = '\0';
546     return b == buf && len > 0 ? Z_NULL : b;
547 }
548
549
550 #ifndef NO_GZCOMPRESS
551 /* ===========================================================================
552      Writes the given number of uncompressed bytes into the compressed file.
553    gzwrite returns the number of bytes actually written (0 in case of error).
554 */
555 int ZEXPORT gzwrite (file, buf, len)
556     gzFile file;
557     voidpc buf;
558     unsigned len;
559 {
560     gz_stream *s = (gz_stream*)file;
561
562     if (s == NULL || s->mode != 'w') return Z_STREAM_ERROR;
563
564     s->stream.next_in = (Bytef*)buf;
565     s->stream.avail_in = len;
566
567     while (s->stream.avail_in != 0) {
568
569         if (s->stream.avail_out == 0) {
570
571             s->stream.next_out = s->outbuf;
572             if (fwrite(s->outbuf, 1, Z_BUFSIZE, s->file) != Z_BUFSIZE) {
573                 s->z_err = Z_ERRNO;
574                 break;
575             }
576             s->stream.avail_out = Z_BUFSIZE;
577         }
578         s->in += s->stream.avail_in;
579         s->out += s->stream.avail_out;
580         s->z_err = deflate(&(s->stream), Z_NO_FLUSH);
581         s->in -= s->stream.avail_in;
582         s->out -= s->stream.avail_out;
583         if (s->z_err != Z_OK) break;
584     }
585     s->crc = crc32(s->crc, (const Bytef *)buf, len);
586
587     return (int)(len - s->stream.avail_in);
588 }
589
590
591 /* ===========================================================================
592      Converts, formats, and writes the args to the compressed file under
593    control of the format string, as in fprintf. gzprintf returns the number of
594    uncompressed bytes actually written (0 in case of error).
595 */
596 #ifdef STDC
597 #include <stdarg.h>
598
599 int ZEXPORTVA gzprintf (gzFile file, const char *format, /* args */ ...)
600 {
601     char buf[Z_PRINTF_BUFSIZE];
602     va_list va;
603     int len;
604
605     buf[sizeof(buf) - 1] = 0;
606     va_start(va, format);
607 #ifdef NO_vsnprintf
608 #  ifdef HAS_vsprintf_void
609     (void)vsprintf(buf, format, va);
610     va_end(va);
611     for (len = 0; len < sizeof(buf); len++)
612         if (buf[len] == 0) break;
613 #  else
614     len = vsprintf(buf, format, va);
615     va_end(va);
616 #  endif
617 #else
618 #  ifdef HAS_vsnprintf_void
619     (void)vsnprintf(buf, sizeof(buf), format, va);
620     va_end(va);
621     len = strlen(buf);
622 #  else
623     len = vsnprintf(buf, sizeof(buf), format, va);
624     va_end(va);
625 #  endif
626 #endif
627     if (len <= 0 || len >= (int)sizeof(buf) || buf[sizeof(buf) - 1] != 0)
628         return 0;
629     return gzwrite(file, buf, (unsigned)len);
630 }
631 #else /* not ANSI C */
632
633 int ZEXPORTVA gzprintf (file, format, a1, a2, a3, a4, a5, a6, a7, a8, a9, a10,
634                        a11, a12, a13, a14, a15, a16, a17, a18, a19, a20)
635     gzFile file;
636     const char *format;
637     int a1, a2, a3, a4, a5, a6, a7, a8, a9, a10,
638         a11, a12, a13, a14, a15, a16, a17, a18, a19, a20;
639 {
640     char buf[Z_PRINTF_BUFSIZE];
641     int len;
642
643     buf[sizeof(buf) - 1] = 0;
644 #ifdef NO_snprintf
645 #  ifdef HAS_sprintf_void
646     sprintf(buf, format, a1, a2, a3, a4, a5, a6, a7, a8,
647             a9, a10, a11, a12, a13, a14, a15, a16, a17, a18, a19, a20);
648     for (len = 0; len < sizeof(buf); len++)
649         if (buf[len] == 0) break;
650 #  else
651     len = sprintf(buf, format, a1, a2, a3, a4, a5, a6, a7, a8,
652                 a9, a10, a11, a12, a13, a14, a15, a16, a17, a18, a19, a20);
653 #  endif
654 #else
655 #  ifdef HAS_snprintf_void
656     snprintf(buf, sizeof(buf), format, a1, a2, a3, a4, a5, a6, a7, a8,
657              a9, a10, a11, a12, a13, a14, a15, a16, a17, a18, a19, a20);
658     len = strlen(buf);
659 #  else
660     len = snprintf(buf, sizeof(buf), format, a1, a2, a3, a4, a5, a6, a7, a8,
661                  a9, a10, a11, a12, a13, a14, a15, a16, a17, a18, a19, a20);
662 #  endif
663 #endif
664     if (len <= 0 || len >= sizeof(buf) || buf[sizeof(buf) - 1] != 0)
665         return 0;
666     return gzwrite(file, buf, len);
667 }
668 #endif
669
670 /* ===========================================================================
671       Writes c, converted to an unsigned char, into the compressed file.
672    gzputc returns the value that was written, or -1 in case of error.
673 */
674 int ZEXPORT gzputc(file, c)
675     gzFile file;
676     int c;
677 {
678     unsigned char cc = (unsigned char) c; /* required for big endian systems */
679
680     return gzwrite(file, &cc, 1) == 1 ? (int)cc : -1;
681 }
682
683
684 /* ===========================================================================
685       Writes the given null-terminated string to the compressed file, excluding
686    the terminating null character.
687       gzputs returns the number of characters written, or -1 in case of error.
688 */
689 int ZEXPORT gzputs(file, s)
690     gzFile file;
691     const char *s;
692 {
693     return gzwrite(file, (char*)s, (unsigned)strlen(s));
694 }
695
696
697 /* ===========================================================================
698      Flushes all pending output into the compressed file. The parameter
699    flush is as in the deflate() function.
700 */
701 local int do_flush (file, flush)
702     gzFile file;
703     int flush;
704 {
705     uInt len;
706     int done = 0;
707     gz_stream *s = (gz_stream*)file;
708
709     if (s == NULL || s->mode != 'w') return Z_STREAM_ERROR;
710
711     s->stream.avail_in = 0; /* should be zero already anyway */
712
713     for (;;) {
714         len = Z_BUFSIZE - s->stream.avail_out;
715
716         if (len != 0) {
717             if ((uInt)fwrite(s->outbuf, 1, len, s->file) != len) {
718                 s->z_err = Z_ERRNO;
719                 return Z_ERRNO;
720             }
721             s->stream.next_out = s->outbuf;
722             s->stream.avail_out = Z_BUFSIZE;
723         }
724         if (done) break;
725         s->out += s->stream.avail_out;
726         s->z_err = deflate(&(s->stream), flush);
727         s->out -= s->stream.avail_out;
728
729         /* Ignore the second of two consecutive flushes: */
730         if (len == 0 && s->z_err == Z_BUF_ERROR) s->z_err = Z_OK;
731
732         /* deflate has finished flushing only when it hasn't used up
733          * all the available space in the output buffer:
734          */
735         done = (s->stream.avail_out != 0 || s->z_err == Z_STREAM_END);
736
737         if (s->z_err != Z_OK && s->z_err != Z_STREAM_END) break;
738     }
739     return  s->z_err == Z_STREAM_END ? Z_OK : s->z_err;
740 }
741
742 int ZEXPORT gzflush (file, flush)
743      gzFile file;
744      int flush;
745 {
746     gz_stream *s = (gz_stream*)file;
747     int err = do_flush (file, flush);
748
749     if (err) return err;
750     fflush(s->file);
751     return  s->z_err == Z_STREAM_END ? Z_OK : s->z_err;
752 }
753 #endif /* NO_GZCOMPRESS */
754
755 /* ===========================================================================
756       Sets the starting position for the next gzread or gzwrite on the given
757    compressed file. The offset represents a number of bytes in the
758       gzseek returns the resulting offset location as measured in bytes from
759    the beginning of the uncompressed stream, or -1 in case of error.
760       SEEK_END is not implemented, returns error.
761       In this version of the library, gzseek can be extremely slow.
762 */
763 z_off_t ZEXPORT gzseek (file, offset, whence)
764     gzFile file;
765     z_off_t offset;
766     int whence;
767 {
768     gz_stream *s = (gz_stream*)file;
769
770     if (s == NULL || whence == SEEK_END ||
771         s->z_err == Z_ERRNO || s->z_err == Z_DATA_ERROR) {
772         return -1L;
773     }
774
775     if (s->mode == 'w') {
776 #ifdef NO_GZCOMPRESS
777         return -1L;
778 #else
779         if (whence == SEEK_SET) {
780             offset -= s->in;
781         }
782         if (offset < 0) return -1L;
783
784         /* At this point, offset is the number of zero bytes to write. */
785         if (s->inbuf == Z_NULL) {
786             s->inbuf = (Byte*)ALLOC(Z_BUFSIZE); /* for seeking */
787             if (s->inbuf == Z_NULL) return -1L;
788             zmemzero(s->inbuf, Z_BUFSIZE);
789         }
790         while (offset > 0)  {
791             uInt size = Z_BUFSIZE;
792             if (offset < Z_BUFSIZE) size = (uInt)offset;
793
794             size = gzwrite(file, s->inbuf, size);
795             if (size == 0) return -1L;
796
797             offset -= size;
798         }
799         return s->in;
800 #endif
801     }
802     /* Rest of function is for reading only */
803
804     /* compute absolute position */
805     if (whence == SEEK_CUR) {
806         offset += s->out;
807     }
808     if (offset < 0) return -1L;
809
810     if (s->transparent) {
811         /* map to fseek */
812         s->back = EOF;
813         s->stream.avail_in = 0;
814         s->stream.next_in = s->inbuf;
815         if (fseek(s->file, offset, SEEK_SET) < 0) return -1L;
816
817         s->in = s->out = offset;
818         return offset;
819     }
820
821     /* For a negative seek, rewind and use positive seek */
822     if (offset >= s->out) {
823         offset -= s->out;
824     } else if (gzrewind(file) < 0) {
825         return -1L;
826     }
827     /* offset is now the number of bytes to skip. */
828
829     if (offset != 0 && s->outbuf == Z_NULL) {
830         s->outbuf = (Byte*)ALLOC(Z_BUFSIZE);
831         if (s->outbuf == Z_NULL) return -1L;
832     }
833     if (offset && s->back != EOF) {
834         s->back = EOF;
835         s->out++;
836         offset--;
837         if (s->last) s->z_err = Z_STREAM_END;
838     }
839     while (offset > 0)  {
840         int size = Z_BUFSIZE;
841         if (offset < Z_BUFSIZE) size = (int)offset;
842
843         size = gzread(file, s->outbuf, (uInt)size);
844         if (size <= 0) return -1L;
845         offset -= size;
846     }
847     return s->out;
848 }
849
850 /* ===========================================================================
851      Rewinds input file.
852 */
853 int ZEXPORT gzrewind (file)
854     gzFile file;
855 {
856     gz_stream *s = (gz_stream*)file;
857
858     if (s == NULL || s->mode != 'r') return -1;
859
860     s->z_err = Z_OK;
861     s->z_eof = 0;
862     s->back = EOF;
863     s->stream.avail_in = 0;
864     s->stream.next_in = s->inbuf;
865     s->crc = crc32(0L, Z_NULL, 0);
866     if (!s->transparent) (void)inflateReset(&s->stream);
867     s->in = 0;
868     s->out = 0;
869     return fseek(s->file, s->start, SEEK_SET);
870 }
871
872 /* ===========================================================================
873      Returns the starting position for the next gzread or gzwrite on the
874    given compressed file. This position represents a number of bytes in the
875    uncompressed data stream.
876 */
877 z_off_t ZEXPORT gztell (file)
878     gzFile file;
879 {
880     return gzseek(file, 0L, SEEK_CUR);
881 }
882
883 /* ===========================================================================
884      Returns 1 when EOF has previously been detected reading the given
885    input stream, otherwise zero.
886 */
887 int ZEXPORT gzeof (file)
888     gzFile file;
889 {
890     gz_stream *s = (gz_stream*)file;
891
892     /* With concatenated compressed files that can have embedded
893      * crc trailers, z_eof is no longer the only/best indicator of EOF
894      * on a gz_stream. Handle end-of-stream error explicitly here.
895      */
896     if (s == NULL || s->mode != 'r') return 0;
897     if (s->z_eof) return 1;
898     return s->z_err == Z_STREAM_END;
899 }
900
901 /* ===========================================================================
902    Outputs a long in LSB order to the given file
903 */
904 local void putLong (file, x)
905     FILE *file;
906     uLong x;
907 {
908     int n;
909     for (n = 0; n < 4; n++) {
910         fputc((int)(x & 0xff), file);
911         x >>= 8;
912     }
913 }
914
915 /* ===========================================================================
916    Reads a long in LSB order from the given gz_stream. Sets z_err in case
917    of error.
918 */
919 local uLong getLong (s)
920     gz_stream *s;
921 {
922     uLong x = (uLong)get_byte(s);
923     int c;
924
925     x += ((uLong)get_byte(s))<<8;
926     x += ((uLong)get_byte(s))<<16;
927     c = get_byte(s);
928     if (c == EOF) s->z_err = Z_DATA_ERROR;
929     x += ((uLong)c)<<24;
930     return x;
931 }
932
933 /* ===========================================================================
934      Flushes all pending output if necessary, closes the compressed file
935    and deallocates all the (de)compression state.
936 */
937 int ZEXPORT gzclose (file)
938     gzFile file;
939 {
940     int err;
941     gz_stream *s = (gz_stream*)file;
942
943     if (s == NULL) return Z_STREAM_ERROR;
944
945     if (s->mode == 'w') {
946 #ifdef NO_GZCOMPRESS
947         return Z_STREAM_ERROR;
948 #else
949         err = do_flush (file, Z_FINISH);
950         if (err != Z_OK) return destroy((gz_stream*)file);
951
952         putLong (s->file, s->crc);
953         putLong (s->file, (uLong)(s->in & 0xffffffff));
954 #endif
955     }
956     return destroy((gz_stream*)file);
957 }
958
959 /* ===========================================================================
960      Returns the error message for the last error which occured on the
961    given compressed file. errnum is set to zlib error number. If an
962    error occured in the file system and not in the compression library,
963    errnum is set to Z_ERRNO and the application may consult errno
964    to get the exact error code.
965 */
966 const char * ZEXPORT gzerror (file, errnum)
967     gzFile file;
968     int *errnum;
969 {
970     char *m;
971     gz_stream *s = (gz_stream*)file;
972
973     if (s == NULL) {
974         *errnum = Z_STREAM_ERROR;
975         return (const char*)ERR_MSG(Z_STREAM_ERROR);
976     }
977     *errnum = s->z_err;
978     if (*errnum == Z_OK) return (const char*)"";
979
980     m = (char*)(*errnum == Z_ERRNO ? zstrerror(errno) : s->stream.msg);
981
982     if (m == NULL || *m == '\0') m = (char*)ERR_MSG(s->z_err);
983
984     TRYFREE(s->msg);
985     s->msg = (char*)ALLOC(strlen(s->path) + strlen(m) + 3);
986     if (s->msg == Z_NULL) return (const char*)ERR_MSG(Z_MEM_ERROR);
987     strcpy(s->msg, s->path);
988     strcat(s->msg, ": ");
989     strcat(s->msg, m);
990     return (const char*)s->msg;
991 }
992
993 /* ===========================================================================
994      Clear the error and end-of-file flags, and do the same for the real file.
995 */
996 void ZEXPORT gzclearerr (file)
997     gzFile file;
998 {
999     gz_stream *s = (gz_stream*)file;
1000
1001     if (s == NULL) return;
1002     if (s->z_err != Z_STREAM_END) s->z_err = Z_OK;
1003     s->z_eof = 0;
1004     clearerr(s->file);
1005 }