1 1544f909 2004-12-25 devnull #include "threadimpl.h"
3 1544f909 2004-12-25 devnull int _threaddebuglevel;
5 1544f909 2004-12-25 devnull static uint threadnproc;
6 1544f909 2004-12-25 devnull static uint threadnsysproc;
7 1544f909 2004-12-25 devnull static Lock threadnproclock;
8 1544f909 2004-12-25 devnull static Ref threadidref;
9 4dbefdd4 2004-12-27 devnull static Proc *threadmainproc;
10 baef953d 2020-05-18 rsc static int pthreadperthread;
12 4dbefdd4 2004-12-27 devnull static void addproc(Proc*);
13 4dbefdd4 2004-12-27 devnull static void delproc(Proc*);
14 1544f909 2004-12-25 devnull static void addthread(_Threadlist*, _Thread*);
15 1544f909 2004-12-25 devnull static void delthread(_Threadlist*, _Thread*);
16 df970459 2006-06-26 devnull static int onlist(_Threadlist*, _Thread*);
17 1544f909 2004-12-25 devnull static void addthreadinproc(Proc*, _Thread*);
18 1544f909 2004-12-25 devnull static void delthreadinproc(Proc*, _Thread*);
19 1544f909 2004-12-25 devnull static void contextswitch(Context *from, Context *to);
20 0158bcee 2020-01-12 rsc static void procmain(Proc*);
21 1fdb4a54 2005-01-23 devnull static void procscheduler(Proc*);
22 6dde87f8 2005-09-26 devnull static int threadinfo(void*, char*);
24 2c87dda8 2004-12-28 devnull static void
25 2c87dda8 2004-12-28 devnull _threaddebug(char *fmt, ...)
27 2c87dda8 2004-12-28 devnull va_list arg;
28 2c87dda8 2004-12-28 devnull char buf[128];
29 2c87dda8 2004-12-28 devnull _Thread *t;
31 af89fc10 2005-01-06 devnull static int fd = -1;
33 5b092791 2005-09-26 devnull if(_threaddebuglevel == 0)
36 af89fc10 2005-01-06 devnull if(fd < 0){
37 af89fc10 2005-01-06 devnull p = strrchr(argv0, '/');
41 af89fc10 2005-01-06 devnull p = argv0;
42 af89fc10 2005-01-06 devnull snprint(buf, sizeof buf, "/tmp/%s.tlog", p);
43 af89fc10 2005-01-06 devnull if((fd = create(buf, OWRITE, 0666)) < 0)
44 af89fc10 2005-01-06 devnull fd = open("/dev/null", OWRITE);
45 d93cc14e 2006-06-12 devnull if(fd >= 0 && fd != 2){
46 d93cc14e 2006-06-12 devnull dup(fd, 2);
47 d93cc14e 2006-06-12 devnull close(fd);
52 2c87dda8 2004-12-28 devnull va_start(arg, fmt);
53 2c87dda8 2004-12-28 devnull vsnprint(buf, sizeof buf, fmt, arg);
54 2c87dda8 2004-12-28 devnull va_end(arg);
55 2c87dda8 2004-12-28 devnull t = proc()->thread;
57 162d0d5c 2020-05-18 rsc fprint(fd, "%p %d.%d: %s\n", proc(), getpid(), t->id, buf);
59 162d0d5c 2020-05-18 rsc fprint(fd, "%p %d._: %s\n", proc(), getpid(), buf);
62 1544f909 2004-12-25 devnull static _Thread*
63 1544f909 2004-12-25 devnull getthreadnow(void)
65 1544f909 2004-12-25 devnull return proc()->thread;
67 1544f909 2004-12-25 devnull _Thread *(*threadnow)(void) = getthreadnow;
69 1544f909 2004-12-25 devnull static Proc*
70 1544f909 2004-12-25 devnull procalloc(void)
74 1544f909 2004-12-25 devnull p = malloc(sizeof *p);
75 73722a8b 2004-12-27 devnull if(p == nil)
76 73722a8b 2004-12-27 devnull sysfatal("procalloc malloc: %r");
77 1544f909 2004-12-25 devnull memset(p, 0, sizeof *p);
78 4dbefdd4 2004-12-27 devnull addproc(p);
79 1544f909 2004-12-25 devnull lock(&threadnproclock);
80 1544f909 2004-12-25 devnull threadnproc++;
81 1544f909 2004-12-25 devnull unlock(&threadnproclock);
82 1544f909 2004-12-25 devnull return p;
85 1544f909 2004-12-25 devnull static void
86 86502504 2005-01-18 devnull threadstart(uint y, uint x)
88 1544f909 2004-12-25 devnull _Thread *t;
91 04e0a9bb 2011-10-14 rsc //print("threadstart\n");
92 df1ee4e1 2008-06-01 rsc z = (ulong)x << 16; /* hide undefined 32-bit shift from 32-bit compilers */
93 86502504 2005-01-18 devnull z <<= 16;
95 86502504 2005-01-18 devnull t = (_Thread*)z;
97 fc567f47 2011-08-02 rsc //print("threadstart sp=%p arg=%p startfn=%p t=%p\n", &t, t, t->startfn, t->startarg);
98 1544f909 2004-12-25 devnull t->startfn(t->startarg);
99 cbeb0b26 2006-04-01 devnull /*print("threadexits %p\n", v); */
100 4dbefdd4 2004-12-27 devnull threadexits(nil);
101 cbeb0b26 2006-04-01 devnull /*print("not reacehd\n"); */
104 1544f909 2004-12-25 devnull static _Thread*
105 1544f909 2004-12-25 devnull threadalloc(void (*fn)(void*), void *arg, uint stack)
107 1544f909 2004-12-25 devnull _Thread *t;
108 1544f909 2004-12-25 devnull sigset_t zero;
109 86502504 2005-01-18 devnull uint x, y;
110 86502504 2005-01-18 devnull ulong z;
112 1544f909 2004-12-25 devnull /* allocate the task and stack together */
113 8c573cab 2020-01-14 rsc t = malloc(sizeof *t);
114 73722a8b 2004-12-27 devnull if(t == nil)
115 73722a8b 2004-12-27 devnull sysfatal("threadalloc malloc: %r");
116 1544f909 2004-12-25 devnull memset(t, 0, sizeof *t);
117 1544f909 2004-12-25 devnull t->id = incref(&threadidref);
118 fc567f47 2011-08-02 rsc //print("fn=%p arg=%p\n", fn, arg);
119 1544f909 2004-12-25 devnull t->startfn = fn;
120 1544f909 2004-12-25 devnull t->startarg = arg;
121 fc567f47 2011-08-02 rsc //print("makecontext sp=%p t=%p startfn=%p\n", (char*)t->stk+t->stksize, t, t->startfn);
123 1544f909 2004-12-25 devnull /* do a reasonable initialization */
124 0158bcee 2020-01-12 rsc if(stack == 0)
126 8c573cab 2020-01-14 rsc t->stk = _threadstkalloc(stack);
127 8c573cab 2020-01-14 rsc if(t->stk == nil)
128 8c573cab 2020-01-14 rsc sysfatal("threadalloc malloc stack: %r");
129 0158bcee 2020-01-12 rsc t->stksize = stack;
130 1544f909 2004-12-25 devnull memset(&t->context.uc, 0, sizeof t->context.uc);
131 1544f909 2004-12-25 devnull sigemptyset(&zero);
132 1544f909 2004-12-25 devnull sigprocmask(SIG_BLOCK, &zero, &t->context.uc.uc_sigmask);
133 fc567f47 2011-08-02 rsc //print("makecontext sp=%p t=%p startfn=%p\n", (char*)t->stk+t->stksize, t, t->startfn);
135 d54ead7f 2004-12-28 devnull /* must initialize with current context */
136 37cc72d3 2005-01-11 devnull if(getcontext(&t->context.uc) < 0)
137 37cc72d3 2005-01-11 devnull sysfatal("threadalloc getcontext: %r");
138 fc567f47 2011-08-02 rsc //print("makecontext sp=%p t=%p startfn=%p\n", (char*)t->stk+t->stksize, t, t->startfn);
141 4197af41 2020-01-24 rsc * Call makecontext to do the real work.
142 4197af41 2020-01-24 rsc * To avoid various mistakes on other system software,
143 4197af41 2020-01-24 rsc * debuggers, and so on, don't get too close to both
144 4197af41 2020-01-24 rsc * ends of the stack. Just staying away is much easier
145 4197af41 2020-01-24 rsc * than debugging everything (outside our control)
146 4197af41 2020-01-24 rsc * that has off-by-one errors.
148 4197af41 2020-01-24 rsc t->context.uc.uc_stack.ss_sp = (void*)(t->stk+64);
149 4197af41 2020-01-24 rsc t->context.uc.uc_stack.ss_size = t->stksize-2*64;
150 d08f4066 2005-07-27 devnull #if defined(__sun__) && !defined(__MAKECONTEXT_V2_SOURCE) /* sigh */
151 37cc72d3 2005-01-11 devnull /* can avoid this with __MAKECONTEXT_V2_SOURCE but only on SunOS 5.9 */
152 fa325e9b 2020-01-10 cross t->context.uc.uc_stack.ss_sp =
153 2b3b1e89 2005-01-14 devnull (char*)t->context.uc.uc_stack.ss_sp
154 2b3b1e89 2005-01-14 devnull +t->context.uc.uc_stack.ss_size;
157 86502504 2005-01-18 devnull * All this magic is because you have to pass makecontext a
158 86502504 2005-01-18 devnull * function that takes some number of word-sized variables,
159 86502504 2005-01-18 devnull * and on 64-bit machines pointers are bigger than words.
161 fc567f47 2011-08-02 rsc //print("makecontext sp=%p t=%p startfn=%p\n", (char*)t->stk+t->stksize, t, t->startfn);
162 86502504 2005-01-18 devnull z = (ulong)t;
164 86502504 2005-01-18 devnull z >>= 16; /* hide undefined 32-bit shift from 32-bit compilers */
165 86502504 2005-01-18 devnull x = z>>16;
166 2b604081 2005-05-07 devnull makecontext(&t->context.uc, (void(*)(void))threadstart, 2, y, x);
168 1544f909 2004-12-25 devnull return t;
171 1544f909 2004-12-25 devnull _Thread*
172 1544f909 2004-12-25 devnull _threadcreate(Proc *p, void (*fn)(void*), void *arg, uint stack)
174 1544f909 2004-12-25 devnull _Thread *t;
176 0829f75b 2009-08-18 rsc /* defend against bad C libraries */
177 0829f75b 2009-08-18 rsc if(stack < (256<<10))
178 0829f75b 2009-08-18 rsc stack = 256<<10;
180 baef953d 2020-05-18 rsc if(p->nthread == 0 || pthreadperthread)
181 0158bcee 2020-01-12 rsc stack = 0; // not using it
182 1544f909 2004-12-25 devnull t = threadalloc(fn, arg, stack);
183 1544f909 2004-12-25 devnull t->proc = p;
184 baef953d 2020-05-18 rsc if(p->nthread == 0)
185 baef953d 2020-05-18 rsc p->thread0 = t;
186 baef953d 2020-05-18 rsc else if(pthreadperthread)
187 baef953d 2020-05-18 rsc _threadpthreadstart(p, t);
188 1544f909 2004-12-25 devnull p->nthread++;
189 baef953d 2020-05-18 rsc addthreadinproc(p, t);
190 1544f909 2004-12-25 devnull _threadready(t);
191 1544f909 2004-12-25 devnull return t;
195 1544f909 2004-12-25 devnull threadcreate(void (*fn)(void*), void *arg, uint stack)
197 1544f909 2004-12-25 devnull _Thread *t;
199 1544f909 2004-12-25 devnull t = _threadcreate(proc(), fn, arg, stack);
200 1544f909 2004-12-25 devnull return t->id;
204 1544f909 2004-12-25 devnull proccreate(void (*fn)(void*), void *arg, uint stack)
207 1544f909 2004-12-25 devnull _Thread *t;
208 1544f909 2004-12-25 devnull Proc *p;
210 1544f909 2004-12-25 devnull p = procalloc();
211 1544f909 2004-12-25 devnull t = _threadcreate(p, fn, arg, stack);
212 803292c6 2005-01-18 devnull id = t->id; /* t might be freed after _procstart */
213 0158bcee 2020-01-12 rsc _procstart(p, procmain);
214 803292c6 2005-01-18 devnull return id;
217 baef953d 2020-05-18 rsc // For pthreadperthread mode, procswitch flips
218 baef953d 2020-05-18 rsc // between the threads.
220 baef953d 2020-05-18 rsc procswitch(Proc *p, _Thread *from, _Thread *to)
222 162d0d5c 2020-05-18 rsc _threaddebug("procswitch %p %d %d", p, from?from->id:-1, to?to->id:-1);
223 baef953d 2020-05-18 rsc lock(&p->schedlock);
224 baef953d 2020-05-18 rsc from->schedrend.l = &p->schedlock;
226 baef953d 2020-05-18 rsc p->schedthread = to;
227 baef953d 2020-05-18 rsc to->schedrend.l = &p->schedlock;
228 162d0d5c 2020-05-18 rsc _threaddebug("procswitch wakeup %p %d", p, to->id);
229 baef953d 2020-05-18 rsc _procwakeup(&to->schedrend);
231 baef953d 2020-05-18 rsc if(p->schedthread != from) {
232 baef953d 2020-05-18 rsc if(from->exiting) {
233 baef953d 2020-05-18 rsc unlock(&p->schedlock);
234 baef953d 2020-05-18 rsc _threadpexit();
235 162d0d5c 2020-05-18 rsc _threaddebug("procswitch exit wakeup!!!\n");
237 162d0d5c 2020-05-18 rsc while(p->schedthread != from) {
238 162d0d5c 2020-05-18 rsc _threaddebug("procswitch sleep %p %d", p, from->id);
239 162d0d5c 2020-05-18 rsc _procsleep(&from->schedrend);
240 162d0d5c 2020-05-18 rsc _threaddebug("procswitch awake %p %d", p, from->id);
242 162d0d5c 2020-05-18 rsc if(p->schedthread != from)
243 162d0d5c 2020-05-18 rsc sysfatal("_procswitch %p %p oops", p->schedthread, from);
245 baef953d 2020-05-18 rsc unlock(&p->schedlock);
249 1544f909 2004-12-25 devnull _threadswitch(void)
251 1544f909 2004-12-25 devnull Proc *p;
253 c8b6342d 2005-01-13 devnull needstack(0);
254 1544f909 2004-12-25 devnull p = proc();
256 cbeb0b26 2006-04-01 devnull /*print("threadswtch %p\n", p); */
258 baef953d 2020-05-18 rsc if(p->thread == p->thread0)
259 0158bcee 2020-01-12 rsc procscheduler(p);
260 baef953d 2020-05-18 rsc else if(pthreadperthread)
261 baef953d 2020-05-18 rsc procswitch(p, p->thread, p->thread0);
263 0158bcee 2020-01-12 rsc contextswitch(&p->thread->context, &p->schedcontext);
267 1544f909 2004-12-25 devnull _threadready(_Thread *t)
269 1544f909 2004-12-25 devnull Proc *p;
271 1544f909 2004-12-25 devnull p = t->proc;
272 1544f909 2004-12-25 devnull lock(&p->lock);
273 a0a331aa 2005-01-06 devnull p->runrend.l = &p->lock;
274 1544f909 2004-12-25 devnull addthread(&p->runqueue, t);
275 cbeb0b26 2006-04-01 devnull /*print("%d wake for job %d->%d\n", time(0), getpid(), p->osprocid); */
276 8cbd854a 2004-12-27 devnull if(p != proc())
277 a0a331aa 2005-01-06 devnull _procwakeupandunlock(&p->runrend);
279 a0a331aa 2005-01-06 devnull unlock(&p->lock);
283 615e0f9f 2006-02-07 devnull threadidle(void)
286 615e0f9f 2006-02-07 devnull Proc *p;
288 615e0f9f 2006-02-07 devnull p = proc();
289 615e0f9f 2006-02-07 devnull n = p->nswitch;
290 615e0f9f 2006-02-07 devnull lock(&p->lock);
291 615e0f9f 2006-02-07 devnull p->runrend.l = &p->lock;
292 615e0f9f 2006-02-07 devnull addthread(&p->idlequeue, p->thread);
293 615e0f9f 2006-02-07 devnull unlock(&p->lock);
294 615e0f9f 2006-02-07 devnull _threadswitch();
295 615e0f9f 2006-02-07 devnull return p->nswitch - n;
299 1544f909 2004-12-25 devnull threadyield(void)
302 8cbd854a 2004-12-27 devnull Proc *p;
304 8cbd854a 2004-12-27 devnull p = proc();
305 8cbd854a 2004-12-27 devnull n = p->nswitch;
306 8cbd854a 2004-12-27 devnull _threadready(p->thread);
307 1544f909 2004-12-25 devnull _threadswitch();
308 8cbd854a 2004-12-27 devnull return p->nswitch - n;
312 1544f909 2004-12-25 devnull threadexits(char *msg)
314 1544f909 2004-12-25 devnull Proc *p;
316 1544f909 2004-12-25 devnull p = proc();
317 4dbefdd4 2004-12-27 devnull if(msg == nil)
318 4dbefdd4 2004-12-27 devnull msg = "";
319 1544f909 2004-12-25 devnull utfecpy(p->msg, p->msg+sizeof p->msg, msg);
320 4dbefdd4 2004-12-27 devnull proc()->thread->exiting = 1;
321 4dbefdd4 2004-12-27 devnull _threadswitch();
325 df970459 2006-06-26 devnull threadpin(void)
327 df970459 2006-06-26 devnull Proc *p;
329 df970459 2006-06-26 devnull p = proc();
330 df970459 2006-06-26 devnull if(p->pinthread){
331 df970459 2006-06-26 devnull fprint(2, "already pinning a thread - %p %p\n", p->pinthread, p->thread);
332 df970459 2006-06-26 devnull assert(0);
334 df970459 2006-06-26 devnull p->pinthread = p->thread;
338 df970459 2006-06-26 devnull threadunpin(void)
340 df970459 2006-06-26 devnull Proc *p;
342 df970459 2006-06-26 devnull p = proc();
343 df970459 2006-06-26 devnull if(p->pinthread != p->thread){
344 df970459 2006-06-26 devnull fprint(2, "wrong pinthread - %p %p\n", p->pinthread, p->thread);
345 df970459 2006-06-26 devnull assert(0);
347 df970459 2006-06-26 devnull p->pinthread = nil;
351 d19769ae 2008-10-26 rsc threadsysfatal(char *fmt, va_list arg)
353 69d1259c 2008-07-20 devnull char buf[256];
355 69d1259c 2008-07-20 devnull vseprint(buf, buf+sizeof(buf), fmt, arg);
356 69d1259c 2008-07-20 devnull __fixargv0();
357 69d1259c 2008-07-20 devnull fprint(2, "%s: %s\n", argv0 ? argv0 : "<prog>", buf);
358 69d1259c 2008-07-20 devnull threadexitsall(buf);
361 1544f909 2004-12-25 devnull static void
362 1544f909 2004-12-25 devnull contextswitch(Context *from, Context *to)
364 1544f909 2004-12-25 devnull if(swapcontext(&from->uc, &to->uc) < 0){
365 1544f909 2004-12-25 devnull fprint(2, "swapcontext failed: %r\n");
366 1544f909 2004-12-25 devnull assert(0);
370 1544f909 2004-12-25 devnull static void
371 0158bcee 2020-01-12 rsc procmain(Proc *p)
375 0158bcee 2020-01-12 rsc _threadsetproc(p);
377 0158bcee 2020-01-12 rsc /* take out first thread to run on system stack */
378 0158bcee 2020-01-12 rsc t = p->runqueue.head;
379 0158bcee 2020-01-12 rsc delthread(&p->runqueue, t);
380 0158bcee 2020-01-12 rsc memset(&t->context.uc, 0, sizeof t->context.uc);
382 0158bcee 2020-01-12 rsc /* run it */
383 0158bcee 2020-01-12 rsc p->thread = t;
384 0158bcee 2020-01-12 rsc t->startfn(t->startarg);
385 0158bcee 2020-01-12 rsc if(p->nthread != 0)
386 0158bcee 2020-01-12 rsc threadexits(nil);
390 baef953d 2020-05-18 rsc _threadpthreadmain(Proc *p, _Thread *t)
392 baef953d 2020-05-18 rsc _threadsetproc(p);
393 baef953d 2020-05-18 rsc procswitch(p, t, nil);
394 baef953d 2020-05-18 rsc t->startfn(t->startarg);
395 baef953d 2020-05-18 rsc threadexits(nil);
399 1fdb4a54 2005-01-23 devnull procscheduler(Proc *p)
401 1544f909 2004-12-25 devnull _Thread *t;
403 2c87dda8 2004-12-28 devnull _threaddebug("scheduler enter");
404 04e0a9bb 2011-10-14 rsc //print("s %p\n", p);
406 1544f909 2004-12-25 devnull lock(&p->lock);
407 0158bcee 2020-01-12 rsc t = p->thread;
408 0158bcee 2020-01-12 rsc p->thread = nil;
409 0158bcee 2020-01-12 rsc if(t->exiting){
410 0158bcee 2020-01-12 rsc delthreadinproc(p, t);
411 0158bcee 2020-01-12 rsc p->nthread--;
412 0158bcee 2020-01-12 rsc /*print("nthread %d\n", p->nthread); */
413 8c573cab 2020-01-14 rsc _threadstkfree(t->stk, t->stksize);
417 1544f909 2004-12-25 devnull for(;;){
418 df970459 2006-06-26 devnull if((t = p->pinthread) != nil){
419 df970459 2006-06-26 devnull while(!onlist(&p->runqueue, t)){
420 df970459 2006-06-26 devnull p->runrend.l = &p->lock;
421 df970459 2006-06-26 devnull _threaddebug("scheduler sleep (pin)");
422 df970459 2006-06-26 devnull _procsleep(&p->runrend);
423 df970459 2006-06-26 devnull _threaddebug("scheduler wake (pin)");
426 1544f909 2004-12-25 devnull while((t = p->runqueue.head) == nil){
427 1544f909 2004-12-25 devnull if(p->nthread == 0)
428 1544f909 2004-12-25 devnull goto Out;
429 615e0f9f 2006-02-07 devnull if((t = p->idlequeue.head) != nil){
431 615e0f9f 2006-02-07 devnull * Run all the idling threads once.
433 615e0f9f 2006-02-07 devnull while((t = p->idlequeue.head) != nil){
434 615e0f9f 2006-02-07 devnull delthread(&p->idlequeue, t);
435 615e0f9f 2006-02-07 devnull addthread(&p->runqueue, t);
437 615e0f9f 2006-02-07 devnull continue;
439 1544f909 2004-12-25 devnull p->runrend.l = &p->lock;
440 2c87dda8 2004-12-28 devnull _threaddebug("scheduler sleep");
441 1544f909 2004-12-25 devnull _procsleep(&p->runrend);
442 2c87dda8 2004-12-28 devnull _threaddebug("scheduler wake");
444 df970459 2006-06-26 devnull if(p->pinthread && p->pinthread != t)
445 df970459 2006-06-26 devnull fprint(2, "p->pinthread %p t %p\n", p->pinthread, t);
446 df970459 2006-06-26 devnull assert(p->pinthread == nil || p->pinthread == t);
447 1544f909 2004-12-25 devnull delthread(&p->runqueue, t);
448 1544f909 2004-12-25 devnull unlock(&p->lock);
449 1544f909 2004-12-25 devnull p->thread = t;
450 8cbd854a 2004-12-27 devnull p->nswitch++;
451 2c87dda8 2004-12-28 devnull _threaddebug("run %d (%s)", t->id, t->name);
452 04e0a9bb 2011-10-14 rsc //print("run %p %p %p %p\n", t, *(uintptr*)(t->context.uc.mc.sp), t->context.uc.mc.di, t->context.uc.mc.si);
453 baef953d 2020-05-18 rsc if(t == p->thread0)
455 baef953d 2020-05-18 rsc if(pthreadperthread)
456 baef953d 2020-05-18 rsc procswitch(p, p->thread0, t);
458 baef953d 2020-05-18 rsc contextswitch(&p->schedcontext, &t->context);
459 162d0d5c 2020-05-18 rsc _threaddebug("back in scheduler");
460 cbeb0b26 2006-04-01 devnull /*print("back in scheduler\n"); */
465 2c87dda8 2004-12-28 devnull _threaddebug("scheduler exit");
466 8ee6ad4d 2005-02-14 devnull if(p->mainproc){
468 8ee6ad4d 2005-02-14 devnull * Stupid bug - on Linux 2.6 and maybe elsewhere,
469 8ee6ad4d 2005-02-14 devnull * if the main thread exits then the others keep running
470 8ee6ad4d 2005-02-14 devnull * but the process shows up as a zombie in ps and is not
471 8ee6ad4d 2005-02-14 devnull * attachable with ptrace. We'll just sit around pretending
472 8ee6ad4d 2005-02-14 devnull * to be a system proc instead of exiting.
474 8ee6ad4d 2005-02-14 devnull _threaddaemonize();
475 8ee6ad4d 2005-02-14 devnull lock(&threadnproclock);
476 8ee6ad4d 2005-02-14 devnull if(++threadnsysproc == threadnproc)
477 8ee6ad4d 2005-02-14 devnull threadexitsall(p->msg);
478 8ee6ad4d 2005-02-14 devnull p->sysproc = 1;
479 8ee6ad4d 2005-02-14 devnull unlock(&threadnproclock);
481 8ee6ad4d 2005-02-14 devnull sleep(1000);
484 4dbefdd4 2004-12-27 devnull delproc(p);
485 1544f909 2004-12-25 devnull lock(&threadnproclock);
486 1544f909 2004-12-25 devnull if(p->sysproc)
487 1544f909 2004-12-25 devnull --threadnsysproc;
488 1544f909 2004-12-25 devnull if(--threadnproc == threadnsysproc)
489 4dbefdd4 2004-12-27 devnull threadexitsall(p->msg);
490 1544f909 2004-12-25 devnull unlock(&threadnproclock);
491 1544f909 2004-12-25 devnull unlock(&p->lock);
492 d93cc14e 2006-06-12 devnull _threadsetproc(nil);
493 1544f909 2004-12-25 devnull free(p);
494 481b596d 2020-01-14 rsc _threadpexit();
498 1544f909 2004-12-25 devnull _threadsetsysproc(void)
500 1544f909 2004-12-25 devnull lock(&threadnproclock);
501 1544f909 2004-12-25 devnull if(++threadnsysproc == threadnproc)
502 8ee6ad4d 2005-02-14 devnull threadexitsall(nil);
503 1544f909 2004-12-25 devnull unlock(&threadnproclock);
504 1544f909 2004-12-25 devnull proc()->sysproc = 1;
508 4dbefdd4 2004-12-27 devnull procdata(void)
510 4dbefdd4 2004-12-27 devnull return &proc()->udata;
514 8dd8a81f 2005-03-18 devnull threaddata(void)
516 8dd8a81f 2005-03-18 devnull return &proc()->thread->udata;
519 4dbefdd4 2004-12-27 devnull extern Jmp *(*_notejmpbuf)(void);
520 4dbefdd4 2004-12-27 devnull static Jmp*
521 4dbefdd4 2004-12-27 devnull threadnotejmp(void)
523 4dbefdd4 2004-12-27 devnull return &proc()->sigjmp;
527 1544f909 2004-12-25 devnull * debugging
530 1544f909 2004-12-25 devnull threadsetname(char *fmt, ...)
532 1544f909 2004-12-25 devnull va_list arg;
533 1544f909 2004-12-25 devnull _Thread *t;
535 1544f909 2004-12-25 devnull t = proc()->thread;
536 1544f909 2004-12-25 devnull va_start(arg, fmt);
537 1544f909 2004-12-25 devnull vsnprint(t->name, sizeof t->name, fmt, arg);
538 1544f909 2004-12-25 devnull va_end(arg);
542 515b6e5b 2005-01-18 devnull threadgetname(void)
544 515b6e5b 2005-01-18 devnull return proc()->thread->name;
548 1544f909 2004-12-25 devnull threadsetstate(char *fmt, ...)
550 1544f909 2004-12-25 devnull va_list arg;
551 1544f909 2004-12-25 devnull _Thread *t;
553 1544f909 2004-12-25 devnull t = proc()->thread;
554 1544f909 2004-12-25 devnull va_start(arg, fmt);
555 1544f909 2004-12-25 devnull vsnprint(t->state, sizeof t->name, fmt, arg);
556 1544f909 2004-12-25 devnull va_end(arg);
560 9eda38e5 2006-02-05 devnull threadid(void)
562 9eda38e5 2006-02-05 devnull _Thread *t;
564 9eda38e5 2006-02-05 devnull t = proc()->thread;
565 9eda38e5 2006-02-05 devnull return t->id;
569 c8b6342d 2005-01-13 devnull needstack(int n)
571 c8b6342d 2005-01-13 devnull _Thread *t;
573 c8b6342d 2005-01-13 devnull t = proc()->thread;
574 8c573cab 2020-01-14 rsc if(t->stk == nil)
577 c8b6342d 2005-01-13 devnull if((char*)&t <= (char*)t->stk
578 c8b6342d 2005-01-13 devnull || (char*)&t - (char*)t->stk < 256+n){
579 1fdb4a54 2005-01-23 devnull fprint(2, "thread stack overflow: &t=%p tstk=%p n=%d\n", &t, t->stk, 256+n);
580 c8b6342d 2005-01-13 devnull abort();
585 faf1fb6c 2008-07-09 rsc singlethreaded(void)
587 faf1fb6c 2008-07-09 rsc return threadnproc == 1 && _threadprocs->nthread == 1;
591 1544f909 2004-12-25 devnull * locking
593 1544f909 2004-12-25 devnull static int
594 1544f909 2004-12-25 devnull threadqlock(QLock *l, int block, ulong pc)
596 cbeb0b26 2006-04-01 devnull /*print("threadqlock %p\n", l); */
597 1544f909 2004-12-25 devnull lock(&l->l);
598 1544f909 2004-12-25 devnull if(l->owner == nil){
599 1544f909 2004-12-25 devnull l->owner = (*threadnow)();
600 cbeb0b26 2006-04-01 devnull /*print("qlock %p @%#x by %p\n", l, pc, l->owner); */
601 162d0d5c 2020-05-18 rsc if(l->owner == nil) {
602 162d0d5c 2020-05-18 rsc fprint(2, "%s: qlock uncontended owner=nil oops\n", argv0);
605 1544f909 2004-12-25 devnull unlock(&l->l);
606 1544f909 2004-12-25 devnull return 1;
608 1544f909 2004-12-25 devnull if(!block){
609 1544f909 2004-12-25 devnull unlock(&l->l);
610 1544f909 2004-12-25 devnull return 0;
613 faf1fb6c 2008-07-09 rsc if(singlethreaded()){
614 faf1fb6c 2008-07-09 rsc fprint(2, "qlock deadlock\n");
618 cbeb0b26 2006-04-01 devnull /*print("qsleep %p @%#x by %p\n", l, pc, (*threadnow)()); */
619 1544f909 2004-12-25 devnull addthread(&l->waiting, (*threadnow)());
620 1544f909 2004-12-25 devnull unlock(&l->l);
622 1544f909 2004-12-25 devnull _threadswitch();
624 1544f909 2004-12-25 devnull if(l->owner != (*threadnow)()){
625 15cd8255 2005-01-04 devnull fprint(2, "%s: qlock pc=0x%lux owner=%p self=%p oops\n",
626 15cd8255 2005-01-04 devnull argv0, pc, l->owner, (*threadnow)());
627 1544f909 2004-12-25 devnull abort();
629 162d0d5c 2020-05-18 rsc if(l->owner == nil) {
630 162d0d5c 2020-05-18 rsc fprint(2, "%s: qlock threadswitch owner=nil oops\n", argv0);
634 cbeb0b26 2006-04-01 devnull /*print("qlock wakeup %p @%#x by %p\n", l, pc, (*threadnow)()); */
635 1544f909 2004-12-25 devnull return 1;
638 1544f909 2004-12-25 devnull static void
639 1544f909 2004-12-25 devnull threadqunlock(QLock *l, ulong pc)
641 80b8842f 2005-02-15 devnull _Thread *ready;
643 1544f909 2004-12-25 devnull lock(&l->l);
644 cbeb0b26 2006-04-01 devnull /*print("qlock unlock %p @%#x by %p (owner %p)\n", l, pc, (*threadnow)(), l->owner); */
645 1aa9c533 2005-01-07 devnull if(l->owner == 0){
646 15cd8255 2005-01-04 devnull fprint(2, "%s: qunlock pc=0x%lux owner=%p self=%p oops\n",
647 15cd8255 2005-01-04 devnull argv0, pc, l->owner, (*threadnow)());
648 1aa9c533 2005-01-07 devnull abort();
650 80b8842f 2005-02-15 devnull if((l->owner = ready = l->waiting.head) != nil)
651 1544f909 2004-12-25 devnull delthread(&l->waiting, l->owner);
653 80b8842f 2005-02-15 devnull * N.B. Cannot call _threadready() before unlocking l->l,
654 80b8842f 2005-02-15 devnull * because the thread we are readying might:
655 80b8842f 2005-02-15 devnull * - be in another proc
656 80b8842f 2005-02-15 devnull * - start running immediately
657 80b8842f 2005-02-15 devnull * - and free l before we get a chance to run again
659 1544f909 2004-12-25 devnull unlock(&l->l);
660 80b8842f 2005-02-15 devnull if(ready)
661 80b8842f 2005-02-15 devnull _threadready(l->owner);
664 1544f909 2004-12-25 devnull static int
665 1544f909 2004-12-25 devnull threadrlock(RWLock *l, int block, ulong pc)
667 1544f909 2004-12-25 devnull USED(pc);
669 1544f909 2004-12-25 devnull lock(&l->l);
670 1544f909 2004-12-25 devnull if(l->writer == nil && l->wwaiting.head == nil){
671 1544f909 2004-12-25 devnull l->readers++;
672 1544f909 2004-12-25 devnull unlock(&l->l);
673 1544f909 2004-12-25 devnull return 1;
675 1544f909 2004-12-25 devnull if(!block){
676 1544f909 2004-12-25 devnull unlock(&l->l);
677 1544f909 2004-12-25 devnull return 0;
679 faf1fb6c 2008-07-09 rsc if(singlethreaded()){
680 faf1fb6c 2008-07-09 rsc fprint(2, "rlock deadlock\n");
683 1544f909 2004-12-25 devnull addthread(&l->rwaiting, (*threadnow)());
684 1544f909 2004-12-25 devnull unlock(&l->l);
685 1544f909 2004-12-25 devnull _threadswitch();
689 1544f909 2004-12-25 devnull static int
690 1544f909 2004-12-25 devnull threadwlock(RWLock *l, int block, ulong pc)
692 1544f909 2004-12-25 devnull USED(pc);
694 1544f909 2004-12-25 devnull lock(&l->l);
695 1544f909 2004-12-25 devnull if(l->writer == nil && l->readers == 0){
696 1544f909 2004-12-25 devnull l->writer = (*threadnow)();
697 1544f909 2004-12-25 devnull unlock(&l->l);
698 1544f909 2004-12-25 devnull return 1;
700 1544f909 2004-12-25 devnull if(!block){
701 1544f909 2004-12-25 devnull unlock(&l->l);
702 1544f909 2004-12-25 devnull return 0;
704 faf1fb6c 2008-07-09 rsc if(singlethreaded()){
705 faf1fb6c 2008-07-09 rsc fprint(2, "wlock deadlock\n");
708 1544f909 2004-12-25 devnull addthread(&l->wwaiting, (*threadnow)());
709 1544f909 2004-12-25 devnull unlock(&l->l);
710 1544f909 2004-12-25 devnull _threadswitch();
711 1544f909 2004-12-25 devnull return 1;
714 1544f909 2004-12-25 devnull static void
715 1544f909 2004-12-25 devnull threadrunlock(RWLock *l, ulong pc)
717 1544f909 2004-12-25 devnull _Thread *t;
719 1544f909 2004-12-25 devnull USED(pc);
720 80b8842f 2005-02-15 devnull t = nil;
721 1544f909 2004-12-25 devnull lock(&l->l);
722 1544f909 2004-12-25 devnull --l->readers;
723 1544f909 2004-12-25 devnull if(l->readers == 0 && (t = l->wwaiting.head) != nil){
724 1544f909 2004-12-25 devnull delthread(&l->wwaiting, t);
725 1544f909 2004-12-25 devnull l->writer = t;
727 1544f909 2004-12-25 devnull unlock(&l->l);
729 80b8842f 2005-02-15 devnull _threadready(t);
733 1544f909 2004-12-25 devnull static void
734 1544f909 2004-12-25 devnull threadwunlock(RWLock *l, ulong pc)
736 1544f909 2004-12-25 devnull _Thread *t;
738 1544f909 2004-12-25 devnull USED(pc);
739 1544f909 2004-12-25 devnull lock(&l->l);
740 1544f909 2004-12-25 devnull l->writer = nil;
741 1544f909 2004-12-25 devnull assert(l->readers == 0);
742 1544f909 2004-12-25 devnull while((t = l->rwaiting.head) != nil){
743 1544f909 2004-12-25 devnull delthread(&l->rwaiting, t);
744 1544f909 2004-12-25 devnull l->readers++;
745 1544f909 2004-12-25 devnull _threadready(t);
747 80b8842f 2005-02-15 devnull t = nil;
748 1544f909 2004-12-25 devnull if(l->readers == 0 && (t = l->wwaiting.head) != nil){
749 1544f909 2004-12-25 devnull delthread(&l->wwaiting, t);
750 1544f909 2004-12-25 devnull l->writer = t;
752 1544f909 2004-12-25 devnull unlock(&l->l);
754 80b8842f 2005-02-15 devnull _threadready(t);
758 1544f909 2004-12-25 devnull * sleep and wakeup
760 1544f909 2004-12-25 devnull static void
761 1544f909 2004-12-25 devnull threadrsleep(Rendez *r, ulong pc)
763 faf1fb6c 2008-07-09 rsc if(singlethreaded()){
764 faf1fb6c 2008-07-09 rsc fprint(2, "rsleep deadlock\n");
767 1544f909 2004-12-25 devnull addthread(&r->waiting, proc()->thread);
768 1544f909 2004-12-25 devnull qunlock(r->l);
769 1544f909 2004-12-25 devnull _threadswitch();
770 1544f909 2004-12-25 devnull qlock(r->l);
773 1544f909 2004-12-25 devnull static int
774 1544f909 2004-12-25 devnull threadrwakeup(Rendez *r, int all, ulong pc)
777 1544f909 2004-12-25 devnull _Thread *t;
779 1544f909 2004-12-25 devnull for(i=0;; i++){
780 1544f909 2004-12-25 devnull if(i==1 && !all)
782 1544f909 2004-12-25 devnull if((t = r->waiting.head) == nil)
784 1544f909 2004-12-25 devnull delthread(&r->waiting, t);
785 fa325e9b 2020-01-10 cross _threadready(t);
787 1544f909 2004-12-25 devnull return i;
791 4dbefdd4 2004-12-27 devnull * startup
794 4dbefdd4 2004-12-27 devnull static int threadargc;
795 4dbefdd4 2004-12-27 devnull static char **threadargv;
796 4dbefdd4 2004-12-27 devnull int mainstacksize;
797 d93cc14e 2006-06-12 devnull extern int _p9usepwlibrary; /* getgrgid etc. smash the stack - tell _p9dir just say no */
798 4dbefdd4 2004-12-27 devnull static void
799 4dbefdd4 2004-12-27 devnull threadmainstart(void *v)
801 4dbefdd4 2004-12-27 devnull USED(v);
804 0b561695 2005-01-16 devnull * N.B. This call to proc() is a program's first call (indirectly) to a
805 0b561695 2005-01-16 devnull * pthreads function while executing on a non-pthreads-allocated
806 0b561695 2005-01-16 devnull * stack. If the pthreads implementation is using the stack pointer
807 0b561695 2005-01-16 devnull * to locate the per-thread data, then this call will blow up.
808 0b561695 2005-01-16 devnull * This means the pthread implementation is not suitable for
809 0b561695 2005-01-16 devnull * running under libthread. Time to write your own. Sorry.
811 d93cc14e 2006-06-12 devnull _p9usepwlibrary = 0;
812 4dbefdd4 2004-12-27 devnull threadmainproc = proc();
813 4dbefdd4 2004-12-27 devnull threadmain(threadargc, threadargv);
816 d19769ae 2008-10-26 rsc extern void (*_sysfatal)(char*, va_list);
819 4dbefdd4 2004-12-27 devnull main(int argc, char **argv)
821 4dbefdd4 2004-12-27 devnull Proc *p;
824 1d2533d0 2004-12-28 devnull argv0 = argv[0];
826 baef953d 2020-05-18 rsc opts = getenv("LIBTHREAD");
827 baef953d 2020-05-18 rsc if(opts == nil)
830 baef953d 2020-05-18 rsc pthreadperthread = (strstr(opts, "pthreadperthread") != nil);
831 baef953d 2020-05-18 rsc #ifdef PLAN9PORT_ASAN
832 baef953d 2020-05-18 rsc // ASAN can't deal with the coroutine stack switches.
833 baef953d 2020-05-18 rsc // In theory it has support for informing it about stack switches,
834 baef953d 2020-05-18 rsc // but even with those calls added it can't deal with things
835 baef953d 2020-05-18 rsc // like fork or exit from a coroutine stack.
836 baef953d 2020-05-18 rsc // Easier to just run in pthread-per-thread mode.
837 baef953d 2020-05-18 rsc pthreadperthread = 1;
839 162d0d5c 2020-05-18 rsc if(strstr(opts, "nodaemon") == nil && getenv("NOLIBTHREADDAEMONIZE") == nil)
840 615e0f9f 2006-02-07 devnull _threadsetupdaemonize();
842 4dbefdd4 2004-12-27 devnull threadargc = argc;
843 4dbefdd4 2004-12-27 devnull threadargv = argv;
846 4dbefdd4 2004-12-27 devnull * Install locking routines into C library.
848 4dbefdd4 2004-12-27 devnull _lock = _threadlock;
849 4dbefdd4 2004-12-27 devnull _unlock = _threadunlock;
850 4dbefdd4 2004-12-27 devnull _qlock = threadqlock;
851 4dbefdd4 2004-12-27 devnull _qunlock = threadqunlock;
852 4dbefdd4 2004-12-27 devnull _rlock = threadrlock;
853 4dbefdd4 2004-12-27 devnull _runlock = threadrunlock;
854 4dbefdd4 2004-12-27 devnull _wlock = threadwlock;
855 4dbefdd4 2004-12-27 devnull _wunlock = threadwunlock;
856 4dbefdd4 2004-12-27 devnull _rsleep = threadrsleep;
857 4dbefdd4 2004-12-27 devnull _rwakeup = threadrwakeup;
858 4dbefdd4 2004-12-27 devnull _notejmpbuf = threadnotejmp;
859 df970459 2006-06-26 devnull _pin = threadpin;
860 df970459 2006-06-26 devnull _unpin = threadunpin;
861 69d1259c 2008-07-20 devnull _sysfatal = threadsysfatal;
863 4dbefdd4 2004-12-27 devnull _pthreadinit();
864 4dbefdd4 2004-12-27 devnull p = procalloc();
865 8ee6ad4d 2005-02-14 devnull p->mainproc = 1;
866 4dbefdd4 2004-12-27 devnull _threadsetproc(p);
867 4dbefdd4 2004-12-27 devnull if(mainstacksize == 0)
868 a0e8d02d 2005-01-23 devnull mainstacksize = 256*1024;
869 af6e459f 2006-04-21 devnull atnotify(threadinfo, 1);
870 4dbefdd4 2004-12-27 devnull _threadcreate(p, threadmainstart, nil, mainstacksize);
871 0158bcee 2020-01-12 rsc procmain(p);
872 d7688cce 2005-02-16 devnull sysfatal("procscheduler returned in threadmain!");
873 8ee6ad4d 2005-02-14 devnull /* does not return */
874 15cd8255 2005-01-04 devnull return 0;
878 1544f909 2004-12-25 devnull * hooray for linked lists
880 1544f909 2004-12-25 devnull static void
881 1544f909 2004-12-25 devnull addthread(_Threadlist *l, _Thread *t)
883 1544f909 2004-12-25 devnull if(l->tail){
884 1544f909 2004-12-25 devnull l->tail->next = t;
885 1544f909 2004-12-25 devnull t->prev = l->tail;
887 1544f909 2004-12-25 devnull l->head = t;
888 1544f909 2004-12-25 devnull t->prev = nil;
890 1544f909 2004-12-25 devnull l->tail = t;
891 1544f909 2004-12-25 devnull t->next = nil;
894 1544f909 2004-12-25 devnull static void
895 1544f909 2004-12-25 devnull delthread(_Threadlist *l, _Thread *t)
897 1544f909 2004-12-25 devnull if(t->prev)
898 1544f909 2004-12-25 devnull t->prev->next = t->next;
900 1544f909 2004-12-25 devnull l->head = t->next;
901 1544f909 2004-12-25 devnull if(t->next)
902 1544f909 2004-12-25 devnull t->next->prev = t->prev;
904 1544f909 2004-12-25 devnull l->tail = t->prev;
907 df970459 2006-06-26 devnull /* inefficient but rarely used */
908 df970459 2006-06-26 devnull static int
909 df970459 2006-06-26 devnull onlist(_Threadlist *l, _Thread *t)
911 df970459 2006-06-26 devnull _Thread *tt;
913 df970459 2006-06-26 devnull for(tt = l->head; tt; tt=tt->next)
914 df970459 2006-06-26 devnull if(tt == t)
915 df970459 2006-06-26 devnull return 1;
916 df970459 2006-06-26 devnull return 0;
919 1544f909 2004-12-25 devnull static void
920 1544f909 2004-12-25 devnull addthreadinproc(Proc *p, _Thread *t)
922 1544f909 2004-12-25 devnull _Threadlist *l;
924 1544f909 2004-12-25 devnull l = &p->allthreads;
925 1544f909 2004-12-25 devnull if(l->tail){
926 1544f909 2004-12-25 devnull l->tail->allnext = t;
927 1544f909 2004-12-25 devnull t->allprev = l->tail;
929 1544f909 2004-12-25 devnull l->head = t;
930 1544f909 2004-12-25 devnull t->allprev = nil;
932 1544f909 2004-12-25 devnull l->tail = t;
933 1544f909 2004-12-25 devnull t->allnext = nil;
936 1544f909 2004-12-25 devnull static void
937 1544f909 2004-12-25 devnull delthreadinproc(Proc *p, _Thread *t)
939 1544f909 2004-12-25 devnull _Threadlist *l;
941 1544f909 2004-12-25 devnull l = &p->allthreads;
942 1544f909 2004-12-25 devnull if(t->allprev)
943 1544f909 2004-12-25 devnull t->allprev->allnext = t->allnext;
945 1544f909 2004-12-25 devnull l->head = t->allnext;
946 1544f909 2004-12-25 devnull if(t->allnext)
947 1544f909 2004-12-25 devnull t->allnext->allprev = t->allprev;
949 1544f909 2004-12-25 devnull l->tail = t->allprev;
952 4dbefdd4 2004-12-27 devnull Proc *_threadprocs;
953 4dbefdd4 2004-12-27 devnull Lock _threadprocslock;
954 4dbefdd4 2004-12-27 devnull static Proc *_threadprocstail;
956 1544f909 2004-12-25 devnull static void
957 4dbefdd4 2004-12-27 devnull addproc(Proc *p)
959 4dbefdd4 2004-12-27 devnull lock(&_threadprocslock);
960 4dbefdd4 2004-12-27 devnull if(_threadprocstail){
961 4dbefdd4 2004-12-27 devnull _threadprocstail->next = p;
962 4dbefdd4 2004-12-27 devnull p->prev = _threadprocstail;
964 4dbefdd4 2004-12-27 devnull _threadprocs = p;
965 4dbefdd4 2004-12-27 devnull p->prev = nil;
967 4dbefdd4 2004-12-27 devnull _threadprocstail = p;
968 4dbefdd4 2004-12-27 devnull p->next = nil;
969 4dbefdd4 2004-12-27 devnull unlock(&_threadprocslock);
972 4dbefdd4 2004-12-27 devnull static void
973 4dbefdd4 2004-12-27 devnull delproc(Proc *p)
975 4dbefdd4 2004-12-27 devnull lock(&_threadprocslock);
976 4dbefdd4 2004-12-27 devnull if(p->prev)
977 4dbefdd4 2004-12-27 devnull p->prev->next = p->next;
979 4dbefdd4 2004-12-27 devnull _threadprocs = p->next;
980 4dbefdd4 2004-12-27 devnull if(p->next)
981 4dbefdd4 2004-12-27 devnull p->next->prev = p->prev;
983 4dbefdd4 2004-12-27 devnull _threadprocstail = p->prev;
984 4dbefdd4 2004-12-27 devnull unlock(&_threadprocslock);
988 15cd8255 2005-01-04 devnull * notify - for now just use the usual mechanisms
991 15cd8255 2005-01-04 devnull threadnotify(int (*f)(void*, char*), int in)
993 15cd8255 2005-01-04 devnull atnotify(f, in);
996 6dde87f8 2005-09-26 devnull static int
997 6dde87f8 2005-09-26 devnull onrunqueue(Proc *p, _Thread *t)
999 6dde87f8 2005-09-26 devnull _Thread *tt;
1001 6dde87f8 2005-09-26 devnull for(tt=p->runqueue.head; tt; tt=tt->next)
1002 6dde87f8 2005-09-26 devnull if(tt == t)
1003 6dde87f8 2005-09-26 devnull return 1;
1004 6dde87f8 2005-09-26 devnull return 0;
1008 6dde87f8 2005-09-26 devnull * print state - called from SIGINFO
1010 6dde87f8 2005-09-26 devnull static int
1011 6dde87f8 2005-09-26 devnull threadinfo(void *v, char *s)
1013 6dde87f8 2005-09-26 devnull Proc *p;
1014 6dde87f8 2005-09-26 devnull _Thread *t;
1016 6dde87f8 2005-09-26 devnull if(strcmp(s, "quit") != 0 && strcmp(s, "sys: status request") != 0)
1017 6dde87f8 2005-09-26 devnull return 0;
1019 6dde87f8 2005-09-26 devnull for(p=_threadprocs; p; p=p->next){
1020 6dde87f8 2005-09-26 devnull fprint(2, "proc %p %s%s\n", (void*)p->osprocid, p->msg,
1021 6dde87f8 2005-09-26 devnull p->sysproc ? " (sysproc)": "");
1022 6dde87f8 2005-09-26 devnull for(t=p->allthreads.head; t; t=t->allnext){
1023 fa325e9b 2020-01-10 cross fprint(2, "\tthread %d %s: %s %s\n",
1025 fa325e9b 2020-01-10 cross t == p->thread ? "Running" :
1026 6dde87f8 2005-09-26 devnull onrunqueue(p, t) ? "Ready" : "Sleeping",
1027 6dde87f8 2005-09-26 devnull t->state, t->name);
1030 6dde87f8 2005-09-26 devnull return 1;
