diff options
| author | nicm <nicm> | 2015-11-14 09:41:06 +0000 |
|---|---|---|
| committer | nicm <nicm> | 2015-11-14 09:41:06 +0000 |
| commit | c56b81a2ce815f6d289232f20bb6e07cfd0e36ec (patch) | |
| tree | 7a018a8f9d4354684ad5748e4d218fd8d3273fc5 /cmd-queue.c | |
| parent | 908e6bb68f127f2bdf0c15ac25dde9ccc06e9104 (diff) | |
| download | rtmux-c56b81a2ce815f6d289232f20bb6e07cfd0e36ec.tar.gz rtmux-c56b81a2ce815f6d289232f20bb6e07cfd0e36ec.tar.bz2 rtmux-c56b81a2ce815f6d289232f20bb6e07cfd0e36ec.zip | |
Push stdout and stderr to clients more aggressively, and add an event to
continue if the send fails.
Diffstat (limited to 'cmd-queue.c')
| -rw-r--r-- | cmd-queue.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cmd-queue.c b/cmd-queue.c index 5015981c..2d896212 100644 --- a/cmd-queue.c +++ b/cmd-queue.c @@ -85,7 +85,7 @@ cmdq_print(struct cmd_q *cmdq, const char *fmt, ...) } else evbuffer_add_vprintf(c->stdout_data, fmt, ap); evbuffer_add(c->stdout_data, "\n", 1); - server_push_stdout(c); + server_client_push_stdout(c); } else { w = c->session->curw->window; if (w->active->mode != &window_copy_mode) { @@ -125,7 +125,7 @@ cmdq_error(struct cmd_q *cmdq, const char *fmt, ...) } evbuffer_add(c->stderr_data, msg, msglen); evbuffer_add(c->stderr_data, "\n", 1); - server_push_stderr(c); + server_client_push_stderr(c); c->retval = 1; } else { *msg = toupper((u_char) *msg); @@ -146,7 +146,7 @@ cmdq_guard(struct cmd_q *cmdq, const char *guard, int flags) evbuffer_add_printf(c->stdout_data, "%%%s %ld %u %d\n", guard, (long) cmdq->time, cmdq->number, flags); - server_push_stdout(c); + server_client_push_stdout(c); } /* Add command list to queue and begin processing if needed. */ |