4 * Copyright (c) 2009 Nicholas Marriott <nicm@users.sourceforge.net>
6 * Permission to use, copy, modify, and distribute this software for any
7 * purpose with or without fee is hereby granted, provided that the above
8 * copyright notice and this permission notice appear in all copies.
10 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
11 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
12 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
13 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
14 * WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER
15 * IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
16 * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
19 #include <sys/types.h>
20 #include <sys/socket.h>
31 * Open pipe to redirect pane output. If already open, close first.
34 int cmd_pipe_pane_exec(struct cmd
*, struct cmd_ctx
*);
36 void cmd_pipe_pane_error_callback(struct bufferevent
*, short, void *);
38 const struct cmd_entry cmd_pipe_pane_entry
= {
40 CMD_TARGET_PANE_USAGE
"[-o] [command]",
50 cmd_pipe_pane_exec(struct cmd
*self
, struct cmd_ctx
*ctx
)
52 struct cmd_target_data
*data
= self
->data
;
53 struct window_pane
*wp
;
54 int old_fd
, pipe_fd
[2], null_fd
, mode
;
56 if (cmd_find_pane(ctx
, data
->target
, NULL
, &wp
) == NULL
)
59 /* Destroy the old pipe. */
61 if (wp
->pipe_fd
!= -1) {
62 bufferevent_free(wp
->pipe_event
);
67 /* If no pipe command, that is enough. */
68 if (data
->arg
== NULL
|| *data
->arg
== '\0')
72 * With -o, only open the new pipe if there was no previous one. This
73 * allows a pipe to be toggled with a single key, for example:
75 * bind ^p pipep -o 'cat >>~/output'
77 if (cmd_check_flag(data
->chflags
, 'o') && old_fd
!= -1)
80 /* Open the new pipe. */
81 if (socketpair(AF_UNIX
, SOCK_STREAM
, PF_UNSPEC
, pipe_fd
) != 0) {
82 ctx
->error(ctx
, "socketpair error: %s", strerror(errno
));
89 ctx
->error(ctx
, "fork error: %s", strerror(errno
));
96 if (dup2(pipe_fd
[1], STDIN_FILENO
) == -1)
98 if (pipe_fd
[1] != STDIN_FILENO
)
101 null_fd
= open(_PATH_DEVNULL
, O_WRONLY
, 0);
102 if (dup2(null_fd
, STDOUT_FILENO
) == -1)
104 if (dup2(null_fd
, STDERR_FILENO
) == -1)
106 if (null_fd
!= STDOUT_FILENO
&& null_fd
!= STDERR_FILENO
)
109 execl(_PATH_BSHELL
, "sh", "-c", data
->arg
, (char *) NULL
);
112 /* Parent process. */
115 wp
->pipe_fd
= pipe_fd
[0];
116 wp
->pipe_off
= EVBUFFER_LENGTH(wp
->event
->input
);
118 wp
->pipe_event
= bufferevent_new(wp
->pipe_fd
,
119 NULL
, NULL
, cmd_pipe_pane_error_callback
, wp
);
120 bufferevent_enable(wp
->pipe_event
, EV_WRITE
);
122 if ((mode
= fcntl(wp
->pipe_fd
, F_GETFL
)) == -1)
123 fatal("fcntl failed");
124 if (fcntl(wp
->pipe_fd
, F_SETFL
, mode
|O_NONBLOCK
) == -1)
125 fatal("fcntl failed");
126 if (fcntl(wp
->pipe_fd
, F_SETFD
, FD_CLOEXEC
) == -1)
127 fatal("fcntl failed");
134 cmd_pipe_pane_error_callback(
135 unused
struct bufferevent
*bufev
, unused
short what
, void *data
)
137 struct window_pane
*wp
= data
;
139 bufferevent_free(wp
->pipe_event
);