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;
}