1/* Copyright (C) 2003-2024 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
26static pthread_barrier_t bar;
27static int fd[2];
28
29
30static void
31cleanup (void *arg)
32{
33 static int ncall;
34
35 if (++ncall != 1)
36 {
37 puts (s: "second call to cleanup");
38 exit (1);
39 }
40
41 printf (format: "cleanup call #%d\n", ncall);
42}
43
44
45static void *
46tf (void *arg)
47{
48 pthread_cleanup_push (cleanup, NULL);
49
50 int e = pthread_barrier_wait (barrier: &bar);
51 if (e != 0 && e != PTHREAD_BARRIER_SERIAL_THREAD)
52 {
53 puts (s: "tf: 1st barrier_wait failed");
54 exit (1);
55 }
56
57 /* This call should block and be cancelable. */
58 char buf[20];
59 if (read (fd[0], buf, sizeof (buf)))
60 {
61 puts (s: "read unexpectedly returned");
62 exit (1);
63 }
64
65 pthread_cleanup_pop (0);
66
67 return NULL;
68}
69
70
71static int
72do_test (void)
73{
74 pthread_t th;
75
76 if (pthread_barrier_init (barrier: &bar, NULL, count: 2) != 0)
77 {
78 puts (s: "barrier_init failed");
79 exit (1);
80 }
81
82 if (pipe (pipedes: fd) != 0)
83 {
84 puts (s: "pipe failed");
85 exit (1);
86 }
87
88 if (pthread_create (newthread: &th, NULL, start_routine: tf, NULL) != 0)
89 {
90 puts (s: "create failed");
91 exit (1);
92 }
93
94 int e = pthread_barrier_wait (barrier: &bar);
95 if (e != 0 && e != PTHREAD_BARRIER_SERIAL_THREAD)
96 {
97 puts (s: "1st barrier_wait failed");
98 exit (1);
99 }
100
101 if (pthread_cancel (th: th) != 0)
102 {
103 puts (s: "1st cancel failed");
104 exit (1);
105 }
106
107 void *r;
108 if (pthread_join (th: th, thread_return: &r) != 0)
109 {
110 puts (s: "join failed");
111 exit (1);
112 }
113
114 if (r != PTHREAD_CANCELED)
115 {
116 puts (s: "thread not canceled");
117 exit (1);
118 }
119
120 return 0;
121}
122
123
124#define TEST_FUNCTION do_test ()
125#include "../test-skeleton.c"
126

source code of glibc/sysdeps/pthread/tst-cancel11.c