gzip.c revision 1.48 1 1.48 mrg /* $NetBSD: gzip.c,v 1.48 2004/06/06 12:28:52 mrg Exp $ */
2 1.1 mrg
3 1.1 mrg /*
4 1.37 mrg * Copyright (c) 1997, 1998, 2003, 2004 Matthew R. Green
5 1.1 mrg * All rights reserved.
6 1.1 mrg *
7 1.1 mrg * Redistribution and use in source and binary forms, with or without
8 1.1 mrg * modification, are permitted provided that the following conditions
9 1.1 mrg * are met:
10 1.1 mrg * 1. Redistributions of source code must retain the above copyright
11 1.1 mrg * notice, this list of conditions and the following disclaimer.
12 1.1 mrg * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 mrg * notice, this list of conditions and the following disclaimer in the
14 1.1 mrg * documentation and/or other materials provided with the distribution.
15 1.1 mrg * 3. The name of the author may not be used to endorse or promote products
16 1.1 mrg * derived from this software without specific prior written permission.
17 1.1 mrg *
18 1.1 mrg * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
19 1.1 mrg * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
20 1.1 mrg * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21 1.1 mrg * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22 1.1 mrg * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
23 1.1 mrg * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
24 1.1 mrg * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
25 1.1 mrg * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
26 1.1 mrg * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27 1.1 mrg * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28 1.1 mrg * SUCH DAMAGE.
29 1.1 mrg */
30 1.1 mrg
31 1.4 mrg #include <sys/cdefs.h>
32 1.4 mrg #ifndef lint
33 1.37 mrg __COPYRIGHT("@(#) Copyright (c) 1997, 1998, 2003, 2004 Matthew R. Green\n\
34 1.4 mrg All rights reserved.\n");
35 1.48 mrg __RCSID("$NetBSD: gzip.c,v 1.48 2004/06/06 12:28:52 mrg Exp $");
36 1.4 mrg #endif /* not lint */
37 1.4 mrg
38 1.1 mrg /*
39 1.1 mrg * gzip.c -- GPL free gzip using zlib.
40 1.1 mrg *
41 1.6 mrg * TODO:
42 1.6 mrg * - handle .taz/.tgz files?
43 1.10 mrg * - use mmap where possible
44 1.16 wiz * - handle some signals better (remove outfile?)
45 1.41 mrg * - make bzip2/compress -v/-t/-l support work as well as possible
46 1.1 mrg */
47 1.1 mrg
48 1.1 mrg #include <sys/param.h>
49 1.1 mrg #include <sys/stat.h>
50 1.1 mrg #include <sys/time.h>
51 1.1 mrg
52 1.1 mrg #include <unistd.h>
53 1.1 mrg #include <stdio.h>
54 1.1 mrg #include <string.h>
55 1.1 mrg #include <stdlib.h>
56 1.1 mrg #include <err.h>
57 1.1 mrg #include <errno.h>
58 1.1 mrg #include <fcntl.h>
59 1.1 mrg #include <zlib.h>
60 1.1 mrg #include <fts.h>
61 1.1 mrg #include <libgen.h>
62 1.1 mrg #include <stdarg.h>
63 1.1 mrg #include <getopt.h>
64 1.1 mrg
65 1.10 mrg /* what type of file are we dealing with */
66 1.10 mrg enum filetype {
67 1.10 mrg FT_GZIP,
68 1.24 tsutsui #ifndef NO_BZIP2_SUPPORT
69 1.10 mrg FT_BZIP2,
70 1.24 tsutsui #endif
71 1.24 tsutsui #ifndef NO_COMPRESS_SUPPORT
72 1.22 mrg FT_Z,
73 1.24 tsutsui #endif
74 1.10 mrg FT_LAST,
75 1.10 mrg FT_UNKNOWN
76 1.10 mrg };
77 1.10 mrg
78 1.24 tsutsui #ifndef NO_BZIP2_SUPPORT
79 1.10 mrg #include <bzlib.h>
80 1.10 mrg
81 1.24 tsutsui #define BZ2_SUFFIX ".bz2"
82 1.24 tsutsui #define BZIP2_MAGIC "\102\132\150"
83 1.24 tsutsui #endif
84 1.24 tsutsui
85 1.24 tsutsui #ifndef NO_COMPRESS_SUPPORT
86 1.22 mrg #define Z_SUFFIX ".Z"
87 1.22 mrg #define Z_MAGIC "\037\235"
88 1.24 tsutsui #endif
89 1.10 mrg
90 1.10 mrg #define GZ_SUFFIX ".gz"
91 1.1 mrg
92 1.37 mrg #define BUFLEN (64 * 1024)
93 1.1 mrg
94 1.9 mrg #define GZIP_MAGIC0 0x1F
95 1.10 mrg #define GZIP_MAGIC1 0x8B
96 1.10 mrg #define GZIP_OMAGIC1 0x9E
97 1.9 mrg
98 1.48 mrg #define GZIP_TIMESTAMP (off_t)4
99 1.47 mrg #define GZIP_ORIGNAME (off_t)10
100 1.47 mrg
101 1.37 mrg #define HEAD_CRC 0x02
102 1.37 mrg #define EXTRA_FIELD 0x04
103 1.37 mrg #define ORIG_NAME 0x08
104 1.37 mrg #define COMMENT 0x10
105 1.1 mrg
106 1.37 mrg #define OS_CODE 3 /* Unix */
107 1.1 mrg
108 1.46 mrg static const char gzip_version[] = "NetBSD gzip 20040524";
109 1.1 mrg
110 1.1 mrg static int cflag; /* stdout mode */
111 1.1 mrg static int dflag; /* decompress mode */
112 1.25 mrg static int lflag; /* list mode */
113 1.41 mrg static int numflag = 6; /* gzip -1..-9 value */
114 1.26 mrg
115 1.25 mrg #ifndef SMALL
116 1.1 mrg static int fflag; /* force mode */
117 1.1 mrg static int nflag; /* don't save name/timestamp */
118 1.1 mrg static int Nflag; /* don't restore name/timestamp */
119 1.1 mrg static int qflag; /* quiet mode */
120 1.1 mrg static int rflag; /* recursive mode */
121 1.26 mrg static int tflag; /* test */
122 1.26 mrg static char *Sflag;
123 1.26 mrg static int vflag; /* verbose mode */
124 1.25 mrg #else
125 1.25 mrg #define qflag 0
126 1.25 mrg #endif
127 1.26 mrg
128 1.46 mrg static int exit_value = 0; /* exit value */
129 1.46 mrg
130 1.45 agc static const char *suffix;
131 1.10 mrg #define suffix_len (strlen(suffix) + 1) /* len + nul */
132 1.1 mrg static char *infile; /* name of file coming in */
133 1.1 mrg
134 1.46 mrg static void maybe_err(const char *fmt, ...);
135 1.46 mrg static void maybe_errx(const char *fmt, ...);
136 1.1 mrg static void maybe_warn(const char *fmt, ...);
137 1.1 mrg static void maybe_warnx(const char *fmt, ...);
138 1.32 mrg static enum filetype file_gettype(u_char *);
139 1.46 mrg static int check_outfile(const char *outfile, struct stat *sb);
140 1.37 mrg static off_t gz_compress(FILE *, int, off_t *, const char *, time_t);
141 1.46 mrg static off_t gz_uncompress(int, int, char *, size_t, off_t *, const char *);
142 1.45 agc static off_t file_compress(char *, char *, size_t);
143 1.45 agc static off_t file_uncompress(char *, char *, size_t);
144 1.1 mrg static void handle_pathname(char *);
145 1.1 mrg static void handle_file(char *, struct stat *);
146 1.1 mrg static void handle_stdin(void);
147 1.1 mrg static void handle_stdout(void);
148 1.6 mrg static void print_ratio(off_t, off_t, FILE *);
149 1.7 mrg static void print_list(int fd, off_t, const char *, time_t);
150 1.10 mrg static void usage(void);
151 1.10 mrg static void display_version(void);
152 1.26 mrg
153 1.26 mrg #ifndef SMALL
154 1.26 mrg static void prepend_gzip(char *, int *, char ***);
155 1.26 mrg static void handle_dir(char *, struct stat *);
156 1.31 mrg static void print_verbage(char *, char *, off_t, off_t);
157 1.45 agc static void print_test(const char *, int);
158 1.29 mrg static void copymodes(const char *, struct stat *);
159 1.26 mrg #endif
160 1.26 mrg
161 1.24 tsutsui #ifndef NO_BZIP2_SUPPORT
162 1.37 mrg static off_t unbzip2(int, int, char *, size_t, off_t *);
163 1.24 tsutsui #endif
164 1.26 mrg
165 1.24 tsutsui #ifndef NO_COMPRESS_SUPPORT
166 1.37 mrg static FILE *zopen(const char *, FILE *);
167 1.37 mrg static off_t zuncompress(FILE *, FILE *, char *, size_t, off_t *);
168 1.24 tsutsui #endif
169 1.1 mrg
170 1.1 mrg int main(int, char *p[]);
171 1.1 mrg
172 1.11 mrg #ifdef SMALL
173 1.11 mrg #define getopt_long(a,b,c,d,e) getopt(a,b,c)
174 1.11 mrg #else
175 1.3 jdolecek static const struct option longopts[] = {
176 1.1 mrg { "stdout", no_argument, 0, 'c' },
177 1.1 mrg { "to-stdout", no_argument, 0, 'c' },
178 1.1 mrg { "decompress", no_argument, 0, 'd' },
179 1.1 mrg { "uncompress", no_argument, 0, 'd' },
180 1.1 mrg { "force", no_argument, 0, 'f' },
181 1.1 mrg { "help", no_argument, 0, 'h' },
182 1.5 mrg { "list", no_argument, 0, 'l' },
183 1.1 mrg { "no-name", no_argument, 0, 'n' },
184 1.1 mrg { "name", no_argument, 0, 'N' },
185 1.1 mrg { "quiet", no_argument, 0, 'q' },
186 1.1 mrg { "recursive", no_argument, 0, 'r' },
187 1.1 mrg { "suffix", required_argument, 0, 'S' },
188 1.1 mrg { "test", no_argument, 0, 't' },
189 1.1 mrg { "verbose", no_argument, 0, 'v' },
190 1.1 mrg { "version", no_argument, 0, 'V' },
191 1.1 mrg { "fast", no_argument, 0, '1' },
192 1.1 mrg { "best", no_argument, 0, '9' },
193 1.1 mrg #if 0
194 1.1 mrg /*
195 1.10 mrg * This is what else GNU gzip implements. --ascii isn't useful
196 1.10 mrg * on NetBSD, and I don't care to have a --license.
197 1.1 mrg */
198 1.1 mrg { "ascii", no_argument, 0, 'a' },
199 1.1 mrg { "license", no_argument, 0, 'L' },
200 1.1 mrg #endif
201 1.12 mrg { NULL, no_argument, 0, 0 },
202 1.1 mrg };
203 1.11 mrg #endif
204 1.1 mrg
205 1.1 mrg int
206 1.1 mrg main(int argc, char **argv)
207 1.1 mrg {
208 1.28 mrg const char *progname = getprogname();
209 1.25 mrg #ifndef SMALL
210 1.15 mrg char *gzip;
211 1.25 mrg #endif
212 1.1 mrg int ch;
213 1.1 mrg
214 1.15 mrg /* XXX set up signals */
215 1.15 mrg
216 1.10 mrg suffix = GZ_SUFFIX;;
217 1.10 mrg
218 1.25 mrg #ifndef SMALL
219 1.15 mrg if ((gzip = getenv("GZIP")) != NULL)
220 1.15 mrg prepend_gzip(gzip, &argc, &argv);
221 1.28 mrg #endif
222 1.15 mrg
223 1.1 mrg /*
224 1.1 mrg * XXX
225 1.1 mrg * handle being called `gunzip', `zcat' and `gzcat'
226 1.1 mrg */
227 1.1 mrg if (strcmp(progname, "gunzip") == 0)
228 1.1 mrg dflag = 1;
229 1.1 mrg else if (strcmp(progname, "zcat") == 0 ||
230 1.1 mrg strcmp(progname, "gzcat") == 0)
231 1.1 mrg dflag = cflag = 1;
232 1.25 mrg
233 1.25 mrg #ifdef SMALL
234 1.31 mrg #define OPT_LIST "cdhHltV123456789"
235 1.25 mrg #else
236 1.28 mrg #define OPT_LIST "cdfhHlnNqrS:tvV123456789"
237 1.25 mrg #endif
238 1.1 mrg
239 1.28 mrg while ((ch = getopt_long(argc, argv, OPT_LIST, longopts, NULL)) != -1)
240 1.1 mrg switch (ch) {
241 1.1 mrg case 'c':
242 1.1 mrg cflag = 1;
243 1.1 mrg break;
244 1.1 mrg case 'd':
245 1.1 mrg dflag = 1;
246 1.1 mrg break;
247 1.5 mrg case 'l':
248 1.5 mrg lflag = 1;
249 1.5 mrg dflag = 1;
250 1.5 mrg break;
251 1.26 mrg case 'V':
252 1.26 mrg display_version();
253 1.26 mrg /* NOTREACHED */
254 1.26 mrg case '1': case '2': case '3':
255 1.26 mrg case '4': case '5': case '6':
256 1.26 mrg case '7': case '8': case '9':
257 1.38 mrg numflag = ch - '0';
258 1.26 mrg break;
259 1.25 mrg #ifndef SMALL
260 1.25 mrg case 'f':
261 1.25 mrg fflag = 1;
262 1.25 mrg break;
263 1.1 mrg case 'n':
264 1.1 mrg nflag = 1;
265 1.1 mrg Nflag = 0;
266 1.1 mrg break;
267 1.1 mrg case 'N':
268 1.1 mrg nflag = 0;
269 1.1 mrg Nflag = 1;
270 1.1 mrg break;
271 1.1 mrg case 'q':
272 1.1 mrg qflag = 1;
273 1.1 mrg break;
274 1.1 mrg case 'r':
275 1.1 mrg rflag = 1;
276 1.1 mrg break;
277 1.1 mrg case 'S':
278 1.1 mrg Sflag = optarg;
279 1.1 mrg break;
280 1.1 mrg case 't':
281 1.1 mrg cflag = 1;
282 1.1 mrg tflag = 1;
283 1.1 mrg dflag = 1;
284 1.1 mrg break;
285 1.1 mrg case 'v':
286 1.1 mrg vflag = 1;
287 1.1 mrg break;
288 1.26 mrg #endif
289 1.12 mrg default:
290 1.12 mrg usage();
291 1.12 mrg /* NOTREACHED */
292 1.1 mrg }
293 1.1 mrg argv += optind;
294 1.1 mrg argc -= optind;
295 1.1 mrg
296 1.1 mrg if (argc == 0) {
297 1.1 mrg if (dflag) /* stdin mode */
298 1.1 mrg handle_stdin();
299 1.1 mrg else /* stdout mode */
300 1.1 mrg handle_stdout();
301 1.1 mrg } else {
302 1.1 mrg do {
303 1.1 mrg handle_pathname(argv[0]);
304 1.5 mrg } while (*++argv);
305 1.1 mrg }
306 1.29 mrg #ifndef SMALL
307 1.6 mrg if (qflag == 0 && lflag && argc > 1)
308 1.7 mrg print_list(-1, 0, "(totals)", 0);
309 1.29 mrg #endif
310 1.46 mrg exit(exit_value);
311 1.1 mrg }
312 1.1 mrg
313 1.1 mrg /* maybe print a warning */
314 1.1 mrg void
315 1.1 mrg maybe_warn(const char *fmt, ...)
316 1.1 mrg {
317 1.1 mrg va_list ap;
318 1.1 mrg
319 1.1 mrg if (qflag == 0) {
320 1.1 mrg va_start(ap, fmt);
321 1.1 mrg vwarn(fmt, ap);
322 1.1 mrg va_end(ap);
323 1.1 mrg }
324 1.46 mrg if (exit_value == 0)
325 1.46 mrg exit_value = 1;
326 1.1 mrg }
327 1.1 mrg
328 1.46 mrg /* ... without an errno. */
329 1.1 mrg void
330 1.1 mrg maybe_warnx(const char *fmt, ...)
331 1.1 mrg {
332 1.1 mrg va_list ap;
333 1.1 mrg
334 1.1 mrg if (qflag == 0) {
335 1.1 mrg va_start(ap, fmt);
336 1.1 mrg vwarnx(fmt, ap);
337 1.1 mrg va_end(ap);
338 1.1 mrg }
339 1.46 mrg if (exit_value == 0)
340 1.46 mrg exit_value = 1;
341 1.1 mrg }
342 1.1 mrg
343 1.46 mrg /* maybe print an error */
344 1.1 mrg void
345 1.46 mrg maybe_err(const char *fmt, ...)
346 1.1 mrg {
347 1.1 mrg va_list ap;
348 1.1 mrg
349 1.1 mrg if (qflag == 0) {
350 1.1 mrg va_start(ap, fmt);
351 1.1 mrg vwarn(fmt, ap);
352 1.1 mrg va_end(ap);
353 1.1 mrg }
354 1.46 mrg exit(2);
355 1.1 mrg }
356 1.1 mrg
357 1.46 mrg /* ... without an errno. */
358 1.9 mrg void
359 1.46 mrg maybe_errx(const char *fmt, ...)
360 1.9 mrg {
361 1.9 mrg va_list ap;
362 1.9 mrg
363 1.9 mrg if (qflag == 0) {
364 1.9 mrg va_start(ap, fmt);
365 1.9 mrg vwarnx(fmt, ap);
366 1.9 mrg va_end(ap);
367 1.9 mrg }
368 1.46 mrg exit(2);
369 1.9 mrg }
370 1.9 mrg
371 1.25 mrg #ifndef SMALL
372 1.15 mrg /* split up $GZIP and prepend it to the argument list */
373 1.15 mrg static void
374 1.15 mrg prepend_gzip(char *gzip, int *argc, char ***argv)
375 1.15 mrg {
376 1.15 mrg char *s, **nargv, **ac;
377 1.15 mrg int nenvarg = 0, i;
378 1.15 mrg
379 1.15 mrg /* scan how many arguments there are */
380 1.15 mrg for (s = gzip; *s; s++) {
381 1.15 mrg if (*s == ' ' || *s == '\t')
382 1.15 mrg continue;
383 1.15 mrg nenvarg++;
384 1.15 mrg for (; *s; s++)
385 1.15 mrg if (*s == ' ' || *s == '\t')
386 1.15 mrg break;
387 1.45 agc if (*s == 0x0)
388 1.18 mrg break;
389 1.15 mrg }
390 1.15 mrg /* punt early */
391 1.15 mrg if (nenvarg == 0)
392 1.15 mrg return;
393 1.15 mrg
394 1.15 mrg *argc += nenvarg;
395 1.15 mrg ac = *argv;
396 1.15 mrg
397 1.17 simonb nargv = (char **)malloc((*argc + 1) * sizeof(char *));
398 1.15 mrg if (nargv == NULL)
399 1.46 mrg maybe_err("malloc");
400 1.15 mrg
401 1.15 mrg /* stash this away */
402 1.15 mrg *argv = nargv;
403 1.15 mrg
404 1.15 mrg /* copy the program name first */
405 1.15 mrg i = 0;
406 1.15 mrg nargv[i++] = *(ac++);
407 1.15 mrg
408 1.15 mrg /* take a copy of $GZIP and add it to the array */
409 1.15 mrg s = strdup(gzip);
410 1.15 mrg if (s == NULL)
411 1.46 mrg maybe_err("strdup");
412 1.15 mrg for (; *s; s++) {
413 1.15 mrg if (*s == ' ' || *s == '\t')
414 1.15 mrg continue;
415 1.15 mrg nargv[i++] = s;
416 1.15 mrg for (; *s; s++)
417 1.15 mrg if (*s == ' ' || *s == '\t') {
418 1.15 mrg *s = 0;
419 1.15 mrg break;
420 1.15 mrg }
421 1.15 mrg }
422 1.15 mrg
423 1.15 mrg /* copy the original arguments and a NULL */
424 1.15 mrg while (*ac)
425 1.15 mrg nargv[i++] = *(ac++);
426 1.15 mrg nargv[i] = NULL;
427 1.15 mrg }
428 1.25 mrg #endif
429 1.15 mrg
430 1.1 mrg /* compress input to output then close both files */
431 1.37 mrg static off_t
432 1.37 mrg gz_compress(FILE *in, int out, off_t *gsizep, const char *origname, time_t mtime)
433 1.1 mrg {
434 1.37 mrg z_stream z;
435 1.37 mrg char inbuf[BUFLEN], outbuf[BUFLEN];
436 1.37 mrg off_t in_tot = 0, out_tot = 0;
437 1.37 mrg ssize_t in_size;
438 1.37 mrg char *str;
439 1.37 mrg int i, error;
440 1.37 mrg uLong crc;
441 1.37 mrg
442 1.37 mrg i = asprintf(&str, "%c%c%c%c%c%c%c%c%c%c%s",
443 1.37 mrg GZIP_MAGIC0, GZIP_MAGIC1,
444 1.37 mrg Z_DEFLATED, origname ? ORIG_NAME : 0,
445 1.37 mrg (int)mtime & 0xff,
446 1.37 mrg (int)(mtime >> 8) & 0xff,
447 1.37 mrg (int)(mtime >> 16) & 0xff,
448 1.37 mrg (int)(mtime >> 24) & 0xff,
449 1.37 mrg 0, OS_CODE, origname ? origname : "");
450 1.37 mrg if (i == -1)
451 1.46 mrg maybe_err("asprintf");
452 1.37 mrg if (origname)
453 1.37 mrg i++;
454 1.46 mrg if (write(out, str, i) != i) {
455 1.46 mrg maybe_warn("write");
456 1.46 mrg in_tot = -1;
457 1.46 mrg goto out;
458 1.46 mrg }
459 1.37 mrg free(str);
460 1.37 mrg
461 1.37 mrg memset(&z, 0, sizeof z);
462 1.37 mrg z.next_out = outbuf;
463 1.37 mrg z.avail_out = sizeof outbuf;
464 1.38 mrg z.zalloc = Z_NULL;
465 1.38 mrg z.zfree = Z_NULL;
466 1.37 mrg z.opaque = 0;
467 1.37 mrg
468 1.37 mrg error = deflateInit2(&z, numflag, Z_DEFLATED,
469 1.37 mrg -MAX_WBITS, 8, Z_DEFAULT_STRATEGY);
470 1.46 mrg if (error != Z_OK) {
471 1.46 mrg maybe_warnx("deflateInit2 failed");
472 1.46 mrg in_tot = -1;
473 1.46 mrg goto out;
474 1.46 mrg }
475 1.37 mrg
476 1.37 mrg crc = crc32(0L, Z_NULL, 0);
477 1.37 mrg for (;;) {
478 1.37 mrg if (z.avail_out == 0) {
479 1.46 mrg if (write(out, outbuf, sizeof outbuf) != sizeof outbuf) {
480 1.46 mrg maybe_warn("write");
481 1.46 mrg in_tot = -1;
482 1.46 mrg goto out;
483 1.46 mrg }
484 1.37 mrg
485 1.37 mrg out_tot += sizeof outbuf;
486 1.37 mrg z.next_out = outbuf;
487 1.37 mrg z.avail_out = sizeof outbuf;
488 1.37 mrg }
489 1.37 mrg
490 1.37 mrg if (z.avail_in == 0) {
491 1.37 mrg in_size = fread(inbuf, 1, sizeof inbuf, in);
492 1.46 mrg if (ferror(in)) {
493 1.46 mrg maybe_warn("fread");
494 1.46 mrg in_tot = -1;
495 1.46 mrg goto out;
496 1.46 mrg }
497 1.37 mrg if (in_size == 0)
498 1.37 mrg break;
499 1.37 mrg
500 1.37 mrg crc = crc32(crc, (const Bytef *)inbuf, (unsigned)in_size);
501 1.37 mrg in_tot += in_size;
502 1.37 mrg z.next_in = inbuf;
503 1.37 mrg z.avail_in = in_size;
504 1.37 mrg }
505 1.37 mrg
506 1.37 mrg error = deflate(&z, Z_NO_FLUSH);
507 1.46 mrg if (error != Z_OK && error != Z_STREAM_END) {
508 1.46 mrg maybe_warnx("deflate failed");
509 1.46 mrg in_tot = -1;
510 1.46 mrg goto out;
511 1.46 mrg }
512 1.37 mrg }
513 1.1 mrg
514 1.37 mrg /* clean up */
515 1.1 mrg for (;;) {
516 1.37 mrg size_t len;
517 1.37 mrg
518 1.37 mrg error = deflate(&z, Z_FINISH);
519 1.46 mrg if (error != Z_OK && error != Z_STREAM_END) {
520 1.46 mrg maybe_warnx("deflate failed");
521 1.46 mrg in_tot = -1;
522 1.46 mrg goto out;
523 1.46 mrg }
524 1.37 mrg
525 1.37 mrg len = sizeof outbuf - z.avail_out;
526 1.37 mrg
527 1.46 mrg if (write(out, outbuf, len) != len) {
528 1.46 mrg maybe_warn("write");
529 1.46 mrg out_tot = -1;
530 1.46 mrg goto out;
531 1.46 mrg }
532 1.37 mrg out_tot += len;
533 1.37 mrg z.next_out = outbuf;
534 1.37 mrg z.avail_out = sizeof outbuf;
535 1.37 mrg
536 1.37 mrg if (error == Z_STREAM_END)
537 1.1 mrg break;
538 1.37 mrg }
539 1.37 mrg
540 1.46 mrg if (deflateEnd(&z) != Z_OK) {
541 1.46 mrg maybe_warnx("deflateEnd failed");
542 1.46 mrg in_tot = -1;
543 1.46 mrg goto out;
544 1.46 mrg }
545 1.37 mrg
546 1.37 mrg i = asprintf(&str, "%c%c%c%c%c%c%c%c",
547 1.37 mrg (int)crc & 0xff,
548 1.37 mrg (int)(crc >> 8) & 0xff,
549 1.37 mrg (int)(crc >> 16) & 0xff,
550 1.37 mrg (int)(crc >> 24) & 0xff,
551 1.37 mrg (int)in_tot & 0xff,
552 1.37 mrg (int)(in_tot >> 8) & 0xff,
553 1.37 mrg (int)(in_tot >> 16) & 0xff,
554 1.37 mrg (int)(in_tot >> 24) & 0xff);
555 1.37 mrg if (i != 8)
556 1.46 mrg maybe_err("asprintf");
557 1.46 mrg if (write(out, str, i) != i) {
558 1.46 mrg maybe_warn("write");
559 1.46 mrg in_tot = -1;
560 1.46 mrg }
561 1.37 mrg free(str);
562 1.1 mrg
563 1.46 mrg out:
564 1.37 mrg if (gsizep)
565 1.37 mrg *gsizep = out_tot;
566 1.37 mrg return in_tot;
567 1.1 mrg }
568 1.1 mrg
569 1.37 mrg /*
570 1.37 mrg * uncompress input to output then close the input. return the
571 1.37 mrg * uncompressed size written, and put the compressed sized read
572 1.37 mrg * into `*gsizep'.
573 1.37 mrg */
574 1.1 mrg static off_t
575 1.46 mrg gz_uncompress(int in, int out, char *pre, size_t prelen, off_t *gsizep,
576 1.46 mrg const char *filename)
577 1.1 mrg {
578 1.37 mrg z_stream z;
579 1.37 mrg char outbuf[BUFLEN], inbuf[BUFLEN];
580 1.37 mrg off_t out_tot, in_tot;
581 1.37 mrg enum {
582 1.37 mrg GZSTATE_MAGIC0,
583 1.37 mrg GZSTATE_MAGIC1,
584 1.37 mrg GZSTATE_METHOD,
585 1.37 mrg GZSTATE_FLAGS,
586 1.37 mrg GZSTATE_SKIPPING,
587 1.37 mrg GZSTATE_EXTRA,
588 1.37 mrg GZSTATE_EXTRA2,
589 1.37 mrg GZSTATE_EXTRA3,
590 1.37 mrg GZSTATE_ORIGNAME,
591 1.37 mrg GZSTATE_COMMENT,
592 1.37 mrg GZSTATE_HEAD_CRC1,
593 1.37 mrg GZSTATE_HEAD_CRC2,
594 1.37 mrg GZSTATE_INIT,
595 1.37 mrg GZSTATE_READ
596 1.37 mrg } state = GZSTATE_MAGIC0;
597 1.37 mrg int flags = 0, skip_count = 0;
598 1.37 mrg int error, done_reading = 0;
599 1.37 mrg
600 1.37 mrg #define ADVANCE() { z.next_in++; z.avail_in--; }
601 1.37 mrg
602 1.37 mrg memset(&z, 0, sizeof z);
603 1.37 mrg z.avail_in = prelen;
604 1.37 mrg z.next_in = pre;
605 1.37 mrg z.avail_out = sizeof outbuf;
606 1.37 mrg z.next_out = outbuf;
607 1.37 mrg z.zalloc = NULL;
608 1.37 mrg z.zfree = NULL;
609 1.37 mrg z.opaque = 0;
610 1.37 mrg
611 1.37 mrg in_tot = prelen;
612 1.37 mrg out_tot = 0;
613 1.1 mrg
614 1.37 mrg for (;;) {
615 1.37 mrg if (z.avail_in == 0 && done_reading == 0) {
616 1.37 mrg size_t in_size = read(in, inbuf, BUFLEN);
617 1.1 mrg
618 1.37 mrg if (in_size == -1) {
619 1.26 mrg #ifndef SMALL
620 1.46 mrg if (tflag && vflag)
621 1.46 mrg print_test(filename, 0);
622 1.37 mrg #endif
623 1.37 mrg maybe_warn("failed to read stdin\n");
624 1.46 mrg out_tot = -1;
625 1.46 mrg goto stop;
626 1.37 mrg } else if (in_size == 0)
627 1.37 mrg done_reading = 1;
628 1.37 mrg
629 1.37 mrg z.avail_in = in_size;
630 1.37 mrg z.next_in = inbuf;
631 1.37 mrg
632 1.37 mrg in_tot += in_size;
633 1.37 mrg }
634 1.37 mrg switch (state) {
635 1.37 mrg case GZSTATE_MAGIC0:
636 1.46 mrg if (*z.next_in != GZIP_MAGIC0) {
637 1.46 mrg maybe_warn("input not gziped\n");
638 1.46 mrg out_tot = -1;
639 1.46 mrg goto stop;
640 1.46 mrg }
641 1.37 mrg ADVANCE();
642 1.37 mrg state++;
643 1.37 mrg break;
644 1.37 mrg
645 1.37 mrg case GZSTATE_MAGIC1:
646 1.37 mrg if (*z.next_in != GZIP_MAGIC1 &&
647 1.46 mrg *z.next_in != GZIP_OMAGIC1) {
648 1.46 mrg maybe_warn("input not gziped\n");
649 1.46 mrg out_tot = -1;
650 1.46 mrg goto stop;
651 1.46 mrg }
652 1.37 mrg ADVANCE();
653 1.37 mrg state++;
654 1.37 mrg break;
655 1.37 mrg
656 1.37 mrg case GZSTATE_METHOD:
657 1.46 mrg if (*z.next_in != Z_DEFLATED) {
658 1.46 mrg maybe_warn("unknown compression method\n");
659 1.46 mrg out_tot = -1;
660 1.46 mrg goto stop;
661 1.46 mrg }
662 1.37 mrg ADVANCE();
663 1.37 mrg state++;
664 1.37 mrg break;
665 1.37 mrg
666 1.37 mrg case GZSTATE_FLAGS:
667 1.37 mrg flags = *z.next_in;
668 1.37 mrg ADVANCE();
669 1.37 mrg skip_count = 6;
670 1.37 mrg state++;
671 1.37 mrg break;
672 1.37 mrg
673 1.37 mrg case GZSTATE_SKIPPING:
674 1.37 mrg if (skip_count > 0) {
675 1.37 mrg skip_count--;
676 1.37 mrg ADVANCE();
677 1.37 mrg } else
678 1.37 mrg state++;
679 1.37 mrg break;
680 1.37 mrg
681 1.37 mrg case GZSTATE_EXTRA:
682 1.37 mrg if ((flags & EXTRA_FIELD) == 0) {
683 1.37 mrg state = GZSTATE_ORIGNAME;
684 1.37 mrg break;
685 1.37 mrg }
686 1.37 mrg skip_count = *z.next_in;
687 1.37 mrg ADVANCE();
688 1.37 mrg state++;
689 1.37 mrg break;
690 1.37 mrg
691 1.37 mrg case GZSTATE_EXTRA2:
692 1.37 mrg skip_count |= ((*z.next_in) << 8);
693 1.37 mrg ADVANCE();
694 1.37 mrg state++;
695 1.37 mrg break;
696 1.37 mrg
697 1.37 mrg case GZSTATE_EXTRA3:
698 1.37 mrg if (skip_count > 0) {
699 1.37 mrg skip_count--;
700 1.37 mrg ADVANCE();
701 1.1 mrg } else
702 1.37 mrg state++;
703 1.37 mrg break;
704 1.37 mrg
705 1.37 mrg case GZSTATE_ORIGNAME:
706 1.37 mrg if ((flags & ORIG_NAME) == 0) {
707 1.37 mrg state++;
708 1.37 mrg break;
709 1.37 mrg }
710 1.37 mrg if (*z.next_in == 0)
711 1.37 mrg state++;
712 1.37 mrg ADVANCE();
713 1.37 mrg break;
714 1.37 mrg
715 1.37 mrg case GZSTATE_COMMENT:
716 1.37 mrg if ((flags & COMMENT) == 0) {
717 1.37 mrg state++;
718 1.37 mrg break;
719 1.37 mrg }
720 1.37 mrg if (*z.next_in == 0)
721 1.37 mrg state++;
722 1.37 mrg ADVANCE();
723 1.37 mrg break;
724 1.37 mrg
725 1.37 mrg case GZSTATE_HEAD_CRC1:
726 1.37 mrg if (flags & HEAD_CRC)
727 1.37 mrg skip_count = 2;
728 1.37 mrg else
729 1.37 mrg skip_count = 0;
730 1.37 mrg state++;
731 1.37 mrg break;
732 1.37 mrg
733 1.37 mrg case GZSTATE_HEAD_CRC2:
734 1.37 mrg if (skip_count > 0) {
735 1.37 mrg skip_count--;
736 1.37 mrg ADVANCE();
737 1.37 mrg } else
738 1.37 mrg state++;
739 1.37 mrg break;
740 1.37 mrg
741 1.37 mrg case GZSTATE_INIT:
742 1.37 mrg if (inflateInit2(&z, -MAX_WBITS) != Z_OK) {
743 1.46 mrg maybe_warn("failed to inflateInit\n");
744 1.46 mrg out_tot = -1;
745 1.37 mrg goto stop;
746 1.37 mrg }
747 1.37 mrg state++;
748 1.37 mrg break;
749 1.37 mrg
750 1.37 mrg case GZSTATE_READ:
751 1.37 mrg error = inflate(&z, Z_FINISH);
752 1.37 mrg if (error == Z_STREAM_END || error == Z_BUF_ERROR) {
753 1.37 mrg size_t wr = BUFLEN - z.avail_out;
754 1.37 mrg
755 1.46 mrg /*
756 1.46 mrg * If there's nothing to output, we must
757 1.46 mrg * have an error...
758 1.46 mrg */
759 1.46 mrg if (wr == 0) {
760 1.46 mrg out_tot = -1;
761 1.46 mrg goto stop;
762 1.46 mrg }
763 1.37 mrg if (
764 1.37 mrg #ifndef SMALL
765 1.37 mrg /* don't write anything with -t */
766 1.37 mrg tflag == 0 &&
767 1.37 mrg #endif
768 1.46 mrg write(out, outbuf, wr) != wr) {
769 1.46 mrg maybe_warn("error writing "
770 1.39 mrg "to output\n");
771 1.46 mrg out_tot = -1;
772 1.46 mrg goto stop;
773 1.46 mrg }
774 1.39 mrg
775 1.39 mrg out_tot += wr;
776 1.37 mrg
777 1.37 mrg if (error == Z_STREAM_END)
778 1.37 mrg goto stop;
779 1.39 mrg
780 1.37 mrg z.next_out = outbuf;
781 1.37 mrg z.avail_out = BUFLEN;
782 1.37 mrg
783 1.37 mrg break;
784 1.37 mrg }
785 1.37 mrg if (error < 0) {
786 1.38 mrg maybe_warnx("decompression error\n");
787 1.37 mrg out_tot = -1;
788 1.37 mrg goto stop;
789 1.37 mrg }
790 1.1 mrg break;
791 1.1 mrg }
792 1.37 mrg continue;
793 1.37 mrg stop:
794 1.37 mrg break;
795 1.37 mrg }
796 1.37 mrg if (state > GZSTATE_INIT)
797 1.37 mrg inflateEnd(&z);
798 1.1 mrg
799 1.26 mrg #ifndef SMALL
800 1.46 mrg if (tflag && vflag)
801 1.46 mrg print_test(filename, out_tot != -1);
802 1.26 mrg #endif
803 1.1 mrg
804 1.37 mrg if (gsizep)
805 1.37 mrg *gsizep = in_tot;
806 1.37 mrg return (out_tot);
807 1.1 mrg }
808 1.1 mrg
809 1.29 mrg #ifndef SMALL
810 1.1 mrg /*
811 1.1 mrg * set the owner, mode, flags & utimes for a file
812 1.1 mrg */
813 1.1 mrg static void
814 1.1 mrg copymodes(const char *file, struct stat *sbp)
815 1.1 mrg {
816 1.1 mrg struct timeval times[2];
817 1.1 mrg
818 1.1 mrg /*
819 1.1 mrg * If we have no info on the input, give this file some
820 1.1 mrg * default values and return..
821 1.1 mrg */
822 1.1 mrg if (sbp == NULL) {
823 1.1 mrg mode_t mask = umask(022);
824 1.1 mrg
825 1.1 mrg (void)chmod(file, DEFFILEMODE & ~mask);
826 1.1 mrg (void)umask(mask);
827 1.1 mrg return;
828 1.1 mrg }
829 1.1 mrg
830 1.1 mrg /* if the chown fails, remove set-id bits as-per compress(1) */
831 1.1 mrg if (chown(file, sbp->st_uid, sbp->st_gid) < 0) {
832 1.1 mrg if (errno != EPERM)
833 1.1 mrg maybe_warn("couldn't chown: %s", file);
834 1.1 mrg sbp->st_mode &= ~(S_ISUID|S_ISGID);
835 1.1 mrg }
836 1.1 mrg
837 1.1 mrg /* we only allow set-id and the 9 normal permission bits */
838 1.1 mrg sbp->st_mode &= S_ISUID|S_ISGID|S_IRWXU|S_IRWXG|S_IRWXO;
839 1.1 mrg if (chmod(file, sbp->st_mode) < 0)
840 1.1 mrg maybe_warn("couldn't chmod: %s", file);
841 1.1 mrg
842 1.1 mrg /* only try flags if they exist already */
843 1.1 mrg if (sbp->st_flags != 0 && chflags(file, sbp->st_flags) < 0)
844 1.1 mrg maybe_warn("couldn't chflags: %s", file);
845 1.1 mrg
846 1.1 mrg TIMESPEC_TO_TIMEVAL(×[0], &sbp->st_atimespec);
847 1.1 mrg TIMESPEC_TO_TIMEVAL(×[1], &sbp->st_mtimespec);
848 1.1 mrg if (utimes(file, times) < 0)
849 1.1 mrg maybe_warn("couldn't utimes: %s", file);
850 1.1 mrg }
851 1.29 mrg #endif
852 1.1 mrg
853 1.32 mrg /* what sort of file is this? */
854 1.32 mrg static enum filetype
855 1.32 mrg file_gettype(u_char *buf)
856 1.32 mrg {
857 1.32 mrg
858 1.32 mrg if (buf[0] == GZIP_MAGIC0 &&
859 1.32 mrg (buf[1] == GZIP_MAGIC1 || buf[1] == GZIP_OMAGIC1))
860 1.32 mrg return FT_GZIP;
861 1.32 mrg else
862 1.32 mrg #ifndef NO_BZIP2_SUPPORT
863 1.32 mrg if (memcmp(buf, BZIP2_MAGIC, 3) == 0 &&
864 1.32 mrg buf[3] >= '0' && buf[3] <= '9')
865 1.32 mrg return FT_BZIP2;
866 1.32 mrg else
867 1.32 mrg #endif
868 1.32 mrg #ifndef NO_COMPRESS_SUPPORT
869 1.32 mrg if (memcmp(buf, Z_MAGIC, 2) == 0)
870 1.32 mrg return FT_Z;
871 1.32 mrg else
872 1.32 mrg #endif
873 1.32 mrg return FT_UNKNOWN;
874 1.32 mrg }
875 1.32 mrg
876 1.46 mrg #ifndef SMALL
877 1.46 mrg /* check the outfile is OK. */
878 1.46 mrg static int
879 1.46 mrg check_outfile(const char *outfile, struct stat *sb)
880 1.46 mrg {
881 1.46 mrg int ok = 1;
882 1.46 mrg
883 1.46 mrg if (fflag == 0 && lflag == 0 && stat(outfile, sb) == 0) {
884 1.46 mrg if (isatty(STDIN_FILENO)) {
885 1.46 mrg char ans[10] = { 'n', '\0' }; /* default */
886 1.46 mrg
887 1.46 mrg fprintf(stderr, "%s already exists -- do you wish to "
888 1.46 mrg "overwrite (y or n)? " , outfile);
889 1.46 mrg (void)fgets(ans, sizeof(ans) - 1, stdin);
890 1.46 mrg if (ans[0] != 'y' && ans[0] != 'Y') {
891 1.46 mrg fprintf(stderr, "\tnot overwritting\n");
892 1.46 mrg ok = 0;
893 1.46 mrg } else
894 1.46 mrg unlink(outfile);
895 1.46 mrg } else {
896 1.46 mrg maybe_warnx("%s already exists -- skipping", outfile);
897 1.46 mrg ok = 0;
898 1.46 mrg }
899 1.46 mrg }
900 1.46 mrg return ok;
901 1.46 mrg }
902 1.46 mrg #endif
903 1.46 mrg
904 1.1 mrg /*
905 1.1 mrg * compress the given file: create a corresponding .gz file and remove the
906 1.1 mrg * original.
907 1.1 mrg */
908 1.31 mrg static off_t
909 1.45 agc file_compress(char *file, char *outfile, size_t outsize)
910 1.1 mrg {
911 1.1 mrg FILE *in;
912 1.37 mrg int out;
913 1.1 mrg struct stat isb, osb;
914 1.31 mrg off_t size;
915 1.25 mrg #ifndef SMALL
916 1.1 mrg u_int32_t mtime = 0;
917 1.37 mrg char *savename;
918 1.25 mrg #endif
919 1.1 mrg
920 1.1 mrg if (cflag == 0) {
921 1.45 agc (void)strncpy(outfile, file, outsize - suffix_len);
922 1.45 agc outfile[outsize - suffix_len] = '\0';
923 1.45 agc (void)strlcat(outfile, suffix, outsize);
924 1.1 mrg
925 1.25 mrg #ifndef SMALL
926 1.46 mrg if (check_outfile(outfile, &osb) == 0)
927 1.46 mrg goto lose;
928 1.46 mrg
929 1.1 mrg if (stat(file, &isb) == 0) {
930 1.33 tron if (isb.st_nlink > 1 && fflag == 0) {
931 1.1 mrg maybe_warnx("%s has %d other link%s -- "
932 1.33 tron "skipping", file, isb.st_nlink - 1,
933 1.1 mrg isb.st_nlink == 1 ? "" : "s");
934 1.1 mrg goto lose;
935 1.1 mrg }
936 1.1 mrg if (nflag == 0)
937 1.1 mrg mtime = (u_int32_t)isb.st_mtime;
938 1.34 mrg }
939 1.25 mrg #endif
940 1.1 mrg }
941 1.1 mrg in = fopen(file, "r");
942 1.46 mrg if (in == NULL) {
943 1.46 mrg maybe_warn("can't fopen %s", file);
944 1.46 mrg goto lose;
945 1.46 mrg }
946 1.1 mrg
947 1.37 mrg #ifndef SMALL
948 1.43 bouyer if (nflag == 0)
949 1.43 bouyer savename = basename(file);
950 1.43 bouyer else
951 1.43 bouyer savename = NULL;
952 1.1 mrg #endif
953 1.43 bouyer if (cflag == 0) {
954 1.37 mrg out = open(outfile, O_WRONLY|O_CREAT|O_EXCL, 0600);
955 1.39 mrg if (out == -1) {
956 1.39 mrg maybe_warn("could not create output: %s", outfile);
957 1.39 mrg goto lose;
958 1.39 mrg }
959 1.1 mrg } else
960 1.37 mrg out = STDOUT_FILENO;
961 1.1 mrg
962 1.37 mrg #ifdef SMALL
963 1.37 mrg gz_compress(in, out, NULL, NULL, 0);
964 1.37 mrg #else
965 1.37 mrg gz_compress(in, out, NULL, savename, mtime);
966 1.37 mrg #endif
967 1.1 mrg
968 1.42 mrg (void)fclose(in);
969 1.42 mrg
970 1.1 mrg /*
971 1.1 mrg * if we compressed to stdout, we don't know the size and
972 1.1 mrg * we don't know the new file name, punt. if we can't stat
973 1.1 mrg * the file, whine, otherwise set the size from the stat
974 1.1 mrg * buffer. we only blow away the file if we can stat the
975 1.1 mrg * output, just in case.
976 1.1 mrg */
977 1.1 mrg if (cflag == 0) {
978 1.39 mrg if (close(out) == -1)
979 1.39 mrg maybe_warn("couldn't close ouput");
980 1.39 mrg
981 1.1 mrg if (stat(outfile, &osb) < 0) {
982 1.1 mrg maybe_warn("couldn't stat: %s", outfile);
983 1.1 mrg maybe_warnx("leaving original %s", file);
984 1.1 mrg size = 0;
985 1.1 mrg } else {
986 1.1 mrg unlink(file);
987 1.1 mrg size = osb.st_size;
988 1.1 mrg }
989 1.29 mrg #ifndef SMALL
990 1.1 mrg copymodes(outfile, &isb);
991 1.29 mrg #endif
992 1.1 mrg } else {
993 1.1 mrg lose:
994 1.46 mrg size = -1;
995 1.1 mrg }
996 1.1 mrg
997 1.1 mrg return (size);
998 1.1 mrg }
999 1.1 mrg
1000 1.1 mrg /* uncompress the given file and remove the original */
1001 1.31 mrg static off_t
1002 1.45 agc file_uncompress(char *file, char *outfile, size_t outsize)
1003 1.1 mrg {
1004 1.1 mrg struct stat isb, osb;
1005 1.45 agc char *s;
1006 1.1 mrg off_t size;
1007 1.1 mrg ssize_t len = strlen(file);
1008 1.37 mrg unsigned char header1[4], name[PATH_MAX + 1];
1009 1.10 mrg enum filetype method;
1010 1.48 mrg int fd, zfd;
1011 1.48 mrg #ifndef SMALL
1012 1.48 mrg time_t timestamp = 0;
1013 1.48 mrg #endif
1014 1.9 mrg
1015 1.9 mrg /* gather the old name info */
1016 1.1 mrg
1017 1.9 mrg fd = open(file, O_RDONLY);
1018 1.46 mrg if (fd < 0) {
1019 1.46 mrg maybe_warn("can't open %s", file);
1020 1.46 mrg goto lose;
1021 1.46 mrg }
1022 1.37 mrg if (read(fd, header1, sizeof header1) != sizeof header1) {
1023 1.10 mrg /* we don't want to fail here. */
1024 1.25 mrg #ifndef SMALL
1025 1.10 mrg if (fflag)
1026 1.42 mrg goto lose_close_it;
1027 1.25 mrg #endif
1028 1.46 mrg maybe_warn("can't read %s", file);
1029 1.46 mrg goto lose;
1030 1.10 mrg }
1031 1.10 mrg
1032 1.32 mrg method = file_gettype(header1);
1033 1.29 mrg
1034 1.32 mrg #ifndef SMALL
1035 1.32 mrg if (Sflag == NULL) {
1036 1.32 mrg # ifndef NO_BZIP2_SUPPORT
1037 1.32 mrg if (method == FT_BZIP2)
1038 1.10 mrg suffix = BZ2_SUFFIX;
1039 1.32 mrg else
1040 1.26 mrg # endif
1041 1.32 mrg # ifndef NO_COMPRESS_SUPPORT
1042 1.32 mrg if (method == FT_Z)
1043 1.22 mrg suffix = Z_SUFFIX;
1044 1.26 mrg # endif
1045 1.32 mrg }
1046 1.9 mrg
1047 1.42 mrg if (fflag == 0 && method == FT_UNKNOWN) {
1048 1.42 mrg maybe_warnx("%s: not in gzip format", file);
1049 1.42 mrg goto lose_close_it;
1050 1.42 mrg }
1051 1.25 mrg #endif
1052 1.9 mrg
1053 1.10 mrg if (cflag == 0 || lflag) {
1054 1.10 mrg s = &file[len - suffix_len + 1];
1055 1.10 mrg if (strncmp(s, suffix, suffix_len) == 0) {
1056 1.10 mrg (void)strncpy(outfile, file, len - suffix_len + 1);
1057 1.10 mrg outfile[len - suffix_len + 1] = '\0';
1058 1.42 mrg } else if (lflag == 0) {
1059 1.42 mrg maybe_warnx("unknown suffix %s", s);
1060 1.42 mrg goto lose_close_it;
1061 1.42 mrg }
1062 1.10 mrg }
1063 1.10 mrg
1064 1.25 mrg #ifdef SMALL
1065 1.25 mrg if (method == FT_GZIP && lflag)
1066 1.25 mrg #else
1067 1.25 mrg if (method == FT_GZIP && (Nflag || lflag))
1068 1.25 mrg #endif
1069 1.25 mrg {
1070 1.48 mrg #ifndef SMALL
1071 1.48 mrg unsigned char header2[4]; /* timestamp */
1072 1.48 mrg
1073 1.48 mrg if (lseek(fd, GZIP_TIMESTAMP, SEEK_SET) == -1) {
1074 1.48 mrg maybe_warn("can't lseek %s", file);
1075 1.48 mrg goto close_header_read;
1076 1.48 mrg }
1077 1.48 mrg if (read(fd, header2, sizeof header2) != sizeof header2) {
1078 1.48 mrg if (fflag)
1079 1.48 mrg goto lose_close_it;
1080 1.48 mrg maybe_warn("can't read %s", file);
1081 1.48 mrg goto lose;
1082 1.48 mrg }
1083 1.48 mrg timestamp = ((time_t)header2[3] << 24)
1084 1.48 mrg + ((time_t)header2[2] << 16)
1085 1.48 mrg + ((time_t)header2[1] << 8)
1086 1.48 mrg + (time_t)header2[0];
1087 1.48 mrg #endif
1088 1.48 mrg
1089 1.9 mrg if (header1[3] & ORIG_NAME) {
1090 1.9 mrg size_t rbytes;
1091 1.9 mrg int i;
1092 1.9 mrg
1093 1.47 mrg if (lseek(fd, GZIP_ORIGNAME, SEEK_SET) == -1) {
1094 1.47 mrg maybe_warn("can't lseek %s", file);
1095 1.47 mrg goto close_header_read;
1096 1.47 mrg }
1097 1.9 mrg rbytes = read(fd, name, PATH_MAX + 1);
1098 1.42 mrg if (rbytes < 0) {
1099 1.42 mrg maybe_warn("can't read %s", file);
1100 1.42 mrg goto lose_close_it;
1101 1.42 mrg }
1102 1.9 mrg for (i = 0; i < rbytes && name[i]; i++)
1103 1.9 mrg ;
1104 1.9 mrg if (i < rbytes) {
1105 1.9 mrg name[i] = 0;
1106 1.9 mrg /* now maybe merge old dirname */
1107 1.45 agc if (strchr(outfile, '/') == NULL)
1108 1.45 agc (void) strlcpy(outfile, name, outsize);
1109 1.9 mrg else {
1110 1.45 agc char newbuf[PATH_MAX + 1];
1111 1.45 agc
1112 1.45 agc (void) snprintf(newbuf, sizeof(newbuf),
1113 1.45 agc "%s/%s", dirname(outfile),
1114 1.45 agc name);
1115 1.45 agc (void) strlcpy(outfile, newbuf,
1116 1.45 agc outsize);
1117 1.1 mrg }
1118 1.1 mrg }
1119 1.1 mrg }
1120 1.9 mrg }
1121 1.47 mrg close_header_read:
1122 1.9 mrg close(fd);
1123 1.1 mrg
1124 1.31 mrg if (cflag == 0 || lflag) {
1125 1.25 mrg #ifndef SMALL
1126 1.46 mrg if (check_outfile(outfile, &osb) == 0)
1127 1.9 mrg goto lose;
1128 1.46 mrg
1129 1.31 mrg #endif
1130 1.9 mrg if (stat(file, &isb) == 0) {
1131 1.31 mrg #ifndef SMALL
1132 1.33 tron if (isb.st_nlink > 1 && lflag == 0 && fflag == 0) {
1133 1.9 mrg maybe_warnx("%s has %d other links -- skipping",
1134 1.9 mrg file, isb.st_nlink - 1);
1135 1.1 mrg goto lose;
1136 1.1 mrg }
1137 1.48 mrg if (nflag == 0 && timestamp)
1138 1.48 mrg isb.st_mtime = timestamp;
1139 1.31 mrg #endif
1140 1.9 mrg } else
1141 1.9 mrg goto lose;
1142 1.1 mrg }
1143 1.5 mrg
1144 1.48 mrg if (cflag == 0 && lflag == 0) {
1145 1.46 mrg zfd = open(outfile, O_WRONLY|O_CREAT|O_EXCL, 0600);
1146 1.46 mrg if (zfd == -1) {
1147 1.46 mrg maybe_warn("can't open %s", outfile);
1148 1.46 mrg goto lose;
1149 1.46 mrg }
1150 1.46 mrg } else
1151 1.46 mrg zfd = STDOUT_FILENO;
1152 1.46 mrg
1153 1.24 tsutsui #ifndef NO_BZIP2_SUPPORT
1154 1.10 mrg if (method == FT_BZIP2) {
1155 1.46 mrg int in;
1156 1.5 mrg
1157 1.30 mrg /* XXX */
1158 1.46 mrg if (lflag) {
1159 1.46 mrg maybe_warnx("no -l with bzip2 files");
1160 1.46 mrg goto lose;
1161 1.46 mrg }
1162 1.26 mrg
1163 1.46 mrg if ((in = open(file, O_RDONLY)) == -1) {
1164 1.46 mrg maybe_warn("open for read: %s", file);
1165 1.42 mrg goto lose;
1166 1.42 mrg }
1167 1.5 mrg
1168 1.46 mrg size = unbzip2(in, zfd, NULL, 0, NULL);
1169 1.46 mrg if (size == -1) {
1170 1.36 mrg if (cflag == 0)
1171 1.36 mrg unlink(outfile);
1172 1.46 mrg maybe_warnx("%s: uncompress failed", file);
1173 1.10 mrg goto lose;
1174 1.10 mrg }
1175 1.42 mrg if (close(in) != 0)
1176 1.42 mrg maybe_warn("couldn't close input");
1177 1.46 mrg if (cflag == 0 && close(zfd) != 0)
1178 1.42 mrg maybe_warn("couldn't close output");
1179 1.24 tsutsui } else
1180 1.24 tsutsui #endif
1181 1.29 mrg
1182 1.24 tsutsui #ifndef NO_COMPRESS_SUPPORT
1183 1.24 tsutsui if (method == FT_Z) {
1184 1.22 mrg FILE *in, *out;
1185 1.22 mrg
1186 1.30 mrg /* XXX */
1187 1.46 mrg if (lflag) {
1188 1.46 mrg maybe_warnx("no -l with Lempel-Ziv files");
1189 1.46 mrg goto lose;
1190 1.46 mrg }
1191 1.26 mrg
1192 1.46 mrg if ((in = zopen(file, NULL)) == NULL) {
1193 1.46 mrg maybe_warn("open for read: %s", file);
1194 1.46 mrg goto lose;
1195 1.46 mrg }
1196 1.22 mrg
1197 1.46 mrg out = fdopen(zfd, "w");
1198 1.46 mrg if (out == NULL) {
1199 1.46 mrg maybe_warn("open for write: %s", outfile);
1200 1.46 mrg goto lose;
1201 1.22 mrg }
1202 1.22 mrg
1203 1.37 mrg size = zuncompress(in, out, NULL, 0, NULL);
1204 1.42 mrg if (ferror(in) || fclose(in) != 0) {
1205 1.42 mrg unlink(outfile);
1206 1.46 mrg (void)fclose(out);
1207 1.46 mrg maybe_warn("failed infile fclose");
1208 1.42 mrg }
1209 1.36 mrg if (cflag == 0) {
1210 1.46 mrg if (size == -1) {
1211 1.46 mrg maybe_warnx("%s: uncompress failed", file);
1212 1.46 mrg (void)fclose(out);
1213 1.36 mrg unlink(outfile);
1214 1.36 mrg goto lose;
1215 1.36 mrg }
1216 1.42 mrg if (fclose(out) != 0) {
1217 1.36 mrg unlink(outfile);
1218 1.46 mrg maybe_warn("failed outfile close");
1219 1.46 mrg goto lose;
1220 1.36 mrg }
1221 1.22 mrg }
1222 1.24 tsutsui } else
1223 1.24 tsutsui #endif
1224 1.24 tsutsui {
1225 1.46 mrg int in;
1226 1.37 mrg
1227 1.10 mrg if (lflag) {
1228 1.46 mrg if ((zfd = open(file, O_RDONLY)) == -1) {
1229 1.46 mrg maybe_warn("open: %s", file);
1230 1.46 mrg goto lose;
1231 1.46 mrg }
1232 1.45 agc print_list(zfd, isb.st_size, outfile, isb.st_mtime);
1233 1.10 mrg return 0; /* XXX */
1234 1.10 mrg }
1235 1.10 mrg
1236 1.37 mrg in = open(file, O_RDONLY);
1237 1.46 mrg if (in == -1) {
1238 1.46 mrg maybe_warn("can't open %s", file);
1239 1.46 mrg goto lose;
1240 1.46 mrg }
1241 1.1 mrg
1242 1.46 mrg size = gz_uncompress(in, zfd, NULL, 0, NULL, file);
1243 1.42 mrg (void)close(in);
1244 1.36 mrg if (cflag == 0) {
1245 1.45 agc if (close(zfd))
1246 1.42 mrg maybe_warn("failed close");
1247 1.37 mrg if (size == -1) {
1248 1.46 mrg maybe_warnx("%s: uncompress failed", file);
1249 1.36 mrg unlink(outfile);
1250 1.36 mrg goto lose;
1251 1.36 mrg }
1252 1.10 mrg }
1253 1.10 mrg }
1254 1.1 mrg
1255 1.1 mrg /* if testing, or we uncompressed to stdout, this is all we need */
1256 1.26 mrg #ifndef SMALL
1257 1.26 mrg if (tflag)
1258 1.26 mrg return (size);
1259 1.26 mrg #endif
1260 1.26 mrg if (cflag)
1261 1.1 mrg return (size);
1262 1.1 mrg
1263 1.1 mrg /*
1264 1.1 mrg * if we create a file...
1265 1.1 mrg */
1266 1.1 mrg if (cflag == 0) {
1267 1.1 mrg /*
1268 1.1 mrg * if we can't stat the file, or we are uncompressing to
1269 1.1 mrg * stdin, don't remove the file.
1270 1.1 mrg */
1271 1.1 mrg if (stat(outfile, &osb) < 0) {
1272 1.1 mrg maybe_warn("couldn't stat (leaving original): %s",
1273 1.1 mrg outfile);
1274 1.1 mrg goto lose;
1275 1.1 mrg }
1276 1.1 mrg if (osb.st_size != size) {
1277 1.1 mrg maybe_warn("stat gave different size: %llu != %llu "
1278 1.1 mrg "(leaving original)",
1279 1.1 mrg (unsigned long long)size,
1280 1.1 mrg (unsigned long long)osb.st_size);
1281 1.1 mrg goto lose;
1282 1.1 mrg }
1283 1.36 mrg if (cflag == 0)
1284 1.36 mrg unlink(file);
1285 1.1 mrg size = osb.st_size;
1286 1.29 mrg #ifndef SMALL
1287 1.1 mrg copymodes(outfile, &isb);
1288 1.29 mrg #endif
1289 1.1 mrg }
1290 1.1 mrg return (size);
1291 1.1 mrg
1292 1.42 mrg lose_close_it:
1293 1.42 mrg close(fd);
1294 1.1 mrg lose:
1295 1.46 mrg return -1;
1296 1.1 mrg }
1297 1.1 mrg
1298 1.37 mrg #ifndef SMALL
1299 1.37 mrg static off_t
1300 1.37 mrg cat_stdin(unsigned char * prepend, size_t count, off_t *gsizep)
1301 1.37 mrg {
1302 1.37 mrg char buf[BUFLEN];
1303 1.37 mrg size_t rv;
1304 1.37 mrg off_t in_tot;
1305 1.37 mrg
1306 1.37 mrg in_tot = count;
1307 1.46 mrg if (write(STDOUT_FILENO, prepend, count) != count) {
1308 1.46 mrg maybe_warn("write to stdout");
1309 1.46 mrg return -1;
1310 1.46 mrg }
1311 1.37 mrg for (;;) {
1312 1.37 mrg rv = read(STDIN_FILENO, buf, sizeof buf);
1313 1.37 mrg
1314 1.46 mrg if (write(STDOUT_FILENO, buf, rv) != rv) {
1315 1.46 mrg maybe_warn("write to stdout");
1316 1.46 mrg return -1;
1317 1.46 mrg }
1318 1.37 mrg in_tot += rv;
1319 1.37 mrg }
1320 1.37 mrg
1321 1.37 mrg if (gsizep)
1322 1.37 mrg *gsizep = in_tot;
1323 1.37 mrg return (in_tot);
1324 1.37 mrg }
1325 1.37 mrg #endif
1326 1.37 mrg
1327 1.1 mrg static void
1328 1.1 mrg handle_stdin(void)
1329 1.1 mrg {
1330 1.37 mrg unsigned char header1[4];
1331 1.37 mrg off_t usize, gsize;
1332 1.37 mrg enum filetype method;
1333 1.37 mrg #ifndef NO_COMPRESS_SUPPORT
1334 1.37 mrg FILE *in;
1335 1.37 mrg #endif
1336 1.1 mrg
1337 1.25 mrg #ifndef SMALL
1338 1.5 mrg if (fflag == 0 && lflag == 0 && isatty(STDIN_FILENO)) {
1339 1.1 mrg maybe_warnx("standard input is a terminal -- ignoring");
1340 1.1 mrg return;
1341 1.1 mrg }
1342 1.25 mrg #endif
1343 1.5 mrg
1344 1.5 mrg if (lflag) {
1345 1.5 mrg struct stat isb;
1346 1.5 mrg
1347 1.37 mrg /* XXX could read the whole file, etc. */
1348 1.46 mrg if (fstat(STDIN_FILENO, &isb) < 0) {
1349 1.46 mrg maybe_warn("fstat");
1350 1.46 mrg return;
1351 1.46 mrg }
1352 1.7 mrg print_list(STDIN_FILENO, isb.st_size, "stdout", isb.st_mtime);
1353 1.5 mrg return;
1354 1.5 mrg }
1355 1.5 mrg
1356 1.46 mrg if (read(STDIN_FILENO, header1, sizeof header1) != sizeof header1) {
1357 1.46 mrg maybe_warn("can't read stdin");
1358 1.46 mrg return;
1359 1.46 mrg }
1360 1.37 mrg
1361 1.37 mrg method = file_gettype(header1);
1362 1.37 mrg switch (method) {
1363 1.37 mrg default:
1364 1.37 mrg #ifndef SMALL
1365 1.46 mrg if (fflag == 0) {
1366 1.46 mrg maybe_warnx("unknown compression format");
1367 1.46 mrg return;
1368 1.46 mrg }
1369 1.37 mrg usize = cat_stdin(header1, sizeof header1, &gsize);
1370 1.37 mrg break;
1371 1.37 mrg #endif
1372 1.37 mrg case FT_GZIP:
1373 1.37 mrg usize = gz_uncompress(STDIN_FILENO, STDOUT_FILENO,
1374 1.46 mrg header1, sizeof header1, &gsize, "(stdin)");
1375 1.37 mrg break;
1376 1.37 mrg #ifndef NO_BZIP2_SUPPORT
1377 1.37 mrg case FT_BZIP2:
1378 1.37 mrg usize = unbzip2(STDIN_FILENO, STDOUT_FILENO,
1379 1.37 mrg header1, sizeof header1, &gsize);
1380 1.37 mrg break;
1381 1.37 mrg #endif
1382 1.37 mrg #ifndef NO_COMPRESS_SUPPORT
1383 1.37 mrg case FT_Z:
1384 1.46 mrg if ((in = zopen(NULL, stdin)) == NULL) {
1385 1.46 mrg maybe_warnx("zopen of stdin");
1386 1.46 mrg return;
1387 1.46 mrg }
1388 1.37 mrg
1389 1.37 mrg usize = zuncompress(in, stdout, header1, sizeof header1, &gsize);
1390 1.37 mrg break;
1391 1.37 mrg #endif
1392 1.37 mrg }
1393 1.37 mrg
1394 1.37 mrg #ifndef SMALL
1395 1.37 mrg if (vflag && !tflag && usize != -1 && gsize != -1)
1396 1.37 mrg print_verbage(NULL, 0, usize, gsize);
1397 1.37 mrg #endif
1398 1.37 mrg
1399 1.1 mrg }
1400 1.1 mrg
1401 1.1 mrg static void
1402 1.1 mrg handle_stdout(void)
1403 1.1 mrg {
1404 1.37 mrg off_t gsize, usize;
1405 1.1 mrg
1406 1.25 mrg #ifndef SMALL
1407 1.1 mrg if (fflag == 0 && isatty(STDOUT_FILENO)) {
1408 1.1 mrg maybe_warnx("standard output is a terminal -- ignoring");
1409 1.1 mrg return;
1410 1.1 mrg }
1411 1.25 mrg #endif
1412 1.37 mrg usize = gz_compress(stdin, STDOUT_FILENO, &gsize, NULL, 0);
1413 1.37 mrg
1414 1.37 mrg #ifndef SMALL
1415 1.37 mrg if (vflag && !tflag && usize != -1 && gsize != -1)
1416 1.37 mrg print_verbage(NULL, 0, usize, gsize);
1417 1.37 mrg #endif
1418 1.1 mrg }
1419 1.1 mrg
1420 1.1 mrg /* do what is asked for, for the path name */
1421 1.1 mrg static void
1422 1.1 mrg handle_pathname(char *path)
1423 1.1 mrg {
1424 1.44 agc char *opath = path, *s = NULL;
1425 1.1 mrg ssize_t len;
1426 1.1 mrg struct stat sb;
1427 1.1 mrg
1428 1.1 mrg /* check for stdout/stdin */
1429 1.1 mrg if (path[0] == '-' && path[1] == '\0') {
1430 1.1 mrg if (dflag)
1431 1.1 mrg handle_stdin();
1432 1.1 mrg else
1433 1.1 mrg handle_stdout();
1434 1.1 mrg }
1435 1.1 mrg
1436 1.1 mrg retry:
1437 1.1 mrg if (stat(path, &sb) < 0) {
1438 1.1 mrg /* lets try <path>.gz if we're decompressing */
1439 1.44 agc if (dflag && s == NULL && errno == ENOENT) {
1440 1.1 mrg len = strlen(path);
1441 1.44 agc s = malloc(len + suffix_len + 1);
1442 1.44 agc if (s == NULL)
1443 1.46 mrg maybe_err("malloc");
1444 1.1 mrg memmove(s, path, len);
1445 1.10 mrg memmove(&s[len], suffix, suffix_len);
1446 1.44 agc s[len + suffix_len] = 0x0;
1447 1.1 mrg path = s;
1448 1.1 mrg goto retry;
1449 1.1 mrg }
1450 1.1 mrg maybe_warn("can't stat: %s", opath);
1451 1.1 mrg goto out;
1452 1.1 mrg }
1453 1.1 mrg
1454 1.1 mrg if (S_ISDIR(sb.st_mode)) {
1455 1.25 mrg #ifndef SMALL
1456 1.1 mrg if (rflag)
1457 1.1 mrg handle_dir(path, &sb);
1458 1.1 mrg else
1459 1.25 mrg #endif
1460 1.1 mrg maybe_warn("%s is a directory", path);
1461 1.1 mrg goto out;
1462 1.1 mrg }
1463 1.1 mrg
1464 1.1 mrg if (S_ISREG(sb.st_mode))
1465 1.1 mrg handle_file(path, &sb);
1466 1.1 mrg
1467 1.1 mrg out:
1468 1.1 mrg if (s)
1469 1.1 mrg free(s);
1470 1.1 mrg }
1471 1.1 mrg
1472 1.1 mrg /* compress/decompress a file */
1473 1.1 mrg static void
1474 1.1 mrg handle_file(char *file, struct stat *sbp)
1475 1.1 mrg {
1476 1.31 mrg off_t usize, gsize;
1477 1.45 agc char outfile[PATH_MAX];
1478 1.1 mrg
1479 1.1 mrg infile = file;
1480 1.1 mrg if (dflag) {
1481 1.45 agc usize = file_uncompress(file, outfile, sizeof(outfile));
1482 1.46 mrg if (usize == -1)
1483 1.1 mrg return;
1484 1.1 mrg gsize = sbp->st_size;
1485 1.1 mrg } else {
1486 1.45 agc gsize = file_compress(file, outfile, sizeof(outfile));
1487 1.46 mrg if (gsize == -1)
1488 1.1 mrg return;
1489 1.1 mrg usize = sbp->st_size;
1490 1.1 mrg }
1491 1.1 mrg
1492 1.26 mrg
1493 1.26 mrg #ifndef SMALL
1494 1.1 mrg if (vflag && !tflag)
1495 1.45 agc print_verbage(file, (cflag) ? NULL : outfile, usize, gsize);
1496 1.26 mrg #endif
1497 1.1 mrg }
1498 1.1 mrg
1499 1.25 mrg #ifndef SMALL
1500 1.1 mrg /* this is used with -r to recursively decend directories */
1501 1.1 mrg static void
1502 1.1 mrg handle_dir(char *dir, struct stat *sbp)
1503 1.1 mrg {
1504 1.1 mrg char *path_argv[2];
1505 1.1 mrg FTS *fts;
1506 1.1 mrg FTSENT *entry;
1507 1.1 mrg
1508 1.1 mrg path_argv[0] = dir;
1509 1.1 mrg path_argv[1] = 0;
1510 1.1 mrg fts = fts_open(path_argv, FTS_PHYSICAL, NULL);
1511 1.1 mrg if (fts == NULL) {
1512 1.1 mrg warn("couldn't fts_open %s", dir);
1513 1.1 mrg return;
1514 1.1 mrg }
1515 1.1 mrg
1516 1.1 mrg while ((entry = fts_read(fts))) {
1517 1.1 mrg switch(entry->fts_info) {
1518 1.1 mrg case FTS_D:
1519 1.1 mrg case FTS_DP:
1520 1.1 mrg continue;
1521 1.1 mrg
1522 1.1 mrg case FTS_DNR:
1523 1.1 mrg case FTS_ERR:
1524 1.1 mrg case FTS_NS:
1525 1.1 mrg maybe_warn("%s", entry->fts_path);
1526 1.1 mrg continue;
1527 1.1 mrg case FTS_F:
1528 1.1 mrg handle_file(entry->fts_name, entry->fts_statp);
1529 1.1 mrg }
1530 1.1 mrg }
1531 1.1 mrg (void)fts_close(fts);
1532 1.1 mrg }
1533 1.25 mrg #endif
1534 1.1 mrg
1535 1.6 mrg /* print a ratio */
1536 1.6 mrg static void
1537 1.6 mrg print_ratio(off_t in, off_t out, FILE *where)
1538 1.6 mrg {
1539 1.35 mrg int64_t percent10; /* 10 * percent */
1540 1.35 mrg off_t diff = in - out;
1541 1.35 mrg char ch;
1542 1.6 mrg
1543 1.35 mrg if (in == 0)
1544 1.35 mrg percent10 = 0;
1545 1.35 mrg else if (diff > 0x400000) /* anything with 22 or more bits */
1546 1.35 mrg percent10 = diff / (in / 1000);
1547 1.35 mrg else
1548 1.35 mrg percent10 = (1000 * diff) / in;
1549 1.35 mrg
1550 1.35 mrg if (percent10 < 0) {
1551 1.35 mrg percent10 = -percent10;
1552 1.35 mrg ch = '-';
1553 1.35 mrg } else
1554 1.35 mrg ch = ' ';
1555 1.35 mrg
1556 1.35 mrg /*
1557 1.35 mrg * ugh. for negative percentages < 10, we need to avoid printing a
1558 1.35 mrg * a space between the "-" and the single number.
1559 1.35 mrg */
1560 1.35 mrg if (ch == '-' && percent10 / 10LL < 10)
1561 1.35 mrg fprintf(where, " -%1d.%1u%%", (unsigned)(percent10 / 10LL),
1562 1.35 mrg (unsigned)(percent10 % 10LL));
1563 1.6 mrg else
1564 1.35 mrg fprintf(where, "%c%2d.%1u%%", ch, (unsigned)(percent10 / 10LL),
1565 1.35 mrg (unsigned)(percent10 % 10LL));
1566 1.6 mrg }
1567 1.6 mrg
1568 1.26 mrg #ifndef SMALL
1569 1.1 mrg /* print compression statistics, and the new name (if there is one!) */
1570 1.1 mrg static void
1571 1.31 mrg print_verbage(char *file, char *nfile, off_t usize, off_t gsize)
1572 1.1 mrg {
1573 1.37 mrg if (file)
1574 1.37 mrg fprintf(stderr, "%s:%s ", file,
1575 1.37 mrg strlen(file) < 7 ? "\t\t" : "\t");
1576 1.31 mrg print_ratio((off_t)usize, (off_t)gsize, stderr);
1577 1.4 mrg if (nfile)
1578 1.4 mrg fprintf(stderr, " -- replaced with %s", nfile);
1579 1.1 mrg fprintf(stderr, "\n");
1580 1.1 mrg fflush(stderr);
1581 1.1 mrg }
1582 1.1 mrg
1583 1.1 mrg /* print test results */
1584 1.1 mrg static void
1585 1.45 agc print_test(const char *file, int ok)
1586 1.1 mrg {
1587 1.1 mrg
1588 1.46 mrg if (exit_value == 0 && ok == 0)
1589 1.46 mrg exit_value = 1;
1590 1.1 mrg fprintf(stderr, "%s:%s %s\n", file,
1591 1.1 mrg strlen(file) < 7 ? "\t\t" : "\t", ok ? "OK" : "NOT OK");
1592 1.1 mrg fflush(stderr);
1593 1.1 mrg }
1594 1.26 mrg #endif
1595 1.1 mrg
1596 1.5 mrg /* print a file's info ala --list */
1597 1.5 mrg /* eg:
1598 1.5 mrg compressed uncompressed ratio uncompressed_name
1599 1.5 mrg 354841 1679360 78.8% /usr/pkgsrc/distfiles/libglade-2.0.1.tar
1600 1.5 mrg */
1601 1.5 mrg static void
1602 1.35 mrg print_list(int fd, off_t out, const char *outfile, time_t ts)
1603 1.5 mrg {
1604 1.5 mrg static int first = 1;
1605 1.29 mrg #ifndef SMALL
1606 1.6 mrg static off_t in_tot, out_tot;
1607 1.29 mrg u_int32_t crc;
1608 1.29 mrg #endif
1609 1.35 mrg off_t in;
1610 1.5 mrg int rv;
1611 1.5 mrg
1612 1.7 mrg if (first) {
1613 1.26 mrg #ifndef SMALL
1614 1.7 mrg if (vflag)
1615 1.7 mrg printf("method crc date time ");
1616 1.26 mrg #endif
1617 1.7 mrg if (qflag == 0)
1618 1.7 mrg printf(" compressed uncompressed "
1619 1.7 mrg "ratio uncompressed_name\n");
1620 1.7 mrg }
1621 1.5 mrg first = 0;
1622 1.5 mrg
1623 1.6 mrg /* print totals? */
1624 1.29 mrg #ifndef SMALL
1625 1.6 mrg if (fd == -1) {
1626 1.6 mrg in = in_tot;
1627 1.6 mrg out = out_tot;
1628 1.29 mrg } else
1629 1.29 mrg #endif
1630 1.29 mrg {
1631 1.6 mrg /* read the last 4 bytes - this is the uncompressed size */
1632 1.7 mrg rv = lseek(fd, (off_t)(-8), SEEK_END);
1633 1.6 mrg if (rv != -1) {
1634 1.7 mrg unsigned char buf[8];
1635 1.6 mrg u_int32_t usize;
1636 1.6 mrg
1637 1.6 mrg if (read(fd, (char *)buf, sizeof(buf)) != sizeof(buf))
1638 1.37 mrg maybe_warn("read of uncompressed size");
1639 1.7 mrg usize = buf[4] | buf[5] << 8 | buf[6] << 16 | buf[7] << 24;
1640 1.35 mrg in = (off_t)usize;
1641 1.29 mrg #ifndef SMALL
1642 1.29 mrg crc = buf[0] | buf[1] << 8 | buf[2] << 16 | buf[3] << 24;
1643 1.29 mrg #endif
1644 1.6 mrg }
1645 1.6 mrg }
1646 1.5 mrg
1647 1.26 mrg #ifndef SMALL
1648 1.7 mrg if (vflag && fd == -1)
1649 1.7 mrg printf(" ");
1650 1.7 mrg else if (vflag) {
1651 1.7 mrg char *date = ctime(&ts);
1652 1.7 mrg
1653 1.7 mrg /* skip the day, 1/100th second, and year */
1654 1.7 mrg date += 4;
1655 1.7 mrg date[12] = 0;
1656 1.7 mrg printf("%5s %08x %11s ", "defla"/*XXX*/, crc, date);
1657 1.7 mrg }
1658 1.29 mrg in_tot += in;
1659 1.29 mrg out_tot += out;
1660 1.26 mrg #endif
1661 1.35 mrg printf("%12llu %12llu ", (unsigned long long)out, (unsigned long long)in);
1662 1.6 mrg print_ratio(in, out, stdout);
1663 1.6 mrg printf(" %s\n", outfile);
1664 1.5 mrg }
1665 1.5 mrg
1666 1.1 mrg /* display the usage of NetBSD gzip */
1667 1.1 mrg static void
1668 1.1 mrg usage(void)
1669 1.1 mrg {
1670 1.1 mrg
1671 1.1 mrg fprintf(stderr, "%s\n", gzip_version);
1672 1.1 mrg fprintf(stderr,
1673 1.29 mrg "usage: %s [-" OPT_LIST "] [<file> [<file> ...]]\n"
1674 1.11 mrg #ifndef SMALL
1675 1.1 mrg " -c --stdout write to stdout, keep original files\n"
1676 1.1 mrg " --to-stdout\n"
1677 1.1 mrg " -d --decompress uncompress files\n"
1678 1.1 mrg " --uncompress\n"
1679 1.1 mrg " -f --force force overwriting & compress links\n"
1680 1.1 mrg " -h --help display this help\n"
1681 1.1 mrg " -n --no-name don't save original file name or time stamp\n"
1682 1.1 mrg " -N --name save or restore original file name and time stamp\n"
1683 1.1 mrg " -q --quiet output no warnings\n"
1684 1.1 mrg " -r --recursive recursively compress files in directories\n"
1685 1.1 mrg " -S .suf use suffix .suf instead of .gz\n"
1686 1.1 mrg " --suffix .suf\n"
1687 1.1 mrg " -t --test test compressed file\n"
1688 1.1 mrg " -v --verbose print extra statistics\n"
1689 1.1 mrg " -V --version display program version\n"
1690 1.1 mrg " -1 --fast fastest (worst) compression\n"
1691 1.1 mrg " -2 .. -8 set compression level\n"
1692 1.1 mrg " -9 --best best (slowest) compression\n",
1693 1.11 mrg #else
1694 1.11 mrg ,
1695 1.11 mrg #endif
1696 1.1 mrg getprogname());
1697 1.1 mrg exit(0);
1698 1.1 mrg }
1699 1.1 mrg
1700 1.1 mrg /* display the version of NetBSD gzip */
1701 1.1 mrg static void
1702 1.1 mrg display_version(void)
1703 1.1 mrg {
1704 1.1 mrg
1705 1.1 mrg fprintf(stderr, "%s\n", gzip_version);
1706 1.1 mrg exit(0);
1707 1.1 mrg }
1708 1.10 mrg
1709 1.24 tsutsui #ifndef NO_BZIP2_SUPPORT
1710 1.10 mrg #include "unbzip2.c"
1711 1.24 tsutsui #endif
1712 1.24 tsutsui #ifndef NO_COMPRESS_SUPPORT
1713 1.22 mrg #include "zuncompress.c"
1714 1.24 tsutsui #endif
1715