2009-10-10 17:03:01 +02:00
|
|
|
/* $OpenBSD$ */
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Copyright (c) 2009 Nicholas Marriott <nicm@users.sourceforge.net>
|
|
|
|
*
|
|
|
|
* Permission to use, copy, modify, and distribute this software for any
|
|
|
|
* purpose with or without fee is hereby granted, provided that the above
|
|
|
|
* copyright notice and this permission notice appear in all copies.
|
|
|
|
*
|
|
|
|
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
|
|
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
|
|
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
|
|
|
* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
|
|
* WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER
|
|
|
|
* IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
|
|
|
|
* OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
|
|
*/
|
|
|
|
|
|
|
|
#include <sys/types.h>
|
2009-11-04 22:04:43 +01:00
|
|
|
#include <sys/socket.h>
|
2009-10-10 17:03:01 +02:00
|
|
|
|
|
|
|
#include <fcntl.h>
|
|
|
|
#include <paths.h>
|
2014-10-21 01:27:14 +02:00
|
|
|
#include <signal.h>
|
2012-07-10 13:53:01 +02:00
|
|
|
#include <stdlib.h>
|
2009-10-10 17:03:01 +02:00
|
|
|
#include <string.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
|
|
|
|
#include "tmux.h"
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Job scheduling. Run queued commands in the background and record their
|
|
|
|
* output.
|
|
|
|
*/
|
|
|
|
|
2009-11-04 22:04:43 +01:00
|
|
|
void job_callback(struct bufferevent *, short, void *);
|
2013-03-25 12:43:01 +01:00
|
|
|
void job_write_callback(struct bufferevent *, void *);
|
2009-11-04 22:04:43 +01:00
|
|
|
|
2011-01-26 02:54:56 +01:00
|
|
|
/* All jobs list. */
|
|
|
|
struct joblist all_jobs = LIST_HEAD_INITIALIZER(all_jobs);
|
2009-10-10 17:03:01 +02:00
|
|
|
|
2011-01-26 02:54:56 +01:00
|
|
|
/* Start a job running, if it isn't already. */
|
2009-10-10 17:03:01 +02:00
|
|
|
struct job *
|
2015-04-25 00:19:36 +02:00
|
|
|
job_run(const char *cmd, struct session *s, int cwd,
|
2009-10-10 17:03:01 +02:00
|
|
|
void (*callbackfn)(struct job *), void (*freefn)(void *), void *data)
|
|
|
|
{
|
|
|
|
struct job *job;
|
2011-01-26 02:54:56 +01:00
|
|
|
struct environ env;
|
|
|
|
pid_t pid;
|
|
|
|
int nullfd, out[2];
|
2009-10-10 17:03:01 +02:00
|
|
|
|
2009-11-04 22:04:43 +01:00
|
|
|
if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, out) != 0)
|
2011-01-26 02:54:56 +01:00
|
|
|
return (NULL);
|
2009-10-10 17:03:01 +02:00
|
|
|
|
2011-01-23 12:03:43 +01:00
|
|
|
environ_init(&env);
|
|
|
|
environ_copy(&global_environ, &env);
|
2013-03-25 12:43:01 +01:00
|
|
|
if (s != NULL)
|
|
|
|
environ_copy(&s->environ, &env);
|
|
|
|
server_fill_environ(s, &env);
|
2011-01-23 12:03:43 +01:00
|
|
|
|
2011-01-26 02:54:56 +01:00
|
|
|
switch (pid = fork()) {
|
2009-10-10 17:03:01 +02:00
|
|
|
case -1:
|
2011-01-23 12:03:43 +01:00
|
|
|
environ_free(&env);
|
2014-04-15 00:27:30 +02:00
|
|
|
close(out[0]);
|
|
|
|
close(out[1]);
|
2011-01-26 02:54:56 +01:00
|
|
|
return (NULL);
|
2009-10-10 17:03:01 +02:00
|
|
|
case 0: /* child */
|
2010-08-19 20:29:01 +02:00
|
|
|
clear_signals(1);
|
2010-04-04 21:02:09 +02:00
|
|
|
|
2015-04-25 00:19:36 +02:00
|
|
|
if (cwd != -1 && fchdir(cwd) != 0)
|
|
|
|
chdir("/");
|
|
|
|
|
2011-01-23 12:03:43 +01:00
|
|
|
environ_push(&env);
|
|
|
|
environ_free(&env);
|
2009-10-10 17:03:01 +02:00
|
|
|
|
2013-03-25 12:43:01 +01:00
|
|
|
if (dup2(out[1], STDIN_FILENO) == -1)
|
|
|
|
fatal("dup2 failed");
|
2009-10-21 09:24:23 +02:00
|
|
|
if (dup2(out[1], STDOUT_FILENO) == -1)
|
2009-10-21 00:15:32 +02:00
|
|
|
fatal("dup2 failed");
|
2013-03-25 12:43:01 +01:00
|
|
|
if (out[1] != STDIN_FILENO && out[1] != STDOUT_FILENO)
|
2009-10-21 09:24:23 +02:00
|
|
|
close(out[1]);
|
|
|
|
close(out[0]);
|
2009-10-21 00:15:32 +02:00
|
|
|
|
2009-10-21 09:24:23 +02:00
|
|
|
nullfd = open(_PATH_DEVNULL, O_RDWR, 0);
|
2009-10-10 17:03:01 +02:00
|
|
|
if (nullfd < 0)
|
|
|
|
fatal("open failed");
|
|
|
|
if (dup2(nullfd, STDERR_FILENO) == -1)
|
|
|
|
fatal("dup2 failed");
|
2013-03-25 12:43:01 +01:00
|
|
|
if (nullfd != STDERR_FILENO)
|
2009-10-10 17:03:01 +02:00
|
|
|
close(nullfd);
|
|
|
|
|
2010-10-16 10:31:55 +02:00
|
|
|
closefrom(STDERR_FILENO + 1);
|
|
|
|
|
2011-01-26 02:54:56 +01:00
|
|
|
execl(_PATH_BSHELL, "sh", "-c", cmd, (char *) NULL);
|
2009-10-10 17:03:01 +02:00
|
|
|
fatal("execl failed");
|
2011-01-26 02:54:56 +01:00
|
|
|
}
|
2009-10-10 17:03:01 +02:00
|
|
|
|
2011-01-26 02:54:56 +01:00
|
|
|
/* parent */
|
|
|
|
environ_free(&env);
|
|
|
|
close(out[1]);
|
2009-10-10 17:03:01 +02:00
|
|
|
|
2011-01-26 02:54:56 +01:00
|
|
|
job = xmalloc(sizeof *job);
|
|
|
|
job->cmd = xstrdup(cmd);
|
|
|
|
job->pid = pid;
|
|
|
|
job->status = 0;
|
2009-10-10 17:03:01 +02:00
|
|
|
|
2011-01-26 02:54:56 +01:00
|
|
|
LIST_INSERT_HEAD(&all_jobs, job, lentry);
|
|
|
|
|
|
|
|
job->callbackfn = callbackfn;
|
|
|
|
job->freefn = freefn;
|
|
|
|
job->data = data;
|
|
|
|
|
|
|
|
job->fd = out[0];
|
|
|
|
setblocking(job->fd, 0);
|
|
|
|
|
2013-03-25 12:43:01 +01:00
|
|
|
job->event = bufferevent_new(job->fd, NULL, job_write_callback,
|
|
|
|
job_callback, job);
|
2013-04-10 14:20:35 +02:00
|
|
|
bufferevent_enable(job->event, EV_READ|EV_WRITE);
|
2011-01-26 02:54:56 +01:00
|
|
|
|
|
|
|
log_debug("run job %p: %s, pid %ld", job, job->cmd, (long) job->pid);
|
|
|
|
return (job);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Kill and free an individual job. */
|
|
|
|
void
|
|
|
|
job_free(struct job *job)
|
|
|
|
{
|
|
|
|
log_debug("free job %p: %s", job, job->cmd);
|
|
|
|
|
|
|
|
LIST_REMOVE(job, lentry);
|
2012-07-10 13:53:01 +02:00
|
|
|
free(job->cmd);
|
2011-01-26 02:54:56 +01:00
|
|
|
|
|
|
|
if (job->freefn != NULL && job->data != NULL)
|
|
|
|
job->freefn(job->data);
|
|
|
|
|
|
|
|
if (job->pid != -1)
|
|
|
|
kill(job->pid, SIGTERM);
|
|
|
|
if (job->event != NULL)
|
|
|
|
bufferevent_free(job->event);
|
2012-01-29 03:22:11 +01:00
|
|
|
if (job->fd != -1)
|
|
|
|
close(job->fd);
|
2011-01-26 02:54:56 +01:00
|
|
|
|
2012-07-10 13:53:01 +02:00
|
|
|
free(job);
|
2009-10-10 17:03:01 +02:00
|
|
|
}
|
|
|
|
|
2013-03-25 12:43:01 +01:00
|
|
|
/* Called when output buffer falls below low watermark (default is 0). */
|
|
|
|
void
|
|
|
|
job_write_callback(unused struct bufferevent *bufev, void *data)
|
|
|
|
{
|
|
|
|
struct job *job = data;
|
|
|
|
size_t len = EVBUFFER_LENGTH(EVBUFFER_OUTPUT(job->event));
|
|
|
|
|
2013-04-17 10:41:41 +02:00
|
|
|
log_debug("job write %p: %s, pid %ld, output left %zu", job, job->cmd,
|
2013-10-10 14:35:30 +02:00
|
|
|
(long) job->pid, len);
|
2013-03-25 12:43:01 +01:00
|
|
|
|
|
|
|
if (len == 0) {
|
|
|
|
shutdown(job->fd, SHUT_WR);
|
|
|
|
bufferevent_disable(job->event, EV_WRITE);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2009-11-04 22:04:43 +01:00
|
|
|
/* Job buffer error callback. */
|
|
|
|
void
|
|
|
|
job_callback(unused struct bufferevent *bufev, unused short events, void *data)
|
|
|
|
{
|
|
|
|
struct job *job = data;
|
|
|
|
|
2011-01-26 02:54:56 +01:00
|
|
|
log_debug("job error %p: %s, pid %ld", job, job->cmd, (long) job->pid);
|
2009-11-04 22:04:43 +01:00
|
|
|
|
2009-11-04 22:10:49 +01:00
|
|
|
if (job->pid == -1) {
|
|
|
|
if (job->callbackfn != NULL)
|
|
|
|
job->callbackfn(job);
|
2011-01-26 02:54:56 +01:00
|
|
|
job_free(job);
|
|
|
|
} else {
|
|
|
|
bufferevent_disable(job->event, EV_READ);
|
|
|
|
close(job->fd);
|
|
|
|
job->fd = -1;
|
2009-11-04 22:10:49 +01:00
|
|
|
}
|
2009-11-04 22:04:43 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
/* Job died (waitpid() returned its pid). */
|
|
|
|
void
|
|
|
|
job_died(struct job *job, int status)
|
|
|
|
{
|
2011-01-26 02:54:56 +01:00
|
|
|
log_debug("job died %p: %s, pid %ld", job, job->cmd, (long) job->pid);
|
|
|
|
|
2009-11-04 22:04:43 +01:00
|
|
|
job->status = status;
|
2009-12-03 23:50:09 +01:00
|
|
|
|
2009-11-04 22:10:49 +01:00
|
|
|
if (job->fd == -1) {
|
|
|
|
if (job->callbackfn != NULL)
|
|
|
|
job->callbackfn(job);
|
2011-01-26 02:54:56 +01:00
|
|
|
job_free(job);
|
|
|
|
} else
|
|
|
|
job->pid = -1;
|
2009-10-10 17:03:01 +02:00
|
|
|
}
|