diff options
Diffstat (limited to '')
| -rw-r--r-- | src/gammad.c | 133 |
1 files changed, 121 insertions, 12 deletions
diff --git a/src/gammad.c b/src/gammad.c index eef65b7..6fb2076 100644 --- a/src/gammad.c +++ b/src/gammad.c @@ -25,6 +25,7 @@ #include <stdio.h> #include <string.h> #include <unistd.h> +#include <signal.h> #include "arg.h" #include "output.h" @@ -238,7 +239,7 @@ static int is_pidfile_reusable(const char* pidfile, const char* token) { if (++tries > 1) goto bad; - usleep(100000); /* 1 tenth of a second */ + usleep(100000); /* 1 tenth of a second */ /* TODO replace with nanosleep */ goto retry; } @@ -373,7 +374,7 @@ static void usage(void) /** - * Must not be started without stdout or stderr (may be /dev/null) + * Must not be started without stdin, stdout, or stderr (may be /dev/null) * * The process closes stdout when the socket has been created * @@ -383,7 +384,8 @@ static void usage(void) */ int main(int argc, char** argv) { - int method = -1, gerror, rc = 1, preserve = 0, r; + int method = -1, gerror, rc = 1, preserve = 0, foreground = 0, r; + int keep_stderr = 0; char* sitename = NULL; libgamma_site_state_t site; libgamma_partition_state_t* partitions = NULL; @@ -391,6 +393,7 @@ int main(int argc, char** argv) size_t i, j, n, n0; char* pidpath = NULL; char* socketpath = NULL; + sigset_t mask; memset(&site, 0, sizeof(site)); @@ -407,6 +410,12 @@ int main(int argc, char** argv) case 'p': preserve = 1; break; + case 'f': + foreground = 1; + break; + case 'k': + keep_stderr = 1; + break; default: usage(); } @@ -414,6 +423,17 @@ int main(int argc, char** argv) if (argc > 0) usage(); + /* TODO Close all file descriptors above stderr */ + + /* Set umask, reset signal handlers, and reset signal mask */ + umask(0); + for (r = 1; r < _NSIG; r++) + signal(r, SIG_DFL); + if (sigfillset(&mask)) + perror(argv0); + else + sigprocmask(SIG_UNBLOCK, &mask, NULL); + /* Get method */ if ((method < 0) && (libgamma_list_methods(&method, 1, 0) < 1)) return fprintf(stderr, "%s: no adjustment method available\n", argv0), 1; @@ -436,15 +456,6 @@ int main(int argc, char** argv) goto fail; } - /* TODO socket */ - - /* Signal the spawner that the service is ready */ - close(STDOUT_FILENO); - /* Avoid potential catastrophes that would occur if a library that is being - * used was so mindless as to write to stdout. */ - if (dup2(STDERR_FILENO, STDOUT_FILENO) < 0) - perror(argv0); - /* Get partitions */ if (site.partitions_available) if (!(partitions = calloc(site.partitions_available, sizeof(*partitions)))) @@ -577,6 +588,104 @@ int main(int argc, char** argv) goto fail; } + /* TODO socket */ + + /* Change directory to / to avoid blocking umounting. */ + if (chdir("/") < 0) + perror(argv0); + + /* Place in the background unless -f */ + if (foreground == 0) + { + pid_t pid; + int fd = -1, saved_errno; + int notify_rw[2] = { -1, -1 }; + char a_byte = 0; + ssize_t got; + + if (pipe(notify_rw) < 0) + goto fail; + if (notify_rw[0] <= STDERR_FILENO) + if ((notify_rw[0] = dup2atleast(notify_rw[0], STDERR_FILENO + 1)) < 0) + goto fail_background; + if (notify_rw[1] <= STDERR_FILENO) + if ((notify_rw[1] = dup2atleast(notify_rw[1], STDERR_FILENO + 1)) < 0) + goto fail_background; + + switch ((pid = fork())) + { + case -1: + goto fail_background; + case 0: + /* Child */ + close(notify_rw[0]), notify_rw[0] = -1; + if (setsid() < 0) + goto fail_background; + switch ((pid = fork())) + { + case -1: + goto fail_background; + case 0: + /* Replace std* with /dev/null */ + fd = open("/dev/null", O_RDWR); + if (fd < 0) + goto fail; +#define xdup2(s, d) do if (s != d) { close(d); if (dup2(s, d) < 0) goto fail; } while (0) + xdup2(fd, STDIN_FILENO); + xdup2(fd, STDOUT_FILENO); + if (keep_stderr) + xdup2(fd, STDERR_FILENO); + if (fd > STDERR_FILENO) + close(fd); + fd = -1; + + /* Update PID file */ + fd = open(pidpath, O_WRONLY); + if (fd < 0) + goto fail_background; + if (dprintf(fd, "%llu\n", (unsigned long long)getpid()) < 0) + goto fail_background; + close(fd), fd = -1; + + /* Notify */ + if (write(notify_rw[1], &a_byte, 1) <= 0) + goto fail_background; + close(notify_rw[1]); + break; + default: + /* Parent */ + return 0; + } + break; + default: + /* Parent */ + close(notify_rw[1]), notify_rw[1] = -1; + got = read(notify_rw[0], &a_byte, 1); + if (got < 0) + goto fail_background; + close(notify_rw[0]); + return got == 0; + } + + goto done_background; + fail_background: + saved_errno = errno; + if (fd >= 0) close(fd); + if (notify_rw[0] >= 0) close(notify_rw[0]); + if (notify_rw[1] >= 0) close(notify_rw[1]); + errno = saved_errno; + done_background:; + } + else + { + /* Signal the spawner that the service is ready */ + close(STDOUT_FILENO); + /* Avoid potential catastrophes that would occur if a library that is being + * used was so mindless as to write to stdout. */ + if (dup2(STDERR_FILENO, STDOUT_FILENO) < 0) + perror(argv0); + } + /* Done */ rc = 0; done: |