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