1991/0705/port/devproc.c (diff list | history)

1991/0705/sys/src/9/port/devproc.c:1,477 – 1991/0712/sys/src/9/port/devproc.c:1,479 (short | long | prev | next)
1990/0227		#include "u.h" #include "lib.h" #include "mem.h" #include "dat.h" #include "fns.h" #include "errno.h" #include "devtab.h" enum{ Qdir, Qctl, Qmem, Qnote,
1990/1110		Qnotepg,
1990/0227		Qproc,
1991/0705		Qsegment,
1990/0227		Qstatus, Qtext, };
1991/0712		#define STATSIZE (2*NAMELEN+12+6*12)
1990/0227		Dirtab procdir[]={
1990/11211		"ctl", {Qctl}, 0, 0600, "mem", {Qmem}, 0, 0600, "note", {Qnote}, 0, 0600, "notepg", {Qnotepg}, 0, 0200, "proc", {Qproc}, sizeof(Proc), 0600,
1991/0705		"segment", {Qsegment}, 0, 0400,
1990/11211		"status", {Qstatus}, NAMELEN+12+6*12, 0600,
1991/0712		"status", {Qstatus}, STATSIZE, 0600,
1990/11211		"text", {Qtext}, 0, 0600,
1990/0227		};
1991/0705		char *sname[]={ /* Segment type from portdat.h */ "Text", "Data", "Bss", "Stack", "Shared", "Phys", };
1990/0227		/*
1990/11211		* Qids are, in path:
1990/0227		* 4 bits of file type (qids above)
1990/1128		* 23 bits of process slot number + 1
1990/11211		* in vers, * 32 bits of pid, for consistency checking * If notepg, c->pgrpid.path is pgrp slot, .vers is pgrpid.
1990/0227		*/ #define NPROC (sizeof procdir/sizeof(Dirtab)) #define QSHIFT 4 /* location in qid of proc slot # */
1990/11211		#define QID(q) (((q).path&0x0000000F)>>0)
1990/1128		#define SLOT(q) ((((q).path&0x07FFFFFF0)>>QSHIFT)-1)
1990/11211		#define PID(q) ((q).vers)
1990/0227		int procgen(Chan *c, Dirtab *tab, int ntab, int s, Dir *dp) { Proc *p; char buf[NAMELEN];
1991/0705		ulong pid, path;
1990/0227
1990/11211		if(c->qid.path == CHDIR){
1990/0227		if(s >= conf.nproc) return -1; p = proctab(s); pid = p->pid; if(pid == 0) return 0; sprint(buf, "%d", pid);
1990/11211		devdir(c, (Qid){CHDIR|((s+1)<<QSHIFT), pid}, buf, 0, CHDIR|0500, dp);
1990/0227		return 1; } if(s >= NPROC) return -1; if(tab) panic("procgen"); tab = &procdir[s];
1991/0705		path = c->qid.path&~(CHDIR|((1<<QSHIFT)-1)); /* slot component */ devdir(c, (Qid){path|tab->qid.path, c->qid.vers},
1990/11211		tab->name, tab->length, tab->perm, dp);
1990/0227		return 1; } void procinit(void) { if(conf.nproc >= (1<<(16-QSHIFT))-1) print("warning: too many procs for devproc\n"); } void procreset(void) { } Chan* procattach(char *spec) {
1990/03081		Chan *c;
1990/0227		return devattach('p', spec); } Chan* procclone(Chan *c, Chan *nc) { return devclone(c, nc); } int procwalk(Chan *c, char *name) { return devwalk(c, name, 0, 0, procgen); } void procstat(Chan *c, char *db) { devstat(c, db, 0, 0, procgen); } Chan * procopen(Chan *c, int omode) { Proc *p;
1990/1110		Pgrp *pg;
1991/0705		Segment *s;
1990/0227		Chan *tc;
1990/11211		if(c->qid.path == CHDIR){
1990/03081		if(omode != OREAD)
1990/11211		error(Eperm);
1990/03081		goto done; }
1990/0227		p = proctab(SLOT(c->qid));
1990/1110		pg = p->pgrp;
1990/11211		if(p->pid != PID(c->qid))
1990/0227		Died:
1990/11211		error(Eprocdied);
1990/0227		omode = openmode(omode); switch(QID(c->qid)){ case Qtext:
1991/0705		s = p->seg[TSEG]; if(s==0 || p->state==Dead || s->image==0)
1990/0227		goto Died;
1991/0605
1991/0705		tc = s->image->c;
1990/0227		if(tc == 0) goto Died;
1991/0605
1990/0227		if(incref(tc) == 0){ Close: close(tc); goto Died; } if(!(tc->flag&COPEN) || tc->mode!=OREAD) goto Close;
1991/0605
1990/11211		if(p->pid != PID(c->qid))
1990/0227		goto Close;
1991/0605
1991/0411		qlock(&tc->rdl);
1990/0227		tc->offset = 0;
1991/0411		qunlock(&tc->rdl);
1990/0227		return tc; case Qctl: case Qnote:
1991/0705		case Qsegment:
1990/0227		break;
1990/1110		case Qnotepg:
1990/1115		if(omode!=OWRITE || pg->pgrpid==1) /* easy to do by mistake */
1990/11211		error(Eperm); c->pgrpid.path = pg->index+1; c->pgrpid.vers = pg->pgrpid;
1990/1110		break;
1990/0227		case Qdir:
1990/0614		case Qmem:
1990/0227		case Qproc: case Qstatus:
1990/1110		if(omode != OREAD)
1990/11211		error(Eperm);
1990/0424		break;
1990/0227		default: pprint("unknown qid in devopen\n");
1990/11211		error(Egreg);
1990/0227		} /* * Affix pid to qid */ if(p->state != Dead)
1990/11211		c->qid.vers = p->pid;
1990/03081		done:
1990/0227		c->mode = omode; c->flag |= COPEN; c->offset = 0; return c; } void proccreate(Chan *c, char *name, int omode, ulong perm) {
1990/11211		error(Eperm);
1990/0227		} void procremove(Chan *c) {
1990/11211		error(Eperm);
1990/0227		} void procwstat(Chan *c, char *db) {
1990/11211		error(Eperm);
1990/0227		} void procclose(Chan * c) { } long
1991/0411		procread(Chan *c, void *va, long n, ulong offset)
1990/0227		{ char *a = va, *b;
1991/0705		char statbuf[NSEG*32];
1990/0227		Proc *p;
1991/0705		Pte *pte; Segment *s;
1990/0227		Page *pg;
1990/0614		KMap *k;
1991/0705		int i, j;
1990/0227		long l; long pid; User *up;
1991/0705		ulong soff; Segment *sg;
1990/0227
1990/11211		if(c->qid.path & CHDIR)
1990/0227		return devdirread(c, a, n, 0, 0, procgen); /* * BUG: should lock(&p->debug)? */ p = proctab(SLOT(c->qid));
1990/11211		if(p->pid != PID(c->qid)) error(Eprocdied);
1990/0227		switch(QID(c->qid)){ case Qmem: /* * One page at a time */
1991/0411		if(((offset+n)&~(BY2PG-1)) != (offset&~(BY2PG-1))) n = BY2PG - (offset&(BY2PG-1));
1991/0705		s = seg(p, offset, 1);
1990/0227		if(s){
1991/0705		if(p->pid!=PID(c->qid)){ qunlock(&s->lk);
1990/11211		error(Eprocdied);
1990/0227		}
1991/0705		soff = offset-s->base; pte = s->map[soff/PTEMAPMEM]; pg = 0; if(pte) pg = pte->pages[(soff&(PTEMAPMEM-1))/BY2PG]; s->steal++; qunlock(&s->lk); if(pagedout(pg)){
1991/0411		pprint("nonresident page addr %lux (complain to rob)\n", offset);
1990/0227		memset(a, 0, n); }else{
1990/0614		k = kmap(pg); b = (char*)VA(k);
1991/0411		memmove(a, b+(offset&(BY2PG-1)), n);
1990/0614		kunmap(k);
1990/0227		}
1991/0705		qlock(&s->lk); s->steal--; qunlock(&s->lk);
1990/0227		return n; } /* u area */
1991/0411		if(offset>=USERADDR && offset<USERADDR+BY2PG){ if(offset+n > USERADDR+BY2PG) n = USERADDR+BY2PG - offset;
1990/0227		pg = p->upage;
1990/11211		if(pg==0 || p->pid!=PID(c->qid)) error(Eprocdied);
1990/0614		k = kmap(pg); b = (char*)VA(k);
1991/0411		memmove(a, b+(offset-USERADDR), n);
1990/0614		kunmap(k);
1990/0227		return n; } /* kernel memory. BUG: shouldn't be so easygoing. BUG: mem mapping? */
1991/0411		if(offset>=KZERO && offset<KZERO+conf.npage0*BY2PG){ if(offset+n > KZERO+conf.npage0*BY2PG) n = KZERO+conf.npage0*BY2PG - offset; memmove(a, (char*)offset, n);
1990/0914		return n;
1990/0227		} return 0; break; case Qnote: lock(&p->debug); if(waserror()){ unlock(&p->debug); nexterror(); }
1990/11211		if(p->pid != PID(c->qid)) error(Eprocdied);
1990/0614		k = kmap(p->upage); up = (User*)VA(k);
1990/0227		if(up->p != p){
1990/0614		kunmap(k);
1990/0227		pprint("note read u/p mismatch");
1990/11211		error(Egreg);
1990/0227		} if(n < ERRLEN)
1990/11211		error(Etoosmall);
1990/0227		if(up->nnote == 0) n = 0; else{
1991/0318		memmove(va, up->note[0].msg, ERRLEN);
1990/0227		up->nnote--;
1991/0318		memmove(&up->note[0], &up->note[1], up->nnote*sizeof(Note));
1990/0227		n = ERRLEN; }
1990/0614		kunmap(k);
1991/0614		poperror();
1990/0227		unlock(&p->debug); return n; case Qproc:
1991/0411		if(offset >= sizeof(Proc))
1990/0227		return 0;
1991/0411		if(offset+n > sizeof(Proc)) n = sizeof(Proc) - offset; memmove(a, ((char*)p)+offset, n);
1990/0227		return n; case Qstatus:
1991/0411		if(offset >= sizeof statbuf)
1991/0712		if(offset >= STATSIZE)
1990/0227		return 0;
1991/0411		if(offset+n > sizeof statbuf) n = sizeof statbuf - offset;
1990/0227		sprint(statbuf, "%-27s %-27s %-11s ", p->text, p->pgrp->user, statename[p->state]);
1991/0712		if(offset+n > STATSIZE) n = STATSIZE - offset; j = sprint(statbuf, "%-27s %-27s %-11s ", p->text, p->pgrp->user, statename[p->state]);
1990/0227		for(i=0; i<6; i++){ l = p->time[i]; if(i == TReal) l = MACHP(0)->ticks - l;
1990/0614		l = TK2MS(l);
1990/0227		readnum(0, statbuf+2*NAMELEN+12+NUMSIZE*i, NUMSIZE, l, NUMSIZE);
1991/0712		readnum(0, statbuf+j+NUMSIZE*i, NUMSIZE, l, NUMSIZE);
1990/0227		}
1991/0411		memmove(a, statbuf+offset, n);
1990/0227		return n;
1991/0705		case Qsegment: j = 0; for(i = 0; i < NSEG; i++) if(sg = p->seg[i]) j += sprint(&statbuf[j], "%-6s %c %.8lux %.8lux %4d\n", sname[sg->type&SG_TYPE], sg->type&SG_RONLY ? 'R' : ' ', sg->base, sg->top, sg->ref); if(offset >= j) return 0; if(offset+n > j) n = j-offset; memmove(a, &statbuf[offset], n); return n;
1990/0227		}
1990/11211		error(Egreg);
1990/0227		} long
1991/0411		procwrite(Chan *c, void *va, long n, ulong offset)
1990/0227		{ Proc *p;
1990/1110		Pgrp *pg;
1990/0227		User *up;
1990/0614		KMap *k;
1990/0227		char buf[ERRLEN];
1990/11211		if(c->qid.path & CHDIR) error(Eisdir);
1990/1110
1990/1126		p = proctab(SLOT(c->qid));
1990/1110		/* * Special case: don't worry about process, just use remembered group */ if(QID(c->qid) == Qnotepg){
1990/11211		pg = pgrptab(c->pgrpid.path-1);
1991/0212		qlock(&pg->debug);
1990/1110		if(waserror()){
1991/0212		qunlock(&pg->debug);
1990/1110		nexterror(); }
1990/11211		if(pg->pgrpid != c->pgrpid.vers){
1991/0212		qunlock(&pg->debug);
1990/1110		goto Died; } pgrpnote(pg, va, n, NUser);
1991/0614		poperror();
1991/0212		qunlock(&pg->debug);
1990/1110		return n; }
1990/0227		lock(&p->debug); if(waserror()){ unlock(&p->debug); nexterror(); }
1990/11211		if(p->pid != PID(c->qid))
1990/0227		Died:
1990/11211		error(Eprocdied);
1990/0227		switch(QID(c->qid)){ case Qctl:
1991/0705		if(n >= 4 && strncmp(va, "exit", 4) == 0) { if(p->state == Broken) { ready(p); break; } }
1990/0227		else
1991/0705		if(n >= 4 && strncmp(va, "stop", 4) == 0) { p->procctl = Proc_stopme; break; } else if(n >= 5 && strncmp(va, "start", 5) == 0) { if(p->state == Stopped) { ready(p); break; } errors("not stopped"); } else if(n >= 4 && strncmp(va, "kill", 4) == 0) { p->procctl = Proc_exitme; break; } error(Ebadctl);
1990/0227		case Qnote:
1990/0614		k = kmap(p->upage); up = (User*)VA(k);
1990/0227		if(up->p != p){
1990/0614		kunmap(k);
1990/0227		pprint("note write u/p mismatch");
1990/11211		error(Egreg);
1990/0227		}
1990/0614		kunmap(k);
1990/0227		if(n >= ERRLEN-1)
1990/11211		error(Etoobig);
1990/0227		if(n>=4 && strncmp(va, "sys:", 4)==0)
1990/11211		error(Ebadarg);
1991/0318		memmove(buf, va, n);
1990/0227		buf[n] = 0; if(!postnote(p, 0, buf, NUser))
1990/11211		error(Enonote);
1990/0227		break; default: pprint("unknown qid in procwrite\n");
1990/11211		error(Egreg);
1990/0227		}
1991/0614		poperror();
1990/0227		unlock(&p->debug); return n; }