Blame


1 881a9dd9 2021-01-16 op /*
2 881a9dd9 2021-01-16 op * Copyright (c) 2021 Omar Polo <op@omarpolo.com>
3 881a9dd9 2021-01-16 op *
4 881a9dd9 2021-01-16 op * Permission to use, copy, modify, and distribute this software for any
5 881a9dd9 2021-01-16 op * purpose with or without fee is hereby granted, provided that the above
6 881a9dd9 2021-01-16 op * copyright notice and this permission notice appear in all copies.
7 881a9dd9 2021-01-16 op *
8 881a9dd9 2021-01-16 op * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9 881a9dd9 2021-01-16 op * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10 881a9dd9 2021-01-16 op * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11 881a9dd9 2021-01-16 op * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12 881a9dd9 2021-01-16 op * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13 881a9dd9 2021-01-16 op * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14 881a9dd9 2021-01-16 op * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
15 881a9dd9 2021-01-16 op */
16 52418c8d 2021-02-12 op
17 52418c8d 2021-02-12 op #include "gmid.h"
18 881a9dd9 2021-01-16 op
19 8ad1c570 2021-05-09 op #include <sys/un.h>
20 8ad1c570 2021-05-09 op
21 881a9dd9 2021-01-16 op #include <err.h>
22 881a9dd9 2021-01-16 op #include <errno.h>
23 881a9dd9 2021-01-16 op
24 2c3e53da 2021-03-03 op #include <event.h>
25 881a9dd9 2021-01-16 op #include <fcntl.h>
26 2fafa2d2 2021-02-01 op #include <libgen.h>
27 2fafa2d2 2021-02-01 op #include <limits.h>
28 881a9dd9 2021-01-16 op #include <signal.h>
29 2fafa2d2 2021-02-01 op #include <stdarg.h>
30 881a9dd9 2021-01-16 op #include <string.h>
31 881a9dd9 2021-01-16 op
32 bc99d868 2021-03-19 op static void handle_imsg_cgi_req(struct imsgbuf*, struct imsg*, size_t);
33 8ad1c570 2021-05-09 op static void handle_imsg_fcgi_req(struct imsgbuf*, struct imsg*, size_t);
34 72b033ef 2021-12-29 op static void handle_imsg_conn_req(struct imsgbuf *, struct imsg *, size_t);
35 bc99d868 2021-03-19 op static void handle_imsg_quit(struct imsgbuf*, struct imsg*, size_t);
36 bc99d868 2021-03-19 op static void handle_dispatch_imsg(int, short, void*);
37 881a9dd9 2021-01-16 op
38 bc99d868 2021-03-19 op static imsg_handlerfn *handlers[] = {
39 8ad1c570 2021-05-09 op [IMSG_FCGI_REQ] = handle_imsg_fcgi_req,
40 bc99d868 2021-03-19 op [IMSG_CGI_REQ] = handle_imsg_cgi_req,
41 72b033ef 2021-12-29 op [IMSG_CONN_REQ] = handle_imsg_conn_req,
42 bc99d868 2021-03-19 op [IMSG_QUIT] = handle_imsg_quit,
43 bc99d868 2021-03-19 op };
44 881a9dd9 2021-01-16 op
45 881a9dd9 2021-01-16 op static inline void
46 881a9dd9 2021-01-16 op safe_setenv(const char *name, const char *val)
47 881a9dd9 2021-01-16 op {
48 881a9dd9 2021-01-16 op if (val == NULL)
49 881a9dd9 2021-01-16 op val = "";
50 881a9dd9 2021-01-16 op setenv(name, val, 1);
51 881a9dd9 2021-01-16 op }
52 881a9dd9 2021-01-16 op
53 2fafa2d2 2021-02-01 op static char *
54 2fafa2d2 2021-02-01 op xasprintf(const char *fmt, ...)
55 2fafa2d2 2021-02-01 op {
56 2fafa2d2 2021-02-01 op va_list ap;
57 2fafa2d2 2021-02-01 op char *s;
58 2fafa2d2 2021-02-01 op
59 2fafa2d2 2021-02-01 op va_start(ap, fmt);
60 2fafa2d2 2021-02-01 op if (vasprintf(&s, fmt, ap) == -1)
61 2fafa2d2 2021-02-01 op s = NULL;
62 2fafa2d2 2021-02-01 op va_end(ap);
63 2fafa2d2 2021-02-01 op
64 2fafa2d2 2021-02-01 op return s;
65 9f006a21 2021-02-07 op }
66 9f006a21 2021-02-07 op
67 9f006a21 2021-02-07 op static void
68 9f006a21 2021-02-07 op do_exec(const char *ex, const char *spath, char *query)
69 9f006a21 2021-02-07 op {
70 9f006a21 2021-02-07 op char **argv, buf[PATH_MAX], *sname, *t;
71 9f006a21 2021-02-07 op size_t i, n;
72 9f006a21 2021-02-07 op
73 3841a369 2021-04-20 op /* restore the default handlers */
74 3841a369 2021-04-20 op signal(SIGPIPE, SIG_DFL);
75 3841a369 2021-04-20 op signal(SIGCHLD, SIG_DFL);
76 3841a369 2021-04-20 op signal(SIGHUP, SIG_DFL);
77 3841a369 2021-04-20 op signal(SIGINT, SIG_DFL);
78 3841a369 2021-04-20 op signal(SIGTERM, SIG_DFL);
79 3841a369 2021-04-20 op
80 9f006a21 2021-02-07 op strlcpy(buf, spath, sizeof(buf));
81 9f006a21 2021-02-07 op sname = basename(buf);
82 9f006a21 2021-02-07 op
83 9f006a21 2021-02-07 op if (query == NULL || strchr(query, '=') != NULL) {
84 9f006a21 2021-02-07 op if ((argv = calloc(2, sizeof(char*))) == NULL)
85 9f006a21 2021-02-07 op err(1, "calloc");
86 9f006a21 2021-02-07 op argv[0] = sname;
87 9f006a21 2021-02-07 op execvp(ex, argv);
88 9f006a21 2021-02-07 op warn("execvp: %s", argv[0]);
89 9f006a21 2021-02-07 op return;
90 9f006a21 2021-02-07 op }
91 9f006a21 2021-02-07 op
92 9f006a21 2021-02-07 op n = 1;
93 9f006a21 2021-02-07 op for (t = query ;; t++, n++) {
94 9f006a21 2021-02-07 op if ((t = strchr(t, '+')) == NULL)
95 9f006a21 2021-02-07 op break;
96 9f006a21 2021-02-07 op }
97 9f006a21 2021-02-07 op
98 9f006a21 2021-02-07 op if ((argv = calloc(n+2, sizeof(char*))) == NULL)
99 9f006a21 2021-02-07 op err(1, "calloc");
100 9f006a21 2021-02-07 op
101 9f006a21 2021-02-07 op argv[0] = sname;
102 9f006a21 2021-02-07 op for (i = 0; i < n; ++i) {
103 9f006a21 2021-02-07 op t = strchr(query, '+');
104 9f006a21 2021-02-07 op if (t != NULL)
105 9f006a21 2021-02-07 op *t = '\0';
106 9f006a21 2021-02-07 op argv[i+1] = pct_decode_str(query);
107 9f006a21 2021-02-07 op query = t+1;
108 9f006a21 2021-02-07 op }
109 9f006a21 2021-02-07 op
110 9f006a21 2021-02-07 op execvp(ex, argv);
111 9f006a21 2021-02-07 op warn("execvp: %s", argv[0]);
112 b63e30ff 2021-02-07 op }
113 b63e30ff 2021-02-07 op
114 b63e30ff 2021-02-07 op static inline void
115 b63e30ff 2021-02-07 op setenv_time(const char *var, time_t t)
116 b63e30ff 2021-02-07 op {
117 b63e30ff 2021-02-07 op char timebuf[21];
118 b63e30ff 2021-02-07 op struct tm tminfo;
119 b63e30ff 2021-02-07 op
120 b63e30ff 2021-02-07 op if (t == -1)
121 b63e30ff 2021-02-07 op return;
122 b63e30ff 2021-02-07 op
123 b63e30ff 2021-02-07 op strftime(timebuf, sizeof(timebuf), "%FT%TZ",
124 b63e30ff 2021-02-07 op gmtime_r(&t, &tminfo));
125 b63e30ff 2021-02-07 op setenv(var, timebuf, 1);
126 2fafa2d2 2021-02-01 op }
127 2fafa2d2 2021-02-01 op
128 881a9dd9 2021-01-16 op /* fd or -1 on error */
129 881a9dd9 2021-01-16 op static int
130 fdea6aa0 2021-04-30 op launch_cgi(struct iri *iri, struct cgireq *req, struct vhost *vhost,
131 fdea6aa0 2021-04-30 op struct location *loc)
132 881a9dd9 2021-01-16 op {
133 ea976e87 2021-07-06 op int p[2], errp[2]; /* read end, write end */
134 881a9dd9 2021-01-16 op
135 403c4220 2021-10-02 op if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, p) == -1)
136 881a9dd9 2021-01-16 op return -1;
137 403c4220 2021-10-02 op if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, errp) == -1)
138 ea976e87 2021-07-06 op return -1;
139 881a9dd9 2021-01-16 op
140 881a9dd9 2021-01-16 op switch (fork()) {
141 881a9dd9 2021-01-16 op case -1:
142 e7c6502b 2021-07-08 op log_err(NULL, "fork failed: %s", strerror(errno));
143 e7c6502b 2021-07-08 op close(p[0]);
144 e7c6502b 2021-07-08 op close(p[1]);
145 e7c6502b 2021-07-08 op close(errp[0]);
146 e7c6502b 2021-07-08 op close(errp[1]);
147 881a9dd9 2021-01-16 op return -1;
148 881a9dd9 2021-01-16 op
149 881a9dd9 2021-01-16 op case 0: { /* child */
150 2fafa2d2 2021-02-01 op char *ex, *pwd;
151 2fafa2d2 2021-02-01 op char iribuf[GEMINI_URL_LEN];
152 2fafa2d2 2021-02-01 op char path[PATH_MAX];
153 9cc630aa 2021-04-28 op struct envlist *e;
154 881a9dd9 2021-01-16 op
155 881a9dd9 2021-01-16 op close(p[0]);
156 881a9dd9 2021-01-16 op if (dup2(p[1], 1) == -1)
157 881a9dd9 2021-01-16 op goto childerr;
158 881a9dd9 2021-01-16 op
159 ea976e87 2021-07-06 op close(errp[0]);
160 ea976e87 2021-07-06 op if (dup2(errp[1], 2) == -1)
161 ea976e87 2021-07-06 op goto childerr;
162 ea976e87 2021-07-06 op
163 fdea6aa0 2021-04-30 op ex = xasprintf("%s/%s", loc->dir, req->spath);
164 881a9dd9 2021-01-16 op
165 2fafa2d2 2021-02-01 op serialize_iri(iri, iribuf, sizeof(iribuf));
166 881a9dd9 2021-01-16 op
167 881a9dd9 2021-01-16 op safe_setenv("GATEWAY_INTERFACE", "CGI/1.1");
168 fdea6aa0 2021-04-30 op safe_setenv("GEMINI_DOCUMENT_ROOT", loc->dir);
169 2fafa2d2 2021-02-01 op safe_setenv("GEMINI_SCRIPT_FILENAME",
170 fdea6aa0 2021-04-30 op xasprintf("%s/%s", loc->dir, req->spath));
171 2fafa2d2 2021-02-01 op safe_setenv("GEMINI_URL", iribuf);
172 881a9dd9 2021-01-16 op
173 2fafa2d2 2021-02-01 op strlcpy(path, "/", sizeof(path));
174 bc99d868 2021-03-19 op strlcat(path, req->spath, sizeof(path));
175 2fafa2d2 2021-02-01 op safe_setenv("GEMINI_URL_PATH", path);
176 881a9dd9 2021-01-16 op
177 bc99d868 2021-03-19 op if (*req->relpath != '\0') {
178 2fafa2d2 2021-02-01 op strlcpy(path, "/", sizeof(path));
179 bc99d868 2021-03-19 op strlcat(path, req->relpath, sizeof(path));
180 2fafa2d2 2021-02-01 op safe_setenv("PATH_INFO", path);
181 2fafa2d2 2021-02-01 op
182 fdea6aa0 2021-04-30 op strlcpy(path, loc->dir, sizeof(path));
183 2fafa2d2 2021-02-01 op strlcat(path, "/", sizeof(path));
184 bc99d868 2021-03-19 op strlcat(path, req->relpath, sizeof(path));
185 2fafa2d2 2021-02-01 op safe_setenv("PATH_TRANSLATED", path);
186 2fafa2d2 2021-02-01 op }
187 2fafa2d2 2021-02-01 op
188 2fafa2d2 2021-02-01 op safe_setenv("QUERY_STRING", iri->query);
189 bc99d868 2021-03-19 op safe_setenv("REMOTE_ADDR", req->addr);
190 bc99d868 2021-03-19 op safe_setenv("REMOTE_HOST", req->addr);
191 2fafa2d2 2021-02-01 op safe_setenv("REQUEST_METHOD", "");
192 881a9dd9 2021-01-16 op
193 2fafa2d2 2021-02-01 op strlcpy(path, "/", sizeof(path));
194 bc99d868 2021-03-19 op strlcat(path, req->spath, sizeof(path));
195 2fafa2d2 2021-02-01 op safe_setenv("SCRIPT_NAME", path);
196 2fafa2d2 2021-02-01 op
197 2fafa2d2 2021-02-01 op safe_setenv("SERVER_NAME", iri->host);
198 2fafa2d2 2021-02-01 op
199 2fafa2d2 2021-02-01 op snprintf(path, sizeof(path), "%d", conf.port);
200 2fafa2d2 2021-02-01 op safe_setenv("SERVER_PORT", path);
201 2fafa2d2 2021-02-01 op
202 2fafa2d2 2021-02-01 op safe_setenv("SERVER_PROTOCOL", "GEMINI");
203 ce2c9edb 2021-05-15 op safe_setenv("SERVER_SOFTWARE", GMID_VERSION);
204 2fafa2d2 2021-02-01 op
205 bc99d868 2021-03-19 op if (*req->subject != '\0')
206 881a9dd9 2021-01-16 op safe_setenv("AUTH_TYPE", "Certificate");
207 3e541809 2021-02-01 op else
208 3e541809 2021-02-01 op safe_setenv("AUTH_TYPE", "");
209 05748e49 2021-01-24 op
210 bc99d868 2021-03-19 op safe_setenv("REMOTE_USER", req->subject);
211 bc99d868 2021-03-19 op safe_setenv("TLS_CLIENT_ISSUER", req->issuer);
212 bc99d868 2021-03-19 op safe_setenv("TLS_CLIENT_HASH", req->hash);
213 89541eee 2021-04-13 op safe_setenv("TLS_VERSION", req->version);
214 89541eee 2021-04-13 op safe_setenv("TLS_CIPHER", req->cipher);
215 89541eee 2021-04-13 op
216 89541eee 2021-04-13 op snprintf(path, sizeof(path), "%d", req->cipher_strength);
217 89541eee 2021-04-13 op safe_setenv("TLS_CIPHER_STRENGTH", path);
218 89541eee 2021-04-13 op
219 bc99d868 2021-03-19 op setenv_time("TLS_CLIENT_NOT_AFTER", req->notafter);
220 bc99d868 2021-03-19 op setenv_time("TLS_CLIENT_NOT_BEFORE", req->notbefore);
221 3e541809 2021-02-01 op
222 9cc630aa 2021-04-28 op TAILQ_FOREACH(e, &vhost->env, envs) {
223 9cc630aa 2021-04-28 op safe_setenv(e->name, e->value);
224 9cc630aa 2021-04-28 op }
225 9cc630aa 2021-04-28 op
226 9f006a21 2021-02-07 op strlcpy(path, ex, sizeof(path));
227 9f006a21 2021-02-07 op
228 2fafa2d2 2021-02-01 op pwd = dirname(path);
229 2fafa2d2 2021-02-01 op if (chdir(pwd)) {
230 2fafa2d2 2021-02-01 op warn("chdir");
231 2fafa2d2 2021-02-01 op goto childerr;
232 2fafa2d2 2021-02-01 op }
233 881a9dd9 2021-01-16 op
234 bc99d868 2021-03-19 op do_exec(ex, req->spath, iri->query);
235 881a9dd9 2021-01-16 op goto childerr;
236 881a9dd9 2021-01-16 op }
237 881a9dd9 2021-01-16 op
238 881a9dd9 2021-01-16 op default:
239 881a9dd9 2021-01-16 op close(p[1]);
240 e7c6502b 2021-07-08 op close(errp[0]);
241 ea976e87 2021-07-06 op close(errp[1]);
242 52053e1a 2021-02-06 op mark_nonblock(p[0]);
243 881a9dd9 2021-01-16 op return p[0];
244 881a9dd9 2021-01-16 op }
245 881a9dd9 2021-01-16 op
246 881a9dd9 2021-01-16 op childerr:
247 881a9dd9 2021-01-16 op dprintf(p[1], "%d internal server error\r\n", TEMP_FAILURE);
248 881a9dd9 2021-01-16 op _exit(1);
249 881a9dd9 2021-01-16 op }
250 881a9dd9 2021-01-16 op
251 b8e64ccd 2021-03-31 op static struct vhost *
252 b8e64ccd 2021-03-31 op host_nth(size_t n)
253 b8e64ccd 2021-03-31 op {
254 b8e64ccd 2021-03-31 op struct vhost *h;
255 b8e64ccd 2021-03-31 op
256 b8e64ccd 2021-03-31 op TAILQ_FOREACH(h, &hosts, vhosts) {
257 b8e64ccd 2021-03-31 op if (n == 0)
258 b8e64ccd 2021-03-31 op return h;
259 b8e64ccd 2021-03-31 op n--;
260 b8e64ccd 2021-03-31 op }
261 b8e64ccd 2021-03-31 op
262 b8e64ccd 2021-03-31 op return NULL;
263 b8e64ccd 2021-03-31 op }
264 b8e64ccd 2021-03-31 op
265 fdea6aa0 2021-04-30 op static struct location *
266 fdea6aa0 2021-04-30 op loc_nth(struct vhost *vhost, size_t n)
267 fdea6aa0 2021-04-30 op {
268 fdea6aa0 2021-04-30 op struct location *loc;
269 fdea6aa0 2021-04-30 op
270 fdea6aa0 2021-04-30 op TAILQ_FOREACH(loc, &vhost->locations, locations) {
271 fdea6aa0 2021-04-30 op if (n == 0)
272 fdea6aa0 2021-04-30 op return loc;
273 fdea6aa0 2021-04-30 op n--;
274 fdea6aa0 2021-04-30 op }
275 fdea6aa0 2021-04-30 op
276 fdea6aa0 2021-04-30 op return NULL;
277 fdea6aa0 2021-04-30 op }
278 fdea6aa0 2021-04-30 op
279 2c3e53da 2021-03-03 op static void
280 bc99d868 2021-03-19 op handle_imsg_cgi_req(struct imsgbuf *ibuf, struct imsg *imsg, size_t datalen)
281 881a9dd9 2021-01-16 op {
282 b8e64ccd 2021-03-31 op struct vhost *h;
283 fdea6aa0 2021-04-30 op struct location *l;
284 b8e64ccd 2021-03-31 op struct cgireq req;
285 b8e64ccd 2021-03-31 op struct iri iri;
286 b8e64ccd 2021-03-31 op int fd;
287 2c3e53da 2021-03-03 op
288 bc99d868 2021-03-19 op if (datalen != sizeof(req))
289 bc99d868 2021-03-19 op abort();
290 bc99d868 2021-03-19 op
291 bc99d868 2021-03-19 op memcpy(&req, imsg->data, datalen);
292 bc99d868 2021-03-19 op
293 bc99d868 2021-03-19 op iri.schema = req.iri_schema_off + req.buf;
294 bc99d868 2021-03-19 op iri.host = req.iri_host_off + req.buf;
295 bc99d868 2021-03-19 op iri.port = req.iri_port_off + req.buf;
296 bc99d868 2021-03-19 op iri.path = req.iri_path_off + req.buf;
297 bc99d868 2021-03-19 op iri.query = req.iri_query_off + req.buf;
298 bc99d868 2021-03-19 op iri.fragment = req.iri_fragment_off + req.buf;
299 bc99d868 2021-03-19 op
300 bc99d868 2021-03-19 op /* patch the query, otherwise do_exec will always pass "" as
301 bc99d868 2021-03-19 op * first argument to the script. */
302 bc99d868 2021-03-19 op if (*iri.query == '\0')
303 bc99d868 2021-03-19 op iri.query = NULL;
304 bc99d868 2021-03-19 op
305 b8e64ccd 2021-03-31 op if ((h = host_nth(req.host_off)) == NULL)
306 bc99d868 2021-03-19 op abort();
307 bc99d868 2021-03-19 op
308 1feaf2a6 2021-05-15 op if ((l = loc_nth(h, req.loc_off)) == NULL)
309 fdea6aa0 2021-04-30 op abort();
310 fdea6aa0 2021-04-30 op
311 fdea6aa0 2021-04-30 op fd = launch_cgi(&iri, &req, h, l);
312 bc99d868 2021-03-19 op imsg_compose(ibuf, IMSG_CGI_RES, imsg->hdr.peerid, 0, fd, NULL, 0);
313 bc99d868 2021-03-19 op imsg_flush(ibuf);
314 8ad1c570 2021-05-09 op }
315 8ad1c570 2021-05-09 op
316 8ad1c570 2021-05-09 op static int
317 8ad1c570 2021-05-09 op fcgi_open_prog(struct fcgi *f)
318 8ad1c570 2021-05-09 op {
319 8ad1c570 2021-05-09 op int s[2];
320 8ad1c570 2021-05-09 op pid_t p;
321 8ad1c570 2021-05-09 op
322 8ad1c570 2021-05-09 op /* XXX! */
323 8ad1c570 2021-05-09 op
324 2e2e189b 2021-07-08 op if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, s) == -1)
325 8ad1c570 2021-05-09 op err(1, "socketpair");
326 8ad1c570 2021-05-09 op
327 8ad1c570 2021-05-09 op switch (p = fork()) {
328 8ad1c570 2021-05-09 op case -1:
329 8ad1c570 2021-05-09 op err(1, "fork");
330 8ad1c570 2021-05-09 op case 0:
331 8ad1c570 2021-05-09 op close(s[0]);
332 8ad1c570 2021-05-09 op if (dup2(s[1], 0) == -1)
333 8ad1c570 2021-05-09 op err(1, "dup2");
334 8ad1c570 2021-05-09 op execl(f->prog, f->prog, NULL);
335 8ad1c570 2021-05-09 op err(1, "execl %s", f->prog);
336 8ad1c570 2021-05-09 op default:
337 8ad1c570 2021-05-09 op close(s[1]);
338 8ad1c570 2021-05-09 op return s[0];
339 8ad1c570 2021-05-09 op }
340 bc99d868 2021-03-19 op }
341 bc99d868 2021-03-19 op
342 8ad1c570 2021-05-09 op static int
343 8ad1c570 2021-05-09 op fcgi_open_sock(struct fcgi *f)
344 8ad1c570 2021-05-09 op {
345 8ad1c570 2021-05-09 op struct sockaddr_un addr;
346 8ad1c570 2021-05-09 op int fd;
347 8ad1c570 2021-05-09 op
348 8ad1c570 2021-05-09 op if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {
349 8ad1c570 2021-05-09 op log_err(NULL, "socket: %s", strerror(errno));
350 8ad1c570 2021-05-09 op return -1;
351 8ad1c570 2021-05-09 op }
352 8ad1c570 2021-05-09 op
353 8ad1c570 2021-05-09 op memset(&addr, 0, sizeof(addr));
354 8ad1c570 2021-05-09 op addr.sun_family = AF_UNIX;
355 8ad1c570 2021-05-09 op strlcpy(addr.sun_path, f->path, sizeof(addr.sun_path));
356 8ad1c570 2021-05-09 op
357 8ad1c570 2021-05-09 op if (connect(fd, (struct sockaddr*)&addr, sizeof(addr)) == -1) {
358 8ad1c570 2021-05-09 op log_warn(NULL, "failed to connect to %s: %s", f->path,
359 8ad1c570 2021-05-09 op strerror(errno));
360 8ad1c570 2021-05-09 op close(fd);
361 8ad1c570 2021-05-09 op return -1;
362 8ad1c570 2021-05-09 op }
363 8ad1c570 2021-05-09 op
364 8ad1c570 2021-05-09 op return fd;
365 8ad1c570 2021-05-09 op }
366 8ad1c570 2021-05-09 op
367 8ad1c570 2021-05-09 op static int
368 8ad1c570 2021-05-09 op fcgi_open_conn(struct fcgi *f)
369 8ad1c570 2021-05-09 op {
370 8ad1c570 2021-05-09 op struct addrinfo hints, *servinfo, *p;
371 8ad1c570 2021-05-09 op int r, sock;
372 8ad1c570 2021-05-09 op
373 8ad1c570 2021-05-09 op memset(&hints, 0, sizeof(hints));
374 8ad1c570 2021-05-09 op hints.ai_family = AF_UNSPEC;
375 8ad1c570 2021-05-09 op hints.ai_socktype = SOCK_STREAM;
376 8ad1c570 2021-05-09 op hints.ai_flags = AI_ADDRCONFIG;
377 8ad1c570 2021-05-09 op
378 8ad1c570 2021-05-09 op if ((r = getaddrinfo(f->path, f->port, &hints, &servinfo)) != 0) {
379 8ad1c570 2021-05-09 op log_warn(NULL, "getaddrinfo %s:%s: %s", f->path, f->port,
380 8ad1c570 2021-05-09 op gai_strerror(r));
381 8ad1c570 2021-05-09 op return -1;
382 8ad1c570 2021-05-09 op }
383 8ad1c570 2021-05-09 op
384 8ad1c570 2021-05-09 op for (p = servinfo; p != NULL; p = p->ai_next) {
385 8ad1c570 2021-05-09 op sock = socket(p->ai_family, p->ai_socktype, p->ai_protocol);
386 8ad1c570 2021-05-09 op if (sock == -1)
387 8ad1c570 2021-05-09 op continue;
388 8ad1c570 2021-05-09 op if (connect(sock, p->ai_addr, p->ai_addrlen) == -1) {
389 8ad1c570 2021-05-09 op close(sock);
390 8ad1c570 2021-05-09 op continue;
391 8ad1c570 2021-05-09 op }
392 8ad1c570 2021-05-09 op break;
393 8ad1c570 2021-05-09 op }
394 8ad1c570 2021-05-09 op
395 8ad1c570 2021-05-09 op if (p == NULL) {
396 8ad1c570 2021-05-09 op log_warn(NULL, "couldn't connect to %s:%s", f->path, f->port);
397 8ad1c570 2021-05-09 op sock = -1;
398 8ad1c570 2021-05-09 op }
399 8ad1c570 2021-05-09 op
400 8ad1c570 2021-05-09 op freeaddrinfo(servinfo);
401 8ad1c570 2021-05-09 op return sock;
402 8ad1c570 2021-05-09 op }
403 8ad1c570 2021-05-09 op
404 bc99d868 2021-03-19 op static void
405 8ad1c570 2021-05-09 op handle_imsg_fcgi_req(struct imsgbuf *ibuf, struct imsg *imsg, size_t datalen)
406 8ad1c570 2021-05-09 op {
407 8ad1c570 2021-05-09 op struct fcgi *f;
408 8ad1c570 2021-05-09 op int id, fd;
409 8ad1c570 2021-05-09 op
410 8ad1c570 2021-05-09 op if (datalen != sizeof(id))
411 8ad1c570 2021-05-09 op abort();
412 8ad1c570 2021-05-09 op memcpy(&id, imsg->data, datalen);
413 8ad1c570 2021-05-09 op
414 8ad1c570 2021-05-09 op if (id > FCGI_MAX || (fcgi[id].path == NULL && fcgi[id].prog == NULL))
415 8ad1c570 2021-05-09 op abort();
416 8ad1c570 2021-05-09 op
417 8ad1c570 2021-05-09 op f = &fcgi[id];
418 8ad1c570 2021-05-09 op if (f->prog != NULL)
419 8ad1c570 2021-05-09 op fd = fcgi_open_prog(f);
420 8ad1c570 2021-05-09 op else if (f->port != NULL)
421 8ad1c570 2021-05-09 op fd = fcgi_open_conn(f);
422 8ad1c570 2021-05-09 op else
423 8ad1c570 2021-05-09 op fd = fcgi_open_sock(f);
424 8ad1c570 2021-05-09 op
425 4cd25209 2021-10-07 op imsg_compose(ibuf, IMSG_FCGI_FD, imsg->hdr.peerid, 0, fd, NULL, 0);
426 72b033ef 2021-12-29 op imsg_flush(ibuf);
427 72b033ef 2021-12-29 op }
428 72b033ef 2021-12-29 op
429 72b033ef 2021-12-29 op static void
430 72b033ef 2021-12-29 op handle_imsg_conn_req(struct imsgbuf *ibuf, struct imsg *imsg, size_t datalen)
431 72b033ef 2021-12-29 op {
432 72b033ef 2021-12-29 op struct addrinfo hints, *res, *res0;
433 72b033ef 2021-12-29 op struct connreq req;
434 72b033ef 2021-12-29 op int r, sock;
435 72b033ef 2021-12-29 op
436 72b033ef 2021-12-29 op if (datalen != sizeof(req))
437 72b033ef 2021-12-29 op abort();
438 72b033ef 2021-12-29 op memcpy(&req, imsg->data, sizeof(req));
439 72b033ef 2021-12-29 op req.flag = 0;
440 72b033ef 2021-12-29 op
441 72b033ef 2021-12-29 op memset(&hints, 0, sizeof(hints));
442 72b033ef 2021-12-29 op hints.ai_family = AF_UNSPEC;
443 72b033ef 2021-12-29 op hints.ai_socktype = SOCK_STREAM;
444 72b033ef 2021-12-29 op
445 72b033ef 2021-12-29 op /* XXX: do this asynchronously if possible */
446 72b033ef 2021-12-29 op r = getaddrinfo(req.host, req.port, &hints, &res0);
447 72b033ef 2021-12-29 op if (r != 0) {
448 72b033ef 2021-12-29 op log_warn(NULL, "getaddrinfo(\"%s\", \"%s\"): %s",
449 72b033ef 2021-12-29 op req.host, req.port, gai_strerror(r));
450 72b033ef 2021-12-29 op goto err;
451 72b033ef 2021-12-29 op }
452 72b033ef 2021-12-29 op
453 72b033ef 2021-12-29 op for (res = res0; res; res = res->ai_next) {
454 72b033ef 2021-12-29 op sock = socket(res->ai_family, res->ai_socktype,
455 72b033ef 2021-12-29 op res->ai_protocol);
456 72b033ef 2021-12-29 op if (sock == -1)
457 72b033ef 2021-12-29 op continue;
458 72b033ef 2021-12-29 op
459 72b033ef 2021-12-29 op if (connect(sock, res->ai_addr, res->ai_addrlen) == -1) {
460 72b033ef 2021-12-29 op close(sock);
461 72b033ef 2021-12-29 op sock = -1;
462 72b033ef 2021-12-29 op continue;
463 72b033ef 2021-12-29 op }
464 72b033ef 2021-12-29 op
465 72b033ef 2021-12-29 op break;
466 72b033ef 2021-12-29 op }
467 72b033ef 2021-12-29 op
468 72b033ef 2021-12-29 op freeaddrinfo(res0);
469 72b033ef 2021-12-29 op
470 72b033ef 2021-12-29 op if (sock == -1) {
471 72b033ef 2021-12-29 op log_warn(NULL, "can't connect to %s:%s", req.host,
472 72b033ef 2021-12-29 op req.port);
473 72b033ef 2021-12-29 op goto err;
474 72b033ef 2021-12-29 op }
475 72b033ef 2021-12-29 op
476 72b033ef 2021-12-29 op imsg_compose(ibuf, IMSG_CONN_FD, imsg->hdr.peerid, 0, sock, NULL, 0);
477 8ad1c570 2021-05-09 op imsg_flush(ibuf);
478 72b033ef 2021-12-29 op return;
479 72b033ef 2021-12-29 op
480 72b033ef 2021-12-29 op err:
481 72b033ef 2021-12-29 op imsg_compose(ibuf, IMSG_CONN_FD, imsg->hdr.peerid, 0, -1, NULL, 0);
482 72b033ef 2021-12-29 op imsg_flush(ibuf);
483 8ad1c570 2021-05-09 op }
484 8ad1c570 2021-05-09 op
485 8ad1c570 2021-05-09 op static void
486 bc99d868 2021-03-19 op handle_imsg_quit(struct imsgbuf *ibuf, struct imsg *imsg, size_t datalen)
487 bc99d868 2021-03-19 op {
488 bc99d868 2021-03-19 op int i;
489 bc99d868 2021-03-19 op
490 bc99d868 2021-03-19 op for (i = 0; i < conf.prefork; ++i) {
491 bc99d868 2021-03-19 op imsg_compose(&servibuf[i], IMSG_QUIT, 0, 0, -1, NULL, 0);
492 bc99d868 2021-03-19 op imsg_flush(&exibuf);
493 bc99d868 2021-03-19 op close(servibuf[i].fd);
494 1fbac5ba 2021-03-03 op }
495 2c3e53da 2021-03-03 op
496 bc99d868 2021-03-19 op event_loopbreak();
497 bc99d868 2021-03-19 op }
498 2c3e53da 2021-03-03 op
499 bc99d868 2021-03-19 op static void
500 bc99d868 2021-03-19 op handle_dispatch_imsg(int fd, short ev, void *d)
501 bc99d868 2021-03-19 op {
502 bc99d868 2021-03-19 op struct imsgbuf *ibuf = d;
503 bc99d868 2021-03-19 op dispatch_imsg(ibuf, handlers, sizeof(handlers));
504 2c3e53da 2021-03-03 op }
505 2c3e53da 2021-03-03 op
506 2c3e53da 2021-03-03 op int
507 bc99d868 2021-03-19 op executor_main(struct imsgbuf *ibuf)
508 2c3e53da 2021-03-03 op {
509 bc99d868 2021-03-19 op struct event evs[PROC_MAX], imsgev;
510 2c3e53da 2021-03-03 op int i;
511 10782292 2021-01-25 op
512 2c3e53da 2021-03-03 op event_init();
513 881a9dd9 2021-01-16 op
514 bc99d868 2021-03-19 op if (ibuf != NULL) {
515 bc99d868 2021-03-19 op event_set(&imsgev, ibuf->fd, EV_READ | EV_PERSIST,
516 bc99d868 2021-03-19 op handle_dispatch_imsg, ibuf);
517 bc99d868 2021-03-19 op event_add(&imsgev, NULL);
518 bc99d868 2021-03-19 op }
519 bc99d868 2021-03-19 op
520 2c3e53da 2021-03-03 op for (i = 0; i < conf.prefork; ++i) {
521 bc99d868 2021-03-19 op event_set(&evs[i], servibuf[i].fd, EV_READ | EV_PERSIST,
522 bc99d868 2021-03-19 op handle_dispatch_imsg, &servibuf[i]);
523 2c3e53da 2021-03-03 op event_add(&evs[i], NULL);
524 881a9dd9 2021-01-16 op }
525 881a9dd9 2021-01-16 op
526 62e001b0 2021-03-20 op sandbox_executor_process();
527 62e001b0 2021-03-20 op
528 2c3e53da 2021-03-03 op event_dispatch();
529 ca21e100 2021-02-04 op
530 881a9dd9 2021-01-16 op return 1;
531 881a9dd9 2021-01-16 op }