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