File: pth_cond_destroy_busy.c

package info (click to toggle)
valgrind 1%3A3.12.0~svn20160714-1
  • links: PTS, VCS
  • area: main
  • in suites: stretch
  • size: 120,428 kB
  • ctags: 70,855
  • sloc: ansic: 674,645; exp: 26,134; xml: 21,574; asm: 7,570; cpp: 7,567; makefile: 7,380; sh: 6,188; perl: 5,855; haskell: 195
file content (69 lines) | stat: -rw-r--r-- 1,488 bytes parent folder | download | duplicates (8)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
/*
 * Invoke pthread_cond_destroy() on a condition variable that is being waited
 * upon.
 */

#include <assert.h>
#include <errno.h>
#include <stdio.h>     // printf()
#include <pthread.h>

static pthread_mutex_t s_mutex;
static pthread_cond_t  s_cond;
static int             s_i;

static const char* err_to_str(int errnum)
{
  switch (errnum) {
  case 0:      return "success";
  case EBUSY:  return "EBUSY";
  case EINVAL: return "EINVAL";
  default:     return "?";
  }
}

static void* thread_func(void* thread_arg)
{
  pthread_mutex_lock(&s_mutex);
  s_i = 1;
  pthread_cond_signal(&s_cond);
  while (s_i == 1)
    pthread_cond_wait(&s_cond, &s_mutex);
  pthread_mutex_unlock(&s_mutex);

  return 0;
}

int main(int argc, char** argv)
{
  pthread_t threadid;
  int ret;

  pthread_mutex_init(&s_mutex, 0);
  pthread_cond_init(&s_cond, 0);

  pthread_create(&threadid, 0, thread_func, 0);

  pthread_mutex_lock(&s_mutex);
  while (s_i == 0)
    pthread_cond_wait(&s_cond, &s_mutex);
  pthread_mutex_unlock(&s_mutex);

  ret = pthread_cond_destroy(&s_cond);
  fprintf(stderr, "First pthread_cond_destroy() call returned %s.\n",
          err_to_str(ret));

  pthread_mutex_lock(&s_mutex);
  s_i = 2;
  pthread_cond_signal(&s_cond);
  pthread_mutex_unlock(&s_mutex);

  pthread_join(threadid, 0);

  ret = pthread_cond_destroy(&s_cond);
  fprintf(stderr, "Second pthread_cond_destroy() call returned %s.\n",
          err_to_str(ret));
  pthread_mutex_destroy(&s_mutex);

  return 0;
}