Annotation of src/usr.bin/tmux/job.c, Revision 1.33
1.33 ! nicm 1: /* $OpenBSD: job.c,v 1.32 2013/10/10 12:35:31 nicm Exp $ */
1.1 nicm 2:
3: /*
4: * Copyright (c) 2009 Nicholas Marriott <nicm@users.sourceforge.net>
5: *
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.
9: *
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.
17: */
18:
19: #include <sys/types.h>
1.11 nicm 20: #include <sys/socket.h>
1.1 nicm 21:
22: #include <fcntl.h>
23: #include <paths.h>
1.27 nicm 24: #include <stdlib.h>
1.1 nicm 25: #include <string.h>
26: #include <unistd.h>
27:
28: #include "tmux.h"
29:
30: /*
31: * Job scheduling. Run queued commands in the background and record their
32: * output.
33: */
34:
1.25 nicm 35: void job_callback(struct bufferevent *, short, void *);
1.29 nicm 36: void job_write_callback(struct bufferevent *, void *);
1.25 nicm 37:
1.2 nicm 38: /* All jobs list. */
1.24 nicm 39: struct joblist all_jobs = LIST_HEAD_INITIALIZER(all_jobs);
1.2 nicm 40:
1.25 nicm 41: /* Start a job running, if it isn't already. */
1.1 nicm 42: struct job *
1.29 nicm 43: job_run(const char *cmd, struct session *s,
1.1 nicm 44: void (*callbackfn)(struct job *), void (*freefn)(void *), void *data)
45: {
46: struct job *job;
1.25 nicm 47: struct environ env;
48: pid_t pid;
49: int nullfd, out[2];
1.1 nicm 50:
1.11 nicm 51: if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, out) != 0)
1.25 nicm 52: return (NULL);
1.1 nicm 53:
1.23 nicm 54: environ_init(&env);
55: environ_copy(&global_environ, &env);
1.29 nicm 56: if (s != NULL)
57: environ_copy(&s->environ, &env);
58: server_fill_environ(s, &env);
1.23 nicm 59:
1.25 nicm 60: switch (pid = fork()) {
1.1 nicm 61: case -1:
1.23 nicm 62: environ_free(&env);
1.33 ! nicm 63: close(out[0]);
! 64: close(out[1]);
1.25 nicm 65: return (NULL);
1.1 nicm 66: case 0: /* child */
1.20 nicm 67: clear_signals(1);
1.16 nicm 68:
1.23 nicm 69: environ_push(&env);
70: environ_free(&env);
1.1 nicm 71:
1.29 nicm 72: if (dup2(out[1], STDIN_FILENO) == -1)
73: fatal("dup2 failed");
1.7 nicm 74: if (dup2(out[1], STDOUT_FILENO) == -1)
1.6 nicm 75: fatal("dup2 failed");
1.29 nicm 76: if (out[1] != STDIN_FILENO && out[1] != STDOUT_FILENO)
1.7 nicm 77: close(out[1]);
78: close(out[0]);
1.6 nicm 79:
1.7 nicm 80: nullfd = open(_PATH_DEVNULL, O_RDWR, 0);
1.1 nicm 81: if (nullfd < 0)
82: fatal("open failed");
83: if (dup2(nullfd, STDERR_FILENO) == -1)
84: fatal("dup2 failed");
1.29 nicm 85: if (nullfd != STDERR_FILENO)
1.1 nicm 86: close(nullfd);
87:
1.21 nicm 88: closefrom(STDERR_FILENO + 1);
89:
1.25 nicm 90: execl(_PATH_BSHELL, "sh", "-c", cmd, (char *) NULL);
1.1 nicm 91: fatal("execl failed");
1.25 nicm 92: }
93:
94: /* parent */
95: environ_free(&env);
96: close(out[1]);
97:
98: job = xmalloc(sizeof *job);
99: job->cmd = xstrdup(cmd);
100: job->pid = pid;
101: job->status = 0;
102:
103: LIST_INSERT_HEAD(&all_jobs, job, lentry);
104:
105: job->callbackfn = callbackfn;
106: job->freefn = freefn;
107: job->data = data;
108:
109: job->fd = out[0];
110: setblocking(job->fd, 0);
111:
1.29 nicm 112: job->event = bufferevent_new(job->fd, NULL, job_write_callback,
113: job_callback, job);
1.30 nicm 114: bufferevent_enable(job->event, EV_READ|EV_WRITE);
1.25 nicm 115:
116: log_debug("run job %p: %s, pid %ld", job, job->cmd, (long) job->pid);
117: return (job);
118: }
119:
120: /* Kill and free an individual job. */
121: void
122: job_free(struct job *job)
123: {
124: log_debug("free job %p: %s", job, job->cmd);
1.1 nicm 125:
1.25 nicm 126: LIST_REMOVE(job, lentry);
1.27 nicm 127: free(job->cmd);
1.1 nicm 128:
1.25 nicm 129: if (job->freefn != NULL && job->data != NULL)
130: job->freefn(job->data);
131:
132: if (job->pid != -1)
133: kill(job->pid, SIGTERM);
1.26 nicm 134: if (job->event != NULL)
135: bufferevent_free(job->event);
1.25 nicm 136: if (job->fd != -1)
137: close(job->fd);
1.1 nicm 138:
1.27 nicm 139: free(job);
1.29 nicm 140: }
141:
142: /* Called when output buffer falls below low watermark (default is 0). */
143: void
144: job_write_callback(unused struct bufferevent *bufev, void *data)
145: {
146: struct job *job = data;
147: size_t len = EVBUFFER_LENGTH(EVBUFFER_OUTPUT(job->event));
148:
1.31 nicm 149: log_debug("job write %p: %s, pid %ld, output left %zu", job, job->cmd,
1.32 nicm 150: (long) job->pid, len);
1.29 nicm 151:
152: if (len == 0) {
153: shutdown(job->fd, SHUT_WR);
154: bufferevent_disable(job->event, EV_WRITE);
155: }
1.11 nicm 156: }
157:
158: /* Job buffer error callback. */
159: void
160: job_callback(unused struct bufferevent *bufev, unused short events, void *data)
161: {
162: struct job *job = data;
163:
1.25 nicm 164: log_debug("job error %p: %s, pid %ld", job, job->cmd, (long) job->pid);
1.11 nicm 165:
1.12 nicm 166: if (job->pid == -1) {
167: if (job->callbackfn != NULL)
168: job->callbackfn(job);
1.25 nicm 169: job_free(job);
170: } else {
171: bufferevent_disable(job->event, EV_READ);
172: close(job->fd);
173: job->fd = -1;
1.12 nicm 174: }
1.11 nicm 175: }
176:
177: /* Job died (waitpid() returned its pid). */
178: void
179: job_died(struct job *job, int status)
180: {
1.25 nicm 181: log_debug("job died %p: %s, pid %ld", job, job->cmd, (long) job->pid);
182:
1.11 nicm 183: job->status = status;
1.14 nicm 184:
1.12 nicm 185: if (job->fd == -1) {
186: if (job->callbackfn != NULL)
187: job->callbackfn(job);
1.25 nicm 188: job_free(job);
189: } else
190: job->pid = -1;
1.1 nicm 191: }
![[BACK]](/icons/back.gif){kind=icon}
Return to job.c CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [local] / src / usr.bin / tmux