1 be22ae2d 2004-03-26 devnull #include <u.h>
2 76193d7c 2003-09-30 devnull #include <signal.h>
3 cd7ddc9b 2003-11-23 devnull #include "threadimpl.h"
5 76193d7c 2003-09-30 devnull typedef struct Mainarg Mainarg;
6 76193d7c 2003-09-30 devnull struct Mainarg
9 76193d7c 2003-09-30 devnull char **argv;
12 76193d7c 2003-09-30 devnull int mainstacksize;
13 76193d7c 2003-09-30 devnull int _threadnotefd;
14 76193d7c 2003-09-30 devnull int _threadpasserpid;
15 76193d7c 2003-09-30 devnull static void mainlauncher(void*);
16 76193d7c 2003-09-30 devnull extern void (*_sysfatal)(char*, va_list);
19 02a1a5c1 2004-03-05 devnull _threadstatus(int x)
22 02a1a5c1 2004-03-05 devnull threadstatus();
26 76193d7c 2003-09-30 devnull _threaddie(int x)
28 76193d7c 2003-09-30 devnull extern char *_threadexitsallstatus;
31 76193d7c 2003-09-30 devnull if(_threadexitsallstatus)
32 1be1539e 2004-05-23 devnull _exit(_threadexitsallstatus[0] ? 1 : 0);
36 76193d7c 2003-09-30 devnull main(int argc, char **argv)
38 76193d7c 2003-09-30 devnull Mainarg *a;
41 76193d7c 2003-09-30 devnull //_threaddebuglevel = (DBGSCHED|DBGCHAN|DBGREND)^~0;
42 76193d7c 2003-09-30 devnull _systhreadinit();
43 76193d7c 2003-09-30 devnull _qlockinit(_threadrendezvous);
44 76193d7c 2003-09-30 devnull _sysfatal = _threadsysfatal;
45 32f69c36 2003-12-11 devnull notify(_threadnote);
46 76193d7c 2003-09-30 devnull if(mainstacksize == 0)
47 76193d7c 2003-09-30 devnull mainstacksize = 32*1024;
49 76193d7c 2003-09-30 devnull a = _threadmalloc(sizeof *a, 1);
50 76193d7c 2003-09-30 devnull a->argc = argc;
51 76193d7c 2003-09-30 devnull a->argv = argv;
53 76193d7c 2003-09-30 devnull p = _newproc(mainlauncher, a, mainstacksize, "threadmain", 0, 0);
54 76193d7c 2003-09-30 devnull _schedinit(p);
55 76193d7c 2003-09-30 devnull abort(); /* not reached */
56 76193d7c 2003-09-30 devnull return 0;
59 76193d7c 2003-09-30 devnull static void
60 76193d7c 2003-09-30 devnull mainlauncher(void *arg)
62 76193d7c 2003-09-30 devnull Mainarg *a;
65 76193d7c 2003-09-30 devnull threadmain(a->argc, a->argv);
66 76193d7c 2003-09-30 devnull threadexits("threadmain");
70 76193d7c 2003-09-30 devnull _threadsignal(void)
75 76193d7c 2003-09-30 devnull _threadsignalpasser(void)
80 76193d7c 2003-09-30 devnull _schedfork(Proc *p)
83 cd7ddc9b 2003-11-23 devnull lock(&p->lock);
84 cd7ddc9b 2003-11-23 devnull pid = ffork(RFMEM|RFNOWAIT, _schedinit, p);
85 cd7ddc9b 2003-11-23 devnull p->pid = pid;
86 cd7ddc9b 2003-11-23 devnull unlock(&p->lock);
87 cd7ddc9b 2003-11-23 devnull return pid;
92 76193d7c 2003-09-30 devnull _schedexit(Proc *p)
94 76193d7c 2003-09-30 devnull char ex[ERRMAX];
95 76193d7c 2003-09-30 devnull Proc **l;
97 76193d7c 2003-09-30 devnull lock(&_threadpq.lock);
98 76193d7c 2003-09-30 devnull for(l=&_threadpq.head; *l; l=&(*l)->next){
99 76193d7c 2003-09-30 devnull if(*l == p){
100 76193d7c 2003-09-30 devnull *l = p->next;
101 76193d7c 2003-09-30 devnull if(*l == nil)
102 76193d7c 2003-09-30 devnull _threadpq.tail = l;
106 32f69c36 2003-12-11 devnull _threadprocs--;
107 76193d7c 2003-09-30 devnull unlock(&_threadpq.lock);
109 76193d7c 2003-09-30 devnull strncpy(ex, p->exitstr, sizeof ex);
110 76193d7c 2003-09-30 devnull ex[sizeof ex-1] = '\0';
111 76193d7c 2003-09-30 devnull free(p);
112 76193d7c 2003-09-30 devnull _exit(ex[0]);
116 76193d7c 2003-09-30 devnull nrand(int n)
118 76193d7c 2003-09-30 devnull return random()%n;
122 76193d7c 2003-09-30 devnull _systhreadinit(void)
127 76193d7c 2003-09-30 devnull threadstats(void)
129 76193d7c 2003-09-30 devnull extern int _threadnrendez, _threadhighnrendez,
130 76193d7c 2003-09-30 devnull _threadnalt, _threadhighnentry;
131 76193d7c 2003-09-30 devnull fprint(2, "*** THREAD LIBRARY STATS ***\n");
132 76193d7c 2003-09-30 devnull fprint(2, "nrendez %d high simultaneous %d\n",
133 76193d7c 2003-09-30 devnull _threadnrendez, _threadhighnrendez);
134 76193d7c 2003-09-30 devnull fprint(2, "nalt %d high simultaneous entry %d\n",
135 76193d7c 2003-09-30 devnull _threadnalt, _threadhighnentry);