1 #include "u.h"
2 #include <errno.h>
3 #include <sys/time.h>
4 #include <sys/types.h>
5 #include <sys/wait.h>
6 #include <sched.h>
7 #include <signal.h>
8 #include <ucontext.h>
9 #include "libc.h"
10 #include "thread.h"
11 
12 #if defined(__FreeBSD__) && __FreeBSD_version < 500000
13 extern	int		getcontext(ucontext_t*);
14 extern	void		setcontext(ucontext_t*);
15 extern	int		swapcontext(ucontext_t*, ucontext_t*);
16 extern	void		makecontext(ucontext_t*, void(*)(), int, ...);
17 #endif
18 
19 typedef struct Context Context;
20 typedef struct Execjob Execjob;
21 typedef struct Proc Proc;
22 typedef struct _Procrendez _Procrendez;
23 
24 typedef struct Jmp Jmp;
25 struct Jmp
26 {
27 	p9jmp_buf b;
28 };
29 
30 enum
31 {
32 	STACK = 8192
33 };
34 
35 struct Context
36 {
37 	ucontext_t	uc;
38 };
39 
40 struct Execjob
41 {
42 	int *fd;
43 	char *cmd;
44 	char **argv;
45 	Channel *c;
46 };
47 
48 struct _Thread
49 {
50 	_Thread	*next;
51 	_Thread	*prev;
52 	_Thread	*allnext;
53 	_Thread	*allprev;
54 	Context	context;
55 	uint	id;
56 	uchar	*stk;
57 	uint	stksize;
58 	int		exiting;
59 	void	(*startfn)(void*);
60 	void	*startarg;
61 	Proc	*proc;
62 	char	name[256];
63 	char	state[256];
64 };
65 
66 struct _Procrendez
67 {
68 	Lock		*l;
69 	int		asleep;
70 #ifdef PLAN9PORT_USING_PTHREADS
71 	pthread_cond_t	cond;
72 #else
73 	int		pid;
74 #endif
75 };
76 
77 extern	void	_procsleep(_Procrendez*);
78 extern	void	_procwakeup(_Procrendez*);
79 
80 struct Proc
81 {
82 	Proc		*next;
83 	Proc		*prev;
84 	char		msg[128];
85 #ifdef PLAN9PORT_USING_PTHREADS
86 	pthread_t	osprocid;
87 #else
88 	uint		osprocid;
89 #endif
90 	Lock		lock;
91 	int			nswitch;
92 	_Thread		*thread;
93 	_Threadlist	runqueue;
94 	_Threadlist	allthreads;
95 	uint		nthread;
96 	uint		sysproc;
97 	_Procrendez	runrend;
98 	Context	schedcontext;
99 	void		*udata;
100 	Jmp		sigjmp;
101 };
102 
103 #define proc() _threadproc()
104 #define setproc(p) _threadsetproc(p)
105 
106 extern Proc *_threadprocs;
107 extern Lock _threadprocslock;
108 extern Proc *_threadexecproc;
109 extern Channel *_threadexecchan;
110 extern QLock _threadexeclock;
111 extern Channel *_dowaitchan;
112 
113 extern void _procstart(Proc*, void (*fn)(Proc*));
114 extern _Thread *_threadcreate(Proc*, void(*fn)(void*), void*, uint);
115 extern void _threadexit(void);
116 extern Proc *_threadproc(void);
117 extern void _threadsetproc(Proc*);
118 extern int _threadlock(Lock*, int, ulong);
119 extern void _threadunlock(Lock*, ulong);
120 extern void _pthreadinit(void);
121 extern int _threadspawn(int*, char*, char**);
122 extern int _runthreadspawn(int*, char*, char**);
123 extern void _threadsetupdaemonize(void);
124 extern void _threaddodaemonize(char*);
125 extern void _threadpexit(void);