restore old plan 9 property that when the

last thread exits the main proc, the remaining
program ends up in the background and the
program appears to have exited.

6 files changed, 36 insertions, 8 deletions

diff --git a/src/libthread/FreeBSD.c b/src/libthread/FreeBSD.c
index 0fdb54b9..df5bdb96 100644
--- a/src/libthread/FreeBSD.c
+++ b/src/libthread/FreeBSD.c
@@ -346,6 +346,13 @@ _pthreadinit(void)
 	signal(SIGUSR2, sigusr2handler);
 }
 
+void
+_threadpexit(void)
+{
+	_exit(0);
+}
+
+
 /*
  * FreeBSD 4 and earlier needs the context functions.
  */
diff --git a/src/libthread/Linux.c b/src/libthread/Linux.c
index 103cb428..3d31a4a9 100644
--- a/src/libthread/Linux.c
+++ b/src/libthread/Linux.c
@@ -348,3 +348,8 @@ _pthreadinit(void)
 	signal(SIGUSR2, sigusr2handler);
 }
 
+void
+_threadpexit(void)
+{
+	_exit(0);
+}
diff --git a/src/libthread/daemonize.c b/src/libthread/daemonize.c
index dab6e42b..1b6ae6f6 100644
--- a/src/libthread/daemonize.c
+++ b/src/libthread/daemonize.c
@@ -9,10 +9,13 @@ static int threadpassfd;
 static void
 child(void)
 {
-	int status;
-	if(wait(&status) == sigpid)
-		if(WIFEXITED(status))
-			 _exit(WEXITSTATUS(status));
+	int status, pid;
+	pid = wait(&status);
+	if(pid < 0)
+		fprint(2, "wait: %r\n");
+	else if(WIFEXITED(status))
+		 _exit(WEXITSTATUS(status));
+print("pid %d if %d %d\n", pid, WIFEXITED(status), WEXITSTATUS(status));
 	_exit(97);
 }
 
@@ -51,6 +54,7 @@ _threadsetupdaemonize(void)
 	if(fcntl(p[0], F_SETFD, 1) < 0 || fcntl(p[1], F_SETFD, 1) < 0)
 		sysfatal("passer pipe pipe fcntl: %r");
 
+	signal(SIGCHLD, sigpass);
 	switch(pid = fork()){
 	case -1:
 		sysfatal("passer fork: %r");
@@ -58,6 +62,7 @@ _threadsetupdaemonize(void)
 		close(p[1]);
 		break;
 	case 0:
+		signal(SIGCHLD, SIG_DFL);
 		rfork(RFNOTEG);
 		close(p[0]);
 		threadpassfd = p[1];
@@ -89,7 +94,9 @@ _threadsetupdaemonize(void)
 void
 threaddaemonize(void)
 {
-	write(threadpassfd, "0", 1);
-	close(threadpassfd);
-	threadpassfd = -1;
+	if(threadpassfd >= 0){
+		write(threadpassfd, "0", 1);
+		close(threadpassfd);
+		threadpassfd = -1;
+	}
 }
diff --git a/src/libthread/pthread.c b/src/libthread/pthread.c
index 8d3c7f9a..fcc309b7 100644
--- a/src/libthread/pthread.c
+++ b/src/libthread/pthread.c
@@ -132,3 +132,8 @@ threadexitsall(char *msg)
 	exits(msg);
 }
 
+void
+_threadpexit(void)
+{
+	pthread_exit(0);
+}
diff --git a/src/libthread/thread.c b/src/libthread/thread.c
index 92e93940..84e21717 100644
--- a/src/libthread/thread.c
+++ b/src/libthread/thread.c
@@ -476,6 +476,8 @@ main(int argc, char **argv)
 {
 	Proc *p;
 
+	argv0 = argv[0];
+
 	_threadsetupdaemonize();
 
 	threadargc = argc;
@@ -503,7 +505,8 @@ main(int argc, char **argv)
 		mainstacksize = 65536;
 	_threadcreate(p, threadmainstart, nil, mainstacksize);
 	scheduler(p);
-	return 0;	/* not reached */
+	threaddaemonize();
+	_threadpexit();
 }
 
 /*
diff --git a/src/libthread/threadimpl.h b/src/libthread/threadimpl.h
index 32afa5fe..5cdba60c 100644
--- a/src/libthread/threadimpl.h
+++ b/src/libthread/threadimpl.h
@@ -122,3 +122,4 @@ extern int _threadspawn(int*, char*, char**);
 extern int _runthreadspawn(int*, char*, char**);
 extern void _threadsetupdaemonize(void);
 extern void _threaddodaemonize(char*);
+extern void _threadpexit(void);