tmux.c revision 1.35
1/* $OpenBSD: tmux.c,v 1.35 2009/08/23 18:21:02 nicm Exp $ */ 2 3/* 4 * Copyright (c) 2007 Nicholas Marriott <nicm@users.sourceforge.net> 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/stat.h> 21 22#include <errno.h> 23#include <paths.h> 24#include <pwd.h> 25#include <signal.h> 26#include <stdlib.h> 27#include <string.h> 28#include <syslog.h> 29#include <unistd.h> 30 31#include "tmux.h" 32 33#ifdef DEBUG 34const char *malloc_options = "AFGJPX"; 35#endif 36 37volatile sig_atomic_t sigwinch; 38volatile sig_atomic_t sigterm; 39volatile sig_atomic_t sigcont; 40volatile sig_atomic_t sigchld; 41volatile sig_atomic_t sigusr1; 42volatile sig_atomic_t sigusr2; 43 44char *cfg_file; 45struct options global_s_options; /* session options */ 46struct options global_w_options; /* window options */ 47struct environ global_environ; 48 49int server_locked; 50u_int password_failures; 51char *server_password; 52time_t server_activity; 53 54int debug_level; 55int be_quiet; 56time_t start_time; 57char *socket_path; 58 59__dead void usage(void); 60char *makesockpath(const char *); 61int prepare_unlock(enum msgtype *, void **, size_t *, int); 62int prepare_cmd(enum msgtype *, void **, size_t *, int, char **); 63int dispatch_imsg(struct client_ctx *, int *); 64 65__dead void 66usage(void) 67{ 68 fprintf(stderr, 69 "usage: %s [-28dqUuv] [-f file] [-L socket-name] [-S socket-path]\n" 70 " [command [flags]]\n", 71 __progname); 72 exit(1); 73} 74 75void 76logfile(const char *name) 77{ 78 char *path; 79 80 log_close(); 81 if (debug_level > 0) { 82 xasprintf(&path, "tmux-%s-%ld.log", name, (long) getpid()); 83 log_open_file(debug_level, path); 84 xfree(path); 85 } 86} 87 88void 89sighandler(int sig) 90{ 91 int saved_errno; 92 93 saved_errno = errno; 94 switch (sig) { 95 case SIGWINCH: 96 sigwinch = 1; 97 break; 98 case SIGTERM: 99 sigterm = 1; 100 break; 101 case SIGCHLD: 102 sigchld = 1; 103 break; 104 case SIGCONT: 105 sigcont = 1; 106 break; 107 case SIGUSR1: 108 sigusr1 = 1; 109 break; 110 case SIGUSR2: 111 sigusr2 = 1; 112 break; 113 } 114 errno = saved_errno; 115} 116 117void 118siginit(void) 119{ 120 struct sigaction act; 121 122 memset(&act, 0, sizeof act); 123 sigemptyset(&act.sa_mask); 124 act.sa_flags = SA_RESTART; 125 126 act.sa_handler = SIG_IGN; 127 if (sigaction(SIGPIPE, &act, NULL) != 0) 128 fatal("sigaction failed"); 129 if (sigaction(SIGINT, &act, NULL) != 0) 130 fatal("sigaction failed"); 131 if (sigaction(SIGTSTP, &act, NULL) != 0) 132 fatal("sigaction failed"); 133 if (sigaction(SIGQUIT, &act, NULL) != 0) 134 fatal("sigaction failed"); 135 136 act.sa_handler = sighandler; 137 if (sigaction(SIGWINCH, &act, NULL) != 0) 138 fatal("sigaction failed"); 139 if (sigaction(SIGTERM, &act, NULL) != 0) 140 fatal("sigaction failed"); 141 if (sigaction(SIGCHLD, &act, NULL) != 0) 142 fatal("sigaction failed"); 143 if (sigaction(SIGUSR1, &act, NULL) != 0) 144 fatal("sigaction failed"); 145 if (sigaction(SIGUSR2, &act, NULL) != 0) 146 fatal("sigaction failed"); 147} 148 149void 150sigreset(void) 151{ 152 struct sigaction act; 153 154 memset(&act, 0, sizeof act); 155 sigemptyset(&act.sa_mask); 156 157 act.sa_handler = SIG_DFL; 158 if (sigaction(SIGPIPE, &act, NULL) != 0) 159 fatal("sigaction failed"); 160 if (sigaction(SIGUSR1, &act, NULL) != 0) 161 fatal("sigaction failed"); 162 if (sigaction(SIGUSR2, &act, NULL) != 0) 163 fatal("sigaction failed"); 164 if (sigaction(SIGINT, &act, NULL) != 0) 165 fatal("sigaction failed"); 166 if (sigaction(SIGTSTP, &act, NULL) != 0) 167 fatal("sigaction failed"); 168 if (sigaction(SIGQUIT, &act, NULL) != 0) 169 fatal("sigaction failed"); 170 if (sigaction(SIGWINCH, &act, NULL) != 0) 171 fatal("sigaction failed"); 172 if (sigaction(SIGTERM, &act, NULL) != 0) 173 fatal("sigaction failed"); 174 if (sigaction(SIGCHLD, &act, NULL) != 0) 175 fatal("sigaction failed"); 176} 177 178char * 179makesockpath(const char *label) 180{ 181 char base[MAXPATHLEN], *path; 182 struct stat sb; 183 u_int uid; 184 185 uid = getuid(); 186 xsnprintf(base, MAXPATHLEN, "%s/tmux-%d", _PATH_TMP, uid); 187 188 if (mkdir(base, S_IRWXU) != 0 && errno != EEXIST) 189 return (NULL); 190 191 if (lstat(base, &sb) != 0) 192 return (NULL); 193 if (!S_ISDIR(sb.st_mode)) { 194 errno = ENOTDIR; 195 return (NULL); 196 } 197 if (sb.st_uid != uid || (sb.st_mode & (S_IRWXG|S_IRWXO)) != 0) { 198 errno = EACCES; 199 return (NULL); 200 } 201 202 xasprintf(&path, "%s/%s", base, label); 203 return (path); 204} 205 206int 207prepare_unlock(enum msgtype *msg, void **buf, size_t *len, int argc) 208{ 209 static struct msg_unlock_data unlockdata; 210 char *pass; 211 212 if (argc != 0) { 213 log_warnx("can't specify a command when unlocking"); 214 return (-1); 215 } 216 217 if ((pass = getpass("Password: ")) == NULL) 218 return (-1); 219 220 if (strlen(pass) >= sizeof unlockdata.pass) { 221 log_warnx("password too long"); 222 return (-1); 223 } 224 225 strlcpy(unlockdata.pass, pass, sizeof unlockdata.pass); 226 memset(pass, 0, strlen(pass)); 227 228 *buf = &unlockdata; 229 *len = sizeof unlockdata; 230 231 *msg = MSG_UNLOCK; 232 return (0); 233} 234 235int 236prepare_cmd(enum msgtype *msg, void **buf, size_t *len, int argc, char **argv) 237{ 238 static struct msg_command_data cmddata; 239 240 client_fill_session(&cmddata); 241 242 cmddata.argc = argc; 243 if (cmd_pack_argv(argc, argv, cmddata.argv, sizeof cmddata.argv) != 0) { 244 log_warnx("command too long"); 245 return (-1); 246 } 247 248 *buf = &cmddata; 249 *len = sizeof cmddata; 250 251 *msg = MSG_COMMAND; 252 return (0); 253} 254 255int 256main(int argc, char **argv) 257{ 258 struct client_ctx cctx; 259 struct cmd_list *cmdlist; 260 struct cmd *cmd; 261 struct pollfd pfd; 262 enum msgtype msg; 263 struct passwd *pw; 264 char *s, *path, *label, *home, *cause, **var; 265 char cwd[MAXPATHLEN]; 266 void *buf; 267 size_t len; 268 int retcode, opt, flags, unlock, cmdflags = 0; 269 int nfds; 270 271 unlock = flags = 0; 272 label = path = NULL; 273 while ((opt = getopt(argc, argv, "28df:L:qS:uUv")) != -1) { 274 switch (opt) { 275 case '2': 276 flags |= IDENTIFY_256COLOURS; 277 flags &= ~IDENTIFY_88COLOURS; 278 break; 279 case '8': 280 flags |= IDENTIFY_88COLOURS; 281 flags &= ~IDENTIFY_256COLOURS; 282 break; 283 case 'f': 284 if (cfg_file) 285 xfree(cfg_file); 286 cfg_file = xstrdup(optarg); 287 break; 288 case 'L': 289 if (label != NULL) 290 xfree(label); 291 label = xstrdup(optarg); 292 break; 293 case 'S': 294 if (path != NULL) 295 xfree(path); 296 path = xstrdup(optarg); 297 break; 298 case 'q': 299 be_quiet = 1; 300 break; 301 case 'u': 302 flags |= IDENTIFY_UTF8; 303 break; 304 case 'U': 305 unlock = 1; 306 break; 307 case 'd': 308 flags |= IDENTIFY_HASDEFAULTS; 309 break; 310 case 'v': 311 debug_level++; 312 break; 313 default: 314 usage(); 315 } 316 } 317 argc -= optind; 318 argv += optind; 319 320 log_open_tty(debug_level); 321 siginit(); 322 323 environ_init(&global_environ); 324 for (var = environ; *var != NULL; var++) 325 environ_put(&global_environ, *var); 326 327 if (!(flags & IDENTIFY_UTF8)) { 328 /* 329 * If the user has set whichever of LC_ALL, LC_CTYPE or LANG 330 * exist (in that order) to contain UTF-8, it is a safe 331 * assumption that either they are using a UTF-8 terminal, or 332 * if not they know that output from UTF-8-capable programs may 333 * be wrong. 334 */ 335 if ((s = getenv("LC_ALL")) == NULL) { 336 if ((s = getenv("LC_CTYPE")) == NULL) 337 s = getenv("LANG"); 338 } 339 if (s != NULL && (strcasestr(s, "UTF-8") != NULL || 340 strcasestr(s, "UTF8") != NULL)) 341 flags |= IDENTIFY_UTF8; 342 } 343 344 options_init(&global_s_options, NULL); 345 options_set_number(&global_s_options, "base-index", 0); 346 options_set_number(&global_s_options, "bell-action", BELL_ANY); 347 options_set_number(&global_s_options, "buffer-limit", 9); 348 options_set_string(&global_s_options, "default-command", "%s", ""); 349 options_set_string(&global_s_options, "default-terminal", "screen"); 350 options_set_number(&global_s_options, "display-time", 750); 351 options_set_number(&global_s_options, "history-limit", 2000); 352 options_set_number(&global_s_options, "lock-after-time", 0); 353 options_set_number(&global_s_options, "message-attr", 0); 354 options_set_number(&global_s_options, "message-bg", 3); 355 options_set_number(&global_s_options, "message-fg", 0); 356 options_set_number(&global_s_options, "prefix", '\002'); 357 options_set_number(&global_s_options, "repeat-time", 500); 358 options_set_number(&global_s_options, "set-remain-on-exit", 0); 359 options_set_number(&global_s_options, "set-titles", 0); 360 options_set_number(&global_s_options, "status", 1); 361 options_set_number(&global_s_options, "status-attr", 0); 362 options_set_number(&global_s_options, "status-bg", 2); 363 options_set_number(&global_s_options, "status-fg", 0); 364 options_set_number(&global_s_options, "status-interval", 15); 365 options_set_number(&global_s_options, "status-keys", MODEKEY_EMACS); 366 options_set_number(&global_s_options, "status-justify", 0); 367 options_set_string(&global_s_options, "status-left", "[#S]"); 368 options_set_number(&global_s_options, "status-left-attr", 0); 369 options_set_number(&global_s_options, "status-left-fg", 8); 370 options_set_number(&global_s_options, "status-left-bg", 8); 371 options_set_number(&global_s_options, "status-left-length", 10); 372 options_set_string( 373 &global_s_options, "status-right", "\"#22T\" %%H:%%M %%d-%%b-%%y"); 374 options_set_number(&global_s_options, "status-right-attr", 0); 375 options_set_number(&global_s_options, "status-right-fg", 8); 376 options_set_number(&global_s_options, "status-right-bg", 8); 377 options_set_number(&global_s_options, "status-right-length", 40); 378 if (flags & IDENTIFY_UTF8) 379 options_set_number(&global_s_options, "status-utf8", 1); 380 else 381 options_set_number(&global_s_options, "status-utf8", 0); 382 options_set_string(&global_s_options, 383 "terminal-overrides", "*88col*:colors=88,*256col*:colors=256"); 384 options_set_string(&global_s_options, "update-environment", "DISPLAY " 385 "WINDOWID SSH_ASKPASS SSH_AUTH_SOCK SSH_AGENT_PID SSH_CONNECTION"); 386 options_set_number(&global_s_options, "visual-activity", 0); 387 options_set_number(&global_s_options, "visual-bell", 0); 388 options_set_number(&global_s_options, "visual-content", 0); 389 390 options_init(&global_w_options, NULL); 391 options_set_number(&global_w_options, "aggressive-resize", 0); 392 options_set_number(&global_w_options, "automatic-rename", 1); 393 options_set_number(&global_w_options, "clock-mode-colour", 4); 394 options_set_number(&global_w_options, "clock-mode-style", 1); 395 options_set_number(&global_w_options, "force-height", 0); 396 options_set_number(&global_w_options, "force-width", 0); 397 options_set_number(&global_w_options, "main-pane-width", 81); 398 options_set_number(&global_w_options, "main-pane-height", 24); 399 options_set_number(&global_w_options, "mode-attr", 0); 400 options_set_number(&global_w_options, "mode-bg", 3); 401 options_set_number(&global_w_options, "mode-fg", 0); 402 options_set_number(&global_w_options, "mode-keys", MODEKEY_EMACS); 403 options_set_number(&global_w_options, "mode-mouse", 0); 404 options_set_number(&global_w_options, "monitor-activity", 0); 405 options_set_string(&global_w_options, "monitor-content", "%s", ""); 406 if (flags & IDENTIFY_UTF8) 407 options_set_number(&global_w_options, "utf8", 1); 408 else 409 options_set_number(&global_w_options, "utf8", 0); 410 options_set_number(&global_w_options, "window-status-attr", 0); 411 options_set_number(&global_w_options, "window-status-bg", 8); 412 options_set_number(&global_w_options, "window-status-fg", 8); 413 options_set_number(&global_w_options, "window-status-current-attr", 0); 414 options_set_number(&global_w_options, "window-status-current-bg", 8); 415 options_set_number(&global_w_options, "window-status-current-fg", 8); 416 options_set_number(&global_w_options, "xterm-keys", 0); 417 options_set_number(&global_w_options, "remain-on-exit", 0); 418 419 if (cfg_file == NULL) { 420 home = getenv("HOME"); 421 if (home == NULL || *home == '\0') { 422 pw = getpwuid(getuid()); 423 if (pw != NULL) 424 home = pw->pw_dir; 425 } 426 xasprintf(&cfg_file, "%s/%s", home, DEFAULT_CFG); 427 if (access(cfg_file, R_OK) != 0) { 428 xfree(cfg_file); 429 cfg_file = NULL; 430 } 431 } else { 432 if (access(cfg_file, R_OK) != 0) { 433 log_warn("%s", cfg_file); 434 exit(1); 435 } 436 } 437 438 if (label == NULL) 439 label = xstrdup("default"); 440 if (path == NULL && (path = makesockpath(label)) == NULL) { 441 log_warn("can't create socket"); 442 exit(1); 443 } 444 xfree(label); 445 446 if (getcwd(cwd, sizeof cwd) == NULL) { 447 pw = getpwuid(getuid()); 448 if (pw->pw_dir != NULL && *pw->pw_dir != '\0') 449 strlcpy(cwd, pw->pw_dir, sizeof cwd); 450 else 451 strlcpy(cwd, "/", sizeof cwd); 452 } 453 options_set_string(&global_s_options, "default-path", "%s", cwd); 454 455 if (unlock) { 456 if (prepare_unlock(&msg, &buf, &len, argc) != 0) 457 exit(1); 458 } else { 459 if (prepare_cmd(&msg, &buf, &len, argc, argv) != 0) 460 exit(1); 461 } 462 463 if (unlock) 464 cmdflags &= ~CMD_STARTSERVER; 465 else if (argc == 0) 466 cmdflags |= CMD_STARTSERVER|CMD_SENDENVIRON; 467 else { 468 /* 469 * It sucks parsing the command string twice (in client and 470 * later in server) but it is necessary to get the start server 471 * flag. 472 */ 473 if ((cmdlist = cmd_list_parse(argc, argv, &cause)) == NULL) { 474 log_warnx("%s", cause); 475 exit(1); 476 } 477 cmdflags &= ~CMD_STARTSERVER; 478 TAILQ_FOREACH(cmd, cmdlist, qentry) { 479 if (cmd->entry->flags & CMD_STARTSERVER) 480 cmdflags |= CMD_STARTSERVER; 481 if (cmd->entry->flags & CMD_SENDENVIRON) 482 cmdflags |= CMD_SENDENVIRON; 483 } 484 cmd_list_free(cmdlist); 485 } 486 487 memset(&cctx, 0, sizeof cctx); 488 if (client_init(path, &cctx, cmdflags, flags) != 0) 489 exit(1); 490 xfree(path); 491 492 client_write_server(&cctx, msg, buf, len); 493 memset(buf, 0, len); 494 495 retcode = 0; 496 for (;;) { 497 pfd.fd = cctx.ibuf.fd; 498 pfd.events = POLLIN; 499 if (cctx.ibuf.w.queued != 0) 500 pfd.events |= POLLOUT; 501 502 if ((nfds = poll(&pfd, 1, INFTIM)) == -1) { 503 if (errno == EAGAIN || errno == EINTR) 504 continue; 505 fatal("poll failed"); 506 } 507 if (nfds == 0) 508 continue; 509 510 if (pfd.revents & (POLLERR|POLLHUP|POLLNVAL)) 511 fatalx("socket error"); 512 513 if (pfd.revents & POLLIN) { 514 if (dispatch_imsg(&cctx, &retcode) != 0) 515 break; 516 } 517 518 if (pfd.revents & POLLOUT) { 519 if (msgbuf_write(&cctx.ibuf.w) < 0) 520 fatalx("msgbuf_write failed"); 521 } 522 } 523 524 options_free(&global_s_options); 525 options_free(&global_w_options); 526 527 return (retcode); 528} 529 530int 531dispatch_imsg(struct client_ctx *cctx, int *retcode) 532{ 533 struct imsg imsg; 534 ssize_t n, datalen; 535 struct msg_print_data printdata; 536 537 if ((n = imsg_read(&cctx->ibuf)) == -1 || n == 0) 538 fatalx("imsg_read failed"); 539 540 for (;;) { 541 if ((n = imsg_get(&cctx->ibuf, &imsg)) == -1) 542 fatalx("imsg_get failed"); 543 if (n == 0) 544 return (0); 545 datalen = imsg.hdr.len - IMSG_HEADER_SIZE; 546 547 switch (imsg.hdr.type) { 548 case MSG_EXIT: 549 case MSG_SHUTDOWN: 550 if (datalen != 0) 551 fatalx("bad MSG_EXIT size"); 552 553 return (-1); 554 case MSG_ERROR: 555 *retcode = 1; 556 /* FALLTHROUGH */ 557 case MSG_PRINT: 558 if (datalen != sizeof printdata) 559 fatalx("bad MSG_PRINT size"); 560 memcpy(&printdata, imsg.data, sizeof printdata); 561 printdata.msg[(sizeof printdata.msg) - 1] = '\0'; 562 563 log_info("%s", printdata.msg); 564 break; 565 case MSG_READY: 566 if (datalen != 0) 567 fatalx("bad MSG_READY size"); 568 569 *retcode = client_main(cctx); 570 return (-1); 571 case MSG_VERSION: 572 if (datalen != 0) 573 fatalx("bad MSG_VERSION size"); 574 575 log_warnx("protocol version mismatch (client %u, " 576 "server %u)", PROTOCOL_VERSION, imsg.hdr.peerid); 577 *retcode = 1; 578 return (-1); 579 default: 580 fatalx("unexpected message"); 581 } 582 583 imsg_free(&imsg); 584 } 585} 586