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"
  6 f08fdedc 2003-11-23 devnull /*
  7 f08fdedc 2003-11-23 devnull  * Start executing the given code at the given pc with the given redirection
  8 f08fdedc 2003-11-23 devnull  */
  9 f08fdedc 2003-11-23 devnull char *argv0="rc";
 10 f08fdedc 2003-11-23 devnull void start(code *c, int pc, var *local)
 11 f08fdedc 2003-11-23 devnull {
 12 f08fdedc 2003-11-23 devnull 	struct thread *p=new(struct thread);
 13 f08fdedc 2003-11-23 devnull 	p->code=codecopy(c);
 14 f08fdedc 2003-11-23 devnull 	p->pc=pc;
 15 f08fdedc 2003-11-23 devnull 	p->argv=0;
 16 f08fdedc 2003-11-23 devnull 	p->redir=p->startredir=runq?runq->redir:0;
 17 f08fdedc 2003-11-23 devnull 	p->local=local;
 18 f08fdedc 2003-11-23 devnull 	p->cmdfile=0;
 19 f08fdedc 2003-11-23 devnull 	p->cmdfd=0;
 20 f08fdedc 2003-11-23 devnull 	p->eof=0;
 21 f08fdedc 2003-11-23 devnull 	p->iflag=0;
 22 f08fdedc 2003-11-23 devnull 	p->lineno=1;
 23 f08fdedc 2003-11-23 devnull 	p->ret=runq;
 24 f08fdedc 2003-11-23 devnull 	runq=p;
 25 f08fdedc 2003-11-23 devnull }
 26 f08fdedc 2003-11-23 devnull word *newword(char *wd, word *next)
 27 f08fdedc 2003-11-23 devnull {
 28 f08fdedc 2003-11-23 devnull 	word *p=new(word);
 29 f08fdedc 2003-11-23 devnull 	p->word=strdup(wd);
 30 f08fdedc 2003-11-23 devnull 	p->next=next;
 31 f08fdedc 2003-11-23 devnull 	return p;
 32 f08fdedc 2003-11-23 devnull }
 33 f08fdedc 2003-11-23 devnull void pushword(char *wd)
 34 f08fdedc 2003-11-23 devnull {
 35 f08fdedc 2003-11-23 devnull 	if(runq->argv==0) panic("pushword but no argv!", 0);
 36 f08fdedc 2003-11-23 devnull 	runq->argv->words=newword(wd, runq->argv->words);
 37 f08fdedc 2003-11-23 devnull }
 38 f08fdedc 2003-11-23 devnull void popword(void){
 39 f08fdedc 2003-11-23 devnull 	word *p;
 40 f08fdedc 2003-11-23 devnull 	if(runq->argv==0) panic("popword but no argv!", 0);
 41 f08fdedc 2003-11-23 devnull 	p=runq->argv->words;
 42 f08fdedc 2003-11-23 devnull 	if(p==0) panic("popword but no word!", 0);
 43 f08fdedc 2003-11-23 devnull 	runq->argv->words=p->next;
 44 f08fdedc 2003-11-23 devnull 	efree(p->word);
 45 f08fdedc 2003-11-23 devnull 	efree((char *)p);
 46 f08fdedc 2003-11-23 devnull }
 47 f08fdedc 2003-11-23 devnull void freelist(word *w)
 48 f08fdedc 2003-11-23 devnull {
 49 f08fdedc 2003-11-23 devnull 	word *nw;
 50 f08fdedc 2003-11-23 devnull 	while(w){
 51 f08fdedc 2003-11-23 devnull 		nw=w->next;
 52 f08fdedc 2003-11-23 devnull 		efree(w->word);
 53 f08fdedc 2003-11-23 devnull 		efree((char *)w);
 54 f08fdedc 2003-11-23 devnull 		w=nw;
 55 f08fdedc 2003-11-23 devnull 	}
 56 f08fdedc 2003-11-23 devnull }
 57 f08fdedc 2003-11-23 devnull void pushlist(void){
 58 f08fdedc 2003-11-23 devnull 	list *p=new(list);
 59 f08fdedc 2003-11-23 devnull 	p->next=runq->argv;
 60 f08fdedc 2003-11-23 devnull 	p->words=0;
 61 f08fdedc 2003-11-23 devnull 	runq->argv=p;
 62 f08fdedc 2003-11-23 devnull }
 63 f08fdedc 2003-11-23 devnull void poplist(void){
 64 f08fdedc 2003-11-23 devnull 	list *p=runq->argv;
 65 f08fdedc 2003-11-23 devnull 	if(p==0) panic("poplist but no argv", 0);
 66 f08fdedc 2003-11-23 devnull 	freelist(p->words);
 67 f08fdedc 2003-11-23 devnull 	runq->argv=p->next;
 68 f08fdedc 2003-11-23 devnull 	efree((char *)p);
 69 f08fdedc 2003-11-23 devnull }
 70 f08fdedc 2003-11-23 devnull int count(word *w)
 71 f08fdedc 2003-11-23 devnull {
 72 f08fdedc 2003-11-23 devnull 	int n;
 73 f08fdedc 2003-11-23 devnull 	for(n=0;w;n++) w=w->next;
 74 f08fdedc 2003-11-23 devnull 	return n;
 75 f08fdedc 2003-11-23 devnull }
 76 f08fdedc 2003-11-23 devnull void pushredir(int type, int from, int to){
 77 f08fdedc 2003-11-23 devnull 	redir * rp=new(redir);
 78 f08fdedc 2003-11-23 devnull 	rp->type=type;
 79 f08fdedc 2003-11-23 devnull 	rp->from=from;
 80 f08fdedc 2003-11-23 devnull 	rp->to=to;
 81 f08fdedc 2003-11-23 devnull 	rp->next=runq->redir;
 82 f08fdedc 2003-11-23 devnull 	runq->redir=rp;
 83 f08fdedc 2003-11-23 devnull }
 84 f08fdedc 2003-11-23 devnull var *newvar(char *name, var *next)
 85 f08fdedc 2003-11-23 devnull {
 86 f08fdedc 2003-11-23 devnull 	var *v=new(var);
 87 f08fdedc 2003-11-23 devnull 	v->name=name;
 88 f08fdedc 2003-11-23 devnull 	v->val=0;
 89 f08fdedc 2003-11-23 devnull 	v->fn=0;
 90 f08fdedc 2003-11-23 devnull 	v->changed=0;
 91 f08fdedc 2003-11-23 devnull 	v->fnchanged=0;
 92 f08fdedc 2003-11-23 devnull 	v->next=next;
 93 f08fdedc 2003-11-23 devnull 	return v;
 94 f08fdedc 2003-11-23 devnull }
 95 f08fdedc 2003-11-23 devnull /*
 96 f08fdedc 2003-11-23 devnull  * get command line flags, initialize keywords & traps.
 97 f08fdedc 2003-11-23 devnull  * get values from environment.
 98 f08fdedc 2003-11-23 devnull  * set $pid, $cflag, $*
 99 f08fdedc 2003-11-23 devnull  * fabricate bootstrap code and start it (*=(argv);. /usr/lib/rcmain $*)
100 f08fdedc 2003-11-23 devnull  * start interpreting code
101 f08fdedc 2003-11-23 devnull  */
102 f08fdedc 2003-11-23 devnull int
103 f08fdedc 2003-11-23 devnull main(int argc, char *argv[])
104 f08fdedc 2003-11-23 devnull {
105 f08fdedc 2003-11-23 devnull 	code bootstrap[32];
106 f08fdedc 2003-11-23 devnull 	char num[12], *rcmain;
107 f08fdedc 2003-11-23 devnull 	int i;
108 f08fdedc 2003-11-23 devnull 
109 f08fdedc 2003-11-23 devnull 	argc=getflags(argc, argv, "srdiIlxepvVc:1m:1[command]", 1);
110 f08fdedc 2003-11-23 devnull 	if(argc==-1) usage("[file [arg ...]]");
111 f08fdedc 2003-11-23 devnull 	if(argv[0][0]=='-') flag['l']=flagset;
112 f08fdedc 2003-11-23 devnull 	if(flag['I']) flag['i'] = 0;
113 f08fdedc 2003-11-23 devnull 	else if(flag['i']==0 && argc==1 && Isatty(0)) flag['i'] = flagset;
114 f08fdedc 2003-11-23 devnull 	rcmain=flag['m']?flag['m'][0]:Rcmain(); 
115 f08fdedc 2003-11-23 devnull 	err=openfd(2);
116 f08fdedc 2003-11-23 devnull 	kinit();
117 f08fdedc 2003-11-23 devnull 	Trapinit();
118 f08fdedc 2003-11-23 devnull 	Vinit();
119 f08fdedc 2003-11-23 devnull 	itoa(num, mypid=getpid());
120 f08fdedc 2003-11-23 devnull 	setvar("pid", newword(num, (word *)0));
121 f08fdedc 2003-11-23 devnull 	setvar("cflag", flag['c']?newword(flag['c'][0], (word *)0)
122 f08fdedc 2003-11-23 devnull 				:(word *)0);
123 f08fdedc 2003-11-23 devnull 	setvar("rcname", newword(argv[0], (word *)0));
124 f08fdedc 2003-11-23 devnull 	i=0;
125 f08fdedc 2003-11-23 devnull 	bootstrap[i++].i=1;
126 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xmark;
127 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xword;
128 f08fdedc 2003-11-23 devnull 	bootstrap[i++].s="*";
129 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xassign;
130 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xmark;
131 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xmark;
132 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xword;
133 f08fdedc 2003-11-23 devnull 	bootstrap[i++].s="*";
134 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xdol;
135 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xword;
136 f08fdedc 2003-11-23 devnull 	bootstrap[i++].s=rcmain;
137 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xword;
138 f08fdedc 2003-11-23 devnull 	bootstrap[i++].s=".";
139 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xsimple;
140 f08fdedc 2003-11-23 devnull 	bootstrap[i++].f=Xexit;
141 f08fdedc 2003-11-23 devnull 	bootstrap[i].i=0;
142 f08fdedc 2003-11-23 devnull 	start(bootstrap, 1, (var *)0);
143 f08fdedc 2003-11-23 devnull 	/* prime bootstrap argv */
144 f08fdedc 2003-11-23 devnull 	pushlist();
145 f08fdedc 2003-11-23 devnull 	argv0 = strdup(argv[0]);
146 f08fdedc 2003-11-23 devnull 	for(i=argc-1;i!=0;--i) pushword(argv[i]);
147 f08fdedc 2003-11-23 devnull 	for(;;){
148 f08fdedc 2003-11-23 devnull 		if(flag['r']) pfnc(err, runq);
149 f08fdedc 2003-11-23 devnull 		runq->pc++;
150 f08fdedc 2003-11-23 devnull 		(*runq->code[runq->pc-1].f)();
151 f08fdedc 2003-11-23 devnull 		if(ntrap) dotrap();
152 f08fdedc 2003-11-23 devnull 	}
153 f08fdedc 2003-11-23 devnull }
154 f08fdedc 2003-11-23 devnull /*
155 f08fdedc 2003-11-23 devnull  * Opcode routines
156 f08fdedc 2003-11-23 devnull  * Arguments on stack (...)
157 f08fdedc 2003-11-23 devnull  * Arguments in line [...]
158 f08fdedc 2003-11-23 devnull  * Code in line with jump around {...}
159 f08fdedc 2003-11-23 devnull  *
160 f08fdedc 2003-11-23 devnull  * Xappend(file)[fd]			open file to append
161 f08fdedc 2003-11-23 devnull  * Xassign(name, val)			assign val to name
162 f08fdedc 2003-11-23 devnull  * Xasync{... Xexit}			make thread for {}, no wait
163 f08fdedc 2003-11-23 devnull  * Xbackq{... Xreturn}			make thread for {}, push stdout
164 f08fdedc 2003-11-23 devnull  * Xbang				complement condition
165 f08fdedc 2003-11-23 devnull  * Xcase(pat, value){...}		exec code on match, leave (value) on
166 f08fdedc 2003-11-23 devnull  * 					stack
167 f08fdedc 2003-11-23 devnull  * Xclose[i]				close file descriptor
168 f08fdedc 2003-11-23 devnull  * Xconc(left, right)			concatenate, push results
169 f08fdedc 2003-11-23 devnull  * Xcount(name)				push var count
170 f08fdedc 2003-11-23 devnull  * Xdelfn(name)				delete function definition
171 f08fdedc 2003-11-23 devnull  * Xdeltraps(names)			delete named traps
172 f08fdedc 2003-11-23 devnull  * Xdol(name)				get variable value
173 f08fdedc 2003-11-23 devnull  * Xqdol(name)				concatenate variable components
174 f08fdedc 2003-11-23 devnull  * Xdup[i j]				dup file descriptor
175 f08fdedc 2003-11-23 devnull  * Xexit				rc exits with status
176 f08fdedc 2003-11-23 devnull  * Xfalse{...}				execute {} if false
177 f08fdedc 2003-11-23 devnull  * Xfn(name){... Xreturn}			define function
178 f08fdedc 2003-11-23 devnull  * Xfor(var, list){... Xreturn}		for loop
179 f08fdedc 2003-11-23 devnull  * Xjump[addr]				goto
180 f08fdedc 2003-11-23 devnull  * Xlocal(name, val)			create local variable, assign value
181 f08fdedc 2003-11-23 devnull  * Xmark				mark stack
182 f08fdedc 2003-11-23 devnull  * Xmatch(pat, str)			match pattern, set status
183 f08fdedc 2003-11-23 devnull  * Xpipe[i j]{... Xreturn}{... Xreturn}	construct a pipe between 2 new threads,
184 f08fdedc 2003-11-23 devnull  * 					wait for both
185 f08fdedc 2003-11-23 devnull  * Xpipefd[type]{... Xreturn}		connect {} to pipe (input or output,
186 f08fdedc 2003-11-23 devnull  * 					depending on type), push /dev/fd/??
187 f08fdedc 2003-11-23 devnull  * Xpopm(value)				pop value from stack
188 f08fdedc 2003-11-23 devnull  * Xread(file)[fd]			open file to read
189 f08fdedc 2003-11-23 devnull  * Xsettraps(names){... Xreturn}		define trap functions
190 f08fdedc 2003-11-23 devnull  * Xshowtraps				print trap list
191 f08fdedc 2003-11-23 devnull  * Xsimple(args)			run command and wait
192 f08fdedc 2003-11-23 devnull  * Xreturn				kill thread
193 f08fdedc 2003-11-23 devnull  * Xsubshell{... Xexit}			execute {} in a subshell and wait
194 f08fdedc 2003-11-23 devnull  * Xtrue{...}				execute {} if true
195 f08fdedc 2003-11-23 devnull  * Xunlocal				delete local variable
196 f08fdedc 2003-11-23 devnull  * Xword[string]			push string
197 f08fdedc 2003-11-23 devnull  * Xwrite(file)[fd]			open file to write
198 f08fdedc 2003-11-23 devnull  */
199 f08fdedc 2003-11-23 devnull void Xappend(void){
200 f08fdedc 2003-11-23 devnull 	char *file;
201 f08fdedc 2003-11-23 devnull 	int f;
202 f08fdedc 2003-11-23 devnull 	switch(count(runq->argv->words)){
203 f08fdedc 2003-11-23 devnull 	default: Xerror1(">> requires singleton"); return;
204 f08fdedc 2003-11-23 devnull 	case 0: Xerror1(">> requires file"); return;
205 f08fdedc 2003-11-23 devnull 	case 1: break;
206 f08fdedc 2003-11-23 devnull 	}
207 f08fdedc 2003-11-23 devnull 	file=runq->argv->words->word;
208 f08fdedc 2003-11-23 devnull 	if((f=open(file, 1))<0 && (f=Creat(file))<0){
209 f08fdedc 2003-11-23 devnull 		pfmt(err, "%s: ", file);
210 f08fdedc 2003-11-23 devnull 		Xerror("can't open");
211 f08fdedc 2003-11-23 devnull 		return;
212 f08fdedc 2003-11-23 devnull 	}
213 f08fdedc 2003-11-23 devnull 	Seek(f, 0L, 2);
214 f08fdedc 2003-11-23 devnull 	pushredir(ROPEN, f, runq->code[runq->pc].i);
215 f08fdedc 2003-11-23 devnull 	runq->pc++;
216 f08fdedc 2003-11-23 devnull 	poplist();
217 f08fdedc 2003-11-23 devnull }
218 f08fdedc 2003-11-23 devnull void Xasync(void){
219 f08fdedc 2003-11-23 devnull 	int null=open("/dev/null", 0);
220 f08fdedc 2003-11-23 devnull 	int pid;
221 f08fdedc 2003-11-23 devnull 	char npid[10];
222 f08fdedc 2003-11-23 devnull 	if(null<0){
223 f08fdedc 2003-11-23 devnull 		Xerror("Can't open /dev/null\n");
224 f08fdedc 2003-11-23 devnull 		return;
225 f08fdedc 2003-11-23 devnull 	}
226 f08fdedc 2003-11-23 devnull 	switch(pid=rfork(RFFDG|RFPROC|RFNOTEG)){
227 f08fdedc 2003-11-23 devnull 	case -1:
228 f08fdedc 2003-11-23 devnull 		close(null);
229 f08fdedc 2003-11-23 devnull 		Xerror("try again");
230 f08fdedc 2003-11-23 devnull 		break;
231 f08fdedc 2003-11-23 devnull 	case 0:
232 f08fdedc 2003-11-23 devnull 		pushredir(ROPEN, null, 0);
233 f08fdedc 2003-11-23 devnull 		start(runq->code, runq->pc+1, runq->local);
234 f08fdedc 2003-11-23 devnull 		runq->ret=0;
235 f08fdedc 2003-11-23 devnull 		break;
236 f08fdedc 2003-11-23 devnull 	default:
237 f08fdedc 2003-11-23 devnull 		close(null);
238 f08fdedc 2003-11-23 devnull 		runq->pc=runq->code[runq->pc].i;
239 f08fdedc 2003-11-23 devnull 		itoa(npid, pid);
240 f08fdedc 2003-11-23 devnull 		setvar("apid", newword(npid, (word *)0));
241 f08fdedc 2003-11-23 devnull 		break;
242 f08fdedc 2003-11-23 devnull 	}
243 f08fdedc 2003-11-23 devnull }
244 f08fdedc 2003-11-23 devnull void Xsettrue(void){
245 f08fdedc 2003-11-23 devnull 	setstatus("");
246 f08fdedc 2003-11-23 devnull }
247 f08fdedc 2003-11-23 devnull void Xbang(void){
248 f08fdedc 2003-11-23 devnull 	setstatus(truestatus()?"false":"");
249 f08fdedc 2003-11-23 devnull }
250 f08fdedc 2003-11-23 devnull void Xclose(void){
251 f08fdedc 2003-11-23 devnull 	pushredir(RCLOSE, runq->code[runq->pc].i, 0);
252 f08fdedc 2003-11-23 devnull 	runq->pc++;
253 f08fdedc 2003-11-23 devnull }
254 f08fdedc 2003-11-23 devnull void Xdup(void){
255 f08fdedc 2003-11-23 devnull 	pushredir(RDUP, runq->code[runq->pc].i, runq->code[runq->pc+1].i);
256 f08fdedc 2003-11-23 devnull 	runq->pc+=2;
257 f08fdedc 2003-11-23 devnull }
258 f08fdedc 2003-11-23 devnull void Xeflag(void){
259 f08fdedc 2003-11-23 devnull 	if(eflagok && !truestatus()) Xexit();
260 f08fdedc 2003-11-23 devnull }
261 f08fdedc 2003-11-23 devnull void Xexit(void){
262 f08fdedc 2003-11-23 devnull 	struct var *trapreq;
263 f08fdedc 2003-11-23 devnull 	struct word *starval;
264 f08fdedc 2003-11-23 devnull 	static int beenhere=0;
265 f08fdedc 2003-11-23 devnull 	if(getpid()==mypid && !beenhere){
266 f08fdedc 2003-11-23 devnull 		trapreq=vlook("sigexit");
267 f08fdedc 2003-11-23 devnull 		if(trapreq->fn){
268 f08fdedc 2003-11-23 devnull 			beenhere=1;
269 f08fdedc 2003-11-23 devnull 			--runq->pc;
270 f08fdedc 2003-11-23 devnull 			starval=vlook("*")->val;
271 f08fdedc 2003-11-23 devnull 			start(trapreq->fn, trapreq->pc, (struct var *)0);
272 f08fdedc 2003-11-23 devnull 			runq->local=newvar(strdup("*"), runq->local);
273 f08fdedc 2003-11-23 devnull 			runq->local->val=copywords(starval, (struct word *)0);
274 f08fdedc 2003-11-23 devnull 			runq->local->changed=1;
275 f08fdedc 2003-11-23 devnull 			runq->redir=runq->startredir=0;
276 f08fdedc 2003-11-23 devnull 			return;
277 f08fdedc 2003-11-23 devnull 		}
278 f08fdedc 2003-11-23 devnull 	}
279 f08fdedc 2003-11-23 devnull 	Exit(getstatus());
280 f08fdedc 2003-11-23 devnull }
281 f08fdedc 2003-11-23 devnull void Xfalse(void){
282 f08fdedc 2003-11-23 devnull 	if(truestatus()) runq->pc=runq->code[runq->pc].i;
283 f08fdedc 2003-11-23 devnull 	else runq->pc++;
284 f08fdedc 2003-11-23 devnull }
285 f08fdedc 2003-11-23 devnull int ifnot;		/* dynamic if not flag */
286 f08fdedc 2003-11-23 devnull void Xifnot(void){
287 f08fdedc 2003-11-23 devnull 	if(ifnot)
288 f08fdedc 2003-11-23 devnull 		runq->pc++;
289 f08fdedc 2003-11-23 devnull 	else
290 f08fdedc 2003-11-23 devnull 		runq->pc=runq->code[runq->pc].i;
291 f08fdedc 2003-11-23 devnull }
292 f08fdedc 2003-11-23 devnull void Xjump(void){
293 f08fdedc 2003-11-23 devnull 	runq->pc=runq->code[runq->pc].i;
294 f08fdedc 2003-11-23 devnull }
295 f08fdedc 2003-11-23 devnull void Xmark(void){
296 f08fdedc 2003-11-23 devnull 	pushlist();
297 f08fdedc 2003-11-23 devnull }
298 f08fdedc 2003-11-23 devnull void Xpopm(void){
299 f08fdedc 2003-11-23 devnull 	poplist();
300 f08fdedc 2003-11-23 devnull }
301 f08fdedc 2003-11-23 devnull void Xread(void){
302 f08fdedc 2003-11-23 devnull 	char *file;
303 f08fdedc 2003-11-23 devnull 	int f;
304 f08fdedc 2003-11-23 devnull 	switch(count(runq->argv->words)){
305 f08fdedc 2003-11-23 devnull 	default: Xerror1("< requires singleton\n"); return;
306 f08fdedc 2003-11-23 devnull 	case 0: Xerror1("< requires file\n"); return;
307 f08fdedc 2003-11-23 devnull 	case 1: break;
308 f08fdedc 2003-11-23 devnull 	}
309 f08fdedc 2003-11-23 devnull 	file=runq->argv->words->word;
310 f08fdedc 2003-11-23 devnull 	if((f=open(file, 0))<0){
311 f08fdedc 2003-11-23 devnull 		pfmt(err, "%s: ", file);
312 f08fdedc 2003-11-23 devnull 		Xerror("can't open");
313 f08fdedc 2003-11-23 devnull 		return;
314 f08fdedc 2003-11-23 devnull 	}
315 f08fdedc 2003-11-23 devnull 	pushredir(ROPEN, f, runq->code[runq->pc].i);
316 f08fdedc 2003-11-23 devnull 	runq->pc++;
317 f08fdedc 2003-11-23 devnull 	poplist();
318 f08fdedc 2003-11-23 devnull }
319 f08fdedc 2003-11-23 devnull void turfredir(void){
320 f08fdedc 2003-11-23 devnull 	while(runq->redir!=runq->startredir)
321 f08fdedc 2003-11-23 devnull 		Xpopredir();
322 f08fdedc 2003-11-23 devnull }
323 f08fdedc 2003-11-23 devnull void Xpopredir(void){
324 f08fdedc 2003-11-23 devnull 	struct redir *rp=runq->redir;
325 f08fdedc 2003-11-23 devnull 	if(rp==0) panic("turfredir null!", 0);
326 f08fdedc 2003-11-23 devnull 	runq->redir=rp->next;
327 f08fdedc 2003-11-23 devnull 	if(rp->type==ROPEN) close(rp->from);
328 f08fdedc 2003-11-23 devnull 	efree((char *)rp);
329 f08fdedc 2003-11-23 devnull }
330 f08fdedc 2003-11-23 devnull void Xreturn(void){
331 f08fdedc 2003-11-23 devnull 	struct thread *p=runq;
332 f08fdedc 2003-11-23 devnull 	turfredir();
333 f08fdedc 2003-11-23 devnull 	while(p->argv) poplist();
334 f08fdedc 2003-11-23 devnull 	codefree(p->code);
335 f08fdedc 2003-11-23 devnull 	runq=p->ret;
336 f08fdedc 2003-11-23 devnull 	efree((char *)p);
337 f08fdedc 2003-11-23 devnull 	if(runq==0) Exit(getstatus());
338 f08fdedc 2003-11-23 devnull }
339 f08fdedc 2003-11-23 devnull void Xtrue(void){
340 f08fdedc 2003-11-23 devnull 	if(truestatus()) runq->pc++;
341 f08fdedc 2003-11-23 devnull 	else runq->pc=runq->code[runq->pc].i;
342 f08fdedc 2003-11-23 devnull }
343 f08fdedc 2003-11-23 devnull void Xif(void){
344 f08fdedc 2003-11-23 devnull 	ifnot=1;
345 f08fdedc 2003-11-23 devnull 	if(truestatus()) runq->pc++;
346 f08fdedc 2003-11-23 devnull 	else runq->pc=runq->code[runq->pc].i;
347 f08fdedc 2003-11-23 devnull }
348 f08fdedc 2003-11-23 devnull void Xwastrue(void){
349 f08fdedc 2003-11-23 devnull 	ifnot=0;
350 f08fdedc 2003-11-23 devnull }
351 f08fdedc 2003-11-23 devnull void Xword(void){
352 f08fdedc 2003-11-23 devnull 	pushword(runq->code[runq->pc++].s);
353 f08fdedc 2003-11-23 devnull }
354 f08fdedc 2003-11-23 devnull void Xwrite(void){
355 f08fdedc 2003-11-23 devnull 	char *file;
356 f08fdedc 2003-11-23 devnull 	int f;
357 f08fdedc 2003-11-23 devnull 	switch(count(runq->argv->words)){
358 f08fdedc 2003-11-23 devnull 	default: Xerror1("> requires singleton\n"); return;
359 f08fdedc 2003-11-23 devnull 	case 0: Xerror1("> requires file\n"); return;
360 f08fdedc 2003-11-23 devnull 	case 1: break;
361 f08fdedc 2003-11-23 devnull 	}
362 f08fdedc 2003-11-23 devnull 	file=runq->argv->words->word;
363 f08fdedc 2003-11-23 devnull 	if((f=Creat(file))<0){
364 f08fdedc 2003-11-23 devnull 		pfmt(err, "%s: ", file);
365 f08fdedc 2003-11-23 devnull 		Xerror("can't open");
366 f08fdedc 2003-11-23 devnull 		return;
367 f08fdedc 2003-11-23 devnull 	}
368 f08fdedc 2003-11-23 devnull 	pushredir(ROPEN, f, runq->code[runq->pc].i);
369 f08fdedc 2003-11-23 devnull 	runq->pc++;
370 f08fdedc 2003-11-23 devnull 	poplist();
371 f08fdedc 2003-11-23 devnull }
372 f08fdedc 2003-11-23 devnull char *list2str(word *words){
373 f08fdedc 2003-11-23 devnull 	char *value, *s, *t;
374 f08fdedc 2003-11-23 devnull 	int len=0;
375 f08fdedc 2003-11-23 devnull 	word *ap;
376 f08fdedc 2003-11-23 devnull 	for(ap=words;ap;ap=ap->next)
377 f08fdedc 2003-11-23 devnull 		len+=1+strlen(ap->word);
378 f08fdedc 2003-11-23 devnull 	value=emalloc(len+1);
379 f08fdedc 2003-11-23 devnull 	s=value;
380 f08fdedc 2003-11-23 devnull 	for(ap=words;ap;ap=ap->next){
381 f08fdedc 2003-11-23 devnull 		for(t=ap->word;*t;) *s++=*t++;
382 f08fdedc 2003-11-23 devnull 		*s++=' ';
383 f08fdedc 2003-11-23 devnull 	}
384 f08fdedc 2003-11-23 devnull 	if(s==value) *s='\0';
385 f08fdedc 2003-11-23 devnull 	else s[-1]='\0';
386 f08fdedc 2003-11-23 devnull 	return value;
387 f08fdedc 2003-11-23 devnull }
388 f08fdedc 2003-11-23 devnull void Xmatch(void){
389 f08fdedc 2003-11-23 devnull 	word *p;
390 f08fdedc 2003-11-23 devnull 	char *subject;
391 f08fdedc 2003-11-23 devnull 	subject=list2str(runq->argv->words);
392 f08fdedc 2003-11-23 devnull 	setstatus("no match");
393 f08fdedc 2003-11-23 devnull 	for(p=runq->argv->next->words;p;p=p->next)
394 f08fdedc 2003-11-23 devnull 		if(match(subject, p->word, '\0')){
395 f08fdedc 2003-11-23 devnull 			setstatus("");
396 f08fdedc 2003-11-23 devnull 			break;
397 f08fdedc 2003-11-23 devnull 		}
398 f08fdedc 2003-11-23 devnull 	efree(subject);
399 f08fdedc 2003-11-23 devnull 	poplist();
400 f08fdedc 2003-11-23 devnull 	poplist();
401 f08fdedc 2003-11-23 devnull }
402 f08fdedc 2003-11-23 devnull void Xcase(void){
403 f08fdedc 2003-11-23 devnull 	word *p;
404 f08fdedc 2003-11-23 devnull 	char *s;
405 f08fdedc 2003-11-23 devnull 	int ok=0;
406 f08fdedc 2003-11-23 devnull 	s=list2str(runq->argv->next->words);
407 f08fdedc 2003-11-23 devnull 	for(p=runq->argv->words;p;p=p->next){
408 f08fdedc 2003-11-23 devnull 		if(match(s, p->word, '\0')){
409 f08fdedc 2003-11-23 devnull 			ok=1;
410 f08fdedc 2003-11-23 devnull 			break;
411 f08fdedc 2003-11-23 devnull 		}
412 f08fdedc 2003-11-23 devnull 	}
413 f08fdedc 2003-11-23 devnull 	efree(s);
414 f08fdedc 2003-11-23 devnull 	if(ok)
415 f08fdedc 2003-11-23 devnull 		runq->pc++;
416 f08fdedc 2003-11-23 devnull 	else
417 f08fdedc 2003-11-23 devnull 		runq->pc=runq->code[runq->pc].i;
418 f08fdedc 2003-11-23 devnull 	poplist();
419 f08fdedc 2003-11-23 devnull }
420 f08fdedc 2003-11-23 devnull word *conclist(word *lp, word *rp, word *tail)
421 f08fdedc 2003-11-23 devnull {
422 f08fdedc 2003-11-23 devnull 	char *buf;
423 f08fdedc 2003-11-23 devnull 	word *v;
424 f08fdedc 2003-11-23 devnull 	if(lp->next || rp->next)
425 f08fdedc 2003-11-23 devnull 		tail=conclist(lp->next==0?lp:lp->next, rp->next==0?rp:rp->next,
426 f08fdedc 2003-11-23 devnull 			tail);
427 f08fdedc 2003-11-23 devnull 	buf=emalloc(strlen(lp->word)+strlen(rp->word)+1);
428 f08fdedc 2003-11-23 devnull 	strcpy(buf, lp->word);
429 f08fdedc 2003-11-23 devnull 	strcat(buf, rp->word);
430 f08fdedc 2003-11-23 devnull 	v=newword(buf, tail);
431 f08fdedc 2003-11-23 devnull 	efree(buf);
432 f08fdedc 2003-11-23 devnull 	return v;
433 f08fdedc 2003-11-23 devnull }
434 f08fdedc 2003-11-23 devnull void Xconc(void){
435 f08fdedc 2003-11-23 devnull 	word *lp=runq->argv->words;
436 f08fdedc 2003-11-23 devnull 	word *rp=runq->argv->next->words;
437 f08fdedc 2003-11-23 devnull 	word *vp=runq->argv->next->next->words;
438 f08fdedc 2003-11-23 devnull 	int lc=count(lp), rc=count(rp);
439 f08fdedc 2003-11-23 devnull 	if(lc!=0 || rc!=0){
440 f08fdedc 2003-11-23 devnull 		if(lc==0 || rc==0){
441 f08fdedc 2003-11-23 devnull 			Xerror1("null list in concatenation");
442 f08fdedc 2003-11-23 devnull 			return;
443 f08fdedc 2003-11-23 devnull 		}
444 f08fdedc 2003-11-23 devnull 		if(lc!=1 && rc!=1 && lc!=rc){
445 f08fdedc 2003-11-23 devnull 			Xerror1("mismatched list lengths in concatenation");
446 f08fdedc 2003-11-23 devnull 			return;
447 f08fdedc 2003-11-23 devnull 		}
448 f08fdedc 2003-11-23 devnull 		vp=conclist(lp, rp, vp);
449 f08fdedc 2003-11-23 devnull 	}
450 f08fdedc 2003-11-23 devnull 	poplist();
451 f08fdedc 2003-11-23 devnull 	poplist();
452 f08fdedc 2003-11-23 devnull 	runq->argv->words=vp;
453 f08fdedc 2003-11-23 devnull }
454 f08fdedc 2003-11-23 devnull void Xassign(void){
455 f08fdedc 2003-11-23 devnull 	var *v;
456 f08fdedc 2003-11-23 devnull 	if(count(runq->argv->words)!=1){
457 f08fdedc 2003-11-23 devnull 		Xerror1("variable name not singleton!");
458 f08fdedc 2003-11-23 devnull 		return;
459 f08fdedc 2003-11-23 devnull 	}
460 f08fdedc 2003-11-23 devnull 	deglob(runq->argv->words->word);
461 f08fdedc 2003-11-23 devnull 	v=vlook(runq->argv->words->word);
462 f08fdedc 2003-11-23 devnull 	poplist();
463 f08fdedc 2003-11-23 devnull 	globlist();
464 f08fdedc 2003-11-23 devnull 	freewords(v->val);
465 f08fdedc 2003-11-23 devnull 	v->val=runq->argv->words;
466 f08fdedc 2003-11-23 devnull 	v->changed=1;
467 f08fdedc 2003-11-23 devnull 	runq->argv->words=0;
468 f08fdedc 2003-11-23 devnull 	poplist();
469 f08fdedc 2003-11-23 devnull }
470 f08fdedc 2003-11-23 devnull /*
471 f08fdedc 2003-11-23 devnull  * copy arglist a, adding the copy to the front of tail
472 f08fdedc 2003-11-23 devnull  */
473 f08fdedc 2003-11-23 devnull word *copywords(word *a, word *tail)
474 f08fdedc 2003-11-23 devnull {
475 f08fdedc 2003-11-23 devnull 	word *v=0, **end;
476 f08fdedc 2003-11-23 devnull 	for(end=&v;a;a=a->next,end=&(*end)->next)
477 f08fdedc 2003-11-23 devnull 		*end=newword(a->word, 0);
478 f08fdedc 2003-11-23 devnull 	*end=tail;
479 f08fdedc 2003-11-23 devnull 	return v;
480 f08fdedc 2003-11-23 devnull }
481 f08fdedc 2003-11-23 devnull void Xdol(void){
482 f08fdedc 2003-11-23 devnull 	word *a, *star;
483 f08fdedc 2003-11-23 devnull 	char *s, *t;
484 f08fdedc 2003-11-23 devnull 	int n;
485 f08fdedc 2003-11-23 devnull 	if(count(runq->argv->words)!=1){
486 f08fdedc 2003-11-23 devnull 		Xerror1("variable name not singleton!");
487 f08fdedc 2003-11-23 devnull 		return;
488 f08fdedc 2003-11-23 devnull 	}
489 f08fdedc 2003-11-23 devnull 	s=runq->argv->words->word;
490 f08fdedc 2003-11-23 devnull 	deglob(s);
491 f08fdedc 2003-11-23 devnull 	n=0;
492 f08fdedc 2003-11-23 devnull 	for(t=s;'0'<=*t && *t<='9';t++) n=n*10+*t-'0';
493 f08fdedc 2003-11-23 devnull 	a=runq->argv->next->words;
494 f08fdedc 2003-11-23 devnull 	if(n==0 || *t)
495 f08fdedc 2003-11-23 devnull 		a=copywords(vlook(s)->val, a);
496 f08fdedc 2003-11-23 devnull 	else{
497 f08fdedc 2003-11-23 devnull 		star=vlook("*")->val;
498 f08fdedc 2003-11-23 devnull 		if(star && 1<=n && n<=count(star)){
499 f08fdedc 2003-11-23 devnull 			while(--n) star=star->next;
500 f08fdedc 2003-11-23 devnull 			a=newword(star->word, a);
501 f08fdedc 2003-11-23 devnull 		}
502 f08fdedc 2003-11-23 devnull 	}
503 f08fdedc 2003-11-23 devnull 	poplist();
504 f08fdedc 2003-11-23 devnull 	runq->argv->words=a;
505 f08fdedc 2003-11-23 devnull }
506 f08fdedc 2003-11-23 devnull void Xqdol(void){
507 f08fdedc 2003-11-23 devnull 	word *a, *p;
508 f08fdedc 2003-11-23 devnull 	char *s;
509 f08fdedc 2003-11-23 devnull 	int n;
510 f08fdedc 2003-11-23 devnull 	if(count(runq->argv->words)!=1){
511 f08fdedc 2003-11-23 devnull 		Xerror1("variable name not singleton!");
512 f08fdedc 2003-11-23 devnull 		return;
513 f08fdedc 2003-11-23 devnull 	}
514 f08fdedc 2003-11-23 devnull 	s=runq->argv->words->word;
515 f08fdedc 2003-11-23 devnull 	deglob(s);
516 f08fdedc 2003-11-23 devnull 	a=vlook(s)->val;
517 f08fdedc 2003-11-23 devnull 	poplist();
518 f08fdedc 2003-11-23 devnull 	n=count(a);
519 f08fdedc 2003-11-23 devnull 	if(n==0){
520 f08fdedc 2003-11-23 devnull 		pushword("");
521 f08fdedc 2003-11-23 devnull 		return;
522 f08fdedc 2003-11-23 devnull 	}
523 f08fdedc 2003-11-23 devnull 	for(p=a;p;p=p->next) n+=strlen(p->word);
524 f08fdedc 2003-11-23 devnull 	s=emalloc(n);
525 f08fdedc 2003-11-23 devnull 	if(a){
526 f08fdedc 2003-11-23 devnull 		strcpy(s, a->word);
527 f08fdedc 2003-11-23 devnull 		for(p=a->next;p;p=p->next){
528 f08fdedc 2003-11-23 devnull 			strcat(s, " ");
529 f08fdedc 2003-11-23 devnull 			strcat(s, p->word);
530 f08fdedc 2003-11-23 devnull 		}
531 f08fdedc 2003-11-23 devnull 	}
532 f08fdedc 2003-11-23 devnull 	else
533 f08fdedc 2003-11-23 devnull 		s[0]='\0';
534 f08fdedc 2003-11-23 devnull 	pushword(s);
535 f08fdedc 2003-11-23 devnull 	efree(s);
536 f08fdedc 2003-11-23 devnull }
537 f08fdedc 2003-11-23 devnull word *subwords(word *val, int len, word *sub, word *a)
538 f08fdedc 2003-11-23 devnull {
539 f08fdedc 2003-11-23 devnull 	int n;
540 f08fdedc 2003-11-23 devnull 	char *s;
541 f08fdedc 2003-11-23 devnull 	if(!sub) return a;
542 f08fdedc 2003-11-23 devnull 	a=subwords(val, len, sub->next, a);
543 f08fdedc 2003-11-23 devnull 	s=sub->word;
544 f08fdedc 2003-11-23 devnull 	deglob(s);
545 f08fdedc 2003-11-23 devnull 	n=0;
546 f08fdedc 2003-11-23 devnull 	while('0'<=*s && *s<='9') n=n*10+ *s++ -'0';
547 f08fdedc 2003-11-23 devnull 	if(n<1 || len<n) return a;
548 f08fdedc 2003-11-23 devnull 	for(;n!=1;--n) val=val->next;
549 f08fdedc 2003-11-23 devnull 	return newword(val->word, a);
550 f08fdedc 2003-11-23 devnull }
551 f08fdedc 2003-11-23 devnull void Xsub(void){
552 f08fdedc 2003-11-23 devnull 	word *a, *v;
553 f08fdedc 2003-11-23 devnull 	char *s;
554 f08fdedc 2003-11-23 devnull 	if(count(runq->argv->next->words)!=1){
555 f08fdedc 2003-11-23 devnull 		Xerror1("variable name not singleton!");
556 f08fdedc 2003-11-23 devnull 		return;
557 f08fdedc 2003-11-23 devnull 	}
558 f08fdedc 2003-11-23 devnull 	s=runq->argv->next->words->word;
559 f08fdedc 2003-11-23 devnull 	deglob(s);
560 f08fdedc 2003-11-23 devnull 	a=runq->argv->next->next->words;
561 f08fdedc 2003-11-23 devnull 	v=vlook(s)->val;
562 f08fdedc 2003-11-23 devnull 	a=subwords(v, count(v), runq->argv->words, a);
563 f08fdedc 2003-11-23 devnull 	poplist();
564 f08fdedc 2003-11-23 devnull 	poplist();
565 f08fdedc 2003-11-23 devnull 	runq->argv->words=a;
566 f08fdedc 2003-11-23 devnull }
567 f08fdedc 2003-11-23 devnull void Xcount(void){
568 f08fdedc 2003-11-23 devnull 	word *a;
569 f08fdedc 2003-11-23 devnull 	char *s, *t;
570 f08fdedc 2003-11-23 devnull 	int n;
571 f08fdedc 2003-11-23 devnull 	char num[12];
572 f08fdedc 2003-11-23 devnull 	if(count(runq->argv->words)!=1){
573 f08fdedc 2003-11-23 devnull 		Xerror1("variable name not singleton!");
574 f08fdedc 2003-11-23 devnull 		return;
575 f08fdedc 2003-11-23 devnull 	}
576 f08fdedc 2003-11-23 devnull 	s=runq->argv->words->word;
577 f08fdedc 2003-11-23 devnull 	deglob(s);
578 f08fdedc 2003-11-23 devnull 	n=0;
579 f08fdedc 2003-11-23 devnull 	for(t=s;'0'<=*t && *t<='9';t++) n=n*10+*t-'0';
580 f08fdedc 2003-11-23 devnull 	if(n==0 || *t){
581 f08fdedc 2003-11-23 devnull 		a=vlook(s)->val;
582 f08fdedc 2003-11-23 devnull 		itoa(num, count(a));
583 f08fdedc 2003-11-23 devnull 	}
584 f08fdedc 2003-11-23 devnull 	else{
585 f08fdedc 2003-11-23 devnull 		a=vlook("*")->val;
586 f08fdedc 2003-11-23 devnull 		itoa(num, a && 1<=n && n<=count(a)?1:0);
587 f08fdedc 2003-11-23 devnull 	}
588 f08fdedc 2003-11-23 devnull 	poplist();
589 f08fdedc 2003-11-23 devnull 	pushword(num);
590 f08fdedc 2003-11-23 devnull }
591 f08fdedc 2003-11-23 devnull void Xlocal(void){
592 f08fdedc 2003-11-23 devnull 	if(count(runq->argv->words)!=1){
593 f08fdedc 2003-11-23 devnull 		Xerror1("variable name must be singleton\n");
594 f08fdedc 2003-11-23 devnull 		return;
595 f08fdedc 2003-11-23 devnull 	}
596 f08fdedc 2003-11-23 devnull 	deglob(runq->argv->words->word);
597 f08fdedc 2003-11-23 devnull 	runq->local=newvar(strdup(runq->argv->words->word), runq->local);
598 f08fdedc 2003-11-23 devnull 	runq->local->val=copywords(runq->argv->next->words, (word *)0);
599 f08fdedc 2003-11-23 devnull 	runq->local->changed=1;
600 f08fdedc 2003-11-23 devnull 	poplist();
601 f08fdedc 2003-11-23 devnull 	poplist();
602 f08fdedc 2003-11-23 devnull }
603 f08fdedc 2003-11-23 devnull void Xunlocal(void){
604 f08fdedc 2003-11-23 devnull 	var *v=runq->local, *hid;
605 f08fdedc 2003-11-23 devnull 	if(v==0) panic("Xunlocal: no locals!", 0);
606 f08fdedc 2003-11-23 devnull 	runq->local=v->next;
607 f08fdedc 2003-11-23 devnull 	hid=vlook(v->name);
608 f08fdedc 2003-11-23 devnull 	hid->changed=1;
609 f08fdedc 2003-11-23 devnull 	efree(v->name);
610 f08fdedc 2003-11-23 devnull 	freewords(v->val);
611 f08fdedc 2003-11-23 devnull 	efree((char *)v);
612 f08fdedc 2003-11-23 devnull }
613 f08fdedc 2003-11-23 devnull void freewords(word *w)
614 f08fdedc 2003-11-23 devnull {
615 f08fdedc 2003-11-23 devnull 	word *nw;
616 f08fdedc 2003-11-23 devnull 	while(w){
617 f08fdedc 2003-11-23 devnull 		efree(w->word);
618 f08fdedc 2003-11-23 devnull 		nw=w->next;
619 f08fdedc 2003-11-23 devnull 		efree((char *)w);
620 f08fdedc 2003-11-23 devnull 		w=nw;
621 f08fdedc 2003-11-23 devnull 	}
622 f08fdedc 2003-11-23 devnull }
623 f08fdedc 2003-11-23 devnull void Xfn(void){
624 f08fdedc 2003-11-23 devnull 	var *v;
625 f08fdedc 2003-11-23 devnull 	word *a;
626 f08fdedc 2003-11-23 devnull 	int end;
627 f08fdedc 2003-11-23 devnull 	end=runq->code[runq->pc].i;
628 f08fdedc 2003-11-23 devnull 	for(a=runq->argv->words;a;a=a->next){
629 f08fdedc 2003-11-23 devnull 		v=gvlook(a->word);
630 f08fdedc 2003-11-23 devnull 		if(v->fn) codefree(v->fn);
631 f08fdedc 2003-11-23 devnull 		v->fn=codecopy(runq->code);
632 f08fdedc 2003-11-23 devnull 		v->pc=runq->pc+2;
633 f08fdedc 2003-11-23 devnull 		v->fnchanged=1;
634 f08fdedc 2003-11-23 devnull 	}
635 f08fdedc 2003-11-23 devnull 	runq->pc=end;
636 f08fdedc 2003-11-23 devnull 	poplist();
637 f08fdedc 2003-11-23 devnull }
638 f08fdedc 2003-11-23 devnull void Xdelfn(void){
639 f08fdedc 2003-11-23 devnull 	var *v;
640 f08fdedc 2003-11-23 devnull 	word *a;
641 f08fdedc 2003-11-23 devnull 	for(a=runq->argv->words;a;a=a->next){
642 f08fdedc 2003-11-23 devnull 		v=gvlook(a->word);
643 f08fdedc 2003-11-23 devnull 		if(v->fn) codefree(v->fn);
644 f08fdedc 2003-11-23 devnull 		v->fn=0;
645 f08fdedc 2003-11-23 devnull 		v->fnchanged=1;
646 f08fdedc 2003-11-23 devnull 	}
647 f08fdedc 2003-11-23 devnull 	poplist();
648 f08fdedc 2003-11-23 devnull }
649 f08fdedc 2003-11-23 devnull void Xpipe(void){
650 f08fdedc 2003-11-23 devnull 	struct thread *p=runq;
651 f08fdedc 2003-11-23 devnull 	int pc=p->pc, forkid;
652 f08fdedc 2003-11-23 devnull 	int lfd=p->code[pc++].i;
653 f08fdedc 2003-11-23 devnull 	int rfd=p->code[pc++].i;
654 f08fdedc 2003-11-23 devnull 	int pfd[2];
655 f08fdedc 2003-11-23 devnull 	if(pipe(pfd)<0){
656 f08fdedc 2003-11-23 devnull 		Xerror("can't get pipe");
657 f08fdedc 2003-11-23 devnull 		return;
658 f08fdedc 2003-11-23 devnull 	}
659 f08fdedc 2003-11-23 devnull 	switch(forkid=fork()){
660 f08fdedc 2003-11-23 devnull 	case -1:
661 f08fdedc 2003-11-23 devnull 		Xerror("try again");
662 f08fdedc 2003-11-23 devnull 		break;
663 f08fdedc 2003-11-23 devnull 	case 0:
664 f08fdedc 2003-11-23 devnull 		start(p->code, pc+2, runq->local);
665 f08fdedc 2003-11-23 devnull 		runq->ret=0;
666 f08fdedc 2003-11-23 devnull 		close(pfd[PRD]);
667 f08fdedc 2003-11-23 devnull 		pushredir(ROPEN, pfd[PWR], lfd);
668 f08fdedc 2003-11-23 devnull 		break;
669 f08fdedc 2003-11-23 devnull 	default:
670 f08fdedc 2003-11-23 devnull 		start(p->code, p->code[pc].i, runq->local);
671 f08fdedc 2003-11-23 devnull 		close(pfd[PWR]);
672 f08fdedc 2003-11-23 devnull 		pushredir(ROPEN, pfd[PRD], rfd);
673 f08fdedc 2003-11-23 devnull 		p->pc=p->code[pc+1].i;
674 f08fdedc 2003-11-23 devnull 		p->pid=forkid;
675 f08fdedc 2003-11-23 devnull 		break;
676 f08fdedc 2003-11-23 devnull 	}
677 f08fdedc 2003-11-23 devnull }
678 f08fdedc 2003-11-23 devnull char *concstatus(char *s, char *t)
679 f08fdedc 2003-11-23 devnull {
680 f08fdedc 2003-11-23 devnull 	static char v[NSTATUS+1];
681 f08fdedc 2003-11-23 devnull 	int n=strlen(s);
682 f08fdedc 2003-11-23 devnull 	strncpy(v, s, NSTATUS);
683 f08fdedc 2003-11-23 devnull 	if(n<NSTATUS){
684 f08fdedc 2003-11-23 devnull 		v[n]='|';
685 f08fdedc 2003-11-23 devnull 		strncpy(v+n+1, t, NSTATUS-n-1);
686 f08fdedc 2003-11-23 devnull 	}
687 f08fdedc 2003-11-23 devnull 	v[NSTATUS]='\0';
688 f08fdedc 2003-11-23 devnull 	return v;
689 f08fdedc 2003-11-23 devnull }
690 f08fdedc 2003-11-23 devnull void Xpipewait(void){
691 f08fdedc 2003-11-23 devnull 	char status[NSTATUS+1];
692 f08fdedc 2003-11-23 devnull 	if(runq->pid==-1)
693 f08fdedc 2003-11-23 devnull 		setstatus(concstatus(runq->status, getstatus()));
694 f08fdedc 2003-11-23 devnull 	else{
695 f08fdedc 2003-11-23 devnull 		strncpy(status, getstatus(), NSTATUS);
696 f08fdedc 2003-11-23 devnull 		status[NSTATUS]='\0';
697 f08fdedc 2003-11-23 devnull 		Waitfor(runq->pid, 1);
698 f08fdedc 2003-11-23 devnull 		runq->pid=-1;
699 f08fdedc 2003-11-23 devnull 		setstatus(concstatus(getstatus(), status));
700 f08fdedc 2003-11-23 devnull 	}
701 f08fdedc 2003-11-23 devnull }
702 f08fdedc 2003-11-23 devnull void Xrdcmds(void){
703 f08fdedc 2003-11-23 devnull 	struct thread *p=runq;
704 f08fdedc 2003-11-23 devnull 	word *prompt;
705 f08fdedc 2003-11-23 devnull 	flush(err);
706 f08fdedc 2003-11-23 devnull 	nerror=0;
707 f08fdedc 2003-11-23 devnull 	if(flag['s'] && !truestatus())
708 f08fdedc 2003-11-23 devnull 		pfmt(err, "status=%v\n", vlook("status")->val);
709 f08fdedc 2003-11-23 devnull 	if(runq->iflag){
710 f08fdedc 2003-11-23 devnull 		prompt=vlook("prompt")->val;
711 f08fdedc 2003-11-23 devnull 		if(prompt)
712 f08fdedc 2003-11-23 devnull 			promptstr=prompt->word;
713 f08fdedc 2003-11-23 devnull 		else
714 f08fdedc 2003-11-23 devnull 			promptstr="% ";
715 f08fdedc 2003-11-23 devnull 	}
716 f08fdedc 2003-11-23 devnull 	Noerror();
717 f08fdedc 2003-11-23 devnull 	if(yyparse()){
718 f08fdedc 2003-11-23 devnull 		if(!p->iflag || p->eof && !Eintr()){
719 f08fdedc 2003-11-23 devnull 			if(p->cmdfile) efree(p->cmdfile);
720 f08fdedc 2003-11-23 devnull 			closeio(p->cmdfd);
721 f08fdedc 2003-11-23 devnull 			Xreturn();	/* should this be omitted? */
722 f08fdedc 2003-11-23 devnull 		}
723 f08fdedc 2003-11-23 devnull 		else{
724 f08fdedc 2003-11-23 devnull 			if(Eintr()){
725 f08fdedc 2003-11-23 devnull 				pchr(err, '\n');
726 f08fdedc 2003-11-23 devnull 				p->eof=0;
727 f08fdedc 2003-11-23 devnull 			}
728 f08fdedc 2003-11-23 devnull 			--p->pc;	/* go back for next command */
729 f08fdedc 2003-11-23 devnull 		}
730 f08fdedc 2003-11-23 devnull 	}
731 f08fdedc 2003-11-23 devnull 	else{
732 f08fdedc 2003-11-23 devnull 		ntrap = 0;	/* avoid double-interrupts during blocked writes */
733 f08fdedc 2003-11-23 devnull 		--p->pc;	/* re-execute Xrdcmds after codebuf runs */
734 f08fdedc 2003-11-23 devnull 		start(codebuf, 1, runq->local);
735 f08fdedc 2003-11-23 devnull 	}
736 f08fdedc 2003-11-23 devnull 	freenodes();
737 f08fdedc 2003-11-23 devnull }
738 f08fdedc 2003-11-23 devnull void Xerror(char *s)
739 f08fdedc 2003-11-23 devnull {
740 f08fdedc 2003-11-23 devnull 	if(strcmp(argv0, "rc")==0 || strcmp(argv0, "/bin/rc")==0)
741 f08fdedc 2003-11-23 devnull 		pfmt(err, "rc: %s: %r\n", s);
742 f08fdedc 2003-11-23 devnull 	else
743 f08fdedc 2003-11-23 devnull 		pfmt(err, "rc (%s): %s: %r\n", argv0, s);
744 f08fdedc 2003-11-23 devnull 	flush(err);
745 f08fdedc 2003-11-23 devnull 	while(!runq->iflag) Xreturn();
746 f08fdedc 2003-11-23 devnull }
747 f08fdedc 2003-11-23 devnull void Xerror1(char *s)
748 f08fdedc 2003-11-23 devnull {
749 f08fdedc 2003-11-23 devnull 	if(strcmp(argv0, "rc")==0 || strcmp(argv0, "/bin/rc")==0)
750 f08fdedc 2003-11-23 devnull 		pfmt(err, "rc: %s\n", s);
751 f08fdedc 2003-11-23 devnull 	else
752 f08fdedc 2003-11-23 devnull 		pfmt(err, "rc (%s): %s\n", argv0, s);
753 f08fdedc 2003-11-23 devnull 	flush(err);
754 f08fdedc 2003-11-23 devnull 	while(!runq->iflag) Xreturn();
755 f08fdedc 2003-11-23 devnull }
756 f08fdedc 2003-11-23 devnull void Xbackq(void){
757 f08fdedc 2003-11-23 devnull 	char wd[8193];
758 f08fdedc 2003-11-23 devnull 	int c;
759 f08fdedc 2003-11-23 devnull 	char *s, *ewd=&wd[8192], *stop;
760 f08fdedc 2003-11-23 devnull 	struct io *f;
761 f08fdedc 2003-11-23 devnull 	var *ifs=vlook("ifs");
762 f08fdedc 2003-11-23 devnull 	word *v, *nextv;
763 f08fdedc 2003-11-23 devnull 	int pfd[2];
764 f08fdedc 2003-11-23 devnull 	int pid;
765 f08fdedc 2003-11-23 devnull 	stop=ifs->val?ifs->val->word:"";
766 f08fdedc 2003-11-23 devnull 	if(pipe(pfd)<0){
767 f08fdedc 2003-11-23 devnull 		Xerror("can't make pipe");
768 f08fdedc 2003-11-23 devnull 		return;
769 f08fdedc 2003-11-23 devnull 	}
770 f08fdedc 2003-11-23 devnull 	switch(pid=fork()){
771 f08fdedc 2003-11-23 devnull 	case -1: Xerror("try again");
772 f08fdedc 2003-11-23 devnull 		close(pfd[PRD]);
773 f08fdedc 2003-11-23 devnull 		close(pfd[PWR]);
774 f08fdedc 2003-11-23 devnull 		return;
775 f08fdedc 2003-11-23 devnull 	case 0:
776 f08fdedc 2003-11-23 devnull 		close(pfd[PRD]);
777 f08fdedc 2003-11-23 devnull 		start(runq->code, runq->pc+1, runq->local);
778 f08fdedc 2003-11-23 devnull 		pushredir(ROPEN, pfd[PWR], 1);
779 f08fdedc 2003-11-23 devnull 		return;
780 f08fdedc 2003-11-23 devnull 	default:
781 f08fdedc 2003-11-23 devnull 		close(pfd[PWR]);
782 f08fdedc 2003-11-23 devnull 		f=openfd(pfd[PRD]);
783 f08fdedc 2003-11-23 devnull 		s=wd;
784 f08fdedc 2003-11-23 devnull 		v=0;
785 f08fdedc 2003-11-23 devnull 		while((c=rchr(f))!=EOF){
786 f08fdedc 2003-11-23 devnull 			if(strchr(stop, c) || s==ewd){
787 f08fdedc 2003-11-23 devnull 				if(s!=wd){
788 f08fdedc 2003-11-23 devnull 					*s='\0';
789 f08fdedc 2003-11-23 devnull 					v=newword(wd, v);
790 f08fdedc 2003-11-23 devnull 					s=wd;
791 f08fdedc 2003-11-23 devnull 				}
792 f08fdedc 2003-11-23 devnull 			}
793 f08fdedc 2003-11-23 devnull 			else *s++=c;
794 f08fdedc 2003-11-23 devnull 		}
795 f08fdedc 2003-11-23 devnull 		if(s!=wd){
796 f08fdedc 2003-11-23 devnull 			*s='\0';
797 f08fdedc 2003-11-23 devnull 			v=newword(wd, v);
798 f08fdedc 2003-11-23 devnull 		}
799 f08fdedc 2003-11-23 devnull 		closeio(f);
800 f08fdedc 2003-11-23 devnull 		Waitfor(pid, 0);
801 f08fdedc 2003-11-23 devnull 		/* v points to reversed arglist -- reverse it onto argv */
802 f08fdedc 2003-11-23 devnull 		while(v){
803 f08fdedc 2003-11-23 devnull 			nextv=v->next;
804 f08fdedc 2003-11-23 devnull 			v->next=runq->argv->words;
805 f08fdedc 2003-11-23 devnull 			runq->argv->words=v;
806 f08fdedc 2003-11-23 devnull 			v=nextv;
807 f08fdedc 2003-11-23 devnull 		}
808 f08fdedc 2003-11-23 devnull 		runq->pc=runq->code[runq->pc].i;
809 f08fdedc 2003-11-23 devnull 		return;
810 f08fdedc 2003-11-23 devnull 	}
811 f08fdedc 2003-11-23 devnull }
812 f08fdedc 2003-11-23 devnull /*
813 f08fdedc 2003-11-23 devnull  * Who should wait for the exit from the fork?
814 f08fdedc 2003-11-23 devnull  */
815 f08fdedc 2003-11-23 devnull void Xpipefd(void){
816 f08fdedc 2003-11-23 devnull 	struct thread *p=runq;
817 f08fdedc 2003-11-23 devnull 	int pc=p->pc;
818 f08fdedc 2003-11-23 devnull 	char name[40];
819 f08fdedc 2003-11-23 devnull 	int pfd[2];
820 f08fdedc 2003-11-23 devnull 	int sidefd, mainfd;
821 f08fdedc 2003-11-23 devnull 	if(pipe(pfd)<0){
822 f08fdedc 2003-11-23 devnull 		Xerror("can't get pipe");
823 f08fdedc 2003-11-23 devnull 		return;
824 f08fdedc 2003-11-23 devnull 	}
825 f08fdedc 2003-11-23 devnull 	if(p->code[pc].i==READ){
826 f08fdedc 2003-11-23 devnull 		sidefd=pfd[PWR];
827 f08fdedc 2003-11-23 devnull 		mainfd=pfd[PRD];
828 f08fdedc 2003-11-23 devnull 	}
829 f08fdedc 2003-11-23 devnull 	else{
830 f08fdedc 2003-11-23 devnull 		sidefd=pfd[PRD];
831 f08fdedc 2003-11-23 devnull 		mainfd=pfd[PWR];
832 f08fdedc 2003-11-23 devnull 	}
833 f08fdedc 2003-11-23 devnull 	switch(fork()){
834 f08fdedc 2003-11-23 devnull 	case -1:
835 f08fdedc 2003-11-23 devnull 		Xerror("try again");
836 f08fdedc 2003-11-23 devnull 		break;
837 f08fdedc 2003-11-23 devnull 	case 0:
838 f08fdedc 2003-11-23 devnull 		start(p->code, pc+2, runq->local);
839 f08fdedc 2003-11-23 devnull 		close(mainfd);
840 f08fdedc 2003-11-23 devnull 		pushredir(ROPEN, sidefd, p->code[pc].i==READ?1:0);
841 f08fdedc 2003-11-23 devnull 		runq->ret=0;
842 f08fdedc 2003-11-23 devnull 		break;
843 f08fdedc 2003-11-23 devnull 	default:
844 f08fdedc 2003-11-23 devnull 		close(sidefd);
845 f08fdedc 2003-11-23 devnull 		pushredir(ROPEN, mainfd, mainfd);	/* isn't this a noop? */
846 f08fdedc 2003-11-23 devnull 		strcpy(name, Fdprefix);
847 f08fdedc 2003-11-23 devnull 		itoa(name+strlen(name), mainfd);
848 f08fdedc 2003-11-23 devnull 		pushword(name);
849 f08fdedc 2003-11-23 devnull 		p->pc=p->code[pc+1].i;
850 f08fdedc 2003-11-23 devnull 		break;
851 f08fdedc 2003-11-23 devnull 	}
852 f08fdedc 2003-11-23 devnull }
853 f08fdedc 2003-11-23 devnull void Xsubshell(void){
854 f08fdedc 2003-11-23 devnull 	int pid;
855 f08fdedc 2003-11-23 devnull 	switch(pid=fork()){
856 f08fdedc 2003-11-23 devnull 	case -1:
857 f08fdedc 2003-11-23 devnull 		Xerror("try again");
858 f08fdedc 2003-11-23 devnull 		break;
859 f08fdedc 2003-11-23 devnull 	case 0:
860 f08fdedc 2003-11-23 devnull 		start(runq->code, runq->pc+1, runq->local);
861 f08fdedc 2003-11-23 devnull 		runq->ret=0;
862 f08fdedc 2003-11-23 devnull 		break;
863 f08fdedc 2003-11-23 devnull 	default:
864 f08fdedc 2003-11-23 devnull 		Waitfor(pid, 1);
865 f08fdedc 2003-11-23 devnull 		runq->pc=runq->code[runq->pc].i;
866 f08fdedc 2003-11-23 devnull 		break;
867 f08fdedc 2003-11-23 devnull 	}
868 f08fdedc 2003-11-23 devnull }
869 f08fdedc 2003-11-23 devnull void setstatus(char *s)
870 f08fdedc 2003-11-23 devnull {
871 f08fdedc 2003-11-23 devnull 	setvar("status", newword(s, (word *)0));
872 f08fdedc 2003-11-23 devnull }
873 f08fdedc 2003-11-23 devnull char *getstatus(void){
874 f08fdedc 2003-11-23 devnull 	var *status=vlook("status");
875 f08fdedc 2003-11-23 devnull 	return status->val?status->val->word:"";
876 f08fdedc 2003-11-23 devnull }
877 f08fdedc 2003-11-23 devnull int truestatus(void){
878 f08fdedc 2003-11-23 devnull 	char *s;
879 f08fdedc 2003-11-23 devnull 	for(s=getstatus();*s;s++)
880 f08fdedc 2003-11-23 devnull 		if(*s!='|' && *s!='0') return 0;
881 f08fdedc 2003-11-23 devnull 	return 1;
882 f08fdedc 2003-11-23 devnull }
883 f08fdedc 2003-11-23 devnull void Xdelhere(void){
884 f08fdedc 2003-11-23 devnull 	Unlink(runq->code[runq->pc++].s);
885 f08fdedc 2003-11-23 devnull }
886 f08fdedc 2003-11-23 devnull void Xfor(void){
887 f08fdedc 2003-11-23 devnull 	if(runq->argv->words==0){
888 f08fdedc 2003-11-23 devnull 		poplist();
889 f08fdedc 2003-11-23 devnull 		runq->pc=runq->code[runq->pc].i;
890 f08fdedc 2003-11-23 devnull 	}
891 f08fdedc 2003-11-23 devnull 	else{
892 f08fdedc 2003-11-23 devnull 		freelist(runq->local->val);
893 f08fdedc 2003-11-23 devnull 		runq->local->val=runq->argv->words;
894 f08fdedc 2003-11-23 devnull 		runq->local->changed=1;
895 f08fdedc 2003-11-23 devnull 		runq->argv->words=runq->argv->words->next;
896 f08fdedc 2003-11-23 devnull 		runq->local->val->next=0;
897 f08fdedc 2003-11-23 devnull 		runq->pc++;
898 f08fdedc 2003-11-23 devnull 	}
899 f08fdedc 2003-11-23 devnull }
900 f08fdedc 2003-11-23 devnull void Xglob(void){
901 f08fdedc 2003-11-23 devnull 	globlist();
902 f08fdedc 2003-11-23 devnull }