1 /* Copyright (C) 2003-2022 Free Software Foundation, Inc.
2    This file is part of the GNU C Library.
3 
4    The GNU C Library is free software; you can redistribute it and/or
5    modify it under the terms of the GNU Lesser General Public
6    License as published by the Free Software Foundation; either
7    version 2.1 of the License, or (at your option) any later version.
8 
9    The GNU C Library is distributed in the hope that it will be useful,
10    but WITHOUT ANY WARRANTY; without even the implied warranty of
11    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
12    Lesser General Public License for more details.
13 
14    You should have received a copy of the GNU Lesser General Public
15    License along with the GNU C Library; if not, see
16    <https://www.gnu.org/licenses/>.  */
17 
18 #include <errno.h>
19 #include <pthread.h>
20 #include <stdio.h>
21 #include <stdlib.h>
22 #include <string.h>
23 #include <unistd.h>
24 
25 
26 static pthread_barrier_t bar;
27 static int fd[2];
28 
29 
30 static void
cleanup(void * arg)31 cleanup (void *arg)
32 {
33   static int ncall;
34 
35   if (++ncall != 1)
36     {
37       puts ("second call to cleanup");
38       exit (1);
39     }
40 
41   printf ("cleanup call #%d\n", ncall);
42 }
43 
44 
45 static void *
tf(void * arg)46 tf (void *arg)
47 {
48   pthread_cleanup_push (cleanup, NULL);
49 
50   int e = pthread_barrier_wait (&bar);
51   if (e != 0 && e != PTHREAD_BARRIER_SERIAL_THREAD)
52     {
53       puts ("tf: 1st barrier_wait failed");
54       exit (1);
55     }
56 
57   /* This call should block and be cancelable.  */
58   char buf[20];
59   read (fd[0], buf, sizeof (buf));
60 
61   pthread_cleanup_pop (0);
62 
63   return NULL;
64 }
65 
66 
67 static int
do_test(void)68 do_test (void)
69 {
70   pthread_t th;
71 
72   if (pthread_barrier_init (&bar, NULL, 2) != 0)
73     {
74       puts ("barrier_init failed");
75       exit (1);
76     }
77 
78   if (pipe (fd) != 0)
79     {
80       puts ("pipe failed");
81       exit (1);
82     }
83 
84   if (pthread_create (&th, NULL, tf, NULL) != 0)
85     {
86       puts ("create failed");
87       exit (1);
88     }
89 
90   int e = pthread_barrier_wait (&bar);
91   if (e != 0 && e != PTHREAD_BARRIER_SERIAL_THREAD)
92     {
93       puts ("1st barrier_wait failed");
94       exit (1);
95     }
96 
97   if (pthread_cancel (th) != 0)
98     {
99       puts ("1st cancel failed");
100       exit (1);
101     }
102 
103   void *r;
104   if (pthread_join (th, &r) != 0)
105     {
106       puts ("join failed");
107       exit (1);
108     }
109 
110   if (r != PTHREAD_CANCELED)
111     {
112       puts ("thread not canceled");
113       exit (1);
114     }
115 
116   return 0;
117 }
118 
119 
120 #define TEST_FUNCTION do_test ()
121 #include "../test-skeleton.c"
122