| /* $OpenBSD$ */ |
| |
| /* |
| * Copyright (c) 2009 Tiago Cunha <me@tiagocunha.org> |
| * Copyright (c) 2009 Nicholas Marriott <nicm@openbsd.org> |
| * |
| * Permission to use, copy, modify, and distribute this software for any |
| * purpose with or without fee is hereby granted, provided that the above |
| * copyright notice and this permission notice appear in all copies. |
| * |
| * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES |
| * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF |
| * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR |
| * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES |
| * WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER |
| * IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING |
| * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. |
| */ |
| |
| #include <sys/types.h> |
| #include <sys/wait.h> |
| |
| #include <stdlib.h> |
| #include <string.h> |
| |
| #include "tmux.h" |
| |
| /* |
| * Runs a command without a window. |
| */ |
| |
| enum cmd_retval cmd_run_shell_exec(struct cmd *, struct cmd_q *); |
| |
| void cmd_run_shell_callback(struct job *); |
| void cmd_run_shell_free(void *); |
| void cmd_run_shell_print(struct job *, const char *); |
| |
| const struct cmd_entry cmd_run_shell_entry = { |
| "run-shell", "run", |
| "bt:", 1, 1, |
| "[-b] " CMD_TARGET_PANE_USAGE " shell-command", |
| 0, |
| cmd_run_shell_exec |
| }; |
| |
| struct cmd_run_shell_data { |
| char *cmd; |
| struct cmd_q *cmdq; |
| int bflag; |
| int wp_id; |
| }; |
| |
| void |
| cmd_run_shell_print(struct job *job, const char *msg) |
| { |
| struct cmd_run_shell_data *cdata = job->data; |
| struct window_pane *wp = NULL; |
| |
| if (cdata->wp_id != -1) |
| wp = window_pane_find_by_id(cdata->wp_id); |
| if (wp == NULL) { |
| cmdq_print(cdata->cmdq, "%s", msg); |
| return; |
| } |
| |
| if (window_pane_set_mode(wp, &window_copy_mode) == 0) |
| window_copy_init_for_output(wp); |
| if (wp->mode == &window_copy_mode) |
| window_copy_add(wp, "%s", msg); |
| } |
| |
| enum cmd_retval |
| cmd_run_shell_exec(struct cmd *self, struct cmd_q *cmdq) |
| { |
| struct args *args = self->args; |
| struct cmd_run_shell_data *cdata; |
| char *shellcmd; |
| struct client *c; |
| struct session *s = NULL; |
| struct winlink *wl = NULL; |
| struct window_pane *wp = NULL; |
| struct format_tree *ft; |
| |
| if (args_has(args, 't')) |
| wl = cmd_find_pane(cmdq, args_get(args, 't'), &s, &wp); |
| else { |
| c = cmd_find_client(cmdq, NULL, 1); |
| if (c != NULL && c->session != NULL) { |
| s = c->session; |
| wl = s->curw; |
| wp = wl->window->active; |
| } |
| } |
| |
| ft = format_create(); |
| format_defaults(ft, NULL, s, wl, wp); |
| shellcmd = format_expand(ft, args->argv[0]); |
| format_free(ft); |
| |
| cdata = xmalloc(sizeof *cdata); |
| cdata->cmd = shellcmd; |
| cdata->bflag = args_has(args, 'b'); |
| cdata->wp_id = wp != NULL ? (int) wp->id : -1; |
| |
| cdata->cmdq = cmdq; |
| cmdq->references++; |
| |
| job_run(shellcmd, s, cmd_run_shell_callback, cmd_run_shell_free, cdata); |
| |
| if (cdata->bflag) |
| return (CMD_RETURN_NORMAL); |
| return (CMD_RETURN_WAIT); |
| } |
| |
| void |
| cmd_run_shell_callback(struct job *job) |
| { |
| struct cmd_run_shell_data *cdata = job->data; |
| struct cmd_q *cmdq = cdata->cmdq; |
| char *cmd, *msg, *line; |
| size_t size; |
| int retcode; |
| u_int lines; |
| |
| if (cmdq->dead) |
| return; |
| cmd = cdata->cmd; |
| |
| lines = 0; |
| do { |
| if ((line = evbuffer_readline(job->event->input)) != NULL) { |
| cmd_run_shell_print(job, line); |
| free(line); |
| lines++; |
| } |
| } while (line != NULL); |
| |
| size = EVBUFFER_LENGTH(job->event->input); |
| if (size != 0) { |
| line = xmalloc(size + 1); |
| memcpy(line, EVBUFFER_DATA(job->event->input), size); |
| line[size] = '\0'; |
| |
| cmd_run_shell_print(job, line); |
| lines++; |
| |
| free(line); |
| } |
| |
| msg = NULL; |
| if (WIFEXITED(job->status)) { |
| if ((retcode = WEXITSTATUS(job->status)) != 0) |
| xasprintf(&msg, "'%s' returned %d", cmd, retcode); |
| } else if (WIFSIGNALED(job->status)) { |
| retcode = WTERMSIG(job->status); |
| xasprintf(&msg, "'%s' terminated by signal %d", cmd, retcode); |
| } |
| if (msg != NULL) |
| cmd_run_shell_print(job, msg); |
| free(msg); |
| } |
| |
| void |
| cmd_run_shell_free(void *data) |
| { |
| struct cmd_run_shell_data *cdata = data; |
| struct cmd_q *cmdq = cdata->cmdq; |
| |
| if (!cmdq_free(cmdq) && !cdata->bflag) |
| cmdq_continue(cmdq); |
| |
| free(cdata->cmd); |
| free(cdata); |
| } |