1 76193d7c 2003-09-30 devnull #include <signal.h>
2 cd7ddc9b 2003-11-23 devnull #include "threadimpl.h"
4 76193d7c 2003-09-30 devnull typedef struct Mainarg Mainarg;
5 76193d7c 2003-09-30 devnull struct Mainarg
8 76193d7c 2003-09-30 devnull char **argv;
11 76193d7c 2003-09-30 devnull int mainstacksize;
12 76193d7c 2003-09-30 devnull int _threadnotefd;
13 76193d7c 2003-09-30 devnull int _threadpasserpid;
14 76193d7c 2003-09-30 devnull static void mainlauncher(void*);
15 76193d7c 2003-09-30 devnull extern void (*_sysfatal)(char*, va_list);
18 76193d7c 2003-09-30 devnull _threaddie(int x)
20 76193d7c 2003-09-30 devnull extern char *_threadexitsallstatus;
23 76193d7c 2003-09-30 devnull if(_threadexitsallstatus)
24 76193d7c 2003-09-30 devnull exit(_threadexitsallstatus[0] ? 1 : 0);
28 76193d7c 2003-09-30 devnull main(int argc, char **argv)
30 76193d7c 2003-09-30 devnull Mainarg *a;
33 76193d7c 2003-09-30 devnull signal(SIGTERM, _threaddie);
34 76193d7c 2003-09-30 devnull // rfork(RFREND);
36 76193d7c 2003-09-30 devnull //_threaddebuglevel = (DBGSCHED|DBGCHAN|DBGREND)^~0;
37 76193d7c 2003-09-30 devnull _systhreadinit();
38 76193d7c 2003-09-30 devnull _qlockinit(_threadrendezvous);
39 76193d7c 2003-09-30 devnull _sysfatal = _threadsysfatal;
40 32f69c36 2003-12-11 devnull notify(_threadnote);
41 76193d7c 2003-09-30 devnull if(mainstacksize == 0)
42 76193d7c 2003-09-30 devnull mainstacksize = 32*1024;
44 76193d7c 2003-09-30 devnull a = _threadmalloc(sizeof *a, 1);
45 76193d7c 2003-09-30 devnull a->argc = argc;
46 76193d7c 2003-09-30 devnull a->argv = argv;
48 76193d7c 2003-09-30 devnull p = _newproc(mainlauncher, a, mainstacksize, "threadmain", 0, 0);
49 76193d7c 2003-09-30 devnull _schedinit(p);
50 76193d7c 2003-09-30 devnull abort(); /* not reached */
51 76193d7c 2003-09-30 devnull return 0;
54 76193d7c 2003-09-30 devnull static void
55 76193d7c 2003-09-30 devnull mainlauncher(void *arg)
57 76193d7c 2003-09-30 devnull Mainarg *a;
60 76193d7c 2003-09-30 devnull threadmain(a->argc, a->argv);
61 76193d7c 2003-09-30 devnull threadexits("threadmain");
65 76193d7c 2003-09-30 devnull _threadsignal(void)
70 76193d7c 2003-09-30 devnull _threadsignalpasser(void)
75 76193d7c 2003-09-30 devnull _schedfork(Proc *p)
78 cd7ddc9b 2003-11-23 devnull lock(&p->lock);
79 cd7ddc9b 2003-11-23 devnull pid = ffork(RFMEM|RFNOWAIT, _schedinit, p);
80 cd7ddc9b 2003-11-23 devnull p->pid = pid;
81 cd7ddc9b 2003-11-23 devnull unlock(&p->lock);
82 cd7ddc9b 2003-11-23 devnull return pid;
87 76193d7c 2003-09-30 devnull _schedexit(Proc *p)
89 76193d7c 2003-09-30 devnull char ex[ERRMAX];
90 76193d7c 2003-09-30 devnull Proc **l;
92 76193d7c 2003-09-30 devnull lock(&_threadpq.lock);
93 76193d7c 2003-09-30 devnull for(l=&_threadpq.head; *l; l=&(*l)->next){
94 76193d7c 2003-09-30 devnull if(*l == p){
95 76193d7c 2003-09-30 devnull *l = p->next;
96 76193d7c 2003-09-30 devnull if(*l == nil)
97 76193d7c 2003-09-30 devnull _threadpq.tail = l;
101 32f69c36 2003-12-11 devnull _threadprocs--;
102 76193d7c 2003-09-30 devnull unlock(&_threadpq.lock);
104 76193d7c 2003-09-30 devnull strncpy(ex, p->exitstr, sizeof ex);
105 76193d7c 2003-09-30 devnull ex[sizeof ex-1] = '\0';
106 76193d7c 2003-09-30 devnull free(p);
107 76193d7c 2003-09-30 devnull _exit(ex[0]);
111 76193d7c 2003-09-30 devnull nrand(int n)
113 76193d7c 2003-09-30 devnull return random()%n;
117 76193d7c 2003-09-30 devnull _systhreadinit(void)
122 76193d7c 2003-09-30 devnull threadstats(void)
124 76193d7c 2003-09-30 devnull extern int _threadnrendez, _threadhighnrendez,
125 76193d7c 2003-09-30 devnull _threadnalt, _threadhighnentry;
126 76193d7c 2003-09-30 devnull fprint(2, "*** THREAD LIBRARY STATS ***\n");
127 76193d7c 2003-09-30 devnull fprint(2, "nrendez %d high simultaneous %d\n",
128 76193d7c 2003-09-30 devnull _threadnrendez, _threadhighnrendez);
129 76193d7c 2003-09-30 devnull fprint(2, "nalt %d high simultaneous entry %d\n",
130 76193d7c 2003-09-30 devnull _threadnalt, _threadhighnentry);