drd/tests/bug-235681.c

   1 /*
   2  * pthread_cond_wait() test program.
   3  * See also https://bugs.kde.org/show_bug.cgi?id=235681.
   4  */
   5
   6 #include <string.h>
   7 #include <stdio.h>
   8 #include <assert.h>
   9 #include <pthread.h>
  10 #include <errno.h>
  11 #include <unistd.h>
  12
  13 pthread_mutex_t mutex;
  14 pthread_cond_t cond_var;
  15 int status;
  16 int silent;
  17
  18 static void *run_fn(void *v)
  19 {
  20     int rc;
  21
  22     if (!silent)
  23         fprintf(stderr, "run_fn starting\n");
  24
  25     rc = pthread_mutex_lock(&mutex);
  26     assert(!rc);
  27
  28     while (!status) {
  29         if (!silent)
  30             fprintf(stderr, "run_fn(): status==0\n");
  31         rc = pthread_cond_wait(&cond_var, &mutex);
  32         assert(!rc);
  33         if (!silent)
  34             fprintf(stderr, "run_fn(): woke up\n");
  35     }
  36     if (!silent)
  37         fprintf(stderr, "run_fn(): status==1\n");
  38
  39     rc = pthread_mutex_unlock(&mutex);
  40     assert(!rc);
  41
  42     if (!silent)
  43         fprintf(stderr, "run_fn done\n");
  44
  45     return NULL;
  46 }
  47
  48 int main(int argc, char **argv)
  49 {
  50     int rc;
  51     pthread_t other_thread;
  52
  53     if (argc > 1)
  54         silent = 1;
  55
  56     rc = pthread_mutex_init(&mutex, NULL);
  57     assert(!rc);
  58     rc = pthread_cond_init(&cond_var, NULL);
  59     assert(!rc);
  60
  61     status = 0;
  62
  63     rc = pthread_create(&other_thread, NULL, run_fn, NULL);
  64     assert(!rc);
  65
  66     /* yield the processor, and give the other thread a chance to get into the while loop */
  67     if (!silent)
  68         fprintf(stderr, "main(): sleeping...\n");
  69     sleep(1);
  70
  71     rc = pthread_mutex_lock(&mutex);
  72     assert(!rc);
  73     /**** BEGIN CS *****/
  74
  75     if (!silent)
  76         fprintf(stderr, "main(): status=1\n");
  77     status = 1;
  78     rc = pthread_cond_broadcast(&cond_var);
  79     assert(!rc);
  80
  81     /**** END CS *****/
  82     rc = pthread_mutex_unlock(&mutex);
  83     assert(!rc);
  84
  85     if (!silent)
  86         fprintf(stderr, "joining...\n");
  87
  88     rc = pthread_join(other_thread, NULL);
  89     assert(!rc);
  90
  91     fprintf(stderr, "Done.\n");
  92
  93     return 0;
  94 }