From 453836db72eb1a5b188c57730bf73dbf56653e71 Mon Sep 17 00:00:00 2001
From: Szabolcs Nagy <nsz@port70.net>
Date: Mon, 5 Aug 2013 15:59:48 +0000
Subject: [PATCH] unnamed semaphore test

---
 src/functional/sem_init.c            | 79 ++++++++++++++++++++++++++++
 src/functional/{sem.c => sem_open.c} |  1 +
 2 files changed, 80 insertions(+)
 create mode 100644 src/functional/sem_init.c
 rename src/functional/{sem.c => sem_open.c} (98%)

diff --git a/src/functional/sem_init.c b/src/functional/sem_init.c
new file mode 100644
index 0000000..0d30f02
--- /dev/null
+++ b/src/functional/sem_init.c
@@ -0,0 +1,79 @@
+/* unnamed semaphore sanity check */
+#include <pthread.h>
+#include <semaphore.h>
+#include <time.h>
+#include <string.h>
+#include <errno.h>
+#include "test.h"
+
+#define T(f) if(f) t_error(#f" failed: %s\n", strerror(errno))
+#define T2(r,f) if((r=(f))) t_error(#f" failed: %s\n", strerror(r))
+
+static void *start(void *arg)
+{
+	struct timespec ts;
+	sem_t *s = arg;
+	T(clock_gettime(CLOCK_REALTIME, &ts));
+	ts.tv_sec += 1;
+	T(sem_post(s));
+	T(sem_timedwait(s+1, &ts));
+	return 0;
+}
+
+static void many_waiters()
+{
+	pthread_t t[3];
+	sem_t s[2];
+	int r;
+	void *p;
+
+	T(sem_init(s, 0, 0));
+	T(sem_init(s+1, 0, 0));
+	T2(r,pthread_create(t, 0, start, s));
+	T2(r,pthread_create(t+1, 0, start, s));
+	T2(r,pthread_create(t+2, 0, start, s));
+	T(sem_wait(s));
+	T(sem_wait(s));
+	T(sem_wait(s));
+	T(sem_getvalue(s, &r));
+	if (r)
+		t_error("sem value should be 0, got %d\n", r);
+	T(sem_post(s+1));
+	T(sem_post(s+1));
+	T(sem_post(s+1));
+	T2(r,pthread_join(t[0],&p));
+	T2(r,pthread_join(t[1],&p));
+	T2(r,pthread_join(t[2],&p));
+	T(sem_getvalue(s+1, &r));
+	if (r)
+		t_error("sem value should be 0, got %d\n", r);
+	T(sem_destroy(s));
+	T(sem_destroy(s+1));
+}
+
+static void single_thread()
+{
+	struct timespec ts;
+	sem_t s;
+	int r;
+
+	T(sem_init(&s, 0, 1));
+	T(sem_wait(&s));
+	T(sem_getvalue(&s, &r));
+	if (r)
+		t_error("sem value should be 0, got %d\n", r);
+	if (sem_trywait(&s) != -1 || errno != EAGAIN)
+		t_error("sem_trywait should fail with EAGAIN, got %s\n", strerror(errno));
+	errno = 0;
+	T(clock_gettime(CLOCK_REALTIME, &ts));
+	if (sem_timedwait(&s, &ts)!=-1 || errno != ETIMEDOUT)
+		t_error("sem_timedwait should fail with ETIMEDOUT, got %s\n", strerror(errno));
+	T(sem_destroy(&s));
+}
+
+int main(void)
+{
+	single_thread();
+	many_waiters();
+	return t_status;
+}
diff --git a/src/functional/sem.c b/src/functional/sem_open.c
similarity index 98%
rename from src/functional/sem.c
rename to src/functional/sem_open.c
index 86662b6..360e491 100644
--- a/src/functional/sem.c
+++ b/src/functional/sem_open.c
@@ -1,3 +1,4 @@
+/* named semaphore sanity check */
 #include <stdlib.h>
 #include <stdio.h>
 #include <errno.h>
-- 
2.20.1