diff options
| -rw-r--r-- | daemon.c | 53 | ||||
| -rw-r--r-- | daemon.h | 3 |
2 files changed, 53 insertions, 3 deletions
diff --git a/daemon.c b/daemon.c index c759f20..13098af 100644 --- a/daemon.c +++ b/daemon.c @@ -17,6 +17,7 @@ #include <err.h> #include <errno.h> #include <fcntl.h> +#include <fnmatch.h> #include <grp.h> #include <poll.h> #include <pwd.h> @@ -27,6 +28,7 @@ #include <stdio.h> #include <stdlib.h> #include <string.h> +#include <strings.h> #include <sys/stat.h> #include <sys/time.h> #include <sys/wait.h> @@ -115,6 +117,50 @@ err: fclose(file); } +typedef void Action(struct Service *service); +static void parseControl(char *command) { + char *action = strsep(&command, WS); + if (!command) { + syslog(LOG_NOTICE, "no service names for %s", action); + return; + } + + Action *fn = NULL; + int signal = 0; + if (!strcmp(action, "start")) { + fn = serviceStart; + } else if (!strcmp(action, "stop")) { + fn = serviceStop; + } else if (!strcmp(action, "restart")) { + fn = serviceRestart; + } else if (!strcmp(action, "status")) { + // TODO + } else { + for (int i = 1; i < NSIG; ++i) { + if (strcasecmp(action, sys_signame[i])) continue; + signal = i; + break; + } + } + if (!fn && !signal) { + syslog(LOG_NOTICE, "unknown action or signal %s", action); + return; + } + + while (command) { + char *pattern = strsep(&command, WS); + for (size_t i = 0; i < services.len; ++i) { + struct Service *service = &services.ptr[i]; + if (fnmatch(pattern, service->name, 0)) continue; + if (signal) { + serviceSignal(service, signal); + } else { + fn(service); + } + } + } +} + static void parseExits(char *list) { setClear(&stopExits); while (*list) { @@ -288,7 +334,9 @@ int main(int argc, char *argv[]) { if (nfds > 0 && fds[0].revents) { const char *line; while (NULL != (line = lineRead(&fifoLine, fifo))) { - syslog(LOG_INFO, "control: %s", line); + char buf[LineCap]; + snprintf(buf, sizeof(buf), "%s", line); + parseControl(buf); } if (errno != EAGAIN) syslog(LOG_ERR, "read: %m"); } @@ -331,7 +379,8 @@ int main(int argc, char *argv[]) { signals[SIGHUP] = 0; } if (signals[SIGINFO]) { - // TODO: status * + char command[] = "status *"; + parseControl(command); signals[SIGINFO] = 0; } } diff --git a/daemon.h b/daemon.h index 17b1c7f..b8b288b 100644 --- a/daemon.h +++ b/daemon.h @@ -51,9 +51,10 @@ static inline int prependAdd(const char *command) { return 0; } +enum { LineCap = 512 }; struct Line { size_t len; - char buf[512]; + char buf[LineCap]; }; static inline const char *lineFlush(struct Line *line) { |