*: use llist_pop for traverse-and-free list operation
[oweals/busybox.git] / libbb / vfork_daemon_rexec.c
index aef74e9949554e68d96e2eacfeabeeffac7aba7d..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,24 +100,11 @@ int wait4pid(int pid)
        return 0;
 }
 
-int wait_nohang(int *wstat)
-{
-       return waitpid(-1, wstat, WNOHANG);
-}
-
-int wait_pid(int *wstat, int pid)
-{
-       int r;
-
-       do
-               r = waitpid(pid, wstat, 0);
-       while ((r == -1) && (errno == EINTR));
-       return r;
-}
-
+#if ENABLE_FEATURE_PREFER_APPLETS
 void save_nofork_data(struct nofork_save_area *save)
 {
-       save->current_applet = current_applet;
+       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;
@@ -111,27 +113,27 @@ void save_nofork_data(struct nofork_save_area *save)
 
 void restore_nofork_data(struct nofork_save_area *save)
 {
-       current_applet = save->current_applet;
+       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;
-
-       applet_name = current_applet->name;
 }
 
-int run_nofork_applet_prime(struct nofork_save_area *old, const struct bb_applet *a, char **argv)
+int run_nofork_applet_prime(struct nofork_save_area *old, int applet_no, char **argv)
 {
        int rc, argc;
 
-       current_applet = a;
-       applet_name = a->name;
+       applet_name = APPLET_NAME(applet_no);
        xfunc_error_retval = EXIT_FAILURE;
-       /*option_mask32 = 0; - not needed */
-       /* special flag for xfunc_die(). If xfunc will "die"
+
+       /* 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++;
@@ -143,39 +145,50 @@ int run_nofork_applet_prime(struct nofork_save_area *old, const struct bb_applet
                char *tmp_argv[argc+1];
                memcpy(tmp_argv, argv, (argc+1) * sizeof(tmp_argv[0]));
                /* Finally we can call NOFORK applet's main() */
-               rc = a->main(argc, tmp_argv);
+               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 == -111)
+               if (rc == -2222)
                        rc = 0;
        }
 
        /* Restoring globals */
        restore_nofork_data(old);
-       return rc;
+       return rc & 0xff; /* don't confuse people with "exitcodes" >255 */
 }
 
-int run_nofork_applet(const struct bb_applet *a, char **argv)
+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, a, argv);
+       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
-       const struct bb_applet *a = find_applet_by_name(argv[0]);
+       int a = find_applet_by_name(argv[0]);
 
-       if (a && (a->nofork
+       if (a >= 0 && (APPLET_IS_NOFORK(a)
 #if BB_MMU
-                || a->noexec /* NOEXEC trick needs fork() */
+                       || APPLET_IS_NOEXEC(a) /* NOEXEC trick needs fork() */
 #endif
        )) {
 #if BB_MMU
-               if (a->nofork)
+               if (APPLET_IS_NOFORK(a))
 #endif
                {
                        return run_nofork_applet(a, argv);
@@ -188,8 +201,7 @@ int spawn_and_wait(char **argv)
                        return wait4pid(rc);
                /* child */
                xfunc_error_retval = EXIT_FAILURE;
-               current_applet = a;
-               run_current_applet_and_exit(argv);
+               run_applet_no_and_exit(a, argv);
 #endif
        }
 #endif /* FEATURE_PREFER_APPLETS */
@@ -197,8 +209,16 @@ int spawn_and_wait(char **argv)
        return wait4pid(rc);
 }
 
-
 #if !BB_MMU
+void re_exec(char **argv)
+{
+       /* 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);
+}
+
 void forkexit_or_rexec(char **argv)
 {
        pid_t pid;
@@ -210,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)...*/
@@ -228,7 +244,7 @@ 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()
@@ -240,8 +256,6 @@ void bb_daemonize_or_rexec(int flags, char **argv)
 {
        int fd;
 
-       fd = xopen(bb_dev_null, O_RDWR);
-
        if (flags & DAEMON_CHDIR_ROOT)
                xchdir("/");
 
@@ -251,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)