-#define _POSIX_C_SOURCE 200809L
#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) ( \
- ((r) = (f)) == (x) || \
+ 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)
static void *start3(void *arg)
{
pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, 0);
- pthread_barrier_wait(arg);
+ sem_post(arg);
for (;;);
return 0;
}
static void cleanup4a3(void *arg)
{
*(int *)arg += 3;
- pthread_exit(0);
}
static void cleanup4a4(void *arg)
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);
-void test_pthread(void)
+ return 0;
+}
+
+int main(void)
{
- pthread_t td;
+ pthread_t td, td1, td2, td3;
int r;
void *res;
int foo[4], bar[2];
pthread_barrier_t barrier2;
-// pthread_mutexattr_t mtx_a;
-// pthread_mutex_t *sh_mtx;
-// int fd;
+ 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");
TEST(r, pthread_key_delete(k2), 0, "failed to destroy key");
/* Asynchronous cancellation */
- TEST(r, pthread_create(&td, 0, start3, &barrier2), 0, "failed to create thread");
- pthread_barrier_wait(&barrier2);
+ 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");
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, 0, "canceled thread exit status");
+ 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_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,
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;
}