xref: /illumos-gate/usr/src/cmd/fs.d/umount.c (revision c65ebfc7045424bd04a6c7719a27b0ad3399ad54)
1 /*
2  * CDDL HEADER START
3  *
4  * The contents of this file are subject to the terms of the
5  * Common Development and Distribution License (the "License").
6  * You may not use this file except in compliance with the License.
7  *
8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9  * or http://www.opensolaris.org/os/licensing.
10  * See the License for the specific language governing permissions
11  * and limitations under the License.
12  *
13  * When distributing Covered Code, include this CDDL HEADER in each
14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15  * If applicable, add the following below this CDDL HEADER, with the
16  * fields enclosed by brackets "[]" replaced with your own identifying
17  * information: Portions Copyright [yyyy] [name of copyright owner]
18  *
19  * CDDL HEADER END
20  */
21 /*
22  * Copyright 2010 Sun Microsystems, Inc.  All rights reserved.
23  * Use is subject to license terms.
24  * Copyright 2015 Nexenta Systems, Inc. All rights reserved.
25  */
26 
27 /*	Copyright (c) 1984, 1986, 1987, 1988, 1989 AT&T	*/
28 /*	  All Rights Reserved  	*/
29 
30 
31 #include	<stdio.h>
32 #include	<stdio_ext.h>
33 #include	<limits.h>
34 #include	<unistd.h>
35 #include	<stdlib.h>
36 #include	<string.h>
37 #include	<sys/signal.h>
38 #include	<sys/mnttab.h>
39 #include	<errno.h>
40 #include	<sys/types.h>
41 #include	<sys/stat.h>
42 #include	<sys/param.h>
43 #include	<sys/wait.h>
44 #include	<sys/vfstab.h>
45 #include	<sys/fcntl.h>
46 #include	<sys/resource.h>
47 #include	<sys/mntent.h>
48 #include	<sys/ctfs.h>
49 #include	<locale.h>
50 #include	<stdarg.h>
51 #include	<sys/mount.h>
52 #include	<sys/objfs.h>
53 #include	"fslib.h"
54 #include	<sharefs/share.h>
55 
56 #define	FS_PATH		"/usr/lib/fs"
57 #define	ALT_PATH	"/etc/fs"
58 #define	FULLPATH_MAX	32
59 #define	FSTYPE_MAX	8
60 #define	ARGV_MAX	16
61 
62 int	aflg, oflg, Vflg, dashflg, dflg, fflg;
63 
64 extern void	rpterr(), usage(), mnterror();
65 
66 extern	char	*optarg;	/* used by getopt */
67 extern	int	optind, opterr;
68 
69 static char	*myname;
70 char	fs_path[] = FS_PATH;
71 char	alt_path[] = ALT_PATH;
72 char	mnttab[MAXPATHLEN + 1];
73 char	*oarg, *farg;
74 int	maxrun, nrun;
75 int	no_mnttab;
76 int	lofscnt;		/* presence of lofs prohibits parallel */
77 				/* umounting */
78 int	exitcode;
79 char	resolve[MAXPATHLEN];
80 static  char ibuf[BUFSIZ];
81 
82 /*
83  * The basic mount struct that describes an mnttab entry.
84  * It is used both in an array and as a linked list elem.
85  */
86 
87 typedef struct mountent {
88 	struct mnttab	ment;		/* the mnttab data */
89 	int		mlevel;		/* mount level of the mount pt */
90 	pid_t		pid;		/* the pid of this mount process */
91 #define	RDPIPE		0
92 #define	WRPIPE		1
93 	int		sopipe[2];	/* pipe attached to child's stdout */
94 	int		sepipe[2];	/* pipe attached to child's stderr */
95 	struct mountent *link;		/* used when in linked list */
96 } mountent_t;
97 
98 static mountent_t	*mntll;		/* head of global linked list of */
99 					/* mountents */
100 int			listlength;	/* # of elems in this list */
101 
102 /*
103  * If the automatic flag (-a) is given and mount points are not specified
104  * on the command line, then do not attempt to umount these.  These
105  * generally need to be kept mounted until system shutdown.
106  */
107 static const char   *keeplist[] = {
108 	"/",
109 	"/dev",
110 	"/dev/fd",
111 	"/devices",
112 	"/etc/mnttab",
113 	"/etc/svc/volatile",
114 	"/lib",
115 	"/proc",
116 	"/sbin",
117 	CTFS_ROOT,
118 	OBJFS_ROOT,
119 	"/tmp",
120 	"/usr",
121 	"/var",
122 	"/var/adm",
123 	"/var/run",
124 	SHARETAB,
125 	NULL
126 };
127 
128 static void	nomem();
129 static void	doexec(struct mnttab *);
130 static int	setup_iopipe(mountent_t *);
131 static void	setup_output(mountent_t *);
132 static void	doio(mountent_t *);
133 static void	do_umounts(mountent_t **);
134 static int	dowait();
135 static int	parumount();
136 static int	mcompar(const void *, const void *);
137 static void	cleanup(int);
138 
139 static mountent_t	**make_mntarray(char **, int);
140 static mountent_t	*getmntall();
141 static mountent_t 	*new_mountent(struct mnttab *);
142 static mountent_t	*getmntlast(mountent_t *, char *, char *);
143 
144 int
145 main(int argc, char **argv)
146 {
147 	int 	cc;
148 	struct mnttab  mget;
149 	char 	*mname, *is_special;
150 	int	fscnt;
151 	mountent_t	*mp;
152 
153 	(void) setlocale(LC_ALL, "");
154 
155 #if !defined(TEXT_DOMAIN)
156 #define	TEXT_DOMAIN "SYS_TEST"
157 #endif
158 	(void) textdomain(TEXT_DOMAIN);
159 
160 	myname = strrchr(argv[0], '/');
161 	if (myname)
162 		myname++;
163 	else
164 		myname = argv[0];
165 
166 	/*
167 	 * Process the args.
168 	 * "-d" for compatibility
169 	 */
170 	while ((cc = getopt(argc, argv, "ado:Vf?")) != -1)
171 		switch (cc) {
172 		case 'a':
173 			aflg++;
174 			break;
175 #ifdef DEBUG
176 		case 'd':
177 			dflg++;
178 			break;
179 #endif
180 
181 		case '?':
182 			usage();
183 			break;
184 		case 'o':
185 			if (oflg)
186 				usage();
187 			else {
188 				oflg++;
189 				oarg = optarg;
190 			}
191 			break;
192 		case 'f':
193 			fflg++;
194 			break;
195 		case 'V':
196 			if (Vflg)
197 				usage();
198 			else
199 				Vflg++;
200 			break;
201 		default:
202 			usage();
203 			break;
204 		}
205 
206 	fscnt = argc - optind;
207 	if (!aflg && fscnt != 1)
208 		usage();
209 
210 	/* copy '--' to specific */
211 	if (strcmp(argv[optind-1], "--") == 0)
212 		dashflg++;
213 
214 	/*
215 	 * mnttab may be a symlink to a file in another file system.
216 	 * This happens during install when / is mounted read-only
217 	 * and /etc/mnttab is symlinked to a file in /tmp.
218 	 * If this is the case, we need to follow the symlink to the
219 	 * read-write file itself so that the subsequent mnttab.temp
220 	 * open and rename will work.
221 	 */
222 	if (realpath(MNTTAB, mnttab) == NULL) {
223 		strcpy(mnttab, MNTTAB);
224 	}
225 
226 	/*
227 	 * bugid 1205242
228 	 * call the realpath() here, so that if the user is
229 	 * trying to umount an autofs directory, the directory
230 	 * is forced to mount.
231 	 */
232 
233 	mname = argv[optind];
234 	is_special = realpath(mname, resolve);
235 
236 	/*
237 	 * Read the whole mnttab into memory.
238 	 */
239 	mntll = getmntall();
240 
241 	if (aflg && fscnt != 1)
242 		exit(parumount(argv + optind, fscnt));
243 
244 	aflg = 0;
245 
246 	mntnull(&mget);
247 	if (listlength == 0) {
248 		fprintf(stderr, gettext(
249 		    "%s: warning: no entries found in %s\n"),
250 		    myname, mnttab);
251 		mget.mnt_mountp = mname;	/* assume mount point */
252 		no_mnttab++;
253 		doexec(&mget);
254 		exit(0);
255 	}
256 
257 	mp = NULL;
258 
259 	/*
260 	 * if realpath fails, it can't be a mount point, so we'll
261 	 * go straight to the code that treats the arg as a special.
262 	 * if realpath succeeds, it could be a special or a mount point;
263 	 * we'll start by assuming it's a mount point, and if it's not,
264 	 * try to treat it as a special.
265 	 */
266 	if (is_special != NULL) {
267 		/*
268 		 * if this succeeds,
269 		 * we'll have the appropriate record; if it fails
270 		 * we'll assume the arg is a special of some sort
271 		 */
272 		mp = getmntlast(mntll, NULL, resolve);
273 	}
274 	/*
275 	 * Since stackable mount is allowed (RFE 2001535),
276 	 * we will un-mount the last entry in the MNTTAB that matches.
277 	 */
278 	if (mp == NULL) {
279 		/*
280 		 * Perhaps there is a bogus mnttab entry that
281 		 * can't be resolved:
282 		 */
283 		if ((mp = getmntlast(mntll, NULL, mname)) == NULL)
284 			/*
285 			 * assume it's a device (special) now
286 			 */
287 			mp = getmntlast(mntll, mname, NULL);
288 		if (mp) {
289 			/*
290 			 * Found it.
291 			 * This is a device. Now we want to know if
292 			 * it stackmounted on by something else.
293 			 * The original fix for bug 1103850 has a
294 			 * problem with lockfs (bug 1119731). This
295 			 * is a revised method.
296 			 */
297 			mountent_t *lmp;
298 			lmp = getmntlast(mntll, NULL, mp->ment.mnt_mountp);
299 
300 			if (lmp && strcmp(lmp->ment.mnt_special,
301 			    mp->ment.mnt_special)) {
302 				errno = EBUSY;
303 				rpterr(mname);
304 				exit(1);
305 			}
306 		} else {
307 			fprintf(stderr, gettext(
308 			    "%s: warning: %s not in mnttab\n"),
309 			    myname, mname);
310 			if (Vflg)
311 				exit(1);
312 				/*
313 				 * same error as mount -V
314 				 * would give for unknown
315 				 * mount point
316 				 */
317 			mget.mnt_special = mget.mnt_mountp = mname;
318 		}
319 	}
320 
321 	if (mp)
322 		doexec(&mp->ment);
323 	else
324 		doexec(&mget);
325 
326 	return (0);
327 }
328 
329 void
330 doexec(struct mnttab *ment)
331 {
332 	int 	ret;
333 
334 #ifdef DEBUG
335 	if (dflg)
336 		fprintf(stderr, "%d: umounting %s\n",
337 		    getpid(), ment->mnt_mountp);
338 #endif
339 
340 	/* try to exec the dependent portion */
341 	if ((ment->mnt_fstype != NULL) || Vflg) {
342 		char	full_path[FULLPATH_MAX];
343 		char	alter_path[FULLPATH_MAX];
344 		char	*newargv[ARGV_MAX];
345 		int 	ii;
346 
347 		if (strlen(ment->mnt_fstype) > (size_t)FSTYPE_MAX) {
348 			fprintf(stderr, gettext(
349 			    "%s: FSType %s exceeds %d characters\n"),
350 			    myname, ment->mnt_fstype, FSTYPE_MAX);
351 			exit(1);
352 		}
353 
354 		/* build the full pathname of the fstype dependent command. */
355 		sprintf(full_path, "%s/%s/%s", fs_path, ment->mnt_fstype,
356 		    myname);
357 		sprintf(alter_path, "%s/%s/%s", alt_path, ment->mnt_fstype,
358 		    myname);
359 
360 		/*
361 		 * create the new arg list, and end the list with a
362 		 * null pointer
363 		 */
364 		ii = 2;
365 		if (oflg) {
366 			newargv[ii++] = "-o";
367 			newargv[ii++] = oarg;
368 		}
369 		if (dashflg) {
370 			newargv[ii++] = "--";
371 		}
372 		if (fflg) {
373 			newargv[ii++] = "-f";
374 		}
375 		newargv[ii++] = (ment->mnt_mountp)
376 		    ? ment->mnt_mountp : ment->mnt_special;
377 		newargv[ii] = NULL;
378 
379 		/* set the new argv[0] to the filename */
380 		newargv[1] = myname;
381 
382 		if (Vflg) {
383 			printf("%s", myname);
384 			for (ii = 2; newargv[ii]; ii++)
385 				printf(" %s", newargv[ii]);
386 			printf("\n");
387 			fflush(stdout);
388 			exit(0);
389 		}
390 
391 		/* Try to exec the fstype dependent umount. */
392 		execv(full_path, &newargv[1]);
393 		if (errno == ENOEXEC) {
394 			newargv[0] = "sh";
395 			newargv[1] = full_path;
396 			execv("/sbin/sh", &newargv[0]);
397 		}
398 		newargv[1] = myname;
399 		execv(alter_path, &newargv[1]);
400 		if (errno == ENOEXEC) {
401 			newargv[0] = "sh";
402 			newargv[1] = alter_path;
403 			execv("/sbin/sh", &newargv[0]);
404 		}
405 		/* exec failed */
406 		if (errno != ENOENT) {
407 			fprintf(stderr, gettext("umount: cannot execute %s\n"),
408 			    full_path);
409 			exit(1);
410 		}
411 	}
412 	/*
413 	 * No fstype independent executable then.  We'll go generic
414 	 * from here.
415 	 */
416 
417 	/* don't use -o with generic */
418 	if (oflg) {
419 		fprintf(stderr, gettext(
420 		    "%s: %s specific umount does not exist;"
421 		    " -o suboption ignored\n"),
422 		    myname, ment->mnt_fstype ? ment->mnt_fstype : "<null>");
423 	}
424 
425 	signal(SIGHUP,  SIG_IGN);
426 	signal(SIGQUIT, SIG_IGN);
427 	signal(SIGINT,  SIG_IGN);
428 	/*
429 	 * Try to umount the mountpoint.
430 	 * If that fails, try the corresponding special.
431 	 * (This ordering is necessary for nfs umounts.)
432 	 * (for remote resources:  if the first umount returns EBUSY
433 	 * don't call umount again - umount() with a resource name
434 	 * will return a misleading error to the user
435 	 */
436 	if (fflg) {
437 		if (((ret = umount2(ment->mnt_mountp, MS_FORCE)) < 0) &&
438 		    (errno != EBUSY && errno != ENOTSUP &&
439 		    errno != EPERM))
440 			ret = umount2(ment->mnt_special, MS_FORCE);
441 	} else {
442 		if (((ret = umount2(ment->mnt_mountp, 0)) < 0) &&
443 		    (errno != EBUSY) && (errno != EPERM))
444 			ret = umount2(ment->mnt_special, 0);
445 	}
446 
447 	if (ret < 0) {
448 		rpterr(ment->mnt_mountp);
449 		if (errno != EINVAL && errno != EFAULT)
450 			exit(1);
451 
452 		exitcode = 1;
453 	}
454 
455 	exit(exitcode);
456 }
457 
458 void
459 rpterr(char *sp)
460 {
461 	switch (errno) {
462 	case EPERM:
463 		fprintf(stderr, gettext("%s: permission denied\n"), myname);
464 		break;
465 	case ENXIO:
466 		fprintf(stderr, gettext("%s: %s no device\n"), myname, sp);
467 		break;
468 	case ENOENT:
469 		fprintf(stderr,
470 		    gettext("%s: %s no such file or directory\n"),
471 		    myname, sp);
472 		break;
473 	case EINVAL:
474 		fprintf(stderr, gettext("%s: %s not mounted\n"), myname, sp);
475 		break;
476 	case EBUSY:
477 		fprintf(stderr, gettext("%s: %s busy\n"), myname, sp);
478 		break;
479 	case ENOTBLK:
480 		fprintf(stderr,
481 		    gettext("%s: %s block device required\n"), myname, sp);
482 		break;
483 	case ECOMM:
484 		fprintf(stderr,
485 		    gettext("%s: warning: broken link detected\n"), myname);
486 		break;
487 	default:
488 		perror(myname);
489 		fprintf(stderr, gettext("%s: cannot unmount %s\n"), myname, sp);
490 	}
491 }
492 
493 void
494 usage(void)
495 {
496 	fprintf(stderr, gettext(
497 "Usage:\n%s [-f] [-V] [-o specific_options] {special | mount-point}\n"),
498 	    myname);
499 	fprintf(stderr, gettext(
500 "%s -a [-f] [-V] [-o specific_options] [mount_point ...]\n"), myname);
501 	exit(1);
502 }
503 
504 void
505 mnterror(int flag)
506 {
507 	switch (flag) {
508 	case MNT_TOOLONG:
509 		fprintf(stderr,
510 		    gettext("%s: line in mnttab exceeds %d characters\n"),
511 		    myname, MNT_LINE_MAX-2);
512 		break;
513 	case MNT_TOOFEW:
514 		fprintf(stderr,
515 		    gettext("%s: line in mnttab has too few entries\n"),
516 		    myname);
517 		break;
518 	default:
519 		break;
520 	}
521 }
522 
523 /*
524  * Search the mlist linked list for the
525  * first match of specp or mntp.  The list is expected to be in reverse
526  * order of /etc/mnttab.
527  * If both are specified, then both have to match.
528  * Returns the (mountent_t *) of the match, otherwise returns NULL.
529  */
530 mountent_t *
531 getmntlast(mountent_t *mlist, char *specp, char *mntp)
532 {
533 	int		mfound, sfound;
534 
535 	for (/* */; mlist; mlist = mlist->link) {
536 		mfound = sfound = 0;
537 		if (mntp && (strcmp(mlist->ment.mnt_mountp, mntp) == 0)) {
538 			if (specp == NULL)
539 				return (mlist);
540 			mfound++;
541 		}
542 		if (specp && (strcmp(mlist->ment.mnt_special, specp) == 0)) {
543 			if (mntp == NULL)
544 				return (mlist);
545 			sfound++;
546 		}
547 		if (mfound && sfound)
548 			return (mlist);
549 	}
550 	return (NULL);
551 }
552 
553 
554 
555 /*
556  * Perform the parallel version of umount.  Returns 0 if no errors occurred,
557  * non zero otherwise.
558  */
559 int
560 parumount(char **mntlist, int count)
561 {
562 	int 		maxfd = OPEN_MAX;
563 	struct rlimit 	rl;
564 	mountent_t	**mntarray, **ml, *mp;
565 
566 	/*
567 	 * If no mount points are specified and none were found in mnttab,
568 	 * then end it all here.
569 	 */
570 	if (count == 0 && mntll == NULL)
571 		return (0);
572 
573 	/*
574 	 * This is the process scaling section.  After running a series
575 	 * of tests based on the number of simultaneous processes and
576 	 * processors available, optimum performance was achieved near or
577 	 * at (PROCN * 2).
578 	 */
579 	if ((maxrun = sysconf(_SC_NPROCESSORS_ONLN)) == -1)
580 		maxrun = 4;
581 	else
582 		maxrun = maxrun * 2 + 1;
583 
584 	if (getrlimit(RLIMIT_NOFILE, &rl) == 0) {
585 		rl.rlim_cur = rl.rlim_max;
586 		if (setrlimit(RLIMIT_NOFILE, &rl) == 0)
587 			maxfd = (int)rl.rlim_cur;
588 		(void) enable_extended_FILE_stdio(-1, -1);
589 	}
590 
591 	/*
592 	 * The parent needs to maintain 3 of its own fd's, plus 2 for
593 	 * each child (the stdout and stderr pipes).
594 	 */
595 	maxfd = (maxfd / 2) - 6;	/* 6 takes care of temporary  */
596 					/* periods of open fds */
597 	if (maxfd < maxrun)
598 		maxrun = maxfd;
599 	if (maxrun < 4)
600 		maxrun = 4;		/* sanity check */
601 
602 	mntarray = make_mntarray(mntlist, count);
603 
604 	if (listlength == 0) {
605 		if (count == 0)		/* not an error, just none found */
606 			return (0);
607 		fprintf(stderr, gettext("%s: no valid entries found in %s\n"),
608 		    myname, mnttab);
609 		return (1);
610 	}
611 
612 	/*
613 	 * Sort the entries based on their mount level only if lofs's are
614 	 * not present.
615 	 */
616 	if (lofscnt == 0) {
617 		qsort((void *)mntarray, listlength, sizeof (mountent_t *),
618 		    mcompar);
619 		/*
620 		 * If we do not detect a lofs by now, we never will.
621 		 */
622 		lofscnt = -1;
623 	}
624 	/*
625 	 * Now link them up so that a given pid is easier to find when
626 	 * we go to clean up after they are done.
627 	 */
628 	mntll = mntarray[0];
629 	for (ml = mntarray; mp = *ml; /* */)
630 		mp->link = *++ml;
631 
632 	/*
633 	 * Try to handle interrupts in a reasonable way.
634 	 */
635 	sigset(SIGHUP, cleanup);
636 	sigset(SIGQUIT, cleanup);
637 	sigset(SIGINT, cleanup);
638 
639 	do_umounts(mntarray);	/* do the umounts */
640 	return (exitcode);
641 }
642 
643 /*
644  * Returns a mountent_t array based on mntlist.  If mntlist is NULL, then
645  * it returns all mnttab entries with a few exceptions.  Sets the global
646  * variable listlength to the number of entries in the array.
647  */
648 mountent_t **
649 make_mntarray(char **mntlist, int count)
650 {
651 	mountent_t 	*mp, **mpp;
652 	int 		ndx;
653 	char		*cp;
654 
655 	if (count > 0)
656 		listlength = count;
657 
658 	mpp = (mountent_t **)malloc(sizeof (*mp) * (listlength + 1));
659 	if (mpp == NULL)
660 		nomem();
661 
662 	if (count == 0) {
663 		if (mntll == NULL) {	/* no entries? */
664 			listlength = 0;
665 			return (NULL);
666 		}
667 		/*
668 		 * No mount list specified: take all mnttab mount points
669 		 * except for a few cases.
670 		 */
671 		for (ndx = 0, mp = mntll; mp; mp = mp->link) {
672 			if (fsstrinlist(mp->ment.mnt_mountp, keeplist))
673 				continue;
674 			mp->mlevel = fsgetmlevel(mp->ment.mnt_mountp);
675 			if (mp->ment.mnt_fstype &&
676 			    (strcmp(mp->ment.mnt_fstype, MNTTYPE_LOFS) == 0))
677 				lofscnt++;
678 
679 			mpp[ndx++] = mp;
680 		}
681 		mpp[ndx] = NULL;
682 		listlength = ndx;
683 		return (mpp);
684 	}
685 
686 	/*
687 	 * A list of mount points was specified on the command line.
688 	 * Build an array out of these.
689 	 */
690 	for (ndx = 0; count--; ) {
691 		cp = *mntlist++;
692 		if (realpath(cp, resolve) == NULL) {
693 			fprintf(stderr,
694 			    gettext("%s: warning: can't resolve %s\n"),
695 			    myname, cp);
696 			exitcode = 1;
697 			mp = getmntlast(mntll, NULL, cp); /* try anyways */
698 		} else
699 			mp = getmntlast(mntll, NULL, resolve);
700 		if (mp == NULL) {
701 			struct mnttab mnew;
702 			/*
703 			 * Then we've reached the end without finding
704 			 * what we are looking for, but we still have to
705 			 * try to umount it: append it to mntarray.
706 			 */
707 			fprintf(stderr, gettext(
708 			    "%s: warning: %s not found in %s\n"),
709 			    myname, resolve, mnttab);
710 			exitcode = 1;
711 			mntnull(&mnew);
712 			mnew.mnt_special = mnew.mnt_mountp = strdup(resolve);
713 			if (mnew.mnt_special == NULL)
714 				nomem();
715 			mp = new_mountent(&mnew);
716 		}
717 		if (mp->ment.mnt_fstype &&
718 		    (strcmp(mp->ment.mnt_fstype, MNTTYPE_LOFS) == 0))
719 			lofscnt++;
720 
721 		mp->mlevel = fsgetmlevel(mp->ment.mnt_mountp);
722 		mpp[ndx++] = mp;
723 	}
724 	mpp[ndx] = NULL;
725 	listlength = ndx;
726 	return (mpp);
727 }
728 
729 /*
730  * Returns the tail of a linked list of all mnttab entries.  I.e, it's faster
731  * to return the mnttab in reverse order.
732  * Sets listlength to the number of entries in the list.
733  * Returns NULL if none are found.
734  */
735 mountent_t *
736 getmntall(void)
737 {
738 	FILE		*fp;
739 	mountent_t	*mtail;
740 	int		cnt = 0, ret;
741 	struct mnttab	mget;
742 
743 	if ((fp = fopen(mnttab, "r")) == NULL) {
744 		fprintf(stderr, gettext("%s: warning cannot open %s\n"),
745 		    myname, mnttab);
746 		return (0);
747 	}
748 	mtail = NULL;
749 
750 	while ((ret = getmntent(fp, &mget)) != -1) {
751 		mountent_t	*mp;
752 
753 		if (ret > 0) {
754 			mnterror(ret);
755 			continue;
756 		}
757 
758 		mp = new_mountent(&mget);
759 		mp->link = mtail;
760 		mtail = mp;
761 		cnt++;
762 	}
763 	fclose(fp);
764 	if (mtail == NULL) {
765 		listlength = 0;
766 		return (NULL);
767 	}
768 	listlength = cnt;
769 	return (mtail);
770 }
771 
772 void
773 do_umounts(mountent_t **mntarray)
774 {
775 	mountent_t *mp, *mpprev, **ml = mntarray;
776 	int	cnt = listlength;
777 
778 	/*
779 	 * Main loop for the forked children:
780 	 */
781 	for (mpprev = *ml; mp = *ml; mpprev = mp, ml++, cnt--) {
782 		pid_t	pid;
783 
784 		/*
785 		 * Check to see if we cross a mount level: e.g.,
786 		 * /a/b/c -> /a/b.  If so, we need to wait for all current
787 		 * umounts to finish before umounting the rest.
788 		 *
789 		 * Also, we unmount serially as long as there are lofs's
790 		 * to mount to avoid improper umount ordering.
791 		 */
792 		if (mp->mlevel < mpprev->mlevel || lofscnt > 0)
793 			while (nrun > 0 && (dowait() != -1))
794 				;
795 
796 		if (lofscnt == 0) {
797 			/*
798 			 * We can now go to parallel umounting.
799 			 */
800 			qsort((void *)ml, cnt, sizeof (mountent_t *), mcompar);
801 			mp = *ml;	/* possible first entry */
802 			lofscnt--;	/* so we don't do this again */
803 		}
804 
805 		while (setup_iopipe(mp) == -1 && (dowait() != -1))
806 			;
807 
808 		while (nrun >= maxrun && (dowait() != -1))	/* throttle */
809 			;
810 
811 		if ((pid = fork()) == -1) {
812 			perror("fork");
813 			cleanup(-1);
814 			/* not reached */
815 		}
816 #ifdef DEBUG
817 		if (dflg && pid > 0) {
818 			fprintf(stderr, "parent %d: umounting %d %s\n",
819 			    getpid(), pid, mp->ment.mnt_mountp);
820 		}
821 #endif
822 		if (pid == 0) {		/* child */
823 			signal(SIGHUP, SIG_IGN);
824 			signal(SIGQUIT, SIG_IGN);
825 			signal(SIGINT, SIG_IGN);
826 			setup_output(mp);
827 			doexec(&mp->ment);
828 			perror("exec");
829 			exit(1);
830 		}
831 
832 		/* parent */
833 		(void) close(mp->sopipe[WRPIPE]);
834 		(void) close(mp->sepipe[WRPIPE]);
835 		mp->pid = pid;
836 		nrun++;
837 	}
838 	cleanup(0);
839 }
840 
841 /*
842  * cleanup the existing children and exit with an error
843  * if asig != 0.
844  */
845 void
846 cleanup(int asig)
847 {
848 	/*
849 	 * Let the stragglers finish.
850 	 */
851 	while (nrun > 0 && (dowait() != -1))
852 		;
853 	if (asig != 0)
854 		exit(1);
855 }
856 
857 
858 /*
859  * Waits for 1 child to die.
860  *
861  * Returns -1 if no children are left to wait for.
862  * Returns 0 if a child died without an error.
863  * Returns 1 if a child died with an error.
864  * Sets the global exitcode if an error occurred.
865  */
866 int
867 dowait(void)
868 {
869 	int		wstat, child, ret;
870 	mountent_t 	*mp, *prevp;
871 
872 	if ((child = wait(&wstat)) == -1)
873 		return (-1);
874 
875 	if (WIFEXITED(wstat))		/* this should always be true */
876 		ret = WEXITSTATUS(wstat);
877 	else
878 		ret = 1;		/* assume some kind of error */
879 	nrun--;
880 	if (ret)
881 		exitcode = 1;
882 
883 	/*
884 	 * Find our child so we can process its std output, if any.
885 	 * This search gets smaller and smaller as children are cleaned
886 	 * up.
887 	 */
888 	for (prevp = NULL, mp = mntll; mp; mp = mp->link) {
889 		if (mp->pid != child) {
890 			prevp = mp;
891 			continue;
892 		}
893 		/*
894 		 * Found: let's remove it from this list.
895 		 */
896 		if (prevp) {
897 			prevp->link = mp->link;
898 			mp->link = NULL;
899 		}
900 		break;
901 	}
902 
903 	if (mp == NULL) {
904 		/*
905 		 * This should never happen.
906 		 */
907 #ifdef DEBUG
908 		fprintf(stderr, gettext(
909 		    "%s: unknown child %d\n"), myname, child);
910 #endif
911 		exitcode = 1;
912 		return (1);
913 	}
914 	doio(mp);	/* Any output? */
915 
916 	if (mp->ment.mnt_fstype &&
917 	    (strcmp(mp->ment.mnt_fstype, MNTTYPE_LOFS) == 0))
918 		lofscnt--;
919 
920 	return (ret);
921 }
922 
923 static const mountent_t zmount = { 0 };
924 
925 mountent_t *
926 new_mountent(struct mnttab *ment)
927 {
928 	mountent_t *new;
929 
930 	new = (mountent_t *)malloc(sizeof (*new));
931 	if (new == NULL)
932 		nomem();
933 
934 	*new = zmount;
935 	if (ment->mnt_special &&
936 	    (new->ment.mnt_special = strdup(ment->mnt_special)) == NULL)
937 		nomem();
938 	if (ment->mnt_mountp &&
939 	    (new->ment.mnt_mountp = strdup(ment->mnt_mountp)) == NULL)
940 		nomem();
941 	if (ment->mnt_fstype &&
942 	    (new->ment.mnt_fstype = strdup(ment->mnt_fstype)) == NULL)
943 		nomem();
944 	return (new);
945 }
946 
947 
948 /*
949  * Sort in descending order of "mount level".  For example, /a/b/c is
950  * placed before /a/b .
951  */
952 int
953 mcompar(const void *a, const void *b)
954 {
955 	mountent_t *a1, *b1;
956 
957 	a1 = *(mountent_t **)a;
958 	b1 = *(mountent_t **)b;
959 	return (b1->mlevel - a1->mlevel);
960 }
961 
962 /*
963  * The purpose of this routine is to form stdout and stderr
964  * pipes for the children's output.  The parent then reads and writes it
965  * out it serially in order to ensure that the output is
966  * not garbled.
967  */
968 
969 int
970 setup_iopipe(mountent_t *mp)
971 {
972 	/*
973 	 * Make a stdout and stderr pipe.  This should never fail.
974 	 */
975 	if (pipe(mp->sopipe) == -1)
976 		return (-1);
977 	if (pipe(mp->sepipe) == -1) {
978 		(void) close(mp->sopipe[RDPIPE]);
979 		(void) close(mp->sopipe[WRPIPE]);
980 		return (-1);
981 	}
982 	/*
983 	 * Don't block on an empty pipe.
984 	 */
985 	(void) fcntl(mp->sopipe[RDPIPE], F_SETFL, O_NDELAY|O_NONBLOCK);
986 	(void) fcntl(mp->sepipe[RDPIPE], F_SETFL, O_NDELAY|O_NONBLOCK);
987 	return (0);
988 }
989 
990 /*
991  * Called by a child to attach its stdout and stderr to the write side of
992  * the pipes.
993  */
994 void
995 setup_output(mountent_t *mp)
996 {
997 	(void) close(fileno(stdout));
998 	(void) dup(mp->sopipe[WRPIPE]);
999 	(void) close(mp->sopipe[WRPIPE]);
1000 
1001 	(void) close(fileno(stderr));
1002 	(void) dup(mp->sepipe[WRPIPE]);
1003 	(void) close(mp->sepipe[WRPIPE]);
1004 }
1005 
1006 /*
1007  * Parent uses this to print any stdout or stderr output issued by
1008  * the child.
1009  */
1010 static void
1011 doio(mountent_t *mp)
1012 {
1013 	int bytes;
1014 
1015 	while ((bytes = read(mp->sepipe[RDPIPE], ibuf, sizeof (ibuf))) > 0)
1016 		write(fileno(stderr), ibuf, bytes);
1017 	while ((bytes = read(mp->sopipe[RDPIPE], ibuf, sizeof (ibuf))) > 0)
1018 		write(fileno(stdout), ibuf, bytes);
1019 
1020 	(void) close(mp->sopipe[RDPIPE]);
1021 	(void) close(mp->sepipe[RDPIPE]);
1022 }
1023 
1024 void
1025 nomem(void)
1026 {
1027 	fprintf(stderr, gettext("%s: out of memory\n"), myname);
1028 	/*
1029 	 * Let the stragglers finish.
1030 	 */
1031 	while (nrun > 0 && (dowait() != -1))
1032 		;
1033 	exit(1);
1034 }
1035