/*  * This file is part of the UCB release of Plan 9. It is subject to the license * terms in the LICENSE file found in the top-level directory of this * distribution and at http://akaros.cs.berkeley.edu/files/Plan9License. No * part of the UCB release of Plan 9, including this file, may be copied, * modified, propagated, or distributed except according to the terms contained * in the LICENSE file. */ #include <u.h>#include <libc.h>#include <thread.h>#include "threadimpl.h" static void tinterrupt(Proc*, Thread*); static voidthreadxxxgrp(int grp, int dokill){	Proc *p;	Thread *t; 	lock(&_threadpq.lock);	for(p=_threadpq.head; p; p=p->next){		lock(&p->lock);		for(t=p->threads.head; t; t=t->nextt)			if(t->grp == grp){				if(dokill)					t->moribund = 1;				tinterrupt(p, t);			}		unlock(&p->lock);	}	unlock(&_threadpq.lock);	_threadbreakrendez();} static voidthreadxxx(int id, int dokill){	Proc *p;	Thread *t; 	lock(&_threadpq.lock);	for(p=_threadpq.head; p; p=p->next){		lock(&p->lock);		for(t=p->threads.head; t; t=t->nextt)			if(t->id == id){				if(dokill)					t->moribund = 1;				tinterrupt(p, t);				unlock(&p->lock);				unlock(&_threadpq.lock);				_threadbreakrendez();				return;			}		unlock(&p->lock);	}	unlock(&_threadpq.lock);	_threaddebug(DBGNOTE, "Can't find thread to kill");	return;} voidthreadkillgrp(int grp){	threadxxxgrp(grp, 1);} voidthreadkill(int id){	threadxxx(id, 1);} voidthreadintgrp(int grp){	threadxxxgrp(grp, 0);} voidthreadint(int id){	threadxxx(id, 0);} static voidtinterrupt(Proc *p, Thread *t){	switch(t->state){	case Running:		postnote(PNPROC, p->pid, "threadint");		break;	case Rendezvous:		_threadflagrendez(t);		break;	}}