2 b0a6bcf7 2022-09-13 op * Copyright (c) 2022 Omar Polo <op@omarpolo.com>
4 b0a6bcf7 2022-09-13 op * Permission to use, copy, modify, and distribute this software for any
5 b0a6bcf7 2022-09-13 op * purpose with or without fee is hereby granted, provided that the above
6 b0a6bcf7 2022-09-13 op * copyright notice and this permission notice appear in all copies.
8 b0a6bcf7 2022-09-13 op * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9 b0a6bcf7 2022-09-13 op * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10 b0a6bcf7 2022-09-13 op * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11 b0a6bcf7 2022-09-13 op * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12 b0a6bcf7 2022-09-13 op * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13 b0a6bcf7 2022-09-13 op * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14 b0a6bcf7 2022-09-13 op * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
17 b0a6bcf7 2022-09-13 op #include <sys/queue.h>
18 b0a6bcf7 2022-09-13 op #include <sys/tree.h>
19 b0a6bcf7 2022-09-13 op #include <sys/socket.h>
21 b0a6bcf7 2022-09-13 op #include <netinet/in.h>
22 b0a6bcf7 2022-09-13 op #include <arpa/inet.h>
24 b0a6bcf7 2022-09-13 op #include <errno.h>
25 b0a6bcf7 2022-09-13 op #include <event.h>
26 b0a6bcf7 2022-09-13 op #include <limits.h>
27 b0a6bcf7 2022-09-13 op #include <stdarg.h>
28 b0a6bcf7 2022-09-13 op #include <stdio.h>
29 b0a6bcf7 2022-09-13 op #include <stdlib.h>
30 b0a6bcf7 2022-09-13 op #include <stdint.h>
31 b0a6bcf7 2022-09-13 op #include <string.h>
32 b0a6bcf7 2022-09-13 op #include <unistd.h>
34 b0a6bcf7 2022-09-13 op #include "log.h"
36 b0a6bcf7 2022-09-13 op #include "galileo.h"
38 b0a6bcf7 2022-09-13 op #define MIN(a, b) ((a) < (b) ? (a) : (b))
40 b0a6bcf7 2022-09-13 op struct fcgi_header {
41 b0a6bcf7 2022-09-13 op unsigned char version;
42 b0a6bcf7 2022-09-13 op unsigned char type;
43 b0a6bcf7 2022-09-13 op unsigned char req_id1;
44 b0a6bcf7 2022-09-13 op unsigned char req_id0;
45 b0a6bcf7 2022-09-13 op unsigned char content_len1;
46 b0a6bcf7 2022-09-13 op unsigned char content_len0;
47 b0a6bcf7 2022-09-13 op unsigned char padding;
48 b0a6bcf7 2022-09-13 op unsigned char reserved;
49 b0a6bcf7 2022-09-13 op } __attribute__((packed));
52 b0a6bcf7 2022-09-13 op * number of bytes in a FCGI_HEADER. Future version of the protocol
53 b0a6bcf7 2022-09-13 op * will not reduce this number.
55 b0a6bcf7 2022-09-13 op #define FCGI_HEADER_LEN 8
58 b0a6bcf7 2022-09-13 op * values for the version component
60 b0a6bcf7 2022-09-13 op #define FCGI_VERSION_1 1
63 b0a6bcf7 2022-09-13 op * values for the type component
65 b0a6bcf7 2022-09-13 op #define FCGI_BEGIN_REQUEST 1
66 b0a6bcf7 2022-09-13 op #define FCGI_ABORT_REQUEST 2
67 b0a6bcf7 2022-09-13 op #define FCGI_END_REQUEST 3
68 b0a6bcf7 2022-09-13 op #define FCGI_PARAMS 4
69 b0a6bcf7 2022-09-13 op #define FCGI_STDIN 5
70 b0a6bcf7 2022-09-13 op #define FCGI_STDOUT 6
71 b0a6bcf7 2022-09-13 op #define FCGI_STDERR 7
72 b0a6bcf7 2022-09-13 op #define FCGI_DATA 8
73 b0a6bcf7 2022-09-13 op #define FCGI_GET_VALUES 9
74 b0a6bcf7 2022-09-13 op #define FCGI_GET_VALUES_RESULT 10
75 b0a6bcf7 2022-09-13 op #define FCGI_UNKNOWN_TYPE 11
76 b0a6bcf7 2022-09-13 op #define FCGI_MAXTYPE (FCGI_UNKNOWN_TYPE)
78 b0a6bcf7 2022-09-13 op struct fcgi_begin_req {
79 b0a6bcf7 2022-09-13 op unsigned char role1;
80 b0a6bcf7 2022-09-13 op unsigned char role0;
81 b0a6bcf7 2022-09-13 op unsigned char flags;
82 b0a6bcf7 2022-09-13 op unsigned char reserved[5];
85 b0a6bcf7 2022-09-13 op struct fcgi_begin_req_record {
86 b0a6bcf7 2022-09-13 op struct fcgi_header header;
87 b0a6bcf7 2022-09-13 op struct fcgi_begin_req body;
91 b0a6bcf7 2022-09-13 op * mask for flags;
93 b0a6bcf7 2022-09-13 op #define FCGI_KEEP_CONN 1
96 b0a6bcf7 2022-09-13 op * values for the role
98 b0a6bcf7 2022-09-13 op #define FCGI_RESPONDER 1
99 b0a6bcf7 2022-09-13 op #define FCGI_AUTHORIZER 2
100 b0a6bcf7 2022-09-13 op #define FCGI_FILTER 3
102 b0a6bcf7 2022-09-13 op struct fcgi_end_req_body {
103 b0a6bcf7 2022-09-13 op unsigned char app_status3;
104 b0a6bcf7 2022-09-13 op unsigned char app_status2;
105 b0a6bcf7 2022-09-13 op unsigned char app_status1;
106 b0a6bcf7 2022-09-13 op unsigned char app_status0;
107 b0a6bcf7 2022-09-13 op unsigned char proto_status;
108 b0a6bcf7 2022-09-13 op unsigned char reserved[3];
112 b0a6bcf7 2022-09-13 op * values for proto_status
114 b0a6bcf7 2022-09-13 op #define FCGI_REQUEST_COMPLETE 0
115 b0a6bcf7 2022-09-13 op #define FCGI_CANT_MPX_CONN 1
116 b0a6bcf7 2022-09-13 op #define FCGI_OVERLOADED 2
117 b0a6bcf7 2022-09-13 op #define FCGI_UNKNOWN_ROLE 3
120 b0a6bcf7 2022-09-13 op * Variable names for FCGI_GET_VALUES / FCGI_GET_VALUES_RESULT
123 b0a6bcf7 2022-09-13 op #define FCGI_MAX_CONNS "FCGI_MAX_CONNS"
124 b0a6bcf7 2022-09-13 op #define FCGI_MAX_REQS "FCGI_MAX_REQS"
125 b0a6bcf7 2022-09-13 op #define FCGI_MPXS_CONNS "FCGI_MPXS_CONNS"
127 b0a6bcf7 2022-09-13 op #define CAT(f0, f1) ((f0) + ((f1) << 8))
130 b0a6bcf7 2022-09-13 op FCGI_RECORD_HEADER,
131 b0a6bcf7 2022-09-13 op FCGI_RECORD_BODY,
134 b0a6bcf7 2022-09-13 op volatile int fcgi_inflight;
137 b0a6bcf7 2022-09-13 op fcgi_send_end_req(struct fcgi *fcgi, int id, int as, int ps)
139 b0a6bcf7 2022-09-13 op struct bufferevent *bev = fcgi->fcg_bev;
140 b0a6bcf7 2022-09-13 op struct fcgi_header hdr;
141 b0a6bcf7 2022-09-13 op struct fcgi_end_req_body end;
143 b0a6bcf7 2022-09-13 op memset(&hdr, 0, sizeof(hdr));
144 b0a6bcf7 2022-09-13 op memset(&end, 0, sizeof(end));
146 b0a6bcf7 2022-09-13 op hdr.version = FCGI_VERSION_1;
147 b0a6bcf7 2022-09-13 op hdr.type = FCGI_END_REQUEST;
148 b0a6bcf7 2022-09-13 op hdr.req_id0 = (id & 0xFF);
149 b0a6bcf7 2022-09-13 op hdr.req_id1 = (id >> 8);
150 b0a6bcf7 2022-09-13 op hdr.content_len0 = sizeof(end);
152 b0a6bcf7 2022-09-13 op end.app_status0 = (unsigned char)as;
153 b0a6bcf7 2022-09-13 op end.proto_status = (unsigned char)ps;
155 b0a6bcf7 2022-09-13 op if (bufferevent_write(bev, &hdr, sizeof(hdr)) == -1)
157 b0a6bcf7 2022-09-13 op if (bufferevent_write(bev, &end, sizeof(end)) == -1)
163 b0a6bcf7 2022-09-13 op end_request(struct client *clt, int status, int proto_status)
165 b0a6bcf7 2022-09-13 op struct fcgi *fcgi = clt->clt_fcgi;
168 b0a6bcf7 2022-09-13 op if (clt_flush(clt) == -1)
171 b0a6bcf7 2022-09-13 op r = fcgi_send_end_req(fcgi, clt->clt_id, status,
172 b0a6bcf7 2022-09-13 op proto_status);
173 b0a6bcf7 2022-09-13 op if (r == -1) {
174 b0a6bcf7 2022-09-13 op fcgi_error(fcgi->fcg_bev, EV_WRITE, fcgi);
178 b0a6bcf7 2022-09-13 op SPLAY_REMOVE(client_tree, &fcgi->fcg_clients, clt);
179 b0a6bcf7 2022-09-13 op proxy_client_free(clt);
184 b0a6bcf7 2022-09-13 op fcgi_end_request(struct client *clt, int status)
186 b0a6bcf7 2022-09-13 op return (end_request(clt, status, FCGI_REQUEST_COMPLETE));
190 b0a6bcf7 2022-09-13 op fcgi_abort_request(struct client *clt)
192 b0a6bcf7 2022-09-13 op return (end_request(clt, 1, FCGI_OVERLOADED));
196 b0a6bcf7 2022-09-13 op fcgi_inflight_dec(const char *why)
198 b0a6bcf7 2022-09-13 op fcgi_inflight--;
199 b0a6bcf7 2022-09-13 op log_debug("%s: fcgi inflight decremented, now %d, %s",
200 b0a6bcf7 2022-09-13 op __func__, fcgi_inflight, why);
204 ea8874f1 2022-09-13 op fcgi_accept(int fd, short event, void *arg)
206 ea8874f1 2022-09-13 op struct galileo *env = arg;
207 b0a6bcf7 2022-09-13 op struct fcgi *fcgi = NULL;
208 b0a6bcf7 2022-09-13 op socklen_t slen;
209 b0a6bcf7 2022-09-13 op struct sockaddr_storage ss;
212 ea8874f1 2022-09-13 op event_add(&env->sc_evpause, NULL);
213 ea8874f1 2022-09-13 op if ((event & EV_TIMEOUT))
216 b0a6bcf7 2022-09-13 op slen = sizeof(ss);
217 b0a6bcf7 2022-09-13 op if ((s = accept_reserve(env->sc_sock_fd, (struct sockaddr *)&ss,
218 b0a6bcf7 2022-09-13 op &slen, FD_RESERVE, &fcgi_inflight)) == -1) {
220 b0a6bcf7 2022-09-13 op * Pause accept if we are out of file descriptors, or
221 b0a6bcf7 2022-09-13 op * libevent will haunt us here too.
223 b0a6bcf7 2022-09-13 op if (errno == ENFILE || errno == EMFILE) {
224 b0a6bcf7 2022-09-13 op struct timeval evtpause = { 1, 0 };
226 b0a6bcf7 2022-09-13 op event_del(&env->sc_evsock);
227 b0a6bcf7 2022-09-13 op evtimer_add(&env->sc_evpause, &evtpause);
228 b0a6bcf7 2022-09-13 op log_debug("%s: deferring connections", __func__);
233 b0a6bcf7 2022-09-13 op if ((fcgi = calloc(1, sizeof(*fcgi))) == NULL)
236 b0a6bcf7 2022-09-13 op fcgi->fcg_id = ++proxy_fcg_id;
237 b0a6bcf7 2022-09-13 op fcgi->fcg_s = s;
238 b0a6bcf7 2022-09-13 op fcgi->fcg_env = env;
239 b0a6bcf7 2022-09-13 op fcgi->fcg_want = FCGI_RECORD_HEADER;
240 b0a6bcf7 2022-09-13 op fcgi->fcg_toread = sizeof(struct fcgi_header);
241 b0a6bcf7 2022-09-13 op SPLAY_INIT(&fcgi->fcg_clients);
243 b0a6bcf7 2022-09-13 op /* assume it's enabled until we get a FCGI_BEGIN_REQUEST */
244 b0a6bcf7 2022-09-13 op fcgi->fcg_keep_conn = 1;
246 b0a6bcf7 2022-09-13 op fcgi->fcg_bev = bufferevent_new(fcgi->fcg_s, fcgi_read, fcgi_write,
247 b0a6bcf7 2022-09-13 op fcgi_error, fcgi);
248 b0a6bcf7 2022-09-13 op if (fcgi->fcg_bev == NULL)
251 b0a6bcf7 2022-09-13 op bufferevent_enable(fcgi->fcg_bev, EV_READ | EV_WRITE);
255 b0a6bcf7 2022-09-13 op if (s != -1) {
258 b0a6bcf7 2022-09-13 op fcgi_inflight_dec(__func__);
263 b0a6bcf7 2022-09-13 op parse_len(struct fcgi *fcgi, struct evbuffer *src)
265 b0a6bcf7 2022-09-13 op unsigned char c, x[3];
267 b0a6bcf7 2022-09-13 op fcgi->fcg_toread--;
268 b0a6bcf7 2022-09-13 op evbuffer_remove(src, &c, 1);
269 b0a6bcf7 2022-09-13 op if (c >> 7 == 0)
272 b0a6bcf7 2022-09-13 op if (fcgi->fcg_toread < 3)
275 b0a6bcf7 2022-09-13 op fcgi->fcg_toread -= 3;
276 b0a6bcf7 2022-09-13 op evbuffer_remove(src, x, sizeof(x));
277 b0a6bcf7 2022-09-13 op return (((c & 0x7F) << 24) | (x[0] << 16) | (x[1] << 8) | x[2]);
281 b0a6bcf7 2022-09-13 op fcgi_parse_params(struct fcgi *fcgi, struct evbuffer *src, struct client *clt)
283 b0a6bcf7 2022-09-13 op char pname[32];
284 b0a6bcf7 2022-09-13 op char server[HOST_NAME_MAX + 1];
285 b0a6bcf7 2022-09-13 op char path[PATH_MAX];
286 b0a6bcf7 2022-09-13 op int nlen, vlen;
288 b0a6bcf7 2022-09-13 op while (fcgi->fcg_toread > 0) {
289 b0a6bcf7 2022-09-13 op if ((nlen = parse_len(fcgi, src)) < 0 ||
290 b0a6bcf7 2022-09-13 op (vlen = parse_len(fcgi, src)) < 0)
293 b0a6bcf7 2022-09-13 op if (fcgi->fcg_toread < nlen + vlen)
296 b0a6bcf7 2022-09-13 op if ((size_t)nlen > sizeof(pname) - 1) {
297 b0a6bcf7 2022-09-13 op /* ignore this parameter */
298 b0a6bcf7 2022-09-13 op fcgi->fcg_toread -= nlen - vlen;
299 b0a6bcf7 2022-09-13 op evbuffer_drain(src, nlen + vlen);
303 b0a6bcf7 2022-09-13 op fcgi->fcg_toread -= nlen;
304 b0a6bcf7 2022-09-13 op evbuffer_remove(src, &pname, nlen);
305 b0a6bcf7 2022-09-13 op pname[nlen] = '\0';
307 b0a6bcf7 2022-09-13 op if (!strcmp(pname, "SERVER_NAME") &&
308 b0a6bcf7 2022-09-13 op (size_t)vlen < sizeof(server)) {
309 b0a6bcf7 2022-09-13 op fcgi->fcg_toread -= vlen;
310 b0a6bcf7 2022-09-13 op evbuffer_remove(src, &server, vlen);
311 b0a6bcf7 2022-09-13 op server[vlen] = '\0';
313 b0a6bcf7 2022-09-13 op if ((clt->clt_server_name = strdup(server)) == NULL)
315 b0a6bcf7 2022-09-13 op log_debug("clt %d: server_name: %s", clt->clt_id,
316 b0a6bcf7 2022-09-13 op clt->clt_server_name);
320 b0a6bcf7 2022-09-13 op if (!strcmp(pname, "SCRIPT_NAME") &&
321 b0a6bcf7 2022-09-13 op (size_t)vlen < sizeof(path)) {
322 b0a6bcf7 2022-09-13 op fcgi->fcg_toread -= vlen;
323 b0a6bcf7 2022-09-13 op evbuffer_remove(src, &path, vlen);
324 b0a6bcf7 2022-09-13 op path[vlen] = '\0';
326 b0a6bcf7 2022-09-13 op if ((clt->clt_script_name = strdup(path)) == NULL)
328 b0a6bcf7 2022-09-13 op log_debug("clt %d: script_name: %s", clt->clt_id,
329 b0a6bcf7 2022-09-13 op clt->clt_script_name);
333 b0a6bcf7 2022-09-13 op if (!strcmp(pname, "PATH_INFO") &&
334 b0a6bcf7 2022-09-13 op (size_t)vlen < sizeof(path)) {
335 b0a6bcf7 2022-09-13 op fcgi->fcg_toread -= vlen;
336 b0a6bcf7 2022-09-13 op evbuffer_remove(src, &path, vlen);
337 b0a6bcf7 2022-09-13 op path[vlen] = '\0';
339 b0a6bcf7 2022-09-13 op if ((clt->clt_path_info = strdup(path)) == NULL)
341 b0a6bcf7 2022-09-13 op log_debug("clt %d: path_info: %s", clt->clt_id,
342 b0a6bcf7 2022-09-13 op clt->clt_path_info);
346 b0a6bcf7 2022-09-13 op fcgi->fcg_toread -= vlen;
347 b0a6bcf7 2022-09-13 op evbuffer_drain(src, vlen);
354 b0a6bcf7 2022-09-13 op fcgi_read(struct bufferevent *bev, void *d)
356 b0a6bcf7 2022-09-13 op struct fcgi *fcgi = d;
357 b0a6bcf7 2022-09-13 op struct galileo *env = fcgi->fcg_env;
358 b0a6bcf7 2022-09-13 op struct evbuffer *src = EVBUFFER_INPUT(bev);
359 b0a6bcf7 2022-09-13 op struct fcgi_header hdr;
360 b0a6bcf7 2022-09-13 op struct fcgi_begin_req breq;
361 b0a6bcf7 2022-09-13 op struct client *clt, q;
364 b0a6bcf7 2022-09-13 op memset(&q, 0, sizeof(q));
367 b0a6bcf7 2022-09-13 op if (EVBUFFER_LENGTH(src) < (size_t)fcgi->fcg_toread)
370 b0a6bcf7 2022-09-13 op if (fcgi->fcg_want == FCGI_RECORD_HEADER) {
371 b0a6bcf7 2022-09-13 op fcgi->fcg_want = FCGI_RECORD_BODY;
372 b0a6bcf7 2022-09-13 op bufferevent_read(bev, &hdr, sizeof(hdr));
375 b0a6bcf7 2022-09-13 op log_warnx("header: v=%d t=%d id=%d len=%d p=%d",
376 b0a6bcf7 2022-09-13 op hdr.version, hdr.type,
377 b0a6bcf7 2022-09-13 op CAT(hdr.req_id0, hdr.req_id1),
378 b0a6bcf7 2022-09-13 op CAT(hdr.content_len0, hdr.content_len1),
379 b0a6bcf7 2022-09-13 op hdr.padding);
382 b0a6bcf7 2022-09-13 op if (hdr.version != FCGI_VERSION_1) {
383 b0a6bcf7 2022-09-13 op log_warnx("unknown fastcgi version: %d",
384 b0a6bcf7 2022-09-13 op hdr.version);
385 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_READ, d);
389 b0a6bcf7 2022-09-13 op fcgi->fcg_toread = CAT(hdr.content_len0,
390 b0a6bcf7 2022-09-13 op hdr.content_len1);
391 b0a6bcf7 2022-09-13 op if (fcgi->fcg_toread < 0) {
392 b0a6bcf7 2022-09-13 op log_warnx("invalid record length: %d",
393 b0a6bcf7 2022-09-13 op fcgi->fcg_toread);
394 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_READ, d);
398 b0a6bcf7 2022-09-13 op fcgi->fcg_padding = hdr.padding;
399 b0a6bcf7 2022-09-13 op if (fcgi->fcg_padding < 0) {
400 b0a6bcf7 2022-09-13 op log_warnx("invalid padding: %d",
401 b0a6bcf7 2022-09-13 op fcgi->fcg_padding);
402 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_READ, d);
406 b0a6bcf7 2022-09-13 op fcgi->fcg_type = hdr.type;
407 b0a6bcf7 2022-09-13 op fcgi->fcg_rec_id = CAT(hdr.req_id0, hdr.req_id1);
411 b0a6bcf7 2022-09-13 op q.clt_id = fcgi->fcg_rec_id;
412 b0a6bcf7 2022-09-13 op clt = SPLAY_FIND(client_tree, &fcgi->fcg_clients, &q);
414 b0a6bcf7 2022-09-13 op switch (fcgi->fcg_type) {
415 b0a6bcf7 2022-09-13 op case FCGI_BEGIN_REQUEST:
416 b0a6bcf7 2022-09-13 op if (sizeof(breq) != fcgi->fcg_toread) {
417 b0a6bcf7 2022-09-13 op log_warnx("unexpected size for "
418 b0a6bcf7 2022-09-13 op "FCGI_BEGIN_REQUEST");
419 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_READ, d);
423 b0a6bcf7 2022-09-13 op evbuffer_remove(src, &breq, sizeof(breq));
425 b0a6bcf7 2022-09-13 op role = CAT(breq.role0, breq.role1);
426 b0a6bcf7 2022-09-13 op if (role != FCGI_RESPONDER) {
427 b0a6bcf7 2022-09-13 op log_warnx("unknown fastcgi role: %d",
429 b0a6bcf7 2022-09-13 op if (fcgi_send_end_req(fcgi, fcgi->fcg_rec_id,
430 b0a6bcf7 2022-09-13 op 1, FCGI_UNKNOWN_ROLE) == -1) {
431 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_READ, d);
437 b0a6bcf7 2022-09-13 op if (!fcgi->fcg_keep_conn) {
438 b0a6bcf7 2022-09-13 op log_warnx("trying to reuse the fastcgi "
439 b0a6bcf7 2022-09-13 op "socket without marking it as so.");
440 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_READ, d);
443 b0a6bcf7 2022-09-13 op fcgi->fcg_keep_conn = breq.flags & FCGI_KEEP_CONN;
445 b0a6bcf7 2022-09-13 op if (clt != NULL) {
446 b0a6bcf7 2022-09-13 op log_warnx("ignoring attemp to re-use an "
447 b0a6bcf7 2022-09-13 op "active request id (%d)",
448 b0a6bcf7 2022-09-13 op fcgi->fcg_rec_id);
452 b0a6bcf7 2022-09-13 op if ((clt = calloc(1, sizeof(*clt))) == NULL) {
453 b0a6bcf7 2022-09-13 op log_warnx("calloc");
457 b0a6bcf7 2022-09-13 op clt->clt_id = fcgi->fcg_rec_id;
458 b0a6bcf7 2022-09-13 op clt->clt_fd = -1;
459 b0a6bcf7 2022-09-13 op clt->clt_fcgi = fcgi;
460 b0a6bcf7 2022-09-13 op SPLAY_INSERT(client_tree, &fcgi->fcg_clients, clt);
462 b0a6bcf7 2022-09-13 op case FCGI_PARAMS:
463 b0a6bcf7 2022-09-13 op if (clt == NULL) {
464 b0a6bcf7 2022-09-13 op log_warnx("got FCGI_PARAMS for inactive id "
465 b0a6bcf7 2022-09-13 op "(%d)", fcgi->fcg_rec_id);
466 b0a6bcf7 2022-09-13 op evbuffer_drain(src, fcgi->fcg_toread);
469 b0a6bcf7 2022-09-13 op if (fcgi->fcg_toread == 0) {
470 b0a6bcf7 2022-09-13 op evbuffer_drain(src, fcgi->fcg_toread);
471 b0a6bcf7 2022-09-13 op proxy_start_request(env, clt);
474 b0a6bcf7 2022-09-13 op if (fcgi_parse_params(fcgi, src, clt) == -1) {
475 b0a6bcf7 2022-09-13 op log_warnx("fcgi_parse_params failed");
476 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_READ, d);
480 b0a6bcf7 2022-09-13 op case FCGI_STDIN:
482 b0a6bcf7 2022-09-13 op evbuffer_drain(src, fcgi->fcg_toread);
484 b0a6bcf7 2022-09-13 op case FCGI_ABORT_REQUEST:
485 b0a6bcf7 2022-09-13 op if (clt == NULL) {
486 b0a6bcf7 2022-09-13 op log_warnx("got FCGI_ABORT_REQUEST for inactive"
487 b0a6bcf7 2022-09-13 op " id (%d)", fcgi->fcg_rec_id);
488 b0a6bcf7 2022-09-13 op evbuffer_drain(src, fcgi->fcg_toread);
491 b0a6bcf7 2022-09-13 op if (fcgi_end_request(clt, 1) == -1) {
492 b0a6bcf7 2022-09-13 op /* calls fcgi_error on failure */
497 b0a6bcf7 2022-09-13 op log_warnx("unknown fastcgi record type %d",
498 b0a6bcf7 2022-09-13 op fcgi->fcg_type);
499 b0a6bcf7 2022-09-13 op evbuffer_drain(src, fcgi->fcg_toread);
503 b0a6bcf7 2022-09-13 op /* Prepare for the next record. */
504 b0a6bcf7 2022-09-13 op evbuffer_drain(src, fcgi->fcg_padding);
505 b0a6bcf7 2022-09-13 op fcgi->fcg_want = FCGI_RECORD_HEADER;
506 b0a6bcf7 2022-09-13 op fcgi->fcg_toread = sizeof(struct fcgi_header);
511 b0a6bcf7 2022-09-13 op fcgi_write(struct bufferevent *bev, void *d)
513 b0a6bcf7 2022-09-13 op struct fcgi *fcgi = d;
519 b0a6bcf7 2022-09-13 op fcgi_error(struct bufferevent *bev, short event, void *d)
521 b0a6bcf7 2022-09-13 op struct fcgi *fcgi = d;
522 b0a6bcf7 2022-09-13 op struct galileo *env = fcgi->fcg_env;
523 b0a6bcf7 2022-09-13 op struct client *clt;
525 b0a6bcf7 2022-09-13 op log_debug("fcgi failure, shutting down connection (ev: %x)",
527 b0a6bcf7 2022-09-13 op fcgi_inflight_dec(__func__);
529 b0a6bcf7 2022-09-13 op while ((clt = SPLAY_MIN(client_tree, &fcgi->fcg_clients)) != NULL) {
530 b0a6bcf7 2022-09-13 op SPLAY_REMOVE(client_tree, &fcgi->fcg_clients, clt);
531 b0a6bcf7 2022-09-13 op proxy_client_free(clt);
534 b0a6bcf7 2022-09-13 op close(fcgi->fcg_s);
535 b0a6bcf7 2022-09-13 op bufferevent_free(fcgi->fcg_bev);
536 b0a6bcf7 2022-09-13 op SPLAY_REMOVE(fcgi_tree, &env->sc_fcgi_socks, fcgi);
543 b0a6bcf7 2022-09-13 op clt_flush(struct client *clt)
545 b0a6bcf7 2022-09-13 op struct fcgi *fcgi = clt->clt_fcgi;
546 b0a6bcf7 2022-09-13 op struct bufferevent *bev = fcgi->fcg_bev;
547 b0a6bcf7 2022-09-13 op struct fcgi_header hdr;
549 b0a6bcf7 2022-09-13 op if (clt->clt_buflen == 0)
552 b0a6bcf7 2022-09-13 op memset(&hdr, 0, sizeof(hdr));
553 b0a6bcf7 2022-09-13 op hdr.version = FCGI_VERSION_1;
554 b0a6bcf7 2022-09-13 op hdr.type = FCGI_STDOUT;
555 b0a6bcf7 2022-09-13 op hdr.req_id0 = (clt->clt_id & 0xFF);
556 b0a6bcf7 2022-09-13 op hdr.req_id1 = (clt->clt_id >> 8);
557 b0a6bcf7 2022-09-13 op hdr.content_len0 = (clt->clt_buflen & 0xFF);
558 b0a6bcf7 2022-09-13 op hdr.content_len1 = (clt->clt_buflen >> 8);
560 b0a6bcf7 2022-09-13 op if (bufferevent_write(bev, &hdr, sizeof(hdr)) == -1 ||
561 b0a6bcf7 2022-09-13 op bufferevent_write(bev, clt->clt_buf, clt->clt_buflen) == -1) {
562 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_WRITE, fcgi);
566 b0a6bcf7 2022-09-13 op clt->clt_buflen = 0;
572 b0a6bcf7 2022-09-13 op clt_write(struct client *clt, const uint8_t *buf, size_t len)
574 b0a6bcf7 2022-09-13 op size_t left, copy;
576 b0a6bcf7 2022-09-13 op while (len > 0) {
577 b0a6bcf7 2022-09-13 op left = sizeof(clt->clt_buf) - clt->clt_buflen;
578 b0a6bcf7 2022-09-13 op if (left == 0) {
579 b0a6bcf7 2022-09-13 op if (clt_flush(clt) == -1)
581 b0a6bcf7 2022-09-13 op left = sizeof(clt->clt_buf);
584 b0a6bcf7 2022-09-13 op copy = MIN(left, len);
586 b0a6bcf7 2022-09-13 op memcpy(&clt->clt_buf[clt->clt_buflen], buf, copy);
587 b0a6bcf7 2022-09-13 op clt->clt_buflen += copy;
596 c9dc4bc6 2022-09-13 op clt_putc(struct client *clt, char ch)
598 c9dc4bc6 2022-09-13 op return (clt_write(clt, &ch, 1));
602 c9dc4bc6 2022-09-13 op clt_puts(struct client *clt, const char *str)
604 c9dc4bc6 2022-09-13 op return (clt_write(clt, str, strlen(str)));
608 b0a6bcf7 2022-09-13 op clt_write_bufferevent(struct client *clt, struct bufferevent *bev)
610 b0a6bcf7 2022-09-13 op struct evbuffer *src = EVBUFFER_INPUT(bev);
611 b0a6bcf7 2022-09-13 op size_t len, left, copy;
613 b0a6bcf7 2022-09-13 op len = EVBUFFER_LENGTH(src);
614 b0a6bcf7 2022-09-13 op while (len > 0) {
615 b0a6bcf7 2022-09-13 op left = sizeof(clt->clt_buf) - clt->clt_buflen;
616 b0a6bcf7 2022-09-13 op if (left == 0) {
617 b0a6bcf7 2022-09-13 op if (clt_flush(clt) == -1)
619 b0a6bcf7 2022-09-13 op left = sizeof(clt->clt_buf);
622 b0a6bcf7 2022-09-13 op copy = bufferevent_read(bev, &clt->clt_buf[clt->clt_buflen],
623 b0a6bcf7 2022-09-13 op MIN(left, len));
624 b0a6bcf7 2022-09-13 op clt->clt_buflen += copy;
626 b0a6bcf7 2022-09-13 op len = EVBUFFER_LENGTH(src);
633 b0a6bcf7 2022-09-13 op clt_printf(struct client *clt, const char *fmt, ...)
635 b0a6bcf7 2022-09-13 op struct fcgi *fcgi = clt->clt_fcgi;
636 b0a6bcf7 2022-09-13 op struct bufferevent *bev = fcgi->fcg_bev;
641 b0a6bcf7 2022-09-13 op va_start(ap, fmt);
642 b0a6bcf7 2022-09-13 op r = vasprintf(&str, fmt, ap);
644 b0a6bcf7 2022-09-13 op if (r == -1) {
645 b0a6bcf7 2022-09-13 op fcgi_error(bev, EV_WRITE, fcgi);
649 b0a6bcf7 2022-09-13 op r = clt_write(clt, str, r);
655 b0a6bcf7 2022-09-13 op fcgi_cmp(struct fcgi *a, struct fcgi *b)
657 b0a6bcf7 2022-09-13 op return ((int)a->fcg_id - b->fcg_id);
661 b0a6bcf7 2022-09-13 op fcgi_client_cmp(struct client *a, struct client *b)
663 b0a6bcf7 2022-09-13 op return ((int)a->clt_id - b->clt_id);
666 b0a6bcf7 2022-09-13 op SPLAY_GENERATE(fcgi_tree, fcgi, fcg_nodes, fcgi_cmp);
667 b0a6bcf7 2022-09-13 op SPLAY_GENERATE(client_tree, client, clt_nodes, fcgi_client_cmp);