diff options
| author | Denis Vlasenko <vda.linux@googlemail.com> | 2007-03-26 13:20:04 +0000 |
|---|---|---|
| committer | Denis Vlasenko <vda.linux@googlemail.com> | 2007-03-26 13:20:04 +0000 |
| commit | bb7fcb4229fd5ff583039f26ca1c06340e3f09ea (patch) | |
| tree | 5e4a6cc92e42ff7694ffc8b6a91434640e953726 | |
| parent | f62c6fa1cae0f944243c57b0a776c29eb0c61f18 (diff) | |
| download | busybox-w32-bb7fcb4229fd5ff583039f26ca1c06340e3f09ea.tar.gz busybox-w32-bb7fcb4229fd5ff583039f26ca1c06340e3f09ea.tar.bz2 busybox-w32-bb7fcb4229fd5ff583039f26ca1c06340e3f09ea.zip | |
libbb: rework NOMMU helper API so that it makes more sense
and easier to use. Doesn't compile - need two more commits.
| -rw-r--r-- | include/libbb.h | 86 | ||||
| -rw-r--r-- | libbb/vfork_daemon_rexec.c | 134 | ||||
| -rw-r--r-- | libbb/xfuncs.c | 78 |
3 files changed, 191 insertions, 107 deletions
diff --git a/include/libbb.h b/include/libbb.h index aba9316d1..ff7d3bf1a 100644 --- a/include/libbb.h +++ b/include/libbb.h | |||
| @@ -263,17 +263,9 @@ char *xrealloc_getcwd_or_warn(char *cwd); | |||
| 263 | char *xmalloc_readlink_or_warn(const char *path); | 263 | char *xmalloc_readlink_or_warn(const char *path); |
| 264 | char *xmalloc_realpath(const char *path); | 264 | char *xmalloc_realpath(const char *path); |
| 265 | extern void xstat(const char *filename, struct stat *buf); | 265 | extern void xstat(const char *filename, struct stat *buf); |
| 266 | extern pid_t spawn(char **argv); | ||
| 267 | extern pid_t xspawn(char **argv); | ||
| 268 | extern int wait4pid(int pid); | 266 | extern int wait4pid(int pid); |
| 269 | extern void xsetgid(gid_t gid); | 267 | extern void xsetgid(gid_t gid); |
| 270 | extern void xsetuid(uid_t uid); | 268 | extern void xsetuid(uid_t uid); |
| 271 | extern void xdaemon(int nochdir, int noclose); | ||
| 272 | /* More clever/thorough xdaemon */ | ||
| 273 | extern void bb_sanitize_stdio_maybe_daemonize(int daemonize); | ||
| 274 | extern void bb_sanitize_stdio(void); | ||
| 275 | /* NB: be careful: dont open syslog/network sockets before bb_daemonize */ | ||
| 276 | extern void bb_daemonize(void); | ||
| 277 | extern void xchdir(const char *path); | 269 | extern void xchdir(const char *path); |
| 278 | extern void xsetenv(const char *key, const char *value); | 270 | extern void xsetenv(const char *key, const char *value); |
| 279 | extern int xopen(const char *pathname, int flags); | 271 | extern int xopen(const char *pathname, int flags); |
| @@ -460,6 +452,62 @@ void clear_username_cache(void); | |||
| 460 | enum { USERNAME_MAX_SIZE = 16 - sizeof(int) }; | 452 | enum { USERNAME_MAX_SIZE = 16 - sizeof(int) }; |
| 461 | 453 | ||
| 462 | 454 | ||
| 455 | int execable_file(const char *name); | ||
| 456 | char *find_execable(const char *filename); | ||
| 457 | int exists_execable(const char *filename); | ||
| 458 | |||
| 459 | #if ENABLE_FEATURE_EXEC_PREFER_APPLETS | ||
| 460 | int bb_execvp(const char *file, char *const argv[]); | ||
| 461 | #define BB_EXECVP(prog,cmd) bb_execvp(prog,cmd) | ||
| 462 | #define BB_EXECLP(prog,cmd,...) \ | ||
| 463 | execlp((find_applet_by_name(prog)) ? CONFIG_BUSYBOX_EXEC_PATH : prog, \ | ||
| 464 | cmd, __VA_ARGS__) | ||
| 465 | #else | ||
| 466 | #define BB_EXECVP(prog,cmd) execvp(prog,cmd) | ||
| 467 | #define BB_EXECLP(prog,cmd,...) execlp(prog,cmd, __VA_ARGS__) | ||
| 468 | #endif | ||
| 469 | |||
| 470 | /* NOMMU friendy fork+exec */ | ||
| 471 | pid_t spawn(char **argv); | ||
| 472 | pid_t xspawn(char **argv); | ||
| 473 | /* Helpers for daemonization. | ||
| 474 | * bb_daemonize(flags) = daemonize, does not compile on NOMMU | ||
| 475 | * bb_daemonize_or_rexec(flags, argv) = daemonizes on MMU (and ignores argv), | ||
| 476 | * rexec's itself on NOMMU with argv passed as command line. | ||
| 477 | * Thus bb_daemonize_or_rexec may cause your <applet>_main() to be re-executed | ||
| 478 | * from the start. (It will detect it and not reexec again second time). | ||
| 479 | * You have to audit carefully that you don't do something twice as a result | ||
| 480 | * (opening files/sockets, parsing config files etc...)! | ||
| 481 | * | ||
| 482 | * Both of the above will redirect fd 0,1,2 to /dev/null and drop ctty | ||
| 483 | * (will do setsid()). | ||
| 484 | * | ||
| 485 | * Helper for network daemons in foreground mode: | ||
| 486 | * bb_sanitize_stdio() = make sure that fd 0,1,2 are opened by opening them | ||
| 487 | * to /dev/null if they are not. | ||
| 488 | */ | ||
| 489 | enum { | ||
| 490 | DAEMON_CHDIR_ROOT = 1, | ||
| 491 | DAEMON_DEVNULL_STDIO = /* 2 */ 0, /* no users so far */ | ||
| 492 | DAEMON_CLOSE_EXTRA_FDS = 4, | ||
| 493 | DAEMON_ONLY_SANITIZE = 8, /* internal use */ | ||
| 494 | }; | ||
| 495 | #ifndef BB_NOMMU | ||
| 496 | #define bb_daemonize_or_rexec(flags, argv) bb_daemonize_or_rexec(flags) | ||
| 497 | #define bb_daemonize(flags) bb_daemonize_or_rexec(flags, bogus) | ||
| 498 | #else | ||
| 499 | extern smallint re_execed; | ||
| 500 | pid_t BUG_fork_is_unavailable_on_nommu(void); | ||
| 501 | pid_t BUG_daemon_is_unavailable_on_nommu(void); | ||
| 502 | pid_t BUG_bb_daemonize_is_unavailable_on_nommu(void); | ||
| 503 | #define fork() BUG_fork_is_unavailable_on_nommu() | ||
| 504 | #define daemon(a,b) BUG_daemon_is_unavailable_on_nommu() | ||
| 505 | #define bb_daemonize(a) BUG_bb_daemonize_is_unavailable_on_nommu() | ||
| 506 | #endif | ||
| 507 | void bb_daemonize_or_rexec(int flags, char **argv); | ||
| 508 | void bb_sanitize_stdio(void); | ||
| 509 | |||
| 510 | |||
| 463 | enum { BB_GETOPT_ERROR = 0x80000000 }; | 511 | enum { BB_GETOPT_ERROR = 0x80000000 }; |
| 464 | extern const char *opt_complementary; | 512 | extern const char *opt_complementary; |
| 465 | #if ENABLE_GETOPT_LONG | 513 | #if ENABLE_GETOPT_LONG |
| @@ -569,20 +617,6 @@ char *concat_path_file(const char *path, const char *filename); | |||
| 569 | char *concat_subpath_file(const char *path, const char *filename); | 617 | char *concat_subpath_file(const char *path, const char *filename); |
| 570 | char *last_char_is(const char *s, int c); | 618 | char *last_char_is(const char *s, int c); |
| 571 | 619 | ||
| 572 | int execable_file(const char *name); | ||
| 573 | char *find_execable(const char *filename); | ||
| 574 | int exists_execable(const char *filename); | ||
| 575 | |||
| 576 | #if ENABLE_FEATURE_EXEC_PREFER_APPLETS | ||
| 577 | int bb_execvp(const char *file, char *const argv[]); | ||
| 578 | #define BB_EXECVP(prog,cmd) bb_execvp(prog,cmd) | ||
| 579 | #define BB_EXECLP(prog,cmd,...) \ | ||
| 580 | execlp((find_applet_by_name(prog)) ? CONFIG_BUSYBOX_EXEC_PATH : prog, \ | ||
| 581 | cmd, __VA_ARGS__) | ||
| 582 | #else | ||
| 583 | #define BB_EXECVP(prog,cmd) execvp(prog,cmd) | ||
| 584 | #define BB_EXECLP(prog,cmd,...) execlp(prog,cmd, __VA_ARGS__) | ||
| 585 | #endif | ||
| 586 | 620 | ||
| 587 | USE_DESKTOP(long long) int uncompress(int fd_in, int fd_out); | 621 | USE_DESKTOP(long long) int uncompress(int fd_in, int fd_out); |
| 588 | int inflate(int in, int out); | 622 | int inflate(int in, int out); |
| @@ -617,12 +651,8 @@ extern int index_in_str_array(const char * const string_array[], const char *key | |||
| 617 | extern int index_in_substr_array(const char * const string_array[], const char *key); | 651 | extern int index_in_substr_array(const char * const string_array[], const char *key); |
| 618 | extern void print_login_issue(const char *issue_file, const char *tty); | 652 | extern void print_login_issue(const char *issue_file, const char *tty); |
| 619 | extern void print_login_prompt(void); | 653 | extern void print_login_prompt(void); |
| 620 | #ifdef BB_NOMMU | 654 | |
| 621 | extern pid_t BUG_fork_is_unavailable_on_nommu(void); | 655 | |
| 622 | #define fork() BUG_fork_is_unavailable_on_nommu() | ||
| 623 | extern void vfork_daemon_rexec(int nochdir, int noclose, char **argv); | ||
| 624 | extern smallint re_execed; | ||
| 625 | #endif | ||
| 626 | extern int get_terminal_width_height(const int fd, int *width, int *height); | 656 | extern int get_terminal_width_height(const int fd, int *width, int *height); |
| 627 | 657 | ||
| 628 | char *is_in_ino_dev_hashtable(const struct stat *statbuf); | 658 | char *is_in_ino_dev_hashtable(const struct stat *statbuf); |
diff --git a/libbb/vfork_daemon_rexec.c b/libbb/vfork_daemon_rexec.c index 3185f2d39..c59b0b6fd 100644 --- a/libbb/vfork_daemon_rexec.c +++ b/libbb/vfork_daemon_rexec.c | |||
| @@ -18,11 +18,68 @@ | |||
| 18 | #include <paths.h> | 18 | #include <paths.h> |
| 19 | #include "libbb.h" | 19 | #include "libbb.h" |
| 20 | 20 | ||
| 21 | #ifdef BB_NOMMU | 21 | /* This does a fork/exec in one call, using vfork(). Returns PID of new child, |
| 22 | * -1 for failure. Runs argv[0], searching path if that has no / in it. */ | ||
| 23 | pid_t spawn(char **argv) | ||
| 24 | { | ||
| 25 | /* Compiler should not optimize stores here */ | ||
| 26 | volatile int failed; | ||
| 27 | pid_t pid; | ||
| 28 | |||
| 29 | // Be nice to nommu machines. | ||
| 30 | failed = 0; | ||
| 31 | pid = vfork(); | ||
| 32 | if (pid < 0) /* error */ | ||
| 33 | return pid; | ||
| 34 | if (!pid) { /* child */ | ||
| 35 | /* Don't use BB_EXECVP tricks here! */ | ||
| 36 | execvp(argv[0], argv); | ||
| 37 | |||
| 38 | /* We are (maybe) sharing a stack with blocked parent, | ||
| 39 | * let parent know we failed and then exit to unblock parent | ||
| 40 | * (but don't run atexit() stuff, which would screw up parent.) | ||
| 41 | */ | ||
| 42 | failed = errno; | ||
| 43 | _exit(0); | ||
| 44 | } | ||
| 45 | /* parent */ | ||
| 46 | /* Unfortunately, this is not reliable: vfork() | ||
| 47 | * can be equivalent to fork() according to standards */ | ||
| 48 | if (failed) { | ||
| 49 | errno = failed; | ||
| 50 | return -1; | ||
| 51 | } | ||
| 52 | return pid; | ||
| 53 | } | ||
| 54 | |||
| 55 | /* Die with an error message if we can't spawn a child process. */ | ||
| 56 | pid_t xspawn(char **argv) | ||
| 57 | { | ||
| 58 | pid_t pid = spawn(argv); | ||
| 59 | if (pid < 0) bb_perror_msg_and_die("%s", *argv); | ||
| 60 | return pid; | ||
| 61 | } | ||
| 62 | |||
| 63 | |||
| 64 | |||
| 65 | #if 0 //ndef BB_NOMMU | ||
| 66 | // Die with an error message if we can't daemonize. | ||
| 67 | void xdaemon(int nochdir, int noclose) | ||
| 68 | { | ||
| 69 | if (daemon(nochdir, noclose)) | ||
| 70 | bb_perror_msg_and_die("daemon"); | ||
| 71 | } | ||
| 72 | #endif | ||
| 73 | |||
| 74 | #if 0 // def BB_NOMMU | ||
| 22 | void vfork_daemon_rexec(int nochdir, int noclose, char **argv) | 75 | void vfork_daemon_rexec(int nochdir, int noclose, char **argv) |
| 23 | { | 76 | { |
| 24 | int fd; | 77 | int fd; |
| 25 | 78 | ||
| 79 | /* Maybe we are already re-execed and come here again? */ | ||
| 80 | if (re_execed) | ||
| 81 | return; | ||
| 82 | |||
| 26 | setsid(); | 83 | setsid(); |
| 27 | 84 | ||
| 28 | if (!nochdir) | 85 | if (!nochdir) |
| @@ -56,3 +113,78 @@ void vfork_daemon_rexec(int nochdir, int noclose, char **argv) | |||
| 56 | } | 113 | } |
| 57 | } | 114 | } |
| 58 | #endif /* BB_NOMMU */ | 115 | #endif /* BB_NOMMU */ |
| 116 | |||
| 117 | #ifdef BB_NOMMU | ||
| 118 | static void daemon_or_rexec(char **argv) | ||
| 119 | { | ||
| 120 | pid_t pid; | ||
| 121 | /* Maybe we are already re-execed and come here again? */ | ||
| 122 | if (re_execed) | ||
| 123 | return; | ||
| 124 | |||
| 125 | pid = vfork(); | ||
| 126 | if (pid < 0) /* wtf? */ | ||
| 127 | bb_perror_msg_and_die("vfork"); | ||
| 128 | if (pid) /* parent */ | ||
| 129 | exit(0); | ||
| 130 | /* child - re-exec ourself */ | ||
| 131 | /* high-order bit of first char in argv[0] is a hidden | ||
| 132 | * "we have (alrealy) re-execed, don't do it again" flag */ | ||
| 133 | argv[0][0] |= 0x80; | ||
| 134 | execv(CONFIG_BUSYBOX_EXEC_PATH, argv); | ||
| 135 | bb_perror_msg_and_die("exec %s", CONFIG_BUSYBOX_EXEC_PATH); | ||
| 136 | } | ||
| 137 | #else | ||
| 138 | static void daemon_or_rexec(void) | ||
| 139 | { | ||
| 140 | pid_t pid; | ||
| 141 | pid = fork(); | ||
| 142 | if (pid < 0) /* wtf? */ | ||
| 143 | bb_perror_msg_and_die("fork"); | ||
| 144 | if (pid) /* parent */ | ||
| 145 | exit(0); | ||
| 146 | /* child */ | ||
| 147 | } | ||
| 148 | #define daemon_or_rexec(argv) daemon_or_rexec() | ||
| 149 | #endif | ||
| 150 | |||
| 151 | |||
| 152 | /* Due to a #define in libbb.h on MMU systems we actually have 1 argument - | ||
| 153 | * char **argv "vanishes" */ | ||
| 154 | void bb_daemonize_or_rexec(int flags, char **argv) | ||
| 155 | { | ||
| 156 | int fd; | ||
| 157 | |||
| 158 | fd = xopen(bb_dev_null, O_RDWR); | ||
| 159 | |||
| 160 | if (flags & DAEMON_CHDIR_ROOT) | ||
| 161 | xchdir("/"); | ||
| 162 | |||
| 163 | if (flags & DAEMON_DEVNULL_STDIO) { | ||
| 164 | close(0); | ||
| 165 | close(1); | ||
| 166 | close(2); | ||
| 167 | } | ||
| 168 | |||
| 169 | while ((unsigned)fd < 2) | ||
| 170 | fd = dup(fd); /* have 0,1,2 open at least to /dev/null */ | ||
| 171 | |||
| 172 | if (!(flags & DAEMON_ONLY_SANITIZE)) { | ||
| 173 | daemon_or_rexec(argv); | ||
| 174 | /* if daemonizing, make sure we detach from stdio */ | ||
| 175 | setsid(); | ||
| 176 | dup2(fd, 0); | ||
| 177 | dup2(fd, 1); | ||
| 178 | dup2(fd, 2); | ||
| 179 | } | ||
| 180 | if (fd > 2) | ||
| 181 | close(fd--); | ||
| 182 | if (flags & DAEMON_CLOSE_EXTRA_FDS) | ||
| 183 | while (fd > 2) | ||
| 184 | close(fd--); /* close everything after fd#2 */ | ||
| 185 | } | ||
| 186 | |||
| 187 | void bb_sanitize_stdio(void) | ||
| 188 | { | ||
| 189 | bb_daemonize_or_rexec(DAEMON_ONLY_SANITIZE, NULL); | ||
| 190 | } | ||
diff --git a/libbb/xfuncs.c b/libbb/xfuncs.c index 1dcdbc065..14bd62a15 100644 --- a/libbb/xfuncs.c +++ b/libbb/xfuncs.c | |||
| @@ -187,43 +187,6 @@ void xfflush_stdout(void) | |||
| 187 | } | 187 | } |
| 188 | } | 188 | } |
| 189 | 189 | ||
| 190 | // This does a fork/exec in one call, using vfork(). Return PID of new child, | ||
| 191 | // -1 for failure. Runs argv[0], searching path if that has no / in it. | ||
| 192 | pid_t spawn(char **argv) | ||
| 193 | { | ||
| 194 | /* Why static? */ | ||
| 195 | static int failed; | ||
| 196 | pid_t pid; | ||
| 197 | |||
| 198 | // Be nice to nommu machines. | ||
| 199 | failed = 0; | ||
| 200 | pid = vfork(); | ||
| 201 | if (pid < 0) return pid; | ||
| 202 | if (!pid) { | ||
| 203 | BB_EXECVP(argv[0], argv); | ||
| 204 | |||
| 205 | // We're sharing a stack with blocked parent, let parent know we failed | ||
| 206 | // and then exit to unblock parent (but don't run atexit() stuff, which | ||
| 207 | // would screw up parent.) | ||
| 208 | |||
| 209 | failed = errno; | ||
| 210 | _exit(0); | ||
| 211 | } | ||
| 212 | if (failed) { | ||
| 213 | errno = failed; | ||
| 214 | return -1; | ||
| 215 | } | ||
| 216 | return pid; | ||
| 217 | } | ||
| 218 | |||
| 219 | // Die with an error message if we can't spawn a child process. | ||
| 220 | pid_t xspawn(char **argv) | ||
| 221 | { | ||
| 222 | pid_t pid = spawn(argv); | ||
| 223 | if (pid < 0) bb_perror_msg_and_die("%s", *argv); | ||
| 224 | return pid; | ||
| 225 | } | ||
| 226 | |||
| 227 | // Wait for the specified child PID to exit, returning child's error return. | 190 | // Wait for the specified child PID to exit, returning child's error return. |
| 228 | int wait4pid(int pid) | 191 | int wait4pid(int pid) |
| 229 | { | 192 | { |
| @@ -510,47 +473,6 @@ DIR *xopendir(const char *path) | |||
| 510 | return dp; | 473 | return dp; |
| 511 | } | 474 | } |
| 512 | 475 | ||
| 513 | #ifndef BB_NOMMU | ||
| 514 | // Die with an error message if we can't daemonize. | ||
| 515 | void xdaemon(int nochdir, int noclose) | ||
| 516 | { | ||
| 517 | if (daemon(nochdir, noclose)) | ||
| 518 | bb_perror_msg_and_die("daemon"); | ||
| 519 | } | ||
| 520 | #endif | ||
| 521 | |||
| 522 | void bb_sanitize_stdio_maybe_daemonize(int daemonize) | ||
| 523 | { | ||
| 524 | int fd; | ||
| 525 | /* Mega-paranoid */ | ||
| 526 | fd = xopen(bb_dev_null, O_RDWR); | ||
| 527 | while ((unsigned)fd < 2) | ||
| 528 | fd = dup(fd); /* have 0,1,2 open at least to /dev/null */ | ||
| 529 | if (daemonize) { | ||
| 530 | pid_t pid = fork(); | ||
| 531 | if (pid < 0) /* wtf? */ | ||
| 532 | bb_perror_msg_and_die("fork"); | ||
| 533 | if (pid) /* parent */ | ||
| 534 | exit(0); | ||
| 535 | /* child */ | ||
| 536 | /* if daemonizing, make sure we detach from stdio */ | ||
| 537 | setsid(); | ||
| 538 | dup2(fd, 0); | ||
| 539 | dup2(fd, 1); | ||
| 540 | dup2(fd, 2); | ||
| 541 | } | ||
| 542 | while (fd > 2) | ||
| 543 | close(fd--); /* close everything after fd#2 */ | ||
| 544 | } | ||
| 545 | void bb_sanitize_stdio(void) | ||
| 546 | { | ||
| 547 | bb_sanitize_stdio_maybe_daemonize(0); | ||
| 548 | } | ||
| 549 | void bb_daemonize(void) | ||
| 550 | { | ||
| 551 | bb_sanitize_stdio_maybe_daemonize(1); | ||
| 552 | } | ||
| 553 | |||
| 554 | // Die with an error message if we can't open a new socket. | 476 | // Die with an error message if we can't open a new socket. |
| 555 | int xsocket(int domain, int type, int protocol) | 477 | int xsocket(int domain, int type, int protocol) |
| 556 | { | 478 | { |
