Run status update on a per-client timer at status-interval.

This commit is contained in:
nicm 2015-08-28 12:16:28 +00:00
parent 18d4802a7b
commit 75d10058a4
10 changed files with 67 additions and 45 deletions

View File

@ -133,6 +133,7 @@ cmd_attach_session(struct cmd_q *cmdq, const char *tflag, int dflag, int rflag,
} }
c->session = s; c->session = s;
status_timer_start(c);
notify_attached_session_changed(c); notify_attached_session_changed(c);
session_update_activity(s); session_update_activity(s);
server_redraw_client(c); server_redraw_client(c);
@ -177,6 +178,7 @@ cmd_attach_session(struct cmd_q *cmdq, const char *tflag, int dflag, int rflag,
} }
c->session = s; c->session = s;
status_timer_start(c);
notify_attached_session_changed(c); notify_attached_session_changed(c);
session_update_activity(s); session_update_activity(s);
server_redraw_client(c); server_redraw_client(c);

View File

@ -275,6 +275,7 @@ cmd_new_session_exec(struct cmd *self, struct cmd_q *cmdq)
else if (c->session != NULL) else if (c->session != NULL)
c->last_session = c->session; c->last_session = c->session;
c->session = s; c->session = s;
status_timer_start(c);
notify_attached_session_changed(c); notify_attached_session_changed(c);
session_update_activity(s); session_update_activity(s);
server_redraw_client(c); server_redraw_client(c);

View File

@ -176,7 +176,7 @@ cmd_set_option_exec(struct cmd *self, struct cmd_q *cmdq)
return (CMD_RETURN_ERROR); return (CMD_RETURN_ERROR);
} }
/* Start or stop timers when automatic-rename changed. */ /* Start or stop timers when name or status options changed. */
if (strcmp(oe->name, "automatic-rename") == 0) { if (strcmp(oe->name, "automatic-rename") == 0) {
RB_FOREACH(w, windows, &windows) { RB_FOREACH(w, windows, &windows) {
if (options_get_number(&w->options, "automatic-rename")) if (options_get_number(&w->options, "automatic-rename"))
@ -185,6 +185,9 @@ cmd_set_option_exec(struct cmd *self, struct cmd_q *cmdq)
evtimer_del(&w->name_timer); evtimer_del(&w->name_timer);
} }
} }
if (strcmp(oe->name, "status") == 0 ||
strcmp(oe->name, "status-interval") == 0)
status_timer_start_all();
/* Update sizes and redraw. May not need it but meh. */ /* Update sizes and redraw. May not need it but meh. */
recalculate_sizes(); recalculate_sizes();

View File

@ -127,6 +127,7 @@ cmd_switch_client_exec(struct cmd *self, struct cmd_q *cmdq)
if (c->session != NULL) if (c->session != NULL)
c->last_session = c->session; c->last_session = c->session;
c->session = s; c->session = s;
status_timer_start(c);
session_update_activity(s); session_update_activity(s);
recalculate_sizes(); recalculate_sizes();

View File

@ -247,7 +247,7 @@ format_job_timer(unused int fd, unused short events, unused void *arg)
if (fj->job != NULL) if (fj->job != NULL)
job_free(fj->job); job_free(fj->job);
free((void*)fj->cmd); free((void *)fj->cmd);
free(fj->out); free(fj->out);
free(fj); free(fj);

View File

@ -188,6 +188,8 @@ server_client_lost(struct client *c)
if (c->stderr_data != c->stdout_data) if (c->stderr_data != c->stdout_data)
evbuffer_free(c->stderr_data); evbuffer_free(c->stderr_data);
if (event_initialized(&c->status_timer))
evtimer_del(&c->status_timer);
screen_free(&c->status); screen_free(&c->status);
free(c->title); free(c->title);
@ -289,42 +291,6 @@ client_lost:
server_client_lost(c); server_client_lost(c);
} }
/* Handle client status timer. */
void
server_client_status_timer(void)
{
struct client *c;
struct session *s;
struct timeval tv;
int interval;
time_t difference;
if (gettimeofday(&tv, NULL) != 0)
fatal("gettimeofday failed");
TAILQ_FOREACH(c, &clients, entry) {
if (c->session == NULL)
continue;
if (c->message_string != NULL || c->prompt_string != NULL) {
/*
* Don't need timed redraw for messages/prompts so bail
* now. The status timer isn't reset when they are
* redrawn anyway.
*/
continue;
}
s = c->session;
if (!options_get_number(&s->options, "status"))
continue;
interval = options_get_number(&s->options, "status-interval");
difference = tv.tv_sec - c->status_timer.tv_sec;
if (interval != 0 && difference >= interval)
c->flags |= CLIENT_STATUS;
}
}
/* Check for mouse keys. */ /* Check for mouse keys. */
int int
server_client_check_mouse(struct client *c) server_client_check_mouse(struct client *c)

View File

@ -419,6 +419,7 @@ server_destroy_session(struct session *s)
} else { } else {
c->last_session = NULL; c->last_session = NULL;
c->session = s_new; c->session = s_new;
status_timer_start(c);
notify_attached_session_changed(c); notify_attached_session_changed(c);
session_update_activity(s_new); session_update_activity(s_new);
server_redraw_client(c); server_redraw_client(c);

View File

@ -520,8 +520,6 @@ server_second_callback(unused int fd, unused short events, unused void *arg)
} }
} }
server_client_status_timer();
evtimer_del(&server_ev_second); evtimer_del(&server_ev_second);
memset(&tv, 0, sizeof tv); memset(&tv, 0, sizeof tv);
tv.tv_sec = 1; tv.tv_sec = 1;

View File

@ -37,6 +37,7 @@ char *status_print(struct client *, struct winlink *, time_t,
struct grid_cell *); struct grid_cell *);
char *status_replace(struct client *, struct winlink *, const char *, time_t); char *status_replace(struct client *, struct winlink *, const char *, time_t);
void status_message_callback(int, short, void *); void status_message_callback(int, short, void *);
void status_timer_callback(int, short, void *);
const char *status_prompt_up_history(u_int *); const char *status_prompt_up_history(u_int *);
const char *status_prompt_down_history(u_int *); const char *status_prompt_down_history(u_int *);
@ -142,6 +143,55 @@ status_prompt_save_history(void)
} }
/* Status timer callback. */
void
status_timer_callback(unused int fd, unused short events, void *arg)
{
struct client *c = arg;
struct session *s = c->session;
struct timeval tv;
evtimer_del(&c->status_timer);
if (s == NULL)
return;
if (c->message_string == NULL && c->prompt_string == NULL)
c->flags |= CLIENT_STATUS;
timerclear(&tv);
tv.tv_sec = options_get_number(&s->options, "status-interval");
if (tv.tv_sec != 0)
evtimer_add(&c->status_timer, &tv);
log_debug("client %d, status interval %d", c->ibuf.fd, (int)tv.tv_sec);
}
/* Start status timer for client. */
void
status_timer_start(struct client *c)
{
struct session *s = c->session;
if (event_initialized(&c->status_timer))
evtimer_del(&c->status_timer);
else
evtimer_set(&c->status_timer, status_timer_callback, c);
if (s != NULL && options_get_number(&s->options, "status"))
status_timer_callback(-1, 0, c);
}
/* Start status timer for all clients. */
void
status_timer_start_all(void)
{
struct client *c;
TAILQ_FOREACH(c, &clients, entry)
status_timer_start(c);
}
/* Get screen line of status line. -1 means off. */ /* Get screen line of status line. -1 means off. */
int int
status_at_line(struct client *c) status_at_line(struct client *c)
@ -244,10 +294,8 @@ status_redraw(struct client *c)
left = right = NULL; left = right = NULL;
larrow = rarrow = 0; larrow = rarrow = 0;
/* Update status timer. */ /* Store current time. */
if (gettimeofday(&c->status_timer, NULL) != 0) t = time(NULL);
fatal("gettimeofday failed");
t = c->status_timer.tv_sec;
/* Set up default colour. */ /* Set up default colour. */
style_apply(&stdgc, &s->options, "status-style"); style_apply(&stdgc, &s->options, "status-style");

4
tmux.h
View File

@ -1207,7 +1207,7 @@ struct client {
struct event repeat_timer; struct event repeat_timer;
struct timeval status_timer; struct event status_timer;
struct screen status; struct screen status;
#define CLIENT_TERMINAL 0x1 #define CLIENT_TERMINAL 0x1
@ -1893,6 +1893,8 @@ int server_set_stdin_callback(struct client *, void (*)(struct client *,
void server_unzoom_window(struct window *); void server_unzoom_window(struct window *);
/* status.c */ /* status.c */
void status_timer_start(struct client *);
void status_timer_start_all(void);
int status_at_line(struct client *); int status_at_line(struct client *);
struct window *status_get_window_at(struct client *, u_int); struct window *status_get_window_at(struct client *, u_int);
int status_redraw(struct client *); int status_redraw(struct client *);