/* $OpenBSD: cancel2.c,v 1.3 2015/09/14 08:35:44 guenther Exp $ */
/* PUBLIC DOMAIN <marc@snafu.org> */

/*
 * Check that a thread waiting on a select or poll without timeout can be
 * cancelled.
 */

#include <sys/types.h>
#include <sys/time.h>

#include <poll.h>
#include <pthread.h>
#include <unistd.h>

#include "test.h"

static void *
select_thread(void *arg)
{
	int read_fd = *(int*) arg;
	fd_set read_fds;
	int result;

	FD_ZERO(&read_fds);
	FD_SET(read_fd, &read_fds);
	result = select(read_fd + 1, &read_fds, NULL, NULL, NULL);
	printf("select returned %d\n", result);
	return 0;
}


static void *
pselect_thread(void *arg)
{
	int read_fd = *(int*) arg;
	fd_set read_fds;
	int result;

	FD_ZERO(&read_fds);
	FD_SET(read_fd, &read_fds);
	result = pselect(read_fd + 1, &read_fds, NULL, NULL, NULL, NULL);
	printf("pselect returned %d\n", result);
	return 0;
}

static void *
poll_thread(void *arg)
{
	int read_fd = *(int*) arg;
	struct pollfd pfd;
	int result;

	pfd.fd = read_fd;
	pfd.events = POLLIN;

	result = poll(&pfd, 1, -1);
	printf("poll returned %d\n", result);
	return arg;
}


static void *
ppoll_thread(void *arg)
{
	int read_fd = *(int*) arg;
	struct pollfd pfd;
	int result;

	pfd.fd = read_fd;
	pfd.events = POLLIN;

	result = ppoll(&pfd, 1, NULL, NULL);
	printf("ppoll returned %d\n", result);
	return arg;
}

int
main(int argc, char *argv[])
{
	pthread_t thread;
	void *result = NULL;
	int pipe_fd[2];

	CHECKe(pipe(pipe_fd));

	printf("trying select\n");
	CHECKr(pthread_create(&thread, NULL, select_thread, pipe_fd));
	sleep(1);
	CHECKr(pthread_cancel(thread));
	CHECKr(pthread_join(thread, &result));
	ASSERT(result == PTHREAD_CANCELED);

	printf("trying pselect\n");
	CHECKr(pthread_create(&thread, NULL, pselect_thread, pipe_fd));
	sleep(1);
	CHECKr(pthread_cancel(thread));
	CHECKr(pthread_join(thread, &result));
	ASSERT(result == PTHREAD_CANCELED);

	printf("trying poll\n");
	CHECKr(pthread_create(&thread, NULL, poll_thread, pipe_fd));
	sleep(1);
	CHECKr(pthread_cancel(thread));
	CHECKr(pthread_join(thread, &result));
	ASSERT(result == PTHREAD_CANCELED);

	printf("trying ppoll\n");
	CHECKr(pthread_create(&thread, NULL, ppoll_thread, pipe_fd));
	sleep(1);
	CHECKr(pthread_cancel(thread));
	CHECKr(pthread_join(thread, &result));
	ASSERT(result == PTHREAD_CANCELED);

	SUCCEED;
}