2 * Plan 9 versions of system-specific functions
3 * By convention, exported routines herein have names beginning with an
12 "sigexit", "sighup", "sigint", "sigquit",
13 "sigalrm", "sigkill", "sigfpe", "sigterm",
17 "exit", /* can't happen */
20 "quit", /* can't happen */
30 return unsharp("#9/rcmain");
33 char Fdprefix[]="/dev/fd/";
34 long readnb(int, char *, long);
38 void execulimit(void);
45 "exec", execexec, /* but with popword first */
64 switch(count(runq->argv->words)){
66 arg = RFENVG|RFNOTEG|RFNAMEG;
70 for(s = runq->argv->words->next->word;*s;s++) switch(*s){
79 /* arg|=RFENVG; */ break;
92 pfmt(err, "Usage: %s [nNeEsfF]\n", runq->argv->words->word);
93 setstatus("rfork usage");
98 pfmt(err, "rc: %s failed\n", runq->argv->words->word);
99 setstatus("rfork failed");
110 struct word *enval(s)
114 register struct word *v;
115 for(t=s;*t && *t!=SEP;t++);
118 v=newword(s, c=='\0'?(struct word *)0:enval(t+1));
123 extern char **environ;
125 register char **env=environ;
128 for(s=*env;*s && *s!='(' && *s!='=';s++);
131 /* pfmt(err, "rc: odd environment %q?\n", *env); */
135 setvar(*env, enval(s+1));
138 case '(': /* ignore functions for now */
150 if(strncmp(s, "fn#", 3) == 0){
157 execcmds(opencore(s, len));
162 for(s=*envp;*s && *s!='(' && *s!='=';s++);
165 pfmt(err, "environment %q?\n", *envp);
167 case '=': /* ignore variables */
169 case '(': /* Bourne again */
174 execcmds(opencore(s, len+1));
183 void execfinit(void){
194 start(rdfns, 1, runq->local);
196 extern int mapfd(int);
197 int Waitfor(int pid, int unused0){
202 if(pid >= 0 && !havewaitpid(pid))
204 while((w = wait()) != nil){
207 if(strncmp(w->msg, "signal: ", 8) == 0)
208 fprint(mapfd(2), "%d: %s\n", w->pid, w->msg);
213 if(runq->iflag && strncmp(w->msg, "signal: ", 8) == 0)
214 fprint(2, "%d: %s\n", w->pid, w->msg);
215 for(p=runq->ret;p;p=p->ret)
218 strcpy(p->status, w->msg);
223 rerrstr(errbuf, sizeof errbuf);
224 if(strcmp(errbuf, "interrupted")==0) return -1;
227 char **mkargv(word *a)
229 char **argv=(char **)emalloc((count(a)+2)*sizeof(char *));
230 char **argp=argv+1; /* leave one at front for runcoms */
231 for(;a;a=a->next) *argp++=a->word;
244 snprint(envname, sizeof envname, "/env/%s", v->name);
245 if((f=Creat(envname))<0)
246 pfmt(err, "rc: can't open %s: %r\n", envname);
248 for(w=v->val;w;w=w->next)
249 write(f, w->word, strlen(w->word)+1L);
255 snprint(envname, sizeof envname, "/env/fn#%s", v->name);
256 if((f=Creat(envname))<0)
257 pfmt(err, "rc: can't open %s: %r\n", envname);
261 pfmt(fd, "fn %s %s\n", v->name, v->fn[v->pc-1].s);
268 void updenvlocal(var *v)
271 updenvlocal(v->next);
277 for(h=gvar;h!=&gvar[NVAR];h++)
278 for(v=*h;v;v=v->next)
280 if(runq) updenvlocal(runq->local);
284 cmpenv(const void *a, const void *b)
286 return strcmp(*(char**)a, *(char**)b);
289 register char **env, **ep, *p, *q;
290 register struct var **h, *v;
291 register struct word *a;
292 register int nvar=0, nchr=0, sep;
294 * Slightly kludgy loops look at locals then globals
296 for(h=gvar-1;h!=&gvar[NVAR];h++) for(v=h>=gvar?*h:runq->local;v;v=v->next){
297 if((v==vlook(v->name)) && v->val){
299 nchr+=strlen(v->name)+1;
300 for(a=v->val;a;a=a->next)
301 nchr+=strlen(a->word)+1;
305 nchr+=strlen(v->name)+strlen(v->fn[v->pc-1].s)+8;
308 env=(char **)emalloc((nvar+1)*sizeof(char *)+nchr);
310 p=(char *)&env[nvar+1];
311 for(h=gvar-1;h!=&gvar[NVAR];h++) for(v=h>=gvar?*h:runq->local;v;v=v->next){
312 if((v==vlook(v->name)) && v->val){
317 for(a=v->val;a;a=a->next){
328 *p++='#'; *p++='('; *p++=')'; /* to fool Bourne */
329 *p++='f'; *p++='n'; *p++=' ';
334 *p++='f'; *p++='n'; *p++='#';
345 qsort((char *)env, nvar, sizeof ep[0], cmpenv);
349 void Execute(word *args, word *path)
351 char **argv=mkargv(args);
356 for(;path;path=path->next){
357 nc=strlen(path->word);
359 strcpy(file, path->word);
364 if(nc+strlen(argv[1])<1024){
365 strcat(file, argv[1]);
366 execve(file, argv+1, env);
368 else werrstr("command name too long");
371 rerrstr(file, sizeof file);
372 pfmt(err, "%s: %s\n", argv[1], file);
375 #define NDIR 256 /* shoud be a better way */
376 int Globsize(char *p)
378 ulong isglob=0, globlen=NDIR+1;
382 if(*p!=GLOB) isglob++;
383 globlen+=*p=='*'?NDIR:1;
388 return isglob?globlen:0;
397 int Opendir(char *name)
405 if(db!=nil && (db->mode&DMDIR)){
417 int Readdir(int f, char *p, int onlydirs)
420 USED(onlydirs); /* only advisory */
424 if(dir[f].i==dir[f].n){ /* read */
427 n=dirread(f, &dir[f].dbuf);
434 if(dir[f].i==dir[f].n)
436 strcpy(p, dir[f].dbuf[dir[f].i].name);
440 void Closedir(int f){
451 notifyf(void *unused0, char *s)
454 for(i=0;syssigname[i];i++)
455 if(strncmp(s, syssigname[i], strlen(syssigname[i]))==0){
456 if(strncmp(s, "sys: ", 5)!=0){
457 if(kidpid && !interrupted){
459 postnote(PNGROUP, kidpid, s);
465 if(strcmp(s, "sys: window size change") != 0)
466 if(strcmp(s, "sys: write on closed pipe") != 0)
467 if(strcmp(s, "sys: child") != 0)
468 pfmt(err, "rc: note: %s\n", s);
472 if(strcmp(s, "interrupt")!=0 || trap[i]==0){
476 if(ntrap>=32){ /* rc is probably in a trap loop */
477 pfmt(err, "rc: Too many traps (trap %s), aborting\n", s);
485 void Unlink(char *name)
489 long Write(int fd, char *buf, long cnt)
491 return write(fd, buf, (long)cnt);
493 long Read(int fd, char *buf, long cnt)
497 i = readnb(fd, buf, cnt);
501 long Seek(int fd, long cnt, long whence)
503 return seek(fd, cnt, whence);
505 int Executable(char *file)
510 statbuf = dirstat(file);
511 if(statbuf == nil) return 0;
512 ret = ((statbuf->mode&0111)!=0 && (statbuf->mode&DMDIR)==0);
516 int Creat(char *file)
518 return create(file, 1, 0666L);
520 int Dup(int a, int b){
526 void Exit(char *stat)
530 exits(truestatus()?"":getstatus());
543 pfmt(err, "aborting\n");
547 void Memcpy(char *a, char *b, long n)
549 memmove(a, b, (long)n);
551 void *Malloc(ulong n){
572 waitpids = realloc(waitpids, (nwaitpids+1)*sizeof waitpids[0]);
574 panic("Can't realloc %d waitpids", nwaitpids+1);
575 waitpids[nwaitpids++] = pid;
583 for(r=w=0; r<nwaitpids; r++)
584 if(waitpids[r] != pid)
585 waitpids[w++] = waitpids[r];
600 for(i=0; i<nwaitpids; i++)
601 if(waitpids[i] == pid)