/* 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;

}