72 lines · 1.3 KB · C
RawDownload
#include <u.h>#include <libc.h>#include <thread.h>#include "threadimpl.h"#include <tos.h> char *_threadexitsallstatus;Channel *_threadwaitchan; voidthreadexits(char *exitstr){	Proc *p;	Thread *t; 	p = _threadgetproc();	t = p->thread;	t->moribund = 1;	if(exitstr==nil)		exitstr="";	utfecpy(p->exitstr, p->exitstr+ERRMAX, exitstr);	_sched();} voidthreadexitsall(char *exitstr){	Proc *p;	int pid[64];	int i, npid, mypid; 	if(exitstr == nil)		exitstr = "";	_threadexitsallstatus = exitstr;	_threaddebug(DBGSCHED, "_threadexitsallstatus set to %p", _threadexitsallstatus);	mypid = _tos->pid; //getpid(); 	/*	 * signal others.	 * copying all the pids first avoids other threads	 * teardown procedures getting in the way.	 *	 * avoid mallocs since malloc can post a note which can	 * call threadexitsall...	 */	for(;;){		lock(&_threadpq.lock);		npid = 0;		for(p = _threadpq.head; p && npid < nelem(pid); p=p->next){			if(p->threadint == 0 && p->pid != mypid){				pid[npid++] = p->pid;				p->threadint = 1;			}		}		unlock(&_threadpq.lock);		if(npid == 0)			break;		for(i=0; i<npid; i++)			postnote(PNPROC, pid[i], "threadint");	} 	/* leave */	exits(exitstr);} Channel*threadwaitchan(void){	if(_threadwaitchan==nil)		_threadwaitchan = chancreate(sizeof(Waitmsg*), 16);	return _threadwaitchan;}