1 1544f909 2004-12-25 devnull #include "threadimpl.h"
3 1544f909 2004-12-25 devnull static Lock thewaitlock;
4 1544f909 2004-12-25 devnull static Channel *thewaitchan;
6 1544f909 2004-12-25 devnull static void
7 8cbd854a 2004-12-27 devnull execproc(void *v)
10 1544f909 2004-12-25 devnull Channel *c;
11 8cbd854a 2004-12-27 devnull Execjob *e;
12 1544f909 2004-12-25 devnull Waitmsg *w;
15 8cbd854a 2004-12-27 devnull pid = _threadspawn(e->fd, e->cmd, e->argv);
16 8cbd854a 2004-12-27 devnull sendul(e->c, pid);
17 8cbd854a 2004-12-27 devnull if(pid > 0){
18 8cbd854a 2004-12-27 devnull w = waitfor(pid);
19 1544f909 2004-12-25 devnull if((c = thewaitchan) != nil)
20 1544f909 2004-12-25 devnull sendp(c, w);
24 8cbd854a 2004-12-27 devnull threadexits(nil);
28 8cbd854a 2004-12-27 devnull _runthreadspawn(int *fd, char *cmd, char **argv)
31 8cbd854a 2004-12-27 devnull Execjob e;
33 8cbd854a 2004-12-27 devnull e.fd = fd;
34 8cbd854a 2004-12-27 devnull e.cmd = cmd;
35 8cbd854a 2004-12-27 devnull e.argv = argv;
36 8cbd854a 2004-12-27 devnull e.c = chancreate(sizeof(void*), 0);
37 8cbd854a 2004-12-27 devnull proccreate(execproc, &e, 65536);
38 8cbd854a 2004-12-27 devnull pid = recvul(e.c);
39 8cbd854a 2004-12-27 devnull chanfree(e.c);
40 8cbd854a 2004-12-27 devnull return pid;
44 1544f909 2004-12-25 devnull threadwaitchan(void)
46 1544f909 2004-12-25 devnull if(thewaitchan)
47 1544f909 2004-12-25 devnull return thewaitchan;
48 1544f909 2004-12-25 devnull lock(&thewaitlock);
49 1544f909 2004-12-25 devnull if(thewaitchan){
50 1544f909 2004-12-25 devnull unlock(&thewaitlock);
51 1544f909 2004-12-25 devnull return thewaitchan;
53 1544f909 2004-12-25 devnull thewaitchan = chancreate(sizeof(Waitmsg*), 4);
54 1544f909 2004-12-25 devnull chansetname(thewaitchan, "threadwaitchan");
55 1544f909 2004-12-25 devnull unlock(&thewaitlock);
56 1544f909 2004-12-25 devnull return thewaitchan;
60 e127e40b 2004-12-27 devnull _threadspawn(int fd[3], char *cmd, char *argv[])
62 1544f909 2004-12-25 devnull int i, n, p[2], pid;
63 1544f909 2004-12-25 devnull char exitstr[100];
65 1544f909 2004-12-25 devnull if(pipe(p) < 0)
66 1544f909 2004-12-25 devnull return -1;
67 1544f909 2004-12-25 devnull if(fcntl(p[0], F_SETFD, 1) < 0 || fcntl(p[1], F_SETFD, 1) < 0){
68 1544f909 2004-12-25 devnull close(p[0]);
69 1544f909 2004-12-25 devnull close(p[1]);
70 1544f909 2004-12-25 devnull return -1;
72 1544f909 2004-12-25 devnull switch(pid = fork()){
74 1544f909 2004-12-25 devnull close(p[0]);
75 1544f909 2004-12-25 devnull close(p[1]);
76 1544f909 2004-12-25 devnull return -1;
78 515bd9ec 2005-01-10 devnull rfork(RFNOTEG);
79 1544f909 2004-12-25 devnull dup2(fd[0], 0);
80 1544f909 2004-12-25 devnull dup2(fd[1], 1);
81 1544f909 2004-12-25 devnull dup2(fd[2], 2);
82 1544f909 2004-12-25 devnull for(i=3; i<100; i++)
83 1544f909 2004-12-25 devnull if(i != p[1])
84 1544f909 2004-12-25 devnull close(i);
85 1544f909 2004-12-25 devnull execvp(cmd, argv);
86 1544f909 2004-12-25 devnull fprint(p[1], "%d", errno);
87 1544f909 2004-12-25 devnull close(p[1]);
88 1544f909 2004-12-25 devnull _exit(0);
91 1544f909 2004-12-25 devnull close(p[1]);
92 1544f909 2004-12-25 devnull n = read(p[0], exitstr, sizeof exitstr-1);
93 1544f909 2004-12-25 devnull close(p[0]);
94 1544f909 2004-12-25 devnull if(n > 0){ /* exec failed */
95 1544f909 2004-12-25 devnull exitstr[n] = 0;
96 1544f909 2004-12-25 devnull errno = atoi(exitstr);
97 1544f909 2004-12-25 devnull return -1;
100 1544f909 2004-12-25 devnull close(fd[0]);
101 1544f909 2004-12-25 devnull if(fd[1] != fd[0])
102 1544f909 2004-12-25 devnull close(fd[1]);
103 1544f909 2004-12-25 devnull if(fd[2] != fd[1] && fd[2] != fd[0])
104 1544f909 2004-12-25 devnull close(fd[2]);
105 1544f909 2004-12-25 devnull return pid;
109 e127e40b 2004-12-27 devnull threadspawn(int fd[3], char *cmd, char *argv[])
111 e127e40b 2004-12-27 devnull return _runthreadspawn(fd, cmd, argv);
115 3d867865 2005-01-18 devnull threadspawnl(int fd[3], char *cmd, ...)
117 3d867865 2005-01-18 devnull char **argv, *s;
118 3d867865 2005-01-18 devnull int n, pid;
119 3d867865 2005-01-18 devnull va_list arg;
121 3d867865 2005-01-18 devnull va_start(arg, cmd);
122 3d867865 2005-01-18 devnull for(n=0; va_arg(arg, char*) != nil; n++)
125 3d867865 2005-01-18 devnull va_end(arg);
127 3d867865 2005-01-18 devnull argv = malloc(n*sizeof(argv[0]));
128 3d867865 2005-01-18 devnull if(argv == nil)
129 3d867865 2005-01-18 devnull return -1;
131 3d867865 2005-01-18 devnull va_start(arg, cmd);
132 3d867865 2005-01-18 devnull for(n=0; (s=va_arg(arg, char*)) != nil; n++)
133 3d867865 2005-01-18 devnull argv[n] = s;
134 3d867865 2005-01-18 devnull argv[n] = 0;
135 3d867865 2005-01-18 devnull va_end(arg);
137 3d867865 2005-01-18 devnull pid = threadspawn(fd, cmd, argv);
138 3d867865 2005-01-18 devnull free(argv);
139 3d867865 2005-01-18 devnull return pid;
143 1544f909 2004-12-25 devnull _threadexec(Channel *cpid, int fd[3], char *cmd, char *argv[])
145 1544f909 2004-12-25 devnull int pid;
147 1544f909 2004-12-25 devnull pid = threadspawn(fd, cmd, argv);
148 1544f909 2004-12-25 devnull if(cpid){
149 1544f909 2004-12-25 devnull if(pid < 0)
150 1544f909 2004-12-25 devnull chansendul(cpid, ~0);
152 1544f909 2004-12-25 devnull chansendul(cpid, pid);
154 1544f909 2004-12-25 devnull return pid;
158 1544f909 2004-12-25 devnull threadexec(Channel *cpid, int fd[3], char *cmd, char *argv[])
160 1544f909 2004-12-25 devnull if(_threadexec(cpid, fd, cmd, argv) >= 0)
161 1544f909 2004-12-25 devnull threadexits("threadexec");
165 1544f909 2004-12-25 devnull threadexecl(Channel *cpid, int fd[3], char *cmd, ...)
167 1544f909 2004-12-25 devnull char **argv, *s;
168 1544f909 2004-12-25 devnull int n, pid;
169 1544f909 2004-12-25 devnull va_list arg;
171 1544f909 2004-12-25 devnull va_start(arg, cmd);
172 1544f909 2004-12-25 devnull for(n=0; va_arg(arg, char*) != nil; n++)
175 1544f909 2004-12-25 devnull va_end(arg);
177 1544f909 2004-12-25 devnull argv = malloc(n*sizeof(argv[0]));
178 1544f909 2004-12-25 devnull if(argv == nil){
179 1544f909 2004-12-25 devnull if(cpid)
180 1544f909 2004-12-25 devnull chansendul(cpid, ~0);
184 1544f909 2004-12-25 devnull va_start(arg, cmd);
185 1544f909 2004-12-25 devnull for(n=0; (s=va_arg(arg, char*)) != nil; n++)
186 1544f909 2004-12-25 devnull argv[n] = s;
187 1544f909 2004-12-25 devnull argv[n] = 0;
188 1544f909 2004-12-25 devnull va_end(arg);
190 1544f909 2004-12-25 devnull pid = _threadexec(cpid, fd, cmd, argv);
191 1544f909 2004-12-25 devnull free(argv);
193 1544f909 2004-12-25 devnull if(pid >= 0)
194 1544f909 2004-12-25 devnull threadexits("threadexecl");