xref: /netbsd-src/external/bsd/tmux/dist/client.c (revision e89934bbf778a6d6d6894877c4da59d0c7835b0f)
1 /* $OpenBSD$ */
2 
3 /*
4  * Copyright (c) 2007 Nicholas Marriott <nicholas.marriott@gmail.com>
5  *
6  * Permission to use, copy, modify, and distribute this software for any
7  * purpose with or without fee is hereby granted, provided that the above
8  * copyright notice and this permission notice appear in all copies.
9  *
10  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
11  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
12  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
13  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
14  * WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER
15  * IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
16  * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
17  */
18 
19 #include <sys/types.h>
20 #include <sys/file.h>
21 #include <sys/socket.h>
22 #include <sys/stat.h>
23 #include <sys/un.h>
24 #include <sys/wait.h>
25 
26 #include <errno.h>
27 #include <event.h>
28 #include <fcntl.h>
29 #include <signal.h>
30 #include <stdlib.h>
31 #include <string.h>
32 #include <unistd.h>
33 
34 #include "tmux.h"
35 
36 struct tmuxproc	*client_proc;
37 struct tmuxpeer	*client_peer;
38 int		 client_flags;
39 struct event	 client_stdin;
40 enum {
41 	CLIENT_EXIT_NONE,
42 	CLIENT_EXIT_DETACHED,
43 	CLIENT_EXIT_DETACHED_HUP,
44 	CLIENT_EXIT_LOST_TTY,
45 	CLIENT_EXIT_TERMINATED,
46 	CLIENT_EXIT_LOST_SERVER,
47 	CLIENT_EXIT_EXITED,
48 	CLIENT_EXIT_SERVER_EXITED,
49 } client_exitreason = CLIENT_EXIT_NONE;
50 int		 client_exitval;
51 enum msgtype	 client_exittype;
52 const char	*client_exitsession;
53 int		 client_attached;
54 
55 __dead void	client_exec(const char *,const char *);
56 int		client_get_lock(char *);
57 int		client_connect(struct event_base *, const char *, int);
58 void		client_send_identify(const char *, const char *);
59 void		client_stdin_callback(int, short, void *);
60 void		client_write(int, const char *, size_t);
61 void		client_signal(int);
62 void		client_dispatch(struct imsg *, void *);
63 void		client_dispatch_attached(struct imsg *);
64 void		client_dispatch_wait(struct imsg *, const char *);
65 const char     *client_exit_message(void);
66 
67 /*
68  * Get server create lock. If already held then server start is happening in
69  * another client, so block until the lock is released and return -2 to
70  * retry. Return -1 on failure to continue and start the server anyway.
71  */
72 int
73 client_get_lock(char *lockfile)
74 {
75 	int lockfd;
76 
77 	log_debug("lock file is %s", lockfile);
78 
79 	if ((lockfd = open(lockfile, O_WRONLY|O_CREAT, 0600)) == -1) {
80 		log_debug("open failed: %s", strerror(errno));
81 		return (-1);
82 	}
83 
84 	if (flock(lockfd, LOCK_EX|LOCK_NB) == -1) {
85 		log_debug("flock failed: %s", strerror(errno));
86 		if (errno != EAGAIN)
87 			return (lockfd);
88 		while (flock(lockfd, LOCK_EX) == -1 && errno == EINTR)
89 			/* nothing */;
90 		close(lockfd);
91 		return (-2);
92 	}
93 	log_debug("flock succeeded");
94 
95 	return (lockfd);
96 }
97 
98 /* Connect client to server. */
99 int
100 client_connect(struct event_base *base, const char *path, int start_server)
101 {
102 	struct sockaddr_un	sa;
103 	size_t			size;
104 	int			fd, lockfd = -1, locked = 0;
105 	char		       *lockfile = NULL;
106 
107 	memset(&sa, 0, sizeof sa);
108 	sa.sun_family = AF_UNIX;
109 	size = strlcpy(sa.sun_path, path, sizeof sa.sun_path);
110 	if (size >= sizeof sa.sun_path) {
111 		errno = ENAMETOOLONG;
112 		return (-1);
113 	}
114 	log_debug("socket is %s", path);
115 
116 retry:
117 	if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1)
118 		return (-1);
119 
120 	log_debug("trying connect");
121 	if (connect(fd, (struct sockaddr *)&sa, sizeof sa) == -1) {
122 		log_debug("connect failed: %s", strerror(errno));
123 		if (errno != ECONNREFUSED && errno != ENOENT)
124 			goto failed;
125 		if (!start_server)
126 			goto failed;
127 		close(fd);
128 
129 		if (!locked) {
130 			xasprintf(&lockfile, "%s.lock", path);
131 			if ((lockfd = client_get_lock(lockfile)) < 0) {
132 				log_debug("didn't get lock (%d)", lockfd);
133 
134 				free(lockfile);
135 				lockfile = NULL;
136 
137 				if (lockfd == -2)
138 					goto retry;
139 			}
140 			log_debug("got lock (%d)", lockfd);
141 
142 			/*
143 			 * Always retry at least once, even if we got the lock,
144 			 * because another client could have taken the lock,
145 			 * started the server and released the lock between our
146 			 * connect() and flock().
147 			 */
148 			locked = 1;
149 			goto retry;
150 		}
151 
152 		if (lockfd >= 0 && unlink(path) != 0 && errno != ENOENT) {
153 			free(lockfile);
154 			close(lockfd);
155 			return (-1);
156 		}
157 		fd = server_start(base, lockfd, lockfile);
158 	}
159 
160 	if (locked && lockfd >= 0) {
161 		free(lockfile);
162 		close(lockfd);
163 	}
164 	setblocking(fd, 0);
165 	return (fd);
166 
167 failed:
168 	if (locked) {
169 		free(lockfile);
170 		close(lockfd);
171 	}
172 	close(fd);
173 	return (-1);
174 }
175 
176 /* Get exit string from reason number. */
177 const char *
178 client_exit_message(void)
179 {
180 	static char msg[256];
181 
182 	switch (client_exitreason) {
183 	case CLIENT_EXIT_NONE:
184 		break;
185 	case CLIENT_EXIT_DETACHED:
186 		if (client_exitsession != NULL) {
187 			xsnprintf(msg, sizeof msg, "detached "
188 			    "(from session %s)", client_exitsession);
189 			return (msg);
190 		}
191 		return ("detached");
192 	case CLIENT_EXIT_DETACHED_HUP:
193 		if (client_exitsession != NULL) {
194 			xsnprintf(msg, sizeof msg, "detached and SIGHUP "
195 			    "(from session %s)", client_exitsession);
196 			return (msg);
197 		}
198 		return ("detached and SIGHUP");
199 	case CLIENT_EXIT_LOST_TTY:
200 		return ("lost tty");
201 	case CLIENT_EXIT_TERMINATED:
202 		return ("terminated");
203 	case CLIENT_EXIT_LOST_SERVER:
204 		return ("lost server");
205 	case CLIENT_EXIT_EXITED:
206 		return ("exited");
207 	case CLIENT_EXIT_SERVER_EXITED:
208 		return ("server exited");
209 	}
210 	return ("unknown reason");
211 }
212 
213 /* Client main loop. */
214 int
215 client_main(struct event_base *base, int argc, char **argv, int flags,
216     const char *shellcmd)
217 {
218 	struct cmd		*cmd;
219 	struct cmd_list		*cmdlist;
220 	struct msg_command_data	*data;
221 	int			 cmdflags, fd, i;
222 	const char		*ttynam, *cwd;
223 	pid_t			 ppid;
224 	enum msgtype		 msg;
225 	char			*cause, path[PATH_MAX];
226 	struct termios		 tio, saved_tio;
227 	size_t			 size;
228 
229 	/* Ignore SIGCHLD now or daemon() in the server will leave a zombie. */
230 	signal(SIGCHLD, SIG_IGN);
231 
232 	/* Save the flags. */
233 	client_flags = flags;
234 
235 	/* Set up the initial command. */
236 	cmdflags = 0;
237 	if (shellcmd != NULL) {
238 		msg = MSG_SHELL;
239 		cmdflags = CMD_STARTSERVER;
240 	} else if (argc == 0) {
241 		msg = MSG_COMMAND;
242 		cmdflags = CMD_STARTSERVER;
243 	} else {
244 		msg = MSG_COMMAND;
245 
246 		/*
247 		 * It sucks parsing the command string twice (in client and
248 		 * later in server) but it is necessary to get the start server
249 		 * flag.
250 		 */
251 		cmdlist = cmd_list_parse(argc, argv, NULL, 0, &cause);
252 		if (cmdlist == NULL) {
253 			fprintf(stderr, "%s\n", cause);
254 			return (1);
255 		}
256 		cmdflags &= ~CMD_STARTSERVER;
257 		TAILQ_FOREACH(cmd, &cmdlist->list, qentry) {
258 			if (cmd->entry->flags & CMD_STARTSERVER)
259 				cmdflags |= CMD_STARTSERVER;
260 		}
261 		cmd_list_free(cmdlist);
262 	}
263 
264 	/* Create client process structure (starts logging). */
265 	client_proc = proc_start("client", base, 0, client_signal);
266 
267 	/* Initialize the client socket and start the server. */
268 	fd = client_connect(base, socket_path, cmdflags & CMD_STARTSERVER);
269 	if (fd == -1) {
270 		if (errno == ECONNREFUSED) {
271 			fprintf(stderr, "no server running on %s\n",
272 			    socket_path);
273 		} else {
274 			fprintf(stderr, "error connecting to %s (%s)\n",
275 			    socket_path, strerror(errno));
276 		}
277 		return (1);
278 	}
279 	client_peer = proc_add_peer(client_proc, fd, client_dispatch,
280 	    __UNCONST(shellcmd));
281 
282 	/* Save these before pledge(). */
283 	if ((cwd = getcwd(path, sizeof path)) == NULL) {
284 		if ((cwd = find_home()) == NULL)
285 			cwd = "/";
286 	}
287 	if ((ttynam = ttyname(STDIN_FILENO)) == NULL)
288 		ttynam = "";
289 
290 #ifdef __OpenBSD__
291 	/*
292 	 * Drop privileges for client. "proc exec" is needed for -c and for
293 	 * locking (which uses system(3)).
294 	 *
295 	 * "tty" is needed to restore termios(4) and also for some reason -CC
296 	 * does not work properly without it (input is not recognised).
297 	 *
298 	 * "sendfd" is dropped later in client_dispatch_wait().
299 	 */
300 	if (pledge("stdio unix sendfd proc exec tty", NULL) != 0)
301 		fatal("pledge failed");
302 #endif
303 
304 	/* Free stuff that is not used in the client. */
305 	options_free(global_options);
306 	options_free(global_s_options);
307 	options_free(global_w_options);
308 	environ_free(global_environ);
309 
310 	/* Create stdin handler. */
311 	setblocking(STDIN_FILENO, 0);
312 	event_set(&client_stdin, STDIN_FILENO, EV_READ|EV_PERSIST,
313 	    client_stdin_callback, NULL);
314 	if (client_flags & CLIENT_CONTROLCONTROL) {
315 		if (tcgetattr(STDIN_FILENO, &saved_tio) != 0)
316 			fatal("tcgetattr failed");
317 		cfmakeraw(&tio);
318 		tio.c_iflag = ICRNL|IXANY;
319 		tio.c_oflag = OPOST|ONLCR;
320 #ifdef NOKERNINFO
321 		tio.c_lflag = NOKERNINFO;
322 #endif
323 		tio.c_cflag = CREAD|CS8|HUPCL;
324 		tio.c_cc[VMIN] = 1;
325 		tio.c_cc[VTIME] = 0;
326 		cfsetispeed(&tio, cfgetispeed(&saved_tio));
327 		cfsetospeed(&tio, cfgetospeed(&saved_tio));
328 		tcsetattr(STDIN_FILENO, TCSANOW, &tio);
329 	}
330 
331 	/* Send identify messages. */
332 	client_send_identify(ttynam, cwd);
333 
334 	/* Send first command. */
335 	if (msg == MSG_COMMAND) {
336 		/* How big is the command? */
337 		size = 0;
338 		for (i = 0; i < argc; i++)
339 			size += strlen(argv[i]) + 1;
340 		data = xmalloc((sizeof *data) + size);
341 
342 		/* Prepare command for server. */
343 		data->argc = argc;
344 		if (cmd_pack_argv(argc, argv, (char *)(data + 1), size) != 0) {
345 			fprintf(stderr, "command too long\n");
346 			free(data);
347 			return (1);
348 		}
349 		size += sizeof *data;
350 
351 		/* Send the command. */
352 		if (proc_send(client_peer, msg, -1, data, size) != 0) {
353 			fprintf(stderr, "failed to send command\n");
354 			free(data);
355 			return (1);
356 		}
357 		free(data);
358 	} else if (msg == MSG_SHELL)
359 		proc_send(client_peer, msg, -1, NULL, 0);
360 
361 	/* Start main loop. */
362 	proc_loop(client_proc, NULL);
363 
364 	/* Print the exit message, if any, and exit. */
365 	if (client_attached) {
366 		if (client_exitreason != CLIENT_EXIT_NONE)
367 			printf("[%s]\n", client_exit_message());
368 
369 		ppid = getppid();
370 		if (client_exittype == MSG_DETACHKILL && ppid > 1)
371 			kill(ppid, SIGHUP);
372 	} else if (client_flags & CLIENT_CONTROLCONTROL) {
373 		if (client_exitreason != CLIENT_EXIT_NONE)
374 			printf("%%exit %s\n", client_exit_message());
375 		else
376 			printf("%%exit\n");
377 		printf("\033\\");
378 		tcsetattr(STDOUT_FILENO, TCSAFLUSH, &saved_tio);
379 	} else if (client_exitreason != CLIENT_EXIT_NONE)
380 		fprintf(stderr, "%s\n", client_exit_message());
381 	setblocking(STDIN_FILENO, 1);
382 	return (client_exitval);
383 }
384 
385 /* Send identify messages to server. */
386 void
387 client_send_identify(const char *ttynam, const char *cwd)
388 {
389 	const char	 *s;
390 	char		**ss;
391 	size_t		  sslen;
392 	int		  fd, flags = client_flags;
393 	pid_t		  pid;
394 
395 	proc_send(client_peer, MSG_IDENTIFY_FLAGS, -1, &flags, sizeof flags);
396 
397 	if ((s = getenv("TERM")) == NULL)
398 		s = "";
399 	proc_send(client_peer, MSG_IDENTIFY_TERM, -1, s, strlen(s) + 1);
400 
401 	proc_send(client_peer, MSG_IDENTIFY_TTYNAME, -1, ttynam,
402 	    strlen(ttynam) + 1);
403 	proc_send(client_peer, MSG_IDENTIFY_CWD, -1, cwd, strlen(cwd) + 1);
404 
405 	if ((fd = dup(STDIN_FILENO)) == -1)
406 		fatal("dup failed");
407 	proc_send(client_peer, MSG_IDENTIFY_STDIN, fd, NULL, 0);
408 
409 	pid = getpid();
410 	proc_send(client_peer, MSG_IDENTIFY_CLIENTPID, -1, &pid, sizeof pid);
411 
412 	for (ss = environ; *ss != NULL; ss++) {
413 		sslen = strlen(*ss) + 1;
414 		if (sslen > MAX_IMSGSIZE - IMSG_HEADER_SIZE)
415 			continue;
416 		proc_send(client_peer, MSG_IDENTIFY_ENVIRON, -1, *ss, sslen);
417 	}
418 
419 	proc_send(client_peer, MSG_IDENTIFY_DONE, -1, NULL, 0);
420 }
421 
422 /* Callback for client stdin read events. */
423 void
424 client_stdin_callback(__unused int fd, __unused short events,
425     __unused void *arg)
426 {
427 	struct msg_stdin_data	data;
428 
429 	data.size = read(STDIN_FILENO, data.data, sizeof data.data);
430 	if (data.size < 0 && (errno == EINTR || errno == EAGAIN))
431 		return;
432 
433 	proc_send(client_peer, MSG_STDIN, -1, &data, sizeof data);
434 	if (data.size <= 0)
435 		event_del(&client_stdin);
436 }
437 
438 /* Force write to file descriptor. */
439 void
440 client_write(int fd, const char *data, size_t size)
441 {
442 	ssize_t	used;
443 
444 	while (size != 0) {
445 		used = write(fd, data, size);
446 		if (used == -1) {
447 			if (errno == EINTR || errno == EAGAIN)
448 				continue;
449 			break;
450 		}
451 		data += used;
452 		size -= used;
453 	}
454 }
455 
456 /* Run command in shell; used for -c. */
457 __dead void
458 client_exec(const char *shell, const char *shellcmd)
459 {
460 	const char	*name, *ptr;
461 	char		*argv0;
462 
463 	log_debug("shell %s, command %s", shell, shellcmd);
464 
465 	ptr = strrchr(shell, '/');
466 	if (ptr != NULL && *(ptr + 1) != '\0')
467 		name = ptr + 1;
468 	else
469 		name = shell;
470 	if (client_flags & CLIENT_LOGIN)
471 		xasprintf(&argv0, "-%s", name);
472 	else
473 		xasprintf(&argv0, "%s", name);
474 	setenv("SHELL", shell, 1);
475 
476 	setblocking(STDIN_FILENO, 1);
477 	setblocking(STDOUT_FILENO, 1);
478 	setblocking(STDERR_FILENO, 1);
479 	closefrom(STDERR_FILENO + 1);
480 
481 	execl(shell, argv0, "-c", shellcmd, (char *) NULL);
482 	fatal("execl failed");
483 }
484 
485 /* Callback to handle signals in the client. */
486 void
487 client_signal(int sig)
488 {
489 	struct sigaction sigact;
490 	int		 status;
491 
492 	if (sig == SIGCHLD)
493 		waitpid(WAIT_ANY, &status, WNOHANG);
494 	else if (!client_attached) {
495 		if (sig == SIGTERM)
496 			proc_exit(client_proc);
497 	} else {
498 		switch (sig) {
499 		case SIGHUP:
500 			client_exitreason = CLIENT_EXIT_LOST_TTY;
501 			client_exitval = 1;
502 			proc_send(client_peer, MSG_EXITING, -1, NULL, 0);
503 			break;
504 		case SIGTERM:
505 			client_exitreason = CLIENT_EXIT_TERMINATED;
506 			client_exitval = 1;
507 			proc_send(client_peer, MSG_EXITING, -1, NULL, 0);
508 			break;
509 		case SIGWINCH:
510 			proc_send(client_peer, MSG_RESIZE, -1, NULL, 0);
511 			break;
512 		case SIGCONT:
513 			memset(&sigact, 0, sizeof sigact);
514 			sigemptyset(&sigact.sa_mask);
515 			sigact.sa_flags = SA_RESTART;
516 			sigact.sa_handler = SIG_IGN;
517 			if (sigaction(SIGTSTP, &sigact, NULL) != 0)
518 				fatal("sigaction failed");
519 			proc_send(client_peer, MSG_WAKEUP, -1, NULL, 0);
520 			break;
521 		}
522 	}
523 }
524 
525 /* Callback for client read events. */
526 void
527 client_dispatch(struct imsg *imsg, void *arg)
528 {
529 	if (imsg == NULL) {
530 		client_exitreason = CLIENT_EXIT_LOST_SERVER;
531 		client_exitval = 1;
532 		proc_exit(client_proc);
533 		return;
534 	}
535 
536 	if (client_attached)
537 		client_dispatch_attached(imsg);
538 	else
539 		client_dispatch_wait(imsg, arg);
540 }
541 
542 /* Dispatch imsgs when in wait state (before MSG_READY). */
543 void
544 client_dispatch_wait(struct imsg *imsg, const char *shellcmd)
545 {
546 	char			*data;
547 	ssize_t			 datalen;
548 	struct msg_stdout_data	 stdoutdata;
549 	struct msg_stderr_data	 stderrdata;
550 	int			 retval;
551 #ifdef __OpenBSD__
552 	static int		 pledge_applied;
553 
554 	/*
555 	 * "sendfd" is no longer required once all of the identify messages
556 	 * have been sent. We know the server won't send us anything until that
557 	 * point (because we don't ask it to), so we can drop "sendfd" once we
558 	 * get the first message from the server.
559 	 */
560 	if (!pledge_applied) {
561 		if (pledge("stdio unix proc exec tty", NULL) != 0)
562 			fatal("pledge failed");
563 		pledge_applied = 1;
564 	};
565 #endif
566 
567 	data = imsg->data;
568 	datalen = imsg->hdr.len - IMSG_HEADER_SIZE;
569 
570 	switch (imsg->hdr.type) {
571 	case MSG_EXIT:
572 	case MSG_SHUTDOWN:
573 		if (datalen != sizeof retval && datalen != 0)
574 			fatalx("bad MSG_EXIT size");
575 		if (datalen == sizeof retval) {
576 			memcpy(&retval, data, sizeof retval);
577 			client_exitval = retval;
578 		}
579 		proc_exit(client_proc);
580 		break;
581 	case MSG_READY:
582 		if (datalen != 0)
583 			fatalx("bad MSG_READY size");
584 
585 		event_del(&client_stdin);
586 		client_attached = 1;
587 		proc_send(client_peer, MSG_RESIZE, -1, NULL, 0);
588 		break;
589 	case MSG_STDIN:
590 		if (datalen != 0)
591 			fatalx("bad MSG_STDIN size");
592 
593 		event_add(&client_stdin, NULL);
594 		break;
595 	case MSG_STDOUT:
596 		if (datalen != sizeof stdoutdata)
597 			fatalx("bad MSG_STDOUT size");
598 		memcpy(&stdoutdata, data, sizeof stdoutdata);
599 
600 		client_write(STDOUT_FILENO, stdoutdata.data,
601 		    stdoutdata.size);
602 		break;
603 	case MSG_STDERR:
604 		if (datalen != sizeof stderrdata)
605 			fatalx("bad MSG_STDERR size");
606 		memcpy(&stderrdata, data, sizeof stderrdata);
607 
608 		client_write(STDERR_FILENO, stderrdata.data,
609 		    stderrdata.size);
610 		break;
611 	case MSG_VERSION:
612 		if (datalen != 0)
613 			fatalx("bad MSG_VERSION size");
614 
615 		fprintf(stderr, "protocol version mismatch "
616 		    "(client %d, server %u)\n", PROTOCOL_VERSION,
617 		    imsg->hdr.peerid & 0xff);
618 		client_exitval = 1;
619 		proc_exit(client_proc);
620 		break;
621 	case MSG_SHELL:
622 		if (datalen == 0 || data[datalen - 1] != '\0')
623 			fatalx("bad MSG_SHELL string");
624 
625 		clear_signals(0);
626 		client_exec(data, shellcmd);
627 		/* NOTREACHED */
628 	case MSG_DETACH:
629 	case MSG_DETACHKILL:
630 		proc_send(client_peer, MSG_EXITING, -1, NULL, 0);
631 		break;
632 	case MSG_EXITED:
633 		proc_exit(client_proc);
634 		break;
635 	}
636 }
637 
638 /* Dispatch imsgs in attached state (after MSG_READY). */
639 void
640 client_dispatch_attached(struct imsg *imsg)
641 {
642 	struct sigaction	 sigact;
643 	char			*data;
644 	ssize_t			 datalen;
645 
646 	data = imsg->data;
647 	datalen = imsg->hdr.len - IMSG_HEADER_SIZE;
648 
649 	switch (imsg->hdr.type) {
650 	case MSG_DETACH:
651 	case MSG_DETACHKILL:
652 		if (datalen == 0 || data[datalen - 1] != '\0')
653 			fatalx("bad MSG_DETACH string");
654 
655 		client_exitsession = xstrdup(data);
656 		client_exittype = imsg->hdr.type;
657 		if (imsg->hdr.type == MSG_DETACHKILL)
658 			client_exitreason = CLIENT_EXIT_DETACHED_HUP;
659 		else
660 			client_exitreason = CLIENT_EXIT_DETACHED;
661 		proc_send(client_peer, MSG_EXITING, -1, NULL, 0);
662 		break;
663 	case MSG_EXIT:
664 		if (datalen != 0 && datalen != sizeof (int))
665 			fatalx("bad MSG_EXIT size");
666 
667 		proc_send(client_peer, MSG_EXITING, -1, NULL, 0);
668 		client_exitreason = CLIENT_EXIT_EXITED;
669 		break;
670 	case MSG_EXITED:
671 		if (datalen != 0)
672 			fatalx("bad MSG_EXITED size");
673 
674 		proc_exit(client_proc);
675 		break;
676 	case MSG_SHUTDOWN:
677 		if (datalen != 0)
678 			fatalx("bad MSG_SHUTDOWN size");
679 
680 		proc_send(client_peer, MSG_EXITING, -1, NULL, 0);
681 		client_exitreason = CLIENT_EXIT_SERVER_EXITED;
682 		client_exitval = 1;
683 		break;
684 	case MSG_SUSPEND:
685 		if (datalen != 0)
686 			fatalx("bad MSG_SUSPEND size");
687 
688 		memset(&sigact, 0, sizeof sigact);
689 		sigemptyset(&sigact.sa_mask);
690 		sigact.sa_flags = SA_RESTART;
691 		sigact.sa_handler = SIG_DFL;
692 		if (sigaction(SIGTSTP, &sigact, NULL) != 0)
693 			fatal("sigaction failed");
694 		kill(getpid(), SIGTSTP);
695 		break;
696 	case MSG_LOCK:
697 		if (datalen == 0 || data[datalen - 1] != '\0')
698 			fatalx("bad MSG_LOCK string");
699 
700 		system(data);
701 		proc_send(client_peer, MSG_UNLOCK, -1, NULL, 0);
702 		break;
703 	}
704 }
705