63 lines · 1.1 KB · C
RawDownload
#include "threadimpl.h"#include <signal.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;	int i, npid, mypid; 	if(exitstr == nil)		exitstr = "";	_threadexitsallstatus = exitstr;	_threaddebug(DBGSCHED, "_threadexitsallstatus set to %p", _threadexitsallstatus);	mypid = _threadgetpid(); 	/*	 * signal others.	 * copying all the pids first avoids other threads	 * teardown procedures getting in the way.	 */	lock(&_threadpq.lock);	npid = 0;	for(p=_threadpq.head; p; p=p->next)		npid++;	pid = _threadmalloc(npid*sizeof(pid[0]), 0);	npid = 0;	for(p = _threadpq.head; p; p=p->next)		pid[npid++] = p->pid;	unlock(&_threadpq.lock);	for(i=0; i<npid; i++)		if(pid[i] != mypid)			kill(pid[i], SIGTERM); 	/* leave */	exit(0);} Channel*threadwaitchan(void){	if(_threadwaitchan==nil)		_threadwaitchan = chancreate(sizeof(Waitmsg*), 16);	return _threadwaitchan;}