2 * Copyright (c) 2020-2021 Tracey Emery <tracey@traceyemery.net>
3 * Copyright (c) 2015 Reyk Floeter <reyk@openbsd.org>
5 * Permission to use, copy, modify, and distribute this software for any
6 * purpose with or without fee is hereby granted, provided that the above
7 * copyright notice and this permission notice appear in all copies.
9 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
18 #include <sys/types.h>
19 #include <sys/queue.h>
22 #include <sys/socket.h>
25 #include <netinet/in.h>
39 #include "got_opentemp.h"
40 #include "got_reference.h"
45 config_init(struct gotwebd *env)
47 strlcpy(env->httpd_chroot, D_HTTPD_CHROOT, sizeof(env->httpd_chroot));
49 env->prefork_gotwebd = GOTWEBD_NUMPROC;
51 TAILQ_INIT(&env->servers);
52 TAILQ_INIT(&env->sockets);
53 TAILQ_INIT(&env->addresses);
59 config_getcfg(struct gotwebd *env, struct imsg *imsg)
61 /* nothing to do but tell gotwebd configuration is done */
62 if (sockets_compose_main(env, IMSG_CFG_DONE, NULL, 0) == -1)
63 fatal("sockets_compose_main IMSG_CFG_DONE");
68 config_setserver(struct gotwebd *env, struct server *srv)
70 if (main_compose_sockets(env, IMSG_CFG_SRV, -1, srv, sizeof(*srv))
72 fatal("main_compose_sockets IMSG_CFG_SRV");
77 config_getserver(struct gotwebd *env, struct imsg *imsg)
80 uint8_t *p = imsg->data;
82 srv = calloc(1, sizeof(*srv));
84 fatalx("%s: calloc", __func__);
86 if (IMSG_DATA_SIZE(imsg) != sizeof(*srv))
87 fatalx("%s: wrong size", __func__);
89 memcpy(srv, p, sizeof(*srv));
92 log_debug("%s: server=%s", __func__, srv->name);
94 TAILQ_INSERT_TAIL(&env->servers, srv, entry);
100 config_setsock(struct gotwebd *env, struct socket *sock)
102 /* open listening sockets */
103 if (sockets_privinit(env, sock) == -1)
106 if (main_compose_sockets(env, IMSG_CFG_SOCK, sock->fd,
107 &sock->conf, sizeof(sock->conf)) == -1)
108 fatal("main_compose_sockets IMSG_CFG_SOCK");
115 config_getsock(struct gotwebd *env, struct imsg *imsg)
117 struct socket *sock = NULL;
118 struct socket_conf sock_conf;
119 uint8_t *p = imsg->data;
122 if (IMSG_DATA_SIZE(imsg) != sizeof(sock_conf))
123 fatalx("%s: wrong size", __func__);
125 memcpy(&sock_conf, p, sizeof(sock_conf));
127 if (IMSG_DATA_SIZE(imsg) != sizeof(sock_conf)) {
128 log_debug("%s: imsg size error", __func__);
132 /* create a new socket */
133 if ((sock = calloc(1, sizeof(*sock))) == NULL) {
137 memcpy(&sock->conf, &sock_conf, sizeof(sock->conf));
138 sock->fd = imsg_get_fd(imsg);
140 TAILQ_INSERT_TAIL(&env->sockets, sock, entry);
142 for (i = 0; i < PRIV_FDS__MAX; i++)
143 sock->priv_fd[i] = -1;
145 for (i = 0; i < GOTWEB_PACK_NUM_TEMPFILES; i++)
146 sock->pack_fds[i] = -1;
148 /* log new socket info */
149 log_debug("%s: id=%d af_type=%s socket_path=%s",
150 __func__, sock->conf.id,
151 sock->conf.af_type == AF_UNIX ? "unix" :
152 (sock->conf.af_type == AF_INET ? "inet" :
153 (sock->conf.af_type == AF_INET6 ? "inet6" : "unknown")),
154 *sock->conf.unix_socket_name != '\0' ?
155 sock->conf.unix_socket_name : "none");
161 config_setfd(struct gotwebd *env, struct socket *sock)
165 log_debug("%s: Allocating %d file descriptors",
166 __func__, PRIV_FDS__MAX + GOTWEB_PACK_NUM_TEMPFILES);
168 for (i = 0; i < PRIV_FDS__MAX + GOTWEB_PACK_NUM_TEMPFILES; i++) {
169 for (j = 0; j < env->nserver; ++j) {
170 fd = got_opentempfd();
172 fatal("got_opentemp");
173 if (imsg_compose_event(&env->iev_server[j],
174 IMSG_CFG_FD, 0, -1, fd, &sock->conf.id,
175 sizeof(sock->conf.id)) == -1)
176 fatal("imsg_compose_event IMSG_CFG_FD");
179 ret = imsg_flush(&env->iev_server[j].ibuf);
180 } while (ret == -1 && errno == EAGAIN);
183 imsg_event_add(&env->iev_server[j]);
191 config_getfd(struct gotwebd *env, struct imsg *imsg)
194 uint8_t *p = imsg->data;
195 int sock_id, match = 0, i, j;
197 if (IMSG_DATA_SIZE(imsg) != sizeof(sock_id))
198 fatalx("%s: wrong size", __func__);
200 memcpy(&sock_id, p, sizeof(sock_id));
202 TAILQ_FOREACH(sock, &env->sockets, entry) {
203 const int nfds = (GOTWEB_PACK_NUM_TEMPFILES + PRIV_FDS__MAX);
204 for (i = 0; i < nfds; i++) {
205 if (i < PRIV_FDS__MAX && sock->priv_fd[i] == -1) {
206 sock->priv_fd[i] = imsg_get_fd(imsg);
207 log_debug("%s: assigning socket %d priv_fd %d",
208 __func__, sock_id, sock->priv_fd[i]);
213 j = i - PRIV_FDS__MAX;
214 if (sock->pack_fds[j] == -1) {
215 sock->pack_fds[j] = imsg_get_fd(imsg);
216 log_debug("%s: assigning socket %d pack_fd %d",
217 __func__, sock_id, sock->pack_fds[j]);