/* $OpenBSD: control.c,v 1.31 2020/05/21 07:24:13 nicm Exp $ */ /* * Copyright (c) 2012 Nicholas Marriott * Copyright (c) 2012 George Nachman * * 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 #include #include #include #include #include "tmux.h" /* Write a line. */ void control_write(struct client *c, const char *fmt, ...) { va_list ap; va_start(ap, fmt); file_vprint(c, fmt, ap); file_print(c, "\n"); va_end(ap); } /* Write output from a pane. */ void control_write_output(struct client *c, struct window_pane *wp) { struct client_offset *co; struct evbuffer *message; u_char *new_data; size_t new_size, i; if (c->flags & CLIENT_CONTROL_NOOUTPUT) return; /* * Only write input if the window pane is linked to a window belonging * to the client's session. */ if (winlink_find_by_window(&c->session->windows, wp->window) == NULL) return; co = server_client_add_pane_offset(c, wp); if (co->flags & CLIENT_OFFSET_OFF) { window_pane_update_used_data(wp, &co->offset, SIZE_MAX, 1); return; } new_data = window_pane_get_new_data(wp, &co->offset, &new_size); if (new_size == 0) return; message = evbuffer_new(); if (message == NULL) fatalx("out of memory"); evbuffer_add_printf(message, "%%output %%%u ", wp->id); for (i = 0; i < new_size; i++) { if (new_data[i] < ' ' || new_data[i] == '\\') evbuffer_add_printf(message, "\\%03o", new_data[i]); else evbuffer_add_printf(message, "%c", new_data[i]); } evbuffer_add(message, "", 1); control_write(c, "%s", EVBUFFER_DATA(message)); evbuffer_free(message); window_pane_update_used_data(wp, &co->offset, new_size, 1); } /* Control error callback. */ static enum cmd_retval control_error(struct cmdq_item *item, void *data) { struct client *c = cmdq_get_client(item); char *error = data; cmdq_guard(item, "begin", 1); control_write(c, "parse error: %s", error); cmdq_guard(item, "error", 1); free(error); return (CMD_RETURN_NORMAL); } /* Control input callback. Read lines and fire commands. */ static void control_callback(__unused struct client *c, __unused const char *path, int read_error, int closed, struct evbuffer *buffer, __unused void *data) { char *line, *error; struct cmdq_state *state; enum cmd_parse_status status; if (closed || read_error != 0) c->flags |= CLIENT_EXIT; for (;;) { line = evbuffer_readln(buffer, NULL, EVBUFFER_EOL_LF); if (line == NULL) break; log_debug("%s: %s", __func__, line); if (*line == '\0') { /* empty line exit */ free(line); c->flags |= CLIENT_EXIT; break; } state = cmdq_new_state(NULL, NULL, CMDQ_STATE_CONTROL); status = cmd_parse_and_append(line, NULL, c, state, &error); if (status == CMD_PARSE_ERROR) cmdq_append(c, cmdq_get_callback(control_error, error)); cmdq_free_state(state); free(line); } } void control_start(struct client *c) { file_read(c, "-", control_callback, c); if (c->flags & CLIENT_CONTROLCONTROL) file_print(c, "\033P1000p"); }