Subversion Repositories planix.SVN

#include <u.h>

#include <libc.h>

#include <thread.h>

#include "threadimpl.h"

#include <tos.h>

char *_threadexitsallstatus;

Channel *_threadwaitchan;

void

threadexits(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();

}

void

threadexitsall(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;

}