aboutsummaryrefslogtreecommitdiff
path: root/cmd-queue.c
diff options
context:
space:
mode:
authorNicholas Marriott <nicholas.marriott@gmail.com>2013-03-11 21:31:46 +0000
committerNicholas Marriott <nicholas.marriott@gmail.com>2013-03-11 21:31:46 +0000
commit543420ccd2c3c23437405b391e3f9fe1d05223f7 (patch)
tree7581f8eb90cd26fd51c5e406f31f561e0e4eb603 /cmd-queue.c
parent064022548bcbf4d45705fdbff8441f2b5da5f682 (diff)
parent7c009509676b4580065fdc6f0084a93b9758fac0 (diff)
downloadrtmux-543420ccd2c3c23437405b391e3f9fe1d05223f7.tar.gz
rtmux-543420ccd2c3c23437405b391e3f9fe1d05223f7.tar.bz2
rtmux-543420ccd2c3c23437405b391e3f9fe1d05223f7.zip
Merge branch 'master' of ssh://git.code.sf.net/p/tmux/tmux-code
Diffstat (limited to 'cmd-queue.c')
-rw-r--r--cmd-queue.c39
1 files changed, 25 insertions, 14 deletions
diff --git a/cmd-queue.c b/cmd-queue.c
index 4b00fceb..17992a37 100644
--- a/cmd-queue.c
+++ b/cmd-queue.c
@@ -151,6 +151,22 @@ cmdq_error(struct cmd_q *cmdq, const char *fmt, ...)
free(msg);
}
+/* Print a guard line. */
+void
+cmdq_guard(struct cmd_q *cmdq, const char *guard)
+{
+ struct client *c = cmdq->client;
+
+ if (c == NULL || c->session == NULL)
+ return;
+ if (!(c->flags & CLIENT_CONTROL))
+ return;
+
+ evbuffer_add_printf(c->stdout_data, "%%%s %ld %u\n", guard,
+ (long) cmdq->time, cmdq->number);
+ server_push_stdout(c);
+}
+
/* Add command list to queue and begin processing if needed. */
void
cmdq_run(struct cmd_q *cmdq, struct cmd_list *cmdlist)
@@ -179,16 +195,11 @@ cmdq_append(struct cmd_q *cmdq, struct cmd_list *cmdlist)
int
cmdq_continue(struct cmd_q *cmdq)
{
- struct client *c = cmdq->client;
struct cmd_q_item *next;
enum cmd_retval retval;
- int guards, empty;
+ int empty;
char s[1024];
- guards = 0;
- if (c != NULL && c->session != NULL)
- guards = c->flags & CLIENT_CONTROL;
-
notify_disable();
empty = TAILQ_EMPTY(&cmdq->queue);
@@ -209,15 +220,15 @@ cmdq_continue(struct cmd_q *cmdq)
log_debug("cmdq %p: %s (client %d)", cmdq, s,
cmdq->client != NULL ? cmdq->client->ibuf.fd : -1);
- if (guards)
- cmdq_print(cmdq, "%%begin");
+ cmdq->time = time(NULL);
+ cmdq->number++;
+
+ cmdq_guard(cmdq, "begin");
retval = cmdq->cmd->entry->exec(cmdq->cmd, cmdq);
- if (guards) {
- if (retval == CMD_RETURN_ERROR)
- cmdq_print(cmdq, "%%error");
- else
- cmdq_print(cmdq, "%%end");
- }
+ if (retval == CMD_RETURN_ERROR)
+ cmdq_guard(cmdq, "error");
+ else
+ cmdq_guard(cmdq, "end");
if (retval == CMD_RETURN_ERROR)
break;