1 619085f0 2004-12-25 devnull #include "u.h"
  2 619085f0 2004-12-25 devnull #include <errno.h>
  3 619085f0 2004-12-25 devnull #include "libc.h"
  4 619085f0 2004-12-25 devnull #include "thread.h"
  5 619085f0 2004-12-25 devnull #include "threadimpl.h"
  6 619085f0 2004-12-25 devnull 
  7 619085f0 2004-12-25 devnull static pthread_mutex_t initmutex = PTHREAD_MUTEX_INITIALIZER;
  8 619085f0 2004-12-25 devnull 
  9 619085f0 2004-12-25 devnull static void
 10 619085f0 2004-12-25 devnull lockinit(Lock *lk)
 11 619085f0 2004-12-25 devnull {
 12 619085f0 2004-12-25 devnull 	pthread_mutexattr_t attr;
 13 619085f0 2004-12-25 devnull 
 14 619085f0 2004-12-25 devnull 	pthread_mutex_lock(&initmutex);
 15 619085f0 2004-12-25 devnull 	if(lk->init == 0){
 16 619085f0 2004-12-25 devnull 		pthread_mutexattr_init(&attr);
 17 619085f0 2004-12-25 devnull 		pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_NORMAL);
 18 619085f0 2004-12-25 devnull 		pthread_mutex_init(&lk->mutex, &attr);
 19 619085f0 2004-12-25 devnull 		pthread_mutexattr_destroy(&attr);
 20 619085f0 2004-12-25 devnull 		lk->init = 1;
 21 619085f0 2004-12-25 devnull 	}
 22 619085f0 2004-12-25 devnull 	pthread_mutex_unlock(&initmutex);
 23 619085f0 2004-12-25 devnull }
 24 619085f0 2004-12-25 devnull 
 25 619085f0 2004-12-25 devnull int
 26 619085f0 2004-12-25 devnull _threadlock(Lock *lk, int block, ulong pc)
 27 619085f0 2004-12-25 devnull {
 28 619085f0 2004-12-25 devnull 	int r;
 29 619085f0 2004-12-25 devnull 
 30 619085f0 2004-12-25 devnull 	if(!lk->init)
 31 619085f0 2004-12-25 devnull 		lockinit(lk);
 32 619085f0 2004-12-25 devnull 	if(block){
 33 619085f0 2004-12-25 devnull 		if(pthread_mutex_lock(&lk->mutex) != 0)
 34 619085f0 2004-12-25 devnull 			abort();
 35 619085f0 2004-12-25 devnull 		return 1;
 36 619085f0 2004-12-25 devnull 	}else{
 37 619085f0 2004-12-25 devnull 		r = pthread_mutex_trylock(&lk->mutex);
 38 619085f0 2004-12-25 devnull 		if(r == 0)
 39 619085f0 2004-12-25 devnull 			return 1;
 40 619085f0 2004-12-25 devnull 		if(r == EBUSY)
 41 619085f0 2004-12-25 devnull 			return 0;
 42 619085f0 2004-12-25 devnull 		abort();
 43 619085f0 2004-12-25 devnull 		return 0;
 44 619085f0 2004-12-25 devnull 	}
 45 619085f0 2004-12-25 devnull }
 46 619085f0 2004-12-25 devnull 
 47 619085f0 2004-12-25 devnull void
 48 619085f0 2004-12-25 devnull _threadunlock(Lock *lk, ulong pc)
 49 619085f0 2004-12-25 devnull {
 50 619085f0 2004-12-25 devnull 	if(pthread_mutex_unlock(&lk->mutex) != 0)
 51 619085f0 2004-12-25 devnull 		abort();
 52 619085f0 2004-12-25 devnull }
 53 619085f0 2004-12-25 devnull 
 54 619085f0 2004-12-25 devnull void
 55 619085f0 2004-12-25 devnull _procsleep(_Procrendez *r)
 56 619085f0 2004-12-25 devnull {
 57 619085f0 2004-12-25 devnull 	/* r is protected by r->l, which we hold */
 58 619085f0 2004-12-25 devnull 	pthread_cond_init(&r->cond, 0);
 59 619085f0 2004-12-25 devnull 	r->asleep = 1;
 60 619085f0 2004-12-25 devnull 	pthread_cond_wait(&r->cond, &r->l->mutex);
 61 619085f0 2004-12-25 devnull 	pthread_cond_destroy(&r->cond);
 62 619085f0 2004-12-25 devnull 	r->asleep = 0;
 63 619085f0 2004-12-25 devnull }
 64 619085f0 2004-12-25 devnull 
 65 619085f0 2004-12-25 devnull void
 66 619085f0 2004-12-25 devnull _procwakeup(_Procrendez *r)
 67 619085f0 2004-12-25 devnull {
 68 619085f0 2004-12-25 devnull 	if(r->asleep){
 69 619085f0 2004-12-25 devnull 		r->asleep = 0;
 70 619085f0 2004-12-25 devnull 		pthread_cond_signal(&r->cond);
 71 619085f0 2004-12-25 devnull 	}
 72 619085f0 2004-12-25 devnull }
 73 619085f0 2004-12-25 devnull 
 74 619085f0 2004-12-25 devnull void
 75 619085f0 2004-12-25 devnull _procstart(Proc *p, void (*fn)(void*))
 76 619085f0 2004-12-25 devnull {
 77 619085f0 2004-12-25 devnull //print("pc\n");
 78 619085f0 2004-12-25 devnull 	if(pthread_create(&p->tid, nil, (void*(*)(void*))fn, p) < 0){
 79 619085f0 2004-12-25 devnull //print("pc1\n");
 80 619085f0 2004-12-25 devnull 		fprint(2, "pthread_create: %r\n");
 81 619085f0 2004-12-25 devnull 		abort();
 82 619085f0 2004-12-25 devnull 	}
 83 619085f0 2004-12-25 devnull //print("pc2\n");
 84 619085f0 2004-12-25 devnull }
 85 619085f0 2004-12-25 devnull 
 86 619085f0 2004-12-25 devnull static pthread_key_t prockey;
 87 619085f0 2004-12-25 devnull 
 88 619085f0 2004-12-25 devnull Proc*
 89 619085f0 2004-12-25 devnull _threadproc(void)
 90 619085f0 2004-12-25 devnull {
 91 619085f0 2004-12-25 devnull 	Proc *p;
 92 619085f0 2004-12-25 devnull 
 93 619085f0 2004-12-25 devnull 	p = pthread_getspecific(prockey);
 94 619085f0 2004-12-25 devnull 	return p;
 95 619085f0 2004-12-25 devnull }
 96 619085f0 2004-12-25 devnull 
 97 619085f0 2004-12-25 devnull void
 98 619085f0 2004-12-25 devnull _threadsetproc(Proc *p)
 99 619085f0 2004-12-25 devnull {
100 619085f0 2004-12-25 devnull 	pthread_setspecific(prockey, p);
101 619085f0 2004-12-25 devnull }
102 619085f0 2004-12-25 devnull 
103 619085f0 2004-12-25 devnull void
104 619085f0 2004-12-25 devnull pthreadinit(void)
105 619085f0 2004-12-25 devnull {
106 619085f0 2004-12-25 devnull 	pthread_key_create(&prockey, 0);
107 619085f0 2004-12-25 devnull }
108 619085f0 2004-12-25 devnull