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 c4097c29 2004-05-11 devnull t->lastfd = -1;
28 cd7ddc9b 2003-11-23 devnull s = _threadmalloc(stacksize, 0);
29 a0f1e21f 2004-04-20 devnull t->stk = (uchar*)s;
30 cd7ddc9b 2003-11-23 devnull t->stksize = stacksize;
31 cd7ddc9b 2003-11-23 devnull _threaddebugmemset(s, 0xFE, stacksize);
32 76193d7c 2003-09-30 devnull _threadinitstack(t, f, arg);
33 76193d7c 2003-09-30 devnull t->proc = p;
34 76193d7c 2003-09-30 devnull t->grp = grp;
36 76193d7c 2003-09-30 devnull t->cmdname = strdup(name);
37 76193d7c 2003-09-30 devnull t->id = nextID();
38 76193d7c 2003-09-30 devnull id = t->id;
39 76193d7c 2003-09-30 devnull t->next = (Thread*)~0;
40 76193d7c 2003-09-30 devnull _threaddebug(DBGSCHED, "create thread %d.%d name %s", p->pid, t->id, name);
41 76193d7c 2003-09-30 devnull lock(&p->lock);
42 76193d7c 2003-09-30 devnull p->nthreads++;
43 76193d7c 2003-09-30 devnull if(p->threads.head == nil)
44 76193d7c 2003-09-30 devnull p->threads.head = t;
46 76193d7c 2003-09-30 devnull t->prevt = p->threads.tail;
47 76193d7c 2003-09-30 devnull t->prevt->nextt = t;
49 76193d7c 2003-09-30 devnull p->threads.tail = t;
50 76193d7c 2003-09-30 devnull t->state = Ready;
51 76193d7c 2003-09-30 devnull _threadready(t);
52 76193d7c 2003-09-30 devnull unlock(&p->lock);
53 76193d7c 2003-09-30 devnull return id;
56 76193d7c 2003-09-30 devnull static int
57 76193d7c 2003-09-30 devnull nextID(void)
59 76193d7c 2003-09-30 devnull static Lock l;
60 76193d7c 2003-09-30 devnull static int id;
63 76193d7c 2003-09-30 devnull lock(&l);
64 76193d7c 2003-09-30 devnull i = ++id;
65 76193d7c 2003-09-30 devnull unlock(&l);
66 76193d7c 2003-09-30 devnull return i;
70 76193d7c 2003-09-30 devnull procrfork(void (*f)(void *), void *arg, uint stacksize, int rforkflag)
75 76193d7c 2003-09-30 devnull p = _threadgetproc();
76 76193d7c 2003-09-30 devnull assert(p->newproc == nil);
77 76193d7c 2003-09-30 devnull p->newproc = _newproc(f, arg, stacksize, nil, p->thread->grp, rforkflag);
78 76193d7c 2003-09-30 devnull id = p->newproc->threads.head->id;
79 76193d7c 2003-09-30 devnull _sched();
80 76193d7c 2003-09-30 devnull return id;
84 76193d7c 2003-09-30 devnull proccreate(void (*f)(void*), void *arg, uint stacksize)
88 e97ceade 2003-12-06 devnull p = _threadgetproc();
89 e97ceade 2003-12-06 devnull if(p->idle){
90 5a8e63b2 2004-02-29 devnull fprint(2, "cannot create procs once there is an idle thread\n");
91 e97ceade 2003-12-06 devnull werrstr("cannot create procs once there is an idle thread");
92 e97ceade 2003-12-06 devnull return -1;
94 76193d7c 2003-09-30 devnull return procrfork(f, arg, stacksize, 0);
98 76193d7c 2003-09-30 devnull _freeproc(Proc *p)
100 76193d7c 2003-09-30 devnull Thread *t, *nextt;
102 76193d7c 2003-09-30 devnull for(t = p->threads.head; t; t = nextt){
103 76193d7c 2003-09-30 devnull if(t->cmdname)
104 76193d7c 2003-09-30 devnull free(t->cmdname);
105 76193d7c 2003-09-30 devnull assert(t->stk != nil);
106 cd7ddc9b 2003-11-23 devnull _stackfree(t->stk);
107 76193d7c 2003-09-30 devnull nextt = t->nextt;
108 76193d7c 2003-09-30 devnull free(t);
110 76193d7c 2003-09-30 devnull free(p);
114 76193d7c 2003-09-30 devnull * Create a new thread and schedule it to run.
115 76193d7c 2003-09-30 devnull * The thread grp is inherited from the currently running thread.
118 76193d7c 2003-09-30 devnull threadcreate(void (*f)(void *arg), void *arg, uint stacksize)
120 76193d7c 2003-09-30 devnull return newthread(_threadgetproc(), f, arg, stacksize, nil, threadgetgrp());
124 e97ceade 2003-12-06 devnull threadcreateidle(void (*f)(void *arg), void *arg, uint stacksize)
128 32f69c36 2003-12-11 devnull if(_threadprocs!=1){
129 5a8e63b2 2004-02-29 devnull fprint(2, "cannot have idle thread in multi-proc program\n");
130 e97ceade 2003-12-06 devnull werrstr("cannot have idle thread in multi-proc program");
131 e97ceade 2003-12-06 devnull return -1;
133 e97ceade 2003-12-06 devnull id = newthread(_threadgetproc(), f, arg, stacksize, nil, threadgetgrp());
134 32f69c36 2003-12-11 devnull _threaddebug(DBGSCHED, "idle is %d", id);
135 e97ceade 2003-12-06 devnull _threadidle();
136 e97ceade 2003-12-06 devnull return id;
140 76193d7c 2003-09-30 devnull * Create and initialize a new Proc structure with a single Thread
141 76193d7c 2003-09-30 devnull * running inside it. Add the Proc to the global process list.
144 76193d7c 2003-09-30 devnull _newproc(void (*f)(void *arg), void *arg, uint stacksize, char *name, int grp, int rforkflag)
146 76193d7c 2003-09-30 devnull Proc *p;
148 76193d7c 2003-09-30 devnull p = _threadmalloc(sizeof *p, 1);
149 76193d7c 2003-09-30 devnull p->pid = -1;
150 76193d7c 2003-09-30 devnull p->rforkflag = rforkflag;
151 76193d7c 2003-09-30 devnull newthread(p, f, arg, stacksize, name, grp);
153 76193d7c 2003-09-30 devnull lock(&_threadpq.lock);
154 76193d7c 2003-09-30 devnull if(_threadpq.head == nil)
155 76193d7c 2003-09-30 devnull _threadpq.head = p;
157 76193d7c 2003-09-30 devnull *_threadpq.tail = p;
158 76193d7c 2003-09-30 devnull _threadpq.tail = &p->next;
160 5a8e63b2 2004-02-29 devnull if(_threadprocs == 1)
161 5a8e63b2 2004-02-29 devnull _threadmultiproc();
162 32f69c36 2003-12-11 devnull _threadprocs++;
163 76193d7c 2003-09-30 devnull unlock(&_threadpq.lock);
164 76193d7c 2003-09-30 devnull return p;
