1 619085f0 2004-12-25 devnull #include "threadimpl.h"
3 619085f0 2004-12-25 devnull static pthread_mutex_t initmutex = PTHREAD_MUTEX_INITIALIZER;
5 619085f0 2004-12-25 devnull static void
6 619085f0 2004-12-25 devnull lockinit(Lock *lk)
8 619085f0 2004-12-25 devnull pthread_mutexattr_t attr;
10 619085f0 2004-12-25 devnull pthread_mutex_lock(&initmutex);
11 619085f0 2004-12-25 devnull if(lk->init == 0){
12 619085f0 2004-12-25 devnull pthread_mutexattr_init(&attr);
13 619085f0 2004-12-25 devnull pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_NORMAL);
14 619085f0 2004-12-25 devnull pthread_mutex_init(&lk->mutex, &attr);
15 619085f0 2004-12-25 devnull pthread_mutexattr_destroy(&attr);
16 619085f0 2004-12-25 devnull lk->init = 1;
18 619085f0 2004-12-25 devnull pthread_mutex_unlock(&initmutex);
22 619085f0 2004-12-25 devnull _threadlock(Lock *lk, int block, ulong pc)
26 619085f0 2004-12-25 devnull if(!lk->init)
27 619085f0 2004-12-25 devnull lockinit(lk);
28 619085f0 2004-12-25 devnull if(block){
29 619085f0 2004-12-25 devnull if(pthread_mutex_lock(&lk->mutex) != 0)
31 619085f0 2004-12-25 devnull return 1;
33 619085f0 2004-12-25 devnull r = pthread_mutex_trylock(&lk->mutex);
34 619085f0 2004-12-25 devnull if(r == 0)
35 619085f0 2004-12-25 devnull return 1;
36 619085f0 2004-12-25 devnull if(r == EBUSY)
37 619085f0 2004-12-25 devnull return 0;
39 619085f0 2004-12-25 devnull return 0;
44 619085f0 2004-12-25 devnull _threadunlock(Lock *lk, ulong pc)
46 619085f0 2004-12-25 devnull if(pthread_mutex_unlock(&lk->mutex) != 0)
51 619085f0 2004-12-25 devnull _procsleep(_Procrendez *r)
53 619085f0 2004-12-25 devnull /* r is protected by r->l, which we hold */
54 619085f0 2004-12-25 devnull pthread_cond_init(&r->cond, 0);
55 619085f0 2004-12-25 devnull r->asleep = 1;
56 619085f0 2004-12-25 devnull pthread_cond_wait(&r->cond, &r->l->mutex);
57 619085f0 2004-12-25 devnull pthread_cond_destroy(&r->cond);
58 619085f0 2004-12-25 devnull r->asleep = 0;
62 619085f0 2004-12-25 devnull _procwakeup(_Procrendez *r)
64 619085f0 2004-12-25 devnull if(r->asleep){
65 619085f0 2004-12-25 devnull r->asleep = 0;
66 619085f0 2004-12-25 devnull pthread_cond_signal(&r->cond);
70 73722a8b 2004-12-27 devnull static void
71 73722a8b 2004-12-27 devnull startprocfn(void *v)
73 73722a8b 2004-12-27 devnull void **a;
74 73722a8b 2004-12-27 devnull void (*fn)(void*);
77 73722a8b 2004-12-27 devnull a = (void**)v;
78 73722a8b 2004-12-27 devnull fn = a[0];
79 73722a8b 2004-12-27 devnull p = a[1];
81 4dbefdd4 2004-12-27 devnull p->osprocid = pthread_self();
82 4dbefdd4 2004-12-27 devnull pthread_detach(p->osprocid);
84 73722a8b 2004-12-27 devnull (*fn)(p);
86 73722a8b 2004-12-27 devnull pthread_exit(0);
90 73722a8b 2004-12-27 devnull _procstart(Proc *p, void (*fn)(Proc*))
92 73722a8b 2004-12-27 devnull void **a;
94 73722a8b 2004-12-27 devnull a = malloc(2*sizeof a[0]);
95 73722a8b 2004-12-27 devnull if(a == nil)
96 73722a8b 2004-12-27 devnull sysfatal("_procstart malloc: %r");
97 73722a8b 2004-12-27 devnull a[0] = fn;
98 73722a8b 2004-12-27 devnull a[1] = p;
100 4dbefdd4 2004-12-27 devnull if(pthread_create(&p->osprocid, nil, (void*(*)(void*))startprocfn, (void*)a) < 0){
101 619085f0 2004-12-25 devnull fprint(2, "pthread_create: %r\n");
102 619085f0 2004-12-25 devnull abort();
106 619085f0 2004-12-25 devnull static pthread_key_t prockey;
109 619085f0 2004-12-25 devnull _threadproc(void)
111 619085f0 2004-12-25 devnull Proc *p;
113 619085f0 2004-12-25 devnull p = pthread_getspecific(prockey);
114 619085f0 2004-12-25 devnull return p;
118 619085f0 2004-12-25 devnull _threadsetproc(Proc *p)
120 619085f0 2004-12-25 devnull pthread_setspecific(prockey, p);
124 e1dc7e45 2004-12-27 devnull _pthreadinit(void)
126 619085f0 2004-12-25 devnull pthread_key_create(&prockey, 0);
130 93eb807a 2004-12-28 devnull threadexitsall(char *msg)
132 93eb807a 2004-12-28 devnull exits(msg);
136 1d2533d0 2004-12-28 devnull _threadpexit(void)
138 1d2533d0 2004-12-28 devnull pthread_exit(0);