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;
27 af89fc10 2005-01-06 devnull static int fd = -1;
30 af89fc10 2005-01-06 devnull if(fd < 0){
31 af89fc10 2005-01-06 devnull p = strrchr(argv0, '/');
35 af89fc10 2005-01-06 devnull p = argv0;
36 af89fc10 2005-01-06 devnull snprint(buf, sizeof buf, "/tmp/%s.tlog", p);
37 af89fc10 2005-01-06 devnull if((fd = create(buf, OWRITE, 0666)) < 0)
38 af89fc10 2005-01-06 devnull fd = open("/dev/null", OWRITE);
41 2c87dda8 2004-12-28 devnull va_start(arg, fmt);
42 2c87dda8 2004-12-28 devnull vsnprint(buf, sizeof buf, fmt, arg);
43 2c87dda8 2004-12-28 devnull va_end(arg);
44 2c87dda8 2004-12-28 devnull t = proc()->thread;
46 af89fc10 2005-01-06 devnull fprint(fd, "%d.%d: %s\n", getpid(), t->id, buf);
48 af89fc10 2005-01-06 devnull fprint(fd, "%d._: %s\n", getpid(), buf);
51 1544f909 2004-12-25 devnull static _Thread*
52 1544f909 2004-12-25 devnull getthreadnow(void)
54 1544f909 2004-12-25 devnull return proc()->thread;
56 1544f909 2004-12-25 devnull _Thread *(*threadnow)(void) = getthreadnow;
58 1544f909 2004-12-25 devnull static Proc*
59 1544f909 2004-12-25 devnull procalloc(void)
63 1544f909 2004-12-25 devnull p = malloc(sizeof *p);
64 73722a8b 2004-12-27 devnull if(p == nil)
65 73722a8b 2004-12-27 devnull sysfatal("procalloc malloc: %r");
66 1544f909 2004-12-25 devnull memset(p, 0, sizeof *p);
67 4dbefdd4 2004-12-27 devnull addproc(p);
68 1544f909 2004-12-25 devnull lock(&threadnproclock);
69 1544f909 2004-12-25 devnull threadnproc++;
70 1544f909 2004-12-25 devnull unlock(&threadnproclock);
71 1544f909 2004-12-25 devnull return p;
74 1544f909 2004-12-25 devnull static void
75 1544f909 2004-12-25 devnull threadstart(void *v)
77 1544f909 2004-12-25 devnull _Thread *t;
80 1544f909 2004-12-25 devnull t->startfn(t->startarg);
81 2c87dda8 2004-12-28 devnull memset(&v, 0xff, 32); /* try to cut off stack traces */
82 4dbefdd4 2004-12-27 devnull threadexits(nil);
85 1544f909 2004-12-25 devnull static _Thread*
86 1544f909 2004-12-25 devnull threadalloc(void (*fn)(void*), void *arg, uint stack)
88 1544f909 2004-12-25 devnull _Thread *t;
89 1544f909 2004-12-25 devnull sigset_t zero;
91 1544f909 2004-12-25 devnull /* allocate the task and stack together */
92 1544f909 2004-12-25 devnull t = malloc(sizeof *t+stack);
93 73722a8b 2004-12-27 devnull if(t == nil)
94 73722a8b 2004-12-27 devnull sysfatal("threadalloc malloc: %r");
95 1544f909 2004-12-25 devnull memset(t, 0, sizeof *t);
96 1544f909 2004-12-25 devnull t->stk = (uchar*)(t+1);
97 1544f909 2004-12-25 devnull t->stksize = stack;
98 1544f909 2004-12-25 devnull t->id = incref(&threadidref);
99 1544f909 2004-12-25 devnull t->startfn = fn;
100 1544f909 2004-12-25 devnull t->startarg = arg;
102 1544f909 2004-12-25 devnull /* do a reasonable initialization */
103 1544f909 2004-12-25 devnull memset(&t->context.uc, 0, sizeof t->context.uc);
104 1544f909 2004-12-25 devnull sigemptyset(&zero);
105 1544f909 2004-12-25 devnull sigprocmask(SIG_BLOCK, &zero, &t->context.uc.uc_sigmask);
107 d54ead7f 2004-12-28 devnull /* must initialize with current context */
108 1544f909 2004-12-25 devnull getcontext(&t->context.uc);
110 1544f909 2004-12-25 devnull /* call makecontext to do the real work. */
111 1544f909 2004-12-25 devnull /* leave a few words open on both ends */
112 1544f909 2004-12-25 devnull t->context.uc.uc_stack.ss_sp = t->stk+8;
113 2c87dda8 2004-12-28 devnull t->context.uc.uc_stack.ss_size = t->stksize-64;
114 1544f909 2004-12-25 devnull makecontext(&t->context.uc, (void(*)())threadstart, 1, t);
116 1544f909 2004-12-25 devnull return t;
119 1544f909 2004-12-25 devnull _Thread*
120 1544f909 2004-12-25 devnull _threadcreate(Proc *p, void (*fn)(void*), void *arg, uint stack)
122 1544f909 2004-12-25 devnull _Thread *t;
124 1544f909 2004-12-25 devnull t = threadalloc(fn, arg, stack);
125 1544f909 2004-12-25 devnull t->proc = p;
126 1544f909 2004-12-25 devnull addthreadinproc(p, t);
127 1544f909 2004-12-25 devnull p->nthread++;
128 1544f909 2004-12-25 devnull _threadready(t);
129 1544f909 2004-12-25 devnull return t;
133 1544f909 2004-12-25 devnull threadcreate(void (*fn)(void*), void *arg, uint stack)
135 1544f909 2004-12-25 devnull _Thread *t;
137 1544f909 2004-12-25 devnull t = _threadcreate(proc(), fn, arg, stack);
138 1544f909 2004-12-25 devnull return t->id;
142 1544f909 2004-12-25 devnull proccreate(void (*fn)(void*), void *arg, uint stack)
144 1544f909 2004-12-25 devnull _Thread *t;
145 1544f909 2004-12-25 devnull Proc *p;
147 1544f909 2004-12-25 devnull p = procalloc();
148 1544f909 2004-12-25 devnull t = _threadcreate(p, fn, arg, stack);
149 1544f909 2004-12-25 devnull _procstart(p, scheduler);
150 1544f909 2004-12-25 devnull return t->id;
154 1544f909 2004-12-25 devnull _threadswitch(void)
156 1544f909 2004-12-25 devnull Proc *p;
158 1544f909 2004-12-25 devnull p = proc();
159 1544f909 2004-12-25 devnull contextswitch(&p->thread->context, &p->schedcontext);
163 1544f909 2004-12-25 devnull _threadready(_Thread *t)
165 1544f909 2004-12-25 devnull Proc *p;
167 1544f909 2004-12-25 devnull p = t->proc;
168 1544f909 2004-12-25 devnull lock(&p->lock);
169 a0a331aa 2005-01-06 devnull p->runrend.l = &p->lock;
170 1544f909 2004-12-25 devnull addthread(&p->runqueue, t);
171 8cbd854a 2004-12-27 devnull //print("%d wake for job %d->%d\n", time(0), getpid(), p->osprocid);
172 8cbd854a 2004-12-27 devnull if(p != proc())
173 a0a331aa 2005-01-06 devnull _procwakeupandunlock(&p->runrend);
175 a0a331aa 2005-01-06 devnull unlock(&p->lock);
179 1544f909 2004-12-25 devnull threadyield(void)
182 8cbd854a 2004-12-27 devnull Proc *p;
184 8cbd854a 2004-12-27 devnull p = proc();
185 8cbd854a 2004-12-27 devnull n = p->nswitch;
186 8cbd854a 2004-12-27 devnull _threadready(p->thread);
187 1544f909 2004-12-25 devnull _threadswitch();
188 8cbd854a 2004-12-27 devnull return p->nswitch - n;
192 1544f909 2004-12-25 devnull threadexits(char *msg)
194 1544f909 2004-12-25 devnull Proc *p;
196 1544f909 2004-12-25 devnull p = proc();
197 4dbefdd4 2004-12-27 devnull if(msg == nil)
198 4dbefdd4 2004-12-27 devnull msg = "";
199 1544f909 2004-12-25 devnull utfecpy(p->msg, p->msg+sizeof p->msg, msg);
200 4dbefdd4 2004-12-27 devnull proc()->thread->exiting = 1;
201 4dbefdd4 2004-12-27 devnull _threadswitch();
204 1544f909 2004-12-25 devnull static void
205 1544f909 2004-12-25 devnull contextswitch(Context *from, Context *to)
207 1544f909 2004-12-25 devnull if(swapcontext(&from->uc, &to->uc) < 0){
208 1544f909 2004-12-25 devnull fprint(2, "swapcontext failed: %r\n");
209 1544f909 2004-12-25 devnull assert(0);
213 1544f909 2004-12-25 devnull static void
214 73722a8b 2004-12-27 devnull scheduler(Proc *p)
216 1544f909 2004-12-25 devnull _Thread *t;
218 1544f909 2004-12-25 devnull setproc(p);
219 2c87dda8 2004-12-28 devnull _threaddebug("scheduler enter");
220 e1dc7e45 2004-12-27 devnull // print("s %p %d\n", p, gettid());
221 1544f909 2004-12-25 devnull lock(&p->lock);
222 1544f909 2004-12-25 devnull for(;;){
223 1544f909 2004-12-25 devnull while((t = p->runqueue.head) == nil){
224 1544f909 2004-12-25 devnull if(p->nthread == 0)
225 1544f909 2004-12-25 devnull goto Out;
226 1544f909 2004-12-25 devnull p->runrend.l = &p->lock;
227 2c87dda8 2004-12-28 devnull _threaddebug("scheduler sleep");
228 1544f909 2004-12-25 devnull _procsleep(&p->runrend);
229 2c87dda8 2004-12-28 devnull _threaddebug("scheduler wake");
231 1544f909 2004-12-25 devnull delthread(&p->runqueue, t);
232 1544f909 2004-12-25 devnull unlock(&p->lock);
233 1544f909 2004-12-25 devnull p->thread = t;
234 8cbd854a 2004-12-27 devnull p->nswitch++;
235 2c87dda8 2004-12-28 devnull _threaddebug("run %d (%s)", t->id, t->name);
236 1544f909 2004-12-25 devnull contextswitch(&p->schedcontext, &t->context);
237 1544f909 2004-12-25 devnull p->thread = nil;
238 1544f909 2004-12-25 devnull lock(&p->lock);
239 1544f909 2004-12-25 devnull if(t->exiting){
240 1544f909 2004-12-25 devnull delthreadinproc(p, t);
241 1544f909 2004-12-25 devnull p->nthread--;
242 1544f909 2004-12-25 devnull free(t);
247 2c87dda8 2004-12-28 devnull _threaddebug("scheduler exit");
248 4dbefdd4 2004-12-27 devnull delproc(p);
249 1544f909 2004-12-25 devnull lock(&threadnproclock);
250 1544f909 2004-12-25 devnull if(p->sysproc)
251 1544f909 2004-12-25 devnull --threadnsysproc;
252 1544f909 2004-12-25 devnull if(--threadnproc == threadnsysproc)
253 4dbefdd4 2004-12-27 devnull threadexitsall(p->msg);
254 1544f909 2004-12-25 devnull unlock(&threadnproclock);
255 1544f909 2004-12-25 devnull unlock(&p->lock);
256 1544f909 2004-12-25 devnull free(p);
257 1544f909 2004-12-25 devnull setproc(0);
261 1544f909 2004-12-25 devnull _threadsetsysproc(void)
263 1544f909 2004-12-25 devnull lock(&threadnproclock);
264 1544f909 2004-12-25 devnull if(++threadnsysproc == threadnproc)
265 1544f909 2004-12-25 devnull exit(0);
266 1544f909 2004-12-25 devnull unlock(&threadnproclock);
267 1544f909 2004-12-25 devnull proc()->sysproc = 1;
271 4dbefdd4 2004-12-27 devnull procdata(void)
273 4dbefdd4 2004-12-27 devnull return &proc()->udata;
276 4dbefdd4 2004-12-27 devnull extern Jmp *(*_notejmpbuf)(void);
277 4dbefdd4 2004-12-27 devnull static Jmp*
278 4dbefdd4 2004-12-27 devnull threadnotejmp(void)
280 4dbefdd4 2004-12-27 devnull return &proc()->sigjmp;
284 1544f909 2004-12-25 devnull * debugging
287 1544f909 2004-12-25 devnull threadsetname(char *fmt, ...)
289 1544f909 2004-12-25 devnull va_list arg;
290 1544f909 2004-12-25 devnull _Thread *t;
292 1544f909 2004-12-25 devnull t = proc()->thread;
293 1544f909 2004-12-25 devnull va_start(arg, fmt);
294 1544f909 2004-12-25 devnull vsnprint(t->name, sizeof t->name, fmt, arg);
295 1544f909 2004-12-25 devnull va_end(arg);
299 1544f909 2004-12-25 devnull threadsetstate(char *fmt, ...)
301 1544f909 2004-12-25 devnull va_list arg;
302 1544f909 2004-12-25 devnull _Thread *t;
304 1544f909 2004-12-25 devnull t = proc()->thread;
305 1544f909 2004-12-25 devnull va_start(arg, fmt);
306 1544f909 2004-12-25 devnull vsnprint(t->state, sizeof t->name, fmt, arg);
307 1544f909 2004-12-25 devnull va_end(arg);
311 1544f909 2004-12-25 devnull * locking
313 1544f909 2004-12-25 devnull static int
314 1544f909 2004-12-25 devnull threadqlock(QLock *l, int block, ulong pc)
316 1544f909 2004-12-25 devnull lock(&l->l);
317 1544f909 2004-12-25 devnull if(l->owner == nil){
318 1544f909 2004-12-25 devnull l->owner = (*threadnow)();
319 1544f909 2004-12-25 devnull //print("qlock %p @%#x by %p\n", l, pc, l->owner);
320 1544f909 2004-12-25 devnull unlock(&l->l);
321 1544f909 2004-12-25 devnull return 1;
323 1544f909 2004-12-25 devnull if(!block){
324 1544f909 2004-12-25 devnull unlock(&l->l);
325 1544f909 2004-12-25 devnull return 0;
327 1544f909 2004-12-25 devnull //print("qsleep %p @%#x by %p\n", l, pc, (*threadnow)());
328 1544f909 2004-12-25 devnull addthread(&l->waiting, (*threadnow)());
329 1544f909 2004-12-25 devnull unlock(&l->l);
331 1544f909 2004-12-25 devnull _threadswitch();
333 1544f909 2004-12-25 devnull if(l->owner != (*threadnow)()){
334 15cd8255 2005-01-04 devnull fprint(2, "%s: qlock pc=0x%lux owner=%p self=%p oops\n",
335 15cd8255 2005-01-04 devnull argv0, pc, l->owner, (*threadnow)());
336 1544f909 2004-12-25 devnull abort();
338 1544f909 2004-12-25 devnull //print("qlock wakeup %p @%#x by %p\n", l, pc, (*threadnow)());
339 1544f909 2004-12-25 devnull return 1;
342 1544f909 2004-12-25 devnull static void
343 1544f909 2004-12-25 devnull threadqunlock(QLock *l, ulong pc)
345 1544f909 2004-12-25 devnull lock(&l->l);
346 1544f909 2004-12-25 devnull //print("qlock unlock %p @%#x by %p (owner %p)\n", l, pc, (*threadnow)(), l->owner);
347 15cd8255 2005-01-04 devnull if(l->owner != (*threadnow)()){
348 15cd8255 2005-01-04 devnull fprint(2, "%s: qunlock pc=0x%lux owner=%p self=%p oops\n",
349 15cd8255 2005-01-04 devnull argv0, pc, l->owner, (*threadnow)());
351 1544f909 2004-12-25 devnull if((l->owner = l->waiting.head) != nil){
352 1544f909 2004-12-25 devnull delthread(&l->waiting, l->owner);
353 1544f909 2004-12-25 devnull _threadready(l->owner);
355 1544f909 2004-12-25 devnull unlock(&l->l);
358 1544f909 2004-12-25 devnull static int
359 1544f909 2004-12-25 devnull threadrlock(RWLock *l, int block, ulong pc)
361 1544f909 2004-12-25 devnull USED(pc);
363 1544f909 2004-12-25 devnull lock(&l->l);
364 1544f909 2004-12-25 devnull if(l->writer == nil && l->wwaiting.head == nil){
365 1544f909 2004-12-25 devnull l->readers++;
366 1544f909 2004-12-25 devnull unlock(&l->l);
367 1544f909 2004-12-25 devnull return 1;
369 1544f909 2004-12-25 devnull if(!block){
370 1544f909 2004-12-25 devnull unlock(&l->l);
371 1544f909 2004-12-25 devnull return 0;
373 1544f909 2004-12-25 devnull addthread(&l->rwaiting, (*threadnow)());
374 1544f909 2004-12-25 devnull unlock(&l->l);
375 1544f909 2004-12-25 devnull _threadswitch();
376 1544f909 2004-12-25 devnull return 1;
379 1544f909 2004-12-25 devnull static int
380 1544f909 2004-12-25 devnull threadwlock(RWLock *l, int block, ulong pc)
382 1544f909 2004-12-25 devnull USED(pc);
384 1544f909 2004-12-25 devnull lock(&l->l);
385 1544f909 2004-12-25 devnull if(l->writer == nil && l->readers == 0){
386 1544f909 2004-12-25 devnull l->writer = (*threadnow)();
387 1544f909 2004-12-25 devnull unlock(&l->l);
388 1544f909 2004-12-25 devnull return 1;
390 1544f909 2004-12-25 devnull if(!block){
391 1544f909 2004-12-25 devnull unlock(&l->l);
392 1544f909 2004-12-25 devnull return 0;
394 1544f909 2004-12-25 devnull addthread(&l->wwaiting, (*threadnow)());
395 1544f909 2004-12-25 devnull unlock(&l->l);
396 1544f909 2004-12-25 devnull _threadswitch();
397 1544f909 2004-12-25 devnull return 1;
400 1544f909 2004-12-25 devnull static void
401 1544f909 2004-12-25 devnull threadrunlock(RWLock *l, ulong pc)
403 1544f909 2004-12-25 devnull _Thread *t;
405 1544f909 2004-12-25 devnull USED(pc);
406 1544f909 2004-12-25 devnull lock(&l->l);
407 1544f909 2004-12-25 devnull --l->readers;
408 1544f909 2004-12-25 devnull if(l->readers == 0 && (t = l->wwaiting.head) != nil){
409 1544f909 2004-12-25 devnull delthread(&l->wwaiting, t);
410 1544f909 2004-12-25 devnull l->writer = t;
411 1544f909 2004-12-25 devnull _threadready(t);
413 1544f909 2004-12-25 devnull unlock(&l->l);
416 1544f909 2004-12-25 devnull static void
417 1544f909 2004-12-25 devnull threadwunlock(RWLock *l, ulong pc)
419 1544f909 2004-12-25 devnull _Thread *t;
421 1544f909 2004-12-25 devnull USED(pc);
422 1544f909 2004-12-25 devnull lock(&l->l);
423 1544f909 2004-12-25 devnull l->writer = nil;
424 1544f909 2004-12-25 devnull assert(l->readers == 0);
425 1544f909 2004-12-25 devnull while((t = l->rwaiting.head) != nil){
426 1544f909 2004-12-25 devnull delthread(&l->rwaiting, t);
427 1544f909 2004-12-25 devnull l->readers++;
428 1544f909 2004-12-25 devnull _threadready(t);
430 1544f909 2004-12-25 devnull if(l->readers == 0 && (t = l->wwaiting.head) != nil){
431 1544f909 2004-12-25 devnull delthread(&l->wwaiting, t);
432 1544f909 2004-12-25 devnull l->writer = t;
433 1544f909 2004-12-25 devnull _threadready(t);
435 1544f909 2004-12-25 devnull unlock(&l->l);
439 1544f909 2004-12-25 devnull * sleep and wakeup
441 1544f909 2004-12-25 devnull static void
442 1544f909 2004-12-25 devnull threadrsleep(Rendez *r, ulong pc)
444 1544f909 2004-12-25 devnull addthread(&r->waiting, proc()->thread);
445 1544f909 2004-12-25 devnull qunlock(r->l);
446 1544f909 2004-12-25 devnull _threadswitch();
447 1544f909 2004-12-25 devnull qlock(r->l);
450 1544f909 2004-12-25 devnull static int
451 1544f909 2004-12-25 devnull threadrwakeup(Rendez *r, int all, ulong pc)
454 1544f909 2004-12-25 devnull _Thread *t;
456 1544f909 2004-12-25 devnull for(i=0;; i++){
457 1544f909 2004-12-25 devnull if(i==1 && !all)
459 1544f909 2004-12-25 devnull if((t = r->waiting.head) == nil)
461 1544f909 2004-12-25 devnull delthread(&r->waiting, t);
462 1544f909 2004-12-25 devnull _threadready(t);
464 1544f909 2004-12-25 devnull return i;
468 4dbefdd4 2004-12-27 devnull * startup
471 4dbefdd4 2004-12-27 devnull static int threadargc;
472 4dbefdd4 2004-12-27 devnull static char **threadargv;
473 4dbefdd4 2004-12-27 devnull int mainstacksize;
475 4dbefdd4 2004-12-27 devnull static void
476 4dbefdd4 2004-12-27 devnull threadmainstart(void *v)
478 4dbefdd4 2004-12-27 devnull USED(v);
479 4dbefdd4 2004-12-27 devnull threadmainproc = proc();
480 4dbefdd4 2004-12-27 devnull threadmain(threadargc, threadargv);
484 2c87dda8 2004-12-28 devnull threadlinklibrary(void)
489 4dbefdd4 2004-12-27 devnull main(int argc, char **argv)
491 4dbefdd4 2004-12-27 devnull Proc *p;
493 1d2533d0 2004-12-28 devnull argv0 = argv[0];
495 2c87dda8 2004-12-28 devnull _threadsetupdaemonize();
497 4dbefdd4 2004-12-27 devnull threadargc = argc;
498 4dbefdd4 2004-12-27 devnull threadargv = argv;
501 4dbefdd4 2004-12-27 devnull * Install locking routines into C library.
503 4dbefdd4 2004-12-27 devnull _lock = _threadlock;
504 4dbefdd4 2004-12-27 devnull _unlock = _threadunlock;
505 4dbefdd4 2004-12-27 devnull _qlock = threadqlock;
506 4dbefdd4 2004-12-27 devnull _qunlock = threadqunlock;
507 4dbefdd4 2004-12-27 devnull _rlock = threadrlock;
508 4dbefdd4 2004-12-27 devnull _runlock = threadrunlock;
509 4dbefdd4 2004-12-27 devnull _wlock = threadwlock;
510 4dbefdd4 2004-12-27 devnull _wunlock = threadwunlock;
511 4dbefdd4 2004-12-27 devnull _rsleep = threadrsleep;
512 4dbefdd4 2004-12-27 devnull _rwakeup = threadrwakeup;
513 4dbefdd4 2004-12-27 devnull _notejmpbuf = threadnotejmp;
515 4dbefdd4 2004-12-27 devnull _pthreadinit();
516 4dbefdd4 2004-12-27 devnull p = procalloc();
517 4dbefdd4 2004-12-27 devnull _threadsetproc(p);
518 4dbefdd4 2004-12-27 devnull if(mainstacksize == 0)
519 4dbefdd4 2004-12-27 devnull mainstacksize = 65536;
520 4dbefdd4 2004-12-27 devnull _threadcreate(p, threadmainstart, nil, mainstacksize);
521 4dbefdd4 2004-12-27 devnull scheduler(p);
522 15cd8255 2005-01-04 devnull _threaddaemonize();
523 1d2533d0 2004-12-28 devnull _threadpexit();
524 15cd8255 2005-01-04 devnull return 0;
528 1544f909 2004-12-25 devnull * hooray for linked lists
530 1544f909 2004-12-25 devnull static void
531 1544f909 2004-12-25 devnull addthread(_Threadlist *l, _Thread *t)
533 1544f909 2004-12-25 devnull if(l->tail){
534 1544f909 2004-12-25 devnull l->tail->next = t;
535 1544f909 2004-12-25 devnull t->prev = l->tail;
537 1544f909 2004-12-25 devnull l->head = t;
538 1544f909 2004-12-25 devnull t->prev = nil;
540 1544f909 2004-12-25 devnull l->tail = t;
541 1544f909 2004-12-25 devnull t->next = nil;
544 1544f909 2004-12-25 devnull static void
545 1544f909 2004-12-25 devnull delthread(_Threadlist *l, _Thread *t)
547 1544f909 2004-12-25 devnull if(t->prev)
548 1544f909 2004-12-25 devnull t->prev->next = t->next;
550 1544f909 2004-12-25 devnull l->head = t->next;
551 1544f909 2004-12-25 devnull if(t->next)
552 1544f909 2004-12-25 devnull t->next->prev = t->prev;
554 1544f909 2004-12-25 devnull l->tail = t->prev;
557 1544f909 2004-12-25 devnull static void
558 1544f909 2004-12-25 devnull addthreadinproc(Proc *p, _Thread *t)
560 1544f909 2004-12-25 devnull _Threadlist *l;
562 1544f909 2004-12-25 devnull l = &p->allthreads;
563 1544f909 2004-12-25 devnull if(l->tail){
564 1544f909 2004-12-25 devnull l->tail->allnext = t;
565 1544f909 2004-12-25 devnull t->allprev = l->tail;
567 1544f909 2004-12-25 devnull l->head = t;
568 1544f909 2004-12-25 devnull t->allprev = nil;
570 1544f909 2004-12-25 devnull l->tail = t;
571 1544f909 2004-12-25 devnull t->allnext = nil;
574 1544f909 2004-12-25 devnull static void
575 1544f909 2004-12-25 devnull delthreadinproc(Proc *p, _Thread *t)
577 1544f909 2004-12-25 devnull _Threadlist *l;
579 1544f909 2004-12-25 devnull l = &p->allthreads;
580 1544f909 2004-12-25 devnull if(t->allprev)
581 1544f909 2004-12-25 devnull t->allprev->allnext = t->allnext;
583 1544f909 2004-12-25 devnull l->head = t->allnext;
584 1544f909 2004-12-25 devnull if(t->allnext)
585 1544f909 2004-12-25 devnull t->allnext->allprev = t->allprev;
587 1544f909 2004-12-25 devnull l->tail = t->allprev;
590 4dbefdd4 2004-12-27 devnull Proc *_threadprocs;
591 4dbefdd4 2004-12-27 devnull Lock _threadprocslock;
592 4dbefdd4 2004-12-27 devnull static Proc *_threadprocstail;
594 1544f909 2004-12-25 devnull static void
595 4dbefdd4 2004-12-27 devnull addproc(Proc *p)
597 4dbefdd4 2004-12-27 devnull lock(&_threadprocslock);
598 4dbefdd4 2004-12-27 devnull if(_threadprocstail){
599 4dbefdd4 2004-12-27 devnull _threadprocstail->next = p;
600 4dbefdd4 2004-12-27 devnull p->prev = _threadprocstail;
602 4dbefdd4 2004-12-27 devnull _threadprocs = p;
603 4dbefdd4 2004-12-27 devnull p->prev = nil;
605 4dbefdd4 2004-12-27 devnull _threadprocstail = p;
606 4dbefdd4 2004-12-27 devnull p->next = nil;
607 4dbefdd4 2004-12-27 devnull unlock(&_threadprocslock);
610 4dbefdd4 2004-12-27 devnull static void
611 4dbefdd4 2004-12-27 devnull delproc(Proc *p)
613 4dbefdd4 2004-12-27 devnull lock(&_threadprocslock);
614 4dbefdd4 2004-12-27 devnull if(p->prev)
615 4dbefdd4 2004-12-27 devnull p->prev->next = p->next;
617 4dbefdd4 2004-12-27 devnull _threadprocs = p->next;
618 4dbefdd4 2004-12-27 devnull if(p->next)
619 4dbefdd4 2004-12-27 devnull p->next->prev = p->prev;
621 4dbefdd4 2004-12-27 devnull _threadprocstail = p->prev;
622 4dbefdd4 2004-12-27 devnull unlock(&_threadprocslock);
626 15cd8255 2005-01-04 devnull * notify - for now just use the usual mechanisms
629 15cd8255 2005-01-04 devnull threadnotify(int (*f)(void*, char*), int in)
631 15cd8255 2005-01-04 devnull atnotify(f, in);