#include <stdio.h> #include <stdlib.h> #include <errno.h> #include <pthread.h> #include <unistd.h> #include <sys/time.h> static pthread_mutex_t m; static void * tf (void *data) { int err = pthread_mutex_lock (&m); if (err == EOWNERDEAD) { err = pthread_mutex_consistent_np (&m); if (err) { puts ("pthread_mutex_consistent_np"); exit (1); } } else if (err) { puts ("pthread_mutex_lock"); exit (1); } printf ("thread%ld got the lock.\n", (long int) data); sleep (1); /* exit without unlock */ return NULL; } static int do_test (void) { int err, i; pthread_t t[3]; pthread_mutexattr_t ma; pthread_mutexattr_init (&ma); err = pthread_mutexattr_setrobust_np (&ma, PTHREAD_MUTEX_ROBUST_NP); if (err) { puts ("pthread_mutexattr_setrobust_np"); return 1; } #ifdef ENABLE_PI if (pthread_mutexattr_setprotocol (&ma, PTHREAD_PRIO_INHERIT) != 0) { puts ("pthread_mutexattr_setprotocol failed"); return 1; } #endif err = pthread_mutex_init (&m, &ma); #ifdef ENABLE_PI if (err == ENOTSUP) { puts ("PI robust mutexes not supported"); return 0; } #endif if (err) { puts ("pthread_mutex_init"); return 1; } for (i = 0; i < sizeof (t) / sizeof (t[0]); i++) { err = pthread_create (&t[i], NULL, tf, (void *) (long int) i); if (err) { puts ("pthread_create"); return 1; } } for (i = 0; i < sizeof (t) / sizeof (t[0]); i++) { err = pthread_join (t[i], NULL); if (err) { puts ("pthread_join"); return 1; } } return 0; } #define TIMEOUT 5 #define TEST_FUNCTION do_test () #include "../test-skeleton.c"