1993/1115/port/pgrp.c (diff list | history)

port/pgrp.c on 1990/0227
1990/0227		#include "u.h"
1992/0321		#include "../port/lib.h"
1990/0227		#include "mem.h" #include "dat.h" #include "fns.h"
1992/0111		#include "../port/error.h"
1990/0227
1992/0619		static Ref pgrpid; static Ref mountid;
1990/0227		void
1992/0428		pgrpnote(ulong noteid, char *a, long n, int flag)
1990/1110		{
1992/0428		Proc *p, *ep;
1990/1110		char buf[ERRLEN]; if(n >= ERRLEN-1)
1990/11211		error(Etoobig);
1992/0428
1991/0318		memmove(buf, a, n);
1990/1110		buf[n] = 0; p = proctab(0);
1992/0428		ep = p+conf.nproc; for(; p < ep; p++) { if(p->state == Dead) continue; if(p->noteid == noteid && p->kp == 0) {
1991/1216		qlock(&p->debug);
1992/0824		if(p->pid == 0 || p->noteid != noteid){
1991/1216		qunlock(&p->debug);
1990/1110		continue; }
1992/0824		if(!waserror()) {
1991/0125		postnote(p, 0, buf, flag); poperror();
1990/1110		}
1991/1216		qunlock(&p->debug);
1990/1110		} } } Pgrp*
1990/0227		newpgrp(void) { Pgrp *p;
1992/0824		p = smalloc(sizeof(Pgrp));
1992/0619		p->ref = 1; p->pgrpid = incref(&pgrpid); return p;
1991/0705		} void
1990/0227		closepgrp(Pgrp *p) {
1991/1011		Mhead **h, **e, *f, *next;
1990/0227		if(decref(p) == 0){
1991/0212		qlock(&p->debug);
1990/1110		p->pgrpid = -1;
1991/1011		e = &p->mnthash[MNTHASH]; for(h = p->mnthash; h < e; h++) { for(f = *h; f; f = next) { close(f->from); mountfree(f->mount); next = f->hash;
1992/0619		free(f);
1990/0227		}
1991/1011		}
1991/0212		qunlock(&p->debug);
1992/0619		free(p);
1990/0227		} }
1991/0705		void
1991/0514		pgrpcpy(Pgrp *to, Pgrp *from) {
1991/1113		Mhead **h, **e, *f, **tom, **l, *mh;
1991/1011		Mount *n, *m, **link;
1991/0514
1991/1011		rlock(&from->ns); e = &from->mnthash[MNTHASH];
1991/1113		tom = to->mnthash;
1991/1011		for(h = from->mnthash; h < e; h++) {
1991/1113		l = tom++;
1991/1011		for(f = *h; f; f = f->hash) {
1992/0619		mh = smalloc(sizeof(Mhead));
1991/1011		mh->from = f->from; incref(mh->from); *l = mh;
1991/1113		l = &mh->hash;
1991/1011		link = &mh->mount; for(m = f->mount; m; m = m->next) {
1993/0501		n = newmount(mh, m->to, m->flag, m->spec);
1991/1011		*link = n; link = &n->next; }
1991/0514		}
1991/1011		} runlock(&from->ns); }
1991/0514
1992/0824		Fgrp* dupfgrp(Fgrp *f) { Fgrp *new; Chan *c; int i; new = smalloc(sizeof(Fgrp)); new->ref = 1; lock(f); new->maxfd = f->maxfd; for(i = 0; i <= f->maxfd; i++) { if(c = f->fd[i]){ incref(c); new->fd[i] = c; } } unlock(f); return new; }
1991/1011		void
1992/0824		closefgrp(Fgrp *f) { int i; Chan *c; if(decref(f) == 0) { for(i = 0; i <= f->maxfd; i++) if(c = f->fd[i]) close(c); free(f); } } Mount*
1993/0501		newmount(Mhead *mh, Chan *to, int flag, char *spec)
1992/0824		{ Mount *m; m = smalloc(sizeof(Mount)); m->to = to; m->head = mh; incref(to); m->mountid = incref(&mountid);
1993/0501		m->flag = flag; if(spec != 0) strcpy(m->spec, spec);
1992/0824		return m; } void
1991/1011		mountfree(Mount *m) { Mount *f;
1992/0705		while(m) { f = m->next; close(m->to);
1993/0501		m->mountid = 0;
1992/0705		free(m); m = f; }
1992/0824		} void resrcwait(char *reason) { char *p;
1993/0501		if(up == 0) panic("resrcwait"); p = up->psstate;
1992/0824		if(reason) {
1993/0501		up->psstate = reason;
1992/0824		print("%s\n", reason); }
1993/0501		tsleep(&up->sleep, return0, 0, 300); up->psstate = p;
1990/0227		}