2 * Copyright (c) 2011-2015 The DragonFly Project. All rights reserved.
4 * This code is derived from software contributed to The DragonFly Project
5 * by Matthew Dillon <dillon@dragonflybsd.org>
6 * by Venkatesh Srinivas <vsrinivas@dragonflybsd.org>
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions
12 * 1. Redistributions of source code must retain the above copyright
13 * notice, this list of conditions and the following disclaimer.
14 * 2. Redistributions in binary form must reproduce the above copyright
15 * notice, this list of conditions and the following disclaimer in
16 * the documentation and/or other materials provided with the
18 * 3. Neither the name of The DragonFly Project nor the names of its
19 * contributors may be used to endorse or promote products derived
20 * from this software without specific, prior written permission.
22 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
23 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
24 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
25 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
26 * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
27 * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
28 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
29 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
30 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
31 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
32 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
35 #include <sys/types.h>
36 #include <sys/param.h>
37 #include <sys/mount.h>
38 #include <sys/socket.h>
39 #include <netinet/in.h>
40 #include <vfs/hammer2/hammer2_mount.h>
50 static int cluster_connect(const char *volume
);
51 static void usage(const char *ctl
, ...);
53 static struct mntopt mopts
[] = {
55 { "update", 0, MNT_UPDATE
, 0 },
56 { "local", 0, HMNT2_LOCAL
, 1 },
61 * Usage: mount_hammer2 [volume] [mtpt]
64 main(int ac
, char *av
[])
66 struct hammer2_mount_info info
;
75 bzero(&info
, sizeof(info
));
79 while ((ch
= getopt(ac
, av
, "o:u")) != -1) {
82 getmntopts(optarg
, mopts
, &mount_flags
, &info
.hflags
);
85 init_flags
|= MNT_UPDATE
;
88 usage("unknown option: -%c", ch
);
94 mount_flags
|= init_flags
;
96 error
= getvfsbyname("hammer2", &vfc
);
98 fprintf(stderr
, "hammer2 vfs not loaded\n");
103 * Only the mount point need be specified in update mode.
105 if (init_flags
& MNT_UPDATE
) {
107 usage("missing parameter (mountpoint)");
111 if (mount(vfc
.vfc_name
, mountpt
, mount_flags
, &info
))
112 usage("mount %s: %s", mountpt
, strerror(errno
));
120 usage("missing parameter(s) (dev@LABEL mountpt)");
124 devpath
= strdup(av
[0]);
127 if (strchr(devpath
, '@') == NULL
) {
129 "hammer2_mount: no @LABEL specified: \"%s\"\n"
130 "typical labels are @LOCAL, @ROOT\n",
136 * Connect to the cluster controller. This handles both remote
137 * mounts and device cache/master/slave mounts.
139 * When doing remote mounts that are allowed to run in the background
140 * the mount program will fork, detach, print a message, and exit(0)
141 * the originator while retrying in the background.
143 info
.cluster_fd
= cluster_connect(devpath
);
144 if (info
.cluster_fd
< 0) {
146 "hammer2_mount: cluster_connect(%s) failed\n",
152 * Try to mount it, prefix if necessary.
154 if (devpath
[0] != '/') {
156 asprintf(&p2
, "/dev/%s", devpath
);
160 info
.volume
= devpath
;
162 error
= mount(vfc
.vfc_name
, mountpt
, mount_flags
, &info
);
164 if (errno
== ERANGE
) {
166 "%s integrated with %s\n",
167 info
.volume
, mountpt
);
176 * XXX fork a backgrounded reconnector process to handle connection
184 * Connect to the cluster controller. We can connect to a local or remote
185 * cluster controller, depending. For a multi-node cluster we always want
186 * to connect to the local controller and let it maintain the connections
187 * to the multiple remote nodes.
191 cluster_connect(const char *volume __unused
)
193 struct sockaddr_in lsin
;
197 * This starts the hammer2 service if it isn't already running,
198 * so we can connect to it.
200 system("/sbin/hammer2 -q service");
203 * Connect us to the service but leave the rest to the kernel.
204 * If the connection is lost during the mount
206 if ((fd
= socket(AF_INET
, SOCK_STREAM
, 0)) < 0) {
210 bzero(&lsin
, sizeof(lsin
));
211 lsin
.sin_family
= AF_INET
;
212 lsin
.sin_addr
.s_addr
= htonl(INADDR_LOOPBACK
);
213 lsin
.sin_port
= htons(DMSG_LISTEN_PORT
);
215 if (connect(fd
, (struct sockaddr
*)&lsin
, sizeof(lsin
)) < 0) {
217 fprintf(stderr
, "mount_hammer2: unable to connect to "
218 "cluster controller\n");
227 usage(const char *ctl
, ...)
232 fprintf(stderr
, "hammer2_mount: ");
233 vfprintf(stderr
, ctl
, va
);
235 fprintf(stderr
, "\n");
236 fprintf(stderr
, " hammer2_mount -u [-o opts] mountpt\n");
237 fprintf(stderr
, " hammer2_mount [-o opts] dev@LABEL mountpt\n");
238 fprintf(stderr
, "\n");
239 fprintf(stderr
, "options:\n"
240 " <standard_mount_opts>\n"
241 " local\t- disable PFS clustering for whole device\n"