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

1/* Copyright (C) 2003-2019 Free Software Foundation, Inc.
2 This file is part of the GNU C Library.
3 Contributed by Ulrich Drepper <drepper@redhat.com>, 2003.
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 <errno.h>
20#include <pthread.h>
21#include <stdio.h>
22#include <stdlib.h>
23#include <time.h>
24#include <sys/time.h>
25
26
27static pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
28static pthread_mutex_t mut = PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP;
29
30static pthread_barrier_t bar;
31
32
33static void
34ch (void *arg)
35{
36 int e = pthread_mutex_lock (&mut);
37 if (e == 0)
38 {
39 puts ("mutex not locked at all by cond_wait");
40 exit (1);
41 }
42
43 if (e != EDEADLK)
44 {
45 puts ("no deadlock error signaled");
46 exit (1);
47 }
48
49 if (pthread_mutex_unlock (&mut) != 0)
50 {
51 puts ("ch: cannot unlock mutex");
52 exit (1);
53 }
54
55 puts ("ch done");
56}
57
58
59static void *
60tf1 (void *p)
61{
62 int err;
63
64 if (pthread_setcancelstate (PTHREAD_CANCEL_ENABLE, NULL) != 0
65 || pthread_setcanceltype (PTHREAD_CANCEL_DEFERRED, NULL) != 0)
66 {
67 puts ("cannot set cancellation options");
68 exit (1);
69 }
70
71 err = pthread_mutex_lock (&mut);
72 if (err != 0)
73 {
74 puts ("child: cannot get mutex");
75 exit (1);
76 }
77
78 err = pthread_barrier_wait (&bar);
79 if (err != 0 && err != PTHREAD_BARRIER_SERIAL_THREAD)
80 {
81 printf ("barrier_wait returned %d\n", err);
82 exit (1);
83 }
84
85 puts ("child: got mutex; waiting");
86
87 pthread_cleanup_push (ch, NULL);
88
89 pthread_cond_wait (&cond, &mut);
90
91 pthread_cleanup_pop (0);
92
93 puts ("child: cond_wait should not have returned");
94
95 return NULL;
96}
97
98
99static void *
100tf2 (void *p)
101{
102 int err;
103
104 if (pthread_setcancelstate (PTHREAD_CANCEL_ENABLE, NULL) != 0
105 || pthread_setcanceltype (PTHREAD_CANCEL_DEFERRED, NULL) != 0)
106 {
107 puts ("cannot set cancellation options");
108 exit (1);
109 }
110
111 err = pthread_mutex_lock (&mut);
112 if (err != 0)
113 {
114 puts ("child: cannot get mutex");
115 exit (1);
116 }
117
118 err = pthread_barrier_wait (&bar);
119 if (err != 0 && err != PTHREAD_BARRIER_SERIAL_THREAD)
120 {
121 printf ("barrier_wait returned %d\n", err);
122 exit (1);
123 }
124
125 puts ("child: got mutex; waiting");
126
127 pthread_cleanup_push (ch, NULL);
128
129 /* Current time. */
130 struct timeval tv;
131 (void) gettimeofday (&tv, NULL);
132 /* +1000 seconds in correct format. */
133 struct timespec ts;
134 TIMEVAL_TO_TIMESPEC (&tv, &ts);
135 ts.tv_sec += 1000;
136
137 pthread_cond_timedwait (&cond, &mut, &ts);
138
139 pthread_cleanup_pop (0);
140
141 puts ("child: cond_wait should not have returned");
142
143 return NULL;
144}
145
146
147static int
148do_test (void)
149{
150 pthread_t th;
151 int err;
152
153 printf ("&cond = %p\n&mut = %p\n", &cond, &mut);
154
155 puts ("parent: get mutex");
156
157 err = pthread_barrier_init (&bar, NULL, 2);
158 if (err != 0)
159 {
160 puts ("parent: cannot init barrier");
161 exit (1);
162 }
163
164 puts ("parent: create child");
165
166 err = pthread_create (&th, NULL, tf1, NULL);
167 if (err != 0)
168 {
169 puts ("parent: cannot create thread");
170 exit (1);
171 }
172
173 puts ("parent: wait for child to lock mutex");
174
175 err = pthread_barrier_wait (&bar);
176 if (err != 0 && err != PTHREAD_BARRIER_SERIAL_THREAD)
177 {
178 puts ("parent: cannot wait for barrier");
179 exit (1);
180 }
181
182 err = pthread_mutex_lock (&mut);
183 if (err != 0)
184 {
185 puts ("parent: mutex_lock failed");
186 exit (1);
187 }
188
189 err = pthread_mutex_unlock (&mut);
190 if (err != 0)
191 {
192 puts ("parent: mutex_unlock failed");
193 exit (1);
194 }
195
196 if (pthread_cancel (th) != 0)
197 {
198 puts ("cannot cancel thread");
199 exit (1);
200 }
201
202 void *r;
203 err = pthread_join (th, &r);
204 if (err != 0)
205 {
206 puts ("parent: failed to join");
207 exit (1);
208 }
209
210 if (r != PTHREAD_CANCELED)
211 {
212 puts ("child hasn't been canceled");
213 exit (1);
214 }
215
216
217
218 puts ("parent: create 2nd child");
219
220 err = pthread_create (&th, NULL, tf2, NULL);
221 if (err != 0)
222 {
223 puts ("parent: cannot create thread");
224 exit (1);
225 }
226
227 puts ("parent: wait for child to lock mutex");
228
229 err = pthread_barrier_wait (&bar);
230 if (err != 0 && err != PTHREAD_BARRIER_SERIAL_THREAD)
231 {
232 puts ("parent: cannot wait for barrier");
233 exit (1);
234 }
235
236 err = pthread_mutex_lock (&mut);
237 if (err != 0)
238 {
239 puts ("parent: mutex_lock failed");
240 exit (1);
241 }
242
243 err = pthread_mutex_unlock (&mut);
244 if (err != 0)
245 {
246 puts ("parent: mutex_unlock failed");
247 exit (1);
248 }
249
250 if (pthread_cancel (th) != 0)
251 {
252 puts ("cannot cancel thread");
253 exit (1);
254 }
255
256 err = pthread_join (th, &r);
257 if (err != 0)
258 {
259 puts ("parent: failed to join");
260 exit (1);
261 }
262
263 if (r != PTHREAD_CANCELED)
264 {
265 puts ("child hasn't been canceled");
266 exit (1);
267 }
268
269 puts ("done");
270
271 return 0;
272}
273
274
275#define TEST_FUNCTION do_test ()
276#include "../test-skeleton.c"
277

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