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