xref: /openbsd-src/usr.bin/tmux/cmd-queue.c (revision 1693b10bbdb876791a8ba7277dd26d2fd5e7aff8)
1 /* $OpenBSD: cmd-queue.c,v 1.105 2021/08/20 19:50:16 nicm Exp $ */
2 
3 /*
4  * Copyright (c) 2013 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 
21 #include <ctype.h>
22 #include <stdlib.h>
23 #include <string.h>
24 #include <time.h>
25 
26 #include "tmux.h"
27 
28 /* Command queue flags. */
29 #define CMDQ_FIRED 0x1
30 #define CMDQ_WAITING 0x2
31 
32 /* Command queue item type. */
33 enum cmdq_type {
34 	CMDQ_COMMAND,
35 	CMDQ_CALLBACK,
36 };
37 
38 /* Command queue item. */
39 struct cmdq_item {
40 	char			*name;
41 	struct cmdq_list	*queue;
42 	struct cmdq_item	*next;
43 
44 	struct client		*client;
45 	struct client		*target_client;
46 
47 	enum cmdq_type		 type;
48 	u_int			 group;
49 
50 	u_int			 number;
51 	time_t			 time;
52 
53 	int			 flags;
54 
55 	struct cmdq_state	*state;
56 	struct cmd_find_state	 source;
57 	struct cmd_find_state	 target;
58 
59 	struct cmd_list		*cmdlist;
60 	struct cmd		*cmd;
61 
62 	cmdq_cb			 cb;
63 	void			*data;
64 
65 	TAILQ_ENTRY(cmdq_item)	 entry;
66 };
67 TAILQ_HEAD(cmdq_item_list, cmdq_item);
68 
69 /*
70  * Command queue state. This is the context for commands on the command queue.
71  * It holds information about how the commands were fired (the key and flags),
72  * any additional formats for the commands, and the current default target.
73  * Multiple commands can share the same state and a command may update the
74  * default target.
75  */
76 struct cmdq_state {
77 	int			 references;
78 	int			 flags;
79 
80 	struct format_tree	*formats;
81 
82 	struct key_event	 event;
83 	struct cmd_find_state	 current;
84 };
85 
86 /* Command queue. */
87 struct cmdq_list {
88 	struct cmdq_item	*item;
89 	struct cmdq_item_list	 list;
90 };
91 
92 /* Get command queue name. */
93 static const char *
94 cmdq_name(struct client *c)
95 {
96 	static char	s[256];
97 
98 	if (c == NULL)
99 		return ("<global>");
100 	if (c->name != NULL)
101 		xsnprintf(s, sizeof s, "<%s>", c->name);
102 	else
103 		xsnprintf(s, sizeof s, "<%p>", c);
104 	return (s);
105 }
106 
107 /* Get command queue from client. */
108 static struct cmdq_list *
109 cmdq_get(struct client *c)
110 {
111 	static struct cmdq_list *global_queue;
112 
113 	if (c == NULL) {
114 		if (global_queue == NULL)
115 			global_queue = cmdq_new();
116 		return (global_queue);
117 	}
118 	return (c->queue);
119 }
120 
121 /* Create a queue. */
122 struct cmdq_list *
123 cmdq_new(void)
124 {
125 	struct cmdq_list	*queue;
126 
127 	queue = xcalloc (1, sizeof *queue);
128 	TAILQ_INIT (&queue->list);
129 	return (queue);
130 }
131 
132 /* Free a queue. */
133 void
134 cmdq_free(struct cmdq_list *queue)
135 {
136 	if (!TAILQ_EMPTY(&queue->list))
137 		fatalx("queue not empty");
138 	free(queue);
139 }
140 
141 /* Get item name. */
142 const char *
143 cmdq_get_name(struct cmdq_item *item)
144 {
145 	return (item->name);
146 }
147 
148 /* Get item client. */
149 struct client *
150 cmdq_get_client(struct cmdq_item *item)
151 {
152 	return (item->client);
153 }
154 
155 /* Get item target client. */
156 struct client *
157 cmdq_get_target_client(struct cmdq_item *item)
158 {
159 	return (item->target_client);
160 }
161 
162 /* Get item state. */
163 struct cmdq_state *
164 cmdq_get_state(struct cmdq_item *item)
165 {
166 	return (item->state);
167 }
168 
169 /* Get item target. */
170 struct cmd_find_state *
171 cmdq_get_target(struct cmdq_item *item)
172 {
173 	return (&item->target);
174 }
175 
176 /* Get item source. */
177 struct cmd_find_state *
178 cmdq_get_source(struct cmdq_item *item)
179 {
180 	return (&item->source);
181 }
182 
183 /* Get state event. */
184 struct key_event *
185 cmdq_get_event(struct cmdq_item *item)
186 {
187 	return (&item->state->event);
188 }
189 
190 /* Get state current target. */
191 struct cmd_find_state *
192 cmdq_get_current(struct cmdq_item *item)
193 {
194 	return (&item->state->current);
195 }
196 
197 /* Get state flags. */
198 int
199 cmdq_get_flags(struct cmdq_item *item)
200 {
201 	return (item->state->flags);
202 }
203 
204 /* Create a new state. */
205 struct cmdq_state *
206 cmdq_new_state(struct cmd_find_state *current, struct key_event *event,
207     int flags)
208 {
209 	struct cmdq_state	*state;
210 
211 	state = xcalloc(1, sizeof *state);
212 	state->references = 1;
213 	state->flags = flags;
214 
215 	if (event != NULL)
216 		memcpy(&state->event, event, sizeof state->event);
217 	else
218 		state->event.key = KEYC_NONE;
219 	if (current != NULL && cmd_find_valid_state(current))
220 		cmd_find_copy_state(&state->current, current);
221 	else
222 		cmd_find_clear_state(&state->current, 0);
223 
224 	return (state);
225 }
226 
227 /* Add a reference to a state. */
228 struct cmdq_state *
229 cmdq_link_state(struct cmdq_state *state)
230 {
231 	state->references++;
232 	return (state);
233 }
234 
235 /* Make a copy of a state. */
236 struct cmdq_state *
237 cmdq_copy_state(struct cmdq_state *state)
238 {
239 	return (cmdq_new_state(&state->current, &state->event, state->flags));
240 }
241 
242 /* Free a state. */
243 void
244 cmdq_free_state(struct cmdq_state *state)
245 {
246 	if (--state->references != 0)
247 		return;
248 
249 	if (state->formats != NULL)
250 		format_free(state->formats);
251 	free(state);
252 }
253 
254 /* Add a format to command queue. */
255 void
256 cmdq_add_format(struct cmdq_state *state, const char *key, const char *fmt, ...)
257 {
258 	va_list	 ap;
259 	char	*value;
260 
261 	va_start(ap, fmt);
262 	xvasprintf(&value, fmt, ap);
263 	va_end(ap);
264 
265 	if (state->formats == NULL)
266 		state->formats = format_create(NULL, NULL, FORMAT_NONE, 0);
267 	format_add(state->formats, key, "%s", value);
268 
269 	free(value);
270 }
271 
272 /* Add formats to command queue. */
273 void
274 cmdq_add_formats(struct cmdq_state *state, struct format_tree *ft)
275 {
276 	if (state->formats == NULL)
277 		state->formats = format_create(NULL, NULL, FORMAT_NONE, 0);
278 	format_merge(state->formats, ft);
279 }
280 
281 /* Merge formats from item. */
282 void
283 cmdq_merge_formats(struct cmdq_item *item, struct format_tree *ft)
284 {
285 	const struct cmd_entry	*entry;
286 
287 	if (item->cmd != NULL) {
288 		entry = cmd_get_entry(item->cmd);
289 		format_add(ft, "command", "%s", entry->name);
290 	}
291 	if (item->state->formats != NULL)
292 		format_merge(ft, item->state->formats);
293 }
294 
295 /* Append an item. */
296 struct cmdq_item *
297 cmdq_append(struct client *c, struct cmdq_item *item)
298 {
299 	struct cmdq_list	*queue = cmdq_get(c);
300 	struct cmdq_item	*next;
301 
302 	do {
303 		next = item->next;
304 		item->next = NULL;
305 
306 		if (c != NULL)
307 			c->references++;
308 		item->client = c;
309 
310 		item->queue = queue;
311 		TAILQ_INSERT_TAIL(&queue->list, item, entry);
312 		log_debug("%s %s: %s", __func__, cmdq_name(c), item->name);
313 
314 		item = next;
315 	} while (item != NULL);
316 	return (TAILQ_LAST(&queue->list, cmdq_item_list));
317 }
318 
319 /* Insert an item. */
320 struct cmdq_item *
321 cmdq_insert_after(struct cmdq_item *after, struct cmdq_item *item)
322 {
323 	struct client		*c = after->client;
324 	struct cmdq_list	*queue = after->queue;
325 	struct cmdq_item	*next;
326 
327 	do {
328 		next = item->next;
329 		item->next = after->next;
330 		after->next = item;
331 
332 		if (c != NULL)
333 			c->references++;
334 		item->client = c;
335 
336 		item->queue = queue;
337 		TAILQ_INSERT_AFTER(&queue->list, after, item, entry);
338 		log_debug("%s %s: %s after %s", __func__, cmdq_name(c),
339 		    item->name, after->name);
340 
341 		after = item;
342 		item = next;
343 	} while (item != NULL);
344 	return (after);
345 }
346 
347 /* Insert a hook. */
348 void
349 cmdq_insert_hook(struct session *s, struct cmdq_item *item,
350     struct cmd_find_state *current, const char *fmt, ...)
351 {
352 	struct cmdq_state		*state = item->state;
353 	struct cmd			*cmd = item->cmd;
354 	struct args			*args = cmd_get_args(cmd);
355 	struct args_entry		*ae;
356 	struct args_value		*av;
357 	struct options			*oo;
358 	va_list				 ap;
359 	char				*name, tmp[32], flag, *arguments;
360 	u_int				 i;
361 	const char			*value;
362 	struct cmdq_item		*new_item;
363 	struct cmdq_state		*new_state;
364 	struct options_entry		*o;
365 	struct options_array_item	*a;
366 	struct cmd_list			*cmdlist;
367 
368 	if (item->state->flags & CMDQ_STATE_NOHOOKS)
369 		return;
370 	if (s == NULL)
371 		oo = global_s_options;
372 	else
373 		oo = s->options;
374 
375 	va_start(ap, fmt);
376 	xvasprintf(&name, fmt, ap);
377 	va_end(ap);
378 
379 	o = options_get(oo, name);
380 	if (o == NULL) {
381 		free(name);
382 		return;
383 	}
384 	log_debug("running hook %s (parent %p)", name, item);
385 
386 	/*
387 	 * The hooks get a new state because they should not update the current
388 	 * target or formats for any subsequent commands.
389 	 */
390 	new_state = cmdq_new_state(current, &state->event, CMDQ_STATE_NOHOOKS);
391 	cmdq_add_format(new_state, "hook", "%s", name);
392 
393 	arguments = args_print(args);
394 	cmdq_add_format(new_state, "hook_arguments", "%s", arguments);
395 	free(arguments);
396 
397 	for (i = 0; i < args_count(args); i++) {
398 		xsnprintf(tmp, sizeof tmp, "hook_argument_%d", i);
399 		cmdq_add_format(new_state, tmp, "%s", args_string(args, i));
400 	}
401 	flag = args_first(args, &ae);
402 	while (flag != 0) {
403 		value = args_get(args, flag);
404 		if (value == NULL) {
405 			xsnprintf(tmp, sizeof tmp, "hook_flag_%c", flag);
406 			cmdq_add_format(new_state, tmp, "1");
407 		} else {
408 			xsnprintf(tmp, sizeof tmp, "hook_flag_%c", flag);
409 			cmdq_add_format(new_state, tmp, "%s", value);
410 		}
411 
412 		i = 0;
413 		av = args_first_value(args, flag);
414 		while (av != NULL) {
415 			xsnprintf(tmp, sizeof tmp, "hook_flag_%c_%d", flag, i);
416 			cmdq_add_format(new_state, tmp, "%s", av->value);
417 			i++;
418 			av = args_next_value(av);
419 		}
420 
421 		flag = args_next(&ae);
422 	}
423 
424 	a = options_array_first(o);
425 	while (a != NULL) {
426 		cmdlist = options_array_item_value(a)->cmdlist;
427 		if (cmdlist != NULL) {
428 			new_item = cmdq_get_command(cmdlist, new_state);
429 			if (item != NULL)
430 				item = cmdq_insert_after(item, new_item);
431 			else
432 				item = cmdq_append(NULL, new_item);
433 		}
434 		a = options_array_next(a);
435 	}
436 
437 	cmdq_free_state(new_state);
438 	free(name);
439 }
440 
441 /* Continue processing command queue. */
442 void
443 cmdq_continue(struct cmdq_item *item)
444 {
445 	item->flags &= ~CMDQ_WAITING;
446 }
447 
448 /* Remove an item. */
449 static void
450 cmdq_remove(struct cmdq_item *item)
451 {
452 	if (item->client != NULL)
453 		server_client_unref(item->client);
454 	if (item->cmdlist != NULL)
455 		cmd_list_free(item->cmdlist);
456 	cmdq_free_state(item->state);
457 
458 	TAILQ_REMOVE(&item->queue->list, item, entry);
459 
460 	free(item->name);
461 	free(item);
462 }
463 
464 /* Remove all subsequent items that match this item's group. */
465 static void
466 cmdq_remove_group(struct cmdq_item *item)
467 {
468 	struct cmdq_item	*this, *next;
469 
470 	if (item->group == 0)
471 		return;
472 	this = TAILQ_NEXT(item, entry);
473 	while (this != NULL) {
474 		next = TAILQ_NEXT(this, entry);
475 		if (this->group == item->group)
476 			cmdq_remove(this);
477 		this = next;
478 	}
479 }
480 
481 /* Get a command for the command queue. */
482 struct cmdq_item *
483 cmdq_get_command(struct cmd_list *cmdlist, struct cmdq_state *state)
484 {
485 	struct cmdq_item	*item, *first = NULL, *last = NULL;
486 	struct cmd		*cmd;
487 	const struct cmd_entry	*entry;
488 	int			 created = 0;
489 
490 	if (state == NULL) {
491 		state = cmdq_new_state(NULL, NULL, 0);
492 		created = 1;
493 	}
494 
495 	cmd = cmd_list_first(cmdlist);
496 	while (cmd != NULL) {
497 		entry = cmd_get_entry(cmd);
498 
499 		item = xcalloc(1, sizeof *item);
500 		xasprintf(&item->name, "[%s/%p]", entry->name, item);
501 		item->type = CMDQ_COMMAND;
502 
503 		item->group = cmd_get_group(cmd);
504 		item->state = cmdq_link_state(state);
505 
506 		item->cmdlist = cmdlist;
507 		item->cmd = cmd;
508 
509 		cmdlist->references++;
510 		log_debug("%s: %s group %u", __func__, item->name, item->group);
511 
512 		if (first == NULL)
513 			first = item;
514 		if (last != NULL)
515 			last->next = item;
516 		last = item;
517 
518 		cmd = cmd_list_next(cmd);
519 	}
520 
521 	if (created)
522 		cmdq_free_state(state);
523 	return (first);
524 }
525 
526 /* Fill in flag for a command. */
527 static enum cmd_retval
528 cmdq_find_flag(struct cmdq_item *item, struct cmd_find_state *fs,
529     const struct cmd_entry_flag *flag)
530 {
531 	const char	*value;
532 
533 	if (flag->flag == 0) {
534 		cmd_find_from_client(fs, item->target_client, 0);
535 		return (CMD_RETURN_NORMAL);
536 	}
537 
538 	value = args_get(cmd_get_args(item->cmd), flag->flag);
539 	if (cmd_find_target(fs, item, value, flag->type, flag->flags) != 0) {
540 		cmd_find_clear_state(fs, 0);
541 		return (CMD_RETURN_ERROR);
542 	}
543 	return (CMD_RETURN_NORMAL);
544 }
545 
546 /* Add message with command. */
547 static void
548 cmdq_add_message(struct cmdq_item *item)
549 {
550 	struct client		*c = item->client;
551 	struct cmdq_state	*state = item->state;
552 	const char		*name, *key;
553 	char			*tmp;
554 
555 	tmp = cmd_print(item->cmd);
556 	if (c != NULL) {
557 		name = c->name;
558 		if (c->session != NULL && state->event.key != KEYC_NONE) {
559 			key = key_string_lookup_key(state->event.key, 0);
560 			server_add_message("%s key %s: %s", name, key, tmp);
561 		} else
562 			server_add_message("%s command: %s", name, tmp);
563 	} else
564 		server_add_message("command: %s", tmp);
565 	free(tmp);
566 }
567 
568 /* Fire command on command queue. */
569 static enum cmd_retval
570 cmdq_fire_command(struct cmdq_item *item)
571 {
572 	const char		*name = cmdq_name(item->client);
573 	struct cmdq_state	*state = item->state;
574 	struct cmd		*cmd = item->cmd;
575 	struct args		*args = cmd_get_args(cmd);
576 	const struct cmd_entry	*entry = cmd_get_entry(cmd);
577 	struct client		*tc, *saved = item->client;
578 	enum cmd_retval		 retval;
579 	struct cmd_find_state	*fsp, fs;
580 	int			 flags, quiet = 0;
581 	char			*tmp;
582 
583 	if (cfg_finished)
584 		cmdq_add_message(item);
585 	if (log_get_level() > 1) {
586 		tmp = cmd_print(cmd);
587 		log_debug("%s %s: (%u) %s", __func__, name, item->group, tmp);
588 		free(tmp);
589 	}
590 
591 	flags = !!(state->flags & CMDQ_STATE_CONTROL);
592 	cmdq_guard(item, "begin", flags);
593 
594 	if (item->client == NULL)
595 		item->client = cmd_find_client(item, NULL, 1);
596 
597 	if (entry->flags & CMD_CLIENT_CANFAIL)
598 		quiet = 1;
599 	if (entry->flags & CMD_CLIENT_CFLAG) {
600 		tc = cmd_find_client(item, args_get(args, 'c'), quiet);
601 		if (tc == NULL && !quiet) {
602 			retval = CMD_RETURN_ERROR;
603 			goto out;
604 		}
605 	} else if (entry->flags & CMD_CLIENT_TFLAG) {
606 		tc = cmd_find_client(item, args_get(args, 't'), quiet);
607 		if (tc == NULL && !quiet) {
608 			retval = CMD_RETURN_ERROR;
609 			goto out;
610 		}
611 	} else
612 		tc = cmd_find_client(item, NULL, 1);
613 	item->target_client = tc;
614 
615 	retval = cmdq_find_flag(item, &item->source, &entry->source);
616 	if (retval == CMD_RETURN_ERROR)
617 		goto out;
618 	retval = cmdq_find_flag(item, &item->target, &entry->target);
619 	if (retval == CMD_RETURN_ERROR)
620 		goto out;
621 
622 	retval = entry->exec(cmd, item);
623 	if (retval == CMD_RETURN_ERROR)
624 		goto out;
625 
626 	if (entry->flags & CMD_AFTERHOOK) {
627 		if (cmd_find_valid_state(&item->target))
628 			fsp = &item->target;
629 		else if (cmd_find_valid_state(&item->state->current))
630 			fsp = &item->state->current;
631 		else if (cmd_find_from_client(&fs, item->client, 0) == 0)
632 			fsp = &fs;
633 		else
634 			goto out;
635 		cmdq_insert_hook(fsp->s, item, fsp, "after-%s", entry->name);
636 	}
637 
638 out:
639 	item->client = saved;
640 	if (retval == CMD_RETURN_ERROR)
641 		cmdq_guard(item, "error", flags);
642 	else
643 		cmdq_guard(item, "end", flags);
644 	return (retval);
645 }
646 
647 /* Get a callback for the command queue. */
648 struct cmdq_item *
649 cmdq_get_callback1(const char *name, cmdq_cb cb, void *data)
650 {
651 	struct cmdq_item	*item;
652 
653 	item = xcalloc(1, sizeof *item);
654 	xasprintf(&item->name, "[%s/%p]", name, item);
655 	item->type = CMDQ_CALLBACK;
656 
657 	item->group = 0;
658 	item->state = cmdq_new_state(NULL, NULL, 0);
659 
660 	item->cb = cb;
661 	item->data = data;
662 
663 	return (item);
664 }
665 
666 /* Generic error callback. */
667 static enum cmd_retval
668 cmdq_error_callback(struct cmdq_item *item, void *data)
669 {
670 	char	*error = data;
671 
672 	cmdq_error(item, "%s", error);
673 	free(error);
674 
675 	return (CMD_RETURN_NORMAL);
676 }
677 
678 /* Get an error callback for the command queue. */
679 struct cmdq_item *
680 cmdq_get_error(const char *error)
681 {
682 	return (cmdq_get_callback(cmdq_error_callback, xstrdup(error)));
683 }
684 
685 /* Fire callback on callback queue. */
686 static enum cmd_retval
687 cmdq_fire_callback(struct cmdq_item *item)
688 {
689 	return (item->cb(item, item->data));
690 }
691 
692 /* Process next item on command queue. */
693 u_int
694 cmdq_next(struct client *c)
695 {
696 	struct cmdq_list	*queue = cmdq_get(c);
697 	const char		*name = cmdq_name(c);
698 	struct cmdq_item	*item;
699 	enum cmd_retval		 retval;
700 	u_int			 items = 0;
701 	static u_int		 number;
702 
703 	if (TAILQ_EMPTY(&queue->list)) {
704 		log_debug("%s %s: empty", __func__, name);
705 		return (0);
706 	}
707 	if (TAILQ_FIRST(&queue->list)->flags & CMDQ_WAITING) {
708 		log_debug("%s %s: waiting", __func__, name);
709 		return (0);
710 	}
711 
712 	log_debug("%s %s: enter", __func__, name);
713 	for (;;) {
714 		item = queue->item = TAILQ_FIRST(&queue->list);
715 		if (item == NULL)
716 			break;
717 		log_debug("%s %s: %s (%d), flags %x", __func__, name,
718 		    item->name, item->type, item->flags);
719 
720 		/*
721 		 * Any item with the waiting flag set waits until an external
722 		 * event clears the flag (for example, a job - look at
723 		 * run-shell).
724 		 */
725 		if (item->flags & CMDQ_WAITING)
726 			goto waiting;
727 
728 		/*
729 		 * Items are only fired once, once the fired flag is set, a
730 		 * waiting flag can only be cleared by an external event.
731 		 */
732 		if (~item->flags & CMDQ_FIRED) {
733 			item->time = time(NULL);
734 			item->number = ++number;
735 
736 			switch (item->type) {
737 			case CMDQ_COMMAND:
738 				retval = cmdq_fire_command(item);
739 
740 				/*
741 				 * If a command returns an error, remove any
742 				 * subsequent commands in the same group.
743 				 */
744 				if (retval == CMD_RETURN_ERROR)
745 					cmdq_remove_group(item);
746 				break;
747 			case CMDQ_CALLBACK:
748 				retval = cmdq_fire_callback(item);
749 				break;
750 			default:
751 				retval = CMD_RETURN_ERROR;
752 				break;
753 			}
754 			item->flags |= CMDQ_FIRED;
755 
756 			if (retval == CMD_RETURN_WAIT) {
757 				item->flags |= CMDQ_WAITING;
758 				goto waiting;
759 			}
760 			items++;
761 		}
762 		cmdq_remove(item);
763 	}
764 	queue->item = NULL;
765 
766 	log_debug("%s %s: exit (empty)", __func__, name);
767 	return (items);
768 
769 waiting:
770 	log_debug("%s %s: exit (wait)", __func__, name);
771 	return (items);
772 }
773 
774 /* Get running item if any. */
775 struct cmdq_item *
776 cmdq_running(struct client *c)
777 {
778 	struct cmdq_list	*queue = cmdq_get(c);
779 
780 	if (queue->item == NULL)
781         return (NULL);
782     if (queue->item->flags & CMDQ_WAITING)
783         return (NULL);
784     return (queue->item);
785 }
786 
787 /* Print a guard line. */
788 void
789 cmdq_guard(struct cmdq_item *item, const char *guard, int flags)
790 {
791 	struct client	*c = item->client;
792 	long		 t = item->time;
793 	u_int		 number = item->number;
794 
795 	if (c != NULL && (c->flags & CLIENT_CONTROL))
796 		control_write(c, "%%%s %ld %u %d", guard, t, number, flags);
797 }
798 
799 /* Show message from command. */
800 void
801 cmdq_print(struct cmdq_item *item, const char *fmt, ...)
802 {
803 	struct client			*c = item->client;
804 	struct window_pane		*wp;
805 	struct window_mode_entry	*wme;
806 	va_list				 ap;
807 	char				*tmp, *msg;
808 
809 	va_start(ap, fmt);
810 	xvasprintf(&msg, fmt, ap);
811 	va_end(ap);
812 
813 	log_debug("%s: %s", __func__, msg);
814 
815 	if (c == NULL)
816 		/* nothing */;
817 	else if (c->session == NULL || (c->flags & CLIENT_CONTROL)) {
818 		if (~c->flags & CLIENT_UTF8) {
819 			tmp = msg;
820 			msg = utf8_sanitize(tmp);
821 			free(tmp);
822 		}
823 		if (c->flags & CLIENT_CONTROL)
824 			control_write(c, "%s", msg);
825 		else
826 			file_print(c, "%s\n", msg);
827 	} else {
828 		wp = server_client_get_pane(c);
829 		wme = TAILQ_FIRST(&wp->modes);
830 		if (wme == NULL || wme->mode != &window_view_mode) {
831 			window_pane_set_mode(wp, NULL, &window_view_mode, NULL,
832 			    NULL);
833 		}
834 		window_copy_add(wp, "%s", msg);
835 	}
836 
837 	free(msg);
838 }
839 
840 /* Show error from command. */
841 void
842 cmdq_error(struct cmdq_item *item, const char *fmt, ...)
843 {
844 	struct client	*c = item->client;
845 	struct cmd	*cmd = item->cmd;
846 	va_list		 ap;
847 	char		*msg, *tmp;
848 	const char	*file;
849 	u_int		 line;
850 
851 	va_start(ap, fmt);
852 	xvasprintf(&msg, fmt, ap);
853 	va_end(ap);
854 
855 	log_debug("%s: %s", __func__, msg);
856 
857 	if (c == NULL) {
858 		cmd_get_source(cmd, &file, &line);
859 		cfg_add_cause("%s:%u: %s", file, line, msg);
860 	} else if (c->session == NULL || (c->flags & CLIENT_CONTROL)) {
861 		server_add_message("%s message: %s", c->name, msg);
862 		if (~c->flags & CLIENT_UTF8) {
863 			tmp = msg;
864 			msg = utf8_sanitize(tmp);
865 			free(tmp);
866 		}
867 		if (c->flags & CLIENT_CONTROL)
868 			control_write(c, "%s", msg);
869 		else
870 			file_error(c, "%s\n", msg);
871 		c->retval = 1;
872 	} else {
873 		*msg = toupper((u_char) *msg);
874 		status_message_set(c, -1, 1, 0, "%s", msg);
875 	}
876 
877 	free(msg);
878 }
879