1 #include "threadimpl.h"
2 
3 static pthread_mutex_t initmutex = PTHREAD_MUTEX_INITIALIZER;
4 
5 static void
6 lockinit(Lock *lk)
7 {
8 	pthread_mutexattr_t attr;
9 
10 	pthread_mutex_lock(&initmutex);
11 	if(lk->init == 0){
12 		pthread_mutexattr_init(&attr);
13 		pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_NORMAL);
14 		pthread_mutex_init(&lk->mutex, &attr);
15 		pthread_mutexattr_destroy(&attr);
16 		lk->init = 1;
17 	}
18 	pthread_mutex_unlock(&initmutex);
19 }
20 
21 int
22 _threadlock(Lock *lk, int block, ulong pc)
23 {
24 	int r;
25 
26 	if(!lk->init)
27 		lockinit(lk);
28 	if(block){
29 		if(pthread_mutex_lock(&lk->mutex) != 0)
30 			abort();
31 		return 1;
32 	}else{
33 		r = pthread_mutex_trylock(&lk->mutex);
34 		if(r == 0)
35 			return 1;
36 		if(r == EBUSY)
37 			return 0;
38 		abort();
39 		return 0;
40 	}
41 }
42 
43 void
44 _threadunlock(Lock *lk, ulong pc)
45 {
46 	if(pthread_mutex_unlock(&lk->mutex) != 0)
47 		abort();
48 }
49 
50 void
51 _procsleep(_Procrendez *r)
52 {
53 	/* r is protected by r->l, which we hold */
54 	pthread_cond_init(&r->cond, 0);
55 	r->asleep = 1;
56 	pthread_cond_wait(&r->cond, &r->l->mutex);
57 	pthread_cond_destroy(&r->cond);
58 	r->asleep = 0;
59 }
60 
61 void
62 _procwakeup(_Procrendez *r)
63 {
64 	if(r->asleep){
65 		r->asleep = 0;
66 		pthread_cond_signal(&r->cond);
67 	}
68 }
69 
70 static void
71 startprocfn(void *v)
72 {
73 	void **a;
74 	void (*fn)(void*);
75 	Proc *p;
76 
77 	a = (void**)v;
78 	fn = a[0];
79 	p = a[1];
80 	free(a);
81 	p->osprocid = pthread_self();
82 	pthread_detach(p->osprocid);
83 
84 	(*fn)(p);
85 
86 	pthread_exit(0);
87 }
88 
89 void
90 _procstart(Proc *p, void (*fn)(Proc*))
91 {
92 	void **a;
93 
94 	a = malloc(2*sizeof a[0]);
95 	if(a == nil)
96 		sysfatal("_procstart malloc: %r");
97 	a[0] = fn;
98 	a[1] = p;
99 
100 	if(pthread_create(&p->osprocid, nil, (void*(*)(void*))startprocfn, (void*)a) < 0){
101 		fprint(2, "pthread_create: %r\n");
102 		abort();
103 	}
104 }
105 
106 static pthread_key_t prockey;
107 
108 Proc*
109 _threadproc(void)
110 {
111 	Proc *p;
112 
113 	p = pthread_getspecific(prockey);
114 	return p;
115 }
116 
117 void
118 _threadsetproc(Proc *p)
119 {
120 	pthread_setspecific(prockey, p);
121 }
122 
123 void
124 _pthreadinit(void)
125 {
126 	pthread_key_create(&prockey, 0);
127 }
128 
129 void
130 threadexitsall(char *msg)
131 {
132 	exits(msg);
133 }
134 
135 void
136 _threadpexit(void)
137 {
138 	pthread_exit(0);
139 }