forked from OSchip/llvm-project
92 lines
2.4 KiB
C++
92 lines
2.4 KiB
C++
// 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
|