*: use llist_pop for traverse-and-free list operation
[oweals/busybox.git] / libbb / vfork_daemon_rexec.c
index d25693917be8ea6d29908339e923d56229482357..9624efbb95b3de09f2606ced75fba4dfbc4aa17d 100644 (file)
@@ -16,7 +16,7 @@
  */
 
 #include <paths.h>
-#include "busybox.h" /* for struct BB_applet */
+#include "busybox.h" /* uses applet tables */
 
 /* This does a fork/exec in one call, using vfork().  Returns PID of new child,
  * -1 for failure.  Runs argv[0], searching path if that has no / in it. */
@@ -62,10 +62,25 @@ pid_t xspawn(char **argv)
 {
        pid_t pid = spawn(argv);
        if (pid < 0)
-               bb_perror_msg_and_die("%s", *argv);
+               bb_simple_perror_msg_and_die(*argv);
        return pid;
 }
 
+int safe_waitpid(int pid, int *wstat, int options)
+{
+       int r;
+
+       do
+               r = waitpid(pid, wstat, options);
+       while ((r == -1) && (errno == EINTR));
+       return r;
+}
+
+int wait_any_nohang(int *wstat)
+{
+       return safe_waitpid(-1, wstat, WNOHANG);
+}
+
 // Wait for the specified child PID to exit, returning child's error return.
 int wait4pid(int pid)
 {
@@ -76,7 +91,7 @@ int wait4pid(int pid)
                /* we expect errno to be already set from failed [v]fork/exec */
                return -1;
        }
-       if (waitpid(pid, &status, 0) == -1)
+       if (safe_waitpid(pid, &status, 0) == -1)
                return -1;
        if (WIFEXITED(status))
                return WEXITSTATUS(status);
@@ -85,109 +100,125 @@ int wait4pid(int pid)
        return 0;
 }
 
-int wait_nohang(int *wstat)
+#if ENABLE_FEATURE_PREFER_APPLETS
+void save_nofork_data(struct nofork_save_area *save)
 {
-       return waitpid(-1, wstat, WNOHANG);
+       memcpy(&save->die_jmp, &die_jmp, sizeof(die_jmp));
+       save->applet_name = applet_name;
+       save->xfunc_error_retval = xfunc_error_retval;
+       save->option_mask32 = option_mask32;
+       save->die_sleep = die_sleep;
+       save->saved = 1;
 }
 
-int wait_pid(int *wstat, int pid)
+void restore_nofork_data(struct nofork_save_area *save)
 {
-       int r;
+       memcpy(&die_jmp, &save->die_jmp, sizeof(die_jmp));
+       applet_name = save->applet_name;
+       xfunc_error_retval = save->xfunc_error_retval;
+       option_mask32 = save->option_mask32;
+       die_sleep = save->die_sleep;
+}
 
-       do
-               r = waitpid(pid, wstat, 0);
-       while ((r == -1) && (errno == EINTR));
-       return r;
+int run_nofork_applet_prime(struct nofork_save_area *old, int applet_no, char **argv)
+{
+       int rc, argc;
+
+       applet_name = APPLET_NAME(applet_no);
+       xfunc_error_retval = EXIT_FAILURE;
+
+       /* Special flag for xfunc_die(). If xfunc will "die"
+        * in NOFORK applet, xfunc_die() sees negative
+        * die_sleep and longjmp here instead. */
+       die_sleep = -1;
+
+       /* option_mask32 = 0; - not needed */
+
+       argc = 1;
+       while (argv[argc])
+               argc++;
+
+       rc = setjmp(die_jmp);
+       if (!rc) {
+               /* Some callers (xargs)
+                * need argv untouched because they free argv[i]! */
+               char *tmp_argv[argc+1];
+               memcpy(tmp_argv, argv, (argc+1) * sizeof(tmp_argv[0]));
+               /* Finally we can call NOFORK applet's main() */
+               rc = applet_main[applet_no](argc, tmp_argv);
+
+       /* The whole reason behind nofork_save_area is that <applet>_main
+        * may exit non-locally! For example, in hush Ctrl-Z tries
+        * (modulo bugs) to dynamically create a child (backgrounded task)
+        * if it detects that Ctrl-Z was pressed when a NOFORK was running.
+        * Testcase: interactive "rm -i".
+        * Don't fool yourself into thinking "and <applet>_main() returns
+        * quickly here" and removing "useless" nofork_save_area code. */
+
+       } else { /* xfunc died in NOFORK applet */
+               /* in case they meant to return 0... */
+               if (rc == -2222)
+                       rc = 0;
+       }
+
+       /* Restoring globals */
+       restore_nofork_data(old);
+       return rc & 0xff; /* don't confuse people with "exitcodes" >255 */
+}
+
+int run_nofork_applet(int applet_no, char **argv)
+{
+       struct nofork_save_area old;
+
+       /* Saving globals */
+       save_nofork_data(&old);
+       return run_nofork_applet_prime(&old, applet_no, argv);
 }
+#endif /* FEATURE_PREFER_APPLETS */
 
 int spawn_and_wait(char **argv)
 {
        int rc;
+#if ENABLE_FEATURE_PREFER_APPLETS
+       int a = find_applet_by_name(argv[0]);
 
-       if (ENABLE_FEATURE_EXEC_PREFER_APPLETS) {
-               const struct BB_applet *a = find_applet_by_name(argv[0]);
-               if (a && (a->nofork
-#ifndef BB_NOMMU
-                        || a->noexec /* NOEXEC cannot be used on NOMMU */
+       if (a >= 0 && (APPLET_IS_NOFORK(a)
+#if BB_MMU
+                       || APPLET_IS_NOEXEC(a) /* NOEXEC trick needs fork() */
 #endif
-               )) {
-                       int argc = 1;
-                       char **pp = argv;
-                       while (*++pp)
-                               argc++;
-#ifdef BB_NOMMU
-                       return a->main(argc, argv);
-#else
-                       if (a->nofork)
-                               return a->main(argc, argv);
-                       /* a->noexec is true */
-                       rc = fork();
-                       if (rc)
-                               goto w;
-                       /* child */
-                       current_applet = a;
-                       run_current_applet_and_exit(argc, argv);
+       )) {
+#if BB_MMU
+               if (APPLET_IS_NOFORK(a))
 #endif
+               {
+                       return run_nofork_applet(a, argv);
                }
+#if BB_MMU
+               /* MMU only */
+               /* a->noexec is true */
+               rc = fork();
+               if (rc) /* parent or error */
+                       return wait4pid(rc);
+               /* child */
+               xfunc_error_retval = EXIT_FAILURE;
+               run_applet_no_and_exit(a, argv);
+#endif
        }
+#endif /* FEATURE_PREFER_APPLETS */
        rc = spawn(argv);
- w:
        return wait4pid(rc);
 }
 
-#if 0 //ndef BB_NOMMU
-// Die with an error message if we can't daemonize.
-void xdaemon(int nochdir, int noclose)
-{
-       if (daemon(nochdir, noclose))
-               bb_perror_msg_and_die("daemon");
-}
-#endif
-
-#if 0 // def BB_NOMMU
-void vfork_daemon_rexec(int nochdir, int noclose, char **argv)
+#if !BB_MMU
+void re_exec(char **argv)
 {
-       int fd;
-
-       /* Maybe we are already re-execed and come here again? */
-       if (re_execed)
-               return;
-
-       setsid();
-
-       if (!nochdir)
-               xchdir("/");
-
-       if (!noclose) {
-               /* if "/dev/null" doesn't exist, bail out! */
-               fd = xopen(bb_dev_null, O_RDWR);
-               dup2(fd, STDIN_FILENO);
-               dup2(fd, STDOUT_FILENO);
-               dup2(fd, STDERR_FILENO);
-               while (fd > 2)
-                       close(fd--);
-       }
-
-       switch (vfork()) {
-       case 0: /* child */
-               /* Make certain we are not a session leader, or else we
-                * might reacquire a controlling terminal */
-               if (vfork())
-                       _exit(0);
-               /* High-order bit of first char in argv[0] is a hidden
-                * "we have (alrealy) re-execed, don't do it again" flag */
-               argv[0][0] |= 0x80;
-               execv(CONFIG_BUSYBOX_EXEC_PATH, argv);
-               bb_perror_msg_and_die("exec %s", CONFIG_BUSYBOX_EXEC_PATH);
-       case -1: /* error */
-               bb_perror_msg_and_die("vfork");
-       default: /* parent */
-               exit(0);
-       }
+       /* high-order bit of first char in argv[0] is a hidden
+        * "we have (already) re-execed, don't do it again" flag */
+       argv[0][0] |= 0x80;
+       execv(bb_busybox_exec_path, argv);
+       bb_perror_msg_and_die("exec %s", bb_busybox_exec_path);
 }
-#endif /* BB_NOMMU */
 
-#ifdef BB_NOMMU
 void forkexit_or_rexec(char **argv)
 {
        pid_t pid;
@@ -199,13 +230,9 @@ void forkexit_or_rexec(char **argv)
        if (pid < 0) /* wtf? */
                bb_perror_msg_and_die("vfork");
        if (pid) /* parent */
-               exit(0);
+               exit(EXIT_SUCCESS);
        /* child - re-exec ourself */
-       /* high-order bit of first char in argv[0] is a hidden
-        * "we have (alrealy) re-execed, don't do it again" flag */
-       argv[0][0] |= 0x80;
-       execv(CONFIG_BUSYBOX_EXEC_PATH, argv);
-       bb_perror_msg_and_die("exec %s", CONFIG_BUSYBOX_EXEC_PATH);
+       re_exec(argv);
 }
 #else
 /* Dance around (void)...*/
@@ -217,21 +244,18 @@ void forkexit_or_rexec(void)
        if (pid < 0) /* wtf? */
                bb_perror_msg_and_die("fork");
        if (pid) /* parent */
-               exit(0);
+               exit(EXIT_SUCCESS);
        /* child */
 }
 #define forkexit_or_rexec(argv) forkexit_or_rexec()
 #endif
 
-
 /* Due to a #define in libbb.h on MMU systems we actually have 1 argument -
  * char **argv "vanishes" */
 void bb_daemonize_or_rexec(int flags, char **argv)
 {
        int fd;
 
-       fd = xopen(bb_dev_null, O_RDWR);
-
        if (flags & DAEMON_CHDIR_ROOT)
                xchdir("/");
 
@@ -241,22 +265,25 @@ void bb_daemonize_or_rexec(int flags, char **argv)
                close(2);
        }
 
+       fd = xopen(bb_dev_null, O_RDWR);
+
        while ((unsigned)fd < 2)
                fd = dup(fd); /* have 0,1,2 open at least to /dev/null */
 
        if (!(flags & DAEMON_ONLY_SANITIZE)) {
                forkexit_or_rexec(argv);
-               /* if daemonizing, make sure we detach from stdio */
+               /* if daemonizing, make sure we detach from stdio & ctty */
                setsid();
                dup2(fd, 0);
                dup2(fd, 1);
                dup2(fd, 2);
        }
-       if (fd > 2)
+       while (fd > 2) {
                close(fd--);
-       if (flags & DAEMON_CLOSE_EXTRA_FDS)
-               while (fd > 2)
-                       close(fd--); /* close everything after fd#2 */
+               if (!(flags & DAEMON_CLOSE_EXTRA_FDS))
+                       return;
+               /* else close everything after fd#2 */
+       }
 }
 
 void bb_sanitize_stdio(void)