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 void
71 _procwakeupandunlock(_Procrendez *r)
72 {
73 	if(r->asleep){
74 		r->asleep = 0;
75 		pthread_cond_signal(&r->cond);
76 	}
77 	unlock(r->l);
78 }
79 
80 static void
81 startprocfn(void *v)
82 {
83 	void **a;
84 	void (*fn)(void*);
85 	Proc *p;
86 
87 	a = (void**)v;
88 	fn = (void(*)(void*))a[0];
89 	p = a[1];
90 	free(a);
91 	p->osprocid = pthread_self();
92 	pthread_detach(p->osprocid);
93 
94 	(*fn)(p);
95 
96 	pthread_exit(0);
97 }
98 
99 void
100 _procstart(Proc *p, void (*fn)(Proc*))
101 {
102 	void **a;
103 
104 	a = malloc(2*sizeof a[0]);
105 	if(a == nil)
106 		sysfatal("_procstart malloc: %r");
107 	a[0] = (void*)fn;
108 	a[1] = p;
109 
110 	if(pthread_create(&p->osprocid, nil, (void*(*)(void*))startprocfn, (void*)a) < 0){
111 		fprint(2, "pthread_create: %r\n");
112 		abort();
113 	}
114 }
115 
116 static pthread_key_t prockey;
117 
118 Proc*
119 _threadproc(void)
120 {
121 	Proc *p;
122 
123 	p = pthread_getspecific(prockey);
124 	return p;
125 }
126 
127 void
128 _threadsetproc(Proc *p)
129 {
130 	pthread_setspecific(prockey, p);
131 }
132 
133 void
134 _pthreadinit(void)
135 {
136 	pthread_key_create(&prockey, 0);
137 }
138 
139 void
140 threadexitsall(char *msg)
141 {
142 	exits(msg);
143 }
144 
145 void
146 _threadpexit(void)
147 {
148 	pthread_exit(0);
149 }