Warning: That file was not part of the compilation database. It may have many parsing errors.

1/* Copyright (C) 2004-2019 Free Software Foundation, Inc.
2 This file is part of the GNU C Library.
3 Contributed by Jakub Jelinek <jakub@redhat.com>, 2004.
4
5 The GNU C Library is free software; you can redistribute it and/or
6 modify it under the terms of the GNU Lesser General Public
7 License as published by the Free Software Foundation; either
8 version 2.1 of the License, or (at your option) any later version.
9
10 The GNU C Library is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Lesser General Public License for more details.
14
15 You should have received a copy of the GNU Lesser General Public
16 License along with the GNU C Library; if not, see
17 <http://www.gnu.org/licenses/>. */
18
19#include <pthread.h>
20#include <stdio.h>
21#include <stdlib.h>
22#include <string.h>
23#include <unistd.h>
24
25#define N 10
26#define ROUNDS 1000
27static pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
28static pthread_cond_t cond2 = PTHREAD_COND_INITIALIZER;
29static pthread_mutex_t mut = PTHREAD_MUTEX_INITIALIZER;
30static pthread_barrier_t b;
31static int count;
32
33static void *
34tf (void *p)
35{
36 int i;
37 for (i = 0; i < ROUNDS; ++i)
38 {
39 pthread_mutex_lock (&mut);
40
41 if (++count == N)
42 pthread_cond_signal (&cond2);
43
44#ifdef TIMED
45 struct timeval tv;
46 gettimeofday (&tv, NULL);
47 struct timespec ts;
48 /* Wait three seconds. */
49 ts.tv_sec = tv.tv_sec + 3;
50 ts.tv_nsec = tv.tv_usec * 1000;
51 pthread_cond_timedwait (&cond, &mut, &ts);
52#else
53 pthread_cond_wait (&cond, &mut);
54#endif
55
56 pthread_mutex_unlock (&mut);
57
58 int err = pthread_barrier_wait (&b);
59 if (err != 0 && err != PTHREAD_BARRIER_SERIAL_THREAD)
60 {
61 puts ("child: barrier_wait failed");
62 exit (1);
63 }
64
65 err = pthread_barrier_wait (&b);
66 if (err != 0 && err != PTHREAD_BARRIER_SERIAL_THREAD)
67 {
68 puts ("child: barrier_wait failed");
69 exit (1);
70 }
71 }
72
73 return NULL;
74}
75
76
77static int
78do_test (void)
79{
80 if (pthread_barrier_init (&b, NULL, N + 1) != 0)
81 {
82 puts ("barrier_init failed");
83 return 1;
84 }
85
86 pthread_mutex_lock (&mut);
87
88 int i, j, err;
89 pthread_t th[N];
90 for (i = 0; i < N; ++i)
91 if ((err = pthread_create (&th[i], NULL, tf, NULL)) != 0)
92 {
93 printf ("cannot create thread %d: %s\n", i, strerror (err));
94 return 1;
95 }
96
97 for (i = 0; i < ROUNDS; ++i)
98 {
99 /* Make sure we discard spurious wake-ups. */
100 do
101 pthread_cond_wait (&cond2, &mut);
102 while (count != N);
103
104 if (i & 1)
105 pthread_mutex_unlock (&mut);
106
107 if (i & 2)
108 pthread_cond_broadcast (&cond);
109 else if (i & 4)
110 for (j = 0; j < N; ++j)
111 pthread_cond_signal (&cond);
112 else
113 {
114 for (j = 0; j < (i / 8) % N; ++j)
115 pthread_cond_signal (&cond);
116 pthread_cond_broadcast (&cond);
117 }
118
119 if ((i & 1) == 0)
120 pthread_mutex_unlock (&mut);
121
122 err = pthread_cond_destroy (&cond);
123 if (err)
124 {
125 printf ("pthread_cond_destroy failed: %s\n", strerror (err));
126 return 1;
127 }
128
129 /* Now clobber the cond variable which has been successfully
130 destroyed above. */
131 memset (&cond, (char) i, sizeof (cond));
132
133 err = pthread_barrier_wait (&b);
134 if (err != 0 && err != PTHREAD_BARRIER_SERIAL_THREAD)
135 {
136 puts ("parent: barrier_wait failed");
137 return 1;
138 }
139
140 pthread_mutex_lock (&mut);
141
142 err = pthread_barrier_wait (&b);
143 if (err != 0 && err != PTHREAD_BARRIER_SERIAL_THREAD)
144 {
145 puts ("parent: barrier_wait failed");
146 return 1;
147 }
148
149 count = 0;
150 err = pthread_cond_init (&cond, NULL);
151 if (err)
152 {
153 printf ("pthread_cond_init failed: %s\n", strerror (err));
154 return 1;
155 }
156 }
157
158 for (i = 0; i < N; ++i)
159 if ((err = pthread_join (th[i], NULL)) != 0)
160 {
161 printf ("failed to join thread %d: %s\n", i, strerror (err));
162 return 1;
163 }
164
165 puts ("done");
166
167 return 0;
168}
169
170
171#define TEST_FUNCTION do_test ()
172#include "../test-skeleton.c"
173

Warning: That file was not part of the compilation database. It may have many parsing errors.