xref: /netbsd/usr.sbin/puffs/rump_lfs/rump_lfs.c (revision 6550d01e)
1 /*	$NetBSD: rump_lfs.c,v 1.16 2010/03/03 17:37:01 pooka Exp $	*/
2 
3 /*
4  * Copyright (c) 2008 Antti Kantee.  All Rights Reserved.
5  *
6  * Redistribution and use in source and binary forms, with or without
7  * modification, are permitted provided that the following conditions
8  * are met:
9  * 1. Redistributions of source code must retain the above copyright
10  *    notice, this list of conditions and the following disclaimer.
11  * 2. Redistributions in binary form must reproduce the above copyright
12  *    notice, this list of conditions and the following disclaimer in the
13  *    documentation and/or other materials provided with the distribution.
14  *
15  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
16  * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
17  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
18  * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
19  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
20  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
21  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
22  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
23  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
24  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
25  * SUCH DAMAGE.
26  */
27 
28 #include <sys/types.h>
29 #include <sys/mount.h>
30 
31 #include <ufs/ufs/ufsmount.h>
32 
33 #include <err.h>
34 #include <pthread.h>
35 #include <puffs.h>
36 #include <stdio.h>
37 #include <stdlib.h>
38 #include <unistd.h>
39 
40 #include <rump/rump.h>
41 #include <rump/p2k.h>
42 #include <rump/ukfs.h>
43 
44 #include "mount_lfs.h"
45 
46 static void *
47 cleaner(void *arg)
48 {
49 	const char *the_argv[7];
50 
51 	the_argv[0] = "megamaid";
52 	the_argv[1] = "-D"; /* don't fork() & detach */
53 	the_argv[2] = arg;
54 
55 	lfs_cleaner_main(3, __UNCONST(the_argv));
56 
57 	return NULL;
58 }
59 
60 int
61 main(int argc, char *argv[])
62 {
63 	struct ufs_args args;
64 	char canon_dev[UKFS_DEVICE_MAXPATHLEN], canon_dir[MAXPATHLEN];
65 	char rawdev[MAXPATHLEN];
66 	struct p2k_mount *p2m;
67 	pthread_t cleanerthread;
68 	struct ukfs_part *part;
69 	int mntflags;
70 	int rv;
71 
72 	setprogname(argv[0]);
73 	puffs_unmountonsignal(SIGINT, true);
74 	puffs_unmountonsignal(SIGTERM, true);
75 
76 	if (argc >= 3) {
77 		UKFS_DEVICE_ARGVPROBE(&part);
78 		if (part != ukfs_part_none) {
79 			errx(1, "lfs does not currently support "
80 			    "embedded partitions");
81 		}
82 	}
83 	mount_lfs_parseargs(argc, argv, &args, &mntflags, canon_dev, canon_dir);
84 
85 	p2m = p2k_init(0);
86 	if (!p2m)
87 		err(1, "init p2k");
88 	/*
89 	 * XXX: this particular piece inspired by the cleaner code.
90 	 * obviously FIXXXME along with the cleaner.
91 	 */
92 	sprintf(rawdev, "/dev/r%s", canon_dev+5);
93 	rump_pub_etfs_register(rawdev, canon_dev, RUMP_ETFS_CHR);
94 
95 	/*
96 	 * We basically have two choices:
97 	 *  1) run the cleaner in another process and do rump ipc syscalls
98 	 *  2) run it off a thread in this process and do rump syscalls
99 	 *     as function calls.
100 	 *
101 	 * opt for "2" for now
102 	 */
103 #ifdef CLEANER_TESTING
104 	ukfs_mount(MOUNT_LFS, canon_dev, canon_dir, mntflags,
105 	    &args, sizeof(args));
106 	cleaner(canon_dir);
107 #endif
108 	if (p2k_setup_diskfs(p2m, MOUNT_LFS, canon_dev, part, canon_dir,
109 	    mntflags, &args, sizeof(args)) == -1)
110 		err(1, "mount");
111 	ukfs_part_release(part);
112 
113 #ifndef CLEANER_TESTING
114 	if ((mntflags & MNT_RDONLY) == 0) {
115 		if (pthread_create(&cleanerthread, NULL,
116 		    cleaner, canon_dir) == -1)
117 			err(1, "cannot start cleaner");
118 	}
119 #endif
120 
121 	rv = p2k_mainloop(p2m);
122 	if (rv == -1)
123 		err(1, "fs service");
124 
125 	return 0;
126 }
127