ar_io.c revision 1.36 1 1.36 agc /* $NetBSD: ar_io.c,v 1.36 2003/08/07 09:05:19 agc Exp $ */
2 1.4 cgd
3 1.1 jtc /*-
4 1.1 jtc * Copyright (c) 1992, 1993
5 1.1 jtc * The Regents of the University of California. All rights reserved.
6 1.1 jtc *
7 1.1 jtc * This code is derived from software contributed to Berkeley by
8 1.1 jtc * Keith Muller of the University of California, San Diego.
9 1.1 jtc *
10 1.1 jtc * Redistribution and use in source and binary forms, with or without
11 1.1 jtc * modification, are permitted provided that the following conditions
12 1.1 jtc * are met:
13 1.1 jtc * 1. Redistributions of source code must retain the above copyright
14 1.1 jtc * notice, this list of conditions and the following disclaimer.
15 1.1 jtc * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 jtc * notice, this list of conditions and the following disclaimer in the
17 1.1 jtc * documentation and/or other materials provided with the distribution.
18 1.36 agc * 3. Neither the name of the University nor the names of its contributors
19 1.36 agc * may be used to endorse or promote products derived from this software
20 1.36 agc * without specific prior written permission.
21 1.36 agc *
22 1.36 agc * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23 1.36 agc * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24 1.36 agc * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25 1.36 agc * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26 1.36 agc * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27 1.36 agc * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28 1.36 agc * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29 1.36 agc * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 1.36 agc * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31 1.36 agc * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 1.36 agc * SUCH DAMAGE.
33 1.36 agc */
34 1.36 agc
35 1.36 agc /*-
36 1.36 agc * Copyright (c) 1992 Keith Muller.
37 1.36 agc *
38 1.36 agc * This code is derived from software contributed to Berkeley by
39 1.36 agc * Keith Muller of the University of California, San Diego.
40 1.36 agc *
41 1.36 agc * Redistribution and use in source and binary forms, with or without
42 1.36 agc * modification, are permitted provided that the following conditions
43 1.36 agc * are met:
44 1.36 agc * 1. Redistributions of source code must retain the above copyright
45 1.36 agc * notice, this list of conditions and the following disclaimer.
46 1.36 agc * 2. Redistributions in binary form must reproduce the above copyright
47 1.36 agc * notice, this list of conditions and the following disclaimer in the
48 1.36 agc * documentation and/or other materials provided with the distribution.
49 1.1 jtc * 3. All advertising materials mentioning features or use of this software
50 1.1 jtc * must display the following acknowledgement:
51 1.1 jtc * This product includes software developed by the University of
52 1.1 jtc * California, Berkeley and its contributors.
53 1.1 jtc * 4. Neither the name of the University nor the names of its contributors
54 1.1 jtc * may be used to endorse or promote products derived from this software
55 1.1 jtc * without specific prior written permission.
56 1.1 jtc *
57 1.1 jtc * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
58 1.1 jtc * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
59 1.1 jtc * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
60 1.1 jtc * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
61 1.1 jtc * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
62 1.1 jtc * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
63 1.1 jtc * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
64 1.1 jtc * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
65 1.1 jtc * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
66 1.1 jtc * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
67 1.1 jtc * SUCH DAMAGE.
68 1.1 jtc */
69 1.1 jtc
70 1.7 christos #include <sys/cdefs.h>
71 1.22 tv #if defined(__RCSID) && !defined(lint)
72 1.4 cgd #if 0
73 1.4 cgd static char sccsid[] = "@(#)ar_io.c 8.2 (Berkeley) 4/18/94";
74 1.4 cgd #else
75 1.36 agc __RCSID("$NetBSD: ar_io.c,v 1.36 2003/08/07 09:05:19 agc Exp $");
76 1.4 cgd #endif
77 1.1 jtc #endif /* not lint */
78 1.1 jtc
79 1.1 jtc #include <sys/types.h>
80 1.1 jtc #include <sys/time.h>
81 1.1 jtc #include <sys/stat.h>
82 1.1 jtc #include <sys/ioctl.h>
83 1.1 jtc #include <sys/mtio.h>
84 1.1 jtc #include <sys/param.h>
85 1.23 christos #include <sys/wait.h>
86 1.1 jtc #include <signal.h>
87 1.1 jtc #include <string.h>
88 1.1 jtc #include <fcntl.h>
89 1.1 jtc #include <unistd.h>
90 1.1 jtc #include <stdio.h>
91 1.1 jtc #include <ctype.h>
92 1.1 jtc #include <errno.h>
93 1.1 jtc #include <stdlib.h>
94 1.25 thorpej #ifdef SUPPORT_RMT
95 1.23 christos #define __RMTLIB_PRIVATE
96 1.23 christos #include <rmt.h>
97 1.25 thorpej #endif /* SUPPORT_RMT */
98 1.1 jtc #include "pax.h"
99 1.23 christos #include "options.h"
100 1.1 jtc #include "extern.h"
101 1.1 jtc
102 1.1 jtc /*
103 1.1 jtc * Routines which deal directly with the archive I/O device/file.
104 1.1 jtc */
105 1.1 jtc
106 1.1 jtc #define DMOD 0666 /* default mode of created archives */
107 1.1 jtc #define EXT_MODE O_RDONLY /* open mode for list/extract */
108 1.1 jtc #define AR_MODE (O_WRONLY | O_CREAT | O_TRUNC) /* mode for archive */
109 1.1 jtc #define APP_MODE O_RDWR /* mode for append */
110 1.17 itohy #define STDO "<STDOUT>" /* pseudo name for stdout */
111 1.17 itohy #define STDN "<STDIN>" /* pseudo name for stdin */
112 1.1 jtc static int arfd = -1; /* archive file descriptor */
113 1.1 jtc static int artyp = ISREG; /* archive type: file/FIFO/tape */
114 1.1 jtc static int arvol = 1; /* archive volume number */
115 1.1 jtc static int lstrval = -1; /* return value from last i/o */
116 1.1 jtc static int io_ok; /* i/o worked on volume after resync */
117 1.1 jtc static int did_io; /* did i/o ever occur on volume? */
118 1.1 jtc static int done; /* set via tty termination */
119 1.1 jtc static struct stat arsb; /* stat of archive device at open */
120 1.1 jtc static int invld_rec; /* tape has out of spec record size */
121 1.1 jtc static int wr_trail = 1; /* trailer was rewritten in append */
122 1.1 jtc static int can_unlnk = 0; /* do we unlink null archives? */
123 1.17 itohy const char *arcname; /* printable name of archive */
124 1.9 mycroft const char *gzip_program; /* name of gzip program */
125 1.23 christos static pid_t zpid = -1; /* pid of child process */
126 1.13 christos time_t starttime; /* time the run started */
127 1.18 thorpej int force_one_volume; /* 1 if we ignore volume changes */
128 1.1 jtc
129 1.20 lukem static int get_phys(void);
130 1.1 jtc extern sigset_t s_mask;
131 1.23 christos static void ar_start_gzip(int, const char *, int);
132 1.20 lukem static const char *timefmt(char *, size_t, off_t, time_t);
133 1.20 lukem static const char *sizefmt(char *, size_t, off_t);
134 1.24 thorpej
135 1.24 thorpej #ifdef SUPPORT_RMT
136 1.23 christos #ifdef SYS_NO_RESTART
137 1.23 christos static int rmtread_with_restart(int, void *, int);
138 1.23 christos static int rmtwrite_with_restart(int, void *, int);
139 1.23 christos #else
140 1.23 christos #define rmtread_with_restart(a, b, c) rmtread((a), (b), (c))
141 1.23 christos #define rmtwrite_with_restart(a, b, c) rmtwrite((a), (b), (c))
142 1.23 christos #endif
143 1.24 thorpej #endif /* SUPPORT_RMT */
144 1.1 jtc
145 1.1 jtc /*
146 1.1 jtc * ar_open()
147 1.1 jtc * Opens the next archive volume. Determines the type of the device and
148 1.1 jtc * sets up block sizes as required by the archive device and the format.
149 1.1 jtc * Note: we may be called with name == NULL on the first open only.
150 1.1 jtc * Return:
151 1.1 jtc * -1 on failure, 0 otherwise
152 1.1 jtc */
153 1.1 jtc
154 1.1 jtc int
155 1.9 mycroft ar_open(const char *name)
156 1.1 jtc {
157 1.17 itohy struct mtget mb;
158 1.8 mrg
159 1.1 jtc if (arfd != -1)
160 1.1 jtc (void)close(arfd);
161 1.1 jtc arfd = -1;
162 1.1 jtc can_unlnk = did_io = io_ok = invld_rec = 0;
163 1.1 jtc artyp = ISREG;
164 1.1 jtc flcnt = 0;
165 1.1 jtc
166 1.24 thorpej #ifdef SUPPORT_RMT
167 1.26 christos if (name && strchr(name, ':') != NULL && !forcelocal) {
168 1.23 christos artyp = ISRMT;
169 1.23 christos if ((arfd = rmtopen(name, O_RDWR, DMOD)) == -1) {
170 1.23 christos syswarn(0, errno, "Failed open on %s", name);
171 1.23 christos return -1;
172 1.23 christos }
173 1.23 christos blksz = rdblksz = 8192;
174 1.23 christos lstrval = 1;
175 1.23 christos return 0;
176 1.23 christos }
177 1.24 thorpej #endif /* SUPPORT_RMT */
178 1.23 christos
179 1.1 jtc /*
180 1.1 jtc * open based on overall operation mode
181 1.1 jtc */
182 1.1 jtc switch (act) {
183 1.1 jtc case LIST:
184 1.1 jtc case EXTRACT:
185 1.1 jtc if (name == NULL) {
186 1.1 jtc arfd = STDIN_FILENO;
187 1.1 jtc arcname = STDN;
188 1.1 jtc } else if ((arfd = open(name, EXT_MODE, DMOD)) < 0)
189 1.1 jtc syswarn(0, errno, "Failed open to read on %s", name);
190 1.23 christos if (arfd != -1 && gzip_program != NULL)
191 1.23 christos ar_start_gzip(arfd, gzip_program, 0);
192 1.1 jtc break;
193 1.1 jtc case ARCHIVE:
194 1.1 jtc if (name == NULL) {
195 1.1 jtc arfd = STDOUT_FILENO;
196 1.1 jtc arcname = STDO;
197 1.1 jtc } else if ((arfd = open(name, AR_MODE, DMOD)) < 0)
198 1.1 jtc syswarn(0, errno, "Failed open to write on %s", name);
199 1.1 jtc else
200 1.1 jtc can_unlnk = 1;
201 1.23 christos if (arfd != -1 && gzip_program != NULL)
202 1.23 christos ar_start_gzip(arfd, gzip_program, 1);
203 1.1 jtc break;
204 1.1 jtc case APPND:
205 1.1 jtc if (name == NULL) {
206 1.1 jtc arfd = STDOUT_FILENO;
207 1.1 jtc arcname = STDO;
208 1.1 jtc } else if ((arfd = open(name, APP_MODE, DMOD)) < 0)
209 1.1 jtc syswarn(0, errno, "Failed open to read/write on %s",
210 1.1 jtc name);
211 1.1 jtc break;
212 1.1 jtc case COPY:
213 1.1 jtc /*
214 1.1 jtc * arfd not used in COPY mode
215 1.1 jtc */
216 1.1 jtc arcname = "<NONE>";
217 1.1 jtc lstrval = 1;
218 1.1 jtc return(0);
219 1.1 jtc }
220 1.1 jtc if (arfd < 0)
221 1.1 jtc return(-1);
222 1.1 jtc
223 1.23 christos if (chdname != NULL)
224 1.23 christos if (chdir(chdname) != 0)
225 1.23 christos syswarn(1, errno, "Failed chdir to %s", chdname);
226 1.1 jtc /*
227 1.1 jtc * set up is based on device type
228 1.1 jtc */
229 1.1 jtc if (fstat(arfd, &arsb) < 0) {
230 1.1 jtc syswarn(0, errno, "Failed stat on %s", arcname);
231 1.1 jtc (void)close(arfd);
232 1.1 jtc arfd = -1;
233 1.1 jtc can_unlnk = 0;
234 1.1 jtc return(-1);
235 1.1 jtc }
236 1.1 jtc if (S_ISDIR(arsb.st_mode)) {
237 1.7 christos tty_warn(0, "Cannot write an archive on top of a directory %s",
238 1.1 jtc arcname);
239 1.1 jtc (void)close(arfd);
240 1.1 jtc arfd = -1;
241 1.1 jtc can_unlnk = 0;
242 1.1 jtc return(-1);
243 1.1 jtc }
244 1.1 jtc
245 1.1 jtc if (S_ISCHR(arsb.st_mode))
246 1.1 jtc artyp = ioctl(arfd, MTIOCGET, &mb) ? ISCHR : ISTAPE;
247 1.1 jtc else if (S_ISBLK(arsb.st_mode))
248 1.1 jtc artyp = ISBLK;
249 1.1 jtc else if ((lseek(arfd, (off_t)0L, SEEK_CUR) == -1) && (errno == ESPIPE))
250 1.1 jtc artyp = ISPIPE;
251 1.1 jtc else
252 1.1 jtc artyp = ISREG;
253 1.29 christos
254 1.29 christos /*
255 1.29 christos * Special handling for empty files.
256 1.29 christos */
257 1.29 christos if (artyp == ISREG && arsb.st_size == 0) {
258 1.29 christos switch (act) {
259 1.29 christos case LIST:
260 1.29 christos case EXTRACT:
261 1.29 christos return -1;
262 1.29 christos case APPND:
263 1.30 christos act = -ARCHIVE;
264 1.29 christos return -1;
265 1.29 christos case ARCHIVE:
266 1.29 christos break;
267 1.29 christos }
268 1.29 christos }
269 1.1 jtc
270 1.1 jtc /*
271 1.1 jtc * make sure we beyond any doubt that we only can unlink regular files
272 1.1 jtc * we created
273 1.1 jtc */
274 1.1 jtc if (artyp != ISREG)
275 1.1 jtc can_unlnk = 0;
276 1.14 is
277 1.14 is /*
278 1.1 jtc * if we are writing, we are done
279 1.1 jtc */
280 1.1 jtc if (act == ARCHIVE) {
281 1.1 jtc blksz = rdblksz = wrblksz;
282 1.1 jtc lstrval = 1;
283 1.1 jtc return(0);
284 1.8 mrg }
285 1.8 mrg
286 1.8 mrg /*
287 1.1 jtc * set default blksz on read. APPNDs writes rdblksz on the last volume
288 1.1 jtc * On all new archive volumes, we shift to wrblksz (if the user
289 1.1 jtc * specified one, otherwize we will continue to use rdblksz). We
290 1.31 wiz * must set blocksize based on what kind of device the archive is
291 1.1 jtc * stored.
292 1.1 jtc */
293 1.1 jtc switch(artyp) {
294 1.1 jtc case ISTAPE:
295 1.1 jtc /*
296 1.1 jtc * Tape drives come in at least two flavors. Those that support
297 1.1 jtc * variable sized records and those that have fixed sized
298 1.1 jtc * records. They must be treated differently. For tape drives
299 1.1 jtc * that support variable sized records, we must make large
300 1.1 jtc * reads to make sure we get the entire record, otherwise we
301 1.1 jtc * will just get the first part of the record (up to size we
302 1.1 jtc * asked). Tapes with fixed sized records may or may not return
303 1.1 jtc * multiple records in a single read. We really do not care
304 1.1 jtc * what the physical record size is UNLESS we are going to
305 1.1 jtc * append. (We will need the physical block size to rewrite
306 1.1 jtc * the trailer). Only when we are appending do we go to the
307 1.1 jtc * effort to figure out the true PHYSICAL record size.
308 1.1 jtc */
309 1.1 jtc blksz = rdblksz = MAXBLK;
310 1.1 jtc break;
311 1.1 jtc case ISPIPE:
312 1.1 jtc case ISBLK:
313 1.1 jtc case ISCHR:
314 1.1 jtc /*
315 1.1 jtc * Blocksize is not a major issue with these devices (but must
316 1.1 jtc * be kept a multiple of 512). If the user specified a write
317 1.1 jtc * block size, we use that to read. Under append, we must
318 1.1 jtc * always keep blksz == rdblksz. Otherwise we go ahead and use
319 1.1 jtc * the device optimal blocksize as (and if) returned by stat
320 1.1 jtc * and if it is within pax specs.
321 1.1 jtc */
322 1.1 jtc if ((act == APPND) && wrblksz) {
323 1.1 jtc blksz = rdblksz = wrblksz;
324 1.1 jtc break;
325 1.1 jtc }
326 1.1 jtc
327 1.1 jtc if ((arsb.st_blksize > 0) && (arsb.st_blksize < MAXBLK) &&
328 1.1 jtc ((arsb.st_blksize % BLKMULT) == 0))
329 1.1 jtc rdblksz = arsb.st_blksize;
330 1.1 jtc else
331 1.1 jtc rdblksz = DEVBLK;
332 1.1 jtc /*
333 1.1 jtc * For performance go for large reads when we can without harm
334 1.1 jtc */
335 1.1 jtc if ((act == APPND) || (artyp == ISCHR))
336 1.1 jtc blksz = rdblksz;
337 1.1 jtc else
338 1.1 jtc blksz = MAXBLK;
339 1.1 jtc break;
340 1.1 jtc case ISREG:
341 1.1 jtc /*
342 1.1 jtc * if the user specified wrblksz works, use it. Under appends
343 1.1 jtc * we must always keep blksz == rdblksz
344 1.1 jtc */
345 1.1 jtc if ((act == APPND) && wrblksz && ((arsb.st_size%wrblksz)==0)){
346 1.1 jtc blksz = rdblksz = wrblksz;
347 1.1 jtc break;
348 1.1 jtc }
349 1.1 jtc /*
350 1.1 jtc * See if we can find the blocking factor from the file size
351 1.1 jtc */
352 1.1 jtc for (rdblksz = MAXBLK; rdblksz > 0; rdblksz -= BLKMULT)
353 1.1 jtc if ((arsb.st_size % rdblksz) == 0)
354 1.1 jtc break;
355 1.1 jtc /*
356 1.17 itohy * When we cannot find a match, we may have a flawed archive.
357 1.1 jtc */
358 1.1 jtc if (rdblksz <= 0)
359 1.1 jtc rdblksz = FILEBLK;
360 1.1 jtc /*
361 1.1 jtc * for performance go for large reads when we can
362 1.1 jtc */
363 1.1 jtc if (act == APPND)
364 1.1 jtc blksz = rdblksz;
365 1.1 jtc else
366 1.1 jtc blksz = MAXBLK;
367 1.1 jtc break;
368 1.1 jtc default:
369 1.1 jtc /*
370 1.31 wiz * should never happen, worst case, slow...
371 1.1 jtc */
372 1.1 jtc blksz = rdblksz = BLKMULT;
373 1.1 jtc break;
374 1.1 jtc }
375 1.1 jtc lstrval = 1;
376 1.1 jtc return(0);
377 1.1 jtc }
378 1.1 jtc
379 1.1 jtc /*
380 1.1 jtc * ar_close()
381 1.1 jtc * closes archive device, increments volume number, and prints i/o summary
382 1.1 jtc */
383 1.1 jtc void
384 1.1 jtc ar_close(void)
385 1.1 jtc {
386 1.1 jtc if (arfd < 0) {
387 1.1 jtc did_io = io_ok = flcnt = 0;
388 1.1 jtc return;
389 1.1 jtc }
390 1.1 jtc
391 1.1 jtc
392 1.1 jtc /*
393 1.1 jtc * Close archive file. This may take a LONG while on tapes (we may be
394 1.1 jtc * forced to wait for the rewind to complete) so tell the user what is
395 1.1 jtc * going on (this avoids the user hitting control-c thinking pax is
396 1.1 jtc * broken).
397 1.1 jtc */
398 1.1 jtc if (vflag && (artyp == ISTAPE)) {
399 1.1 jtc if (vfpart)
400 1.23 christos (void)putc('\n', listf);
401 1.23 christos (void)fprintf(listf,
402 1.1 jtc "%s: Waiting for tape drive close to complete...",
403 1.1 jtc argv0);
404 1.23 christos (void)fflush(listf);
405 1.1 jtc }
406 1.1 jtc
407 1.1 jtc /*
408 1.1 jtc * if nothing was written to the archive (and we created it), we remove
409 1.1 jtc * it
410 1.1 jtc */
411 1.1 jtc if (can_unlnk && (fstat(arfd, &arsb) == 0) && (S_ISREG(arsb.st_mode)) &&
412 1.1 jtc (arsb.st_size == 0)) {
413 1.1 jtc (void)unlink(arcname);
414 1.1 jtc can_unlnk = 0;
415 1.1 jtc }
416 1.1 jtc
417 1.23 christos /*
418 1.23 christos * for a quick extract/list, pax frequently exits before the child
419 1.23 christos * process is done
420 1.23 christos */
421 1.23 christos if ((act == LIST || act == EXTRACT) && nflag && zpid > 0) {
422 1.23 christos int status;
423 1.23 christos kill(zpid, SIGINT);
424 1.23 christos waitpid(zpid, &status, 0);
425 1.23 christos }
426 1.23 christos
427 1.24 thorpej #ifdef SUPPORT_RMT
428 1.23 christos if (artyp == ISRMT)
429 1.23 christos (void)rmtclose(arfd);
430 1.23 christos else
431 1.24 thorpej #endif /* SUPPORT_RMT */
432 1.23 christos (void)close(arfd);
433 1.1 jtc
434 1.1 jtc if (vflag && (artyp == ISTAPE)) {
435 1.23 christos (void)fputs("done.\n", listf);
436 1.1 jtc vfpart = 0;
437 1.23 christos (void)fflush(listf);
438 1.1 jtc }
439 1.1 jtc arfd = -1;
440 1.1 jtc
441 1.1 jtc if (!io_ok && !did_io) {
442 1.1 jtc flcnt = 0;
443 1.1 jtc return;
444 1.1 jtc }
445 1.1 jtc did_io = io_ok = 0;
446 1.1 jtc
447 1.1 jtc /*
448 1.1 jtc * The volume number is only increased when the last device has data
449 1.1 jtc * and we have already determined the archive format.
450 1.1 jtc */
451 1.1 jtc if (frmt != NULL)
452 1.1 jtc ++arvol;
453 1.1 jtc
454 1.1 jtc if (!vflag) {
455 1.1 jtc flcnt = 0;
456 1.1 jtc return;
457 1.1 jtc }
458 1.1 jtc
459 1.1 jtc /*
460 1.1 jtc * Print out a summary of I/O for this archive volume.
461 1.1 jtc */
462 1.1 jtc if (vfpart) {
463 1.23 christos (void)putc('\n', listf);
464 1.1 jtc vfpart = 0;
465 1.1 jtc }
466 1.23 christos /*
467 1.23 christos * If we have not determined the format yet, we just say how many bytes
468 1.23 christos * we have skipped over looking for a header to id. there is no way we
469 1.23 christos * could have written anything yet.
470 1.23 christos */
471 1.23 christos if (frmt == NULL) {
472 1.23 christos (void)fprintf(listf, "%s: unknown format, " OFFT_F
473 1.23 christos " bytes skipped.\n", argv0, rdcnt);
474 1.23 christos (void)fflush(listf);
475 1.23 christos flcnt = 0;
476 1.23 christos return;
477 1.23 christos }
478 1.23 christos
479 1.23 christos if (strcmp(NM_CPIO, argv0) == 0) {
480 1.23 christos (void)fprintf(listf, OFFT_F " blocks\n",
481 1.23 christos (rdcnt ? rdcnt : wrcnt) / 5120);
482 1.23 christos }
483 1.1 jtc
484 1.13 christos ar_summary(0);
485 1.1 jtc
486 1.23 christos (void)fflush(listf);
487 1.1 jtc flcnt = 0;
488 1.1 jtc }
489 1.1 jtc
490 1.1 jtc /*
491 1.1 jtc * ar_drain()
492 1.1 jtc * drain any archive format independent padding from an archive read
493 1.1 jtc * from a socket or a pipe. This is to prevent the process on the
494 1.1 jtc * other side of the pipe from getting a SIGPIPE (pax will stop
495 1.1 jtc * reading an archive once a format dependent trailer is detected).
496 1.1 jtc */
497 1.1 jtc void
498 1.1 jtc ar_drain(void)
499 1.1 jtc {
500 1.6 tls int res;
501 1.1 jtc char drbuf[MAXBLK];
502 1.1 jtc
503 1.1 jtc /*
504 1.1 jtc * we only drain from a pipe/socket. Other devices can be closed
505 1.1 jtc * without reading up to end of file. We sure hope that pipe is closed
506 1.1 jtc * on the other side so we will get an EOF.
507 1.1 jtc */
508 1.1 jtc if ((artyp != ISPIPE) || (lstrval <= 0))
509 1.1 jtc return;
510 1.1 jtc
511 1.1 jtc /*
512 1.1 jtc * keep reading until pipe is drained
513 1.1 jtc */
514 1.24 thorpej #ifdef SUPPORT_RMT
515 1.23 christos if (artyp == ISRMT) {
516 1.24 thorpej while ((res = rmtread_with_restart(arfd,
517 1.24 thorpej drbuf, sizeof(drbuf))) > 0)
518 1.23 christos continue;
519 1.23 christos } else {
520 1.24 thorpej #endif /* SUPPORT_RMT */
521 1.24 thorpej while ((res = read_with_restart(arfd,
522 1.24 thorpej drbuf, sizeof(drbuf))) > 0)
523 1.23 christos continue;
524 1.24 thorpej #ifdef SUPPORT_RMT
525 1.23 christos }
526 1.24 thorpej #endif /* SUPPORT_RMT */
527 1.1 jtc lstrval = res;
528 1.1 jtc }
529 1.1 jtc
530 1.1 jtc /*
531 1.1 jtc * ar_set_wr()
532 1.1 jtc * Set up device right before switching from read to write in an append.
533 1.1 jtc * device dependent code (if required) to do this should be added here.
534 1.1 jtc * For all archive devices we are already positioned at the place we want
535 1.1 jtc * to start writing when this routine is called.
536 1.1 jtc * Return:
537 1.1 jtc * 0 if all ready to write, -1 otherwise
538 1.1 jtc */
539 1.1 jtc
540 1.1 jtc int
541 1.1 jtc ar_set_wr(void)
542 1.1 jtc {
543 1.1 jtc off_t cpos;
544 1.1 jtc
545 1.1 jtc /*
546 1.1 jtc * we must make sure the trailer is rewritten on append, ar_next()
547 1.1 jtc * will stop us if the archive containing the trailer was not written
548 1.1 jtc */
549 1.1 jtc wr_trail = 0;
550 1.17 itohy
551 1.17 itohy /*
552 1.1 jtc * Add any device dependent code as required here
553 1.1 jtc */
554 1.1 jtc if (artyp != ISREG)
555 1.1 jtc return(0);
556 1.1 jtc /*
557 1.1 jtc * Ok we have an archive in a regular file. If we were rewriting a
558 1.1 jtc * file, we must get rid of all the stuff after the current offset
559 1.1 jtc * (it was not written by pax).
560 1.1 jtc */
561 1.1 jtc if (((cpos = lseek(arfd, (off_t)0L, SEEK_CUR)) < 0) ||
562 1.1 jtc (ftruncate(arfd, cpos) < 0)) {
563 1.1 jtc syswarn(1, errno, "Unable to truncate archive file");
564 1.1 jtc return(-1);
565 1.1 jtc }
566 1.1 jtc return(0);
567 1.1 jtc }
568 1.1 jtc
569 1.1 jtc /*
570 1.1 jtc * ar_app_ok()
571 1.1 jtc * check if the last volume in the archive allows appends. We cannot check
572 1.17 itohy * this until we are ready to write since there is no spec that says all
573 1.1 jtc * volumes in a single archive have to be of the same type...
574 1.1 jtc * Return:
575 1.1 jtc * 0 if we can append, -1 otherwise.
576 1.1 jtc */
577 1.1 jtc
578 1.1 jtc int
579 1.1 jtc ar_app_ok(void)
580 1.1 jtc {
581 1.1 jtc if (artyp == ISPIPE) {
582 1.7 christos tty_warn(1,
583 1.7 christos "Cannot append to an archive obtained from a pipe.");
584 1.1 jtc return(-1);
585 1.1 jtc }
586 1.1 jtc
587 1.1 jtc if (!invld_rec)
588 1.1 jtc return(0);
589 1.7 christos tty_warn(1,
590 1.7 christos "Cannot append, device record size %d does not support %s spec",
591 1.7 christos rdblksz, argv0);
592 1.1 jtc return(-1);
593 1.1 jtc }
594 1.1 jtc
595 1.15 itohy #ifdef SYS_NO_RESTART
596 1.15 itohy /*
597 1.15 itohy * read_with_restart()
598 1.15 itohy * Equivalent to read() but does retry on signals.
599 1.15 itohy * This function is not needed on 4.2BSD and later.
600 1.15 itohy * Return:
601 1.15 itohy * Number of bytes written. -1 indicates an error.
602 1.15 itohy */
603 1.15 itohy
604 1.15 itohy int
605 1.15 itohy read_with_restart(int fd, void *buf, int bsz)
606 1.15 itohy {
607 1.15 itohy int r;
608 1.15 itohy
609 1.15 itohy while (((r = read(fd, buf, bsz)) < 0) && errno == EINTR)
610 1.23 christos continue;
611 1.23 christos
612 1.23 christos return(r);
613 1.23 christos }
614 1.23 christos
615 1.23 christos /*
616 1.23 christos * rmtread_with_restart()
617 1.23 christos * Equivalent to rmtread() but does retry on signals.
618 1.23 christos * This function is not needed on 4.2BSD and later.
619 1.23 christos * Return:
620 1.23 christos * Number of bytes written. -1 indicates an error.
621 1.23 christos */
622 1.23 christos static int
623 1.23 christos rmtread_with_restart(int fd, void *buf, int bsz)
624 1.23 christos {
625 1.23 christos int r;
626 1.23 christos
627 1.23 christos while (((r = rmtread(fd, buf, bsz)) < 0) && errno == EINTR)
628 1.23 christos continue;
629 1.15 itohy
630 1.15 itohy return(r);
631 1.15 itohy }
632 1.15 itohy #endif
633 1.15 itohy
634 1.15 itohy /*
635 1.15 itohy * xread()
636 1.15 itohy * Equivalent to read() but does retry on partial read, which may occur
637 1.15 itohy * on signals.
638 1.15 itohy * Return:
639 1.15 itohy * Number of bytes read. 0 for end of file, -1 for an error.
640 1.15 itohy */
641 1.15 itohy
642 1.15 itohy int
643 1.15 itohy xread(int fd, void *buf, int bsz)
644 1.15 itohy {
645 1.15 itohy char *b = buf;
646 1.15 itohy int nread = 0;
647 1.15 itohy int r;
648 1.15 itohy
649 1.15 itohy do {
650 1.24 thorpej #ifdef SUPPORT_RMT
651 1.23 christos if ((r = rmtread_with_restart(fd, b, bsz)) <= 0)
652 1.15 itohy break;
653 1.24 thorpej #else
654 1.24 thorpej if ((r = read_with_restart(fd, b, bsz)) <= 0)
655 1.24 thorpej break;
656 1.24 thorpej #endif /* SUPPORT_RMT */
657 1.15 itohy b += r;
658 1.15 itohy bsz -= r;
659 1.15 itohy nread += r;
660 1.15 itohy } while (bsz > 0);
661 1.15 itohy
662 1.15 itohy return(nread ? nread : r);
663 1.15 itohy }
664 1.15 itohy
665 1.15 itohy #ifdef SYS_NO_RESTART
666 1.15 itohy /*
667 1.15 itohy * write_with_restart()
668 1.15 itohy * Equivalent to write() but does retry on signals.
669 1.15 itohy * This function is not needed on 4.2BSD and later.
670 1.15 itohy * Return:
671 1.15 itohy * Number of bytes written. -1 indicates an error.
672 1.15 itohy */
673 1.15 itohy
674 1.15 itohy int
675 1.15 itohy write_with_restart(int fd, void *buf, int bsz)
676 1.15 itohy {
677 1.15 itohy int r;
678 1.15 itohy
679 1.15 itohy while (((r = write(fd, buf, bsz)) < 0) && errno == EINTR)
680 1.15 itohy ;
681 1.15 itohy
682 1.15 itohy return(r);
683 1.15 itohy }
684 1.23 christos
685 1.23 christos /*
686 1.23 christos * rmtwrite_with_restart()
687 1.23 christos * Equivalent to write() but does retry on signals.
688 1.23 christos * This function is not needed on 4.2BSD and later.
689 1.23 christos * Return:
690 1.23 christos * Number of bytes written. -1 indicates an error.
691 1.23 christos */
692 1.23 christos
693 1.23 christos static int
694 1.23 christos rmtwrite_with_restart(int fd, void *buf, int bsz)
695 1.23 christos {
696 1.23 christos int r;
697 1.23 christos
698 1.23 christos while (((r = rmtwrite(fd, buf, bsz)) < 0) && errno == EINTR)
699 1.23 christos ;
700 1.23 christos
701 1.23 christos return(r);
702 1.23 christos }
703 1.15 itohy #endif
704 1.15 itohy
705 1.15 itohy /*
706 1.15 itohy * xwrite()
707 1.15 itohy * Equivalent to write() but does retry on partial write, which may occur
708 1.15 itohy * on signals.
709 1.15 itohy * Return:
710 1.15 itohy * Number of bytes written. -1 indicates an error.
711 1.15 itohy */
712 1.15 itohy
713 1.15 itohy int
714 1.15 itohy xwrite(int fd, void *buf, int bsz)
715 1.15 itohy {
716 1.15 itohy char *b = buf;
717 1.15 itohy int written = 0;
718 1.15 itohy int r;
719 1.15 itohy
720 1.15 itohy do {
721 1.24 thorpej #ifdef SUPPORT_RMT
722 1.23 christos if ((r = rmtwrite_with_restart(fd, b, bsz)) <= 0)
723 1.15 itohy break;
724 1.24 thorpej #else
725 1.24 thorpej if ((r = write_with_restart(fd, b, bsz)) <= 0)
726 1.24 thorpej break;
727 1.24 thorpej #endif /* SUPPORT_RMT */
728 1.15 itohy b += r;
729 1.15 itohy bsz -= r;
730 1.15 itohy written += r;
731 1.15 itohy } while (bsz > 0);
732 1.15 itohy
733 1.15 itohy return(written ? written : r);
734 1.15 itohy }
735 1.15 itohy
736 1.1 jtc /*
737 1.1 jtc * ar_read()
738 1.1 jtc * read up to a specified number of bytes from the archive into the
739 1.1 jtc * supplied buffer. When dealing with tapes we may not always be able to
740 1.1 jtc * read what we want.
741 1.1 jtc * Return:
742 1.1 jtc * Number of bytes in buffer. 0 for end of file, -1 for a read error.
743 1.1 jtc */
744 1.1 jtc
745 1.1 jtc int
746 1.6 tls ar_read(char *buf, int cnt)
747 1.1 jtc {
748 1.6 tls int res = 0;
749 1.1 jtc
750 1.1 jtc /*
751 1.1 jtc * if last i/o was in error, no more reads until reset or new volume
752 1.1 jtc */
753 1.1 jtc if (lstrval <= 0)
754 1.1 jtc return(lstrval);
755 1.1 jtc
756 1.1 jtc /*
757 1.1 jtc * how we read must be based on device type
758 1.1 jtc */
759 1.1 jtc switch (artyp) {
760 1.24 thorpej #ifdef SUPPORT_RMT
761 1.23 christos case ISRMT:
762 1.23 christos if ((res = rmtread_with_restart(arfd, buf, cnt)) > 0) {
763 1.23 christos io_ok = 1;
764 1.23 christos return res;
765 1.23 christos }
766 1.23 christos break;
767 1.24 thorpej #endif /* SUPPORT_RMT */
768 1.1 jtc case ISTAPE:
769 1.15 itohy if ((res = read_with_restart(arfd, buf, cnt)) > 0) {
770 1.1 jtc /*
771 1.1 jtc * CAUTION: tape systems may not always return the same
772 1.1 jtc * sized records so we leave blksz == MAXBLK. The
773 1.1 jtc * physical record size that a tape drive supports is
774 1.1 jtc * very hard to determine in a uniform and portable
775 1.1 jtc * manner.
776 1.1 jtc */
777 1.1 jtc io_ok = 1;
778 1.1 jtc if (res != rdblksz) {
779 1.1 jtc /*
780 1.31 wiz * Record size changed. If this happens on
781 1.1 jtc * any record after the first, we probably have
782 1.1 jtc * a tape drive which has a fixed record size
783 1.31 wiz * (we are getting multiple records in a single
784 1.1 jtc * read). Watch out for record blocking that
785 1.1 jtc * violates pax spec (must be a multiple of
786 1.1 jtc * BLKMULT).
787 1.1 jtc */
788 1.1 jtc rdblksz = res;
789 1.1 jtc if (rdblksz % BLKMULT)
790 1.1 jtc invld_rec = 1;
791 1.1 jtc }
792 1.1 jtc return(res);
793 1.1 jtc }
794 1.1 jtc break;
795 1.1 jtc case ISREG:
796 1.1 jtc case ISBLK:
797 1.1 jtc case ISCHR:
798 1.1 jtc case ISPIPE:
799 1.1 jtc default:
800 1.1 jtc /*
801 1.1 jtc * Files are so easy to deal with. These other things cannot
802 1.1 jtc * be trusted at all. So when we are dealing with character
803 1.1 jtc * devices and pipes we just take what they have ready for us
804 1.1 jtc * and return. Trying to do anything else with them runs the
805 1.1 jtc * risk of failure.
806 1.1 jtc */
807 1.15 itohy if ((res = read_with_restart(arfd, buf, cnt)) > 0) {
808 1.1 jtc io_ok = 1;
809 1.1 jtc return(res);
810 1.1 jtc }
811 1.1 jtc break;
812 1.1 jtc }
813 1.1 jtc
814 1.1 jtc /*
815 1.1 jtc * We are in trouble at this point, something is broken...
816 1.1 jtc */
817 1.1 jtc lstrval = res;
818 1.1 jtc if (res < 0)
819 1.1 jtc syswarn(1, errno, "Failed read on archive volume %d", arvol);
820 1.34 christos else
821 1.7 christos tty_warn(0, "End of archive volume %d reached", arvol);
822 1.1 jtc return(res);
823 1.17 itohy }
824 1.1 jtc
825 1.1 jtc /*
826 1.1 jtc * ar_write()
827 1.1 jtc * Write a specified number of bytes in supplied buffer to the archive
828 1.1 jtc * device so it appears as a single "block". Deals with errors and tries
829 1.1 jtc * to recover when faced with short writes.
830 1.1 jtc * Return:
831 1.1 jtc * Number of bytes written. 0 indicates end of volume reached and with no
832 1.1 jtc * flaws (as best that can be detected). A -1 indicates an unrecoverable
833 1.19 wiz * error in the archive occurred.
834 1.1 jtc */
835 1.1 jtc
836 1.1 jtc int
837 1.6 tls ar_write(char *buf, int bsz)
838 1.1 jtc {
839 1.6 tls int res;
840 1.1 jtc off_t cpos;
841 1.1 jtc
842 1.1 jtc /*
843 1.1 jtc * do not allow pax to create a "bad" archive. Once a write fails on
844 1.1 jtc * an archive volume prevent further writes to it.
845 1.1 jtc */
846 1.1 jtc if (lstrval <= 0)
847 1.1 jtc return(lstrval);
848 1.1 jtc
849 1.15 itohy if ((res = xwrite(arfd, buf, bsz)) == bsz) {
850 1.1 jtc wr_trail = 1;
851 1.1 jtc io_ok = 1;
852 1.1 jtc return(bsz);
853 1.1 jtc }
854 1.1 jtc /*
855 1.1 jtc * write broke, see what we can do with it. We try to send any partial
856 1.1 jtc * writes that may violate pax spec to the next archive volume.
857 1.1 jtc */
858 1.1 jtc if (res < 0)
859 1.1 jtc lstrval = res;
860 1.1 jtc else
861 1.1 jtc lstrval = 0;
862 1.1 jtc
863 1.1 jtc switch (artyp) {
864 1.1 jtc case ISREG:
865 1.1 jtc if ((res > 0) && (res % BLKMULT)) {
866 1.1 jtc /*
867 1.17 itohy * try to fix up partial writes which are not BLKMULT
868 1.1 jtc * in size by forcing the runt record to next archive
869 1.1 jtc * volume
870 1.17 itohy */
871 1.1 jtc if ((cpos = lseek(arfd, (off_t)0L, SEEK_CUR)) < 0)
872 1.1 jtc break;
873 1.1 jtc cpos -= (off_t)res;
874 1.1 jtc if (ftruncate(arfd, cpos) < 0)
875 1.1 jtc break;
876 1.1 jtc res = lstrval = 0;
877 1.1 jtc break;
878 1.1 jtc }
879 1.1 jtc if (res >= 0)
880 1.1 jtc break;
881 1.1 jtc /*
882 1.1 jtc * if file is out of space, handle it like a return of 0
883 1.1 jtc */
884 1.1 jtc if ((errno == ENOSPC) || (errno == EFBIG) || (errno == EDQUOT))
885 1.1 jtc res = lstrval = 0;
886 1.1 jtc break;
887 1.1 jtc case ISTAPE:
888 1.1 jtc case ISCHR:
889 1.1 jtc case ISBLK:
890 1.24 thorpej #ifdef SUPPORT_RMT
891 1.23 christos case ISRMT:
892 1.24 thorpej #endif /* SUPPORT_RMT */
893 1.1 jtc if (res >= 0)
894 1.1 jtc break;
895 1.1 jtc if (errno == EACCES) {
896 1.7 christos tty_warn(0,
897 1.7 christos "Write failed, archive is write protected.");
898 1.1 jtc res = lstrval = 0;
899 1.1 jtc return(0);
900 1.1 jtc }
901 1.1 jtc /*
902 1.1 jtc * see if we reached the end of media, if so force a change to
903 1.1 jtc * the next volume
904 1.1 jtc */
905 1.1 jtc if ((errno == ENOSPC) || (errno == EIO) || (errno == ENXIO))
906 1.1 jtc res = lstrval = 0;
907 1.1 jtc break;
908 1.1 jtc case ISPIPE:
909 1.1 jtc default:
910 1.1 jtc /*
911 1.1 jtc * we cannot fix errors to these devices
912 1.1 jtc */
913 1.1 jtc break;
914 1.1 jtc }
915 1.1 jtc
916 1.1 jtc /*
917 1.1 jtc * Better tell the user the bad news...
918 1.1 jtc * if this is a block aligned archive format, we may have a bad archive
919 1.17 itohy * if the format wants the header to start at a BLKMULT boundary. While
920 1.1 jtc * we can deal with the mis-aligned data, it violates spec and other
921 1.1 jtc * archive readers will likely fail. if the format is not block
922 1.1 jtc * aligned, the user may be lucky (and the archive is ok).
923 1.1 jtc */
924 1.1 jtc if (res >= 0) {
925 1.1 jtc if (res > 0)
926 1.1 jtc wr_trail = 1;
927 1.1 jtc io_ok = 1;
928 1.1 jtc }
929 1.1 jtc
930 1.1 jtc /*
931 1.1 jtc * If we were trying to rewrite the trailer and it didn't work, we
932 1.1 jtc * must quit right away.
933 1.1 jtc */
934 1.1 jtc if (!wr_trail && (res <= 0)) {
935 1.7 christos tty_warn(1,
936 1.7 christos "Unable to append, trailer re-write failed. Quitting.");
937 1.1 jtc return(res);
938 1.1 jtc }
939 1.17 itohy
940 1.17 itohy if (res == 0)
941 1.7 christos tty_warn(0, "End of archive volume %d reached", arvol);
942 1.1 jtc else if (res < 0)
943 1.1 jtc syswarn(1, errno, "Failed write to archive volume: %d", arvol);
944 1.1 jtc else if (!frmt->blkalgn || ((res % frmt->blkalgn) == 0))
945 1.7 christos tty_warn(0,
946 1.7 christos "WARNING: partial archive write. Archive MAY BE FLAWED");
947 1.1 jtc else
948 1.7 christos tty_warn(1,"WARNING: partial archive write. Archive IS FLAWED");
949 1.1 jtc return(res);
950 1.1 jtc }
951 1.1 jtc
952 1.1 jtc /*
953 1.1 jtc * ar_rdsync()
954 1.1 jtc * Try to move past a bad spot on a flawed archive as needed to continue
955 1.1 jtc * I/O. Clears error flags to allow I/O to continue.
956 1.1 jtc * Return:
957 1.1 jtc * 0 when ok to try i/o again, -1 otherwise.
958 1.1 jtc */
959 1.1 jtc
960 1.1 jtc int
961 1.1 jtc ar_rdsync(void)
962 1.1 jtc {
963 1.1 jtc long fsbz;
964 1.1 jtc off_t cpos;
965 1.1 jtc off_t mpos;
966 1.17 itohy struct mtop mb;
967 1.1 jtc
968 1.1 jtc /*
969 1.31 wiz * Fail resync attempts at user request (done) or if this is going to be
970 1.1 jtc * an update/append to a existing archive. if last i/o hit media end,
971 1.1 jtc * we need to go to the next volume not try a resync
972 1.1 jtc */
973 1.1 jtc if ((done > 0) || (lstrval == 0))
974 1.1 jtc return(-1);
975 1.1 jtc
976 1.1 jtc if ((act == APPND) || (act == ARCHIVE)) {
977 1.7 christos tty_warn(1, "Cannot allow updates to an archive with flaws.");
978 1.1 jtc return(-1);
979 1.1 jtc }
980 1.1 jtc if (io_ok)
981 1.1 jtc did_io = 1;
982 1.1 jtc
983 1.1 jtc switch(artyp) {
984 1.24 thorpej #ifdef SUPPORT_RMT
985 1.23 christos case ISRMT:
986 1.24 thorpej #endif /* SUPPORT_RMT */
987 1.1 jtc case ISTAPE:
988 1.1 jtc /*
989 1.1 jtc * if the last i/o was a successful data transfer, we assume
990 1.1 jtc * the fault is just a bad record on the tape that we are now
991 1.1 jtc * past. If we did not get any data since the last resync try
992 1.17 itohy * to move the tape forward one PHYSICAL record past any
993 1.1 jtc * damaged tape section. Some tape drives are stubborn and need
994 1.1 jtc * to be pushed.
995 1.1 jtc */
996 1.1 jtc if (io_ok) {
997 1.1 jtc io_ok = 0;
998 1.1 jtc lstrval = 1;
999 1.1 jtc break;
1000 1.1 jtc }
1001 1.1 jtc mb.mt_op = MTFSR;
1002 1.1 jtc mb.mt_count = 1;
1003 1.24 thorpej #ifdef SUPPORT_RMT
1004 1.23 christos if (artyp == ISRMT) {
1005 1.23 christos if (rmtioctl(arfd, MTIOCTOP, &mb) < 0)
1006 1.23 christos break;
1007 1.23 christos } else {
1008 1.24 thorpej #endif /* SUPPORT_RMT */
1009 1.23 christos if (ioctl(arfd, MTIOCTOP, &mb) < 0)
1010 1.23 christos break;
1011 1.24 thorpej #ifdef SUPPORT_RMT
1012 1.23 christos }
1013 1.24 thorpej #endif /* SUPPORT_RMT */
1014 1.1 jtc lstrval = 1;
1015 1.1 jtc break;
1016 1.1 jtc case ISREG:
1017 1.1 jtc case ISCHR:
1018 1.1 jtc case ISBLK:
1019 1.1 jtc /*
1020 1.1 jtc * try to step over the bad part of the device.
1021 1.1 jtc */
1022 1.1 jtc io_ok = 0;
1023 1.1 jtc if (((fsbz = arsb.st_blksize) <= 0) || (artyp != ISREG))
1024 1.1 jtc fsbz = BLKMULT;
1025 1.1 jtc if ((cpos = lseek(arfd, (off_t)0L, SEEK_CUR)) < 0)
1026 1.1 jtc break;
1027 1.1 jtc mpos = fsbz - (cpos % (off_t)fsbz);
1028 1.17 itohy if (lseek(arfd, mpos, SEEK_CUR) < 0)
1029 1.1 jtc break;
1030 1.1 jtc lstrval = 1;
1031 1.1 jtc break;
1032 1.1 jtc case ISPIPE:
1033 1.1 jtc default:
1034 1.1 jtc /*
1035 1.1 jtc * cannot recover on these archive device types
1036 1.1 jtc */
1037 1.1 jtc io_ok = 0;
1038 1.1 jtc break;
1039 1.1 jtc }
1040 1.1 jtc if (lstrval <= 0) {
1041 1.7 christos tty_warn(1, "Unable to recover from an archive read failure.");
1042 1.1 jtc return(-1);
1043 1.1 jtc }
1044 1.7 christos tty_warn(0, "Attempting to recover from an archive read failure.");
1045 1.1 jtc return(0);
1046 1.1 jtc }
1047 1.1 jtc
1048 1.1 jtc /*
1049 1.1 jtc * ar_fow()
1050 1.17 itohy * Move the I/O position within the archive forward the specified number of
1051 1.1 jtc * bytes as supported by the device. If we cannot move the requested
1052 1.1 jtc * number of bytes, return the actual number of bytes moved in skipped.
1053 1.1 jtc * Return:
1054 1.1 jtc * 0 if moved the requested distance, -1 on complete failure, 1 on
1055 1.1 jtc * partial move (the amount moved is in skipped)
1056 1.1 jtc */
1057 1.1 jtc
1058 1.1 jtc int
1059 1.1 jtc ar_fow(off_t sksz, off_t *skipped)
1060 1.1 jtc {
1061 1.1 jtc off_t cpos;
1062 1.1 jtc off_t mpos;
1063 1.1 jtc
1064 1.1 jtc *skipped = 0;
1065 1.1 jtc if (sksz <= 0)
1066 1.1 jtc return(0);
1067 1.1 jtc
1068 1.1 jtc /*
1069 1.17 itohy * we cannot move forward at EOF or error
1070 1.1 jtc */
1071 1.1 jtc if (lstrval <= 0)
1072 1.1 jtc return(lstrval);
1073 1.1 jtc
1074 1.1 jtc /*
1075 1.1 jtc * Safer to read forward on devices where it is hard to find the end of
1076 1.1 jtc * the media without reading to it. With tapes we cannot be sure of the
1077 1.1 jtc * number of physical blocks to skip (we do not know physical block
1078 1.17 itohy * size at this point), so we must only read forward on tapes!
1079 1.1 jtc */
1080 1.24 thorpej if (artyp == ISTAPE || artyp == ISPIPE
1081 1.24 thorpej #ifdef SUPPORT_RMT
1082 1.24 thorpej || artyp == ISRMT
1083 1.24 thorpej #endif /* SUPPORT_RMT */
1084 1.24 thorpej )
1085 1.1 jtc return(0);
1086 1.1 jtc
1087 1.1 jtc /*
1088 1.1 jtc * figure out where we are in the archive
1089 1.1 jtc */
1090 1.1 jtc if ((cpos = lseek(arfd, (off_t)0L, SEEK_CUR)) >= 0) {
1091 1.17 itohy /*
1092 1.17 itohy * we can be asked to move farther than there are bytes in this
1093 1.1 jtc * volume, if so, just go to file end and let normal buf_fill()
1094 1.1 jtc * deal with the end of file (it will go to next volume by
1095 1.1 jtc * itself)
1096 1.17 itohy */
1097 1.16 itohy mpos = cpos + sksz;
1098 1.16 itohy if (artyp == ISREG && mpos > arsb.st_size)
1099 1.1 jtc mpos = arsb.st_size;
1100 1.16 itohy if ((mpos = lseek(arfd, mpos, SEEK_SET)) >= 0) {
1101 1.16 itohy *skipped = mpos - cpos;
1102 1.1 jtc return(0);
1103 1.16 itohy }
1104 1.16 itohy } else {
1105 1.16 itohy if (artyp != ISREG)
1106 1.16 itohy return(0); /* non-seekable device */
1107 1.1 jtc }
1108 1.17 itohy syswarn(1, errno, "Forward positioning operation on archive failed");
1109 1.1 jtc lstrval = -1;
1110 1.1 jtc return(-1);
1111 1.1 jtc }
1112 1.1 jtc
1113 1.1 jtc /*
1114 1.1 jtc * ar_rev()
1115 1.1 jtc * move the i/o position within the archive backwards the specified byte
1116 1.1 jtc * count as supported by the device. With tapes drives we RESET rdblksz to
1117 1.1 jtc * the PHYSICAL blocksize.
1118 1.1 jtc * NOTE: We should only be called to move backwards so we can rewrite the
1119 1.1 jtc * last records (the trailer) of an archive (APPEND).
1120 1.1 jtc * Return:
1121 1.1 jtc * 0 if moved the requested distance, -1 on complete failure
1122 1.1 jtc */
1123 1.1 jtc
1124 1.1 jtc int
1125 1.1 jtc ar_rev(off_t sksz)
1126 1.1 jtc {
1127 1.1 jtc off_t cpos;
1128 1.17 itohy struct mtop mb;
1129 1.17 itohy int phyblk;
1130 1.1 jtc
1131 1.1 jtc /*
1132 1.1 jtc * make sure we do not have try to reverse on a flawed archive
1133 1.1 jtc */
1134 1.1 jtc if (lstrval < 0)
1135 1.1 jtc return(lstrval);
1136 1.1 jtc
1137 1.1 jtc switch(artyp) {
1138 1.1 jtc case ISPIPE:
1139 1.17 itohy if (sksz <= 0)
1140 1.1 jtc break;
1141 1.1 jtc /*
1142 1.1 jtc * cannot go backwards on these critters
1143 1.1 jtc */
1144 1.7 christos tty_warn(1, "Reverse positioning on pipes is not supported.");
1145 1.1 jtc lstrval = -1;
1146 1.1 jtc return(-1);
1147 1.1 jtc case ISREG:
1148 1.1 jtc case ISBLK:
1149 1.1 jtc case ISCHR:
1150 1.1 jtc default:
1151 1.1 jtc if (sksz <= 0)
1152 1.1 jtc break;
1153 1.1 jtc
1154 1.1 jtc /*
1155 1.1 jtc * For things other than files, backwards movement has a very
1156 1.1 jtc * high probability of failure as we really do not know the
1157 1.1 jtc * true attributes of the device we are talking to (the device
1158 1.1 jtc * may not even have the ability to lseek() in any direction).
1159 1.1 jtc * First we figure out where we are in the archive.
1160 1.1 jtc */
1161 1.1 jtc if ((cpos = lseek(arfd, (off_t)0L, SEEK_CUR)) < 0) {
1162 1.1 jtc syswarn(1, errno,
1163 1.1 jtc "Unable to obtain current archive byte offset");
1164 1.1 jtc lstrval = -1;
1165 1.1 jtc return(-1);
1166 1.1 jtc }
1167 1.1 jtc
1168 1.1 jtc /*
1169 1.1 jtc * we may try to go backwards past the start when the archive
1170 1.31 wiz * is only a single record. If this happens and we are on a
1171 1.31 wiz * multi-volume archive, we need to go to the end of the
1172 1.1 jtc * previous volume and continue our movement backwards from
1173 1.1 jtc * there.
1174 1.1 jtc */
1175 1.1 jtc if ((cpos -= sksz) < (off_t)0L) {
1176 1.1 jtc if (arvol > 1) {
1177 1.1 jtc /*
1178 1.1 jtc * this should never happen
1179 1.1 jtc */
1180 1.7 christos tty_warn(1,
1181 1.7 christos "Reverse position on previous volume.");
1182 1.1 jtc lstrval = -1;
1183 1.1 jtc return(-1);
1184 1.1 jtc }
1185 1.1 jtc cpos = (off_t)0L;
1186 1.1 jtc }
1187 1.1 jtc if (lseek(arfd, cpos, SEEK_SET) < 0) {
1188 1.1 jtc syswarn(1, errno, "Unable to seek archive backwards");
1189 1.1 jtc lstrval = -1;
1190 1.1 jtc return(-1);
1191 1.1 jtc }
1192 1.1 jtc break;
1193 1.1 jtc case ISTAPE:
1194 1.24 thorpej #ifdef SUPPORT_RMT
1195 1.23 christos case ISRMT:
1196 1.24 thorpej #endif /* SUPPORT_RMT */
1197 1.1 jtc /*
1198 1.17 itohy * Calculate and move the proper number of PHYSICAL tape
1199 1.1 jtc * blocks. If the sksz is not an even multiple of the physical
1200 1.1 jtc * tape size, we cannot do the move (this should never happen).
1201 1.31 wiz * (We also cannot handle trailers spread over two vols).
1202 1.1 jtc * get_phys() also makes sure we are in front of the filemark.
1203 1.17 itohy */
1204 1.1 jtc if ((phyblk = get_phys()) <= 0) {
1205 1.1 jtc lstrval = -1;
1206 1.1 jtc return(-1);
1207 1.1 jtc }
1208 1.1 jtc
1209 1.1 jtc /*
1210 1.1 jtc * make sure future tape reads only go by physical tape block
1211 1.1 jtc * size (set rdblksz to the real size).
1212 1.1 jtc */
1213 1.1 jtc rdblksz = phyblk;
1214 1.1 jtc
1215 1.1 jtc /*
1216 1.1 jtc * if no movement is required, just return (we must be after
1217 1.1 jtc * get_phys() so the physical blocksize is properly set)
1218 1.1 jtc */
1219 1.1 jtc if (sksz <= 0)
1220 1.1 jtc break;
1221 1.1 jtc
1222 1.1 jtc /*
1223 1.1 jtc * ok we have to move. Make sure the tape drive can do it.
1224 1.1 jtc */
1225 1.1 jtc if (sksz % phyblk) {
1226 1.7 christos tty_warn(1,
1227 1.1 jtc "Tape drive unable to backspace requested amount");
1228 1.1 jtc lstrval = -1;
1229 1.1 jtc return(-1);
1230 1.1 jtc }
1231 1.1 jtc
1232 1.1 jtc /*
1233 1.1 jtc * move backwards the requested number of bytes
1234 1.1 jtc */
1235 1.1 jtc mb.mt_op = MTBSR;
1236 1.1 jtc mb.mt_count = sksz/phyblk;
1237 1.24 thorpej if (
1238 1.24 thorpej #ifdef SUPPORT_RMT
1239 1.24 thorpej rmtioctl(arfd, MTIOCTOP, &mb)
1240 1.24 thorpej #else
1241 1.24 thorpej ioctl(arfd, MTIOCTOP, &mb)
1242 1.24 thorpej #endif /* SUPPORT_RMT */
1243 1.24 thorpej < 0) {
1244 1.32 grant syswarn(1, errno, "Unable to backspace tape %ld blocks.",
1245 1.11 christos (long) mb.mt_count);
1246 1.1 jtc lstrval = -1;
1247 1.1 jtc return(-1);
1248 1.1 jtc }
1249 1.1 jtc break;
1250 1.1 jtc }
1251 1.1 jtc lstrval = 1;
1252 1.1 jtc return(0);
1253 1.1 jtc }
1254 1.1 jtc
1255 1.1 jtc /*
1256 1.1 jtc * get_phys()
1257 1.1 jtc * Determine the physical block size on a tape drive. We need the physical
1258 1.17 itohy * block size so we know how many bytes we skip over when we move with
1259 1.1 jtc * mtio commands. We also make sure we are BEFORE THE TAPE FILEMARK when
1260 1.1 jtc * return.
1261 1.1 jtc * This is one really SLOW routine...
1262 1.1 jtc * Return:
1263 1.1 jtc * physical block size if ok (ok > 0), -1 otherwise
1264 1.1 jtc */
1265 1.1 jtc
1266 1.1 jtc static int
1267 1.1 jtc get_phys(void)
1268 1.1 jtc {
1269 1.6 tls int padsz = 0;
1270 1.6 tls int res;
1271 1.6 tls int phyblk;
1272 1.1 jtc struct mtop mb;
1273 1.1 jtc char scbuf[MAXBLK];
1274 1.1 jtc
1275 1.1 jtc /*
1276 1.1 jtc * move to the file mark, and then back up one record and read it.
1277 1.1 jtc * this should tell us the physical record size the tape is using.
1278 1.1 jtc */
1279 1.1 jtc if (lstrval == 1) {
1280 1.1 jtc /*
1281 1.1 jtc * we know we are at file mark when we get back a 0 from
1282 1.1 jtc * read()
1283 1.1 jtc */
1284 1.24 thorpej #ifdef SUPPORT_RMT
1285 1.24 thorpej while ((res = rmtread_with_restart(arfd,
1286 1.24 thorpej scbuf, sizeof(scbuf))) > 0)
1287 1.24 thorpej #else
1288 1.24 thorpej while ((res = read_with_restart(arfd,
1289 1.24 thorpej scbuf, sizeof(scbuf))) > 0)
1290 1.24 thorpej #endif /* SUPPORT_RMT */
1291 1.1 jtc padsz += res;
1292 1.1 jtc if (res < 0) {
1293 1.1 jtc syswarn(1, errno, "Unable to locate tape filemark.");
1294 1.1 jtc return(-1);
1295 1.1 jtc }
1296 1.1 jtc }
1297 1.1 jtc
1298 1.1 jtc /*
1299 1.1 jtc * move backwards over the file mark so we are at the end of the
1300 1.1 jtc * last record.
1301 1.1 jtc */
1302 1.1 jtc mb.mt_op = MTBSF;
1303 1.1 jtc mb.mt_count = 1;
1304 1.24 thorpej if (
1305 1.24 thorpej #ifdef SUPPORT_RMT
1306 1.24 thorpej rmtioctl(arfd, MTIOCTOP, &mb)
1307 1.24 thorpej #else
1308 1.24 thorpej ioctl(arfd, MTIOCTOP, &mb)
1309 1.24 thorpej #endif /* SUPPORT_RMT */
1310 1.24 thorpej < 0) {
1311 1.1 jtc syswarn(1, errno, "Unable to backspace over tape filemark.");
1312 1.1 jtc return(-1);
1313 1.1 jtc }
1314 1.1 jtc
1315 1.1 jtc /*
1316 1.1 jtc * move backwards so we are in front of the last record and read it to
1317 1.1 jtc * get physical tape blocksize.
1318 1.1 jtc */
1319 1.1 jtc mb.mt_op = MTBSR;
1320 1.1 jtc mb.mt_count = 1;
1321 1.24 thorpej if (
1322 1.24 thorpej #ifdef SUPPORT_RMT
1323 1.24 thorpej rmtioctl(arfd, MTIOCTOP, &mb)
1324 1.24 thorpej #else
1325 1.24 thorpej ioctl(arfd, MTIOCTOP, &mb)
1326 1.24 thorpej #endif /* SUPPORT_RMT */
1327 1.24 thorpej < 0) {
1328 1.1 jtc syswarn(1, errno, "Unable to backspace over last tape block.");
1329 1.1 jtc return(-1);
1330 1.1 jtc }
1331 1.24 thorpej if ((phyblk =
1332 1.24 thorpej #ifdef SUPPORT_RMT
1333 1.24 thorpej rmtread_with_restart(arfd, scbuf, sizeof(scbuf))
1334 1.24 thorpej #else
1335 1.24 thorpej read_with_restart(arfd, scbuf, sizeof(scbuf))
1336 1.24 thorpej #endif /* SUPPORT_RMT */
1337 1.24 thorpej ) <= 0) {
1338 1.1 jtc syswarn(1, errno, "Cannot determine archive tape blocksize.");
1339 1.1 jtc return(-1);
1340 1.1 jtc }
1341 1.1 jtc
1342 1.1 jtc /*
1343 1.17 itohy * read forward to the file mark, then back up in front of the filemark
1344 1.1 jtc * (this is a bit paranoid, but should be safe to do).
1345 1.1 jtc */
1346 1.24 thorpej while ((res =
1347 1.24 thorpej #ifdef SUPPORT_RMT
1348 1.24 thorpej rmtread_with_restart(arfd, scbuf, sizeof(scbuf))
1349 1.24 thorpej #else
1350 1.24 thorpej read_with_restart(arfd, scbuf, sizeof(scbuf))
1351 1.24 thorpej #endif /* SUPPORT_RMT */
1352 1.24 thorpej ) > 0)
1353 1.1 jtc ;
1354 1.1 jtc if (res < 0) {
1355 1.1 jtc syswarn(1, errno, "Unable to locate tape filemark.");
1356 1.1 jtc return(-1);
1357 1.1 jtc }
1358 1.1 jtc mb.mt_op = MTBSF;
1359 1.1 jtc mb.mt_count = 1;
1360 1.24 thorpej if (
1361 1.24 thorpej #ifdef SUPPORT_RMT
1362 1.24 thorpej rmtioctl(arfd, MTIOCTOP, &mb)
1363 1.24 thorpej #else
1364 1.24 thorpej ioctl(arfd, MTIOCTOP, &mb)
1365 1.24 thorpej #endif /* SUPPORT_RMT */
1366 1.24 thorpej < 0) {
1367 1.1 jtc syswarn(1, errno, "Unable to backspace over tape filemark.");
1368 1.1 jtc return(-1);
1369 1.1 jtc }
1370 1.1 jtc
1371 1.1 jtc /*
1372 1.1 jtc * set lstrval so we know that the filemark has not been seen
1373 1.1 jtc */
1374 1.1 jtc lstrval = 1;
1375 1.1 jtc
1376 1.1 jtc /*
1377 1.1 jtc * return if there was no padding
1378 1.1 jtc */
1379 1.1 jtc if (padsz == 0)
1380 1.1 jtc return(phyblk);
1381 1.1 jtc
1382 1.1 jtc /*
1383 1.1 jtc * make sure we can move backwards over the padding. (this should
1384 1.1 jtc * never fail).
1385 1.1 jtc */
1386 1.1 jtc if (padsz % phyblk) {
1387 1.7 christos tty_warn(1, "Tape drive unable to backspace requested amount");
1388 1.1 jtc return(-1);
1389 1.1 jtc }
1390 1.1 jtc
1391 1.1 jtc /*
1392 1.1 jtc * move backwards over the padding so the head is where it was when
1393 1.1 jtc * we were first called (if required).
1394 1.1 jtc */
1395 1.1 jtc mb.mt_op = MTBSR;
1396 1.1 jtc mb.mt_count = padsz/phyblk;
1397 1.24 thorpej if (
1398 1.24 thorpej #ifdef SUPPORT_RMT
1399 1.24 thorpej rmtioctl(arfd, MTIOCTOP, &mb)
1400 1.24 thorpej #else
1401 1.24 thorpej ioctl(arfd, MTIOCTOP, &mb)
1402 1.24 thorpej #endif /* SUPPORT_RMT */
1403 1.24 thorpej < 0) {
1404 1.32 grant syswarn(1, errno,
1405 1.32 grant "Unable to backspace tape over %ld pad blocks",
1406 1.11 christos (long)mb.mt_count);
1407 1.1 jtc return(-1);
1408 1.1 jtc }
1409 1.1 jtc return(phyblk);
1410 1.1 jtc }
1411 1.1 jtc
1412 1.1 jtc /*
1413 1.1 jtc * ar_next()
1414 1.1 jtc * prompts the user for the next volume in this archive. For some devices
1415 1.1 jtc * we may allow the media to be changed. Otherwise a new archive is
1416 1.1 jtc * prompted for. By pax spec, if there is no controlling tty or an eof is
1417 1.1 jtc * read on tty input, we must quit pax.
1418 1.1 jtc * Return:
1419 1.1 jtc * 0 when ready to continue, -1 when all done
1420 1.1 jtc */
1421 1.1 jtc
1422 1.1 jtc int
1423 1.1 jtc ar_next(void)
1424 1.1 jtc {
1425 1.1 jtc char buf[PAXPATHLEN+2];
1426 1.1 jtc static int freeit = 0;
1427 1.1 jtc sigset_t o_mask;
1428 1.1 jtc
1429 1.1 jtc /*
1430 1.1 jtc * WE MUST CLOSE THE DEVICE. A lot of devices must see last close, (so
1431 1.1 jtc * things like writing EOF etc will be done) (Watch out ar_close() can
1432 1.1 jtc * also be called via a signal handler, so we must prevent a race.
1433 1.1 jtc */
1434 1.1 jtc if (sigprocmask(SIG_BLOCK, &s_mask, &o_mask) < 0)
1435 1.1 jtc syswarn(0, errno, "Unable to set signal mask");
1436 1.1 jtc ar_close();
1437 1.1 jtc if (sigprocmask(SIG_SETMASK, &o_mask, (sigset_t *)NULL) < 0)
1438 1.1 jtc syswarn(0, errno, "Unable to restore signal mask");
1439 1.1 jtc
1440 1.34 christos if (done || !wr_trail || force_one_volume)
1441 1.1 jtc return(-1);
1442 1.1 jtc
1443 1.35 christos if (!is_gnutar)
1444 1.35 christos tty_prnt("\nATTENTION! %s archive volume change required.\n",
1445 1.35 christos argv0);
1446 1.1 jtc
1447 1.1 jtc /*
1448 1.1 jtc * if i/o is on stdin or stdout, we cannot reopen it (we do not know
1449 1.1 jtc * the name), the user will be forced to type it in.
1450 1.1 jtc */
1451 1.1 jtc if (strcmp(arcname, STDO) && strcmp(arcname, STDN) && (artyp != ISREG)
1452 1.1 jtc && (artyp != ISPIPE)) {
1453 1.24 thorpej if (artyp == ISTAPE
1454 1.24 thorpej #ifdef SUPPORT_RMT
1455 1.24 thorpej || artyp == ISRMT
1456 1.24 thorpej #endif /* SUPPORT_RMT */
1457 1.24 thorpej ) {
1458 1.1 jtc tty_prnt("%s ready for archive tape volume: %d\n",
1459 1.1 jtc arcname, arvol);
1460 1.1 jtc tty_prnt("Load the NEXT TAPE on the tape drive");
1461 1.1 jtc } else {
1462 1.1 jtc tty_prnt("%s ready for archive volume: %d\n",
1463 1.1 jtc arcname, arvol);
1464 1.1 jtc tty_prnt("Load the NEXT STORAGE MEDIA (if required)");
1465 1.1 jtc }
1466 1.1 jtc
1467 1.1 jtc if ((act == ARCHIVE) || (act == APPND))
1468 1.1 jtc tty_prnt(" and make sure it is WRITE ENABLED.\n");
1469 1.1 jtc else
1470 1.1 jtc tty_prnt("\n");
1471 1.1 jtc
1472 1.1 jtc for(;;) {
1473 1.1 jtc tty_prnt("Type \"y\" to continue, \".\" to quit %s,",
1474 1.1 jtc argv0);
1475 1.1 jtc tty_prnt(" or \"s\" to switch to new device.\nIf you");
1476 1.1 jtc tty_prnt(" cannot change storage media, type \"s\"\n");
1477 1.1 jtc tty_prnt("Is the device ready and online? > ");
1478 1.1 jtc
1479 1.1 jtc if ((tty_read(buf,sizeof(buf))<0) || !strcmp(buf,".")){
1480 1.1 jtc done = 1;
1481 1.1 jtc lstrval = -1;
1482 1.1 jtc tty_prnt("Quitting %s!\n", argv0);
1483 1.1 jtc vfpart = 0;
1484 1.1 jtc return(-1);
1485 1.1 jtc }
1486 1.1 jtc
1487 1.1 jtc if ((buf[0] == '\0') || (buf[1] != '\0')) {
1488 1.1 jtc tty_prnt("%s unknown command, try again\n",buf);
1489 1.1 jtc continue;
1490 1.1 jtc }
1491 1.1 jtc
1492 1.1 jtc switch (buf[0]) {
1493 1.1 jtc case 'y':
1494 1.1 jtc case 'Y':
1495 1.1 jtc /*
1496 1.1 jtc * we are to continue with the same device
1497 1.1 jtc */
1498 1.17 itohy if (ar_open(arcname) >= 0)
1499 1.1 jtc return(0);
1500 1.1 jtc tty_prnt("Cannot re-open %s, try again\n",
1501 1.1 jtc arcname);
1502 1.1 jtc continue;
1503 1.1 jtc case 's':
1504 1.1 jtc case 'S':
1505 1.1 jtc /*
1506 1.1 jtc * user wants to open a different device
1507 1.1 jtc */
1508 1.1 jtc tty_prnt("Switching to a different archive\n");
1509 1.1 jtc break;
1510 1.1 jtc default:
1511 1.1 jtc tty_prnt("%s unknown command, try again\n",buf);
1512 1.1 jtc continue;
1513 1.1 jtc }
1514 1.1 jtc break;
1515 1.1 jtc }
1516 1.35 christos } else {
1517 1.35 christos if (is_gnutar) {
1518 1.35 christos tty_warn(1, "Unexpected EOF on archive file");
1519 1.35 christos return -1;
1520 1.35 christos }
1521 1.1 jtc tty_prnt("Ready for archive volume: %d\n", arvol);
1522 1.35 christos }
1523 1.1 jtc
1524 1.1 jtc /*
1525 1.1 jtc * have to go to a different archive
1526 1.1 jtc */
1527 1.1 jtc for (;;) {
1528 1.1 jtc tty_prnt("Input archive name or \".\" to quit %s.\n", argv0);
1529 1.1 jtc tty_prnt("Archive name > ");
1530 1.1 jtc
1531 1.1 jtc if ((tty_read(buf, sizeof(buf)) < 0) || !strcmp(buf, ".")) {
1532 1.1 jtc done = 1;
1533 1.1 jtc lstrval = -1;
1534 1.1 jtc tty_prnt("Quitting %s!\n", argv0);
1535 1.1 jtc vfpart = 0;
1536 1.1 jtc return(-1);
1537 1.1 jtc }
1538 1.1 jtc if (buf[0] == '\0') {
1539 1.1 jtc tty_prnt("Empty file name, try again\n");
1540 1.1 jtc continue;
1541 1.1 jtc }
1542 1.17 itohy if (!strcmp(buf, "..")) {
1543 1.17 itohy tty_prnt("Illegal file name: .. try again\n");
1544 1.17 itohy continue;
1545 1.17 itohy }
1546 1.1 jtc if (strlen(buf) > PAXPATHLEN) {
1547 1.1 jtc tty_prnt("File name too long, try again\n");
1548 1.1 jtc continue;
1549 1.1 jtc }
1550 1.1 jtc
1551 1.1 jtc /*
1552 1.1 jtc * try to open new archive
1553 1.1 jtc */
1554 1.1 jtc if (ar_open(buf) >= 0) {
1555 1.1 jtc if (freeit) {
1556 1.9 mycroft (void)free((char *)arcname);
1557 1.1 jtc freeit = 0;
1558 1.1 jtc }
1559 1.1 jtc if ((arcname = strdup(buf)) == NULL) {
1560 1.1 jtc done = 1;
1561 1.1 jtc lstrval = -1;
1562 1.7 christos tty_warn(0, "Cannot save archive name.");
1563 1.1 jtc return(-1);
1564 1.1 jtc }
1565 1.1 jtc freeit = 1;
1566 1.1 jtc break;
1567 1.1 jtc }
1568 1.1 jtc tty_prnt("Cannot open %s, try again\n", buf);
1569 1.1 jtc continue;
1570 1.1 jtc }
1571 1.1 jtc return(0);
1572 1.5 mrg }
1573 1.5 mrg
1574 1.5 mrg /*
1575 1.5 mrg * ar_start_gzip()
1576 1.33 wiz * starts the compression/decompression process as a child, using magic
1577 1.33 wiz * to keep the fd the same in the calling function (parent). possible
1578 1.33 wiz * programs are GZIP_CMD, BZIP2_CMD, and COMPRESS_CMD.
1579 1.5 mrg */
1580 1.5 mrg void
1581 1.23 christos ar_start_gzip(int fd, const char *gzp, int wr)
1582 1.5 mrg {
1583 1.5 mrg int fds[2];
1584 1.20 lukem const char *gzip_flags;
1585 1.5 mrg
1586 1.5 mrg if (pipe(fds) < 0)
1587 1.5 mrg err(1, "could not pipe");
1588 1.23 christos zpid = fork();
1589 1.23 christos if (zpid < 0)
1590 1.5 mrg err(1, "could not fork");
1591 1.5 mrg
1592 1.5 mrg /* parent */
1593 1.23 christos if (zpid) {
1594 1.23 christos if (wr)
1595 1.5 mrg dup2(fds[1], fd);
1596 1.23 christos else
1597 1.5 mrg dup2(fds[0], fd);
1598 1.5 mrg close(fds[0]);
1599 1.5 mrg close(fds[1]);
1600 1.5 mrg } else {
1601 1.23 christos if (wr) {
1602 1.5 mrg dup2(fds[0], STDIN_FILENO);
1603 1.5 mrg dup2(fd, STDOUT_FILENO);
1604 1.5 mrg gzip_flags = "-c";
1605 1.23 christos } else {
1606 1.5 mrg dup2(fds[1], STDOUT_FILENO);
1607 1.5 mrg dup2(fd, STDIN_FILENO);
1608 1.5 mrg gzip_flags = "-dc";
1609 1.5 mrg }
1610 1.5 mrg close(fds[0]);
1611 1.5 mrg close(fds[1]);
1612 1.23 christos if (execlp(gzp, gzp, gzip_flags, NULL) < 0)
1613 1.5 mrg err(1, "could not exec");
1614 1.5 mrg /* NOTREACHED */
1615 1.5 mrg }
1616 1.13 christos }
1617 1.13 christos
1618 1.13 christos static const char *
1619 1.13 christos timefmt(buf, size, sz, tm)
1620 1.13 christos char *buf;
1621 1.13 christos size_t size;
1622 1.13 christos off_t sz;
1623 1.13 christos time_t tm;
1624 1.13 christos {
1625 1.20 lukem (void)snprintf(buf, size, "%lu secs (" OFFT_F " bytes/sec)",
1626 1.20 lukem (unsigned long)tm, (OFFT_T)(sz / tm));
1627 1.13 christos return buf;
1628 1.13 christos }
1629 1.13 christos
1630 1.13 christos static const char *
1631 1.13 christos sizefmt(buf, size, sz)
1632 1.13 christos char *buf;
1633 1.13 christos size_t size;
1634 1.13 christos off_t sz;
1635 1.13 christos {
1636 1.20 lukem (void)snprintf(buf, size, OFFT_F " bytes", (OFFT_T)sz);
1637 1.13 christos return buf;
1638 1.13 christos }
1639 1.13 christos
1640 1.13 christos void
1641 1.13 christos ar_summary(int n)
1642 1.13 christos {
1643 1.13 christos time_t secs;
1644 1.13 christos int len;
1645 1.13 christos char buf[MAXPATHLEN];
1646 1.13 christos char tbuf[MAXPATHLEN/4];
1647 1.13 christos char s1buf[MAXPATHLEN/8];
1648 1.13 christos char s2buf[MAXPATHLEN/8];
1649 1.13 christos FILE *outf;
1650 1.13 christos
1651 1.13 christos if (act == LIST)
1652 1.13 christos outf = stdout;
1653 1.13 christos else
1654 1.13 christos outf = stderr;
1655 1.13 christos
1656 1.13 christos /*
1657 1.13 christos * If we are called from a signal (n != 0), use snprintf(3) so that we
1658 1.13 christos * don't reenter stdio(3).
1659 1.13 christos */
1660 1.13 christos (void)time(&secs);
1661 1.13 christos if ((secs -= starttime) == 0)
1662 1.13 christos secs = 1;
1663 1.13 christos
1664 1.13 christos /*
1665 1.13 christos * If we have not determined the format yet, we just say how many bytes
1666 1.13 christos * we have skipped over looking for a header to id. there is no way we
1667 1.13 christos * could have written anything yet.
1668 1.13 christos */
1669 1.13 christos if (frmt == NULL) {
1670 1.17 itohy len = snprintf(buf, sizeof(buf),
1671 1.13 christos "unknown format, %s skipped in %s\n",
1672 1.13 christos sizefmt(s1buf, sizeof(s1buf), rdcnt),
1673 1.13 christos timefmt(tbuf, sizeof(tbuf), rdcnt, secs));
1674 1.13 christos if (n == 0)
1675 1.13 christos (void)fprintf(outf, "%s: %s", argv0, buf);
1676 1.17 itohy else
1677 1.13 christos (void)write(STDERR_FILENO, buf, len);
1678 1.13 christos return;
1679 1.13 christos }
1680 1.13 christos
1681 1.13 christos
1682 1.13 christos if (n != 0) {
1683 1.13 christos len = snprintf(buf, sizeof(buf), "Working on `%s' (%s)\n",
1684 1.13 christos archd.name, sizefmt(s1buf, sizeof(s1buf), archd.sb.st_size));
1685 1.13 christos (void)write(STDERR_FILENO, buf, len);
1686 1.13 christos }
1687 1.13 christos
1688 1.13 christos
1689 1.13 christos len = snprintf(buf, sizeof(buf),
1690 1.13 christos "%s vol %d, %lu files, %s read, %s written in %s\n",
1691 1.13 christos frmt->name, arvol-1, (unsigned long)flcnt,
1692 1.13 christos sizefmt(s1buf, sizeof(s1buf), rdcnt),
1693 1.13 christos sizefmt(s2buf, sizeof(s2buf), wrcnt),
1694 1.13 christos timefmt(tbuf, sizeof(tbuf), rdcnt + wrcnt, secs));
1695 1.13 christos if (n == 0)
1696 1.13 christos (void)fprintf(outf, "%s: %s", argv0, buf);
1697 1.13 christos else
1698 1.13 christos (void)write(STDERR_FILENO, buf, strlen(buf));
1699 1.14 is }
1700 1.14 is
1701 1.14 is /*
1702 1.14 is * ar_dochdir(name)
1703 1.14 is * change directory to name, and remember where we came from and
1704 1.14 is * where we change to (for ar_open).
1705 1.14 is *
1706 1.14 is * Maybe we could try to be smart and only do the actual chdir
1707 1.14 is * when necessary to write a file read from the archive, but this
1708 1.14 is * is not easy to get right given the pax code structure.
1709 1.14 is *
1710 1.14 is * Be sure to not leak descriptors!
1711 1.14 is *
1712 1.14 is * We are called N * M times when extracting, and N times when
1713 1.14 is * writing archives, where
1714 1.14 is * N: number of -C options
1715 1.14 is * M: number of files in archive
1716 1.17 itohy *
1717 1.14 is * Returns 0 if all went well, else -1.
1718 1.14 is */
1719 1.14 is
1720 1.14 is int
1721 1.14 is ar_dochdir(char *name)
1722 1.14 is {
1723 1.23 christos /* First fchdir() back... */
1724 1.23 christos if (fchdir(cwdfd) < 0) {
1725 1.23 christos syswarn(1, errno, "Can't fchdir to starting directory");
1726 1.23 christos return(-1);
1727 1.14 is }
1728 1.23 christos if (chdir(name) < 0) {
1729 1.23 christos syswarn(1, errno, "Can't chdir to %s", name);
1730 1.23 christos return(-1);
1731 1.14 is }
1732 1.14 is return (0);
1733 1.1 jtc }
1734