post9pservice: accept mtpt (via fuse)

include/libc.h

@@ -832,7 +832,8 @@ extern	char*	get9root(void);
 extern	char*	unsharp(char*);
 extern	int	sendfd(int, int);
 extern	int	recvfd(int);
-extern	int	post9pservice(int, char*);
+extern	int	post9pservice(int, char*, char*);
+extern	int	chattyfuse;
 
 /* external names that we don't want to step on */
 #ifndef NOPLAN9DEFINES

src/cmd/tapefs/fs.c

@@ -75,18 +75,22 @@ void
 main(int argc, char *argv[])
 {
 	Ram *r;
-	char *defmnt;
+	char *defmnt, *defsrv;
 	int p[2];
 	char buf[TICKREQLEN];
 
 	fmtinstall('F', fcallfmt);
 	initfcalls();
 
-	defmnt = "tapefs";
+	defmnt = nil;
+	defsrv = nil;
 	ARGBEGIN{
 	case 'm':
 		defmnt = ARGF();
 		break;
+	case 's':
+		defsrv = ARGF();
+		break;
 	case 'p':			/* password file */
 		uidmap = getpass(ARGF());
 		break;
@@ -142,8 +146,8 @@ main(int argc, char *argv[])
 		break;
 	default:
 		close(p[0]);	/* don't deadlock if child fails */
-		if(post9pservice(p[1], defmnt, nil) < 0) {
+		if(post9pservice(p[1], defsrv, defmnt) < 0){
-			sprint(buf, "post on `%s' failed", defmnt);
+			sprint(buf, "post9pservice: %r");
 			error(buf);
 		}
 	}

src/lib9/post9p.c

@@ -1,46 +1,79 @@
 #include <u.h>
 #include <libc.h>
 
+int chattyfuse;
+
 int
-post9pservice(int fd, char *name)
+post9pservice(int fd, char *name, char *mtpt)
 {
-	int i;
+	int i, pid;
-	char *ns, *s;
+	char *ns, *addr;
 	Waitmsg *w;
 
-	if(strchr(name, '!'))	/* assume is already network address */
+	if(name == nil && mtpt == nil){
-		s = strdup(name);
+		close(fd);
-	else{
+		werrstr("nothing to do");
-		if((ns = getns()) == nil)
+		return -1;
-			return -1;
-		s = smprint("unix!%s/%s", ns, name);
-		free(ns);
 	}
-	if(s == nil)
+
-		return -1;
+	if(name){
-	switch(fork()){
+		if(strchr(name, '!'))	/* assume is already network address */
-	case -1:
+			addr = strdup(name);
-		return -1;
+		else{
-	case 0:
+			if((ns = getns()) == nil)
-		dup(fd, 0);
+				return -1;
-		dup(fd, 1);
+			addr = smprint("unix!%s/%s", ns, name);
-		for(i=3; i<20; i++)
+			free(ns);
-			close(i);
+		}
-		execlp("9pserve", "9pserve", "-u", s, (char*)0);
+		if(addr == nil)
-		fprint(2, "exec 9pserve: %r\n");
+			return -1;
-		_exits("exec");
+		switch(pid = fork()){
-	default:
+		case -1:
-		w = wait();
+			return -1;
+		case 0:
+			dup(fd, 0);
+			dup(fd, 1);
+			for(i=3; i<20; i++)
+				close(i);
+			execlp("9pserve", "9pserve", "-u", addr, (char*)0);
+			fprint(2, "exec 9pserve: %r\n");
+			_exits("exec");
+		}
+		close(fd);
+		w = waitfor(pid);
 		if(w == nil)
 			return -1;
-		close(fd);
-		free(s);
 		if(w->msg && w->msg[0]){
 			free(w);
 			werrstr("9pserve failed");
 			return -1;
 		}
 		free(w);
-		return 0;
+		if(mtpt){
+			/* reopen */
+			if((fd = dial(addr, nil, nil, nil)) < 0){
+				werrstr("cannot reopen for mount: %r");
+				return -1;
+			}
+		}
+		free(addr);
 	}
+	if(mtpt){
+		switch(pid = rfork(RFFDG|RFPROC|RFNOWAIT)){
+		case -1:
+			return -1;
+		case 0:
+			dup(fd, 0);
+			for(i=3; i<20; i++)
+				close(i);
+			if(chattyfuse)
+				execlp("9pfuse", "9pfuse", "-D", "-", mtpt, (char*)0);
+			else
+				execlp("9pfuse", "9pfuse", "-", mtpt, (char*)0);
+			fprint(2, "exec 9pfuse: %r\n");
+			_exits("exec");
+		}
+		close(fd);
+	}
+	return 0;
 }

src/lib9p/tpost.c

@@ -14,9 +14,8 @@ void
 threadpostmountsrv(Srv *s, char *name, char *mtpt, int flag)
 {
 	int fd[2];
-
+	int mtfd;
-	if(mtpt)
+	char *addr;
-		sysfatal("mount not supported");
 
 	if(!s->nopipe){
 		if(pipe(fd) < 0)
@@ -24,7 +23,10 @@ threadpostmountsrv(Srv *s, char *name, char *mtpt, int flag)
 		s->infd = s->outfd = fd[1];
 		s->srvfd = fd[0];
 	}
-	if(name && post9pservice(s->srvfd, name) < 0)
+	if(name || mtpt){
-		sysfatal("post9pservice %s: %r", name);
+		if(post9pservice(s->srvfd, name, mtpt) < 0)
+			sysfatal("post9pservice %s: %r", name);
+	}else if(!s->nopipe)
+		sysfatal("no one to serve");
 	proccreate(launchsrv, s, 32*1024);
 }