From 08cb396fb7dbb632c49b0893a8e116269f195844 Mon Sep 17 00:00:00 2001
From: Szabolcs Nagy <nsz@port70.net>
Date: Mon, 8 Jul 2013 09:50:16 +0000
Subject: [PATCH] split pthread test into several files

---
 src/functional/Makefile         |   2 +-
 src/functional/pthread.c        | 294 --------------------------------
 src/functional/pthread_cancel.c |  98 +++++++++++
 src/functional/pthread_cond.c   |  99 +++++++++++
 src/functional/pthread_robust.c |  72 ++++++++
 src/functional/pthread_tsd.c    |  49 ++++++
 6 files changed, 319 insertions(+), 295 deletions(-)
 delete mode 100644 src/functional/pthread.c
 create mode 100644 src/functional/pthread_cancel.c
 create mode 100644 src/functional/pthread_cond.c
 create mode 100644 src/functional/pthread_robust.c
 create mode 100644 src/functional/pthread_tsd.c

diff --git a/src/functional/Makefile b/src/functional/Makefile
index db10e7e..b7da7fe 100644
--- a/src/functional/Makefile
+++ b/src/functional/Makefile
@@ -35,7 +35,7 @@ $(DSOOBJ): CFLAGS+=-fPIC
 	$(CC) $(LDFLAGS) -o $@ $< $(LDLIBS) || echo BUILDERROR $@
 
 dlopen: LDLIBS+=-ldl -rdynamic
-pthread pthread-static: LDLIBS+=-lpthread
+pthread%: LDLIBS+=-lpthread
 sem sem-static: LDLIBS+=-lpthread -lrt
 strtod_simple strtod_simple-static: LDLIBS+=-lm
 tgmath tgmath-static: LDLIBS+=-lm
diff --git a/src/functional/pthread.c b/src/functional/pthread.c
deleted file mode 100644
index 3c25c57..0000000
--- a/src/functional/pthread.c
+++ /dev/null
@@ -1,294 +0,0 @@
-#include <pthread.h>
-#include <semaphore.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <stdio.h>
-#include <errno.h>
-#include <string.h>
-#include <signal.h>
-#include "test.h"
-
-#define TEST(r, f, x, m) ( \
-	msg = #f, ((r) = (f)) == (x) || \
-	(error("%s failed (" m ")\n", #f, r, x), 0) )
-
-#define TEST_S(s, x, m) ( \
-	!strcmp((s),(x)) || \
-	(error("[%s] != [%s] (%s)\n", s, x, m), 0) )
-
-static volatile char *msg = "";
-
-static void alarmhandler(int sig) {
-	error("timeout in %s\n", msg);
-	_Exit(1);
-}
-
-static pthread_key_t k1, k2;
-
-static void dtor(void *p)
-{
-	*(int *)p = 1;
-}
-
-static void *start1(void *arg)
-{
-	return arg;
-}
-
-static void *start2(void *arg)
-{
-	int *p = arg;
-	if (pthread_setspecific(k1, p) || pthread_setspecific(k2, p+1))
-		return arg;
-	return 0;
-}
-
-static void *start3(void *arg)
-{
-	pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, 0);
-	sem_post(arg);
-	for (;;);
-	return 0;
-}
-
-static void cleanup4(void *arg)
-{
-	*(int *)arg = 1;
-}
-
-static void *start4(void *arg)
-{
-	pthread_cleanup_push(cleanup4, arg);
-	sleep(3);
-	pthread_cleanup_pop(0);
-	return 0;
-}
-
-static void cleanup4a2(void *arg)
-{
-	*(int *)arg += 2;
-}
-
-static void cleanup4a3(void *arg)
-{
-	*(int *)arg += 3;
-}
-
-static void cleanup4a4(void *arg)
-{
-	*(int *)arg += 4;
-}
-
-static void *start4a(void *arg)
-{
-	int *foo = arg;
-	pthread_cleanup_push(cleanup4, foo);
-	pthread_cleanup_push(cleanup4a2, foo+1);
-	pthread_cleanup_push(cleanup4a3, foo+2);
-	pthread_cleanup_push(cleanup4a4, foo+3);
-	sleep(3);
-	pthread_cleanup_pop(0);
-	pthread_cleanup_pop(0);
-	pthread_cleanup_pop(0);
-	pthread_cleanup_pop(0);
-	return 0;
-}
-
-static void *start5(void *arg)
-{
-	pthread_mutex_lock(arg);
-	return 0;
-}
-
-static void *start6(void *arg)
-{
-	void **args = arg;
-	pthread_mutex_lock(args[1]);
-	pthread_barrier_wait(args[0]);
-	nanosleep(&(struct timespec){ .tv_nsec = 10000000 }, 0);
-	return 0;
-}
-
-static void *start7(void *arg)
-{
-	void **args = arg;
-	pthread_mutex_lock(args[1]);
-	pthread_cond_signal(args[0]);
-	pthread_mutex_unlock(args[1]);
-	return 0;
-}
-
-static void *start8(void *arg)
-{
-	void **args = arg;
-	pthread_mutex_t *m = args[1];
-	pthread_cond_t *c = args[0];
-	int *x = args[2];
-
-	pthread_mutex_lock(m);
-	while (*x) pthread_cond_wait(c, m);
-	pthread_mutex_unlock(m);
-
-	return 0;
-}
-
-int main(void)
-{
-	pthread_t td, td1, td2, td3;
-	int r;
-	void *res;
-	int foo[4], bar[2];
-	pthread_barrier_t barrier2;
-	pthread_mutexattr_t mtx_a;
-	sem_t sem1;
-	pthread_mutex_t mtx;
-	pthread_cond_t cond;
-
-	signal(SIGALRM, alarmhandler);
-	alarm(10);
-
-	TEST(r, pthread_barrier_init(&barrier2, 0, 2), 0, "creating barrier");
-	TEST(r, sem_init(&sem1, 0, 0), 0, "creating semaphore");
-
-	/* Test basic thread creation and joining */
-	TEST(r, pthread_create(&td, 0, start1, &res), 0, "failed to create thread");
-	res = 0;
-	TEST(r, pthread_join(td, &res), 0, "failed to join");
-	TEST(r, (res==&res), 1, "wrong result from join");
-
-	/* Test POSIX thread-specific data */
-	TEST(r, pthread_key_create(&k1, dtor), 0, "failed to create key");
-	TEST(r, pthread_key_create(&k2, dtor), 0, "failed to create key");
-	foo[0] = foo[1] = 0;
-	TEST(r, pthread_setspecific(k1, bar), 0, "failed to set tsd");
-	TEST(r, pthread_setspecific(k2, bar+1), 0, "failed to set tsd");
-	TEST(r, pthread_create(&td, 0, start2, foo), 0, "failed to create thread");
-	TEST(r, pthread_join(td, &res), 0, "failed to join");
-	TEST(res, res, 0, "pthread_setspecific failed in thread");
-	TEST(r, foo[0], 1, "dtor failed to run");
-	TEST(r, foo[1], 1, "dtor failed to run");
-	TEST(res, pthread_getspecific(k1), bar, "tsd corrupted");
-	TEST(res, pthread_getspecific(k2), bar+1, "tsd corrupted");
-	TEST(r, pthread_setspecific(k1, 0), 0, "failed to clear tsd");
-	TEST(r, pthread_setspecific(k2, 0), 0, "failed to clear tsd");
-	TEST(r, pthread_key_delete(k1), 0, "failed to destroy key");
-	TEST(r, pthread_key_delete(k2), 0, "failed to destroy key");
-
-	/* Asynchronous cancellation */
-	TEST(r, pthread_create(&td, 0, start3, &sem1), 0, "failed to create thread");
-	while (sem_wait(&sem1));
-	TEST(r, pthread_cancel(td), 0, "canceling");
-	TEST(r, pthread_join(td, &res), 0, "joining canceled thread");
-	TEST(res, res, PTHREAD_CANCELED, "canceled thread exit status");
-
-	/* Cancellation cleanup handlers */
-	foo[0] = 0;
-	TEST(r, pthread_create(&td, 0, start4, foo), 0, "failed to create thread");
-	TEST(r, pthread_cancel(td), 0, "cancelling");
-	TEST(r, pthread_join(td, &res), 0, "joining canceled thread");
-	TEST(res, res, PTHREAD_CANCELED, "canceled thread exit status");
-	TEST(r, foo[0], 1, "cleanup handler failed to run");
-
-	/* Nested cleanup handlers */
-	memset(foo, 0, sizeof foo);
-	TEST(r, pthread_create(&td, 0, start4a, foo), 0, "failed to create thread");
-	TEST(r, pthread_cancel(td), 0, "cancelling");
-	TEST(r, pthread_join(td, &res), 0, "joining canceled thread");
-	TEST(res, res, PTHREAD_CANCELED, "canceled thread exit status");
-	TEST(r, foo[0], 1, "cleanup handler failed to run");
-	TEST(r, foo[1], 2, "cleanup handler failed to run");
-	TEST(r, foo[2], 3, "cleanup handler failed to run");
-	TEST(r, foo[3], 4, "cleanup handler failed to run");
-
-	/* Robust mutexes */
-	TEST(r, pthread_mutexattr_init(&mtx_a), 0, "initializing mutex attr");
-	TEST(r, pthread_mutexattr_setrobust(&mtx_a, PTHREAD_MUTEX_ROBUST), 0, "setting robust attribute");
-	TEST(r, pthread_mutex_init(&mtx, &mtx_a), 0, "initializing robust mutex");
-	TEST(r, pthread_mutex_lock(&mtx), 0, "locking robust mutex");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "unlocking robust mutex");
-	TEST(r, pthread_create(&td, 0, start5, &mtx), 0, "failed to create thread");
-	TEST(r, pthread_join(td, &res), 0, "joining thread");
-	TEST(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "locking orphaned robust mutex %d!=%d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "unlocking orphaned robust mutex %d!=%d");
-	TEST(r, pthread_mutex_lock(&mtx), ENOTRECOVERABLE, "re-locking orphaned robust mutex %d!=%d");
-	TEST(r, pthread_mutex_destroy(&mtx), 0, "destroying unrecoverable mutex %d!=%d");
-
-	TEST(r, pthread_mutex_init(&mtx, &mtx_a), 0, "initializing robust mutex");
-	TEST(r, pthread_create(&td, 0, start5, &mtx), 0, "failed to create thread");
-	TEST(r, pthread_join(td, &res), 0, "joining thread");
-	TEST(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "locking orphaned robust mutex %d!=%d");
-	TEST(r, pthread_mutex_consistent(&mtx), 0, "%d!=%d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "unlocking orphaned robust mutex %d!=%d");
-	TEST(r, pthread_mutex_lock(&mtx), 0, "re-locking orphaned robust mutex %d!=%d");
-	TEST(r, pthread_mutex_destroy(&mtx), 0, "destroying mutex %d!=%d");
-
-	TEST(r, pthread_mutex_init(&mtx, &mtx_a), 0, "%d != %d");
-	TEST(r, pthread_create(&td, 0, start6, (void *[]){ &barrier2, &mtx }), 0, "%d != %d");
-	pthread_barrier_wait(&barrier2);
-	TEST(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "%d != %d");
-	TEST(r, pthread_join(td, &res), 0, "%d != %d");
-	TEST(r, pthread_mutex_consistent(&mtx), 0, "%d != %d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_mutex_destroy(&mtx), 0, "%d != %d");
-
-	//TEST(r, (fd=open("/dev/zero", O_RDWR))>=0, 1, "opening zero page file");
-	//TEST(r, 
-
-	/* Condition variables */
-	TEST(r, pthread_mutex_init(&mtx, 0), 0, "%d != %d");
-	TEST(r, pthread_cond_init(&cond, 0), 0, "%d != %d");
-	TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_create(&td, 0, start7, (void *[]){ &cond, &mtx }), 0, "%d != %d");
-	TEST(r, pthread_cond_wait(&cond, &mtx), 0, "%d != %d");
-	TEST(r, pthread_join(td, &res), 0, "%d != %d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_mutex_destroy(&mtx), 0, "%d != %d");
-	TEST(r, pthread_cond_destroy(&cond), 0, "%d != %d");
-
-	/* Condition variables with multiple waiters */
-	TEST(r, pthread_mutex_init(&mtx, 0), 0, "%d != %d");
-	TEST(r, pthread_cond_init(&cond, 0), 0, "%d != %d");
-	TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
-	foo[0] = 1;
-	TEST(r, pthread_create(&td1, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
-	TEST(r, pthread_create(&td2, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
-	TEST(r, pthread_create(&td3, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
-	nanosleep(&(struct timespec){.tv_nsec=1000000}, 0);
-	foo[0] = 0;
-	TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_cond_signal(&cond), 0, "%d != %d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_cond_signal(&cond), 0, "%d != %d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_cond_signal(&cond), 0, "%d != %d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_join(td1, 0), 0, "%d != %d");
-	TEST(r, pthread_join(td2, 0), 0, "%d != %d");
-	TEST(r, pthread_join(td3, 0), 0, "%d != %d");
-	TEST(r, pthread_mutex_destroy(&mtx), 0, "%d != %d");
-	TEST(r, pthread_cond_destroy(&cond), 0, "%d != %d");
-
-	/* Condition variables with broadcast signals */
-	TEST(r, pthread_mutex_init(&mtx, 0), 0, "%d != %d");
-	TEST(r, pthread_cond_init(&cond, 0), 0, "%d != %d");
-	TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
-	foo[0] = 1;
-	TEST(r, pthread_create(&td1, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
-	TEST(r, pthread_create(&td2, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
-	TEST(r, pthread_create(&td3, 0, start8, (void *[]){ &cond, &mtx, foo }), 0, "%d != %d");
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
-	nanosleep(&(struct timespec){.tv_nsec=1000000}, 0);
-	TEST(r, pthread_mutex_lock(&mtx), 0, "%d != %d");
-	foo[0] = 0;
-	TEST(r, pthread_mutex_unlock(&mtx), 0, "%d != %d");
-	TEST(r, pthread_cond_broadcast(&cond), 0, "%d != %d");
-	TEST(r, pthread_join(td1, 0), 0, "%d != %d");
-	TEST(r, pthread_join(td2, 0), 0, "%d != %d");
-	TEST(r, pthread_join(td3, 0), 0, "%d != %d");
-	TEST(r, pthread_mutex_destroy(&mtx), 0, "%d != %d");
-	TEST(r, pthread_cond_destroy(&cond), 0, "%d != %d");
-	return test_status;
-}
diff --git a/src/functional/pthread_cancel.c b/src/functional/pthread_cancel.c
new file mode 100644
index 0000000..cbdd37a
--- /dev/null
+++ b/src/functional/pthread_cancel.c
@@ -0,0 +1,98 @@
+#include <pthread.h>
+#include <semaphore.h>
+#include <string.h>
+#include "test.h"
+
+#define TESTC(c, m) ( (c) || (error("%s failed (" m ")\n", #c), 0) )
+#define TESTR(r, f, m) ( \
+	((r) = (f)) == 0 || (error("%s failed: %s (" m ")\n", #f, strerror(r)), 0) )
+
+static void *start_async(void *arg)
+{
+	pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, 0);
+	sem_post(arg);
+	for (;;);
+	return 0;
+}
+
+static void cleanup1(void *arg)
+{
+	*(int *)arg = 1;
+}
+
+static void cleanup2(void *arg)
+{
+	*(int *)arg += 2;
+}
+
+static void cleanup3(void *arg)
+{
+	*(int *)arg += 3;
+}
+
+static void cleanup4(void *arg)
+{
+	*(int *)arg += 4;
+}
+
+static void *start_single(void *arg)
+{
+	pthread_cleanup_push(cleanup1, arg);
+	sleep(3);
+	pthread_cleanup_pop(0);
+	return 0;
+}
+
+static void *start_nested(void *arg)
+{
+	int *foo = arg;
+	pthread_cleanup_push(cleanup1, foo);
+	pthread_cleanup_push(cleanup2, foo+1);
+	pthread_cleanup_push(cleanup3, foo+2);
+	pthread_cleanup_push(cleanup4, foo+3);
+	sleep(3);
+	pthread_cleanup_pop(0);
+	pthread_cleanup_pop(0);
+	pthread_cleanup_pop(0);
+	pthread_cleanup_pop(0);
+	return 0;
+}
+
+int main(void)
+{
+	pthread_t td;
+	sem_t sem1;
+	int r;
+	void *res;
+	int foo[4];
+
+	TESTR(r, sem_init(&sem1, 0, 0), "creating semaphore");
+
+	/* Asynchronous cancellation */
+	TESTR(r, pthread_create(&td, 0, start_async, &sem1), "failed to create thread");
+	while (sem_wait(&sem1));
+	TESTR(r, pthread_cancel(td), "canceling");
+	TESTR(r, pthread_join(td, &res), "joining canceled thread");
+	TESTC(res == PTHREAD_CANCELED, "canceled thread exit status");
+
+	/* Cancellation cleanup handlers */
+	foo[0] = 0;
+	TESTR(r, pthread_create(&td, 0, start_single, foo), "failed to create thread");
+	TESTR(r, pthread_cancel(td), "cancelling");
+	TESTR(r, pthread_join(td, &res), "joining canceled thread");
+	TESTC(res == PTHREAD_CANCELED, "canceled thread exit status");
+	TESTC(foo[0] == 1, "cleanup handler failed to run");
+
+	/* Nested cleanup handlers */
+	memset(foo, 0, sizeof foo);
+	TESTR(r, pthread_create(&td, 0, start_nested, foo), "failed to create thread");
+	TESTR(r, pthread_cancel(td), "cancelling");
+	TESTR(r, pthread_join(td, &res), "joining canceled thread");
+	TESTC(res == PTHREAD_CANCELED, "canceled thread exit status");
+	TESTC(foo[0] == 1, "cleanup handler failed to run");
+	TESTC(foo[1] == 2, "cleanup handler failed to run");
+	TESTC(foo[2] == 3, "cleanup handler failed to run");
+	TESTC(foo[3] == 4, "cleanup handler failed to run");
+
+	return test_status;
+}
diff --git a/src/functional/pthread_cond.c b/src/functional/pthread_cond.c
new file mode 100644
index 0000000..23c9924
--- /dev/null
+++ b/src/functional/pthread_cond.c
@@ -0,0 +1,99 @@
+#include <pthread.h>
+#include <string.h>
+#include "test.h"
+
+#define TEST(r, f, m) ( \
+	((r) = (f)) == 0 || (error("%s failed: %s (" m ")\n", #f, strerror(r)), 0) )
+
+
+static void *start_signal(void *arg)
+{
+	void **args = arg;
+	pthread_mutex_lock(args[1]);
+	pthread_cond_signal(args[0]);
+	pthread_mutex_unlock(args[1]);
+	return 0;
+}
+
+static void *start_wait(void *arg)
+{
+	void **args = arg;
+	pthread_mutex_t *m = args[1];
+	pthread_cond_t *c = args[0];
+	int *x = args[2];
+
+	pthread_mutex_lock(m);
+	while (*x) pthread_cond_wait(c, m);
+	pthread_mutex_unlock(m);
+
+	return 0;
+}
+
+int main(void)
+{
+	pthread_t td, td1, td2, td3;
+	int r;
+	void *res;
+	pthread_mutex_t mtx;
+	pthread_cond_t cond;
+	int foo[1];
+
+	/* Condition variables */
+	TEST(r, pthread_mutex_init(&mtx, 0), "");
+	TEST(r, pthread_cond_init(&cond, 0), "");
+	TEST(r, pthread_mutex_lock(&mtx), "");
+	TEST(r, pthread_create(&td, 0, start_signal, (void *[]){ &cond, &mtx }), "");
+	TEST(r, pthread_cond_wait(&cond, &mtx), "");
+	TEST(r, pthread_join(td, &res), "");
+	TEST(r, pthread_mutex_unlock(&mtx), "");
+	TEST(r, pthread_mutex_destroy(&mtx), "");
+	TEST(r, pthread_cond_destroy(&cond), "");
+
+	/* Condition variables with multiple waiters */
+	TEST(r, pthread_mutex_init(&mtx, 0), "");
+	TEST(r, pthread_cond_init(&cond, 0), "");
+	TEST(r, pthread_mutex_lock(&mtx), "");
+	foo[0] = 1;
+	TEST(r, pthread_create(&td1, 0, start_wait, (void *[]){ &cond, &mtx, foo }), "");
+	TEST(r, pthread_create(&td2, 0, start_wait, (void *[]){ &cond, &mtx, foo }), "");
+	TEST(r, pthread_create(&td3, 0, start_wait, (void *[]){ &cond, &mtx, foo }), "");
+	TEST(r, pthread_mutex_unlock(&mtx), "");
+	nanosleep(&(struct timespec){.tv_nsec=1000000}, 0);
+	foo[0] = 0;
+	TEST(r, pthread_mutex_lock(&mtx), "");
+	TEST(r, pthread_cond_signal(&cond), "");
+	TEST(r, pthread_mutex_unlock(&mtx), "");
+	TEST(r, pthread_mutex_lock(&mtx), "");
+	TEST(r, pthread_cond_signal(&cond), "");
+	TEST(r, pthread_mutex_unlock(&mtx), "");
+	TEST(r, pthread_mutex_lock(&mtx), "");
+	TEST(r, pthread_cond_signal(&cond), "");
+	TEST(r, pthread_mutex_unlock(&mtx), "");
+	TEST(r, pthread_join(td1, 0), "");
+	TEST(r, pthread_join(td2, 0), "");
+	TEST(r, pthread_join(td3, 0), "");
+	TEST(r, pthread_mutex_destroy(&mtx), "");
+	TEST(r, pthread_cond_destroy(&cond), "");
+
+	/* Condition variables with broadcast signals */
+	TEST(r, pthread_mutex_init(&mtx, 0), "");
+	TEST(r, pthread_cond_init(&cond, 0), "");
+	TEST(r, pthread_mutex_lock(&mtx), "");
+	foo[0] = 1;
+	TEST(r, pthread_create(&td1, 0, start_wait, (void *[]){ &cond, &mtx, foo }), "");
+	TEST(r, pthread_create(&td2, 0, start_wait, (void *[]){ &cond, &mtx, foo }), "");
+	TEST(r, pthread_create(&td3, 0, start_wait, (void *[]){ &cond, &mtx, foo }), "");
+	TEST(r, pthread_mutex_unlock(&mtx), "");
+	nanosleep(&(struct timespec){.tv_nsec=1000000}, 0);
+	TEST(r, pthread_mutex_lock(&mtx), "");
+	foo[0] = 0;
+	TEST(r, pthread_mutex_unlock(&mtx), "");
+	TEST(r, pthread_cond_broadcast(&cond), "");
+	TEST(r, pthread_join(td1, 0), "");
+	TEST(r, pthread_join(td2, 0), "");
+	TEST(r, pthread_join(td3, 0), "");
+	TEST(r, pthread_mutex_destroy(&mtx), "");
+	TEST(r, pthread_cond_destroy(&cond), "");
+
+	return test_status;
+}
diff --git a/src/functional/pthread_robust.c b/src/functional/pthread_robust.c
new file mode 100644
index 0000000..0c4ce8d
--- /dev/null
+++ b/src/functional/pthread_robust.c
@@ -0,0 +1,72 @@
+#include <pthread.h>
+#include <string.h>
+#include <errno.h>
+#include "test.h"
+
+#define TEST(r, f, m) ( \
+	((r) = (f)) == 0 || (error("%s failed: %s (" m ")\n", #f, strerror(r)), 0) )
+#define TESTX(r, f, x, m) ( \
+	((r) = (f)) == (x) || (error("%s failed: got %d \"%s\" want %d \"%s\" (" m ")\n", #f, r, strerror(r), x, strerror(x)), 0) )
+
+static void *start_lock(void *arg)
+{
+	pthread_mutex_lock(arg);
+	return 0;
+}
+
+static void *start_wait(void *arg)
+{
+	void **args = arg;
+	pthread_mutex_lock(args[1]);
+	pthread_barrier_wait(args[0]);
+	nanosleep(&(struct timespec){ .tv_nsec = 10000000 }, 0);
+	return 0;
+}
+
+int main(void)
+{
+	pthread_t td;
+	int r;
+	void *res;
+	pthread_barrier_t barrier2;
+	pthread_mutexattr_t mtx_a;
+	pthread_mutex_t mtx;
+
+	TEST(r, pthread_barrier_init(&barrier2, 0, 2), "creating barrier");
+
+	/* Robust mutexes */
+	TEST(r, pthread_mutexattr_init(&mtx_a), "initializing mutex attr");
+	TEST(r, pthread_mutexattr_setrobust(&mtx_a, PTHREAD_MUTEX_ROBUST), "setting robust attribute");
+	TEST(r, pthread_mutex_init(&mtx, &mtx_a), "initializing robust mutex");
+	TEST(r, pthread_mutex_lock(&mtx), "locking robust mutex");
+	TEST(r, pthread_mutex_unlock(&mtx), "unlocking robust mutex");
+	TEST(r, pthread_create(&td, 0, start_lock, &mtx), "failed to create thread");
+	TEST(r, pthread_join(td, &res), "joining thread");
+	TESTX(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "locking orphaned robust mutex");
+	TEST(r, pthread_mutex_unlock(&mtx), "unlocking orphaned robust mutex");
+	TESTX(r, pthread_mutex_lock(&mtx), ENOTRECOVERABLE, "re-locking orphaned robust mutex");
+	TEST(r, pthread_mutex_destroy(&mtx), "destroying unrecoverable mutex");
+
+	TEST(r, pthread_mutex_init(&mtx, &mtx_a), "initializing robust mutex");
+	TEST(r, pthread_create(&td, 0, start_lock, &mtx), "failed to create thread");
+	TEST(r, pthread_join(td, &res), "joining thread");
+	TESTX(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "locking orphaned robust mutex");
+	TEST(r, pthread_mutex_consistent(&mtx), "");
+	TEST(r, pthread_mutex_unlock(&mtx), "unlocking orphaned robust mutex");
+	TEST(r, pthread_mutex_lock(&mtx), "re-locking orphaned robust mutex");
+	TEST(r, pthread_mutex_destroy(&mtx), "destroying mutex");
+
+	TEST(r, pthread_mutex_init(&mtx, &mtx_a), "");
+	TEST(r, pthread_create(&td, 0, start_wait, (void *[]){ &barrier2, &mtx }), "");
+	r = pthread_barrier_wait(&barrier2);
+	if (r && r != PTHREAD_BARRIER_SERIAL_THREAD)
+		error("pthread_barrier_wait failed: got %d \"%s\", wanted either 0 or %d\n",
+			r, strerror(r), PTHREAD_BARRIER_SERIAL_THREAD);
+	TESTX(r, pthread_mutex_lock(&mtx), EOWNERDEAD, "");
+	TEST(r, pthread_join(td, &res), "");
+	TEST(r, pthread_mutex_consistent(&mtx), "");
+	TEST(r, pthread_mutex_unlock(&mtx), "");
+	TEST(r, pthread_mutex_destroy(&mtx), "");
+
+	return test_status;
+}
diff --git a/src/functional/pthread_tsd.c b/src/functional/pthread_tsd.c
new file mode 100644
index 0000000..477496a
--- /dev/null
+++ b/src/functional/pthread_tsd.c
@@ -0,0 +1,49 @@
+#include <pthread.h>
+#include <string.h>
+#include "test.h"
+
+#define TESTC(c, m) ( (c) || (error("%s failed (" m ")\n", #c), 0) )
+#define TESTR(r, f, m) ( \
+	((r) = (f)) == 0 || (error("%s failed: %s (" m ")\n", #f, strerror(r)), 0) )
+
+static pthread_key_t k1, k2;
+
+static void dtor(void *p)
+{
+	*(int *)p = 1;
+}
+
+static void *start(void *arg)
+{
+	int *p = arg;
+	if (pthread_setspecific(k1, p) || pthread_setspecific(k2, p+1))
+		return arg;
+	return 0;
+}
+
+int main(void)
+{
+	pthread_t td;
+	int r;
+	void *res;
+	int foo[2], bar[2];
+
+	/* Test POSIX thread-specific data */
+	TESTR(r, pthread_key_create(&k1, dtor), "failed to create key");
+	TESTR(r, pthread_key_create(&k2, dtor), "failed to create key");
+	foo[0] = foo[1] = 0;
+	TESTR(r, pthread_setspecific(k1, bar), "failed to set tsd");
+	TESTR(r, pthread_setspecific(k2, bar+1), "failed to set tsd");
+	TESTR(r, pthread_create(&td, 0, start, foo), "failed to create thread");
+	TESTR(r, pthread_join(td, &res), "failed to join");
+	TESTC(res == 0, "pthread_setspecific failed in thread");
+	TESTC(foo[0] == 1, "dtor failed to run");
+	TESTC(foo[1] == 1, "dtor failed to run");
+	TESTC(pthread_getspecific(k1) == bar, "tsd corrupted");
+	TESTC(pthread_getspecific(k2) == bar+1, "tsd corrupted");
+	TESTR(r, pthread_setspecific(k1, 0), "failed to clear tsd");
+	TESTR(r, pthread_setspecific(k2, 0), "failed to clear tsd");
+	TESTR(r, pthread_key_delete(k1), "failed to destroy key");
+	TESTR(r, pthread_key_delete(k2), "failed to destroy key");
+	return test_status;
+}
-- 
2.20.1