summaryrefslogtreecommitdiffstats
path: root/window.c
diff options
context:
space:
mode:
Diffstat (limited to 'window.c')
-rw-r--r--window.c53
1 files changed, 40 insertions, 13 deletions
diff --git a/window.c b/window.c
index 15a2293d..7b8a2a3f 100644
--- a/window.c
+++ b/window.c
@@ -1,4 +1,4 @@
-/* $Id: window.c,v 1.119 2009-11-08 22:59:53 tcunha Exp $ */
+/* $Id: window.c,v 1.120 2009-11-08 23:02:56 tcunha Exp $ */
/*
* Copyright (c) 2007 Nicholas Marriott <nicm@users.sourceforge.net>
@@ -54,6 +54,9 @@
/* Global window list. */
struct windows windows;
+void window_pane_read_callback(struct bufferevent *, void *);
+void window_pane_error_callback(struct bufferevent *, short, void *);
+
RB_GENERATE(winlinks, winlink, entry, winlink_cmp);
int
@@ -410,8 +413,7 @@ window_pane_create(struct window *w, u_int sx, u_int sy, u_int hlimit)
wp->cwd = NULL;
wp->fd = -1;
- wp->in = buffer_create(BUFSIZ);
- wp->out = buffer_create(BUFSIZ);
+ wp->event = NULL;
wp->mode = NULL;
@@ -440,8 +442,10 @@ window_pane_create(struct window *w, u_int sx, u_int sy, u_int hlimit)
void
window_pane_destroy(struct window_pane *wp)
{
- if (wp->fd != -1)
+ if (wp->fd != -1) {
close(wp->fd);
+ bufferevent_free(wp->event);
+ }
input_free(wp);
@@ -455,10 +459,6 @@ window_pane_destroy(struct window_pane *wp)
bufferevent_free(wp->pipe_event);
}
- buffer_destroy(wp->in);
- buffer_destroy(wp->out);
- event_del(&wp->event);
-
if (wp->cwd != NULL)
xfree(wp->cwd);
if (wp->shell != NULL)
@@ -482,8 +482,10 @@ window_pane_spawn(struct window_pane *wp, const char *cmd, const char *shell,
struct termios tio2;
u_int i;
- if (wp->fd != -1)
+ if (wp->fd != -1) {
close(wp->fd);
+ bufferevent_free(wp->event);
+ }
if (cmd != NULL) {
if (wp->cmd != NULL)
xfree(wp->cmd);
@@ -572,11 +574,33 @@ window_pane_spawn(struct window_pane *wp, const char *cmd, const char *shell,
fatal("fcntl failed");
if (fcntl(wp->fd, F_SETFD, FD_CLOEXEC) == -1)
fatal("fcntl failed");
+ wp->event = bufferevent_new(wp->fd,
+ window_pane_read_callback, NULL, window_pane_error_callback, wp);
+ bufferevent_enable(wp->event, EV_READ|EV_WRITE);
return (0);
}
void
+window_pane_read_callback(unused struct bufferevent *bufev, void *data)
+{
+ struct window_pane *wp = data;
+
+ window_pane_parse(wp);
+}
+
+void
+window_pane_error_callback(
+ unused struct bufferevent *bufev, unused short what, void *data)
+{
+ struct window_pane *wp = data;
+
+ close(wp->fd);
+ bufferevent_free(wp->event);
+ wp->fd = -1;
+}
+
+void
window_pane_resize(struct window_pane *wp, u_int sx, u_int sy)
{
struct winsize ws;
@@ -638,18 +662,21 @@ window_pane_reset_mode(struct window_pane *wp)
void
window_pane_parse(struct window_pane *wp)
{
+ char *data;
size_t new_size;
if (wp->mode != NULL)
return;
- new_size = BUFFER_USED(wp->in) - wp->pipe_off;
- if (wp->pipe_fd != -1 && new_size > 0)
- bufferevent_write(wp->pipe_event, BUFFER_OUT(wp->in), new_size);
+ new_size = EVBUFFER_LENGTH(wp->event->input) - wp->pipe_off;
+ if (wp->pipe_fd != -1 && new_size > 0) {
+ data = EVBUFFER_DATA(wp->event->input);
+ bufferevent_write(wp->pipe_event, data, new_size);
+ }
input_parse(wp);
- wp->pipe_off = BUFFER_USED(wp->in);
+ wp->pipe_off = EVBUFFER_LENGTH(wp->event->input);
}
void