1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
// RUN: %clang_tsan -O1 %s -o %t && %run %t 2>&1 | FileCheck %s
// The test was reported to hang sometimes on Darwin:
// https://lists.llvm.org/pipermail/llvm-commits/Week-of-Mon-20210517/917003.html
// UNSUPPORTED: darwin
#include "test.h"
#include <signal.h>
#include <string.h>
#include <sys/time.h>
int test;
int done;
int signals_handled;
pthread_t main_thread;
pthread_mutex_t mutex;
pthread_cond_t cond;
void timer_handler(int signum) {
write(2, "timer_handler\n", strlen("timer_handler\n"));
if (++signals_handled < 10)
return;
switch (test) {
case 0:
__atomic_store_n(&done, 1, __ATOMIC_RELEASE);
(void)pthread_kill(main_thread, SIGUSR1);
case 1:
if (pthread_mutex_trylock(&mutex) == 0) {
__atomic_store_n(&done, 1, __ATOMIC_RELEASE);
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
}
case 2:
__atomic_store_n(&done, 1, __ATOMIC_RELEASE);
}
}
int main(int argc, char **argv) {
main_thread = pthread_self();
pthread_mutex_init(&mutex, 0);
pthread_cond_init(&cond, 0);
sigset_t sigset;
sigemptyset(&sigset);
sigaddset(&sigset, SIGUSR1);
if (sigprocmask(SIG_BLOCK, &sigset, NULL))
exit((perror("sigprocmask"), 1));
struct sigaction sa;
memset(&sa, 0, sizeof(sa));
sa.sa_handler = &timer_handler;
if (sigaction(SIGALRM, &sa, NULL))
exit((perror("setitimer"), 1));
for (test = 0; test < 3; test++) {
fprintf(stderr, "test %d\n", test);
struct itimerval timer;
timer.it_value.tv_sec = 0;
timer.it_value.tv_usec = 50000;
timer.it_interval = timer.it_value;
if (setitimer(ITIMER_REAL, &timer, NULL))
exit((perror("setitimer"), 1));
switch (test) {
case 0:
while (__atomic_load_n(&done, __ATOMIC_ACQUIRE) == 0) {
int signum;
sigwait(&sigset, &signum);
write(2, "sigwait\n", strlen("sigwait\n"));
}
case 1:
pthread_mutex_lock(&mutex);
while (__atomic_load_n(&done, __ATOMIC_ACQUIRE) == 0) {
pthread_cond_wait(&cond, &mutex);
write(2, "pthread_cond_wait\n", strlen("pthread_cond_wait\n"));
}
pthread_mutex_unlock(&mutex);
case 2:
while (__atomic_load_n(&done, __ATOMIC_ACQUIRE) == 0) {
}
}
memset(&timer, 0, sizeof(timer));
if (setitimer(ITIMER_REAL, &timer, NULL))
exit((perror("setitimer"), 1));
done = 0;
signals_handled = 0;
}
fprintf(stderr, "DONE\n");
}
// CHECK: DONE
|
