regress/lib/libpthread/condcancel1/condcancel1.c

   1 /*      $Id: condcancel1.c,v 1.2 2003/11/21 19:25:50 nathanw Exp $      */
   2
   3 #include <err.h>
   4 #include <pthread.h>
   5 #include <stdio.h>
   6 #include <string.h>
   7
   8 void *threadfunc(void *);
   9 void unlock(void *);
  10
  11 pthread_mutex_t mutex;
  12 pthread_cond_t cond;
  13 int share;
  14
  15 int
  16 main(int argc, char *argv[])
  17 {
  18         pthread_t thread;
  19         int ret;
  20
  21         printf("Test of CV state after cancelling a wait\n");
  22
  23         ret = pthread_mutex_init(&mutex, NULL);
  24         if (ret) errx(1, "pthread_mutex_init: %s", strerror(ret));
  25
  26         ret = pthread_cond_init(&cond, NULL);
  27         if (ret) errx(1, "pthread_cond_init: %s", strerror(ret));
  28
  29         ret = pthread_mutex_lock(&mutex);
  30         if (ret) errx(1, "pthread_mutex_lock: %s", strerror(ret));
  31
  32         ret = pthread_create(&thread, NULL, threadfunc, NULL);
  33         if (ret) errx(1, "pthread_create: %s", strerror(ret));
  34
  35         while (share == 0) {
  36                 ret = pthread_cond_wait(&cond, &mutex);
  37                 if (ret) errx(1, "pthread_cond_wait: %s", strerror(ret));
  38         }
  39
  40         ret = pthread_mutex_unlock(&mutex);
  41         if (ret) errx(1, "pthread_mutex_unlock: %s", strerror(ret));
  42
  43         ret = pthread_cancel(thread);
  44         if (ret) errx(1, "pthread_cancel: %s", strerror(ret));
  45
  46         ret = pthread_join(thread, NULL);
  47         if (ret) errx(1, "pthread_join: %s", strerror(ret));
  48
  49         ret = pthread_cond_destroy(&cond);
  50         if (ret) errx(1, "pthread_cond_destroy: %s", strerror(ret));
  51
  52         printf("CV successfully destroyed.\n");
  53
  54         ret = pthread_mutex_destroy(&mutex);
  55         if (ret) errx(1, "pthread_mutex_destroy: %s", strerror(ret));
  56
  57         return 0;
  58 }
  59
  60 void *
  61 threadfunc(void *arg)
  62 {
  63         int ret;
  64
  65         ret = pthread_mutex_lock(&mutex);
  66         if (ret) errx(1, "pthread_mutex_lock: %s", strerror(ret));
  67
  68         pthread_cleanup_push(unlock, &mutex);
  69
  70         while (1) {
  71                 share = 1;
  72                 ret = pthread_cond_broadcast(&cond);
  73                 if (ret) errx(1, "pthread_cond_broadcast: %s", strerror(ret));
  74                 ret = pthread_cond_wait(&cond, &mutex);
  75                 if (ret) errx(1, "pthread_cond_wait: %s", strerror(ret));
  76         }
  77
  78         pthread_cleanup_pop(0);
  79         ret = pthread_mutex_unlock(&mutex);
  80         if (ret) errx(1, "pthread_mutex_unlock: %s", strerror(ret));
  81
  82
  83
  84         return NULL;
  85 }
  86
  87 void
  88 unlock(void *arg)
  89 {
  90         pthread_mutex_unlock((pthread_mutex_t *)arg);
  91 }