2 b0a6bcf7 2022-09-13 op * Copyright (c) 2022 Omar Polo <op@omarpolo.com>
3 b0a6bcf7 2022-09-13 op * Copyright (c) 2011 - 2015 Reyk Floeter <reyk@openbsd.org>
5 b0a6bcf7 2022-09-13 op * Permission to use, copy, modify, and distribute this software for any
6 b0a6bcf7 2022-09-13 op * purpose with or without fee is hereby granted, provided that the above
7 b0a6bcf7 2022-09-13 op * copyright notice and this permission notice appear in all copies.
9 b0a6bcf7 2022-09-13 op * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10 b0a6bcf7 2022-09-13 op * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11 b0a6bcf7 2022-09-13 op * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12 b0a6bcf7 2022-09-13 op * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13 b0a6bcf7 2022-09-13 op * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14 b0a6bcf7 2022-09-13 op * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15 b0a6bcf7 2022-09-13 op * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
18 b0a6bcf7 2022-09-13 op #include <sys/types.h>
19 b0a6bcf7 2022-09-13 op #include <sys/queue.h>
20 b0a6bcf7 2022-09-13 op #include <sys/socket.h>
21 b0a6bcf7 2022-09-13 op #include <sys/un.h>
22 b0a6bcf7 2022-09-13 op #include <sys/tree.h>
23 b0a6bcf7 2022-09-13 op #include <sys/time.h>
24 b0a6bcf7 2022-09-13 op #include <sys/uio.h>
26 b0a6bcf7 2022-09-13 op #include <sys/stat.h> /* umask */
27 b0a6bcf7 2022-09-13 op #include <sys/un.h> /* sockaddr_un */
29 b0a6bcf7 2022-09-13 op #include <errno.h>
30 b0a6bcf7 2022-09-13 op #include <event.h>
31 b0a6bcf7 2022-09-13 op #include <limits.h>
32 b0a6bcf7 2022-09-13 op #include <pwd.h>
33 b0a6bcf7 2022-09-13 op #include <unistd.h>
34 b0a6bcf7 2022-09-13 op #include <stdlib.h>
35 b0a6bcf7 2022-09-13 op #include <stdio.h>
36 b0a6bcf7 2022-09-13 op #include <string.h>
37 b0a6bcf7 2022-09-13 op #include <imsg.h>
39 b0a6bcf7 2022-09-13 op #include "proc.h"
40 b0a6bcf7 2022-09-13 op #include "log.h"
41 b0a6bcf7 2022-09-13 op #include "xmalloc.h"
43 b0a6bcf7 2022-09-13 op #include "galileo.h"
46 b0a6bcf7 2022-09-13 op config_init(struct galileo *env)
48 b0a6bcf7 2022-09-13 op /* Global configuration */
49 b0a6bcf7 2022-09-13 op if (privsep_process == PROC_PARENT)
50 b0a6bcf7 2022-09-13 op env->sc_prefork = PROXY_NUMPROC;
52 b0a6bcf7 2022-09-13 op /* Other configuration. */
53 afb86b2c 2022-09-23 op TAILQ_INIT(&env->sc_proxies);
55 b0a6bcf7 2022-09-13 op env->sc_sock_fd = -1;
61 b0a6bcf7 2022-09-13 op config_purge(struct galileo *env)
63 afb86b2c 2022-09-23 op struct proxy *p;
64 40f762b2 2022-09-23 op struct fcgi *fcgi;
65 40f762b2 2022-09-23 op struct client *clt;
67 40f762b2 2022-09-23 op while ((fcgi = SPLAY_MIN(fcgi_tree, &env->sc_fcgi_socks))) {
68 40f762b2 2022-09-23 op while ((clt = SPLAY_MIN(client_tree, &fcgi->fcg_clients))) {
69 40f762b2 2022-09-23 op if (fcgi_abort_request(clt) == -1) {
75 40f762b2 2022-09-23 op if (fcgi == NULL)
78 40f762b2 2022-09-23 op SPLAY_REMOVE(fcgi_tree, &env->sc_fcgi_socks, fcgi);
79 40f762b2 2022-09-23 op fcgi_free(fcgi);
82 40f762b2 2022-09-23 op event_del(&env->sc_evsock);
83 40f762b2 2022-09-23 op event_del(&env->sc_evpause);
84 40f762b2 2022-09-23 op close(env->sc_sock_fd);
85 40f762b2 2022-09-23 op env->sc_sock_fd = -1;
87 afb86b2c 2022-09-23 op while ((p = TAILQ_FIRST(&env->sc_proxies)) != NULL) {
88 afb86b2c 2022-09-23 op TAILQ_REMOVE(&env->sc_proxies, p, pr_entry);
89 afb86b2c 2022-09-23 op proxy_purge(p);
94 afb86b2c 2022-09-23 op config_setproxy(struct galileo *env, struct proxy *p)
96 b0a6bcf7 2022-09-13 op struct privsep *ps = env->sc_ps;
98 afb86b2c 2022-09-23 op if (proc_compose(ps, PROC_PROXY, IMSG_CFG_SRV, p, sizeof(*p)) == -1)
99 b0a6bcf7 2022-09-13 op fatal("proc_compose");
104 afb86b2c 2022-09-23 op config_getproxy(struct galileo *env, struct imsg *imsg)
106 afb86b2c 2022-09-23 op struct proxy *proxy;
108 afb86b2c 2022-09-23 op proxy = xcalloc(1, sizeof(*proxy));
109 afb86b2c 2022-09-23 op if (IMSG_DATA_SIZE(imsg) != sizeof(*proxy))
110 b0a6bcf7 2022-09-13 op fatalx("%s: bad imsg size", __func__);
112 afb86b2c 2022-09-23 op memcpy(proxy, imsg->data, sizeof(*proxy));
114 26cd3e9d 2022-09-23 op log_debug("%s: proxy=%s -> %s:%s (%s)", __func__,
115 afb86b2c 2022-09-23 op proxy->pr_conf.host, proxy->pr_conf.proxy_addr,
116 afb86b2c 2022-09-23 op proxy->pr_conf.proxy_port, proxy->pr_conf.proxy_name);
118 afb86b2c 2022-09-23 op TAILQ_INSERT_TAIL(&env->sc_proxies, proxy, pr_entry);
124 b0a6bcf7 2022-09-13 op config_setsock(struct galileo *env)
126 b0a6bcf7 2022-09-13 op struct privsep *ps = env->sc_ps;
127 b0a6bcf7 2022-09-13 op struct passwd *pw = ps->ps_pw;
128 b0a6bcf7 2022-09-13 op struct sockaddr_un sun;
129 b0a6bcf7 2022-09-13 op const char *path = GALILEO_SOCK;
130 b0a6bcf7 2022-09-13 op int id, fd, old_umask;
133 b0a6bcf7 2022-09-13 op * open listening socket.
135 b0a6bcf7 2022-09-13 op * XXX: move to server.c as server_privinit like httpd once we
136 b0a6bcf7 2022-09-13 op * support more than one listening socket.
138 b0a6bcf7 2022-09-13 op if ((fd = socket(AF_UNIX, SOCK_STREAM | SOCK_NONBLOCK, 0)) == -1) {
139 b0a6bcf7 2022-09-13 op log_warn("%s: socket", __func__);
143 b0a6bcf7 2022-09-13 op memset(&sun, 0, sizeof(sun));
144 b0a6bcf7 2022-09-13 op sun.sun_family = AF_UNIX;
145 b0a6bcf7 2022-09-13 op strlcpy(sun.sun_path, path, sizeof(sun.sun_path));
147 b0a6bcf7 2022-09-13 op if (unlink(path) == -1)
148 b0a6bcf7 2022-09-13 op if (errno != ENOENT) {
149 b0a6bcf7 2022-09-13 op log_warn("%s: unlink %s", __func__, path);
154 b0a6bcf7 2022-09-13 op old_umask = umask(S_IXUSR|S_IXGRP|S_IWOTH|S_IROTH|S_IXOTH);
155 b0a6bcf7 2022-09-13 op if (bind(fd, (struct sockaddr *)&sun, sizeof(sun)) == -1) {
156 b0a6bcf7 2022-09-13 op log_warn("%s: bind: %s (%d)", __func__, path, geteuid());
158 b0a6bcf7 2022-09-13 op umask(old_umask);
161 b0a6bcf7 2022-09-13 op umask(old_umask);
163 b0a6bcf7 2022-09-13 op if (chmod(path, S_IRUSR|S_IWUSR|S_IRGRP|S_IWGRP) == -1) {
164 b0a6bcf7 2022-09-13 op log_warn("%s: chmod", __func__);
166 b0a6bcf7 2022-09-13 op (void)unlink(path);
170 b0a6bcf7 2022-09-13 op if (chown(path, pw->pw_uid, pw->pw_gid) == -1) {
171 b0a6bcf7 2022-09-13 op log_warn("%s: chown", __func__);
173 b0a6bcf7 2022-09-13 op (void)unlink(path);
177 b0a6bcf7 2022-09-13 op if (listen(fd, 5) == -1) {
178 b0a6bcf7 2022-09-13 op log_warn("%s: listen", __func__);
180 b0a6bcf7 2022-09-13 op (void)unlink(path);
184 b0a6bcf7 2022-09-13 op for (id = 0; id < PROC_MAX; ++id) {
187 b0a6bcf7 2022-09-13 op if (id == privsep_process || id != PROC_PROXY)
191 b0a6bcf7 2022-09-13 op proc_range(ps, id, &n, &m);
192 b0a6bcf7 2022-09-13 op for (n = 0; n < m; ++n) {
195 b0a6bcf7 2022-09-13 op if ((d = dup(fd)) == -1) {
196 b0a6bcf7 2022-09-13 op log_warn("%s: dup", __func__);
201 b0a6bcf7 2022-09-13 op if (proc_compose_imsg(ps, id, n, IMSG_CFG_SOCK,
202 b0a6bcf7 2022-09-13 op -1, d, NULL, 0) == -1) {
203 b0a6bcf7 2022-09-13 op log_warn("%s: failed to compose "
204 b0a6bcf7 2022-09-13 op "IMSG_CFG_SOCK", __func__);
208 b0a6bcf7 2022-09-13 op if (proc_flush_imsg(ps, id, n) == -1) {
209 b0a6bcf7 2022-09-13 op log_warn("%s: failed to flush", __func__);
221 b0a6bcf7 2022-09-13 op config_getsock(struct galileo *env, struct imsg *imsg)
223 b0a6bcf7 2022-09-13 op /* XXX: make it more like httpd/gotwebd' one */
224 c9e6d547 2022-09-23 op return (imsg->fd);
228 b0a6bcf7 2022-09-13 op config_setreset(struct galileo *env)
230 b0a6bcf7 2022-09-13 op struct privsep *ps = env->sc_ps;
233 b0a6bcf7 2022-09-13 op for (id = 0; id < PROC_MAX; ++id)
234 40f762b2 2022-09-23 op if (id != PROC_PARENT)
235 40f762b2 2022-09-23 op proc_compose(ps, id, IMSG_CTL_RESET, NULL, 0);
241 b0a6bcf7 2022-09-13 op config_getreset(struct galileo *env, struct imsg *imsg)
243 b0a6bcf7 2022-09-13 op config_purge(env);
249 40f762b2 2022-09-23 op config_getcfg(struct galileo *env, struct imsg *imsg)
251 40f762b2 2022-09-23 op if (privsep_process != PROC_PARENT)
252 40f762b2 2022-09-23 op proc_compose(env->sc_ps, PROC_PARENT,
253 40f762b2 2022-09-23 op IMSG_CFG_DONE, NULL, 0);