1 #include "threadimpl.h"
2 #include <signal.h>
3 
4 typedef struct Mainarg Mainarg;
5 struct Mainarg
6 {
7 	int	argc;
8 	char	**argv;
9 };
10 
11 int	mainstacksize;
12 int	_threadnotefd;
13 int	_threadpasserpid;
14 static void mainlauncher(void*);
15 extern void (*_sysfatal)(char*, va_list);
16 
17 void
18 _threaddie(int x)
19 {
20 	extern char *_threadexitsallstatus;
21 	USED(x);
22 
23 	if(_threadexitsallstatus)
24 		exit(_threadexitsallstatus[0] ? 1 : 0);
25 }
26 
27 int
28 main(int argc, char **argv)
29 {
30 	Mainarg *a;
31 	Proc *p;
32 
33 	signal(SIGTERM, _threaddie);
34 //	rfork(RFREND);
35 
36 //_threaddebuglevel = (DBGSCHED|DBGCHAN|DBGREND)^~0;
37 	_systhreadinit();
38 	_qlockinit(_threadrendezvous);
39 	_sysfatal = _threadsysfatal;
40 //	notify(_threadnote);
41 	if(mainstacksize == 0)
42 		mainstacksize = 32*1024;
43 
44 	a = _threadmalloc(sizeof *a, 1);
45 	a->argc = argc;
46 	a->argv = argv;
47 
48 	p = _newproc(mainlauncher, a, mainstacksize, "threadmain", 0, 0);
49 	_schedinit(p);
50 	abort();	/* not reached */
51 	return 0;
52 }
53 
54 static void
55 mainlauncher(void *arg)
56 {
57 	Mainarg *a;
58 
59 	a = arg;
60 	threadmain(a->argc, a->argv);
61 	threadexits("threadmain");
62 }
63 
64 void
65 _threadsignal(void)
66 {
67 }
68 
69 void
70 _threadsignalpasser(void)
71 {
72 }
73 
74 int
75 _schedfork(Proc *p)
76 {
77 	return ffork(RFMEM|RFNOWAIT, _schedinit, p);
78 }
79 
80 void
81 _schedexit(Proc *p)
82 {
83 	char ex[ERRMAX];
84 	Proc **l;
85 
86 	lock(&_threadpq.lock);
87 	for(l=&_threadpq.head; *l; l=&(*l)->next){
88 		if(*l == p){
89 			*l = p->next;
90 			if(*l == nil)
91 				_threadpq.tail = l;
92 			break;
93 		}
94 	}
95 	unlock(&_threadpq.lock);
96 
97 	strncpy(ex, p->exitstr, sizeof ex);
98 	ex[sizeof ex-1] = '\0';
99 	free(p);
100 	_exit(ex[0]);
101 }
102 
103 int
104 nrand(int n)
105 {
106 	return random()%n;
107 }
108 
109 void
110 _systhreadinit(void)
111 {
112 }
113 
114 void
115 threadstats(void)
116 {
117 	extern int _threadnrendez, _threadhighnrendez,
118 		_threadnalt, _threadhighnentry;
119 	fprint(2, "*** THREAD LIBRARY STATS ***\n");
120 	fprint(2, "nrendez %d high simultaneous %d\n", 
121 		_threadnrendez, _threadhighnrendez);
122 	fprint(2, "nalt %d high simultaneous entry %d\n",
123 		_threadnalt, _threadhighnentry);
124 }