1 /* Test case for async-signal-safe fork (with respect to malloc).
2 Copyright (C) 2016-2022 Free Software Foundation, Inc.
3 This file is part of the GNU C Library.
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 License as
7 published by the Free Software Foundation; either version 2.1 of the
8 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; see the file COPYING.LIB. If
17 not, see <https://www.gnu.org/licenses/>. */
18
19 /* This test will fail if the process is multi-threaded because we
20 only have an async-signal-safe fork in the single-threaded case
21 (where we skip acquiring the malloc heap locks).
22
23 This test only checks async-signal-safety with regards to malloc;
24 other, more rarely-used glibc subsystems could have locks which
25 still make fork unsafe, even in single-threaded processes. */
26
27 #include <errno.h>
28 #include <sched.h>
29 #include <signal.h>
30 #include <stdbool.h>
31 #include <stdio.h>
32 #include <stdlib.h>
33 #include <string.h>
34 #include <sys/wait.h>
35 #include <time.h>
36 #include <unistd.h>
37 #include <array_length.h>
38 #include <support/check.h>
39 #include <support/support.h>
40 #include <support/xthread.h>
41 #include <support/xunistd.h>
42
43 /* How many malloc objects to keep arond. */
44 enum { malloc_objects = 1009 };
45
46 /* The maximum size of an object. */
47 enum { malloc_maximum_size = 70000 };
48
49 /* How many iterations the test performs before exiting. */
50 enum { iterations = 10000 };
51
52 /* Barrier for synchronization with the processes sending SIGUSR1
53 signals, to make it more likely that the signals arrive during a
54 fork/free/malloc call. */
55 static struct { pthread_barrier_t barrier; } *shared;
56
57 /* Set to 1 if SIGUSR1 is received. Used to detect a signal during
58 fork/free/malloc. */
59 static volatile sig_atomic_t sigusr1_received;
60
61 /* Periodically set to 1, to indicate that the process is making
62 progress. Checked by liveness_signal_handler. */
63 static volatile sig_atomic_t progress_indicator = 1;
64
65 /* Set to 1 if an error occurs in the signal handler. */
66 static volatile sig_atomic_t error_indicator = 0;
67
68 static void
sigusr1_handler(int signo)69 sigusr1_handler (int signo)
70 {
71 sigusr1_received = 1;
72
73 /* Perform a fork with a trivial subprocess. */
74 pid_t pid = fork ();
75 if (pid == -1)
76 {
77 write_message ("error: fork\n");
78 error_indicator = 1;
79 return;
80 }
81 if (pid == 0)
82 _exit (0);
83 int status;
84 int ret = TEMP_FAILURE_RETRY (waitpid (pid, &status, 0));
85 if (ret < 0)
86 {
87 write_message ("error: waitpid\n");
88 error_indicator = 1;
89 return;
90 }
91 if (status != 0)
92 {
93 write_message ("error: unexpected exit status from subprocess\n");
94 error_indicator = 1;
95 return;
96 }
97 }
98
99 static void
liveness_signal_handler(int signo)100 liveness_signal_handler (int signo)
101 {
102 if (progress_indicator)
103 progress_indicator = 0;
104 else
105 write_message ("warning: process seems to be stuck\n");
106 }
107
108 /* Send SIGNO to the parent process. If SLEEP, wait a second between
109 signals, otherwise use barriers to delay sending signals. */
110 static void
111 __attribute__ ((noreturn))
signal_sender(int signo,bool sleep)112 signal_sender (int signo, bool sleep)
113 {
114 pid_t target = getppid ();
115 while (true)
116 {
117 if (!sleep)
118 xpthread_barrier_wait (&shared->barrier);
119 if (kill (target, signo) != 0)
120 {
121 dprintf (STDOUT_FILENO, "error: kill: %m\n");
122 abort ();
123 }
124 if (sleep)
125 usleep (1 * 1000 * 1000);
126 else
127 xpthread_barrier_wait (&shared->barrier);
128 }
129 }
130
131 /* Children processes. */
132 static pid_t sigusr1_sender_pids[5] = { 0 };
133 static pid_t sigusr2_sender_pid = 0;
134
135 static void
kill_children(void)136 kill_children (void)
137 {
138 for (size_t i = 0; i < array_length (sigusr1_sender_pids); ++i)
139 if (sigusr1_sender_pids[i] > 0)
140 kill (sigusr1_sender_pids[i], SIGKILL);
141 if (sigusr2_sender_pid > 0)
142 kill (sigusr2_sender_pid, SIGKILL);
143 }
144
145 static int
do_test(void)146 do_test (void)
147 {
148 atexit (kill_children);
149
150 /* shared->barrier is intialized along with sigusr1_sender_pids
151 below. */
152 shared = support_shared_allocate (sizeof (*shared));
153
154 struct sigaction action =
155 {
156 .sa_handler = sigusr1_handler,
157 };
158 sigemptyset (&action.sa_mask);
159
160 if (sigaction (SIGUSR1, &action, NULL) != 0)
161 {
162 printf ("error: sigaction: %m");
163 return 1;
164 }
165
166 action.sa_handler = liveness_signal_handler;
167 if (sigaction (SIGUSR2, &action, NULL) != 0)
168 {
169 printf ("error: sigaction: %m");
170 return 1;
171 }
172
173 sigusr2_sender_pid = xfork ();
174 if (sigusr2_sender_pid == 0)
175 signal_sender (SIGUSR2, true);
176
177 /* Send SIGUSR1 signals from several processes. Hopefully, one
178 signal will hit one of the ciritical functions. Use a barrier to
179 avoid sending signals while not running fork/free/malloc. */
180 {
181 pthread_barrierattr_t attr;
182 xpthread_barrierattr_init (&attr);
183 xpthread_barrierattr_setpshared (&attr, PTHREAD_PROCESS_SHARED);
184 xpthread_barrier_init (&shared->barrier, &attr,
185 array_length (sigusr1_sender_pids) + 1);
186 xpthread_barrierattr_destroy (&attr);
187 }
188 for (size_t i = 0; i < array_length (sigusr1_sender_pids); ++i)
189 {
190 sigusr1_sender_pids[i] = xfork ();
191 if (sigusr1_sender_pids[i] == 0)
192 signal_sender (SIGUSR1, false);
193 }
194
195 void *objects[malloc_objects] = {};
196 unsigned int fork_signals = 0;
197 unsigned int free_signals = 0;
198 unsigned int malloc_signals = 0;
199 unsigned seed = 1;
200 for (int i = 0; i < iterations; ++i)
201 {
202 progress_indicator = 1;
203 int slot = rand_r (&seed) % malloc_objects;
204 size_t size = rand_r (&seed) % malloc_maximum_size;
205
206 /* Occasionally do a fork first, to catch deadlocks there as
207 well (see bug 24161). */
208 bool do_fork = (rand_r (&seed) % 7) == 0;
209
210 xpthread_barrier_wait (&shared->barrier);
211 if (do_fork)
212 {
213 sigusr1_received = 0;
214 pid_t pid = xfork ();
215 if (sigusr1_received)
216 ++fork_signals;
217 if (pid == 0)
218 _exit (0);
219 int status;
220 int ret = TEMP_FAILURE_RETRY (waitpid (pid, &status, 0));
221 if (ret < 0)
222 FAIL_EXIT1 ("waitpid: %m");
223 TEST_COMPARE (status, 0);
224 }
225 sigusr1_received = 0;
226 free (objects[slot]);
227 if (sigusr1_received)
228 ++free_signals;
229 sigusr1_received = 0;
230 objects[slot] = malloc (size);
231 if (sigusr1_received)
232 ++malloc_signals;
233 xpthread_barrier_wait (&shared->barrier);
234
235 if (objects[slot] == NULL || error_indicator != 0)
236 {
237 printf ("error: malloc: %m\n");
238 for (size_t i = 0; i < array_length (sigusr1_sender_pids); ++i)
239 kill (sigusr1_sender_pids[i], SIGKILL);
240 kill (sigusr2_sender_pid, SIGKILL);
241 return 1;
242 }
243 }
244
245 /* Clean up allocations. */
246 for (int slot = 0; slot < malloc_objects; ++slot)
247 free (objects[slot]);
248
249 printf ("info: signals received during fork: %u\n", fork_signals);
250 printf ("info: signals received during free: %u\n", free_signals);
251 printf ("info: signals received during malloc: %u\n", malloc_signals);
252
253 /* Do not destroy the barrier because of the SIGKILL above, which
254 may have left the barrier in an inconsistent state. */
255 support_shared_free (shared);
256
257 return 0;
258 }
259
260 #define TIMEOUT 100
261 #include <support/test-driver.c>
262