diff --git a/server-client.c b/server-client.c index cc88d95b..67af5700 100644 --- a/server-client.c +++ b/server-client.c @@ -1,4 +1,4 @@ -/* $Id: server-client.c,v 1.14 2009-11-08 22:58:37 tcunha Exp $ */ +/* $Id: server-client.c,v 1.15 2009-11-08 23:09:36 tcunha Exp $ */ /* * Copyright (c) 2009 Nicholas Marriott @@ -60,6 +60,7 @@ server_client_create(int fd) c = xcalloc(1, sizeof *c); c->references = 0; imsg_init(&c->ibuf, fd); + server_update_event(c); if (gettimeofday(&c->creation_time, NULL) != 0) fatal("gettimeofday failed"); @@ -149,30 +150,6 @@ server_client_lost(struct client *c) recalculate_sizes(); } -/* Register clients for poll. */ -void -server_client_prepare(void) -{ - struct client *c; - u_int i; - int events; - - for (i = 0; i < ARRAY_LENGTH(&clients); i++) { - if ((c = ARRAY_ITEM(&clients, i)) == NULL) - continue; - - events = 0; - if (!(c->flags & CLIENT_BAD)) - events |= EV_READ; - if (c->ibuf.w.queued > 0) - events |= EV_WRITE; - event_del(&c->event); - event_set(&c->event, - c->ibuf.fd, events, server_client_callback, c); - event_add(&c->event, NULL); - } -} - /* Process a single client event. */ void server_client_callback(int fd, short events, void *data) @@ -195,7 +172,8 @@ server_client_callback(int fd, short events, void *data) if (events & EV_READ && server_client_msg_dispatch(c) != 0) goto client_lost; } - + + server_update_event(c); return; client_lost: diff --git a/server-fn.c b/server-fn.c index e7077335..6dc810a2 100644 --- a/server-fn.c +++ b/server-fn.c @@ -1,4 +1,4 @@ -/* $Id: server-fn.c,v 1.94 2009-10-12 00:37:41 tcunha Exp $ */ +/* $Id: server-fn.c,v 1.95 2009-11-08 23:09:36 tcunha Exp $ */ /* * Copyright (c) 2007 Nicholas Marriott @@ -59,6 +59,7 @@ server_write_client( return; log_debug("writing %d to client %d", type, c->ibuf.fd); imsg_compose(ibuf, type, PROTOCOL_VERSION, -1, -1, (void *) buf, len); + server_update_event(c); } void @@ -371,3 +372,18 @@ server_clear_identify(struct client *c) server_redraw_client(c); } } + +void +server_update_event(struct client *c) +{ + short events; + + events = 0; + if (!(c->flags & CLIENT_BAD)) + events |= EV_READ; + if (c->ibuf.w.queued > 0) + events |= EV_WRITE; + event_del(&c->event); + event_set(&c->event, c->ibuf.fd, events, server_client_callback, c); + event_add(&c->event, NULL); +} diff --git a/server.c b/server.c index 300019ca..d40366f5 100644 --- a/server.c +++ b/server.c @@ -1,4 +1,4 @@ -/* $Id: server.c,v 1.221 2009-11-08 23:06:25 tcunha Exp $ */ +/* $Id: server.c,v 1.222 2009-11-08 23:09:36 tcunha Exp $ */ /* * Copyright (c) 2007 Nicholas Marriott @@ -164,11 +164,11 @@ server_start(char *path) setproctitle("server (%s)", rpathbuf); #endif + event_init(); + server_fd = server_create_socket(); server_client_create(pair[1]); - event_init(); - if (access(SYSTEM_CFG, R_OK) == 0) { if (load_cfg(SYSTEM_CFG, NULL, &cause) != 0) goto error; @@ -219,8 +219,6 @@ server_loop(void) while (!server_should_shutdown()) { server_update_socket(); - server_client_prepare(); - event_loopexit(&tv); event_loop(EVLOOP_ONCE); diff --git a/tmux.h b/tmux.h index 420076ff..c445b30d 100644 --- a/tmux.h +++ b/tmux.h @@ -1,4 +1,4 @@ -/* $Id: tmux.h,v 1.502 2009-11-08 23:05:36 tcunha Exp $ */ +/* $Id: tmux.h,v 1.503 2009-11-08 23:09:36 tcunha Exp $ */ /* * Copyright (c) 2007 Nicholas Marriott @@ -1563,7 +1563,6 @@ void server_signal_clear(void); /* server-client.c */ void server_client_create(int); void server_client_lost(struct client *); -void server_client_prepare(void); void server_client_callback(int, short, void *); void server_client_loop(void); @@ -1597,6 +1596,7 @@ void server_destroy_session_group(struct session *); void server_destroy_session(struct session *); void server_set_identify(struct client *); void server_clear_identify(struct client *); +void server_update_event(struct client *); /* status.c */ int status_redraw(struct client *);