1 76193d7c 2003-09-30 devnull #include "threadimpl.h"
3 76193d7c 2003-09-30 devnull Pqueue _threadpq;
4 32f69c36 2003-12-11 devnull int _threadprocs;
6 76193d7c 2003-09-30 devnull static int nextID(void);
9 76193d7c 2003-09-30 devnull * Create and initialize a new Thread structure attached to a given proc.
12 76193d7c 2003-09-30 devnull _stackfree(void *v)
17 76193d7c 2003-09-30 devnull static int
18 76193d7c 2003-09-30 devnull newthread(Proc *p, void (*f)(void *arg), void *arg, uint stacksize, char *name, int grp)
21 76193d7c 2003-09-30 devnull Thread *t;
24 76193d7c 2003-09-30 devnull if(stacksize < 32)
25 76193d7c 2003-09-30 devnull sysfatal("bad stacksize %d", stacksize);
26 76193d7c 2003-09-30 devnull t = _threadmalloc(sizeof(Thread), 1);
27 cd7ddc9b 2003-11-23 devnull s = _threadmalloc(stacksize, 0);
28 76193d7c 2003-09-30 devnull t->stk = (char*)s;
29 cd7ddc9b 2003-11-23 devnull t->stksize = stacksize;
30 cd7ddc9b 2003-11-23 devnull _threaddebugmemset(s, 0xFE, stacksize);
31 76193d7c 2003-09-30 devnull _threadinitstack(t, f, arg);
32 76193d7c 2003-09-30 devnull t->proc = p;
33 76193d7c 2003-09-30 devnull t->grp = grp;
35 76193d7c 2003-09-30 devnull t->cmdname = strdup(name);
36 76193d7c 2003-09-30 devnull t->id = nextID();
37 76193d7c 2003-09-30 devnull id = t->id;
38 76193d7c 2003-09-30 devnull t->next = (Thread*)~0;
39 76193d7c 2003-09-30 devnull _threaddebug(DBGSCHED, "create thread %d.%d name %s", p->pid, t->id, name);
40 76193d7c 2003-09-30 devnull lock(&p->lock);
41 76193d7c 2003-09-30 devnull p->nthreads++;
42 76193d7c 2003-09-30 devnull if(p->threads.head == nil)
43 76193d7c 2003-09-30 devnull p->threads.head = t;
45 76193d7c 2003-09-30 devnull t->prevt = p->threads.tail;
46 76193d7c 2003-09-30 devnull t->prevt->nextt = t;
48 76193d7c 2003-09-30 devnull p->threads.tail = t;
49 76193d7c 2003-09-30 devnull t->state = Ready;
50 76193d7c 2003-09-30 devnull _threadready(t);
51 76193d7c 2003-09-30 devnull unlock(&p->lock);
52 76193d7c 2003-09-30 devnull return id;
55 76193d7c 2003-09-30 devnull static int
56 76193d7c 2003-09-30 devnull nextID(void)
58 76193d7c 2003-09-30 devnull static Lock l;
59 76193d7c 2003-09-30 devnull static int id;
62 76193d7c 2003-09-30 devnull lock(&l);
63 76193d7c 2003-09-30 devnull i = ++id;
64 76193d7c 2003-09-30 devnull unlock(&l);
65 76193d7c 2003-09-30 devnull return i;
69 76193d7c 2003-09-30 devnull procrfork(void (*f)(void *), void *arg, uint stacksize, int rforkflag)
74 76193d7c 2003-09-30 devnull p = _threadgetproc();
75 76193d7c 2003-09-30 devnull assert(p->newproc == nil);
76 76193d7c 2003-09-30 devnull p->newproc = _newproc(f, arg, stacksize, nil, p->thread->grp, rforkflag);
77 76193d7c 2003-09-30 devnull id = p->newproc->threads.head->id;
78 76193d7c 2003-09-30 devnull _sched();
79 76193d7c 2003-09-30 devnull return id;
83 76193d7c 2003-09-30 devnull proccreate(void (*f)(void*), void *arg, uint stacksize)
87 e97ceade 2003-12-06 devnull p = _threadgetproc();
88 e97ceade 2003-12-06 devnull if(p->idle){
89 e97ceade 2003-12-06 devnull werrstr("cannot create procs once there is an idle thread");
90 e97ceade 2003-12-06 devnull return -1;
92 76193d7c 2003-09-30 devnull return procrfork(f, arg, stacksize, 0);
96 76193d7c 2003-09-30 devnull _freeproc(Proc *p)
98 76193d7c 2003-09-30 devnull Thread *t, *nextt;
100 76193d7c 2003-09-30 devnull for(t = p->threads.head; t; t = nextt){
101 76193d7c 2003-09-30 devnull if(t->cmdname)
102 76193d7c 2003-09-30 devnull free(t->cmdname);
103 76193d7c 2003-09-30 devnull assert(t->stk != nil);
104 cd7ddc9b 2003-11-23 devnull _stackfree(t->stk);
105 76193d7c 2003-09-30 devnull nextt = t->nextt;
106 76193d7c 2003-09-30 devnull free(t);
108 76193d7c 2003-09-30 devnull free(p);
112 76193d7c 2003-09-30 devnull * Create a new thread and schedule it to run.
113 76193d7c 2003-09-30 devnull * The thread grp is inherited from the currently running thread.
116 76193d7c 2003-09-30 devnull threadcreate(void (*f)(void *arg), void *arg, uint stacksize)
118 76193d7c 2003-09-30 devnull return newthread(_threadgetproc(), f, arg, stacksize, nil, threadgetgrp());
122 e97ceade 2003-12-06 devnull threadcreateidle(void (*f)(void *arg), void *arg, uint stacksize)
126 32f69c36 2003-12-11 devnull if(_threadprocs!=1){
127 e97ceade 2003-12-06 devnull werrstr("cannot have idle thread in multi-proc program");
128 e97ceade 2003-12-06 devnull return -1;
130 e97ceade 2003-12-06 devnull id = newthread(_threadgetproc(), f, arg, stacksize, nil, threadgetgrp());
131 32f69c36 2003-12-11 devnull _threaddebug(DBGSCHED, "idle is %d", id);
132 e97ceade 2003-12-06 devnull _threadidle();
133 e97ceade 2003-12-06 devnull return id;
137 76193d7c 2003-09-30 devnull * Create and initialize a new Proc structure with a single Thread
138 76193d7c 2003-09-30 devnull * running inside it. Add the Proc to the global process list.
141 76193d7c 2003-09-30 devnull _newproc(void (*f)(void *arg), void *arg, uint stacksize, char *name, int grp, int rforkflag)
143 76193d7c 2003-09-30 devnull Proc *p;
145 76193d7c 2003-09-30 devnull p = _threadmalloc(sizeof *p, 1);
146 76193d7c 2003-09-30 devnull p->pid = -1;
147 76193d7c 2003-09-30 devnull p->rforkflag = rforkflag;
148 76193d7c 2003-09-30 devnull newthread(p, f, arg, stacksize, name, grp);
150 76193d7c 2003-09-30 devnull lock(&_threadpq.lock);
151 76193d7c 2003-09-30 devnull if(_threadpq.head == nil)
152 76193d7c 2003-09-30 devnull _threadpq.head = p;
154 76193d7c 2003-09-30 devnull *_threadpq.tail = p;
155 76193d7c 2003-09-30 devnull _threadpq.tail = &p->next;
156 32f69c36 2003-12-11 devnull _threadprocs++;
157 76193d7c 2003-09-30 devnull unlock(&_threadpq.lock);
158 76193d7c 2003-09-30 devnull return p;
