11 #define TEST(r, f, x, m) ( \
12 msg = #f, ((r) = (f)) == (x) || \
13 (error("%s failed (" m ")\n", #f, r, x), 0) )
15 #define TEST_S(s, x, m) ( \
17 (error("[%s] != [%s] (%s)\n", s, x, m), 0) )
19 static volatile char *msg = "";
21 static void alarmhandler(int sig) {
22 error("timeout in %s\n", msg);
26 static pthread_key_t k1, k2;
28 static void dtor(void *p)
33 static void *start1(void *arg)
38 static void *start2(void *arg)
41 if (pthread_setspecific(k1, p) || pthread_setspecific(k2, p+1))
46 static void *start3(void *arg)
48 pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, 0);
54 static void cleanup4(void *arg)
59 static void *start4(void *arg)
61 pthread_cleanup_push(cleanup4, arg);
63 pthread_cleanup_pop(0);
67 static void cleanup4a2(void *arg)
72 static void cleanup4a3(void *arg)
77 static void cleanup4a4(void *arg)
82 static void *start4a(void *arg)
85 pthread_cleanup_push(cleanup4, foo);
86 pthread_cleanup_push(cleanup4a2, foo+1);
87 pthread_cleanup_push(cleanup4a3, foo+2);
88 pthread_cleanup_push(cleanup4a4, foo+3);
90 pthread_cleanup_pop(0);
91 pthread_cleanup_pop(0);
92 pthread_cleanup_pop(0);
93 pthread_cleanup_pop(0);
97 static void *start5(void *arg)
99 pthread_mutex_lock(arg);
103 static void *start6(void *arg)
106 pthread_mutex_lock(args[1]);
107 pthread_barrier_wait(args[0]);
108 nanosleep(&(struct timespec){ .tv_nsec = 10000000 }, 0);
112 static void *start7(void *arg)
115 pthread_mutex_lock(args[1]);
116 pthread_cond_signal(args[0]);
117 pthread_mutex_unlock(args[1]);
121 static void *start8(void *arg)
124 pthread_mutex_t *m = args[1];
125 pthread_cond_t *c = args[0];
128 pthread_mutex_lock(m);
129 while (*x) pthread_cond_wait(c, m);
130 pthread_mutex_unlock(m);
136 void test_pthread(void)
138 pthread_t td, td1, td2, td3;
142 pthread_barrier_t barrier2;
143 pthread_mutexattr_t mtx_a;
148 signal(SIGALRM, alarmhandler);
151 TEST(r, pthread_barrier_init(&barrier2, 0, 2), 0, "creating barrier");
152 TEST(r, sem_init(&sem1, 0, 0), 0, "creating semaphore");
154 /* Test basic thread creation and joining */
155 TEST(r, pthread_create(&td, 0, start1, &res), 0, "failed to create thread");
157 TEST(r, pthread_join(td, &res), 0, "failed to join");
158 TEST(r, (res==&res), 1, "wrong result from join");
160 /* Test POSIX thread-specific data */
161 TEST(r, pthread_key_create(&k1, dtor), 0, "failed to create key");
162 TEST(r, pthread_key_create(&k2, dtor), 0, "failed to create key");
164 TEST(r, pthread_setspecific(k1, bar), 0, "failed to set tsd");
165 TEST(r, pthread_setspecific(k2, bar+1), 0, "failed to set tsd");
166 TEST(r, pthread_create(&td, 0, start2, foo), 0, "failed to create thread");
167 TEST(r, pthread_join(td, &res), 0, "failed to join");
168 TEST(res, res, 0, "pthread_setspecific failed in thread");
169 TEST(r, foo[0], 1, "dtor failed to run");
170 TEST(r, foo[1], 1, "dtor failed to run");
171 TEST(res, pthread_getspecific(k1), bar, "tsd corrupted");
172 TEST(res, pthread_getspecific(k2), bar+1, "tsd corrupted");
173 TEST(r, pthread_setspecific(k1, 0), 0, "failed to clear tsd");
174 TEST(r, pthread_setspecific(k2, 0), 0, "failed to clear tsd");
175 TEST(r, pthread_key_delete(k1), 0, "failed to destroy key");
176 TEST(r, pthread_key_delete(k2), 0, "failed to destroy key");
178 /* Asynchronous cancellation */
179 TEST(r, pthread_create(&td, 0, start3, &sem1), 0, "failed to create thread");
180 while (sem_wait(&sem1));
181 TEST(r, pthread_cancel(td), 0, "canceling");
182 TEST(r, pthread_join(td, &res), 0, "joining canceled thread");
183 TEST(res, res, PTHREAD_CANCELED, "canceled thread exit status");
185 /* Cancellation cleanup handlers */
187 TEST(r, pthread_create(&td, 0, start4, foo), 0, "failed to create thread");
188 TEST(r, pthread_cancel(td), 0, "cancelling");
189 TEST(r, pthread_join(td, &res), 0, "joining canceled thread");
190 TEST(res, res, PTHREAD_CANCELED, "canceled thread exit status");
191 TEST(r, foo[0], 1, "cleanup handler failed to run");
193 /* Nested cleanup handlers */
194 memset(foo, 0, sizeof foo);
195 TEST(r, pthread_create(&td, 0, start4a, foo), 0, "failed to create thread");
196 TEST(r, pthread_cancel(td), 0, "cancelling");
197 TEST(r, pthread_join(td, &res), 0, "joining canceled thread");
198 TEST(res, res, PTHREAD_CANCELED, "canceled thread exit status");
199 TEST(r, foo[0], 1, "cleanup handler failed to run");
200 TEST(r, foo[1], 2, "cleanup handler failed to run");
201 TEST(r, foo[2], 3, "cleanup handler failed to run");
202 TEST(r, foo[3], 4, "cleanup handler failed to run");
205 TEST(r, pthread_mutexattr_init(&mtx_a), 0, "initializing mutex attr");
206 TEST(r, pthread_mutexattr_setrobust(&mtx_a, PTHREAD_MUTEX_ROBUST), 0, "setting robust attribute");
207 TEST(r, pthread_mutex_init(&mtx, &mtx_a), 0, "initializing robust mutex");
208 TEST(r, pthread_mutex_lock(&mtx), 0, "locking robust mutex");
209 TEST(r, pthread_mutex_unlock(&mtx), 0, "unlocking robust mutex");
210 TEST(r, pthread_create(&td, 0, start5, &mtx), 0, "failed to create thread");
211 TEST(r, pthread_join(td, &res), 0, "joining thread");
212 TEST(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "locking orphaned robust mutex %d!=%d");
213 TEST(r, pthread_mutex_unlock(&mtx), 0, "unlocking orphaned robust mutex %d!=%d");
214 TEST(r, pthread_mutex_lock(&mtx), ENOTRECOVERABLE, "re-locking orphaned robust mutex %d!=%d");
215 TEST(r, pthread_mutex_destroy(&mtx), 0, "destroying unrecoverable mutex %d!=%d");
217 TEST(r, pthread_mutex_init(&mtx, &mtx_a), 0, "initializing robust mutex");
218 TEST(r, pthread_create(&td, 0, start5, &mtx), 0, "failed to create thread");
219 TEST(r, pthread_join(td, &res), 0, "joining thread");
220 TEST(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "locking orphaned robust mutex %d!=%d");
221 TEST(r, pthread_mutex_consistent(&mtx), 0, "%d!=%d");
222 TEST(r, pthread_mutex_unlock(&mtx), 0, "unlocking orphaned robust mutex %d!=%d");
223 TEST(r, pthread_mutex_lock(&mtx), 0, "re-locking orphaned robust mutex %d!=%d");
224 TEST(r, pthread_mutex_destroy(&mtx), 0, "destroying mutex %d!=%d");
226 TEST(r, pthread_mutex_init(&mtx, &mtx_a), 0, "%d != %d");
227 TEST(r, pthread_create(&td, 0, start6, (void *[]){ &barrier2, &mtx }), 0, "%d != %d");
228 pthread_barrier_wait(&barrier2);
229 TEST(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "%d != %d");
230 TEST(r, pthread_join(td, &res), 0, "%d != %d");
231 TEST(r, pthread_mutex_consistent(&mtx), 0, "%d != %d");
232 TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
233 TEST(r, pthread_mutex_destroy(&mtx), 0, "%d != %d");
235 //TEST(r, (fd=open("/dev/zero", O_RDWR))>=0, 1, "opening zero page file");
238 /* Condition variables */
239 TEST(r, pthread_mutex_init(&mtx, 0), 0, "%d != %d");
240 TEST(r, pthread_cond_init(&cond, 0), 0, "%d != %d");
241 TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
242 TEST(r, pthread_create(&td, 0, start7, (void *[]){ &cond, &mtx }), 0, "%d != %d");
243 TEST(r, pthread_cond_wait(&cond, &mtx), 0, "%d != %d");
244 TEST(r, pthread_join(td, &res), 0, "%d != %d");
245 TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
246 TEST(r, pthread_mutex_destroy(&mtx), 0, "%d != %d");
247 TEST(r, pthread_cond_destroy(&cond), 0, "%d != %d");
249 /* Condition variables with multiple waiters */
250 TEST(r, pthread_mutex_init(&mtx, 0), 0, "%d != %d");
251 TEST(r, pthread_cond_init(&cond, 0), 0, "%d != %d");
252 TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
254 TEST(r, pthread_create(&td1, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
255 TEST(r, pthread_create(&td2, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
256 TEST(r, pthread_create(&td3, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
257 TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
258 nanosleep(&(struct timespec){.tv_nsec=1000000}, 0);
260 TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
261 TEST(r, pthread_cond_signal(&cond), 0, "%d != %d");
262 TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
263 TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
264 TEST(r, pthread_cond_signal(&cond), 0, "%d != %d");
265 TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
266 TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
267 TEST(r, pthread_cond_signal(&cond), 0, "%d != %d");
268 TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
269 TEST(r, pthread_join(td1, 0), 0, "%d != %d");
270 TEST(r, pthread_join(td2, 0), 0, "%d != %d");
271 TEST(r, pthread_join(td3, 0), 0, "%d != %d");
272 TEST(r, pthread_mutex_destroy(&mtx), 0, "%d != %d");
273 TEST(r, pthread_cond_destroy(&cond), 0, "%d != %d");
275 /* Condition variables with broadcast signals */
276 TEST(r, pthread_mutex_init(&mtx, 0), 0, "%d != %d");
277 TEST(r, pthread_cond_init(&cond, 0), 0, "%d != %d");
278 TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
280 TEST(r, pthread_create(&td1, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
281 TEST(r, pthread_create(&td2, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
282 TEST(r, pthread_create(&td3, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
283 TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
284 nanosleep(&(struct timespec){.tv_nsec=1000000}, 0);
285 TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
287 TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
288 TEST(r, pthread_cond_broadcast(&cond), 0, "%d != %d");
289 TEST(r, pthread_join(td1, 0), 0, "%d != %d");
290 TEST(r, pthread_join(td2, 0), 0, "%d != %d");
291 TEST(r, pthread_join(td3, 0), 0, "%d != %d");
292 TEST(r, pthread_mutex_destroy(&mtx), 0, "%d != %d");
293 TEST(r, pthread_cond_destroy(&cond), 0, "%d != %d");