1990/11211/gnot/devproc.c (diff list | history)

gnot/devproc.c on 1990/03091
1990/03091		#include "u.h" #include "lib.h" #include "mem.h" #include "dat.h" #include "fns.h" #include "errno.h"
1990/11211		/* BUG mips only TAKE IT OUT */ #include "io.h"
1990/03091		#include "devtab.h" enum{ Qdir, Qctl, Qmem, Qnote,
1990/1106		Qnotepg,
1990/03091		Qproc, Qstatus, Qtext, }; 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, "status", {Qstatus}, NAMELEN+12+6*12, 0600, "text", {Qtext}, 0, 0600,
1990/03091		}; /*
1990/11211		* Qids are, in path:
1990/03091		* 4 bits of file type (qids above)
1990/11211		* 24 bits of process slot number + 1 * in vers, * 32 bits of pid, for consistency checking * If notepg, c->pgrpid.path is pgrp slot, .vers is pgrpid.
1990/03091		*/ #define NPROC (sizeof procdir/sizeof(Dirtab)) #define QSHIFT 4 /* location in qid of proc slot # */
1990/11211		#define QID(q) (((q).path&0x0000000F)>>0) #define SLOT(q) ((((q).path&0x0FFFFFFF0)>>QSHIFT)-1) #define PID(q) ((q).vers)
1990/03091		int procgen(Chan *c, Dirtab *tab, int ntab, int s, Dir *dp) { Proc *p; char buf[NAMELEN]; ulong pid;
1990/11211		if(c->qid.path == CHDIR){
1990/03091		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/03091		return 1; } if(s >= NPROC) return -1; if(tab) panic("procgen"); tab = &procdir[s];
1990/11211		devdir(c, (Qid){(~CHDIR)&(c->qid.path|tab->qid.path), c->qid.vers}, tab->name, tab->length, tab->perm, dp);
1990/03091		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) { Chan *c; 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/1106		Pgrp *pg;
1990/03091		Orig *o; Chan *tc;
1990/11211		if(c->qid.path == CHDIR){
1990/03091		if(omode != OREAD)
1990/11211		error(Eperm);
1990/03091		goto done; } p = proctab(SLOT(c->qid));
1990/1106		pg = p->pgrp;
1990/11211		if(p->pid != PID(c->qid))
1990/03091		Died:
1990/11211		error(Eprocdied);
1990/03091		omode = openmode(omode); switch(QID(c->qid)){ case Qtext: o = p->seg[TSEG].o; if(o==0 || p->state==Dead) goto Died; tc = o->chan; if(tc == 0) goto Died; if(incref(tc) == 0){ Close: close(tc); goto Died; } if(!(tc->flag&COPEN) || tc->mode!=OREAD) goto Close;
1990/11211		if(p->pid != PID(c->qid))
1990/03091		goto Close; qlock(tc); tc->offset = 0; qunlock(tc); return tc; case Qctl: case Qnote: break;
1990/1106		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/1106		break;
1990/03091		case Qdir: case Qmem: case Qproc: case Qstatus:
1990/1106		if(omode != OREAD)
1990/11211		error(Eperm);
1990/03091		break; default: pprint("unknown qid in devopen\n");
1990/11211		error(Egreg);
1990/03091		} /* * Affix pid to qid */ if(p->state != Dead)
1990/11211		c->qid.vers = p->pid;
1990/03091		done: 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/03091		} void procremove(Chan *c) {
1990/11211		error(Eperm);
1990/03091		} void procwstat(Chan *c, char *db) {
1990/11211		error(Eperm);
1990/03091		} void procclose(Chan * c) { } long procread(Chan *c, void *va, long n) { char *a = va, *b; char statbuf[2*NAMELEN+12+6*12]; Proc *p; Seg *s; Orig *o; Page *pg;
1990/06021		KMap *k;
1990/05313		PTE *pte, *opte;
1990/03091		int i; long l; long pid; User *up;
1990/11211		if(c->qid.path & CHDIR)
1990/03091		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/03091		switch(QID(c->qid)){ case Qmem: /* * One page at a time */ if(((c->offset+n)&~(BY2PG-1)) != (c->offset&~(BY2PG-1))) n = BY2PG - (c->offset&(BY2PG-1)); s = seg(p, c->offset); if(s){ o = s->o; if(o == 0)
1990/11211		error(Eprocdied);
1990/03091		lock(o);
1990/11211		if(s->o!=o || p->pid!=PID(c->qid)){
1990/03091		unlock(o);
1990/11211		error(Eprocdied);
1990/03091		} if(seg(p, c->offset) != s){ unlock(o);
1990/11211		error(Egreg);
1990/03091		}
1990/05313		pte = &o->pte[(c->offset-o->va)>>PGSHIFT]; if(s->mod){ opte = pte; while(pte = pte->nextmod) /* assign = */ if(pte->proc == p) break; if(pte == 0) pte = opte; } pg = pte->page;
1990/03091		unlock(o); if(pg == 0){
1990/05313		pprint("nonresident page addr %lux (complain to rob)\n", c->offset);
1990/03091		memset(a, 0, n); }else{
1990/06021		k = kmap(pg);
1990/0614		b = (char*)VA(k);
1990/03091		memcpy(a, b+(c->offset&(BY2PG-1)), n);
1990/06021		kunmap(k);
1990/03091		} return n; } /* u area */
1990/0617		if(c->offset>=USERADDR && c->offset<USERADDR+BY2PG){
1990/03091		if(c->offset+n > USERADDR+BY2PG) n = USERADDR+BY2PG - c->offset; pg = p->upage;
1990/11211		if(pg==0 || p->pid!=PID(c->qid)) error(Eprocdied);
1990/06021		k = kmap(pg);
1990/0614		b = (char*)VA(k);
1990/03091		memcpy(a, b+(c->offset-USERADDR), n);
1990/06021		kunmap(k);
1990/03091		return n; } /* kernel memory. BUG: shouldn't be so easygoing. BUG: mem mapping? */
1990/06021		if(c->offset>=KZERO && c->offset<KZERO+conf.npage0*BY2PG){ if(c->offset+n > KZERO+conf.npage0*BY2PG) n = KZERO+conf.npage0*BY2PG - c->offset;
1990/03091		memcpy(a, (char*)c->offset, n); return n; } 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/06021		k = kmap(p->upage);
1990/0614		up = (User*)VA(k);
1990/03091		if(up->p != p){
1990/06021		kunmap(k);
1990/03091		pprint("note read u/p mismatch");
1990/11211		error(Egreg);
1990/03091		} if(n < ERRLEN)
1990/11211		error(Etoosmall);
1990/03091		if(up->nnote == 0) n = 0; else{ memcpy(va, up->note[0].msg, ERRLEN); up->nnote--; memcpy(&up->note[0], &up->note[1], up->nnote*sizeof(Note)); n = ERRLEN; }
1990/06021		kunmap(k);
1990/03091		unlock(&p->debug); return n; case Qproc: if(c->offset >= sizeof(Proc)) return 0; if(c->offset+n > sizeof(Proc)) n = sizeof(Proc) - c->offset; memcpy(a, ((char*)p)+c->offset, n); return n; case Qstatus: if(c->offset >= sizeof statbuf) return 0; if(c->offset+n > sizeof statbuf) n = sizeof statbuf - c->offset; sprint(statbuf, "%-27s %-27s %-11s ", p->text, p->pgrp->user, statename[p->state]); for(i=0; i<6; i++){ l = p->time[i]; if(i == TReal) l = MACHP(0)->ticks - l;
1990/06111		l = TK2MS(l);
1990/03091		readnum(0, statbuf+2*NAMELEN+12+NUMSIZE*i, NUMSIZE, l, NUMSIZE); } memcpy(a, statbuf+c->offset, n); return n; }
1990/11211		error(Egreg);
1990/03091		} long procwrite(Chan *c, void *va, long n) { Proc *p;
1990/1106		Pgrp *pg;
1990/03091		User *up;
1990/06021		KMap *k;
1990/03091		char buf[ERRLEN];
1990/11211		if(c->qid.path & CHDIR) error(Eisdir);
1990/1106		/* * Special case: don't worry about process, just use remembered group */ if(QID(c->qid) == Qnotepg){
1990/11211		pg = pgrptab(c->pgrpid.path-1);
1990/1106		lock(&pg->debug); if(waserror()){ unlock(&pg->debug); nexterror(); }
1990/11211		if(pg->pgrpid != c->pgrpid.vers){
1990/1106		unlock(&pg->debug); goto Died; } pgrpnote(pg, va, n, NUser); unlock(&pg->debug); return n; }
1990/03091		p = proctab(SLOT(c->qid)); lock(&p->debug); if(waserror()){ unlock(&p->debug); nexterror(); }
1990/11211		if(p->pid != PID(c->qid))
1990/03091		Died:
1990/11211		error(Eprocdied);
1990/03091		switch(QID(c->qid)){ case Qctl: if(p->state==Broken && n>=4 && strncmp(va, "exit", 4)==0) ready(p); else
1990/11211		error(Ebadctl);
1990/03091		break; case Qnote:
1990/06021		k = kmap(p->upage);
1990/0614		up = (User*)VA(k);
1990/03091		if(up->p != p){
1990/06021		kunmap(k);
1990/03091		pprint("note write u/p mismatch");
1990/11211		error(Egreg);
1990/03091		}
1990/06021		kunmap(k);
1990/03091		if(n >= ERRLEN-1)
1990/11211		error(Etoobig);
1990/03091		if(n>=4 && strncmp(va, "sys:", 4)==0)
1990/11211		error(Ebadarg);
1990/03091		memcpy(buf, va, n); buf[n] = 0; if(!postnote(p, 0, buf, NUser))
1990/11211		error(Enonote);
1990/03091		break; default: pprint("unknown qid in procwrite\n");
1990/11211		error(Egreg);
1990/03091		} unlock(&p->debug); return n; }