1 f08fdedc 2003-11-23 devnull #include "rc.h"
2 f08fdedc 2003-11-23 devnull #include "getflags.h"
3 f08fdedc 2003-11-23 devnull #include "exec.h"
4 f08fdedc 2003-11-23 devnull #include "io.h"
5 f08fdedc 2003-11-23 devnull #include "fns.h"
7 f08fdedc 2003-11-23 devnull int havefork = 1;
10 f08fdedc 2003-11-23 devnull Xasync(void)
12 f08fdedc 2003-11-23 devnull int null = open("/dev/null", 0);
14 f08fdedc 2003-11-23 devnull char npid[10];
15 f08fdedc 2003-11-23 devnull if(null<0){
16 f08fdedc 2003-11-23 devnull Xerror("Can't open /dev/null\n");
19 f08fdedc 2003-11-23 devnull switch(pid = rfork(RFFDG|RFPROC|RFNOTEG)){
21 f08fdedc 2003-11-23 devnull close(null);
22 f08fdedc 2003-11-23 devnull Xerror("try again");
25 f08fdedc 2003-11-23 devnull pushredir(ROPEN, null, 0);
26 f08fdedc 2003-11-23 devnull start(runq->code, runq->pc+1, runq->local);
27 f08fdedc 2003-11-23 devnull runq->ret = 0;
30 f08fdedc 2003-11-23 devnull close(null);
31 f08fdedc 2003-11-23 devnull runq->pc = runq->code[runq->pc].i;
32 f08fdedc 2003-11-23 devnull inttoascii(npid, pid);
33 f08fdedc 2003-11-23 devnull setvar("apid", newword(npid, (word *)0));
39 f08fdedc 2003-11-23 devnull Xpipe(void)
41 f08fdedc 2003-11-23 devnull struct thread *p = runq;
42 f08fdedc 2003-11-23 devnull int pc = p->pc, forkid;
43 f08fdedc 2003-11-23 devnull int lfd = p->code[pc++].i;
44 f08fdedc 2003-11-23 devnull int rfd = p->code[pc++].i;
45 f08fdedc 2003-11-23 devnull int pfd[2];
46 f08fdedc 2003-11-23 devnull if(pipe(pfd)<0){
47 f08fdedc 2003-11-23 devnull Xerror("can't get pipe");
50 f08fdedc 2003-11-23 devnull switch(forkid = fork()){
52 f08fdedc 2003-11-23 devnull Xerror("try again");
55 f08fdedc 2003-11-23 devnull start(p->code, pc+2, runq->local);
56 f08fdedc 2003-11-23 devnull runq->ret = 0;
57 f08fdedc 2003-11-23 devnull close(pfd[PRD]);
58 f08fdedc 2003-11-23 devnull pushredir(ROPEN, pfd[PWR], lfd);
61 f08fdedc 2003-11-23 devnull start(p->code, p->code[pc].i, runq->local);
62 f08fdedc 2003-11-23 devnull close(pfd[PWR]);
63 f08fdedc 2003-11-23 devnull pushredir(ROPEN, pfd[PRD], rfd);
64 f08fdedc 2003-11-23 devnull p->pc = p->code[pc+1].i;
65 f08fdedc 2003-11-23 devnull p->pid = forkid;
71 f08fdedc 2003-11-23 devnull * Who should wait for the exit from the fork?
74 f08fdedc 2003-11-23 devnull Xbackq(void)
76 f08fdedc 2003-11-23 devnull char wd[8193];
78 f08fdedc 2003-11-23 devnull char *s, *ewd=&wd[8192], *stop;
79 f08fdedc 2003-11-23 devnull struct io *f;
80 f08fdedc 2003-11-23 devnull var *ifs = vlook("ifs");
81 f08fdedc 2003-11-23 devnull word *v, *nextv;
82 f08fdedc 2003-11-23 devnull int pfd[2];
84 f08fdedc 2003-11-23 devnull stop = ifs->val?ifs->val->word:"";
85 f08fdedc 2003-11-23 devnull if(pipe(pfd)<0){
86 f08fdedc 2003-11-23 devnull Xerror("can't make pipe");
89 f08fdedc 2003-11-23 devnull switch(pid = fork()){
91 f08fdedc 2003-11-23 devnull Xerror("try again");
92 f08fdedc 2003-11-23 devnull close(pfd[PRD]);
93 f08fdedc 2003-11-23 devnull close(pfd[PWR]);
96 f08fdedc 2003-11-23 devnull close(pfd[PRD]);
97 f08fdedc 2003-11-23 devnull start(runq->code, runq->pc+1, runq->local);
98 f08fdedc 2003-11-23 devnull pushredir(ROPEN, pfd[PWR], 1);
100 f08fdedc 2003-11-23 devnull default:
101 f08fdedc 2003-11-23 devnull close(pfd[PWR]);
102 f08fdedc 2003-11-23 devnull f = openfd(pfd[PRD]);
105 f08fdedc 2003-11-23 devnull while((c = rchr(f))!=EOF){
106 f08fdedc 2003-11-23 devnull if(strchr(stop, c) || s==ewd){
107 f08fdedc 2003-11-23 devnull if(s!=wd){
108 f08fdedc 2003-11-23 devnull *s='\0';
109 f08fdedc 2003-11-23 devnull v = newword(wd, v);
113 f08fdedc 2003-11-23 devnull else *s++=c;
115 f08fdedc 2003-11-23 devnull if(s!=wd){
116 f08fdedc 2003-11-23 devnull *s='\0';
117 f08fdedc 2003-11-23 devnull v = newword(wd, v);
119 f08fdedc 2003-11-23 devnull closeio(f);
120 f08fdedc 2003-11-23 devnull Waitfor(pid, 0);
121 f08fdedc 2003-11-23 devnull /* v points to reversed arglist -- reverse it onto argv */
122 f08fdedc 2003-11-23 devnull while(v){
123 f08fdedc 2003-11-23 devnull nextv = v->next;
124 f08fdedc 2003-11-23 devnull v->next = runq->argv->words;
125 f08fdedc 2003-11-23 devnull runq->argv->words = v;
126 f08fdedc 2003-11-23 devnull v = nextv;
128 f08fdedc 2003-11-23 devnull runq->pc = runq->code[runq->pc].i;
134 f08fdedc 2003-11-23 devnull Xpipefd(void)
136 f08fdedc 2003-11-23 devnull struct thread *p = runq;
137 f08fdedc 2003-11-23 devnull int pc = p->pc;
138 f08fdedc 2003-11-23 devnull char name[40];
139 f08fdedc 2003-11-23 devnull int pfd[2];
140 f08fdedc 2003-11-23 devnull int sidefd, mainfd;
141 f08fdedc 2003-11-23 devnull if(pipe(pfd)<0){
142 f08fdedc 2003-11-23 devnull Xerror("can't get pipe");
145 f08fdedc 2003-11-23 devnull if(p->code[pc].i==READ){
146 f08fdedc 2003-11-23 devnull sidefd = pfd[PWR];
147 f08fdedc 2003-11-23 devnull mainfd = pfd[PRD];
150 f08fdedc 2003-11-23 devnull sidefd = pfd[PRD];
151 f08fdedc 2003-11-23 devnull mainfd = pfd[PWR];
153 f08fdedc 2003-11-23 devnull switch(fork()){
154 f08fdedc 2003-11-23 devnull case -1:
155 f08fdedc 2003-11-23 devnull Xerror("try again");
158 f08fdedc 2003-11-23 devnull start(p->code, pc+2, runq->local);
159 f08fdedc 2003-11-23 devnull close(mainfd);
160 f08fdedc 2003-11-23 devnull pushredir(ROPEN, sidefd, p->code[pc].i==READ?1:0);
161 f08fdedc 2003-11-23 devnull runq->ret = 0;
163 f08fdedc 2003-11-23 devnull default:
164 f08fdedc 2003-11-23 devnull close(sidefd);
165 f08fdedc 2003-11-23 devnull pushredir(ROPEN, mainfd, mainfd); /* isn't this a noop? */
166 f08fdedc 2003-11-23 devnull strcpy(name, Fdprefix);
167 f08fdedc 2003-11-23 devnull inttoascii(name+strlen(name), mainfd);
168 f08fdedc 2003-11-23 devnull pushword(name);
169 f08fdedc 2003-11-23 devnull p->pc = p->code[pc+1].i;
175 f08fdedc 2003-11-23 devnull Xsubshell(void)
177 f08fdedc 2003-11-23 devnull int pid;
178 f08fdedc 2003-11-23 devnull switch(pid = fork()){
179 f08fdedc 2003-11-23 devnull case -1:
180 f08fdedc 2003-11-23 devnull Xerror("try again");
183 f08fdedc 2003-11-23 devnull start(runq->code, runq->pc+1, runq->local);
184 f08fdedc 2003-11-23 devnull runq->ret = 0;
186 f08fdedc 2003-11-23 devnull default:
187 f08fdedc 2003-11-23 devnull Waitfor(pid, 1);
188 f08fdedc 2003-11-23 devnull runq->pc = runq->code[runq->pc].i;
194 f08fdedc 2003-11-23 devnull execforkexec(void)
196 f08fdedc 2003-11-23 devnull int pid;
198 f08fdedc 2003-11-23 devnull char buf[ERRMAX];
200 f08fdedc 2003-11-23 devnull switch(pid = fork()){
201 f08fdedc 2003-11-23 devnull case -1:
202 f08fdedc 2003-11-23 devnull return -1;
204 f08fdedc 2003-11-23 devnull pushword("exec");
205 f08fdedc 2003-11-23 devnull execexec();
206 f08fdedc 2003-11-23 devnull strcpy(buf, "can't exec: ");
207 f08fdedc 2003-11-23 devnull n = strlen(buf);
208 f08fdedc 2003-11-23 devnull errstr(buf+n, ERRMAX-n);
209 f08fdedc 2003-11-23 devnull Exit(buf);
211 f08fdedc 2003-11-23 devnull return pid;