2 8d1b399b 2021-07-22 op * Copyright (c) 2021 Omar Polo <op@omarpolo.com>
3 8d1b399b 2021-07-22 op * Copyright (c) 2018 Florian Obser <florian@openbsd.org>
4 8d1b399b 2021-07-22 op * Copyright (c) 2005 Claudio Jeker <claudio@openbsd.org>
5 8d1b399b 2021-07-22 op * Copyright (c) 2004 Esben Norby <norby@openbsd.org>
6 8d1b399b 2021-07-22 op * Copyright (c) 2003, 2004 Henning Brauer <henning@openbsd.org>
8 8d1b399b 2021-07-22 op * Permission to use, copy, modify, and distribute this software for any
9 8d1b399b 2021-07-22 op * purpose with or without fee is hereby granted, provided that the above
10 8d1b399b 2021-07-22 op * copyright notice and this permission notice appear in all copies.
12 8d1b399b 2021-07-22 op * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
13 8d1b399b 2021-07-22 op * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
14 8d1b399b 2021-07-22 op * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
15 8d1b399b 2021-07-22 op * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
16 8d1b399b 2021-07-22 op * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
17 8d1b399b 2021-07-22 op * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
18 8d1b399b 2021-07-22 op * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
21 8d1b399b 2021-07-22 op #include <sys/socket.h>
22 8d1b399b 2021-07-22 op #include <sys/wait.h>
24 8d1b399b 2021-07-22 op #include <arpa/inet.h>
25 8d1b399b 2021-07-22 op #include <netinet/in.h>
27 8d1b399b 2021-07-22 op #include <errno.h>
28 8d1b399b 2021-07-22 op #include <fcntl.h>
29 8d1b399b 2021-07-22 op #include <pwd.h>
30 8d1b399b 2021-07-22 op #include <signal.h>
31 8d1b399b 2021-07-22 op #include <stdio.h>
32 8d1b399b 2021-07-22 op #include <stdlib.h>
33 8d1b399b 2021-07-22 op #include <string.h>
34 8d1b399b 2021-07-22 op #include <syslog.h>
35 8d1b399b 2021-07-22 op #include <unistd.h>
37 8d1b399b 2021-07-22 op #include "client.h"
38 8d1b399b 2021-07-22 op #include "control.h"
39 8d1b399b 2021-07-22 op #include "kamid.h"
40 8d1b399b 2021-07-22 op #include "listener.h"
41 8d1b399b 2021-07-22 op #include "log.h"
42 8d1b399b 2021-07-22 op #include "sandbox.h"
43 0ca6718e 2021-07-22 op #include "table.h"
44 8d1b399b 2021-07-22 op #include "utils.h"
46 8d1b399b 2021-07-22 op enum kd_process {
48 8d1b399b 2021-07-22 op PROC_LISTENER,
49 8d1b399b 2021-07-22 op PROC_CLIENTCONN,
52 8d1b399b 2021-07-22 op const char *saved_argv0;
53 8d1b399b 2021-07-22 op static int debug, nflag;
56 06a84967 2021-07-22 op ATTR_DEAD void usage(void);
58 8d1b399b 2021-07-22 op void main_sig_handler(int, short, void *);
59 8d1b399b 2021-07-22 op void main_dispatch_listener(int, short, void *);
60 8d1b399b 2021-07-22 op int main_reload(void);
61 8d1b399b 2021-07-22 op int main_imsg_send_config(struct kd_conf *);
62 8d1b399b 2021-07-22 op void main_dispatch_listener(int, short, void *);
63 06a84967 2021-07-22 op ATTR_DEAD void main_shutdown(void);
65 8d1b399b 2021-07-22 op static pid_t start_child(enum kd_process, int, int, int);
67 8d1b399b 2021-07-22 op struct kd_conf *main_conf;
68 8d1b399b 2021-07-22 op static struct imsgev *iev_listener;
69 8d1b399b 2021-07-22 op const char *conffile;
70 8d1b399b 2021-07-22 op pid_t listener_pid;
71 8d1b399b 2021-07-22 op uint32_t cmd_opts;
73 06a84967 2021-07-22 op ATTR_DEAD void
76 8d1b399b 2021-07-22 op fprintf(stderr, "usage: %s [-dnv] [-f file] [-s socket]\n",
77 8d1b399b 2021-07-22 op getprogname());
82 8d1b399b 2021-07-22 op main(int argc, char **argv)
84 8d1b399b 2021-07-22 op struct event ev_sigint, ev_sigterm, ev_sighup;
86 8d1b399b 2021-07-22 op int listener_flag = 0, client_flag = 0;
87 8d1b399b 2021-07-22 op int pipe_main2listener[2];
88 8d1b399b 2021-07-22 op int control_fd;
89 8d1b399b 2021-07-22 op const char *csock;
91 8d1b399b 2021-07-22 op conffile = KD_CONF_FILE;
92 8d1b399b 2021-07-22 op csock = KD_SOCKET;
94 8d1b399b 2021-07-22 op log_init(1, LOG_DAEMON); /* Log to stderr until deamonized. */
95 8d1b399b 2021-07-22 op log_setverbose(1);
97 8d1b399b 2021-07-22 op saved_argv0 = argv[0];
98 8d1b399b 2021-07-22 op if (saved_argv0 == NULL)
99 8d1b399b 2021-07-22 op saved_argv0 = "kamid";
101 8d1b399b 2021-07-22 op while ((ch = getopt(argc, argv, "D:df:nsT:v")) != -1) {
102 8d1b399b 2021-07-22 op switch (ch) {
104 8d1b399b 2021-07-22 op if (cmdline_symset(optarg) == -1)
105 8d1b399b 2021-07-22 op log_warnx("could not parse macro definition %s",
112 8d1b399b 2021-07-22 op conffile = optarg;
118 8d1b399b 2021-07-22 op csock = optarg;
121 8d1b399b 2021-07-22 op switch (*optarg) {
123 8d1b399b 2021-07-22 op client_flag = 1;
126 8d1b399b 2021-07-22 op listener_flag = 1;
129 8d1b399b 2021-07-22 op fatalx("invalid process spec %c", *optarg);
140 8d1b399b 2021-07-22 op argc -= optind;
141 8d1b399b 2021-07-22 op argv += optind;
142 8d1b399b 2021-07-22 op if (argc > 0 || (listener_flag && client_flag))
145 8d1b399b 2021-07-22 op if (client_flag)
146 8d1b399b 2021-07-22 op client(debug, verbose);
147 8d1b399b 2021-07-22 op else if (listener_flag)
148 8d1b399b 2021-07-22 op listener(debug, verbose);
150 8d1b399b 2021-07-22 op if ((main_conf = parse_config(conffile)) == NULL)
154 8d1b399b 2021-07-22 op fprintf(stderr, "configuratino OK\n");
158 8d1b399b 2021-07-22 op /* Check for root privileges. */
159 8d1b399b 2021-07-22 op if (geteuid())
160 8d1b399b 2021-07-22 op fatalx("need root privileges");
162 8d1b399b 2021-07-22 op /* Check for assigned daemon user. */
163 8d1b399b 2021-07-22 op if (getpwnam(KD_USER) == NULL)
164 8d1b399b 2021-07-22 op fatalx("unknown user %s", KD_USER);
166 8d1b399b 2021-07-22 op log_init(debug, LOG_DAEMON);
167 8d1b399b 2021-07-22 op log_setverbose(verbose);
170 8d1b399b 2021-07-22 op daemon(1, 0);
172 8d1b399b 2021-07-22 op log_info("startup");
174 8d1b399b 2021-07-22 op if (socketpair(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC | SOCK_NONBLOCK,
175 8d1b399b 2021-07-22 op PF_UNSPEC, pipe_main2listener) == -1)
176 8d1b399b 2021-07-22 op fatal("main2listener socketpair");
178 8d1b399b 2021-07-22 op /* Start children. */
179 8d1b399b 2021-07-22 op listener_pid = start_child(PROC_LISTENER, pipe_main2listener[1],
180 8d1b399b 2021-07-22 op debug, verbose);
182 8d1b399b 2021-07-22 op log_procinit("main");
184 8d1b399b 2021-07-22 op event_init();
186 8d1b399b 2021-07-22 op /* Setup signal handler */
187 8d1b399b 2021-07-22 op signal_set(&ev_sigint, SIGINT, main_sig_handler, NULL);
188 8d1b399b 2021-07-22 op signal_set(&ev_sigterm, SIGTERM, main_sig_handler, NULL);
189 8d1b399b 2021-07-22 op signal_set(&ev_sighup, SIGHUP, main_sig_handler, NULL);
191 8d1b399b 2021-07-22 op signal_add(&ev_sigint, NULL);
192 8d1b399b 2021-07-22 op signal_add(&ev_sigterm, NULL);
193 8d1b399b 2021-07-22 op signal_add(&ev_sighup, NULL);
195 8d1b399b 2021-07-22 op signal(SIGCHLD, SIG_IGN);
196 8d1b399b 2021-07-22 op signal(SIGPIPE, SIG_IGN);
198 8d1b399b 2021-07-22 op if ((iev_listener = malloc(sizeof(*iev_listener))) == NULL)
200 8d1b399b 2021-07-22 op imsg_init(&iev_listener->ibuf, pipe_main2listener[0]);
201 8d1b399b 2021-07-22 op iev_listener->handler = main_dispatch_listener;
203 8d1b399b 2021-07-22 op /* Setup event handlers for pipes to listener. */
204 8d1b399b 2021-07-22 op iev_listener->events = EV_READ;
205 8d1b399b 2021-07-22 op event_set(&iev_listener->ev, iev_listener->ibuf.fd,
206 8d1b399b 2021-07-22 op iev_listener->events, iev_listener->handler, iev_listener);
207 8d1b399b 2021-07-22 op event_add(&iev_listener->ev, NULL);
209 8d1b399b 2021-07-22 op if ((control_fd = control_init(csock)) == -1)
210 8d1b399b 2021-07-22 op fatalx("control socket setup failed");
212 8d1b399b 2021-07-22 op main_imsg_compose_listener(IMSG_CONTROLFD, control_fd, 0,
214 8d1b399b 2021-07-22 op main_imsg_send_config(main_conf);
216 8d1b399b 2021-07-22 op sandbox_main();
218 8d1b399b 2021-07-22 op event_dispatch();
220 8d1b399b 2021-07-22 op main_shutdown();
225 8d1b399b 2021-07-22 op main_sig_handler(int sig, short event, void *arg)
228 8d1b399b 2021-07-22 op * Normal signal handler rules don't apply because libevent
229 8d1b399b 2021-07-22 op * decouples for us.
232 8d1b399b 2021-07-22 op switch (sig) {
233 8d1b399b 2021-07-22 op case SIGTERM:
235 8d1b399b 2021-07-22 op main_shutdown();
238 8d1b399b 2021-07-22 op if (main_reload() == -1)
239 8d1b399b 2021-07-22 op log_warnx("configuration reload failed");
241 8d1b399b 2021-07-22 op log_debug("configuration reloaded");
244 8d1b399b 2021-07-22 op fatalx("unexpected signal %d", sig);
248 0ca6718e 2021-07-22 op static inline struct table *
249 0ca6718e 2021-07-22 op auth_table_by_id(uint32_t id)
251 0ca6718e 2021-07-22 op struct kd_listen_conf *listen;
253 0ca6718e 2021-07-22 op SIMPLEQ_FOREACH(listen, &main_conf->listen_head, entry) {
254 0ca6718e 2021-07-22 op if (listen->id == id)
255 0ca6718e 2021-07-22 op return listen->auth_table;
261 8d1b399b 2021-07-22 op static inline void
262 8d1b399b 2021-07-22 op do_auth_tls(struct imsg *imsg)
264 0ca6718e 2021-07-22 op char *username = NULL;
265 8d1b399b 2021-07-22 op struct passwd *pw;
266 0ca6718e 2021-07-22 op struct table *t;
267 0ca6718e 2021-07-22 op struct kd_auth_req auth;
270 0ca6718e 2021-07-22 op if (sizeof(auth) != IMSG_DATA_SIZE(*imsg))
271 0ca6718e 2021-07-22 op fatal("wrong size for IMSG_AUTH_TLS: "
272 0ca6718e 2021-07-22 op "got %lu; want %lu", IMSG_DATA_SIZE(*imsg),
273 0ca6718e 2021-07-22 op sizeof(auth));
274 0ca6718e 2021-07-22 op memcpy(&auth, imsg->data, sizeof(auth));
276 0ca6718e 2021-07-22 op if (memmem(auth.hash, sizeof(auth.hash), "", 1) == NULL)
277 0ca6718e 2021-07-22 op fatal("non NUL-terminated hash received");
279 0ca6718e 2021-07-22 op log_debug("tls id=%u hash=%s", auth.listen_id, auth.hash);
281 0ca6718e 2021-07-22 op if ((t = auth_table_by_id(auth.listen_id)) == NULL)
282 0ca6718e 2021-07-22 op fatal("request for invalid listener id %d", imsg->hdr.pid);
284 0ca6718e 2021-07-22 op log_debug("before table_lookup");
285 0ca6718e 2021-07-22 op if (table_lookup(t, auth.hash, &username) == -1) {
286 0ca6718e 2021-07-22 op log_warnx("login failed for hash %s", auth.hash);
290 0ca6718e 2021-07-22 op log_debug("matched local user %s", username);
292 8d1b399b 2021-07-22 op if ((pw = getpwnam(username)) == NULL) {
293 8d1b399b 2021-07-22 op log_warn("getpwnam(%s)", username);
297 8d1b399b 2021-07-22 op if (socketpair(AF_UNIX, SOCK_STREAM|SOCK_CLOEXEC|SOCK_NONBLOCK,
298 8d1b399b 2021-07-22 op PF_UNSPEC, p) == -1)
299 8d1b399b 2021-07-22 op fatal("socketpair");
301 8d1b399b 2021-07-22 op start_child(PROC_CLIENTCONN, p[1], debug, verbose);
303 8d1b399b 2021-07-22 op main_imsg_compose_listener(IMSG_AUTH, p[0], imsg->hdr.peerid,
304 8d1b399b 2021-07-22 op username, strlen(username)+1);
305 8d1b399b 2021-07-22 op main_imsg_compose_listener(IMSG_AUTH_DIR, -1, imsg->hdr.peerid,
306 8d1b399b 2021-07-22 op pw->pw_dir, strlen(pw->pw_dir)+1);
308 0ca6718e 2021-07-22 op free(username);
312 0ca6718e 2021-07-22 op free(username);
313 8d1b399b 2021-07-22 op main_imsg_compose_listener(IMSG_AUTH, -1, imsg->hdr.peerid,
318 8d1b399b 2021-07-22 op main_dispatch_listener(int fd, short event, void *d)
320 8d1b399b 2021-07-22 op struct imsgev *iev = d;
321 8d1b399b 2021-07-22 op struct imsgbuf *ibuf;
322 8d1b399b 2021-07-22 op struct imsg imsg;
324 8d1b399b 2021-07-22 op int shut = 0;
326 8d1b399b 2021-07-22 op ibuf = &iev->ibuf;
328 8d1b399b 2021-07-22 op if (event & EV_READ) {
329 8d1b399b 2021-07-22 op if ((n = imsg_read(ibuf)) == -1 && errno != EAGAIN)
330 8d1b399b 2021-07-22 op fatal("imsg_read error");
331 8d1b399b 2021-07-22 op if (n == 0) /* Connection closed. */
334 8d1b399b 2021-07-22 op if (event & EV_WRITE) {
335 8d1b399b 2021-07-22 op if ((n = msgbuf_write(&ibuf->w)) == -1 && errno != EAGAIN)
336 8d1b399b 2021-07-22 op fatal("msgbuf_write");
337 8d1b399b 2021-07-22 op if (n == 0) /* Connection closed. */
342 8d1b399b 2021-07-22 op if ((n = imsg_get(ibuf, &imsg)) == -1)
343 8d1b399b 2021-07-22 op fatal("imsg_get");
344 8d1b399b 2021-07-22 op if (n == 0) /* No more messages. */
347 8d1b399b 2021-07-22 op switch (imsg.hdr.type) {
348 8d1b399b 2021-07-22 op case IMSG_AUTH_TLS:
349 8d1b399b 2021-07-22 op do_auth_tls(&imsg);
352 8d1b399b 2021-07-22 op log_debug("%s: error handling imsg %d", __func__,
353 8d1b399b 2021-07-22 op imsg.hdr.type);
356 8d1b399b 2021-07-22 op imsg_free(&imsg);
359 8d1b399b 2021-07-22 op imsg_event_add(iev);
361 8d1b399b 2021-07-22 op /* This pipe is dead. Remove its event handler. */
362 8d1b399b 2021-07-22 op event_del(&iev->ev);
363 8d1b399b 2021-07-22 op event_loopexit(NULL);
368 8d1b399b 2021-07-22 op main_reload(void)
370 8d1b399b 2021-07-22 op struct kd_conf *xconf;
372 8d1b399b 2021-07-22 op if ((xconf = parse_config(conffile)) == NULL)
375 8d1b399b 2021-07-22 op if (main_imsg_send_config(xconf) == -1)
378 8d1b399b 2021-07-22 op merge_config(main_conf, xconf);
383 8d1b399b 2021-07-22 op static inline int
384 8d1b399b 2021-07-22 op make_socket_for(struct kd_listen_conf *l)
386 8d1b399b 2021-07-22 op struct sockaddr_in addr4;
390 8d1b399b 2021-07-22 op memset(&addr4, 0, sizeof(addr4));
391 8d1b399b 2021-07-22 op addr4.sin_family = AF_INET;
392 8d1b399b 2021-07-22 op addr4.sin_port = htons(l->port);
393 8d1b399b 2021-07-22 op addr4.sin_addr.s_addr = INADDR_ANY;
395 8d1b399b 2021-07-22 op if ((fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
396 8d1b399b 2021-07-22 op fatal("socket");
399 8d1b399b 2021-07-22 op if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &v, sizeof(v)) == -1)
400 8d1b399b 2021-07-22 op fatal("setsockopt(SO_REUSEADDR)");
403 8d1b399b 2021-07-22 op if (setsockopt(fd, SOL_SOCKET, SO_REUSEPORT, &v, sizeof(v)) == -1)
404 8d1b399b 2021-07-22 op fatal("setsockopt(SO_REUSEPORT)");
406 8d1b399b 2021-07-22 op len = sizeof(addr4);
407 8d1b399b 2021-07-22 op if (bind(fd, (struct sockaddr *)&addr4, len) == -1)
408 8d1b399b 2021-07-22 op fatal("bind(%s, %d)", l->iface, l->port);
410 8d1b399b 2021-07-22 op if (listen(fd, 16) == -1)
411 8d1b399b 2021-07-22 op fatal("l(%s, %d)", l->iface, l->port);
417 8d1b399b 2021-07-22 op main_imsg_send_config(struct kd_conf *xconf)
419 8d1b399b 2021-07-22 op struct kd_pki_conf *pki;
420 8d1b399b 2021-07-22 op struct kd_listen_conf *listen;
422 8d1b399b 2021-07-22 op #define SEND(type, fd, data, len) do { \
423 8d1b399b 2021-07-22 op if (main_imsg_compose_listener(type, fd, 0, data, len) \
428 8d1b399b 2021-07-22 op /* Send fixed part of config to children. */
429 8d1b399b 2021-07-22 op SEND(IMSG_RECONF_CONF, -1, xconf, sizeof(*xconf));
431 8d1b399b 2021-07-22 op SIMPLEQ_FOREACH(pki, &xconf->pki_head, entry) {
432 8d1b399b 2021-07-22 op log_debug("sending pki %s", pki->name);
433 8d1b399b 2021-07-22 op SEND(IMSG_RECONF_PKI, -1, pki->name, sizeof(pki->name));
434 8d1b399b 2021-07-22 op SEND(IMSG_RECONF_PKI_CERT, -1, pki->cert, pki->certlen);
435 8d1b399b 2021-07-22 op SEND(IMSG_RECONF_PKI_KEY, -1, pki->key, pki->keylen);
438 8d1b399b 2021-07-22 op SIMPLEQ_FOREACH(listen, &xconf->listen_head, entry) {
439 8d1b399b 2021-07-22 op log_debug("sending listen on port %d", listen->port);
440 8d1b399b 2021-07-22 op SEND(IMSG_RECONF_LISTEN, make_socket_for(listen), listen,
441 8d1b399b 2021-07-22 op sizeof(*listen));
444 8d1b399b 2021-07-22 op SEND(IMSG_RECONF_END, -1, NULL, 0);
451 8d1b399b 2021-07-22 op merge_config(struct kd_conf *conf, struct kd_conf *xconf)
453 8d1b399b 2021-07-22 op /* do stuff... */
458 8d1b399b 2021-07-22 op struct kd_conf *
459 8d1b399b 2021-07-22 op config_new_empty(void)
461 8d1b399b 2021-07-22 op struct kd_conf *xconf;
463 8d1b399b 2021-07-22 op if ((xconf = calloc(1, sizeof(*xconf))) == NULL)
466 8d1b399b 2021-07-22 op /* set default values */
468 8d1b399b 2021-07-22 op return xconf;
472 8d1b399b 2021-07-22 op config_clear(struct kd_conf *conf)
474 8d1b399b 2021-07-22 op struct kd_conf *xconf;
476 8d1b399b 2021-07-22 op /* Merge current config with an empty one. */
477 8d1b399b 2021-07-22 op xconf = config_new_empty();
478 8d1b399b 2021-07-22 op merge_config(conf, xconf);
483 06a84967 2021-07-22 op ATTR_DEAD void
484 8d1b399b 2021-07-22 op main_shutdown(void)
489 8d1b399b 2021-07-22 op /* close pipes. */
490 8d1b399b 2021-07-22 op config_clear(main_conf);
492 8d1b399b 2021-07-22 op log_debug("waiting for children to terminate");
494 8d1b399b 2021-07-22 op pid = wait(&status);
495 8d1b399b 2021-07-22 op if (pid == -1) {
496 8d1b399b 2021-07-22 op if (errno != EINTR && errno != ECHILD)
497 8d1b399b 2021-07-22 op fatal("wait");
498 8d1b399b 2021-07-22 op } else if (WIFSIGNALED(status))
499 8d1b399b 2021-07-22 op log_warnx("%s terminated; signal %d",
500 8d1b399b 2021-07-22 op (pid == listener_pid) ? "logger" : "clientconn",
501 8d1b399b 2021-07-22 op WTERMSIG(status));
502 8d1b399b 2021-07-22 op } while (pid != -1 || (pid == -1 && errno == EINTR));
504 8d1b399b 2021-07-22 op free(iev_listener);
506 8d1b399b 2021-07-22 op log_info("terminating");
511 8d1b399b 2021-07-22 op start_child(enum kd_process p, int fd, int debug, int verbose)
513 8d1b399b 2021-07-22 op const char *argv[5];
514 8d1b399b 2021-07-22 op int argc = 0;
517 8d1b399b 2021-07-22 op switch (pid = fork()) {
519 8d1b399b 2021-07-22 op fatal("cannot fork");
527 8d1b399b 2021-07-22 op if (fd != 3) {
528 8d1b399b 2021-07-22 op if (dup2(fd, 3) == -1)
529 8d1b399b 2021-07-22 op fatal("cannot setup imsg fd");
530 8d1b399b 2021-07-22 op } else if (fcntl(F_SETFD, 0) == -1)
531 8d1b399b 2021-07-22 op fatal("cannot setup imsg fd");
533 8d1b399b 2021-07-22 op argv[argc++] = saved_argv0;
535 8d1b399b 2021-07-22 op case PROC_MAIN:
536 8d1b399b 2021-07-22 op fatalx("Can not start main process");
537 8d1b399b 2021-07-22 op case PROC_LISTENER:
538 8d1b399b 2021-07-22 op argv[argc++] = "-Tl";
540 8d1b399b 2021-07-22 op case PROC_CLIENTCONN:
541 8d1b399b 2021-07-22 op argv[argc++] = "-Tc";
545 8d1b399b 2021-07-22 op argv[argc++] = "-d";
547 8d1b399b 2021-07-22 op argv[argc++] = "-v";
548 8d1b399b 2021-07-22 op argv[argc++] = NULL;
550 8d1b399b 2021-07-22 op /* really? */
551 8d1b399b 2021-07-22 op execvp(saved_argv0, (char *const *)argv);
552 8d1b399b 2021-07-22 op fatal("execvp");
556 8d1b399b 2021-07-22 op imsg_event_add(struct imsgev *iev)
558 8d1b399b 2021-07-22 op iev->events = EV_READ;
559 8d1b399b 2021-07-22 op if (iev->ibuf.w.queued)
560 8d1b399b 2021-07-22 op iev->events |= EV_WRITE;
562 8d1b399b 2021-07-22 op event_del(&iev->ev);
563 8d1b399b 2021-07-22 op event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev);
564 8d1b399b 2021-07-22 op event_add(&iev->ev, NULL);
568 8d1b399b 2021-07-22 op imsg_compose_event(struct imsgev *iev, uint16_t type, uint32_t peerid,
569 8d1b399b 2021-07-22 op pid_t pid, int fd, const void *data, uint16_t datalen)
573 8d1b399b 2021-07-22 op if ((ret = imsg_compose(&iev->ibuf, type, peerid, pid, fd, data,
574 8d1b399b 2021-07-22 op datalen) != -1))
575 8d1b399b 2021-07-22 op imsg_event_add(iev);
581 8d1b399b 2021-07-22 op main_imsg_compose_listener(int type, int fd, uint32_t peerid,
582 8d1b399b 2021-07-22 op const void *data, uint16_t datalen)
584 8d1b399b 2021-07-22 op if (iev_listener)
585 8d1b399b 2021-07-22 op return imsg_compose_event(iev_listener, type, peerid, 0,
586 8d1b399b 2021-07-22 op fd, data, datalen);