1 619085f0 2004-12-25 devnull #include "threadimpl.h"
  2 619085f0 2004-12-25 devnull 
  3 619085f0 2004-12-25 devnull static pthread_mutex_t initmutex = PTHREAD_MUTEX_INITIALIZER;
  4 619085f0 2004-12-25 devnull 
  5 619085f0 2004-12-25 devnull static void
  6 619085f0 2004-12-25 devnull lockinit(Lock *lk)
  7 619085f0 2004-12-25 devnull {
  8 619085f0 2004-12-25 devnull 	pthread_mutexattr_t attr;
  9 619085f0 2004-12-25 devnull 
 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;
 17 619085f0 2004-12-25 devnull 	}
 18 619085f0 2004-12-25 devnull 	pthread_mutex_unlock(&initmutex);
 19 619085f0 2004-12-25 devnull }
 20 619085f0 2004-12-25 devnull 
 21 619085f0 2004-12-25 devnull int
 22 619085f0 2004-12-25 devnull _threadlock(Lock *lk, int block, ulong pc)
 23 619085f0 2004-12-25 devnull {
 24 619085f0 2004-12-25 devnull 	int r;
 25 619085f0 2004-12-25 devnull 
 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)
 30 619085f0 2004-12-25 devnull 			abort();
 31 619085f0 2004-12-25 devnull 		return 1;
 32 619085f0 2004-12-25 devnull 	}else{
 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;
 38 619085f0 2004-12-25 devnull 		abort();
 39 619085f0 2004-12-25 devnull 		return 0;
 40 619085f0 2004-12-25 devnull 	}
 41 619085f0 2004-12-25 devnull }
 42 619085f0 2004-12-25 devnull 
 43 619085f0 2004-12-25 devnull void
 44 619085f0 2004-12-25 devnull _threadunlock(Lock *lk, ulong pc)
 45 619085f0 2004-12-25 devnull {
 46 619085f0 2004-12-25 devnull 	if(pthread_mutex_unlock(&lk->mutex) != 0)
 47 619085f0 2004-12-25 devnull 		abort();
 48 619085f0 2004-12-25 devnull }
 49 619085f0 2004-12-25 devnull 
 50 619085f0 2004-12-25 devnull void
 51 619085f0 2004-12-25 devnull _procsleep(_Procrendez *r)
 52 619085f0 2004-12-25 devnull {
 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;
 59 619085f0 2004-12-25 devnull }
 60 619085f0 2004-12-25 devnull 
 61 619085f0 2004-12-25 devnull void
 62 619085f0 2004-12-25 devnull _procwakeup(_Procrendez *r)
 63 619085f0 2004-12-25 devnull {
 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);
 67 619085f0 2004-12-25 devnull 	}
 68 619085f0 2004-12-25 devnull }
 69 619085f0 2004-12-25 devnull 
 70 a0a331aa 2005-01-06 devnull void
 71 a0a331aa 2005-01-06 devnull _procwakeupandunlock(_Procrendez *r)
 72 a0a331aa 2005-01-06 devnull {
 73 a0a331aa 2005-01-06 devnull 	if(r->asleep){
 74 a0a331aa 2005-01-06 devnull 		r->asleep = 0;
 75 a0a331aa 2005-01-06 devnull 		pthread_cond_signal(&r->cond);
 76 a0a331aa 2005-01-06 devnull 	}
 77 c345061e 2005-01-07 devnull 	unlock(r->l);
 78 a0a331aa 2005-01-06 devnull }
 79 a0a331aa 2005-01-06 devnull 
 80 73722a8b 2004-12-27 devnull static void
 81 73722a8b 2004-12-27 devnull startprocfn(void *v)
 82 73722a8b 2004-12-27 devnull {
 83 73722a8b 2004-12-27 devnull 	void **a;
 84 73722a8b 2004-12-27 devnull 	void (*fn)(void*);
 85 73722a8b 2004-12-27 devnull 	Proc *p;
 86 73722a8b 2004-12-27 devnull 
 87 73722a8b 2004-12-27 devnull 	a = (void**)v;
 88 c345061e 2005-01-07 devnull 	fn = (void(*)(void*))a[0];
 89 73722a8b 2004-12-27 devnull 	p = a[1];
 90 73722a8b 2004-12-27 devnull 	free(a);
 91 4dbefdd4 2004-12-27 devnull 	p->osprocid = pthread_self();
 92 4dbefdd4 2004-12-27 devnull 	pthread_detach(p->osprocid);
 93 73722a8b 2004-12-27 devnull 
 94 73722a8b 2004-12-27 devnull 	(*fn)(p);
 95 73722a8b 2004-12-27 devnull 
 96 73722a8b 2004-12-27 devnull 	pthread_exit(0);
 97 73722a8b 2004-12-27 devnull }
 98 73722a8b 2004-12-27 devnull 
 99 619085f0 2004-12-25 devnull void
100 73722a8b 2004-12-27 devnull _procstart(Proc *p, void (*fn)(Proc*))
101 619085f0 2004-12-25 devnull {
102 73722a8b 2004-12-27 devnull 	void **a;
103 73722a8b 2004-12-27 devnull 
104 73722a8b 2004-12-27 devnull 	a = malloc(2*sizeof a[0]);
105 73722a8b 2004-12-27 devnull 	if(a == nil)
106 73722a8b 2004-12-27 devnull 		sysfatal("_procstart malloc: %r");
107 c345061e 2005-01-07 devnull 	a[0] = (void*)fn;
108 73722a8b 2004-12-27 devnull 	a[1] = p;
109 73722a8b 2004-12-27 devnull 
110 4dbefdd4 2004-12-27 devnull 	if(pthread_create(&p->osprocid, nil, (void*(*)(void*))startprocfn, (void*)a) < 0){
111 619085f0 2004-12-25 devnull 		fprint(2, "pthread_create: %r\n");
112 619085f0 2004-12-25 devnull 		abort();
113 619085f0 2004-12-25 devnull 	}
114 619085f0 2004-12-25 devnull }
115 619085f0 2004-12-25 devnull 
116 619085f0 2004-12-25 devnull static pthread_key_t prockey;
117 619085f0 2004-12-25 devnull 
118 619085f0 2004-12-25 devnull Proc*
119 619085f0 2004-12-25 devnull _threadproc(void)
120 619085f0 2004-12-25 devnull {
121 619085f0 2004-12-25 devnull 	Proc *p;
122 619085f0 2004-12-25 devnull 
123 619085f0 2004-12-25 devnull 	p = pthread_getspecific(prockey);
124 619085f0 2004-12-25 devnull 	return p;
125 619085f0 2004-12-25 devnull }
126 619085f0 2004-12-25 devnull 
127 619085f0 2004-12-25 devnull void
128 619085f0 2004-12-25 devnull _threadsetproc(Proc *p)
129 619085f0 2004-12-25 devnull {
130 619085f0 2004-12-25 devnull 	pthread_setspecific(prockey, p);
131 619085f0 2004-12-25 devnull }
132 619085f0 2004-12-25 devnull 
133 619085f0 2004-12-25 devnull void
134 e1dc7e45 2004-12-27 devnull _pthreadinit(void)
135 619085f0 2004-12-25 devnull {
136 619085f0 2004-12-25 devnull 	pthread_key_create(&prockey, 0);
137 619085f0 2004-12-25 devnull }
138 619085f0 2004-12-25 devnull 
139 93eb807a 2004-12-28 devnull void
140 93eb807a 2004-12-28 devnull threadexitsall(char *msg)
141 93eb807a 2004-12-28 devnull {
142 93eb807a 2004-12-28 devnull 	exits(msg);
143 93eb807a 2004-12-28 devnull }
144 93eb807a 2004-12-28 devnull 
145 1d2533d0 2004-12-28 devnull void
146 1d2533d0 2004-12-28 devnull _threadpexit(void)
147 1d2533d0 2004-12-28 devnull {
148 1d2533d0 2004-12-28 devnull 	pthread_exit(0);
149 1d2533d0 2004-12-28 devnull }