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;
11 4dbefdd4 2004-12-27 devnull static void addproc(Proc*);
12 4dbefdd4 2004-12-27 devnull static void delproc(Proc*);
13 1544f909 2004-12-25 devnull static void addthread(_Threadlist*, _Thread*);
14 1544f909 2004-12-25 devnull static void delthread(_Threadlist*, _Thread*);
15 1544f909 2004-12-25 devnull static void addthreadinproc(Proc*, _Thread*);
16 1544f909 2004-12-25 devnull static void delthreadinproc(Proc*, _Thread*);
17 1544f909 2004-12-25 devnull static void contextswitch(Context *from, Context *to);
18 73722a8b 2004-12-27 devnull static void scheduler(Proc*);
20 2c87dda8 2004-12-28 devnull static void
21 2c87dda8 2004-12-28 devnull _threaddebug(char *fmt, ...)
23 2c87dda8 2004-12-28 devnull va_list arg;
24 2c87dda8 2004-12-28 devnull char buf[128];
25 2c87dda8 2004-12-28 devnull _Thread *t;
29 2c87dda8 2004-12-28 devnull va_start(arg, fmt);
30 2c87dda8 2004-12-28 devnull vsnprint(buf, sizeof buf, fmt, arg);
31 2c87dda8 2004-12-28 devnull va_end(arg);
32 2c87dda8 2004-12-28 devnull t = proc()->thread;
34 2c87dda8 2004-12-28 devnull fprint(2, "%d.%d: %s\n", getpid(), t->id, buf);
36 2c87dda8 2004-12-28 devnull fprint(2, "%d._: %s\n", getpid(), buf);
39 1544f909 2004-12-25 devnull static _Thread*
40 1544f909 2004-12-25 devnull getthreadnow(void)
42 1544f909 2004-12-25 devnull return proc()->thread;
44 1544f909 2004-12-25 devnull _Thread *(*threadnow)(void) = getthreadnow;
46 1544f909 2004-12-25 devnull static Proc*
47 1544f909 2004-12-25 devnull procalloc(void)
51 1544f909 2004-12-25 devnull p = malloc(sizeof *p);
52 73722a8b 2004-12-27 devnull if(p == nil)
53 73722a8b 2004-12-27 devnull sysfatal("procalloc malloc: %r");
54 1544f909 2004-12-25 devnull memset(p, 0, sizeof *p);
55 4dbefdd4 2004-12-27 devnull addproc(p);
56 1544f909 2004-12-25 devnull lock(&threadnproclock);
57 1544f909 2004-12-25 devnull threadnproc++;
58 1544f909 2004-12-25 devnull unlock(&threadnproclock);
59 1544f909 2004-12-25 devnull return p;
62 1544f909 2004-12-25 devnull static void
63 1544f909 2004-12-25 devnull threadstart(void *v)
65 1544f909 2004-12-25 devnull _Thread *t;
68 1544f909 2004-12-25 devnull t->startfn(t->startarg);
69 2c87dda8 2004-12-28 devnull memset(&v, 0xff, 32); /* try to cut off stack traces */
70 4dbefdd4 2004-12-27 devnull threadexits(nil);
73 1544f909 2004-12-25 devnull static _Thread*
74 1544f909 2004-12-25 devnull threadalloc(void (*fn)(void*), void *arg, uint stack)
76 1544f909 2004-12-25 devnull _Thread *t;
77 1544f909 2004-12-25 devnull sigset_t zero;
79 1544f909 2004-12-25 devnull /* allocate the task and stack together */
80 1544f909 2004-12-25 devnull t = malloc(sizeof *t+stack);
81 73722a8b 2004-12-27 devnull if(t == nil)
82 73722a8b 2004-12-27 devnull sysfatal("threadalloc malloc: %r");
83 1544f909 2004-12-25 devnull memset(t, 0, sizeof *t);
84 1544f909 2004-12-25 devnull t->stk = (uchar*)(t+1);
85 1544f909 2004-12-25 devnull t->stksize = stack;
86 1544f909 2004-12-25 devnull t->id = incref(&threadidref);
87 1544f909 2004-12-25 devnull t->startfn = fn;
88 1544f909 2004-12-25 devnull t->startarg = arg;
90 1544f909 2004-12-25 devnull /* do a reasonable initialization */
91 1544f909 2004-12-25 devnull memset(&t->context.uc, 0, sizeof t->context.uc);
92 1544f909 2004-12-25 devnull sigemptyset(&zero);
93 1544f909 2004-12-25 devnull sigprocmask(SIG_BLOCK, &zero, &t->context.uc.uc_sigmask);
95 d54ead7f 2004-12-28 devnull /* must initialize with current context */
96 1544f909 2004-12-25 devnull getcontext(&t->context.uc);
98 1544f909 2004-12-25 devnull /* call makecontext to do the real work. */
99 1544f909 2004-12-25 devnull /* leave a few words open on both ends */
100 1544f909 2004-12-25 devnull t->context.uc.uc_stack.ss_sp = t->stk+8;
101 2c87dda8 2004-12-28 devnull t->context.uc.uc_stack.ss_size = t->stksize-64;
102 1544f909 2004-12-25 devnull makecontext(&t->context.uc, (void(*)())threadstart, 1, t);
104 1544f909 2004-12-25 devnull return t;
107 1544f909 2004-12-25 devnull _Thread*
108 1544f909 2004-12-25 devnull _threadcreate(Proc *p, void (*fn)(void*), void *arg, uint stack)
110 1544f909 2004-12-25 devnull _Thread *t;
112 1544f909 2004-12-25 devnull t = threadalloc(fn, arg, stack);
113 1544f909 2004-12-25 devnull t->proc = p;
114 1544f909 2004-12-25 devnull addthreadinproc(p, t);
115 1544f909 2004-12-25 devnull p->nthread++;
116 1544f909 2004-12-25 devnull _threadready(t);
117 1544f909 2004-12-25 devnull return t;
121 1544f909 2004-12-25 devnull threadcreate(void (*fn)(void*), void *arg, uint stack)
123 1544f909 2004-12-25 devnull _Thread *t;
125 1544f909 2004-12-25 devnull t = _threadcreate(proc(), fn, arg, stack);
126 1544f909 2004-12-25 devnull return t->id;
130 1544f909 2004-12-25 devnull proccreate(void (*fn)(void*), void *arg, uint stack)
132 1544f909 2004-12-25 devnull _Thread *t;
133 1544f909 2004-12-25 devnull Proc *p;
135 1544f909 2004-12-25 devnull p = procalloc();
136 1544f909 2004-12-25 devnull t = _threadcreate(p, fn, arg, stack);
137 1544f909 2004-12-25 devnull _procstart(p, scheduler);
138 1544f909 2004-12-25 devnull return t->id;
142 1544f909 2004-12-25 devnull _threadswitch(void)
144 1544f909 2004-12-25 devnull Proc *p;
146 1544f909 2004-12-25 devnull p = proc();
147 1544f909 2004-12-25 devnull contextswitch(&p->thread->context, &p->schedcontext);
151 1544f909 2004-12-25 devnull _threadready(_Thread *t)
153 1544f909 2004-12-25 devnull Proc *p;
155 1544f909 2004-12-25 devnull p = t->proc;
156 1544f909 2004-12-25 devnull lock(&p->lock);
157 1544f909 2004-12-25 devnull addthread(&p->runqueue, t);
158 8cbd854a 2004-12-27 devnull //print("%d wake for job %d->%d\n", time(0), getpid(), p->osprocid);
159 8cbd854a 2004-12-27 devnull if(p != proc())
160 8cbd854a 2004-12-27 devnull _procwakeup(&p->runrend);
161 1544f909 2004-12-25 devnull unlock(&p->lock);
165 1544f909 2004-12-25 devnull threadyield(void)
168 8cbd854a 2004-12-27 devnull Proc *p;
170 8cbd854a 2004-12-27 devnull p = proc();
171 8cbd854a 2004-12-27 devnull n = p->nswitch;
172 8cbd854a 2004-12-27 devnull _threadready(p->thread);
173 1544f909 2004-12-25 devnull _threadswitch();
174 8cbd854a 2004-12-27 devnull return p->nswitch - n;
178 1544f909 2004-12-25 devnull threadexits(char *msg)
180 1544f909 2004-12-25 devnull Proc *p;
182 1544f909 2004-12-25 devnull p = proc();
183 4dbefdd4 2004-12-27 devnull if(msg == nil)
184 4dbefdd4 2004-12-27 devnull msg = "";
185 1544f909 2004-12-25 devnull utfecpy(p->msg, p->msg+sizeof p->msg, msg);
186 4dbefdd4 2004-12-27 devnull proc()->thread->exiting = 1;
187 4dbefdd4 2004-12-27 devnull _threadswitch();
190 1544f909 2004-12-25 devnull static void
191 1544f909 2004-12-25 devnull contextswitch(Context *from, Context *to)
193 1544f909 2004-12-25 devnull if(swapcontext(&from->uc, &to->uc) < 0){
194 1544f909 2004-12-25 devnull fprint(2, "swapcontext failed: %r\n");
195 1544f909 2004-12-25 devnull assert(0);
199 1544f909 2004-12-25 devnull static void
200 73722a8b 2004-12-27 devnull scheduler(Proc *p)
202 1544f909 2004-12-25 devnull _Thread *t;
204 1544f909 2004-12-25 devnull setproc(p);
205 2c87dda8 2004-12-28 devnull _threaddebug("scheduler enter");
206 e1dc7e45 2004-12-27 devnull // print("s %p %d\n", p, gettid());
207 1544f909 2004-12-25 devnull lock(&p->lock);
208 1544f909 2004-12-25 devnull for(;;){
209 1544f909 2004-12-25 devnull while((t = p->runqueue.head) == nil){
210 1544f909 2004-12-25 devnull if(p->nthread == 0)
211 1544f909 2004-12-25 devnull goto Out;
212 1544f909 2004-12-25 devnull p->runrend.l = &p->lock;
213 2c87dda8 2004-12-28 devnull _threaddebug("scheduler sleep");
214 1544f909 2004-12-25 devnull _procsleep(&p->runrend);
215 2c87dda8 2004-12-28 devnull _threaddebug("scheduler wake");
217 1544f909 2004-12-25 devnull delthread(&p->runqueue, t);
218 1544f909 2004-12-25 devnull unlock(&p->lock);
219 1544f909 2004-12-25 devnull p->thread = t;
220 8cbd854a 2004-12-27 devnull p->nswitch++;
221 2c87dda8 2004-12-28 devnull _threaddebug("run %d (%s)", t->id, t->name);
222 1544f909 2004-12-25 devnull contextswitch(&p->schedcontext, &t->context);
223 1544f909 2004-12-25 devnull p->thread = nil;
224 1544f909 2004-12-25 devnull lock(&p->lock);
225 1544f909 2004-12-25 devnull if(t->exiting){
226 1544f909 2004-12-25 devnull delthreadinproc(p, t);
227 1544f909 2004-12-25 devnull p->nthread--;
228 1544f909 2004-12-25 devnull free(t);
233 2c87dda8 2004-12-28 devnull _threaddebug("scheduler exit");
234 4dbefdd4 2004-12-27 devnull delproc(p);
235 1544f909 2004-12-25 devnull lock(&threadnproclock);
236 1544f909 2004-12-25 devnull if(p->sysproc)
237 1544f909 2004-12-25 devnull --threadnsysproc;
238 1544f909 2004-12-25 devnull if(--threadnproc == threadnsysproc)
239 4dbefdd4 2004-12-27 devnull threadexitsall(p->msg);
240 1544f909 2004-12-25 devnull unlock(&threadnproclock);
241 1544f909 2004-12-25 devnull unlock(&p->lock);
242 1544f909 2004-12-25 devnull free(p);
243 1544f909 2004-12-25 devnull setproc(0);
247 1544f909 2004-12-25 devnull _threadsetsysproc(void)
249 1544f909 2004-12-25 devnull lock(&threadnproclock);
250 1544f909 2004-12-25 devnull if(++threadnsysproc == threadnproc)
251 1544f909 2004-12-25 devnull exit(0);
252 1544f909 2004-12-25 devnull unlock(&threadnproclock);
253 1544f909 2004-12-25 devnull proc()->sysproc = 1;
257 4dbefdd4 2004-12-27 devnull procdata(void)
259 4dbefdd4 2004-12-27 devnull return &proc()->udata;
262 4dbefdd4 2004-12-27 devnull extern Jmp *(*_notejmpbuf)(void);
263 4dbefdd4 2004-12-27 devnull static Jmp*
264 4dbefdd4 2004-12-27 devnull threadnotejmp(void)
266 4dbefdd4 2004-12-27 devnull return &proc()->sigjmp;
270 1544f909 2004-12-25 devnull * debugging
273 1544f909 2004-12-25 devnull threadsetname(char *fmt, ...)
275 1544f909 2004-12-25 devnull va_list arg;
276 1544f909 2004-12-25 devnull _Thread *t;
278 1544f909 2004-12-25 devnull t = proc()->thread;
279 1544f909 2004-12-25 devnull va_start(arg, fmt);
280 1544f909 2004-12-25 devnull vsnprint(t->name, sizeof t->name, fmt, arg);
281 1544f909 2004-12-25 devnull va_end(arg);
285 1544f909 2004-12-25 devnull threadsetstate(char *fmt, ...)
287 1544f909 2004-12-25 devnull va_list arg;
288 1544f909 2004-12-25 devnull _Thread *t;
290 1544f909 2004-12-25 devnull t = proc()->thread;
291 1544f909 2004-12-25 devnull va_start(arg, fmt);
292 1544f909 2004-12-25 devnull vsnprint(t->state, sizeof t->name, fmt, arg);
293 1544f909 2004-12-25 devnull va_end(arg);
297 1544f909 2004-12-25 devnull * locking
299 1544f909 2004-12-25 devnull static int
300 1544f909 2004-12-25 devnull threadqlock(QLock *l, int block, ulong pc)
302 1544f909 2004-12-25 devnull lock(&l->l);
303 1544f909 2004-12-25 devnull if(l->owner == nil){
304 1544f909 2004-12-25 devnull l->owner = (*threadnow)();
305 1544f909 2004-12-25 devnull //print("qlock %p @%#x by %p\n", l, pc, l->owner);
306 1544f909 2004-12-25 devnull unlock(&l->l);
307 1544f909 2004-12-25 devnull return 1;
309 1544f909 2004-12-25 devnull if(!block){
310 1544f909 2004-12-25 devnull unlock(&l->l);
311 1544f909 2004-12-25 devnull return 0;
313 1544f909 2004-12-25 devnull //print("qsleep %p @%#x by %p\n", l, pc, (*threadnow)());
314 1544f909 2004-12-25 devnull addthread(&l->waiting, (*threadnow)());
315 1544f909 2004-12-25 devnull unlock(&l->l);
317 1544f909 2004-12-25 devnull _threadswitch();
319 1544f909 2004-12-25 devnull if(l->owner != (*threadnow)()){
320 1544f909 2004-12-25 devnull fprint(2, "qlock pc=0x%lux owner=%p self=%p oops\n", pc, l->owner, (*threadnow)());
321 1544f909 2004-12-25 devnull abort();
323 1544f909 2004-12-25 devnull //print("qlock wakeup %p @%#x by %p\n", l, pc, (*threadnow)());
324 1544f909 2004-12-25 devnull return 1;
327 1544f909 2004-12-25 devnull static void
328 1544f909 2004-12-25 devnull threadqunlock(QLock *l, ulong pc)
330 1544f909 2004-12-25 devnull lock(&l->l);
331 1544f909 2004-12-25 devnull //print("qlock unlock %p @%#x by %p (owner %p)\n", l, pc, (*threadnow)(), l->owner);
332 1544f909 2004-12-25 devnull if(l->owner == nil){
333 1544f909 2004-12-25 devnull fprint(2, "qunlock pc=0x%lux owner=%p self=%p oops\n",
334 1544f909 2004-12-25 devnull pc, l->owner, (*threadnow)());
335 1544f909 2004-12-25 devnull abort();
337 1544f909 2004-12-25 devnull if((l->owner = l->waiting.head) != nil){
338 1544f909 2004-12-25 devnull delthread(&l->waiting, l->owner);
339 1544f909 2004-12-25 devnull _threadready(l->owner);
341 1544f909 2004-12-25 devnull unlock(&l->l);
344 1544f909 2004-12-25 devnull static int
345 1544f909 2004-12-25 devnull threadrlock(RWLock *l, int block, ulong pc)
347 1544f909 2004-12-25 devnull USED(pc);
349 1544f909 2004-12-25 devnull lock(&l->l);
350 1544f909 2004-12-25 devnull if(l->writer == nil && l->wwaiting.head == nil){
351 1544f909 2004-12-25 devnull l->readers++;
352 1544f909 2004-12-25 devnull unlock(&l->l);
353 1544f909 2004-12-25 devnull return 1;
355 1544f909 2004-12-25 devnull if(!block){
356 1544f909 2004-12-25 devnull unlock(&l->l);
357 1544f909 2004-12-25 devnull return 0;
359 1544f909 2004-12-25 devnull addthread(&l->rwaiting, (*threadnow)());
360 1544f909 2004-12-25 devnull unlock(&l->l);
361 1544f909 2004-12-25 devnull _threadswitch();
362 1544f909 2004-12-25 devnull return 1;
365 1544f909 2004-12-25 devnull static int
366 1544f909 2004-12-25 devnull threadwlock(RWLock *l, int block, ulong pc)
368 1544f909 2004-12-25 devnull USED(pc);
370 1544f909 2004-12-25 devnull lock(&l->l);
371 1544f909 2004-12-25 devnull if(l->writer == nil && l->readers == 0){
372 1544f909 2004-12-25 devnull l->writer = (*threadnow)();
373 1544f909 2004-12-25 devnull unlock(&l->l);
374 1544f909 2004-12-25 devnull return 1;
376 1544f909 2004-12-25 devnull if(!block){
377 1544f909 2004-12-25 devnull unlock(&l->l);
378 1544f909 2004-12-25 devnull return 0;
380 1544f909 2004-12-25 devnull addthread(&l->wwaiting, (*threadnow)());
381 1544f909 2004-12-25 devnull unlock(&l->l);
382 1544f909 2004-12-25 devnull _threadswitch();
383 1544f909 2004-12-25 devnull return 1;
386 1544f909 2004-12-25 devnull static void
387 1544f909 2004-12-25 devnull threadrunlock(RWLock *l, ulong pc)
389 1544f909 2004-12-25 devnull _Thread *t;
391 1544f909 2004-12-25 devnull USED(pc);
392 1544f909 2004-12-25 devnull lock(&l->l);
393 1544f909 2004-12-25 devnull --l->readers;
394 1544f909 2004-12-25 devnull if(l->readers == 0 && (t = l->wwaiting.head) != nil){
395 1544f909 2004-12-25 devnull delthread(&l->wwaiting, t);
396 1544f909 2004-12-25 devnull l->writer = t;
397 1544f909 2004-12-25 devnull _threadready(t);
399 1544f909 2004-12-25 devnull unlock(&l->l);
402 1544f909 2004-12-25 devnull static void
403 1544f909 2004-12-25 devnull threadwunlock(RWLock *l, ulong pc)
405 1544f909 2004-12-25 devnull _Thread *t;
407 1544f909 2004-12-25 devnull USED(pc);
408 1544f909 2004-12-25 devnull lock(&l->l);
409 1544f909 2004-12-25 devnull l->writer = nil;
410 1544f909 2004-12-25 devnull assert(l->readers == 0);
411 1544f909 2004-12-25 devnull while((t = l->rwaiting.head) != nil){
412 1544f909 2004-12-25 devnull delthread(&l->rwaiting, t);
413 1544f909 2004-12-25 devnull l->readers++;
414 1544f909 2004-12-25 devnull _threadready(t);
416 1544f909 2004-12-25 devnull if(l->readers == 0 && (t = l->wwaiting.head) != nil){
417 1544f909 2004-12-25 devnull delthread(&l->wwaiting, t);
418 1544f909 2004-12-25 devnull l->writer = t;
419 1544f909 2004-12-25 devnull _threadready(t);
421 1544f909 2004-12-25 devnull unlock(&l->l);
425 1544f909 2004-12-25 devnull * sleep and wakeup
427 1544f909 2004-12-25 devnull static void
428 1544f909 2004-12-25 devnull threadrsleep(Rendez *r, ulong pc)
430 1544f909 2004-12-25 devnull addthread(&r->waiting, proc()->thread);
431 1544f909 2004-12-25 devnull qunlock(r->l);
432 1544f909 2004-12-25 devnull _threadswitch();
433 1544f909 2004-12-25 devnull qlock(r->l);
436 1544f909 2004-12-25 devnull static int
437 1544f909 2004-12-25 devnull threadrwakeup(Rendez *r, int all, ulong pc)
440 1544f909 2004-12-25 devnull _Thread *t;
442 1544f909 2004-12-25 devnull for(i=0;; i++){
443 1544f909 2004-12-25 devnull if(i==1 && !all)
445 1544f909 2004-12-25 devnull if((t = r->waiting.head) == nil)
447 1544f909 2004-12-25 devnull delthread(&r->waiting, t);
448 1544f909 2004-12-25 devnull _threadready(t);
450 1544f909 2004-12-25 devnull return i;
454 4dbefdd4 2004-12-27 devnull * startup
457 4dbefdd4 2004-12-27 devnull static int threadargc;
458 4dbefdd4 2004-12-27 devnull static char **threadargv;
459 4dbefdd4 2004-12-27 devnull int mainstacksize;
461 4dbefdd4 2004-12-27 devnull static void
462 4dbefdd4 2004-12-27 devnull threadmainstart(void *v)
464 4dbefdd4 2004-12-27 devnull USED(v);
465 4dbefdd4 2004-12-27 devnull threadmainproc = proc();
466 4dbefdd4 2004-12-27 devnull threadmain(threadargc, threadargv);
470 2c87dda8 2004-12-28 devnull threadlinklibrary(void)
475 4dbefdd4 2004-12-27 devnull main(int argc, char **argv)
477 4dbefdd4 2004-12-27 devnull Proc *p;
479 1d2533d0 2004-12-28 devnull argv0 = argv[0];
481 2c87dda8 2004-12-28 devnull _threadsetupdaemonize();
483 4dbefdd4 2004-12-27 devnull threadargc = argc;
484 4dbefdd4 2004-12-27 devnull threadargv = argv;
487 4dbefdd4 2004-12-27 devnull * Install locking routines into C library.
489 4dbefdd4 2004-12-27 devnull _lock = _threadlock;
490 4dbefdd4 2004-12-27 devnull _unlock = _threadunlock;
491 4dbefdd4 2004-12-27 devnull _qlock = threadqlock;
492 4dbefdd4 2004-12-27 devnull _qunlock = threadqunlock;
493 4dbefdd4 2004-12-27 devnull _rlock = threadrlock;
494 4dbefdd4 2004-12-27 devnull _runlock = threadrunlock;
495 4dbefdd4 2004-12-27 devnull _wlock = threadwlock;
496 4dbefdd4 2004-12-27 devnull _wunlock = threadwunlock;
497 4dbefdd4 2004-12-27 devnull _rsleep = threadrsleep;
498 4dbefdd4 2004-12-27 devnull _rwakeup = threadrwakeup;
499 4dbefdd4 2004-12-27 devnull _notejmpbuf = threadnotejmp;
501 4dbefdd4 2004-12-27 devnull _pthreadinit();
502 4dbefdd4 2004-12-27 devnull p = procalloc();
503 4dbefdd4 2004-12-27 devnull _threadsetproc(p);
504 4dbefdd4 2004-12-27 devnull if(mainstacksize == 0)
505 4dbefdd4 2004-12-27 devnull mainstacksize = 65536;
506 4dbefdd4 2004-12-27 devnull _threadcreate(p, threadmainstart, nil, mainstacksize);
507 4dbefdd4 2004-12-27 devnull scheduler(p);
508 1d2533d0 2004-12-28 devnull threaddaemonize();
509 1d2533d0 2004-12-28 devnull _threadpexit();
513 1544f909 2004-12-25 devnull * hooray for linked lists
515 1544f909 2004-12-25 devnull static void
516 1544f909 2004-12-25 devnull addthread(_Threadlist *l, _Thread *t)
518 1544f909 2004-12-25 devnull if(l->tail){
519 1544f909 2004-12-25 devnull l->tail->next = t;
520 1544f909 2004-12-25 devnull t->prev = l->tail;
522 1544f909 2004-12-25 devnull l->head = t;
523 1544f909 2004-12-25 devnull t->prev = nil;
525 1544f909 2004-12-25 devnull l->tail = t;
526 1544f909 2004-12-25 devnull t->next = nil;
529 1544f909 2004-12-25 devnull static void
530 1544f909 2004-12-25 devnull delthread(_Threadlist *l, _Thread *t)
532 1544f909 2004-12-25 devnull if(t->prev)
533 1544f909 2004-12-25 devnull t->prev->next = t->next;
535 1544f909 2004-12-25 devnull l->head = t->next;
536 1544f909 2004-12-25 devnull if(t->next)
537 1544f909 2004-12-25 devnull t->next->prev = t->prev;
539 1544f909 2004-12-25 devnull l->tail = t->prev;
542 1544f909 2004-12-25 devnull static void
543 1544f909 2004-12-25 devnull addthreadinproc(Proc *p, _Thread *t)
545 1544f909 2004-12-25 devnull _Threadlist *l;
547 1544f909 2004-12-25 devnull l = &p->allthreads;
548 1544f909 2004-12-25 devnull if(l->tail){
549 1544f909 2004-12-25 devnull l->tail->allnext = t;
550 1544f909 2004-12-25 devnull t->allprev = l->tail;
552 1544f909 2004-12-25 devnull l->head = t;
553 1544f909 2004-12-25 devnull t->allprev = nil;
555 1544f909 2004-12-25 devnull l->tail = t;
556 1544f909 2004-12-25 devnull t->allnext = nil;
559 1544f909 2004-12-25 devnull static void
560 1544f909 2004-12-25 devnull delthreadinproc(Proc *p, _Thread *t)
562 1544f909 2004-12-25 devnull _Threadlist *l;
564 1544f909 2004-12-25 devnull l = &p->allthreads;
565 1544f909 2004-12-25 devnull if(t->allprev)
566 1544f909 2004-12-25 devnull t->allprev->allnext = t->allnext;
568 1544f909 2004-12-25 devnull l->head = t->allnext;
569 1544f909 2004-12-25 devnull if(t->allnext)
570 1544f909 2004-12-25 devnull t->allnext->allprev = t->allprev;
572 1544f909 2004-12-25 devnull l->tail = t->allprev;
575 4dbefdd4 2004-12-27 devnull Proc *_threadprocs;
576 4dbefdd4 2004-12-27 devnull Lock _threadprocslock;
577 4dbefdd4 2004-12-27 devnull static Proc *_threadprocstail;
579 1544f909 2004-12-25 devnull static void
580 4dbefdd4 2004-12-27 devnull addproc(Proc *p)
582 4dbefdd4 2004-12-27 devnull lock(&_threadprocslock);
583 4dbefdd4 2004-12-27 devnull if(_threadprocstail){
584 4dbefdd4 2004-12-27 devnull _threadprocstail->next = p;
585 4dbefdd4 2004-12-27 devnull p->prev = _threadprocstail;
587 4dbefdd4 2004-12-27 devnull _threadprocs = p;
588 4dbefdd4 2004-12-27 devnull p->prev = nil;
590 4dbefdd4 2004-12-27 devnull _threadprocstail = p;
591 4dbefdd4 2004-12-27 devnull p->next = nil;
592 4dbefdd4 2004-12-27 devnull unlock(&_threadprocslock);
595 4dbefdd4 2004-12-27 devnull static void
596 4dbefdd4 2004-12-27 devnull delproc(Proc *p)
598 4dbefdd4 2004-12-27 devnull lock(&_threadprocslock);
599 4dbefdd4 2004-12-27 devnull if(p->prev)
600 4dbefdd4 2004-12-27 devnull p->prev->next = p->next;
602 4dbefdd4 2004-12-27 devnull _threadprocs = p->next;
603 4dbefdd4 2004-12-27 devnull if(p->next)
604 4dbefdd4 2004-12-27 devnull p->next->prev = p->prev;
606 4dbefdd4 2004-12-27 devnull _threadprocstail = p->prev;
607 4dbefdd4 2004-12-27 devnull unlock(&_threadprocslock);